Lines Matching refs:send

1083     } send, receive;  in test_binary_set_impl()  local
1085 size_t len = storage_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_set_impl()
1092 safe_send(send.bytes, len, false); in test_binary_set_impl()
1104 send.request.message.header.request.cas = receive.response.message.header.response.cas; in test_binary_set_impl()
1105 safe_send(send.bytes, len, false); 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
1134 size_t len = storage_command(send.bytes, sizeof(send.bytes), cmd, key, in test_binary_add_impl()
1141 safe_send(send.bytes, len, false); in test_binary_add_impl()
1172 } send, receive; in test_binary_replace_impl() local
1173 size_t len = storage_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_replace_impl()
1176 safe_send(send.bytes, len, false); in test_binary_replace_impl()
1180 len = storage_command(send.bytes, sizeof(send.bytes), in test_binary_replace_impl()
1183 safe_send(send.bytes, len, false); in test_binary_replace_impl()
1188 len = storage_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_replace_impl()
1192 safe_send(send.bytes, len, false); in test_binary_replace_impl()
1223 } send, receive; in test_binary_delete_impl() local
1224 size_t len = raw_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_delete_impl()
1227 safe_send(send.bytes, len, false); in test_binary_delete_impl()
1231 len = storage_command(send.bytes, sizeof(send.bytes), in test_binary_delete_impl()
1234 safe_send(send.bytes, len, false); in test_binary_delete_impl()
1239 len = raw_command(send.bytes, sizeof(send.bytes), in test_binary_delete_impl()
1241 safe_send(send.bytes, len, false); in test_binary_delete_impl()
1249 safe_send(send.bytes, len, false); in test_binary_delete_impl()
1272 } send, receive; in test_binary_get_impl() local
1279 size_t len = ext_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_get_impl()
1283 safe_send(send.bytes, len, false); in test_binary_get_impl()
1288 len = storage_command(send.bytes, sizeof(send.bytes), in test_binary_get_impl()
1292 safe_send(send.bytes, len, false); in test_binary_get_impl()
1308 memcpy(send.bytes + len, temp.bytes, l); in test_binary_get_impl()
1312 safe_send(send.bytes, len, false); in test_binary_get_impl()
1344 } send, temp, receive; in test_binary_getq_impl() local
1351 size_t len = storage_command(send.bytes, sizeof(send.bytes), in test_binary_getq_impl()
1361 memcpy(send.bytes + len, temp.bytes, len2); in test_binary_getq_impl()
1367 memcpy(send.bytes + len, temp.bytes, len2); in test_binary_getq_impl()
1370 safe_send(send.bytes, len, false); in test_binary_getq_impl()
1404 } send, receive; in test_binary_incr_impl() local
1405 size_t len = arithmetic_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_incr_impl()
1410 safe_send(send.bytes, len, false); in test_binary_incr_impl()
1441 } send, receive; in test_binary_decr_impl() local
1442 size_t len = arithmetic_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_decr_impl()
1447 safe_send(send.bytes, len, false); in test_binary_decr_impl()
1457 safe_send(send.bytes, len, false); in test_binary_decr_impl()
1504 } send, receive; in test_binary_flush_impl() local
1506 size_t len = storage_command(send.bytes, sizeof(send.bytes), in test_binary_flush_impl()
1509 safe_send(send.bytes, len, false); in test_binary_flush_impl()
1514 len = flush_command(send.bytes, sizeof(send.bytes), cmd, 2, true); in test_binary_flush_impl()
1515 safe_send(send.bytes, len, false); in test_binary_flush_impl()
1522 len = raw_command(send.bytes, sizeof(send.bytes), PROTOCOL_BINARY_CMD_GET, in test_binary_flush_impl()
1524 safe_send(send.bytes, len, false); in test_binary_flush_impl()
1530 safe_send(send.bytes, len, false); in test_binary_flush_impl()
1537 len = storage_command(send.bytes, sizeof(send.bytes), in test_binary_flush_impl()
1540 safe_send(send.bytes, len, false); in test_binary_flush_impl()
1545 len = flush_command(send.bytes, sizeof(send.bytes), cmd, 0, ii == 0); in test_binary_flush_impl()
1546 safe_send(send.bytes, len, false); in test_binary_flush_impl()
1553 len = raw_command(send.bytes, sizeof(send.bytes), in test_binary_flush_impl()
1556 safe_send(send.bytes, len, false); in test_binary_flush_impl()
1580 } send, receive; in test_binary_concat_impl() local
1583 size_t len = raw_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_concat_impl()
1587 safe_send(send.bytes, len, false); in test_binary_concat_impl()
1592 len = storage_command(send.bytes, sizeof(send.bytes), in test_binary_concat_impl()
1595 safe_send(send.bytes, len, false); in test_binary_concat_impl()
1600 len = raw_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_concat_impl()
1602 safe_send(send.bytes, len, false); in test_binary_concat_impl()
1609 len = raw_command(send.bytes, sizeof(send.bytes), PROTOCOL_BINARY_CMD_NOOP, in test_binary_concat_impl()
1611 safe_send(send.bytes, len, false); in test_binary_concat_impl()
1617 len = raw_command(send.bytes, sizeof(send.bytes), PROTOCOL_BINARY_CMD_GETK, in test_binary_concat_impl()
1620 safe_send(send.bytes, len, false); in test_binary_concat_impl()