Lines Matching refs:buffer

594     char buffer[80];  in start_server()  local
595 while ((fgets(buffer, sizeof(buffer), fp)) != NULL) { in start_server()
596 if (strncmp(buffer, "TCP INET: ", 10) == 0) { in start_server()
598 assert(safe_strtol(buffer + 10, &val)); in start_server()
622 for (int x = 0; x < 20 && fgets(buffer, sizeof(buffer), fp) == NULL; x++) { in start_server()
628 assert(safe_strtol(buffer, &val)); in start_server()
809 static void read_ascii_response(char *buffer, size_t size) { in read_ascii_response() argument
813 ssize_t nr = con->read(con, buffer + offset, 1); in read_ascii_response()
821 if (buffer[offset] == '\n') { in read_ascii_response()
823 buffer[offset + 1] = '\0'; in read_ascii_response()
832 char buffer[1024]; in test_issue_92() local
840 read_ascii_response(buffer, sizeof(buffer)); in test_issue_92()
841 assert(strncmp(buffer, "END", strlen("END")) == 0); in test_issue_92()
844 read_ascii_response(buffer, sizeof(buffer)); in test_issue_92()
845 assert(strncmp(buffer, "CLIENT_ERROR", strlen("CLIENT_ERROR")) == 0); in test_issue_92()
856 char buffer[256]; in test_crc32c() local
858 buffer[x] = x; in test_crc32c()
861 crc_hw = crc32c(0, buffer, 256); in test_crc32c()
862 crc_sw = crc32c_sw(0, buffer, 256); in test_crc32c()
867 crc_hw = crc32c(crc_hw, buffer, 256); in test_crc32c()
868 crc_sw = crc32c_sw(crc_sw, buffer, 256); in test_crc32c()
873 crc_hw = crc32c(crc_hw, buffer + 1, 256 - 2); in test_crc32c()
874 crc_sw = crc32c_sw(crc_sw, buffer + 1, 256 - 2); in test_crc32c()
882 char buffer[4096]; in test_issue_102() local
883 memset(buffer, ' ', sizeof(buffer)); in test_issue_102()
884 buffer[sizeof(buffer) - 1] = '\0'; in test_issue_102()
890 send_ascii_command(buffer); in test_issue_102()
892 assert(con->read(con, buffer, sizeof(buffer)) == 0); in test_issue_102()
898 snprintf(buffer, sizeof(buffer), "gets "); in test_issue_102()
901 offset += snprintf(buffer + offset, sizeof(buffer) - offset, in test_issue_102()
905 send_ascii_command(buffer); in test_issue_102()
912 buffer[3]= ' '; in test_issue_102()
913 send_ascii_command(buffer); in test_issue_102()
919 memset(buffer, ' ', sizeof(buffer)); in test_issue_102()
920 int len = snprintf(buffer + 101, sizeof(buffer) - 101, "gets foo"); in test_issue_102()
921 buffer[101 + len] = ' '; in test_issue_102()
922 buffer[sizeof(buffer) - 1] = '\0'; in test_issue_102()
923 send_ascii_command(buffer); in test_issue_102()
925 assert(con->read(con, buffer, sizeof(buffer)) == 0); in test_issue_102()
952 char buffer[1024]; in shutdown_memcached_server() local
960 assert(con->read(con, buffer, sizeof(buffer)) == 0); in shutdown_memcached_server()
1336 } buffer; in test_binary_noop() local
1338 size_t len = raw_command(buffer.bytes, sizeof(buffer.bytes), in test_binary_noop()
1342 safe_send(buffer.bytes, len, false); in test_binary_noop()
1343 safe_recv_packet(buffer.bytes, sizeof(buffer.bytes)); in test_binary_noop()
1344 validate_response_header(&buffer.response, PROTOCOL_BINARY_CMD_NOOP, in test_binary_noop()
1355 } buffer; in test_binary_quit_impl() local
1356 size_t len = raw_command(buffer.bytes, sizeof(buffer.bytes), in test_binary_quit_impl()
1359 safe_send(buffer.bytes, len, false); in test_binary_quit_impl()
1361 safe_recv_packet(buffer.bytes, sizeof(buffer.bytes)); in test_binary_quit_impl()
1362 validate_response_header(&buffer.response, PROTOCOL_BINARY_CMD_QUIT, in test_binary_quit_impl()
1367 assert(con->read(con, buffer.bytes, sizeof(buffer.bytes)) == 0); in test_binary_quit_impl()
1790 } buffer; in test_binary_version() local
1792 size_t len = raw_command(buffer.bytes, sizeof(buffer.bytes), in test_binary_version()
1796 safe_send(buffer.bytes, len, false); in test_binary_version()
1797 safe_recv_packet(buffer.bytes, sizeof(buffer.bytes)); in test_binary_version()
1798 validate_response_header(&buffer.response, PROTOCOL_BINARY_CMD_VERSION, in test_binary_version()
1971 } buffer; in test_binary_stat() local
1973 size_t len = raw_command(buffer.bytes, sizeof(buffer.bytes), in test_binary_stat()
1977 safe_send(buffer.bytes, len, false); in test_binary_stat()
1979 safe_recv_packet(buffer.bytes, sizeof(buffer.bytes)); in test_binary_stat()
1980 validate_response_header(&buffer.response, PROTOCOL_BINARY_CMD_STAT, in test_binary_stat()
1982 } while (buffer.response.message.header.response.keylen != 0); in test_binary_stat()
1994 } buffer; in test_binary_illegal() local
1995 size_t len = raw_command(buffer.bytes, sizeof(buffer.bytes), in test_binary_illegal()
1997 safe_send(buffer.bytes, len, false); in test_binary_illegal()
1998 safe_recv_packet(buffer.bytes, sizeof(buffer.bytes)); in test_binary_illegal()
1999 validate_response_header(&buffer.response, cmd, in test_binary_illegal()
2025 static enum test_return test_binary_pipeline_hickup_chunk(void *buffer, size_t buffersize) { in test_binary_pipeline_hickup_chunk() argument
2122 memcpy(((char*)buffer) + offset, command.bytes, len); in test_binary_pipeline_hickup_chunk()
2128 safe_send(buffer, offset, true); in test_binary_pipeline_hickup_chunk()
2136 void *buffer = malloc(buffersize); in test_binary_pipeline_hickup() local
2146 free(buffer); in test_binary_pipeline_hickup()
2155 test_binary_pipeline_hickup_chunk(buffer, buffersize); in test_binary_pipeline_hickup()
2159 size_t len = raw_command(buffer, buffersize, PROTOCOL_BINARY_CMD_QUITQ, in test_binary_pipeline_hickup()
2161 safe_send(buffer, len, false); in test_binary_pipeline_hickup()
2164 free(buffer); in test_binary_pipeline_hickup()