46 static int cache_constructor(void *buffer, void *notused1, int notused2) {  in cache_constructor()  argument
47     uint64_t *ptr = buffer;  in cache_constructor()
64 static int cache_fail_constructor(void *buffer, void *notused1, int notused2) {  in cache_fail_constructor()  argument
85 static void cache_destructor(void *buffer, void *notused) {  in cache_destructor()  argument
86     destruct_data = buffer;  in cache_destructor()
372     char buffer[80];  in start_server()  local
373     while ((fgets(buffer, sizeof(buffer), fp)) != NULL) {  in start_server()
374         if (strncmp(buffer, "TCP INET: ", 10) == 0) {  in start_server()
376             assert(safe_strtol(buffer + 10, &val));  in start_server()
400         for (int x = 0; x < 20 && fgets(buffer, sizeof(buffer), fp) == NULL; x++) {  in start_server()
406         assert(safe_strtol(buffer, &val));  in start_server()
542 static void read_ascii_response(char *buffer, size_t size) {  in read_ascii_response()  argument
546         ssize_t nr = read(sock, buffer + offset, 1);  in read_ascii_response()
554             if (buffer[offset] == '\n') {  in read_ascii_response()
556                 buffer[offset + 1] = '\0';  in read_ascii_response()
565     char buffer[1024];  in test_issue_92()  local
571     read_ascii_response(buffer, sizeof(buffer));  in test_issue_92()
572     assert(strncmp(buffer, "END", strlen("END")) == 0);  in test_issue_92()
575     read_ascii_response(buffer, sizeof(buffer));  in test_issue_92()
576     assert(strncmp(buffer, "CLIENT_ERROR", strlen("CLIENT_ERROR")) == 0);  in test_issue_92()
584     char buffer[4096];  in test_issue_102()  local
585     memset(buffer, ' ', sizeof(buffer));  in test_issue_102()
586     buffer[sizeof(buffer) - 1] = '\0';  in test_issue_102()
591     send_ascii_command(buffer);  in test_issue_102()
593     assert(read(sock, buffer, sizeof(buffer)) == 0);  in test_issue_102()
597     snprintf(buffer, sizeof(buffer), "gets ");  in test_issue_102()
600         offset += snprintf(buffer + offset, sizeof(buffer) - offset,  in test_issue_102()
604     send_ascii_command(buffer);  in test_issue_102()
611     buffer[3]= ' ';  in test_issue_102()
612     send_ascii_command(buffer);  in test_issue_102()
618     memset(buffer, ' ', sizeof(buffer));  in test_issue_102()
619     int len = snprintf(buffer + 101, sizeof(buffer) - 101, "gets foo");  in test_issue_102()
620     buffer[101 + len] = ' ';  in test_issue_102()
621     buffer[sizeof(buffer) - 1] = '\0';  in test_issue_102()
622     send_ascii_command(buffer);  in test_issue_102()
624     assert(read(sock, buffer, sizeof(buffer)) == 0);  in test_issue_102()
648     char buffer[1024];  in shutdown_memcached_server()  local
655     assert(read(sock, buffer, sizeof(buffer)) == 0);  in shutdown_memcached_server()
1032     } buffer;  in test_binary_noop()  local
1034     size_t len = raw_command(buffer.bytes, sizeof(buffer.bytes),  in test_binary_noop()
1038     safe_send(buffer.bytes, len, false);  in test_binary_noop()
1039     safe_recv_packet(buffer.bytes, sizeof(buffer.bytes));  in test_binary_noop()
1040     validate_response_header(&buffer.response, PROTOCOL_BINARY_CMD_NOOP,  in test_binary_noop()
1051     } buffer;  in test_binary_quit_impl()  local
1052     size_t len = raw_command(buffer.bytes, sizeof(buffer.bytes),  in test_binary_quit_impl()
1055     safe_send(buffer.bytes, len, false);  in test_binary_quit_impl()
1057         safe_recv_packet(buffer.bytes, sizeof(buffer.bytes));  in test_binary_quit_impl()
1058         validate_response_header(&buffer.response, PROTOCOL_BINARY_CMD_QUIT,  in test_binary_quit_impl()
1063     assert(read(sock, buffer.bytes, sizeof(buffer.bytes)) == 0);  in test_binary_quit_impl()
1485     } buffer;  in test_binary_version()  local
1487     size_t len = raw_command(buffer.bytes, sizeof(buffer.bytes),  in test_binary_version()
1491     safe_send(buffer.bytes, len, false);  in test_binary_version()
1492     safe_recv_packet(buffer.bytes, sizeof(buffer.bytes));  in test_binary_version()
1493     validate_response_header(&buffer.response, PROTOCOL_BINARY_CMD_VERSION,  in test_binary_version()
1666     } buffer;  in test_binary_stat()  local
1668     size_t len = raw_command(buffer.bytes, sizeof(buffer.bytes),  in test_binary_stat()
1672     safe_send(buffer.bytes, len, false);  in test_binary_stat()
1674         safe_recv_packet(buffer.bytes, sizeof(buffer.bytes));  in test_binary_stat()
1675         validate_response_header(&buffer.response, PROTOCOL_BINARY_CMD_STAT,  in test_binary_stat()
1677     } while (buffer.response.message.header.response.keylen != 0);  in test_binary_stat()
1689         } buffer;  in test_binary_illegal()  local
1690         size_t len = raw_command(buffer.bytes, sizeof(buffer.bytes),  in test_binary_illegal()
1692         safe_send(buffer.bytes, len, false);  in test_binary_illegal()
1693         safe_recv_packet(buffer.bytes, sizeof(buffer.bytes));  in test_binary_illegal()
1694         validate_response_header(&buffer.response, cmd,  in test_binary_illegal()
1720 static enum test_return test_binary_pipeline_hickup_chunk(void *buffer, size_t buffersize) {  in test_binary_pipeline_hickup_chunk()  argument
1817             memcpy(((char*)buffer) + offset, command.bytes, len);  in test_binary_pipeline_hickup_chunk()
1823     safe_send(buffer, offset, true);  in test_binary_pipeline_hickup_chunk()
1831     void *buffer = malloc(buffersize);  in test_binary_pipeline_hickup()  local
1849         test_binary_pipeline_hickup_chunk(buffer, buffersize);  in test_binary_pipeline_hickup()
1853     size_t len = raw_command(buffer, buffersize, PROTOCOL_BINARY_CMD_QUITQ,  in test_binary_pipeline_hickup()
1855     safe_send(buffer, len, false);  in test_binary_pipeline_hickup()
1858     free(buffer);  in test_binary_pipeline_hickup()