Home
last modified time | relevance | path

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

/redis-3.2.3/src/
H A Dae.c67 if ((eventLoop = zmalloc(sizeof(*eventLoop))) == NULL) goto err; in aeCreateEventLoop()
70 if (eventLoop->events == NULL || eventLoop->fired == NULL) goto err; in aeCreateEventLoop()
75 eventLoop->stop = 0; in aeCreateEventLoop()
83 return eventLoop; in aeCreateEventLoop()
86 if (eventLoop) { in aeCreateEventLoop()
89 zfree(eventLoop); in aeCreateEventLoop()
114 eventLoop->fired = zrealloc(eventLoop->fired,sizeof(aeFiredEvent)*setsize); in aeResizeSetSize()
128 zfree(eventLoop); in aeDeleteEventLoop()
132 eventLoop->stop = 1; in aeStop()
402 aeFileEvent *fe = &eventLoop->events[eventLoop->fired[j].fd]; in aeProcessEvents()
[all …]
H A Dae.h62 typedef void aeBeforeSleepProc(struct aeEventLoop *eventLoop);
105 void aeDeleteEventLoop(aeEventLoop *eventLoop);
106 void aeStop(aeEventLoop *eventLoop);
107 int aeCreateFileEvent(aeEventLoop *eventLoop, int fd, int mask,
109 void aeDeleteFileEvent(aeEventLoop *eventLoop, int fd, int mask);
110 int aeGetFileEvents(aeEventLoop *eventLoop, int fd);
114 int aeDeleteTimeEvent(aeEventLoop *eventLoop, long long id);
115 int aeProcessEvents(aeEventLoop *eventLoop, int flags);
117 void aeMain(aeEventLoop *eventLoop);
120 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_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.c1090 int serverCron(struct aeEventLoop *eventLoop, long long id, void *clientData) { in serverCron() argument
1092 UNUSED(eventLoop); in serverCron()
1312 void beforeSleep(struct aeEventLoop *eventLoop) { in beforeSleep() argument
1313 UNUSED(eventLoop); in beforeSleep()