leveldb::anonymous_namespace{memenv.cc}::InMemoryEnv Class Reference

Inheritance diagram for leveldb::anonymous_namespace{memenv.cc}::InMemoryEnv:

Collaboration diagram for leveldb::anonymous_namespace{memenv.cc}::InMemoryEnv:

Public Member Functions
	InMemoryEnv (Env *base_env)
virtual	~InMemoryEnv ()
virtual Status	NewSequentialFile (const std::string &fname, SequentialFile **result)
virtual Status	NewRandomAccessFile (const std::string &fname, RandomAccessFile **result)
virtual Status	NewWritableFile (const std::string &fname, WritableFile **result)
virtual Status	NewAppendableFile (const std::string &fname, WritableFile **result)
virtual bool	FileExists (const std::string &fname)
virtual Status	GetChildren (const std::string &dir, std::vector< std::string > *result)
void	DeleteFileInternal (const std::string &fname)
virtual Status	DeleteFile (const std::string &fname)
virtual Status	CreateDir (const std::string &dirname)
virtual Status	DeleteDir (const std::string &dirname)
virtual Status	GetFileSize (const std::string &fname, uint64_t *file_size)
virtual Status	RenameFile (const std::string &src, const std::string &target)
virtual Status	LockFile (const std::string &fname, FileLock **lock)
virtual Status	UnlockFile (FileLock *lock)
virtual Status	GetTestDirectory (std::string *path)
virtual Status	NewLogger (const std::string &fname, Logger **result)
Public Member Functions inherited from leveldb::EnvWrapper
	EnvWrapper (Env *t)
virtual	~EnvWrapper ()
Env *	target () const
Status	NewSequentialFile (const std::string &f, SequentialFile **r)
Status	NewRandomAccessFile (const std::string &f, RandomAccessFile **r)
Status	NewWritableFile (const std::string &f, WritableFile **r)
Status	NewAppendableFile (const std::string &f, WritableFile **r)
bool	FileExists (const std::string &f)
Status	GetChildren (const std::string &dir, std::vector< std::string > *r)
Status	DeleteFile (const std::string &f)
Status	CreateDir (const std::string &d)
Status	DeleteDir (const std::string &d)
Status	GetFileSize (const std::string &f, uint64_t *s)
Status	RenameFile (const std::string &s, const std::string &t)
Status	LockFile (const std::string &f, FileLock **l)
Status	UnlockFile (FileLock *l)
void	Schedule (void(*f)(void *), void *a)
void	StartThread (void(*f)(void *), void *a)
uint64_t	NowMicros ()
void	SleepForMicroseconds (int micros)
Public Member Functions inherited from leveldb::Env
	Env ()
virtual	~Env ()
virtual void	Schedule (void(*function)(void *arg), void *arg)=0
virtual void	StartThread (void(*function)(void *arg), void *arg)=0

Private Types
typedef std::map< std::string, FileState * >	FileSystem

Private Attributes
port::Mutex	mutex_
FileSystem	file_map_

Additional Inherited Members
Static Public Member Functions inherited from leveldb::Env
static Env *	Default ()

Detailed Description

Definition at line 230 of file memenv.cc.

Member Typedef Documentation

FileSystem

typedef std::map<std::string, FileState*> leveldb::anonymous_namespace{memenv.cc}::InMemoryEnv::FileSystem

private

Definition at line 387 of file memenv.cc.

Constructor & Destructor Documentation

InMemoryEnv()

leveldb::anonymous_namespace{memenv.cc}::InMemoryEnv::InMemoryEnv ( Env *  base_env )

inlineexplicit

Definition at line 232 of file memenv.cc.

: EnvWrapper(base_env) { }

~InMemoryEnv()

virtual leveldb::anonymous_namespace{memenv.cc}::InMemoryEnv::~InMemoryEnv ( )

inlinevirtual

Definition at line 234 of file memenv.cc.

                         {
    for (FileSystem::iterator i = file_map_.begin(); i != file_map_.end(); ++i){
      i->second->Unref();
    }
  }

Member Function Documentation

CreateDir()

