src/hotspot/share/prims/jvmtiRawMonitor.cpp
author chegar
Thu, 17 Oct 2019 20:53:35 +0100
branchdatagramsocketimpl-branch
changeset 58678 9cf78a70fa4f
parent 54469 8592226f5cd3
child 58679 9c3209ff7550
permissions -rw-r--r--
datagramsocketimpl-branch: update to default
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
     1
/*
54469
8592226f5cd3 8221584: SIGSEGV in os::PlatformEvent::unpark() in JvmtiRawMonitor::raw_exit while posting method exit event
dholmes
parents: 51702
diff changeset
     2
 * Copyright (c) 2003, 2019, Oracle and/or its affiliates. All rights reserved.
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
     3
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
     4
 *
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
     5
 * This code is free software; you can redistribute it and/or modify it
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
     6
 * under the terms of the GNU General Public License version 2 only, as
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
     7
 * published by the Free Software Foundation.
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
     8
 *
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
     9
 * This code is distributed in the hope that it will be useful, but WITHOUT
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    10
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    11
 * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    12
 * version 2 for more details (a copy is included in the LICENSE file that
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    13
 * accompanied this code).
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    14
 *
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    15
 * You should have received a copy of the GNU General Public License version
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    16
 * 2 along with this work; if not, write to the Free Software Foundation,
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    17
 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    18
 *
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    19
 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    20
 * or visit www.oracle.com if you need additional information or have any
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    21
 * questions.
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    22
 *
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    23
 */
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    24
7397
5b173b4ca846 6989984: Use standard include model for Hospot
stefank
parents: 6975
diff changeset
    25
#include "precompiled.hpp"
49360
886acec3b4c6 8199275: Fix inclusions of allocation.inline.hpp
stefank
parents: 48488
diff changeset
    26
#include "memory/allocation.inline.hpp"
7397
5b173b4ca846 6989984: Use standard include model for Hospot
stefank
parents: 6975
diff changeset
    27
#include "prims/jvmtiRawMonitor.hpp"
40655
9f644073d3a0 8157907: Incorrect inclusion of atomic.hpp instead of atomic.inline.hpp
dholmes
parents: 25351
diff changeset
    28
#include "runtime/atomic.hpp"
49449
ef5d5d343e2a 8199263: Split interfaceSupport.hpp to not require including .inline.hpp files
coleenp
parents: 49360
diff changeset
    29
#include "runtime/interfaceSupport.inline.hpp"
50429
83aec1d357d4 8204301: Make OrderAccess functions available to hpp rather than inline.hpp files
coleenp
parents: 49449
diff changeset
    30
#include "runtime/orderAccess.hpp"
24351
61b33cc6d3cf 8042195: Introduce umbrella header orderAccess.inline.hpp.
goetz
parents: 13963
diff changeset
    31
#include "runtime/thread.inline.hpp"
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    32
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
    33
JvmtiRawMonitor::QNode::QNode(Thread* thread) : _next(NULL), _prev(NULL),
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
    34
                                                _event(thread->_ParkEvent),
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
    35
                                                _notified(0), _t_state(TS_RUN) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
    36
}
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
    37
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
    38
GrowableArray<JvmtiRawMonitor*>* JvmtiPendingMonitors::_monitors =
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
    39
  new (ResourceObj::C_HEAP, mtInternal) GrowableArray<JvmtiRawMonitor*>(1, true);
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    40
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    41
void JvmtiPendingMonitors::transition_raw_monitors() {
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    42
  assert((Threads::number_of_threads()==1),
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
    43
         "Java thread has not been created yet or more than one java thread "
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
    44
         "is running. Raw monitor transition will not work");
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
    45
  JavaThread* current_java_thread = JavaThread::current();
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    46
  assert(current_java_thread->thread_state() == _thread_in_vm, "Must be in vm");
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
    47
  for (int i = 0; i < count(); i++) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
    48
    JvmtiRawMonitor* rmonitor = monitors()->at(i);
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
    49
    rmonitor->raw_enter(current_java_thread);
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    50
  }
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    51
  // pending monitors are converted to real monitor so delete them all.
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    52
  dispose();
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    53
}
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    54
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    55
//
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    56
// class JvmtiRawMonitor
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    57
//
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    58
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
    59
