| /mOS-networking-stack/core/src/include/ |
| H A D | socket.h | 17 typedef struct socket_map * socket_map_t; typedef 29 socket_map_t socket; 40 socket_map_t socket; 79 socket_map_t socket; 131 socket_map_t 137 socket_map_t
|
| H A D | tcp_stream.h | 234 socket_map_t socket; /* relating to MOS_SOCK_STREAM */ 290 int queue_type, socket_map_t socket, uint32_t event); 305 CreateTCPStream(mtcp_manager_t mtcp, socket_map_t socket, int type, 310 CreateDualTCPStream(mtcp_manager_t mtcp, socket_map_t socket, int type, uint32_t saddr, 314 CreateClientTCPStream(mtcp_manager_t mtcp, socket_map_t socket, int type, 328 GetFragInfo(socket_map_t sock, int side, void *optval, socklen_t *optlen); 331 GetBufInfo(socket_map_t sock, int side, void *optval, socklen_t *optlen); 338 DisableBuf(socket_map_t sock, int side);
|
| H A D | event_callback.h | 10 typedef struct socket_map * socket_map_t; typedef 78 socket_map_t socket, int side, struct pkt_ctx *pctx, event_t events);
|
| H A D | mtcp.h | 216 socket_map_t smap; 218 socket_map_t msmap;
|
| H A D | scalable_event.h | 75 socket_map_t socket, int side, struct pkt_ctx *pctx, event_t events);
|
| H A D | mos_api.h | 24 typedef struct socket_map * socket_map_t; typedef
|
| /mOS-networking-stack/core/src/ |
| H A D | socket.c | 12 FreeMonListener(mtcp_manager_t mtcp, socket_map_t socket) in FreeMonListener() 42 FreeMonStream(mtcp_manager_t mtcp, socket_map_t socket) in FreeMonStream() 70 socket_map_t 74 socket_map_t socket = NULL; in AllocateSocket() 136 socket_map_t socket = NULL; in FreeSocket() 167 socket_map_t
|
| H A D | pipe.c | 27 socket_map_t socket[2]; 42 socket_map_t socket[2]; in mtcp_pipe() 111 RaiseEventToPair(mtcp_manager_t mtcp, socket_map_t socket, uint32_t event) in RaiseEventToPair() 114 socket_map_t pair_socket; in RaiseEventToPair() 134 socket_map_t socket; in PipeRead() 237 socket_map_t socket; in PipeWrite() 337 socket_map_t socket = GetSocket(mctx, pipeid); in RaisePendingPipeEvents() 369 socket_map_t socket; in PipeClose()
|
| H A D | mos_api.c | 95 socket_map_t sock; in mtcp_bind_monitor_filter() 202 socket_map_t socket = &mtcp->msmap[msock]; in mtcp_set_uctx() 233 socket_map_t socket = &mtcp->msmap[msock]; in mtcp_get_uctx() 249 socket_map_t sock; in mtcp_peek() 367 socket_map_t sock; in mtcp_ppeek() 456 socket_map_t socket; in mtcp_getlastpkt() 558 socket_map_t socket; in mtcp_sendpkt() 708 socket_map_t socket; in mtcp_cb_stop() 795 socket_map_t socket; in mtcp_reset_conn() 852 socket_map_t socket; in mtcp_getpeername() [all …]
|
| H A D | api.c | 133 socket_map_t socket; in mtcp_getsockname() 177 socket_map_t socket; in mtcp_getsockopt() 264 socket_map_t socket; in mtcp_setsockopt() 495 socket_map_t socket; in mtcp_ioctl() 626 socket_map_t socket; in mtcp_socket() 822 socket_map_t socket; in mtcp_accept() 985 socket_map_t socket; in mtcp_connect() 1505 socket_map_t socket; in mtcp_recv() 1621 socket_map_t socket; in mtcp_readv() 1773 socket_map_t socket; in mtcp_write() [all …]
|
| H A D | eventpoll.c | 96 socket_map_t epsocket; in mtcp_epoll_create() 201 struct mtcp_epoll *ep, socket_map_t socket) in RaisePendingStreamEvents() 246 socket_map_t socket; in mtcp_epoll_ctl() 345 socket_map_t event_socket; in mtcp_epoll_wait() 545 int queue_type, socket_map_t socket, uint32_t event) in AddEpollEvent()
|
| H A D | tcp_stream.c | 62 GetFragInfo(socket_map_t sock, int side, void *optval, socklen_t *len) in GetFragInfo() 116 GetBufInfo(socket_map_t sock, int side, void *optval, socklen_t *len) in GetBufInfo() 163 DisableBuf(socket_map_t sock, int side) in DisableBuf() 393 DestroyMonitorStreamSocket(mtcp_manager_t mtcp, socket_map_t msock) in DestroyMonitorStreamSocket() 427 CreateTCPStream(mtcp_manager_t mtcp, socket_map_t socket, int type, 582 CreateDualTCPStream(mtcp_manager_t mtcp, socket_map_t socket, int type, uint32_t saddr, 615 CreateClientTCPStream(mtcp_manager_t mtcp, socket_map_t socket, int type, 913 socket_map_t socket = stream->socket;
|
| H A D | event_callback.c | 429 socket_map_t socket; in ModifyCallback() 598 socket_map_t socket, int side, struct pkt_ctx *pctx, event_t events) in HandleCallback()
|
| H A D | scalable_event.c | 942 socket_map_t socket; in mtcp_register_callback() 1025 socket_map_t socket, int side, struct pkt_ctx *pctx, event_t events) in HandleCallback()
|
| H A D | core.c | 1159 mtcp->smap = (socket_map_t)calloc(g_config.mos->max_concurrency, sizeof(struct socket_map)); in InitializeMTCPManager() 1167 mtcp->msmap = (socket_map_t)calloc(g_config.mos->max_concurrency, sizeof(struct socket_map)); in InitializeMTCPManager()
|
| /mOS-networking-stack/core/include/ |
| H A D | mos_api.h | 24 typedef struct socket_map * socket_map_t; typedef
|