blob: 03e66b24e9d25b40d4294ebe7af3773e0aa36fb4 [file] [log] [blame]
// Copyright 2022 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "ipcz/link_side.h"
#include "ipcz/router.h"
#include "ipcz/router_link.h"
#include "util/ref_counted.h"
namespace ipcz {
struct RouterLinkState;
// Local link between two Routers on the same node. This class is thread-safe.
// NOTE: This implementation must take caution when calling into any Router. See
// note on RouterLink's own class documentation.
class LocalRouterLink : public RouterLink {
// Creates a new pair of LocalRouterLinks linking the given pair of Routers
// together. `type` must be either kCentral or kBridge, as local links may
// never be peripheral. `initial_state` determines whether the new link starts
// in a stable state.
// It is the caller's responsibilty to give the returned links to their
// respective Routers.
enum InitialState { kUnstable, kStable };
static RouterLink::Pair CreatePair(LinkType type,
const Router::Pair& routers,
InitialState initial_state = kUnstable);
// RouterLink:
LinkType GetType() const override;
RouterLinkState* GetLinkState() const override;
void WaitForLinkStateAsync(std::function<void()> callback) override;
Ref<Router> GetLocalPeer() override;
RemoteRouterLink* AsRemoteRouterLink() override;
void AllocateParcelData(size_t num_bytes,
bool allow_partial,
Parcel& parcel) override;
void AcceptParcel(const OperationContext& context, Parcel& parcel) override;
void AcceptRouteClosure(const OperationContext& context,
SequenceNumber sequence_length) override;
void AcceptRouteDisconnected(const OperationContext& context) override;
void MarkSideStable() override;
bool TryLockForBypass(const NodeName& bypass_request_source) override;
bool TryLockForClosure() override;
void Unlock() override;
bool FlushOtherSideIfWaiting(const OperationContext& context) override;
bool CanNodeRequestBypass(const NodeName& bypass_request_source) override;
void BypassPeer(const OperationContext& context,
const NodeName& bypass_target_node,
SublinkId bypass_target_sublink) override;
void StopProxying(const OperationContext& context,
SequenceNumber inbound_sequence_length,
SequenceNumber outbound_sequence_length) override;
void ProxyWillStop(const OperationContext& context,
SequenceNumber inbound_sequence_length) override;
void BypassPeerWithLink(const OperationContext& context,
SublinkId new_sublink,
FragmentRef<RouterLinkState> new_link_state,
SequenceNumber inbound_sequence_length) override;
void StopProxyingToLocalPeer(
const OperationContext& context,
SequenceNumber outbound_sequence_length) override;
void Deactivate() override;
std::string Describe() const override;
class SharedState;
LocalRouterLink(LinkSide side, Ref<SharedState> state);
~LocalRouterLink() override;
const LinkSide side_;
const Ref<SharedState> state_;
} // namespace ipcz