Lines Matching refs:receive
1388 } send, receive; in test_binary_set_impl() local
1399 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_set_impl()
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()
1412 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); 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()
1438 } send, receive; in test_binary_add_impl() local
1449 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_add_impl()
1450 validate_response_header(&receive.response, cmd, in test_binary_add_impl()
1454 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_add_impl()
1455 validate_response_header(&receive.response, cmd, in test_binary_add_impl()
1477 } send, receive; in test_binary_replace_impl() local
1482 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_replace_impl()
1483 validate_response_header(&receive.response, cmd, in test_binary_replace_impl()
1489 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_replace_impl()
1490 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_ADD, in test_binary_replace_impl()
1499 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_replace_impl()
1500 validate_response_header(&receive.response, in test_binary_replace_impl()
1528 } send, receive; in test_binary_delete_impl() local
1533 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_delete_impl()
1534 validate_response_header(&receive.response, cmd, in test_binary_delete_impl()
1540 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_delete_impl()
1541 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_ADD, in test_binary_delete_impl()
1549 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_delete_impl()
1550 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_DELETE, in test_binary_delete_impl()
1555 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_delete_impl()
1556 validate_response_header(&receive.response, cmd, in test_binary_delete_impl()
1577 } send, receive; in test_binary_get_impl() local
1589 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_get_impl()
1590 validate_response_header(&receive.response, cmd, in test_binary_get_impl()
1598 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_get_impl()
1599 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_ADD, in test_binary_get_impl()
1619 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_get_impl()
1620 validate_response_header(&receive.response, cmd, in test_binary_get_impl()
1649 } send, temp, receive; in test_binary_getq_impl() local
1676 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_getq_impl()
1677 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_ADD, in test_binary_getq_impl()
1680 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_getq_impl()
1681 validate_response_header(&receive.response, cmd, in test_binary_getq_impl()
1709 } send, receive; in test_binary_incr_impl() local
1717 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_incr_impl()
1718 validate_response_header(&receive.response_header, cmd, in test_binary_incr_impl()
1720 assert(ntohll(receive.response.message.body.value) == ii); in test_binary_incr_impl()
1746 } send, receive; in test_binary_decr_impl() local
1754 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_decr_impl()
1755 validate_response_header(&receive.response_header, cmd, in test_binary_decr_impl()
1757 assert(ntohll(receive.response.message.body.value) == ii); in test_binary_decr_impl()
1764 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_decr_impl()
1765 validate_response_header(&receive.response_header, cmd, in test_binary_decr_impl()
1767 assert(ntohll(receive.response.message.body.value) == 0); in test_binary_decr_impl()
1809 } send, receive; in test_binary_flush_impl() local
1815 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_flush_impl()
1816 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_ADD, in test_binary_flush_impl()
1822 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_flush_impl()
1823 validate_response_header(&receive.response, cmd, in test_binary_flush_impl()
1830 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_flush_impl()
1831 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_GET, in test_binary_flush_impl()
1836 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_flush_impl()
1837 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_GET, in test_binary_flush_impl()
1846 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_flush_impl()
1847 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_ADD, in test_binary_flush_impl()
1853 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_flush_impl()
1854 validate_response_header(&receive.response, cmd, in test_binary_flush_impl()
1862 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_flush_impl()
1863 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_GET, in test_binary_flush_impl()
1885 } send, receive; in test_binary_concat_impl() local
1893 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_concat_impl()
1894 validate_response_header(&receive.response, cmd, in test_binary_concat_impl()
1901 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_concat_impl()
1902 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_ADD, in test_binary_concat_impl()
1910 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_concat_impl()
1911 validate_response_header(&receive.response, cmd, in test_binary_concat_impl()
1917 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_concat_impl()
1918 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_NOOP, in test_binary_concat_impl()
1926 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); 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()
1933 char *ptr = receive.bytes; in test_binary_concat_impl()
1934 ptr += sizeof(receive.response); in test_binary_concat_impl()