| /external/webrtc/webrtc/base/ |
| thread_unittest.cc | 17 #include "webrtc/base/thread.h"
52 Thread* post_thread, MessageHandler* phandler)
77 Thread* post_thread_;
84 MessageClient(Thread* pth, Socket* socket)
103 class CustomThread : public rtc::Thread {
110 return Thread::WrapCurrent();
113 Thread::UnwrapCurrent();
118 // A thread that does nothing when it runs and signals an event
120 class SignalWhenDestroyedThread : public Thread {
171 // Function objects to test Thread::Invoke
235 Thread *thread; local
269 Thread thread; local
289 AutoThread thread; local
314 AutoThread thread; local
412 Thread thread; local
423 Thread thread; local
435 Thread thread; local
452 Thread thread; local
467 Thread thread; local
634 Thread thread; local
649 Thread thread; local
720 Thread* thread = new ComThread(); local
[all...] |
| virtualsocket_unittest.cc | 22 #include "webrtc/base/thread.h"
30 Sender(Thread* th, AsyncSocket* s, uint32_t rt)
31 : thread(th),
37 thread->PostDelayed(NextDelay(), this, 1);
62 thread->PostDelayed(NextDelay(), this, 1);
65 Thread* thread; member in struct:Sender
76 Receiver(Thread* th, AsyncSocket* s, uint32_t bw)
77 : thread(th),
87 thread->PostDelayed(1000, this, 1)
125 Thread* thread; member in struct:Receiver
[all...] |
| /frameworks/av/services/audioflinger/ |
| Effects.h | 45 EffectModule(ThreadBase *thread,
100 void setThread(const wp<ThreadBase>& thread)
101 { mThread = thread; mThreadType = thread.promote()->type(); }
102 const wp<ThreadBase>& thread() { return mThread; } function in class:EffectModule
163 wp<ThreadBase> mThread; // parent thread
164 ThreadBase::type_t mThreadType; // parent thread type
302 // There can be any number of EffectChain objects per output mixer thread (PlaybackThread).
313 EffectChain(ThreadBase *thread, audio_session_t sessionId);
334 ThreadBase *thread,
[all...] |
| PlaybackTracks.h | 61 Track( PlaybackThread *thread,
142 * Thread safe.
148 /** Copy the track metadata in the provided iterator. Thread safe. */
206 // FIXME parameters not needed, could get them from the thread
210 /** Set that a metadata has changed and needs to be notified to backend. Thread safe. */
244 // access these three variables only when holding thread lock.
291 bool mFlushHwPending; // track requests for thread flush
308 OutputTrack(PlaybackThread *thread,
324 const wp<ThreadBase>& thread() const { return mThread; } function in class:OutputTrack
327 /** Set the metadatas of the upstream tracks. Thread safe. *
[all...] |
| /frameworks/base/cmds/incidentd/src/ |
| Section.cpp | 280 // data might be gone now. don't use it after this point in this thread.
286 pthread_t thread; local
291 // Data shared between this thread and the worker thread.
299 // Create the thread
304 // TODO: Do we need to tweak thread priority?
311 // The worker thread needs a reference and we can't let the count go to zero
312 // if that thread is slow to start.
315 err = pthread_create(&thread, &attr, worker_thread_func, (void*)data.get());
328 // Done with the read fd. The worker thread closes the write one s
[all...] |
| /developers/build/prebuilts/gradle/Camera2Video/Application/src/main/java/com/example/android/camera2video/ |
| Camera2VideoFragment.java | 170 * An additional thread for running tasks that shouldn't block the UI.
332 * Starts a background thread and its {@link Handler}.
341 * Stops the background thread and its {@link Handler}.
534 HandlerThread thread = new HandlerThread("CameraPreview"); local
535 thread.start();
|
| /developers/samples/android/media/Camera2Video/Application/src/main/java/com/example/android/camera2video/ |
| Camera2VideoFragment.java | 170 * An additional thread for running tasks that shouldn't block the UI.
332 * Starts a background thread and its {@link Handler}.
341 * Stops the background thread and its {@link Handler}.
534 HandlerThread thread = new HandlerThread("CameraPreview"); local
535 thread.start();
|
| /development/samples/browseable/Camera2Video/src/com.example.android.camera2video/ |
| Camera2VideoFragment.java | 170 * An additional thread for running tasks that shouldn't block the UI.
333 * Starts a background thread and its {@link Handler}.
342 * Stops the background thread and its {@link Handler}.
530 HandlerThread thread = new HandlerThread("CameraPreview"); local
531 thread.start();
|
| /external/guava/guava-tests/test/com/google/common/cache/ |
| CacheLoadingTest.java | 24 import static java.lang.Thread.currentThread;
77 // TODO(cpovirk): run tests in other thread instead of messing with main thread interrupt status
2104 Thread thread = new Thread(new Runnable() { local
[all...] |
| /cts/tests/tests/media/src/android/media/cts/ |
| DecodeAccuracyTestBase.java | 270 final long threadDelayMs = 3; // In case of delay in thread.
273 Thread.sleep(delayMs - threadDelayMs);
1423 private final HandlerThread thread; field in class:SurfaceViewSnapshot.SynchronousPixelCopy
[all...] |
| /art/openjdkjvmti/ |
| ti_heap.cc | 40 #include "thread-inl.h"
374 static void VisitStatic(art::Thread* self, art::ObjPtr<art::mirror::Class> klass, T& visitor)
380 void Visit(art::Thread* self, art::ObjPtr<art::mirror::Class> klass, T& visitor)
395 void VisitInterface(art::Thread* self, art::ObjPtr<art::mirror::Class> inf_klass, T& visitor)
436 RecursiveInterfaceVisit<decltype(visitor)>::VisitStatic(art::Thread::Current(), klass, visitor);
665 art::Thread* self = art::Thread::Current();
732 art::Thread* self = art::Thread::Current();
968 art::Thread* thread = FindThread(info); local
1000 art::Thread* thread = FindThread(info); local
[all...] |
| /art/runtime/jni/ |
| java_vm_ext.cc | 52 #include "thread-inl.h"
73 SharedLibrary(JNIEnv* env, Thread* self, const std::string& path, void* handle,
88 Thread* self = Thread::Current();
114 * If the call has not yet finished in another thread, wait for it.
118 Thread* self = Thread::Current();
143 Thread* self = Thread::Current();
161 // No mutator lock since dlsym may block for a while if another thread is doing dlopen
415 Thread* thread = Thread::Current(); local
[all...] |
| /art/runtime/ |
| monitor.cc | 40 #include "thread.h"
74 * Only one thread can own the monitor at any time. There may be several threads waiting on it
92 Monitor::Monitor(Thread* self, Thread* owner, ObjPtr<mirror::Object> obj, int32_t hash_code)
115 Monitor::Monitor(Thread* self,
116 Thread* owner,
153 bool Monitor::Install(Thread* self) {
169 // The owner_ is suspended but another thread beat us to install a monitor.
193 explicit NextMethodVisitor(Thread* thread) REQUIRES_SHARED(Locks::mutator_lock_
629 oss << *thread; local
740 Thread* thread = wake_set_; local
[all...] |
| thread_list.cc | 48 #include "thread.h"
92 // Detach the current thread if necessary. If we failed to start, there might not be any threads.
93 // We need to detach the current thread here in case there's another thread waiting to join with
96 Thread* self = Thread::Current();
110 heap->WaitForGcToComplete(gc::kGcCauseBackground, Thread::Current());
111 // TODO: there's an unaddressed race here where a thread may attach during shutdown, see
112 // Thread::Init.
118 bool ThreadList::Contains(Thread* thread)
757 oss << std::endl << "Thread not suspended: " << *thread; local
901 Thread* thread; local
1030 Thread* thread = nullptr; local
[all...] |
| /art/runtime/verifier/ |
| verifier_deps.cc | 189 // end of verification will have all the per-thread VerifierDeps merged into it.
198 // During AOT, each thread has its own VerifierDeps, to avoid lock contention. At the end
203 return Thread::Current()->GetVerifierDeps();
239 ReaderMutexLock mu(Thread::Current(), *Locks::verifier_deps_lock_);
245 WriterMutexLock mu(Thread::Current(), *Locks::verifier_deps_lock_);
361 Thread* thread = Thread::Current(); local
371 ObjPtr<mirror::Class> direct = mirror::Class::GetDirectInterface(thread, current, i);
391 ObjPtr<mirror::Class> direct = mirror::Class::GetDirectInterface(thread, itf, j)
[all...] |
| /device/generic/goldfish/gps/ |
| gps_qemu.c | 78 pthread_t thread; member in struct:__anon1720
624 /* this runs in child thread */
672 /* commands sent to the gps thread */
684 // tell the thread to quit, and wait for it
688 pthread_join(s->thread, &dummy);
761 /* this is the main thread, it waits for commands from gps_state_start/stop and,
792 D("gps thread running");
813 D("gps thread received %d events", nevents);
832 D("gps thread quitting on demand");
837 D("gps thread starting location_cb=%p", state->callbacks.location_cb)
[all...] |
| /external/adhd/cras/src/server/ |
| audio_thread.c | 37 /* Messages that can be sent from the main context to the audio thread. */
98 /* Audio thread logging. */
171 /* Sends a response (error code) from the audio thread to the main thread.
172 * Indicates that the last message sent to the audio thread has been handled
175 * thread - thread responding to command.
176 * rc - Result code to send back to the main thread.
178 * The number of bytes written to the main thread.
180 static int audio_thread_send_response(struct audio_thread *thread, int rc
891 struct audio_thread *thread = (struct audio_thread *)arg; local
1217 struct audio_thread *thread; local
[all...] |
| /external/adhd/cras/src/tests/ |
| audio_thread_unittest.cc | 649 // Audio thread should ask iodev to handle output underrun.
692 // Audio thread should ask main thread to reset device.
703 struct audio_thread thread; local
716 EXPECT_EQ(1, thread_drain_stream_ms_remaining(&thread, &rstream));
719 EXPECT_EQ(10, thread_drain_stream_ms_remaining(&thread, &rstream));
722 EXPECT_EQ(0, thread_drain_stream_ms_remaining(&thread, &rstream));
726 EXPECT_EQ(0, thread_drain_stream_ms_remaining(&thread, &rstream));
[all...] |
| audio_thread_unittest_obsolete.cc | 240 struct audio_thread *thread; local
242 thread = audio_thread_create();
243 ASSERT_TRUE(thread);
244 thread_set_active_dev(thread, &iodev_);
246 thread_add_stream(thread, rstream_);
251 rc = unified_io(thread, &ts);
258 audio_thread_destroy(thread);
265 struct audio_thread *thread; local
267 thread = audio_thread_create();
268 ASSERT_TRUE(thread);
296 struct audio_thread *thread; local
328 struct audio_thread *thread; local
366 struct audio_thread *thread; local
407 struct audio_thread *thread; local
455 struct audio_thread *thread; local
1198 struct audio_thread *thread; local
1307 struct audio_thread *thread; local
1350 struct audio_thread *thread; local
1386 struct audio_thread *thread; local
[all...] |
| iodev_list_unittest.cc | 40 static struct audio_thread thread; member in namespace:__anon15201
[all...] |
| /external/conscrypt/repackaged/common/src/main/java/com/android/org/conscrypt/ |
| AbstractConscryptSocket.java | 605 // The RI runs the handlers in a separate thread,
608 // the handshaking thread just because a listener
610 Thread thread = Thread.currentThread(); local
611 thread.getUncaughtExceptionHandler().uncaughtException(thread, e);
|
| /external/curl/tests/server/ |
| sockfilt.c | 535 HANDLE event; /* internal event to abort waiting thread */
667 HANDLE thread = NULL; local
675 /* launch waiting thread */
676 thread = CreateThread(NULL, 0,
680 /* free data if thread failed to launch */
681 if(!thread) {
686 return thread;
692 HANDLE thread; /* the internal threads handle (indexed by thd) */ member in struct:select_ws_data
764 data[thd].thread = handle;
790 data[thd].thread = handle
[all...] |
| /external/elfutils/libdwfl/ |
| libdwflP.h | 255 Dwfl_Thread *thread; member in struct:Dwfl_Frame
415 /* Structure used for keeping track of ptrace attaching a thread.
425 Should be cleared on detachment (because that makes the thread
|
| /external/google-breakpad/src/client/linux/minidump_writer/ |
| minidump_writer.cc | 113 // Estimate for how big each thread's stack will be (in bytes).
117 // the crashing thread will never be limited). Threads beyond this count are
120 // Maximum stack size to dump for any extra thread (in bytes).
260 bool FillThreadStack(MDRawThread* thread, uintptr_t stack_pointer,
274 dumper_->CopyFromProcess(*stack_copy, thread->thread_id, stack,
277 thread->stack.start_of_memory_range =
279 thread->stack.memory = memory.location();
280 memory_blocks_.push_back(thread->stack);
282 thread->stack.start_of_memory_range = stack_pointer;
283 thread->stack.memory.data_size = 0
318 MDRawThread thread; local
[all...] |
| /external/google-breakpad/src/client/mac/handler/ |
| minidump_generator.cc | 287 // some circumstances, the stack for thread 0 winds up broken up into
325 // In some situations the stack address for the thread can come back 0.
946 MDRawThread *thread) {
952 if (!WriteStack(state, &thread->stack))
955 memory_blocks_.push_back(thread->stack);
957 if (!WriteContext(state, &thread->thread_context))
960 thread->thread_id = thread_id;
978 // Don't include the generator thread
992 MDRawThread thread; local
996 memset(&thread, 0, sizeof(MDRawThread))
[all...] |
