blob: ee2a6f32795327f23eba0f03b838a0f1a1783d59 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
|
// Copyright Epic Games, Inc. All Rights Reserved.
#include "hordecomputechannel.h"
namespace zen::horde {
ComputeChannel::ComputeChannel(ComputeBufferReader InReader, ComputeBufferWriter InWriter)
: Reader(std::move(InReader))
, Writer(std::move(InWriter))
{
}
bool
ComputeChannel::IsValid() const
{
return Reader.IsValid() && Writer.IsValid();
}
size_t
ComputeChannel::Send(const void* Data, size_t Size, int TimeoutMs)
{
return Writer.Write(Data, Size, TimeoutMs);
}
size_t
ComputeChannel::Recv(void* Data, size_t Size, int TimeoutMs)
{
return Reader.Read(Data, Size, TimeoutMs);
}
void
ComputeChannel::MarkComplete()
{
Writer.MarkComplete();
}
} // namespace zen::horde
|