leveldb::PosixLogger Class Reference

#include <posix_logger.h>

Inheritance diagram for leveldb::PosixLogger:

Collaboration diagram for leveldb::PosixLogger:

Public Member Functions
	PosixLogger (FILE *f, uint64_t(*gettid)())
virtual	~PosixLogger ()
virtual void	Logv (const char *format, va_list ap)
Public Member Functions inherited from leveldb::Logger
	Logger ()
virtual	~Logger ()

Private Attributes
FILE *	file_
uint64_t(*	gettid_ )()

Detailed Description

Definition at line 19 of file posix_logger.h.

Constructor & Destructor Documentation

PosixLogger()

leveldb::PosixLogger::PosixLogger ( FILE *  f, uint64_t(*)()  gettid  )

inline

Definition at line 24 of file posix_logger.h.

: file_(f), gettid_(gettid) { }

~PosixLogger()

virtual leveldb::PosixLogger::~PosixLogger ( )

inlinevirtual

Definition at line 25 of file posix_logger.h.

                         {
    fclose(file_);
  }

Member Function Documentation

Logv()

virtual void leveldb::PosixLogger::Logv ( const char *  format, va_list  ap  )

inlinevirtual

Implements leveldb::Logger.

Definition at line 28 of file posix_logger.h.

                                                    {
    const uint64_t thread_id = (*gettid_)();

    // We try twice: the first time with a fixed-size stack allocated buffer,
    // and the second time with a much larger dynamically allocated buffer.
    char buffer[500];
    for (int iter = 0; iter < 2; iter++) {
      char* base;
      int bufsize;
      if (iter == 0) {
        bufsize = sizeof(buffer);
        base = buffer;
      } else {
        bufsize = 30000;
        base = new char[bufsize];
      }
      char* p = base;
      char* limit = base + bufsize;

      struct timeval now_tv;
      gettimeofday(&now_tv, NULL);
      const time_t seconds = now_tv.tv_sec;
      struct tm t;
      localtime_r(&seconds, &t);
      p += snprintf(p, limit - p,
                    "%04d/%02d/%02d-%02d:%02d:%02d.%06d %llx ",
                    t.tm_year + 1900,
                    t.tm_mon + 1,
                    t.tm_mday,
                    t.tm_hour,
                    t.tm_min,
                    t.tm_sec,
                    static_cast<int>(now_tv.tv_usec),
                    static_cast<long long unsigned int>(thread_id));

      // Print the message
      if (p < limit) {
        va_list backup_ap;
        va_copy(backup_ap, ap);
        p += vsnprintf(p, limit - p, format, backup_ap);
        va_end(backup_ap);
      }

      // Truncate to available space if necessary
      if (p >= limit) {
        if (iter == 0) {
          continue;       // Try again with larger buffer
        } else {
          p = limit - 1;
        }
      }

      // Add newline if necessary
      if (p == base || p[-1] != '\n') {
        *p++ = '\n';
      }

      assert(p <= limit);
      fwrite(base, 1, p - base, file_);
      fflush(file_);
      if (base != buffer) {
        delete[] base;
      }
      break;
    }
  }

Member Data Documentation

file_

FILE* leveldb::PosixLogger::file_

private

Definition at line 21 of file posix_logger.h.

gettid_

uint64_t(* leveldb::PosixLogger::gettid_) ()

private

Definition at line 22 of file posix_logger.h.

---

The documentation for this class was generated from the following file:

• util/posix_logger.h