src/hotspot/share/jfr/recorder/checkpoint/types/jfrTypeManager.cpp
author mgronlun
Wed, 30 Oct 2019 19:43:52 +0100
changeset 58863 c16ac7a2eba4
parent 58786 7909763ad193
permissions -rw-r--r--
8226511: Implement JFR Event Streaming Reviewed-by: egahlin, mseledtsov, mgronlun Contributed-by: erik.gahlin@oracle.com, mikhailo.seledtsov@oracle.com, markus.gronlund@oracle.com
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
     1
/*
54623
1126f0607c70 8222811: Consolidate MutexLockerEx and MutexLocker
coleenp
parents: 52212
diff changeset
     2
 * Copyright (c) 2016, 2019, Oracle and/or its affiliates. All rights reserved.
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
     3
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
     4
 *
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
     5
 * This code is free software; you can redistribute it and/or modify it
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
     6
 * under the terms of the GNU General Public License version 2 only, as
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
     7
 * published by the Free Software Foundation.
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
     8
 *
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
     9
 * This code is distributed in the hope that it will be useful, but WITHOUT
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    10
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    11
 * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    12
 * version 2 for more details (a copy is included in the LICENSE file that
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    13
 * accompanied this code).
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    14
 *
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    15
 * You should have received a copy of the GNU General Public License version
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    16
 * 2 along with this work; if not, write to the Free Software Foundation,
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    17
 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    18
 *
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    19
 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    20
 * or visit www.oracle.com if you need additional information or have any
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    21
 * questions.
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    22
 *
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    23
 */
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    24
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    25
#include "precompiled.hpp"
50703
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    26
#include "jfr/metadata/jfrSerializer.hpp"
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    27
#include "jfr/recorder/checkpoint/jfrCheckpointWriter.hpp"
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    28
#include "jfr/recorder/checkpoint/types/jfrType.hpp"
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    29
#include "jfr/recorder/checkpoint/types/jfrTypeManager.hpp"
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
    30
#include "jfr/recorder/jfrRecorder.hpp"
50703
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    31
#include "jfr/utilities/jfrDoublyLinkedList.hpp"
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    32
#include "jfr/utilities/jfrIterator.hpp"
58132
caa25ab47aca 8225797: OldObjectSample event creates unexpected amount of checkpoint data
mgronlun
parents: 58003
diff changeset
    33
#include "memory/resourceArea.hpp"
caa25ab47aca 8225797: OldObjectSample event creates unexpected amount of checkpoint data
mgronlun
parents: 58003
diff changeset
    34
#include "runtime/handles.inline.hpp"
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    35
#include "runtime/safepoint.hpp"
58786
7909763ad193 8231081: TestMetadataRetention fails due to missing symbol id
mgronlun
parents: 58132
diff changeset
    36
#include "runtime/semaphore.hpp"
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    37
#include "runtime/thread.inline.hpp"
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    38
#include "utilities/exceptions.hpp"
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    39
50703
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    40
class JfrSerializerRegistration : public JfrCHeapObj {
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    41
 private:
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    42
  JfrSerializerRegistration* _next;
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    43
  JfrSerializerRegistration* _prev;
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    44
  JfrSerializer* _serializer;
58132
caa25ab47aca 8225797: OldObjectSample event creates unexpected amount of checkpoint data
mgronlun
parents: 58003
diff changeset
    45
  mutable JfrBlobHandle _cache;
50703
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    46
  JfrTypeId _id;
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    47
  bool _permit_cache;
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    48
50703
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    49
 public:
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    50
  JfrSerializerRegistration(JfrTypeId id, bool permit_cache, JfrSerializer* serializer) :
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    51
    _next(NULL), _prev(NULL), _serializer(serializer), _cache(), _id(id), _permit_cache(permit_cache) {}
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    52
50703
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    53
  ~JfrSerializerRegistration() {
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    54
    delete _serializer;
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    55
  }
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    56
50703
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    57
  JfrSerializerRegistration* next() const {
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    58
    return _next;
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    59
  }
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    60
50703
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    61
  void set_next(JfrSerializerRegistration* next) {
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    62
    _next = next;
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    63
  }
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    64
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    65
  JfrSerializerRegistration* prev() const {
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    66
    return _prev;
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    67
  }
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    68
50703
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    69
  void set_prev(JfrSerializerRegistration* prev) {
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    70
    _prev = prev;
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    71
  }
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    72
50703
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    73
  JfrTypeId id() const {
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    74
    return _id;
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
    75
  }
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    76
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
    77
  void on_rotation() const {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
    78
    _serializer->on_rotation();
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
    79
  }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
    80
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
    81
  void invoke(JfrCheckpointWriter& writer) const {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
    82
    if (_cache.valid()) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
    83
      writer.increment();
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
    84
      _cache->write(writer);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
    85
      return;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
    86
    }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
    87
    const JfrCheckpointContext ctx = writer.context();
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
    88
    // serialize the type id before invoking callback
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
    89
    writer.write_type(_id);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
    90
    const intptr_t start = writer.current_offset();
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
    91
    // invoke the serializer routine
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
    92
    _serializer->serialize(writer);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
    93
    if (start == writer.current_offset()) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
    94
      // the serializer implementation did nothing, rewind to restore
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
    95
      writer.set_context(ctx);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
    96
      return;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
    97
    }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
    98
    if (_permit_cache) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
    99
      _cache = writer.copy(&ctx);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   100
    }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   101
  }
