| /mOS-networking-stack/core/src/ |
| H A D | api.c | 140 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_getsockname()
185 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_getsockopt()
273 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_setsockopt()
474 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_setsock_nonblock()
503 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_ioctl()
567 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_monitor()
691 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_bind()
753 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_listen()
787 listener->sockid = sockid; in mtcp_listen()
1355 FreeSocket(mctx, sockid, mtcp->smap[sockid].socktype); in mtcp_close()
[all …]
|
| H A D | socket.c | 133 FreeSocket(mctx_t mctx, int sockid, int socktype) in FreeSocket() argument
142 socket = &mtcp->msmap[sockid]; in FreeSocket()
149 socket = &mtcp->msmap[sockid]; in FreeSocket()
155 socket = &mtcp->smap[sockid]; in FreeSocket()
158 mtcp->smap[sockid].stream = NULL; in FreeSocket()
168 GetSocket(mctx_t mctx, int sockid) in GetSocket() argument
170 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in GetSocket()
175 return &g_mtcp[mctx->cpu]->smap[sockid]; in GetSocket()
|
| H A D | eventpoll.c | 260 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_epoll_ctl()
261 TRACE_API("Socket id %d out of range.\n", sockid); in mtcp_epoll_ctl()
281 socket = &mtcp->smap[sockid]; in mtcp_epoll_ctl()
304 RaisePendingPipeEvents(mctx, epid, sockid); in mtcp_epoll_ctl()
322 RaisePendingPipeEvents(mctx, epid, sockid); in mtcp_epoll_ctl()
474 assert(eq->events[eq->start].sockid >= 0); in mtcp_epoll_wait()
484 eq->events[eq->start].sockid, in mtcp_epoll_wait()
512 assert(eq->events[eq->start].sockid >= 0); in mtcp_epoll_wait()
522 eq->events[eq->start].sockid, in mtcp_epoll_wait()
585 eq->events[index].sockid = socket->id; in AddEpollEvent()
[all …]
|
| H A D | event_callback.c | 426 ModifyCallback(mctx_t mctx, int op, int sockid, event_t events, in ModifyCallback() argument
447 socket = &mtcp->msmap[sockid]; in ModifyCallback()
483 mtcp_register_callback(mctx_t mctx, int sockid, event_t events, in mtcp_register_callback() argument
491 return ModifyCallback(mctx, OP_REG, sockid, events, hook_point, callback); in mtcp_register_callback()
495 mtcp_unregister_callback(mctx_t mctx, int sockid, event_t events, in mtcp_unregister_callback() argument
498 return ModifyCallback(mctx, OP_UNREG, sockid, events, hook_point, NULL); in mtcp_unregister_callback()
|
| H A D | scalable_event.c | 939 mtcp_register_callback(mctx_t mctx, int sockid, event_t event, in mtcp_register_callback() argument
986 socket = &mtcp->msmap[sockid]; in mtcp_register_callback()
1017 mtcp_unregister_callback(mctx_t mctx, int sockid, event_t event, in mtcp_unregister_callback() argument
1020 return mtcp_register_callback(mctx, sockid, event, hook_point, NULL); in mtcp_unregister_callback()
|
| H A D | mos_api.c | 93 mtcp_bind_monitor_filter(mctx_t mctx, int sockid, monitor_filter_t ft) in mtcp_bind_monitor_filter() argument
111 if (sockid < 0 || sockid >= g_config.mos->max_concurrency) { in mtcp_bind_monitor_filter()
116 sock = &mtcp->msmap[sockid]; in mtcp_bind_monitor_filter()
|
| H A D | tcp_stream.c | 396 int socktype, sockid, rc; in DestroyMonitorStreamSocket() local
407 sockid = msock->id; in DestroyMonitorStreamSocket()
411 FreeSocket(&mctx, sockid, socktype); in DestroyMonitorStreamSocket()
|
| H A D | core.c | 489 cur_stream = mtcp->smap[mtcpq->events[offset++].sockid].stream; in FlushBufferedReadEvents()
|
| /mOS-networking-stack/samples/epwget/ |
| H A D | epwget.c | 168 int sockid; in CreateConnection() local
175 if (sockid < 0) { in CreateConnection()
196 mtcp_close(mctx, sockid); in CreateConnection()
206 ev.data.sock = sockid; in CreateConnection()
209 return sockid; in CreateConnection()
216 mtcp_close(ctx->mctx, sockid); in CloseConnection()
263 CloseConnection(ctx, sockid); in SendHTTPRequest()
270 ev.data.sock = sockid; in SendHTTPRequest()
327 ev.data.sock = sockid; in DownloadNext()
343 CloseConnection(ctx, sockid); in DownloadComplete()
[all …]
|
| H A D | epwget-mp.c | 167 int sockid; in CreateConnection() local
174 if (sockid < 0) { in CreateConnection()
195 mtcp_close(mctx, sockid); in CreateConnection()
205 ev.data.sock = sockid; in CreateConnection()
208 return sockid; in CreateConnection()
215 mtcp_close(ctx->mctx, sockid); in CloseConnection()
262 CloseConnection(ctx, sockid); in SendHTTPRequest()
269 ev.data.sock = sockid; in SendHTTPRequest()
326 ev.data.sock = sockid; in DownloadNext()
342 CloseConnection(ctx, sockid); in DownloadComplete()
[all …]
|
| /mOS-networking-stack/samples/epserver/ |
| H A D | epserver-mp.c | 116 mtcp_close(ctx->mctx, sockid); in CloseConnection()
137 ret = mtcp_write(ctx->mctx, sockid, in SendUntilAvailable()
142 "try: %d, sent: %d\n", sockid, len, ret); in SendUntilAvailable()
159 ev.data.sock = sockid; in SendUntilAvailable()
165 CloseConnection(ctx, sockid, sv); in SendUntilAvailable()
203 sockid, rd, sv->recv_len, in HandleReadEvent()
252 "try: %d, sent: %d\n", sockid, len, sent); in HandleReadEvent()
253 CloseConnection(ctx, sockid, sv); in HandleReadEvent()
256 sockid, len, sent); in HandleReadEvent()
261 ev.data.sock = sockid; in HandleReadEvent()
[all …]
|
| H A D | epserver.c | 117 mtcp_close(ctx->mctx, sockid); in CloseConnection()
138 ret = mtcp_write(ctx->mctx, sockid, in SendUntilAvailable()
143 "try: %d, sent: %d\n", sockid, len, ret); in SendUntilAvailable()
160 ev.data.sock = sockid; in SendUntilAvailable()
166 CloseConnection(ctx, sockid, sv); in SendUntilAvailable()
204 sockid, rd, sv->recv_len, in HandleReadEvent()
253 "try: %d, sent: %d\n", sockid, len, sent); in HandleReadEvent()
254 CloseConnection(ctx, sockid, sv); in HandleReadEvent()
257 sockid, len, sent); in HandleReadEvent()
262 ev.data.sock = sockid; in HandleReadEvent()
[all …]
|
| /mOS-networking-stack/core/src/include/ |
| H A D | socket.h | 28 int sockid; member
135 FreeSocket(mctx_t mctx, int sockid, int socktype);
138 GetSocket(mctx_t mctx, int sockid);
|
| H A D | eventpoll.h | 23 int sockid; member
|
| H A D | mtcp_api.h | 382 mtcp_recv(mctx_t mctx, int sockid, char *buf, size_t len, int flags);
|
| /mOS-networking-stack/samples/simple_firewall/ |
| H A D | simple_firewall.c | 363 CatchInitSYN(mctx_t mctx, int sockid, in CatchInitSYN() argument
368 if (mtcp_getlastpkt(mctx, sockid, side, &p) < 0) in CatchInitSYN()
|
| /mOS-networking-stack/core/include/ |
| H A D | mtcp_api.h | 382 mtcp_recv(mctx_t mctx, int sockid, char *buf, size_t len, int flags);
|
| /mOS-networking-stack/core/test/scalable_event/ |
| H A D | test.c | 60 ft_prob(mctx_t mctx, int sockid, int side, uint64_t events, filter_arg_t *arg) in ft_prob() argument
|