Author: ron.sigal(a)jboss.com Date: 2009-09-12 12:21:04 -0400 (Sat, 12 Sep 2009) New Revision: 5455 Modified: remoting2/branches/2.2/src/main/org/jboss/remoting/LeasePinger.java Log: JBREM-1154: sendClientPing() and addClient() throw exceptions instead of swallowing them. Modified: remoting2/branches/2.2/src/main/org/jboss/remoting/LeasePinger.java =================================================================== --- remoting2/branches/2.2/src/main/org/jboss/remoting/LeasePinger.java 2009-09-12 16:19:00 UTC (rev 5454) +++ remoting2/branches/2.2/src/main/org/jboss/remoting/LeasePinger.java 2009-09-12 16:21:04 UTC (rev 5455) @@ -172,8 +172,16 @@ ClientHolder newClient = new ClientHolder(sessionID, configuration, leasePeriod); clientSessionIds.put(sessionID, newClient); - sendClientPing(); - + try + { + sendClientPing(); + } + catch (Throwable t) + { + log.debug(this + " failed to ping to server", t); + log.warn(this + " failed to ping to server: " + t.getMessage()); + throw new RuntimeException(t); + } // if new client lease period is less than the current ping period, need to refresh to new one if (leasePeriod < pingPeriod) { @@ -339,42 +347,34 @@ // Private -------------------------------------------------------------------------------------- - private void sendClientPing() + private void sendClientPing() throws Throwable { - try + if(trace) { - if(trace) + StringBuffer sb = new StringBuffer(); + if(clientSessionIds != null) { - StringBuffer sb = new StringBuffer(); - if(clientSessionIds != null) + for(Iterator i = clientSessionIds.values().iterator(); i.hasNext(); ) { - for(Iterator i = clientSessionIds.values().iterator(); i.hasNext(); ) - { - ClientHolder h = (ClientHolder)i.next(); - sb.append(" ").append(h.getSessionId()).append('\n'); - } + ClientHolder h = (ClientHolder)i.next(); + sb.append(" ").append(h.getSessionId()).append('\n'); } + } - log.trace(this + " sending ping to server. Currently managing lease " + + log.trace(this + " sending ping to server. Currently managing lease " + "for following clients:\n" + sb.toString()); - } + } - Map clientsClone = new ConcurrentHashMap(clientSessionIds); - Map requestClients = new ConcurrentHashMap(); - requestClients.put(ClientHolder.CLIENT_HOLDER_KEY, clientsClone); - requestClients.put(LeasePinger.LEASE_PINGER_ID, leasePingerId); - requestClients.put(TIME_STAMP, Long.toString(System.currentTimeMillis())); - - InvocationRequest ir = new InvocationRequest(invokerSessionID, null, "$PING$", requestClients, null, null); - invoker.invoke(ir); + Map clientsClone = new ConcurrentHashMap(clientSessionIds); + Map requestClients = new ConcurrentHashMap(); + requestClients.put(ClientHolder.CLIENT_HOLDER_KEY, clientsClone); + requestClients.put(LeasePinger.LEASE_PINGER_ID, leasePingerId); + requestClients.put(TIME_STAMP, Long.toString(System.currentTimeMillis())); - if(trace) { log.trace(this + " successfully pinged the server"); } - } - catch (Throwable t) - { - log.debug(this + " failed to ping to server", t); - log.warn(this + " failed to ping to server: " + t.getMessage()); - } + InvocationRequest ir = new InvocationRequest(invokerSessionID, null, "$PING$", requestClients, null, null); + invoker.invoke(ir); + + if(trace) { log.trace(this + " successfully pinged the server"); } } // Inner classes -------------------------------------------------------------------------------- @@ -398,7 +398,15 @@ if (currentPinger != null) { - currentPinger.sendClientPing(); + try + { + currentPinger.sendClientPing(); + } + catch (Throwable t) + { + log.debug(this + " failed to ping to server", t); + log.warn(this + " failed to ping to server: " + t.getMessage()); + } } }