| /bionic/libc/bionic/ |
| pthread_accessor.h | 29 for (thread_ = g_thread_list; thread_ != NULL; thread_ = thread_->next) {
30 if (thread_ == reinterpret_cast<pthread_internal_t*>(desired_thread)) {
43 thread_ = NULL;
48 pthread_internal_t& operator*() const { return *thread_; }
49 pthread_internal_t* operator->() const { return thread_; }
50 pthread_internal_t* get() const { return thread_; }
53 pthread_internal_t* thread_; member in class:pthread_accessor
[all...] |
| /external/chromium_org/device/bluetooth/ |
| bluetooth_socket_thread.cc | 34 if (thread_) {
35 thread_->Stop();
36 thread_.reset(NULL);
50 if (active_socket_count_ == 0 && thread_) {
51 thread_->Stop();
52 thread_.reset(NULL);
59 if (thread_)
64 thread_.reset(new base::Thread("BluetoothSocketThread"));
65 thread_->StartWithOptions(thread_options);
66 task_runner_ = thread_->message_loop_proxy()
[all...] |
| /external/chromium_org/third_party/webrtc/system_wrappers/source/ |
| thread_win.cc | 33 thread_(NULL),
50 if (thread_) {
51 CloseHandle(thread_);
77 thread_ = (HANDLE)_beginthreadex(NULL, 1024 * 1024, StartThread, (void*)this,
79 if (thread_ == NULL) {
87 SetThreadPriority(thread_, THREAD_PRIORITY_BELOW_NORMAL);
90 SetThreadPriority(thread_, THREAD_PRIORITY_NORMAL);
93 SetThreadPriority(thread_, THREAD_PRIORITY_ABOVE_NORMAL);
96 SetThreadPriority(thread_, THREAD_PRIORITY_HIGHEST);
99 SetThreadPriority(thread_, THREAD_PRIORITY_TIME_CRITICAL)
[all...] |
| condition_variable_unittest.cc | 147 thread_ = ThreadWrapper::CreateThread(&WaitingRunFunction,
150 ASSERT_TRUE(thread_->Start(id));
160 thread_->SetNotAlive();
162 ASSERT_TRUE(thread_->Stop());
163 delete thread_;
170 ThreadWrapper* thread_; member in class:webrtc::__anon20773::CondVarTest
|
| /external/chromium_org/ppapi/utility/threading/ |
| simple_thread.cc | 53 thread_(0) {
61 thread_(0) {
73 if (!thread_)
79 DWORD result = WaitForSingleObject(thread_, INFINITE);
80 CloseHandle(thread_);
81 thread_ = 0;
86 int result = pthread_join(thread_, &retval);
87 thread_ = 0;
93 if (thread_)
102 thread_ = CreateThread(NULL, stacksize_, &RunThread, data, 0, NULL)
[all...] |
| simple_thread.h | 51 ThreadHandle thread() const { return thread_; }
57 ThreadHandle thread_; member in class:pp::SimpleThread
|
| /external/chromium_org/ppapi/examples/threading/ |
| threading.cc | 15 thread_ = new pp::SimpleThread(this);
20 delete thread_;
24 thread_->Start();
25 thread_->message_loop().PostWork(
39 pp::SimpleThread* thread_; member in class:MyInstance
|
| /external/chromium_org/third_party/webrtc/voice_engine/test/auto_test/fakes/ |
| fake_external_transport.cc | 21 thread_(NULL),
31 thread_ = webrtc::ThreadWrapper::CreateThread(
33 if (thread_) {
35 thread_->Start(id);
40 if (thread_) {
41 thread_->SetNotAlive();
43 if (thread_->Stop()) {
44 delete thread_;
45 thread_ = NULL;
|
| /external/chromium_org/third_party/webrtc/base/ |
| criticalsection.h | 43 TRACK_OWNER(thread_ = 0);
50 TRACK_OWNER(thread_ = GetCurrentThreadId());
54 TRACK_OWNER(thread_ = GetCurrentThreadId());
60 TRACK_OWNER(thread_ = 0);
65 bool CurrentThreadIsOwner() const { return thread_ == GetCurrentThreadId(); }
70 TRACK_OWNER(DWORD thread_); // The section's owning thread id
83 TRACK_OWNER(thread_ = 0);
90 TRACK_OWNER(thread_ = pthread_self());
94 TRACK_OWNER(thread_ = pthread_self());
100 TRACK_OWNER(thread_ = 0)
[all...] |
| signalthread_unittest.cc | 76 thread_ = new SlowSignalThread(this);
77 thread_->SignalWorkDone.connect(this, &SignalThreadTest::OnWorkComplete);
90 SlowSignalThread* thread_; member in class:SignalThreadTest
161 thread_->Start();
170 thread_->Start();
172 thread_->Release();
182 thread_->Start();
184 thread_->Destroy(true);
191 thread_->Start();
193 thread_->Destroy(false)
[all...] |
| thread.cc | 129 : thread_(Thread::Current()),
130 previous_state_(thread_->SetAllowBlockingCalls(false)) {
134 ASSERT(thread_->IsCurrent());
135 thread_->SetAllowBlockingCalls(previous_state_);
143 thread_(NULL),
191 ASSERT(thread_ != NULL);
194 ret = ::SetThreadPriority(thread_, THREAD_PRIORITY_NORMAL);
196 ret = ::SetThreadPriority(thread_, THREAD_PRIORITY_HIGHEST);
198 ret = ::SetThreadPriority(thread_, THREAD_PRIORITY_ABOVE_NORMAL);
200 ret = ::SetThreadPriority(thread_, THREAD_PRIORITY_IDLE)
[all...] |
| /external/chromium_org/chrome/browser/sync/glue/ |
| browser_thread_model_worker.cc | 20 thread_(thread), group_(group) {
26 if (BrowserThread::CurrentlyOn(thread_)) {
27 DLOG(WARNING) << "Already on thread " << thread_;
32 thread_,
37 DLOG(WARNING) << "Failed to post task to thread " << thread_;
52 if (BrowserThread::CurrentlyOn(thread_)) {
56 thread_, FROM_HERE,
65 DCHECK(BrowserThread::CurrentlyOn(thread_));
|
| /external/chromium_org/media/audio/ |
| audio_device_thread.cc | 53 base::PlatformThreadHandle thread_; member in class:media::AudioDeviceThread::Thread
68 AudioDeviceThread::~AudioDeviceThread() { DCHECK(!thread_.get()); }
75 CHECK(!thread_.get());
76 thread_ = new AudioDeviceThread::Thread(
78 thread_->Start();
83 if (thread_.get()) {
84 thread_->Stop(loop_for_join);
85 thread_ = NULL;
91 return !thread_.get();
99 : thread_(),
[all...] |
| clockless_audio_sink.cc | 25 thread_.reset(new base::DelegateSimpleThread(this, "ClocklessAudioSink"));
26 thread_->Start();
32 thread_->Join();
58 scoped_ptr<base::DelegateSimpleThread> thread_; member in class:media::ClocklessAudioSinkThread
71 thread_.reset(new ClocklessAudioSinkThread(params, callback));
92 thread_->Start();
102 playback_time_ = thread_->Stop();
|
| /external/chromium_org/mojo/shell/ |
| in_process_dynamic_service_runner.cc | 48 if (thread_) {
49 DCHECK(thread_->HasBeenStarted());
50 DCHECK(!thread_->HasBeenJoined());
51 thread_->Join();
75 DCHECK(!thread_);
76 thread_.reset(new base::DelegateSimpleThread(this, "app_thread"));
77 thread_->Start();
|
| /external/chromium_org/chrome/common/ |
| profiling.cc | 91 ProfilingThreadControl() : thread_(NULL) {}
96 if (thread_ && thread_->IsRunning())
98 thread_ = new base::Thread("Profiling_Flush");
99 thread_->Start();
100 thread_->message_loop()->PostTask(
101 FROM_HERE, base::Bind(&FlushProfilingData, thread_));
107 if (!thread_ || !thread_->IsRunning())
109 thread_->Stop()
115 base::Thread* thread_; member in class:__anon10320::ProfilingThreadControl
[all...] |
| /external/chromium_org/jingle/glue/ |
| thread_wrapper_unittest.cc | 75 thread_->Send(&handler, kTestMessage2, data);
80 : thread_(NULL) {
85 thread_ = rtc::Thread::Current();
90 rtc::Thread* thread_; member in class:jingle_glue::ThreadWrapperTest
101 thread_->Post(&handler1_, kTestMessage1, data1);
102 thread_->Post(&handler1_, kTestMessage2, data2);
103 thread_->Post(&handler2_, kTestMessage1, data3);
104 thread_->Post(&handler2_, kTestMessage1, data4);
130 thread_->PostDelayed(kTestDelayMs1, &handler1_, kTestMessage1, data1);
131 thread_->PostDelayed(kTestDelayMs2, &handler1_, kTestMessage2, data2)
[all...] |
| /external/chromium_org/content/child/ |
| webthread_impl.cc | 59 : thread_(new base::Thread(name)) {
60 thread_->Start();
64 thread_->message_loop()->PostTask(
69 thread_->message_loop()->PostDelayedTask(
77 CHECK(!thread_->message_loop()->is_running()); // We don't support nesting.
78 thread_->message_loop()->Run();
83 CHECK(thread_->message_loop()->is_running());
84 thread_->message_loop()->Quit();
88 return thread_->thread_id() == base::PlatformThread::CurrentId();
92 return thread_->thread_id()
[all...] |
| /external/chromium_org/mojo/services/html_viewer/ |
| webthread_impl.cc | 59 : thread_(new base::Thread(name)) {
60 thread_->Start();
64 thread_->message_loop()->PostTask(
69 thread_->message_loop()->PostDelayedTask(
77 CHECK(!thread_->message_loop()->is_running()); // We don't support nesting.
78 thread_->message_loop()->Run();
83 CHECK(thread_->message_loop()->is_running());
84 thread_->message_loop()->Quit();
88 return thread_->thread_id() == base::PlatformThread::CurrentId();
92 return thread_->thread_id()
[all...] |
| /external/chromium_org/mojo/public/cpp/utility/lib/ |
| thread.cc | 13 thread_(),
20 thread_(),
45 rv = pthread_create(&thread_, &attr, &ThreadRunTrampoline, this);
58 int rv MOJO_ALLOW_UNUSED = pthread_join(thread_, NULL);
|
| /external/chromium_org/base/android/ |
| application_status_listener_unittest.cc | 45 thread_("ApplicationStatusTest thread"),
51 thread_.Start();
52 thread_.message_loop()
75 EXPECT_EQ(thread_.message_loop(), base::MessageLoop::current());
94 base::Thread thread_; member in class:base::android::__anon6801::MultiThreadedTest
|
| /external/chromium_org/chrome/browser/history/android/ |
| android_history_provider_service.cc | 32 DCHECK(hs->thread_) << "History service being called after cleanup";
35 hs->thread_->message_loop_proxy().get(),
60 DCHECK(hs->thread_) << "History service being called after cleanup";
63 hs->thread_->message_loop_proxy().get(),
86 DCHECK(hs->thread_) << "History service being called after cleanup";
89 hs->thread_->message_loop_proxy().get(),
110 DCHECK(hs->thread_) << "History service being called after cleanup";
113 hs->thread_->message_loop_proxy().get(),
134 DCHECK(hs->thread_) << "History service being called after cleanup";
137 hs->thread_->message_loop_proxy().get()
[all...] |
| /external/chromium_org/third_party/webrtc/test/ |
| direct_transport.cc | 23 thread_(ThreadWrapper::CreateThread(NetworkProcess, this)),
28 EXPECT_TRUE(thread_->Start(thread_id));
35 thread_(ThreadWrapper::CreateThread(NetworkProcess, this)),
40 EXPECT_TRUE(thread_->Start(thread_id));
56 EXPECT_TRUE(thread_->Stop());
|
| fake_audio_device.cc | 47 if (thread_.get() != NULL)
48 thread_->Stop();
58 thread_.reset(ThreadWrapper::CreateThread(
60 if (thread_.get() == NULL)
63 if (!thread_->Start(thread_id)) {
64 thread_.reset();
|
| /external/chromium_org/chrome/browser/history/ |
| history_service.cc | 209 : thread_(new base::Thread(kHistoryThreadName)),
218 : thread_(new base::Thread(kHistoryThreadName)),
244 DCHECK(thread_) << "History service being called after cleanup";
296 DCHECK(thread_) << "History service being called after cleanup";
304 DCHECK(thread_) << "History service being called after cleanup";
316 DCHECK(thread_) << "History service being called after cleanup";
324 DCHECK(thread_) << "History service being called after cleanup";
331 DCHECK(thread_) << "History service being called after cleanup";
339 DCHECK(thread_) << "History service being called after cleanup";
346 thread_->message_loop_proxy()->PostTask
[all...] |
