Revert of Created new Windows LevelDB environment.

third_party/leveldatabase/env_chromium.h

 // Copyright (c) 2013 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.
 
 #ifndef THIRD_PARTY_LEVELDATABASE_ENV_CHROMIUM_H_
 #define THIRD_PARTY_LEVELDATABASE_ENV_CHROMIUM_H_
 
 #include <deque>
 #include <map>
 #include <set>
 
 #include "base/metrics/histogram.h"
 #include "base/platform_file.h"
+#include "base/synchronization/condition_variable.h"
 #include "leveldb/env.h"
+#include "leveldb/slice.h"
+#include "leveldb/status.h"
 #include "port/port_chromium.h"
 #include "util/mutexlock.h"
 
 namespace leveldb_env {
 
 enum MethodID {
   kSequentialFileRead,
   kSequentialFileSkip,
   kRandomAccessFileRead,
   kWritableFileAppend,
@@ skipping 66 matching lines @@
       MethodID method) const = 0;
 };
 
 class WriteTracker {
  public:
   virtual void DidCreateNewFile(const std::string& fname) = 0;
   virtual bool DoesDirNeedSync(const std::string& fname) = 0;
   virtual void DidSyncDir(const std::string& fname) = 0;
 };
 
+class ChromiumWritableFile : public leveldb::WritableFile {
+ public:
+  ChromiumWritableFile(const std::string& fname,
+                       FILE* f,
+                       const UMALogger* uma_logger,
+                       WriteTracker* tracker,
+                       bool make_backup);
+  virtual ~ChromiumWritableFile();
+  virtual leveldb::Status Append(const leveldb::Slice& data);
+  virtual leveldb::Status Close();
+  virtual leveldb::Status Flush();
+  virtual leveldb::Status Sync();
+
+ private:
+  enum Type {
+    kManifest,
+    kTable,
+    kOther
+  };
+  leveldb::Status SyncParent();
+
+  std::string filename_;
+  FILE* file_;
+  const UMALogger* uma_logger_;
+  WriteTracker* tracker_;
+  Type file_type_;
+  std::string parent_dir_;
+  bool make_backup_;
+};
+
 class ChromiumEnv : public leveldb::Env,
                     public UMALogger,
                     public RetrierProvider,
                     public WriteTracker {
  public:
-  static bool MakeBackup(const std::string& fname);
-  static base::FilePath CreateFilePath(const std::string& file_path);
-  static const char* PlatformFileErrorString(
-      const ::base::PlatformFileError& error);
-  static bool HasTableExtension(const base::FilePath& path);
+  ChromiumEnv();
   virtual ~ChromiumEnv();
 
+  virtual leveldb::Status NewSequentialFile(const std::string& fname,
+                                            leveldb::SequentialFile** result);
+  virtual leveldb::Status NewRandomAccessFile(
+      const std::string& fname,
+      leveldb::RandomAccessFile** result);
+  virtual leveldb::Status NewWritableFile(const std::string& fname,
+                                          leveldb::WritableFile** result);
   virtual bool FileExists(const std::string& fname);
   virtual leveldb::Status GetChildren(const std::string& dir,
                                       std::vector<std::string>* result);
   virtual leveldb::Status DeleteFile(const std::string& fname);
   virtual leveldb::Status CreateDir(const std::string& name);
   virtual leveldb::Status DeleteDir(const std::string& name);
   virtual leveldb::Status GetFileSize(const std::string& fname, uint64_t* size);
   virtual leveldb::Status RenameFile(const std::string& src,
                                      const std::string& dst);
   virtual leveldb::Status LockFile(const std::string& fname,
                                    leveldb::FileLock** lock);
   virtual leveldb::Status UnlockFile(leveldb::FileLock* lock);
   virtual void Schedule(void (*function)(void*), void* arg);
   virtual void StartThread(void (*function)(void* arg), void* arg);
   virtual leveldb::Status GetTestDirectory(std::string* path);
+  virtual leveldb::Status NewLogger(const std::string& fname,
+                                    leveldb::Logger** result);
   virtual uint64_t NowMicros();
   virtual void SleepForMicroseconds(int micros);
 
  protected:
-  ChromiumEnv();
-
   virtual void DidCreateNewFile(const std::string& fname);
   virtual bool DoesDirNeedSync(const std::string& fname);
   virtual void DidSyncDir(const std::string& fname);
-  virtual base::PlatformFileError GetDirectoryEntries(
-      const base::FilePath& dir_param,
-      std::vector<base::FilePath>* result) const = 0;
-  virtual void RecordErrorAt(MethodID method) const;
-  virtual void RecordOSError(MethodID method, int saved_errno) const;
-  virtual void RecordOSError(MethodID method,
-                             base::PlatformFileError error) const;
-  base::HistogramBase* GetMaxFDHistogram(const std::string& type) const;
-  base::HistogramBase* GetOSErrorHistogram(MethodID method, int limit) const;
 
   std::string name_;
   bool make_backup_;
 
  private:
   // File locks may not be exclusive within a process (e.g. on POSIX). Track
   // locks held by the ChromiumEnv to prevent access within the process.
   class LockTable {
    public:
     bool Insert(const std::string& fname) {
@@ skipping 12 matching lines @@
   std::map<std::string, bool> needs_sync_map_;
   base::Lock map_lock_;
 
   const int kMaxRetryTimeMillis;
   // BGThread() is the body of the background thread
   void BGThread();
   static void BGThreadWrapper(void* arg) {
     reinterpret_cast<ChromiumEnv*>(arg)->BGThread();
   }
 
+  virtual void RecordErrorAt(MethodID method) const;
+  virtual void RecordOSError(MethodID method, int saved_errno) const;
+  virtual void RecordOSError(MethodID method,
+                             base::PlatformFileError error) const;
   virtual void RecordBackupResult(bool result) const;
   void RestoreIfNecessary(const std::string& dir,
                           std::vector<std::string>* children);
   base::FilePath RestoreFromBackup(const base::FilePath& base_name);
+  void RecordOpenFilesLimit(const std::string& type);
   void RecordLockFileAncestors(int num_missing_ancestors) const;
+  base::HistogramBase* GetOSErrorHistogram(MethodID method, int limit) const;
   base::HistogramBase* GetMethodIOErrorHistogram() const;
+  base::HistogramBase* GetMaxFDHistogram(const std::string& type) const;
   base::HistogramBase* GetLockFileAncestorHistogram() const;
 
   // RetrierProvider implementation.
   virtual int MaxRetryTimeMillis() const { return kMaxRetryTimeMillis; }
   virtual base::HistogramBase* GetRetryTimeHistogram(MethodID method) const;
   virtual base::HistogramBase* GetRecoveredFromErrorHistogram(
       MethodID method) const;
 
   base::FilePath test_directory_;
 
   ::base::Lock mu_;
   ::base::ConditionVariable bgsignal_;
   bool started_bgthread_;
 
   // Entry per Schedule() call
   struct BGItem {
     void* arg;
     void (*function)(void*);
   };
   typedef std::deque<BGItem> BGQueue;
   BGQueue queue_;
   LockTable locks_;
 };
 
 }  // namespace leveldb_env
 
 #endif