Home
last modified time | relevance | path

Searched refs:payload (Results 1 – 6 of 6) sorted by relevance

/redis-3.2.3/tests/unit/
H A Dprotocol.tcl77 set payload [string repeat A 1024]"\n"
82 puts -nonewline $s payload
84 incr payload_size [string length $payload]
/redis-3.2.3/tests/
H A Dtest_helper.tcl248 set payload [read $fd $bytes]
249 foreach {status data} $payload break
377 set payload [read $::test_server_fd $bytes]
378 foreach {cmd data} $payload break
388 set payload [list $status $data]
389 puts $fd [string length $payload]
390 puts -nonewline $fd $payload
/redis-3.2.3/tests/unit/type/
H A Dstring.tcl12 test {Very big payload in GET/SET} {
19 test {Very big payload random access} {
21 array set payload {}
25 set payload($j) $buf
31 if {$buf != $payload($index)} {
32 set err "Values differ: I set '$payload($index)' but I read back '$buf'"
36 unset payload
/redis-3.2.3/src/
H A Dcluster.c2354 payload = buf; in clusterSendPublish()
2356 payload = zmalloc(totlen); in clusterSendPublish()
2358 hdr = (clusterMsg*) payload; in clusterSendPublish()
2371 if (payload != buf) zfree(payload); in clusterSendPublish()
4416 payload->io.buffer.ptr = sdscatlen(payload->io.buffer.ptr,buf,2); in createDumpPayload()
4422 payload->io.buffer.ptr = sdscatlen(payload->io.buffer.ptr,&crc,8); in createDumpPayload()
4453 rio payload; in dumpCommand() local
4462 createDumpPayload(&payload,o); in dumpCommand()
4474 rio payload; in restoreCommand() local
4659 rio cmd, payload; in migrateCommand() local
[all …]
H A Dredis-cli.c1688 unsigned long long payload = sendSync(fd); in slaveMode() local
1693 "bytes of bulk transfer...\n", payload); in slaveMode()
1696 while(payload) { in slaveMode()
1699 nread = read(fd,buf,(payload > sizeof(buf)) ? sizeof(buf) : payload); in slaveMode()
1704 payload -= nread; in slaveMode()
1723 unsigned long long payload = sendSync(s); in getRDB() local
1727 payload, config.rdb_filename); in getRDB()
1741 while(payload) { in getRDB()
1744 nread = read(s,buf,(payload > sizeof(buf)) ? sizeof(buf) : payload); in getRDB()
1755 payload -= nread; in getRDB()
H A Dsentinel.c586 robj *channel, *payload; in sentinelEvent() local
622 payload = createStringObject(msg,strlen(msg)); in sentinelEvent()
623 pubsubPublishMessage(channel,payload); in sentinelEvent()
625 decrRefCount(payload); in sentinelEvent()
2467 char payload[NET_IP_STR_LEN+1024]; in sentinelSendHello() local
2489 snprintf(payload,sizeof(payload), in sentinelSendHello()
2499 SENTINEL_HELLO_CHANNEL,payload); in sentinelSendHello()