Searched refs:anetNonBlock (Results 1 – 11 of 11) sorted by relevance
| /f-stack/app/redis-5.0.5/src/ |
| H A D | childinfo.c | 41 } else if (anetNonBlock(NULL,server.child_info_pipe[0]) != ANET_OK) { in openChildInfoPipe()
|
| H A D | anet.h | 67 int anetNonBlock(char *err, int fd);
|
| H A D | anet.c | 93 int anetNonBlock(char *err, int fd) { in anetNonBlock() function
300 if (flags & ANET_CONNECT_NONBLOCK && anetNonBlock(err,s) != ANET_OK) in anetTcpGenericConnect()
392 if (anetNonBlock(err,s) != ANET_OK) { in anetUnixGenericConnect()
|
| H A D | aof.c | 1428 if (anetNonBlock(NULL,server.aof_pipe_read_ack_from_parent) != ANET_OK) in rewriteAppendOnlyFile()
1512 if (anetNonBlock(NULL,fds[0]) != ANET_OK) goto error; in aofCreatePipes()
1513 if (anetNonBlock(NULL,fds[1]) != ANET_OK) goto error; in aofCreatePipes()
|
| H A D | server.c | 1934 anetNonBlock(NULL,fds[*count]); in listenToPort()
1946 anetNonBlock(NULL,fds[*count]); in listenToPort()
1977 anetNonBlock(NULL,fds[*count]); in listenToPort()
2074 anetNonBlock(NULL,server.sofd); in initServer()
|
| H A D | module.c | 5072 anetNonBlock(NULL,server.module_blocked_pipe[0]); in moduleInitModulesSystem()
5073 anetNonBlock(NULL,server.module_blocked_pipe[1]); in moduleInitModulesSystem()
|
| H A D | networking.c | 94 anetNonBlock(NULL,fd); in createClient()
|
| H A D | scripting.c | 1730 anetNonBlock(NULL,ldb.fd); in ldbEndSession()
|
| H A D | rdb.c | 2204 anetNonBlock(NULL,slave->fd); in backgroundSaveDoneHandlerSocket()
|
| H A D | cluster.c | 636 anetNonBlock(NULL,cfd); in clusterAcceptHandler()
|
| H A D | redis-cli.c | 6059 if (anetNonBlock(aneterr,fd) == ANET_ERR) { in pipeMode()
|