From 461a72bd9470ec7f7c241a45b18cd738cdddae46 Mon Sep 17 00:00:00 2001
From: Michael Bayne <mdb@threerings.net>
Date: Sat, 21 Feb 2004 00:51:02 +0000
Subject: [PATCH] Mark each upstream message with a the time at which it was
 decoded from incoming network data.

git-svn-id: svn+ssh://src.earth.threerings.net/narya/trunk@2959 542714f4-19e9-0310-aa3c-eee0fc999fb1
---
 src/java/com/threerings/presents/net/UpstreamMessage.java   | 5 ++++-
 src/java/com/threerings/presents/server/net/Connection.java | 3 ++-
 2 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/src/java/com/threerings/presents/net/UpstreamMessage.java b/src/java/com/threerings/presents/net/UpstreamMessage.java
index 91093e3a2..5d5d146d0 100644
--- a/src/java/com/threerings/presents/net/UpstreamMessage.java
+++ b/src/java/com/threerings/presents/net/UpstreamMessage.java
@@ -1,5 +1,5 @@
 //
-// $Id: UpstreamMessage.java,v 1.11 2002/12/20 23:41:26 mdb Exp $
+// $Id: UpstreamMessage.java,v 1.12 2004/02/21 00:51:02 mdb Exp $
 
 package com.threerings.presents.net;
 
@@ -20,6 +20,9 @@ public abstract class UpstreamMessage extends SimpleStreamableObject
      */
     public short messageId;
 
+    /** A timestamp indicating when this upstream message was received. */
+    public transient long received;
+
     /**
      * Each upstream message derived class must provide a zero argument
      * constructor so that it can be unserialized when read from the
diff --git a/src/java/com/threerings/presents/server/net/Connection.java b/src/java/com/threerings/presents/server/net/Connection.java
index e45a0da9e..687710e4f 100644
--- a/src/java/com/threerings/presents/server/net/Connection.java
+++ b/src/java/com/threerings/presents/server/net/Connection.java
@@ -1,5 +1,5 @@
 //
-// $Id: Connection.java,v 1.16 2003/08/20 19:32:27 mdb Exp $
+// $Id: Connection.java,v 1.17 2004/02/21 00:51:02 mdb Exp $
 
 package com.threerings.presents.server.net;
 
@@ -239,6 +239,7 @@ public abstract class Connection implements NetEventHandler
                 bytesIn = _fin.available() + 4;
                 // parse the message and pass it on
                 UpstreamMessage msg = (UpstreamMessage)_oin.readObject();
+                msg.received = when;
 //                 Log.info("Read message " + msg + ".");
                 _handler.handleMessage(msg);
             }