@@ -293,6 +293,10 @@ public final class MemcachedConnection extends SpyObject { ByteBuffer rbuf=qa.getRbuf(); final SocketChannel channel = qa.getChannel(); int read=channel.read(rbuf); + if (read < 0) { + // GRUMBLE. + throw new IOException("Disconnected"); + } while(read > 0) { getLogger().debug("Read %d bytes", read); rbuf.flip(); src/main/java/net/spy/memcached/MemcachedConnection.java 255d13bdb16e66175c58bf16a15010555e3dced7 Robey Pointer robey@twitter.com http://github.com/dustin/java-memcached-client/commit/c7213d018047b6a17cfac88953e7cacf9ab48b10 c7213d018047b6a17cfac88953e7cacf9ab48b10 2008-10-02T21:49:30-07:00 2008-07-21T16:48:51-07:00 if the memcache server disconnects, try to notice. ba9954495da439d46e78f518eb438f30c6695d24 Dustin Sallings dustin@spy.net