author | manc |
Mon, 14 Oct 2019 18:48:10 -0700 | |
changeset 58652 | 9b67dd88a931 |
parent 54623 | 1126f0607c70 |
permissions | -rw-r--r-- |
23472 | 1 |
/* |
54623
1126f0607c70
8222811: Consolidate MutexLockerEx and MutexLocker
coleenp
parents:
50574
diff
changeset
|
2 |
* Copyright (c) 2014, 2019, Oracle and/or its affiliates. All rights reserved. |
23472 | 3 |
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. |
4 |
* |
|
5 |
* This code is free software; you can redistribute it and/or modify it |
|
6 |
* under the terms of the GNU General Public License version 2 only, as |
|
7 |
* published by the Free Software Foundation. |
|
8 |
* |
|
9 |
* This code is distributed in the hope that it will be useful, but WITHOUT |
|
10 |
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or |
|
11 |
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License |
|
12 |
* version 2 for more details (a copy is included in the LICENSE file that |
|
13 |
* accompanied this code). |
|
14 |
* |
|
15 |
* You should have received a copy of the GNU General Public License version |
|
16 |
* 2 along with this work; if not, write to the Free Software Foundation, |
|
17 |
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA. |
|
18 |
* |
|
19 |
* Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA |
|
20 |
* or visit www.oracle.com if you need additional information or have any |
|
21 |
* questions. |
|
22 |
* |
|
23 |
*/ |
|
24 |
||
25 |
#include "precompiled.hpp" |
|
29081
c61eb4914428
8072911: Remove includes of oop.inline.hpp from .hpp files
stefank
parents:
25351
diff
changeset
|
26 |
#include "classfile/javaClasses.inline.hpp" |
30764 | 27 |
#include "gc/g1/g1CollectedHeap.hpp" |
28 |
#include "gc/g1/g1StringDedup.hpp" |
|
29 |
#include "gc/g1/g1StringDedupQueue.hpp" |
|
35061 | 30 |
#include "logging/log.hpp" |
29081
c61eb4914428
8072911: Remove includes of oop.inline.hpp from .hpp files
stefank
parents:
25351
diff
changeset
|
31 |
#include "oops/oop.inline.hpp" |
40655
9f644073d3a0
8157907: Incorrect inclusion of atomic.hpp instead of atomic.inline.hpp
dholmes
parents:
39690
diff
changeset
|
32 |
#include "runtime/atomic.hpp" |
23472 | 33 |
#include "runtime/mutexLocker.hpp" |
49594
898ef81cbc0e
8200106: Move NoSafepointVerifier out from gcLocker.hpp
stefank
parents:
47552
diff
changeset
|
34 |
#include "runtime/safepointVerifiers.hpp" |
23472 | 35 |
#include "utilities/stack.inline.hpp" |
36 |
||
37 |
const size_t G1StringDedupQueue::_max_size = 1000000; // Max number of elements per queue |
|
38 |
const size_t G1StringDedupQueue::_max_cache_size = 0; // Max cache size per queue |
|
39 |
||
40 |
G1StringDedupQueue::G1StringDedupQueue() : |
|
41 |
_cursor(0), |
|
24093
095cc0a63ed9
8037112: gc/g1/TestHumongousAllocInitialMark.java caused SIGSEGV
pliden
parents:
23472
diff
changeset
|
42 |
_cancel(false), |
23472 | 43 |
_empty(true), |
44 |
_dropped(0) { |
|
30876
44a71334fd94
8080876: Replace unnecessary MAX2(ParallelGCThreads, 1) calls with ParallelGCThreads
stefank
parents:
30764
diff
changeset
|
45 |
_nqueues = ParallelGCThreads; |
23472 | 46 |
_queues = NEW_C_HEAP_ARRAY(G1StringDedupWorkerQueue, _nqueues, mtGC); |
47 |
for (size_t i = 0; i < _nqueues; i++) { |
|
48 |
new (_queues + i) G1StringDedupWorkerQueue(G1StringDedupWorkerQueue::default_segment_size(), _max_cache_size, _max_size); |
|
49 |
} |
|
50 |
} |
|
51 |
||
52 |
G1StringDedupQueue::~G1StringDedupQueue() { |
|
53 |
ShouldNotReachHere(); |
|
54 |
} |
|
55 |
||
50574 | 56 |
void G1StringDedupQueue::wait_impl() { |
54623
1126f0607c70
8222811: Consolidate MutexLockerEx and MutexLocker
coleenp
parents:
50574
diff
changeset
|
57 |
MonitorLocker ml(StringDedupQueue_lock, Mutex::_no_safepoint_check_flag); |
50574 | 58 |
while (_empty && !_cancel) { |
54623
1126f0607c70
8222811: Consolidate MutexLockerEx and MutexLocker
coleenp
parents:
50574
diff
changeset
|
59 |
ml.wait(); |
23472 | 60 |
} |
61 |
} |
|
62 |
||
50574 | 63 |
void G1StringDedupQueue::cancel_wait_impl() { |
54623
1126f0607c70
8222811: Consolidate MutexLockerEx and MutexLocker
coleenp
parents:
50574
diff
changeset
|
64 |
MonitorLocker ml(StringDedupQueue_lock, Mutex::_no_safepoint_check_flag); |
50574 | 65 |
_cancel = true; |
24093
095cc0a63ed9
8037112: gc/g1/TestHumongousAllocInitialMark.java caused SIGSEGV
pliden
parents:
23472
diff
changeset
|
66 |
ml.notify(); |
095cc0a63ed9
8037112: gc/g1/TestHumongousAllocInitialMark.java caused SIGSEGV
pliden
parents:
23472
diff
changeset
|
67 |
} |
095cc0a63ed9
8037112: gc/g1/TestHumongousAllocInitialMark.java caused SIGSEGV
pliden
parents:
23472
diff
changeset
|
68 |
|
50574 | 69 |
void G1StringDedupQueue::push_impl(uint worker_id, oop java_string) { |
23472 | 70 |
assert(SafepointSynchronize::is_at_safepoint(), "Must be at safepoint"); |
50574 | 71 |
assert(worker_id < _nqueues, "Invalid queue"); |
23472 | 72 |
|
73 |
// Push and notify waiter |
|
50574 | 74 |
G1StringDedupWorkerQueue& worker_queue = _queues[worker_id]; |
23472 | 75 |
if (!worker_queue.is_full()) { |
76 |
worker_queue.push(java_string); |
|
50574 | 77 |
if (_empty) { |
54623
1126f0607c70
8222811: Consolidate MutexLockerEx and MutexLocker
coleenp
parents:
50574
diff
changeset
|
78 |
MonitorLocker ml(StringDedupQueue_lock, Mutex::_no_safepoint_check_flag); |
50574 | 79 |
if (_empty) { |
23472 | 80 |
// Mark non-empty and notify waiter |
50574 | 81 |
_empty = false; |
23472 | 82 |
ml.notify(); |
83 |
} |
|
84 |
} |
|
85 |
} else { |
|
86 |
// Queue is full, drop the string and update the statistics |
|
50574 | 87 |
Atomic::inc(&_dropped); |
23472 | 88 |
} |
89 |
} |
|
90 |
||
50574 | 91 |
oop G1StringDedupQueue::pop_impl() { |
23472 | 92 |
assert(!SafepointSynchronize::is_at_safepoint(), "Must not be at safepoint"); |
35492
c8c0273e6b91
8146690: Make all classes in GC follow the naming convention.
david
parents:
35061
diff
changeset
|
93 |
NoSafepointVerifier nsv; |
23472 | 94 |
|
95 |
// Try all queues before giving up |
|
50574 | 96 |
for (size_t tries = 0; tries < _nqueues; tries++) { |
23472 | 97 |
// The cursor indicates where we left of last time |
50574 | 98 |
G1StringDedupWorkerQueue* queue = &_queues[_cursor]; |
23472 | 99 |
while (!queue->is_empty()) { |
100 |
oop obj = queue->pop(); |
|
101 |
// The oop we pop can be NULL if it was marked |
|
102 |
// dead. Just ignore those and pop the next oop. |
|
103 |
if (obj != NULL) { |
|
104 |
return obj; |
|
105 |
} |
|
106 |
} |
|
107 |
||
108 |
// Try next queue |
|
50574 | 109 |
_cursor = (_cursor + 1) % _nqueues; |
23472 | 110 |
} |
111 |
||
112 |
// Mark empty |
|
50574 | 113 |
_empty = true; |
23472 | 114 |
|
115 |
return NULL; |
|
116 |
} |
|
117 |
||
50574 | 118 |
void G1StringDedupQueue::unlink_or_oops_do_impl(StringDedupUnlinkOrOopsDoClosure* cl, size_t queue) { |
119 |
assert(queue < _nqueues, "Invalid queue"); |
|
120 |
StackIterator<oop, mtGC> iter(_queues[queue]); |
|
23472 | 121 |
while (!iter.is_empty()) { |
122 |
oop* p = iter.next_addr(); |
|
123 |
if (*p != NULL) { |
|
124 |
if (cl->is_alive(*p)) { |
|
125 |
cl->keep_alive(p); |
|
126 |
} else { |
|
127 |
// Clear dead reference |
|
128 |
*p = NULL; |
|
129 |
} |
|
130 |
} |
|
131 |
} |
|
132 |
} |
|
133 |
||
50574 | 134 |
void G1StringDedupQueue::print_statistics_impl() { |
39690
09a3ee292336
8159974: G1 String deduplication logging not aligned with the rest of G1
pliden
parents:
35492
diff
changeset
|
135 |
log_debug(gc, stringdedup)(" Queue"); |
50574 | 136 |
log_debug(gc, stringdedup)(" Dropped: " UINTX_FORMAT, _dropped); |
23472 | 137 |
} |
138 |
||
50574 | 139 |
void G1StringDedupQueue::verify_impl() { |
140 |
for (size_t i = 0; i < _nqueues; i++) { |
|
141 |
StackIterator<oop, mtGC> iter(_queues[i]); |
|
23472 | 142 |
while (!iter.is_empty()) { |
143 |
oop obj = iter.next(); |
|
144 |
if (obj != NULL) { |
|
30173
13cf7580b000
8077413: Avoid use of Universe::heap() inside collectors
pliden
parents:
29081
diff
changeset
|
145 |
guarantee(G1CollectedHeap::heap()->is_in_reserved(obj), "Object must be on the heap"); |
23472 | 146 |
guarantee(!obj->is_forwarded(), "Object must not be forwarded"); |
147 |
guarantee(java_lang_String::is_instance(obj), "Object must be a String"); |
|
148 |
} |
|
149 |
} |
|
150 |
} |
|
151 |
} |