Index: net/base/tcp_client_socket_unittest.cc |
=================================================================== |
--- net/base/tcp_client_socket_unittest.cc (revision 14682) |
+++ net/base/tcp_client_socket_unittest.cc (working copy) |
@@ -103,7 +103,11 @@ |
} |
const char request_text[] = "GET / HTTP/1.0\r\n\r\n"; |
- rv = sock_->Write(request_text, arraysize(request_text) - 1, &callback); |
+ scoped_refptr<net::IOBuffer> request_buffer = |
+ new net::IOBuffer(arraysize(request_text) - 1); |
+ memcpy(request_buffer->data(), request_text, arraysize(request_text) - 1); |
+ |
+ rv = sock_->Write(request_buffer, arraysize(request_text) - 1, &callback); |
EXPECT_TRUE(rv >= 0 || rv == net::ERR_IO_PENDING); |
if (rv == net::ERR_IO_PENDING) { |
@@ -111,9 +115,9 @@ |
EXPECT_EQ(rv, static_cast<int>(arraysize(request_text) - 1)); |
} |
- char buf[4096]; |
+ scoped_refptr<net::IOBuffer> buf = new net::IOBuffer(4096); |
for (;;) { |
- rv = sock_->Read(buf, sizeof(buf), &callback); |
+ rv = sock_->Read(buf, 4096, &callback); |
EXPECT_TRUE(rv >= 0 || rv == net::ERR_IO_PENDING); |
if (rv == net::ERR_IO_PENDING) |
@@ -136,7 +140,11 @@ |
} |
const char request_text[] = "GET / HTTP/1.0\r\n\r\n"; |
- rv = sock_->Write(request_text, arraysize(request_text) - 1, &callback); |
+ scoped_refptr<net::IOBuffer> request_buffer = |
+ new net::IOBuffer(arraysize(request_text) - 1); |
+ memcpy(request_buffer->data(), request_text, arraysize(request_text) - 1); |
+ |
+ rv = sock_->Write(request_buffer, arraysize(request_text) - 1, &callback); |
EXPECT_TRUE(rv >= 0 || rv == net::ERR_IO_PENDING); |
if (rv == net::ERR_IO_PENDING) { |
@@ -144,9 +152,9 @@ |
EXPECT_EQ(rv, static_cast<int>(arraysize(request_text) - 1)); |
} |
- char buf[1]; |
+ scoped_refptr<net::IOBuffer> buf = new net::IOBuffer(1); |
for (;;) { |
- rv = sock_->Read(buf, sizeof(buf), &callback); |
+ rv = sock_->Read(buf, 1, &callback); |
EXPECT_TRUE(rv >= 0 || rv == net::ERR_IO_PENDING); |
if (rv == net::ERR_IO_PENDING) |
@@ -169,7 +177,11 @@ |
} |
const char request_text[] = "GET / HTTP/1.0\r\n\r\n"; |
- rv = sock_->Write(request_text, arraysize(request_text) - 1, &callback); |
+ scoped_refptr<net::IOBuffer> request_buffer = |
+ new net::IOBuffer(arraysize(request_text) - 1); |
+ memcpy(request_buffer->data(), request_text, arraysize(request_text) - 1); |
+ |
+ rv = sock_->Write(request_buffer, arraysize(request_text) - 1, &callback); |
EXPECT_TRUE(rv >= 0 || rv == net::ERR_IO_PENDING); |
if (rv == net::ERR_IO_PENDING) { |
@@ -178,8 +190,8 @@ |
} |
// Do a partial read and then exit. This test should not crash! |
- char buf[512]; |
- rv = sock_->Read(buf, sizeof(buf), &callback); |
+ scoped_refptr<net::IOBuffer> buf = new net::IOBuffer(512); |
+ rv = sock_->Read(buf, 512, &callback); |
EXPECT_TRUE(rv >= 0 || rv == net::ERR_IO_PENDING); |
if (rv == net::ERR_IO_PENDING) |
@@ -198,13 +210,19 @@ |
EXPECT_EQ(rv, net::OK); |
} |
- char buf[4096]; |
- rv = sock_->Read(buf, sizeof(buf), &callback); |
+ const int kBufLen = 4096; |
+ scoped_refptr<net::IOBuffer> buf = new net::IOBuffer(kBufLen); |
+ rv = sock_->Read(buf, kBufLen, &callback); |
EXPECT_EQ(net::ERR_IO_PENDING, rv); |
const char request_text[] = "GET / HTTP/1.0\r\n\r\n"; |
+ scoped_refptr<net::IOBuffer> request_buffer = |
+ new net::IOBuffer(arraysize(request_text) - 1); |
+ memcpy(request_buffer->data(), request_text, arraysize(request_text) - 1); |
TestCompletionCallback write_callback; |
- rv = sock_->Write(request_text, arraysize(request_text) - 1, &write_callback); |
+ |
+ rv = sock_->Write(request_buffer, arraysize(request_text) - 1, |
+ &write_callback); |
EXPECT_TRUE(rv >= 0 || rv == net::ERR_IO_PENDING); |
if (rv == net::ERR_IO_PENDING) { |
@@ -215,7 +233,7 @@ |
rv = callback.WaitForResult(); |
EXPECT_GE(rv, 0); |
while (rv > 0) { |
- rv = sock_->Read(buf, sizeof(buf), &callback); |
+ rv = sock_->Read(buf, kBufLen, &callback); |
EXPECT_TRUE(rv >= 0 || rv == net::ERR_IO_PENDING); |
if (rv == net::ERR_IO_PENDING) |
@@ -238,12 +256,18 @@ |
} |
const char request_text[] = "GET / HTTP/1.0\r\n\r\n"; |
+ scoped_refptr<net::IOBuffer> request_buffer = |
+ new net::IOBuffer(arraysize(request_text) - 1); |
+ memcpy(request_buffer->data(), request_text, arraysize(request_text) - 1); |
TestCompletionCallback write_callback; |
- rv = sock_->Write(request_text, arraysize(request_text) - 1, &write_callback); |
+ |
+ rv = sock_->Write(request_buffer, arraysize(request_text) - 1, |
+ &write_callback); |
EXPECT_TRUE(rv >= 0 || rv == net::ERR_IO_PENDING); |
- char buf[4096]; |
- int read_rv = sock_->Read(buf, sizeof(buf), &callback); |
+ const int kBufLen = 4096; |
+ scoped_refptr<net::IOBuffer> buf = new net::IOBuffer(kBufLen); |
+ int read_rv = sock_->Read(buf, kBufLen, &callback); |
EXPECT_TRUE(read_rv >= 0 || read_rv == net::ERR_IO_PENDING); |
if (rv == net::ERR_IO_PENDING) { |
@@ -254,7 +278,7 @@ |
rv = callback.WaitForResult(); |
EXPECT_GE(rv, 0); |
while (rv > 0) { |
- rv = sock_->Read(buf, sizeof(buf), &callback); |
+ rv = sock_->Read(buf, kBufLen, &callback); |
EXPECT_TRUE(rv >= 0 || rv == net::ERR_IO_PENDING); |
if (rv == net::ERR_IO_PENDING) |