leveldb::TestWritableFile Class Reference

Inheritance diagram for leveldb::TestWritableFile:

Collaboration diagram for leveldb::TestWritableFile:

Public Member Functions
	TestWritableFile (const FileState &state, WritableFile *f, FaultInjectionTestEnv *env)
virtual	~TestWritableFile ()
virtual Status	Append (const Slice &data)
virtual Status	Close ()
virtual Status	Flush ()
virtual Status	Sync ()
Public Member Functions inherited from leveldb::WritableFile
	WritableFile ()
virtual	~WritableFile ()

Private Member Functions
Status	SyncParent ()

Private Attributes
FileState	state_
WritableFile *	target_
bool	writable_file_opened_
FaultInjectionTestEnv *	env_

Detailed Description

Definition at line 107 of file fault_injection_test.cc.

Constructor & Destructor Documentation

TestWritableFile()

leveldb::TestWritableFile::TestWritableFile	(	const FileState &	state,
		WritableFile *	f,
		FaultInjectionTestEnv *	env
	)

Definition at line 159 of file fault_injection_test.cc.

    : state_(state),
      target_(f),
      writable_file_opened_(true),
      env_(env) {
  assert(f != NULL);
}

Here is the caller graph for this function:

~TestWritableFile()

leveldb::TestWritableFile::~TestWritableFile ( )

virtual

Definition at line 169 of file fault_injection_test.cc.

                                    {
  if (writable_file_opened_) {
    Close();
  }
  delete target_;
}

Here is the call graph for this function:

Member Function Documentation

Append()

Status leveldb::TestWritableFile::Append ( const Slice &  data )

virtual

Implements leveldb::WritableFile.

Definition at line 176 of file fault_injection_test.cc.

                                                 {
  Status s = target_->Append(data);
  if (s.ok() && env_->IsFilesystemActive()) {
    state_.pos_ += data.size();
  }
  return s;
}

Here is the call graph for this function:

Close()

Status leveldb::TestWritableFile::Close ( )

virtual

Implements leveldb::WritableFile.

Definition at line 184 of file fault_injection_test.cc.

                               {
  writable_file_opened_ = false;
  Status s = target_->Close();
  if (s.ok()) {
    env_->WritableFileClosed(state_);
  }
  return s;
}

Here is the call graph for this function:

Here is the caller graph for this function:

Flush()

Status leveldb::TestWritableFile::Flush ( )

virtual

Implements leveldb::WritableFile.

Definition at line 193 of file fault_injection_test.cc.

                               {
  Status s = target_->Flush();
  if (s.ok() && env_->IsFilesystemActive()) {
    state_.pos_at_last_flush_ = state_.pos_;
  }
  return s;
}

Here is the call graph for this function:

Sync()

Status leveldb::TestWritableFile::Sync ( )

virtual

Implements leveldb::WritableFile.

Definition at line 209 of file fault_injection_test.cc.

                              {
  if (!env_->IsFilesystemActive()) {
    return Status::OK();
  }
  // Ensure new files referred to by the manifest are in the filesystem.
  Status s = target_->Sync();
  if (s.ok()) {
    state_.pos_at_last_sync_ = state_.pos_;
  }
  if (env_->IsFileCreatedSinceLastDirSync(state_.filename_)) {
    Status ps = SyncParent();
    if (s.ok() && !ps.ok()) {
      s = ps;
    }
  }
  return s;
}

Here is the call graph for this function:

SyncParent()

Status leveldb::TestWritableFile::SyncParent ( )

private

Definition at line 201 of file fault_injection_test.cc.

                                    {
  Status s = SyncDir(GetDirName(state_.filename_));
  if (s.ok()) {
    env_->DirWasSynced();
  }
  return s;
}

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

env_

FaultInjectionTestEnv* leveldb::TestWritableFile::env_

private

Definition at line 122 of file fault_injection_test.cc.

state_

FileState leveldb::TestWritableFile::state_

private

Definition at line 119 of file fault_injection_test.cc.

target_

WritableFile* leveldb::TestWritableFile::target_

private

Definition at line 120 of file fault_injection_test.cc.

writable_file_opened_

bool leveldb::TestWritableFile::writable_file_opened_

private

Definition at line 121 of file fault_injection_test.cc.

---

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

• db/fault_injection_test.cc