1/*
2 * Copyright (c) 2016, 2019, Oracle and/or its affiliates. All rights reserved.
3 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
4 *
5 * This code is free software; you can redistribute it and/or modify it
6 * under the terms of the GNU General Public License version 2 only, as
7 * published by the Free Software Foundation.
8 *
9 * This code is distributed in the hope that it will be useful, but WITHOUT
10 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
11 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
12 * version 2 for more details (a copy is included in the LICENSE file that
13 * accompanied this code).
14 *
15 * You should have received a copy of the GNU General Public License version
16 * 2 along with this work; if not, write to the Free Software Foundation,
17 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
18 *
19 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
20 * or visit www.oracle.com if you need additional information or have any
21 * questions.
22 *
23 */
24
25#ifndef SHARE_JFR_RECORDER_CHECKPOINT_JFRCHECKPOINTWRITER_HPP
26#define SHARE_JFR_RECORDER_CHECKPOINT_JFRCHECKPOINTWRITER_HPP
27
28#include "jfr/recorder/checkpoint/jfrCheckpointBlob.hpp"
29#include "jfr/recorder/storage/jfrBuffer.hpp"
30#include "jfr/utilities/jfrTime.hpp"
31#include "jfr/utilities/jfrTypes.hpp"
32#include "jfr/writers/jfrEventWriterHost.inline.hpp"
33#include "jfr/writers/jfrMemoryWriterHost.inline.hpp"
34#include "jfr/writers/jfrStorageAdapter.hpp"
35
36class Thread;
37
38class JfrCheckpointFlush : public StackObj {
39 public:
40 typedef JfrBuffer Type;
41 JfrCheckpointFlush(Type* old, size_t used, size_t requested, Thread* t);
42 Type* result() { return _result; }
43 private:
44 Type* _result;
45};
46
47typedef Adapter<JfrCheckpointFlush> JfrCheckpointAdapter;
48typedef AcquireReleaseMemoryWriterHost<JfrCheckpointAdapter, StackObj > JfrTransactionalCheckpointWriter;
49typedef EventWriterHost<BigEndianEncoder, CompressedIntegerEncoder, JfrTransactionalCheckpointWriter> JfrCheckpointWriterBase;
50
51struct JfrCheckpointContext {
52 int64_t offset;
53 u4 count;
54};
55
56class JfrCheckpointWriter : public JfrCheckpointWriterBase {
57 friend class JfrSerializerRegistration;
58 private:
59 JfrTicks _time;
60 int64_t _offset;
61 u4 _count;
62 bool _flushpoint;
63 bool _header;
64
65 u4 count() const;
66 void set_count(u4 count);
67 void increment();
68 void set_flushpoint(bool flushpoint);
69 bool is_flushpoint() const;
70 const u1* session_data(size_t* size, const JfrCheckpointContext* ctx = NULL);
71 void release();
72
73 public:
74 JfrCheckpointWriter(bool flushpoint, bool header, Thread* thread);
75 ~JfrCheckpointWriter();
76 void write_type(JfrTypeId type_id);
77 void write_count(u4 nof_entries);
78 void write_count(u4 nof_entries, int64_t offset);
79 void write_key(u8 key);
80 const JfrCheckpointContext context() const;
81 void set_context(const JfrCheckpointContext ctx);
82 bool has_data() const;
83 JfrCheckpointBlobHandle checkpoint_blob();
84 JfrCheckpointBlobHandle copy(const JfrCheckpointContext* ctx = NULL);
85 JfrCheckpointBlobHandle move(const JfrCheckpointContext* ctx = NULL);
86};
87
88#endif // SHARE_JFR_RECORDER_CHECKPOINT_JFRCHECKPOINTWRITER_HPP
89