< prev index next >

src/hotspot/share/gc/shared/threadLocalAllocBuffer.cpp

Print this page
rev 50392 : JEP 331

*** 43,52 **** --- 43,60 ---- void ThreadLocalAllocBuffer::clear_before_allocation() { _slow_refill_waste += (unsigned)remaining(); make_parsable(true); // also retire the TLAB } + size_t ThreadLocalAllocBuffer::remaining() { + if (end() == NULL) { + return 0; + } + + return pointer_delta(hard_end(), top()); + } + void ThreadLocalAllocBuffer::accumulate_statistics_before_gc() { global_stats()->initialize(); for (JavaThreadIteratorWithHandle jtiwh; JavaThread *thread = jtiwh.next(); ) { thread->tlab().accumulate_statistics();
*** 119,132 **** if (retire || ZeroTLAB) { // "Reset" the TLAB set_start(NULL); set_top(NULL); set_pf_top(NULL); set_end(NULL); } } assert(!(retire || ZeroTLAB) || ! (start() == NULL && end() == NULL && top() == NULL), "TLAB must be reset"); } void ThreadLocalAllocBuffer::resize_all_tlabs() { if (ResizeTLAB) { --- 127,142 ---- if (retire || ZeroTLAB) { // "Reset" the TLAB set_start(NULL); set_top(NULL); set_pf_top(NULL); set_end(NULL); + set_allocation_end(NULL); } } assert(!(retire || ZeroTLAB) || ! (start() == NULL && end() == NULL && top() == NULL && ! _allocation_end == NULL), "TLAB must be reset"); } void ThreadLocalAllocBuffer::resize_all_tlabs() { if (ResizeTLAB) {
*** 170,181 **** --- 180,196 ---- size_t new_size) { _number_of_refills++; _allocated_size += new_size; print_stats("fill"); assert(top <= start + new_size - alignment_reserve(), "size too small"); + initialize(start, top, start + new_size - alignment_reserve()); + if (ThreadHeapSampler::enabled()) { + set_sample_end(); + } + // Reset amount of internal fragmentation set_refill_waste_limit(initial_refill_waste_limit()); } void ThreadLocalAllocBuffer::initialize(HeapWord* start,
*** 183,192 **** --- 198,208 ---- HeapWord* end) { set_start(start); set_top(top); set_pf_top(top); set_end(end); + set_allocation_end(end); invariants(); } void ThreadLocalAllocBuffer::initialize() { initialize(NULL, // start
*** 304,319 **** --- 320,368 ---- p += oop(p)->size(); } guarantee(p == top(), "end of last object must match end of space"); } + void ThreadLocalAllocBuffer::set_sample_end() { + size_t heap_words_remaining = pointer_delta(_end, _top); + size_t bytes_until_sample = myThread()->heap_sampler().bytes_until_sample(); + size_t words_until_sample = bytes_until_sample / HeapWordSize;; + + if (heap_words_remaining > words_until_sample) { + HeapWord* new_end = _top + words_until_sample; + set_end(new_end); + _bytes_since_last_sample_point = bytes_until_sample; + } else { + _bytes_since_last_sample_point = heap_words_remaining * HeapWordSize;; + } + } + Thread* ThreadLocalAllocBuffer::myThread() { return (Thread*)(((char *)this) + in_bytes(start_offset()) - in_bytes(Thread::tlab_start_offset())); } + void ThreadLocalAllocBuffer::set_back_allocation_end() { + _end = _allocation_end; + } + + HeapWord* ThreadLocalAllocBuffer::allocate_sampled_object(size_t size) { + set_back_allocation_end(); + HeapWord* result = allocate(size); + + if (result) { + myThread()->heap_sampler().check_for_sampling(result, size * HeapWordSize, _bytes_since_last_sample_point); + set_sample_end(); + } + + return result; + } + + HeapWord* ThreadLocalAllocBuffer::hard_end() { + return _allocation_end + alignment_reserve(); + } GlobalTLABStats::GlobalTLABStats() : _allocating_threads_avg(TLABAllocationWeight) { initialize();
< prev index next >