From 0763d09a81e5a1d3df11763a7ec75e7860c9510a Mon Sep 17 00:00:00 2001
From: Stefan Boberg <stefan.boberg@epicgames.com>
Date: Wed, 4 Mar 2026 14:13:46 +0100
Subject: compute orchestration (#763)

- Added local process runners for Linux/Wine, Mac with some sandboxing support
- Horde & Nomad provisioning for development and testing
- Client session queues with lifecycle management (active/draining/cancelled), automatic retry with configurable limits, and manual reschedule API
- Improved web UI for orchestrator, compute, and hub dashboards with WebSocket push updates
- Some security hardening
- Improved scalability and `zen exec` command

Still experimental - compute support is disabled by default
---
 src/zencompute/functionrunner.cpp | 112 --------------------------------------
 1 file changed, 112 deletions(-)
 delete mode 100644 src/zencompute/functionrunner.cpp

(limited to 'src/zencompute/functionrunner.cpp')

diff --git a/src/zencompute/functionrunner.cpp b/src/zencompute/functionrunner.cpp
deleted file mode 100644
index 8e7c12b2b..000000000
--- a/src/zencompute/functionrunner.cpp
+++ /dev/null
@@ -1,112 +0,0 @@
-// Copyright Epic Games, Inc. All Rights Reserved.
-
-#include "functionrunner.h"
-
-#if ZEN_WITH_COMPUTE_SERVICES
-
-#	include <zencore/compactbinary.h>
-#	include <zencore/filesystem.h>
-
-#	include <fmt/format.h>
-#	include <vector>
-
-namespace zen::compute {
-
-FunctionRunner::FunctionRunner(std::filesystem::path BasePath) : m_ActionsPath(BasePath / "actions")
-{
-}
-
-FunctionRunner::~FunctionRunner() = default;
-
-size_t
-FunctionRunner::QueryCapacity()
-{
-	return 1;
-}
-
-std::vector<SubmitResult>
-FunctionRunner::SubmitActions(const std::vector<Ref<RunnerAction>>& Actions)
-{
-	std::vector<SubmitResult> Results;
-	Results.reserve(Actions.size());
-
-	for (const Ref<RunnerAction>& Action : Actions)
-	{
-		Results.push_back(SubmitAction(Action));
-	}
-
-	return Results;
-}
-
-void
-FunctionRunner::MaybeDumpAction(int ActionLsn, const CbObject& ActionObject)
-{
-	if (m_DumpActions)
-	{
-		std::string			  UniqueId = fmt::format("{}.ddb", ActionLsn);
-		std::filesystem::path Path	   = m_ActionsPath / UniqueId;
-
-		zen::WriteFile(Path, IoBuffer(ActionObject.GetBuffer().AsIoBuffer()));
-	}
-}
-
-//////////////////////////////////////////////////////////////////////////
-
-RunnerAction::RunnerAction(FunctionServiceSession* OwnerSession) : m_OwnerSession(OwnerSession)
-{
-	this->Timestamps[static_cast<int>(State::New)] = DateTime::Now().GetTicks();
-}
-
-RunnerAction::~RunnerAction()
-{
-}
-
-void
-RunnerAction::SetActionState(State NewState)
-{
-	ZEN_ASSERT(NewState < State::_Count);
-	this->Timestamps[static_cast<int>(NewState)] = DateTime::Now().GetTicks();
-
-	do
-	{
-		if (State CurrentState = m_ActionState.load(); CurrentState == NewState)
-		{
-			// No state change
-			return;
-		}
-		else
-		{
-			if (NewState <= CurrentState)
-			{
-				// Cannot transition to an earlier or same state
-				return;
-			}
-
-			if (m_ActionState.compare_exchange_strong(CurrentState, NewState))
-			{
-				// Successful state change
-
-				m_OwnerSession->PostUpdate(this);
-
-				return;
-			}
-		}
-	} while (true);
-}
-
-void
-RunnerAction::SetResult(CbPackage&& Result)
-{
-	m_Result = std::move(Result);
-}
-
-CbPackage&
-RunnerAction::GetResult()
-{
-	ZEN_ASSERT(IsCompleted());
-	return m_Result;
-}
-
-}  // namespace zen::compute
-
-#endif	// ZEN_WITH_COMPUTE_SERVICES
\ No newline at end of file
-- 
cgit v1.2.3