Lines Matching refs:StreamEnqueue
1155 ret = StreamEnqueue(mtcp->connectq, cur_stream); in mtcp_connect()
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()
1257 ret = StreamEnqueue(mtcp->closeq, cur_stream); in CloseStreamSocket()
1414 StreamEnqueue(mtcp->destroyq, cur_stream); in mtcp_abort()
1426 StreamEnqueue(mtcp->destroyq, cur_stream); in mtcp_abort()
1441 ret = StreamEnqueue(mtcp->resetq, cur_stream); in mtcp_abort()
1490 StreamEnqueue(mtcp->ackq, cur_stream); /* this always success */ in CopyToUser()
1834 StreamEnqueue(mtcp->sendq, cur_stream); /* this always success */ in mtcp_write()
1921 StreamEnqueue(mtcp->sendq, cur_stream); /* this always success */ in mtcp_writev()