/external/chromium_org/third_party/libjingle/source/talk/base/ |
H A D | worker.cc | 34 namespace talk_base { namespace 50 talk_base::Thread *me = talk_base::Thread::Current(); 70 } else if (worker_thread_ != talk_base::Thread::Current()) { 86 void Worker::OnMessage(talk_base::Message *msg) { 88 ASSERT(worker_thread_ == talk_base::Thread::Current()); 92 } // namespace talk_base
|
H A D | asynctcpsocket_unittest.cc | 36 namespace talk_base { namespace 43 : pss_(new talk_base::PhysicalSocketServer), 44 vss_(new talk_base::VirtualSocketServer(pss_.get())), 52 void OnReadyToSend(talk_base::AsyncPacketSocket* socket) { 70 } // namespace talk_base
|
H A D | asyncudpsocket_unittest.cc | 36 namespace talk_base { namespace 43 : pss_(new talk_base::PhysicalSocketServer), 44 vss_(new talk_base::VirtualSocketServer(pss_.get())), 52 void OnReadyToSend(talk_base::AsyncPacketSocket* socket) { 70 } // namespace talk_base
|
H A D | systeminfo_unittest.cc | 34 talk_base::SystemInfo info; 42 talk_base::SystemInfo info; 44 EXPECT_TRUE(talk_base::string_match(info.GetCpuVendor().c_str(), 46 talk_base::string_match(info.GetCpuVendor().c_str(), 49 EXPECT_TRUE(talk_base::string_match(info.GetCpuVendor().c_str(), "ARM")); 56 talk_base::SystemInfo info; 58 talk_base::SystemInfo::Architecture architecture = info.GetCpuArchitecture(); 61 EXPECT_EQ(talk_base::SystemInfo::SI_ARCH_X64, architecture); 64 EXPECT_EQ(talk_base::SystemInfo::SI_ARCH_ARM, architecture); 66 EXPECT_EQ(talk_base [all...] |
/external/chromium_org/third_party/libjingle/source/talk/session/media/ |
H A D | audiomonitor.h | 47 class AudioMonitor : public talk_base::MessageHandler, 50 AudioMonitor(VoiceChannel* voice_channel, talk_base::Thread *monitor_thread); 57 talk_base::Thread *monitor_thread(); 62 void OnMessage(talk_base::Message *message); 67 talk_base::Thread* monitoring_thread_; 68 talk_base::CriticalSection crit_;
|
H A D | mediamonitor.h | 41 class MediaMonitor : public talk_base::MessageHandler, 44 MediaMonitor(talk_base::Thread* worker_thread, 45 talk_base::Thread* monitor_thread); 52 void OnMessage(talk_base::Message *message); 57 talk_base::CriticalSection crit_; 58 talk_base::Thread* worker_thread_; 59 talk_base::Thread* monitor_thread_; 68 MediaMonitorT(MC* media_channel, talk_base::Thread* worker_thread, 69 talk_base::Thread* monitor_thread)
|
/external/chromium/third_party/libjingle/source/talk/examples/login/ |
H A D | xmppthread.h | 38 public talk_base::Thread, XmppPumpNotify, talk_base::MessageHandler { 54 void OnMessage(talk_base::Message* pmsg);
|
/external/chromium_org/third_party/libjingle/source/talk/app/webrtc/ |
H A D | audiotrack.cc | 45 talk_base::scoped_refptr<AudioTrack> AudioTrack::Create( 47 talk_base::RefCountedObject<AudioTrack>* track = 48 new talk_base::RefCountedObject<AudioTrack>(id, source);
|
/external/chromium_org/third_party/libjingle/source/talk/xmpp/ |
H A D | xmppthread.h | 40 public talk_base::Thread, buzz::XmppPumpNotify, talk_base::MessageHandler { 56 void OnMessage(talk_base::Message* pmsg);
|
H A D | pingtask.h | 45 class PingTask : public buzz::XmppTask, private talk_base::MessageHandler { 48 talk_base::MessageQueue* message_queue, uint32 ping_period_millis, 60 virtual void OnMessage(talk_base::Message* msg); 62 talk_base::MessageQueue* message_queue_;
|
/external/chromium/third_party/libjingle/source/talk/base/ |
H A D | messagehandler.h | 31 namespace talk_base { namespace 44 } // namespace talk_base
|
H A D | stringdigest.h | 34 namespace talk_base { namespace 45 } // namespace talk_base
|
/external/chromium_org/content/browser/renderer_host/p2p/ |
H A D | socket_host_throttler.cc | 19 : timing_(new talk_base::Timing()), 20 rate_limiter_(new talk_base::RateLimiter(kMaxIceMessageBandwidth, 1.0)) { 26 void P2PMessageThrottler::SetTiming(scoped_ptr<talk_base::Timing> timing) { 31 rate_limiter_.reset(new talk_base::RateLimiter(bandwidth_kbps, 1.0));
|
/external/chromium_org/remoting/client/plugin/ |
H A D | pepper_util.h | 17 namespace talk_base { namespace 26 const talk_base::SocketAddress& address, 30 const talk_base::SocketAddress& address, 33 talk_base::SocketAddress* address);
|
/external/chromium_org/third_party/libjingle/source/talk/app/webrtc/objc/ |
H A D | RTCAudioTrack+Internal.h | 35 talk_base::scoped_refptr<webrtc::AudioTrackInterface> audioTrack;
|
H A D | RTCVideoSource+Internal.h | 35 talk_base::scoped_refptr<webrtc::VideoSourceInterface>videoSource;
|
/external/chromium_org/third_party/libjingle/source/talk/p2p/client/ |
H A D | fakeportallocator.h | 14 namespace talk_base { namespace 23 FakePortAllocatorSession(talk_base::Thread* worker_thread, 24 talk_base::PacketSocketFactory* factory, 34 talk_base::IPAddress(INADDR_LOOPBACK), 8), 37 network_.AddIP(talk_base::IPAddress(INADDR_LOOPBACK)); 70 talk_base::Thread* worker_thread_; 71 talk_base::PacketSocketFactory* factory_; 72 talk_base::Network network_; 73 talk_base::scoped_ptr<cricket::Port> port_; 80 FakePortAllocator(talk_base [all...] |
H A D | connectivitychecker_unittest.cc | 19 static const talk_base::SocketAddress kClientAddr1("11.11.11.11", 0); 20 static const talk_base::SocketAddress kClientAddr2("22.22.22.22", 0); 21 static const talk_base::SocketAddress kExternalAddr("33.33.33.33", 3333); 22 static const talk_base::SocketAddress kStunAddr("44.44.44.44", 4444); 23 static const talk_base::SocketAddress kRelayAddr("55.55.55.55", 5555); 24 static const talk_base::SocketAddress kProxyAddr("66.66.66.66", 6666); 25 static const talk_base::ProxyType kProxyType = talk_base::PROXY_HTTPS; 47 FakeRelayPort(talk_base::Thread* thread, 48 talk_base [all...] |
/external/chromium/third_party/libjingle/source/talk/session/phone/ |
H A D | mediamonitor.h | 41 class MediaMonitor : public talk_base::MessageHandler, 44 MediaMonitor(talk_base::Thread* worker_thread, 45 talk_base::Thread* monitor_thread); 52 void OnMessage(talk_base::Message *message); 57 talk_base::CriticalSection crit_; 58 talk_base::Thread* worker_thread_; 59 talk_base::Thread* monitor_thread_; 68 MediaMonitorT(MC* media_channel, talk_base::Thread* worker_thread, 69 talk_base::Thread* monitor_thread)
|
H A D | filemediaengine.cc | 80 : public talk_base::Thread, public talk_base::MessageHandler { 87 void OnPacketReceived(talk_base::Buffer* packet); 90 virtual void OnMessage(talk_base::Message* pmsg); 102 talk_base::scoped_ptr<talk_base::StreamInterface> input_stream_; 103 talk_base::scoped_ptr<talk_base::StreamInterface> output_stream_; 104 talk_base::scoped_ptr<RtpDumpLoopReader> rtp_dump_reader_; 105 talk_base [all...] |
/external/chromium_org/third_party/libjingle/source/talk/examples/peerconnection/client/linux/ |
H A D | main.cc | 37 class CustomSocketServer : public talk_base::PhysicalSocketServer { 39 CustomSocketServer(talk_base::Thread* thread, GtkMainWnd* wnd) 60 return talk_base::PhysicalSocketServer::Wait(0/*cms == -1 ? 1 : cms*/, 65 talk_base::Thread* thread_; 92 talk_base::AutoThread auto_thread; 93 talk_base::Thread* thread = talk_base::Thread::Current(); 99 talk_base::scoped_refptr<Conductor> conductor( 100 new talk_base::RefCountedObject<Conductor>(&client, &wnd));
|
/external/chromium_org/third_party/libjingle/source/talk/p2p/base/ |
H A D | relayport_unittest.cc | 41 using talk_base::SocketAddress; 63 : main_(talk_base::Thread::Current()), 64 physical_socket_server_(new talk_base::PhysicalSocketServer), 65 virtual_socket_server_(new talk_base::VirtualSocketServer( 68 network_("unittest", "unittest", talk_base::IPAddress(INADDR_ANY), 32), 69 socket_factory_(talk_base::Thread::Current()), 70 username_(talk_base::CreateRandomString(16)), 71 password_(talk_base::CreateRandomString(16)), 79 void OnReadPacket(talk_base::AsyncPacketSocket* socket, 81 const talk_base [all...] |
H A D | testturnserver.h | 46 TestTurnServer(talk_base::Thread* thread, 47 const talk_base::SocketAddress& udp_int_addr, 48 const talk_base::SocketAddress& udp_ext_addr) 51 server_.SetExternalSocketFactory(new talk_base::BasicPacketSocketFactory(), 64 void AddInternalSocket(const talk_base::SocketAddress& int_addr, 66 talk_base::Thread* thread = talk_base::Thread::Current(); 68 server_.AddInternalSocket(talk_base::AsyncUDPSocket::Create( 73 talk_base::AsyncSocket* socket =
|
H A D | stunport_unittest.cc | 38 using talk_base::SocketAddress; 54 : pss_(new talk_base::PhysicalSocketServer), 55 ss_(new talk_base::VirtualSocketServer(pss_.get())), 57 network_("unittest", "unittest", talk_base::IPAddress(INADDR_ANY), 32), 58 socket_factory_(talk_base::Thread::Current()), 60 talk_base::Thread::Current(), kStunAddr)), 68 void CreateStunPort(const talk_base::SocketAddress& server_addr) { 70 talk_base::Thread::Current(), &socket_factory_, &network_, 71 kLocalAddr.ipaddr(), 0, 0, talk_base::CreateRandomString(16), 72 talk_base [all...] |
/external/chromium_org/third_party/libjingle/source/talk/examples/peerconnection/client/ |
H A D | peer_connection_client.h | 57 public talk_base::MessageHandler { 87 void OnMessage(talk_base::Message* msg); 94 void OnConnect(talk_base::AsyncSocket* socket); 95 void OnHangingGetConnect(talk_base::AsyncSocket* socket); 106 bool ReadIntoBuffer(talk_base::AsyncSocket* socket, std::string* data, 109 void OnRead(talk_base::AsyncSocket* socket); 111 void OnHangingGetRead(talk_base::AsyncSocket* socket); 122 void OnClose(talk_base::AsyncSocket* socket, int err); 124 void OnResolveResult(talk_base::AsyncResolverInterface* resolver); 127 talk_base [all...] |