| /external/compiler-rt/test/tsan/ |
| getline_nohang.cc | 13 void *thread(void *unused) { function
32 pthread_create(&t, &a, thread, NULL);
|
| /external/deqp/framework/delibs/destream/ |
| deStreamCpyThread.c | 21 * \brief Stream copying thread
30 deStreamCpyThread* thread = (deStreamCpyThread*)arg; local
31 deUint8* buffer = malloc(sizeof(deUint8) * (size_t)thread->bufferSize);
39 readResult = deInStream_read(thread->input, buffer, thread->bufferSize, &read);
44 deOutStream_write(thread->output, buffer, read - written, &wrote);
56 deOutStream_flush(thread->output);
62 deStreamCpyThread* thread = malloc(sizeof(deStreamCpyThread)); local
64 DE_ASSERT(thread);
68 thread->input = input
[all...] |
| /external/linux-kselftest/tools/testing/selftests/powerpc/tm/ |
| tm-vmx-unavail.c | 92 pthread_t *thread; local
99 thread = malloc(sizeof(pthread_t)*threads);
100 if (!thread)
104 pthread_create(&thread[i], NULL, &worker, NULL);
107 pthread_join(thread[i], NULL);
109 free(thread);
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_cond_destroy/speculative/ |
| 4-1.c | 28 void *thread(void *tmp) function
74 rc = pthread_create(&low_id, NULL, thread, NULL);
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_rwlock_init/ |
| 1-1.c | 16 * 2. Create a child thread, the thread lock 'rwlock' for reading, shall not block.
60 pthread_t thread; local
77 printf("main: create thread\n");
78 if (pthread_create(&thread, NULL, fn_rd, NULL) != 0) {
79 printf("main: failed to create thread\n");
85 /* We expect the thread not to block */
92 printf("Test FAILED: thread blocked on read lock\n");
95 printf("main: Unexpected thread state\n");
99 if (pthread_join(thread, NULL) != 0)
[all...] |
| 2-1.c | 16 * 2. Create a child thread, the thread lock 'rwlock' for reading, shall not block.
59 pthread_t thread; local
70 printf("main: create thread\n");
71 if (pthread_create(&thread, NULL, fn_rd, NULL) != 0) {
72 printf("main: failed to create thread\n");
78 /* We expect the thread not to block */
85 printf("Test FAILED: thread blocked on read lock\n");
88 printf("main: Unexpected thread state\n");
92 if (pthread_join(thread, NULL) != 0)
[all...] |
| /external/python/cpython2/Lib/test/ |
| fork_wait.py | 5 We want fork1() semantics -- only the forking thread survives in the
17 thread = test_support.import_module('thread') variable
51 thread.start_new(self.f, (i,))
|
| test_imp.py | 6 import thread
8 thread = None variable
10 @unittest.skipUnless(thread, 'threading not available')
|
| test_threadsignals.py | 8 thread = import_module('thread') variable
14 signalled_all=thread.allocate_lock()
28 signal_blackboard[sig]['tripped_by'] = thread.get_ident()
30 # a function that will be spawned as a separate thread.
38 We spawn a thread, have the thread send two signals, and
40 and that they were run by the main thread.
49 # (it might even be after the thread exits
61 thread.get_ident()
[all...] |
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| worker_env.h | 24 namespace thread { namespace in namespace:tensorflow
26 } // namespace thread
61 thread::ThreadPool* compute_pool = nullptr;
|
| /external/testng/src/main/java/org/testng/internal/thread/ |
| FutureResultAdapter.java | 1 package org.testng.internal.thread;
|
| IExecutor.java | 1 package org.testng.internal.thread;
|
| IThreadFactory.java | 1 package org.testng.internal.thread;
12 Thread newThread(Runnable run);
16 List<Thread> getThreads();
|
| /external/testng/src/main/java/org/testng/internal/thread/graph/ |
| IWorker.java | 1 package org.testng.internal.thread.graph;
|
| /external/testng/src/test/java/test/thread/ |
| B.java | 1 package test.thread;
18 Long id = Thread.currentThread().getId();
|
| Helper.java | 1 package test.thread;
|
| ParallelWithFactorySampleTest.java | 1 package test.thread;
31 addId("f1 " + getN(), Thread.currentThread().getId());
36 addId("f2", Thread.currentThread().getId());
|
| ThreadPoolSampleBugTest.java | 1 package test.thread;
10 Thread.sleep(TIMEOUT);
15 Thread.sleep(TIMEOUT);
20 Thread.sleep(TIMEOUT);
25 Thread.sleep(TIMEOUT);
|
| ThreadTest.java | 1 package test.thread;
|
| /external/valgrind/drd/tests/ |
| concurrent_close.cpp | 15 void* thread(void*) function
37 r = pthread_create(&threads[i], &attr, thread, 0);
39 fprintf(stderr, "Failed to create thread %d\n", i);
47 fprintf(stderr, "Failed to join thread %d\n", i);
|
| pth_barrier_thr_cr.c | 3 * pthread_barrier_wait() call is invoked by another thread. This is the only
18 static void* thread(void* arg) function
40 res = pthread_create(&tid[i], NULL, thread, NULL);
|
| std_string.cpp | 2 * Test program that uses std::string object from more than one thread and
49 pthread_t thread[2]; local
51 for (int i = 0; i < sizeof(thread)/sizeof(thread[0]); i++) {
52 int ret = pthread_create(&thread[i], NULL, &fillTable, NULL);
54 fprintf(stderr, "Failed to create thread %d: %d\n", i, ret);
59 for (int i = 0; i < sizeof(thread)/sizeof(thread[0]); i++) {
60 int ret = pthread_join(thread[i], NULL);
62 fprintf(stderr, "Failed to join thread %d: %d\n", i, ret)
[all...] |
| /external/vogar/src/vogar/util/ |
| Threads.java | 35 public synchronized Thread newThread(Runnable r) {
36 Thread thread = new Thread(r, name + "-" + (nextId++)); local
37 thread.setDaemon(true);
38 return thread;
|
| /external/webrtc/webrtc/base/ |
| nullsocketserver_unittest.cc | 31 Thread thread; local
32 EXPECT_TRUE(thread.Start());
33 thread.Post(this, 0);
|
| /frameworks/av/media/mtp/ |
| PosixAsyncIO.h | 23 #include <thread>
38 std::thread thread; member in struct:aiocb
49 // Suspend current thread until given IO is complete, at which point
|
