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))); |
{ |