WorkerMessagePortChannelProvider.h [plain text]
#pragma once
#include "MessagePortChannelProvider.h"
#include <wtf/CompletionHandler.h>
#include <wtf/HashMap.h>
#include <wtf/Vector.h>
namespace WebCore {
class WorkerGlobalScope;
class WorkerMessagePortChannelProvider final : public MessagePortChannelProvider {
WTF_MAKE_FAST_ALLOCATED;
public:
explicit WorkerMessagePortChannelProvider(WorkerGlobalScope&);
~WorkerMessagePortChannelProvider();
private:
void createNewMessagePortChannel(const MessagePortIdentifier& local, const MessagePortIdentifier& remote) final;
void entangleLocalPortInThisProcessToRemote(const MessagePortIdentifier& local, const MessagePortIdentifier& remote) final;
void messagePortDisentangled(const MessagePortIdentifier& local) final;
void messagePortClosed(const MessagePortIdentifier& local) final;
void postMessageToRemote(MessageWithMessagePorts&&, const MessagePortIdentifier& remoteTarget) final;
void takeAllMessagesForPort(const MessagePortIdentifier&, CompletionHandler<void(Vector<MessageWithMessagePorts>&&, Function<void()>&&)>&&) final;
void checkRemotePortForActivity(const MessagePortIdentifier& remoteTarget, CompletionHandler<void(HasActivity)>&& callback) final;
WorkerGlobalScope& m_scope;
uint64_t m_lastCallbackIdentifier { 0 };
HashMap<uint64_t, CompletionHandler<void(Vector<MessageWithMessagePorts>&&, Function<void()>&&)>> m_takeAllMessagesCallbacks;
HashMap<uint64_t, CompletionHandler<void(HasActivity)>> m_activityCallbacks;
};
}