Home
last modified time | relevance | path

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

/redis-3.2.3/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()
347 if (getLongLongFromObjectOrReply(c,o,&value,NULL) != C_OK) return; in incrDecrCommand()
407 if (getLongDoubleFromObjectOrReply(c,o,&value,NULL) != C_OK || in incrbyfloatCommand()
[all …]
H A Dobject.c354 return C_OK; in isObjectRepresentableAsLongLong()
562 return C_OK; in getDoubleFromObject()
567 if (getDoubleFromObject(o, &value) != C_OK) { in getDoubleFromObjectOrReply()
576 return C_OK; in getDoubleFromObjectOrReply()
600 return C_OK; in getLongDoubleFromObject()
605 if (getLongDoubleFromObject(o, &value) != C_OK) { in getLongDoubleFromObjectOrReply()
614 return C_OK; in getLongDoubleFromObjectOrReply()
633 return C_OK; in getLongLongFromObject()
638 if (getLongLongFromObject(o, &value) != C_OK) { in getLongLongFromObjectOrReply()
647 return C_OK; in getLongLongFromObjectOrReply()
[all …]
H A Drdb.c824 return C_OK; in rdbSaveRio()
850 return C_OK; in rdbSaveRioWithEOFMark()
908 server.lastbgsave_status = C_OK; in rdbSave()
909 return C_OK; in rdbSave()
935 if (retval == C_OK) { in rdbSaveBackground()
961 return C_OK; in rdbSaveBackground()
963 return C_OK; /* unreached */ in rdbSaveBackground()
1424 return C_OK; in rdbLoad()
1440 server.lastbgsave_status = C_OK; in backgroundSaveDoneHandlerDisk()
1640 if (retval == C_OK) { in rdbSaveToSlavesSockets()
[all …]
H A Dbitops.c430 return C_OK; in getBitOffsetFromArgument()
463 return C_OK; in getBitfieldTypeFromArgument()
526 if (getBitOffsetFromArgument(c,c->argv[2],&bitoffset,0,0) != C_OK) in setbitCommand()
529 if (getLongFromObjectOrReply(c,c->argv[3],&on,err) != C_OK) in setbitCommand()
564 if (getBitOffsetFromArgument(c,c->argv[2],&bitoffset,0,0) != C_OK) in getbitCommand()
771 if (getLongFromObjectOrReply(c,c->argv[2],&start,NULL) != C_OK) in bitcountCommand()
773 if (getLongFromObjectOrReply(c,c->argv[3],&end,NULL) != C_OK) in bitcountCommand()
816 if (getLongFromObjectOrReply(c,c->argv[2],&bit,NULL) != C_OK) in bitposCommand()
835 if (getLongFromObjectOrReply(c,c->argv[3],&start,NULL) != C_OK) in bitposCommand()
838 if (getLongFromObjectOrReply(c,c->argv[4],&end,NULL) != C_OK) in bitposCommand()
[all …]
H A Dnetworking.c158 if (c->flags & CLIENT_LUA) return C_OK; in prepareClientToWrite()
190 return C_OK; in prepareClientToWrite()
227 return C_OK; in _addReplyToBuffer()
366 if (prepareClientToWrite(c) != C_OK) { in addReplySds()
381 if (_addReplyToBuffer(c,s,len) != C_OK) in addReplyString()
984 return C_OK; in writeToClient()
1106 return C_OK; in processInlineBuffer()
1158 return C_OK; in processMultibulkBuffer()
1254 if (c->multibulklen == 0) return C_OK; in processMultibulkBuffer()
1297 if (processCommand(c) == C_OK) in processInputBuffer()
[all …]
H A Dblocked.c80 "timeout is not an integer or out of range") != C_OK) in getTimeoutFromObjectOrReply()
94 return C_OK; in getTimeoutFromObjectOrReply()
H A Dserver.c1818 return C_OK; in listenToPort()
2360 return C_OK; in processCommand()
2366 return C_OK; in processCommand()
2374 return C_OK; in processCommand()
2441 return C_OK; in processCommand()
2454 return C_OK; in processCommand()
2464 return C_OK; in processCommand()
2475 return C_OK; in processCommand()
2525 return C_OK; in processCommand()
2611 return C_OK; in prepareForShutdown()
[all …]
H A Dt_list.c311 if ((getLongFromObjectOrReply(c, c->argv[2], &index, NULL) != C_OK)) in lindexCommand()
338 if ((getLongFromObjectOrReply(c, c->argv[2], &index, NULL) != C_OK)) in lsetCommand()
393 if ((getLongFromObjectOrReply(c, c->argv[2], &start, NULL) != C_OK) || in lrangeCommand()
394 (getLongFromObjectOrReply(c, c->argv[3], &end, NULL) != C_OK)) return; in lrangeCommand()
439 if ((getLongFromObjectOrReply(c, c->argv[2], &start, NULL) != C_OK) || in ltrimCommand()
440 (getLongFromObjectOrReply(c, c->argv[3], &end, NULL) != C_OK)) return; in ltrimCommand()
487 if ((getLongFromObjectOrReply(c, c->argv[2], &toremove, NULL) != C_OK)) in lremCommand()
776 return C_OK; in serveClientBlockedOnList()
877 != C_OK) return; in blockingPopGenericCommand()
939 != C_OK) return; in brpoplpushCommand()
H A Daof.c265 return C_OK; in startAppendOnly()
413 server.aof_last_write_status = C_OK; in flushAppendOnlyFile()
723 return C_OK; in loadAppendOnlyFile()
1163 return C_OK; in rewriteAppendOnlyFile()
1227 return C_OK; in aofCreatePipes()
1268 if (aofCreatePipes() != C_OK) return C_ERR; in rewriteAppendOnlyFileBackground()
1277 if (rewriteAppendOnlyFile(tmpfile) == C_OK) { in rewriteAppendOnlyFileBackground()
1312 return C_OK; in rewriteAppendOnlyFileBackground()
1314 return C_OK; /* unreached */ in rewriteAppendOnlyFileBackground()
1323 } else if (rewriteAppendOnlyFileBackground() == C_OK) { in bgrewriteaofCommand()
[all …]
H A Dreplication.c408 return C_OK; in replicationSetupSlaveForFullResync()
440 C_OK) goto need_full_resync; in masterTryPartialResynchronization()
469 return C_OK; in masterTryPartialResynchronization()
559 if (retval == C_OK) replicationScriptCacheFlush(); in startBgsaveForReplication()
597 if (masterTryPartialResynchronization(c) == C_OK) { in syncCommand()
722 &port,NULL) != C_OK)) in replconfCommand()
903 if (bgsaveerr != C_OK) { in updateSlavesWaitingBgsave()
1137 if (rdbLoad(server.rdb_filename) != C_OK) { in readSyncBulkPayload()
1676 return C_OK; in connectWithMaster()
2146 != C_OK) return; in waitCommand()
[all …]
H A Dt_zset.c463 return C_OK; in zslParseRange()
490 return C_OK; in zslParseLexRangeItem()
496 return C_OK; in zslParseLexRangeItem()
500 return C_OK; in zslParseLexRangeItem()
504 return C_OK; in zslParseLexRangeItem()
528 return C_OK; in zslParseLexRange()
1198 return C_OK; in zsetScore()
1275 != C_OK) goto cleanup; in zaddGenericCommand()
1490 if (zslParseRange(c->argv[2],c->argv[3],&range) != C_OK) { in zremrangeGenericCommand()
2494 if (zslParseRange(c->argv[2],c->argv[3],&range) != C_OK) { in zcountCommand()
[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()
498 &count, NULL) != C_OK) return; in georadiusGeneric()
H A Dhyperloglog.c576 if (hdr->encoding == HLL_DENSE) return C_OK; in hllSparseToDense()
619 return C_OK; in hllSparseToDense()
1082 return C_OK; in hllMerge()
1145 return C_OK; in isHLLObjectOrReply()
1168 if (isHLLObjectOrReply(c,o) != C_OK) return; in pfaddCommand()
1217 if (isHLLObjectOrReply(c,o) != C_OK) return; in pfcountCommand()
1242 if (isHLLObjectOrReply(c,o) != C_OK) return; in pfcountCommand()
1298 if (isHLLObjectOrReply(c,o) != C_OK) return; in pfmergeCommand()
1466 if (isHLLObjectOrReply(c,o) != C_OK) return; in pfdebugCommand()
H A Dt_hash.c269 if (dictDelete((dict*)o->ptr, field) == C_OK) { in hashTypeDelete()
357 return C_OK; in hashTypeNext()
542 if (getLongLongFromObjectOrReply(c,c->argv[3],&incr,NULL) != C_OK) return; in hincrbyCommand()
546 "hash value is not an integer") != C_OK) { in hincrbyCommand()
576 if (getLongDoubleFromObjectOrReply(c,c->argv[3],&incr,NULL) != C_OK) return; in hincrbyfloatCommand()
580 "hash value is not a valid float") != C_OK) { in hincrbyfloatCommand()
H A Dsentinel.c351 return C_OK; in redisAeAttach()
1042 return C_OK; in sentinelTryConnectionSharing()
1514 return C_OK; in sentinelResetMasterAndChangeAddress()
2207 if (retval == C_OK) in sentinelRefreshInstanceInfo()
2502 return C_OK; in sentinelSendHello()
2534 return C_OK; in sentinelForceHelloUpdateForMaster()
2545 if (retval == C_OK) { in sentinelSendPing()
3017 != C_OK) return; in sentinelCommand()
3019 != C_OK) return; in sentinelCommand()
3792 return C_OK; in sentinelSendSlaveOf()
[all …]
H A Dt_set.c43 if (isObjectRepresentableAsLongLong(value,NULL) == C_OK) in setTypeCreate()
61 if (isObjectRepresentableAsLongLong(value,&llval) == C_OK) { in setTypeAdd()
96 if (isObjectRepresentableAsLongLong(value,&llval) == C_OK) { in setTypeRemove()
112 if (isObjectRepresentableAsLongLong(value,&llval) == C_OK) { in setTypeIsMember()
417 if (getLongFromObjectOrReply(c,c->argv[2],&l,NULL) != C_OK) return; in spopWithCountCommand()
632 if (getLongFromObjectOrReply(c,c->argv[2],&l,NULL) != C_OK) return; in srandmemberWithCountCommand()
H A Dcluster.c275 return C_OK; in clusterLoadConfig()
395 return C_OK; in clusterLockConfig()
790 return C_OK; in clusterNodeRemoveSlave()
807 return C_OK; in clusterNodeAddSlave()
849 return (retval == DICT_OK) ? C_OK : C_ERR; in clusterAddNode()
983 return C_OK; in clusterBumpConfigEpochWithoutConsensus()
3422 return C_OK; in clusterAddSlot()
3434 return C_OK; in clusterDelSlot()
3594 if (nodeIsSlave(myself)) return C_OK; in verifyClusterConfigWithData()
3629 return C_OK; in verifyClusterConfigWithData()
[all …]
H A Ddebug.c319 != C_OK) return; in debugCommand()
335 if (rdbSave(server.rdb_filename) != C_OK) { in debugCommand()
340 if (rdbLoad(server.rdb_filename) != C_OK) { in debugCommand()
349 if (loadAppendOnlyFile(server.aof_filename) != C_OK) { in debugCommand()
437 if (getLongFromObjectOrReply(c, c->argv[2], &keys, NULL) != C_OK) in debugCommand()
507 if (getLongFromObjectOrReply(c, c->argv[2], &dbid, NULL) != C_OK) in debugCommand()
H A Ddb.c293 return C_OK; in selectDb()
377 "invalid DB index") != C_OK) in selectCommand()
477 return C_OK; in parseScanCursorOrReply()
513 != C_OK) in scanGenericCommand()
727 if (prepareForShutdown(flags) == C_OK) exit(0); in shutdownCommand()
947 if (getLongLongFromObjectOrReply(c, param, &when, NULL) != C_OK) in expireGenericCommand()
H A Dslowlog.c146 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 Dscripting.c1178 return C_OK; in luaCreateFunction()
1231 if (getLongLongFromObjectOrReply(c,c->argv[2],&numkeys,NULL) != C_OK) in evalGenericCommand()
2338 return C_OK; in ldbRepl()
H A Dserver.h74 #define C_OK 0 macro