Packages

rocksdb

3.1.2
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.cc
Raw

deps/rocksdb/monitoring/iostats_context.cc 

// 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).



#include <sstream>



#include "monitoring/iostats_context_imp.h"

#include "rocksdb/env.h"



namespace ROCKSDB_NAMESPACE {



#ifdef NIOSTATS_CONTEXT

// Should not be used because the counters are not thread-safe.

// Put here just to make get_iostats_context() simple without ifdef.

static IOStatsContext iostats_context;

#else

thread_local IOStatsContext iostats_context;

#endif



IOStatsContext* get_iostats_context() { return &iostats_context; }



void IOStatsContext::Reset() {

#ifndef NIOSTATS_CONTEXT

  thread_pool_id = Env::Priority::TOTAL;

  bytes_read = 0;

  bytes_written = 0;

  open_nanos = 0;

  allocate_nanos = 0;

  write_nanos = 0;

  read_nanos = 0;

  range_sync_nanos = 0;

  prepare_write_nanos = 0;

  fsync_nanos = 0;

  logger_nanos = 0;

  cpu_write_nanos = 0;

  cpu_read_nanos = 0;

  file_io_stats_by_temperature.Reset();

#endif  //! NIOSTATS_CONTEXT

}



#define IOSTATS_CONTEXT_OUTPUT(counter)         \

  if (!exclude_zero_counters || counter > 0) {  \

    ss << #counter << " = " << counter << ", "; \

  }



std::string IOStatsContext::ToString(bool exclude_zero_counters) const {

#ifdef NIOSTATS_CONTEXT

  (void)exclude_zero_counters;

  return "";

#else

  std::ostringstream ss;

  IOSTATS_CONTEXT_OUTPUT(thread_pool_id);

  IOSTATS_CONTEXT_OUTPUT(bytes_read);

  IOSTATS_CONTEXT_OUTPUT(bytes_written);

  IOSTATS_CONTEXT_OUTPUT(open_nanos);

  IOSTATS_CONTEXT_OUTPUT(allocate_nanos);

  IOSTATS_CONTEXT_OUTPUT(write_nanos);

  IOSTATS_CONTEXT_OUTPUT(read_nanos);

  IOSTATS_CONTEXT_OUTPUT(range_sync_nanos);

  IOSTATS_CONTEXT_OUTPUT(fsync_nanos);

  IOSTATS_CONTEXT_OUTPUT(prepare_write_nanos);

  IOSTATS_CONTEXT_OUTPUT(logger_nanos);

  IOSTATS_CONTEXT_OUTPUT(cpu_write_nanos);

  IOSTATS_CONTEXT_OUTPUT(cpu_read_nanos);

  IOSTATS_CONTEXT_OUTPUT(file_io_stats_by_temperature.hot_file_bytes_read);

  IOSTATS_CONTEXT_OUTPUT(file_io_stats_by_temperature.warm_file_bytes_read);

  IOSTATS_CONTEXT_OUTPUT(file_io_stats_by_temperature.cool_file_bytes_read);

  IOSTATS_CONTEXT_OUTPUT(file_io_stats_by_temperature.cold_file_bytes_read);

  IOSTATS_CONTEXT_OUTPUT(file_io_stats_by_temperature.hot_file_read_count);

  IOSTATS_CONTEXT_OUTPUT(file_io_stats_by_temperature.warm_file_read_count);

  IOSTATS_CONTEXT_OUTPUT(file_io_stats_by_temperature.cool_file_read_count);

  IOSTATS_CONTEXT_OUTPUT(file_io_stats_by_temperature.cold_file_read_count);

  std::string str = ss.str();

  str.erase(str.find_last_not_of(", ") + 1);

  return str;

#endif  //! NIOSTATS_CONTEXT

}



}  // namespace ROCKSDB_NAMESPACE