Searched refs:sendq (Results 1 – 3 of 3) sorted by relevance
580 while ((stream = StreamDequeue(mtcp->sendq))) { in HandleApplicationCalls()1225 mtcp->sendq = CreateStreamQueue(g_config.mos->max_concurrency); in InitializeMTCPManager()1226 if (!mtcp->sendq) { in InitializeMTCPManager()1561 if (mtcp->sendq) { in mtcp_free_context()1562 DestroyStreamQueue(mtcp->sendq); in mtcp_free_context()1563 mtcp->sendq = NULL; in mtcp_free_context()
1834 StreamEnqueue(mtcp->sendq, cur_stream); /* this always success */ in mtcp_write()1921 StreamEnqueue(mtcp->sendq, cur_stream); /* this always success */ in mtcp_writev()
248 stream_queue_t sendq; /* streams need to send data */ member