Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

updated loadbalancing failover implementation to ease merging issue#36 #97

Open
wants to merge 26 commits into
base: master
Choose a base branch
from
Open
Changes from 1 commit
Commits
Show all changes
26 commits
Select commit Hold shift + click to select a range
b0ebcd2
updated failover logic to ease merging
bkrok Jun 22, 2017
7a2e62b
changed RequestType package
bkrok Jul 3, 2017
162287f
implemented additional method in testsuite
bkrok Jul 5, 2017
f31450b
1. Added new classes, back to previous versions IMessage and MessageImpl
bkrok Jul 4, 2017
1cedf9c
Cherry picked commits
bkrok Jul 5, 2017
5c8481c
1. replaced SESSION_INACTIVITY_TIMER_NAME with IDLE_SESSION_TIME_NAME
bkrok Jul 5, 2017
5f41df6
replaced RetransmissionTimeout with MessageTimeout
bkrok Jul 5, 2017
809679f
jdiameter-config_ext_routing_failover fixed
bkrok Jul 5, 2017
4700b9e
reformat code
bkrok Jul 5, 2017
0360248
fix
bkrok Jul 6, 2017
7583b7a
1. revert some changes from commit f31450bd41977c9ac874501354c816c26b…
bkrok Jul 6, 2017
5c2e50f
parameters order kept
bkrok Jul 6, 2017
7e099ff
1. testsuite ClassCastException fixed
bkrok Jul 11, 2017
e8bca24
deleted CCAMessage
bkrok Jul 26, 2017
4fd806e
removed getCcSessionFailover method
bkrok Jul 26, 2017
f96d30f
fix backward compability issue with ClientCCASessionImpl contructor
bkrok Jul 27, 2017
e94f273
fix to session inactivity timer
bkrok Jul 27, 2017
84d264c
Revert "fix to session inactivity timer"
bkrok Jul 27, 2017
1e7f457
Inactive session timer refactoring into idle session timeout
Jul 28, 2017
7f836ab
fixed cast exception
bkrok Aug 8, 2017
5a9c021
Get AVP index methods implemented
bkrok Aug 8, 2017
c5003b3
old timer commented
bkrok Aug 10, 2017
0dd40cd
moved constants from IMessage to IRoMessageFactory
bkrok Aug 18, 2017
4204f5b
old timer deleted
bkrok Aug 18, 2017
36a739d
removed session inactivity timeout, config for jdiameter updated
bkrok Aug 29, 2017
7eac72c
removed retransmission timeout
bkrok Aug 29, 2017
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
parameters order kept
bkrok committed Jul 6, 2017
commit 5c2e50ff80c9170a2e019270c8fe7b61bcb4c33b
Original file line number Diff line number Diff line change
@@ -145,7 +145,7 @@ void doRequestTimeout(ClientRoSession session, Message msg, Peer peer)
* @throws RouteException The NoRouteException signals that no route exist for a given realm.
* @throws OverloadException The OverloadException signals that destination host is overloaded.
*/
void doPeerUnavailability(RouteException cause, ClientRoSession session, Message msg, Peer peer)
void doPeerUnavailability(ClientRoSession session, Message msg, Peer peer, RouteException cause)
throws InternalException, IllegalDiameterStateException, RouteException, OverloadException;

/**
Original file line number Diff line number Diff line change
@@ -1480,7 +1480,7 @@ protected void deliverPeerUnavailabilityError(Message msg, NoMorePeersAvailableE
logger.debug("Propagating peer unavailability error event to listener [{}] on {} session", listener, isValid() ? "valid" : "invalid");
try {
if (isValid()) {
listener.doPeerUnavailability(cause, this, msg, ((ICCAMessage) msg).getPeer());
listener.doPeerUnavailability(this, msg, ((ICCAMessage) msg).getPeer(), cause);
}
}
catch (Exception e) {
Original file line number Diff line number Diff line change
@@ -388,7 +388,7 @@ public void doRequestTimeout(ClientRoSession session, Message msg, Peer peer) th
}

@Override
public void doPeerUnavailability(RouteException cause, ClientRoSession session, Message msg, Peer peer) throws InternalException {
public void doPeerUnavailability(ClientRoSession session, Message msg, Peer peer, RouteException cause) throws InternalException {

}