Home
last modified time | relevance | path

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

12

/f-stack/app/redis-5.0.5/src/
H A Dgeo.c98 return C_ERR; in extractLongLatOrReply()
105 return C_ERR; in extractLongLatOrReply()
116 if (zsetScore(zobj, member->ptr, &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()
279 == C_ERR) sdsfree(ele); in geoGetPointsInRange()
479 if (extractLongLatOrReply(c, c->argv + 2, xy) == C_ERR) in georadiusGeneric()
484 if (longLatFromMember(zobj, member, xy) == C_ERR) { in georadiusGeneric()
805 if (zsetScore(zobj, c->argv[2]->ptr, &score1) == C_ERR || in geodistCommand()
[all …]
H A Daof.c263 return C_ERR; in startAppendOnly()
279 return C_ERR; in startAppendOnly()
720 return C_ERR; in loadAppendOnlyFile()
1103 while (hashTypeNext(hi) != C_ERR) { in rewriteHashObject()
1361 return C_ERR; in rewriteAppendOnlyFileRio()
1383 return C_ERR; in rewriteAppendOnlyFile()
1457 return C_ERR; in rewriteAppendOnlyFile()
1466 return C_ERR; in rewriteAppendOnlyFile()
1529 return C_ERR; in aofCreatePipes()
1564 if (aofCreatePipes() != C_OK) return C_ERR; in rewriteAppendOnlyFileBackground()
[all …]
H A Drdb.c1189 return C_ERR; in rdbSaveRio()
1215 return C_ERR; in rdbSaveRioWithEOFMark()
1236 return C_ERR; in rdbSave()
1266 return C_ERR; in rdbSave()
1279 return C_ERR; in rdbSave()
1324 return C_ERR; in rdbSaveBackground()
1864 return C_ERR; in rdbLoadRio()
1870 return C_ERR; in rdbLoadRio()
2095 server.lastbgsave_status = C_ERR; in backgroundSaveDoneHandlerDisk()
2292 retval = C_ERR; in rdbSaveToSlavesSockets()
[all …]
H A Dhyperloglog.c630 return C_ERR; in hllSparseToDense()
882 if (hllSparseToDense(o) == C_ERR) return -1; /* Corrupted HLL. */ in hllSparseSet()
1105 if (i != HLL_REGISTERS) return C_ERR; in hllMerge()
1154 return C_ERR; /* Error already sent. */ in isHLLObjectOrReply()
1177 return C_ERR; in isHLLObjectOrReply()
1247 if (hllMerge(registers,o) == C_ERR) { in pfcountCommand()
1334 if (hllMerge(max,o) == C_ERR) { in pfmergeCommand()
1357 if (use_dense && hllSparseToDense(o) == C_ERR) { in pfmergeCommand()
1514 if (hllSparseToDense(o) == C_ERR) { in pfdebugCommand()
1578 if (hllSparseToDense(o) == C_ERR) { in pfdebugCommand()
H A Dnetworking.c1048 return C_ERR; in writeToClient()
1065 return C_ERR; in writeToClient()
1198 return C_ERR; in processInlineBuffer()
1213 return C_ERR; in processInlineBuffer()
1301 return C_ERR; in processMultibulkBuffer()
1306 return C_ERR; in processMultibulkBuffer()
1315 return C_ERR; in processMultibulkBuffer()
1339 return C_ERR; in processMultibulkBuffer()
1353 return C_ERR; in processMultibulkBuffer()
1360 return C_ERR; in processMultibulkBuffer()
[all …]
H A Ddb.c381 return C_ERR; in selectDb()
420 return C_ERR; in getFlushCommandFlags()
435 if (getFlushCommandFlags(c,&flags) == C_ERR) return; in flushdbCommand()
447 if (getFlushCommandFlags(c,&flags) == C_ERR) return; in flushallCommand()
517 if (selectDb(c,id) == C_ERR) { in selectCommand()
608 return C_ERR; in parseScanCursorOrReply()
804 if (parseScanCursorOrReply(c,c->argv[1],&cursor) == C_ERR) return; in scanCommand()
934 if (getLongLongFromObject(c->argv[2],&dbid) == C_ERR || in moveCommand()
936 selectDb(c,dbid) == C_ERR) in moveCommand()
1002 id2 < 0 || id2 >= server.dbnum) return C_ERR; in dbSwapDatabases()
[all …]
H A Dt_hash.c124 return C_ERR; in hashTypeGetValue()
136 if (hashTypeGetValue(o,field,&vstr,&vlen,&vll) == C_ERR) return NULL; in hashTypeGetValueObject()
366 if (fptr == NULL) return C_ERR; in hashTypeNext()
376 if ((hi->de = dictNext(hi->di)) == NULL) return C_ERR; in hashTypeNext()
479 while (hashTypeNext(hi) != C_ERR) { in hashTypeConvertZiplist()
786 while (hashTypeNext(hi) != C_ERR) { in genericHgetallCommand()
825 if (parseScanCursorOrReply(c,c->argv[2],&cursor) == C_ERR) return; in hscanCommand()
H A Dobject.c405 return string2ll(s,sdslen(s),llval) ? C_OK : C_ERR; in isSdsRepresentableAsLongLong()
619 return C_ERR; in getDoubleFromObject()
638 return C_ERR; in getDoubleFromObjectOrReply()
661 return C_ERR; in getLongDoubleFromObject()
680 return C_ERR; in getLongDoubleFromObjectOrReply()
694 if (string2ll(o->ptr,sdslen(o->ptr),&value) == 0) return C_ERR; in getLongLongFromObject()
713 return C_ERR; in getLongLongFromObjectOrReply()
722 if (getLongLongFromObjectOrReply(c, o, &value, msg) != C_OK) return C_ERR; in getLongFromObjectOrReply()
729 return C_ERR; in getLongFromObjectOrReply()
1318 == C_ERR) return; in memoryCommand()
H A Dblocked.c83 return C_ERR; in getTimeoutFromObjectOrReply()
87 return C_ERR; in getTimeoutFromObjectOrReply()
304 where) == C_ERR) in handleClientsBlockedOnKeys()
H A Dt_zset.c533 if (eptr[0] != '\0' || isnan(spec->min)) return C_ERR; in zslParseRange()
537 if (eptr[0] != '\0' || isnan(spec->min)) return C_ERR; in zslParseRange()
545 if (eptr[0] != '\0' || isnan(spec->max)) return C_ERR; in zslParseRange()
576 if (c[1] != '\0') return C_ERR; in zslParseLexRangeItem()
581 if (c[1] != '\0') return C_ERR; in zslParseLexRangeItem()
594 return C_ERR; in zslParseLexRangeItem()
616 max->encoding == OBJ_ENCODING_INT) return C_ERR; in zslParseLexRange()
622 return C_ERR; in zslParseLexRange()
1256 if (!zobj || !member) return C_ERR; in zsetScore()
1263 if (de == NULL) return C_ERR; in zsetScore()
[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 Dsentinel.c341 return C_ERR; in redisAeAttach()
1068 return C_ERR; in sentinelTryConnectionSharing()
1493 if (newaddr == NULL) return C_ERR; in sentinelResetMasterAndChangeAddress()
2571 if (ri->link->disconnected) return C_ERR; in sentinelSendHello()
2579 return C_ERR; in sentinelSendHello()
2598 if (retval != C_OK) return C_ERR; in sentinelSendHello()
3941 if (retval == C_ERR) return retval; in sentinelSendSlaveOf()
3948 if (retval == C_ERR) return retval; in sentinelSendSlaveOf()
3954 if (retval == C_ERR) return retval; in sentinelSendSlaveOf()
3965 if (retval == C_ERR) return retval; in sentinelSendSlaveOf()
[all …]
H A Dserver.c1313 if (server.aof_last_write_status == C_ERR) in serverCron()
1761 return C_ERR; in restartServer()
1771 return C_ERR; in restartServer()
1779 return C_ERR; in restartServer()
1799 return C_ERR; /* Never reached. */ in restartServer()
1975 return C_ERR; in listenToPort()
2561 return C_ERR; in processCommand()
2820 return C_ERR; in prepareForShutdown()
2845 return C_ERR; in prepareForShutdown()
2882 server.lastbgsave_status == C_ERR) in writeCommandsDeniedByDiskError()
[all …]
H A Devict.c434 return C_ERR; in getMaxmemoryState()
622 return C_ERR; in freeMemoryIfNeeded()
H A Dredis-check-aof.c193 if (redis_check_rdb_main(argc,argv,fp) == C_ERR) { in redis_check_aof_main()
H A Dcluster.c98 return C_ERR; in clusterLoadConfig()
111 return C_ERR; in clusterLoadConfig()
389 return C_ERR; in clusterLockConfig()
404 return C_ERR; in clusterLockConfig()
489 server.cfd,&server.cfd_count) == C_ERR) in clusterInit()
835 return C_ERR; in clusterNodeRemoveSlave()
891 return (retval == DICT_OK) ? C_OK : C_ERR; in clusterAddNode()
1027 return C_ERR; in clusterBumpConfigEpochWithoutConsensus()
3718 if (!n) return C_ERR; in clusterDelSlot()
4818 if (len < 10) return C_ERR; in verifyDumpPayload()
[all …]
H A Dbitops.c423 return C_ERR; in getBitOffsetFromArgument()
433 return C_ERR; in getBitOffsetFromArgument()
458 return C_ERR; in getBitfieldTypeFromArgument()
467 return C_ERR; in getBitfieldTypeFromArgument()
H A Dt_stream.c178 if (use_id && streamCompareID(use_id,&s->last_id) <= 0) return C_ERR; in streamAppendItem()
1137 return C_ERR; in streamGenericParseIDOrReply()
1228 == C_ERR) in xaddCommand()
1269 if (streamParseIDOrReply(c,startarg,&startid,0) == C_ERR) return; in xrangeGenericCommand()
1270 if (streamParseIDOrReply(c,endarg,&endid,UINT64_MAX) == C_ERR) return; in xrangeGenericCommand()
1940 if (getLongLongFromObjectOrReply(c,c->argv[5],&count,NULL) == C_ERR) in xpendingCommand()
1943 if (streamParseIDOrReply(c,c->argv[3],&startid,0) == C_ERR) in xpendingCommand()
1945 if (streamParseIDOrReply(c,c->argv[4],&endid,UINT64_MAX) == C_ERR) in xpendingCommand()
H A Dreplication.c437 return C_ERR; in replicationSetupSlaveForFullResync()
543 return C_ERR; in masterTryPartialResynchronization()
584 retval = C_ERR; in startBgsaveForReplication()
590 if (retval == C_ERR) { in startBgsaveForReplication()
1894 return C_ERR; in connectWithMaster()
1902 return C_ERR; in connectWithMaster()
H A Dredis-check-rdb.c361 if (fp) return (retval == 0) ? C_OK : C_ERR; in redis_check_rdb_main()
H A Dmodule.c1483 if (retval == C_ERR) flags |= REDISMODULE_CTX_FLAGS_OOM; in RM_GetContextFlags()
1932 if (zsetScore(key->value,ele->ptr,score) == C_ERR) return REDISMODULE_ERR; in RM_ZsetScore()
2041 if (zslParseLexRange(min, max, zlrs) == C_ERR) return REDISMODULE_ERR; in zsetInitLexRange()
5100 == C_ERR) in moduleLoadFromQueue()
5149 return C_ERR; in moduleLoad()
5157 return C_ERR; in moduleLoad()
5169 return C_ERR; in moduleLoad()
H A Dconfig.c876 if (getLongLongFromObject(o,&ll) == C_ERR) goto badfmt; \
933 if (getLongLongFromObject(o,&ll) == C_ERR || ll < 1) goto badfmt;
963 if (startAppendOnly() == C_ERR) {
H A Dt_list.c679 return C_ERR; in serveClientBlockedOnList()
H A Dscripting.c2308 return C_ERR; in ldbRepl()
2446 if (ldbRepl(lua) == C_ERR && timeout) { in luaLdbLineHook()
H A Dt_set.c1111 if (parseScanCursorOrReply(c,c->argv[2],&cursor) == C_ERR) return; in sscanCommand()

12