Searched refs:ackq (Results 1 – 3 of 3) sorted by relevance
586 while ((stream = StreamDequeue(mtcp->ackq))) { in HandleApplicationCalls()1230 mtcp->ackq = CreateStreamQueue(g_config.mos->max_concurrency); in InitializeMTCPManager()1231 if (!mtcp->ackq) { in InitializeMTCPManager()1565 if (mtcp->ackq) { in mtcp_free_context()1566 DestroyStreamQueue(mtcp->ackq); in mtcp_free_context()1567 mtcp->ackq = NULL; in mtcp_free_context()
1490 StreamEnqueue(mtcp->ackq, cur_stream); /* this always success */ in CopyToUser()
249 stream_queue_t ackq; /* streams need to send ack */ member