HTML MessagePort as mojo::MessagePipeHandle

third_party/WebKit/Source/core/workers/InProcessWorkerMessagingProxy.cpp

 /*
  * Copyright (C) 2008 Apple Inc. All Rights Reserved.
  * Copyright (C) 2009 Google Inc. All Rights Reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions
  * are met:
  * 1. Redistributions of source code must retain the above copyright
  *    notice, this list of conditions and the following disclaimer.
  * 2. Redistributions in binary form must reproduce the above copyright
@@ skipping 101 matching lines @@
           OriginTrialContext::getTokens(document).get(),
           std::move(workerSettings), workerV8Settings);
 
   initializeWorkerThread(std::move(startupData));
   workerInspectorProxy()->workerThreadCreated(document, workerThread(),
                                               scriptURL);
 }
 
 void InProcessWorkerMessagingProxy::postMessageToWorkerObject(
     PassRefPtr<SerializedScriptValue> message,
-    std::unique_ptr<MessagePortChannelArray> channels) {
+    MessagePortChannelArray channels) {
   DCHECK(isParentContextThread());
   if (!m_workerObject || askedToTerminate())
     return;
 
   MessagePortArray* ports =
       MessagePort::entanglePorts(*getExecutionContext(), std::move(channels));
   m_workerObject->dispatchEvent(
       MessageEvent::create(ports, std::move(message)));
 }
 
 void InProcessWorkerMessagingProxy::postMessageToWorkerGlobalScope(
     PassRefPtr<SerializedScriptValue> message,
-    std::unique_ptr<MessagePortChannelArray> channels) {
+    MessagePortChannelArray channels) {
   DCHECK(isParentContextThread());
   if (askedToTerminate())
     return;
 
   if (workerThread()) {
     // A message event is an activity and may initiate another activity.
     m_workerGlobalScopeHasPendingActivity = true;
     ++m_unconfirmedMessageCount;
     std::unique_ptr<WTF::CrossThreadClosure> task = crossThreadBind(
         &InProcessWorkerObjectProxy::processMessageFromWorkerObject,
@@ skipping 87 matching lines @@
 
 bool InProcessWorkerMessagingProxy::hasPendingActivity() const {
   DCHECK(isParentContextThread());
   if (askedToTerminate())
     return false;
   return m_workerGlobalScopeHasPendingActivity;
 }
 
 InProcessWorkerMessagingProxy::QueuedTask::QueuedTask(
     RefPtr<SerializedScriptValue> message,
-    std::unique_ptr<MessagePortChannelArray> channels)
+    MessagePortChannelArray channels)
     : message(std::move(message)), channels(std::move(channels)) {}
 
 InProcessWorkerMessagingProxy::QueuedTask::~QueuedTask() = default;
 
 }  // namespace blink