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 util event_logger.cc
Raw

deps/rocksdb/util/event_logger.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).



#ifndef __STDC_FORMAT_MACROS

#define __STDC_FORMAT_MACROS

#endif



#include "util/event_logger.h"



#include <inttypes.h>

#include <cassert>

#include <sstream>

#include <string>



#include "util/logging.h"

#include "util/string_util.h"



namespace rocksdb {





EventLoggerStream::EventLoggerStream(Logger* logger)

    : logger_(logger), log_buffer_(nullptr), json_writer_(nullptr) {}



EventLoggerStream::EventLoggerStream(LogBuffer* log_buffer)

    : logger_(nullptr), log_buffer_(log_buffer), json_writer_(nullptr) {}



EventLoggerStream::~EventLoggerStream() {

  if (json_writer_) {

    json_writer_->EndObject();

#ifdef ROCKSDB_PRINT_EVENTS_TO_STDOUT

    printf("%s\n", json_writer_->Get().c_str());

#else

    if (logger_) {

      EventLogger::Log(logger_, *json_writer_);

    } else if (log_buffer_) {

      EventLogger::LogToBuffer(log_buffer_, *json_writer_);

    }

#endif

    delete json_writer_;

  }

}



void EventLogger::Log(const JSONWriter& jwriter) {

  Log(logger_, jwriter);

}



void EventLogger::Log(Logger* logger, const JSONWriter& jwriter) {

#ifdef ROCKSDB_PRINT_EVENTS_TO_STDOUT

  printf("%s\n", jwriter.Get().c_str());

#else

  rocksdb::Log(logger, "%s %s", Prefix(), jwriter.Get().c_str());

#endif

}



void EventLogger::LogToBuffer(

    LogBuffer* log_buffer, const JSONWriter& jwriter) {

#ifdef ROCKSDB_PRINT_EVENTS_TO_STDOUT

  printf("%s\n", jwriter.Get().c_str());

#else

  assert(log_buffer);

  rocksdb::LogToBuffer(log_buffer, "%s %s", Prefix(), jwriter.Get().c_str());

#endif

}



}  // namespace rocksdb