Lines Matching refs:len
788 size_t len = strlen(buf); in send_ascii_command() local
791 ssize_t nw = con->write((void*)con, ptr + offset, len - offset); in send_ascii_command()
800 } while (offset < len); in send_ascii_command()
920 int len = snprintf(buffer + 101, sizeof(buffer) - 101, "gets foo"); in test_issue_102() local
921 buffer[101 + len] = ' '; in test_issue_102()
972 static void safe_send(const void* buf, size_t len, bool hickup) in safe_send() argument
979 fprintf(stderr, "About to send %lu bytes:", (unsigned long)len); in safe_send()
980 for (int ii = 0; ii < len; ++ii) { in safe_send()
992 size_t num_bytes = len - offset; in safe_send()
1010 } while (offset < len); in safe_send()
1013 static bool safe_recv(void *buf, size_t len) { in safe_recv() argument
1014 if (len == 0) { in safe_recv()
1019 ssize_t nr = con->read(con, ((char*)buf) + offset, len - offset); in safe_recv()
1032 } while (offset < len); in safe_recv()
1047 size_t len = sizeof(*response); in safe_recv_packet() local
1050 ptr += len; in safe_recv_packet()
1058 len += response->message.header.response.bodylen; in safe_recv_packet()
1061 fprintf(stderr, "Received %lu bytes:", (unsigned long)len); in safe_recv_packet()
1062 for (int ii = 0; ii < len; ++ii) { in safe_recv_packet()
1338 size_t len = raw_command(buffer.bytes, sizeof(buffer.bytes), in test_binary_noop() local
1342 safe_send(buffer.bytes, len, false); in test_binary_noop()
1356 size_t len = raw_command(buffer.bytes, sizeof(buffer.bytes), in test_binary_quit_impl() local
1359 safe_send(buffer.bytes, len, false); in test_binary_quit_impl()
1390 size_t len = storage_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_set_impl() local
1397 safe_send(send.bytes, len, false); in test_binary_set_impl()
1410 safe_send(send.bytes, len, false); in test_binary_set_impl()
1439 size_t len = storage_command(send.bytes, sizeof(send.bytes), cmd, key, in test_binary_add_impl() local
1446 safe_send(send.bytes, len, false); in test_binary_add_impl()
1478 size_t len = storage_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_replace_impl() local
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()
1529 size_t len = raw_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_delete_impl() local
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()
1584 size_t len = ext_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_get_impl() local
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()
1603 len = 0; in test_binary_get_impl()
1613 memcpy(send.bytes + len, temp.bytes, l); in test_binary_get_impl()
1614 len += l; in test_binary_get_impl()
1617 safe_send(send.bytes, len, false); in test_binary_get_impl()
1656 size_t len = storage_command(send.bytes, sizeof(send.bytes), in test_binary_getq_impl() local
1666 memcpy(send.bytes + len, temp.bytes, len2); in test_binary_getq_impl()
1667 len += len2; in test_binary_getq_impl()
1672 memcpy(send.bytes + len, temp.bytes, len2); in test_binary_getq_impl()
1673 len += len2; in test_binary_getq_impl()
1675 safe_send(send.bytes, len, false); in test_binary_getq_impl()
1710 size_t len = arithmetic_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_incr_impl() local
1715 safe_send(send.bytes, len, false); in test_binary_incr_impl()
1747 size_t len = arithmetic_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_decr_impl() local
1752 safe_send(send.bytes, len, false); in test_binary_decr_impl()
1762 safe_send(send.bytes, len, false); in test_binary_decr_impl()
1792 size_t len = raw_command(buffer.bytes, sizeof(buffer.bytes), in test_binary_version() local
1796 safe_send(buffer.bytes, len, false); in test_binary_version()
1811 size_t len = storage_command(send.bytes, sizeof(send.bytes), in test_binary_flush_impl() local
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()
1888 size_t len = raw_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_concat_impl() local
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()
1973 size_t len = raw_command(buffer.bytes, sizeof(buffer.bytes), in test_binary_stat() local
1977 safe_send(buffer.bytes, len, false); in test_binary_stat()
1995 size_t len = raw_command(buffer.bytes, sizeof(buffer.bytes), in test_binary_illegal() local
1997 safe_send(buffer.bytes, len, false); in test_binary_illegal()
2037 size_t len; in test_binary_pipeline_hickup_chunk() local
2047 len = storage_command(command.bytes, sizeof(command.bytes), cmd, in test_binary_pipeline_hickup_chunk()
2055 len = raw_command(command.bytes, sizeof(command.bytes), cmd, in test_binary_pipeline_hickup_chunk()
2060 len = raw_command(command.bytes, sizeof(command.bytes), cmd, in test_binary_pipeline_hickup_chunk()
2064 len = raw_command(command.bytes, sizeof(command.bytes), cmd, in test_binary_pipeline_hickup_chunk()
2069 len = raw_command(command.bytes, sizeof(command.bytes), cmd, in test_binary_pipeline_hickup_chunk()
2076 len = arithmetic_command(command.bytes, sizeof(command.bytes), cmd, in test_binary_pipeline_hickup_chunk()
2080 len = raw_command(command.bytes, sizeof(command.bytes), in test_binary_pipeline_hickup_chunk()
2088 len = raw_command(command.bytes, sizeof(command.bytes), cmd, in test_binary_pipeline_hickup_chunk()
2097 len = touch_command(command.bytes, sizeof(command.bytes), cmd, in test_binary_pipeline_hickup_chunk()
2102 len = raw_command(command.bytes, sizeof(command.bytes), in test_binary_pipeline_hickup_chunk()
2117 len = raw_command(command.bytes, sizeof(command.bytes), in test_binary_pipeline_hickup_chunk()
2121 if ((len + offset) < buffersize) { in test_binary_pipeline_hickup_chunk()
2122 memcpy(((char*)buffer) + offset, command.bytes, len); in test_binary_pipeline_hickup_chunk()
2123 offset += len; in test_binary_pipeline_hickup_chunk()
2159 size_t len = raw_command(buffer, buffersize, PROTOCOL_BINARY_CMD_QUITQ, in test_binary_pipeline_hickup() local
2161 safe_send(buffer, len, false); in test_binary_pipeline_hickup()