| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include <algorithm> | 5 #include <algorithm> |
| 6 #include <utility> | 6 #include <utility> |
| 7 #include <vector> | 7 #include <vector> |
| 8 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/bind_helpers.h" | 10 #include "base/bind_helpers.h" |
| (...skipping 129 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 140 | 140 |
| 141 void OnWrite(int result) { | 141 void OnWrite(int result) { |
| 142 ASSERT_GT(result, 0); | 142 ASSERT_GT(result, 0); |
| 143 write_buffer_->DidConsume(result); | 143 write_buffer_->DidConsume(result); |
| 144 if (write_buffer_->BytesRemaining()) | 144 if (write_buffer_->BytesRemaining()) |
| 145 Write(); | 145 Write(); |
| 146 } | 146 } |
| 147 | 147 |
| 148 void ReadInternal(const net::CompletionCallback& callback) { | 148 void ReadInternal(const net::CompletionCallback& callback) { |
| 149 read_buffer_ = new IOBufferWithSize(kMaxExpectedResponseLength); | 149 read_buffer_ = new IOBufferWithSize(kMaxExpectedResponseLength); |
| 150 int result = socket_->Read(read_buffer_, | 150 int result = |
| 151 kMaxExpectedResponseLength, | 151 socket_->Read(read_buffer_.get(), kMaxExpectedResponseLength, callback); |
| 152 callback); | |
| 153 if (result != ERR_IO_PENDING) | 152 if (result != ERR_IO_PENDING) |
| 154 callback.Run(result); | 153 callback.Run(result); |
| 155 } | 154 } |
| 156 | 155 |
| 157 bool IsCompleteResponse(const std::string& response) { | 156 bool IsCompleteResponse(const std::string& response) { |
| 158 // Check end of headers first. | 157 // Check end of headers first. |
| 159 int end_of_headers = HttpUtil::LocateEndOfHeaders(response.data(), | 158 int end_of_headers = HttpUtil::LocateEndOfHeaders(response.data(), |
| 160 response.size()); | 159 response.size()); |
| 161 if (end_of_headers < 0) | 160 if (end_of_headers < 0) |
| 162 return false; | 161 return false; |
| (...skipping 363 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 526 return ERR_NOT_IMPLEMENTED; | 525 return ERR_NOT_IMPLEMENTED; |
| 527 } | 526 } |
| 528 virtual int SetReceiveBufferSize(int32 size) OVERRIDE { | 527 virtual int SetReceiveBufferSize(int32 size) OVERRIDE { |
| 529 return ERR_NOT_IMPLEMENTED; | 528 return ERR_NOT_IMPLEMENTED; |
| 530 } | 529 } |
| 531 virtual int SetSendBufferSize(int32 size) OVERRIDE { | 530 virtual int SetSendBufferSize(int32 size) OVERRIDE { |
| 532 return ERR_NOT_IMPLEMENTED; | 531 return ERR_NOT_IMPLEMENTED; |
| 533 } | 532 } |
| 534 | 533 |
| 535 void DidRead(const char* data, int data_len) { | 534 void DidRead(const char* data, int data_len) { |
| 536 if (!read_buf_) { | 535 if (!read_buf_.get()) { |
| 537 pending_read_data_.append(data, data_len); | 536 pending_read_data_.append(data, data_len); |
| 538 return; | 537 return; |
| 539 } | 538 } |
| 540 int read_len = std::min(data_len, read_buf_len_); | 539 int read_len = std::min(data_len, read_buf_len_); |
| 541 memcpy(read_buf_->data(), data, read_len); | 540 memcpy(read_buf_->data(), data, read_len); |
| 542 pending_read_data_.assign(data + read_len, data_len - read_len); | 541 pending_read_data_.assign(data + read_len, data_len - read_len); |
| 543 read_buf_ = NULL; | 542 read_buf_ = NULL; |
| 544 read_buf_len_ = 0; | 543 read_buf_len_ = 0; |
| 545 base::ResetAndReturn(&read_callback_).Run(read_len); | 544 base::ResetAndReturn(&read_callback_).Run(read_len); |
| 546 } | 545 } |
| (...skipping 67 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 614 | 613 |
| 615 ASSERT_EQ(client_connection_id, GetConnectionId(2)); | 614 ASSERT_EQ(client_connection_id, GetConnectionId(2)); |
| 616 server_->Send200(client_connection_id, "Content for /test3", "text/plain"); | 615 server_->Send200(client_connection_id, "Content for /test3", "text/plain"); |
| 617 std::string response3; | 616 std::string response3; |
| 618 ASSERT_TRUE(client.ReadResponse(&response3)); | 617 ASSERT_TRUE(client.ReadResponse(&response3)); |
| 619 ASSERT_TRUE(StartsWithASCII(response3, "HTTP/1.1 200 OK", true)); | 618 ASSERT_TRUE(StartsWithASCII(response3, "HTTP/1.1 200 OK", true)); |
| 620 ASSERT_TRUE(EndsWith(response3, "Content for /test3", true)); | 619 ASSERT_TRUE(EndsWith(response3, "Content for /test3", true)); |
| 621 } | 620 } |
| 622 | 621 |
| 623 } // namespace net | 622 } // namespace net |
| OLD | NEW |