Lines Matching refs:mctx
40 mtcp_pipe(mctx_t mctx, int pipeid[2]) in mtcp_pipe() argument
46 socket[0] = AllocateSocket(mctx, MOS_SOCK_PIPE); in mtcp_pipe()
51 socket[1] = AllocateSocket(mctx, MOS_SOCK_PIPE); in mtcp_pipe()
53 FreeSocket(mctx, socket[0]->id, MOS_SOCK_PIPE); in mtcp_pipe()
61 FreeSocket(mctx, socket[0]->id, MOS_SOCK_PIPE); in mtcp_pipe()
62 FreeSocket(mctx, socket[1]->id, MOS_SOCK_PIPE); in mtcp_pipe()
70 FreeSocket(mctx, socket[0]->id, MOS_SOCK_PIPE); in mtcp_pipe()
71 FreeSocket(mctx, socket[1]->id, MOS_SOCK_PIPE); in mtcp_pipe()
79 FreeSocket(mctx, socket[0]->id, MOS_SOCK_PIPE); in mtcp_pipe()
80 FreeSocket(mctx, socket[1]->id, MOS_SOCK_PIPE); in mtcp_pipe()
89 FreeSocket(mctx, socket[0]->id, MOS_SOCK_PIPE); in mtcp_pipe()
90 FreeSocket(mctx, socket[1]->id, MOS_SOCK_PIPE); in mtcp_pipe()
131 PipeRead(mctx_t mctx, int pipeid, char *buf, int len) in PipeRead() argument
140 mtcp = GetMTCPManager(mctx); in PipeRead()
144 socket = GetSocket(mctx, pipeid); in PipeRead()
234 PipeWrite(mctx_t mctx, int pipeid, const char *buf, int len) in PipeWrite() argument
243 mtcp = GetMTCPManager(mctx); in PipeWrite()
247 socket = GetSocket(mctx, pipeid); in PipeWrite()
334 RaisePendingPipeEvents(mctx_t mctx, int epid, int pipeid) in RaisePendingPipeEvents() argument
336 struct mtcp_epoll *ep = GetSocket(mctx, epid)->ep; in RaisePendingPipeEvents()
337 socket_map_t socket = GetSocket(mctx, pipeid); in RaisePendingPipeEvents()
366 PipeClose(mctx_t mctx, int pipeid) in PipeClose() argument
372 mtcp = GetMTCPManager(mctx); in PipeClose()
376 socket = GetSocket(mctx, pipeid); in PipeClose()