| /redis-3.2.3/src/ |
| H A D | notify.c | 72 res = sdscatlen(res,"A",1); in keyspaceEventsFlagsToString() 76 if (flags & NOTIFY_LIST) res = sdscatlen(res,"l",1); in keyspaceEventsFlagsToString() 77 if (flags & NOTIFY_SET) res = sdscatlen(res,"s",1); in keyspaceEventsFlagsToString() 78 if (flags & NOTIFY_HASH) res = sdscatlen(res,"h",1); in keyspaceEventsFlagsToString() 79 if (flags & NOTIFY_ZSET) res = sdscatlen(res,"z",1); in keyspaceEventsFlagsToString() 83 if (flags & NOTIFY_KEYSPACE) res = sdscatlen(res,"K",1); in keyspaceEventsFlagsToString() 84 if (flags & NOTIFY_KEYEVENT) res = sdscatlen(res,"E",1); in keyspaceEventsFlagsToString() 110 chan = sdscatlen(chan, buf, len); in notifyKeyspaceEvent() 111 chan = sdscatlen(chan, "__:", 3); in notifyKeyspaceEvent() 122 chan = sdscatlen(chan, buf, len); in notifyKeyspaceEvent() [all …]
|
| H A D | sds.c | 376 sds sdscatlen(sds s, const void *t, size_t len) { in sdscatlen() function 392 return sdscatlen(s, t, strlen(t)); in sdscat() 400 return sdscatlen(s, t, sdslen(t)); in sdscatsds() 859 s = sdscatlen(s,"\"",1); in sdscatrepr() 866 case '\n': s = sdscatlen(s,"\\n",2); break; in sdscatrepr() 867 case '\r': s = sdscatlen(s,"\\r",2); break; in sdscatrepr() 868 case '\t': s = sdscatlen(s,"\\t",2); break; in sdscatrepr() 869 case '\a': s = sdscatlen(s,"\\a",2); break; in sdscatrepr() 870 case '\b': s = sdscatlen(s,"\\b",2); break; in sdscatrepr() 880 return sdscatlen(s,"\"",1); in sdscatrepr() [all …]
|
| H A D | scripting.c | 797 log = sdscatlen(log,s,len); in luaLogCommand() 1150 funcdef = sdscatlen(funcdef,"() ",3); in luaCreateFunction() 1567 proto = sdscatlen(proto,"+",1); in ldbSendLogs() 1875 s = sdscatlen(s,"nil",3); in ldbCatStackValueRec() 1909 s = sdscatlen(s,"{",1); in ldbCatStackValueRec() 1911 s = sdscatlen(s,"}",1); in ldbCatStackValueRec() 1979 *o = sdscatlen(*o,reply+1,p-reply-1); in ldbRedisProtocolToHuman_Int() 1989 *o = sdscatlen(*o,"NULL",4); in ldbRedisProtocolToHuman_Bulk() 2012 *o = sdscatlen(*o,"NULL",4); in ldbRedisProtocolToHuman_MultiBulk() 2015 *o = sdscatlen(*o,"[",1); in ldbRedisProtocolToHuman_MultiBulk() [all …]
|
| H A D | sparkline.c | 156 output = sdscatlen(output,chars,len); in sparklineRenderRange() 157 output = sdscatlen(output,"\n",1); in sparklineRenderRange() 171 if (j != 0) output = sdscatlen(output,"\n",1); in sparklineRender()
|
| H A D | redis-benchmark.c | 347 c->obuf = sdscatlen(c->obuf, buf, len); in createClient() 364 c->obuf = sdscatlen(c->obuf, in createClient() 369 c->obuf = sdscatlen(c->obuf,cmd,len); in createClient() 705 title = sdscatlen(title, " ", 1); in main() 706 title = sdscatlen(title, (char*)argv[i], strlen(argv[i])); in main()
|
| H A D | latency.c | 378 report = sdscatlen(report,"\n",1); in createLatencyReport() 553 graph = sdscatlen(graph,"-",1); in latencyCommandGenSparkeline() 554 graph = sdscatlen(graph,"\n",1); in latencyCommandGenSparkeline()
|
| H A D | rio.c | 62 r->io.buffer.ptr = sdscatlen(r->io.buffer.ptr,(char*)buf,len); in rioBufferWrite() 178 r->io.fdset.buf = sdscatlen(r->io.fdset.buf,buf,len); in rioFdsetWrite()
|
| H A D | aof.c | 458 dst = sdscatlen(dst,buf,len); in catAppendOnlyGenericCommand() 466 dst = sdscatlen(dst,buf,len); in catAppendOnlyGenericCommand() 467 dst = sdscatlen(dst,o->ptr,sdslen(o->ptr)); in catAppendOnlyGenericCommand() 468 dst = sdscatlen(dst,"\r\n",2); in catAppendOnlyGenericCommand() 549 server.aof_buf = sdscatlen(server.aof_buf,buf,sdslen(buf)); in feedAppendOnlyFile() 1002 server.aof_child_diff = sdscatlen(server.aof_child_diff,buf,nread); in aofReadDiffFromParent()
|
| H A D | redis-cli.c | 605 out = sdscatlen(out,tmp,sdslen(tmp)); in cliFormatReplyTTY() 626 if (!isColorTerm()) return sdscatlen(o,s,len); in sdscatcolor() 640 o = sdscatlen(o,s,len); in sdscatcolor() 672 out = sdscatlen(out,r->str,r->len); in cliFormatReplyRaw() 673 out = sdscatlen(out,"\n",1); in cliFormatReplyRaw() 693 out = sdscatlen(out,r->str,r->len); in cliFormatReplyRaw() 703 out = sdscatlen(out,tmp,sdslen(tmp)); in cliFormatReplyRaw() 738 out = sdscatlen(out,tmp,sdslen(tmp)); in cliFormatReplyCSV() 1092 arg = sdscatlen(arg,buf,nread); in readArgFromStdin() 1406 script = sdscatlen(script,buf,nread); in evalMode()
|
| H A D | config.c | 1182 buf = sdscatlen(buf," ",1); 1200 buf = sdscatlen(buf," ",1); 1486 line = sdscatlen(line, " ", 1); 1585 line = sdscatlen(line, " ", 1); 1633 line = sdscatlen(line, " ", 1); 1655 content = sdscatlen(content,"\n",1);
|
| H A D | cluster.c | 2061 link->rcvbuf = sdscatlen(link->rcvbuf,buf,nread); in clusterReadHandler() 2088 link->sndbuf = sdscatlen(link->sndbuf, msg, msglen); in clusterSendMessage() 3712 ci = sdscatlen(ci," - ",3); in clusterGenNodeDescription() 3784 ci = sdscatlen(ci,"\n",1); in clusterGenNodesDescription() 4416 payload->io.buffer.ptr = sdscatlen(payload->io.buffer.ptr,buf,2); in createDumpPayload() 4560 name = sdscatlen(name,host->ptr,sdslen(host->ptr)); in migrateGetSocket() 4561 name = sdscatlen(name,":",1); in migrateGetSocket() 4562 name = sdscatlen(name,port->ptr,sdslen(port->ptr)); in migrateGetSocket() 4614 name = sdscatlen(name,host->ptr,sdslen(host->ptr)); in migrateCloseSocket() 4615 name = sdscatlen(name,":",1); in migrateCloseSocket() [all …]
|
| H A D | sds.h | 223 sds sdscatlen(sds s, const void *t, size_t len);
|
| H A D | networking.c | 249 tail->ptr = sdscatlen(tail->ptr,o->ptr,sdslen(o->ptr)); in _addReplyObjectToList() 282 tail->ptr = sdscatlen(tail->ptr,s,sdslen(s)); in _addReplySdsToList() 312 tail->ptr = sdscatlen(tail->ptr,s,len); in _addReplyStringToList() 460 len->ptr = sdscatlen(len->ptr,next->ptr,sdslen(next->ptr)); in setDeferredMultiBulkLength() 1480 o = sdscatlen(o,"\n",1); in getAllClientsInfoString()
|
| H A D | replication.c | 294 cmdrepr = sdscatlen(cmdrepr," ",1); in replicationFeedMonitors() 296 cmdrepr = sdscatlen(cmdrepr,"\r\n",2); in replicationFeedMonitors() 1195 if (sdslen(cmd) != 0) cmd = sdscatlen(cmd," ",1); in sendSynchronousCommand() 1198 cmd = sdscatlen(cmd,"\r\n",2); in sendSynchronousCommand()
|
| H A D | t_string.c | 459 o->ptr = sdscatlen(o->ptr,append->ptr,sdslen(append->ptr)); in appendCommand()
|
| H A D | debug.c | 489 errstr = sdscatlen(errstr,"\r\n",2); in debugCommand()
|
| H A D | sentinel.c | 3205 info = sdscatlen(info,redissection,sdslen(redissection)); \
|
| /redis-3.2.3/deps/hiredis/ |
| H A D | sds.c | 376 sds sdscatlen(sds s, const void *t, size_t len) { in sdscatlen() function 392 return sdscatlen(s, t, strlen(t)); in sdscat() 400 return sdscatlen(s, t, sdslen(t)); in sdscatsds() 859 s = sdscatlen(s,"\"",1); in sdscatrepr() 866 case '\n': s = sdscatlen(s,"\\n",2); break; in sdscatrepr() 867 case '\r': s = sdscatlen(s,"\\r",2); break; in sdscatrepr() 868 case '\t': s = sdscatlen(s,"\\t",2); break; in sdscatrepr() 869 case '\a': s = sdscatlen(s,"\\a",2); break; in sdscatrepr() 870 case '\b': s = sdscatlen(s,"\\b",2); break; in sdscatrepr() 880 return sdscatlen(s,"\"",1); in sdscatrepr() [all …]
|
| H A D | hiredis.c | 604 newbuf = sdscatlen(r->buf,buf,len); in redisReaderFeed() 722 newarg = sdscatlen(curarg,c,1); in redisvFormatCommand() 739 newarg = sdscatlen(curarg,arg,size); in redisvFormatCommand() 745 newarg = sdscatlen(curarg,arg,size); in redisvFormatCommand() 1250 newbuf = sdscatlen(c->obuf,cmd,len); in __redisAppendCommand()
|
| H A D | sds.h | 223 sds sdscatlen(sds s, const void *t, size_t len);
|