Home
last modified time | relevance | path

Searched defs:mctx (Results 1 – 22 of 22) sorted by relevance

/mOS-networking-stack/core/src/
H A Dapi.c52 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()
742 mtcp_listen(mctx_t mctx, int sockid, int backlog) in mtcp_listen()
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 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 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 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 Dcore.c925 struct mtcp_context mctx = {.cpu = ctx->cpu}; in RunMainLoop() local
1284 mctx_t mctx = (mctx_t)arg; in MTCPRunThread() local
1371 mctx_t mctx; in mtcp_create_context() local
1469 mtcp_destroy_context(mctx_t mctx) in mtcp_destroy_context()
1485 mtcp_free_context(mctx_t mctx) in mtcp_free_context()
H A Devent_callback.c426 ModifyCallback(mctx_t mctx, int op, int sockid, event_t events, in ModifyCallback()
483 mtcp_register_callback(mctx_t mctx, int sockid, event_t events, in mtcp_register_callback()
495 mtcp_unregister_callback(mctx_t mctx, int sockid, event_t events, in mtcp_unregister_callback()
671 mctx_t const mctx = g_ctx[mtcp->ctx->cpu]; in HandleCallback() local
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() local
H A Dtcp_stream.c331 struct mtcp_context mctx; in AddMonitorStreamSockets() local
395 struct mtcp_context mctx; in DestroyMonitorStreamSocket() local
H A Dtimer.c584 mtcp_settimer(mctx_t mctx, int id, struct timeval *timeout, callback_t cb) in mtcp_settimer()
/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()
/mOS-networking-stack/samples/midstat/
H A Dmidstat.c71 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/core/test/scalable_event/
H A Dtest.c33 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/samples/epwget/
H A Depwget-mp.c95 mctx_t mctx; member
135 CreateContext(mctx_t mctx) in CreateContext()
164 mctx_t mctx = ctx->mctx; in CreateConnection() local
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
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()
786 mctx_t mctx; in RunMTCP() local
H A Depwget.c96 mctx_t mctx; member
136 CreateContext(mctx_t mctx) in CreateContext()
165 mctx_t mctx = ctx->mctx; in CreateConnection() local
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
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()
788 mctx_t mctx; in RunMTCP() local
/mOS-networking-stack/samples/epserver/
H A Depserver-mp.c69 mctx_t mctx; member
272 mctx_t mctx = ctx->mctx; in AcceptConnection() local
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() local
H A Depserver.c70 mctx_t mctx; member
273 mctx_t mctx = ctx->mctx; in AcceptConnection() local
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() local
/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()
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()
/mOS-networking-stack/core/src/include/
H A Dmtcp_api.h99 mctx_t mctx; /**< mTCP context */ member
/mOS-networking-stack/core/include/
H A Dmtcp_api.h99 mctx_t mctx; /**< mTCP context */ member
/mOS-networking-stack/samples/lighttpd-1.4.32/src/
H A Dbase.h672 mctx_t mctx; member