Index: remoting/protocol/pseudotcp_adapter.cc |
diff --git a/remoting/protocol/pseudotcp_adapter.cc b/remoting/protocol/pseudotcp_adapter.cc |
index 2ba797ee29de369c981cd562b881980be6aacb3d..2b89c7885d3620c06475a40f5166421dff127658 100644 |
--- a/remoting/protocol/pseudotcp_adapter.cc |
+++ b/remoting/protocol/pseudotcp_adapter.cc |
@@ -455,6 +455,7 @@ PseudoTcpAdapter::PseudoTcpAdapter(std::unique_ptr<P2PDatagramSocket> socket) |
: core_(new Core(std::move(socket))) {} |
PseudoTcpAdapter::~PseudoTcpAdapter() { |
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
// Make sure that the underlying socket is destroyed before PseudoTcp. |
core_->DeleteSocket(); |
} |
@@ -462,46 +463,46 @@ PseudoTcpAdapter::~PseudoTcpAdapter() { |
int PseudoTcpAdapter::Read(const scoped_refptr<net::IOBuffer>& buffer, |
int buffer_size, |
const net::CompletionCallback& callback) { |
- DCHECK(CalledOnValidThread()); |
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
return core_->Read(buffer, buffer_size, callback); |
} |
int PseudoTcpAdapter::Write(const scoped_refptr<net::IOBuffer>& buffer, |
int buffer_size, |
const net::CompletionCallback& callback) { |
- DCHECK(CalledOnValidThread()); |
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
return core_->Write(buffer, buffer_size, callback); |
} |
int PseudoTcpAdapter::SetReceiveBufferSize(int32_t size) { |
- DCHECK(CalledOnValidThread()); |
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
core_->SetReceiveBufferSize(size); |
return net::OK; |
} |
int PseudoTcpAdapter::SetSendBufferSize(int32_t size) { |
- DCHECK(CalledOnValidThread()); |
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
core_->SetSendBufferSize(size); |
return net::OK; |
} |
int PseudoTcpAdapter::Connect(const net::CompletionCallback& callback) { |
- DCHECK(CalledOnValidThread()); |
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
return core_->Connect(callback); |
} |
void PseudoTcpAdapter::SetAckDelay(int delay_ms) { |
- DCHECK(CalledOnValidThread()); |
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
core_->SetAckDelay(delay_ms); |
} |
void PseudoTcpAdapter::SetNoDelay(bool no_delay) { |
- DCHECK(CalledOnValidThread()); |
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
core_->SetNoDelay(no_delay); |
} |
void PseudoTcpAdapter::SetWriteWaitsForSend(bool write_waits_for_send) { |
- DCHECK(CalledOnValidThread()); |
+ DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); |
core_->SetWriteWaitsForSend(write_waits_for_send); |
} |