提交 44f2f80a 编写于 作者: J johnc

6843694: G1: assert(index < _vs.committed_size(),"bad index"), g1BlockOffsetTable.inline.hpp:55

Summary: For heaps larger than 32Gb, the number of heap regions overflows the data type used to hold the region index in the SparsePRT structure. Changed the region indexes, card indexes, and RSet hash table buckets to ints and added some size overflow guarantees.
Reviewed-by: ysr, tonyp
上级 e1239a04
...@@ -1535,6 +1535,15 @@ jint G1CollectedHeap::initialize() { ...@@ -1535,6 +1535,15 @@ jint G1CollectedHeap::initialize() {
guarantee(_hrs != NULL, "Couldn't allocate HeapRegionSeq"); guarantee(_hrs != NULL, "Couldn't allocate HeapRegionSeq");
guarantee(_cur_alloc_region == NULL, "from constructor"); guarantee(_cur_alloc_region == NULL, "from constructor");
// 6843694 - ensure that the maximum region index can fit
// in the remembered set structures.
const size_t max_region_idx = ((size_t)1 << (sizeof(RegionIdx_t)*BitsPerByte-1)) - 1;
guarantee((max_regions() - 1) <= max_region_idx, "too many regions");
const size_t cards_per_region = HeapRegion::GrainBytes >> CardTableModRefBS::card_shift;
size_t max_cards_per_region = ((size_t)1 << (sizeof(CardIdx_t)*BitsPerByte-1)) - 1;
guarantee(cards_per_region < max_cards_per_region, "too many cards per region");
_bot_shared = new G1BlockOffsetSharedArray(_reserved, _bot_shared = new G1BlockOffsetSharedArray(_reserved,
heap_word_size(init_byte_size)); heap_word_size(init_byte_size));
......
...@@ -59,6 +59,9 @@ class ConcurrentZFThread; ...@@ -59,6 +59,9 @@ class ConcurrentZFThread;
typedef GenericTaskQueue<oop*> RefToScanQueue; typedef GenericTaskQueue<oop*> RefToScanQueue;
typedef GenericTaskQueueSet<oop*> RefToScanQueueSet; typedef GenericTaskQueueSet<oop*> RefToScanQueueSet;
typedef int RegionIdx_t; // needs to hold [ 0..max_regions() )
typedef int CardIdx_t; // needs to hold [ 0..CardsPerRegion )
enum G1GCThreadGroups { enum G1GCThreadGroups {
G1CRGroup = 0, G1CRGroup = 0,
G1ZFGroup = 1, G1ZFGroup = 1,
......
...@@ -109,7 +109,7 @@ protected: ...@@ -109,7 +109,7 @@ protected:
return new PerRegionTable(hr); return new PerRegionTable(hr);
} }
void add_card_work(short from_card, bool par) { void add_card_work(CardIdx_t from_card, bool par) {
if (!_bm.at(from_card)) { if (!_bm.at(from_card)) {
if (par) { if (par) {
if (_bm.par_at_put(from_card, 1)) { if (_bm.par_at_put(from_card, 1)) {
...@@ -141,11 +141,11 @@ protected: ...@@ -141,11 +141,11 @@ protected:
// and adding a bit to the new table is never incorrect. // and adding a bit to the new table is never incorrect.
if (loc_hr->is_in_reserved(from)) { if (loc_hr->is_in_reserved(from)) {
size_t hw_offset = pointer_delta((HeapWord*)from, loc_hr->bottom()); size_t hw_offset = pointer_delta((HeapWord*)from, loc_hr->bottom());
size_t from_card = CardIdx_t from_card = (CardIdx_t)
hw_offset >> hw_offset >> (CardTableModRefBS::card_shift - LogHeapWordSize);
(CardTableModRefBS::card_shift - LogHeapWordSize);
add_card_work((short) from_card, par); assert(0 <= from_card && from_card < CardsPerRegion, "Must be in range.");
add_card_work(from_card, par);
} }
} }
...@@ -190,11 +190,11 @@ public: ...@@ -190,11 +190,11 @@ public:
#endif #endif
} }
void add_card(short from_card_index) { void add_card(CardIdx_t from_card_index) {
add_card_work(from_card_index, /*parallel*/ true); add_card_work(from_card_index, /*parallel*/ true);
} }
void seq_add_card(short from_card_index) { void seq_add_card(CardIdx_t from_card_index) {
add_card_work(from_card_index, /*parallel*/ false); add_card_work(from_card_index, /*parallel*/ false);
} }
...@@ -604,7 +604,7 @@ void OtherRegionsTable::add_reference(oop* from, int tid) { ...@@ -604,7 +604,7 @@ void OtherRegionsTable::add_reference(oop* from, int tid) {
// Note that this may be a continued H region. // Note that this may be a continued H region.
HeapRegion* from_hr = _g1h->heap_region_containing_raw(from); HeapRegion* from_hr = _g1h->heap_region_containing_raw(from);
size_t from_hrs_ind = (size_t)from_hr->hrs_index(); RegionIdx_t from_hrs_ind = (RegionIdx_t) from_hr->hrs_index();
// If the region is already coarsened, return. // If the region is already coarsened, return.
if (_coarse_map.at(from_hrs_ind)) { if (_coarse_map.at(from_hrs_ind)) {
...@@ -627,11 +627,11 @@ void OtherRegionsTable::add_reference(oop* from, int tid) { ...@@ -627,11 +627,11 @@ void OtherRegionsTable::add_reference(oop* from, int tid) {
uintptr_t from_hr_bot_card_index = uintptr_t from_hr_bot_card_index =
uintptr_t(from_hr->bottom()) uintptr_t(from_hr->bottom())
>> CardTableModRefBS::card_shift; >> CardTableModRefBS::card_shift;
int card_index = from_card - from_hr_bot_card_index; CardIdx_t card_index = from_card - from_hr_bot_card_index;
assert(0 <= card_index && card_index < PosParPRT::CardsPerRegion, assert(0 <= card_index && card_index < PosParPRT::CardsPerRegion,
"Must be in range."); "Must be in range.");
if (G1HRRSUseSparseTable && if (G1HRRSUseSparseTable &&
_sparse_table.add_card((short) from_hrs_ind, card_index)) { _sparse_table.add_card(from_hrs_ind, card_index)) {
if (G1RecordHRRSOops) { if (G1RecordHRRSOops) {
HeapRegionRemSet::record(hr(), from); HeapRegionRemSet::record(hr(), from);
#if HRRS_VERBOSE #if HRRS_VERBOSE
...@@ -656,9 +656,9 @@ void OtherRegionsTable::add_reference(oop* from, int tid) { ...@@ -656,9 +656,9 @@ void OtherRegionsTable::add_reference(oop* from, int tid) {
} }
// Otherwise, transfer from sparse to fine-grain. // Otherwise, transfer from sparse to fine-grain.
short cards[SparsePRTEntry::CardsPerEntry]; CardIdx_t cards[SparsePRTEntry::CardsPerEntry];
if (G1HRRSUseSparseTable) { if (G1HRRSUseSparseTable) {
bool res = _sparse_table.get_cards((short) from_hrs_ind, &cards[0]); bool res = _sparse_table.get_cards(from_hrs_ind, &cards[0]);
assert(res, "There should have been an entry"); assert(res, "There should have been an entry");
} }
...@@ -679,13 +679,13 @@ void OtherRegionsTable::add_reference(oop* from, int tid) { ...@@ -679,13 +679,13 @@ void OtherRegionsTable::add_reference(oop* from, int tid) {
// Add in the cards from the sparse table. // Add in the cards from the sparse table.
if (G1HRRSUseSparseTable) { if (G1HRRSUseSparseTable) {
for (int i = 0; i < SparsePRTEntry::CardsPerEntry; i++) { for (int i = 0; i < SparsePRTEntry::CardsPerEntry; i++) {
short c = cards[i]; CardIdx_t c = cards[i];
if (c != SparsePRTEntry::NullEntry) { if (c != SparsePRTEntry::NullEntry) {
prt->add_card(c); prt->add_card(c);
} }
} }
// Now we can delete the sparse entry. // Now we can delete the sparse entry.
bool res = _sparse_table.delete_entry((short) from_hrs_ind); bool res = _sparse_table.delete_entry(from_hrs_ind);
assert(res, "It should have been there."); assert(res, "It should have been there.");
} }
} }
...@@ -1030,7 +1030,7 @@ bool OtherRegionsTable::contains_reference(oop* from) const { ...@@ -1030,7 +1030,7 @@ bool OtherRegionsTable::contains_reference(oop* from) const {
bool OtherRegionsTable::contains_reference_locked(oop* from) const { bool OtherRegionsTable::contains_reference_locked(oop* from) const {
HeapRegion* hr = _g1h->heap_region_containing_raw(from); HeapRegion* hr = _g1h->heap_region_containing_raw(from);
if (hr == NULL) return false; if (hr == NULL) return false;
size_t hr_ind = hr->hrs_index(); RegionIdx_t hr_ind = (RegionIdx_t) hr->hrs_index();
// Is this region in the coarse map? // Is this region in the coarse map?
if (_coarse_map.at(hr_ind)) return true; if (_coarse_map.at(hr_ind)) return true;
...@@ -1045,8 +1045,9 @@ bool OtherRegionsTable::contains_reference_locked(oop* from) const { ...@@ -1045,8 +1045,9 @@ bool OtherRegionsTable::contains_reference_locked(oop* from) const {
uintptr_t hr_bot_card_index = uintptr_t hr_bot_card_index =
uintptr_t(hr->bottom()) >> CardTableModRefBS::card_shift; uintptr_t(hr->bottom()) >> CardTableModRefBS::card_shift;
assert(from_card >= hr_bot_card_index, "Inv"); assert(from_card >= hr_bot_card_index, "Inv");
int card_index = from_card - hr_bot_card_index; CardIdx_t card_index = from_card - hr_bot_card_index;
return _sparse_table.contains_card((short)hr_ind, card_index); assert(0 <= card_index && card_index < PosParPRT::CardsPerRegion, "Must be in range.");
return _sparse_table.contains_card(hr_ind, card_index);
} }
......
...@@ -33,7 +33,7 @@ void SparsePRT::init_iterator(SparsePRTIter* sprt_iter) { ...@@ -33,7 +33,7 @@ void SparsePRT::init_iterator(SparsePRTIter* sprt_iter) {
sprt_iter->init(this); sprt_iter->init(this);
} }
void SparsePRTEntry::init(short region_ind) { void SparsePRTEntry::init(RegionIdx_t region_ind) {
_region_ind = region_ind; _region_ind = region_ind;
_next_index = NullEntry; _next_index = NullEntry;
#if UNROLL_CARD_LOOPS #if UNROLL_CARD_LOOPS
...@@ -43,11 +43,12 @@ void SparsePRTEntry::init(short region_ind) { ...@@ -43,11 +43,12 @@ void SparsePRTEntry::init(short region_ind) {
_cards[2] = NullEntry; _cards[2] = NullEntry;
_cards[3] = NullEntry; _cards[3] = NullEntry;
#else #else
for (int i = 0; i < CardsPerEntry; i++) _cards[i] = NullEntry; for (int i = 0; i < CardsPerEntry; i++)
_cards[i] = NullEntry;
#endif #endif
} }
bool SparsePRTEntry::contains_card(short card_index) const { bool SparsePRTEntry::contains_card(CardIdx_t card_index) const {
#if UNROLL_CARD_LOOPS #if UNROLL_CARD_LOOPS
assert(CardsPerEntry == 4, "Assumption. If changes, un-unroll."); assert(CardsPerEntry == 4, "Assumption. If changes, un-unroll.");
if (_cards[0] == card_index) return true; if (_cards[0] == card_index) return true;
...@@ -80,10 +81,10 @@ int SparsePRTEntry::num_valid_cards() const { ...@@ -80,10 +81,10 @@ int SparsePRTEntry::num_valid_cards() const {
return sum; return sum;
} }
SparsePRTEntry::AddCardResult SparsePRTEntry::add_card(short card_index) { SparsePRTEntry::AddCardResult SparsePRTEntry::add_card(CardIdx_t card_index) {
#if UNROLL_CARD_LOOPS #if UNROLL_CARD_LOOPS
assert(CardsPerEntry == 4, "Assumption. If changes, un-unroll."); assert(CardsPerEntry == 4, "Assumption. If changes, un-unroll.");
short c = _cards[0]; CardIdx_t c = _cards[0];
if (c == card_index) return found; if (c == card_index) return found;
if (c == NullEntry) { _cards[0] = card_index; return added; } if (c == NullEntry) { _cards[0] = card_index; return added; }
c = _cards[1]; c = _cards[1];
...@@ -97,16 +98,19 @@ SparsePRTEntry::AddCardResult SparsePRTEntry::add_card(short card_index) { ...@@ -97,16 +98,19 @@ SparsePRTEntry::AddCardResult SparsePRTEntry::add_card(short card_index) {
if (c == NullEntry) { _cards[3] = card_index; return added; } if (c == NullEntry) { _cards[3] = card_index; return added; }
#else #else
for (int i = 0; i < CardsPerEntry; i++) { for (int i = 0; i < CardsPerEntry; i++) {
short c = _cards[i]; CardIdx_t c = _cards[i];
if (c == card_index) return found; if (c == card_index) return found;
if (c == NullEntry) { _cards[i] = card_index; return added; } if (c == NullEntry) {
_cards[i] = card_index;
return added;
}
} }
#endif #endif
// Otherwise, we're full. // Otherwise, we're full.
return overflow; return overflow;
} }
void SparsePRTEntry::copy_cards(short* cards) const { void SparsePRTEntry::copy_cards(CardIdx_t* cards) const {
#if UNROLL_CARD_LOOPS #if UNROLL_CARD_LOOPS
assert(CardsPerEntry == 4, "Assumption. If changes, un-unroll."); assert(CardsPerEntry == 4, "Assumption. If changes, un-unroll.");
cards[0] = _cards[0]; cards[0] = _cards[0];
...@@ -130,7 +134,7 @@ RSHashTable::RSHashTable(size_t capacity) : ...@@ -130,7 +134,7 @@ RSHashTable::RSHashTable(size_t capacity) :
_capacity(capacity), _capacity_mask(capacity-1), _capacity(capacity), _capacity_mask(capacity-1),
_occupied_entries(0), _occupied_cards(0), _occupied_entries(0), _occupied_cards(0),
_entries(NEW_C_HEAP_ARRAY(SparsePRTEntry, capacity)), _entries(NEW_C_HEAP_ARRAY(SparsePRTEntry, capacity)),
_buckets(NEW_C_HEAP_ARRAY(short, capacity)), _buckets(NEW_C_HEAP_ARRAY(int, capacity)),
_next_deleted(NULL), _deleted(false), _next_deleted(NULL), _deleted(false),
_free_list(NullEntry), _free_region(0) _free_list(NullEntry), _free_region(0)
{ {
...@@ -143,7 +147,7 @@ RSHashTable::~RSHashTable() { ...@@ -143,7 +147,7 @@ RSHashTable::~RSHashTable() {
_entries = NULL; _entries = NULL;
} }
if (_buckets != NULL) { if (_buckets != NULL) {
FREE_C_HEAP_ARRAY(short, _buckets); FREE_C_HEAP_ARRAY(int, _buckets);
_buckets = NULL; _buckets = NULL;
} }
} }
...@@ -153,14 +157,18 @@ void RSHashTable::clear() { ...@@ -153,14 +157,18 @@ void RSHashTable::clear() {
_occupied_cards = 0; _occupied_cards = 0;
guarantee(_entries != NULL, "INV"); guarantee(_entries != NULL, "INV");
guarantee(_buckets != NULL, "INV"); guarantee(_buckets != NULL, "INV");
guarantee(_capacity <= ((size_t)1 << (sizeof(int)*BitsPerByte-1)) - 1,
"_capacity too large");
// This will put -1 == NullEntry in the key field of all entries. // This will put -1 == NullEntry in the key field of all entries.
memset(_entries, -1, _capacity * sizeof(SparsePRTEntry)); memset(_entries, -1, _capacity * sizeof(SparsePRTEntry));
memset(_buckets, -1, _capacity * sizeof(short)); memset(_buckets, -1, _capacity * sizeof(int));
_free_list = NullEntry; _free_list = NullEntry;
_free_region = 0; _free_region = 0;
} }
bool RSHashTable::add_card(short region_ind, short card_index) { bool RSHashTable::add_card(RegionIdx_t region_ind, CardIdx_t card_index) {
SparsePRTEntry* e = entry_for_region_ind_create(region_ind); SparsePRTEntry* e = entry_for_region_ind_create(region_ind);
assert(e != NULL && e->r_ind() == region_ind, assert(e != NULL && e->r_ind() == region_ind,
"Postcondition of call above."); "Postcondition of call above.");
...@@ -175,9 +183,9 @@ bool RSHashTable::add_card(short region_ind, short card_index) { ...@@ -175,9 +183,9 @@ bool RSHashTable::add_card(short region_ind, short card_index) {
return res != SparsePRTEntry::overflow; return res != SparsePRTEntry::overflow;
} }
bool RSHashTable::get_cards(short region_ind, short* cards) { bool RSHashTable::get_cards(RegionIdx_t region_ind, CardIdx_t* cards) {
short ind = (short) (region_ind & capacity_mask()); int ind = (int) (region_ind & capacity_mask());
short cur_ind = _buckets[ind]; int cur_ind = _buckets[ind];
SparsePRTEntry* cur; SparsePRTEntry* cur;
while (cur_ind != NullEntry && while (cur_ind != NullEntry &&
(cur = entry(cur_ind))->r_ind() != region_ind) { (cur = entry(cur_ind))->r_ind() != region_ind) {
...@@ -192,10 +200,10 @@ bool RSHashTable::get_cards(short region_ind, short* cards) { ...@@ -192,10 +200,10 @@ bool RSHashTable::get_cards(short region_ind, short* cards) {
return true; return true;
} }
bool RSHashTable::delete_entry(short region_ind) { bool RSHashTable::delete_entry(RegionIdx_t region_ind) {
short ind = (short) (region_ind & capacity_mask()); int ind = (int) (region_ind & capacity_mask());
short* prev_loc = &_buckets[ind]; int* prev_loc = &_buckets[ind];
short cur_ind = *prev_loc; int cur_ind = *prev_loc;
SparsePRTEntry* cur; SparsePRTEntry* cur;
while (cur_ind != NullEntry && while (cur_ind != NullEntry &&
(cur = entry(cur_ind))->r_ind() != region_ind) { (cur = entry(cur_ind))->r_ind() != region_ind) {
...@@ -212,10 +220,11 @@ bool RSHashTable::delete_entry(short region_ind) { ...@@ -212,10 +220,11 @@ bool RSHashTable::delete_entry(short region_ind) {
return true; return true;
} }
SparsePRTEntry* RSHashTable::entry_for_region_ind(short region_ind) const { SparsePRTEntry*
RSHashTable::entry_for_region_ind(RegionIdx_t region_ind) const {
assert(occupied_entries() < capacity(), "Precondition"); assert(occupied_entries() < capacity(), "Precondition");
short ind = (short) (region_ind & capacity_mask()); int ind = (int) (region_ind & capacity_mask());
short cur_ind = _buckets[ind]; int cur_ind = _buckets[ind];
SparsePRTEntry* cur; SparsePRTEntry* cur;
// XXX // XXX
// int k = 0; // int k = 0;
...@@ -242,15 +251,16 @@ SparsePRTEntry* RSHashTable::entry_for_region_ind(short region_ind) const { ...@@ -242,15 +251,16 @@ SparsePRTEntry* RSHashTable::entry_for_region_ind(short region_ind) const {
} }
} }
SparsePRTEntry* RSHashTable::entry_for_region_ind_create(short region_ind) { SparsePRTEntry*
RSHashTable::entry_for_region_ind_create(RegionIdx_t region_ind) {
SparsePRTEntry* res = entry_for_region_ind(region_ind); SparsePRTEntry* res = entry_for_region_ind(region_ind);
if (res == NULL) { if (res == NULL) {
short new_ind = alloc_entry(); int new_ind = alloc_entry();
assert(0 <= new_ind && (size_t)new_ind < capacity(), "There should be room."); assert(0 <= new_ind && (size_t)new_ind < capacity(), "There should be room.");
res = entry(new_ind); res = entry(new_ind);
res->init(region_ind); res->init(region_ind);
// Insert at front. // Insert at front.
short ind = (short) (region_ind & capacity_mask()); int ind = (int) (region_ind & capacity_mask());
res->set_next_index(_buckets[ind]); res->set_next_index(_buckets[ind]);
_buckets[ind] = new_ind; _buckets[ind] = new_ind;
_occupied_entries++; _occupied_entries++;
...@@ -258,8 +268,8 @@ SparsePRTEntry* RSHashTable::entry_for_region_ind_create(short region_ind) { ...@@ -258,8 +268,8 @@ SparsePRTEntry* RSHashTable::entry_for_region_ind_create(short region_ind) {
return res; return res;
} }
short RSHashTable::alloc_entry() { int RSHashTable::alloc_entry() {
short res; int res;
if (_free_list != NullEntry) { if (_free_list != NullEntry) {
res = _free_list; res = _free_list;
_free_list = entry(res)->next_index(); _free_list = entry(res)->next_index();
...@@ -273,13 +283,11 @@ short RSHashTable::alloc_entry() { ...@@ -273,13 +283,11 @@ short RSHashTable::alloc_entry() {
} }
} }
void RSHashTable::free_entry(int fi) {
void RSHashTable::free_entry(short fi) {
entry(fi)->set_next_index(_free_list); entry(fi)->set_next_index(_free_list);
_free_list = fi; _free_list = fi;
} }
void RSHashTable::add_entry(SparsePRTEntry* e) { void RSHashTable::add_entry(SparsePRTEntry* e) {
assert(e->num_valid_cards() > 0, "Precondition."); assert(e->num_valid_cards() > 0, "Precondition.");
SparsePRTEntry* e2 = entry_for_region_ind_create(e->r_ind()); SparsePRTEntry* e2 = entry_for_region_ind_create(e->r_ind());
...@@ -322,8 +330,8 @@ RSHashTable* RSHashTable::get_from_deleted_list() { ...@@ -322,8 +330,8 @@ RSHashTable* RSHashTable::get_from_deleted_list() {
return NULL; return NULL;
} }
short /* RSHashTable:: */ RSHashTableIter::find_first_card_in_list() { CardIdx_t /* RSHashTable:: */ RSHashTableIter::find_first_card_in_list() {
short res; CardIdx_t res;
while (_bl_ind != RSHashTable::NullEntry) { while (_bl_ind != RSHashTable::NullEntry) {
res = _rsht->entry(_bl_ind)->card(0); res = _rsht->entry(_bl_ind)->card(0);
if (res != SparsePRTEntry::NullEntry) { if (res != SparsePRTEntry::NullEntry) {
...@@ -336,7 +344,7 @@ short /* RSHashTable:: */ RSHashTableIter::find_first_card_in_list() { ...@@ -336,7 +344,7 @@ short /* RSHashTable:: */ RSHashTableIter::find_first_card_in_list() {
return SparsePRTEntry::NullEntry; return SparsePRTEntry::NullEntry;
} }
size_t /* RSHashTable:: */ RSHashTableIter::compute_card_ind(short ci) { size_t /* RSHashTable:: */ RSHashTableIter::compute_card_ind(CardIdx_t ci) {
return return
_heap_bot_card_ind _heap_bot_card_ind
+ (_rsht->entry(_bl_ind)->r_ind() * CardsPerRegion) + (_rsht->entry(_bl_ind)->r_ind() * CardsPerRegion)
...@@ -345,7 +353,7 @@ size_t /* RSHashTable:: */ RSHashTableIter::compute_card_ind(short ci) { ...@@ -345,7 +353,7 @@ size_t /* RSHashTable:: */ RSHashTableIter::compute_card_ind(short ci) {
bool /* RSHashTable:: */ RSHashTableIter::has_next(size_t& card_index) { bool /* RSHashTable:: */ RSHashTableIter::has_next(size_t& card_index) {
_card_ind++; _card_ind++;
short ci; CardIdx_t ci;
if (_card_ind < SparsePRTEntry::CardsPerEntry && if (_card_ind < SparsePRTEntry::CardsPerEntry &&
((ci = _rsht->entry(_bl_ind)->card(_card_ind)) != ((ci = _rsht->entry(_bl_ind)->card(_card_ind)) !=
SparsePRTEntry::NullEntry)) { SparsePRTEntry::NullEntry)) {
...@@ -379,16 +387,16 @@ bool /* RSHashTable:: */ RSHashTableIter::has_next(size_t& card_index) { ...@@ -379,16 +387,16 @@ bool /* RSHashTable:: */ RSHashTableIter::has_next(size_t& card_index) {
return false; return false;
} }
bool RSHashTable::contains_card(short region_index, short card_index) const { bool RSHashTable::contains_card(RegionIdx_t region_index, CardIdx_t card_index) const {
SparsePRTEntry* e = entry_for_region_ind(region_index); SparsePRTEntry* e = entry_for_region_ind(region_index);
return (e != NULL && e->contains_card(card_index)); return (e != NULL && e->contains_card(card_index));
} }
size_t RSHashTable::mem_size() const { size_t RSHashTable::mem_size() const {
return sizeof(this) + capacity() * (sizeof(SparsePRTEntry) + sizeof(short)); return sizeof(this) +
capacity() * (sizeof(SparsePRTEntry) + sizeof(int));
} }
// ---------------------------------------------------------------------- // ----------------------------------------------------------------------
SparsePRT* SparsePRT::_head_expanded_list = NULL; SparsePRT* SparsePRT::_head_expanded_list = NULL;
...@@ -408,6 +416,7 @@ void SparsePRT::add_to_expanded_list(SparsePRT* sprt) { ...@@ -408,6 +416,7 @@ void SparsePRT::add_to_expanded_list(SparsePRT* sprt) {
} }
} }
SparsePRT* SparsePRT::get_from_expanded_list() { SparsePRT* SparsePRT::get_from_expanded_list() {
SparsePRT* hd = _head_expanded_list; SparsePRT* hd = _head_expanded_list;
while (hd != NULL) { while (hd != NULL) {
...@@ -452,6 +461,7 @@ SparsePRT::SparsePRT(HeapRegion* hr) : ...@@ -452,6 +461,7 @@ SparsePRT::SparsePRT(HeapRegion* hr) :
_next = _cur; _next = _cur;
} }
SparsePRT::~SparsePRT() { SparsePRT::~SparsePRT() {
assert(_next != NULL && _cur != NULL, "Inv"); assert(_next != NULL && _cur != NULL, "Inv");
if (_cur != _next) { delete _cur; } if (_cur != _next) { delete _cur; }
...@@ -465,7 +475,7 @@ size_t SparsePRT::mem_size() const { ...@@ -465,7 +475,7 @@ size_t SparsePRT::mem_size() const {
return sizeof(this) + _next->mem_size(); return sizeof(this) + _next->mem_size();
} }
bool SparsePRT::add_card(short region_id, short card_index) { bool SparsePRT::add_card(RegionIdx_t region_id, CardIdx_t card_index) {
#if SPARSE_PRT_VERBOSE #if SPARSE_PRT_VERBOSE
gclog_or_tty->print_cr(" Adding card %d from region %d to region %d sparse.", gclog_or_tty->print_cr(" Adding card %d from region %d to region %d sparse.",
card_index, region_id, _hr->hrs_index()); card_index, region_id, _hr->hrs_index());
...@@ -476,11 +486,11 @@ bool SparsePRT::add_card(short region_id, short card_index) { ...@@ -476,11 +486,11 @@ bool SparsePRT::add_card(short region_id, short card_index) {
return _next->add_card(region_id, card_index); return _next->add_card(region_id, card_index);
} }
bool SparsePRT::get_cards(short region_id, short* cards) { bool SparsePRT::get_cards(RegionIdx_t region_id, CardIdx_t* cards) {
return _next->get_cards(region_id, cards); return _next->get_cards(region_id, cards);
} }
bool SparsePRT::delete_entry(short region_id) { bool SparsePRT::delete_entry(RegionIdx_t region_id) {
return _next->delete_entry(region_id); return _next->delete_entry(region_id);
} }
......
...@@ -35,32 +35,32 @@ ...@@ -35,32 +35,32 @@
class SparsePRTEntry: public CHeapObj { class SparsePRTEntry: public CHeapObj {
public: public:
enum SomePublicConstants { enum SomePublicConstants {
CardsPerEntry = (short)4, CardsPerEntry = 4,
NullEntry = (short)-1, NullEntry = -1
DeletedEntry = (short)-2
}; };
private: private:
short _region_ind; RegionIdx_t _region_ind;
short _next_index; int _next_index;
short _cards[CardsPerEntry]; CardIdx_t _cards[CardsPerEntry];
public: public:
// Set the region_ind to the given value, and delete all cards. // Set the region_ind to the given value, and delete all cards.
inline void init(short region_ind); inline void init(RegionIdx_t region_ind);
short r_ind() const { return _region_ind; } RegionIdx_t r_ind() const { return _region_ind; }
bool valid_entry() const { return r_ind() >= 0; } bool valid_entry() const { return r_ind() >= 0; }
void set_r_ind(short rind) { _region_ind = rind; } void set_r_ind(RegionIdx_t rind) { _region_ind = rind; }
short next_index() const { return _next_index; } int next_index() const { return _next_index; }
short* next_index_addr() { return &_next_index; } int* next_index_addr() { return &_next_index; }
void set_next_index(short ni) { _next_index = ni; } void set_next_index(int ni) { _next_index = ni; }
// Returns "true" iff the entry contains the given card index. // Returns "true" iff the entry contains the given card index.
inline bool contains_card(short card_index) const; inline bool contains_card(CardIdx_t card_index) const;
// Returns the number of non-NULL card entries. // Returns the number of non-NULL card entries.
inline int num_valid_cards() const; inline int num_valid_cards() const;
...@@ -73,14 +73,14 @@ public: ...@@ -73,14 +73,14 @@ public:
found, found,
added added
}; };
inline AddCardResult add_card(short card_index); inline AddCardResult add_card(CardIdx_t card_index);
// Copy the current entry's cards into "cards". // Copy the current entry's cards into "cards".
inline void copy_cards(short* cards) const; inline void copy_cards(CardIdx_t* cards) const;
// Copy the current entry's cards into the "_card" array of "e." // Copy the current entry's cards into the "_card" array of "e."
inline void copy_cards(SparsePRTEntry* e) const; inline void copy_cards(SparsePRTEntry* e) const;
inline short card(int i) const { return _cards[i]; } inline CardIdx_t card(int i) const { return _cards[i]; }
}; };
...@@ -98,9 +98,9 @@ class RSHashTable : public CHeapObj { ...@@ -98,9 +98,9 @@ class RSHashTable : public CHeapObj {
size_t _occupied_cards; size_t _occupied_cards;
SparsePRTEntry* _entries; SparsePRTEntry* _entries;
short* _buckets; int* _buckets;
short _free_region; int _free_region;
short _free_list; int _free_list;
static RSHashTable* _head_deleted_list; static RSHashTable* _head_deleted_list;
RSHashTable* _next_deleted; RSHashTable* _next_deleted;
...@@ -113,20 +113,20 @@ class RSHashTable : public CHeapObj { ...@@ -113,20 +113,20 @@ class RSHashTable : public CHeapObj {
// operations, and that the the table be less than completely full. If // operations, and that the the table be less than completely full. If
// an entry for "region_ind" is already in the table, finds it and // an entry for "region_ind" is already in the table, finds it and
// returns its address; otherwise returns "NULL." // returns its address; otherwise returns "NULL."
SparsePRTEntry* entry_for_region_ind(short region_ind) const; SparsePRTEntry* entry_for_region_ind(RegionIdx_t region_ind) const;
// Requires that the caller hold a lock preventing parallel modifying // Requires that the caller hold a lock preventing parallel modifying
// operations, and that the the table be less than completely full. If // operations, and that the the table be less than completely full. If
// an entry for "region_ind" is already in the table, finds it and // an entry for "region_ind" is already in the table, finds it and
// returns its address; otherwise allocates, initializes, inserts and // returns its address; otherwise allocates, initializes, inserts and
// returns a new entry for "region_ind". // returns a new entry for "region_ind".
SparsePRTEntry* entry_for_region_ind_create(short region_ind); SparsePRTEntry* entry_for_region_ind_create(RegionIdx_t region_ind);
// Returns the index of the next free entry in "_entries". // Returns the index of the next free entry in "_entries".
short alloc_entry(); int alloc_entry();
// Declares the entry "fi" to be free. (It must have already been // Declares the entry "fi" to be free. (It must have already been
// deleted from any bucket lists. // deleted from any bucket lists.
void free_entry(short fi); void free_entry(int fi);
public: public:
RSHashTable(size_t capacity); RSHashTable(size_t capacity);
...@@ -138,12 +138,12 @@ public: ...@@ -138,12 +138,12 @@ public:
// Otherwise, returns "false" to indicate that the addition would // Otherwise, returns "false" to indicate that the addition would
// overflow the entry for the region. The caller must transfer these // overflow the entry for the region. The caller must transfer these
// entries to a larger-capacity representation. // entries to a larger-capacity representation.
bool add_card(short region_id, short card_index); bool add_card(RegionIdx_t region_id, CardIdx_t card_index);
bool get_cards(short region_id, short* cards); bool get_cards(RegionIdx_t region_id, CardIdx_t* cards);
bool delete_entry(short region_id); bool delete_entry(RegionIdx_t region_id);
bool contains_card(short region_id, short card_index) const; bool contains_card(RegionIdx_t region_id, CardIdx_t card_index) const;
void add_entry(SparsePRTEntry* e); void add_entry(SparsePRTEntry* e);
...@@ -162,52 +162,50 @@ public: ...@@ -162,52 +162,50 @@ public:
static void add_to_deleted_list(RSHashTable* rsht); static void add_to_deleted_list(RSHashTable* rsht);
static RSHashTable* get_from_deleted_list(); static RSHashTable* get_from_deleted_list();
}; };
// ValueObj because will be embedded in HRRS iterator. // ValueObj because will be embedded in HRRS iterator.
class RSHashTableIter VALUE_OBJ_CLASS_SPEC { class RSHashTableIter VALUE_OBJ_CLASS_SPEC {
short _tbl_ind; int _tbl_ind; // [-1, 0.._rsht->_capacity)
short _bl_ind; int _bl_ind; // [-1, 0.._rsht->_capacity)
short _card_ind; short _card_ind; // [0..CardsPerEntry)
RSHashTable* _rsht; RSHashTable* _rsht;
size_t _heap_bot_card_ind; size_t _heap_bot_card_ind;
enum SomePrivateConstants {
CardsPerRegion = HeapRegion::GrainBytes >> CardTableModRefBS::card_shift
};
// If the bucket list pointed to by _bl_ind contains a card, sets
// _bl_ind to the index of that entry, and returns the card.
// Otherwise, returns SparseEntry::NullEnty.
short find_first_card_in_list();
// Computes the proper card index for the card whose offset in the
// current region (as indicated by _bl_ind) is "ci".
// This is subject to errors when there is iteration concurrent with
// modification, but these errors should be benign.
size_t compute_card_ind(short ci);
public:
RSHashTableIter(size_t heap_bot_card_ind) :
_tbl_ind(RSHashTable::NullEntry),
_bl_ind(RSHashTable::NullEntry),
_card_ind((SparsePRTEntry::CardsPerEntry-1)),
_rsht(NULL),
_heap_bot_card_ind(heap_bot_card_ind)
{}
void init(RSHashTable* rsht) {
_rsht = rsht;
_tbl_ind = -1; // So that first increment gets to 0.
_bl_ind = RSHashTable::NullEntry;
_card_ind = (SparsePRTEntry::CardsPerEntry-1);
}
bool has_next(size_t& card_index);
enum SomePrivateConstants {
CardsPerRegion = HeapRegion::GrainBytes >> CardTableModRefBS::card_shift
}; };
// If the bucket list pointed to by _bl_ind contains a card, sets
// _bl_ind to the index of that entry, and returns the card.
// Otherwise, returns SparseEntry::NullEntry.
CardIdx_t find_first_card_in_list();
// Computes the proper card index for the card whose offset in the
// current region (as indicated by _bl_ind) is "ci".
// This is subject to errors when there is iteration concurrent with
// modification, but these errors should be benign.
size_t compute_card_ind(CardIdx_t ci);
public:
RSHashTableIter(size_t heap_bot_card_ind) :
_tbl_ind(RSHashTable::NullEntry),
_bl_ind(RSHashTable::NullEntry),
_card_ind((SparsePRTEntry::CardsPerEntry-1)),
_rsht(NULL),
_heap_bot_card_ind(heap_bot_card_ind)
{}
void init(RSHashTable* rsht) {
_rsht = rsht;
_tbl_ind = -1; // So that first increment gets to 0.
_bl_ind = RSHashTable::NullEntry;
_card_ind = (SparsePRTEntry::CardsPerEntry-1);
}
bool has_next(size_t& card_index);
};
// Concurrent accesss to a SparsePRT must be serialized by some external // Concurrent accesss to a SparsePRT must be serialized by some external
// mutex. // mutex.
...@@ -238,7 +236,6 @@ class SparsePRT VALUE_OBJ_CLASS_SPEC { ...@@ -238,7 +236,6 @@ class SparsePRT VALUE_OBJ_CLASS_SPEC {
SparsePRT* next_expanded() { return _next_expanded; } SparsePRT* next_expanded() { return _next_expanded; }
void set_next_expanded(SparsePRT* nxt) { _next_expanded = nxt; } void set_next_expanded(SparsePRT* nxt) { _next_expanded = nxt; }
static SparsePRT* _head_expanded_list; static SparsePRT* _head_expanded_list;
public: public:
...@@ -255,16 +252,16 @@ public: ...@@ -255,16 +252,16 @@ public:
// Otherwise, returns "false" to indicate that the addition would // Otherwise, returns "false" to indicate that the addition would
// overflow the entry for the region. The caller must transfer these // overflow the entry for the region. The caller must transfer these
// entries to a larger-capacity representation. // entries to a larger-capacity representation.
bool add_card(short region_id, short card_index); bool add_card(RegionIdx_t region_id, CardIdx_t card_index);
// If the table hold an entry for "region_ind", Copies its // If the table hold an entry for "region_ind", Copies its
// cards into "cards", which must be an array of length at least // cards into "cards", which must be an array of length at least
// "CardsPerEntry", and returns "true"; otherwise, returns "false". // "CardsPerEntry", and returns "true"; otherwise, returns "false".
bool get_cards(short region_ind, short* cards); bool get_cards(RegionIdx_t region_ind, CardIdx_t* cards);
// If there is an entry for "region_ind", removes it and return "true"; // If there is an entry for "region_ind", removes it and return "true";
// otherwise returns "false." // otherwise returns "false."
bool delete_entry(short region_ind); bool delete_entry(RegionIdx_t region_ind);
// Clear the table, and reinitialize to initial capacity. // Clear the table, and reinitialize to initial capacity.
void clear(); void clear();
...@@ -276,13 +273,12 @@ public: ...@@ -276,13 +273,12 @@ public:
static void cleanup_all(); static void cleanup_all();
RSHashTable* cur() const { return _cur; } RSHashTable* cur() const { return _cur; }
void init_iterator(SparsePRTIter* sprt_iter); void init_iterator(SparsePRTIter* sprt_iter);
static void add_to_expanded_list(SparsePRT* sprt); static void add_to_expanded_list(SparsePRT* sprt);
static SparsePRT* get_from_expanded_list(); static SparsePRT* get_from_expanded_list();
bool contains_card(short region_id, short card_index) const { bool contains_card(RegionIdx_t region_id, CardIdx_t card_index) const {
return _next->contains_card(region_id, card_index); return _next->contains_card(region_id, card_index);
} }
......
...@@ -51,7 +51,6 @@ concurrentG1Refine.hpp globalDefinitions.hpp ...@@ -51,7 +51,6 @@ concurrentG1Refine.hpp globalDefinitions.hpp
concurrentG1Refine.hpp allocation.hpp concurrentG1Refine.hpp allocation.hpp
concurrentG1Refine.hpp thread.hpp concurrentG1Refine.hpp thread.hpp
concurrentG1RefineThread.cpp concurrentG1Refine.hpp concurrentG1RefineThread.cpp concurrentG1Refine.hpp
concurrentG1RefineThread.cpp concurrentG1RefineThread.hpp concurrentG1RefineThread.cpp concurrentG1RefineThread.hpp
concurrentG1RefineThread.cpp g1CollectedHeap.inline.hpp concurrentG1RefineThread.cpp g1CollectedHeap.inline.hpp
...@@ -334,6 +333,7 @@ sparsePRT.cpp space.inline.hpp ...@@ -334,6 +333,7 @@ sparsePRT.cpp space.inline.hpp
sparsePRT.hpp allocation.hpp sparsePRT.hpp allocation.hpp
sparsePRT.hpp cardTableModRefBS.hpp sparsePRT.hpp cardTableModRefBS.hpp
sparsePRT.hpp globalDefinitions.hpp sparsePRT.hpp globalDefinitions.hpp
sparsePRT.hpp g1CollectedHeap.inline.hpp
sparsePRT.hpp heapRegion.hpp sparsePRT.hpp heapRegion.hpp
sparsePRT.hpp mutex.hpp sparsePRT.hpp mutex.hpp
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册