Index: remoting/protocol/pepper_transport_socket_adapter.cc |
=================================================================== |
--- remoting/protocol/pepper_transport_socket_adapter.cc (revision 113718) |
+++ remoting/protocol/pepper_transport_socket_adapter.cc (working copy) |
@@ -50,7 +50,7 @@ |
connected_(false), |
get_address_pending_(false), |
old_read_callback_(NULL), |
- old_write_callback_(NULL) { |
+ write_callback_(NULL) { |
callback_factory_.Initialize(this); |
} |
@@ -112,7 +112,7 @@ |
int PepperTransportSocketAdapter::Write(net::IOBuffer* buf, int buf_len, |
net::OldCompletionCallback* callback) { |
DCHECK(CalledOnValidThread()); |
- DCHECK(!old_write_callback_ && write_callback_.is_null()); |
+ DCHECK(!write_callback_); |
DCHECK(!write_buffer_); |
if (!transport_.get()) |
@@ -124,27 +124,6 @@ |
&PepperTransportSocketAdapter::OnWrite))); |
if (result == net::ERR_IO_PENDING) { |
- old_write_callback_ = callback; |
- write_buffer_ = buf; |
- } |
- |
- return result; |
-} |
-int PepperTransportSocketAdapter::Write( |
- net::IOBuffer* buf, int buf_len, const net::CompletionCallback& callback) { |
- DCHECK(CalledOnValidThread()); |
- DCHECK(!old_write_callback_ && write_callback_.is_null()); |
- DCHECK(!write_buffer_); |
- |
- if (!transport_.get()) |
- return net::ERR_SOCKET_NOT_CONNECTED; |
- |
- int result = PPErrorToNetError(transport_->Send( |
- buf->data(), buf_len, |
- callback_factory_.NewOptionalCallback( |
- &PepperTransportSocketAdapter::OnWrite))); |
- |
- if (result == net::ERR_IO_PENDING) { |
write_callback_ = callback; |
write_buffer_ = buf; |
} |
@@ -357,20 +336,13 @@ |
void PepperTransportSocketAdapter::OnWrite(int32_t result) { |
DCHECK(CalledOnValidThread()); |
- DCHECK(old_write_callback_ || !write_callback_.is_null()); |
+ DCHECK(write_callback_); |
DCHECK(write_buffer_); |
- if (old_write_callback_) { |
- net::OldCompletionCallback* callback = old_write_callback_; |
- old_write_callback_ = NULL; |
- write_buffer_ = NULL; |
- callback->Run(PPErrorToNetError(result)); |
- } else { |
- net::CompletionCallback callback = write_callback_; |
- write_callback_.Reset(); |
- write_buffer_ = NULL; |
- callback.Run(PPErrorToNetError(result)); |
- } |
+ net::OldCompletionCallback* callback = write_callback_; |
+ write_callback_ = NULL; |
+ write_buffer_ = NULL; |
+ callback->Run(PPErrorToNetError(result)); |
} |
} // namespace protocol |