mariadb/storage/rocksdb/rdb_perf_context.h
Sergei Petrunia 5e47d08eb6 Merge 'merge-myrocks' into 'bb-10.2-mariarocks'
Merged cset:
    Copy of

    commit d1bb19b8f751875472211312c8e810143a7ba4b6
    Author: Manuel Ung <mung@fb.com>
    Date:   Fri Feb 3 11:50:34 2017 -0800
    ...

        Add cardinality stats to information schema
2017-02-19 16:29:01 +00:00

139 lines
3.8 KiB
C++

/*
Portions Copyright (c) 2015-Present, Facebook, Inc.
Portions Copyright (c) 2012,2013 Monty Program Ab
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation; version 2 of the License.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */
#pragma once
/* C++ standard header files */
#include <atomic>
#include <cstdint>
#include <string>
/* MySQL header files */
#include "./handler.h"
#include <my_global.h>
#include "rdb_mariadb_port.h"
namespace myrocks {
enum {
PC_USER_KEY_COMPARISON_COUNT = 0,
PC_BLOCK_CACHE_HIT_COUNT,
PC_BLOCK_READ_COUNT,
PC_BLOCK_READ_BYTE,
PC_BLOCK_READ_TIME,
PC_BLOCK_CHECKSUM_TIME,
PC_BLOCK_DECOMPRESS_TIME,
PC_KEY_SKIPPED,
PC_DELETE_SKIPPED,
PC_GET_SNAPSHOT_TIME,
PC_GET_FROM_MEMTABLE_TIME,
PC_GET_FROM_MEMTABLE_COUNT,
PC_GET_POST_PROCESS_TIME,
PC_GET_FROM_OUTPUT_FILES_TIME,
PC_SEEK_ON_MEMTABLE_TIME,
PC_SEEK_ON_MEMTABLE_COUNT,
PC_SEEK_CHILD_SEEK_TIME,
PC_SEEK_CHILD_SEEK_COUNT,
PC_SEEK_MIN_HEAP_TIME,
PC_SEEK_INTERNAL_SEEK_TIME,
PC_FIND_NEXT_USER_ENTRY_TIME,
PC_WRITE_WAL_TIME,
PC_WRITE_MEMTABLE_TIME,
PC_WRITE_DELAY_TIME,
PC_WRITE_PRE_AND_POST_PROCESSS_TIME,
PC_DB_MUTEX_LOCK_NANOS,
PC_DB_CONDITION_WAIT_NANOS,
PC_MERGE_OPERATOR_TIME_NANOS,
PC_READ_INDEX_BLOCK_NANOS,
PC_READ_FILTER_BLOCK_NANOS,
PC_NEW_TABLE_BLOCK_ITER_NANOS,
PC_NEW_TABLE_ITERATOR_NANOS,
PC_BLOCK_SEEK_NANOS,
PC_FIND_TABLE_NANOS,
PC_IO_THREAD_POOL_ID,
PC_IO_BYTES_WRITTEN,
PC_IO_BYTES_READ,
PC_IO_OPEN_NANOS,
PC_IO_ALLOCATE_NANOS,
PC_IO_WRITE_NANOS,
PC_IO_READ_NANOS,
PC_IO_RANGE_SYNC_NANOS,
PC_IO_LOGGER_NANOS,
PC_MAX_IDX
};
class Rdb_perf_counters;
/*
A collection of performance counters that can be safely incremented by
multiple threads since it stores atomic datapoints.
*/
struct Rdb_atomic_perf_counters {
std::atomic_ullong m_value[PC_MAX_IDX];
};
/*
A collection of performance counters that is meant to be incremented by
a single thread.
*/
class Rdb_perf_counters {
Rdb_perf_counters(const Rdb_perf_counters &) = delete;
Rdb_perf_counters &operator=(const Rdb_perf_counters &) = delete;
public:
Rdb_perf_counters() = default;
uint64_t m_value[PC_MAX_IDX];
void load(const Rdb_atomic_perf_counters &atomic_counters);
};
extern std::string rdb_pc_stat_types[PC_MAX_IDX];
/*
Perf timers for data reads
*/
class Rdb_io_perf {
// Context management
Rdb_atomic_perf_counters *m_atomic_counters = nullptr;
my_io_perf_atomic_t *m_shared_io_perf_read = nullptr;
ha_statistics *m_stats = nullptr;
public:
Rdb_io_perf(const Rdb_io_perf &) = delete;
Rdb_io_perf &operator=(const Rdb_io_perf &) = delete;
void init(Rdb_atomic_perf_counters *const atomic_counters,
my_io_perf_atomic_t *const shared_io_perf_read,
ha_statistics *const stats) {
DBUG_ASSERT(atomic_counters != nullptr);
DBUG_ASSERT(shared_io_perf_read != nullptr);
DBUG_ASSERT(stats != nullptr);
m_atomic_counters = atomic_counters;
m_shared_io_perf_read = shared_io_perf_read;
m_stats = stats;
}
bool start(const uint32_t perf_context_level);
void end_and_record(const uint32_t perf_context_level);
explicit Rdb_io_perf()
: m_atomic_counters(nullptr), m_shared_io_perf_read(nullptr),
m_stats(nullptr) {}
};
} // namespace myrocks