leveldb::anonymous_namespace{env_posix.cc}::PosixWritableFile Class Reference

Inheritance diagram for leveldb::anonymous_namespace{env_posix.cc}::PosixWritableFile:

Collaboration diagram for leveldb::anonymous_namespace{env_posix.cc}::PosixWritableFile:

Public Member Functions
	PosixWritableFile (const std::string &fname, FILE *f)
	~PosixWritableFile ()
virtual Status	Append (const Slice &data)
virtual Status	Close ()
virtual Status	Flush ()
Status	SyncDirIfManifest ()
virtual Status	Sync ()
Public Member Functions inherited from leveldb::WritableFile
	WritableFile ()
virtual	~WritableFile ()

Private Attributes
std::string	filename_
FILE *	file_

Detailed Description

Definition at line 175 of file env_posix.cc.

Constructor & Destructor Documentation

PosixWritableFile()

leveldb::anonymous_namespace{env_posix.cc}::PosixWritableFile::PosixWritableFile ( const std::string &  fname, FILE *  f  )

inline

Definition at line 181 of file env_posix.cc.

      : filename_(fname), file_(f) { }

~PosixWritableFile()

leveldb::anonymous_namespace{env_posix.cc}::PosixWritableFile::~PosixWritableFile ( )

inline

Definition at line 184 of file env_posix.cc.

                       {
    if (file_ != NULL) {
      // Ignoring any potential errors
      fclose(file_);
    }
  }

Member Function Documentation

Append()

virtual Status leveldb::anonymous_namespace{env_posix.cc}::PosixWritableFile::Append ( const Slice &  data )

inlinevirtual

Implements leveldb::WritableFile.

Definition at line 191 of file env_posix.cc.

                                           {
    size_t r = fwrite_unlocked(data.data(), 1, data.size(), file_);
    if (r != data.size()) {
      return IOError(filename_, errno);
    }
    return Status::OK();
  }

Here is the call graph for this function:

Close()

virtual Status leveldb::anonymous_namespace{env_posix.cc}::PosixWritableFile::Close ( )

inlinevirtual

Implements leveldb::WritableFile.

Definition at line 199 of file env_posix.cc.

                         {
    Status result;
    if (fclose(file_) != 0) {
      result = IOError(filename_, errno);
    }
    file_ = NULL;
    return result;
  }

Here is the call graph for this function:

Flush()

virtual Status leveldb::anonymous_namespace{env_posix.cc}::PosixWritableFile::Flush ( )

inlinevirtual

Implements leveldb::WritableFile.

Definition at line 208 of file env_posix.cc.

                         {
    if (fflush_unlocked(file_) != 0) {
      return IOError(filename_, errno);
    }
    return Status::OK();
  }

Here is the call graph for this function:

Sync()

virtual Status leveldb::anonymous_namespace{env_posix.cc}::PosixWritableFile::Sync ( )

inlinevirtual

Implements leveldb::WritableFile.

Definition at line 242 of file env_posix.cc.

                        {
    // Ensure new files referred to by the manifest are in the filesystem.
    Status s = SyncDirIfManifest();
    if (!s.ok()) {
      return s;
    }
    if (fflush_unlocked(file_) != 0 ||
        fdatasync(fileno(file_)) != 0) {
      s = Status::IOError(filename_, strerror(errno));
    }
    return s;
  }

Here is the call graph for this function:

SyncDirIfManifest()

Status leveldb::anonymous_namespace{env_posix.cc}::PosixWritableFile::SyncDirIfManifest ( )

inline

Definition at line 215 of file env_posix.cc.

                             {
    const char* f = filename_.c_str();
    const char* sep = strrchr(f, '/');
    Slice basename;
    std::string dir;
    if (sep == NULL) {
      dir = ".";
      basename = f;
    } else {
      dir = std::string(f, sep - f);
      basename = sep + 1;
    }
    Status s;
    if (basename.starts_with("MANIFEST")) {
      int fd = open(dir.c_str(), O_RDONLY);
      if (fd < 0) {
        s = IOError(dir, errno);
      } else {
        if (fsync(fd) < 0) {
          s = IOError(dir, errno);
        }
        close(fd);
      }
    }
    return s;
  }

Here is the call graph for this function:

Member Data Documentation

file_

FILE* leveldb::anonymous_namespace{env_posix.cc}::PosixWritableFile::file_

private

Definition at line 178 of file env_posix.cc.

filename_

std::string leveldb::anonymous_namespace{env_posix.cc}::PosixWritableFile::filename_

private

Definition at line 177 of file env_posix.cc.

---

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

• util/env_posix.cc