Home
last modified time | relevance | path

Searched refs:sdslen (Results 1 – 25 of 41) sorted by relevance

12

/f-stack/app/redis-5.0.5/deps/hiredis/
H A Dsds.c204 len = sdslen(s); in sdsMakeRoomFor()
249 size_t len = sdslen(s); in sdsRemoveFreeSpace()
359 size_t curlen = sdslen(s); in sdsgrowzero()
377 size_t curlen = sdslen(s); in sdscatlen()
686 ep = end = s+sdslen(s)-1; in sdstrim()
742 int len = sdslen(s), j; in sdstolower()
749 int len = sdslen(s), j; in sdstoupper()
769 l1 = sdslen(s1); in sdscmp()
770 l2 = sdslen(s2); in sdscmp()
1126 sdslen(x) == 33 && in sdsTest()
[all …]
H A Dhiredis.c239 totlen += bulklen(sdslen(curarg)); in redisvFormatCommand()
388 totlen += bulklen(sdslen(curarg)); in redisvFormatCommand()
405 pos += sprintf(cmd+pos,"$%zu\r\n",sdslen(curargv[j])); in redisvFormatCommand()
406 memcpy(cmd+pos,curargv[j],sdslen(curargv[j])); in redisvFormatCommand()
407 pos += sdslen(curargv[j]); in redisvFormatCommand()
515 assert(sdslen(cmd)==totlen); in redisFormatSdsCommandArgv()
838 if (sdslen(c->obuf) > 0) { in redisBufferWrite()
839 nwritten = write(c->fd,c->obuf,sdslen(c->obuf)); in redisBufferWrite()
848 if (nwritten == (signed)sdslen(c->obuf)) { in redisBufferWrite()
856 if (done != NULL) *done = (sdslen(c->obuf) == 0); in redisBufferWrite()
H A Dasync.c66 sdslen((const sds)key)); in callbackHash()
80 l1 = sdslen((const sds)key1); in callbackKeyCompare()
81 l2 = sdslen((const sds)key2); in callbackKeyCompare()
421 if (c->flags & REDIS_DISCONNECTING && sdslen(c->obuf) == 0 in redisProcessCallbacks()
/f-stack/app/redis-5.0.5/src/
H A Dsds.c214 len = sdslen(s); in sdsMakeRoomFor()
259 size_t len = sdslen(s); in sdsRemoveFreeSpace()
380 size_t curlen = sdslen(s); in sdsgrowzero()
398 size_t curlen = sdslen(s); in sdscatlen()
709 ep = end = s+sdslen(s)-1; in sdstrim()
765 size_t len = sdslen(s), j; in sdstolower()
772 size_t len = sdslen(s), j; in sdstoupper()
792 l1 = sdslen(s1); in sdscmp()
793 l2 = sdslen(s2); in sdscmp()
1150 sdslen(x) == 33 && in sdsTest()
[all …]
H A Dt_string.c200 if (sdslen(value) == 0) { in setrangeCommand()
206 if (checkStringLength(c,offset+sdslen(value)) != C_OK) in setrangeCommand()
220 if (sdslen(value) == 0) { in setrangeCommand()
226 if (checkStringLength(c,offset+sdslen(value)) != C_OK) in setrangeCommand()
233 if (sdslen(value) > 0) { in setrangeCommand()
234 o->ptr = sdsgrowzero(o->ptr,offset+sdslen(value)); in setrangeCommand()
235 memcpy((char*)o->ptr+offset,value,sdslen(value)); in setrangeCommand()
241 addReplyLongLong(c,sdslen(o->ptr)); in setrangeCommand()
262 strlen = sdslen(str); in getrangeCommand()
451 totlen = stringObjectLen(o)+sdslen(append->ptr); in appendCommand()
[all …]
H A Dnetworking.c326 _addReplyStringToList(c,s,sdslen(s)); in addReplySds()
391 l = sdslen(s); in addReplyErrorFormat()
395 addReplyErrorLength(c,s,sdslen(s)); in addReplyErrorFormat()
414 addReplyStatusLength(c,s,sdslen(s)); in addReplyStatusFormat()
540 len = sdslen(obj->ptr); in addReplyBulkLen()
1233 if (sdslen(argv[j])) { in processInlineBuffer()
1428 while(c->qb_pos < sdslen(c->querybuf)) { in processInputBuffer()
1542 qblen = sdslen(c->querybuf); in readQueryFromClient()
1602 if (sdslen(c->querybuf) > bib) bib = sdslen(c->querybuf); in getClientsMaxBuffers()
1754 addReplyBulkCBuffer(c,o,sdslen(o)); in clientCommand()
[all …]
H A Dslowlog.c67 sdslen(argv[j]->ptr) > SLOWLOG_ENTRY_MAX_STRING) in slowlogCreateEntry()
73 sdslen(argv[j]->ptr) - SLOWLOG_ENTRY_MAX_STRING); in slowlogCreateEntry()
184 addReplyBulkCBuffer(c,se->peerid,sdslen(se->peerid)); in slowlogCommand()
185 addReplyBulkCBuffer(c,se->cname,sdslen(se->cname)); in slowlogCommand()
H A Dt_hash.c47 sdslen(argv[i]->ptr) > server.hash_max_ziplist_value) in hashTypeTryConversion()
70 fptr = ziplistFind(fptr, (unsigned char*)field, sdslen(field), 1); in hashTypeGetFromZiplist()
118 *vlen = sdslen(value); in hashTypeGetValue()
157 len = sdslen(aux); in hashTypeGetValueLength()
211 fptr = ziplistFind(fptr, (unsigned char*)field, sdslen(field), 1); in hashTypeSet()
223 sdslen(value)); in hashTypeSet()
229 zl = ziplistPush(zl, (unsigned char*)field, sdslen(field), in hashTypeSet()
231 zl = ziplistPush(zl, (unsigned char*)value, sdslen(value), in hashTypeSet()
433 *vlen = sdslen(ele); in hashTypeCurrentObject()
673 addReplyBulkCBuffer(c, value, sdslen(value)); in addHashFieldToReply()
[all …]
H A Dobject.c405 return string2ll(s,sdslen(s),llval) ? C_OK : C_ERR; in isSdsRepresentableAsLongLong()
424 sdsavail(o->ptr) > sdslen(o->ptr)/10) in trimStringObjectIfNeeded()
455 len = sdslen(s); in tryObjectEncoding()
485 emb = createEmbeddedStringObject(s,sdslen(s)); in tryObjectEncoding()
544 alen = sdslen(astr); in compareStringObjectsWithFlags()
551 blen = sdslen(bstr); in compareStringObjectsWithFlags()
596 return sdslen(o->ptr); in stringObjectLen()
613 if (sdslen(o->ptr) == 0 || in getDoubleFromObject()
655 if (sdslen(o->ptr) == 0 || in getLongDoubleFromObject()
793 asize = sdslen(o->ptr)+2+sizeof(*o); in objectComputeSize()
[all …]
H A Daof.c342 if (sdslen(server.aof_buf) == 0) { in flushAppendOnlyFile()
408 if (nwritten != (ssize_t)sdslen(server.aof_buf)) { in flushAppendOnlyFile()
484 if ((sdslen(server.aof_buf)+sdsavail(server.aof_buf)) < 4000) { in flushAppendOnlyFile()
532 len = 1+ll2string(buf+1,sizeof(buf)-1,sdslen(o->ptr)); in catAppendOnlyGenericCommand()
536 dst = sdscatlen(dst,o->ptr,sdslen(o->ptr)); in catAppendOnlyGenericCommand()
634 server.aof_buf = sdscatlen(server.aof_buf,buf,sdslen(buf)); in feedAppendOnlyFile()
641 aofRewriteBufferAppend((unsigned char*)buf,sdslen(buf)); in feedAppendOnlyFile()
914 return rioWriteBulkString(r,obj->ptr,sdslen(obj->ptr)); in rioWriteBulkObject()
990 if (rioWriteBulkString(r,ele,sdslen(ele)) == 0) return 0; in rewriteSetObject()
1089 return rioWriteBulkString(r, value, sdslen(value)); in rioWriteHashIteratorCursor()
[all …]
H A Ddb.c248 keyobj = createStringObject(key,sdslen(key)); in dbRandomKey()
540 int plen = sdslen(pattern), allkeys; in keysCommand()
551 keyobj = createStringObject(key,sdslen(key)); in keysCommand()
573 key = createStringObject(sdskey, sdslen(sdskey)); in scanCallback()
576 key = createStringObject(keysds,sdslen(keysds)); in scanCallback()
580 key = createStringObject(sdskey,sdslen(sdskey)); in scanCallback()
581 val = createStringObject(sdsval,sdslen(sdsval)); in scanCallback()
584 key = createStringObject(sdskey,sdslen(sdskey)); in scanCallback()
659 patlen = sdslen(pat); in scanGenericCommand()
1369 sdslen(argv[3]->ptr) == 0) in migrateGetKeys()
[all …]
H A Dt_set.c483 addReplyBulkCBuffer(c,sdsele,sdslen(sdsele)); in spopWithCountCommand()
484 objele = createStringObject(sdsele,sdslen(sdsele)); in spopWithCountCommand()
527 addReplyBulkCBuffer(c,sdsele,sdslen(sdsele)); in spopWithCountCommand()
528 objele = createStringObject(sdsele,sdslen(sdsele)); in spopWithCountCommand()
580 ele = createStringObject(sdsele,sdslen(sdsele)); in spopCommand()
656 addReplyBulkCBuffer(c,ele,sdslen(ele)); in srandmemberWithCountCommand()
693 retval = dictAdd(d,createStringObject(ele,sdslen(ele)),NULL); in srandmemberWithCountCommand()
723 objele = createStringObject(ele,sdslen(ele)); in srandmemberWithCountCommand()
770 addReplyBulkCBuffer(c,ele,sdslen(ele)); in srandmemberCommand()
878 addReplyBulkCBuffer(c,elesds,sdslen(elesds)); in sinterGenericCommand()
[all …]
H A Ddebug.c79 xorDigest(digest,o->ptr,sdslen(o->ptr)); in xorStringObjectDigest()
109 mixDigest(digest,o->ptr,sdslen(o->ptr)); in mixStringObjectDigest()
143 xorDigest(digest,sdsele,sdslen(sdsele)); in xorObjectDigest()
207 mixDigest(eledigest,sdsele,sdslen(sdsele)); in xorObjectDigest()
210 mixDigest(eledigest,sdsele,sdslen(sdsele)); in xorObjectDigest()
223 mixDigest(digest,itemid,sdslen(itemid)); in xorObjectDigest()
285 keyobj = createStringObject(key,sdslen(key)); in computeDatasetDigest()
287 mixDigest(digest,key,sdslen(key)); in computeDatasetDigest()
456 (long long) sdslen(key), in debugCommand()
459 (long long) sdslen(val->ptr), in debugCommand()
[all …]
H A Dscripting.c628 sdslen(o->ptr) <= LUA_CMD_OBJCACHE_MAX_LEN) in luaRedisGenericCommand()
1186 sha1hex(funcname+2,body->ptr,sdslen(body->ptr)); in luaCreateFunction()
1474 if (sdslen(c->argv[1]->ptr) != 40) { in evalShaCommand()
1612 if (ldb.maxlen && sdslen(entry) > ldb.maxlen) { in ldbLogWithMaxLen()
1639 if (write(ldb.fd,proto,sdslen(proto)) == -1) { in ldbSendLogs()
1700 size_t srclen = sdslen(srcstring); in ldbStartSession()
1837 if (sdslen(ldb.cbuf) == 0) return NULL; in ldbReplParseCommand()
1973 if (sdslen(repr1)) sdsrange(repr1,0,-3); in ldbCatStackValueRec()
1974 if (sdslen(repr2)) sdsrange(repr2,0,-3); in ldbCatStackValueRec()
2176 if (!string2l(arg,sdslen(arg),&line)) { in ldbBreak()
[all …]
H A Dpubsub.c257 sdslen(pat->pattern->ptr), in pubsubPublishMessage()
259 sdslen(channel->ptr),0)) { in pubsubPublishMessage()
351 if (!pat || stringmatchlen(pat, sdslen(pat), in pubsubCommand()
352 channel, sdslen(channel),0)) in pubsubCommand()
H A Dsort.c91 fieldlen = sdslen(spat)-(f-spat)-2; in lookupKeyByPattern()
99 sublen = sdslen(ssub); in lookupKeyByPattern()
100 postfixlen = sdslen(spat)-(prefixlen+1)-(fieldlen ? fieldlen+2 : 0); in lookupKeyByPattern()
421 vector[j].obj = createStringObject(sdsele,sdslen(sdsele)); in sortCommand()
438 vector[j].obj = createStringObject(sdsele,sdslen(sdsele)); in sortCommand()
H A Dutil.c641 if (sdslen(abspath) && abspath[sdslen(abspath)-1] != '/') in getAbsolutePath()
650 while (sdslen(relpath) >= 3 && in getAbsolutePath()
654 if (sdslen(abspath) > 1) { in getAbsolutePath()
655 char *p = abspath + sdslen(abspath)-2; in getAbsolutePath()
H A Drio.c69 if (sdslen(r->io.buffer.ptr)-r->io.buffer.pos < len) in rioBufferRead()
180 if (sdslen(r->io.fdset.buf) > PROTO_IOBUF_LEN) doflush = 1; in rioFdsetWrite()
185 len = sdslen(r->io.fdset.buf); in rioFdsetWrite()
H A Dredis-benchmark.c278 if (sdslen(c->obuf) > c->written) { in writeHandler()
280 ssize_t nwritten = write(c->context->fd,ptr,sdslen(c->obuf)-c->written); in writeHandler()
288 if (sdslen(c->obuf) == c->written) { in writeHandler()
358 (int)sdslen(config.dbnumstr),config.dbnumstr); in createClient()
361 c->prefixlen = sdslen(c->obuf); in createClient()
366 sdslen(from->obuf)-from->prefixlen); in createClient()
H A Drdb.c464 return rdbSaveRawString(rdb,obj->ptr,sdslen(obj->ptr)); in rdbSaveStringObject()
840 (unsigned char*)zn->ele,sdslen(zn->ele))) == -1) in rdbSaveObject()
876 sdslen(field))) == -1) in rdbSaveObject()
883 sdslen(value))) == -1) in rdbSaveObject()
1405 size_t len = sdslen(dec->ptr); in rdbLoadObject()
1480 if (sdslen(sdsele) > maxelelen) maxelelen = sdslen(sdsele); in rdbLoadObject()
1515 sdslen(field), ZIPLIST_TAIL); in rdbLoadObject()
1517 sdslen(value), ZIPLIST_TAIL); in rdbLoadObject()
1520 if (sdslen(field) > server.hash_max_ziplist_value || in rdbLoadObject()
1521 sdslen(value) > server.hash_max_ziplist_value) in rdbLoadObject()
[all …]
H A Dhyperloglog.c588 uint8_t *p = (uint8_t*)sparse, *end = p+sdslen(sparse); in hllSparseToDense()
674 end = p + sdslen(o->ptr) - HLL_HDR_SIZE; in hllSparseSet()
832 sdslen(o->ptr)+deltalen > server.hll_sparse_max_bytes) goto promote; in hllSparseSet()
1029 sdslen((sds)hdr)-HLL_HDR_SIZE,invalid,reghisto); in hllCount()
1080 uint8_t *p = hll->ptr, *end = p + sdslen(hll->ptr); in hllMerge()
1200 sdslen(c->argv[j]->ptr)); in pfaddCommand()
1534 uint8_t *p = o->ptr, *end = p+sdslen(o->ptr); in pfdebugCommand()
1562 addReplyBulkCBuffer(c,decoded,sdslen(decoded)); in pfdebugCommand()
H A Dt_stream.c265 lp = lpAppend(lp,(unsigned char*)field,sdslen(field)); in streamAppendItem()
298 if (sdslen(field) != (size_t)e_len || in streamAppendItem()
338 lp = lpAppend(lp,(unsigned char*)field,sdslen(field)); in streamAppendItem()
339 lp = lpAppend(lp,(unsigned char*)value,sdslen(value)); in streamAppendItem()
1106 if (sdslen(o->ptr) > sizeof(buf)-1) goto invalid; in streamGenericParseIDOrReply()
1107 memcpy(buf,o->ptr,sdslen(o->ptr)+1); in streamGenericParseIDOrReply()
1646 sdslen(groupname)); in streamLookupCG()
1656 sdslen(name)); in streamLookupConsumer()
1662 raxInsert(cg->consumers,(unsigned char*)name,sdslen(name), in streamLookupConsumer()
1691 raxRemove(cg->consumers,(unsigned char*)name,sdslen(name),NULL); in streamDelConsumer()
[all …]
H A Dcluster.c326 content_size = sdslen(ci); in clusterSaveConfig()
338 if (write(fd,ci,sdslen(ci)) != (ssize_t)sdslen(ci)) goto err; in clusterSaveConfig()
2134 if (sdslen(link->sndbuf) == 0) in clusterWriteHandler()
2151 rcvbuflen = sdslen(link->rcvbuf); in clusterReadHandler()
2526 channel_len = sdslen(channel->ptr); in clusterSendPublish()
2527 message_len = sdslen(message->ptr); in clusterSendPublish()
2547 message->ptr,sdslen(message->ptr)); in clusterSendPublish()
3973 size_t orig_len = sdslen(ci); in representClusterNodeFlags()
4502 (unsigned long)sdslen(info))); in clusterCommand()
5157 sdslen(password))); in migrateCommand()
[all …]
H A Dt_zset.c587 *dest = sdsnewlen(c+1,sdslen(c)-1); in zslParseLexRangeItem()
591 *dest = sdsnewlen(c+1,sdslen(c)-1); in zslParseLexRangeItem()
1362 if (sdslen(ele) > server.zset_max_ziplist_value) in zsetAdd()
2023 if (string2ll(val->ele,sdslen(val->ele),&val->ell)) in zuiLongLongFromValue()
2069 val->elen = sdslen(val->ele); in zuiBufferFromValue()
2307 if (sdslen(tmp) > maxelelen) maxelelen = sdslen(tmp); in zunionInterGenericCommand()
2343 if (sdslen(tmp) > maxelelen) maxelelen = sdslen(tmp); in zunionInterGenericCommand()
2503 addReplyBulkCBuffer(c,ele,sdslen(ele)); in zrangeGenericCommand()
2689 addReplyBulkCBuffer(c,ln->ele,sdslen(ln->ele)); in genericZrangebyscoreCommand()
3040 addReplyBulkCBuffer(c,ln->ele,sdslen(ln->ele)); in genericZrangebylexCommand()
[all …]
H A Dreplication.c163 len = sdslen(o->ptr); in feedReplicationBacklogWithObject()
327 sdslen(argv[j]->ptr)); in replicationFeedMonitors()
799 if (sdslen(ip) < sizeof(c->slave_ip)) { in replconfCommand()
800 memcpy(c->slave_ip,ip,sdslen(ip)+1); in replconfCommand()
803 "replica instance is too long: %zd bytes", sdslen(ip)); in replconfCommand()
883 nwritten = write(fd,slave->replpreamble,sdslen(slave->replpreamble)); in sendBulkToSlave()
892 if (sdslen(slave->replpreamble) == 0) { in sendBulkToSlave()
1368 if (syncWrite(fd,cmd,sdslen(cmd),server.repl_syncio_timeout*1000) in sendSynchronousCommand()
1485 if (sdslen(reply) == 0) { in slaveTryPartialResynchronization()

12