Searched refs:destroyq (Results 1 – 3 of 3) sorted by relevance
757 while ((stream = StreamDequeue(mtcp->destroyq))) { in HandleApplicationCalls()1255 mtcp->destroyq = CreateStreamQueue(g_config.mos->max_concurrency); in InitializeMTCPManager()1256 if (!mtcp->destroyq) { in InitializeMTCPManager()1585 if (mtcp->destroyq) { in mtcp_free_context()1586 DestroyStreamQueue(mtcp->destroyq); in mtcp_free_context()1587 mtcp->destroyq = NULL; in mtcp_free_context()
1161 StreamEnqueue(mtcp->destroyq, cur_stream); in mtcp_connect()1233 StreamEnqueue(mtcp->destroyq, cur_stream); in CloseStreamSocket()1241 StreamEnqueue(mtcp->destroyq, cur_stream); in CloseStreamSocket()1414 StreamEnqueue(mtcp->destroyq, cur_stream); in mtcp_abort()1426 StreamEnqueue(mtcp->destroyq, cur_stream); in mtcp_abort()
256 stream_queue_t destroyq; /* streams need to be destroyed */ member