Searched refs:thread (Results 1 - 25 of 1148) sorted by last modified time

1234567891011>>

/external/zxing/qr_scanner/src/com/google/zxing/client/android/
H A DInactivityTimer.java89 Thread thread = new Thread(runnable);
90 thread.setDaemon(true);
91 return thread;
/external/webrtc/webrtc/sound/
H A Dpulseaudiosymboltable.h19 #include <pulse/thread-mainloop.h>
/external/webrtc/webrtc/system_wrappers/source/
H A Dcritical_section_unittest.cc81 rtc::PlatformThread thread( variable
84 thread.Start();
89 // Thus, the thread should not be able to increment the count
91 crit_sect->Leave(); // This frees the thread to act.
93 thread.Stop();
108 rtc::PlatformThread thread( variable
111 thread.Start();
114 // The thread is capable of grabbing the lock multiple times,
120 // The thread does not increment while lock is held.
131 thread
[all...]
/external/webrtc/webrtc/video/
H A Dvideo_quality_test.cc77 // Create thread pool for CPU-expensive PSNR/SSIM calculations.
97 rtc::PlatformThread* thread = local
99 thread->Start();
100 comparison_thread_pool_.push_back(thread);
105 for (rtc::PlatformThread* thread : comparison_thread_pool_) {
106 thread->Stop();
107 delete thread;
254 // Signal stats polling thread if that is still waiting and stop it now,
363 // Set event again to make sure main thread is also signaled, then we're
421 // for this thread t
[all...]
/external/webrtc/webrtc/modules/utility/source/
H A Dprocess_thread_impl_unittest.cc57 ProcessThreadImpl thread("ProcessThread");
58 thread.Start();
59 thread.Stop();
63 ProcessThreadImpl thread("ProcessThread");
65 thread.Start();
66 thread.Stop();
70 // Verifies that we get at least call back to Process() on the worker thread.
72 ProcessThreadImpl thread("ProcessThread");
73 thread.Start();
82 EXPECT_CALL(module, ProcessThreadAttached(&thread))
[all...]
/external/webrtc/webrtc/p2p/base/
H A Dbasicpacketsocketfactory.cc23 #include "webrtc/base/thread.h"
32 BasicPacketSocketFactory::BasicPacketSocketFactory(Thread* thread) argument
33 : thread_(thread),
H A Dbasicpacketsocketfactory.h25 explicit BasicPacketSocketFactory(Thread* thread);
H A Dp2ptransportchannel.cc410 thread()->Post(this, MSG_CHECK_AND_PING);
1208 thread()->PostDelayed(check_delay, this, MSG_CHECK_AND_PING);
H A Dp2ptransportchannel.h187 rtc::Thread* thread() { return worker_thread_; } function in class:cricket::P2PTransportChannel
H A Dport.cc132 Port::Port(rtc::Thread* thread, argument
138 : thread_(thread),
158 Port::Port(rtc::Thread* thread, argument
167 : thread_(thread),
777 requests_(port->thread()),
1004 port_->thread()->Post(this, MSG_DELETE);
H A Dport.h31 #include "webrtc/base/thread.h"
118 Port(rtc::Thread* thread,
124 Port(rtc::Thread* thread,
148 // The thread on which this port performs its I/O.
149 rtc::Thread* thread() { return thread_; } function in class:cricket::Port
H A Dport_unittest.cc32 #include "webrtc/base/thread.h"
100 TestPort(rtc::Thread* thread, argument
109 : Port(thread,
H A Drelayport.cc32 rtc::Thread* thread);
181 RelayPort::RelayPort(rtc::Thread* thread, argument
189 : Port(thread,
208 thread()->Clear(this);
405 rtc::Thread* thread)
408 request_manager_ = new StunRequestManager(thread);
478 port()->thread()->Dispose(current_connection_);
509 port()->thread()->Post(this, kMessageConnectTimeout);
517 current_connection_ = new RelayConnection(ra, socket, port()->thread());
528 port()->thread()
403 RelayConnection(const ProtocolAddress* protocol_address, rtc::AsyncPacketSocket* socket, rtc::Thread* thread) argument
[all...]
H A Drelayport.h38 static RelayPort* Create(rtc::Thread* thread, argument
46 return new RelayPort(thread, factory, network, ip, min_port, max_port,
76 RelayPort(rtc::Thread* thread,
H A Drelayserver.cc81 RelayServer::RelayServer(rtc::Thread* thread) argument
82 : thread_(thread), log_bindings_(true) {
670 server_->thread()->PostDelayed(lifetime_, this, MSG_LIFETIME_TIMER);
675 server_->thread()->Clear(this);
741 server_->thread()->PostDelayed(lifetime_, this, MSG_LIFETIME_TIMER);
H A Drelayserver.h22 #include "webrtc/base/thread.h"
35 // Creates a server, which will use this thread to post messages to itself.
36 explicit RelayServer(rtc::Thread* thread);
39 rtc::Thread* thread() { return thread_; } function in class:cricket::RelayServer
118 // Handle messages in our worker thread.
H A Dstunport.cc119 // unloaded before the thread exits. Please see webrtc bug 5139.
163 UDPPort::UDPPort(rtc::Thread* thread, argument
171 : Port(thread,
177 requests_(thread),
186 UDPPort::UDPPort(rtc::Thread* thread, argument
196 : Port(thread,
205 requests_(thread),
H A Dstunport.h31 static UDPPort* Create(rtc::Thread* thread, argument
39 UDPPort* port = new UDPPort(thread, factory, network, socket, username,
48 static UDPPort* Create(rtc::Thread* thread, argument
59 new UDPPort(thread, factory, network, ip, min_port, max_port, username,
110 UDPPort(rtc::Thread* thread,
121 UDPPort(rtc::Thread* thread,
230 static StunPort* Create(rtc::Thread* thread, argument
240 StunPort* port = new StunPort(thread, factory, network,
258 StunPort(rtc::Thread* thread, argument
268 : UDPPort(thread,
[all...]
H A Dstunrequest.cc27 StunRequestManager::StunRequestManager(rtc::Thread* thread) argument
28 : thread_(thread) {
H A Dstunrequest.h18 #include "webrtc/base/thread.h"
30 StunRequestManager(rtc::Thread* thread);
H A Dtcpport.cc75 TCPPort::TCPPort(rtc::Thread* thread, argument
84 : Port(thread,
430 port()->thread()->PostDelayed(reconnection_timeout(), this,
H A Dtcpport.h31 static TCPPort* Create(rtc::Thread* thread, argument
40 TCPPort* port = new TCPPort(thread, factory, network, ip, min_port,
63 TCPPort(rtc::Thread* thread,
H A Dtestrelayserver.h19 #include "webrtc/base/thread.h"
26 TestRelayServer(rtc::Thread* thread, argument
33 : server_(thread) {
35 thread->socketserver(), udp_int_addr));
37 thread->socketserver(), udp_ext_addr));
39 tcp_int_socket_.reset(CreateListenSocket(thread, tcp_int_addr));
40 tcp_ext_socket_.reset(CreateListenSocket(thread, tcp_ext_addr));
41 ssl_int_socket_.reset(CreateListenSocket(thread, ssl_int_addr));
42 ssl_ext_socket_.reset(CreateListenSocket(thread, ssl_ext_addr));
55 rtc::AsyncSocket* CreateListenSocket(rtc::Thread* thread, argument
[all...]
H A Dteststunserver.h16 #include "webrtc/base/thread.h"
23 static TestStunServer* Create(rtc::Thread* thread, argument
26 thread->socketserver()->CreateAsyncSocket(addr.family(), SOCK_DGRAM);
H A Dtestturnserver.h21 #include "webrtc/base/thread.h"
51 TestTurnServer(rtc::Thread* thread, argument
54 : server_(thread) {
75 rtc::Thread* thread = rtc::Thread::Current(); local
78 thread->socketserver(), int_addr), proto);
83 thread->socketserver()->CreateAsyncSocket(SOCK_STREAM);

Completed in 275 milliseconds

1234567891011>>