X-Git-Url: http://dolda2000.com/gitweb/?p=jagi.git;a=blobdiff_plain;f=src%2Fjagi%2Fscgi%2FEventServer.java;fp=src%2Fjagi%2Fscgi%2FEventServer.java;h=202b8ddad9f109b70bd9dff9e714fa5a292dcd25;hp=2de2e86fef0c6d98c893f9489b46967e601d5dad;hb=794a5c90597dcfeffafbc5976cde812072023d0a;hpb=142de7b251648edb9ebd9956498db7e00be7eef8 diff --git a/src/jagi/scgi/EventServer.java b/src/jagi/scgi/EventServer.java index 2de2e86..202b8dd 100644 --- a/src/jagi/scgi/EventServer.java +++ b/src/jagi/scgi/EventServer.java @@ -334,6 +334,7 @@ public class EventServer implements Runnable { int headlen = 0; ByteBuffer head = null; Map env = null; + Request req = null; Client(SocketChannel sk) { this.sk = sk; @@ -401,8 +402,7 @@ public class EventServer implements Runnable { if((events & SelectionKey.OP_READ) != 0) { if((env == null) && !readhead()) return; - Request req = new Request(env, sk); - submit(() -> EventServer.this.handle(req, handler)); + req = new Request(env, sk); handoff = true; } if(Driver.current().time() > (lastread + timeout)) @@ -410,6 +410,8 @@ public class EventServer implements Runnable { } public void close() { + if(req != null) + submit(() -> EventServer.this.handle(req, handler)); if(!handoff) { try { sk.close();