43 mtcp_cb_stop(mctx_t mctx, int sock, int side);
52 GetMTCPManager(mctx_t mctx)  in GetMTCPManager()  argument
54 	if (!mctx) {  in GetMTCPManager()
59 	if (mctx->cpu < 0 || mctx->cpu >= num_cpus) {  in GetMTCPManager()
64 	if (!g_mtcp[mctx->cpu] || g_mtcp[mctx->cpu]->ctx->done || g_mtcp[mctx->cpu]->ctx->exit) {  in GetMTCPManager()
69 	return g_mtcp[mctx->cpu];  in GetMTCPManager()
129 mtcp_getsockname(mctx_t mctx, int sockid, struct sockaddr *addr,  in mtcp_getsockname()  argument
135 	mtcp = GetMTCPManager(mctx);  in mtcp_getsockname()
173 mtcp_getsockopt(mctx_t mctx, int sockid, int level,   in mtcp_getsockopt()  argument
179 	mtcp = GetMTCPManager(mctx);  in mtcp_getsockopt()
260 mtcp_setsockopt(mctx_t mctx, int sockid, int level,   in mtcp_setsockopt()  argument
267 	mtcp = GetMTCPManager(mctx);  in mtcp_setsockopt()
451 			return mtcp_cb_stop(mctx, sockid, *(int *)optval);  in mtcp_setsockopt()
464 mtcp_setsock_nonblock(mctx_t mctx, int sockid)  in mtcp_setsock_nonblock()  argument
468 	mtcp = GetMTCPManager(mctx);  in mtcp_setsock_nonblock()
492 mtcp_ioctl(mctx_t mctx, int sockid, int request, void *argp)  in mtcp_ioctl()  argument
497 	mtcp = GetMTCPManager(mctx);  in mtcp_ioctl()
555 mtcp_monitor(mctx_t mctx, socket_map_t sock)   in mtcp_monitor()  argument
561 	mtcp = GetMTCPManager(mctx);  in mtcp_monitor()
623 mtcp_socket(mctx_t mctx, int domain, int type, int protocol)  in mtcp_socket()  argument
628 	mtcp = GetMTCPManager(mctx);  in mtcp_socket()
650 	socket = AllocateSocket(mctx, type);  in mtcp_socket()
658 		mtcp_manager_t mtcp = GetMTCPManager(mctx);  in mtcp_socket()
663 		mtcp_monitor(mctx, socket);  in mtcp_socket()
679 mtcp_bind(mctx_t mctx, int sockid,   in mtcp_bind()  argument
685 	mtcp = GetMTCPManager(mctx);  in mtcp_bind()
742 mtcp_listen(mctx_t mctx, int sockid, int backlog)  in mtcp_listen()  argument
747 	mtcp = GetMTCPManager(mctx);  in mtcp_listen()
818 mtcp_accept(mctx_t mctx, int sockid, struct sockaddr *addr, socklen_t *addrlen)  in mtcp_accept()  argument
825 	mtcp = GetMTCPManager(mctx);  in mtcp_accept()
873 		socket = AllocateSocket(mctx, MOS_SOCK_STREAM);  in mtcp_accept()
913 mtcp_init_rss(mctx_t mctx, in_addr_t saddr_base, int num_addr,   in mtcp_init_rss()  argument
919 	mtcp = GetMTCPManager(mctx);  in mtcp_init_rss()
939 	ap = CreateAddressPoolPerCore(mctx->cpu, num_cpus,   in mtcp_init_rss()
981 mtcp_connect(mctx_t mctx, int sockid,   in mtcp_connect()  argument
997 	mtcp = GetMTCPManager(mctx);  in mtcp_connect()
1058 		if (rss_core != mctx->cpu) {  in mtcp_connect()
1065 						  mctx->cpu, num_queues, addr_in, &socket->saddr);  in mtcp_connect()
1073 					   mctx->cpu, num_queues, addr_in, &socket->saddr);  in mtcp_connect()
1198 CloseStreamSocket(mctx_t mctx, int sockid)  in CloseStreamSocket()  argument
1204 	mtcp = GetMTCPManager(mctx);  in CloseStreamSocket()
1271 CloseListeningSocket(mctx_t mctx, int sockid)  in CloseListeningSocket()  argument
1276 	mtcp = GetMTCPManager(mctx);  in CloseListeningSocket()
1307 mtcp_close(mctx_t mctx, int sockid)  in mtcp_close()  argument
1312 	mtcp = GetMTCPManager(mctx);  in mtcp_close()
1334 		ret = CloseStreamSocket(mctx, sockid);  in mtcp_close()
1338 		ret = CloseListeningSocket(mctx, sockid);  in mtcp_close()
1342 		ret = CloseEpollSocket(mctx, sockid);  in mtcp_close()
1346 		ret = PipeClose(mctx, sockid);  in mtcp_close()
1355 	FreeSocket(mctx, sockid, mtcp->smap[sockid].socktype);  in mtcp_close()
1361 mtcp_abort(mctx_t mctx, int sockid)  in mtcp_abort()  argument
1367 	mtcp = GetMTCPManager(mctx);  in mtcp_abort()
1400 	FreeSocket(mctx, sockid, mtcp->smap[sockid].socktype);  in mtcp_abort()
1502 mtcp_recv(mctx_t mctx, int sockid, char *buf, size_t len, int flags)  in mtcp_recv()  argument
1511 	mtcp = GetMTCPManager(mctx);  in mtcp_recv()
1531 		return PipeRead(mctx, sockid, buf, len);  in mtcp_recv()
1612 mtcp_read(mctx_t mctx, int sockid, char *buf, size_t len)  in mtcp_read()  argument
1614 	return mtcp_recv(mctx, sockid, buf, len, 0);  in mtcp_read()
1618 mtcp_readv(mctx_t mctx, int sockid, const struct iovec *iov, int numIOV)  in mtcp_readv()  argument
1627 	mtcp = GetMTCPManager(mctx);  in mtcp_readv()
1770 mtcp_write(mctx_t mctx, int sockid, const char *buf, size_t len)  in mtcp_write()  argument
1778 	mtcp = GetMTCPManager(mctx);  in mtcp_write()
1798 		return PipeWrite(mctx, sockid, buf, len);  in mtcp_write()
1857 mtcp_writev(mctx_t mctx, int sockid, const struct iovec *iov, int numIOV)  in mtcp_writev()  argument
1865 	mtcp = GetMTCPManager(mctx);  in mtcp_writev()
1945 mtcp_get_connection_cnt(mctx_t mctx)  in mtcp_get_connection_cnt()  argument
1948 	mtcp = GetMTCPManager(mctx);  in mtcp_get_connection_cnt()