Home
last modified time | relevance | path

Searched refs:module_blocked_pipe (Results 1 – 3 of 3) sorted by relevance

/f-stack/app/redis-5.0.5/src/
H A Dmodule.c3656 if (write(server.module_blocked_pipe[1],"A",1) != 1) { in RM_UnblockClient()
3707 while (read(server.module_blocked_pipe[0],buf,1) == 1); in moduleHandleBlockedClients()
5064 if (pipe(server.module_blocked_pipe) == -1) { in moduleInitModulesSystem()
5072 anetNonBlock(NULL,server.module_blocked_pipe[0]); in moduleInitModulesSystem()
5073 anetNonBlock(NULL,server.module_blocked_pipe[1]); in moduleInitModulesSystem()
H A Dserver.h964 int module_blocked_pipe[2]; /* Pipe used to awake the event loop if a member
H A Dserver.c2154 if (aeCreateFileEvent(server.el, server.module_blocked_pipe[0], AE_READABLE, in initServer()