Searched refs:smap (Results 1 – 5 of 5) sorted by relevance
146 socket = &mtcp->smap[sockid]; in mtcp_getsockname()193 socket = &mtcp->smap[sockid]; in mtcp_getsockopt()281 socket = &mtcp->smap[sockid]; in mtcp_setsockopt()510 socket = &mtcp->smap[sockid]; in mtcp_ioctl()735 mtcp->smap[sockid].saddr = *addr_in; in mtcp_bind()1034 socket = &mtcp->smap[sockid]; in mtcp_connect()1301 mtcp->smap[sockid].listener = NULL; in CloseListeningSocket()1523 socket = &mtcp->smap[sockid]; in mtcp_recv()1639 socket = &mtcp->smap[sockid]; in mtcp_readv()1790 socket = &mtcp->smap[sockid]; in mtcp_write()[all …]
176 ep = mtcp->smap[epid].ep; in CloseEpollSocket()188 mtcp->smap[epid].ep = NULL; in CloseEpollSocket()266 if (mtcp->smap[epid].socktype == MOS_SOCK_UNUSED) { in mtcp_epoll_ctl()271 if (mtcp->smap[epid].socktype != MOS_SOCK_EPOLL) { in mtcp_epoll_ctl()276 ep = mtcp->smap[epid].ep; in mtcp_epoll_ctl()281 socket = &mtcp->smap[sockid]; in mtcp_epoll_ctl()361 if (mtcp->smap[epid].socktype == MOS_SOCK_UNUSED) { in mtcp_epoll_wait()366 if (mtcp->smap[epid].socktype != MOS_SOCK_EPOLL) { in mtcp_epoll_wait()371 ep = mtcp->smap[epid].ep; in mtcp_epoll_wait()463 event_socket = &mtcp->smap[eq->events[eq->start].sockid]; in mtcp_epoll_wait()[all …]
155 socket = &mtcp->smap[sockid]; in FreeSocket()158 mtcp->smap[sockid].stream = NULL; in FreeSocket()175 return &g_mtcp[mctx->cpu]->smap[sockid]; in GetSocket()
489 cur_stream = mtcp->smap[mtcpq->events[offset++].sockid].stream; in FlushBufferedReadEvents()1159 mtcp->smap = (socket_map_t)calloc(g_config.mos->max_concurrency, sizeof(struct socket_map)); in InitializeMTCPManager()1160 if (!mtcp->smap) { in InitializeMTCPManager()1189 mtcp->smap[i].id = i; in InitializeMTCPManager()1190 mtcp->smap[i].socktype = MOS_SOCK_UNUSED; in InitializeMTCPManager()1191 memset(&mtcp->smap[i].saddr, 0, sizeof(struct sockaddr_in)); in InitializeMTCPManager()1192 mtcp->smap[i].stream = NULL; in InitializeMTCPManager()1193 TAILQ_INSERT_TAIL(&mtcp->free_smap, &mtcp->smap[i], link); in InitializeMTCPManager()1499 if (mtcp->smap[i].socktype == MOS_SOCK_STREAM) { in mtcp_free_context()1501 i, TCPStateToString(mtcp->smap[i].stream)); in mtcp_free_context()[all …]
216 socket_map_t smap; member