Lines Matching refs:socket
244 if (stream->socket && (stream->socket->epoll & MOS_EPOLLIN)) in RaiseReadEvent()
245 AddEpollEvent(mtcp->ep, MOS_EVENT_QUEUE, stream->socket, MOS_EPOLLIN); in RaiseReadEvent()
287 if (stream->socket) { in RaiseWriteEvent()
288 if (stream->socket->epoll & MOS_EPOLLOUT) { in RaiseWriteEvent()
290 MOS_EVENT_QUEUE, stream->socket, MOS_EPOLLOUT); in RaiseWriteEvent()
300 if (stream->socket) { in RaiseCloseEvent()
301 if (stream->socket->epoll & MOS_EPOLLRDHUP) { in RaiseCloseEvent()
303 MOS_EVENT_QUEUE, stream->socket, MOS_EPOLLRDHUP); in RaiseCloseEvent()
304 } else if (stream->socket->epoll & MOS_EPOLLIN) { in RaiseCloseEvent()
306 MOS_EVENT_QUEUE, stream->socket, MOS_EPOLLIN); in RaiseCloseEvent()
316 if (stream->socket) { in RaiseErrorEvent()
317 if (stream->socket->epoll & MOS_EPOLLERR) { in RaiseErrorEvent()
320 MOS_EVENT_QUEUE, stream->socket, MOS_EPOLLERR); in RaiseErrorEvent()
339 socktype = walk->socket->socktype; in AddMonitorStreamSockets()
357 s->monitor_stream->socket = s; in AddMonitorStreamSockets()
427 CreateTCPStream(mtcp_manager_t mtcp, socket_map_t socket, int type, argument
505 if (socket) {
506 stream->socket = socket;
507 socket->stream = stream;
582 CreateDualTCPStream(mtcp_manager_t mtcp, socket_map_t socket, int type, uint32_t saddr, argument
588 cur_stream = CreateTCPStream(mtcp, socket, type,
605 paired_stream->socket = socket;
615 CreateClientTCPStream(mtcp_manager_t mtcp, socket_map_t socket, int type, argument
622 cs = CreateTCPStream(mtcp, socket, type, daddr, dport, saddr, sport, hash);
666 ss->socket = cs->socket;
912 if (stream->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,
921 socket->events, socket->events & MOS_EPOLLIN,
922 socket->events & MOS_EPOLLOUT, socket->events & MOS_EPOLLERR,
923 socket->events & MOS_EPOLLRDHUP, socket->events & MOS_EPOLLET);