Collect all zen admin-related commands into admin.h/.cpp (#418)

* move commands in scrub.h/cpp to admin_cmd.h/cpp
* move job command into admin_cmd.h/.cpp
* admin -> admin_cmd
* bench -> bench_cmd
* cache -> cache_cmd
* copy -> copy_cmd
* dedup -> dedup_cmd
* hash -> hash_cmd
* print -> print_cmd
* projectstore -> projectstore_cmd
* rpcreplay -> rpcreplay_cmd
* serve -> serve_cmd
* status -> status_cmd
* top -> top_cmd
* trace -> trace_cmd
* up -> up_cmd
* version -> version_cmd

1 files changed, 90 insertions, 0 deletions

diff --git a/src/zen/cmds/top_cmd.cpp b/src/zen/cmds/top_cmd.cpp
new file mode 100644
index 000000000..568ee76c9
--- /dev/null
+++ b/src/zen/cmds/top_cmd.cpp
@@ -0,0 +1,90 @@
+// Copyright Epic Games, Inc. All Rights Reserved.
+
+#include "top_cmd.h"
+
+#include <zencore/fmtutils.h>
+#include <zencore/logging.h>
+#include <zencore/uid.h>
+#include <zenutil/zenserverprocess.h>
+
+#include <memory>
+
+//////////////////////////////////////////////////////////////////////////
+
+namespace zen {
+
+TopCommand::TopCommand()
+{
+}
+
+TopCommand::~TopCommand() = default;
+
+int
+TopCommand::Run(const ZenCliOptions& GlobalOptions, int argc, char** argv)
+{
+	ZEN_UNUSED(GlobalOptions, argc, argv);
+
+	ZenServerState State;
+	if (!State.InitializeReadOnly())
+	{
+		ZEN_CONSOLE("no Zen state found");
+
+		return 0;
+	}
+
+	int		  n			   = 0;
+	const int HeaderPeriod = 20;
+
+	for (;;)
+	{
+		if ((n++ % HeaderPeriod) == 0)
+		{
+			ZEN_CONSOLE("{:>5} {:>6} {:>24}", "port", "pid", "session");
+		}
+
+		State.Snapshot([&](const ZenServerState::ZenServerEntry& Entry) {
+			StringBuilder<25> SessionStringBuilder;
+			Entry.GetSessionId().ToString(SessionStringBuilder);
+			ZEN_CONSOLE("{:>5} {:>6} {:>24}", Entry.EffectiveListenPort.load(), Entry.Pid.load(), SessionStringBuilder);
+		});
+
+		zen::Sleep(1000);
+
+		if (!State.IsReadOnly())
+		{
+			State.Sweep();
+		}
+	}
+
+	return 0;
+}
+
+//////////////////////////////////////////////////////////////////////////
+
+PsCommand::PsCommand()
+{
+}
+
+PsCommand::~PsCommand() = default;
+
+int
+PsCommand::Run(const ZenCliOptions& GlobalOptions, int argc, char** argv)
+{
+	ZEN_UNUSED(GlobalOptions, argc, argv);
+
+	ZenServerState State;
+	if (!State.InitializeReadOnly())
+	{
+		ZEN_CONSOLE("no Zen state found");
+
+		return 0;
+	}
+
+	State.Snapshot([&](const ZenServerState::ZenServerEntry& Entry) {
+		ZEN_CONSOLE("Port {} : pid {}", Entry.EffectiveListenPort.load(), Entry.Pid.load());
+	});
+
+	return 0;
+}
+
+}  // namespace zen