| /external/valgrind/none/tests/ |
| pth_atfork1.c | 71 static void *thread (void *arg);
82 if (pthread_create (&th, NULL, thread, NULL) != 0)
83 error (EXIT_FAILURE, 0, "cannot create thread");
96 thread (void *arg) function
|
| /external/valgrind/none/tests/solaris/ |
| coredump_many_threads.c | 2 * Creates 8 threads. The fifth one (counting the main thread as well)
70 pthread_t thread; local
72 int ret = pthread_create(&thread, NULL, thread_func, NULL);
|
| /external/webrtc/webrtc/examples/peerconnection/client/linux/ |
| main.cc | 19 #include "webrtc/base/thread.h"
23 CustomSocketServer(rtc::Thread* thread, GtkMainWnd* wnd)
24 : thread_(thread), wnd_(wnd), conductor_(NULL), client_(NULL) {}
34 // different thread. Alternatively we could look at merging the two loops
49 rtc::Thread* thread_;
81 rtc::Thread* thread = rtc::Thread::Current(); local
82 CustomSocketServer socket_server(thread, &wnd)
[all...] |
| /external/webrtc/webrtc/p2p/stunprober/ |
| main.cc | 26 #include "webrtc/base/thread.h"
88 void StopTrial(rtc::Thread* thread, StunProber* prober, int result) {
89 thread->Quit();
121 rtc::Thread* thread = rtc::ThreadManager::Instance()->WrapCurrentThread(); local
129 new StunProber(socket_factory.get(), rtc::Thread::Current(), networks);
130 auto finish_callback = [thread](StunProber* prober, int result) {
131 StopTrial(thread, prober, result);
136 thread->Run()
[all...] |
| /external/webrtc/webrtc/system_wrappers/source/ |
| critical_section_unittest.cc | 81 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.Stop()
[all...] |
| /frameworks/av/media/libaaudio/tests/ |
| test_bad_disconnect.cpp | 24 #include <thread>
39 std::thread *thread = nullptr; member in struct:AudioEngine
123 s_AudioEngine.thread = nullptr;
131 // Handle stream restart on a separate thread
132 if (s_AudioEngine.thread == nullptr) {
133 s_AudioEngine.thread = new std::thread(s_StartThreadProc);
|
| /frameworks/base/cmds/statsd/src/ |
| main.cpp | 44 * Thread function data.
51 * Thread func for where the log reader runs.
67 * Creates and starts the thread to own the LogReader.
72 pthread_t thread; local
74 // Thread data.
78 // Create the thread
83 // TODO: Do we need to tweak thread priority?
89 err = pthread_create(&thread, &attr, log_reader_thread_func, static_cast<void*>(data));
124 // Start the log reader thread
139 // Loop forever -- the reports run on this thread in a handler, and th
[all...] |
| /hardware/qcom/gps/msm8909/utils/ |
| MsgTask.cpp | 66 LocThread* thread = mThread; local
68 if (thread) {
70 delete thread;
|
| /hardware/qcom/gps/msm8909w_3100/utils/ |
| MsgTask.cpp | 65 LocThread* thread = mThread; local
67 if (thread) {
69 delete thread;
|
| /hardware/qcom/gps/msm8960/loc_api/libloc_api_50001/ |
| loc_eng_ni.h | 39 pthread_t thread; /* NI thread */ member in struct:__anon50605
|
| /hardware/qcom/gps/msm8996/utils/ |
| MsgTask.cpp | 66 LocThread* thread = mThread; local
68 if (thread) {
70 delete thread;
|
| /hardware/qcom/gps/msm8998/utils/ |
| MsgTask.cpp | 65 LocThread* thread = mThread; local
67 if (thread) {
69 delete thread;
|
| /libcore/ojluni/src/main/java/java/io/ |
| SerialCallbackContext.java | 33 * This context keeps track of the thread it was constructed on, and allows
35 * or writeFields which must be invoked on the same thread before the class's
37 * If not set to the current thread, the getObj method throws NotActiveException.
43 * Thread this context is in use by.
44 * As this only works in one thread, we do not need to worry about thread-safety.
46 private Thread thread; field in class:SerialCallbackContext
51 this.thread = Thread.currentThread()
[all...] |
| /packages/apps/TV/common/src/com/android/tv/common/concurrent/ |
| NamedThreadFactory.java | 24 /** A thread factory that creates threads with named <code>prefix-##</code>. */
36 public Thread newThread(@NonNull final Runnable runnable) {
37 final Thread thread = mDefaultThreadFactory.newThread(runnable); local
38 thread.setName(mPrefix + mCount.getAndIncrement());
39 return thread;
42 public boolean namedWithPrefix(Thread thread) {
43 return thread.getName().startsWith(mPrefix);
|
| /prebuilts/gdb/darwin-x86/lib/python2.7/test/ |
| test_capi.py | 11 import thread
14 thread = None variable
23 #this function can be interrupted by thread switching so let's
42 #main thread
56 #do every callback on a separate thread
62 context.n = 2 #submits per thread
69 t = threading.Thread(target=self.pendingcalls_thread, args = (context,))
91 #again, just using the main thread, likely they will all be dispatched at
101 @unittest.skipUnless(threading and thread, 'Threading required for this test.')
106 # some extra thread-state tests driven via _testcap
[all...] |
| /prebuilts/gdb/linux-x86/lib/python2.7/test/ |
| test_capi.py | 11 import thread
14 thread = None variable
23 #this function can be interrupted by thread switching so let's
42 #main thread
56 #do every callback on a separate thread
62 context.n = 2 #submits per thread
69 t = threading.Thread(target=self.pendingcalls_thread, args = (context,))
91 #again, just using the main thread, likely they will all be dispatched at
101 @unittest.skipUnless(threading and thread, 'Threading required for this test.')
106 # some extra thread-state tests driven via _testcap
[all...] |
| /prebuilts/misc/windows/sdl2/test/ |
| testmessage.c | 60 data.message = "This is a custom messagebox from a background thread.";
134 /* Test showing a message box from a background thread.
138 subsystem on the main thread.
148 SDL_Thread* thread = SDL_CreateThread(&button_messagebox, "MessageBox", (void*)eventNumber); local
157 SDL_WaitThread(thread, &status);
159 SDL_Log("Message box thread return %i\n", status);
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/test/ |
| test_capi.py | 11 import thread
14 thread = None variable
23 #this function can be interrupted by thread switching so let's
42 #main thread
56 #do every callback on a separate thread
62 context.n = 2 #submits per thread
69 t = threading.Thread(target=self.pendingcalls_thread, args = (context,))
91 #again, just using the main thread, likely they will all be dispatched at
101 @unittest.skipUnless(threading and thread, 'Threading required for this test.')
106 # some extra thread-state tests driven via _testcap
[all...] |
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/test/ |
| test_capi.py | 11 import thread
14 thread = None variable
23 #this function can be interrupted by thread switching so let's
42 #main thread
56 #do every callback on a separate thread
62 context.n = 2 #submits per thread
69 t = threading.Thread(target=self.pendingcalls_thread, args = (context,))
91 #again, just using the main thread, likely they will all be dispatched at
101 @unittest.skipUnless(threading and thread, 'Threading required for this test.')
106 # some extra thread-state tests driven via _testcap
[all...] |
| /system/bt/btif/src/ |
| btif_sock.cc | 38 #include "osi/include/thread.h"
54 static thread_t* thread; variable
68 CHECK(thread == NULL);
92 thread = thread_new("btif_sock");
93 if (!thread) {
94 LOG_ERROR(LOG_TAG, "%s error creating new thread.", __func__);
99 status = btsock_sco_init(thread);
110 thread_free(thread);
111 thread = NULL;
126 thread_free(thread);
[all...] |
| /system/bt/osi/test/ |
| reactor_test.cc | 13 static pthread_t thread; variable
27 int ret = pthread_create(&thread, NULL, reactor_thread, reactor);
31 static void join_reactor_thread() { pthread_join(thread, NULL); }
|
| /system/bt/test/suite/core/ |
| thread_performance_test.cc | 4 #include <base/threading/thread.h>
12 #include "osi/include/thread.h"
18 thread_t* thread; variable
56 thread = thread_new("performance test thread");
57 thread_post(thread, run_message_loop, nullptr);
64 thread_free(thread); variable
65 thread = nullptr;
102 thread = thread_new("queue performance test thread");
[all...] |
| /system/core/libunwindstack/tests/ |
| MapInfoGetElfTest.cpp | 28 #include <thread>
375 std::vector<std::thread*> threads;
383 std::thread* thread = new std::thread([i, this, &wait, &info, &elf_in_threads]() { local
389 threads.push_back(thread);
395 for (auto thread : threads) {
396 thread->join();
397 delete thread;
405 EXPECT_EQ(elf, elf_in_threads[i]) << "Thread " << i << " mismatched."
[all...] |
| /system/netd/server/ |
| thread_util.h | 53 pthread_t thread; local
54 rval = pthread_create(&thread, &scoped_attr.attr, &runAndDelete<T>, obj);
|
| /cts/hostsidetests/dumpsys/apps/storagedapp/src/com/android/server/cts/storaged/ |
| SimpleIOService.java | 68 Thread.sleep(100);
97 // Start up the thread running the service. Note that we create a
98 // separate thread because the service normally runs in the process's
99 // main thread, which we don't want to block. We also make it
101 HandlerThread thread = new HandlerThread("ServiceStartArguments", local
103 thread.start();
106 mServiceLooper = thread.getLooper();
|
