| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "remoting/protocol/channel_multiplexer.h" | 5 #include "remoting/protocol/channel_multiplexer.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/message_loop/message_loop.h" | 8 #include "base/message_loop/message_loop.h" |
| 9 #include "base/run_loop.h" | 9 #include "base/run_loop.h" |
| 10 #include "net/base/net_errors.h" | 10 #include "net/base/net_errors.h" |
| (...skipping 236 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 247 | 247 |
| 248 host_session_.fake_channel_factory().GetFakeChannel(kMuxChannelName)-> | 248 host_session_.fake_channel_factory().GetFakeChannel(kMuxChannelName)-> |
| 249 set_next_write_error(net::ERR_FAILED); | 249 set_next_write_error(net::ERR_FAILED); |
| 250 host_session_.fake_channel_factory().GetFakeChannel(kMuxChannelName)-> | 250 host_session_.fake_channel_factory().GetFakeChannel(kMuxChannelName)-> |
| 251 set_async_write(false); | 251 set_async_write(false); |
| 252 | 252 |
| 253 scoped_refptr<net::IOBufferWithSize> buf = CreateTestBuffer(100); | 253 scoped_refptr<net::IOBufferWithSize> buf = CreateTestBuffer(100); |
| 254 | 254 |
| 255 MockSocketCallback cb1; | 255 MockSocketCallback cb1; |
| 256 MockSocketCallback cb2; | 256 MockSocketCallback cb2; |
| 257 EXPECT_CALL(cb1, OnDone(net::ERR_FAILED)); |
| 258 EXPECT_CALL(cb2, OnDone(net::ERR_FAILED)); |
| 257 | 259 |
| 258 EXPECT_CALL(cb1, OnDone(_)) | 260 EXPECT_EQ(net::ERR_IO_PENDING, |
| 259 .Times(0); | |
| 260 EXPECT_CALL(cb2, OnDone(_)) | |
| 261 .Times(0); | |
| 262 | |
| 263 EXPECT_EQ(net::ERR_FAILED, | |
| 264 host_socket1_->Write(buf.get(), | 261 host_socket1_->Write(buf.get(), |
| 265 buf->size(), | 262 buf->size(), |
| 266 base::Bind(&MockSocketCallback::OnDone, | 263 base::Bind(&MockSocketCallback::OnDone, |
| 267 base::Unretained(&cb1)))); | 264 base::Unretained(&cb1)))); |
| 268 EXPECT_EQ(net::ERR_FAILED, | 265 EXPECT_EQ(net::ERR_IO_PENDING, |
| 269 host_socket2_->Write(buf.get(), | 266 host_socket2_->Write(buf.get(), |
| 270 buf->size(), | 267 buf->size(), |
| 271 base::Bind(&MockSocketCallback::OnDone, | 268 base::Bind(&MockSocketCallback::OnDone, |
| 272 base::Unretained(&cb2)))); | 269 base::Unretained(&cb2)))); |
| 273 | 270 |
| 274 base::RunLoop().RunUntilIdle(); | 271 base::RunLoop().RunUntilIdle(); |
| 275 } | 272 } |
| 276 | 273 |
| 277 TEST_F(ChannelMultiplexerTest, WriteFailAsync) { | 274 TEST_F(ChannelMultiplexerTest, WriteFailAsync) { |
| 278 ASSERT_NO_FATAL_FAILURE( | 275 ASSERT_NO_FATAL_FAILURE( |
| (...skipping 89 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 368 .WillOnce(InvokeWithoutArgs( | 365 .WillOnce(InvokeWithoutArgs( |
| 369 this, &ChannelMultiplexerTest::DeleteAfterSessionFail)); | 366 this, &ChannelMultiplexerTest::DeleteAfterSessionFail)); |
| 370 EXPECT_CALL(cb2, OnConnectedPtr(_)) | 367 EXPECT_CALL(cb2, OnConnectedPtr(_)) |
| 371 .Times(0); | 368 .Times(0); |
| 372 | 369 |
| 373 base::RunLoop().RunUntilIdle(); | 370 base::RunLoop().RunUntilIdle(); |
| 374 } | 371 } |
| 375 | 372 |
| 376 } // namespace protocol | 373 } // namespace protocol |
| 377 } // namespace remoting | 374 } // namespace remoting |
| OLD | NEW |