Lines Matching refs:msg
76 struct tcpip_msg *msg;
88 sys_timeouts_mbox_fetch(&mbox, (void **)&msg);
90 switch (msg->type) {
93 LWIP_DEBUGF(TCPIP_DEBUG, ("tcpip_thread: API message %p\n", (void *)msg));
94 msg->msg.apimsg->function(&(msg->msg.apimsg->msg));
100 LWIP_DEBUGF(TCPIP_DEBUG, ("tcpip_thread: PACKET %p\n", (void *)msg));
102 if (msg->msg.inp.netif->flags & (NETIF_FLAG_ETHARP | NETIF_FLAG_ETHERNET)) {
103 ethernet_input(msg->msg.inp.p, msg->msg.inp.netif);
107 ip_input(msg->msg.inp.p, msg->msg.inp.netif);
109 memp_free(MEMP_TCPIP_MSG_INPKT, msg);
115 LWIP_DEBUGF(TCPIP_DEBUG, ("tcpip_thread: Netif API message %p\n", (void *)msg));
116 msg->msg.netifapimsg->function(&(msg->msg.netifapimsg->msg));
121 LWIP_DEBUGF(TCPIP_DEBUG, ("tcpip_thread: CALLBACK %p\n", (void *)msg));
122 msg->msg.cb.function(msg->msg.cb.ctx);
123 memp_free(MEMP_TCPIP_MSG_API, msg);
128 LWIP_DEBUGF(TCPIP_DEBUG, ("tcpip_thread: TIMEOUT %p\n", (void *)msg));
129 sys_timeout(msg->msg.tmo.msecs, msg->msg.tmo.h, msg->msg.tmo.arg);
130 memp_free(MEMP_TCPIP_MSG_API, msg);
133 LWIP_DEBUGF(TCPIP_DEBUG, ("tcpip_thread: UNTIMEOUT %p\n", (void *)msg));
134 sys_untimeout(msg->msg.tmo.h, msg->msg.tmo.arg);
135 memp_free(MEMP_TCPIP_MSG_API, msg);
140 LWIP_DEBUGF(TCPIP_DEBUG, ("tcpip_thread: invalid message: %d\n", msg->type));
173 struct tcpip_msg *msg;
176 msg = (struct tcpip_msg *)memp_malloc(MEMP_TCPIP_MSG_INPKT);
177 if (msg == NULL) {
181 msg->type = TCPIP_MSG_INPKT;
182 msg->msg.inp.p = p;
183 msg->msg.inp.netif = inp;
184 if (sys_mbox_trypost(&mbox, msg) != ERR_OK) {
185 memp_free(MEMP_TCPIP_MSG_INPKT, msg);
208 struct tcpip_msg *msg;
211 msg = (struct tcpip_msg *)memp_malloc(MEMP_TCPIP_MSG_API);
212 if (msg == NULL) {
216 msg->type = TCPIP_MSG_CALLBACK;
217 msg->msg.cb.function = function;
218 msg->msg.cb.ctx = ctx;
220 sys_mbox_post(&mbox, msg);
222 if (sys_mbox_trypost(&mbox, msg) != ERR_OK) {
223 memp_free(MEMP_TCPIP_MSG_API, msg);
244 struct tcpip_msg *msg;
247 msg = (struct tcpip_msg *)memp_malloc(MEMP_TCPIP_MSG_API);
248 if (msg == NULL) {
252 msg->type = TCPIP_MSG_TIMEOUT;
253 msg->msg.tmo.msecs = msecs;
254 msg->msg.tmo.h = h;
255 msg->msg.tmo.arg = arg;
256 sys_mbox_post(&mbox, msg);
273 struct tcpip_msg *msg;
276 msg = (struct tcpip_msg *)memp_malloc(MEMP_TCPIP_MSG_API);
277 if (msg == NULL) {
281 msg->type = TCPIP_MSG_UNTIMEOUT;
282 msg->msg.tmo.h = h;
283 msg->msg.tmo.arg = arg;
284 sys_mbox_post(&mbox, msg);
303 struct tcpip_msg msg;
306 apimsg->msg.err = ERR_VAL;
310 msg.type = TCPIP_MSG_API;
311 msg.msg.apimsg = apimsg;
312 sys_mbox_post(&mbox, &msg);
313 sys_arch_sem_wait(&apimsg->msg.conn->op_completed, 0);
314 return apimsg->msg.err;
333 apimsg->msg.err = ERR_VAL;
337 apimsg->function(&(apimsg->msg));
339 return apimsg->msg.err;
357 struct tcpip_msg msg;
360 err_t err = sys_sem_new(&netifapimsg->msg.sem, 0);
362 netifapimsg->msg.err = err;
366 msg.type = TCPIP_MSG_NETIFAPI;
367 msg.msg.netifapimsg = netifapimsg;
368 sys_mbox_post(&mbox, &msg);
369 sys_sem_wait(&netifapimsg->msg.sem);
370 sys_sem_free(&netifapimsg->msg.sem);
371 return netifapimsg->msg.err;
388 netifapimsg->function(&(netifapimsg->msg));
390 return netifapimsg->msg.err;
