| Index: components/resource_provider/resource_provider_apptest.cc
|
| diff --git a/components/resource_provider/resource_provider_apptest.cc b/components/resource_provider/resource_provider_apptest.cc
|
| deleted file mode 100644
|
| index 2d10b6de1825baf806b04587b57613e91164c364..0000000000000000000000000000000000000000
|
| --- a/components/resource_provider/resource_provider_apptest.cc
|
| +++ /dev/null
|
| @@ -1,146 +0,0 @@
|
| -// Copyright 2015 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 <stdint.h>
|
| -
|
| -#include "base/bind.h"
|
| -#include "base/containers/scoped_ptr_hash_map.h"
|
| -#include "base/files/file.h"
|
| -#include "base/run_loop.h"
|
| -#include "components/resource_provider/public/interfaces/resource_provider.mojom.h"
|
| -#include "mojo/application/application_test_base_chromium.h"
|
| -#include "mojo/common/common_type_converters.h"
|
| -#include "mojo/platform_handle/platform_handle_functions.h"
|
| -#include "third_party/mojo/src/mojo/public/cpp/application/application_delegate.h"
|
| -#include "third_party/mojo/src/mojo/public/cpp/application/application_impl.h"
|
| -#include "third_party/mojo/src/mojo/public/cpp/application/service_provider_impl.h"
|
| -#include "third_party/mojo/src/mojo/public/cpp/bindings/array.h"
|
| -#include "third_party/mojo/src/mojo/public/cpp/system/macros.h"
|
| -
|
| -namespace resource_provider {
|
| -namespace {
|
| -
|
| -std::string ReadFile(base::File* file) {
|
| - const size_t kBufferSize = 1 << 16;
|
| - scoped_ptr<char[]> buffer(new char[kBufferSize]);
|
| - const int read = file->ReadAtCurrentPos(buffer.get(), kBufferSize);
|
| - if (read == -1)
|
| - return std::string();
|
| - return std::string(buffer.get(), read);
|
| -}
|
| -
|
| -std::vector<std::string> VectorWithString(const std::string& contents) {
|
| - std::vector<std::string> result;
|
| - result.push_back(contents);
|
| - return result;
|
| -}
|
| -
|
| -std::vector<std::string> VectorWithStrings(const std::string& contents1,
|
| - const std::string& contents2) {
|
| - std::vector<std::string> result;
|
| - result.push_back(contents1);
|
| - result.push_back(contents2);
|
| - return result;
|
| -}
|
| -
|
| -// ResourceFetcher fetches resources from a ResourceProvider, storing the
|
| -// results as well as running
|
| -// a message loop until the resource has been obtained.
|
| -class ResourceFetcher {
|
| - public:
|
| - using ResourceMap = std::map<std::string, std::string>;
|
| -
|
| - explicit ResourceFetcher(ResourceProvider* provider)
|
| - : provider_(provider), waiting_count_(0u) {}
|
| - ~ResourceFetcher() {}
|
| -
|
| - ResourceMap* resources() { return &resources_; }
|
| -
|
| - void WaitForResults() {
|
| - ASSERT_NE(0u, waiting_count_);
|
| - run_loop_.Run();
|
| - }
|
| -
|
| - void GetResources(const std::vector<std::string>& paths) {
|
| - waiting_count_++;
|
| - provider_->GetResources(mojo::Array<mojo::String>::From(paths),
|
| - base::Bind(&ResourceFetcher::OnGotResources,
|
| - base::Unretained(this), paths));
|
| - }
|
| -
|
| - private:
|
| - // Callback when a resource has been fetched.
|
| - void OnGotResources(const std::vector<std::string>& paths,
|
| - mojo::Array<mojo::ScopedHandle> resources) {
|
| - ASSERT_FALSE(resources.is_null());
|
| - ASSERT_EQ(paths.size(), resources.size());
|
| - for (size_t i = 0; i < paths.size(); ++i) {
|
| - std::string contents;
|
| - if (resources[i].is_valid()) {
|
| - MojoPlatformHandle platform_handle;
|
| - ASSERT_EQ(MOJO_RESULT_OK,
|
| - MojoExtractPlatformHandle(resources[i].release().value(),
|
| - &platform_handle));
|
| - base::File file(platform_handle);
|
| - contents = ReadFile(&file);
|
| - }
|
| - resources_[paths[i]] = contents;
|
| - }
|
| -
|
| - if (waiting_count_ > 0) {
|
| - waiting_count_--;
|
| - if (waiting_count_ == 0)
|
| - run_loop_.Quit();
|
| - }
|
| - }
|
| -
|
| - ResourceProvider* provider_;
|
| - ResourceMap resources_;
|
| - // Number of resources we're waiting on.
|
| - size_t waiting_count_;
|
| - base::RunLoop run_loop_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(ResourceFetcher);
|
| -};
|
| -
|
| -class ResourceProviderApplicationTest : public mojo::test::ApplicationTestBase {
|
| - public:
|
| - ResourceProviderApplicationTest() {}
|
| - ~ResourceProviderApplicationTest() override {}
|
| -
|
| - protected:
|
| - // ApplicationTestBase:
|
| - void SetUp() override {
|
| - ApplicationTestBase::SetUp();
|
| - application_impl()->ConnectToService("mojo:resource_provider",
|
| - &resource_provider_);
|
| - }
|
| -
|
| - ResourceProviderPtr resource_provider_;
|
| -
|
| - private:
|
| - MOJO_DISALLOW_COPY_AND_ASSIGN(ResourceProviderApplicationTest);
|
| -};
|
| -
|
| -TEST_F(ResourceProviderApplicationTest, FetchOneResource) {
|
| - ResourceFetcher fetcher(resource_provider_.get());
|
| - fetcher.GetResources(VectorWithString("sample"));
|
| - fetcher.WaitForResults();
|
| - ASSERT_TRUE(fetcher.resources()->count("sample") > 0u);
|
| - EXPECT_EQ("test data\n", (*fetcher.resources())["sample"]);
|
| -}
|
| -
|
| -TEST_F(ResourceProviderApplicationTest, FetchTwoResources) {
|
| - ResourceFetcher fetcher(resource_provider_.get());
|
| - fetcher.GetResources(VectorWithStrings("sample", "dir/sample2"));
|
| - fetcher.WaitForResults();
|
| - ASSERT_TRUE(fetcher.resources()->count("sample") > 0u);
|
| - EXPECT_EQ("test data\n", (*fetcher.resources())["sample"]);
|
| -
|
| - ASSERT_TRUE(fetcher.resources()->count("dir/sample2") > 0u);
|
| - EXPECT_EQ("xxyy\n", (*fetcher.resources())["dir/sample2"]);
|
| -}
|
| -
|
| -} // namespace
|
| -} // namespace resource_provider
|
|
|