Packages

rocksdb

1.4.0
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
63 Versions
0 Dependencies
Dependants
Files
Activity
rocksdb deps rocksdb logging log_buffer.h
Raw

deps/rocksdb/logging/log_buffer.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 <ctime>

#include "memory/arena.h"

#include "port/sys_time.h"

#include "rocksdb/env.h"

#include "util/autovector.h"



namespace rocksdb {



class Logger;



// A class to buffer info log entries and flush them in the end.

class LogBuffer {

 public:

  // log_level: the log level for all the logs

  // info_log:  logger to write the logs to

  LogBuffer(const InfoLogLevel log_level, Logger* info_log);



  // Add a log entry to the buffer. Use default max_log_size.

  // max_log_size indicates maximize log size, including some metadata.

  void AddLogToBuffer(size_t max_log_size, const char* format, va_list ap);



  size_t IsEmpty() const { return logs_.empty(); }



  // Flush all buffered log to the info log.

  void FlushBufferToLog();



 private:

  // One log entry with its timestamp

  struct BufferedLog {

    struct timeval now_tv;  // Timestamp of the log

    char message[1];        // Beginning of log message

  };



  const InfoLogLevel log_level_;

  Logger* info_log_;

  Arena arena_;

  autovector<BufferedLog*> logs_;

};



// Add log to the LogBuffer for a delayed info logging. It can be used when

// we want to add some logs inside a mutex.

// max_log_size indicates maximize log size, including some metadata.

extern void LogToBuffer(LogBuffer* log_buffer, size_t max_log_size,

                        const char* format, ...);

// Same as previous function, but with default max log size.

extern void LogToBuffer(LogBuffer* log_buffer, const char* format, ...);



}  // namespace rocksdb