| Index: net/http/http_network_transaction_unittest.cc
|
| ===================================================================
|
| --- net/http/http_network_transaction_unittest.cc (revision 14682)
|
| +++ net/http/http_network_transaction_unittest.cc (working copy)
|
| @@ -121,9 +121,9 @@
|
| return connected_;
|
| }
|
| // Socket methods:
|
| - virtual int Read(char* buf, int buf_len,
|
| + virtual int Read(IOBuffer* buf, int buf_len,
|
| CompletionCallback* callback) = 0;
|
| - virtual int Write(const char* buf, int buf_len,
|
| + virtual int Write(IOBuffer* buf, int buf_len,
|
| CompletionCallback* callback) = 0;
|
|
|
| #if defined(OS_LINUX)
|
| @@ -178,14 +178,14 @@
|
| }
|
|
|
| // Socket methods:
|
| - virtual int Read(char* buf, int buf_len, CompletionCallback* callback) {
|
| + virtual int Read(IOBuffer* buf, int buf_len, CompletionCallback* callback) {
|
| DCHECK(!callback_);
|
| MockRead& r = data_->reads[read_index_];
|
| int result = r.result;
|
| if (r.data) {
|
| if (r.data_len - read_offset_ > 0) {
|
| result = std::min(buf_len, r.data_len - read_offset_);
|
| - memcpy(buf, r.data + read_offset_, result);
|
| + memcpy(buf->data(), r.data + read_offset_, result);
|
| read_offset_ += result;
|
| if (read_offset_ == r.data_len) {
|
| read_index_++;
|
| @@ -202,7 +202,7 @@
|
| return result;
|
| }
|
|
|
| - virtual int Write(const char* buf, int buf_len,
|
| + virtual int Write(IOBuffer* buf, int buf_len,
|
| CompletionCallback* callback) {
|
| DCHECK(buf);
|
| DCHECK(buf_len > 0);
|
| @@ -217,7 +217,7 @@
|
| int result = w.result;
|
| if (w.data) {
|
| std::string expected_data(w.data, w.data_len);
|
| - std::string actual_data(buf, buf_len);
|
| + std::string actual_data(buf->data(), buf_len);
|
| EXPECT_EQ(expected_data, actual_data);
|
| if (expected_data != actual_data)
|
| return ERR_UNEXPECTED;
|
| @@ -310,12 +310,12 @@
|
| }
|
|
|
| // Socket methods:
|
| - virtual int Read(char* buf, int buf_len, CompletionCallback* callback) {
|
| + virtual int Read(IOBuffer* buf, int buf_len, CompletionCallback* callback) {
|
| DCHECK(!callback_);
|
| return transport_->Read(buf, buf_len, callback);
|
| }
|
|
|
| - virtual int Write(const char* buf, int buf_len,
|
| + virtual int Write(IOBuffer* buf, int buf_len,
|
| CompletionCallback* callback) {
|
| DCHECK(!callback_);
|
| return transport_->Write(buf, buf_len, callback);
|
| @@ -2915,7 +2915,7 @@
|
| CreateSession(proxy_service.get()), &mock_socket_factory));
|
|
|
| // Setup some state (which we expect ResetStateForRestart() will clear).
|
| - trans->header_buf_.reset(static_cast<char*>(malloc(10)));
|
| + trans->header_buf_->Realloc(10);
|
| trans->header_buf_capacity_ = 10;
|
| trans->header_buf_len_ = 3;
|
| trans->header_buf_body_offset_ = 11;
|
| @@ -2924,7 +2924,7 @@
|
| trans->response_body_read_ = 1;
|
| trans->read_buf_ = new IOBuffer(15);
|
| trans->read_buf_len_ = 15;
|
| - trans->request_headers_ = "Authorization: NTLM";
|
| + trans->request_headers_->headers_ = "Authorization: NTLM";
|
| trans->request_headers_bytes_sent_ = 3;
|
|
|
| // Setup state in response_
|
| @@ -2946,7 +2946,7 @@
|
| trans->ResetStateForRestart();
|
|
|
| // Verify that the state that needed to be reset, has been reset.
|
| - EXPECT_EQ(NULL, trans->header_buf_.get());
|
| + EXPECT_EQ(NULL, trans->header_buf_->headers());
|
| EXPECT_EQ(0, trans->header_buf_capacity_);
|
| EXPECT_EQ(0, trans->header_buf_len_);
|
| EXPECT_EQ(-1, trans->header_buf_body_offset_);
|
| @@ -2955,7 +2955,7 @@
|
| EXPECT_EQ(0, trans->response_body_read_);
|
| EXPECT_EQ(NULL, trans->read_buf_.get());
|
| EXPECT_EQ(0, trans->read_buf_len_);
|
| - EXPECT_EQ("", trans->request_headers_);
|
| + EXPECT_EQ("", trans->request_headers_->headers_);
|
| EXPECT_EQ(0U, trans->request_headers_bytes_sent_);
|
| EXPECT_EQ(NULL, trans->response_.auth_challenge.get());
|
| EXPECT_EQ(NULL, trans->response_.headers.get());
|
|
|