| Index: mojo/edk/system/raw_channel_posix.cc
|
| diff --git a/mojo/edk/system/raw_channel_posix.cc b/mojo/edk/system/raw_channel_posix.cc
|
| index 71ec02f7489b42a474835ee8b21174262860e389..45d93e86867985e2f46e910a1c18a63d4fb9ac10 100644
|
| --- a/mojo/edk/system/raw_channel_posix.cc
|
| +++ b/mojo/edk/system/raw_channel_posix.cc
|
| @@ -135,7 +135,8 @@
|
| i += embedder::kPlatformChannelMaxNumHandles) {
|
| scoped_ptr<MessageInTransit> fd_message(new MessageInTransit(
|
| MessageInTransit::kTypeRawChannel,
|
| - MessageInTransit::kSubtypeRawChannelPosixExtraPlatformHandles, 0,
|
| + MessageInTransit::kSubtypeRawChannelPosixExtraPlatformHandles,
|
| + 0,
|
| nullptr));
|
| embedder::ScopedPlatformHandleVectorPtr fds(
|
| new embedder::PlatformHandleVector(
|
| @@ -252,8 +253,8 @@
|
| DCHECK(!buffers.empty());
|
|
|
| if (buffers.size() == 1) {
|
| - write_result = embedder::PlatformChannelWrite(fd_.get(), buffers[0].addr,
|
| - buffers[0].size);
|
| + write_result = embedder::PlatformChannelWrite(
|
| + fd_.get(), buffers[0].addr, buffers[0].size);
|
| } else {
|
| const size_t kMaxBufferCount = 10;
|
| iovec iov[kMaxBufferCount];
|
| @@ -301,8 +302,11 @@
|
| }
|
|
|
| if (message_loop_for_io()->WatchFileDescriptor(
|
| - fd_.get().fd, false, base::MessageLoopForIO::WATCH_WRITE,
|
| - write_watcher_.get(), this)) {
|
| + fd_.get().fd,
|
| + false,
|
| + base::MessageLoopForIO::WATCH_WRITE,
|
| + write_watcher_.get(),
|
| + this)) {
|
| pending_write_ = true;
|
| return IO_PENDING;
|
| }
|
| @@ -319,8 +323,11 @@
|
| write_watcher_.reset(new base::MessageLoopForIO::FileDescriptorWatcher());
|
|
|
| if (!message_loop_for_io()->WatchFileDescriptor(
|
| - fd_.get().fd, true, base::MessageLoopForIO::WATCH_READ,
|
| - read_watcher_.get(), this)) {
|
| + fd_.get().fd,
|
| + true,
|
| + base::MessageLoopForIO::WATCH_READ,
|
| + read_watcher_.get(),
|
| + this)) {
|
| // TODO(vtl): I'm not sure |WatchFileDescriptor()| actually fails cleanly
|
| // (in the sense of returning the message loop's state to what it was before
|
| // it was called).
|
| @@ -414,7 +421,7 @@
|
| // then received the message data plus the first set of handles for the next
|
| // message in the subsequent |recvmsg()|.)
|
| if (read_platform_handles_.size() >
|
| - (TransportData::GetMaxPlatformHandles() +
|
| + (TransportData::kMaxPlatformHandles +
|
| embedder::kPlatformChannelMaxNumHandles)) {
|
| LOG(ERROR) << "Received too many platform handles";
|
| embedder::CloseAllPlatformHandles(&read_platform_handles_);
|
| @@ -448,8 +455,11 @@
|
| DCHECK(write_watcher_);
|
|
|
| if (!message_loop_for_io()->WatchFileDescriptor(
|
| - fd_.get().fd, false, base::MessageLoopForIO::WATCH_WRITE,
|
| - write_watcher_.get(), this)) {
|
| + fd_.get().fd,
|
| + false,
|
| + base::MessageLoopForIO::WATCH_WRITE,
|
| + write_watcher_.get(),
|
| + this)) {
|
| {
|
| base::AutoLock locker(write_lock());
|
|
|
|
|