Lines Matching refs:len
521 size_t len = strlen(buf); in send_ascii_command() local
524 ssize_t nw = write(sock, ptr + offset, len - offset); in send_ascii_command()
533 } while (offset < len); in send_ascii_command()
619 int len = snprintf(buffer + 101, sizeof(buffer) - 101, "gets foo"); in test_issue_102() local
620 buffer[101 + len] = ' '; in test_issue_102()
667 static void safe_send(const void* buf, size_t len, bool hickup) in safe_send() argument
674 fprintf(stderr, "About to send %lu bytes:", (unsigned long)len); in safe_send()
675 for (int ii = 0; ii < len; ++ii) { in safe_send()
687 size_t num_bytes = len - offset; in safe_send()
706 } while (offset < len); in safe_send()
709 static bool safe_recv(void *buf, size_t len) { in safe_recv() argument
710 if (len == 0) { in safe_recv()
715 ssize_t nr = read(sock, ((char*)buf) + offset, len - offset); in safe_recv()
728 } while (offset < len); in safe_recv()
743 size_t len = sizeof(*response); in safe_recv_packet() local
746 ptr += len; in safe_recv_packet()
754 len += response->message.header.response.bodylen; in safe_recv_packet()
757 fprintf(stderr, "Received %lu bytes:", (unsigned long)len); in safe_recv_packet()
758 for (int ii = 0; ii < len; ++ii) { in safe_recv_packet()
1034 size_t len = raw_command(buffer.bytes, sizeof(buffer.bytes), in test_binary_noop() local
1038 safe_send(buffer.bytes, len, false); in test_binary_noop()
1052 size_t len = raw_command(buffer.bytes, sizeof(buffer.bytes), in test_binary_quit_impl() local
1055 safe_send(buffer.bytes, len, false); in test_binary_quit_impl()
1085 size_t len = storage_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_set_impl() local
1092 safe_send(send.bytes, len, false); in test_binary_set_impl()
1105 safe_send(send.bytes, len, false); in test_binary_set_impl()
1134 size_t len = storage_command(send.bytes, sizeof(send.bytes), cmd, key, in test_binary_add_impl() local
1141 safe_send(send.bytes, len, false); in test_binary_add_impl()
1173 size_t len = storage_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_replace_impl() local
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()
1224 size_t len = raw_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_delete_impl() local
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()
1279 size_t len = ext_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_get_impl() local
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()
1298 len = 0; in test_binary_get_impl()
1308 memcpy(send.bytes + len, temp.bytes, l); in test_binary_get_impl()
1309 len += l; in test_binary_get_impl()
1312 safe_send(send.bytes, len, false); in test_binary_get_impl()
1351 size_t len = storage_command(send.bytes, sizeof(send.bytes), in test_binary_getq_impl() local
1361 memcpy(send.bytes + len, temp.bytes, len2); in test_binary_getq_impl()
1362 len += len2; in test_binary_getq_impl()
1367 memcpy(send.bytes + len, temp.bytes, len2); in test_binary_getq_impl()
1368 len += len2; in test_binary_getq_impl()
1370 safe_send(send.bytes, len, false); in test_binary_getq_impl()
1405 size_t len = arithmetic_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_incr_impl() local
1410 safe_send(send.bytes, len, false); in test_binary_incr_impl()
1442 size_t len = arithmetic_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_decr_impl() local
1447 safe_send(send.bytes, len, false); in test_binary_decr_impl()
1457 safe_send(send.bytes, len, false); in test_binary_decr_impl()
1487 size_t len = raw_command(buffer.bytes, sizeof(buffer.bytes), in test_binary_version() local
1491 safe_send(buffer.bytes, len, false); in test_binary_version()
1506 size_t len = storage_command(send.bytes, sizeof(send.bytes), in test_binary_flush_impl() local
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()
1583 size_t len = raw_command(send.bytes, sizeof(send.bytes), cmd, in test_binary_concat_impl() local
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()
1668 size_t len = raw_command(buffer.bytes, sizeof(buffer.bytes), in test_binary_stat() local
1672 safe_send(buffer.bytes, len, false); in test_binary_stat()
1690 size_t len = raw_command(buffer.bytes, sizeof(buffer.bytes), in test_binary_illegal() local
1692 safe_send(buffer.bytes, len, false); in test_binary_illegal()
1732 size_t len; in test_binary_pipeline_hickup_chunk() local
1742 len = storage_command(command.bytes, sizeof(command.bytes), cmd, in test_binary_pipeline_hickup_chunk()
1750 len = raw_command(command.bytes, sizeof(command.bytes), cmd, in test_binary_pipeline_hickup_chunk()
1755 len = raw_command(command.bytes, sizeof(command.bytes), cmd, in test_binary_pipeline_hickup_chunk()
1759 len = raw_command(command.bytes, sizeof(command.bytes), cmd, in test_binary_pipeline_hickup_chunk()
1764 len = raw_command(command.bytes, sizeof(command.bytes), cmd, in test_binary_pipeline_hickup_chunk()
1771 len = arithmetic_command(command.bytes, sizeof(command.bytes), cmd, in test_binary_pipeline_hickup_chunk()
1775 len = raw_command(command.bytes, sizeof(command.bytes), in test_binary_pipeline_hickup_chunk()
1783 len = raw_command(command.bytes, sizeof(command.bytes), cmd, in test_binary_pipeline_hickup_chunk()
1792 len = touch_command(command.bytes, sizeof(command.bytes), cmd, in test_binary_pipeline_hickup_chunk()
1797 len = raw_command(command.bytes, sizeof(command.bytes), in test_binary_pipeline_hickup_chunk()
1812 len = raw_command(command.bytes, sizeof(command.bytes), in test_binary_pipeline_hickup_chunk()
1816 if ((len + offset) < buffersize) { in test_binary_pipeline_hickup_chunk()
1817 memcpy(((char*)buffer) + offset, command.bytes, len); in test_binary_pipeline_hickup_chunk()
1818 offset += len; in test_binary_pipeline_hickup_chunk()
1853 size_t len = raw_command(buffer, buffersize, PROTOCOL_BINARY_CMD_QUITQ, in test_binary_pipeline_hickup() local
1855 safe_send(buffer, len, false); in test_binary_pipeline_hickup()