You've already forked UnrealEngineUWP
mirror of
https://github.com/izzy2lost/UnrealEngineUWP.git
synced 2026-03-26 18:15:20 -07:00
84e0b188d8
#rnx #rb none #ROBOMERGE-OWNER: robert.manuszewski #ROBOMERGE-AUTHOR: ryan.durand #ROBOMERGE-SOURCE: CL 10869240 via CL 10869516 via CL 10869902 via CL 10870584 #ROBOMERGE-BOT: CORE (Main -> Dev-Core) (v626-10872990) [CL 10897060 by ryan durand in Dev-Core branch]
114 lines
3.0 KiB
C++
114 lines
3.0 KiB
C++
// Copyright Epic Games, Inc. All Rights Reserved.
|
|
|
|
#include "CoreTypes.h"
|
|
#include "CoreFwd.h"
|
|
#include "Logging/LogMacros.h"
|
|
#include "Common/TcpSocketBuilder.h"
|
|
#include "string.h"
|
|
|
|
class FIOSDeviceOutputReaderRunnable;
|
|
class FIOSTargetDevice;
|
|
class FIOSTargetDeviceOutput;
|
|
|
|
|
|
|
|
|
|
inline FIOSDeviceOutputReaderRunnable::FIOSDeviceOutputReaderRunnable(const FTargetDeviceId InDeviceId, FOutputDevice* InOutput)
|
|
: StopTaskCounter(0)
|
|
, DeviceId(InDeviceId)
|
|
, Output(InOutput)
|
|
, DSCommander(nullptr)
|
|
{
|
|
}
|
|
|
|
inline bool FIOSDeviceOutputReaderRunnable::StartDSCommander()
|
|
{
|
|
if (DSCommander)
|
|
{
|
|
DSCommander->Stop();
|
|
delete DSCommander;
|
|
}
|
|
Output->Serialize(TEXT("Starting listening ....."), ELogVerbosity::Log, NAME_None);
|
|
Output->Serialize(*DeviceId.GetDeviceName(), ELogVerbosity::Log, NAME_None);
|
|
FString Command = FString::Printf(TEXT("listentodevice -device %s"), *DeviceId.GetDeviceName());
|
|
uint8* DSCommand = (uint8*)TCHAR_TO_UTF8(*Command);
|
|
DSCommander = new FTcpDSCommander(DSCommand, strlen((const char*)DSCommand), OutputQueue);
|
|
return DSCommander->IsValid();
|
|
}
|
|
|
|
inline bool FIOSDeviceOutputReaderRunnable::Init(void)
|
|
{
|
|
return StartDSCommander();
|
|
}
|
|
|
|
inline void FIOSDeviceOutputReaderRunnable::Exit(void)
|
|
{
|
|
StopTaskCounter.Increment();
|
|
if (DSCommander)
|
|
{
|
|
DSCommander->Stop();
|
|
delete DSCommander;
|
|
DSCommander = nullptr;
|
|
}
|
|
}
|
|
|
|
inline void FIOSDeviceOutputReaderRunnable::Stop(void)
|
|
{
|
|
StopTaskCounter.Increment();
|
|
}
|
|
|
|
inline uint32 FIOSDeviceOutputReaderRunnable::Run(void)
|
|
{
|
|
Output->Serialize(TEXT("Starting Output"), ELogVerbosity::Log, NAME_None);
|
|
while (StopTaskCounter.GetValue() == 0 && DSCommander->IsValid())
|
|
{
|
|
if (DSCommander->IsStopped() || !DSCommander->IsValid())
|
|
{
|
|
// When user plugs out USB cable DS process stops
|
|
// Keep trying to restore DS connection until code that uses this object will not kill us
|
|
Output->Serialize(TEXT("Trying to restore connection to device..."), ELogVerbosity::Log, NAME_None);
|
|
if (StartDSCommander())
|
|
{
|
|
FPlatformProcess::Sleep(5.0f);
|
|
}
|
|
else
|
|
{
|
|
Output->Serialize(TEXT("Failed to start DS commander"), ELogVerbosity::Log, NAME_None);
|
|
}
|
|
}
|
|
else
|
|
{
|
|
FString Text;
|
|
if (OutputQueue.Dequeue(Text))
|
|
{
|
|
if (Text.Contains(TEXT("[UE4]"), ESearchCase::CaseSensitive))
|
|
{
|
|
Output->Serialize(*Text, ELogVerbosity::Log, NAME_None);
|
|
}
|
|
}
|
|
else
|
|
{
|
|
FPlatformProcess::Sleep(0.1f);
|
|
}
|
|
}
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
inline bool FIOSTargetDeviceOutput::Init(const FIOSTargetDevice& TargetDevice, FOutputDevice* Output)
|
|
{
|
|
check(Output);
|
|
// Output will be produced by background thread
|
|
check(Output->CanBeUsedOnAnyThread());
|
|
|
|
DeviceId = TargetDevice.GetId();
|
|
DeviceName = TargetDevice.GetName();
|
|
|
|
Output->Serialize(TEXT("Creating FIOSTargetDeviceOutput ....."), ELogVerbosity::Log, NAME_None);
|
|
|
|
auto* Runnable = new FIOSDeviceOutputReaderRunnable(DeviceId, Output);
|
|
DeviceOutputThread = TUniquePtr<FRunnableThread>(FRunnableThread::Create(Runnable, TEXT("FIOSDeviceOutputReaderRunnable")));
|
|
return true;
|
|
}
|