| /mOS-networking-stack/core/src/ |
| H A D | pipe.c | 222 if ((socket->epoll & MOS_EPOLLIN) && !(socket->epoll & MOS_EPOLLET)) { in PipeRead()
224 USR_SHADOW_EVENT_QUEUE, socket, MOS_EPOLLIN); in PipeRead()
227 AddEpollEvent(mtcp->ep, USR_SHADOW_EVENT_QUEUE, socket, MOS_EPOLLIN); in PipeRead()
317 RaiseEventToPair(mtcp, socket, MOS_EPOLLIN); in PipeWrite()
347 if (socket->epoll & MOS_EPOLLIN) { in RaisePendingPipeEvents()
349 AddEpollEvent(ep, USR_SHADOW_EVENT_QUEUE, socket, MOS_EPOLLIN); in RaisePendingPipeEvents()
351 AddEpollEvent(ep, USR_SHADOW_EVENT_QUEUE, socket, MOS_EPOLLIN); in RaisePendingPipeEvents()
396 RaiseEventToPair(mtcp, socket, MOS_EPOLLIN); in PipeClose()
|
| H A D | eventpoll.c | 33 case MOS_EPOLLIN: in EventToString()
214 if (socket->epoll & MOS_EPOLLIN) { in RaisePendingStreamEvents()
218 AddEpollEvent(ep, USR_SHADOW_EVENT_QUEUE, socket, MOS_EPOLLIN); in RaisePendingStreamEvents()
221 AddEpollEvent(ep, USR_SHADOW_EVENT_QUEUE, socket, MOS_EPOLLIN); in RaisePendingStreamEvents()
298 (unsigned long long)socket->epoll & MOS_EPOLLIN, in mtcp_epoll_ctl()
|
| H A D | tcp_stream.c | 244 if (stream->socket && (stream->socket->epoll & MOS_EPOLLIN)) in RaiseReadEvent()
245 AddEpollEvent(mtcp->ep, MOS_EVENT_QUEUE, stream->socket, MOS_EPOLLIN); in RaiseReadEvent()
270 eq->events[index].ev.events = MOS_EPOLLIN; in RaiseReadEvent()
304 } else if (stream->socket->epoll & MOS_EPOLLIN) { in RaiseCloseEvent()
306 MOS_EVENT_QUEUE, stream->socket, MOS_EPOLLIN); in RaiseCloseEvent()
918 socket->epoll, socket->epoll & MOS_EPOLLIN,
921 socket->events, socket->events & MOS_EPOLLIN,
|
| H A D | api.c | 897 listener->socket, MOS_EPOLLIN); in mtcp_accept()
1587 if (socket->epoll & MOS_EPOLLIN) { in mtcp_recv()
1603 USR_SHADOW_EVENT_QUEUE, socket, MOS_EPOLLIN); in mtcp_recv()
1702 if (socket->epoll & MOS_EPOLLIN) { in mtcp_readv()
1716 if (socket->epoll & MOS_EPOLLIN && !(socket->epoll & MOS_EPOLLET)) { in mtcp_readv()
1718 USR_SHADOW_EVENT_QUEUE, socket, MOS_EPOLLIN); in mtcp_readv()
|
| H A D | tcp_in.c | 690 cur_stream->socket? (unsigned long long)cur_stream->socket->epoll & MOS_EPOLLIN : 0, in ProcessTCPPayload()
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 D | core.c | 493 (cur_stream->socket->events | MOS_EPOLLIN)) { in FlushBufferedReadEvents()
|
| /mOS-networking-stack/samples/epserver/ |
| H A D | epserver-mp.c | 158 ev.events = MOS_EPOLLIN; in SendUntilAvailable()
260 ev.events = MOS_EPOLLIN | MOS_EPOLLOUT; in HandleReadEvent()
288 ev.events = MOS_EPOLLIN; in AcceptConnection()
343 ev.events = MOS_EPOLLIN; in CreateListeningSocket()
525 } else if (events[i].events & MOS_EPOLLIN) { in RunServer()
|
| H A D | epserver.c | 159 ev.events = MOS_EPOLLIN; in SendUntilAvailable()
261 ev.events = MOS_EPOLLIN | MOS_EPOLLOUT; in HandleReadEvent()
289 ev.events = MOS_EPOLLIN; in AcceptConnection()
344 ev.events = MOS_EPOLLIN; in CreateListeningSocket()
526 } else if (events[i].events & MOS_EPOLLIN) { in RunServer()
|
| /mOS-networking-stack/samples/lighttpd-1.4.32/src/ |
| H A D | fdevent_libmtcp.c | 61 if (events & FDEVENT_IN) ep.events |= MOS_EPOLLIN; in fdevent_libmtcp_epoll_event_set()
102 if (e & MOS_EPOLLIN) events |= FDEVENT_IN; in fdevent_libmtcp_epoll_event_get_revent()
|
| /mOS-networking-stack/core/include/ |
| H A D | mtcp_epoll.h | 23 MOS_EPOLLIN = (0x1<<1), enumerator
|
| /mOS-networking-stack/core/src/include/ |
| H A D | mtcp_epoll.h | 23 MOS_EPOLLIN = (0x1<<1), enumerator
|
| /mOS-networking-stack/samples/common/ |
| H A D | applib.c | 24 EV_CASE(MOS_EPOLLIN); in strevent()
|
| /mOS-networking-stack/samples/epwget/ |
| H A D | epwget.c | 269 ev.events = MOS_EPOLLIN; in SendHTTPRequest()
729 } else if (ctx->events[i].events & MOS_EPOLLIN) { in RunWget()
|
| H A D | epwget-mp.c | 268 ev.events = MOS_EPOLLIN; in SendHTTPRequest()
727 } else if (ctx->events[i].events & MOS_EPOLLIN) { in RunWget()
|