Home
last modified time | relevance | path

Searched refs:ep (Results 1 – 19 of 19) sorted by relevance

/mOS-networking-stack/core/src/
H A Deventpoll.c110 if (!ep) { in mtcp_epoll_create()
119 free(ep); in mtcp_epoll_create()
127 free(ep); in mtcp_epoll_create()
136 free(ep); in mtcp_epoll_create()
142 mtcp->ep = ep; in mtcp_epoll_create()
143 epsocket->ep = ep; in mtcp_epoll_create()
150 free(ep); in mtcp_epoll_create()
176 ep = mtcp->smap[epid].ep; in CloseEpollSocket()
194 free(ep); in CloseEpollSocket()
276 ep = mtcp->smap[epid].ep; in mtcp_epoll_ctl()
[all …]
H A Dpipe.c123 AddEpollEvent(mtcp->ep, USR_EVENT_QUEUE, pair_socket, event); in RaiseEventToPair()
223 AddEpollEvent(mtcp->ep, in PipeRead()
227 AddEpollEvent(mtcp->ep, USR_SHADOW_EVENT_QUEUE, socket, MOS_EPOLLIN); in PipeRead()
325 AddEpollEvent(mtcp->ep, in PipeWrite()
336 struct mtcp_epoll *ep = GetSocket(mctx, epid)->ep; in RaisePendingPipeEvents() local
349 AddEpollEvent(ep, USR_SHADOW_EVENT_QUEUE, socket, MOS_EPOLLIN); in RaisePendingPipeEvents()
351 AddEpollEvent(ep, USR_SHADOW_EVENT_QUEUE, socket, MOS_EPOLLIN); in RaisePendingPipeEvents()
358 AddEpollEvent(ep, USR_SHADOW_EVENT_QUEUE, socket, MOS_EPOLLOUT); in RaisePendingPipeEvents()
H A Dcore.c412 if (running[i] && g_mtcp[i]->ep) { in PrintNetworkStats()
477 if (mtcp->ep == NULL) { in FlushBufferedReadEvents()
482 mtcpq = mtcp->ep->mtcp_queue; in FlushBufferedReadEvents()
519 struct mtcp_epoll *ep = mtcp->ep; in FlushEpollEvents() local
523 pthread_mutex_lock(&ep->epoll_lock); in FlushEpollEvents()
542 if (ep->waiting && (ep->usr_queue->num_events > 0 || in FlushEpollEvents()
548 ep->stat.wakes++; in FlushEpollEvents()
824 if (mtcp->ep) { in InterruptApplication()
826 if (mtcp->ep->waiting) { in InterruptApplication()
978 if (mtcp->ep) { in RunMainLoop()
[all …]
H A Dtcp_stream.c245 AddEpollEvent(mtcp->ep, MOS_EVENT_QUEUE, stream->socket, MOS_EPOLLIN); in RaiseReadEvent()
289 AddEpollEvent(mtcp->ep, in RaiseWriteEvent()
302 AddEpollEvent(mtcp->ep, in RaiseCloseEvent()
305 AddEpollEvent(mtcp->ep, in RaiseCloseEvent()
319 return AddEpollEvent(mtcp->ep, in RaiseErrorEvent()
H A Dapi.c895 AddEpollEvent(mtcp->ep, in mtcp_accept()
1602 AddEpollEvent(mtcp->ep, in mtcp_recv()
1717 AddEpollEvent(mtcp->ep, in mtcp_readv()
1847 AddEpollEvent(mtcp->ep, in mtcp_write()
1934 AddEpollEvent(mtcp->ep, in mtcp_writev()
H A Dtcp_in.c875 AddEpollEvent(mtcp->ep, in Handle_TCP_ST_SYN_RCVD()
/mOS-networking-stack/samples/lighttpd-1.4.32/src/
H A Dfdevent_linux_sysepoll.c25 struct epoll_event ep; in fdevent_linux_sysepoll_event_del() local
29 memset(&ep, 0, sizeof(ep)); in fdevent_linux_sysepoll_event_del()
31 ep.data.fd = fd; in fdevent_linux_sysepoll_event_del()
32 ep.data.ptr = NULL; in fdevent_linux_sysepoll_event_del()
48 struct epoll_event ep; in fdevent_linux_sysepoll_event_set() local
53 memset(&ep, 0, sizeof(ep)); in fdevent_linux_sysepoll_event_set()
55 ep.events = 0; in fdevent_linux_sysepoll_event_set()
57 if (events & FDEVENT_IN) ep.events |= EPOLLIN; in fdevent_linux_sysepoll_event_set()
58 if (events & FDEVENT_OUT) ep.events |= EPOLLOUT; in fdevent_linux_sysepoll_event_set()
70 ep.data.ptr = NULL; in fdevent_linux_sysepoll_event_set()
[all …]
H A Dfdevent_libmtcp.c33 memset(&ep, 0, sizeof(ep)); in fdevent_libmtcp_epoll_event_del()
35 ep.data.sock = fd; in fdevent_libmtcp_epoll_event_del()
36 ep.data.ptr = NULL; in fdevent_libmtcp_epoll_event_del()
54 struct mtcp_epoll_event ep; in fdevent_libmtcp_epoll_event_set() local
59 ep.events = 0; in fdevent_libmtcp_epoll_event_set()
61 if (events & FDEVENT_IN) ep.events |= MOS_EPOLLIN; in fdevent_libmtcp_epoll_event_set()
62 if (events & FDEVENT_OUT) ep.events |= MOS_EPOLLOUT; in fdevent_libmtcp_epoll_event_set()
72 ep.events |= MOS_EPOLLERR | MOS_EPOLLHUP /* | EPOLLET */; in fdevent_libmtcp_epoll_event_set()
75 ep.data.sock = fd; in fdevent_libmtcp_epoll_event_set()
77 …tcp_epoll_ctl(ev->srv->mctx, ev->epoll_fd, add ? MOS_EPOLL_CTL_ADD : MOS_EPOLL_CTL_MOD, fd, &ep)) { in fdevent_libmtcp_epoll_event_set()
H A Dhttp_auth.c459 const char *sp, *ep; in apr_md5_encode() local
482 for (ep = sp; (*ep != '\0') && (*ep != '$') && (ep < (sp + 8)); ep++) { in apr_md5_encode()
489 sl = ep - sp; in apr_md5_encode()
H A Dlemon.c1581 char *ep; local
1587 ep = list;
1589 NEXT(ep) = 0;
1591 ep = merge(ep,set[i],cmp,offset);
1594 set[i] = ep;
1596 ep = 0;
1597 for(i=0; i<LISTSIZE; i++) if( set[i] ) ep = merge(ep,set[i],cmp,offset);
1598 return ep;
/mOS-networking-stack/core/src/bpf/
H A Dsf_optimize.c309 SET_INSERT(ep->edom, ep->id);
310 if (ep->succ)
312 SET_INTERSECT(ep->succ->et.edom, ep->edom, edgewords);
313 SET_INTERSECT(ep->succ->ef.edom, ep->edom, edgewords);
1435 if (JT(ep->succ) == JF(ep->succ))
1441 if (!use_conflict(ep->pred, ep->succ->et.succ))
1444 ep->succ = JT(ep->succ);
1503 for (ep = ep->next; ep != 0; ep = ep->next)
1568 for (ep = b->in_edges; ep != 0; ep = ep->next)
1598 for (ep = ep->next; ep != 0; ep = ep->next)
[all …]
H A Dsf_nametoaddr.c416 register u_char *ep, *e; in pcap_ether_aton() local
419 e = ep = (u_char *) malloc(6); in pcap_ether_aton()
433 *ep++ = d; in pcap_ether_aton()
443 register struct pcap_etherent *ep; in pcap_ether_hostton() local
460 while ((ep = pcap_next_etherent(fp)) != NULL) in pcap_ether_hostton()
462 if (strcmp(ep->name, name) == 0) in pcap_ether_hostton()
467 memcpy(ap, ep->addr, 6); in pcap_ether_hostton()
/mOS-networking-stack/samples/epserver/
H A Depserver-mp.c71 int ep; member
115 mtcp_epoll_ctl(ctx->mctx, ctx->ep, MOS_EPOLL_CTL_DEL, sockid, NULL); in CloseConnection()
160 mtcp_epoll_ctl(ctx->mctx, ctx->ep, MOS_EPOLL_CTL_MOD, sockid, &ev); in SendUntilAvailable()
262 mtcp_epoll_ctl(ctx->mctx, ctx->ep, MOS_EPOLL_CTL_MOD, sockid, &ev); in HandleReadEvent()
291 mtcp_epoll_ctl(mctx, ctx->ep, MOS_EPOLL_CTL_ADD, c, &ev); in AcceptConnection()
345 mtcp_epoll_ctl(ctx->mctx, ctx->ep, MOS_EPOLL_CTL_ADD, listener, &ev); in CreateListeningSocket()
445 ctx->ep = mtcp_epoll_create(mctx, MAX_EVENTS); in InitServer()
446 if (ctx->ep < 0) { in InitServer()
480 int ep = ctx->ep; in RunServer() local
490 nevents = mtcp_epoll_wait(mctx, ep, events, MAX_EVENTS, -1); in RunServer()
H A Depserver.c72 int ep; member
116 mtcp_epoll_ctl(ctx->mctx, ctx->ep, MOS_EPOLL_CTL_DEL, sockid, NULL); in CloseConnection()
161 mtcp_epoll_ctl(ctx->mctx, ctx->ep, MOS_EPOLL_CTL_MOD, sockid, &ev); in SendUntilAvailable()
263 mtcp_epoll_ctl(ctx->mctx, ctx->ep, MOS_EPOLL_CTL_MOD, sockid, &ev); in HandleReadEvent()
292 mtcp_epoll_ctl(mctx, ctx->ep, MOS_EPOLL_CTL_ADD, c, &ev); in AcceptConnection()
346 mtcp_epoll_ctl(ctx->mctx, ctx->ep, MOS_EPOLL_CTL_ADD, listener, &ev); in CreateListeningSocket()
446 ctx->ep = mtcp_epoll_create(mctx, MAX_EVENTS); in InitServer()
447 if (ctx->ep < 0) { in InitServer()
481 int ep = ctx->ep; in RunServer() local
491 nevents = mtcp_epoll_wait(mctx, ep, events, MAX_EVENTS, -1); in RunServer()
/mOS-networking-stack/samples/epwget/
H A Depwget.c97 int ep; member
207 mtcp_epoll_ctl(mctx, ctx->ep, MOS_EPOLL_CTL_ADD, sockid, &ev); in CreateConnection()
215 mtcp_epoll_ctl(ctx->mctx, ctx->ep, MOS_EPOLL_CTL_DEL, sockid, NULL); in CloseConnection()
271 mtcp_epoll_ctl(ctx->mctx, ctx->ep, MOS_EPOLL_CTL_MOD, sockid, &ev); in SendHTTPRequest()
328 mtcp_epoll_ctl(mctx, ctx->ep, MOS_EPOLL_CTL_MOD, sockid, &ev); in DownloadNext()
611 int ep; in InitWget() local
634 ep = mtcp_epoll_create(mctx, ctx->maxevents); in InitWget()
635 if (ep < 0) { in InitWget()
645 ctx->ep = ep; in InitWget()
698 nevents = mtcp_epoll_wait(mctx, ctx->ep, in RunWget()
H A Depwget-mp.c96 int ep; member
206 mtcp_epoll_ctl(mctx, ctx->ep, MOS_EPOLL_CTL_ADD, sockid, &ev); in CreateConnection()
214 mtcp_epoll_ctl(ctx->mctx, ctx->ep, MOS_EPOLL_CTL_DEL, sockid, NULL); in CloseConnection()
270 mtcp_epoll_ctl(ctx->mctx, ctx->ep, MOS_EPOLL_CTL_MOD, sockid, &ev); in SendHTTPRequest()
327 mtcp_epoll_ctl(mctx, ctx->ep, MOS_EPOLL_CTL_MOD, sockid, &ev); in DownloadNext()
609 int ep; in InitWget() local
632 ep = mtcp_epoll_create(mctx, ctx->maxevents); in InitWget()
633 if (ep < 0) { in InitWget()
643 ctx->ep = ep; in InitWget()
696 nevents = mtcp_epoll_wait(mctx, ctx->ep, in RunWget()
/mOS-networking-stack/core/src/include/
H A Dsocket.h120 struct mtcp_epoll *ep; member
H A Dmtcp.h238 struct mtcp_epoll *ep; member
H A Dtcp_stream.h289 AddEpollEvent(struct mtcp_epoll *ep,