riot-ci/RIOT
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

gnrc_netapi: generic dispatch

Browse Source
This commit is contained in:
Cenk Gündoğan 2015-08-28 13:25:20 +02:00
parent b16b8a9609
commit 7d2129ea56
2 changed files with 26 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
sys/include/net/gnrc/netapi.h
View File

@ -85,6 +85,19 @@ typedef struct {
*/ */
int gnrc_netapi_send(kernel_pid_t pid, gnrc_pktsnip_t *pkt); int gnrc_netapi_send(kernel_pid_t pid, gnrc_pktsnip_t *pkt);
/**
* @brief Sends @p cmd to all subscribers to (@p type, @p demux_ctx).
*
* @param[in] type type of the targeted network module.
* @param[in] demux_ctx demultiplexing context for @p type.
* @param[in] cmd command for all subscribers
* @param[in] pkt pointer into the packet buffer holding the data to send
*
* @return Number of subscribers to (@p type, @p demux_ctx).
*/
int gnrc_netapi_dispatch(gnrc_nettype_t type, uint32_t demux_ctx, uint16_t cmd,
gnrc_pktsnip_t *pkt);
/** /**
* @brief Sends a @ref GNRC_NETAPI_MSG_TYPE_SND command to all subscribers to * @brief Sends a @ref GNRC_NETAPI_MSG_TYPE_SND command to all subscribers to
* (@p type, @p demux_ctx). * (@p type, @p demux_ctx).
@ -95,8 +108,11 @@ int gnrc_netapi_send(kernel_pid_t pid, gnrc_pktsnip_t *pkt);
* *
* @return Number of subscribers to (@p type, @p demux_ctx). * @return Number of subscribers to (@p type, @p demux_ctx).
*/ */
int gnrc_netapi_dispatch_send(gnrc_nettype_t type, uint32_t demux_ctx, static inline int gnrc_netapi_dispatch_send(gnrc_nettype_t type, uint32_t demux_ctx,
gnrc_pktsnip_t *pkt); gnrc_pktsnip_t *pkt)
{
return gnrc_netapi_dispatch(type, demux_ctx, GNRC_NETAPI_MSG_TYPE_SND, pkt);
}
/** /**
* @brief Shortcut function for sending @ref GNRC_NETAPI_MSG_TYPE_RCV messages * @brief Shortcut function for sending @ref GNRC_NETAPI_MSG_TYPE_RCV messages
@ -119,8 +135,11 @@ int gnrc_netapi_receive(kernel_pid_t pid, gnrc_pktsnip_t *pkt);
* *
* @return Number of subscribers to (@p type, @p demux_ctx). * @return Number of subscribers to (@p type, @p demux_ctx).
*/ */
int gnrc_netapi_dispatch_receive(gnrc_nettype_t type, uint32_t demux_ctx, static inline int gnrc_netapi_dispatch_receive(gnrc_nettype_t type, uint32_t demux_ctx,
gnrc_pktsnip_t *pkt); gnrc_pktsnip_t *pkt)
{
return gnrc_netapi_dispatch(type, demux_ctx, GNRC_NETAPI_MSG_TYPE_RCV, pkt);
}
/** /**
* @brief Shortcut function for sending @ref GNRC_NETAPI_MSG_TYPE_GET messages and * @brief Shortcut function for sending @ref GNRC_NETAPI_MSG_TYPE_GET messages and

15
sys/net/gnrc/netapi/gnrc_netapi.c
View File

@ -66,7 +66,7 @@ static inline int _snd_rcv(kernel_pid_t pid, uint16_t type, gnrc_pktsnip_t *pkt)
return msg_send(&msg, pid); return msg_send(&msg, pid);
} }
static inline int _snd_rcv_dispatch(gnrc_nettype_t type, uint32_t demux_ctx, int gnrc_netapi_dispatch(gnrc_nettype_t type, uint32_t demux_ctx,
uint16_t cmd, gnrc_pktsnip_t *pkt) uint16_t cmd, gnrc_pktsnip_t *pkt)
{ {
int numof = gnrc_netreg_num(type, demux_ctx); int numof = gnrc_netreg_num(type, demux_ctx);
@ -84,28 +84,17 @@ static inline int _snd_rcv_dispatch(gnrc_nettype_t type, uint32_t demux_ctx,
return numof; return numof;
} }
int gnrc_netapi_send(kernel_pid_t pid, gnrc_pktsnip_t *pkt) int gnrc_netapi_send(kernel_pid_t pid, gnrc_pktsnip_t *pkt)
{ {
return _snd_rcv(pid, GNRC_NETAPI_MSG_TYPE_SND, pkt); return _snd_rcv(pid, GNRC_NETAPI_MSG_TYPE_SND, pkt);
} }
int gnrc_netapi_dispatch_send(gnrc_nettype_t type, uint32_t demux_ctx,
gnrc_pktsnip_t *pkt)
{
return _snd_rcv_dispatch(type, demux_ctx, GNRC_NETAPI_MSG_TYPE_SND, pkt);
}
int gnrc_netapi_receive(kernel_pid_t pid, gnrc_pktsnip_t *pkt) int gnrc_netapi_receive(kernel_pid_t pid, gnrc_pktsnip_t *pkt)
{ {
return _snd_rcv(pid, GNRC_NETAPI_MSG_TYPE_RCV, pkt); return _snd_rcv(pid, GNRC_NETAPI_MSG_TYPE_RCV, pkt);
} }
int gnrc_netapi_dispatch_receive(gnrc_nettype_t type, uint32_t demux_ctx,
gnrc_pktsnip_t *pkt)
{
return _snd_rcv_dispatch(type, demux_ctx, GNRC_NETAPI_MSG_TYPE_RCV, pkt);
}
int gnrc_netapi_get(kernel_pid_t pid, netopt_t opt, uint16_t context, int gnrc_netapi_get(kernel_pid_t pid, netopt_t opt, uint16_t context,
void *data, size_t data_len) void *data, size_t data_len)
{ {