src/share/vm/prims/jvmtiImpl.hpp

Fri, 11 Mar 2011 22:34:57 -0800

author
jrose
date
Fri, 11 Mar 2011 22:34:57 -0800
changeset 2639
8033953d67ff
parent 2583
f91db74a6810
child 2624
46a56fac55c7
permissions
-rw-r--r--

7012648: move JSR 292 to package java.lang.invoke and adjust names
Summary: package and class renaming only; delete unused methods and classes
Reviewed-by: twisti

duke@435 1 /*
kamg@2511 2 * Copyright (c) 1999, 2011, Oracle and/or its affiliates. All rights reserved.
duke@435 3 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
duke@435 4 *
duke@435 5 * This code is free software; you can redistribute it and/or modify it
duke@435 6 * under the terms of the GNU General Public License version 2 only, as
duke@435 7 * published by the Free Software Foundation.
duke@435 8 *
duke@435 9 * This code is distributed in the hope that it will be useful, but WITHOUT
duke@435 10 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
duke@435 11 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
duke@435 12 * version 2 for more details (a copy is included in the LICENSE file that
duke@435 13 * accompanied this code).
duke@435 14 *
duke@435 15 * You should have received a copy of the GNU General Public License version
duke@435 16 * 2 along with this work; if not, write to the Free Software Foundation,
duke@435 17 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
duke@435 18 *
trims@1907 19 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
trims@1907 20 * or visit www.oracle.com if you need additional information or have any
trims@1907 21 * questions.
duke@435 22 *
duke@435 23 */
duke@435 24
stefank@2314 25 #ifndef SHARE_VM_PRIMS_JVMTIIMPL_HPP
stefank@2314 26 #define SHARE_VM_PRIMS_JVMTIIMPL_HPP
stefank@2314 27
stefank@2314 28 #ifndef JVMTI_KERNEL
stefank@2325 29
stefank@2314 30 #include "classfile/systemDictionary.hpp"
stefank@2314 31 #include "jvmtifiles/jvmti.h"
stefank@2314 32 #include "oops/objArrayOop.hpp"
stefank@2314 33 #include "prims/jvmtiEnvThreadState.hpp"
stefank@2314 34 #include "prims/jvmtiEventController.hpp"
stefank@2314 35 #include "prims/jvmtiTrace.hpp"
stefank@2314 36 #include "prims/jvmtiUtil.hpp"
stefank@2314 37 #include "runtime/stackValueCollection.hpp"
stefank@2314 38 #include "runtime/vm_operations.hpp"
stefank@2314 39
duke@435 40 //
duke@435 41 // Forward Declarations
duke@435 42 //
duke@435 43
duke@435 44 class JvmtiBreakpoint;
duke@435 45 class JvmtiBreakpoints;
duke@435 46
duke@435 47
duke@435 48 ///////////////////////////////////////////////////////////////
duke@435 49 //
duke@435 50 // class GrowableCache, GrowableElement
duke@435 51 // Used by : JvmtiBreakpointCache
duke@435 52 // Used by JVMTI methods: none directly.
duke@435 53 //
duke@435 54 // GrowableCache is a permanent CHeap growable array of <GrowableElement *>
duke@435 55 //
duke@435 56 // In addition, the GrowableCache maintains a NULL terminated cache array of type address
duke@435 57 // that's created from the element array using the function:
duke@435 58 // address GrowableElement::getCacheValue().
duke@435 59 //
duke@435 60 // Whenever the GrowableArray changes size, the cache array gets recomputed into a new C_HEAP allocated
duke@435 61 // block of memory. Additionally, every time the cache changes its position in memory, the
duke@435 62 // void (*_listener_fun)(void *this_obj, address* cache)
duke@435 63 // gets called with the cache's new address. This gives the user of the GrowableCache a callback
duke@435 64 // to update its pointer to the address cache.
duke@435 65 //
duke@435 66
duke@435 67 class GrowableElement : public CHeapObj {
duke@435 68 public:
duke@435 69 virtual address getCacheValue() =0;
duke@435 70 virtual bool equals(GrowableElement* e) =0;
duke@435 71 virtual bool lessThan(GrowableElement *e)=0;
duke@435 72 virtual GrowableElement *clone() =0;
duke@435 73 virtual void oops_do(OopClosure* f) =0;
duke@435 74 };
duke@435 75
duke@435 76 class GrowableCache VALUE_OBJ_CLASS_SPEC {
duke@435 77
duke@435 78 private:
duke@435 79 // Object pointer passed into cache & listener functions.
duke@435 80 void *_this_obj;
duke@435 81
duke@435 82 // Array of elements in the collection
duke@435 83 GrowableArray<GrowableElement *> *_elements;
duke@435 84
duke@435 85 // Parallel array of cached values
duke@435 86 address *_cache;
duke@435 87
duke@435 88 // Listener for changes to the _cache field.
duke@435 89 // Called whenever the _cache field has it's value changed
duke@435 90 // (but NOT when cached elements are recomputed).
duke@435 91 void (*_listener_fun)(void *, address*);
duke@435 92
duke@435 93 static bool equals(void *, GrowableElement *);
duke@435 94
duke@435 95 // recache all elements after size change, notify listener
duke@435 96 void recache();
duke@435 97
duke@435 98 public:
duke@435 99 GrowableCache();
duke@435 100 ~GrowableCache();
duke@435 101
duke@435 102 void initialize(void *this_obj, void listener_fun(void *, address*) );
duke@435 103
duke@435 104 // number of elements in the collection
duke@435 105 int length();
duke@435 106 // get the value of the index element in the collection
duke@435 107 GrowableElement* at(int index);
duke@435 108 // find the index of the element, -1 if it doesn't exist
duke@435 109 int find(GrowableElement* e);
duke@435 110 // append a copy of the element to the end of the collection, notify listener
duke@435 111 void append(GrowableElement* e);
duke@435 112 // insert a copy of the element using lessthan(), notify listener
duke@435 113 void insert(GrowableElement* e);
duke@435 114 // remove the element at index, notify listener
duke@435 115 void remove (int index);
duke@435 116 // clear out all elements and release all heap space, notify listener
duke@435 117 void clear();
duke@435 118 // apply f to every element and update the cache
duke@435 119 void oops_do(OopClosure* f);
kamg@2467 120 // update the cache after a full gc
kamg@2467 121 void gc_epilogue();
duke@435 122 };
duke@435 123
duke@435 124
duke@435 125 ///////////////////////////////////////////////////////////////
duke@435 126 //
duke@435 127 // class JvmtiBreakpointCache
duke@435 128 // Used by : JvmtiBreakpoints
duke@435 129 // Used by JVMTI methods: none directly.
duke@435 130 // Note : typesafe wrapper for GrowableCache of JvmtiBreakpoint
duke@435 131 //
duke@435 132
duke@435 133 class JvmtiBreakpointCache : public CHeapObj {
duke@435 134
duke@435 135 private:
duke@435 136 GrowableCache _cache;
duke@435 137
duke@435 138 public:
duke@435 139 JvmtiBreakpointCache() {}
duke@435 140 ~JvmtiBreakpointCache() {}
duke@435 141
duke@435 142 void initialize(void *this_obj, void listener_fun(void *, address*) ) {
duke@435 143 _cache.initialize(this_obj,listener_fun);
duke@435 144 }
duke@435 145
duke@435 146 int length() { return _cache.length(); }
duke@435 147 JvmtiBreakpoint& at(int index) { return (JvmtiBreakpoint&) *(_cache.at(index)); }
duke@435 148 int find(JvmtiBreakpoint& e) { return _cache.find((GrowableElement *) &e); }
duke@435 149 void append(JvmtiBreakpoint& e) { _cache.append((GrowableElement *) &e); }
duke@435 150 void remove (int index) { _cache.remove(index); }
duke@435 151 void clear() { _cache.clear(); }
duke@435 152 void oops_do(OopClosure* f) { _cache.oops_do(f); }
kamg@2467 153 void gc_epilogue() { _cache.gc_epilogue(); }
duke@435 154 };
duke@435 155
duke@435 156
duke@435 157 ///////////////////////////////////////////////////////////////
duke@435 158 //
duke@435 159 // class JvmtiBreakpoint
duke@435 160 // Used by : JvmtiBreakpoints
duke@435 161 // Used by JVMTI methods: SetBreakpoint, ClearBreakpoint, ClearAllBreakpoints
duke@435 162 // Note: Extends GrowableElement for use in a GrowableCache
duke@435 163 //
duke@435 164 // A JvmtiBreakpoint describes a location (class, method, bci) to break at.
duke@435 165 //
duke@435 166
duke@435 167 typedef void (methodOopDesc::*method_action)(int _bci);
duke@435 168
duke@435 169 class JvmtiBreakpoint : public GrowableElement {
duke@435 170 private:
duke@435 171 methodOop _method;
duke@435 172 int _bci;
duke@435 173 Bytecodes::Code _orig_bytecode;
duke@435 174
duke@435 175 public:
duke@435 176 JvmtiBreakpoint();
duke@435 177 JvmtiBreakpoint(methodOop m_method, jlocation location);
duke@435 178 bool equals(JvmtiBreakpoint& bp);
duke@435 179 bool lessThan(JvmtiBreakpoint &bp);
duke@435 180 void copy(JvmtiBreakpoint& bp);
duke@435 181 bool is_valid();
duke@435 182 address getBcp();
duke@435 183 void each_method_version_do(method_action meth_act);
duke@435 184 void set();
duke@435 185 void clear();
duke@435 186 void print();
duke@435 187
duke@435 188 methodOop method() { return _method; }
duke@435 189
duke@435 190 // GrowableElement implementation
duke@435 191 address getCacheValue() { return getBcp(); }
duke@435 192 bool lessThan(GrowableElement* e) { Unimplemented(); return false; }
duke@435 193 bool equals(GrowableElement* e) { return equals((JvmtiBreakpoint&) *e); }
duke@435 194 void oops_do(OopClosure* f) { f->do_oop((oop *) &_method); }
duke@435 195 GrowableElement *clone() {
duke@435 196 JvmtiBreakpoint *bp = new JvmtiBreakpoint();
duke@435 197 bp->copy(*this);
duke@435 198 return bp;
duke@435 199 }
duke@435 200 };
duke@435 201
duke@435 202
duke@435 203 ///////////////////////////////////////////////////////////////
duke@435 204 //
duke@435 205 // class VM_ChangeBreakpoints
duke@435 206 // Used by : JvmtiBreakpoints
duke@435 207 // Used by JVMTI methods: none directly.
duke@435 208 // Note: A Helper class.
duke@435 209 //
duke@435 210 // VM_ChangeBreakpoints implements a VM_Operation for ALL modifications to the JvmtiBreakpoints class.
duke@435 211 //
duke@435 212
duke@435 213 class VM_ChangeBreakpoints : public VM_Operation {
duke@435 214 private:
duke@435 215 JvmtiBreakpoints* _breakpoints;
duke@435 216 int _operation;
duke@435 217 JvmtiBreakpoint* _bp;
duke@435 218
duke@435 219 public:
duke@435 220 enum { SET_BREAKPOINT=0, CLEAR_BREAKPOINT=1, CLEAR_ALL_BREAKPOINT=2 };
duke@435 221
duke@435 222 VM_ChangeBreakpoints(JvmtiBreakpoints* breakpoints, int operation) {
duke@435 223 _breakpoints = breakpoints;
duke@435 224 _bp = NULL;
duke@435 225 _operation = operation;
duke@435 226 assert(breakpoints != NULL, "breakpoints != NULL");
duke@435 227 assert(operation == CLEAR_ALL_BREAKPOINT, "unknown breakpoint operation");
duke@435 228 }
duke@435 229 VM_ChangeBreakpoints(JvmtiBreakpoints* breakpoints, int operation, JvmtiBreakpoint *bp) {
duke@435 230 _breakpoints = breakpoints;
duke@435 231 _bp = bp;
duke@435 232 _operation = operation;
duke@435 233 assert(breakpoints != NULL, "breakpoints != NULL");
duke@435 234 assert(bp != NULL, "bp != NULL");
duke@435 235 assert(operation == SET_BREAKPOINT || operation == CLEAR_BREAKPOINT , "unknown breakpoint operation");
duke@435 236 }
duke@435 237
duke@435 238 VMOp_Type type() const { return VMOp_ChangeBreakpoints; }
duke@435 239 void doit();
duke@435 240 void oops_do(OopClosure* f);
duke@435 241 };
duke@435 242
duke@435 243
duke@435 244 ///////////////////////////////////////////////////////////////
duke@435 245 //
duke@435 246 // class JvmtiBreakpoints
duke@435 247 // Used by : JvmtiCurrentBreakpoints
duke@435 248 // Used by JVMTI methods: none directly
duke@435 249 // Note: A Helper class
duke@435 250 //
duke@435 251 // JvmtiBreakpoints is a GrowableCache of JvmtiBreakpoint.
duke@435 252 // All changes to the GrowableCache occur at a safepoint using VM_ChangeBreakpoints.
duke@435 253 //
duke@435 254 // Because _bps is only modified at safepoints, its possible to always use the
duke@435 255 // cached byte code pointers from _bps without doing any synchronization (see JvmtiCurrentBreakpoints).
duke@435 256 //
duke@435 257 // It would be possible to make JvmtiBreakpoints a static class, but I've made it
duke@435 258 // CHeap allocated to emphasize its similarity to JvmtiFramePops.
duke@435 259 //
duke@435 260
duke@435 261 class JvmtiBreakpoints : public CHeapObj {
duke@435 262 private:
duke@435 263
duke@435 264 JvmtiBreakpointCache _bps;
duke@435 265
duke@435 266 // These should only be used by VM_ChangeBreakpoints
duke@435 267 // to insure they only occur at safepoints.
duke@435 268 // Todo: add checks for safepoint
duke@435 269 friend class VM_ChangeBreakpoints;
duke@435 270 void set_at_safepoint(JvmtiBreakpoint& bp);
duke@435 271 void clear_at_safepoint(JvmtiBreakpoint& bp);
duke@435 272 void clearall_at_safepoint();
duke@435 273
duke@435 274 static void do_element(GrowableElement *e);
duke@435 275
duke@435 276 public:
duke@435 277 JvmtiBreakpoints(void listener_fun(void *, address *));
duke@435 278 ~JvmtiBreakpoints();
duke@435 279
duke@435 280 int length();
duke@435 281 void oops_do(OopClosure* f);
duke@435 282 void print();
duke@435 283
duke@435 284 int set(JvmtiBreakpoint& bp);
duke@435 285 int clear(JvmtiBreakpoint& bp);
duke@435 286 void clearall_in_class_at_safepoint(klassOop klass);
duke@435 287 void clearall();
kamg@2467 288 void gc_epilogue();
duke@435 289 };
duke@435 290
duke@435 291
duke@435 292 ///////////////////////////////////////////////////////////////
duke@435 293 //
duke@435 294 // class JvmtiCurrentBreakpoints
duke@435 295 //
duke@435 296 // A static wrapper class for the JvmtiBreakpoints that provides:
duke@435 297 // 1. a fast inlined function to check if a byte code pointer is a breakpoint (is_breakpoint).
duke@435 298 // 2. a function for lazily creating the JvmtiBreakpoints class (this is not strictly necessary,
duke@435 299 // but I'm copying the code from JvmtiThreadState which needs to lazily initialize
duke@435 300 // JvmtiFramePops).
duke@435 301 // 3. An oops_do entry point for GC'ing the breakpoint array.
duke@435 302 //
duke@435 303
duke@435 304 class JvmtiCurrentBreakpoints : public AllStatic {
duke@435 305
duke@435 306 private:
duke@435 307
duke@435 308 // Current breakpoints, lazily initialized by get_jvmti_breakpoints();
duke@435 309 static JvmtiBreakpoints *_jvmti_breakpoints;
duke@435 310
duke@435 311 // NULL terminated cache of byte-code pointers corresponding to current breakpoints.
duke@435 312 // Updated only at safepoints (with listener_fun) when the cache is moved.
duke@435 313 // It exists only to make is_breakpoint fast.
duke@435 314 static address *_breakpoint_list;
duke@435 315 static inline void set_breakpoint_list(address *breakpoint_list) { _breakpoint_list = breakpoint_list; }
duke@435 316 static inline address *get_breakpoint_list() { return _breakpoint_list; }
duke@435 317
duke@435 318 // Listener for the GrowableCache in _jvmti_breakpoints, updates _breakpoint_list.
duke@435 319 static void listener_fun(void *this_obj, address *cache);
duke@435 320
duke@435 321 public:
duke@435 322 static void initialize();
duke@435 323 static void destroy();
duke@435 324
duke@435 325 // lazily create _jvmti_breakpoints and _breakpoint_list
duke@435 326 static JvmtiBreakpoints& get_jvmti_breakpoints();
duke@435 327
duke@435 328 // quickly test whether the bcp matches a cached breakpoint in the list
duke@435 329 static inline bool is_breakpoint(address bcp);
duke@435 330
duke@435 331 static void oops_do(OopClosure* f);
kamg@2467 332 static void gc_epilogue();
duke@435 333 };
duke@435 334
duke@435 335 // quickly test whether the bcp matches a cached breakpoint in the list
duke@435 336 bool JvmtiCurrentBreakpoints::is_breakpoint(address bcp) {
duke@435 337 address *bps = get_breakpoint_list();
duke@435 338 if (bps == NULL) return false;
duke@435 339 for ( ; (*bps) != NULL; bps++) {
duke@435 340 if ((*bps) == bcp) return true;
duke@435 341 }
duke@435 342 return false;
duke@435 343 }
duke@435 344
duke@435 345 ///////////////////////////////////////////////////////////////
duke@435 346 // The get/set local operations must only be done by the VM thread
duke@435 347 // because the interpreter version needs to access oop maps, which can
duke@435 348 // only safely be done by the VM thread
duke@435 349 //
duke@435 350 // I'm told that in 1.5 oop maps are now protected by a lock and
duke@435 351 // we could get rid of the VM op
duke@435 352 // However if the VM op is removed then the target thread must
duke@435 353 // be suspended AND a lock will be needed to prevent concurrent
duke@435 354 // setting of locals to the same java thread. This lock is needed
duke@435 355 // to prevent compiledVFrames from trying to add deferred updates
duke@435 356 // to the thread simultaneously.
duke@435 357 //
duke@435 358 class VM_GetOrSetLocal : public VM_Operation {
kamg@2361 359 protected:
duke@435 360 JavaThread* _thread;
duke@435 361 JavaThread* _calling_thread;
duke@435 362 jint _depth;
duke@435 363 jint _index;
duke@435 364 BasicType _type;
duke@435 365 jvalue _value;
duke@435 366 javaVFrame* _jvf;
duke@435 367 bool _set;
duke@435 368
kamg@2361 369 // It is possible to get the receiver out of a non-static native wrapper
kamg@2361 370 // frame. Use VM_GetReceiver to do this.
kamg@2361 371 virtual bool getting_receiver() const { return false; }
kamg@2361 372
duke@435 373 jvmtiError _result;
duke@435 374
duke@435 375 vframe* get_vframe();
duke@435 376 javaVFrame* get_java_vframe();
duke@435 377 bool check_slot_type(javaVFrame* vf);
duke@435 378
duke@435 379 public:
duke@435 380 // Constructor for non-object getter
duke@435 381 VM_GetOrSetLocal(JavaThread* thread, jint depth, jint index, BasicType type);
duke@435 382
duke@435 383 // Constructor for object or non-object setter
duke@435 384 VM_GetOrSetLocal(JavaThread* thread, jint depth, jint index, BasicType type, jvalue value);
duke@435 385
duke@435 386 // Constructor for object getter
duke@435 387 VM_GetOrSetLocal(JavaThread* thread, JavaThread* calling_thread, jint depth,
duke@435 388 int index);
duke@435 389
duke@435 390 VMOp_Type type() const { return VMOp_GetOrSetLocal; }
duke@435 391 jvalue value() { return _value; }
duke@435 392 jvmtiError result() { return _result; }
duke@435 393
duke@435 394 bool doit_prologue();
duke@435 395 void doit();
duke@435 396 bool allow_nested_vm_operations() const;
duke@435 397 const char* name() const { return "get/set locals"; }
duke@435 398
duke@435 399 // Check that the klass is assignable to a type with the given signature.
duke@435 400 static bool is_assignable(const char* ty_sign, Klass* klass, Thread* thread);
duke@435 401 };
duke@435 402
kamg@2361 403 class VM_GetReceiver : public VM_GetOrSetLocal {
kamg@2361 404 protected:
kamg@2361 405 virtual bool getting_receiver() const { return true; }
kamg@2361 406
kamg@2361 407 public:
kamg@2361 408 VM_GetReceiver(JavaThread* thread, JavaThread* calling_thread, jint depth);
kamg@2361 409 const char* name() const { return "get receiver"; }
kamg@2361 410 };
kamg@2361 411
duke@435 412
duke@435 413 ///////////////////////////////////////////////////////////////
duke@435 414 //
duke@435 415 // class JvmtiSuspendControl
duke@435 416 //
duke@435 417 // Convenience routines for suspending and resuming threads.
duke@435 418 //
duke@435 419 // All attempts by JVMTI to suspend and resume threads must go through the
duke@435 420 // JvmtiSuspendControl interface.
duke@435 421 //
duke@435 422 // methods return true if successful
duke@435 423 //
duke@435 424 class JvmtiSuspendControl : public AllStatic {
duke@435 425 public:
duke@435 426 // suspend the thread, taking it to a safepoint
duke@435 427 static bool suspend(JavaThread *java_thread);
duke@435 428 // resume the thread
duke@435 429 static bool resume(JavaThread *java_thread);
duke@435 430
duke@435 431 static void print();
duke@435 432 };
duke@435 433
stefank@2325 434 #endif // !JVMTI_KERNEL
stefank@2325 435
kamg@2511 436 /**
kamg@2511 437 * When a thread (such as the compiler thread or VM thread) cannot post a
kamg@2511 438 * JVMTI event itself because the event needs to be posted from a Java
kamg@2511 439 * thread, then it can defer the event to the Service thread for posting.
kamg@2511 440 * The information needed to post the event is encapsulated into this class
kamg@2511 441 * and then enqueued onto the JvmtiDeferredEventQueue, where the Service
kamg@2511 442 * thread will pick it up and post it.
kamg@2511 443 *
kamg@2511 444 * This is currently only used for posting compiled-method-load and unload
kamg@2511 445 * events, which we don't want posted from the compiler thread.
kamg@2511 446 */
kamg@2511 447 class JvmtiDeferredEvent VALUE_OBJ_CLASS_SPEC {
kamg@2511 448 friend class JvmtiDeferredEventQueue;
kamg@2511 449 private:
kamg@2511 450 typedef enum {
kamg@2511 451 TYPE_NONE,
kamg@2511 452 TYPE_COMPILED_METHOD_LOAD,
kamg@2511 453 TYPE_COMPILED_METHOD_UNLOAD,
kamg@2583 454 TYPE_DYNAMIC_CODE_GENERATED
kamg@2511 455 } Type;
kamg@2511 456
kamg@2511 457 Type _type;
kamg@2511 458 union {
kamg@2511 459 nmethod* compiled_method_load;
kamg@2511 460 struct {
kamg@2511 461 jmethodID method_id;
kamg@2511 462 const void* code_begin;
kamg@2511 463 } compiled_method_unload;
kamg@2583 464 struct {
kamg@2583 465 const char* name;
kamg@2583 466 const void* code_begin;
kamg@2583 467 const void* code_end;
kamg@2583 468 } dynamic_code_generated;
kamg@2511 469 } _event_data;
kamg@2511 470
kamg@2511 471 JvmtiDeferredEvent(Type t) : _type(t) {}
kamg@2511 472
kamg@2511 473 public:
kamg@2511 474
kamg@2511 475 JvmtiDeferredEvent() : _type(TYPE_NONE) {}
kamg@2511 476
kamg@2511 477 // Factory methods
kamg@2511 478 static JvmtiDeferredEvent compiled_method_load_event(nmethod* nm)
kamg@2511 479 KERNEL_RETURN_(JvmtiDeferredEvent());
kamg@2511 480 static JvmtiDeferredEvent compiled_method_unload_event(
kamg@2511 481 jmethodID id, const void* code) KERNEL_RETURN_(JvmtiDeferredEvent());
kamg@2583 482 static JvmtiDeferredEvent dynamic_code_generated_event(
kamg@2583 483 const char* name, const void* begin, const void* end)
kamg@2583 484 KERNEL_RETURN_(JvmtiDeferredEvent());
kamg@2511 485
kamg@2511 486 // Actually posts the event.
kamg@2511 487 void post() KERNEL_RETURN;
kamg@2511 488 };
kamg@2511 489
kamg@2511 490 /**
kamg@2511 491 * Events enqueued on this queue wake up the Service thread which dequeues
kamg@2511 492 * and posts the events. The Service_lock is required to be held
kamg@2511 493 * when operating on the queue (except for the "pending" events).
kamg@2511 494 */
kamg@2511 495 class JvmtiDeferredEventQueue : AllStatic {
kamg@2511 496 friend class JvmtiDeferredEvent;
kamg@2511 497 private:
kamg@2511 498 class QueueNode : public CHeapObj {
kamg@2511 499 private:
kamg@2511 500 JvmtiDeferredEvent _event;
kamg@2511 501 QueueNode* _next;
kamg@2511 502
kamg@2511 503 public:
kamg@2511 504 QueueNode(const JvmtiDeferredEvent& event)
kamg@2511 505 : _event(event), _next(NULL) {}
kamg@2511 506
kamg@2511 507 const JvmtiDeferredEvent& event() const { return _event; }
kamg@2511 508 QueueNode* next() const { return _next; }
kamg@2511 509
kamg@2511 510 void set_next(QueueNode* next) { _next = next; }
kamg@2511 511 };
kamg@2511 512
kamg@2511 513 static QueueNode* _queue_head; // Hold Service_lock to access
kamg@2511 514 static QueueNode* _queue_tail; // Hold Service_lock to access
kamg@2511 515 static volatile QueueNode* _pending_list; // Uses CAS for read/update
kamg@2511 516
kamg@2511 517 // Transfers events from the _pending_list to the _queue.
kamg@2511 518 static void process_pending_events() KERNEL_RETURN;
kamg@2511 519
kamg@2511 520 public:
kamg@2511 521 // Must be holding Service_lock when calling these
kamg@2511 522 static bool has_events() KERNEL_RETURN_(false);
kamg@2511 523 static void enqueue(const JvmtiDeferredEvent& event) KERNEL_RETURN;
kamg@2511 524 static JvmtiDeferredEvent dequeue() KERNEL_RETURN_(JvmtiDeferredEvent());
kamg@2511 525
kamg@2511 526 // Used to enqueue events without using a lock, for times (such as during
kamg@2511 527 // safepoint) when we can't or don't want to lock the Service_lock.
kamg@2511 528 //
kamg@2511 529 // Events will be held off to the side until there's a call to
kamg@2511 530 // dequeue(), enqueue(), or process_pending_events() (all of which require
kamg@2511 531 // the holding of the Service_lock), and will be enqueued at that time.
kamg@2511 532 static void add_pending_event(const JvmtiDeferredEvent&) KERNEL_RETURN;
kamg@2511 533 };
kamg@2511 534
duke@435 535 // Utility macro that checks for NULL pointers:
duke@435 536 #define NULL_CHECK(X, Y) if ((X) == NULL) { return (Y); }
stefank@2314 537
stefank@2314 538 #endif // SHARE_VM_PRIMS_JVMTIIMPL_HPP

mercurial