virtual Status leveldb::anonymous_namespace{memenv.cc}::InMemoryEnv::CreateDir ( const std::string &  dirname )

inlinevirtual

Implements leveldb::Env.

Definition at line 334 of file memenv.cc.

                                                     {
    return Status::OK();
  }

Here is the call graph for this function:

DeleteDir()

virtual Status leveldb::anonymous_namespace{memenv.cc}::InMemoryEnv::DeleteDir ( const std::string &  dirname )

inlinevirtual

Implements leveldb::Env.

Definition at line 338 of file memenv.cc.

                                                     {
    return Status::OK();
  }

Here is the call graph for this function:

DeleteFile()

virtual Status leveldb::anonymous_namespace{memenv.cc}::InMemoryEnv::DeleteFile ( const std::string &  fname )

inlinevirtual

Implements leveldb::Env.

Definition at line 324 of file memenv.cc.

                                                    {
    MutexLock lock(&mutex_);
    if (file_map_.find(fname) == file_map_.end()) {
      return Status::IOError(fname, "File not found");
    }

    DeleteFileInternal(fname);
    return Status::OK();
  }

Here is the call graph for this function:

DeleteFileInternal()

void leveldb::anonymous_namespace{memenv.cc}::InMemoryEnv::DeleteFileInternal ( const std::string &  fname )

inline

Definition at line 315 of file memenv.cc.

                                                  {
    if (file_map_.find(fname) == file_map_.end()) {
      return;
    }

    file_map_[fname]->Unref();
    file_map_.erase(fname);
  }

FileExists()

virtual bool leveldb::anonymous_namespace{memenv.cc}::InMemoryEnv::FileExists ( const std::string &  fname )

inlinevirtual

Implements leveldb::Env.

Definition at line 293 of file memenv.cc.

                                                  {
    MutexLock lock(&mutex_);
    return file_map_.find(fname) != file_map_.end();
  }

GetChildren()

virtual Status leveldb::anonymous_namespace{memenv.cc}::InMemoryEnv::GetChildren ( const std::string &  dir, std::vector< std::string > *  result  )

inlinevirtual

Implements leveldb::Env.

Definition at line 298 of file memenv.cc.

                                                           {
    MutexLock lock(&mutex_);
    result->clear();

    for (FileSystem::iterator i = file_map_.begin(); i != file_map_.end(); ++i){
      const std::string& filename = i->first;

      if (filename.size() >= dir.size() + 1 && filename[dir.size()] == '/' &&
          Slice(filename).starts_with(Slice(dir))) {
        result->push_back(filename.substr(dir.size() + 1));
      }
    }

    return Status::OK();
  }

Here is the call graph for this function:

GetFileSize()

virtual Status leveldb::anonymous_namespace{memenv.cc}::InMemoryEnv::GetFileSize ( const std::string &  fname, uint64_t *  file_size  )

inlinevirtual

Implements leveldb::Env.

Definition at line 342 of file memenv.cc.

                                                                          {
    MutexLock lock(&mutex_);
    if (file_map_.find(fname) == file_map_.end()) {
      return Status::IOError(fname, "File not found");
    }

    *file_size = file_map_[fname]->Size();
    return Status::OK();
  }

Here is the call graph for this function:

GetTestDirectory()

virtual Status leveldb::anonymous_namespace{memenv.cc}::InMemoryEnv::GetTestDirectory ( std::string *  path )

inlinevirtual

Reimplemented from leveldb::EnvWrapper.

Definition at line 375 of file memenv.cc.

                                                   {
    *path = "/test";
    return Status::OK();
  }

Here is the call graph for this function:

LockFile()

virtual Status leveldb::anonymous_namespace{memenv.cc}::InMemoryEnv::LockFile ( const std::string &  fname, FileLock **  lock  )

inlinevirtual

Implements leveldb::Env.

Definition at line 365 of file memenv.cc.

                                                                   {
    *lock = new FileLock;
    return Status::OK();
  }

Here is the call graph for this function:

NewAppendableFile()

virtual Status leveldb::anonymous_namespace{memenv.cc}::InMemoryEnv::NewAppendableFile ( const std::string &  fname, WritableFile **  result  )

