Home
last modified time | relevance | path

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

/f-stack/app/redis-5.0.5/src/
H A Dt_hash.c74 serverAssert(vptr != NULL); in hashTypeGetFromZiplist()
80 serverAssert(ret); in hashTypeGetFromZiplist()
93 serverAssert(o->encoding == OBJ_ENCODING_HT); in hashTypeGetFromHashTable()
215 serverAssert(vptr != NULL); in hashTypeSet()
359 serverAssert(vptr == NULL); in hashTypeNext()
363 serverAssert(vptr != NULL); in hashTypeNext()
370 serverAssert(vptr != NULL); in hashTypeNext()
396 serverAssert(ret); in hashTypeCurrentFromZiplist()
399 serverAssert(ret); in hashTypeCurrentFromZiplist()
407 serverAssert(hi->encoding == OBJ_ENCODING_HT); in hashTypeCurrentFromHashTable()
[all …]
H A Dt_zset.c137 serverAssert(!isnan(score)); in zslInsert()
346 serverAssert(x != NULL); in zslFirstInRange()
371 serverAssert(x != NULL); in zslLastInRange()
686 serverAssert(x != NULL); in zslFirstInLexRange()
711 serverAssert(x != NULL); in zslLastInLexRange()
729 serverAssert(sptr != NULL); in zzlGetScore()
749 serverAssert(sptr != NULL); in ziplistGetObject()
840 serverAssert(p != NULL); in zzlIsInRange()
859 serverAssert(sptr != NULL); in zzlFirstInRange()
939 serverAssert(p != NULL); in zzlIsInLexRange()
[all …]
H A Ddefrag.c196 serverAssert(zsl->header!=oldnode); in zslUpdateNode()
198 serverAssert(newnode->level[0].forward->backward==oldnode); in zslUpdateNode()
201 serverAssert(zsl->tail==oldnode); in zslUpdateNode()
235 serverAssert(x && score == x->score && x->ele==oldele); in zslDefrag()
535 serverAssert(ob->type == OBJ_ZSET && ob->encoding == OBJ_ENCODING_SKIPLIST); in defragZsetSkiplist()
563 serverAssert(ob->type == OBJ_HASH && ob->encoding == OBJ_ENCODING_HT); in defragHash()
581 serverAssert(ob->type == OBJ_SET && ob->encoding == OBJ_ENCODING_HT); in defragSet()
643 serverAssert(ri.key_len==sizeof(last)); in scanLaterStraemListpacks()
703 serverAssert(prev==nack); in defragStreamConsumerPendingEntry()
740 serverAssert(ob->type == OBJ_STREAM && ob->encoding == OBJ_ENCODING_STREAM); in defragStream()
[all …]
H A Daof.c235 serverAssert(server.aof_state != AOF_OFF); in stopAppendOnly()
253 serverAssert(server.aof_state == AOF_OFF); in startAppendOnly()
616 serverAssert(!(exarg && pxarg)); in feedAppendOnlyFile()
826 serverAssert(fakeClient->bufpos == 0 && in loadAppendOnlyFile()
830 serverAssert((fakeClient->flags & CLIENT_BLOCKED) == 0); in loadAppendOnlyFile()
1015 serverAssert(eptr != NULL); in rewriteSortedSetObject()
1017 serverAssert(sptr != NULL); in rewriteSortedSetObject()
1020 serverAssert(ziplistGet(eptr,&vstr,&vlen,&vll)); in rewriteSortedSetObject()
H A Dreplication.c79 serverAssert(server.repl_backlog == NULL); in createReplicationBacklog()
118 serverAssert(listLength(server.slaves) == 0); in freeReplicationBacklog()
192 serverAssert(!(listLength(slaves) != 0 && server.repl_backlog == NULL)); in replicationFeedSlaves()
1927 serverAssert(server.repl_state == REPL_STATE_TRANSFER); in replicationAbortSyncTransfer()
2168 serverAssert(server.master != NULL && server.cached_master == NULL); in replicationCacheMaster()
2367 serverAssert(retval == DICT_OK); in replicationScriptCacheAdd()
2374 serverAssert(retval == DICT_OK); in replicationScriptCacheAdd()
2478 serverAssert(ln != NULL); in unblockClientWaitingReplicas()
H A Dblocked.c118 serverAssert(ln != NULL); in processUnblockedClients()
605 serverAssert(dictAdd(db->ready_keys,key,NULL) == DICT_OK); in signalKeyAsReady()
H A Dsentinel.c478 serverAssert(retval == DICT_OK); in initSentinel()
999 serverAssert(link->refcount > 0); in releaseInstanceLink()
1042 serverAssert(ri->flags & SRI_SENTINEL); in sentinelTryConnectionSharing()
1078 serverAssert(ri->flags & SRI_SENTINEL); in sentinelUpdateSentinelAddressInAllMasters()
1175 serverAssert((flags & SRI_MASTER) || master != NULL); in createSentinelRedisInstance()
1298 serverAssert(ri->flags & SRI_MASTER); in sentinelRedisInstanceLookupSlave()
1424 serverAssert(ri->flags & SRI_MASTER); in sentinelResetMaster()
3828 serverAssert(de != NULL); in sentinelLeaderIncr()
3979 serverAssert(master->flags & SRI_MASTER); in sentinelStartFailover()
4365 serverAssert(ri->flags & SRI_MASTER); in sentinelFailoverStateMachine()
[all …]
H A Dt_set.c79 serverAssert(dictAdd(subject->ptr,sdsdup(value),NULL) == DICT_OK); in setTypeAdd()
252 serverAssert(dictAdd(d,element,NULL) == DICT_OK); in setTypeConvert()
695 serverAssert(retval == DICT_OK); in srandmemberWithCountCommand()
698 serverAssert(dictSize(d) == size); in srandmemberWithCountCommand()
H A Dnetworking.c439 serverAssert(!listNodeValue(ln)); in setDeferredMultiBulkLength()
832 serverAssert(ln != NULL); in unlinkClient()
841 serverAssert(ln != NULL); in unlinkClient()
916 serverAssert(ln != NULL); in freeClient()
934 serverAssert(ln != NULL); in freeClient()
1020 serverAssert(c->reply_bytes == 0); in writeToClient()
2124 serverAssert(c->reply_bytes < SIZE_MAX-(1024*64)); in asyncCloseClientOnOutputBufferLimitReached()
H A Dt_stream.c115 serverAssert(retval != 0); in lpGetInteger()
273 serverAssert(ri.key_len == sizeof(rax_key)); in streamAppendItem()
404 serverAssert(to_delete < entries); in streamTrimByLength()
541 serverAssert(si->ri.key_len == sizeof(streamID)); in streamIteratorGetID()
969 serverAssert(nack != raxNotFound); in streamReplyWithRange()
1781 serverAssert(mkstream); in xgroupCommand()
H A Drio.c303 serverAssert(r->read == rioFileIO.read); in rioSetAutoSync()
H A Dcluster.c189 serverAssert(server.cluster->myself == NULL); in clusterLoadConfig()
245 serverAssert(p != NULL); in clusterLoadConfig()
875 serverAssert(dictDelete(server.cluster->nodes,nodename) == DICT_OK); in freeClusterNode()
957 serverAssert(retval == DICT_OK); in clusterRenameNode()
1225 serverAssert(nodeFailed(node)); in clearNodeFailureIfNeeded()
2826 serverAssert(nodeIsSlave(myself)); in clusterGetSlaveRank()
3719 serverAssert(clusterNodeClearSlotBit(n,slot) == 1); in clusterDelSlot()
3933 serverAssert(n != myself); in clusterSetMaster()
3934 serverAssert(myself->numslots == 0); in clusterSetMaster()
4786 serverAssert(rdbSaveObjectType(payload,o)); in createDumpPayload()
[all …]
H A Dt_list.c114 serverAssert(li->subject->encoding == li->encoding); in listTypeNext()
705 serverAssert(value != NULL); in blockingPopGenericCommand()
H A Dobject.c70 serverAssert(o->refcount == 1); in makeObjectShared()
196 serverAssert(o->type == OBJ_STRING); in dupStringObject()
1209 serverAssert(lfu_freq <= 255); in objectSetLRUOrLFU()
H A Ddb.c318 serverAssert(o->type == OBJ_STRING); in dbUnshareStringValue()
635 serverAssert(o == NULL || o->type == OBJ_SET || o->type == OBJ_HASH || in scanGenericCommand()
754 serverAssert(kobj->encoding == OBJ_ENCODING_INT); in scanGenericCommand()
H A Ddebug.c159 serverAssert(eptr != NULL); in xorObjectDigest()
161 serverAssert(sptr != NULL); in xorObjectDigest()
164 serverAssert(ziplistGet(eptr,&vstr,&vlen,&vll)); in xorObjectDigest()
H A Dhyperloglog.c893 serverAssert(dense_retval == 1); in hllSparseSet()
1136 serverAssert((p-(uint8_t*)s) == sparselen); in createHLLObject()
H A Dgeo.c654 serverAssert(dictAdd(zs->dict,gp->member,&znode->score) == DICT_OK); in georadiusGeneric()
H A Dbitops.c507 serverAssert(o->type == OBJ_STRING); in getObjectReadOnlyString()
H A Drdb.c447 serverAssert(enclen < 32); in rdbSaveLongLongAsStringObject()
1552 serverAssert(len == 0); in rdbLoadObject()
H A Dserver.h457 #define serverAssert(_e) ((_e)?(void)0 : (_serverAssert(#_e,__FILE__,__LINE__),_exit(1))) macro
H A Dscripting.c1340 serverAssert(!lua_isnil(lua,-1)); in evalGenericCommand()
H A Dconfig.c619 serverAssert(retval == DICT_OK); in loadServerConfigFromString()
H A Dserver.c2227 serverAssert(retval1 == DICT_OK && retval2 == DICT_OK); in populateCommandTable()