Revision: 8291
Author: vladimir.ralev
Date: Thu Nov 5 13:18:30 2009
Log: Proxy response retransmissions reaching applicaiton test
http://code.google.com/p/mobicents/source/detail?r=8291
Modified:
/trunk/servers/sip-servlets/sip-servlets-test-suite/testsuite/src/test/java/org/mobicents/servlet/sip/testsuite/proxy/SequentialProxyTest.java
/trunk/servers/sip-servlets/sip-servlets-test-suite/testsuite/src/test/java/org/mobicents/servlet/sip/testsuite/proxy/Shootist.java
=======================================
---
/trunk/servers/sip-servlets/sip-servlets-test-suite/testsuite/src/test/java/org/mobicents/servlet/sip/testsuite/proxy/SequentialProxyTest.java
Wed Nov 4 18:07:12 2009
+++
/trunk/servers/sip-servlets/sip-servlets-test-suite/testsuite/src/test/java/org/mobicents/servlet/sip/testsuite/proxy/SequentialProxyTest.java
Thu Nov 5 13:18:30 2009
@@ -128,6 +128,24 @@
if (cutme.canceled == true)
fail("This party must not ever be contacted");
}
+
+ public void testOKRetransmissionsReachApplication() {
+ this.shootme.init("stackName");
+ this.cutme.init();
+ this.shootist.pauseBeforeAck = 4000;
+ this.shootist.init("sequential-retransmission", false);
+ for (int q = 0; q < 2; q++) {
+ if (shootist.ended == false || cutme.canceled == false)
+ try {
+ Thread.sleep(TIMEOUT);
+ } catch (InterruptedException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
+ }
+ if (shootist.ended == false)
+ fail("Conversation not complete!");
+ }
public void testFirstTargetRespondsBusy() {
this.shootme.inviteResponseCode = 483;
=======================================
---
/trunk/servers/sip-servlets/sip-servlets-test-suite/testsuite/src/test/java/org/mobicents/servlet/sip/testsuite/proxy/Shootist.java
Wed Nov 4 18:07:12 2009
+++
/trunk/servers/sip-servlets/sip-servlets-test-suite/testsuite/src/test/java/org/mobicents/servlet/sip/testsuite/proxy/Shootist.java
Thu Nov 5 13:18:30 2009
@@ -96,6 +96,7 @@
public boolean okToInviteRecevied = false;
public int pauseBeforeBye = 3000;
+ public int pauseBeforeAck = 0;
int count = 0;
@@ -245,6 +246,7 @@
try {
if (response.getStatusCode() == Response.OK) {
if (cseq.getMethod().equals(Request.INVITE)) {
+ Thread.sleep(pauseBeforeAck);
ackRequest =
dialog.createAck(cseq.getSeqNumber());
if(forkingProxy) {
logger.info("dialog = " +
dialog);