From 9858b647524a9dfc779c69ebaee74650befe40d5 Mon Sep 17 00:00:00 2001
From: Alessandro Pignotti <a.pignotti@sssup.it>
Date: Tue, 15 Oct 2024 22:24:26 +0200
Subject: [PATCH] Add disk latency statistics

---
 src/lib/DiskTab.svelte |  4 ++++
 src/lib/WebVM.svelte   | 16 +++++++++++++++-
 src/lib/activities.js  |  1 +
 3 files changed, 20 insertions(+), 1 deletion(-)

diff --git a/src/lib/DiskTab.svelte b/src/lib/DiskTab.svelte
index b7ce80f..f812cdc 100644
--- a/src/lib/DiskTab.svelte
+++ b/src/lib/DiskTab.svelte
@@ -1,4 +1,8 @@
+<script>
+	import { diskLatency } from './activities.js'
+</script>
 <h1 class="text-lg font-bold">Disk</h1>
+<p><span class="font-bold">Backend latency: </span>{$diskLatency}ms</p>
 <p>WebVM runs on top of a complete Linux distribution</p>
 <p>Filesystems up to 2GB are supported and data is downloaded completely on-demand</p>
 <p>The WebVM cloud backend uses WebSockets and a it's distributed via a global CDN to minimize download latency</p>
diff --git a/src/lib/WebVM.svelte b/src/lib/WebVM.svelte
index e968775..3e4a72c 100644
--- a/src/lib/WebVM.svelte
+++ b/src/lib/WebVM.svelte
@@ -6,13 +6,14 @@
 	import '@xterm/xterm/css/xterm.css'
 	import '@fortawesome/fontawesome-free/css/all.min.css'
 	import { networkInterface, startLogin } from '$lib/network.js'
-	import { cpuActivity, diskActivity, cpuPercentage } from '$lib/activities.js'
+	import { cpuActivity, diskActivity, cpuPercentage, diskLatency } from '$lib/activities.js'
 	import { introMessage, errorMessage } from '$lib/messages.js'
 
 	export let configObj = null;
 	export let processCallback = null;
 	export let cacheId = null;
 	export let cpuActivityEvents = [];
+	export let diskLatencies = [];
 	export let activityEventsInterval = 0;
 
 	var term = null;
@@ -97,6 +98,18 @@
 	{
 		diskActivity.set(state != "ready");
 	}
+	function latencyCallback(latency)
+	{
+		diskLatencies.push(latency);
+		if(diskLatencies.length > 30)
+			diskLatencies.shift();
+		// Average the latency over at most 30 blocks
+		var total = 0;
+		for(var i=0;i<diskLatencies.length;i++)
+			total += diskLatencies[i];
+		var avg = total / diskLatencies.length;
+		diskLatency.set(Math.ceil(avg));
+	}
 	function cpuCallback(state)
 	{
 		cpuActivity.set(state != "ready");
@@ -222,6 +235,7 @@
 		}
 		cx.registerCallback("cpuActivity", cpuCallback);
 		cx.registerCallback("diskActivity", hddCallback);
+		cx.registerCallback("diskLatency", latencyCallback);
 		cx.registerCallback("processCreated", handleProcessCreated);
 		term.scrollToBottom();
 		cxReadFunc = cx.setCustomConsole(writeData, term.cols, term.rows);
diff --git a/src/lib/activities.js b/src/lib/activities.js
index 7dd9f54..f8cde1c 100644
--- a/src/lib/activities.js
+++ b/src/lib/activities.js
@@ -3,3 +3,4 @@ import { writable } from 'svelte/store';
 export const cpuActivity = writable(false);
 export const diskActivity = writable(false);
 export const cpuPercentage = writable(0);
+export const diskLatency = writable(0);