Lines Matching refs:response
1038 protocol_binary_response_no_extras *response = buf; in safe_recv_packet() local
1039 assert(size > sizeof(*response)); in safe_recv_packet()
1040 if (!safe_recv(response, sizeof(*response))) { in safe_recv_packet()
1043 response->message.header.response.keylen = ntohs(response->message.header.response.keylen); in safe_recv_packet()
1044 response->message.header.response.status = ntohs(response->message.header.response.status); in safe_recv_packet()
1045 response->message.header.response.bodylen = ntohl(response->message.header.response.bodylen); in safe_recv_packet()
1047 size_t len = sizeof(*response); in safe_recv_packet()
1051 if (!safe_recv(ptr, response->message.header.response.bodylen)) { in safe_recv_packet()
1058 len += response->message.header.response.bodylen; in safe_recv_packet()
1231 static void validate_response_header(protocol_binary_response_no_extras *response, in validate_response_header() argument
1234 assert(response->message.header.response.magic == PROTOCOL_BINARY_RES); in validate_response_header()
1235 assert(response->message.header.response.opcode == cmd); in validate_response_header()
1236 assert(response->message.header.response.datatype == PROTOCOL_BINARY_RAW_BYTES); in validate_response_header()
1237 assert(response->message.header.response.status == status); in validate_response_header()
1238 assert(response->message.header.response.opaque == 0xdeadbeef); in validate_response_header()
1263 assert(response->message.header.response.keylen == 0); in validate_response_header()
1264 assert(response->message.header.response.extlen == 0); in validate_response_header()
1265 assert(response->message.header.response.bodylen == 0); in validate_response_header()
1266 assert(response->message.header.response.cas != 0); in validate_response_header()
1272 assert(response->message.header.response.keylen == 0); in validate_response_header()
1273 assert(response->message.header.response.extlen == 0); in validate_response_header()
1274 assert(response->message.header.response.bodylen == 0); in validate_response_header()
1275 assert(response->message.header.response.cas == 0); in validate_response_header()
1280 assert(response->message.header.response.keylen == 0); in validate_response_header()
1281 assert(response->message.header.response.extlen == 0); in validate_response_header()
1282 assert(response->message.header.response.bodylen == 8); in validate_response_header()
1283 assert(response->message.header.response.cas != 0); in validate_response_header()
1287 assert(response->message.header.response.extlen == 0); in validate_response_header()
1289 assert(response->message.header.response.cas == 0); in validate_response_header()
1293 assert(response->message.header.response.keylen == 0); in validate_response_header()
1294 assert(response->message.header.response.extlen == 0); in validate_response_header()
1295 assert(response->message.header.response.bodylen != 0); in validate_response_header()
1296 assert(response->message.header.response.cas == 0); in validate_response_header()
1303 assert(response->message.header.response.keylen == 0); in validate_response_header()
1304 assert(response->message.header.response.extlen == 4); in validate_response_header()
1305 assert(response->message.header.response.cas != 0); in validate_response_header()
1312 assert(response->message.header.response.keylen != 0); in validate_response_header()
1313 assert(response->message.header.response.extlen == 4); in validate_response_header()
1314 assert(response->message.header.response.cas != 0); in validate_response_header()
1322 assert(response->message.header.response.cas == 0); in validate_response_header()
1323 assert(response->message.header.response.extlen == 0); in validate_response_header()
1326 assert(response->message.header.response.keylen == 0); in validate_response_header()
1334 protocol_binary_response_no_extras response; in test_binary_noop() member
1344 validate_response_header(&buffer.response, PROTOCOL_BINARY_CMD_NOOP, in test_binary_noop()
1353 protocol_binary_response_no_extras response; in test_binary_quit_impl() member
1362 validate_response_header(&buffer.response, PROTOCOL_BINARY_CMD_QUIT, in test_binary_quit_impl()
1386 protocol_binary_response_no_extras response; in test_binary_set_impl() member
1400 validate_response_header(&receive.response, cmd, in test_binary_set_impl()
1409 send.request.message.header.request.cas = receive.response.message.header.response.cas; in test_binary_set_impl()
1413 validate_response_header(&receive.response, cmd, in test_binary_set_impl()
1415 … assert(receive.response.message.header.response.cas != send.request.message.header.request.cas); in test_binary_set_impl()
1436 protocol_binary_response_no_extras response; in test_binary_add_impl() member
1450 validate_response_header(&receive.response, cmd, in test_binary_add_impl()
1455 validate_response_header(&receive.response, cmd, in test_binary_add_impl()
1475 protocol_binary_response_no_extras response; in test_binary_replace_impl() member
1483 validate_response_header(&receive.response, cmd, in test_binary_replace_impl()
1490 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_ADD, in test_binary_replace_impl()
1500 validate_response_header(&receive.response, in test_binary_replace_impl()
1526 protocol_binary_response_no_extras response; in test_binary_delete_impl() member
1534 validate_response_header(&receive.response, cmd, in test_binary_delete_impl()
1541 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_ADD, in test_binary_delete_impl()
1550 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_DELETE, in test_binary_delete_impl()
1556 validate_response_header(&receive.response, cmd, in test_binary_delete_impl()
1575 protocol_binary_response_no_extras response; in test_binary_get_impl() member
1590 validate_response_header(&receive.response, cmd, in test_binary_get_impl()
1599 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_ADD, in test_binary_get_impl()
1620 validate_response_header(&receive.response, cmd, in test_binary_get_impl()
1647 protocol_binary_response_no_extras response; in test_binary_getq_impl() member
1677 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_ADD, in test_binary_getq_impl()
1681 validate_response_header(&receive.response, cmd, in test_binary_getq_impl()
1707 protocol_binary_response_incr response; in test_binary_incr_impl() member
1720 assert(ntohll(receive.response.message.body.value) == ii); in test_binary_incr_impl()
1744 protocol_binary_response_decr response; in test_binary_decr_impl() member
1757 assert(ntohll(receive.response.message.body.value) == ii); in test_binary_decr_impl()
1767 assert(ntohll(receive.response.message.body.value) == 0); in test_binary_decr_impl()
1788 protocol_binary_response_no_extras response; in test_binary_version() member
1798 validate_response_header(&buffer.response, PROTOCOL_BINARY_CMD_VERSION, in test_binary_version()
1807 protocol_binary_response_no_extras response; in test_binary_flush_impl() member
1816 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_ADD, in test_binary_flush_impl()
1823 validate_response_header(&receive.response, cmd, in test_binary_flush_impl()
1831 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_GET, in test_binary_flush_impl()
1837 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_GET, in test_binary_flush_impl()
1847 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_ADD, in test_binary_flush_impl()
1854 validate_response_header(&receive.response, cmd, in test_binary_flush_impl()
1863 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_GET, in test_binary_flush_impl()
1883 protocol_binary_response_no_extras response; in test_binary_concat_impl() member
1894 validate_response_header(&receive.response, cmd, in test_binary_concat_impl()
1902 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_ADD, in test_binary_concat_impl()
1911 validate_response_header(&receive.response, cmd, in test_binary_concat_impl()
1918 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_NOOP, in test_binary_concat_impl()
1927 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_GETK, in test_binary_concat_impl()
1930 assert(receive.response.message.header.response.keylen == strlen(key)); in test_binary_concat_impl()
1931 assert(receive.response.message.header.response.bodylen == (strlen(key) + 2*strlen(value) + 4)); in test_binary_concat_impl()
1934 ptr += sizeof(receive.response); in test_binary_concat_impl()
1969 protocol_binary_response_no_extras response; in test_binary_stat() member
1980 validate_response_header(&buffer.response, PROTOCOL_BINARY_CMD_STAT, in test_binary_stat()
1982 } while (buffer.response.message.header.response.keylen != 0); in test_binary_stat()
1992 protocol_binary_response_no_extras response; in test_binary_illegal() member
1999 validate_response_header(&buffer.response, cmd, in test_binary_illegal()
2010 protocol_binary_response_no_extras *response = malloc(65*1024); in binary_hickup_recv_verification_thread() local
2011 if (response != NULL) { in binary_hickup_recv_verification_thread()
2012 while (safe_recv_packet(response, 65*1024)) { in binary_hickup_recv_verification_thread()
2014 validate_response_header(response, in binary_hickup_recv_verification_thread()
2015 response->message.header.response.opcode, in binary_hickup_recv_verification_thread()
2016 response->message.header.response.status); in binary_hickup_recv_verification_thread()
2018 free(response); in binary_hickup_recv_verification_thread()