equal
deleted
inserted
replaced
54 assert(!in_cset_state.is_in_cset_or_humongous(), |
54 assert(!in_cset_state.is_in_cset_or_humongous(), |
55 err_msg("In_cset_state must be NotInCSet here, but is " CSETSTATE_FORMAT, in_cset_state.value())); |
55 err_msg("In_cset_state must be NotInCSet here, but is " CSETSTATE_FORMAT, in_cset_state.value())); |
56 } |
56 } |
57 |
57 |
58 assert(obj != NULL, "Must be"); |
58 assert(obj != NULL, "Must be"); |
59 update_rs(from, p, queue_num()); |
59 update_rs(from, p, _worker_id); |
60 } |
60 } |
61 |
61 |
62 template <class T> inline void G1ParScanThreadState::push_on_queue(T* ref) { |
62 template <class T> inline void G1ParScanThreadState::push_on_queue(T* ref) { |
63 assert(verify_ref(ref), "sanity"); |
63 assert(verify_ref(ref), "sanity"); |
64 _refs->push(ref); |
64 _refs->push(ref); |
134 } |
134 } |
135 } |
135 } |
136 |
136 |
137 void G1ParScanThreadState::steal_and_trim_queue(RefToScanQueueSet *task_queues) { |
137 void G1ParScanThreadState::steal_and_trim_queue(RefToScanQueueSet *task_queues) { |
138 StarTask stolen_task; |
138 StarTask stolen_task; |
139 while (task_queues->steal(queue_num(), hash_seed(), stolen_task)) { |
139 while (task_queues->steal(_worker_id, &_hash_seed, stolen_task)) { |
140 assert(verify_task(stolen_task), "sanity"); |
140 assert(verify_task(stolen_task), "sanity"); |
141 dispatch_reference(stolen_task); |
141 dispatch_reference(stolen_task); |
142 |
142 |
143 // We've just processed a reference and we might have made |
143 // We've just processed a reference and we might have made |
144 // available new entries on the queues. So we have to make sure |
144 // available new entries on the queues. So we have to make sure |