Home
last modified time | relevance | path

Searched refs:mctx (Results 1 – 25 of 37) sorted by relevance

12

/mOS-networking-stack/core/src/include/
H A Dmtcp_api.h99 mctx_t mctx; /**< mTCP context */ member
116 void (*thread_init)(mctx_t mctx, void **app_ctx);
119 void (*run)(mctx_t mctx, void **app_ctx);
175 mtcp_destroy_context(mctx_t mctx);
192 mtcp_pipe(mctx_t mctx, int pipeid[2]);
277 mtcp_setsock_nonblock(mctx_t mctx, int sock);
312 mtcp_bind(mctx_t mctx, int sock,
351 mtcp_connect(mctx_t mctx, int sock,
358 mtcp_close(mctx_t mctx, int sock);
366 mtcp_abort(mctx_t mctx, int sock);
[all …]
H A Dmos_api.h291 typedef void (*callback_t)(mctx_t mctx, int sock, int side,
294 typedef bool (*filter_t)(mctx_t mctx, int sock, int side,
348 mtcp_register_callback(mctx_t mctx, int sock, event_t event,
388 mtcp_raise_event(mctx_t mctx, event_t event);
401 mtcp_set_uctx(mctx_t mctx, int sock, void *uctx);
410 mtcp_get_uctx(mctx_t mctx, int sock);
423 mtcp_peek(mctx_t mctx, int sock, int side,
446 ssize_t mtcp_ppeek(mctx_t mctx, int sock, int side,
484 mtcp_cb_get_ts(mctx_t mctx);
492 mtcp_app_join(mctx_t mctx);
[all …]
H A Dpipe.h7 PipeRead(mctx_t mctx, int pipeid, char *buf, int len);
10 PipeWrite(mctx_t mctx, int pipeid, const char *buf, int len);
13 RaisePendingPipeEvents(mctx_t mctx, int epid, int pipeid);
16 PipeClose(mctx_t mctx, int pipeid);
H A Dmtcp_epoll.h80 mtcp_epoll_create(mctx_t mctx, int size);
94 mtcp_epoll_ctl(mctx_t mctx, int epid,
108 mtcp_epoll_wait(mctx_t mctx, int epid,
H A Dsocket.h132 AllocateSocket(mctx_t mctx, int socktype);
135 FreeSocket(mctx_t mctx, int sockid, int socktype);
138 GetSocket(mctx_t mctx, int sockid);
/mOS-networking-stack/core/include/
H A Dmtcp_api.h99 mctx_t mctx; /**< mTCP context */ member
116 void (*thread_init)(mctx_t mctx, void **app_ctx);
119 void (*run)(mctx_t mctx, void **app_ctx);
175 mtcp_destroy_context(mctx_t mctx);
192 mtcp_pipe(mctx_t mctx, int pipeid[2]);
277 mtcp_setsock_nonblock(mctx_t mctx, int sock);
312 mtcp_bind(mctx_t mctx, int sock,
351 mtcp_connect(mctx_t mctx, int sock,
358 mtcp_close(mctx_t mctx, int sock);
366 mtcp_abort(mctx_t mctx, int sock);
[all …]
H A Dmos_api.h291 typedef void (*callback_t)(mctx_t mctx, int sock, int side,
294 typedef bool (*filter_t)(mctx_t mctx, int sock, int side,
348 mtcp_register_callback(mctx_t mctx, int sock, event_t event,
388 mtcp_raise_event(mctx_t mctx, event_t event);
401 mtcp_set_uctx(mctx_t mctx, int sock, void *uctx);
410 mtcp_get_uctx(mctx_t mctx, int sock);
423 mtcp_peek(mctx_t mctx, int sock, int side,
446 ssize_t mtcp_ppeek(mctx_t mctx, int sock, int side,
484 mtcp_cb_get_ts(mctx_t mctx);
492 mtcp_app_join(mctx_t mctx);
[all …]
H A Dmtcp_epoll.h80 mtcp_epoll_create(mctx_t mctx, int size);
94 mtcp_epoll_ctl(mctx_t mctx, int epid,
108 mtcp_epoll_wait(mctx_t mctx, int epid,
/mOS-networking-stack/samples/nat/
H A Dnat.c59 assign_port(mctx_t mctx, int sock) in assign_port() argument
77 == mctx->cpu) in assign_port()
82 mtcp_set_uctx(mctx, sock, w); in assign_port()
104 if (mtcp_setlastpkt(mctx, sock, 0, off_ip, in set_addr()
110 if (mtcp_setlastpkt(mctx, sock, 0, off_port, in set_addr()
127 if (!(w = mtcp_get_uctx(mctx, sock))) in translate_addr()
128 assign_port(mctx, sock); in translate_addr()
133 if (!(w = mtcp_get_uctx(mctx, sock))) in translate_addr()
164 if (!(w = mtcp_get_uctx(mctx, sock))) in release_port()
170 mtcp_set_uctx(mctx, sock, NULL); in release_port()
[all …]
/mOS-networking-stack/samples/midstat/
H A Dmidstat.c90 TAILQ_INSERT_TAIL(&g_sockq[mctx->cpu], c, link); in cb_creation()
99 if (!(c = find_connection(mctx->cpu, sock))) in cb_destroy()
102 TAILQ_REMOVE(&g_sockq[mctx->cpu], c, link); in cb_destroy()
113 if (!(c = find_connection(mctx->cpu, sock))) in cb_st_chg()
155 cb_printstat(mctx_t mctx, int sock, int side, in cb_printstat() argument
226 if (mctx->cpu == 0 && in RegisterCallbacks()
227 mtcp_settimer(mctx, sock, &tv_1sec, cb_printstat)) { in RegisterCallbacks()
235 InitMonitor(mctx_t mctx, event_t ev_new_syn) in InitMonitor() argument
240 TAILQ_INIT(&g_sockq[mctx->cpu]); in InitMonitor()
243 if ((sock = mtcp_socket(mctx, AF_INET, in InitMonitor()
[all …]
/mOS-networking-stack/samples/epwget/
H A Depwget.c96 mctx_t mctx; member
147 ctx->mctx = mctx; in CreateContext()
165 mctx_t mctx = ctx->mctx; in CreateConnection() local
171 assert(mctx); in CreateConnection()
291 mctx_t mctx = ctx->mctx; in DownloadNext() local
337 mctx_t mctx = ctx->mctx; in DownloadComplete() local
374 mctx_t mctx = ctx->mctx; in HandleReadEvent() local
613 assert(mctx); in InitWget()
669 assert(mctx); in RunWget()
788 mctx_t mctx; in RunMTCP() local
[all …]
H A Depwget-mp.c95 mctx_t mctx; member
146 ctx->mctx = mctx; in CreateContext()
164 mctx_t mctx = ctx->mctx; in CreateConnection() local
170 assert(mctx); in CreateConnection()
290 mctx_t mctx = ctx->mctx; in DownloadNext() local
336 mctx_t mctx = ctx->mctx; in DownloadComplete() local
373 mctx_t mctx = ctx->mctx; in HandleReadEvent() local
611 assert(mctx); in InitWget()
667 assert(mctx); in RunWget()
786 mctx_t mctx; in RunMTCP() local
[all …]
/mOS-networking-stack/samples/epserver/
H A Depserver-mp.c69 mctx_t mctx; member
116 mtcp_close(ctx->mctx, sockid); in CloseConnection()
272 mctx_t mctx = ctx->mctx; in AcceptConnection() local
442 ctx->mctx = mctx; in InitServer()
570 RunApplication(mctx_t mctx) in RunApplication() argument
581 InitServer(mctx, &(app_ctx)); in RunApplication()
582 RunServer(mctx, &(app_ctx)); in RunApplication()
589 mctx_t mctx; in RunMTCP() local
595 if (!mctx) { in RunMTCP()
602 RunApplication(mctx); in RunMTCP()
[all …]
H A Depserver.c70 mctx_t mctx; member
117 mtcp_close(ctx->mctx, sockid); in CloseConnection()
273 mctx_t mctx = ctx->mctx; in AcceptConnection() local
443 ctx->mctx = mctx; in InitServer()
571 RunApplication(mctx_t mctx) in RunApplication() argument
582 InitServer(mctx, &(app_ctx)); in RunApplication()
583 RunServer(mctx, &(app_ctx)); in RunApplication()
590 mctx_t mctx; in RunMTCP() local
596 if (!mctx) { in RunMTCP()
603 RunApplication(mctx); in RunMTCP()
[all …]
/mOS-networking-stack/core/src/
H A Dpipe.c40 mtcp_pipe(mctx_t mctx, int pipeid[2]) in mtcp_pipe() argument
46 socket[0] = AllocateSocket(mctx, MOS_SOCK_PIPE); in mtcp_pipe()
51 socket[1] = AllocateSocket(mctx, MOS_SOCK_PIPE); in mtcp_pipe()
53 FreeSocket(mctx, socket[0]->id, MOS_SOCK_PIPE); in mtcp_pipe()
140 mtcp = GetMTCPManager(mctx); in PipeRead()
144 socket = GetSocket(mctx, pipeid); in PipeRead()
243 mtcp = GetMTCPManager(mctx); in PipeWrite()
247 socket = GetSocket(mctx, pipeid); in PipeWrite()
366 PipeClose(mctx_t mctx, int pipeid) in PipeClose() argument
372 mtcp = GetMTCPManager(mctx); in PipeClose()
[all …]
H A Dapi.c52 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()
135 mtcp = GetMTCPManager(mctx); in mtcp_getsockname()
179 mtcp = GetMTCPManager(mctx); in mtcp_getsockopt()
267 mtcp = GetMTCPManager(mctx); in mtcp_setsockopt()
468 mtcp = GetMTCPManager(mctx); in mtcp_setsock_nonblock()
497 mtcp = GetMTCPManager(mctx); in mtcp_ioctl()
[all …]
H A Dmos_api.c98 mtcp = GetMTCPManager(mctx); in mtcp_bind_monitor_filter()
171 mtcp_app_join(mctx_t mctx) in mtcp_app_join() argument
187 mtcp = GetMTCPManager(mctx); in mtcp_set_uctx()
215 mtcp = GetMTCPManager(mctx); in mtcp_get_uctx()
252 mtcp = GetMTCPManager(mctx); in mtcp_peek()
369 mtcp = GetMTCPManager(mctx); in mtcp_ppeek()
459 mtcp = GetMTCPManager(mctx); in mtcp_getlastpkt()
530 mtcp = GetMTCPManager(mctx); in mtcp_getlastpkt()
560 mtcp = GetMTCPManager(mctx); in mtcp_sendpkt()
713 mtcp = GetMTCPManager(mctx); in mtcp_cb_stop()
[all …]
H A Deventpoll.c92 mtcp_epoll_create(mctx_t mctx, int size) in mtcp_epoll_create() argument
94 mtcp_manager_t mtcp = g_mtcp[mctx->cpu]; in mtcp_epoll_create()
118 FreeSocket(mctx, epsocket->id, FALSE); in mtcp_epoll_create()
126 FreeSocket(mctx, epsocket->id, FALSE); in mtcp_epoll_create()
135 FreeSocket(mctx, epsocket->id, FALSE); in mtcp_epoll_create()
149 FreeSocket(mctx, epsocket->id, FALSE); in mtcp_epoll_create()
166 CloseEpollSocket(mctx_t mctx, int epid) in CloseEpollSocket() argument
171 mtcp = GetMTCPManager(mctx); in CloseEpollSocket()
241 mtcp_epoll_ctl(mctx_t mctx, int epid, in mtcp_epoll_ctl() argument
249 mtcp = GetMTCPManager(mctx); in mtcp_epoll_ctl()
[all …]
H A Dcore.c1285 int cpu = mctx->cpu; in MTCPRunThread()
1371 mctx_t mctx; in mtcp_create_context() local
1401 if (!mctx) { in mtcp_create_context()
1405 mctx->cpu = cpu; in mtcp_create_context()
1406 g_ctx[cpu] = mctx; in mtcp_create_context()
1465 return mctx; in mtcp_create_context()
1476 m.cpu = mctx->cpu; in mtcp_destroy_context()
1479 free(mctx); in mtcp_destroy_context()
1505 mtcp_close(mctx, i); in mtcp_free_context()
1516 if (master == mctx->cpu) in mtcp_free_context()
[all …]
H A Dsocket.c71 AllocateSocket(mctx_t mctx, int socktype) in AllocateSocket() argument
73 mtcp_manager_t mtcp = g_mtcp[mctx->cpu]; in AllocateSocket()
133 FreeSocket(mctx_t mctx, int sockid, int socktype) in FreeSocket() argument
135 mtcp_manager_t mtcp = g_mtcp[mctx->cpu]; in FreeSocket()
168 GetSocket(mctx_t mctx, int sockid) in GetSocket() argument
175 return &g_mtcp[mctx->cpu]->smap[sockid]; in GetSocket()
H A Devent_callback.c426 ModifyCallback(mctx_t mctx, int op, int sockid, event_t events, in ModifyCallback() argument
443 mtcp_manager_t mtcp = GetMTCPManager(mctx); 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()
671 mctx_t const mctx = g_ctx[mtcp->ctx->cpu]; in HandleCallback() local
688 evt->ent[ev_idx].cb(mctx, socket->id, side, ev, data); in HandleCallback()
712 (tmpdata.u64 = g_udes[ude_id - UDE_OFFSET].ft(mctx, socket->id, side, ev, data))) { in HandleCallback()
/mOS-networking-stack/samples/simple_firewall/
H A Dsimple_firewall.c73 mctx_t mctx; /* per-thread mos context */ member
79 DumpFWRuleTable(mctx_t mctx, int sock, int side, in DumpFWRuleTable() argument
342 if (mtcp_getlastpkt(mctx, msock, side, &p) < 0) in ApplyActionPerFlow()
363 CatchInitSYN(mctx_t mctx, int sockid, in CatchInitSYN() argument
368 if (mtcp_getlastpkt(mctx, sockid, side, &p) < 0) in CatchInitSYN()
383 ctx->mctx = mtcp_create_context(core); in CreateAndInitThreadContext()
399 if (ctx->mctx->cpu == 0 && in CreateAndInitThreadContext()
400 mtcp_settimer(ctx->mctx, ctx->mon_listener, in CreateAndInitThreadContext()
410 mtcp_app_join(ctx->mctx); in WaitAndCleanupThreadContext()
413 mtcp_close(ctx->mctx, ctx->mon_listener); in WaitAndCleanupThreadContext()
[all …]
/mOS-networking-stack/core/test/scalable_event/
H A Dtest.c27 HandleCb(mctx_t mctx, int sock, int side, stree_t *stree, event_t events);
33 GetMTCPManager(mctx_t mctx) in GetMTCPManager() argument
46 cb(mctx_t mctx, int sock, int side, event_t ev, filter_arg_t *arg) in cb() argument
53 ft(mctx_t mctx, int sock, int side, event_t ev, filter_arg_t *arg) in ft() argument
60 ft_prob(mctx_t mctx, int sockid, int side, uint64_t events, filter_arg_t *arg) in ft_prob() argument
88 ft_ac_match(mctx_t mctx, int sock, int side, uint64_t ev, filter_arg_t *arg) in ft_ac_match() argument
216 mtcp_register_callback(mctx, msock, BEV4, MOS_PRE_RCV, cb_void); in main()
219 mtcp_register_callback(mctx, msock, ev, MOS_PRE_RCV, cb_void); in main()
/mOS-networking-stack/samples/lighttpd-1.4.32/src/
H A Dfdevent_libmtcp.c22 mtcp_close(ev->srv->mctx, ev->epoll_fd); in fdevent_libmtcp_epoll_free()
38 if (0 != mtcp_epoll_ctl(ev->srv->mctx, ev->epoll_fd, MOS_EPOLL_CTL_DEL, fd, NULL/*&ep*/)) { in fdevent_libmtcp_epoll_event_del()
77 …if (0 != mtcp_epoll_ctl(ev->srv->mctx, ev->epoll_fd, add ? MOS_EPOLL_CTL_ADD : MOS_EPOLL_CTL_MOD, … in fdevent_libmtcp_epoll_event_set()
92 return mtcp_epoll_wait(ev->srv->mctx, ev->epoll_fd, ev->_epoll_events, in fdevent_libmtcp_epoll_poll()
147 if (-1 == (ev->epoll_fd = mtcp_epoll_create(ev->srv->mctx, ev->srv->max_conns * 3))) { in fdevent_libmtcp_epoll_init()
/mOS-networking-stack/util/
H A Dring_buffer.c222 int MtcpWriteFromBuffer(mctx_t mctx, int fid, ring_buffer *r_buff) in MtcpWriteFromBuffer() argument
229 wr = mtcp_write(mctx, fid, GetDataPoint(r_buff), to_send); in MtcpWriteFromBuffer()
241 int MtcpReadFromBuffer(mctx_t mctx, int fid, ring_buffer *r_buff) in MtcpReadFromBuffer() argument
249 ret = mtcp_read(mctx, fid, ip, free_len); in MtcpReadFromBuffer()

12