Home
last modified time | relevance | path

Searched refs:mask (Results 1 – 25 of 25) sorted by relevance

/redis-3.2.3/src/
H A Dae_epoll.c78 int op = eventLoop->events[fd].mask == AE_NONE ? in aeApiAddEvent()
82 mask |= eventLoop->events[fd].mask; /* Merge old events */ in aeApiAddEvent()
83 if (mask & AE_READABLE) ee.events |= EPOLLIN; in aeApiAddEvent()
84 if (mask & AE_WRITABLE) ee.events |= EPOLLOUT; in aeApiAddEvent()
93 int mask = eventLoop->events[fd].mask & (~delmask); in aeApiDelEvent() local
96 if (mask & AE_READABLE) ee.events |= EPOLLIN; in aeApiDelEvent()
97 if (mask & AE_WRITABLE) ee.events |= EPOLLOUT; in aeApiDelEvent()
99 if (mask != AE_NONE) { in aeApiDelEvent()
119 int mask = 0; in aeApiPoll() local
122 if (e->events & EPOLLIN) mask |= AE_READABLE; in aeApiPoll()
[all …]
H A Dae_select.c62 static int aeApiAddEvent(aeEventLoop *eventLoop, int fd, int mask) { in aeApiAddEvent() argument
65 if (mask & AE_READABLE) FD_SET(fd,&state->rfds); in aeApiAddEvent()
66 if (mask & AE_WRITABLE) FD_SET(fd,&state->wfds); in aeApiAddEvent()
73 if (mask & AE_READABLE) FD_CLR(fd,&state->rfds); in aeApiDelEvent()
74 if (mask & AE_WRITABLE) FD_CLR(fd,&state->wfds); in aeApiDelEvent()
88 int mask = 0; in aeApiPoll() local
91 if (fe->mask == AE_NONE) continue; in aeApiPoll()
92 if (fe->mask & AE_READABLE && FD_ISSET(j,&state->_rfds)) in aeApiPoll()
93 mask |= AE_READABLE; in aeApiPoll()
95 mask |= AE_WRITABLE; in aeApiPoll()
[all …]
H A Dae_evport.c127 if (mask & AE_READABLE) in aeApiAssociate()
129 if (mask & AE_WRITABLE) in aeApiAssociate()
136 (void *)(uintptr_t)mask); in aeApiAssociate()
164 fullmask = mask | eventLoop->events[fd].mask; in aeApiAddEvent()
201 state->pending_masks[pfd] &= ~mask; in aeApiDelEvent()
217 fullmask = eventLoop->events[fd].mask; in aeApiDelEvent()
246 int mask, i; in aeApiPoll() local
298 mask = 0; in aeApiPoll()
300 mask |= AE_READABLE; in aeApiPoll()
302 mask |= AE_WRITABLE; in aeApiPoll()
[all …]
H A Dae.c82 eventLoop->events[i].mask = AE_NONE; in aeCreateEventLoop()
120 eventLoop->events[i].mask = AE_NONE; in aeResizeSetSize()
144 if (aeApiAddEvent(eventLoop, fd, mask) == -1) in aeCreateFileEvent()
146 fe->mask |= mask; in aeCreateFileEvent()
159 if (fe->mask == AE_NONE) return; in aeDeleteFileEvent()
161 aeApiDelEvent(eventLoop, fd, mask); in aeDeleteFileEvent()
162 fe->mask = fe->mask & (~mask); in aeDeleteFileEvent()
177 return fe->mask; in aeGetFileEvents()
403 int mask = eventLoop->fired[j].mask; in aeProcessEvents() local
410 if (fe->mask & mask & AE_READABLE) { in aeProcessEvents()
[all …]
H A Dae_kqueue.c75 static int aeApiAddEvent(aeEventLoop *eventLoop, int fd, int mask) { in aeApiAddEvent() argument
79 if (mask & AE_READABLE) { in aeApiAddEvent()
83 if (mask & AE_WRITABLE) { in aeApiAddEvent()
90 static void aeApiDelEvent(aeEventLoop *eventLoop, int fd, int mask) { in aeApiDelEvent() argument
94 if (mask & AE_READABLE) { in aeApiDelEvent()
98 if (mask & AE_WRITABLE) { in aeApiDelEvent()
124 int mask = 0; in aeApiPoll() local
127 if (e->filter == EVFILT_READ) mask |= AE_READABLE; in aeApiPoll()
128 if (e->filter == EVFILT_WRITE) mask |= AE_WRITABLE; in aeApiPoll()
130 eventLoop->fired[j].mask = mask; in aeApiPoll()
H A Dae.h59 typedef void aeFileProc(struct aeEventLoop *eventLoop, int fd, void *clientData, int mask);
66 int mask; /* one of AE_(READABLE|WRITABLE) */ member
86 int mask; member
107 int aeCreateFileEvent(aeEventLoop *eventLoop, int fd, int mask,
109 void aeDeleteFileEvent(aeEventLoop *eventLoop, int fd, int mask);
116 int aeWait(int fd, int mask, long long milliseconds);
H A Dredis-benchmark.c101 static void writeHandler(aeEventLoop *el, int fd, void *privdata, int mask);
189 static void readHandler(aeEventLoop *el, int fd, void *privdata, int mask) { in readHandler() argument
194 UNUSED(mask); in readHandler()
258 static void writeHandler(aeEventLoop *el, int fd, void *privdata, int mask) { in writeHandler() argument
262 UNUSED(mask); in writeHandler()
H A Ddict.c760 unsigned long mask = ~0; in rev() local
762 mask ^= (mask << s); in rev()
763 v = ((v >> s) & mask) | ((v << s) & ~mask); in rev()
H A Dintset.c319 uint64_t mask = (1<<bits)-1; in createSet() local
325 value = (rand()*rand()) & mask; in createSet()
327 value = rand() & mask; in createSet()
H A Dbitops.c309 uint64_t mask = ((uint64_t)-1) << bits; in checkUnsignedBitfieldOverflow() local
312 res &= ~mask; in checkUnsignedBitfieldOverflow()
352 uint64_t mask = ((uint64_t)-1) << bits; in checkSignedBitfieldOverflow() local
361 c |= mask; in checkSignedBitfieldOverflow()
363 c &= ~mask; in checkSignedBitfieldOverflow()
H A Dredis-cli.c396 int mask; in completionCallback() local
404 mask = CLI_HELP_COMMAND | CLI_HELP_GROUP; in completionCallback()
406 mask = CLI_HELP_COMMAND; in completionCallback()
410 if (!(helpEntries[i].type & mask)) continue; in completionCallback()
1792 int mask = AE_READABLE; in pipeMode() local
1794 if (!eof || obuf_len != 0) mask |= AE_WRITABLE; in pipeMode()
1795 mask = aeWait(fd,mask,1000); in pipeMode()
1798 if (mask & AE_READABLE) { in pipeMode()
1843 if (mask & AE_WRITABLE) { in pipeMode()
H A Dnetworking.c686 void acceptTcpHandler(aeEventLoop *el, int fd, void *privdata, int mask) { in acceptTcpHandler() argument
690 UNUSED(mask); in acceptTcpHandler()
706 void acceptUnixHandler(aeEventLoop *el, int fd, void *privdata, int mask) { in acceptUnixHandler() argument
709 UNUSED(mask); in acceptUnixHandler()
988 void sendReplyToClient(aeEventLoop *el, int fd, void *privdata, int mask) { in sendReplyToClient() argument
990 UNUSED(mask); in sendReplyToClient()
1307 void readQueryFromClient(aeEventLoop *el, int fd, void *privdata, int mask) { in readQueryFromClient() argument
1312 UNUSED(mask); in readQueryFromClient()
H A Dreplication.c798 void sendBulkToSlave(aeEventLoop *el, int fd, void *privdata, int mask) { in sendBulkToSlave() argument
801 UNUSED(mask); in sendBulkToSlave()
984 void readSyncBulkPayload(aeEventLoop *el, int fd, void *privdata, int mask) { in readSyncBulkPayload() argument
990 UNUSED(mask); in readSyncBulkPayload()
1386 void syncWithMaster(aeEventLoop *el, int fd, void *privdata, int mask) { in syncWithMaster() argument
1393 UNUSED(mask); in syncWithMaster()
H A Dserver.h1097 void sendReplyToClient(aeEventLoop *el, int fd, void *privdata, int mask);
1101 void acceptHandler(aeEventLoop *el, int fd, void *privdata, int mask);
1102 void acceptTcpHandler(aeEventLoop *el, int fd, void *privdata, int mask);
1103 void acceptUnixHandler(aeEventLoop *el, int fd, void *privdata, int mask);
1104 void readQueryFromClient(aeEventLoop *el, int fd, void *privdata, int mask);
H A Daof.c95 void aofChildWriteDiffData(aeEventLoop *el, int fd, void *privdata, int mask) { in aofChildWriteDiffData() argument
102 UNUSED(mask); in aofChildWriteDiffData()
1180 void aofChildPipeReadable(aeEventLoop *el, int fd, void *privdata, int mask) { in aofChildPipeReadable() argument
1184 UNUSED(mask); in aofChildPipeReadable()
H A Dcluster.c52 void clusterAcceptHandler(aeEventLoop *el, int fd, void *privdata, int mask);
53 void clusterReadHandler(aeEventLoop *el, int fd, void *privdata, int mask);
574 void clusterAcceptHandler(aeEventLoop *el, int fd, void *privdata, int mask) { in clusterAcceptHandler() argument
580 UNUSED(mask); in clusterAcceptHandler()
1994 void clusterWriteHandler(aeEventLoop *el, int fd, void *privdata, int mask) { in clusterWriteHandler() argument
1998 UNUSED(mask); in clusterWriteHandler()
2015 void clusterReadHandler(aeEventLoop *el, int fd, void *privdata, int mask) { in clusterReadHandler() argument
2022 UNUSED(mask); in clusterReadHandler()
H A Dsentinel.c271 static void redisAeReadEvent(aeEventLoop *el, int fd, void *privdata, int mask) { in redisAeReadEvent() argument
272 ((void)el); ((void)fd); ((void)mask); in redisAeReadEvent()
278 static void redisAeWriteEvent(aeEventLoop *el, int fd, void *privdata, int mask) { in redisAeWriteEvent() argument
279 ((void)el); ((void)fd); ((void)mask); in redisAeWriteEvent()
/redis-3.2.3/deps/jemalloc/test/include/test/
H A DSFMT-sse2.h64 __m128i c, __m128i d, __m128i mask) { in mm_recursion() argument
74 y = _mm_and_si128(y, mask); in mm_recursion()
86 __m128i r, r1, r2, mask; in gen_rand_all() local
87 mask = _mm_set_epi32(MSK4, MSK3, MSK2, MSK1); in gen_rand_all()
93 mask); in gen_rand_all()
100 mask); in gen_rand_all()
116 __m128i r, r1, r2, mask; in gen_rand_array() local
123 mask); in gen_rand_array()
130 mask); in gen_rand_array()
138 mask); in gen_rand_array()
[all …]
H A DSFMT-alti.h72 const vector unsigned int mask = ALTI_MSK64; in vec_recursion() local
76 const vector unsigned int mask = ALTI_MSK; in vec_recursion() local
87 y = vec_and(y, mask); in vec_recursion()
/redis-3.2.3/deps/lua/src/
H A Dldblib.c226 int mask = 0; in makemask() local
227 if (strchr(smask, 'c')) mask |= LUA_MASKCALL; in makemask()
228 if (strchr(smask, 'r')) mask |= LUA_MASKRET; in makemask()
230 if (count > 0) mask |= LUA_MASKCOUNT; in makemask()
231 return mask; in makemask()
237 if (mask & LUA_MASKCALL) smask[i++] = 'c'; in unmakemask()
238 if (mask & LUA_MASKRET) smask[i++] = 'r'; in unmakemask()
239 if (mask & LUA_MASKLINE) smask[i++] = 'l'; in unmakemask()
259 int arg, mask, count; in db_sethook() local
286 int mask = lua_gethookmask(L1); in db_gethook() local
[all …]
H A Dlua_struct.c285 Uinttype mask = (Uinttype)(~((Uinttype)0)) << (size*8 - 1); in getinteger() local
286 if (l & mask) /* negative value? */ in getinteger()
287 l |= mask; /* signal extension */ in getinteger()
H A Dldebug.c56 LUA_API int lua_sethook (lua_State *L, lua_Hook func, int mask, int count) { in lua_sethook() argument
57 if (func == NULL || mask == 0) { /* turn off hooks? */ in lua_sethook()
58 mask = 0; in lua_sethook()
64 L->hookmask = cast_byte(mask); in lua_sethook()
H A Dlvm.c61 lu_byte mask = L->hookmask; in traceexec() local
64 if ((mask & LUA_MASKCOUNT) && L->hookcount == 0) { in traceexec()
68 if (mask & LUA_MASKLINE) { in traceexec()
H A Dlua.h340 LUA_API int lua_sethook (lua_State *L, lua_Hook func, int mask, int count);
/redis-3.2.3/deps/hiredis/adapters/
H A Dae.h45 static void redisAeReadEvent(aeEventLoop *el, int fd, void *privdata, int mask) { in redisAeReadEvent() argument
46 ((void)el); ((void)fd); ((void)mask); in redisAeReadEvent()
52 static void redisAeWriteEvent(aeEventLoop *el, int fd, void *privdata, int mask) { in redisAeWriteEvent() argument
53 ((void)el); ((void)fd); ((void)mask); in redisAeWriteEvent()