Lines Matching refs:response
734 protocol_binary_response_no_extras *response = buf; in safe_recv_packet() local
735 assert(size > sizeof(*response)); in safe_recv_packet()
736 if (!safe_recv(response, sizeof(*response))) { in safe_recv_packet()
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()
743 size_t len = sizeof(*response); 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()
927 static void validate_response_header(protocol_binary_response_no_extras *response, in validate_response_header() argument
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()
1030 protocol_binary_response_no_extras response; in test_binary_noop() member
1040 validate_response_header(&buffer.response, PROTOCOL_BINARY_CMD_NOOP, in test_binary_noop()
1049 protocol_binary_response_no_extras response; in test_binary_quit_impl() member
1058 validate_response_header(&buffer.response, PROTOCOL_BINARY_CMD_QUIT, in test_binary_quit_impl()
1081 protocol_binary_response_no_extras response; in test_binary_set_impl() member
1095 validate_response_header(&receive.response, cmd, in test_binary_set_impl()
1104 send.request.message.header.request.cas = receive.response.message.header.response.cas; in test_binary_set_impl()
1108 validate_response_header(&receive.response, cmd, in test_binary_set_impl()
1110 … assert(receive.response.message.header.response.cas != send.request.message.header.request.cas); in test_binary_set_impl()
1131 protocol_binary_response_no_extras response; in test_binary_add_impl() member
1145 validate_response_header(&receive.response, cmd, in test_binary_add_impl()
1150 validate_response_header(&receive.response, cmd, in test_binary_add_impl()
1170 protocol_binary_response_no_extras response; in test_binary_replace_impl() member
1178 validate_response_header(&receive.response, cmd, in test_binary_replace_impl()
1185 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_ADD, in test_binary_replace_impl()
1195 validate_response_header(&receive.response, in test_binary_replace_impl()
1221 protocol_binary_response_no_extras response; in test_binary_delete_impl() member
1229 validate_response_header(&receive.response, cmd, in test_binary_delete_impl()
1236 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_ADD, in test_binary_delete_impl()
1245 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_DELETE, in test_binary_delete_impl()
1251 validate_response_header(&receive.response, cmd, in test_binary_delete_impl()
1270 protocol_binary_response_no_extras response; in test_binary_get_impl() member
1285 validate_response_header(&receive.response, cmd, in test_binary_get_impl()
1294 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_ADD, in test_binary_get_impl()
1315 validate_response_header(&receive.response, cmd, in test_binary_get_impl()
1342 protocol_binary_response_no_extras response; in test_binary_getq_impl() member
1372 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_ADD, in test_binary_getq_impl()
1376 validate_response_header(&receive.response, cmd, in test_binary_getq_impl()
1402 protocol_binary_response_incr response; in test_binary_incr_impl() member
1415 assert(ntohll(receive.response.message.body.value) == ii); in test_binary_incr_impl()
1439 protocol_binary_response_decr response; in test_binary_decr_impl() member
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()
1483 protocol_binary_response_no_extras response; in test_binary_version() member
1493 validate_response_header(&buffer.response, PROTOCOL_BINARY_CMD_VERSION, in test_binary_version()
1502 protocol_binary_response_no_extras response; in test_binary_flush_impl() member
1511 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_ADD, in test_binary_flush_impl()
1518 validate_response_header(&receive.response, cmd, in test_binary_flush_impl()
1526 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_GET, in test_binary_flush_impl()
1532 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_GET, in test_binary_flush_impl()
1542 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_ADD, in test_binary_flush_impl()
1549 validate_response_header(&receive.response, cmd, in test_binary_flush_impl()
1558 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_GET, in test_binary_flush_impl()
1578 protocol_binary_response_no_extras response; in test_binary_concat_impl() member
1589 validate_response_header(&receive.response, cmd, in test_binary_concat_impl()
1597 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_ADD, in test_binary_concat_impl()
1606 validate_response_header(&receive.response, cmd, in test_binary_concat_impl()
1613 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_NOOP, in test_binary_concat_impl()
1622 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_GETK, in test_binary_concat_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()
1629 ptr += sizeof(receive.response); in test_binary_concat_impl()
1664 protocol_binary_response_no_extras response; in test_binary_stat() member
1675 validate_response_header(&buffer.response, PROTOCOL_BINARY_CMD_STAT, in test_binary_stat()
1677 } while (buffer.response.message.header.response.keylen != 0); in test_binary_stat()
1687 protocol_binary_response_no_extras response; in test_binary_illegal() member
1694 validate_response_header(&buffer.response, cmd, in test_binary_illegal()
1705 protocol_binary_response_no_extras *response = malloc(65*1024); in binary_hickup_recv_verification_thread() local
1706 if (response != NULL) { in binary_hickup_recv_verification_thread()
1707 while (safe_recv_packet(response, 65*1024)) { in binary_hickup_recv_verification_thread()
1709 validate_response_header(response, in binary_hickup_recv_verification_thread()
1710 response->message.header.response.opcode, in binary_hickup_recv_verification_thread()
1711 response->message.header.response.status); in binary_hickup_recv_verification_thread()
1713 free(response); in binary_hickup_recv_verification_thread()