Home
last modified time | relevance | path

Searched refs:C_ERR (Results 1 – 23 of 23) sorted by relevance

/redis-3.2.3/src/
H A Dgeo.c98 return C_ERR; in extractLongLatOrReply()
105 return C_ERR; in extractLongLatOrReply()
116 if (zsetScore(zobj, member, &score) == C_ERR) return C_ERR; in longLatFromMember()
117 if (!decodeGeohash(score, xy)) return C_ERR; in longLatFromMember()
200 return C_ERR; in geoAppendIfWithinRadius()
258 == C_ERR) sdsfree(member); in geoGetPointsInRange()
281 == C_ERR) sdsfree(member); in geoGetPointsInRange()
462 if (longLatFromMember(zobj, member, xy) == C_ERR) { in georadiusGeneric()
678 if (zsetScore(zobj, c->argv[j], &score) == C_ERR) { in geohashCommand()
772 if (zsetScore(zobj, c->argv[2], &score1) == C_ERR || in geodistCommand()
[all …]
H A Drdb.c781 if (!di) return C_ERR; in rdbSaveRio()
829 return C_ERR; in rdbSaveRio()
855 return C_ERR; in rdbSaveRioWithEOFMark()
876 return C_ERR; in rdbSave()
902 return C_ERR; in rdbSave()
915 return C_ERR; in rdbSave()
954 return C_ERR; in rdbSaveBackground()
1295 return C_ERR; in rdbLoad()
1302 return C_ERR; in rdbLoad()
1638 retval = C_ERR; in rdbSaveToSlavesSockets()
[all …]
H A Daof.c252 return C_ERR; in startAppendOnly()
260 return C_ERR; in startAppendOnly()
624 return C_ERR; in loadAppendOnlyFile()
972 while (hashTypeNext(hi) != C_ERR) { in rewriteHashObject()
1032 return C_ERR; in rewriteAppendOnlyFile()
1047 return C_ERR; in rewriteAppendOnlyFile()
1160 return C_ERR; in rewriteAppendOnlyFile()
1170 return C_ERR; in rewriteAppendOnlyFile()
1233 return C_ERR; in aofCreatePipes()
1268 if (aofCreatePipes() != C_OK) return C_ERR; in rewriteAppendOnlyFileBackground()
[all …]
H A Dobject.c356 return string2ll(o->ptr,sdslen(o->ptr),llval) ? C_OK : C_ERR; in isObjectRepresentableAsLongLong()
554 return C_ERR; in getDoubleFromObject()
573 return C_ERR; in getDoubleFromObjectOrReply()
592 return C_ERR; in getLongDoubleFromObject()
611 return C_ERR; in getLongDoubleFromObjectOrReply()
625 if (string2ll(o->ptr,sdslen(o->ptr),&value) == 0) return C_ERR; in getLongLongFromObject()
644 return C_ERR; in getLongLongFromObjectOrReply()
653 if (getLongLongFromObjectOrReply(c, o, &value, msg) != C_OK) return C_ERR; in getLongFromObjectOrReply()
660 return C_ERR; in getLongFromObjectOrReply()
H A Dblocked.c81 return C_ERR; in getTimeoutFromObjectOrReply()
85 return C_ERR; in getTimeoutFromObjectOrReply()
H A Dnetworking.c964 return C_ERR; in writeToClient()
981 return C_ERR; in writeToClient()
1063 return C_ERR; in processInlineBuffer()
1078 return C_ERR; in processInlineBuffer()
1138 return C_ERR; in processMultibulkBuffer()
1143 return C_ERR; in processMultibulkBuffer()
1152 return C_ERR; in processMultibulkBuffer()
1178 return C_ERR; in processMultibulkBuffer()
1192 return C_ERR; in processMultibulkBuffer()
1199 return C_ERR; in processMultibulkBuffer()
[all …]
H A Dhyperloglog.c613 return C_ERR; in hllSparseToDense()
869 if (hllSparseToDense(o) == C_ERR) return -1; /* Corrupted HLL. */ in hllSparseAdd()
1080 if (i != HLL_REGISTERS) return C_ERR; in hllMerge()
1129 return C_ERR; /* Error already sent. */ in isHLLObjectOrReply()
1151 return C_ERR; in isHLLObjectOrReply()
1221 if (hllMerge(registers,o) == C_ERR) { in pfcountCommand()
1302 if (hllMerge(max,o) == C_ERR) { in pfmergeCommand()
1324 if (hllSparseToDense(o) == C_ERR) { in pfmergeCommand()
1475 if (hllSparseToDense(o) == C_ERR) { in pfdebugCommand()
1539 if (hllSparseToDense(o) == C_ERR) { in pfdebugCommand()
H A Dt_hash.c343 if (fptr == NULL) return C_ERR; in hashTypeNext()
353 if ((hi->de = dictNext(hi->di)) == NULL) return C_ERR; in hashTypeNext()
446 while (hashTypeNext(hi) != C_ERR) { in hashTypeConvertZiplist()
759 while (hashTypeNext(hi) != C_ERR) { in genericHgetallCommand()
798 if (parseScanCursorOrReply(c,c->argv[2],&cursor) == C_ERR) return; in hscanCommand()
H A Dt_zset.c443 if (eptr[0] != '\0' || isnan(spec->min)) return C_ERR; in zslParseRange()
447 if (eptr[0] != '\0' || isnan(spec->min)) return C_ERR; in zslParseRange()
455 if (eptr[0] != '\0' || isnan(spec->max)) return C_ERR; in zslParseRange()
486 if (c[1] != '\0') return C_ERR; in zslParseLexRangeItem()
492 if (c[1] != '\0') return C_ERR; in zslParseLexRangeItem()
506 return C_ERR; in zslParseLexRangeItem()
519 max->encoding == OBJ_ENCODING_INT) return C_ERR; in zslParseLexRange()
526 return C_ERR; in zslParseLexRange()
1186 if (!zobj || !member) return C_ERR; in zsetScore()
1193 if (de == NULL) return C_ERR; in zsetScore()
[all …]
H A Dserver.c1260 if (server.aof_last_write_status == C_ERR) in serverCron()
1653 return C_ERR; /* Never reached. */ in restartServer()
1813 return C_ERR; in listenToPort()
2350 return C_ERR; in processCommand()
2412 if (server.current_client == NULL) return C_ERR; in processCommand()
2427 server.lastbgsave_status == C_ERR) || in processCommand()
2428 server.aof_last_write_status == C_ERR) && in processCommand()
2571 return C_ERR; in prepareForShutdown()
2593 return C_ERR; in prepareForShutdown()
3605 return C_ERR; /* nothing to free... */ in freeMemoryIfNeeded()
[all …]
H A Dt_string.c40 return C_ERR; in checkStringLength()
165 return C_ERR; in getGenericCommand()
177 if (getGenericCommand(c) == C_ERR) return; in getsetCommand()
H A Ddb.c291 return C_ERR; in selectDb()
384 if (selectDb(c,id) == C_ERR) { in selectCommand()
475 return C_ERR; in parseScanCursorOrReply()
671 if (parseScanCursorOrReply(c,c->argv[1],&cursor) == C_ERR) return; in scanCommand()
796 if (getLongLongFromObject(c->argv[2],&dbid) == C_ERR || in moveCommand()
798 selectDb(c,dbid) == C_ERR) in moveCommand()
H A Dsentinel.c334 return C_ERR; in redisAeAttach()
1045 return C_ERR; in sentinelTryConnectionSharing()
1468 if (newaddr == NULL) return C_ERR; in sentinelResetMasterAndChangeAddress()
2474 if (ri->link->disconnected) return C_ERR; in sentinelSendHello()
2482 return C_ERR; in sentinelSendHello()
2500 if (retval != C_OK) return C_ERR; in sentinelSendHello()
3764 if (retval == C_ERR) return retval; in sentinelSendSlaveOf()
3769 if (retval == C_ERR) return retval; in sentinelSendSlaveOf()
3774 if (retval == C_ERR) return retval; in sentinelSendSlaveOf()
3784 if (retval == C_ERR) return retval; in sentinelSendSlaveOf()
[all …]
H A Dcluster.c98 return C_ERR; in clusterLoadConfig()
111 return C_ERR; in clusterLoadConfig()
374 return C_ERR; in clusterLockConfig()
389 return C_ERR; in clusterLockConfig()
455 server.cfd,&server.cfd_count) == C_ERR) in clusterInit()
793 return C_ERR; in clusterNodeRemoveSlave()
849 return (retval == DICT_OK) ? C_OK : C_ERR; in clusterAddNode()
985 return C_ERR; in clusterBumpConfigEpochWithoutConsensus()
3431 if (!n) return C_ERR; in clusterDelSlot()
4435 if (len < 10) return C_ERR; in verifyDumpPayload()
[all …]
H A Dscripting.c490 server.lastbgsave_status == C_ERR) in luaRedisGenericCommand()
504 if (freeMemoryIfNeeded() == C_ERR) { in luaRedisGenericCommand()
1159 return C_ERR; in luaCreateFunction()
1166 return C_ERR; in luaCreateFunction()
1277 if (luaCreateFunction(c,lua,funcname,c->argv[1]) == C_ERR) { in evalGenericCommand()
1450 == C_ERR) { in scriptCommand()
2241 return C_ERR; in ldbRepl()
2379 if (ldbRepl(lua) == C_ERR && timeout) { in luaLdbLineHook()
H A Dbitops.c416 return C_ERR; in getBitOffsetFromArgument()
426 return C_ERR; in getBitOffsetFromArgument()
451 return C_ERR; in getBitfieldTypeFromArgument()
460 return C_ERR; in getBitfieldTypeFromArgument()
H A Dreplication.c405 return C_ERR; in replicationSetupSlaveForFullResync()
488 return C_ERR; in masterTryPartialResynchronization()
526 if (retval == C_ERR) { in startBgsaveForReplication()
1154 while (retry-- && startAppendOnly() == C_ERR) { in readSyncBulkPayload()
1662 return C_ERR; in connectWithMaster()
1670 return C_ERR; in connectWithMaster()
H A Dredis-check-rdb.c184 if ((fp = fopen(rdbfilename,"r")) == NULL) return C_ERR; in redis_check_rdb()
H A Dt_list.c773 return C_ERR; in serveClientBlockedOnList()
839 where) == C_ERR) in handleClientsBlockedOnLists()
H A Dconfig.c695 if (getLongLongFromObject(o,&ll) == C_ERR) goto badfmt; \
745 if (getLongLongFromObject(o,&ll) == C_ERR || ll < 1) goto badfmt;
775 if (startAppendOnly() == C_ERR) {
H A Dt_set.c1118 if (parseScanCursorOrReply(c,c->argv[2],&cursor) == C_ERR) return; in sscanCommand()
H A Ddebug.c229 while (hashTypeNext(hi) != C_ERR) { in computeDatasetDigest()
H A Dserver.h75 #define C_ERR -1 macro