Home
last modified time | relevance | path

Searched refs:talk_base (Results 1 – 25 of 591) sorted by relevance

12345678910>>...24

/dports/net-im/kopete/kopete-21.12.3/protocols/jabber/libjingle/talk/p2p/base/
H A Drelayserver.h53 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 Dtestrelayserver.h43 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 Dtcpport.h50 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 Dstunport.h37 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 Drelayport_unittest.cc41 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 Dport.h46 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 Dudpport.h35 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 Dconnectivitychecker.h19 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 Dbasicportallocator.h95 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 Dconnectivitychecker_unittest.cc24 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 Dconnectivitychecker.cc62 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 Dsslstreamadapter_unittest.cc70 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 Dproxy_unittest.cc38 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 Dfakenetworkinterface.h62 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 Dfilemediaengine.cc62 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 Drtpdump.cc113 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 Drtpdump_unittest.cc43 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 Dmediarecorder_unittest.cc65 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 Dfilemediaengine_unittest.cc144 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 Dmediastreamtrackproxy.h73 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 Dmediastreamtrackproxy.cc50 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 Dpeerconnectionfactoryimpl.h43 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 Dmediastream_unittest.cc42 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 Dxmppsocket.cc49 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 Dtunnelsessionclient_unittest.cc164 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 …]

12345678910>>...24