Home
last modified time | relevance | path

Searched refs:C_OK (Results 1 – 25 of 30) sorted by relevance

12

/f-stack/app/redis-5.0.5/src/
H A Dt_string.c42 return C_OK; in checkStringLength()
161 return C_OK; in getGenericCommand()
168 return C_OK; in getGenericCommand()
189 if (getLongFromObjectOrReply(c,c->argv[2],&offset,NULL) != C_OK) in setrangeCommand()
206 if (checkStringLength(c,offset+sdslen(value)) != C_OK) in setrangeCommand()
226 if (checkStringLength(c,offset+sdslen(value)) != C_OK) in setrangeCommand()
250 if (getLongLongFromObjectOrReply(c,c->argv[2],&start,NULL) != C_OK) in getrangeCommand()
252 if (getLongLongFromObjectOrReply(c,c->argv[3],&end,NULL) != C_OK) in getrangeCommand()
345 if (getLongLongFromObjectOrReply(c,o,&value,NULL) != C_OK) return; in incrDecrCommand()
405 if (getLongDoubleFromObjectOrReply(c,o,&value,NULL) != C_OK || in incrbyfloatCommand()
[all …]
H A Devict.c406 if (return_ok_asap && !level) return C_OK; in getMaxmemoryState()
423 if (return_ok_asap) return C_OK; in getMaxmemoryState()
426 if (mem_used <= server.maxmemory) return C_OK; in getMaxmemoryState()
449 if (server.masterhost && server.repl_slave_ignore_maxmemory) return C_OK; in freeMemoryIfNeeded()
459 if (clientsArePaused()) return C_OK; in freeMemoryIfNeeded()
460 if (getMaxmemoryState(&mem_reported,NULL,&mem_tofree,NULL) == C_OK) in freeMemoryIfNeeded()
461 return C_OK; in freeMemoryIfNeeded()
596 if (getMaxmemoryState(NULL,NULL,NULL,NULL) == C_OK) { in freeMemoryIfNeeded()
611 return C_OK; in freeMemoryIfNeeded()
633 if (server.lua_timedout || server.loading) return C_OK; in freeMemoryIfNeededAndSafe()
H A Dbitops.c437 return C_OK; in getBitOffsetFromArgument()
470 return C_OK; in getBitfieldTypeFromArgument()
533 if (getBitOffsetFromArgument(c,c->argv[2],&bitoffset,0,0) != C_OK) in setbitCommand()
536 if (getLongFromObjectOrReply(c,c->argv[3],&on,err) != C_OK) in setbitCommand()
571 if (getBitOffsetFromArgument(c,c->argv[2],&bitoffset,0,0) != C_OK) in getbitCommand()
782 if (getLongFromObjectOrReply(c,c->argv[2],&start,NULL) != C_OK) in bitcountCommand()
784 if (getLongFromObjectOrReply(c,c->argv[3],&end,NULL) != C_OK) in bitcountCommand()
827 if (getLongFromObjectOrReply(c,c->argv[2],&bit,NULL) != C_OK) in bitposCommand()
846 if (getLongFromObjectOrReply(c,c->argv[3],&start,NULL) != C_OK) in bitposCommand()
849 if (getLongFromObjectOrReply(c,c->argv[4],&end,NULL) != C_OK) in bitposCommand()
[all …]
H A Dt_list.c320 if ((getLongFromObjectOrReply(c, c->argv[2], &index, NULL) != C_OK)) in lindexCommand()
347 if ((getLongFromObjectOrReply(c, c->argv[2], &index, NULL) != C_OK)) in lsetCommand()
402 if ((getLongFromObjectOrReply(c, c->argv[2], &start, NULL) != C_OK) || in lrangeCommand()
403 (getLongFromObjectOrReply(c, c->argv[3], &end, NULL) != C_OK)) return; in lrangeCommand()
448 if ((getLongFromObjectOrReply(c, c->argv[2], &start, NULL) != C_OK) || in ltrimCommand()
449 (getLongFromObjectOrReply(c, c->argv[3], &end, NULL) != C_OK)) return; in ltrimCommand()
496 if ((getLongFromObjectOrReply(c, c->argv[2], &toremove, NULL) != C_OK)) in lremCommand()
682 return C_OK; in serveClientBlockedOnList()
692 != C_OK) return; in blockingPopGenericCommand()
754 != C_OK) return; in brpoplpushCommand()
H A Dnetworking.c232 return C_OK; in prepareClientToWrite()
253 return C_OK; in _addReplyToBuffer()
320 if (prepareClientToWrite(c) != C_OK) { in addReplySds()
340 if (_addReplyToBuffer(c,s,len) != C_OK) in addReplyString()
635 if (prepareClientToWrite(dst) != C_OK) in AddReplyFromClient()
1068 return C_OK; in writeToClient()
1241 return C_OK; in processInlineBuffer()
1320 if (ll <= 0) return C_OK; in processMultibulkBuffer()
1414 if (c->multibulklen == 0) return C_OK; in processMultibulkBuffer()
1794 != C_OK) return; in clientCommand()
[all …]
H A Dt_stream.c357 return C_OK; in streamAppendItem()
1116 return C_OK; in streamGenericParseIDOrReply()
1120 return C_OK; in streamGenericParseIDOrReply()
1132 return C_OK; in streamGenericParseIDOrReply()
1196 != C_OK) return; in xaddCommand()
1278 != C_OK) return; in xrangeGenericCommand()
2152 != C_OK) return; in xclaimCommand()
2182 != C_OK) return; in xclaimCommand()
2188 != C_OK) return; in xclaimCommand()
2193 != C_OK) return; in xclaimCommand()
[all …]
H A Dobject.c412 return C_OK; in isObjectRepresentableAsLongLong()
627 return C_OK; in getDoubleFromObject()
632 if (getDoubleFromObject(o, &value) != C_OK) { in getDoubleFromObjectOrReply()
641 return C_OK; in getDoubleFromObjectOrReply()
669 return C_OK; in getLongDoubleFromObject()
674 if (getLongDoubleFromObject(o, &value) != C_OK) { in getLongDoubleFromObjectOrReply()
683 return C_OK; in getLongDoubleFromObjectOrReply()
702 return C_OK; in getLongLongFromObject()
707 if (getLongLongFromObject(o, &value) != C_OK) { in getLongLongFromObjectOrReply()
716 return C_OK; in getLongLongFromObjectOrReply()
[all …]
H A Dlolwut5.c253 getLongFromObjectOrReply(c,c->argv[1],&cols,NULL) != C_OK) in lolwut5Command()
257 getLongFromObjectOrReply(c,c->argv[2],&squares_per_row,NULL) != C_OK) in lolwut5Command()
261 getLongFromObjectOrReply(c,c->argv[3],&squares_per_col,NULL) != C_OK) in lolwut5Command()
H A Dt_hash.c113 return C_OK; in hashTypeGetValue()
119 return C_OK; in hashTypeGetValue()
297 if (dictDelete((dict*)o->ptr, field) == C_OK) { in hashTypeDelete()
380 return C_OK; in hashTypeNext()
566 if (getLongLongFromObjectOrReply(c,c->argv[3],&incr,NULL) != C_OK) return; in hincrbyCommand()
568 if (hashTypeGetValue(o,c->argv[2]->ptr,&vstr,&vlen,&value) == C_OK) { in hincrbyCommand()
602 if (getLongDoubleFromObjectOrReply(c,c->argv[3],&incr,NULL) != C_OK) return; in hincrbyfloatCommand()
604 if (hashTypeGetValue(o,c->argv[2]->ptr,&vstr,&vlen,&ll) == C_OK) { in hincrbyfloatCommand()
H A Drdb.c1184 return C_OK; in rdbSaveRio()
1210 return C_OK; in rdbSaveRioWithEOFMark()
1272 server.lastbgsave_status = C_OK; in rdbSave()
1273 return C_OK; in rdbSave()
1301 if (retval == C_OK) { in rdbSaveBackground()
1331 return C_OK; in rdbSaveBackground()
1333 return C_OK; /* unreached */ in rdbSaveBackground()
2055 return C_OK; in rdbLoadRio()
2092 server.lastbgsave_status = C_OK; in backgroundSaveDoneHandlerDisk()
2294 if (retval == C_OK) { in rdbSaveToSlavesSockets()
[all …]
H A Daof.c287 return C_OK; in startAppendOnly()
477 server.aof_last_write_status = C_OK; in flushAppendOnlyFile()
743 if (rdbLoadRio(&rdb,NULL,1) != C_OK) { in loadAppendOnlyFile()
858 return C_OK; in loadAppendOnlyFile()
1357 return C_OK; in rewriteAppendOnlyFileRio()
1460 return C_OK; in rewriteAppendOnlyFile()
1523 return C_OK; in aofCreatePipes()
1564 if (aofCreatePipes() != C_OK) return C_ERR; in rewriteAppendOnlyFileBackground()
1615 return C_OK; in rewriteAppendOnlyFileBackground()
1617 return C_OK; /* unreached */ in rewriteAppendOnlyFileBackground()
[all …]
H A Dserver.c1980 return C_OK; in listenToPort()
2576 return C_OK; in processCommand()
2582 return C_OK; in processCommand()
2590 return C_OK; in processCommand()
2659 return C_OK; in processCommand()
2672 return C_OK; in processCommand()
2682 return C_OK; in processCommand()
2693 return C_OK; in processCommand()
2705 return C_OK; in processCommand()
2744 return C_OK; in processCommand()
[all …]
H A Dreplication.c440 return C_OK; in replicationSetupSlaveForFullResync()
458 C_OK) goto need_full_resync; in masterTryPartialResynchronization()
524 return C_OK; in masterTryPartialResynchronization()
624 if (retval == C_OK) replicationScriptCacheFlush(); in startBgsaveForReplication()
794 &port,NULL) != C_OK)) in replconfCommand()
977 if (bgsaveerr != C_OK) { in updateSlavesWaitingBgsave()
1101 if (startAppendOnly() == C_OK) break; in restartAOFAfterSYNC()
1292 if (rdbLoad(server.rdb_filename,&rsi) != C_OK) { in readSyncBulkPayload()
1908 return C_OK; in connectWithMaster()
2450 != C_OK) return; in waitCommand()
[all …]
H A Dt_zset.c553 return C_OK; in zslParseRange()
579 return C_OK; in zslParseLexRangeItem()
584 return C_OK; in zslParseLexRangeItem()
588 return C_OK; in zslParseLexRangeItem()
592 return C_OK; in zslParseLexRangeItem()
624 return C_OK; in zslParseLexRange()
1268 return C_OK; in zsetScore()
1596 != C_OK) goto cleanup; in zaddGenericCommand()
2558 != C_OK) || in genericZrangebyscoreCommand()
2560 != C_OK)) in genericZrangebyscoreCommand()
[all …]
H A Dgeo.c97 C_OK) { in extractLongLatOrReply()
107 return C_OK; in extractLongLatOrReply()
118 return C_OK; in longLatFromMember()
156 "need numeric radius") != C_OK) { in extractDistanceOrReply()
210 return C_OK; in geoAppendIfWithinRadius()
520 &count, NULL) != C_OK) return; in georadiusGeneric()
H A Dhyperloglog.c592 if (hdr->encoding == HLL_DENSE) return C_OK; in hllSparseToDense()
636 return C_OK; in hllSparseToDense()
1107 return C_OK; in hllMerge()
1171 return C_OK; in isHLLObjectOrReply()
1194 if (isHLLObjectOrReply(c,o) != C_OK) return; in pfaddCommand()
1243 if (isHLLObjectOrReply(c,o) != C_OK) return; in pfcountCommand()
1268 if (isHLLObjectOrReply(c,o) != C_OK) return; in pfcountCommand()
1325 if (isHLLObjectOrReply(c,o) != C_OK) return; in pfmergeCommand()
1505 if (isHLLObjectOrReply(c,o) != C_OK) return; in pfdebugCommand()
H A Ddb.c383 return C_OK; in selectDb()
426 return C_OK; in getFlushCommandFlags()
510 "invalid DB index") != C_OK) in selectCommand()
610 return C_OK; in parseScanCursorOrReply()
646 != C_OK) in scanGenericCommand()
865 if (prepareForShutdown(flags) == C_OK) exit(0); in shutdownCommand()
1003 if (id1 == id2) return C_OK; in dbSwapDatabases()
1029 return C_OK; in dbSwapDatabases()
1044 "invalid first DB index") != C_OK) in swapdbCommand()
1048 "invalid second DB index") != C_OK) in swapdbCommand()
H A Dcluster.c290 return C_OK; in clusterLoadConfig()
410 return C_OK; in clusterLockConfig()
832 return C_OK; in clusterNodeRemoveSlave()
849 return C_OK; in clusterNodeAddSlave()
1025 return C_OK; in clusterBumpConfigEpochWithoutConsensus()
2640 return C_OK; in clusterSendModuleMessageToTarget()
3709 return C_OK; in clusterAddSlot()
3721 return C_OK; in clusterDelSlot()
3884 return C_OK; in verifyClusterConfigWithData()
3923 return C_OK; in verifyClusterConfigWithData()
[all …]
H A Dsentinel.c358 return C_OK; in redisAeAttach()
1065 return C_OK; in sentinelTryConnectionSharing()
1539 return C_OK; in sentinelResetMasterAndChangeAddress()
1987 name) == C_OK) in sentinelSetClientName()
2600 return C_OK; in sentinelSendHello()
2632 return C_OK; in sentinelForceHelloUpdateForMaster()
2644 if (retval == C_OK) { in sentinelSendPing()
3123 != C_OK) return; in sentinelCommand()
3125 != C_OK) return; in sentinelCommand()
3974 return C_OK; in sentinelSendSlaveOf()
[all …]
H A Dt_set.c43 if (isSdsRepresentableAsLongLong(value,NULL) == C_OK) in setTypeCreate()
63 if (isSdsRepresentableAsLongLong(value,&llval) == C_OK) { in setTypeAdd()
96 if (isSdsRepresentableAsLongLong(value,&llval) == C_OK) { in setTypeRemove()
112 if (isSdsRepresentableAsLongLong(value,&llval) == C_OK) { in setTypeIsMember()
408 if (getLongFromObjectOrReply(c,c->argv[2],&l,NULL) != C_OK) return; in spopWithCountCommand()
625 if (getLongFromObjectOrReply(c,c->argv[2],&l,NULL) != C_OK) return; in srandmemberWithCountCommand()
H A Ddebug.c339 != C_OK) return; in debugCommand()
359 if (rdbSave(server.rdb_filename,rsiptr) != C_OK) { in debugCommand()
367 if (ret != C_OK) { in debugCommand()
379 if (ret != C_OK) { in debugCommand()
481 if (getLongFromObjectOrReply(c, c->argv[2], &keys, NULL) != C_OK) in debugCommand()
490 if (getLongFromObjectOrReply(c, c->argv[4], &valsize, NULL) != C_OK) in debugCommand()
574 if (getLongFromObjectOrReply(c, c->argv[2], &dbid, NULL) != C_OK) in debugCommand()
H A Dblocked.c82 "timeout is not an integer or out of range") != C_OK) in getTimeoutFromObjectOrReply()
96 return C_OK; in getTimeoutFromObjectOrReply()
H A Dslowlog.c168 getLongFromObjectOrReply(c,c->argv[2],&count,NULL) != C_OK) in slowlogCommand()
H A Dsort.c236 != C_OK) || in sortCommand()
238 != C_OK)) in sortCommand()
H A Dredis-check-rdb.c361 if (fp) return (retval == 0) ? C_OK : C_ERR; in redis_check_rdb_main()

12