50703
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   102
};
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   103
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   104
static void serialize_threads(JfrCheckpointWriter& writer) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   105
  JfrThreadConstantSet thread_set;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   106
  writer.write_type(TYPE_THREAD);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   107
  thread_set.serialize(writer);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   108
}
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   109
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   110
static void serialize_thread_groups(JfrCheckpointWriter& writer) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   111
  JfrThreadGroupConstant thread_group_set;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   112
  writer.write_type(TYPE_THREADGROUP);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   113
  thread_group_set.serialize(writer);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   114
}
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   115
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   116
void JfrTypeManager::write_threads(JfrCheckpointWriter& writer) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   117
  serialize_threads(writer);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   118
  serialize_thread_groups(writer);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   119
}
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   120
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   121
void JfrTypeManager::create_thread_blob(Thread* t) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   122
  assert(t != NULL, "invariant");
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   123
  ResourceMark rm(t);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   124
  HandleMark hm(t);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   125
  JfrThreadConstant type_thread(t);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   126
  JfrCheckpointWriter writer(t, true, THREADS);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   127
  writer.write_type(TYPE_THREAD);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   128
  type_thread.serialize(writer);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   129
  // create and install a checkpoint blob
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   130
  t->jfr_thread_local()->set_thread_blob(writer.move());
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   131
  assert(t->jfr_thread_local()->has_thread_blob(), "invariant");
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   132
}
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   133
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   134
void JfrTypeManager::write_thread_checkpoint(Thread* t) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   135
  assert(t != NULL, "invariant");
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   136
  ResourceMark rm(t);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   137
  HandleMark hm(t);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   138
  JfrThreadConstant type_thread(t);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   139
  JfrCheckpointWriter writer(t, true, THREADS);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   140
  writer.write_type(TYPE_THREAD);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   141
  type_thread.serialize(writer);
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   142
}
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   143
50703
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   144
class SerializerRegistrationGuard : public StackObj {
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   145
 private:
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   146
  static Semaphore _mutex_semaphore;
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   147
 public:
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   148
  SerializerRegistrationGuard() {
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   149
    _mutex_semaphore.wait();
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   150
  }
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   151
  ~SerializerRegistrationGuard() {
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   152
    _mutex_semaphore.signal();
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   153
  }
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   154
};
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   155
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   156
Semaphore SerializerRegistrationGuard::_mutex_semaphore(1);
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   157
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   158
typedef JfrDoublyLinkedList<JfrSerializerRegistration> List;
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   159
typedef StopOnNullIterator<const List> Iterator;
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   160
static List types;
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   161
58786
7909763ad193 8231081: TestMetadataRetention fails due to missing symbol id
mgronlun
parents: 58132
diff changeset
   162
