| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_attr_setschedpolicy/ |
| common.h | 63 printf("Failed: policy: %s thread policy: %u != %u\n",
69 printf("Failed: policy: %s thread priority %u != %u\n",
120 pthread_t thread; local
129 rc = pthread_create(&thread, &attr, thread_func, p);
138 pthread_join(thread, &status);
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_cond_broadcast/ |
| 2-2.c | 9 * When each thread unblocked as a result of pthread_cond_signal()
10 * returns from its call to pthread_cond_timedwait(), the thread shall
43 fprintf(stderr, "[Thread 0x%p] failed to acquire the mutex\n",
47 fprintf(stderr, "[Thread 0x%p] started and locked the mutex\n",
58 fprintf(stderr, "[Thread 0x%p] is waiting for the cond for at "
62 fprintf(stderr, "[Thread 0x%p] pthread_cond_wait returned %d\n",
68 fprintf(stderr, "[Thread 0x%p] should not be able to lock the "
73 fprintf(stderr, "[Thread 0x%p] was wakened and acquired the "
78 fprintf(stderr, "[Thread 0x%p] failed to release the mutex\n",
83 fprintf(stderr, "[Thread 0x%p] released the mutex\n", (void *)self)
90 pthread_t thread[THREAD_NUM]; local
[all...] |
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_cond_signal/ |
| 2-1.c | 9 * When each thread unblocked as a result of pthread_cond_signal()
10 * returns from its call to pthread_cond_wait(), the thread shall
30 pthread_t thread[THREAD_NUM]; variable
41 pthread_cancel(thread[i]);
53 fprintf(stderr, "[Thread 0x%p] failed to acquire the mutex\n",
57 fprintf(stderr, "[Thread 0x%p] started and locked the mutex\n",
61 fprintf(stderr, "[Thread 0x%p] is waiting for the cond\n",
71 "[Thread 0x%p] should be able to lock the recursive mutex again\n",
77 "[Thread 0x%p] was wakened and acquired the mutex again\n",
82 fprintf(stderr, "[Thread 0x%p] failed to release the mutex\n"
[all...] |
| 2-2.c | 9 * When each thread unblocked as a result of pthread_cond_signal()
10 * returns from its call to pthread_cond_timedwait(), the thread shall
43 fprintf(stderr, "[Thread 0x%p] failed to acquire the mutex\n",
47 fprintf(stderr, "[Thread 0x%p] started and locked the mutex\n",
59 "[Thread 0x%p] is waiting for the cond for at most %d secs\n",
63 fprintf(stderr, "[Thread 0x%p] pthread_cond_wait returned %d\n",
70 "[Thread 0x%p] should be able to lock the recursive mutex again\n",
76 "[Thread 0x%p] was wakened and acquired the mutex again\n",
81 fprintf(stderr, "[Thread 0x%p] failed to release the mutex\n",
88 "[Thread 0x%p] did not owned the mutex after the cond wait\n"
100 pthread_t thread[THREAD_NUM]; local
[all...] |
| /external/ltp/testcases/realtime/func/async_handler/ |
| async_handler_jk.c | 24 * An async event server thread is created that goes to sleep waiting
27 * A user thread is created that simulates the firing of an event by
28 * signalling the async handler thread to do some work.
82 struct thread *thread = ((struct thread *)arg); local
84 thread->func = NULL; // entrypoint
85 thread->flags |= THREAD_FLAG_SUSPENDED;
88 if ((err = pthread_mutex_lock(&thread->mutex)))
92 while (thread->flags & THREAD_FLAG_SUSPENDED
112 struct thread *thread = ((struct thread *)arg); local
[all...] |
| /external/lzma/CPP/Windows/ |
| Thread.h | 1 // Windows/Thread.h
14 ::CThread thread;
member in class:NWindows::CThread
16 CThread() { Thread_Construct(&thread); }
18 bool IsCreated() { return Thread_WasCreated(&thread) != 0; }
19 WRes Close() { return Thread_Close(&thread); }
21 { return Thread_Create(&thread, startAddress, parameter); }
22 WRes Wait() { return Thread_Wait(&thread); }
25 operator HANDLE() { return thread; }
26 void Attach(HANDLE handle) { thread = handle; }
27 HANDLE Detach() { HANDLE h = thread; thread = NULL; return h; }
[all...] |
| /external/python/cpython2/Lib/test/ |
| test_capi.py | 11 import thread
14 thread = None variable
30 #this function can be interrupted by thread switching so let's
49 #main thread
63 #do every callback on a separate thread
69 context.n = 2 #submits per thread
75 threads = [threading.Thread(target=self.pendingcalls_thread,
94 #again, just using the main thread, likely they will all be dispatched at
104 @unittest.skipUnless(threading and thread, 'Threading required for this test.')
109 # some extra thread-state tests driven via _testcap
[all...] |
| /external/testng/src/main/java/org/testng/internal/thread/ |
| ExecutorAdapter.java | 1 package org.testng.internal.thread;
46 Thread.currentThread().interrupt();
54 List<Thread> threads = m_threadFactory.getThreads();
|
| /external/testng/src/test/java/test/thread/ |
| BaseThreadTest.java | 1 package test.thread;
37 logThread(Thread.currentThread().getId());
42 log("BaseThreadTest", "Logging thread:" + threadId);
65 System.out.println("[" + cls + "] thread:" + Thread.currentThread().getId()
|
| FactoryTest.java | 1 package test.thread;
13 * In non-parallel mode, we should only have one thread id
21 * In parallel mode "methods", we should have as many thread id's
|
| TrueParallelTest.java | 1 package test.thread;
|
| /external/webrtc/webrtc/p2p/base/ |
| testturnserver.h | 21 #include "webrtc/base/thread.h"
51 TestTurnServer(rtc::Thread* thread,
54 : server_(thread) {
75 rtc::Thread* thread = rtc::Thread::Current(); local
78 thread->socketserver(), int_addr), proto);
83 thread->socketserver()->CreateAsyncSocket(SOCK_STREAM);
|
| /frameworks/base/libs/hwui/tests/unit/ |
| ThreadBaseTests.cpp | 19 #include "thread/ThreadBase.h"
28 static ThreadBase& thread() { function
30 static sp<TestThread> thread = []() -> auto { local
36 return *thread;
40 return thread().queue();
|
| /frameworks/base/libs/hwui/thread/ |
| TaskManager.cpp | 37 // we do want to limit ourselves to 1 worker thread on dual-core devices.
67 sp<WorkerThread> thread; local
71 thread = mThreads[i];
76 return thread->addTask(wrapper);
82 // Thread
|
| /frameworks/native/cmds/lshal/ |
| Timeout.h | 21 #include <thread>
67 pthread_t thread; local
68 if (pthread_create(&thread, NULL, callAndNotify, &state)) {
69 std::cerr << "FATAL: could not create background thread." << std::endl;
74 pthread_kill(thread, SIGINT);
76 pthread_join(thread, NULL);
|
| /frameworks/native/services/sensorservice/ |
| SensorRegistrationInfo.h | 21 #include <utils/Thread.h>
46 IPCThreadState *thread = IPCThreadState::self(); local
47 mPid = (thread != nullptr) ? thread->getCallingPid() : -1;
48 mUid = (thread != nullptr) ? thread->getCallingUid() : -1;
|
| /hardware/qcom/gps/loc_api/libloc_api_50001/ |
| loc_eng_ni.h | 41 pthread_t thread; /* NI thread */ member in struct:__anon50261
|
| /hardware/qcom/gps/msm8084/loc_api/libloc_api_50001/ |
| loc_eng_ni.h | 41 pthread_t thread; /* NI thread */ member in struct:__anon50347
|
| /hardware/qcom/gps/msm8909/loc_api/libloc_api_50001/ |
| loc_eng_ni.h | 41 pthread_t thread; /* NI thread */ member in struct:__anon50404
|
| /hardware/qcom/gps/msm8994/loc_api/libloc_api_50001/ |
| loc_eng_ni.h | 41 pthread_t thread; /* NI thread */ member in struct:__anon50697
|
| /hardware/qcom/gps/msm8996/loc_api/libloc_api_50001/ |
| loc_eng_ni.h | 41 pthread_t thread; /* NI thread */ member in struct:__anon50754
|
| /prebuilts/go/darwin-x86/src/regexp/ |
| exec.go | 20 // It holds both the instruction pc and the actual thread.
25 t *thread
28 // A thread is the state of a single path through the machine:
31 type thread struct { type
44 pool []*thread // pool of available threads
95 // alloc allocates a new thread with the given instruction.
97 func (m *machine) alloc(i *syntax.Inst) *thread {
98 var t *thread
103 t = new(thread)
183 // clear frees all threads on the thread queue
[all...] |
| /prebuilts/go/linux-x86/src/regexp/ |
| exec.go | 20 // It holds both the instruction pc and the actual thread.
25 t *thread
28 // A thread is the state of a single path through the machine:
31 type thread struct { type
44 pool []*thread // pool of available threads
95 // alloc allocates a new thread with the given instruction.
97 func (m *machine) alloc(i *syntax.Inst) *thread {
98 var t *thread
103 t = new(thread)
183 // clear frees all threads on the thread queue
[all...] |
| /system/core/debuggerd/ |
| debuggerd_benchmark.cpp | 25 #include <thread>
102 auto thread = std::thread([&]() { max_pause = GetMaximumPause(thread_state); }); local
111 thread.join();
|
| /system/core/libunwindstack/tests/ |
| MapInfoGetLoadBiasTest.cpp | 28 #include <thread>
96 std::vector<std::thread*> threads;
103 std::thread* thread = new std::thread([i, this, &wait, &load_bias_values]() { local
108 threads.push_back(thread);
113 for (auto thread : threads) {
114 thread->join();
115 delete thread;
120 EXPECT_EQ(expected_load_bias, load_bias_values[i]) << "Thread " << i << " mismatched."
[all...] |
