/dports/net-im/kopete/kopete-21.12.3/protocols/jabber/libjingle/talk/p2p/base/ |
H A D | relayserver.h | 53 explicit RelayServer(talk_base::Thread* thread); 56 talk_base::Thread* thread() { return thread_; } in thread() 89 typedef std::map<talk_base::AsyncSocket*, 92 typedef std::map<talk_base::SocketAddressPair, 95 talk_base::Thread* thread_; 133 void OnMessage(talk_base::Message *pmsg); 188 talk_base::SocketAddressPair addr_pair_; 189 talk_base::AsyncPacketSocket* socket_; 191 talk_base::SocketAddress default_dest_; 225 const talk_base::SocketAddress& ext_addr); [all …]
|
H A D | testrelayserver.h | 43 TestRelayServer(talk_base::Thread* thread, in TestRelayServer() 44 const talk_base::SocketAddress& udp_int_addr, in TestRelayServer() 72 talk_base::AsyncSocket* CreateListenSocket(talk_base::Thread* thread, in CreateListenSocket() 73 const talk_base::SocketAddress& addr) { in CreateListenSocket() 74 talk_base::AsyncSocket* socket = in CreateListenSocket() 81 void OnAccept(talk_base::AsyncSocket* socket) { in OnAccept() 88 talk_base::AsyncTCPSocket* packet_socket = new talk_base::AsyncTCPSocket( in OnAccept() 110 talk_base::scoped_ptr<talk_base::AsyncSocket> tcp_int_socket_; 111 talk_base::scoped_ptr<talk_base::AsyncSocket> tcp_ext_socket_; 112 talk_base::scoped_ptr<talk_base::AsyncSocket> ssl_int_socket_; [all …]
|
H A D | tcpport.h | 50 static TCPPort* Create(talk_base::Thread* thread, in Create() 52 talk_base::Network* network, in Create() 53 const talk_base::IPAddress& ip, in Create() 76 TCPPort(talk_base::Thread* thread, talk_base::PacketSocketFactory* factory, 77 talk_base::Network* network, const talk_base::IPAddress& ip, 91 talk_base::SocketAddress addr; 92 talk_base::AsyncPacketSocket* socket; 95 talk_base::AsyncPacketSocket* GetIncoming( 109 talk_base::AsyncPacketSocket* socket_; 129 void OnConnect(talk_base::AsyncPacketSocket* socket); [all …]
|
H A D | stunport.h | 37 namespace talk_base { 49 static StunPort* Create(talk_base::Thread* thread, in Create() 51 talk_base::Network* network, in Create() 52 const talk_base::IPAddress& ip, in Create() 65 talk_base::SocketAddress GetLocalAddress() const { in GetLocalAddress() 91 StunPort(talk_base::Thread* thread, talk_base::PacketSocketFactory* factory, 92 talk_base::Network* network, const talk_base::IPAddress& ip, 111 talk_base::SocketAddress server_addr_; 112 talk_base::SocketAddress server_addr2_; 114 talk_base::AsyncPacketSocket* socket_; [all …]
|
H A D | relayport_unittest.cc | 41 using talk_base::SocketAddress; 96 talk_base::InitRandom(NULL, 0); in SetUpTestCase() 101 talk_base::AsyncUDPSocket* ext_socket = in SetUp() 202 talk_base::scoped_ptr<talk_base::AsyncSocket> tcp_server_socket( in TestConnectSslTcp() 227 talk_base::AsyncSocket* socket = in CreateAsyncUdpSocket() 237 talk_base::AsyncSocket* socket = in CreateServerSocket() 266 talk_base::Thread* main_; 267 talk_base::scoped_ptr<talk_base::PhysicalSocketServer> 269 talk_base::scoped_ptr<talk_base::VirtualSocketServer> virtual_socket_server_; 270 talk_base::SocketServerScope ss_scope_; [all …]
|
H A D | port.h | 46 namespace talk_base { 66 talk_base::SocketAddress address; 79 talk_base::PacketSocketFactory* factory, talk_base::Network* network, 214 talk_base::IPAddress& ip() { return ip_; } in ip() 247 talk_base::Thread* thread_; 248 talk_base::PacketSocketFactory* factory_; 250 talk_base::Network* network_; 251 talk_base::IPAddress ip_; 274 talk_base::ProxyInfo proxy_; 391 void OnMessage(talk_base::Message *pmsg); [all …]
|
H A D | udpport.h | 35 namespace talk_base { 48 static UDPPort* Create(talk_base::Thread* thread, in Create() 49 talk_base::PacketSocketFactory* factory, in Create() 50 talk_base::Network* network, in Create() 51 const talk_base::IPAddress& ip, in Create() 71 UDPPort(talk_base::Thread* thread, talk_base::PacketSocketFactory* factory, 72 talk_base::Network* network, const talk_base::IPAddress& ip, 80 void OnAddressReady(talk_base::AsyncPacketSocket* socket, 81 const talk_base::SocketAddress& address); 84 void OnReadPacket(talk_base::AsyncPacketSocket* socket, [all …]
|
/dports/net-im/kopete/kopete-21.12.3/protocols/jabber/libjingle/talk/p2p/client/ |
H A D | connectivitychecker.h | 19 namespace talk_base { 67 talk_base::IPAddress ip; 95 talk_base::IPAddress ip; 96 talk_base::ProxyInfo proxy_info; 138 talk_base::ProxyInfo proxy_; 179 talk_base::Thread* worker() { in worker() 200 talk_base::Thread* thread) { in CreateSocketFactory() 239 talk_base::Thread* worker_; 246 talk_base::scoped_ptr<talk_base::NetworkManager> network_manager_; 247 talk_base::scoped_ptr<talk_base::BasicPacketSocketFactory> socket_factory_; [all …]
|
H A D | basicportallocator.h | 95 talk_base::NetworkManager* network_manager_; 96 talk_base::PacketSocketFactory* socket_factory_; 97 const talk_base::SocketAddress stun_address_; 98 const talk_base::SocketAddress relay_address_udp_; 99 const talk_base::SocketAddress relay_address_tcp_; 100 const talk_base::SocketAddress relay_address_ssl_; 134 virtual void OnMessage(talk_base::Message *message); 159 talk_base::Thread* network_thread_; 160 talk_base::scoped_ptr<talk_base::PacketSocketFactory> owned_socket_factory_; 161 talk_base::PacketSocketFactory* socket_factory_; [all …]
|
H A D | connectivitychecker_unittest.cc | 24 static const talk_base::ProxyType kProxyType = talk_base::PROXY_HTTPS; 46 FakeRelayPort(talk_base::Thread* thread, in FakeRelayPort() 48 talk_base::Network* network, in FakeRelayPort() 75 FakeStunPort(talk_base::Thread* thread, in FakeStunPort() 77 talk_base::Network* network, in FakeStunPort() 78 const talk_base::IPAddress& ip, in FakeStunPort() 132 talk_base::AsyncHttpRequest* request = in CreateAsyncHttpResponse() 207 talk_base::Thread* thread) { in CreateSocketFactory() 210 new talk_base::BasicPacketSocketFactory(talk_base::Thread::Current()); in CreateSocketFactory() 260 talk_base::ProxyInfo proxy_info_; [all …]
|
H A D | connectivitychecker.cc | 62 talk_base::SignalThread* data) { in OnRequestDone() 63 talk_base::AsyncHttpRequest* request = in OnRequestDone() 74 talk_base::Thread* worker, in ConnectivityChecker() 105 main_ = talk_base::Thread::Current(); in Start() 138 uint32 now = talk_base::Time(); in AddNic() 153 talk_base::ProxyInfo proxy_info; in GetProxyInfo() 210 std::vector<talk_base::Network*> networks; in OnRequestDone() 220 uint32 now = talk_base::Time(); in OnRequestDone() 288 uint32 now = talk_base::Time(); in OnStunAddressReady() 376 uint32 now = talk_base::Time(); in CreateRelayPorts() [all …]
|
/dports/net-im/kopete/kopete-21.12.3/protocols/jabber/libjingle/talk/base/ |
H A D | sslstreamadapter_unittest.cc | 70 virtual talk_base::StreamState GetState() const { return talk_base::SS_OPEN; } in GetState() 74 talk_base::StreamResult r; in Read() 79 if (r == talk_base::SR_EOS) in Read() 80 return talk_base::SR_EOS; in Read() 93 int mask = (talk_base::SE_READ | talk_base::SE_CLOSE); in OnEventIn() 131 talk_base::FifoBuffer *in_; 132 talk_base::FifoBuffer *out_; 154 talk_base::InitializeSSL(); in SSLStreamAdapterTestBase() 356 talk_base::scoped_ptr<talk_base::SSLStreamAdapter> client_ssl_; 357 talk_base::scoped_ptr<talk_base::SSLStreamAdapter> server_ssl_; [all …]
|
H A D | proxy_unittest.cc | 38 using talk_base::Socket; 39 using talk_base::Thread; 40 using talk_base::SocketAddress; 65 socks_.reset(new talk_base::SocksProxyServer( in ProxyTest() 77 talk_base::ProxyType type; in DetectProxyType() 87 talk_base::scoped_ptr<talk_base::SocketServer> ss_; 88 talk_base::scoped_ptr<talk_base::SocksProxyServer> socks_; 90 talk_base::scoped_ptr<talk_base::HttpListenServer> https_; 96 talk_base::AsyncSocksProxySocket* proxy_socket = in TEST_F() 102 talk_base::AsyncTCPSocket* packet_socket = talk_base::AsyncTCPSocket::Create( in TEST_F() [all …]
|
/dports/net-im/kopete/kopete-21.12.3/protocols/jabber/libjingle/talk/session/phone/ |
H A D | fakenetworkinterface.h | 62 talk_base::CritScope cs(&crit_); in SetConferenceMode() 68 talk_base::CritScope cs(&crit_); in NumRtpBytes() 77 talk_base::CritScope cs(&crit_); in NumRtpBytes() 84 talk_base::CritScope cs(&crit_); in NumRtpPackets() 89 talk_base::CritScope cs(&crit_); in NumRtpPackets() 96 talk_base::CritScope cs(&crit_); in NumSentSsrcs() 102 talk_base::CritScope cs(&crit_); in GetRtpPacket() 110 talk_base::CritScope cs(&crit_); in NumRtcpPackets() 176 talk_base::TypedMessageData<talk_base::Buffer>* msg_data = in OnMessage() 177 static_cast<talk_base::TypedMessageData<talk_base::Buffer>*>( in OnMessage() [all …]
|
H A D | filemediaengine.cc | 62 talk_base::FileStream* input_file_stream = NULL; in CreateChannel() 63 talk_base::FileStream* output_file_stream = NULL; in CreateChannel() 91 talk_base::FileStream* input_file_stream = NULL; in CreateVideoChannel() 92 talk_base::FileStream* output_file_stream = NULL; in CreateVideoChannel() 123 : public talk_base::Thread, public talk_base::MessageHandler { 147 talk_base::scoped_ptr<talk_base::StreamInterface> input_stream_; 148 talk_base::scoped_ptr<talk_base::StreamInterface> output_stream_; 166 talk_base::StreamInterface* input_file_stream, in RtpSenderReceiver() 191 start_send_time_ = talk_base::Time(); in SetSend() 221 int wait = talk_base::TimeUntil( in OnMessage() [all …]
|
H A D | rtpdump.cc | 113 talk_base::StreamResult res = talk_base::SR_SUCCESS; in ReadPacket() 126 if (res != talk_base::SR_SUCCESS) { in ReadPacket() 142 if (res == talk_base::SR_SUCCESS && in ReadPacket() 156 if (res != talk_base::SR_SUCCESS) { in ReadFileHeader() 160 return talk_base::SR_ERROR; in ReadFileHeader() 166 if (res == talk_base::SR_SUCCESS) { in ReadFileHeader() 300 talk_base::ByteBuffer buffer; in UpdateDumpPacket() 335 talk_base::ByteBuffer buf; in WriteFileHeader() 345 talk_base::StreamResult res = talk_base::SR_SUCCESS; in WritePacket() 358 return talk_base::SR_SUCCESS; in WritePacket() [all …]
|
H A D | rtpdump_unittest.cc | 43 talk_base::ByteBuffer rtp_buf; in TEST() 63 talk_base::ByteBuffer rtcp_buf; in TEST() 76 talk_base::MemoryStream stream; in TEST() 90 EXPECT_EQ(talk_base::SR_SUCCESS, in TEST() 99 EXPECT_EQ(talk_base::SR_SUCCESS, in TEST() 108 EXPECT_EQ(talk_base::SR_SUCCESS, in TEST() 117 talk_base::MemoryStream stream; in TEST() 153 talk_base::MemoryStream stream; in TEST() 173 talk_base::MemoryStream stream; in TEST() 201 talk_base::MemoryStream stream; in TEST() [all …]
|
H A D | mediarecorder_unittest.cc | 65 talk_base::ByteBuffer buf; in OnRtpPacket() 79 talk_base::Pathname path_; 80 talk_base::scoped_ptr<RtpDumpSink> sink_; 81 talk_base::ByteBuffer rtp_buf_[3]; 82 talk_base::scoped_ptr<talk_base::StreamInterface> stream_; 83 talk_base::scoped_ptr<RtpDumpReader> reader_; 108 EXPECT_EQ(talk_base::SR_EOS, ReadPacket(&packet)); in TEST_F() 129 EXPECT_EQ(talk_base::SR_EOS, ReadPacket(&packet)); in TEST_F() 162 EXPECT_EQ(talk_base::SR_EOS, ReadPacket(&packet)); in TEST_F() 181 talk_base::Pathname path; in TestMediaRecorder() [all …]
|
H A D | filemediaengine_unittest.cc | 144 talk_base::Pathname temp_path; in GetTempFilename() 158 talk_base::scoped_ptr<talk_base::StreamInterface> stream( in WriteTestPacketsToFile() 159 talk_base::Filesystem::OpenFile(talk_base::Pathname(filename), "wb")); in WriteTestPacketsToFile() 173 if (talk_base::Filesystem::IsFile(talk_base::Pathname(pathname))) { in DeleteTempFile() 309 talk_base::MemoryStream net_dump; in TEST_F() 347 talk_base::MemoryStream net_dump; in TEST_F() 368 talk_base::scoped_ptr<talk_base::StreamInterface> voice_output_; in TEST_F() 385 talk_base::MemoryStream net_dump; in TEST_F() 405 talk_base::scoped_ptr<talk_base::StreamInterface> voice_output_; in TEST_F() 421 talk_base::scoped_ptr<talk_base::StreamInterface> input_stream( in TEST_F() [all …]
|
/dports/net-im/kopete/kopete-21.12.3/protocols/jabber/libjingle/talk/app/webrtc/ |
H A D | mediastreamtrackproxy.h | 73 bool HandleMessage(talk_base::Message* msg); 75 mutable talk_base::Thread* signaling_thread_; 86 talk_base::Thread* signaling_thread); 90 talk_base::Thread* signaling_thread); 93 talk_base::Thread* signaling_thread); 99 talk_base::Thread* signaling_thread); 106 virtual void OnMessage(talk_base::Message* msg); 119 talk_base::Thread* signaling_thread); 123 talk_base::Thread* signaling_thread); 126 talk_base::Thread* signaling_thread); [all …]
|
H A D | mediastreamtrackproxy.cc | 50 typedef talk_base::TypedMessageData 76 talk_base::Thread* signaling_thread) in MediaStreamTrackProxy() 171 talk_base::MessageData* data = msg->pdata; in HandleMessage() 237 talk_base::Thread* signaling_thread) { in CreateRemote() 239 talk_base::RefCountedObject<AudioTrackProxy>* track = in CreateRemote() 247 talk_base::Thread* signaling_thread) { in CreateLocal() 249 talk_base::RefCountedObject<AudioTrackProxy>* track = in CreateLocal() 258 talk_base::Thread* signaling_thread) { in CreateLocal() 311 talk_base::Thread* signaling_thread) { in CreateRemote() 321 talk_base::Thread* signaling_thread) { in CreateLocal() [all …]
|
H A D | peerconnectionfactoryimpl.h | 43 virtual talk_base::scoped_refptr<PeerConnectionInterface> 46 virtual talk_base::scoped_refptr<PeerConnectionInterface> 54 virtual talk_base::scoped_refptr<LocalVideoTrackInterface> 63 virtual talk_base::Thread* signaling_thread(); 64 virtual talk_base::Thread* worker_thread(); 70 talk_base::Thread* worker_thread, 71 talk_base::Thread* signaling_thread, 84 void OnMessage(talk_base::Message* msg); 87 talk_base::Thread* signaling_thread_; 88 talk_base::Thread* worker_thread_; [all …]
|
H A D | mediastream_unittest.cc | 42 using talk_base::scoped_refptr; 47 class ReadyStateMessageData : public talk_base::MessageData { 80 explicit MockObserver(talk_base::Thread* signaling_thread) in MockObserver() 90 talk_base::Thread* signaling_thread_; 138 talk_base::Thread* signaling_thread_; 184 talk_base::Thread* signaling_thread_; 213 talk_base::Thread* signaling_thread) in MockLocalAudioTrack() 225 public talk_base::MessageHandler { 228 signaling_thread_ .reset(new talk_base::Thread()); in SetUp() 291 talk_base::scoped_ptr<talk_base::Thread> signaling_thread_; [all …]
|
/dports/net-im/kopete/kopete-21.12.3/protocols/jabber/libjingle/talk/examples/login/ |
H A D | xmppsocket.cc | 49 talk_base::Thread* pth = talk_base::Thread::Current(); in XmppSocket() 50 talk_base::AsyncSocket* socket = in XmppSocket() 126 if ((events & talk_base::SE_OPEN)) { in OnEvent() 131 events |= talk_base::SE_WRITE; in OnEvent() 139 if ((events & talk_base::SE_READ)) in OnEvent() 141 if ((events & talk_base::SE_WRITE)) { in OnEvent() 144 talk_base::StreamResult result; in OnEvent() 153 if (result == talk_base::SR_BLOCK) in OnEvent() 160 if ((events & talk_base::SE_CLOSE)) in OnEvent() 193 if (result == talk_base::SR_SUCCESS) in Read() [all …]
|
/dports/net-im/kopete/kopete-21.12.3/protocols/jabber/libjingle/talk/session/tunnel/ |
H A D | tunnelsessionclient_unittest.cc | 164 if (events & talk_base::SE_READ) { in OnStreamEvent() 169 if (events & talk_base::SE_WRITE) { in OnStreamEvent() 178 if (events & talk_base::SE_CLOSE) { in OnStreamEvent() 191 talk_base::StreamResult res; in ReadData() 193 talk_base::SR_SUCCESS) { in ReadData() 196 ASSERT(res != talk_base::SR_EOS); in ReadData() 204 talk_base::StreamResult res = talk_base::Flow(&send_stream_, in WriteData() 206 if (res == talk_base::SR_BLOCK) { in WriteData() 225 talk_base::scoped_ptr<talk_base::StreamInterface> local_tunnel_; 226 talk_base::scoped_ptr<talk_base::StreamInterface> remote_tunnel_; [all …]
|