2023-04-10 18:12:45 -04:00
|
|
|
// Copyright Epic Games, Inc. All Rights Reserved.
|
|
|
|
|
|
2023-11-22 12:25:59 -05:00
|
|
|
#include "Compute/ComputeChannel.h"
|
2023-05-19 21:50:03 -04:00
|
|
|
#include <string.h>
|
|
|
|
|
#include <stdio.h>
|
2023-11-22 12:25:59 -05:00
|
|
|
#include "Compute/ComputeSocket.h"
|
2023-04-10 18:12:45 -04:00
|
|
|
|
|
|
|
|
FComputeChannel::FComputeChannel()
|
|
|
|
|
{
|
|
|
|
|
}
|
|
|
|
|
|
2023-07-22 14:17:04 -04:00
|
|
|
FComputeChannel::FComputeChannel(FComputeBufferReader InReader, FComputeBufferWriter InWriter)
|
2023-11-30 15:43:35 -05:00
|
|
|
: Reader(MoveTemp(InReader))
|
|
|
|
|
, Writer(MoveTemp(InWriter))
|
2023-07-22 14:17:04 -04:00
|
|
|
{
|
|
|
|
|
}
|
|
|
|
|
|
2023-04-10 18:12:45 -04:00
|
|
|
FComputeChannel::~FComputeChannel()
|
|
|
|
|
{
|
2023-05-19 21:50:03 -04:00
|
|
|
}
|
|
|
|
|
|
2023-07-22 14:17:04 -04:00
|
|
|
bool FComputeChannel::IsValid() const
|
2023-05-19 21:50:03 -04:00
|
|
|
{
|
2023-07-22 14:17:04 -04:00
|
|
|
return Reader.IsValid();
|
2023-04-10 18:12:45 -04:00
|
|
|
}
|
|
|
|
|
|
2023-05-19 21:50:03 -04:00
|
|
|
size_t FComputeChannel::Send(const void* Data, size_t Size, int TimeoutMs)
|
2023-04-10 18:12:45 -04:00
|
|
|
{
|
2023-07-22 14:17:04 -04:00
|
|
|
return Writer.Write(Data, Size, TimeoutMs);
|
2023-04-10 18:12:45 -04:00
|
|
|
}
|
|
|
|
|
|
2023-05-19 21:50:03 -04:00
|
|
|
size_t FComputeChannel::Recv(void* Data, size_t Size, int TimeoutMs)
|
|
|
|
|
{
|
2023-07-22 14:17:04 -04:00
|
|
|
return Reader.Read(Data, Size, TimeoutMs);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
void FComputeChannel::MarkComplete()
|
|
|
|
|
{
|
|
|
|
|
Writer.MarkComplete();
|
2023-05-19 21:50:03 -04:00
|
|
|
}
|