Packages

rocksdb

1.3.0
3.1.2 3.1.1 3.1.0 3.0.0 2.6.2 2.6.1 retired 2.6.0 retired 2.5.0 2.4.1 2.4.0 2.3.0 2.2.0 2.1.0 2.0.0 1.9.0 1.8.0 1.7.0 1.6.0 1.5.1 1.5.0 1.4.0 1.3.2 1.3.1 1.3.0 1.2.0 1.1.1 1.1.0 1.0.0 0.26.2 0.26.1 0.26.0 0.25.0 0.24.0 0.23.3 0.23.2 0.23.1 0.23.0 0.22.0 0.21.0 0.20.1 0.20.0 0.19.0 0.18.0 0.17.0 0.16.0 0.15.0 0.14.0 0.13.1 0.13.0 0.12.0 0.11.0 0.10.0 0.9.1 0.9.0 0.8.2 0.8.1 0.8.0 0.7.1 0.7.0 0.6.4 0.6.3 0.6.2 0.6.1 0.6.0

RocksDB for Erlang

HexDocs

Current section

Files

Jump to
Readme
64 Versions
0 Dependencies
Dependants
Files
Activity
rocksdb deps rocksdb monitoring iostats_context_imp.h
Raw

deps/rocksdb/monitoring/iostats_context_imp.h 

//  Copyright (c) 2011-present, Facebook, Inc.  All rights reserved.

//  This source code is licensed under both the GPLv2 (found in the

//  COPYING file in the root directory) and Apache 2.0 License

//  (found in the LICENSE.Apache file in the root directory).

//

#pragma once

#include "monitoring/perf_step_timer.h"

#include "rocksdb/iostats_context.h"



#ifdef ROCKSDB_SUPPORT_THREAD_LOCAL

namespace rocksdb {

extern __thread IOStatsContext iostats_context;

}  // namespace rocksdb



// increment a specific counter by the specified value

#define IOSTATS_ADD(metric, value) (iostats_context.metric += value)



// Increase metric value only when it is positive

#define IOSTATS_ADD_IF_POSITIVE(metric, value)   \

  if (value > 0) { IOSTATS_ADD(metric, value); }



// reset a specific counter to zero

#define IOSTATS_RESET(metric) (iostats_context.metric = 0)



// reset all counters to zero

#define IOSTATS_RESET_ALL() (iostats_context.Reset())



#define IOSTATS_SET_THREAD_POOL_ID(value) \

  (iostats_context.thread_pool_id = value)



#define IOSTATS_THREAD_POOL_ID() (iostats_context.thread_pool_id)



#define IOSTATS(metric) (iostats_context.metric)



// Declare and set start time of the timer

#define IOSTATS_TIMER_GUARD(metric)                                     \

  PerfStepTimer iostats_step_timer_##metric(&(iostats_context.metric)); \

  iostats_step_timer_##metric.Start();



// Declare and set start time of the timer

#define IOSTATS_CPU_TIMER_GUARD(metric, env)           \

  PerfStepTimer iostats_step_timer_##metric(           \

      &(iostats_context.metric), env, true,            \

      PerfLevel::kEnableTimeAndCPUTimeExceptForMutex); \

  iostats_step_timer_##metric.Start();



#else  // ROCKSDB_SUPPORT_THREAD_LOCAL



#define IOSTATS_ADD(metric, value)

#define IOSTATS_ADD_IF_POSITIVE(metric, value)

#define IOSTATS_RESET(metric)

#define IOSTATS_RESET_ALL()

#define IOSTATS_SET_THREAD_POOL_ID(value)

#define IOSTATS_THREAD_POOL_ID()

#define IOSTATS(metric) 0



#define IOSTATS_TIMER_GUARD(metric)

#define IOSTATS_CPU_TIMER_GUARD(metric, env)   static_cast<void>(env)



#endif  // ROCKSDB_SUPPORT_THREAD_LOCAL