| /redis-3.2.3/src/ |
| H A D | latency.c | 141 char *event = dictGetKey(de); in latencyResetEvent() local
253 char *event = dictGetKey(de); in createLatencyReport() local
262 analyzeLatencyForEvent(event,&ls); in createLatencyReport()
266 eventnum, event, in createLatencyReport()
274 if (!strcasecmp(event,"fork")) { in createLatencyReport()
295 if (!strcasecmp(event,"command")) { in createLatencyReport()
344 if (!strcasecmp(event,"aof-fstat") || in createLatencyReport()
502 char *event = dictGetKey(de); in latencyCommandReplyWithLatestEvents() local
507 addReplyBulkCString(c,event); in latencyCommandReplyWithLatestEvents()
582 char *event; in latencyCommand() local
[all …]
|
| H A D | ae_evport.c | 248 port_event_t event[MAX_EVENT_BATCHSZ]; in aeApiPoll() local
285 if (port_getn(state->portfd, event, MAX_EVENT_BATCHSZ, &nevents, in aeApiPoll()
299 if (event[i].portev_events & POLLIN) in aeApiPoll()
301 if (event[i].portev_events & POLLOUT) in aeApiPoll()
304 eventLoop->fired[i].fd = event[i].portev_object; in aeApiPoll()
309 (int)event[i].portev_object, mask); in aeApiPoll()
311 state->pending_fds[i] = event[i].portev_object; in aeApiPoll()
312 state->pending_masks[i] = (uintptr_t)event[i].portev_user; in aeApiPoll()
|
| H A D | latency.h | 65 void latencyAddSample(char *event, mstime_t latency);
84 #define latencyAddSampleIfNeeded(event,var) \ argument
87 latencyAddSample((event),(var));
|
| H A D | notify.c | 95 void notifyKeyspaceEvent(int type, char *event, robj *key, int dbid) { in notifyKeyspaceEvent() argument
104 eventobj = createStringObject(event,strlen(event)); in notifyKeyspaceEvent()
|
| H A D | t_list.c | 219 char *event = (where == LIST_HEAD) ? "lpush" : "rpush"; in pushGenericCommand() local
222 notifyKeyspaceEvent(NOTIFY_LIST,event,c->argv[1],c->db->id); in pushGenericCommand()
267 char *event = (where == LIST_HEAD) ? "lpush" : "rpush"; in pushxGenericCommand() local
271 notifyKeyspaceEvent(NOTIFY_LIST,event,c->argv[1],c->db->id); in pushxGenericCommand()
366 char *event = (where == LIST_HEAD) ? "lpop" : "rpop"; in popGenericCommand() local
370 notifyKeyspaceEvent(NOTIFY_LIST,event,c->argv[1],c->db->id); in popGenericCommand()
888 char *event = (where == LIST_HEAD) ? "lpop" : "rpop"; in blockingPopGenericCommand() local
896 notifyKeyspaceEvent(NOTIFY_LIST,event, in blockingPopGenericCommand()
|
| H A D | t_zset.c | 1562 char *event[3] = {"zremrangebyrank","zremrangebyscore","zremrangebylex"}; in zremrangeGenericCommand() local
1564 notifyKeyspaceEvent(NOTIFY_ZSET,event[rangetype],key,c->db->id); in zremrangeGenericCommand()
|
| H A D | server.h | 1387 void notifyKeyspaceEvent(int type, char *event, robj *key, int dbid);
|
| H A D | scripting.c | 2355 if (ar->event == LUA_HOOKCOUNT && ldb.step == 0 && bp == 0) { in luaLdbLineHook()
|
| /redis-3.2.3/deps/lua/test/ |
| H A D | trace-calls.lua | 6 local function hook(event)
11 if event=="call" then
17 if event=="call" then
24 io.write(event," ",t.name or "(Lua)"," <",t.linedefined,":",t.short_src,">")
26 io.write(event," ",t.name or "(C)"," [",t.what,"] ")
|
| /redis-3.2.3/deps/lua/src/ |
| H A D | ltm.c | 50 const TValue *luaT_gettm (Table *events, TMS event, TString *ename) { in luaT_gettm() argument
52 lua_assert(event <= TM_EQ); in luaT_gettm()
54 events->flags |= cast_byte(1u<<event); /* cache this fact */ in luaT_gettm()
61 const TValue *luaT_gettmbyobj (lua_State *L, const TValue *o, TMS event) { in luaT_gettmbyobj() argument
73 return (mt ? luaH_getstr(mt, G(L)->tmname[event]) : luaO_nilobject); in luaT_gettmbyobj()
|
| H A D | ltm.h | 49 LUAI_FUNC const TValue *luaT_gettm (Table *events, TMS event, TString *ename);
51 TMS event);
|
| H A D | lvm.c | 166 StkId res, TMS event) { in call_binTM() argument
167 const TValue *tm = luaT_gettmbyobj(L, p1, event); /* try first operand */ in call_binTM()
169 tm = luaT_gettmbyobj(L, p2, event); /* try second operand */ in call_binTM()
177 TMS event) { in get_compTM() argument
178 const TValue *tm1 = fasttm(L, mt1, event); in get_compTM()
182 tm2 = fasttm(L, mt2, event); in get_compTM()
191 TMS event) { in call_orderTM() argument
192 const TValue *tm1 = luaT_gettmbyobj(L, p1, event); in call_orderTM()
195 tm2 = luaT_gettmbyobj(L, p2, event); in call_orderTM()
|
| H A D | ldo.h | 41 LUAI_FUNC void luaD_callhook (lua_State *L, int event, int line);
|
| H A D | lauxlib.c | 203 LUALIB_API int luaL_getmetafield (lua_State *L, int obj, const char *event) { in luaL_getmetafield() argument
206 lua_pushstring(L, event); in luaL_getmetafield()
219 LUALIB_API int luaL_callmeta (lua_State *L, int obj, const char *event) { in luaL_callmeta() argument
221 if (!luaL_getmetafield(L, obj, event)) /* no metafield? */ in luaL_callmeta()
|
| H A D | ldo.c | 181 void luaD_callhook (lua_State *L, int event, int line) { in luaD_callhook() argument
187 ar.event = event; in luaD_callhook()
189 if (event == LUA_HOOKTAILRET) in luaD_callhook()
|
| H A D | lua.h | 347 int event; member
|
| H A D | ldblib.c | 215 lua_pushstring(L, hooknames[(int)ar->event]); in hookf()
|
| /redis-3.2.3/deps/hiredis/adapters/ |
| H A D | libevent.h | 39 struct event rev, wev;
42 static void redisLibeventReadEvent(int fd, short event, void *arg) { in redisLibeventReadEvent() argument
43 ((void)fd); ((void)event); in redisLibeventReadEvent()
48 static void redisLibeventWriteEvent(int fd, short event, void *arg) { in redisLibeventWriteEvent() argument
49 ((void)fd); ((void)event); in redisLibeventWriteEvent()
|
| /redis-3.2.3/deps/hiredis/ |
| H A D | README.md | 228 Hiredis comes with an asynchronous API that works easily with any event library.
266 In an asynchronous context, commands are automatically pipelined due to the nature of an event loop.
308 ### Hooking it up to event library *X*
|
| /redis-3.2.3/ |
| H A D | 00-RELEASENOTES | 57 a Sentinel address update event.
1235 | ae.c: Fix delay until next timer event.
1241 The old code mis-calculated the amount of time to wait till next event.
1266 a timer event (that is the time after it want to run again) is added
1267 to the event *start time*. So if the event takes, in order to run, more
|
| /redis-3.2.3/deps/jemalloc/ |
| H A D | ChangeLog | 69 + Make one call to prof_active_get_unlocked() per allocation event, and use
71 event. Also add a missing check in prof_realloc(). These fixes protect
|