| Index: mojo/edk/system/raw_channel.cc
|
| diff --git a/mojo/edk/system/raw_channel.cc b/mojo/edk/system/raw_channel.cc
|
| index 0bfe104590b33ca4fa63f43ada2acb75e8c05b02..433116680d0d3672f315473f779eaa8bf78cade1 100644
|
| --- a/mojo/edk/system/raw_channel.cc
|
| +++ b/mojo/edk/system/raw_channel.cc
|
| @@ -133,9 +133,8 @@ void RawChannel::WriteBuffer::GetBuffers(std::vector<Buffer>* buffers) const {
|
| // attached.
|
|
|
| // Write from both buffers.
|
| - DCHECK_EQ(
|
| - bytes_to_write,
|
| - message->main_buffer_size() - data_offset_ + transport_data_buffer_size);
|
| + DCHECK_EQ(bytes_to_write, message->main_buffer_size() - data_offset_ +
|
| + transport_data_buffer_size);
|
| Buffer buffer1 = {
|
| static_cast<const char*>(message->main_buffer()) + data_offset_,
|
| message->main_buffer_size() - data_offset_};
|
| @@ -195,11 +194,9 @@ bool RawChannel::Init(Delegate* delegate) {
|
| if (io_result != IO_PENDING) {
|
| // This will notify the delegate about the read failure. Although we're on
|
| // the I/O thread, don't call it in the nested context.
|
| - message_loop_for_io_->PostTask(FROM_HERE,
|
| - base::Bind(&RawChannel::OnReadCompleted,
|
| - weak_ptr_factory_.GetWeakPtr(),
|
| - io_result,
|
| - 0));
|
| + message_loop_for_io_->PostTask(
|
| + FROM_HERE, base::Bind(&RawChannel::OnReadCompleted,
|
| + weak_ptr_factory_.GetWeakPtr(), io_result, 0));
|
| }
|
|
|
| // ScheduleRead() failure is treated as a read failure (by notifying the
|
| @@ -246,15 +243,15 @@ bool RawChannel::WriteMessage(scoped_ptr<MessageInTransit> message) {
|
| if (io_result == IO_PENDING)
|
| return true;
|
|
|
| - bool result = OnWriteCompletedNoLock(
|
| - io_result, platform_handles_written, bytes_written);
|
| + bool result = OnWriteCompletedNoLock(io_result, platform_handles_written,
|
| + bytes_written);
|
| if (!result) {
|
| // Even if we're on the I/O thread, don't call |OnError()| in the nested
|
| // context.
|
| - message_loop_for_io_->PostTask(FROM_HERE,
|
| - base::Bind(&RawChannel::CallOnError,
|
| - weak_ptr_factory_.GetWeakPtr(),
|
| - Delegate::ERROR_WRITE));
|
| + message_loop_for_io_->PostTask(
|
| + FROM_HERE,
|
| + base::Bind(&RawChannel::CallOnError, weak_ptr_factory_.GetWeakPtr(),
|
| + Delegate::ERROR_WRITE));
|
| }
|
|
|
| return result;
|
| @@ -312,8 +309,7 @@ void RawChannel::OnReadCompleted(IOResult io_result, size_t bytes_read) {
|
| // TODO(vtl): Validate that |message_size| is sane.
|
| while (remaining_bytes > 0 && MessageInTransit::GetNextMessageSize(
|
| &read_buffer_->buffer_[read_buffer_start],
|
| - remaining_bytes,
|
| - &message_size) &&
|
| + remaining_bytes, &message_size) &&
|
| remaining_bytes >= message_size) {
|
| MessageInTransit::View message_view(
|
| message_size, &read_buffer_->buffer_[read_buffer_start]);
|
| @@ -341,8 +337,7 @@ void RawChannel::OnReadCompleted(IOResult io_result, size_t bytes_read) {
|
| size_t num_platform_handles;
|
| const void* platform_handle_table;
|
| TransportData::GetPlatformHandleTable(
|
| - message_view.transport_data_buffer(),
|
| - &num_platform_handles,
|
| + message_view.transport_data_buffer(), &num_platform_handles,
|
| &platform_handle_table);
|
|
|
| if (num_platform_handles > 0) {
|
| @@ -383,8 +378,7 @@ void RawChannel::OnReadCompleted(IOResult io_result, size_t bytes_read) {
|
| read_buffer_->num_valid_bytes_ = remaining_bytes;
|
| if (read_buffer_->num_valid_bytes_ > 0) {
|
| memmove(&read_buffer_->buffer_[0],
|
| - &read_buffer_->buffer_[read_buffer_start],
|
| - remaining_bytes);
|
| + &read_buffer_->buffer_[read_buffer_start], remaining_bytes);
|
| }
|
| read_buffer_start = 0;
|
| }
|
| @@ -433,8 +427,8 @@ void RawChannel::OnWriteCompleted(IOResult io_result,
|
| return;
|
| }
|
|
|
| - did_fail = !OnWriteCompletedNoLock(
|
| - io_result, platform_handles_written, bytes_written);
|
| + did_fail = !OnWriteCompletedNoLock(io_result, platform_handles_written,
|
| + bytes_written);
|
| }
|
|
|
| if (did_fail)
|
|
|