Lines Matching refs:payload
2334 unsigned char buf[sizeof(clusterMsg)], *payload; in clusterSendPublish() local
2354 payload = buf; in clusterSendPublish()
2356 payload = zmalloc(totlen); in clusterSendPublish()
2357 memcpy(payload,hdr,sizeof(*hdr)); in clusterSendPublish()
2358 hdr = (clusterMsg*) payload; in clusterSendPublish()
2365 clusterSendMessage(link,payload,totlen); in clusterSendPublish()
2367 clusterBroadcastMessage(payload,totlen); in clusterSendPublish()
2371 if (payload != buf) zfree(payload); in clusterSendPublish()
4396 void createDumpPayload(rio *payload, robj *o) { in createDumpPayload() argument
4402 rioInitWithBuffer(payload,sdsempty()); in createDumpPayload()
4403 serverAssert(rdbSaveObjectType(payload,o)); in createDumpPayload()
4404 serverAssert(rdbSaveObject(payload,o)); in createDumpPayload()
4416 payload->io.buffer.ptr = sdscatlen(payload->io.buffer.ptr,buf,2); in createDumpPayload()
4419 crc = crc64(0,(unsigned char*)payload->io.buffer.ptr, in createDumpPayload()
4420 sdslen(payload->io.buffer.ptr)); 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()
4465 dumpobj = createObject(OBJ_STRING,payload.io.buffer.ptr); in dumpCommand()
4474 rio payload; in restoreCommand() local
4509 rioInitWithBuffer(&payload,c->argv[3]->ptr); in restoreCommand()
4510 if (((type = rdbLoadObjectType(&payload)) == -1) || in restoreCommand()
4511 ((obj = rdbLoadObject(type,&payload)) == NULL)) in restoreCommand()
4659 rio cmd, payload; in migrateCommand() local
4764 createDumpPayload(&payload,ov[j]); in migrateCommand()
4766 rioWriteBulkString(&cmd,payload.io.buffer.ptr, in migrateCommand()
4767 sdslen(payload.io.buffer.ptr))); in migrateCommand()
4768 sdsfree(payload.io.buffer.ptr); in migrateCommand()