| Index: mojo/edk/system/raw_channel_win.cc
|
| diff --git a/mojo/edk/system/raw_channel_win.cc b/mojo/edk/system/raw_channel_win.cc
|
| index 10a9bff7baa54d2b05a973861798c7e6b376bb92..ca2bd41ae18d1af652d4f4af4e8d18367beef11f 100644
|
| --- a/mojo/edk/system/raw_channel_win.cc
|
| +++ b/mojo/edk/system/raw_channel_win.cc
|
| @@ -225,21 +225,21 @@ void RawChannelWin::RawChannelIOHandler::OnPendingReadStarted() {
|
|
|
| bool RawChannelWin::RawChannelIOHandler::pending_write_no_lock() const {
|
| DCHECK(owner_);
|
| - owner_->write_lock().AssertAcquired();
|
| + owner_->write_mutex().AssertHeld();
|
| return pending_write_;
|
| }
|
|
|
| base::MessageLoopForIO::IOContext*
|
| RawChannelWin::RawChannelIOHandler::write_context_no_lock() {
|
| DCHECK(owner_);
|
| - owner_->write_lock().AssertAcquired();
|
| + owner_->write_mutex().AssertHeld();
|
| return &write_context_;
|
| }
|
|
|
| void RawChannelWin::RawChannelIOHandler::OnPendingWriteStartedNoLock(
|
| size_t platform_handles_written) {
|
| DCHECK(owner_);
|
| - owner_->write_lock().AssertAcquired();
|
| + owner_->write_mutex().AssertHeld();
|
| DCHECK(!pending_write_);
|
| pending_write_ = true;
|
| platform_handles_written_ = platform_handles_written;
|
| @@ -276,7 +276,7 @@ void RawChannelWin::RawChannelIOHandler::DetachFromOwnerNoLock(
|
| scoped_ptr<WriteBuffer> write_buffer) {
|
| DCHECK(owner_);
|
| DCHECK_EQ(base::MessageLoop::current(), owner_->message_loop_for_io());
|
| - owner_->write_lock().AssertAcquired();
|
| + owner_->write_mutex().AssertHeld();
|
|
|
| // If read/write is pending, we have to retain the corresponding buffer.
|
| if (pending_read_)
|
| @@ -336,7 +336,7 @@ void RawChannelWin::RawChannelIOHandler::OnWriteCompleted(DWORD bytes_written,
|
| }
|
|
|
| {
|
| - base::AutoLock locker(owner_->write_lock());
|
| + MutexLocker locker(&owner_->write_mutex());
|
| CHECK(pending_write_);
|
| pending_write_ = false;
|
| }
|
| @@ -482,7 +482,7 @@ embedder::ScopedPlatformHandleVectorPtr RawChannelWin::GetReadPlatformHandles(
|
| RawChannel::IOResult RawChannelWin::WriteNoLock(
|
| size_t* platform_handles_written,
|
| size_t* bytes_written) {
|
| - write_lock().AssertAcquired();
|
| + write_mutex().AssertHeld();
|
|
|
| DCHECK(io_handler_);
|
| DCHECK(!io_handler_->pending_write_no_lock());
|
| @@ -551,7 +551,7 @@ RawChannel::IOResult RawChannelWin::WriteNoLock(
|
| }
|
|
|
| RawChannel::IOResult RawChannelWin::ScheduleWriteNoLock() {
|
| - write_lock().AssertAcquired();
|
| + write_mutex().AssertHeld();
|
|
|
| DCHECK(io_handler_);
|
| DCHECK(!io_handler_->pending_write_no_lock());
|
| @@ -598,7 +598,7 @@ void RawChannelWin::OnShutdownNoLock(scoped_ptr<ReadBuffer> read_buffer,
|
| DCHECK_EQ(base::MessageLoop::current(), message_loop_for_io());
|
| DCHECK(io_handler_);
|
|
|
| - write_lock().AssertAcquired();
|
| + write_mutex().AssertHeld();
|
|
|
| if (io_handler_->pending_read() || io_handler_->pending_write_no_lock()) {
|
| // |io_handler_| will be alive until pending read/write (if any) completes.
|
|
|