| Index: net/socket/socket_test_util.cc
|
| ===================================================================
|
| --- net/socket/socket_test_util.cc (revision 113718)
|
| +++ net/socket/socket_test_util.cc (working copy)
|
| @@ -832,27 +832,7 @@
|
|
|
| return write_result.result;
|
| }
|
| -int MockTCPClientSocket::Write(net::IOBuffer* buf, int buf_len,
|
| - const net::CompletionCallback& callback) {
|
| - DCHECK(buf);
|
| - DCHECK_GT(buf_len, 0);
|
|
|
| - if (!connected_)
|
| - return net::ERR_UNEXPECTED;
|
| -
|
| - std::string data(buf->data(), buf_len);
|
| - net::MockWriteResult write_result = data_->OnWrite(data);
|
| -
|
| - was_used_to_convey_data_ = true;
|
| -
|
| - if (write_result.async) {
|
| - RunCallbackAsync(callback, write_result.result);
|
| - return net::ERR_IO_PENDING;
|
| - }
|
| -
|
| - return write_result.result;
|
| -}
|
| -
|
| int MockTCPClientSocket::Connect(net::OldCompletionCallback* callback) {
|
| if (connected_)
|
| return net::OK;
|
| @@ -992,7 +972,7 @@
|
| net::NetLog* net_log, net::DeterministicSocketData* data)
|
| : MockClientSocket(net_log),
|
| write_pending_(false),
|
| - old_write_callback_(NULL),
|
| + write_callback_(NULL),
|
| write_result_(0),
|
| read_data_(),
|
| read_buf_(NULL),
|
| @@ -1007,10 +987,7 @@
|
| void DeterministicMockTCPClientSocket::CompleteWrite() {
|
| was_used_to_convey_data_ = true;
|
| write_pending_ = false;
|
| - if (old_write_callback_)
|
| - old_write_callback_->Run(write_result_);
|
| - else
|
| - write_callback_.Run(write_result_);
|
| + write_callback_->Run(write_result_);
|
| }
|
|
|
| int DeterministicMockTCPClientSocket::CompleteRead() {
|
| @@ -1044,6 +1021,30 @@
|
| return result;
|
| }
|
|
|
| +int DeterministicMockTCPClientSocket::Write(
|
| + net::IOBuffer* buf, int buf_len, net::OldCompletionCallback* callback) {
|
| + DCHECK(buf);
|
| + DCHECK_GT(buf_len, 0);
|
| +
|
| + if (!connected_)
|
| + return net::ERR_UNEXPECTED;
|
| +
|
| + std::string data(buf->data(), buf_len);
|
| + net::MockWriteResult write_result = data_->OnWrite(data);
|
| +
|
| + if (write_result.async) {
|
| + write_callback_ = callback;
|
| + write_result_ = write_result.result;
|
| + DCHECK(write_callback_ != NULL);
|
| + write_pending_ = true;
|
| + return net::ERR_IO_PENDING;
|
| + }
|
| +
|
| + was_used_to_convey_data_ = true;
|
| + write_pending_ = false;
|
| + return write_result.result;
|
| +}
|
| +
|
| int DeterministicMockTCPClientSocket::Read(
|
| net::IOBuffer* buf, int buf_len, net::OldCompletionCallback* callback) {
|
| if (!connected_)
|
| @@ -1091,53 +1092,6 @@
|
| return CompleteRead();
|
| }
|
|
|
| -int DeterministicMockTCPClientSocket::Write(
|
| - net::IOBuffer* buf, int buf_len, net::OldCompletionCallback* callback) {
|
| - DCHECK(buf);
|
| - DCHECK_GT(buf_len, 0);
|
| -
|
| - if (!connected_)
|
| - return net::ERR_UNEXPECTED;
|
| -
|
| - std::string data(buf->data(), buf_len);
|
| - net::MockWriteResult write_result = data_->OnWrite(data);
|
| -
|
| - if (write_result.async) {
|
| - old_write_callback_ = callback;
|
| - write_result_ = write_result.result;
|
| - DCHECK(old_write_callback_ != NULL);
|
| - write_pending_ = true;
|
| - return net::ERR_IO_PENDING;
|
| - }
|
| -
|
| - was_used_to_convey_data_ = true;
|
| - write_pending_ = false;
|
| - return write_result.result;
|
| -}
|
| -int DeterministicMockTCPClientSocket::Write(
|
| - net::IOBuffer* buf, int buf_len, const net::CompletionCallback& callback) {
|
| - DCHECK(buf);
|
| - DCHECK_GT(buf_len, 0);
|
| -
|
| - if (!connected_)
|
| - return net::ERR_UNEXPECTED;
|
| -
|
| - std::string data(buf->data(), buf_len);
|
| - net::MockWriteResult write_result = data_->OnWrite(data);
|
| -
|
| - if (write_result.async) {
|
| - write_callback_ = callback;
|
| - write_result_ = write_result.result;
|
| - DCHECK(!write_callback_.is_null());
|
| - write_pending_ = true;
|
| - return net::ERR_IO_PENDING;
|
| - }
|
| -
|
| - was_used_to_convey_data_ = true;
|
| - write_pending_ = false;
|
| - return write_result.result;
|
| -}
|
| -
|
| // TODO(erikchen): Support connect sequencing.
|
| int DeterministicMockTCPClientSocket::Connect(
|
| net::OldCompletionCallback* callback) {
|
| @@ -1281,10 +1235,6 @@
|
| net::OldCompletionCallback* callback) {
|
| return transport_->socket()->Write(buf, buf_len, callback);
|
| }
|
| -int MockSSLClientSocket::Write(net::IOBuffer* buf, int buf_len,
|
| - const net::CompletionCallback& callback) {
|
| - return transport_->socket()->Write(buf, buf_len, callback);
|
| -}
|
|
|
| int MockSSLClientSocket::Connect(net::OldCompletionCallback* callback) {
|
| OldConnectCallback* connect_callback = new OldConnectCallback(
|
| @@ -1472,24 +1422,7 @@
|
| }
|
| return write_result.result;
|
| }
|
| -int MockUDPClientSocket::Write(net::IOBuffer* buf, int buf_len,
|
| - const net::CompletionCallback& callback) {
|
| - DCHECK(buf);
|
| - DCHECK_GT(buf_len, 0);
|
|
|
| - if (!connected_)
|
| - return ERR_UNEXPECTED;
|
| -
|
| - std::string data(buf->data(), buf_len);
|
| - MockWriteResult write_result = data_->OnWrite(data);
|
| -
|
| - if (write_result.async) {
|
| - RunCallbackAsync(callback, write_result.result);
|
| - return ERR_IO_PENDING;
|
| - }
|
| - return write_result.result;
|
| -}
|
| -
|
| bool MockUDPClientSocket::SetReceiveBufferSize(int32 size) {
|
| return true;
|
| }
|
|
|