Home
last modified time | relevance | path

Searched refs:eventLoop (Results 1 – 10 of 10) sorted by relevance

/f-stack/app/redis-5.0.5/src/
H A Dae.c71 if ((eventLoop = zmalloc(sizeof(*eventLoop))) == NULL) goto err; in aeCreateEventLoop()
74 if (eventLoop->events == NULL || eventLoop->fired == NULL) goto err; in aeCreateEventLoop()
79 eventLoop->stop = 0; in aeCreateEventLoop()
88 return eventLoop; in aeCreateEventLoop()
91 if (eventLoop) { in aeCreateEventLoop()
119 eventLoop->fired = zrealloc(eventLoop->fired,sizeof(aeFiredEvent)*setsize); in aeResizeSetSize()
133 zfree(eventLoop); in aeDeleteEventLoop()
137 eventLoop->stop = 1; in aeStop()
423 eventLoop->aftersleep(eventLoop); in aeProcessEvents()
426 aeFileEvent *fe = &eventLoop->events[eventLoop->fired[j].fd]; in aeProcessEvents()
[all …]
H A Dae.h68 typedef void aeBeforeSleepProc(struct aeEventLoop *eventLoop);
113 void aeDeleteEventLoop(aeEventLoop *eventLoop);
114 void aeStop(aeEventLoop *eventLoop);
115 int aeCreateFileEvent(aeEventLoop *eventLoop, int fd, int mask,
117 void aeDeleteFileEvent(aeEventLoop *eventLoop, int fd, int mask);
118 int aeGetFileEvents(aeEventLoop *eventLoop, int fd);
122 int aeDeleteTimeEvent(aeEventLoop *eventLoop, long long id);
123 int aeProcessEvents(aeEventLoop *eventLoop, int flags);
125 void aeMain(aeEventLoop *eventLoop);
129 int aeGetSetSize(aeEventLoop *eventLoop);
[all …]
H A Dae_select.c42 static int aeApiCreate(aeEventLoop *eventLoop) { in aeApiCreate() argument
48 eventLoop->apidata = state; in aeApiCreate()
58 static void aeApiFree(aeEventLoop *eventLoop) { in aeApiFree() argument
59 zfree(eventLoop->apidata); in aeApiFree()
63 aeApiState *state = eventLoop->apidata; in aeApiAddEvent()
71 aeApiState *state = eventLoop->apidata; in aeApiDelEvent()
78 aeApiState *state = eventLoop->apidata; in aeApiPoll()
84 retval = select(eventLoop->maxfd+1, in aeApiPoll()
87 for (j = 0; j <= eventLoop->maxfd; j++) { in aeApiPoll()
89 aeFileEvent *fe = &eventLoop->events[j]; in aeApiPoll()
[all …]
H A Dae_epoll.c39 static int aeApiCreate(aeEventLoop *eventLoop) { in aeApiCreate() argument
54 eventLoop->apidata = state; in aeApiCreate()
59 aeApiState *state = eventLoop->apidata; in aeApiResize()
65 static void aeApiFree(aeEventLoop *eventLoop) { in aeApiFree() argument
66 aeApiState *state = eventLoop->apidata; in aeApiFree()
74 aeApiState *state = eventLoop->apidata; in aeApiAddEvent()
78 int op = eventLoop->events[fd].mask == AE_NONE ? in aeApiAddEvent()
91 aeApiState *state = eventLoop->apidata; in aeApiDelEvent()
109 aeApiState *state = eventLoop->apidata; in aeApiPoll()
126 eventLoop->fired[j].fd = e->data.fd; in aeApiPoll()
[all …]
H A Dae_ff_kqueue.c43 static int aeApiCreate(aeEventLoop *eventLoop) { in aeApiCreate() argument
58 eventLoop->apidata = state; in aeApiCreate()
62 static int aeApiResize(aeEventLoop *eventLoop, int setsize) { in aeApiResize() argument
63 aeApiState *state = eventLoop->apidata; in aeApiResize()
69 static void aeApiFree(aeEventLoop *eventLoop) { in aeApiFree() argument
70 aeApiState *state = eventLoop->apidata; in aeApiFree()
78 aeApiState *state = eventLoop->apidata; in aeApiAddEvent()
93 aeApiState *state = eventLoop->apidata; in aeApiDelEvent()
107 aeApiState *state = eventLoop->apidata; in aeApiPoll()
131 eventLoop->fired[j].fd = e->ident; in aeApiPoll()
[all …]
H A Dae_kqueue.c41 static int aeApiCreate(aeEventLoop *eventLoop) { in aeApiCreate() argument
56 eventLoop->apidata = state; in aeApiCreate()
60 static int aeApiResize(aeEventLoop *eventLoop, int setsize) { in aeApiResize() argument
61 aeApiState *state = eventLoop->apidata; in aeApiResize()
67 static void aeApiFree(aeEventLoop *eventLoop) { in aeApiFree() argument
68 aeApiState *state = eventLoop->apidata; in aeApiFree()
76 aeApiState *state = eventLoop->apidata; in aeApiAddEvent()
91 aeApiState *state = eventLoop->apidata; in aeApiDelEvent()
105 aeApiState *state = eventLoop->apidata; in aeApiPoll()
129 eventLoop->fired[j].fd = e->ident; in aeApiPoll()
[all …]
H A Dae_evport.c75 static int aeApiCreate(aeEventLoop *eventLoop) { in aeApiCreate() argument
93 eventLoop->apidata = state; in aeApiCreate()
97 static int aeApiResize(aeEventLoop *eventLoop, int setsize) { in aeApiResize() argument
102 static void aeApiFree(aeEventLoop *eventLoop) { in aeApiFree() argument
103 aeApiState *state = eventLoop->apidata; in aeApiFree()
153 aeApiState *state = eventLoop->apidata; in aeApiAddEvent()
164 fullmask = mask | eventLoop->events[fd].mask; in aeApiAddEvent()
184 aeApiState *state = eventLoop->apidata; in aeApiDelEvent()
217 fullmask = eventLoop->events[fd].mask; in aeApiDelEvent()
244 aeApiState *state = eventLoop->apidata; in aeApiPoll()
[all …]
H A Dredis-benchmark.c612 int showThroughput(struct aeEventLoop *eventLoop, long long id, void *clientData) { in showThroughput() argument
613 UNUSED(eventLoop); in showThroughput()
H A Dserver.c1096 int serverCron(struct aeEventLoop *eventLoop, long long id, void *clientData) { in serverCron() argument
1098 UNUSED(eventLoop); in serverCron()
1365 void beforeSleep(struct aeEventLoop *eventLoop) { in beforeSleep() argument
1366 UNUSED(eventLoop); in beforeSleep()
1422 void afterSleep(struct aeEventLoop *eventLoop) { in afterSleep() argument
1423 UNUSED(eventLoop); in afterSleep()
H A Dmodule.c4303 int moduleTimerHandler(struct aeEventLoop *eventLoop, long long id, void *clientData) { in moduleTimerHandler() argument
4304 UNUSED(eventLoop); in moduleTimerHandler()