Home
last modified time | relevance | path

Searched refs:socket (Results 1 – 25 of 40) sorted by relevance

12

/mOS-networking-stack/core/src/
H A Dpipe.c47 if (!socket[0]) { in mtcp_pipe()
52 if (!socket[1]) { in mtcp_pipe()
98 pp->socket[0] = socket[0]; in mtcp_pipe()
99 pp->socket[1] = socket[1]; in mtcp_pipe()
116 if (pp->socket[0] == socket) in RaiseEventToPair()
145 if (!socket) { in PipeRead()
152 pp = socket->pp; in PipeRead()
248 if (!socket) { in PipeWrite()
255 pp = socket->pp; in PipeWrite()
377 if (!socket) { in PipeClose()
[all …]
H A Dsocket.c60 mstream->socket = NULL; in FreeMonStream()
82 if (!socket) in AllocateSocket()
87 if (socket->events) { in AllocateSocket()
91 socket = NULL; in AllocateSocket()
99 if (!socket) in AllocateSocket()
108 socket = NULL; in AllocateSocket()
121 socket->opts = 0; in AllocateSocket()
122 socket->epoll = 0; in AllocateSocket()
123 socket->events = 0; in AllocateSocket()
125 return socket; in AllocateSocket()
[all …]
H A Dapi.c77 if (!socket->stream) { in GetSocketError()
133 socket_map_t socket; in mtcp_getsockname() local
177 socket_map_t socket; in mtcp_getsockopt() local
264 socket_map_t socket; in mtcp_setsockopt() local
495 socket_map_t socket; in mtcp_ioctl() local
626 socket_map_t socket; in mtcp_socket() local
651 if (!socket) { in mtcp_socket()
675 return socket->id; in mtcp_socket()
874 if (!socket) { in mtcp_accept()
881 accepted->socket = socket; in mtcp_accept()
[all …]
H A Deventpoll.c246 socket_map_t socket; in mtcp_epoll_ctl() local
281 socket = &mtcp->smap[sockid]; in mtcp_epoll_ctl()
284 if (socket->epoll) { in mtcp_epoll_ctl()
293 socket->epoll = events; in mtcp_epoll_ctl()
296 socket->id, socket->socktype, in mtcp_epoll_ctl()
308 if (!socket->epoll) { in mtcp_epoll_ctl()
317 socket->epoll = events; in mtcp_epoll_ctl()
326 if (!socket->epoll) { in mtcp_epoll_ctl()
553 if (!ep || !socket || !event) in AddEpollEvent()
558 if (socket->events & event) { in AddEpollEvent()
[all …]
H A Dmos_api.c456 socket_map_t socket; in mtcp_getlastpkt() local
472 socket = &mtcp->msmap[sock]; in mtcp_getlastpkt()
474 switch (socket->socktype) { in mtcp_getlastpkt()
558 socket_map_t socket; in mtcp_sendpkt() local
573 socket = &mtcp->msmap[sock]; in mtcp_sendpkt()
618 switch (socket->socktype) { in RemoveMonitorEvents()
708 socket_map_t socket; in mtcp_cb_stop() local
719 socket = &mtcp->msmap[sock]; in mtcp_cb_stop()
795 socket_map_t socket; in mtcp_reset_conn() local
852 socket_map_t socket; in mtcp_getpeername() local
[all …]
H A Dtcp_stream.c244 if (stream->socket && (stream->socket->epoll & MOS_EPOLLIN)) in RaiseReadEvent()
505 if (socket) {
506 stream->socket = socket;
605 paired_stream->socket = socket;
666 ss->socket = cs->socket;
913 socket_map_t socket = stream->socket; local
917 socket->id, socket->socktype, socket->opts,
918 socket->epoll, socket->epoll & MOS_EPOLLIN,
919 socket->epoll & MOS_EPOLLOUT, socket->epoll & MOS_EPOLLERR,
920 socket->epoll & MOS_EPOLLRDHUP, socket->epoll & MOS_EPOLLET,
[all …]
H A Devent_callback.c429 socket_map_t socket; in ModifyCallback() local
447 socket = &mtcp->msmap[sockid]; in ModifyCallback()
451 evp = &socket->monitor_stream->dontcare_evp; in ModifyCallback()
454 evp = &socket->monitor_stream->pre_tcp_evp; in ModifyCallback()
457 evp = &socket->monitor_stream->post_tcp_evp; in ModifyCallback()
463 || socket->socktype == MOS_SOCK_MONITOR_RAW) { in ModifyCallback()
467 evb = &socket->monitor_listener->pre_tcp_evb; in ModifyCallback()
607 if (!socket) in HandleCallback()
628 &MSTRM(socket)->dontcare_evp) in HandleCallback()
643 fcode = MLSNR(socket)->stream_orphan_fcode; in HandleCallback()
[all …]
H A Dscalable_event.c942 socket_map_t socket; in mtcp_register_callback() local
986 socket = &mtcp->msmap[sockid]; in mtcp_register_callback()
1029 if (!socket) in HandleCallback()
1050 MSTRM(socket)->stree_dontcare) in HandleCallback()
1051 : (socket->socktype == MOS_SOCK_MONITOR_STREAM) in HandleCallback()
1052 || (socket->socktype == MOS_SOCK_MONITOR_RAW) ? in HandleCallback()
1055 MLSNR(socket)->stree_dontcare) : in HandleCallback()
1067 fcode = MLSNR(socket)->stream_orphan_fcode; in HandleCallback()
1074 if (socket->socktype == MOS_SOCK_MONITOR_RAW) { in HandleCallback()
1075 fcode = MLSNR(socket)->raw_pkt_fcode; in HandleCallback()
[all …]
H A Dip_in.c57 if (walk->socket->socktype == MOS_SOCK_MONITOR_RAW) { in ProcessInIPv4Packet()
61 HandleCallback(mtcp, MOS_NULL, walk->socket, MOS_SIDE_BOTH, in ProcessInIPv4Packet()
H A Dtcp_in.c39 addr = &mtcp->listener->socket->saddr; in FilterSYNPacket()
689 cur_stream->socket? (unsigned long long)cur_stream->socket->epoll & MOS_EPOLLET : 0, in ProcessTCPPayload()
690 cur_stream->socket? (unsigned long long)cur_stream->socket->epoll & MOS_EPOLLIN : 0, in ProcessTCPPayload()
691 cur_stream->socket? (unsigned long long)cur_stream->socket->epoll & MOS_EPOLLOUT : 0); in ProcessTCPPayload()
757 if (cur_stream->socket) { in Handle_TCP_ST_SYN_SENT()
794 if (cur_stream->socket) { in Handle_TCP_ST_SYN_SENT()
874 if (listener->socket && (listener->socket->epoll & MOS_EPOLLIN)) { in Handle_TCP_ST_SYN_RCVD()
876 MOS_EVENT_QUEUE, listener->socket, MOS_EPOLLIN); in Handle_TCP_ST_SYN_RCVD()
H A Dtcp.c44 socktype = walk->socket->socktype; in DetectStreamType()
66 addr = &mtcp->listener->socket->saddr; in DetectStreamType()
425 if (walk->socket->socktype == MOS_SOCK_MONITOR_RAW) in ProcessInTCPPacket()
426 HandleCallback(mtcp, MOS_NULL, walk->socket, MOS_SIDE_BOTH, in ProcessInTCPPacket()
493 HandleCallback(mtcp, MOS_NULL, walk->socket, MOS_SIDE_BOTH, in ProcessInTCPPacket()
/mOS-networking-stack/core/src/include/
H A Dtcp_stream.h33 #define SOCKQ_INSERT_TAIL(head, socket) \ argument
38 __s->sock = (socket); \
42 #define SOCKQ_REMOVE(head, socket) \ argument
47 if ((socket) == __walk->sock) break; \
234 socket_map_t socket; /* relating to MOS_SOCK_STREAM */ member
290 int queue_type, socket_map_t socket, uint32_t event);
305 CreateTCPStream(mtcp_manager_t mtcp, socket_map_t socket, int type,
310 CreateDualTCPStream(mtcp_manager_t mtcp, socket_map_t socket, int type, uint32_t saddr,
314 CreateClientTCPStream(mtcp_manager_t mtcp, socket_map_t socket, int type,
H A Dsocket.h29 socket_map_t socket; member
40 socket_map_t socket; member
79 socket_map_t socket; member
H A Devent_callback.h78 socket_map_t socket, int side, struct pkt_ctx *pctx, event_t events);
H A Dscalable_event.h75 socket_map_t socket, int side, struct pkt_ctx *pctx, event_t events);
/mOS-networking-stack/samples/lighttpd-1.4.32/src/
H A Dmod_scgi.c395 f->socket = buffer_init(); in scgi_process_init()
408 buffer_free(f->socket); in scgi_process_free()
583 unlink(proc->socket->ptr); in FREE_FUNC()
739 unlink(proc->socket->ptr); in scgi_spawn_connection()
762 proc->socket, in scgi_spawn_connection()
904 proc->socket); in scgi_spawn_connection()
1375 proc->port, proc->socket); in scgi_establish_connection()
2074 proc->socket, in scgi_restart_dead_procs()
2288 hctx->proc->socket, in scgi_write_request()
2398 proc->socket); in SUBREQUEST_FUNC()
[all …]
/mOS-networking-stack/samples/lighttpd-1.4.32/doc/outdated/
H A Dfastcgi.txt98 "socket" => <string>, # either socket
126 :"socket": path to the unix-domain socket
247 - IP, port, unix-socket (is empty here)
290 (( "socket" => "/tmp/php.socket",
316 (( "socket" => "/tmp/php.socket",
325 It will create one socket and let's PHP create the 384 processes itself.
376 (( "socket" => "/tmp/php-fastcgi.socket",
387 (( "socket" => "/tmp/php-fastcgi.socket",
400 (( "socket" => "/tmp/php-fastcgi.socket",
421 (( "socket" => "/tmp/php-fastcgi.socket",
[all …]
H A Dconfiguration.txt108 $SERVER["socket"]
109 match on socket. Value must be on the format "ip:port" where ip is an IP
111 It also binds the daemon to this socket. Use this if you want to do IP/port-
146 $SERVER["socket"] == "127.0.0.1:81" {
150 $SERVER["socket"] == "127.0.0.1:443" {
204 "socket" => basedir + server.name + "/tmp/fastcgi-" + PID + ".sock"
263 IP address, hostname or absolute path to the unix-domain socket the server
272 server.bind = "/tmp/lighttpd.socket"
282 bind to the IPv6 socket
285 set TCP_DEFER_ACCEPT to the specified value on the socket if the value is > 0
H A Dperformance.txt99 to copy the file into the webserver just to write() it back into a socket
147 1. the TCP/IP socket to the client
148 2. the TCP/IP and Unix domain socket to the FastCGI process
217 Keep in mind that every TCP connection uses the configured amount of memory for socket
H A Dextforward.txt20 $HTTP{''socket"} directive, crashing in config_check_cond while patching
34 - Fixed at least one segfault with SERVER['socket']
H A Dssl.txt39 $SERVER["socket"] == "10.0.0.1:443" {
/mOS-networking-stack/samples/lighttpd-1.4.32/
H A DSConstruct125 sys/socket.h
126 sys/types.h sys/socket.h
159 strdup strerror strstr strtol sendfile getopt socket \
218 …if autoconf.CheckType('socklen_t', '#include <unistd.h>\n#include <sys/socket.h>\n#include <sys/ty…
221 if autoconf.CheckType('struct sockaddr_storage', '#include <sys/socket.h>\n'):
H A Dconfigure.ac61 sys/socket.h sys/time.h unistd.h sys/sendfile.h sys/uio.h \
75 AC_CHECK_TYPES(struct sockaddr_storage,,,[#include <sys/socket.h>])
77 #include <sys/socket.h>])
222 AC_SEARCH_LIBS(socket,socket)
223 AC_SEARCH_LIBS(gethostbyname,nsl socket)
511 strdup strerror strstr strtol sendfile getopt socket lstat \
566 #include <sys/socket.h>
/mOS-networking-stack/util/
H A Dnetlib.c61 if ((s = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) < 0) { in CreateServerSocket()
119 if ((fd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) < 0) { in CreateConnectionSocket()
/mOS-networking-stack/samples/lighttpd-1.4.32/doc/config/vhosts.d/
H A Dvhosts.template24 $SERVER["socket"] == "127.0.0.1:443" {

12