147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org/* 247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org * Copyright 2004 The WebRTC Project Authors. All rights reserved. 347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org * 447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org * Use of this source code is governed by a BSD-style license 547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org * that can be found in the LICENSE file in the root of the source 647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org * tree. An additional intellectual property rights grant can be found 747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org * in the file PATENTS. All contributing project authors may 847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org * be found in the AUTHORS file in the root of the source tree. 947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org */ 1047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 1147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org#include <string> 1247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 1347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org#include "webrtc/base/asyncudpsocket.h" 1447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org#include "webrtc/base/gunit.h" 1547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org#include "webrtc/base/physicalsocketserver.h" 1647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org#include "webrtc/base/scoped_ptr.h" 1747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org#include "webrtc/base/virtualsocketserver.h" 1847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 1947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgnamespace rtc { 2047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 2147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgclass AsyncUdpSocketTest 2247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org : public testing::Test, 2347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org public sigslot::has_slots<> { 2447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org public: 2547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org AsyncUdpSocketTest() 2647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org : pss_(new rtc::PhysicalSocketServer), 2747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org vss_(new rtc::VirtualSocketServer(pss_.get())), 2847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org socket_(vss_->CreateAsyncSocket(SOCK_DGRAM)), 2947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org udp_socket_(new AsyncUDPSocket(socket_)), 3047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ready_to_send_(false) { 3147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org udp_socket_->SignalReadyToSend.connect(this, 3247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org &AsyncUdpSocketTest::OnReadyToSend); 3347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 3447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 3547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org void OnReadyToSend(rtc::AsyncPacketSocket* socket) { 3647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ready_to_send_ = true; 3747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 3847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 3947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org protected: 4047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org scoped_ptr<PhysicalSocketServer> pss_; 4147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org scoped_ptr<VirtualSocketServer> vss_; 4247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org AsyncSocket* socket_; 4347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org scoped_ptr<AsyncUDPSocket> udp_socket_; 4447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org bool ready_to_send_; 4547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org}; 4647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 4747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgTEST_F(AsyncUdpSocketTest, OnWriteEvent) { 4847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org EXPECT_FALSE(ready_to_send_); 4947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org socket_->SignalWriteEvent(socket_); 5047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org EXPECT_TRUE(ready_to_send_); 5147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 5247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 5347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} // namespace rtc 54