Home
last modified time | relevance | path

Searched refs:queue (Results 1 – 20 of 20) sorted by relevance

/art/runtime/base/
Dmessage_queue_test.cc58 TestMessageQueue queue; in TEST_F() local
60 queue.SendMessage(EmptyMessage{}); in TEST_F()
61 ASSERT_TRUE(std::holds_alternative<EmptyMessage>(queue.ReceiveMessage())); in TEST_F()
63 queue.SendMessage(IntMessage{42}); in TEST_F()
64 ASSERT_TRUE(std::holds_alternative<IntMessage>(queue.ReceiveMessage())); in TEST_F()
66 queue.SendMessage(OtherIntMessage{43}); in TEST_F()
67 ASSERT_TRUE(std::holds_alternative<OtherIntMessage>(queue.ReceiveMessage())); in TEST_F()
69 queue.SendMessage(TwoIntMessage{1, 2}); in TEST_F()
70 ASSERT_TRUE(std::holds_alternative<TwoIntMessage>(queue.ReceiveMessage())); in TEST_F()
72 queue.SendMessage(StringMessage{"Hello, World!"}); in TEST_F()
[all …]
/art/runtime/gc/
Dreference_queue_test.cc41 ReferenceQueue queue(&lock); in TEST_F() local
42 ASSERT_TRUE(queue.IsEmpty()); in TEST_F()
43 ASSERT_EQ(queue.GetLength(), 0U); in TEST_F()
52 queue.EnqueueReference(ref1.Get()); in TEST_F()
53 ASSERT_TRUE(!queue.IsEmpty()); in TEST_F()
54 ASSERT_EQ(queue.GetLength(), 1U); in TEST_F()
55 queue.EnqueueReference(ref2.Get()); in TEST_F()
56 ASSERT_TRUE(!queue.IsEmpty()); in TEST_F()
57 ASSERT_EQ(queue.GetLength(), 2U); in TEST_F()
61 dequeued.insert(queue.DequeuePendingReference().Ptr()); in TEST_F()
[all …]
/art/test/004-NativeAllocations/src-art/
DMain.java56 public static PhantomReference $noinline$allocPhantom(ReferenceQueue<Object> queue) { in $noinline$allocPhantom() argument
57 return new PhantomReference(new Object(), queue); in $noinline$allocPhantom()
69 ReferenceQueue<Object> queue = new ReferenceQueue<Object>(); in checkRegisterNativeAllocation() local
70 ref = $noinline$allocPhantom(queue); in checkRegisterNativeAllocation()
91 if (queue.remove(MAX_EXPECTED_GC_DURATION_MS) == null) { in checkRegisterNativeAllocation()
101 System.out.println(" After delay, queue.poll() = " + queue.poll() in checkRegisterNativeAllocation()
106 System.out.println(" After GC, queue.poll() = " + queue.poll() in checkRegisterNativeAllocation()
/art/test/079-phantom/src/
DBitmap.java121 ReferenceQueue<PhantomWrapper> queue, int nativeDataPtr) in PhantomWrapper() argument
123 super(wrapper, queue); in PhantomWrapper()
138 BitmapWatcher(ReferenceQueue<PhantomWrapper> queue) { in BitmapWatcher() argument
139 mQueue = queue; in BitmapWatcher()
/art/tools/dexanalyze/
Ddexanalyze_strings.cc249 T PopRealTop(Queue<T, Args...>& queue) { in PopRealTop() argument
250 auto pair = queue.top(); in PopRealTop()
251 queue.pop(); in PopRealTop()
255 queue.push(pair); in PopRealTop()
256 pair = queue.top(); in PopRealTop()
257 queue.pop(); in PopRealTop()
266 std::priority_queue<std::pair<int32_t, MatchTrie*>> queue; in ExtractPrefixes() local
280 queue.emplace(elem->Savings(), elem); in ExtractPrefixes()
285 while (max != 0u && !queue.empty()) { in ExtractPrefixes()
286 std::pair<int32_t, MatchTrie*> pair = PopRealTop(queue); in ExtractPrefixes()
/art/tools/ahat/src/main/com/android/ahat/heapdump/
DAhatInstance.java736 Queue<Reference> queue = queues.get(reachability); in computeReachability() local
737 while (!queue.isEmpty()) { in computeReachability()
738 Reference ref = queue.poll(); in computeReachability()
749 queue.add(childRef); in computeReachability()
/art/libartservice/service/javatests/com/android/server/art/
DArtdRefCacheTest.java222 var queue = new ReferenceQueue<ArtdRefCache>(); in testReset() local
223 var phantomRef = new PhantomReference(mArtdRefCache, queue); in testReset()
/art/libartservice/service/java/com/android/server/art/
DDexoptHelper.java272 Queue<SharedLibrary> queue = new LinkedList<>(); in getPackageStates() local
280 queue.add(library); in getPackageStates()
296 while ((library = queue.poll()) != null) { in getPackageStates()
/art/odrefresh/
Dodr_fs_utils.cc115 std::queue<std::string> unvisited; in GetUsedSpace()
/art/libartbase/base/
Darena_containers.h57 using ArenaQueue = std::queue<T, ArenaDeque<T>>;
Dscoped_arena_containers.h55 using ScopedArenaQueue = std::queue<T, ScopedArenaDeque<T>>;
/art/test/1940-ddms-ext/
Dddm_ext.cc48 std::queue<DdmCallbackData> callbacks_received;
/art/runtime/
Dquick_exception_handler.cc119 std::queue<ArtMethod*>& GetUnwoundMethods() { in GetUnwoundMethods()
168 std::queue<ArtMethod*> unwound_methods_;
Dmonitor_inflation.md14 word itself does not have space for a wait queue or the like.
Dinstrumentation.h590 std::queue<ArtMethod*>& methods,
Dinstrumentation.cc128 std::queue<ArtMethod*>& methods, in ProcessMethodUnwindCallbacks()
Dclass_linker.cc1095 ArtField* queue = java_lang_ref_Reference->GetInstanceField(1); in FinishInit() local
1096 CHECK_STREQ(queue->GetName(), "queue"); in FinishInit()
1097 CHECK_STREQ(queue->GetTypeDescriptor(), "Ljava/lang/ref/ReferenceQueue;"); in FinishInit()
/art/compiler/optimizing/
Dnodes.cc1223 ScopedArenaDeque<std::pair<HInstruction*, size_t>> queue(allocator.Adapter(kArenaAllocMisc)); in Dump() local
1224 auto add_args = [&queue](HInstruction* instruction, size_t indentation) { in Dump()
1226 queue.emplace_front(arg, indentation); in Dump()
1230 while (!queue.empty()) { in Dump()
1233 std::tie(instruction, indentation) = queue.front(); in Dump()
1234 queue.pop_front(); in Dump()
/art/runtime/verifier/
Dreg_type_test.cc1012 std::queue<const RegType*> work_list; in TEST_F()
/art/build/boot/hiddenapi/
Dhiddenapi-max-target-o-low-priority.txt2474 Ljava/lang/Daemons$FinalizerDaemon;->queue:Ljava/lang/ref/ReferenceQueue;
3041 Ljava/lang/ref/Reference;->queue:Ljava/lang/ref/ReferenceQueue;
6276 Ljava/util/Collections$CheckedQueue;->queue:Ljava/util/Queue;
7108 Ljava/util/concurrent/ConcurrentLinkedDeque$CLDSpliterator;->queue:Ljava/util/concurrent/Concurrent…
7162 Ljava/util/concurrent/ConcurrentLinkedQueue$CLQSpliterator;->queue:Ljava/util/concurrent/Concurrent…
7683 Ljava/util/concurrent/LinkedBlockingDeque$LBDSpliterator;->queue:Ljava/util/concurrent/LinkedBlocki…
7709 Ljava/util/concurrent/LinkedBlockingQueue$LBQSpliterator;->queue:Ljava/util/concurrent/LinkedBlocki…
8056 Ljava/util/concurrent/PriorityBlockingQueue$PBQSpliterator;->queue:Ljava/util/concurrent/PriorityBl…
8066 Ljava/util/concurrent/PriorityBlockingQueue;->queue:[Ljava/lang/Object;
8095 Ljava/util/concurrent/ScheduledThreadPoolExecutor$DelayedWorkQueue;->queue:[Ljava/util/concurrent/R…
[all …]