| Index: components/printing/browser/print_composite_client.cc
|
| diff --git a/components/printing/browser/print_composite_client.cc b/components/printing/browser/print_composite_client.cc
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..5516ccc35d479784ab06a4680a82b7322642026f
|
| --- /dev/null
|
| +++ b/components/printing/browser/print_composite_client.cc
|
| @@ -0,0 +1,83 @@
|
| +// Copyright 2017 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/printing/browser/print_composite_client.h"
|
| +
|
| +#include <memory>
|
| +#include <utility>
|
| +
|
| +#include "base/threading/thread_task_runner_handle.h"
|
| +#include "content/public/browser/browser_thread.h"
|
| +#include "content/public/common/service_manager_connection.h"
|
| +#include "mojo/public/cpp/system/platform_handle.h"
|
| +#include "services/service_manager/public/cpp/connector.h"
|
| +
|
| +DEFINE_WEB_CONTENTS_USER_DATA_KEY(printing::PrintCompositeClient);
|
| +
|
| +namespace printing {
|
| +
|
| +PrintCompositeClient::PrintCompositeClient(content::WebContents* web_contents) {
|
| +}
|
| +
|
| +PrintCompositeClient::~PrintCompositeClient() {}
|
| +
|
| +void PrintCompositeClient::CreateConnectorRequest() {
|
| + connector_ = service_manager::Connector::Create(&connector_request_);
|
| + content::ServiceManagerConnection::GetForProcess()
|
| + ->GetConnector()
|
| + ->BindConnectorRequest(std::move(connector_request_));
|
| +}
|
| +
|
| +void PrintCompositeClient::DoComposite(
|
| + base::SharedMemoryHandle handle,
|
| + uint32_t data_size,
|
| + mojom::PdfCompositor::CompositePdfCallback callback) {
|
| + DCHECK_CURRENTLY_ON(content::BrowserThread::UI);
|
| + DCHECK(data_size);
|
| +
|
| + if (!connector_)
|
| + CreateConnectorRequest();
|
| + Composite(connector_.get(), handle, data_size, std::move(callback),
|
| + base::ThreadTaskRunnerHandle::Get());
|
| +}
|
| +
|
| +std::unique_ptr<base::SharedMemory> PrintCompositeClient::GetShmFromMojoHandle(
|
| + mojo::ScopedSharedBufferHandle handle) {
|
| + if (!handle.is_valid()) {
|
| + DLOG(ERROR) << "Invalid mojo handle.";
|
| + return nullptr;
|
| + }
|
| +
|
| + base::SharedMemoryHandle memory_handle;
|
| + size_t memory_size = 0;
|
| + bool read_only_flag = false;
|
| +
|
| + const MojoResult result = mojo::UnwrapSharedMemoryHandle(
|
| + std::move(handle), &memory_handle, &memory_size, &read_only_flag);
|
| + DCHECK_EQ(MOJO_RESULT_OK, result);
|
| + DCHECK_GT(memory_size, 0u);
|
| +
|
| + std::unique_ptr<base::SharedMemory> shm =
|
| + base::MakeUnique<base::SharedMemory>(memory_handle, true /* read_only */);
|
| + if (!shm->Map(memory_size)) {
|
| + DLOG(ERROR) << "Map shared memory failed.";
|
| + return nullptr;
|
| + }
|
| + return shm;
|
| +}
|
| +
|
| +scoped_refptr<base::RefCountedBytes>
|
| +PrintCompositeClient::GetDataFromMojoHandle(
|
| + mojo::ScopedSharedBufferHandle handle) {
|
| + std::unique_ptr<base::SharedMemory> shm =
|
| + GetShmFromMojoHandle(std::move(handle));
|
| + if (!shm)
|
| + return nullptr;
|
| +
|
| + return base::MakeRefCounted<base::RefCountedBytes>(
|
| + reinterpret_cast<const unsigned char*>(shm->memory()),
|
| + shm->mapped_size());
|
| +}
|
| +
|
| +} // namespace printing
|
|
|