inlinevirtual

Reimplemented from leveldb::Env.

Definition at line 280 of file memenv.cc.

                                                          {
    MutexLock lock(&mutex_);
    FileState** sptr = &file_map_[fname];
    FileState* file = *sptr;
    if (file == NULL) {
      file = new FileState();
      file->Ref();
    }
    *result = new WritableFileImpl(file);
    return Status::OK();
  }

Here is the call graph for this function:

NewLogger()

virtual Status leveldb::anonymous_namespace{memenv.cc}::InMemoryEnv::NewLogger ( const std::string &  fname, Logger **  result  )

inlinevirtual

Reimplemented from leveldb::EnvWrapper.

Definition at line 380 of file memenv.cc.

                                                                    {
    *result = new NoOpLogger;
    return Status::OK();
  }

Here is the call graph for this function:

NewRandomAccessFile()

virtual Status leveldb::anonymous_namespace{memenv.cc}::InMemoryEnv::NewRandomAccessFile ( const std::string &  fname, RandomAccessFile **  result  )

inlinevirtual

Implements leveldb::Env.

Definition at line 253 of file memenv.cc.

                                                                {
    MutexLock lock(&mutex_);
    if (file_map_.find(fname) == file_map_.end()) {
      *result = NULL;
      return Status::IOError(fname, "File not found");
    }

    *result = new RandomAccessFileImpl(file_map_[fname]);
    return Status::OK();
  }

Here is the call graph for this function:

NewSequentialFile()

virtual Status leveldb::anonymous_namespace{memenv.cc}::InMemoryEnv::NewSequentialFile ( const std::string &  fname, SequentialFile **  result  )

inlinevirtual

Implements leveldb::Env.

Definition at line 241 of file memenv.cc.

                                                            {
    MutexLock lock(&mutex_);
    if (file_map_.find(fname) == file_map_.end()) {
      *result = NULL;
      return Status::IOError(fname, "File not found");
    }

    *result = new SequentialFileImpl(file_map_[fname]);
    return Status::OK();
  }

Here is the call graph for this function:

NewWritableFile()

virtual Status leveldb::anonymous_namespace{memenv.cc}::InMemoryEnv::NewWritableFile ( const std::string &  fname, WritableFile **  result  )

inlinevirtual

Implements leveldb::Env.

Definition at line 265 of file memenv.cc.

                                                        {
    MutexLock lock(&mutex_);
    if (file_map_.find(fname) != file_map_.end()) {
      DeleteFileInternal(fname);
    }

    FileState* file = new FileState();
    file->Ref();
    file_map_[fname] = file;

    *result = new WritableFileImpl(file);
    return Status::OK();
  }

Here is the call graph for this function:

RenameFile()

virtual Status leveldb::anonymous_namespace{memenv.cc}::InMemoryEnv::RenameFile ( const std::string &  src, const std::string &  target  )

inlinevirtual

Implements leveldb::Env.

Definition at line 352 of file memenv.cc.

                                                     {
    MutexLock lock(&mutex_);
    if (file_map_.find(src) == file_map_.end()) {
      return Status::IOError(src, "File not found");
    }

    DeleteFileInternal(target);
    file_map_[target] = file_map_[src];
    file_map_.erase(src);
    return Status::OK();
  }

Here is the call graph for this function:

UnlockFile()

virtual Status leveldb::anonymous_namespace{memenv.cc}::InMemoryEnv::UnlockFile ( FileLock *  lock )

inlinevirtual

Implements leveldb::Env.

Definition at line 370 of file memenv.cc.

                                            {
    delete lock;
    return Status::OK();
  }

Here is the call graph for this function:

Member Data Documentation

file_map_

FileSystem leveldb::anonymous_namespace{memenv.cc}::InMemoryEnv::file_map_

private

Definition at line 389 of file memenv.cc.

mutex_

port::Mutex leveldb::anonymous_namespace{memenv.cc}::InMemoryEnv::mutex_

private

Definition at line 388 of file memenv.cc.

---

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

• helpers/memenv/memenv.cc