Created
March 9, 2012 07:14
-
-
Save c4pt0r/2005426 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
// Copyright (c) 2011 The LevelDB Authors. All rights reserved. | |
// Use of this source code is governed by a BSD-style license that can be | |
// found in the LICENSE file. See the AUTHORS file for names of contributors. | |
#include "leveldb/env.h" | |
namespace leveldb { | |
Env::~Env() { | |
} | |
SequentialFile::~SequentialFile() { | |
} | |
RandomAccessFile::~RandomAccessFile() { | |
} | |
WritableFile::~WritableFile() { | |
} | |
Logger::~Logger() { | |
} | |
FileLock::~FileLock() { | |
} | |
void Log(Logger* info_log, const char* format, ...) { | |
if (info_log != NULL) { | |
va_list ap; | |
va_start(ap, format); | |
info_log->Logv(format, ap); | |
va_end(ap); | |
} | |
} | |
static Status DoWriteStringToFile(Env* env, const Slice& data, | |
const std::string& fname, | |
bool should_sync) { | |
WritableFile* file; | |
Status s = env->NewWritableFile(fname, &file); | |
if (!s.ok()) { | |
return s; | |
} | |
s = file->Append(data); | |
if (s.ok() && should_sync) { | |
s = file->Sync(); | |
} | |
if (s.ok()) { | |
s = file->Close(); | |
} | |
delete file; // Will auto-close if we did not close above | |
if (!s.ok()) { | |
env->DeleteFile(fname); | |
} | |
return s; | |
} | |
Status WriteStringToFile(Env* env, const Slice& data, | |
const std::string& fname) { | |
return DoWriteStringToFile(env, data, fname, false); | |
} | |
Status WriteStringToFileSync(Env* env, const Slice& data, | |
const std::string& fname) { | |
return DoWriteStringToFile(env, data, fname, true); | |
} | |
Status ReadFileToString(Env* env, const std::string& fname, std::string* data) { | |
data->clear(); | |
SequentialFile* file; | |
Status s = env->NewSequentialFile(fname, &file); | |
if (!s.ok()) { | |
return s; | |
} | |
static const int kBufferSize = 8192; | |
char* space = new char[kBufferSize]; | |
while (true) { | |
Slice fragment; | |
s = file->Read(kBufferSize, &fragment, space); | |
if (!s.ok()) { | |
break; | |
} | |
data->append(fragment.data(), fragment.size()); | |
if (fragment.empty()) { | |
break; | |
} | |
} | |
delete[] space; | |
delete file; | |
return s; | |
} | |
EnvWrapper::~EnvWrapper() { | |
} | |
} // namespace leveldb |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment