DirectLinkStreamSender.h

Go to the documentation of this file.

// Copyright Epic Games, Inc. All Rights Reserved.
 
#pragma once
 
#include "DirectLinkScenePipe.h"
#include "DirectLinkStreamCommunicationInterface.h"
#include "DirectLinkSceneSnapshot.h"
 
#include "CoreTypes.h"
#include "Containers/SortedMap.h"
 
 
namespace DirectLink
{
class FRemoteSceneView;
class FHaveListReceiver;
 
class FStreamSender : public IStreamSender
{
public:
    FStreamSender(TSharedPtr<FMessageEndpoint, ESPMode::ThreadSafe> ThisEndpoint, const FMessageAddress& DestinationAddress, FStreamPort ReceiverStreamPort);
    ~FStreamSender();
    virtual void SetSceneSnapshot(TSharedPtr<FSceneSnapshot> SceneSnapshot) override;
    virtual void Tick(double Now_s) override;
    virtual void HandleHaveListMessage(const FDirectLinkMsg_HaveListMessage& Message) override; // update RemoteView
 
public: // IStreamCommunicationInterface API
    virtual FCommunicationStatus GetCommunicationStatus() const override { return CurrentCommunicationStatus; }
 
private:
    enum class EStep
    {
        Idle,
        SetupScene,
        ReceiveHaveList,
        GenerateDelta,
        SendDelta,
        Synced,
    };
 
    EStep NextStep = EStep::Idle;
    int32 SyncCycle = 0;
 
    FScenePipeToNetwork PipeToNetwork;
    TUniquePtr<FHaveListReceiver> HaveListReceiver;
    double LastHaveListMessage_s = 0;
 
    TSharedPtr<FSceneSnapshot> Snapshot;
    FCriticalSection NextSnapshotLock;
    TSharedPtr<FSceneSnapshot> NextSnapshot;
 
    TUniquePtr<FRemoteSceneView> RemoteScene;
 
    // Reporting
    FCommunicationStatus CurrentCommunicationStatus;
};
 
 
} // namespace DirectLink