| Index: mojo/edk/embedder/pending_process_connection.cc
|
| diff --git a/mojo/edk/embedder/pending_process_connection.cc b/mojo/edk/embedder/pending_process_connection.cc
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..632a29833ec08308b72554c10221184fe8a6fd50
|
| --- /dev/null
|
| +++ b/mojo/edk/embedder/pending_process_connection.cc
|
| @@ -0,0 +1,49 @@
|
| +// 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 "mojo/edk/embedder/pending_process_connection.h"
|
| +
|
| +#include "mojo/edk/embedder/embedder.h"
|
| +#include "mojo/edk/embedder/embedder_internal.h"
|
| +#include "mojo/edk/system/core.h"
|
| +
|
| +namespace mojo {
|
| +namespace edk {
|
| +
|
| +PendingProcessConnection::PendingProcessConnection()
|
| + : process_token_(GenerateRandomToken()) {
|
| + DCHECK(internal::g_core);
|
| +}
|
| +
|
| +PendingProcessConnection::~PendingProcessConnection() {
|
| + if (!connected_) {
|
| + DCHECK(internal::g_core);
|
| + internal::g_core->ChildLaunchFailed(process_token_);
|
| + }
|
| +}
|
| +
|
| +ScopedMessagePipeHandle PendingProcessConnection::CreateMessagePipe(
|
| + std::string* token) const {
|
| + DCHECK(internal::g_core);
|
| + *token = GenerateRandomToken();
|
| + return internal::g_core->CreateParentMessagePipe(*token, process_token_);
|
| +}
|
| +
|
| +void PendingProcessConnection::Connect(
|
| + base::ProcessHandle process,
|
| + ScopedPlatformHandle channel,
|
| + const ProcessErrorCallback& error_callback) {
|
| + // It's now safe to avoid cleanup in the destructor, as the lifetime of any
|
| + // associated resources is effectively bound to the |channel| passed to
|
| + // AddChild() below.
|
| + DCHECK(!connected_);
|
| + connected_ = true;
|
| +
|
| + DCHECK(internal::g_core);
|
| + internal::g_core->AddChild(process, std::move(channel), process_token_,
|
| + error_callback);
|
| +}
|
| +
|
| +} // namespace edk
|
| +} // namespace mojo
|
|
|