[jdiameter] 2 new revisions pushed by brainslog on 2013-01-25 04:22 GMT

Thu, 24 Jan 2013 20:22:57 -0800 

2 new revisions:

Revision: 3b990fc64db0
Author:   Alexandre Mendonça <ammendonca>
Date:     Thu Jan 24 20:21:39 2013
Log:      FIxing event type when there's a timeout
http://code.google.com/p/jdiameter/source/detail?r=3b990fc64db0

Revision: 0eab8028544d
Author:   Alexandre Mendonça <ammendonca>
Date:     Thu Jan 24 20:22:41 2013
Log:      Adding check for peer state when selecting peers to load balance
http://code.google.com/p/jdiameter/source/detail?r=0eab8028544d

==============================================================================
Revision: 3b990fc64db0
Author:   Alexandre Mendonça <ammendonca>
Date:     Thu Jan 24 20:21:39 2013
Log:      FIxing event type when there's a timeout

http://code.google.com/p/jdiameter/source/detail?r=3b990fc64db0

Modified:
/core/jdiameter/impl/src/main/java/org/jdiameter/client/impl/app/acc/ClientAccSessionImpl.java 

=======================================
--- /core/jdiameter/impl/src/main/java/org/jdiameter/client/impl/app/acc/ClientAccSessionImpl.java Tue Apr 10 11:05:24 2012 +++ /core/jdiameter/impl/src/main/java/org/jdiameter/client/impl/app/acc/ClientAccSessionImpl.java Thu Jan 24 20:21:39 2013 
@@ -687,7 +687,7 @@
   public void timeoutExpired(Request request) {
     try {
        sendAndStateLock.lock();
- handleEvent(new Event(Event.Type.FAILED_RECEIVE_RECORD, createAccountRequest(request))); + handleEvent(new Event(Event.Type.FAILED_SEND_RECORD, createAccountRequest(request))); 
     }
     catch (Exception e) {
       logger.debug("Can not handle timeout event", e);

==============================================================================
Revision: 0eab8028544d
Author:   Alexandre Mendonça <ammendonca>
Date:     Thu Jan 24 20:22:41 2013
Log:      Adding check for peer state when selecting peers to load balance

http://code.google.com/p/jdiameter/source/detail?r=0eab8028544d

Modified:
/core/jdiameter/impl/src/main/java/org/jdiameter/client/impl/router/RouterImpl.java 

=======================================
--- /core/jdiameter/impl/src/main/java/org/jdiameter/client/impl/router/RouterImpl.java Fri Nov 23 19:47:47 2012 +++ /core/jdiameter/impl/src/main/java/org/jdiameter/client/impl/router/RouterImpl.java Thu Jan 24 20:22:41 2013 
@@ -63,6 +63,7 @@
 import org.jdiameter.api.LocalAction;
 import org.jdiameter.api.Message;
 import org.jdiameter.api.MetaData;
+import org.jdiameter.api.PeerState;
 import org.jdiameter.api.RouteException;
 import org.jdiameter.api.URI;
 import org.jdiameter.client.api.IAnswer;
@@ -403,7 +404,9 @@
         if(logger.isDebugEnabled()) {
logger.debug("Checking peer [{}] for name [{}]", new Object[]{localPeer,peerName}); 
         }
-        if (localPeer != null) {
+        // ammendonca: added peer state check.. should not be needed but
+ // hasValidConnection is returning true for disconnected peers in *FTFlowTests + if (localPeer != null && localPeer.getState(PeerState.class) == PeerState.OKAY) { 
           if(localPeer.hasValidConnection()) {
             if(logger.isDebugEnabled()) {
logger.debug("Found available peer to add to available peer list with uri [{}] with a valid connection", localPeer.getUri().toString()); 

--

Reply via email to