From: Ian Jackson <ijackson@chiark.greenend.org.uk>
Date: Wed, 1 Jul 2020 21:25:40 +0000 (+0100)
Subject: before use vec prefix counter thing
X-Git-Tag: otter-0.2.0~1494
X-Git-Url: https://www.chiark.greenend.org.uk/ucgi/~ianmdlvl/git?a=commitdiff_plain;h=58235bc0e8423a6090a41fe8785e7080a52ee006;p=otter.git

before use vec prefix counter thing
---

diff --git a/src/bin/server.rs b/src/bin/server.rs
index 1bd0a4f8..65557f21 100644
--- a/src/bin/server.rs
+++ b/src/bin/server.rs
@@ -215,12 +215,43 @@ const UPDATE_MAX_MSG_SIZE : usize = 1024;
 struct UpdateReader {
   playerid : PlayerId,
   client : ClientId,
-  startat : Counter,
-  amu : Arc<Mutex<Instance>>>,
+  last_sent : Counter, // xxx race for setting this initially
+  ami : Arc<Mutex<Instance>>>,
 }
 impl Read for UpdateReader {
   fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> {
-    let mug = amu.lock()?;
+    let amig = self.ami.lock()?;
+    loop {
+      let send_from = (||{
+        let updates = &amig.updates.get(playerid)
+          .ok_or_else(|| anyhow!("player gone"))?
+        let l = self.updates.len();
+        let last_probe = match updates.last() {
+          None => return None,
+          Some(&now) if self.last_sent > now.gen => return l+1,
+          _ => l,
+        };
+        let (lo, hi /* half-open */) = loop {
+          let depth = l - last_probe;
+          depth *= 2;
+          if depth > l { break (0, last_probe) }
+          let probe = l - depth;
+          let here = updates[probe];
+          if here.gen < l 
+
+        if let Some(&now) =  {
+          if  { return None }
+        }
+        let probe = inst.updates.len() - 1;
+        let (lo, hi) = loop {
+          if search == 0 { break }
+          search -= 1;
+          tu = inst.updates[search];
+          if 
+
+        let lo = 0;
+        
+      };
     loop {
          implement this! 
     }