diff options
| author | willchan@chromium.org <willchan@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2010-05-19 22:17:08 +0000 |
|---|---|---|
| committer | willchan@chromium.org <willchan@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2010-05-19 22:17:08 +0000 |
| commit | 94f808c3eaa95d3bc66be0c7caa66f37d9e0cbae (patch) | |
| tree | ebc3916995102d43a2c60b9d8158fe362a37a77b /net/socket/tcp_client_socket_win.cc | |
| parent | 564261db36338330d9b4b046e4a386b6e99ba10a (diff) | |
| download | chromium_src-94f808c3eaa95d3bc66be0c7caa66f37d9e0cbae.zip chromium_src-94f808c3eaa95d3bc66be0c7caa66f37d9e0cbae.tar.gz chromium_src-94f808c3eaa95d3bc66be0c7caa66f37d9e0cbae.tar.bz2 | |
Make TCPClientSocket* inherit from NonThreadSafe.
Review URL: http://codereview.chromium.org/2108022
git-svn-id: svn://svn.chromium.org/chrome/trunk/src@47735 0039d316-1c4b-4281-b951-d872f2087c98
Diffstat (limited to 'net/socket/tcp_client_socket_win.cc')
| -rw-r--r-- | net/socket/tcp_client_socket_win.cc | 13 |
1 files changed, 13 insertions, 0 deletions
diff --git a/net/socket/tcp_client_socket_win.cc b/net/socket/tcp_client_socket_win.cc index fffc37a..a24a313 100644 --- a/net/socket/tcp_client_socket_win.cc +++ b/net/socket/tcp_client_socket_win.cc @@ -292,6 +292,8 @@ TCPClientSocketWin::~TCPClientSocketWin() { } int TCPClientSocketWin::Connect(CompletionCallback* callback) { + DCHECK(CalledOnValidThread()); + // If already connected, then just return OK. if (socket_ != INVALID_SOCKET) return OK; @@ -368,6 +370,8 @@ int TCPClientSocketWin::DoConnect() { } void TCPClientSocketWin::Disconnect() { + DCHECK(CalledOnValidThread()); + if (socket_ == INVALID_SOCKET) return; @@ -406,6 +410,8 @@ void TCPClientSocketWin::Disconnect() { } bool TCPClientSocketWin::IsConnected() const { + DCHECK(CalledOnValidThread()); + if (socket_ == INVALID_SOCKET || waiting_connect_) return false; @@ -421,6 +427,8 @@ bool TCPClientSocketWin::IsConnected() const { } bool TCPClientSocketWin::IsConnectedAndIdle() const { + DCHECK(CalledOnValidThread()); + if (socket_ == INVALID_SOCKET || waiting_connect_) return false; @@ -437,6 +445,7 @@ bool TCPClientSocketWin::IsConnectedAndIdle() const { } int TCPClientSocketWin::GetPeerAddress(AddressList* address) const { + DCHECK(CalledOnValidThread()); DCHECK(address); if (!current_ai_) return ERR_FAILED; @@ -447,6 +456,7 @@ int TCPClientSocketWin::GetPeerAddress(AddressList* address) const { int TCPClientSocketWin::Read(IOBuffer* buf, int buf_len, CompletionCallback* callback) { + DCHECK(CalledOnValidThread()); DCHECK_NE(socket_, INVALID_SOCKET); DCHECK(!waiting_read_); DCHECK(!read_callback_); @@ -496,6 +506,7 @@ int TCPClientSocketWin::Read(IOBuffer* buf, int TCPClientSocketWin::Write(IOBuffer* buf, int buf_len, CompletionCallback* callback) { + DCHECK(CalledOnValidThread()); DCHECK_NE(socket_, INVALID_SOCKET); DCHECK(!waiting_write_); DCHECK(!write_callback_); @@ -546,6 +557,7 @@ int TCPClientSocketWin::Write(IOBuffer* buf, } bool TCPClientSocketWin::SetReceiveBufferSize(int32 size) { + DCHECK(CalledOnValidThread()); int rv = setsockopt(socket_, SOL_SOCKET, SO_RCVBUF, reinterpret_cast<const char*>(&size), sizeof(size)); DCHECK(!rv) << "Could not set socket receive buffer size: " << GetLastError(); @@ -553,6 +565,7 @@ bool TCPClientSocketWin::SetReceiveBufferSize(int32 size) { } bool TCPClientSocketWin::SetSendBufferSize(int32 size) { + DCHECK(CalledOnValidThread()); int rv = setsockopt(socket_, SOL_SOCKET, SO_SNDBUF, reinterpret_cast<const char*>(&size), sizeof(size)); DCHECK(!rv) << "Could not set socket send buffer size: " << GetLastError(); |