truffle: src/share/vm/runtime/thread.cpp comparison

comparison src/share/vm/runtime/thread.cpp @ 6725:da91efe96a93

6964458: Reimplement class meta-data storage to use native memory Summary: Remove PermGen, allocate meta-data in metaspace linked to class loaders, rewrite GC walking, rewrite and rename metadata to be C++ classes Reviewed-by: jmasa, stefank, never, coleenp, kvn, brutisso, mgerdin, dholmes, jrose, twisti, roland Contributed-by: jmasa <jon.masamitsu@oracle.com>, stefank <stefan.karlsson@oracle.com>, mgerdin <mikael.gerdin@oracle.com>, never <tom.rodriguez@oracle.com>

author	coleenp
date	Sat, 01 Sep 2012 13:25:18 -0400
parents	24b9c7f4cae6
children	33143ee07800

comparison

equal deleted inserted replaced

-:36d1d483d5d6
+:da91efe96a93
 #include "interpreter/interpreter.hpp"
 #include "interpreter/linkResolver.hpp"
 #include "interpreter/oopMapCache.hpp"
 #include "jvmtifiles/jvmtiEnv.hpp"
 #include "memory/gcLocker.inline.hpp"
+#include "memory/metaspaceShared.hpp"
 #include "memory/oopFactory.hpp"
 #include "memory/universe.inline.hpp"
 #include "oops/instanceKlass.hpp"
 #include "oops/objArrayOop.hpp"
 #include "oops/oop.inline.hpp"
 // allocated data structures
 set_osthread(NULL);
 set_resource_area(new (mtThread)ResourceArea());
 set_handle_area(new (mtThread) HandleArea(NULL));
+set_metadata_handles(new (ResourceObj::C_HEAP, mtClass) GrowableArray<Metadata*>(300, true));
 set_active_handles(NULL);
 set_free_handle_block(NULL);
 set_last_handle_mark(NULL);
 // This initial value ==> never claimed.
 ParkEvent::Release (_SleepEvent)  ; _SleepEvent  = NULL ;
 ParkEvent::Release (_MutexEvent)  ; _MutexEvent  = NULL ;
 ParkEvent::Release (_MuxEvent)    ; _MuxEvent    = NULL ;
 delete handle_area();
+delete metadata_handles();
 // osthread() can be NULL, if creation of thread failed.
 if (osthread() != NULL) os::free_thread(osthread());
 delete _SR_lock;
 void Thread::nmethods_do(CodeBlobClosure* cf) {
 // no nmethods in a generic thread...
 }
