Lines Matching refs:receive

1083     } send, receive;  in test_binary_set_impl()  local
1094 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_set_impl()
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()
1107 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); 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()
1133 } send, receive; in test_binary_add_impl() local
1144 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_add_impl()
1145 validate_response_header(&receive.response, cmd, in test_binary_add_impl()
1149 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_add_impl()
1150 validate_response_header(&receive.response, cmd, in test_binary_add_impl()
1172 } send, receive; in test_binary_replace_impl() local
1177 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_replace_impl()
1178 validate_response_header(&receive.response, cmd, in test_binary_replace_impl()
1184 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_replace_impl()
1185 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_ADD, in test_binary_replace_impl()
1194 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_replace_impl()
1195 validate_response_header(&receive.response, in test_binary_replace_impl()
1223 } send, receive; in test_binary_delete_impl() local
1228 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_delete_impl()
1229 validate_response_header(&receive.response, cmd, in test_binary_delete_impl()
1235 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_delete_impl()
1236 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_ADD, in test_binary_delete_impl()
1244 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_delete_impl()
1245 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_DELETE, in test_binary_delete_impl()
1250 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_delete_impl()
1251 validate_response_header(&receive.response, cmd, in test_binary_delete_impl()
1272 } send, receive; in test_binary_get_impl() local
1284 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_get_impl()
1285 validate_response_header(&receive.response, cmd, in test_binary_get_impl()
1293 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_get_impl()
1294 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_ADD, in test_binary_get_impl()
1314 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_get_impl()
1315 validate_response_header(&receive.response, cmd, in test_binary_get_impl()
1344 } send, temp, receive; in test_binary_getq_impl() local
1371 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_getq_impl()
1372 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_ADD, in test_binary_getq_impl()
1375 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_getq_impl()
1376 validate_response_header(&receive.response, cmd, in test_binary_getq_impl()
1404 } send, receive; in test_binary_incr_impl() local
1412 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_incr_impl()
1413 validate_response_header(&receive.response_header, cmd, in test_binary_incr_impl()
1415 assert(ntohll(receive.response.message.body.value) == ii); in test_binary_incr_impl()
1441 } send, receive; in test_binary_decr_impl() local
1449 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_decr_impl()
1450 validate_response_header(&receive.response_header, cmd, in test_binary_decr_impl()
1452 assert(ntohll(receive.response.message.body.value) == ii); in test_binary_decr_impl()
1459 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_decr_impl()
1460 validate_response_header(&receive.response_header, cmd, in test_binary_decr_impl()
1462 assert(ntohll(receive.response.message.body.value) == 0); in test_binary_decr_impl()
1504 } send, receive; in test_binary_flush_impl() local
1510 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_flush_impl()
1511 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_ADD, in test_binary_flush_impl()
1517 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_flush_impl()
1518 validate_response_header(&receive.response, cmd, in test_binary_flush_impl()
1525 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_flush_impl()
1526 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_GET, in test_binary_flush_impl()
1531 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_flush_impl()
1532 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_GET, in test_binary_flush_impl()
1541 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_flush_impl()
1542 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_ADD, in test_binary_flush_impl()
1548 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_flush_impl()
1549 validate_response_header(&receive.response, cmd, in test_binary_flush_impl()
1557 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_flush_impl()
1558 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_GET, in test_binary_flush_impl()
1580 } send, receive; in test_binary_concat_impl() local
1588 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_concat_impl()
1589 validate_response_header(&receive.response, cmd, in test_binary_concat_impl()
1596 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_concat_impl()
1597 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_ADD, in test_binary_concat_impl()
1605 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_concat_impl()
1606 validate_response_header(&receive.response, cmd, in test_binary_concat_impl()
1612 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); in test_binary_concat_impl()
1613 validate_response_header(&receive.response, PROTOCOL_BINARY_CMD_NOOP, in test_binary_concat_impl()
1621 safe_recv_packet(receive.bytes, sizeof(receive.bytes)); 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()
1628 char *ptr = receive.bytes; in test_binary_concat_impl()
1629 ptr += sizeof(receive.response); in test_binary_concat_impl()