mojo leveldb: Get profile and leveldb connected to DOMStorageContext.

components/leveldb/leveldb_service_impl.cc

 // Copyright 2016 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "components/leveldb/leveldb_service_impl.h"
 
 #include "components/leveldb/env_mojo.h"
 #include "components/leveldb/leveldb_database_impl.h"
 #include "components/leveldb/util.h"
 #include "third_party/leveldatabase/env_chromium.h"
 #include "third_party/leveldatabase/src/include/leveldb/db.h"
 #include "third_party/leveldatabase/src/include/leveldb/env.h"
 #include "third_party/leveldatabase/src/include/leveldb/filter_policy.h"
 #include "third_party/leveldatabase/src/include/leveldb/slice.h"
 
 namespace leveldb {
 
-LevelDBServiceImpl::LevelDBServiceImpl()
-    : thread_(new LevelDBFileThread) {
-}
+LevelDBServiceImpl::LevelDBServiceImpl() : thread_(new LevelDBFileThread) {}

[michaeln, 2016/03/17 22:35:41]

ok, so we get one new thread per profile

[Elliot Glaysher, 2016/03/18 19:41:12]

For now at least.

It might be possible to depinject the file thread here.

 
 LevelDBServiceImpl::~LevelDBServiceImpl() {}
 
 void LevelDBServiceImpl::Open(filesystem::DirectoryPtr directory,
                               const mojo::String& dbname,
-                              mojo::InterfaceRequest<LevelDBDatabase> database,
+                              leveldb::LevelDBDatabaseRequest database,
                               const OpenCallback& callback) {
   // This is the place where we open a database.
   leveldb::Options options;
   options.create_if_missing = true;
   options.paranoid_checks = true;
   // TODO(erg): Do we need a filter policy?
   options.reuse_logs = leveldb_env::kDefaultLogReuseOptionValue;
   options.compression = leveldb::kSnappyCompression;
 
   // For info about the troubles we've run into with this parameter, see:
@@ skipping 12 matching lines @@
 
   if (s.ok()) {
     new LevelDBDatabaseImpl(std::move(database), std::move(env_mojo),
                             scoped_ptr<leveldb::DB>(db));
   }
 
   callback.Run(LeveldbStatusToError(s));
 }
 
 }  // namespace leveldb