void JfrTypeManager::destroy() {
50703
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   163
  SerializerRegistrationGuard guard;
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   164
  Iterator iter(types);
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   165
  JfrSerializerRegistration* registration;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   166
  while (iter.has_next()) {
50703
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   167
    registration = types.remove(iter.next());
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   168
    assert(registration != NULL, "invariant");
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   169
    delete registration;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   170
  }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   171
}
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   172
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   173
void JfrTypeManager::on_rotation() {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   174
  const Iterator iter(types);
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   175
  while (iter.has_next()) {
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   176
    iter.next()->on_rotation();
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   177
  }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   178
}
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   179
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   180
#ifdef ASSERT
50703
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   181
static void assert_not_registered_twice(JfrTypeId id, List& list) {
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   182
  const Iterator iter(list);
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   183
  while (iter.has_next()) {
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   184
    assert(iter.next()->id() != id, "invariant");
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   185
  }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   186
}
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   187
#endif
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   188
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   189
static bool new_registration = false;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   190
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   191
static bool register_static_type(JfrTypeId id, bool permit_cache, JfrSerializer* serializer) {
50703
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   192
  assert(serializer != NULL, "invariant");
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   193
  JfrSerializerRegistration* const registration = new JfrSerializerRegistration(id, permit_cache, serializer);
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   194
  if (registration == NULL) {
50703
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   195
    delete serializer;
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   196
    return false;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   197
  }
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   198
  assert(!types.in_list(registration), "invariant");
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   199
  DEBUG_ONLY(assert_not_registered_twice(id, types);)
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   200
  if (JfrRecorder::is_recording()) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   201
    JfrCheckpointWriter writer(STATICS);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   202
    registration->invoke(writer);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   203
    new_registration = true;
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   204
  }
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   205
  types.prepend(registration);
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   206
  return true;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   207
}
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   208
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   209
bool JfrTypeManager::initialize() {
50703
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   210
  SerializerRegistrationGuard guard;
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   211
  register_static_type(TYPE_FLAGVALUEORIGIN, true, new FlagValueOriginConstant());
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   212
  register_static_type(TYPE_INFLATECAUSE, true, new MonitorInflateCauseConstant());
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   213
  register_static_type(TYPE_GCCAUSE, true, new GCCauseConstant());
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   214
  register_static_type(TYPE_GCNAME, true, new GCNameConstant());
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   215
  register_static_type(TYPE_GCWHEN, true, new GCWhenConstant());
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   216
  register_static_type(TYPE_GCTHRESHOLDUPDATER, true, new GCThresholdUpdaterConstant());
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   217
  register_static_type(TYPE_METADATATYPE, true, new MetadataTypeConstant());
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   218
  register_static_type(TYPE_METASPACEOBJECTTYPE, true, new MetaspaceObjectTypeConstant());
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   219
  register_static_type(TYPE_REFERENCETYPE, true, new ReferenceTypeConstant());
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   220
  register_static_type(TYPE_NARROWOOPMODE, true, new NarrowOopModeConstant());
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   221
  register_static_type(TYPE_COMPILERPHASETYPE, true, new CompilerPhaseTypeConstant());
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   222
  register_static_type(TYPE_CODEBLOBTYPE, true, new CodeBlobTypeConstant());
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   223
  register_static_type(TYPE_VMOPERATIONTYPE, true, new VMOperationTypeConstant());
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   224
  register_static_type(TYPE_THREADSTATE, true, new ThreadStateConstant());
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   225
  return true;
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   226
}
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   227
50703
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   228
// implementation for the static registration function exposed in the JfrSerializer api
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   229
bool JfrSerializer::register_serializer(JfrTypeId id, bool permit_cache, JfrSerializer* serializer) {
50703
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   230
  SerializerRegistrationGuard guard;
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   231
  return register_static_type(id, permit_cache, serializer);
50703
0486d7749b8d 8205053: Decouple type registration from framework lifecycle
egahlin
parents: 50525
diff changeset
   232
}
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   233
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   234
bool JfrTypeManager::has_new_static_type() {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   235
  if (new_registration) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   236
    SerializerRegistrationGuard guard;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   237
    new_registration = false;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   238
    return true;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   239
  }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   240
  return false;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   241
}
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   242
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   243
void JfrTypeManager::write_static_types(JfrCheckpointWriter& writer) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   244
  SerializerRegistrationGuard guard;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   245
  const Iterator iter(types);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   246
  while (iter.has_next()) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   247
    iter.next()->invoke(writer);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   248
  }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   249
  new_registration = false;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 58786
diff changeset
   250
}