129 mtcp_getsockname(mctx_t mctx, int sockid, struct sockaddr *addr,  in mtcp_getsockname()  argument
140 	if (sockid < 0 || sockid >= g_config.mos->max_concurrency) {  in mtcp_getsockname()
141 		TRACE_API("Socket id %d out of range.\n", sockid);  in mtcp_getsockname()
146 	socket = &mtcp->smap[sockid];  in mtcp_getsockname()
148 		TRACE_API("Invalid socket id: %d\n", sockid);  in mtcp_getsockname()
161 		TRACE_API("Invalid socket id: %d\n", sockid);  in mtcp_getsockname()
173 mtcp_getsockopt(mctx_t mctx, int sockid, int level,   in mtcp_getsockopt()  argument
185 	if (sockid < 0 || sockid >= g_config.mos->max_concurrency) {  in mtcp_getsockopt()
186 		TRACE_API("Socket id %d out of range.\n", sockid);  in mtcp_getsockopt()
193 		socket = &mtcp->smap[sockid];  in mtcp_getsockopt()
195 			TRACE_API("Invalid socket id: %d\n", sockid);  in mtcp_getsockopt()
202 			TRACE_API("Invalid socket id: %d\n", sockid);  in mtcp_getsockopt()
223 		socket = &mtcp->msmap[sockid];  in mtcp_getsockopt()
225 			TRACE_API("Invalid socket id: %d\n", sockid);  in mtcp_getsockopt()
260 mtcp_setsockopt(mctx_t mctx, int sockid, int level,   in mtcp_setsockopt()  argument
273 	if (sockid < 0 || sockid >= g_config.mos->max_concurrency) {  in mtcp_setsockopt()
274 		TRACE_API("Socket id %d out of range.\n", sockid);  in mtcp_setsockopt()
281 		socket = &mtcp->smap[sockid];  in mtcp_setsockopt()
283 			TRACE_API("Invalid socket id: %d\n", sockid);  in mtcp_setsockopt()
290 			TRACE_API("Invalid socket id: %d\n", sockid);  in mtcp_setsockopt()
296 		socket = &mtcp->msmap[sockid];  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
474 	if (sockid < 0 || sockid >= g_config.mos->max_concurrency) {  in mtcp_setsock_nonblock()
475 		TRACE_API("Socket id %d out of range.\n", sockid);  in mtcp_setsock_nonblock()
480 	if (mtcp->smap[sockid].socktype == MOS_SOCK_UNUSED) {  in mtcp_setsock_nonblock()
481 		TRACE_API("Invalid socket id: %d\n", sockid);  in mtcp_setsock_nonblock()
486 	mtcp->smap[sockid].opts |= MTCP_NONBLOCK;  in mtcp_setsock_nonblock()
492 mtcp_ioctl(mctx_t mctx, int sockid, int request, void *argp)  in mtcp_ioctl()  argument
503 	if (sockid < 0 || sockid >= g_config.mos->max_concurrency) {  in mtcp_ioctl()
504 		TRACE_API("Socket id %d out of range.\n", sockid);  in mtcp_ioctl()
510 	socket = &mtcp->smap[sockid];  in mtcp_ioctl()
514 		TRACE_API("Invalid socket id: %d\n", sockid);  in mtcp_ioctl()
543 			mtcp->smap[sockid].opts |= MTCP_NONBLOCK;  in mtcp_ioctl()
545 			mtcp->smap[sockid].opts &= ~MTCP_NONBLOCK;  in mtcp_ioctl()
559 	int sockid = sock->id;  in mtcp_monitor()  local
567 	if (sockid < 0 || sockid >= g_config.mos->max_concurrency) {  in mtcp_monitor()
568 		TRACE_API("Socket id %d out of range.\n", sockid);  in mtcp_monitor()
573 	if (mtcp->msmap[sockid].socktype == MOS_SOCK_UNUSED) {  in mtcp_monitor()
574 		TRACE_API("Invalid socket id: %d\n", sockid);  in mtcp_monitor()
579 	if (!(mtcp->msmap[sockid].socktype == MOS_SOCK_MONITOR_STREAM ||  in mtcp_monitor()
580 	      mtcp->msmap[sockid].socktype == MOS_SOCK_MONITOR_RAW)) {  in mtcp_monitor()
581 		TRACE_API("Not a monitor socket. id: %d\n", sockid);  in mtcp_monitor()
617 	mtcp->msmap[sockid].monitor_listener = monitor;  in mtcp_monitor()
679 mtcp_bind(mctx_t mctx, int sockid,   in mtcp_bind()  argument
691 	if (sockid < 0 || sockid >= g_config.mos->max_concurrency) {  in mtcp_bind()
692 		TRACE_API("Socket id %d out of range.\n", sockid);  in mtcp_bind()
697 	if (mtcp->smap[sockid].socktype == MOS_SOCK_UNUSED) {  in mtcp_bind()
698 		TRACE_API("Invalid socket id: %d\n", sockid);  in mtcp_bind()
703 	if (mtcp->smap[sockid].socktype != MOS_SOCK_STREAM &&   in mtcp_bind()
704 			mtcp->smap[sockid].socktype != MOS_SOCK_STREAM_LISTEN) {  in mtcp_bind()
705 		TRACE_API("Not a stream socket id: %d\n", sockid);  in mtcp_bind()
711 		TRACE_API("Socket %d: empty address!\n", sockid);  in mtcp_bind()
716 	if (mtcp->smap[sockid].opts & MTCP_ADDR_BIND) {  in mtcp_bind()
717 		TRACE_API("Socket %d: adress already bind for this socket.\n", sockid);  in mtcp_bind()
724 		TRACE_API("Socket %d: invalid argument!\n", sockid);  in mtcp_bind()
735 	mtcp->smap[sockid].saddr = *addr_in;  in mtcp_bind()
736 	mtcp->smap[sockid].opts |= MTCP_ADDR_BIND;  in mtcp_bind()
742 mtcp_listen(mctx_t mctx, int sockid, int backlog)  in mtcp_listen()  argument
753 	if (sockid < 0 || sockid >= g_config.mos->max_concurrency) {  in mtcp_listen()
754 		TRACE_API("Socket id %d out of range.\n", sockid);  in mtcp_listen()
759 	if (mtcp->smap[sockid].socktype == MOS_SOCK_UNUSED) {  in mtcp_listen()
760 		TRACE_API("Invalid socket id: %d\n", sockid);  in mtcp_listen()
765 	if (mtcp->smap[sockid].socktype == MOS_SOCK_STREAM) {  in mtcp_listen()
766 		mtcp->smap[sockid].socktype = MOS_SOCK_STREAM_LISTEN;  in mtcp_listen()
769 	if (mtcp->smap[sockid].socktype != MOS_SOCK_STREAM_LISTEN) {  in mtcp_listen()
770 		TRACE_API("Not a listening socket. id: %d\n", sockid);  in mtcp_listen()
787 	listener->sockid = sockid;  in mtcp_listen()
789 	listener->socket = &mtcp->smap[sockid];  in mtcp_listen()
811 	mtcp->smap[sockid].listener = listener;  in mtcp_listen()
818 mtcp_accept(mctx_t mctx, int sockid, struct sockaddr *addr, socklen_t *addrlen)  in mtcp_accept()  argument
831 	if (sockid < 0 || sockid >= g_config.mos->max_concurrency) {  in mtcp_accept()
832 		TRACE_API("Socket id %d out of range.\n", sockid);  in mtcp_accept()
838 	if (mtcp->smap[sockid].socktype != MOS_SOCK_STREAM_LISTEN) {  in mtcp_accept()
843 	listener = mtcp->smap[sockid].listener;  in mtcp_accept()
981 mtcp_connect(mctx_t mctx, int sockid,   in mtcp_connect()  argument
1003 	if (sockid < 0 || sockid >= g_config.mos->max_concurrency) {  in mtcp_connect()
1004 		TRACE_API("Socket id %d out of range.\n", sockid);  in mtcp_connect()
1009 	if (mtcp->smap[sockid].socktype == MOS_SOCK_UNUSED) {  in mtcp_connect()
1010 		TRACE_API("Invalid socket id: %d\n", sockid);  in mtcp_connect()
1015 	if (mtcp->smap[sockid].socktype != MOS_SOCK_STREAM) {  in mtcp_connect()
1016 		TRACE_API("Not an end socket. id: %d\n", sockid);  in mtcp_connect()
1022 		TRACE_API("Socket %d: empty address!\n", sockid);  in mtcp_connect()
1029 		TRACE_API("Socket %d: invalid argument!\n", sockid);  in mtcp_connect()
1034 	socket = &mtcp->smap[sockid];  in mtcp_connect()
1036 		TRACE_API("Socket %d: stream already exist!\n", sockid);  in mtcp_connect()
1118 		TRACE_ERROR("Socket %d: failed to create tcp_stream!\n", sockid);  in mtcp_connect()
1159 		TRACE_ERROR("Socket %d: failed to enqueue to conenct queue!\n", sockid);  in mtcp_connect()
1181 						sockid, TCPStateToString(cur_stream));  in mtcp_connect()
1198 CloseStreamSocket(mctx_t mctx, int sockid)  in CloseStreamSocket()  argument
1210 	cur_stream = mtcp->smap[sockid].stream;  in CloseStreamSocket()
1212 		TRACE_API("Socket %d: stream does not exist.\n", sockid);  in CloseStreamSocket()
1219 				sockid, cur_stream->id);  in CloseStreamSocket()
1271 CloseListeningSocket(mctx_t mctx, int sockid)  in CloseListeningSocket()  argument
1282 	listener = mtcp->smap[sockid].listener;  in CloseListeningSocket()
1301 	mtcp->smap[sockid].listener = NULL;  in CloseListeningSocket()
1307 mtcp_close(mctx_t mctx, int sockid)  in mtcp_close()  argument
1318 	if (sockid < 0 || sockid >= g_config.mos->max_concurrency) {  in mtcp_close()
1319 		TRACE_API("Socket id %d out of range.\n", sockid);  in mtcp_close()
1324 	if (mtcp->smap[sockid].socktype == MOS_SOCK_UNUSED) {  in mtcp_close()
1325 		TRACE_API("Invalid socket id: %d\n", sockid);  in mtcp_close()
1330 	TRACE_API("Socket %d: mtcp_close called.\n", sockid);  in mtcp_close()
1332 	switch (mtcp->smap[sockid].socktype) {  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
1373 	if (sockid < 0 || sockid >= g_config.mos->max_concurrency) {  in mtcp_abort()
1374 		TRACE_API("Socket id %d out of range.\n", sockid);  in mtcp_abort()
1379 	if (mtcp->smap[sockid].socktype == MOS_SOCK_UNUSED) {  in mtcp_abort()
1380 		TRACE_API("Invalid socket id: %d\n", sockid);  in mtcp_abort()
1385 	if (mtcp->smap[sockid].socktype != MOS_SOCK_STREAM) {  in mtcp_abort()
1386 		TRACE_API("Not an end socket. id: %d\n", sockid);  in mtcp_abort()
1391 	cur_stream = mtcp->smap[sockid].stream;  in mtcp_abort()
1393 		TRACE_API("Stream %d: does not exist.\n", sockid);  in mtcp_abort()
1398 	TRACE_API("Socket %d: mtcp_abort()\n", sockid);  in mtcp_abort()
1400 	FreeSocket(mctx, sockid, mtcp->smap[sockid].socktype);  in mtcp_abort()
1404 		TRACE_API("Stream %d: connection already reset.\n", sockid);  in mtcp_abort()
1435 				"when in reset queue.\n", sockid);  in mtcp_abort()
1502 mtcp_recv(mctx_t mctx, int sockid, char *buf, size_t len, int flags)  in mtcp_recv()  argument
1517 	if (sockid < 0 || sockid >= g_config.mos->max_concurrency) {  in mtcp_recv()
1518 		TRACE_API("Socket id %d out of range.\n", sockid);  in mtcp_recv()
1523 	socket = &mtcp->smap[sockid];  in mtcp_recv()
1525 		TRACE_API("Invalid socket id: %d\n", sockid);  in mtcp_recv()
1531 		return PipeRead(mctx, sockid, buf, len);  in mtcp_recv()
1535 		TRACE_API("Not an end socket. id: %d\n", sockid);  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
1633 	if (sockid < 0 || sockid >= g_config.mos->max_concurrency) {  in mtcp_readv()
1634 		TRACE_API("Socket id %d out of range.\n", sockid);  in mtcp_readv()
1639 	socket = &mtcp->smap[sockid];  in mtcp_readv()
1641 		TRACE_API("Invalid socket id: %d\n", sockid);  in mtcp_readv()
1647 		TRACE_API("Not an end socket. id: %d\n", sockid);  in mtcp_readv()
1770 mtcp_write(mctx_t mctx, int sockid, const char *buf, size_t len)  in mtcp_write()  argument
1784 	if (sockid < 0 || sockid >= g_config.mos->max_concurrency) {  in mtcp_write()
1785 		TRACE_API("Socket id %d out of range.\n", sockid);  in mtcp_write()
1790 	socket = &mtcp->smap[sockid];  in mtcp_write()
1792 		TRACE_API("Invalid socket id: %d\n", sockid);  in mtcp_write()
1798 		return PipeWrite(mctx, sockid, buf, len);  in mtcp_write()
1802 		TRACE_API("Not an end socket. id: %d\n", sockid);  in mtcp_write()
1857 mtcp_writev(mctx_t mctx, int sockid, const struct iovec *iov, int numIOV)  in mtcp_writev()  argument
1871 	if (sockid < 0 || sockid >= g_config.mos->max_concurrency) {  in mtcp_writev()
1872 		TRACE_API("Socket id %d out of range.\n", sockid);  in mtcp_writev()
1877 	socket = &mtcp->smap[sockid];  in mtcp_writev()
1879 		TRACE_API("Invalid socket id: %d\n", sockid);  in mtcp_writev()
1885 		TRACE_API("Not an end socket. id: %d\n", sockid);  in mtcp_writev()