Home
last modified time | relevance | path

Searched refs:serverAssert (Results 1 – 22 of 22) sorted by relevance

/redis-3.2.3/src/
H A Dt_hash.c84 serverAssert(vptr != NULL); in hashTypeGetFromZiplist()
92 serverAssert(ret); in hashTypeGetFromZiplist()
104 serverAssert(o->encoding == OBJ_ENCODING_HT); in hashTypeGetFromHashTable()
208 serverAssert(vptr != NULL); in hashTypeSet()
336 serverAssert(vptr == NULL); in hashTypeNext()
340 serverAssert(vptr != NULL); in hashTypeNext()
347 serverAssert(vptr != NULL); in hashTypeNext()
373 serverAssert(ret); in hashTypeCurrentFromZiplist()
376 serverAssert(ret); in hashTypeCurrentFromZiplist()
457 serverAssert(ret == DICT_OK); in hashTypeConvertZiplist()
[all …]
H A Dt_zset.c115 serverAssert(!isnan(score)); in zslInsert()
256 serverAssert(x != NULL); in zslFirstInRange()
281 serverAssert(x != NULL); in zslLastInRange()
599 serverAssert(x != NULL); in zslFirstInLexRange()
624 serverAssert(x != NULL); in zslLastInLexRange()
642 serverAssert(sptr != NULL); in zzlGetScore()
664 serverAssert(sptr != NULL); in ziplistGetObject()
755 serverAssert(p != NULL); in zzlIsInRange()
774 serverAssert(sptr != NULL); in zzlFirstInRange()
802 serverAssert(sptr != NULL); in zzlLastInRange()
[all …]
H A Daof.c208 serverAssert(server.aof_state != AOF_OFF); in stopAppendOnly()
242 serverAssert(server.aof_state == AOF_OFF); in startAppendOnly()
702 serverAssert(fakeClient->bufpos == 0 && listLength(fakeClient->reply) == 0); in loadAppendOnlyFile()
704 serverAssert((fakeClient->flags & CLIENT_BLOCKED) == 0); in loadAppendOnlyFile()
880 serverAssert(eptr != NULL); in rewriteSortedSetObject()
882 serverAssert(sptr != NULL); in rewriteSortedSetObject()
885 serverAssert(ziplistGet(eptr,&vstr,&vlen,&vll)); in rewriteSortedSetObject()
H A Dblocked.c115 serverAssert(ln != NULL); in processUnblockedClients()
H A Dreplication.c78 serverAssert(server.repl_backlog == NULL); in createReplicationBacklog()
122 serverAssert(listLength(server.slaves) == 0); in freeReplicationBacklog()
184 serverAssert(!(listLength(slaves) != 0 && server.repl_backlog == NULL)); in replicationFeedSlaves()
1695 serverAssert(server.repl_state == REPL_STATE_TRANSFER); in replicationAbortSyncTransfer()
1909 serverAssert(server.master != NULL && server.cached_master == NULL); in replicationCacheMaster()
2068 serverAssert(retval == DICT_OK); in replicationScriptCacheAdd()
2075 serverAssert(retval == DICT_OK); in replicationScriptCacheAdd()
2174 serverAssert(ln != NULL); in unblockClientWaitingReplicas()
H A Dsentinel.c457 serverAssert(retval == DICT_OK); in initSentinel()
976 serverAssert(link->refcount > 0); in releaseInstanceLink()
1019 serverAssert(ri->flags & SRI_SENTINEL); in sentinelTryConnectionSharing()
1055 serverAssert(ri->flags & SRI_SENTINEL); in sentinelUpdateSentinelAddressInAllMasters()
1152 serverAssert((flags & SRI_MASTER) || master != NULL); in createSentinelRedisInstance()
1273 serverAssert(ri->flags & SRI_MASTER); in sentinelRedisInstanceLookupSlave()
1399 serverAssert(ri->flags & SRI_MASTER); in sentinelResetMaster()
3652 serverAssert(de != NULL); in sentinelLeaderIncr()
3797 serverAssert(master->flags & SRI_MASTER); in sentinelStartFailover()
4183 serverAssert(ri->flags & SRI_MASTER); in sentinelFailoverStateMachine()
[all …]
H A Dnetworking.c198 serverAssert(listLength(reply) > 0); in dupLastObjectIfNeeded()
758 serverAssert(ln != NULL); in unlinkClient()
771 serverAssert(ln != NULL); in unlinkClient()
780 serverAssert(ln != NULL); in unlinkClient()
848 serverAssert(ln != NULL); in freeClient()
866 serverAssert(ln != NULL); in freeClient()
1817 serverAssert(c->reply_bytes < SIZE_MAX-(1024*64)); in asyncCloseClientOnOutputBufferLimitReached()
H A Ddb.c266 serverAssert(o->type == OBJ_STRING); in dbUnshareStringValue()
502 serverAssert(o == NULL || o->type == OBJ_SET || o->type == OBJ_HASH || in scanGenericCommand()
621 serverAssert(kobj->encoding == OBJ_ENCODING_INT); in scanGenericCommand()
1077 serverAssert(j < argc); in getKeysUsingCommandTable()
H A Dt_list.c114 serverAssert(li->subject->encoding == li->encoding); in listTypeNext()
707 serverAssert(dictAdd(db->ready_keys,key,NULL) == DICT_OK); in signalListAsReady()
890 serverAssert(value != NULL); in blockingPopGenericCommand()
H A Dcluster.c179 serverAssert(server.cluster->myself == NULL); in clusterLoadConfig()
233 serverAssert(p != NULL); in clusterLoadConfig()
833 serverAssert(dictDelete(server.cluster->nodes,nodename) == DICT_OK); in freeClusterNode()
915 serverAssert(retval == DICT_OK); in clusterRenameNode()
1183 serverAssert(nodeFailed(node)); in clearNodeFailureIfNeeded()
2585 serverAssert(nodeIsSlave(myself)); in clusterGetSlaveRank()
3432 serverAssert(clusterNodeClearSlotBit(n,slot) == 1); in clusterDelSlot()
3639 serverAssert(n != myself); in clusterSetMaster()
3640 serverAssert(myself->numslots == 0); in clusterSetMaster()
4403 serverAssert(rdbSaveObjectType(payload,o)); in createDumpPayload()
[all …]
H A Drdb.c385 serverAssert(enclen < 32); in rdbSaveLongLongAsStringObject()
1094 serverAssert(sdsEncodedObject(field)); in rdbLoadObject()
1097 serverAssert(sdsEncodedObject(value)); in rdbLoadObject()
1137 serverAssert(len == 0); in rdbLoadObject()
H A Drio.c303 serverAssert(r->read == rioFileIO.read); in rioSetAutoSync()
H A Ddebug.c184 serverAssert(eptr != NULL); in computeDatasetDigest()
186 serverAssert(sptr != NULL); in computeDatasetDigest()
189 serverAssert(ziplistGet(eptr,&vstr,&vlen,&vll)); in computeDatasetDigest()
H A Dt_set.c702 serverAssert(retval == DICT_OK); in srandmemberWithCountCommand()
705 serverAssert(dictSize(d) == size); in srandmemberWithCountCommand()
H A Dhyperloglog.c880 serverAssert(dense_retval == 1); in hllSparseAdd()
1111 serverAssert((p-(uint8_t*)s) == sparselen); in createHLLObject()
H A Dobject.c166 serverAssert(o->type == OBJ_STRING); in dupStringObject()
H A Dgeo.c629 serverAssert(dictAdd(zs->dict,ele,&znode->score) == DICT_OK); in georadiusGeneric()
H A Dbitops.c500 serverAssert(o->type == OBJ_STRING); in getObjectReadOnlyString()
H A Dserver.h450 #define serverAssert(_e) ((_e)?(void)0 : (_serverAssert(#_e,__FILE__,__LINE__),_exit(1))) macro
H A Dscripting.c1285 serverAssert(!lua_isnil(lua,-1)); in evalGenericCommand()
H A Dconfig.c482 serverAssert(retval == DICT_OK); in loadServerConfigFromString()
H A Dserver.c2028 serverAssert(retval1 == DICT_OK && retval2 == DICT_OK); in populateCommandTable()