Lines Matching refs:message
739 response->message.header.response.keylen = ntohs(response->message.header.response.keylen); in safe_recv_packet()
740 response->message.header.response.status = ntohs(response->message.header.response.status); in safe_recv_packet()
741 response->message.header.response.bodylen = ntohl(response->message.header.response.bodylen); in safe_recv_packet()
747 if (!safe_recv(ptr, response->message.header.response.bodylen)) { in safe_recv_packet()
754 len += response->message.header.response.bodylen; in safe_recv_packet()
784 request->message.header.request.magic = PROTOCOL_BINARY_REQ; in storage_command()
785 request->message.header.request.opcode = cmd; in storage_command()
786 request->message.header.request.keylen = htons(keylen); in storage_command()
787 request->message.header.request.extlen = 8; in storage_command()
788 request->message.header.request.bodylen = htonl(keylen + 8 + dtalen); in storage_command()
789 request->message.header.request.opaque = 0xdeadbeef; in storage_command()
790 request->message.body.flags = flags; in storage_command()
791 request->message.body.expiration = exp; in storage_command()
816 request->message.header.request.magic = PROTOCOL_BINARY_REQ; in ext_command()
817 request->message.header.request.opcode = cmd; in ext_command()
818 request->message.header.request.extlen = extlen; in ext_command()
819 request->message.header.request.keylen = htons(keylen); in ext_command()
820 request->message.header.request.bodylen = htonl(extlen + keylen + dtalen); in ext_command()
821 request->message.header.request.opaque = 0xdeadbeef; in ext_command()
856 request->message.header.request.magic = PROTOCOL_BINARY_REQ; in flush_command()
857 request->message.header.request.opcode = cmd; in flush_command()
861 request->message.header.request.extlen = 4; in flush_command()
862 request->message.body.expiration = htonl(exptime); in flush_command()
863 request->message.header.request.bodylen = htonl(4); in flush_command()
867 request->message.header.request.opaque = 0xdeadbeef; in flush_command()
883 request->message.header.request.magic = PROTOCOL_BINARY_REQ; in touch_command()
884 request->message.header.request.opcode = cmd; in touch_command()
886 request->message.header.request.keylen = htons(keylen); in touch_command()
887 request->message.header.request.extlen = 4; in touch_command()
888 request->message.body.expiration = htonl(exptime); in touch_command()
889 request->message.header.request.bodylen = htonl(keylen + 4); in touch_command()
891 request->message.header.request.opaque = 0xdeadbeef; in touch_command()
911 request->message.header.request.magic = PROTOCOL_BINARY_REQ; in arithmetic_command()
912 request->message.header.request.opcode = cmd; in arithmetic_command()
913 request->message.header.request.keylen = htons(keylen); in arithmetic_command()
914 request->message.header.request.extlen = 20; in arithmetic_command()
915 request->message.header.request.bodylen = htonl(keylen + 20); in arithmetic_command()
916 request->message.header.request.opaque = 0xdeadbeef; in arithmetic_command()
917 request->message.body.delta = htonll(delta); in arithmetic_command()
918 request->message.body.initial = htonll(initial); in arithmetic_command()
919 request->message.body.expiration = htonl(exp); in arithmetic_command()
930 assert(response->message.header.response.magic == PROTOCOL_BINARY_RES); in validate_response_header()
931 assert(response->message.header.response.opcode == cmd); in validate_response_header()
932 assert(response->message.header.response.datatype == PROTOCOL_BINARY_RAW_BYTES); in validate_response_header()
933 assert(response->message.header.response.status == status); in validate_response_header()
934 assert(response->message.header.response.opaque == 0xdeadbeef); in validate_response_header()
959 assert(response->message.header.response.keylen == 0); in validate_response_header()
960 assert(response->message.header.response.extlen == 0); in validate_response_header()
961 assert(response->message.header.response.bodylen == 0); in validate_response_header()
962 assert(response->message.header.response.cas != 0); in validate_response_header()
968 assert(response->message.header.response.keylen == 0); in validate_response_header()
969 assert(response->message.header.response.extlen == 0); in validate_response_header()
970 assert(response->message.header.response.bodylen == 0); in validate_response_header()
971 assert(response->message.header.response.cas == 0); in validate_response_header()
976 assert(response->message.header.response.keylen == 0); in validate_response_header()
977 assert(response->message.header.response.extlen == 0); in validate_response_header()
978 assert(response->message.header.response.bodylen == 8); in validate_response_header()
979 assert(response->message.header.response.cas != 0); in validate_response_header()
983 assert(response->message.header.response.extlen == 0); in validate_response_header()
985 assert(response->message.header.response.cas == 0); in validate_response_header()
989 assert(response->message.header.response.keylen == 0); in validate_response_header()
990 assert(response->message.header.response.extlen == 0); in validate_response_header()
991 assert(response->message.header.response.bodylen != 0); in validate_response_header()
992 assert(response->message.header.response.cas == 0); in validate_response_header()
999 assert(response->message.header.response.keylen == 0); in validate_response_header()
1000 assert(response->message.header.response.extlen == 4); in validate_response_header()
1001 assert(response->message.header.response.cas != 0); in validate_response_header()
1008 assert(response->message.header.response.keylen != 0); in validate_response_header()
1009 assert(response->message.header.response.extlen == 4); in validate_response_header()
1010 assert(response->message.header.response.cas != 0); in validate_response_header()
1018 assert(response->message.header.response.cas == 0); in validate_response_header()
1019 assert(response->message.header.response.extlen == 0); in validate_response_header()
1022 assert(response->message.header.response.keylen == 0); in validate_response_header()
1104 send.request.message.header.request.cas = receive.response.message.header.response.cas; in test_binary_set_impl()
1110 … assert(receive.response.message.header.response.cas != send.request.message.header.request.cas); in test_binary_set_impl()
1360 temp.request.message.header.request.opaque = 0xfeedface; in test_binary_getq_impl()
1415 assert(ntohll(receive.response.message.body.value) == ii); in test_binary_incr_impl()
1452 assert(ntohll(receive.response.message.body.value) == ii); in test_binary_decr_impl()
1462 assert(ntohll(receive.response.message.body.value) == 0); in test_binary_decr_impl()
1625 assert(receive.response.message.header.response.keylen == strlen(key)); in test_binary_concat_impl()
1626 assert(receive.response.message.header.response.bodylen == (strlen(key) + 2*strlen(value) + 4)); in test_binary_concat_impl()
1677 } while (buffer.response.message.header.response.keylen != 0); in test_binary_stat()
1710 response->message.header.response.opcode, in binary_hickup_recv_verification_thread()
1711 response->message.header.response.status); in binary_hickup_recv_verification_thread()