equal
deleted
inserted
replaced
486 void JfrRecorderService::open_new_chunk(bool vm_error) { |
486 void JfrRecorderService::open_new_chunk(bool vm_error) { |
487 JfrChunkRotation::on_rotation(); |
487 JfrChunkRotation::on_rotation(); |
488 const bool valid_chunk = _repository.open_chunk(vm_error); |
488 const bool valid_chunk = _repository.open_chunk(vm_error); |
489 _storage.control().set_to_disk(valid_chunk); |
489 _storage.control().set_to_disk(valid_chunk); |
490 if (valid_chunk) { |
490 if (valid_chunk) { |
491 _checkpoint_manager.write_constants(); |
491 _checkpoint_manager.write_static_type_set_and_threads(); |
492 } |
492 } |
493 } |
493 } |
494 |
494 |
495 static void stop() { |
495 static void stop() { |
496 assert(JfrRecorderService::is_recording(), "invariant"); |
496 assert(JfrRecorderService::is_recording(), "invariant"); |
662 if (_string_pool.is_modified()) { |
662 if (_string_pool.is_modified()) { |
663 total_elements += flush_stringpool(_string_pool, _chunkwriter); |
663 total_elements += flush_stringpool(_string_pool, _chunkwriter); |
664 } |
664 } |
665 if (_checkpoint_manager.is_type_set_required()) { |
665 if (_checkpoint_manager.is_type_set_required()) { |
666 total_elements += flush_typeset(_checkpoint_manager, _chunkwriter); |
666 total_elements += flush_typeset(_checkpoint_manager, _chunkwriter); |
667 } else if (_checkpoint_manager.is_constant_set_required()) { |
667 } else if (_checkpoint_manager.is_static_type_set_required()) { |
668 // don't tally this, it is only in order to flush the waiting constants |
668 // don't tally this, it is only in order to flush the waiting constants |
669 _checkpoint_manager.flush_constant_set(); |
669 _checkpoint_manager.flush_static_type_set(); |
670 } |
670 } |
671 return total_elements; |
671 return total_elements; |
672 } |
672 } |
673 |
673 |
674 typedef Content<EventFlush, JfrRecorderService, &JfrRecorderService::flush> FlushFunctor; |
674 typedef Content<EventFlush, JfrRecorderService, &JfrRecorderService::flush> FlushFunctor; |