Lines Matching refs:self
54 void AllocationManager::PauseForAllocation(art::Thread* self, T msg) { in PauseForAllocation() argument
62 if (LIKELY(pausing_thread == nullptr || pausing_thread == self)) { in PauseForAllocation()
68 art::ScopedThreadSuspension sts(self, art::ThreadState::kSuspended); in PauseForAllocation()
69 art::MutexLock mu(self, alloc_listener_mutex_); in PauseForAllocation()
71 CHECK_NE(pausing_thread, self) << "We should always be setting pausing_thread = self!" in PauseForAllocation()
72 << " How did this happen? " << *self; in PauseForAllocation()
74 VLOG(plugin) << "Suspending " << *self << " due to " << cause << ". Allocation pause " in PauseForAllocation()
76 alloc_pause_cv_.Wait(self); in PauseForAllocation()
86 void JvmtiAllocationListener::ObjectAllocated(art::Thread* self, in ObjectAllocated() argument
91 cb->ObjectAllocated(self, obj, cnt); in ObjectAllocated()
99 void JvmtiAllocationListener::PreObjectAllocated(art::Thread* self, in PreObjectAllocated() argument
102 manager_->PauseForAllocation(self, [&]() REQUIRES_SHARED(art::Locks::mutator_lock_) { in PreObjectAllocated()
122 void AllocationManager::DisableAllocationCallback(art::Thread* self) { in DisableAllocationCallback() argument
124 DecrListenerInstall(self); in DisableAllocationCallback()
127 void AllocationManager::EnableAllocationCallback(art::Thread* self) { in EnableAllocationCallback() argument
128 IncrListenerInstall(self); in EnableAllocationCallback()
143 void AllocationManager::DecrListenerInstall(art::Thread* self) { in DecrListenerInstall() argument
144 art::ScopedThreadSuspension sts(self, art::ThreadState::kSuspended); in DecrListenerInstall()
145 art::MutexLock mu(self, alloc_listener_mutex_); in DecrListenerInstall()
153 void AllocationManager::IncrListenerInstall(art::Thread* self) { in IncrListenerInstall() argument
154 art::ScopedThreadSuspension sts(self, art::ThreadState::kSuspended); in IncrListenerInstall()
155 art::MutexLock mu(self, alloc_listener_mutex_); in IncrListenerInstall()
163 void AllocationManager::PauseAllocations(art::Thread* self) { in PauseAllocations() argument
191 IncrListenerInstall(self); in PauseAllocations()
194 PauseForAllocation(self, []() { return "request to pause allocations on other threads"; }); in PauseAllocations()
196 null_thr, self, std::memory_order_seq_cst)); in PauseAllocations()
199 art::ScopedThreadSuspension sts(self, art::ThreadState::kSuspended); in PauseAllocations()
205 barrier.Increment(self, requested); in PauseAllocations()
208 void AllocationManager::ResumeAllocations(art::Thread* self) { in ResumeAllocations() argument
209 CHECK_EQ(allocations_paused_thread_.load(), self) << "not paused! "; in ResumeAllocations()
212 art::ScopedThreadSuspension sts(self, art::ThreadState::kSuspended); in ResumeAllocations()
213 art::MutexLock mu(self, alloc_listener_mutex_); in ResumeAllocations()
215 alloc_pause_cv_.Broadcast(self); in ResumeAllocations()