halwiegasjkdlfawegasdfjhwoigekjldfas

Author: hopskipnfall

Notebook.ipynb

@@ -3,12 +3,7 @@
   {
    "cell_type": "code",
    "execution_count": null,
-   "metadata": {
-    "ExecuteTime": {
-     "end_time": "2025-08-16T04:33:07.335326Z",
-     "start_time": "2025-08-16T04:33:04.692050Z"
-    }
-   },
+   "metadata": {},
    "outputs": [],
    "source": [
     "import com.hopskipnfall.*\n",
@@ -60,12 +55,7 @@
   {
    "cell_type": "code",
    "execution_count": null,
-   "metadata": {
-    "ExecuteTime": {
-     "end_time": "2025-08-16T04:34:27.493147Z",
-     "start_time": "2025-08-16T04:33:07.351490Z"
-    }
-   },
+   "metadata": {},
    "outputs": [],
    "source": [
     "%useLatestDescriptors\n",
@@ -119,19 +109,14 @@
   {
    "cell_type": "code",
    "execution_count": null,
-   "metadata": {
-    "ExecuteTime": {
-     "end_time": "2025-08-16T04:34:29.938788Z",
-     "start_time": "2025-08-16T04:34:29.586695Z"
-    }
-   },
+   "metadata": {},
    "outputs": [],
    "source": [
     "import org.emulinker.proto.Event.EventTypeCase.*\n",
     "import java.io.FileInputStream\n",
     "import org.emulinker.proto.GameLog\n",
     "\n",
-    "val log: GameLog = FileInputStream(\"gamelog_1p_1f.bin\").use { GameLog.parseFrom(it.readBytes()) }\n",
+    "val log: GameLog = FileInputStream(\"gamelog_2p_1f.bin\").use { GameLog.parseFrom(it.readBytes()) }\n",
     "val events = log.eventsList\n",
     "\n",
     "println(\"Game configuration:\")\n",
@@ -148,28 +133,25 @@
   {
    "cell_type": "code",
    "execution_count": null,
-   "metadata": {
-    "ExecuteTime": {
-     "end_time": "2025-08-16T04:34:32.428746Z",
-     "start_time": "2025-08-16T04:34:32.187285Z"
-    }
-   },
+   "metadata": {},
    "outputs": [],
    "source": [
     "import org.emulinker.proto.Event\n",
     "import org.jetbrains.kotlinx.dataframe.api.dataFrameOf\n",
     "import org.jetbrains.kotlinx.dataframe.api.toDataFrame\n",
     "\n",
-    "val summaries = events.filter { it.eventTypeCase == LAGSTAT_SUMMARY }\n",
+    "val summaries = events.filter { it.eventTypeCase == LAGSTAT_SUMMARY && it.lagstatSummary.gameLagMs < 2000 }\n",
     "\n",
     "val time = column<Long>(\"Timestamp (ns)\")\n",
     "val observedLag = column<Double>(\"Observed lag (ms)\")\n",
     "val player1Lag = column<Double>(\"Player 1 attributed lag (ms)\")\n",
+    "val player2Lag = column<Double>(\"Player 2 attributed lag (ms)\")\n",
     "\n",
     "val df = dataFrameOf(\n",
     "  time.name() to summaries.map { it.timestampNs },\n",
     "  observedLag.name() to summaries.map { it.lagstatSummary.gameLagMs },\n",
-    "  player1Lag.name() to summaries.map { it.lagstatSummary.playerAttributedLagsList.single().attributedLagMs }\n",
+    "  player1Lag.name() to summaries.map { it.lagstatSummary.getPlayerAttributedLags(0).attributedLagMs },\n",
+    "  player2Lag.name() to summaries.map { it.lagstatSummary.getPlayerAttributedLags(1).attributedLagMs }\n",
     ")\n",
     "\n",
     "df.plot {\n",
@@ -183,8 +165,13 @@
     "    y(player1Lag)\n",
     "    color = Color.BLUE\n",
     "  }\n",
+    "  points {\n",
+    "    y(player2Lag)\n",
+    "    color = Color.RED\n",
+    "  }\n",
     "  layout {\n",
     "    title = \"Server-measured lag\"\n",
+    "    subtitle = \"Grey is server, blue is p1, red is p2\"\n",
     "  }\n",
     "}"
    ]

src/main/proto/lag.proto

@@ -10,14 +10,14 @@ import "google/protobuf/timestamp.proto";
 
 option java_multiple_files = true;
 
-enum PlayerNumber {
+enum Player {
   // Note: In some languages having multiple enum values with the same
   // name causes issues so it's good to prefix with the name.
-  PLAYER_NUMBER_UNKNOWN = 0;
-  ONE = 1;
-  TWO = 2;
-  THREE = 3;
-  FOUR = 4;
+  PLAYER_UNSPECIFIED = 0;
+  PLAYER_ONE = 1;
+  PLAYER_TWO = 2;
+  PLAYER_THREE = 3;
+  PLAYER_FOUR = 4;
 }
 
 message Event {
@@ -28,7 +28,7 @@ message Event {
 
   message GameStart {
     message PlayerDetails {
-      PlayerNumber player_number = 1;
+      Player player_number = 1;
 
       // User's average ping when they joined the server.
       double ping_ms = 2;
@@ -42,7 +42,7 @@ message Event {
   }
 
   message ReceivedGameData {
-    PlayerNumber received_from = 1;
+    Player received_from = 1;
   }
 
   // Server has collected data from all parties for the frame and will
@@ -59,7 +59,7 @@ message Event {
     double game_lag_ms = 2;
 
     message PlayerAttributedLag {
-      PlayerNumber player = 1;
+      Player player = 1;
 
       // How much of the drift can be reliably attributed to the
       // player.