+void Thread::metadata_do(void f(Metadata*)) {
+if (metadata_handles() != NULL) {
+for (int i = 0; i< metadata_handles()->length(); i++) {
+f(metadata_handles()->at(i));
+}
+}
+}
 void Thread::print_on(outputStream* st) const {
 // get_priority assumes osthread initialized
 if (osthread() != NULL) {
 st->print("prio=%d tid=" INTPTR_FORMAT " ", get_priority(this), this);
 osthread()->print_on(st);
 #endif
 bool Thread::is_in_stack(address adr) const {
 assert(Thread::current() == this, "is_in_stack can only be called from current thread");
 address end = os::current_stack_pointer();
+// Allow non Java threads to call this without stack_base
+if (_stack_base == NULL) return true;
 if (stack_base() >= adr && adr >= end) return true;
 return false;
 }
 // NOTE: this must be called inside the main thread.
 return os::create_main_thread((JavaThread*)this);
 }
 static void initialize_class(Symbol* class_name, TRAPS) {
-klassOop klass = SystemDictionary::resolve_or_fail(class_name, true, CHECK);
+Klass* klass = SystemDictionary::resolve_or_fail(class_name, true, CHECK);
-instanceKlass::cast(klass)->initialize(CHECK);
+InstanceKlass::cast(klass)->initialize(CHECK);
 }
 // Creates the initial ThreadGroup
 static Handle create_initial_thread_group(TRAPS) {
-klassOop k = SystemDictionary::resolve_or_fail(vmSymbols::java_lang_ThreadGroup(), true, CHECK_NH);
+Klass* k = SystemDictionary::resolve_or_fail(vmSymbols::java_lang_ThreadGroup(), true, CHECK_NH);
 instanceKlassHandle klass (THREAD, k);
 Handle system_instance = klass->allocate_instance_handle(CHECK_NH);
 {
 JavaValue result(T_VOID);
 return main_instance;
 }
 // Creates the initial Thread
 static oop create_initial_thread(Handle thread_group, JavaThread* thread, TRAPS) {
-klassOop k = SystemDictionary::resolve_or_fail(vmSymbols::java_lang_Thread(), true, CHECK_NULL);
+Klass* k = SystemDictionary::resolve_or_fail(vmSymbols::java_lang_Thread(), true, CHECK_NULL);
 instanceKlassHandle klass (THREAD, k);
 instanceHandle thread_oop = klass->allocate_instance_handle(CHECK_NULL);
 java_lang_Thread::set_thread(thread_oop(), thread);
 java_lang_Thread::set_priority(thread_oop(), NormPriority);
 CHECK_NULL);
 return thread_oop();
 }
 static void call_initializeSystemClass(TRAPS) {
-klassOop k =  SystemDictionary::resolve_or_fail(vmSymbols::java_lang_System(), true, CHECK);
+Klass* k =  SystemDictionary::resolve_or_fail(vmSymbols::java_lang_System(), true, CHECK);
 instanceKlassHandle klass (THREAD, k);
 JavaValue result(T_VOID);
 JavaCalls::call_static(&result, klass, vmSymbols::initializeSystemClass_name(),
 vmSymbols::void_method_signature(), CHECK);
 char java_runtime_name[128] = "";
 // extract the JRE name from sun.misc.Version.java_runtime_name
 static const char* get_java_runtime_name(TRAPS) {
-klassOop k = SystemDictionary::find(vmSymbols::sun_misc_Version(),
+Klass* k = SystemDictionary::find(vmSymbols::sun_misc_Version(),
 Handle(), Handle(), CHECK_AND_CLEAR_NULL);
 fieldDescriptor fd;
 bool found = k != NULL &&
-instanceKlass::cast(k)->find_local_field(vmSymbols::java_runtime_name_name(),
+InstanceKlass::cast(k)->find_local_field(vmSymbols::java_runtime_name_name(),
 vmSymbols::string_signature(), &fd);
 if (found) {
 oop name_oop = k->java_mirror()->obj_field(fd.offset());
 if (name_oop == NULL)
 return NULL;
 }
 // General purpose hook into Java code, run once when the VM is initialized.
 // The Java library method itself may be changed independently from the VM.
 static void call_postVMInitHook(TRAPS) {
-klassOop k = SystemDictionary::PostVMInitHook_klass();
+Klass* k = SystemDictionary::PostVMInitHook_klass();
 instanceKlassHandle klass (THREAD, k);
 if (klass.not_null()) {
 JavaValue result(T_VOID);
 JavaCalls::call_static(&result, klass, vmSymbols::run_method_name(),
 vmSymbols::void_method_signature(),
 // the vm info string
 ResourceMark rm(THREAD);
 const char *vm_info = VM_Version::vm_info_string();
 // java.lang.System class
-klassOop k =  SystemDictionary::resolve_or_fail(vmSymbols::java_lang_System(), true, CHECK);
+Klass* k =  SystemDictionary::resolve_or_fail(vmSymbols::java_lang_System(), true, CHECK);
 instanceKlassHandle klass (THREAD, k);
 // setProperty arguments
 Handle key_str    = java_lang_String::create_from_str("java.vm.info", CHECK);
 Handle value_str  = java_lang_String::create_from_str(vm_info, CHECK);
 void JavaThread::allocate_threadObj(Handle thread_group, char* thread_name, bool daemon, TRAPS) {
 assert(thread_group.not_null(), "thread group should be specified");
 assert(threadObj() == NULL, "should only create Java thread object once");
-klassOop k = SystemDictionary::resolve_or_fail(vmSymbols::java_lang_Thread(), true, CHECK);
+Klass* k = SystemDictionary::resolve_or_fail(vmSymbols::java_lang_Thread(), true, CHECK);
 instanceKlassHandle klass (THREAD, k);
 instanceHandle thread_oop = klass->allocate_instance_handle(CHECK);
 java_lang_Thread::set_thread(thread_oop(), this);
 java_lang_Thread::set_priority(thread_oop(), NormPriority);
 tty->print("Async. exception installed at runtime exit (" INTPTR_FORMAT ")", this);
 if (has_last_Java_frame() ) {
 frame f = last_frame();
 tty->print(" (pc: " INTPTR_FORMAT " sp: " INTPTR_FORMAT " )", f.pc(), f.sp());
 }
-tty->print_cr(" of type: %s", instanceKlass::cast(_pending_async_exception->klass())->external_name());
+tty->print_cr(" of type: %s", InstanceKlass::cast(_pending_async_exception->klass())->external_name());
 }
 _pending_async_exception = NULL;
 clear_has_async_exception();
 }
 }
 // Set async. pending exception in thread.
 set_pending_async_exception(java_throwable);
 if (TraceExceptions) {
 ResourceMark rm;
-tty->print_cr("Pending Async. exception installed of type: %s", instanceKlass::cast(_pending_async_exception->klass())->external_name());
+tty->print_cr("Pending Async. exception installed of type: %s", InstanceKlass::cast(_pending_async_exception->klass())->external_name());
 }
 // for AbortVMOnException flag
-NOT_PRODUCT(Exceptions::debug_check_abort(instanceKlass::cast(_pending_async_exception->klass())->external_name()));
+NOT_PRODUCT(Exceptions::debug_check_abort(InstanceKlass::cast(_pending_async_exception->klass())->external_name()));
 }
 }
 // Interrupt thread so it will wake up from a potential wait()
 // Traverse instance variables at the end since the GC may be moving things
 // around using this function
 f->do_oop((oop*) &_threadObj);
 f->do_oop((oop*) &_vm_result);
-f->do_oop((oop*) &_vm_result_2);
 f->do_oop((oop*) &_exception_oop);
 f->do_oop((oop*) &_pending_async_exception);
 if (jvmti_thread_state() != NULL) {
 jvmti_thread_state()->oops_do(f);
 if (has_last_Java_frame()) {
 // Traverse the execution stack
 for(StackFrameStream fst(this); !fst.is_done(); fst.next()) {
 fst.current()->nmethods_do(cf);
+}
+}
+}
+void JavaThread::metadata_do(void f(Metadata*)) {
+Thread::metadata_do(f);
+if (has_last_Java_frame()) {
+// Traverse the execution stack to call f() on the methods in the stack
+for(StackFrameStream fst(this); !fst.is_done(); fst.next()) {
+fst.current()->metadata_do(f);
+}
+} else if (is_Compiler_thread()) {
+// need to walk ciMetadata in current compile tasks to keep alive.
+CompilerThread* ct = (CompilerThread*)this;
+if (ct->env() != NULL) {
+ct->env()->metadata_do(f);
 }
 }
 }
 // Printing
 // Set the thread field (a JavaThread *) of the
 // oop representing the java_lang_Thread to the new thread (a JavaThread *).
 Handle thread_oop(Thread::current(),
 JNIHandles::resolve_non_null(jni_thread));
-assert(instanceKlass::cast(thread_oop->klass())->is_linked(),
+assert(InstanceKlass::cast(thread_oop->klass())->is_linked(),
 "must be initialized");
 set_threadObj(thread_oop());
 java_lang_Thread::set_thread(thread_oop(), this);
 if (prio == NoPriority) {
 }
 return NULL;
 }
-klassOop JavaThread::security_get_caller_class(int depth) {
+Klass* JavaThread::security_get_caller_class(int depth) {
 vframeStream vfst(this);
 vfst.security_get_caller_frame(depth);
 if (!vfst.at_end()) {
 return vfst.method()->method_holder();
 }
 JavaThread* Threads::_thread_list = NULL;
 int         Threads::_number_of_threads = 0;
 int         Threads::_number_of_non_daemon_threads = 0;
 int         Threads::_return_code = 0;
 size_t      JavaThread::_stack_size_at_create = 0;
+#ifdef ASSERT
+bool        Threads::_vm_complete = false;
+#endif
 // All JavaThreads
 #define ALL_JAVA_THREADS(X) for (JavaThread* X = _thread_list; X; X = X->next())
 void os_stream();
 EXCEPTION_MARK;
 // At this point, the Universe is initialized, but we have not executed
 // any byte code.  Now is a good time (the only time) to dump out the
 // internal state of the JVM for sharing.
 if (DumpSharedSpaces) {
-Universe::heap()->preload_and_dump(CHECK_0);
+MetaspaceShared::preload_and_dump(CHECK_0);
 ShouldNotReachHere();
 }
 // Always call even when there are not JVMTI environments yet, since environments
 // may be attached late and JVMTI must track phases of VM execution
 if (AggressiveOpts) {
 {
 // Forcibly initialize java/util/HashMap and mutate the private
 // static final "frontCacheEnabled" field before we start creating instances
 #ifdef ASSERT
-klassOop tmp_k = SystemDictionary::find(vmSymbols::java_util_HashMap(), Handle(), Handle(), CHECK_0);
+Klass* tmp_k = SystemDictionary::find(vmSymbols::java_util_HashMap(), Handle(), Handle(), CHECK_0);
 assert(tmp_k == NULL, "java/util/HashMap should not be loaded yet");
 #endif
-klassOop k_o = SystemDictionary::resolve_or_null(vmSymbols::java_util_HashMap(), Handle(), Handle(), CHECK_0);
+Klass* k_o = SystemDictionary::resolve_or_null(vmSymbols::java_util_HashMap(), Handle(), Handle(), CHECK_0);
 KlassHandle k = KlassHandle(THREAD, k_o);
 guarantee(k.not_null(), "Must find java/util/HashMap");
 instanceKlassHandle ik = instanceKlassHandle(THREAD, k());
 ik->initialize(CHECK_0);
 fieldDescriptor fd;
 }
 if (UseStringCache) {
 // Forcibly initialize java/lang/StringValue and mutate the private
 // static final "stringCacheEnabled" field before we start creating instances
-klassOop k_o = SystemDictionary::resolve_or_null(vmSymbols::java_lang_StringValue(), Handle(), Handle(), CHECK_0);
+Klass* k_o = SystemDictionary::resolve_or_null(vmSymbols::java_lang_StringValue(), Handle(), Handle(), CHECK_0);
 // Possible that StringValue isn't present: if so, silently don't break
 if (k_o != NULL) {
 KlassHandle k = KlassHandle(THREAD, k_o);
 instanceKlassHandle ik = instanceKlassHandle(THREAD, k());
 ik->initialize(CHECK_0);
 // Give os specific code one last chance to start
 os::init_3();
 create_vm_timer.end();
+#ifdef ASSERT
+_vm_complete = true;
+#endif
 return JNI_OK;
 }
 // type for the Agent_OnLoad and JVM_OnLoad entry points
 extern "C" {
 if (this->has_pending_exception()) {
 this->clear_pending_exception();
 }
 EXCEPTION_MARK;
-klassOop k =
+Klass* k =
 SystemDictionary::resolve_or_null(vmSymbols::java_lang_Shutdown(),
 THREAD);
 if (k != NULL) {
 // SystemDictionary::resolve_or_null will return null if there was
 // an exception.  If we cannot load the Shutdown class, just don't
 //   + Return to caller
 bool Threads::destroy_vm() {
 JavaThread* thread = JavaThread::current();
+#ifdef ASSERT
+_vm_complete = false;
+#endif
 // Wait until we are the last non-daemon thread to execute
 { MutexLocker nu(Threads_lock);
 while (Threads::number_of_non_daemon_threads() > 1 )
 // This wait should make safepoint checks, wait without a timeout,
 // and wait as a suspend-equivalent condition.
 void Threads::nmethods_do(CodeBlobClosure* cf) {
 ALL_JAVA_THREADS(p) {
 p->nmethods_do(cf);
 }
 VMThread::vm_thread()->nmethods_do(cf);
+}
+void Threads::metadata_do(void f(Metadata*)) {
+ALL_JAVA_THREADS(p) {
+p->metadata_do(f);
+}
 }
 void Threads::gc_epilogue() {
 ALL_JAVA_THREADS(p) {
 p->gc_epilogue();

Mercurial > hg > truffle

comparison src/share/vm/runtime/thread.cpp @ 6725:da91efe96a93