Home
last modified time | relevance | path

Searched refs:sock (Results 1 – 25 of 26) sorted by relevance

12

/mOS-networking-stack/samples/midstat/
H A Dmidstat.c34 int sock; /* socket ID */ member
58 find_connection(int cpu, int sock) in find_connection() argument
63 if (c->sock == sock) in find_connection()
81 c->sock = sock; in cb_creation()
99 if (!(c = find_connection(mctx->cpu, sock))) 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
227 mtcp_settimer(mctx, sock, &tv_1sec, cb_printstat)) { in RegisterCallbacks()
237 int sock; in InitMonitor() local
243 if ((sock = mtcp_socket(mctx, AF_INET, in InitMonitor()
[all …]
/mOS-networking-stack/samples/nat/
H A Dnat.c59 assign_port(mctx_t mctx, int sock) in assign_port() argument
68 TRACE_ERROR("mtcp_getpeer() failed for sock=%d\n", sock); 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()
136 if (set_addr(mctx, sock, g_NATIP, w->port, SRC) < 0 && in translate_addr()
164 if (!(w = mtcp_get_uctx(mctx, sock))) in release_port()
[all …]
/mOS-networking-stack/core/src/include/
H A Dmtcp_api.h229 mtcp_getsockopt(mctx_t mctx, int sock, int level,
266 mtcp_setsockopt(mctx_t mctx, int sock, int level,
277 mtcp_setsock_nonblock(mctx_t mctx, int sock);
292 mtcp_ioctl(mctx_t mctx, int sock, int request, void *argp);
312 mtcp_bind(mctx_t mctx, int sock,
321 mtcp_listen(mctx_t mctx, int sock, int backlog);
351 mtcp_connect(mctx_t mctx, int sock,
358 mtcp_close(mctx_t mctx, int sock);
366 mtcp_abort(mctx_t mctx, int sock);
388 mtcp_read(mctx_t mctx, int sock, char *buf, size_t len);
[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,
334 mtcp_bind_monitor_filter(mctx_t mctx, int sock, monitor_filter_t ft);
348 mtcp_register_callback(mctx_t mctx, int sock, 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,
463 mtcp_getlastpkt(mctx_t mctx, int sock, int side, struct pkt_info *p);
527 mtcp_setlastpkt(mctx_t mctx, int sock, int side, off_t offset,
[all …]
H A Dtcp_stream.h28 struct socket_map *sock; member
38 __s->sock = (socket); \
47 if ((socket) == __walk->sock) break; \
58 ((var) = __walk ? __walk->sock : NULL, __walk); \
65 ((var) = __walk ? __walk->sock : NULL, __walk); \
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 Dmtcp_epoll.h60 int sock; member
95 int op, int sock, struct mtcp_epoll_event *event);
/mOS-networking-stack/core/include/
H A Dmtcp_api.h229 mtcp_getsockopt(mctx_t mctx, int sock, int level,
266 mtcp_setsockopt(mctx_t mctx, int sock, int level,
277 mtcp_setsock_nonblock(mctx_t mctx, int sock);
292 mtcp_ioctl(mctx_t mctx, int sock, int request, void *argp);
312 mtcp_bind(mctx_t mctx, int sock,
321 mtcp_listen(mctx_t mctx, int sock, int backlog);
351 mtcp_connect(mctx_t mctx, int sock,
358 mtcp_close(mctx_t mctx, int sock);
366 mtcp_abort(mctx_t mctx, int sock);
388 mtcp_read(mctx_t mctx, int sock, char *buf, size_t len);
[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,
334 mtcp_bind_monitor_filter(mctx_t mctx, int sock, monitor_filter_t ft);
348 mtcp_register_callback(mctx_t mctx, int sock, 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,
463 mtcp_getlastpkt(mctx_t mctx, int sock, int side, struct pkt_info *p);
527 mtcp_setlastpkt(mctx_t mctx, int sock, int side, off_t offset,
[all …]
H A Dmtcp_epoll.h60 int sock; member
95 int op, int sock, struct mtcp_epoll_event *event);
/mOS-networking-stack/samples/epserver/
H A Depserver-mp.c159 ev.data.sock = sockid; in SendUntilAvailable()
261 ev.data.sock = sockid; in HandleReadEvent()
289 ev.data.sock = c; in AcceptConnection()
344 ev.data.sock = listener; in CreateListeningSocket()
510 core, events[i].data.sock); in RunServer()
515 events[i].data.sock, strerror(err)); in RunServer()
523 &ctx->svars[events[i].data.sock]); in RunServer()
527 &ctx->svars[events[i].data.sock]); in RunServer()
532 &ctx->svars[events[i].data.sock]); in RunServer()
537 &ctx->svars[events[i].data.sock]); in RunServer()
[all …]
H A Depserver.c160 ev.data.sock = sockid; in SendUntilAvailable()
262 ev.data.sock = sockid; in HandleReadEvent()
290 ev.data.sock = c; in AcceptConnection()
345 ev.data.sock = listener; in CreateListeningSocket()
511 core, events[i].data.sock); in RunServer()
516 events[i].data.sock, strerror(err)); in RunServer()
524 &ctx->svars[events[i].data.sock]); in RunServer()
528 &ctx->svars[events[i].data.sock]); in RunServer()
533 &ctx->svars[events[i].data.sock]); in RunServer()
538 &ctx->svars[events[i].data.sock]); in RunServer()
[all …]
/mOS-networking-stack/core/src/
H A Dmos_api.c95 socket_map_t sock; in mtcp_bind_monitor_filter() local
116 sock = &mtcp->msmap[sockid]; in mtcp_bind_monitor_filter()
119 switch (sock->socktype) { in mtcp_bind_monitor_filter()
249 socket_map_t sock; in mtcp_peek() local
265 sock = &mtcp->msmap[msock]; in mtcp_peek()
367 socket_map_t sock; in mtcp_ppeek() local
382 sock = &mtcp->msmap[msock]; in mtcp_ppeek()
472 socket = &mtcp->msmap[sock]; in mtcp_getlastpkt()
573 socket = &mtcp->msmap[sock]; in mtcp_sendpkt()
719 socket = &mtcp->msmap[sock]; in mtcp_cb_stop()
[all …]
H A Dtcp_stream.c62 GetFragInfo(socket_map_t sock, int side, void *optval, socklen_t *len) in GetFragInfo() argument
76 struct tcp_stream *mstrm = sock->monitor_stream->stream; in GetFragInfo()
116 GetBufInfo(socket_map_t sock, int side, void *optval, socklen_t *len) in GetBufInfo() argument
136 struct tcp_stream *mstrm = sock->monitor_stream->stream; in GetBufInfo()
163 DisableBuf(socket_map_t sock, int side) in DisableBuf() argument
171 switch (sock->socktype) { in DisableBuf()
174 sock->monitor_listener->client_buf_mgmt = 0; in DisableBuf()
176 sock->monitor_listener->server_buf_mgmt = 0; in DisableBuf()
184 stream = sock->monitor_stream->stream; in DisableBuf()
H A Dscalable_event.c881 HandleCb(mctx_t const mctx, int sock, int side, in HandleCb() argument
908 walk->ft(mctx, sock, side, walk->ev, &walk->arg) == false) { in HandleCb()
915 walk->cb(mctx, sock, side, walk->ev, &walk->arg); in HandleCb()
1043 #define MSTRM(sock) (sock)->monitor_stream in HandleCallback() argument
1044 #define MLSNR(sock) (sock)->monitor_listener in HandleCallback() argument
H A Dconfig.c253 int sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_IP); in FeedNetdevConfLine() local
254 if (sock == -1) { in FeedNetdevConfLine()
260 if (ioctl(sock, SIOCGIFADDR, &ent->ifr) == 0 ) { in FeedNetdevConfLine()
266 if (ioctl(sock, SIOCGIFNETMASK, &ent->ifr) == 0) { in FeedNetdevConfLine()
274 if (ioctl(sock, SIOCGIFHWADDR, &ent->ifr) == 0 ) { in FeedNetdevConfLine()
281 close(sock); in FeedNetdevConfLine()
H A Devent_callback.c621 #define MSTRM(sock) (sock)->monitor_stream in HandleCallback() argument
622 #define MLSNR(sock) (sock)->monitor_listener in HandleCallback() argument
H A Dapi.c43 mtcp_cb_stop(mctx_t mctx, int sock, int side);
555 mtcp_monitor(mctx_t mctx, socket_map_t sock) in mtcp_monitor() argument
559 int sockid = sock->id; in mtcp_monitor()
608 monitor->socket = sock; in mtcp_monitor()
/mOS-networking-stack/samples/lighttpd-1.4.32/src/
H A Dmod_extforward.c413 sock_addr sock; in URIHANDLER_FUNC() local
429 sock.plain.sa_family = AF_UNSPEC; in URIHANDLER_FUNC()
431 sock.plain.sa_family = addrs_left->ai_family; in URIHANDLER_FUNC()
432 if (sock.plain.sa_family == AF_INET) { in URIHANDLER_FUNC()
433 sock.ipv4.sin_addr = ((struct sockaddr_in*)addrs_left->ai_addr)->sin_addr; in URIHANDLER_FUNC()
435 } else if (sock.plain.sa_family == AF_INET6) { in URIHANDLER_FUNC()
436 sock.ipv6.sin6_addr = ((struct sockaddr_in6*)addrs_left->ai_addr)->sin6_addr; in URIHANDLER_FUNC()
442 sock.ipv4.sin_addr.s_addr = inet_addr(real_remote_addr); in URIHANDLER_FUNC()
443 sock.plain.sa_family = (sock.ipv4.sin_addr.s_addr == 0xFFFFFFFF) ? AF_UNSPEC : AF_INET; in URIHANDLER_FUNC()
445 if (sock.plain.sa_family != AF_UNSPEC) { in URIHANDLER_FUNC()
[all …]
H A Dfdevent_libmtcp.c35 ep.data.sock = fd; in fdevent_libmtcp_epoll_event_del()
75 ep.data.sock = fd; in fdevent_libmtcp_epoll_event_set()
114 return ev->_epoll_events[ndx].data.sock; in fdevent_libmtcp_epoll_event_get_fd()
/mOS-networking-stack/samples/epwget/
H A Depwget.c206 ev.data.sock = sockid; in CreateConnection()
270 ev.data.sock = sockid; in SendHTTPRequest()
327 ev.data.sock = sockid; in DownloadNext()
722 if (mtcp_getsockopt(mctx, ctx->events[i].data.sock, in RunWget()
727 CloseConnection(ctx, ctx->events[i].data.sock); in RunWget()
731 ctx->events[i].data.sock, in RunWget()
732 &ctx->wvars[ctx->events[i].data.sock]); in RunWget()
735 struct wget_vars *wv = &ctx->wvars[ctx->events[i].data.sock]; in RunWget()
738 SendHTTPRequest(ctx, ctx->events[i].data.sock, wv); in RunWget()
745 ctx->events[i].data.sock, in RunWget()
H A Depwget-mp.c205 ev.data.sock = sockid; in CreateConnection()
269 ev.data.sock = sockid; in SendHTTPRequest()
326 ev.data.sock = sockid; in DownloadNext()
720 if (mtcp_getsockopt(mctx, ctx->events[i].data.sock, in RunWget()
725 CloseConnection(ctx, ctx->events[i].data.sock); in RunWget()
729 ctx->events[i].data.sock, in RunWget()
730 &ctx->wvars[ctx->events[i].data.sock]); in RunWget()
733 struct wget_vars *wv = &ctx->wvars[ctx->events[i].data.sock]; in RunWget()
736 SendHTTPRequest(ctx, ctx->events[i].data.sock, wv); in RunWget()
743 ctx->events[i].data.sock, in RunWget()
/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);
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
88 ft_ac_match(mctx_t mctx, int sock, int side, uint64_t ev, filter_arg_t *arg) in ft_ac_match() argument
/mOS-networking-stack/samples/lighttpd-1.4.32/doc/outdated/
H A Dmysqlvhost.txt38 mysql-vhost.sock = "/var/mysql.lighttpd.sock"
H A Dconfiguration.txt204 "socket" => basedir + server.name + "/tmp/fastcgi-" + PID + ".sock"
/mOS-networking-stack/samples/simple_firewall/
H A Dsimple_firewall.c79 DumpFWRuleTable(mctx_t mctx, int sock, int side, in DumpFWRuleTable() argument
124 if (mtcp_settimer(mctx, sock, &tv_1sec, DumpFWRuleTable)) in DumpFWRuleTable()

12