Index: net/socket/tcp_client_socket_win.cc |
=================================================================== |
--- net/socket/tcp_client_socket_win.cc (revision 113718) |
+++ net/socket/tcp_client_socket_win.cc (working copy) |
@@ -318,7 +318,7 @@ |
waiting_read_(false), |
waiting_write_(false), |
old_read_callback_(NULL), |
- old_write_callback_(NULL), |
+ write_callback_(NULL), |
next_connect_state_(CONNECT_STATE_NONE), |
connect_os_error_(0), |
net_log_(BoundNetLog::Make(net_log, NetLog::SOURCE_SOCKET)), |
@@ -792,7 +792,7 @@ |
DCHECK(CalledOnValidThread()); |
DCHECK_NE(socket_, INVALID_SOCKET); |
DCHECK(!waiting_write_); |
- DCHECK(!old_write_callback_ && write_callback_.is_null()); |
+ DCHECK(!write_callback_); |
DCHECK_GT(buf_len, 0); |
DCHECK(!core_->write_iobuffer_); |
@@ -833,57 +833,6 @@ |
} |
core_->WatchForWrite(); |
waiting_write_ = true; |
- old_write_callback_ = callback; |
- core_->write_iobuffer_ = buf; |
- return ERR_IO_PENDING; |
-} |
-int TCPClientSocketWin::Write(IOBuffer* buf, |
- int buf_len, |
- const CompletionCallback& callback) { |
- DCHECK(CalledOnValidThread()); |
- DCHECK_NE(socket_, INVALID_SOCKET); |
- DCHECK(!waiting_write_); |
- DCHECK(!old_write_callback_ && write_callback_.is_null()); |
- DCHECK_GT(buf_len, 0); |
- DCHECK(!core_->write_iobuffer_); |
- |
- base::StatsCounter writes("tcp.writes"); |
- writes.Increment(); |
- |
- core_->write_buffer_.len = buf_len; |
- core_->write_buffer_.buf = buf->data(); |
- core_->write_buffer_length_ = buf_len; |
- |
- // TODO(wtc): Remove the assertion after enough testing. |
- AssertEventNotSignaled(core_->write_overlapped_.hEvent); |
- DWORD num; |
- int rv = WSASend(socket_, &core_->write_buffer_, 1, &num, 0, |
- &core_->write_overlapped_, NULL); |
- if (rv == 0) { |
- if (ResetEventIfSignaled(core_->write_overlapped_.hEvent)) { |
- rv = static_cast<int>(num); |
- if (rv > buf_len || rv < 0) { |
- // It seems that some winsock interceptors report that more was written |
- // than was available. Treat this as an error. http://crbug.com/27870 |
- LOG(ERROR) << "Detected broken LSP: Asked to write " << buf_len |
- << " bytes, but " << rv << " bytes reported."; |
- return ERR_WINSOCK_UNEXPECTED_WRITTEN_BYTES; |
- } |
- base::StatsCounter write_bytes("tcp.write_bytes"); |
- write_bytes.Add(rv); |
- if (rv > 0) |
- use_history_.set_was_used_to_convey_data(); |
- net_log_.AddByteTransferEvent(NetLog::TYPE_SOCKET_BYTES_SENT, rv, |
- core_->write_buffer_.buf); |
- return rv; |
- } |
- } else { |
- int os_error = WSAGetLastError(); |
- if (os_error != WSA_IO_PENDING) |
- return MapSystemError(os_error); |
- } |
- core_->WatchForWrite(); |
- waiting_write_ = true; |
write_callback_ = callback; |
core_->write_iobuffer_ = buf; |
return ERR_IO_PENDING; |
@@ -948,19 +897,12 @@ |
void TCPClientSocketWin::DoWriteCallback(int rv) { |
DCHECK_NE(rv, ERR_IO_PENDING); |
- DCHECK(old_write_callback_ || !write_callback_.is_null()); |
+ DCHECK(write_callback_); |
- // Since Run may result in Write being called, clear old_write_callback_ up |
- // front. |
- if (old_write_callback_) { |
- OldCompletionCallback* c = old_write_callback_; |
- old_write_callback_ = NULL; |
- c->Run(rv); |
- } else { |
- CompletionCallback c = write_callback_; |
- write_callback_.Reset(); |
- c.Run(rv); |
- } |
+ // since Run may result in Write being called, clear write_callback_ up front. |
+ OldCompletionCallback* c = write_callback_; |
+ write_callback_ = NULL; |
+ c->Run(rv); |
} |
void TCPClientSocketWin::DidCompleteConnect() { |
Property changes on: net/socket/tcp_client_socket_win.cc |
___________________________________________________________________ |
Deleted: svn:mergeinfo |