Searched refs:closeq (Results 1 – 3 of 3) sorted by relevance
594 while ((stream = StreamDequeue(mtcp->closeq))) { in HandleApplicationCalls()1235 mtcp->closeq = CreateStreamQueue(g_config.mos->max_concurrency); in InitializeMTCPManager()1236 if (!mtcp->closeq) { in InitializeMTCPManager()1569 if (mtcp->closeq) { in mtcp_free_context()1570 DestroyStreamQueue(mtcp->closeq); in mtcp_free_context()1571 mtcp->closeq = NULL; in mtcp_free_context()
1257 ret = StreamEnqueue(mtcp->closeq, cur_stream); in CloseStreamSocket()
251 stream_queue_t closeq; /* streams need to close */ member