// 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