| Index: mojo/edk/system/raw_channel_unittest.cc
|
| diff --git a/mojo/edk/system/raw_channel_unittest.cc b/mojo/edk/system/raw_channel_unittest.cc
|
| index 7717f490ac1d05ffbeb5a6f5c5b3c82d6a95af70..9ee937d0868034be65952ca312cbfe12da16d9a6 100644
|
| --- a/mojo/edk/system/raw_channel_unittest.cc
|
| +++ b/mojo/edk/system/raw_channel_unittest.cc
|
| @@ -41,7 +41,8 @@
|
| return make_scoped_ptr(
|
| new MessageInTransit(MessageInTransit::kTypeMessagePipeEndpoint,
|
| MessageInTransit::kSubtypeMessagePipeEndpointData,
|
| - num_bytes, bytes.empty() ? nullptr : &bytes[0]));
|
| + num_bytes,
|
| + bytes.empty() ? nullptr : &bytes[0]));
|
| }
|
|
|
| bool CheckMessageData(const void* bytes, uint32_t num_bytes) {
|
| @@ -62,8 +63,8 @@
|
| scoped_ptr<MessageInTransit> message(MakeTestMessage(num_bytes));
|
|
|
| size_t write_size = 0;
|
| - mojo::test::BlockingWrite(handle, message->main_buffer(),
|
| - message->main_buffer_size(), &write_size);
|
| + mojo::test::BlockingWrite(
|
| + handle, message->main_buffer(), message->main_buffer_size(), &write_size);
|
| return write_size == message->main_buffer_size();
|
| }
|
|
|
| @@ -134,8 +135,8 @@
|
|
|
| for (size_t i = 0; i < kMessageReaderMaxPollIterations;) {
|
| size_t read_size = 0;
|
| - CHECK(mojo::test::NonBlockingRead(handle_, buffer, sizeof(buffer),
|
| - &read_size));
|
| + CHECK(mojo::test::NonBlockingRead(
|
| + handle_, buffer, sizeof(buffer), &read_size));
|
|
|
| // Append newly-read data to |bytes_|.
|
| bytes_.insert(bytes_.end(), buffer, buffer + read_size);
|
| @@ -143,7 +144,8 @@
|
| // If we have the header....
|
| size_t message_size;
|
| if (MessageInTransit::GetNextMessageSize(
|
| - bytes_.empty() ? nullptr : &bytes_[0], bytes_.size(),
|
| + bytes_.empty() ? nullptr : &bytes_[0],
|
| + bytes_.size(),
|
| &message_size)) {
|
| // If we've read the whole message....
|
| if (bytes_.size() >= message_size) {
|
| @@ -376,14 +378,16 @@
|
| WriteOnlyRawChannelDelegate writer_delegate;
|
| scoped_ptr<RawChannel> writer_rc(RawChannel::Create(handles[0].Pass()));
|
| io_thread()->PostTaskAndWait(FROM_HERE,
|
| - base::Bind(&InitOnIOThread, writer_rc.get(),
|
| + base::Bind(&InitOnIOThread,
|
| + writer_rc.get(),
|
| base::Unretained(&writer_delegate)));
|
|
|
| ReadCountdownRawChannelDelegate reader_delegate(kNumWriterThreads *
|
| kNumWriteMessagesPerThread);
|
| scoped_ptr<RawChannel> reader_rc(RawChannel::Create(handles[1].Pass()));
|
| io_thread()->PostTaskAndWait(FROM_HERE,
|
| - base::Bind(&InitOnIOThread, reader_rc.get(),
|
| + base::Bind(&InitOnIOThread,
|
| + reader_rc.get(),
|
| base::Unretained(&reader_delegate)));
|
|
|
| {
|
|
|