XmppStropheThread.h

Go to the documentation of this file.

// Copyright Epic Games, Inc. All Rights Reserved.
 
#pragma once
 
#include "CoreMinimal.h"
#include "XmppConnection.h"
#include "XmppStrophe/StropheConnection.h"
 
#include "HAL/ThreadSafeBool.h"
#include "HAL/Runnable.h"
#include "Containers/Queue.h"
 
#if WITH_XMPP_STROPHE
 
class FRunnableThread;
class FXmppConnectionStrophe;
class FStropheStanza;
 
class FXmppStropheThread
    : public FRunnable
{
public:
    // FXmppStropheThread
    explicit FXmppStropheThread(FXmppConnectionStrophe& InConnectionManager, const FXmppUserJid& InUser, const FString& InAuth, const FXmppServer& InServerConfiguration);
    virtual ~FXmppStropheThread();
 
    bool SendStanza(FStropheStanza&& Stanza);
 
    // FRunnable
    virtual bool Init() override;
    virtual uint32 Run() override;
    virtual void Stop() override;
    virtual void Exit() override;
 
protected:
    void SendQueuedStanza();
 
protected:
    FXmppConnectionStrophe& ConnectionManager;
 
    FStropheConnection StropheConnection;
 
    const FXmppServer& ServerConfiguration;
 
    TUniquePtr<FRunnableThread> ThreadPtr;
 
    TQueue<TUniquePtr<FStropheStanza>> StanzaSendQueue;
 
    FThreadSafeBool bConnectRequest;
    FThreadSafeBool bDisconnectRequest;
    FThreadSafeBool bExitRequested;
};
 
#endif