/openjdk7/jdk/src/share/classes/sun/nio/ch/ |
H A D | ServerSocketChannelImpl.java | 56 // ID of native thread currently blocked in this channel, for signalling 57 private volatile long thread = 0; field in class:ServerSocketChannelImpl 59 // Lock held by thread currently blocked in this channel 62 // Lock held by any thread that modifies the state fields declared below 239 thread = NativeThread.current(); 247 thread = 0; 281 long th = thread;
|
/openjdk7/jdk/src/solaris/classes/sun/nio/ch/ |
H A D | SctpServerChannelImpl.java | 55 /* IDs of native thread doing accept, for signalling */ 56 private volatile long thread = 0; field in class:SctpServerChannelImpl 58 /* Lock held by thread currently blocked in this channel */ 61 /* Lock held by any thread that modifies the state fields declared below 200 thread = 0; 223 thread = NativeThread.current(); 261 if (thread != 0) 262 NativeThread.signal(thread); 279 // Postpone the kill if there is a thread in accept 280 if (thread [all...] |
/openjdk7/jdk/src/share/classes/java/util/concurrent/ |
H A D | Phaser.java | 94 * waiting thread is interrupted. Interruptible and timeout 498 * parent, and initial phase number 0. Any thread using this 737 * @throws InterruptedException if thread interrupted while waiting 772 * @throws InterruptedException if thread interrupted while waiting 965 Thread t; // its thread 970 (t = q.thread) != null) { 971 q.thread = null; 992 if (q == null || ((t = q.thread) != null && q.phase == p)) 995 q.thread = null; 1009 * avoid it when threads regularly arrive: When a thread i 1086 volatile Thread thread; // nulled to cancel wait field in class:Phaser.QNode [all...] |
/openjdk7/jdk/src/share/classes/java/util/concurrent/locks/ |
H A D | ReentrantReadWriteLock.java | 65 * is released either the longest-waiting single writer thread will 70 * <p>A thread that tries to acquire a fair read lock (non-reentrantly) 72 * writer thread. The thread will not acquire the read lock until 73 * after the oldest currently waiting writer thread has acquired and 79 * <p>A thread that tries to acquire a fair write lock (non-reentrantly) 93 * thread have been released. 150 * // Recheck state because another thread might have 276 * A counter for per-thread read hold counts. 297 * The number of reentrant read locks held by current thread 1364 hasQueuedThread(Thread thread) argument [all...] |
/openjdk7/hotspot/src/share/vm/ci/ |
H A D | ciInstanceKlass.cpp | 64 Thread *thread = Thread::current(); local 66 _loader = JNIHandles::make_local(thread, ik->class_loader()); 67 _protection_domain = JNIHandles::make_local(thread, 71 Handle h_loader(thread, ik->class_loader()); 72 Handle h_protection_domain(thread, ik->protection_domain());
|
/openjdk7/hotspot/src/share/vm/classfile/ |
H A D | dictionary.cpp | 441 // thread is running), and are added to in a safe way (all links must 541 Thread *thread = Thread::current(); local 548 unsigned int hash = compute_hash(class_name, Handle(thread, p->loader()));
|
H A D | placeholders.hpp | 28 #include "runtime/thread.hpp" 77 // and the rest of the threads return the result the first thread gets 90 Thread* thread); 97 Symbol* name, Handle loader, Thread* thread); 118 // result the first thread gets. 125 SeenThread(Thread *thread) { argument 126 _thread = thread; 130 Thread* thread() const { return _thread;} function in class:SeenThread 131 void set_thread(Thread *thread) { _thread = thread; } argument 272 add_seen_thread(Thread* thread, PlaceholderTable::classloadAction action) argument 290 check_seen_thread(Thread* thread, PlaceholderTable::classloadAction action) argument 308 remove_seen_thread(Thread* thread, PlaceholderTable::classloadAction action) argument [all...] |
/openjdk7/hotspot/src/share/vm/code/ |
H A D | compiledIC.cpp | 311 Thread *thread = Thread::current(); local 323 methodHandle method (thread, (methodOop)info.cached_oop()()); 326 ResourceMark rm(thread); 337 ResourceMark rm(thread); 362 ResourceMark rm(thread);
|
/openjdk7/hotspot/src/share/vm/oops/ |
H A D | instanceKlassKlass.cpp | 615 Thread *thread = Thread::current(); local 626 Handle h_loader (thread, ik->class_loader()); 627 Handle h_obj(thread, obj); 636 ResourceMark rm(thread);
|
/openjdk7/hotspot/src/share/vm/opto/ |
H A D | idealKit.hpp | 195 Node* thread() { return gvn().transform(new (C) ThreadLocalNode()); } function in class:IdealKit
|
/openjdk7/jdk/src/share/classes/com/sun/jmx/remote/internal/ |
H A D | ClientNotifForwarder.java | 67 Runnable. It uses at most one thread -- as soon as there is 68 no pending Runnable the thread can exit. Another thread is 81 a new thread when a new task is submitted and the number of 91 if (thread == null) { 92 thread = new Thread() { 100 thread = null; 111 thread.setDaemon(true); 112 thread.setName("ClientNotifForwarder-" + ++threadId); 113 thread 118 private Thread thread; field in class:ClientNotifForwarder.LinearExecutor [all...] |
/openjdk7/jdk/src/share/classes/com/sun/tools/example/debug/gui/ |
H A D | SourceTool.java | 203 private void showSourceContext(ThreadReference thread, int index) { argument 206 if (thread != null) { 208 frame = thread.frame(index);
|
/openjdk7/hotspot/src/cpu/sparc/vm/ |
H A D | frame_sparc.cpp | 177 bool frame::safe_for_sender(JavaThread *thread) { 183 bool sp_safe = (_SP <= thread->stack_base()) && 184 (_SP >= thread->stack_base() - thread->stack_size()); 191 bool unextended_sp_safe = (_UNEXTENDED_SP <= thread->stack_base()) && 197 bool fp_safe = (_FP <= thread->stack_base()) && 236 bool jcw_safe = (jcw <= thread->stack_base()) && ( jcw > _FP); 269 bool sender_fp_safe = (sender_fp <= thread->stack_base()) && 279 return sender.is_interpreted_frame_valid(thread); 297 bool jcw_safe = (jcw <= thread 552 patch_pc(Thread* thread, address pc) argument 719 make_walkable(JavaThread* thread) argument [all...] |
/openjdk7/hotspot/src/cpu/x86/vm/ |
H A D | frame_x86.cpp | 54 bool frame::safe_for_sender(JavaThread *thread) { argument 61 size_t usable_stack_size = thread->stack_size() - stack_guard_size; 64 bool sp_safe = (sp < thread->stack_base()) && 65 (sp >= thread->stack_base() - usable_stack_size); 73 bool unextended_sp_safe = (unextended_sp < thread->stack_base()) && 82 bool fp_safe = (fp < thread->stack_base() && (fp > sp) && (((fp + (return_addr_offset * sizeof(void*))) < thread->stack_base()))); 122 bool jcw_safe = (jcw < thread->stack_base()) && ( jcw > fp); 156 bool saved_fp_safe = ((address)saved_fp < thread->stack_base()) && (saved_fp > sender_sp); 166 return sender.is_interpreted_frame_valid(thread); 266 patch_pc(Thread* thread, address pc) argument [all...] |
/openjdk7/hotspot/src/cpu/zero/vm/ |
H A D | stubGenerator_zero.cpp | 69 JavaThread *thread = (JavaThread *) THREAD; local 70 ZeroStack *stack = thread->zero_stack(); 78 size_t zero_stack_size = stack->suggest_size(thread); 89 thread->push_zero_frame(frame); 118 thread->pop_zero_frame();
|
/openjdk7/hotspot/src/os/bsd/vm/ |
H A D | attachListener_bsd.cpp | 43 // thread is created at startup or is created on-demand via a signal from 234 // means that the attach listener thread is blocked. 409 JavaThread* thread = JavaThread::current(); local 410 ThreadBlockInVM tbivm(thread); 412 thread->set_suspend_equivalent(); 431 thread->check_and_wait_while_suspended(); 440 JavaThread* thread = JavaThread::current(); local 441 ThreadBlockInVM tbivm(thread); 443 thread->set_suspend_equivalent(); 450 thread 456 JavaThread* thread = JavaThread::current(); local [all...] |
/openjdk7/hotspot/src/os/linux/vm/ |
H A D | attachListener_linux.cpp | 43 // thread is created at startup or is created on-demand via a signal from 229 // means that the attach listener thread is blocked. 392 JavaThread* thread = JavaThread::current(); local 393 ThreadBlockInVM tbivm(thread); 395 thread->set_suspend_equivalent(); 414 thread->check_and_wait_while_suspended(); 423 JavaThread* thread = JavaThread::current(); local 424 ThreadBlockInVM tbivm(thread); 426 thread->set_suspend_equivalent(); 433 thread 439 JavaThread* thread = JavaThread::current(); local [all...] |
/openjdk7/hotspot/src/os_cpu/bsd_zero/vm/ |
H A D | os_bsd_zero.cpp | 151 JavaThread* thread = NULL; local 156 thread = (JavaThread*)t; 164 if (info != NULL && thread != NULL) { 169 // check if fault address is within thread stack 170 if (addr < thread->stack_base() && 171 addr >= thread->stack_base() - thread->stack_size()) { 173 if (thread->in_stack_yellow_zone(addr)) { 174 thread->disable_stack_yellow_zone(); 177 else if (thread [all...] |
/openjdk7/hotspot/src/os_cpu/linux_x86/vm/ |
H A D | os_linux_x86.cpp | 127 // For Forte Analyzer AsyncGetCallTrace profiling support - thread 132 ExtendedPC os::Linux::fetch_frame_from_ucontext(Thread* thread, argument 135 assert(thread != NULL, "just checking"); 245 JavaThread* thread = NULL; local 250 thread = (JavaThread*)t; 272 if (info != NULL && uc != NULL && thread != NULL) { 290 // check if fault address is within thread stack 291 if (addr < thread->stack_base() && 292 addr >= thread->stack_base() - thread [all...] |
/openjdk7/hotspot/src/os_cpu/linux_zero/vm/ |
H A D | os_linux_zero.cpp | 146 JavaThread* thread = NULL; local 151 thread = (JavaThread*)t; 159 if (info != NULL && thread != NULL) { 164 // check if fault address is within thread stack 165 if (addr < thread->stack_base() && 166 addr >= thread->stack_base() - thread->stack_size()) { 168 if (thread->in_stack_yellow_zone(addr)) { 169 thread->disable_stack_yellow_zone(); 172 else if (thread [all...] |
/openjdk7/hotspot/src/share/vm/prims/ |
H A D | jvmtiExport.hpp | 127 static void post_field_modification(JavaThread *thread, methodOop method, address location, 227 static void at_single_stepping_point(JavaThread *thread, methodOop method, address location); 228 static void expose_single_stepping(JavaThread *thread); 229 static bool hide_single_stepping(JavaThread *thread); 236 static void post_single_step (JavaThread *thread, methodOop method, address location); 237 static void post_raw_breakpoint (JavaThread *thread, methodOop method, address location); 239 static void post_exception_throw (JavaThread *thread, methodOop method, address location, oop exception); 240 static void notice_unwind_due_to_exception (JavaThread *thread, methodOop method, address location, oop exception, bool in_handler_frame); 242 static oop jni_GetField_probe (JavaThread *thread, jobject jobj, 244 static oop jni_GetField_probe_nh (JavaThread *thread, jobjec 479 JvmtiHideSingleStepping(JavaThread * thread) argument [all...] |
/openjdk7/hotspot/src/share/vm/runtime/ |
H A D | advancedThresholdPolicy.cpp | 213 // how many methods per compiler thread can be in the queue before 426 void AdvancedThresholdPolicy::submit_compile(methodHandle mh, int bci, CompLevel level, JavaThread* thread) { argument 429 CompileBroker::compile_method(mh, bci, level, mh, hot_count, "tiered", thread); 434 CompLevel level, nmethod* nm, JavaThread* thread) { 436 create_mdo(mh, thread); 441 compile(mh, InvocationEntryBci, next_level, thread); 449 int bci, CompLevel level, nmethod* nm, JavaThread* thread) { 451 create_mdo(mh, thread); 455 create_mdo(imh, thread); 463 compile(imh, bci, next_osr_level, thread); 433 method_invocation_event(methodHandle mh, methodHandle imh, CompLevel level, nmethod* nm, JavaThread* thread) argument 448 method_back_branch_event(methodHandle mh, methodHandle imh, int bci, CompLevel level, nmethod* nm, JavaThread* thread) argument [all...] |
H A D | compilationPolicy.cpp | 42 #include "runtime/thread.hpp" 149 // Setup the compiler thread numbers 310 int bci, CompLevel comp_level, nmethod* nm, JavaThread* thread) { 313 if (JvmtiExport::can_post_interpreter_events() && thread->is_interp_only_mode()) { 315 // thread is forced to remain in interpreted code. This is 329 method_invocation_event(method, thread); 345 method_back_branch_event(method, bci, thread); 396 void SimpleCompPolicy::method_invocation_event(methodHandle m, JavaThread* thread) { argument 405 CompileBroker::compile_method(m, InvocationEntryBci, comp_level, m, hot_count, comment, thread); 410 void SimpleCompPolicy::method_back_branch_event(methodHandle m, int bci, JavaThread* thread) { argument 309 event(methodHandle method, methodHandle inlinee, int branch_bci, int bci, CompLevel comp_level, nmethod* nm, JavaThread* thread) argument 427 method_invocation_event(methodHandle m, JavaThread* thread) argument 466 method_back_branch_event(methodHandle m, int bci, JavaThread* thread) argument [all...] |
H A D | interfaceSupport.hpp | 61 HandleMarkCleaner(Thread* thread) { argument 62 _thread = thread; 128 // Basic class for all thread transition classes. 134 ThreadStateTransition(JavaThread *thread) { argument 135 _thread = thread; 136 assert(thread != NULL && thread->is_Java_thread(), "must be Java thread"); 141 static inline void transition(JavaThread *thread, JavaThreadState from, JavaThreadState to) { argument 145 assert(thread 174 transition_and_fence(JavaThread *thread, JavaThreadState from, JavaThreadState to) argument 202 transition_from_java(JavaThread *thread, JavaThreadState to) argument 207 transition_from_native(JavaThread *thread, JavaThreadState to) argument 246 ThreadInVMfromJava(JavaThread* thread) argument 285 ThreadInVMfromNative(JavaThread* thread) argument 296 ThreadToNativeFromVM(JavaThread *thread) argument 315 ThreadBlockInVM(JavaThread *thread) argument 333 ThreadInVMfromJavaNoAsyncException(JavaThread* thread) argument [all...] |
H A D | java.cpp | 441 // are trying to shutdown the VM at the same time, only one thread 443 void before_exit(JavaThread * thread) { argument 452 // thread state for Safepoint. Here we use Monitor wait() and notify_all() 485 // Terminate watcher thread - must before disenrolling any periodic task 525 JvmtiExport::post_thread_end(thread); 531 event.set_javalangthread(java_lang_Thread::thread_id(thread->threadObj())); 540 // Terminate the signal thread 562 Thread* thread = ThreadLocalStorage::is_initialized() ? local 564 if (thread == NULL) { 572 if (thread 605 Thread* thread = ThreadLocalStorage::is_initialized() ? local [all...] |