Home
last modified time | relevance | path

Searched refs:count (Results 1 – 25 of 59) sorted by relevance

123

/redis-3.2.3/deps/jemalloc/test/include/test/
H A Dmq.h35 unsigned count; \
43 mq->count = 0; \
53 a_prefix##count(a_mq_type *mq) \
55 unsigned count; \
58 count = mq->count; \
60 return (count); \
71 mq->count--; \
107 mq->count++; \
/redis-3.2.3/src/
H A Dquicklist.c142 node->count = 0; in quicklistCreateNode()
165 quicklist->count -= current->count; in quicklistRelease()
465 else if ((int)(a->count + b->count) <= fill) in _quicklistNodeAllowMerge()
533 quicklist->count += node->count; in quicklistAppendZiplist()
598 quicklist->count -= node->count; in __quicklistDelNode()
618 node->count--; in quicklistDelIndex()
698 D("Requested merge (a,b) (%u, %u)", a->count, b->count); in _quicklistZiplistMerge()
960 if (count <= 0) in quicklistDelRange()
1205 node->count = current->count; in quicklistDup()
1206 copy->count += node->count; in quicklistDup()
[all …]
H A Drio.c192 size_t count = len < 1024 ? len : 1024; in rioFdsetWrite() local
204 while(nwritten != count) { in rioFdsetWrite()
205 retval = write(r->io.fdset.fds[j],p+nwritten,count-nwritten); in rioFdsetWrite()
217 if (nwritten != count) { in rioFdsetWrite()
224 p += count; in rioFdsetWrite()
225 len -= count; in rioFdsetWrite()
226 r->io.fdset.pos += count; in rioFdsetWrite()
313 size_t rioWriteBulkCount(rio *r, char prefix, int count) { in rioWriteBulkCount() argument
318 clen = 1+ll2string(cbuf+1,sizeof(cbuf)-1,count); in rioWriteBulkCount()
H A Daof.c176 ssize_t count = 0; in aofRewriteBufferWrite() local
189 count += nwritten; in aofRewriteBufferWrite()
192 return count; in aofRewriteBufferWrite()
796 if (count == 0) { in rewriteListObject()
809 if (++count == AOF_REWRITE_ITEMS_PER_CMD) count = 0; in rewriteListObject()
838 if (++count == AOF_REWRITE_ITEMS_PER_CMD) count = 0; in rewriteSetObject()
856 if (++count == AOF_REWRITE_ITEMS_PER_CMD) count = 0; in rewriteSetObject()
903 if (++count == AOF_REWRITE_ITEMS_PER_CMD) count = 0; in rewriteSortedSetObject()
925 if (++count == AOF_REWRITE_ITEMS_PER_CMD) count = 0; in rewriteSortedSetObject()
973 if (count == 0) { in rewriteHashObject()
[all …]
H A Dt_set.c419 count = (unsigned) l; in spopWithCountCommand()
432 if (count == 0) { in spopWithCountCommand()
441 server.dirty += count; in spopWithCountCommand()
446 if (count >= size) { in spopWithCountCommand()
483 while(count--) { in spopWithCountCommand()
634 count = (unsigned) l; in srandmemberWithCountCommand()
638 count = -l; in srandmemberWithCountCommand()
647 if (count == 0) { in srandmemberWithCountCommand()
658 while(count--) { in srandmemberWithCountCommand()
672 if (count >= size) { in srandmemberWithCountCommand()
[all …]
H A Dzmalloc.c60 #define calloc(count,size) tc_calloc(count,size) argument
65 #define calloc(count,size) je_calloc(count,size) argument
269 int fd, count; in zmalloc_get_rss() local
281 count = 23; /* RSS is the 24th field in /proc/<pid>/stat */ in zmalloc_get_rss()
282 while(p && count--) { in zmalloc_get_rss()
H A Dmulti.c37 c->mstate.count = 0; in initClientMultiState()
44 for (j = 0; j < c->mstate.count; j++) { in freeClientMultiState()
61 sizeof(multiCmd)*(c->mstate.count+1)); in queueMultiCommand()
62 mc = c->mstate.commands+c->mstate.count; in queueMultiCommand()
69 c->mstate.count++; in queueMultiCommand()
144 addReplyMultiBulkLen(c,c->mstate.count); in execCommand()
145 for (j = 0; j < c->mstate.count; j++) { in execCommand()
H A Dpubsub.c181 int count = 0; in pubsubUnsubscribeAllChannels() local
186 count += pubsubUnsubscribeChannel(c,channel,notify); in pubsubUnsubscribeAllChannels()
189 if (notify && count == 0) { in pubsubUnsubscribeAllChannels()
197 return count; in pubsubUnsubscribeAllChannels()
205 int count = 0; in pubsubUnsubscribeAllPatterns() local
211 count += pubsubUnsubscribePattern(c,pattern,notify); in pubsubUnsubscribeAllPatterns()
213 if (notify && count == 0) { in pubsubUnsubscribeAllPatterns()
221 return count; in pubsubUnsubscribeAllPatterns()
H A Dsha1.c125 context->count[0] = context->count[1] = 0; in SHA1Init()
135 j = context->count[0]; in SHA1Update()
136 if ((context->count[0] += len << 3) < j) in SHA1Update()
137 context->count[1]++; in SHA1Update()
138 context->count[1] += (len>>29); in SHA1Update()
171 uint32_t t = context->count[i]; in SHA1Final()
179 finalcount[i] = (unsigned char)((context->count[(i >= 4 ? 0 : 1)] in SHA1Final()
185 while ((context->count[0] & 504) != 448) { in SHA1Final()
H A Dbitops.c40 size_t redisPopcount(void *s, long count) { in redisPopcount() argument
47 while((unsigned long)p & 3 && count) { in redisPopcount()
49 count--; in redisPopcount()
54 while(count>=28) { in redisPopcount()
64 count -= 28; in redisPopcount()
123 count--; in redisBitpos()
130 while (count >= sizeof(*l)) { in redisBitpos()
133 count -= sizeof(*l); in redisBitpos()
147 if (count) { in redisBitpos()
150 count--; in redisBitpos()
[all …]
H A Dhyperloglog.c446 int count; in hllPatLen() local
465 count++; in hllPatLen()
469 return count; in hllPatLen()
486 uint8_t oldcount, count; in hllDenseAdd() local
490 count = hllPatLen(ele,elesize,&index); in hllDenseAdd()
492 if (count > oldcount) { in hllDenseAdd()
645 count = hllPatLen(ele,elesize,&index); in hllSparseAdd()
733 if (oldcount >= count) return 0; in hllSparseAdd()
745 HLL_SPARSE_VAL_SET(p,count,1); in hllSparseAdd()
780 HLL_SPARSE_VAL_SET(n,count,1); in hllSparseAdd()
[all …]
H A Dgeo.c330 unsigned int i, count = 0, last_processed = 0; in membersOfAllNeighbors() local
356 count += membersOfGeoHashBox(zobj, neighbors[i], ga, lon, lat, radius); in membersOfAllNeighbors()
359 return count; in membersOfAllNeighbors()
481 long long count = 0; in georadiusGeneric() local
498 &count, NULL) != C_OK) return; in georadiusGeneric()
499 if (count <= 0) { in georadiusGeneric()
529 if (count != 0 && sort == SORT_NONE) sort = SORT_ASC; in georadiusGeneric()
547 long returned_items = (count == 0 || result_length < count) ? in georadiusGeneric()
548 result_length : count; in georadiusGeneric()
H A Ddb.c363 long long count = 0; in existsCommand() local
368 if (dbExists(c->db,c->argv[j])) count++; in existsCommand()
370 addReplyLongLong(c,count); in existsCommand()
495 long count = 10; in scanGenericCommand() local
518 if (count < 1) { in scanGenericCommand()
568 long maxiterations = count*10; in scanGenericCommand()
1267 while(n && n->score == hashslot && count--) { in getKeysInSlot()
1300 int rank, count = 0; in countKeysInSlot() local
1311 count = (zsl->length - (rank - 1)); in countKeysInSlot()
1319 count -= (zsl->length - rank); in countKeysInSlot()
[all …]
H A Dslowlog.c139 long count = 10, sent = 0; in slowlogCommand() local
146 getLongFromObjectOrReply(c,c->argv[2],&count,NULL) != C_OK) in slowlogCommand()
151 while(count-- && (ln = listNext(&li))) { in slowlogCommand()
H A Danet.h58 int anetRead(int fd, char *buf, int count);
66 int anetWrite(int fd, char *buf, int count);
H A Ddict.c689 unsigned int dictGetSomeKeys(dict *d, dictEntry **des, unsigned int count) { in dictGetSomeKeys() argument
695 if (dictSize(d) < count) count = dictSize(d); in dictGetSomeKeys()
696 maxsteps = count*10; in dictGetSomeKeys()
699 for (j = 0; j < count; j++) { in dictGetSomeKeys()
714 while(stored < count && maxsteps--) { in dictGetSomeKeys()
734 if (emptylen >= 5 && emptylen > count) { in dictGetSomeKeys()
747 if (stored == count) return stored; in dictGetSomeKeys()
H A Dquicklist.h49 unsigned int count : 16; /* count of items in ziplist */ member
76 unsigned long count; /* total count of all entries in all ziplists */ member
/redis-3.2.3/tests/unit/
H A Dscan.tcl27 set res [r scan $cur count 5]
95 set count 30
97 set count 1000
100 for {set j 0} {$j < $count} {incr j} {
126 assert_equal $count [llength $keys2]
135 set count 30
137 set count 1000
140 for {set j 0} {$j < $count} {incr j} {
166 assert_equal $count [llength $keys2]
H A Dother.tcl186 gets $fd2 count
187 set count [string range $count 1 end]
188 set val [read $fd2 $count]
/redis-3.2.3/tests/
H A Dtest_helper.tcl471 set count [gets $s]
472 set prefix [string range $count 0 0]
476 error "attach_to_replication_stream error. Received '$count' as count."
478 set count [string range $count 1 end]
481 while {$count} {
482 set buf [read $s $count]
483 set count [expr {$count-[string length $buf]}]
491 while {[gets $s count] == -1} {
496 set count [string range $count 1 end]
500 for {set j 0} {$j < $count} {incr j} {
H A Dinstances.tcl57 proc spawn_instance {type base_port count {conf {}}} {
58 for {set j 0} {$j < $count} {incr j} {
183 set count 10
184 if {[lindex $argv 1] ne {}} {set count [lindex $argv 1]}
187 puts [exec tail -$count redis_$id/log.txt]
191 set count 10
192 if {[lindex $argv 1] ne {}} {set count [lindex $argv 1]}
195 puts [exec tail -$count sentinel_$id/log.txt]
/redis-3.2.3/deps/jemalloc/src/
H A Dckh.c109 ckh->count++; in ckh_try_bucket_insert()
225 size_t count, i, nins; in ckh_rebuild() local
228 count = ckh->count; in ckh_rebuild()
229 ckh->count = 0; in ckh_rebuild()
230 for (i = nins = 0; nins < count; i++) { in ckh_rebuild()
235 ckh->count = count; in ckh_rebuild()
369 ckh->count = 0; in ckh_new()
435 return (ckh->count); in ckh_count()
499 ckh->count--; in ckh_remove()
501 if (ckh->count < (ZU(1) << (ckh->lg_curbuckets in ckh_remove()
/redis-3.2.3/tests/support/
H A Dredis.tcl176 set count [redis_read_line $fd]
177 if {$count == -1} return {}
178 set buf [redis_readnl $fd $count]
183 set count [redis_read_line $fd]
184 if {$count == -1} return {}
187 for {set i 0} {$i < $count} {incr i} {
/redis-3.2.3/deps/lua/src/
H A Dldblib.c225 static int makemask (const char *smask, int count) { in makemask() argument
230 if (count > 0) mask |= LUA_MASKCOUNT; in makemask()
259 int arg, mask, count; in db_sethook() local
264 func = NULL; mask = 0; count = 0; /* turn off hooks */ in db_sethook()
269 count = luaL_optint(L, arg+3, 0); in db_sethook()
270 func = hookf; mask = makemask(smask, count); in db_sethook()
277 lua_sethook(L1, func, mask, count); /* set hooks */ in db_sethook()
/redis-3.2.3/deps/jemalloc/bin/
H A Djeprof.in1112 my $count = $profile->{$k};
1118 print pack('L*', $count & 0xFFFFFFFF, int($count / 2**32));
2740 my $count = $profile->{$k};
2756 my $count = $profile->{$k};
2949 my $count = $profile->{$k};
2979 my $count = $profile->{$k};
3019 my $count = $profile->{$k};
3172 my $count = shift;
4231 my @values = ($cycles, $count, $cycles / $count);
4858 $count++;
[all …]

123