| 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/jingle_glue/chromium_socket_factory.h" | 5 #include "remoting/jingle_glue/chromium_socket_factory.h" |
| 6 | 6 |
| 7 #include "base/message_loop.h" | 7 #include "base/message_loop.h" |
| 8 #include "base/run_loop.h" | 8 #include "base/run_loop.h" |
| 9 #include "testing/gmock/include/gmock/gmock.h" | 9 #include "testing/gmock/include/gmock/gmock.h" |
| 10 #include "testing/gtest/include/gtest/gtest.h" | 10 #include "testing/gtest/include/gtest/gtest.h" |
| (...skipping 19 matching lines...) Expand all Loading... |
| 30 void OnPacket(talk_base::AsyncPacketSocket* socket, | 30 void OnPacket(talk_base::AsyncPacketSocket* socket, |
| 31 const char* data, size_t size, | 31 const char* data, size_t size, |
| 32 const talk_base::SocketAddress& address) { | 32 const talk_base::SocketAddress& address) { |
| 33 EXPECT_EQ(socket, socket_.get()); | 33 EXPECT_EQ(socket, socket_.get()); |
| 34 last_packet_.assign(data, data + size); | 34 last_packet_.assign(data, data + size); |
| 35 last_address_ = address; | 35 last_address_ = address; |
| 36 run_loop_.Quit(); | 36 run_loop_.Quit(); |
| 37 } | 37 } |
| 38 | 38 |
| 39 protected: | 39 protected: |
| 40 MessageLoopForIO message_loop_; | 40 base::MessageLoopForIO message_loop_; |
| 41 base::RunLoop run_loop_; | 41 base::RunLoop run_loop_; |
| 42 | 42 |
| 43 scoped_ptr<talk_base::PacketSocketFactory> socket_factory_; | 43 scoped_ptr<talk_base::PacketSocketFactory> socket_factory_; |
| 44 scoped_ptr<talk_base::AsyncPacketSocket> socket_; | 44 scoped_ptr<talk_base::AsyncPacketSocket> socket_; |
| 45 | 45 |
| 46 std::string last_packet_; | 46 std::string last_packet_; |
| 47 talk_base::SocketAddress last_address_; | 47 talk_base::SocketAddress last_address_; |
| 48 }; | 48 }; |
| 49 | 49 |
| 50 TEST_F(ChromiumSocketFactoryTest, SendAndReceive) { | 50 TEST_F(ChromiumSocketFactoryTest, SendAndReceive) { |
| (...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 85 const int kMaxPort = 12410; | 85 const int kMaxPort = 12410; |
| 86 socket_.reset(socket_factory_->CreateUdpSocket( | 86 socket_.reset(socket_factory_->CreateUdpSocket( |
| 87 talk_base::SocketAddress("127.0.0.1", 0), kMaxPort, kMaxPort)); | 87 talk_base::SocketAddress("127.0.0.1", 0), kMaxPort, kMaxPort)); |
| 88 ASSERT_TRUE(socket_.get() != NULL); | 88 ASSERT_TRUE(socket_.get() != NULL); |
| 89 EXPECT_EQ(socket_->GetState(), talk_base::AsyncPacketSocket::STATE_BOUND); | 89 EXPECT_EQ(socket_->GetState(), talk_base::AsyncPacketSocket::STATE_BOUND); |
| 90 EXPECT_GE(socket_->GetLocalAddress().port(), kMinPort); | 90 EXPECT_GE(socket_->GetLocalAddress().port(), kMinPort); |
| 91 EXPECT_LE(socket_->GetLocalAddress().port(), kMaxPort); | 91 EXPECT_LE(socket_->GetLocalAddress().port(), kMaxPort); |
| 92 } | 92 } |
| 93 | 93 |
| 94 } // namespace remoting | 94 } // namespace remoting |
| OLD | NEW |