Lines Matching refs:send
1388 } send, receive; in test_binary_set_impl() local
1390 size_t len = storage_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_set_impl()
1397 safe_send(send.bytes, len, false); in test_binary_set_impl()
1409 send.request.message.header.request.cas = receive.response.message.header.response.cas; in test_binary_set_impl()
1410 safe_send(send.bytes, len, false); 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
1439 size_t len = storage_command(send.bytes, sizeof(send.bytes), cmd, key, in test_binary_add_impl()
1446 safe_send(send.bytes, len, false); in test_binary_add_impl()
1477 } send, receive; in test_binary_replace_impl() local
1478 size_t len = storage_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_replace_impl()
1481 safe_send(send.bytes, len, false); in test_binary_replace_impl()
1485 len = storage_command(send.bytes, sizeof(send.bytes), in test_binary_replace_impl()
1488 safe_send(send.bytes, len, false); in test_binary_replace_impl()
1493 len = storage_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_replace_impl()
1497 safe_send(send.bytes, len, false); in test_binary_replace_impl()
1528 } send, receive; in test_binary_delete_impl() local
1529 size_t len = raw_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_delete_impl()
1532 safe_send(send.bytes, len, false); in test_binary_delete_impl()
1536 len = storage_command(send.bytes, sizeof(send.bytes), in test_binary_delete_impl()
1539 safe_send(send.bytes, len, false); in test_binary_delete_impl()
1544 len = raw_command(send.bytes, sizeof(send.bytes), in test_binary_delete_impl()
1546 safe_send(send.bytes, len, false); in test_binary_delete_impl()
1554 safe_send(send.bytes, len, false); in test_binary_delete_impl()
1577 } send, receive; in test_binary_get_impl() local
1584 size_t len = ext_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_get_impl()
1588 safe_send(send.bytes, len, false); in test_binary_get_impl()
1593 len = storage_command(send.bytes, sizeof(send.bytes), in test_binary_get_impl()
1597 safe_send(send.bytes, len, false); in test_binary_get_impl()
1613 memcpy(send.bytes + len, temp.bytes, l); in test_binary_get_impl()
1617 safe_send(send.bytes, len, false); in test_binary_get_impl()
1649 } send, temp, receive; in test_binary_getq_impl() local
1656 size_t len = storage_command(send.bytes, sizeof(send.bytes), in test_binary_getq_impl()
1666 memcpy(send.bytes + len, temp.bytes, len2); in test_binary_getq_impl()
1672 memcpy(send.bytes + len, temp.bytes, len2); in test_binary_getq_impl()
1675 safe_send(send.bytes, len, false); in test_binary_getq_impl()
1709 } send, receive; in test_binary_incr_impl() local
1710 size_t len = arithmetic_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_incr_impl()
1715 safe_send(send.bytes, len, false); in test_binary_incr_impl()
1746 } send, receive; in test_binary_decr_impl() local
1747 size_t len = arithmetic_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_decr_impl()
1752 safe_send(send.bytes, len, false); in test_binary_decr_impl()
1762 safe_send(send.bytes, len, false); in test_binary_decr_impl()
1809 } send, receive; in test_binary_flush_impl() local
1811 size_t len = storage_command(send.bytes, sizeof(send.bytes), in test_binary_flush_impl()
1814 safe_send(send.bytes, len, false); in test_binary_flush_impl()
1819 len = flush_command(send.bytes, sizeof(send.bytes), cmd, 2, true); in test_binary_flush_impl()
1820 safe_send(send.bytes, len, false); in test_binary_flush_impl()
1827 len = raw_command(send.bytes, sizeof(send.bytes), PROTOCOL_BINARY_CMD_GET, in test_binary_flush_impl()
1829 safe_send(send.bytes, len, false); in test_binary_flush_impl()
1835 safe_send(send.bytes, len, false); in test_binary_flush_impl()
1842 len = storage_command(send.bytes, sizeof(send.bytes), in test_binary_flush_impl()
1845 safe_send(send.bytes, len, false); in test_binary_flush_impl()
1850 len = flush_command(send.bytes, sizeof(send.bytes), cmd, 0, ii == 0); in test_binary_flush_impl()
1851 safe_send(send.bytes, len, false); in test_binary_flush_impl()
1858 len = raw_command(send.bytes, sizeof(send.bytes), in test_binary_flush_impl()
1861 safe_send(send.bytes, len, false); in test_binary_flush_impl()
1885 } send, receive; in test_binary_concat_impl() local
1888 size_t len = raw_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_concat_impl()
1892 safe_send(send.bytes, len, false); in test_binary_concat_impl()
1897 len = storage_command(send.bytes, sizeof(send.bytes), in test_binary_concat_impl()
1900 safe_send(send.bytes, len, false); in test_binary_concat_impl()
1905 len = raw_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_concat_impl()
1907 safe_send(send.bytes, len, false); in test_binary_concat_impl()
1914 len = raw_command(send.bytes, sizeof(send.bytes), PROTOCOL_BINARY_CMD_NOOP, in test_binary_concat_impl()
1916 safe_send(send.bytes, len, false); in test_binary_concat_impl()
1922 len = raw_command(send.bytes, sizeof(send.bytes), PROTOCOL_BINARY_CMD_GETK, in test_binary_concat_impl()
1925 safe_send(send.bytes, len, false); in test_binary_concat_impl()