exception handling and reopen

run.java

  /**
   * Infinitely loop processing IO.
   */
  @Override
  public void run() {
    while (running) {
      try {
        handleIO();
      } catch (IOException e) {
        logRunException(e);
      } catch (CancelledKeyException e) {
        logRunException(e);
      } catch (ClosedSelectorException e) {
        logRunException(e);
      } catch (IllegalStateException e) {
        logRunException(e);
      } catch (Exception e) {
    	logRunException(e);
    	
    	// iterate through all nodes and callsetupResend
    	// to cancel current ops.
    	for (MemcachedNode qa : locator.getAll()) {
    		qa.setupResend();
    		try {
    			qa.getChannel().close();
    			qa.setChannel(SocketChannel.open(qa.getSocketAddress()));
    		} catch(IOException ex) {
    			// die? "couldnt recover"?
    			logRunException(ex);
    		}
    	}
      }
    }
    getLogger().info("Shut down memcached client");
  }