Home
last modified time | relevance | path

Searched refs:mctx_t (Results 1 – 25 of 30) sorted by relevance

12

/mOS-networking-stack/core/src/include/
H A Dmtcp_api.h28 typedef struct mtcp_context *mctx_t; typedef
99 mctx_t mctx; /**< mTCP context */
119 void (*run)(mctx_t mctx, void **app_ctx);
167 mctx_t
175 mtcp_destroy_context(mctx_t mctx);
192 mtcp_pipe(mctx_t mctx, int pipeid[2]);
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);
H A Deventpoll.h58 CloseEpollSocket(mctx_t mctx, int epid);
/mOS-networking-stack/core/include/
H A Dmtcp_api.h28 typedef struct mtcp_context *mctx_t; typedef
99 mctx_t mctx; /**< mTCP context */
119 void (*run)(mctx_t mctx, void **app_ctx);
167 mctx_t
175 mtcp_destroy_context(mctx_t mctx);
192 mtcp_pipe(mctx_t mctx, int pipeid[2]);
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/midstat/
H A Dmidstat.c42 mctx_t g_mctx[MAX_CORES]; /* mOS context */
71 cb_creation(mctx_t mctx, int sock, int side, uint64_t events, filter_arg_t *arg) in cb_creation()
95 cb_destroy(mctx_t mctx, int sock, int side, uint64_t events, filter_arg_t *arg) in cb_destroy()
108 cb_st_chg(mctx_t mctx, int sock, int side, uint64_t events, filter_arg_t *arg) in cb_st_chg()
155 cb_printstat(mctx_t mctx, int sock, int side, in cb_printstat()
196 RegisterCallbacks(mctx_t mctx, int sock, event_t ev_new_syn) in RegisterCallbacks()
235 InitMonitor(mctx_t mctx, event_t ev_new_syn) in InitMonitor()
/mOS-networking-stack/samples/nat/
H A Dnat.c59 assign_port(mctx_t mctx, int sock) in assign_port()
92 set_addr(mctx_t mctx, int sock, uint32_t ip, uint16_t port, int part) in set_addr()
122 translate_addr(mctx_t mctx, int sock, int side, uint64_t events, in translate_addr()
158 release_port(mctx_t mctx, int sock, int side, uint64_t events, in release_port()
175 init_monitor(mctx_t mctx) in init_monitor()
197 mctx_t mctx_list[MAX_CORES]; /* mOS context */ in main()
/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()
46 cb(mctx_t mctx, int sock, int side, event_t ev, filter_arg_t *arg) in cb()
53 ft(mctx_t mctx, int sock, int side, event_t ev, filter_arg_t *arg) in ft()
60 ft_prob(mctx_t mctx, int sockid, int side, uint64_t events, filter_arg_t *arg) in ft_prob()
88 ft_ac_match(mctx_t mctx, int sock, int side, uint64_t ev, filter_arg_t *arg) in ft_ac_match()
/mOS-networking-stack/core/src/
H A Dapi.c43 mtcp_cb_stop(mctx_t mctx, int sock, int side);
52 GetMTCPManager(mctx_t mctx) in GetMTCPManager()
464 mtcp_setsock_nonblock(mctx_t mctx, int sockid) in mtcp_setsock_nonblock()
555 mtcp_monitor(mctx_t mctx, socket_map_t sock) in mtcp_monitor()
679 mtcp_bind(mctx_t mctx, int sockid, in mtcp_bind()
981 mtcp_connect(mctx_t mctx, int sockid, in mtcp_connect()
1198 CloseStreamSocket(mctx_t mctx, int sockid) in CloseStreamSocket()
1271 CloseListeningSocket(mctx_t mctx, int sockid) in CloseListeningSocket()
1307 mtcp_close(mctx_t mctx, int sockid) in mtcp_close()
1361 mtcp_abort(mctx_t mctx, int sockid) in mtcp_abort()
[all …]
H A Dmos_api.c171 mtcp_app_join(mctx_t mctx) in mtcp_app_join()
183 mtcp_set_uctx(mctx_t mctx, int msock, void *uctx) in mtcp_set_uctx()
211 mtcp_get_uctx(mctx_t mctx, int msock) in mtcp_get_uctx()
361 mtcp_ppeek(mctx_t mctx, int msock, int side, in mtcp_ppeek()
555 mtcp_sendpkt(mctx_t mctx, int sock, const struct pkt_info *pkt) in mtcp_sendpkt()
705 mtcp_cb_stop(mctx_t mctx, int sock, int side) in mtcp_cb_stop()
792 mtcp_reset_conn(mctx_t mctx, int sock) in mtcp_reset_conn()
819 mtcp_cb_get_ts(mctx_t mctx) in mtcp_cb_get_ts()
932 mtcp_setlastpkt(mctx_t mctx, int sock, int side, off_t offset, in mtcp_setlastpkt()
1211 mtcp_cb_dropcurpkt(mctx_t mctx) in mtcp_cb_dropcurpkt()
[all …]
H A Dpipe.c40 mtcp_pipe(mctx_t mctx, int pipeid[2]) in mtcp_pipe()
131 PipeRead(mctx_t mctx, int pipeid, char *buf, int len) in PipeRead()
234 PipeWrite(mctx_t mctx, int pipeid, const char *buf, int len) in PipeWrite()
334 RaisePendingPipeEvents(mctx_t mctx, int epid, int pipeid) in RaisePendingPipeEvents()
366 PipeClose(mctx_t mctx, int pipeid) in PipeClose()
H A Dsocket.c71 AllocateSocket(mctx_t mctx, int socktype) in AllocateSocket()
133 FreeSocket(mctx_t mctx, int sockid, int socktype) in FreeSocket()
168 GetSocket(mctx_t mctx, int sockid) in GetSocket()
H A Deventpoll.c92 mtcp_epoll_create(mctx_t mctx, int size) in mtcp_epoll_create()
166 CloseEpollSocket(mctx_t mctx, int epid) in CloseEpollSocket()
241 mtcp_epoll_ctl(mctx_t mctx, int epid, in mtcp_epoll_ctl()
338 mtcp_epoll_wait(mctx_t mctx, int epid, in mtcp_epoll_wait()
H A Dscalable_event.c861 mtcp_raise_event(mctx_t mctx, event_t event) in mtcp_raise_event()
881 HandleCb(mctx_t const mctx, int sock, int side, in HandleCb()
939 mtcp_register_callback(mctx_t mctx, int sockid, event_t event, in mtcp_register_callback()
1017 mtcp_unregister_callback(mctx_t mctx, int sockid, event_t event, in mtcp_unregister_callback()
1083 mctx_t const mctx = g_ctx[mtcp->ctx->cpu]; in HandleCallback()
/mOS-networking-stack/samples/epwget/
H A Depwget.c53 static mctx_t g_mctx[MAX_CPUS];
96 mctx_t mctx;
136 CreateContext(mctx_t mctx) in CreateContext()
165 mctx_t mctx = ctx->mctx; in CreateConnection()
291 mctx_t mctx = ctx->mctx; in DownloadNext()
337 mctx_t mctx = ctx->mctx; in DownloadComplete()
374 mctx_t mctx = ctx->mctx; in HandleReadEvent()
608 InitWget(mctx_t mctx, void **app_ctx) in InitWget()
662 RunWget(mctx_t mctx, void **app_ctx) in RunWget()
769 RunApplication(mctx_t mctx) in RunApplication()
[all …]
H A Depwget-mp.c52 static mctx_t g_mctx[MAX_CPUS];
95 mctx_t mctx;
135 CreateContext(mctx_t mctx) in CreateContext()
164 mctx_t mctx = ctx->mctx; in CreateConnection()
290 mctx_t mctx = ctx->mctx; in DownloadNext()
336 mctx_t mctx = ctx->mctx; in DownloadComplete()
373 mctx_t mctx = ctx->mctx; in HandleReadEvent()
606 InitWget(mctx_t mctx, void **app_ctx) in InitWget()
660 RunWget(mctx_t mctx, void **app_ctx) in RunWget()
767 RunApplication(mctx_t mctx) in RunApplication()
[all …]
/mOS-networking-stack/util/include/
H A Dring_buffer.h28 int MtcpWriteFromBuffer(mctx_t mtcp, int fid, ring_buffer *r_buff);
29 int MtcpReadFromBuffer(mctx_t mtcp, int fid, ring_buffer *r_buff);
/mOS-networking-stack/samples/epserver/
H A Depserver-mp.c69 mctx_t mctx;
272 mctx_t mctx = ctx->mctx; in AcceptConnection()
432 InitServer(mctx_t mctx, void **app_ctx) in InitServer()
471 RunServer(mctx_t mctx, void **app_ctx) in RunServer()
570 RunApplication(mctx_t mctx) in RunApplication()
589 mctx_t mctx; in RunMTCP()
H A Depserver.c70 mctx_t mctx;
273 mctx_t mctx = ctx->mctx; in AcceptConnection()
433 InitServer(mctx_t mctx, void **app_ctx) in InitServer()
472 RunServer(mctx_t mctx, void **app_ctx) in RunServer()
571 RunApplication(mctx_t mctx) in RunApplication()
590 mctx_t mctx; in RunMTCP()
/mOS-networking-stack/samples/simple_firewall/
H A Dsimple_firewall.c73 mctx_t mctx; /* per-thread mos context */
79 DumpFWRuleTable(mctx_t mctx, int sock, int side, in DumpFWRuleTable()
333 ApplyActionPerFlow(mctx_t mctx, int msock, int side, in ApplyActionPerFlow()
363 CatchInitSYN(mctx_t mctx, int sockid, in CatchInitSYN()
/mOS-networking-stack/util/
H A Dring_buffer.c222 int MtcpWriteFromBuffer(mctx_t mctx, int fid, ring_buffer *r_buff) in MtcpWriteFromBuffer()
241 int MtcpReadFromBuffer(mctx_t mctx, int fid, ring_buffer *r_buff) in MtcpReadFromBuffer()

12