Commit 6683bf2ee081519cf319e9149007a5158b95545f to dustin's java-memcached-client

6683bf2
all branches
all tags
- 2.2rc2
- 2.2rc1
- 2.2
- 2.1rc3
- 2.1rc2
- 2.1rc1
- 2.1
- 2.0.2
- 2.0.1
- 2.0-pre9
- 2.0-pre8
- 2.0-pre7
- 2.0-pre6
- 2.0-pre5
- 2.0-pre4
- 2.0-pre3
- 2.0-pre2
- 2.0-pre1
- 2.0
- 1.4
- 1.3.1
- 1.3
- 1.2
- 1.1
- 1.0.44
- 1.0.43
- 1.0.42
- 1.0.41
- 1.0.40
- 1.0.39
- 1.0.38
- 1.0.37
- 1.0.36
- 1.0.34
comments

dustin / java-memcached-client

Description:	A simple, asynchronous, single-threaded memcached client written in java.
Homepage:	http://code.google.com/p/spymemcached/
Clone URL:	git://github.com/dustin/java-memcached-client.git Give this clone URL to anyone. `git clone git://github.com/dustin/java-memcached-client.git`

  Reconnect if an IOException occurs during handleOperation()

dustin (author)

Sat Mar 31 18:47:52 -0700 2007

commit 6683bf2ee081519cf319e9149007a5158b95545f
tree 6e246becc46f0fb22b160785da4dc40a5ffb9f97
parent e1837b53d7c26034aa9ae1904184694ff2b67f2c

src/java/net/spy/memcached/MemcachedConnection.java

src/java/net/spy/memcached/MemcachedConnection.java

0
@@ -206,7 +206,13 @@ public class MemcachedConnection extends SpyObject {
0
     } else {
0
       Operation currentOp=qa.ops.peek();
0
       if(currentOp != null) {
0
-				handleOperation(currentOp, sk, qa);
0
+				try {
0
+					handleOperation(currentOp, sk, qa);
0
+				} catch(IOException e) {
0
+					getLogger().warn("Exception handling %s, reconnecting",
0
+							currentOp, e);
0
+					queueReconnect(qa);
0
+				}
0
       } else {
0
         if(sk.isReadable()) {
0
           ByteBuffer b=ByteBuffer.allocate(1);

Comments

No one has commented yet.