JvmtiRawMonitor::JvmtiRawMonitor(const char* name) : _owner(NULL),
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
    60
                                                     _recursions(0),
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
    61
                                                     _entry_list(NULL),
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
    62
                                                     _wait_set(NULL),
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
    63
                                                     _waiters(0),
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
    64
                                                     _magic(JVMTI_RM_MAGIC),
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
    65
                                                     _name(NULL) {
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    66
#ifdef ASSERT
13195
be27e1b6a4b9 6995781: Native Memory Tracking (Phase 1)
zgu
parents: 7397
diff changeset
    67
  _name = strcpy(NEW_C_HEAP_ARRAY(char, strlen(name) + 1, mtInternal), name);
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    68
#endif
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    69
}
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    70
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    71
JvmtiRawMonitor::~JvmtiRawMonitor() {
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    72
#ifdef ASSERT
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    73
  FreeHeap(_name);
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    74
#endif
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    75
  _magic = 0;
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    76
}
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    77
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    78
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    79
bool
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    80
JvmtiRawMonitor::is_valid() {
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    81
  int value = 0;
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    82
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    83
  // This object might not be a JvmtiRawMonitor so we can't assume
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    84
  // the _magic field is properly aligned. Get the value in a safe
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    85
  // way and then check against JVMTI_RM_MAGIC.
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    86
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    87
  switch (sizeof(_magic)) {
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    88
  case 2:
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    89
    value = Bytes::get_native_u2((address)&_magic);
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    90
    break;
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    91
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    92
  case 4:
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    93
    value = Bytes::get_native_u4((address)&_magic);
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    94
    break;
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    95
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    96
  case 8:
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    97
    value = Bytes::get_native_u8((address)&_magic);
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    98
    break;
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
    99
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   100
  default:
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   101
    guarantee(false, "_magic field is an unexpected size");
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   102
  }
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   103
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   104
  return value == JVMTI_RM_MAGIC;
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   105
}
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   106
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   107
// -------------------------------------------------------------------------
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   108
// The JVMTI raw monitor subsystem is entirely distinct from normal
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   109
// java-synchronization or jni-synchronization.  JVMTI raw monitors are not
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   110
// associated with objects.  They can be implemented in any manner
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   111
// that makes sense.  The original implementors decided to piggy-back
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   112
// the raw-monitor implementation on the existing Java ObjectMonitor mechanism.
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   113
// Now we just use a simplified form of that ObjectMonitor code.
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   114
//
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   115
// Note that we use the single RawMonitor_lock to protect queue operations for
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   116
// _all_ raw monitors.  This is a scalability impediment, but since raw monitor usage
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   117
// is fairly rare, this is not of concern.  The RawMonitor_lock can not
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   118
// be held indefinitely.  The critical sections must be short and bounded.
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   119
//
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   120
// -------------------------------------------------------------------------
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   121
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   122
void JvmtiRawMonitor::simple_enter(Thread* self) {
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   123
  for (;;) {
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   124
    if (Atomic::replace_if_null(self, &_owner)) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   125
      return;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   126
    }
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   127
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   128
    QNode node(self);
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   129
    self->_ParkEvent->reset();     // strictly optional
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   130
    node._t_state = QNode::TS_ENTER;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   131
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   132
    RawMonitor_lock->lock_without_safepoint_check();
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   133
    node._next = _entry_list;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   134
    _entry_list = &node;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   135
    OrderAccess::fence();
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   136
    if (_owner == NULL && Atomic::replace_if_null(self, &_owner)) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   137
      _entry_list = node._next;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   138
      RawMonitor_lock->unlock();
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   139
      return;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   140
    }
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   141
    RawMonitor_lock->unlock();
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   142
    while (node._t_state == QNode::TS_ENTER) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   143
      self->_ParkEvent->park();
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   144
    }
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   145
  }
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   146
}
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   147
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   148
void JvmtiRawMonitor::simple_exit(Thread* self) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   149
  guarantee(_owner == self, "invariant");
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   150
  OrderAccess::release_store(&_owner, (Thread*)NULL);
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   151
  OrderAccess::fence();
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   152
  if (_entry_list == NULL) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   153
    return;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   154
  }
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   155
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   156
  RawMonitor_lock->lock_without_safepoint_check();
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   157
  QNode* w = _entry_list;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   158
  if (w != NULL) {
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   159
    _entry_list = w->_next;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   160
  }
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   161
  RawMonitor_lock->unlock();
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   162
  if (w != NULL) {
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   163
    guarantee(w ->_t_state == QNode::TS_ENTER, "invariant");
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   164
    // Once we set _t_state to TS_RUN the waiting thread can complete
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   165
    // simple_enter and 'w' is pointing into random stack space. So we have
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   166
    // to ensure we extract the ParkEvent (which is in type-stable memory)
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   167
    // before we set the state, and then don't access 'w'.
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   168
    ParkEvent* ev = w->_event;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   169
    OrderAccess::loadstore();
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   170
    w->_t_state = QNode::TS_RUN;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   171
    OrderAccess::fence();
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   172
    ev->unpark();
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   173
  }
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   174
  return;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   175
}
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   176
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   177
int JvmtiRawMonitor::simple_wait(Thread* self, jlong millis) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   178
  guarantee(_owner == self  , "invariant");
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   179
  guarantee(_recursions == 0, "invariant");
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   180
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   181
  QNode node(self);
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   182
  node._notified = 0;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   183
  node._t_state = QNode::TS_WAIT;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   184
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   185
  RawMonitor_lock->lock_without_safepoint_check();
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   186
  node._next = _wait_set;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   187
  _wait_set = &node;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   188
  RawMonitor_lock->unlock();
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   189
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   190
  simple_exit(self);
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   191
  guarantee(_owner != self, "invariant");
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   192
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   193
  int ret = OS_OK;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   194
  if (millis <= 0) {
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   195
    self->_ParkEvent->park();
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   196
  } else {
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   197
    ret = self->_ParkEvent->park(millis);
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   198
  }
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   199
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   200
  // If thread still resides on the waitset then unlink it.
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   201
  // Double-checked locking -- the usage is safe in this context
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   202
  // as _t_state is volatile and the lock-unlock operators are
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   203
  // serializing (barrier-equivalent).
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   204
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   205
  if (node._t_state == QNode::TS_WAIT) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   206
    RawMonitor_lock->lock_without_safepoint_check();
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   207
    if (node._t_state == QNode::TS_WAIT) {
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   208
      // Simple O(n) unlink, but performance isn't critical here.
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   209
      QNode* p;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   210
      QNode* q = NULL;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   211
      for (p = _wait_set; p != &node; p = p->_next) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   212
        q = p;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   213
      }
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   214
      guarantee(p == &node, "invariant");
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   215
      if (q == NULL) {
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   216
        guarantee (p == _wait_set, "invariant");
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   217
        _wait_set = p->_next;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   218
      } else {
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   219
        guarantee(p == q->_next, "invariant");
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   220
        q->_next = p->_next;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   221
      }
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   222
      node._t_state = QNode::TS_RUN;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   223
    }
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   224
    RawMonitor_lock->unlock();
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   225
  }
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   226
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   227
  guarantee(node._t_state == QNode::TS_RUN, "invariant");
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   228
  simple_enter(self);
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   229
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   230
  guarantee(_owner == self, "invariant");
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   231
  guarantee(_recursions == 0, "invariant");
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   232
  return ret;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   233
}
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   234
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   235
void JvmtiRawMonitor::simple_notify(Thread* self, bool all) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   236
  guarantee(_owner == self, "invariant");
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   237
  if (_wait_set == NULL) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   238
    return;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   239
  }
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   240
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   241
  // We have two options:
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   242
  // A. Transfer the threads from the _wait_set to the _entry_list
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   243
  // B. Remove the thread from the _wait_set and unpark() it.
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   244
  //
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   245
  // We use (B), which is crude and results in lots of futile
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   246
  // context switching.  In particular (B) induces lots of contention.
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   247
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   248
  ParkEvent* ev = NULL;       // consider using a small auto array ...
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   249
  RawMonitor_lock->lock_without_safepoint_check();
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   250
  for (;;) {
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   251
    QNode* w = _wait_set;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   252
    if (w == NULL) break;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   253
    _wait_set = w->_next;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   254
    if (ev != NULL) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   255
      ev->unpark();
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   256
      ev = NULL;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   257
    }
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   258
    ev = w->_event;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   259
    OrderAccess::loadstore();
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   260
    w->_t_state = QNode::TS_RUN;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   261
    OrderAccess::storeload();
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   262
    if (!all) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   263
      break;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   264
    }
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   265
  }
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   266
  RawMonitor_lock->unlock();
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   267
  if (ev != NULL) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   268
    ev->unpark();
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   269
  }
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   270
  return;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   271
}
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   272
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   273
// Any JavaThread will enter here with state _thread_blocked
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   274
void JvmtiRawMonitor::raw_enter(Thread* self) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   275
  void* contended;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   276
  JavaThread* jt = NULL;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   277
  // don't enter raw monitor if thread is being externally suspended, it will
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   278
  // surprise the suspender if a "suspended" thread can still enter monitor
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   279
  if (self->is_Java_thread()) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   280
    jt = (JavaThread*)self;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   281
    jt->SR_lock()->lock_without_safepoint_check();
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   282
    while (jt->is_external_suspend()) {
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   283
      jt->SR_lock()->unlock();
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   284
      jt->java_suspend_self();
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   285
      jt->SR_lock()->lock_without_safepoint_check();
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   286
    }
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   287
    // guarded by SR_lock to avoid racing with new external suspend requests.
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   288
    contended = Atomic::cmpxchg(jt, &_owner, (Thread*)NULL);
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   289
    jt->SR_lock()->unlock();
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   290
  } else {
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   291
    contended = Atomic::cmpxchg(self, &_owner, (Thread*)NULL);
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   292
  }
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   293
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   294
  if (contended == self) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   295
    _recursions++;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   296
    return;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   297
  }
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   298
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   299
  if (contended == NULL) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   300
    guarantee(_owner == self, "invariant");
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   301
    guarantee(_recursions == 0, "invariant");
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   302
    return;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   303
  }
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   304
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   305
  self->set_current_pending_raw_monitor(this);
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   306
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   307
  if (!self->is_Java_thread()) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   308
    simple_enter(self);
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   309
  } else {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   310
    guarantee(jt->thread_state() == _thread_blocked, "invariant");
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   311
    for (;;) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   312
      jt->set_suspend_equivalent();
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   313
      // cleared by handle_special_suspend_equivalent_condition() or
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   314
      // java_suspend_self()
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   315
      simple_enter(jt);
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   316
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   317
      // were we externally suspended while we were waiting?
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   318
      if (!jt->handle_special_suspend_equivalent_condition()) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   319
        break;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   320
      }
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   321
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   322
      // This thread was externally suspended
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   323
      // We have reentered the contended monitor, but while we were
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   324
      // waiting another thread suspended us. We don't want to reenter
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   325
      // the monitor while suspended because that would surprise the
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   326
      // thread that suspended us.
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   327
      //
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   328
      // Drop the lock
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   329
      simple_exit(jt);
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   330
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   331
      jt->java_suspend_self();
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   332
    }
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   333
  }
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   334
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   335
  self->set_current_pending_raw_monitor(NULL);
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   336
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   337
  guarantee(_owner == self, "invariant");
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   338
  guarantee(_recursions == 0, "invariant");
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   339
}
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   340
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   341
int JvmtiRawMonitor::raw_exit(Thread* self) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   342
  if (self != _owner) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   343
    return M_ILLEGAL_MONITOR_STATE;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   344
  }
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   345
  if (_recursions > 0) {
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   346
    _recursions--;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   347
  } else {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   348
    simple_exit(self);
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   349
  }
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   350
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   351
  return M_OK;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   352
}
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   353
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   354
// All JavaThreads will enter here with state _thread_blocked
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   355
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   356
int JvmtiRawMonitor::raw_wait(jlong millis, bool interruptible, Thread* self) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   357
  if (self != _owner) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   358
    return M_ILLEGAL_MONITOR_STATE;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   359
  }
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   360
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   361
  // To avoid spurious wakeups we reset the parkevent. This is strictly optional.
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   362
  // The caller must be able to tolerate spurious returns from raw_wait().
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   363
  self->_ParkEvent->reset();
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   364
  OrderAccess::fence();
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   365
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   366
  JavaThread* jt = NULL;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   367
  // check interrupt event
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   368
  if (interruptible) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   369
    assert(self->is_Java_thread(), "Only JavaThreads can be interruptible");
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   370
    jt = (JavaThread*)self;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   371
    if (jt->is_interrupted(true)) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   372
      return M_INTERRUPTED;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   373
    }
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   374
  } else {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   375
    assert(!self->is_Java_thread(), "JavaThreads must be interuptible");
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   376
  }
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   377
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   378
  intptr_t save = _recursions;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   379
  _recursions = 0;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   380
  _waiters++;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   381
  if (self->is_Java_thread()) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   382
    guarantee(jt->thread_state() == _thread_blocked, "invariant");
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   383
    jt->set_suspend_equivalent();
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   384
  }
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   385
  int rv = simple_wait(self, millis);
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   386
  _recursions = save;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   387
  _waiters--;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   388
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   389
  guarantee(self == _owner, "invariant");
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   390
  if (self->is_Java_thread()) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   391
    for (;;) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   392
      if (!jt->handle_special_suspend_equivalent_condition()) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   393
        break;
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   394
      }
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   395
      simple_exit(jt);
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   396
      jt->java_suspend_self();
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   397
      simple_enter(jt);
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   398
      jt->set_suspend_equivalent();
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   399
    }
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   400
    guarantee(jt == _owner, "invariant");
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   401
  }
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   402
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   403
  if (interruptible && jt->is_interrupted(true)) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   404
    return M_INTERRUPTED;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   405
  }
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   406
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   407
  return M_OK;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   408
}
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   409
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   410
int JvmtiRawMonitor::raw_notify(Thread* self) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   411
  if (self != _owner) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   412
    return M_ILLEGAL_MONITOR_STATE;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   413
  }
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   414
  simple_notify(self, false);
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   415
  return M_OK;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   416
}
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   417
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   418
int JvmtiRawMonitor::raw_notifyAll(Thread* self) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   419
  if (self != _owner) {
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   420
    return M_ILLEGAL_MONITOR_STATE;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   421
  }
58678
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   422
  simple_notify(self, true);
9cf78a70fa4f datagramsocketimpl-branch: update to default
chegar
parents: 54469
diff changeset
   423
  return M_OK;
6975
dc9b63952682 6988353: refactor contended sync subsystem
acorn
parents:
diff changeset
   424
}