/art/test/utils/python/ |
D | generate_java_main.py | 64 def __init__(self): argument 68 self.tests = set() 69 self.global_funcs = set() 71 def add_instance(self, it): argument 75 self.tests.add(it) 77 def add_func(self, f): argument 81 self.global_funcs.add(f) 83 def get_name(self): argument 89 def __str__(self): argument 93 all_tests = sorted(self.tests) [all …]
|
/art/openjdkjvmti/ |
D | alloc_manager.cc | 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() [all …]
|
D | deopt_manager.cc | 117 void DeoptManager::DumpDeoptInfo(art::Thread* self, std::ostream& stream) { in DumpDeoptInfo() argument 118 art::ScopedObjectAccess soa(self); in DumpDeoptInfo() 119 art::MutexLock mutll(self, *art::Locks::thread_list_lock_); in DumpDeoptInfo() 120 art::MutexLock mudsl(self, deoptimization_status_lock_); in DumpDeoptInfo() 121 art::MutexLock mubsl(self, breakpoint_status_lock_); in DumpDeoptInfo() 132 void Run(art::Thread* self) override { in DumpDeoptInfo() 136 self->GetThreadName(name); in DumpDeoptInfo() 137 stream_ << "Thread " << name << " (id: " << std::dec << self->GetThreadId() in DumpDeoptInfo() 138 << ") force interpreter count " << self->ForceInterpreterCount() << "\n"; in DumpDeoptInfo() 165 art::Thread* self = art::Thread::Current(); in FinishSetup() local [all …]
|
D | ti_monitor.cc | 62 static bool Destroy(art::Thread* self, JvmtiMonitor* monitor) NO_THREAD_SAFETY_ANALYSIS { in Destroy() argument 65 if (owner_thread != nullptr && self != owner_thread) { in Destroy() 79 void MonitorEnter(art::Thread* self, bool suspend) NO_THREAD_SAFETY_ANALYSIS { in MonitorEnter() argument 85 ThreadUtil::SuspendCheck(self); in MonitorEnter() 86 if (ThreadUtil::WouldSuspendForUserCode(self)) { in MonitorEnter() 92 if (IsOwner(self)) { in MonitorEnter() 106 if (!suspend || !ThreadUtil::WouldSuspendForUserCode(self)) { in MonitorEnter() 119 owner_.store(self, std::memory_order_relaxed); in MonitorEnter() 124 bool MonitorExit(art::Thread* self) NO_THREAD_SAFETY_ANALYSIS { in MonitorExit() argument 125 if (!IsOwner(self)) { in MonitorExit() [all …]
|
/art/tools/jvmti-agents/ti-alloc-sample/ |
D | mkflame.py | 25 def __init__(self, args): argument 26 self.args = args 28 self.definitions = {} 30 self.weights = {} 32 self.allocation_count = {} 34 def definition(self, index): argument 38 return self.definitions[index] 40 def set_definition(self, index, definition): argument 44 self.definitions[index] = definition 46 def weight(self, index): argument [all …]
|
/art/tools/ |
D | stream-trace-converter.py | 71 def PrintHeader(self, header): argument 78 def ProcessDataHeader(self, input, body): argument 103 self._mRecordSize = 9; 105 self._mRecordSize = 10; 107 self._mRecordSize = ReadShortLE(input) 108 WriteShortLE(body, self._mRecordSize) 114 def ProcessMethod(self, input): argument 117 self._methods.append(str) 120 def ProcessThread(self, input): argument 124 self._threads.append('%d\t%s\n' % (tid, str)) [all …]
|
/art/tools/bisection_search/ |
D | bisection_search.py | 73 def __init__(self, base_cmd, test_env, expected_retcode=None, argument 84 self._base_cmd = base_cmd 85 self._test_env = test_env 86 self._expected_retcode = expected_retcode 87 self._output_checker = output_checker 88 self._compiled_methods_path = self._test_env.CreateFile('compiled_methods') 89 self._passes_to_run_path = self._test_env.CreateFile('run_passes') 90 self._verbose = verbose 91 if RAW_CMD_RUNTIME_ARGS_TAG in self._base_cmd: 92 self._arguments_position = self._base_cmd.index(RAW_CMD_RUNTIME_ARGS_TAG) [all …]
|
/art/runtime/interpreter/ |
D | unstarted_runtime_test.cc | 68 static void Unstarted ## Name(Thread* self, \ 73 interpreter::UnstartedRuntime::Unstarted ## Name(self, shadow_frame, result, arg_offset); \ 83 static void UnstartedJNI ## Name(Thread* self, \ 89 interpreter::UnstartedRuntime::UnstartedJNI ## Name(self, method, receiver, args, result); \ 111 Thread* self, in CreateObjectArray() argument 117 runtime->GetClassLinker()->FindArrayClass(self, component_type); in CreateObjectArray() 120 mirror::ObjectArray<mirror::Object>::Alloc(self, array_type, 3); in CreateObjectArray() 124 CHECK(!self->IsExceptionPending()); in CreateObjectArray() 139 void RunArrayCopy(Thread* self, in RunArrayCopy() argument 154 UnstartedSystemArraycopy(self, tmp, &result, 0); in RunArrayCopy() [all …]
|
D | lock_count_data.cc | 28 void LockCountData::AddMonitor(Thread* self, mirror::Object* obj) { in AddMonitor() argument 35 if (self->IsExceptionPending()) { in AddMonitor() 45 void LockCountData::RemoveMonitorOrThrow(Thread* self, const mirror::Object* obj) { in RemoveMonitorOrThrow() argument 63 self->ClearException(); in RemoveMonitorOrThrow() 64 self->ThrowNewExceptionF("Ljava/lang/IllegalMonitorStateException;", in RemoveMonitorOrThrow() 72 void MonitorExitHelper(Thread* self, mirror::Object* obj) NO_THREAD_SAFETY_ANALYSIS { in MonitorExitHelper() argument 73 DCHECK(self != nullptr); in MonitorExitHelper() 75 obj->MonitorExit(self); in MonitorExitHelper() 78 bool LockCountData::CheckAllMonitorsReleasedOrThrow(Thread* self) { in CheckAllMonitorsReleasedOrThrow() argument 79 DCHECK(self != nullptr); in CheckAllMonitorsReleasedOrThrow() [all …]
|
D | unstarted_runtime.cc | 71 static void AbortTransactionOrFail(Thread* self, const char* fmt, ...) 75 static void AbortTransactionOrFail(Thread* self, const char* fmt, ...) { in AbortTransactionOrFail() argument 79 AbortTransactionV(self, fmt, args); in AbortTransactionOrFail() 93 static void CharacterLowerUpper(Thread* self, in CharacterLowerUpper() argument 102 AbortTransactionOrFail(self, in CharacterLowerUpper() 119 Thread* self, ShadowFrame* shadow_frame, JValue* result, size_t arg_offset) { in UnstartedCharacterToLowerCase() argument 120 CharacterLowerUpper(self, shadow_frame, result, arg_offset, true); in UnstartedCharacterToLowerCase() 124 Thread* self, ShadowFrame* shadow_frame, JValue* result, size_t arg_offset) { in UnstartedCharacterToUpperCase() argument 125 CharacterLowerUpper(self, shadow_frame, result, arg_offset, false); in UnstartedCharacterToUpperCase() 129 static void UnstartedRuntimeFindClass(Thread* self, Handle<mirror::String> className, in UnstartedRuntimeFindClass() argument [all …]
|
/art/runtime/gc/ |
D | reference_processor.cc | 73 void ReferenceProcessor::DisableSlowPath(Thread* self) { in DisableSlowPath() argument 75 condition_.Broadcast(self); in DisableSlowPath() 84 void ReferenceProcessor::BroadcastForSlowPath(Thread* self) { in BroadcastForSlowPath() argument 85 MutexLock mu(self, *Locks::reference_processor_lock_); in BroadcastForSlowPath() 86 condition_.Broadcast(self); in BroadcastForSlowPath() 89 ObjPtr<mirror::Object> ReferenceProcessor::GetReferent(Thread* self, in GetReferent() argument 91 if (!kUseReadBarrier || self->GetWeakRefAccessEnabled()) { in GetReferent() 102 MutexLock mu(self, *Locks::reference_processor_lock_); in GetReferent() 104 (kUseReadBarrier && !self->GetWeakRefAccessEnabled())) { in GetReferent() 134 self->CheckEmptyCheckpointFromWeakRefAccess(Locks::reference_processor_lock_); in GetReferent() [all …]
|
D | task_processor.cc | 41 void TaskProcessor::AddTask(Thread* self, HeapTask* task) { in AddTask() argument 42 ScopedThreadStateChange tsc(self, kWaitingForTaskProcessor); in AddTask() 43 MutexLock mu(self, lock_); in AddTask() 45 cond_.Signal(self); in AddTask() 48 HeapTask* TaskProcessor::GetTask(Thread* self) { in GetTask() argument 49 ScopedThreadStateChange tsc(self, kWaitingForTaskProcessor); in GetTask() 50 MutexLock mu(self, lock_); in GetTask() 56 cond_.Wait(self); // Empty queue, wait until we are signalled. in GetTask() 73 cond_.TimedWait(self, static_cast<int64_t>(ms_delta), static_cast<int32_t>(ns_delta)); in GetTask() 79 void TaskProcessor::UpdateTargetRunTime(Thread* self, HeapTask* task, uint64_t new_target_time) { in UpdateTargetRunTime() argument [all …]
|
D | heap-visit-objects-inl.h | 39 Thread* self = Thread::Current(); in VisitObjects() local 40 Locks::mutator_lock_->AssertSharedHeld(self); in VisitObjects() 41 DCHECK(!Locks::mutator_lock_->IsExclusiveHeld(self)) << "Call VisitObjectsPaused() instead"; in VisitObjects() 51 IncrementDisableMovingGC(self); in VisitObjects() 53 ScopedThreadSuspension sts(self, kWaitingForVisitObjects); in VisitObjects() 58 DecrementDisableMovingGC(self); in VisitObjects() 62 self->PoisonObjectPointers(); in VisitObjects() 67 self->PoisonObjectPointers(); in VisitObjects() 73 Thread* self = Thread::Current(); in VisitObjectsPaused() local 74 Locks::mutator_lock_->AssertExclusiveHeld(self); in VisitObjectsPaused() [all …]
|
/art/test/712-varhandle-invocations/util-src/ |
D | generate_java.py | 31 def __init__(self, name, examples, supports_bitwise=False, supports_numeric=False): argument 32 self.name=name 33 self.examples=examples 34 self.supports_bitwise=supports_bitwise 35 self.supports_numeric=supports_numeric 37 def is_value_type(self): argument 40 def __repr__(self): argument 41 return self.name 43 def __str__(self): argument 44 return self.name [all …]
|
/art/test/971-iface-super/util-src/ |
D | generate_java.py | 43 def __init__(self, inner): argument 44 self.inner = inner 46 def get_name(self): argument 48 return self.inner.get_name() 50 def __str__(self): argument 52 for line in str(self.inner).splitlines(keepends = True): 58 def __init__(self, sources, javac, temp_dir, classes_dir): argument 59 self.javac = javac 60 self.temp_dir = temp_dir 61 self.classes_dir = classes_dir [all …]
|
/art/test/968-default-partial-compile-gen/util-src/ |
D | generate_java.py | 43 def __init__(self, inner): argument 44 self.inner = inner 46 def get_name(self): argument 48 return self.inner.get_name() 50 def __str__(self): argument 52 for line in str(self.inner).splitlines(keepends = True): 58 def __init__(self, sources, javac, temp_dir, classes_dir): argument 59 self.javac = javac 60 self.temp_dir = temp_dir 61 self.classes_dir = classes_dir [all …]
|
/art/test/203-multi-checkpoint/ |
D | multi_checkpoint.cc | 31 void Run(Thread* self) override { in Run() 32 CHECK_EQ(self, Thread::Current()) << "Not running on target thread!"; in Run() 38 ScopedObjectAccess soa(self); in Run() 39 self->FullSuspendCheck(); in Run() 65 void Run(Thread* self) override { in Run() 66 CHECK_EQ(self, Thread::Current()) << "Not running on target thread!"; in Run() 67 ScopedObjectAccess soa(self); in Run() 68 MutexLock tscl_mu(self, *Locks::thread_suspend_count_lock_); in Run() 70 CHECK(self->RequestCheckpoint(&gTestClosure)) << "Could not set first checkpoint."; in Run() 71 CHECK(self->RequestCheckpoint(&gTestClosure)) << "Could not set second checkpoint."; in Run() [all …]
|
/art/runtime/entrypoints/quick/ |
D | quick_field_entrypoints.cc | 37 Thread* self, in FindInstanceField() argument 42 StackHandleScope<1> hs(self); in FindInstanceField() 44 ArtField* field = FindFieldFromCode<type, kAccessCheck>(field_idx, referrer, self, size); in FindInstanceField() 52 static ArtMethod* GetReferrer(Thread* self) REQUIRES_SHARED(Locks::mutator_lock_) { in GetReferrer() argument 56 ArtMethod* outer = GetCalleeSaveOuterMethod(self, CalleeSaveType::kSaveRefsOnly); in GetReferrer() 61 return GetCalleeSaveMethodCallerAndOuterMethod(self, CalleeSaveType::kSaveRefsOnly).caller; in GetReferrer() 73 Thread* self) \ 75 ScopedQuickEntrypointChecks sqec(self); \ 83 field_idx, referrer, self, sizeof(PrimitiveType)); \ 94 Thread* self) \ [all …]
|
D | quick_deoptimization_entrypoints.cc | 28 NO_RETURN static void artDeoptimizeImpl(Thread* self, DeoptimizationKind kind, bool single_frame) in artDeoptimizeImpl() argument 37 self->Dump(LOG_STREAM(INFO)); in artDeoptimizeImpl() 41 self->AssertHasDeoptimizationContext(); in artDeoptimizeImpl() 42 QuickExceptionHandler exception_handler(self, true); in artDeoptimizeImpl() 60 extern "C" NO_RETURN void artDeoptimize(Thread* self) REQUIRES_SHARED(Locks::mutator_lock_) { in artDeoptimize() argument 61 ScopedQuickEntrypointChecks sqec(self); in artDeoptimize() 62 artDeoptimizeImpl(self, DeoptimizationKind::kFullFrame, false); in artDeoptimize() 66 extern "C" NO_RETURN void artDeoptimizeFromCompiledCode(DeoptimizationKind kind, Thread* self) in artDeoptimizeFromCompiledCode() argument 68 ScopedQuickEntrypointChecks sqec(self); in artDeoptimizeFromCompiledCode() 72 self->PushDeoptimizationContext(return_value, in artDeoptimizeFromCompiledCode() [all …]
|
D | quick_lock_entrypoints.cc | 23 extern "C" int artLockObjectFromCode(mirror::Object* obj, Thread* self) in artLockObjectFromCode() argument 27 ScopedQuickEntrypointChecks sqec(self); in artLockObjectFromCode() 32 ObjPtr<mirror::Object> object = obj->MonitorEnter(self); // May block in artLockObjectFromCode() 33 DCHECK(self->HoldsLock(object)); in artLockObjectFromCode() 35 if (UNLIKELY(self->IsExceptionPending())) { in artLockObjectFromCode() 41 bool unlocked = object->MonitorExit(self); in artLockObjectFromCode() 45 DCHECK(self->HoldsLock(object)); in artLockObjectFromCode() 51 extern "C" int artUnlockObjectFromCode(mirror::Object* obj, Thread* self) in artUnlockObjectFromCode() argument 55 ScopedQuickEntrypointChecks sqec(self); in artUnlockObjectFromCode() 61 return obj->MonitorExit(self) ? 0 /* Success */ : -1 /* Failure */; in artUnlockObjectFromCode()
|
/art/test/648-many-direct-methods/util-src/ |
D | generate_java.py | 54 def __init__(self): argument 58 self.tests = set() 60 def add_test_method(self, num): argument 64 self.tests.add(TestMethod(num)) 66 def get_name(self): argument 72 def __str__(self): argument 76 all_tests = sorted(self.tests) 80 main_func = self.MAIN_FUNCTION_TEMPLATE 82 return self.MAIN_CLASS_TEMPLATE.format(copyright = get_copyright("java"), 95 def __init__(self, farg): argument [all …]
|
/art/runtime/arch/ |
D | stub_test.cc | 69 Thread::tls_ptr_sized_values* GetTlsPtr(Thread* self) { in GetTlsPtr() argument 70 return &self->tlsPtr_; in GetTlsPtr() 74 size_t Invoke3(size_t arg0, size_t arg1, size_t arg2, uintptr_t code, Thread* self) { in Invoke3() argument 75 return Invoke3WithReferrer(arg0, arg1, arg2, code, self, nullptr); in Invoke3() 79 size_t Invoke3WithReferrer(size_t arg0, size_t arg1, size_t arg2, uintptr_t code, Thread* self, in Invoke3WithReferrer() argument 81 return Invoke3WithReferrerAndHidden(arg0, arg1, arg2, code, self, referrer, 0); in Invoke3WithReferrer() 86 Thread* self, ArtMethod* referrer, size_t hidden) { in Invoke3WithReferrerAndHidden() argument 89 self->PushManagedStackFragment(&fragment); in Invoke3WithReferrerAndHidden() 179 : [arg0] "r"(arg0), [arg1] "r"(arg1), [arg2] "r"(arg2), [code] "r"(code), [self] "r"(self), in Invoke3WithReferrerAndHidden() 310 : [arg0] "0"(arg0), [arg1] "r"(arg1), [arg2] "r"(arg2), [code] "r"(code), [self] "r"(self), in Invoke3WithReferrerAndHidden() [all …]
|
/art/runtime/ |
D | thread_pool.cc | 100 Thread* self = Thread::Current(); in Run() local 102 thread_pool_->creation_barier_.Pass(self); in Run() 103 while ((task = thread_pool_->GetTask(self)) != nullptr) { in Run() 104 task->Run(self); in Run() 132 void ThreadPool::AddTask(Thread* self, Task* task) { in AddTask() argument 133 MutexLock mu(self, task_queue_lock_); in AddTask() 137 task_queue_condition_.Signal(self); in AddTask() 141 void ThreadPool::RemoveAllTasks(Thread* self) { in RemoveAllTasks() argument 145 while ((task = TryGetTask(self)) != nullptr) { in RemoveAllTasks() 148 MutexLock mu(self, task_queue_lock_); in RemoveAllTasks() [all …]
|
D | barrier_test.cc | 35 void Run(Thread* self) override { in Run() argument 36 LOG(INFO) << "Before barrier" << *self; in Run() 38 barrier_->Wait(self); in Run() 40 LOG(INFO) << "After barrier" << *self; in Run() 62 Thread* self = Thread::Current(); in TEST_F() local 69 thread_pool.AddTask(self, new CheckWaitTask(&barrier, &count1, &count2)); in TEST_F() 71 thread_pool.StartWorkers(self); in TEST_F() 73 timeout_barrier.Increment(self, 1, 100); // sleep 100 msecs in TEST_F() 78 barrier.Wait(self); in TEST_F() 80 thread_pool.Wait(self, true, false); in TEST_F() [all …]
|
D | monitor_pool_test.cc | 39 static void VerifyMonitor(Monitor* mon, Thread* self) { in VerifyMonitor() argument 43 EXPECT_EQ(MonitorPool::ComputeMonitorId(mon, self), mon->GetMonitorId()); in VerifyMonitor() 58 Thread* self = Thread::Current(); in TEST_F() local 59 ScopedObjectAccess soa(self); in TEST_F() 74 Monitor* mon = MonitorPool::CreateMonitor(self, self, nullptr, static_cast<int32_t>(i)); in TEST_F() 77 VerifyMonitor(mon, self); in TEST_F() 85 VerifyMonitor(mon, self); in TEST_F() 87 MonitorPool::ReleaseMonitor(self, mon); in TEST_F() 97 Monitor* mon = MonitorPool::CreateMonitor(self, self, nullptr, in TEST_F() 101 VerifyMonitor(mon, self); in TEST_F() [all …]
|