Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  package test.unit.gov.nist.javax.sip.stack;
  
  
  
 
 import  junit.framework.TestCase;

Testing for deadlock under massive load on the same call. This testcase reproduces deadlock that occurs most frequently with TCP thread pool size set to 1 from this issue https://jain-sip.dev.java.net/issues/show_bug.cgi?id=301 Other related issue is here http://code.google.com/p/mobicents/issues/detail?id=1810 The test sends couple of thousands 180 Ringing responses in order to stall the UAC thread. The issue is more easily reproducible without debug logs - 300 vs 1000 messages on average

Author(s):
vralev
 
 public class StackQueueCongestionControlTest extends TestCase {
 
     public class Shootme implements SipListener {
 
         private  AddressFactory addressFactory;
 
         private  MessageFactory messageFactory;
 
         private  HeaderFactory headerFactory;
 
         private SipStack sipStack;
 
         private SipProvider sipProvider;
 
         private static final String myAddress = "127.0.0.1";
 
         private static final int myPort = 5070;
 
 
 
         private DialogExt dialog;
 
         public static final boolean callerSendsBye = true;
 
 
 
 
         public void processRequest(RequestEvent requestEvent) {
             Request request = requestEvent.getRequest();
             ServerTransaction serverTransactionId = requestEvent
                     .getServerTransaction();
 
             ..println("\n\nRequest " + request.getMethod()
                     + " received at " + .getStackName()
                     + " with server transaction id " + serverTransactionId);
 
             if (request.getMethod().equals(.)) {
                 processInvite(requestEventserverTransactionId);
             } else if(request.getMethod().equals(.)) {
                 processAck(requestEventserverTransactionId);
             }
 
        }
        private int num = 0;
        public void processResponse(ResponseEvent responseEvent) {
            ++;
            if(<5) {
                try {
                    ..println("shootme: got an OK response! ");
                    ..println("Dialog State = " + .getState());
                    SipProvider provider = (SipProviderresponseEvent.getSource();
                    Request messageRequest = .createRequest(.);
                    CSeqHeader cseq = (CSeqHeader)messageRequest.getHeader(.);
                    // We will test if the CSEq validation is off by sending CSeq 1 again
                    cseq.setSeqNumber(1);
                    ClientTransaction ct = provider
                    .getNewClientTransaction(messageRequest);
                    .sendRequest(ct);
                } catch (Exception ex) {
                    ex.printStackTrace();
                }
            } else if ( == 5){
                try {
                    ..println("shootme: got an OK response! ");
                    ..println("Dialog State = " + .getState());
                    SipProvider provider = (SipProviderresponseEvent.getSource();
                    Request messageRequest = .createRequest(.);
                    ClientTransaction ct = provider
                    .getNewClientTransaction(messageRequest);
                    .sendRequest(ct);
                } catch (Exception ex) {
                    ex.printStackTrace();
                }
            }
            if(responseEvent.getResponse().getStatusCode() == 500) {
                fail("We received some error. It should not happen with loose dialog validation. We should not receive error on cseq out of order");
            }
        }
        int acks = 0;
        
Process the ACK request. Send the bye and complete the call flow.
        public void processAck(RequestEvent requestEvent,
                ServerTransaction serverTransaction) {
            ++;
            // We will wait for 5 acks to test if retransmissions are filtered. With loose dialog
            // validation the ACK retransmissions are not filtered by the stack.
            if( == 5)
            {
                try {
                    ..println("shootme: got an ACK! ");
                    ..println("Dialog State = " + .getState());
                    SipProvider provider = (SipProviderrequestEvent.getSource();
                    Request messageRequest = .createRequest(.);
                    CSeqHeader cseq = (CSeqHeader)messageRequest.getHeader(.);
                    // We will test if the CSEq validation is off by sending CSeq 1 again
                    ClientTransaction ct = provider
                    .getNewClientTransaction(messageRequest);
                    cseq.setSeqNumber(1);
                    ct.sendRequest();
                } catch (Exception ex) {
                    ex.printStackTrace();
                }
            }
        }
        int volume;
        int sentResponses;

        
Process the invite request.
        public void processInvite(RequestEvent requestEvent,
                ServerTransaction serverTransaction) {
        
            SipProvider sipProvider = (SipProviderrequestEvent.getSource();
  
            Request request = requestEvent.getRequest();
            try {
                serverTransaction = sipProvider.getNewServerTransaction(request);
                 = (DialogExtsipProvider.getNewDialog(serverTransaction);
                .disableSequenceNumberValidation();
            } catch (Exception e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            for(int q = 0; q<q++) {
            	 ++;
            	try {
            		Response okResponse = .createResponse(180,
            				request);
            		FromHeader from = (FromHeaderokResponse.getHeader(.);
            		from.removeParameter("tag");
            		Address address = .createAddress("Shootme <sip:"
            				+  + ":" +  + ">");
            		ContactHeader contactHeader = 
            		.createContactHeader(address);
            		ToHeader toHeader = (ToHeaderokResponse.getHeader(.);
            		toHeader.setTag("4321"); // Application is supposed to set.
            		FromHeader fromHeader = (FromHeader)okResponse.getHeader(.);
            		fromHeader.setTag("12345");
            		okResponse.addHeader(contactHeader);
            		serverTransaction.sendResponse(okResponse);
            	} catch (Exception ex) {
            		ex.printStackTrace();
            		//System.exit(0);
            	}
            	if(q%100==0) ..println("Send " + q);
            }
            try {
                Response okResponse = .createResponse(200,
                        request);
                FromHeader from = (FromHeaderokResponse.getHeader(.);
                from.removeParameter("tag");
                Address address = .createAddress("Shootme <sip:"
                        +  + ":" +  + ">");
                ContactHeader contactHeader = 
                        .createContactHeader(address);
                ToHeader toHeader = (ToHeaderokResponse.getHeader(.);
                toHeader.setTag("4321"); // Application is supposed to set.
                FromHeader fromHeader = (FromHeader)okResponse.getHeader(.);
                fromHeader.setTag("12345");
                okResponse.addHeader(contactHeader);
                serverTransaction.sendResponse(okResponse);
            } catch (Exception ex) {
                ex.printStackTrace();
                //System.exit(0);
            }
        }
        public void processTimeout(javax.sip.TimeoutEvent timeoutEvent) {
            Transaction transaction;
            if (timeoutEvent.isServerTransaction()) {
                transaction = timeoutEvent.getServerTransaction();
            } else {
                transaction = timeoutEvent.getClientTransaction();
            }
            ..println("state = " + transaction.getState());
            ..println("dialog = " + transaction.getDialog());
            ..println("dialogState = "
                    + transaction.getDialog().getState());
            ..println("Transaction Time out");
        }
        public void init(String transportint volume) {
        	this. = volume;
            SipFactory sipFactory = null;
             = null;
            sipFactory = SipFactory.getInstance();
            sipFactory.setPathName("gov.nist");
            Properties properties = new Properties();
            properties.setProperty("javax.sip.STACK_NAME""shootme");
            // You need 16 for logging traces. 32 for debug + traces.
            // Your code will limp at 32 but it is best for debugging.
            properties.setProperty("gov.nist.javax.sip.TRACE_LEVEL""32");
            properties.setProperty("gov.nist.javax.sip.DEBUG_LOG",
                    "shootmedebug.txt");
            properties.setProperty("gov.nist.javax.sip.SERVER_LOG",
                    "shootmelog.txt");
            properties.setProperty("gov.nist.javax.sip.AUTOMATIC_DIALOG_ERROR_HANDLING""false");
            properties.setProperty("javax.sip.AUTOMATIC_DIALOG_SUPPORT""off");
            try {
                // Create SipStack object
                 = sipFactory.createSipStack(properties);
                ..println("sipStack = " + );
            } catch (PeerUnavailableException e) {
                // could not find
                // gov.nist.jain.protocol.ip.sip.SipStackImpl
                // in the classpath
                e.printStackTrace();
                ..println(e.getMessage());
                if (e.getCause() != null)
                    e.getCause().printStackTrace();
                //System.exit(0);
            }
            try {
                 = sipFactory.createHeaderFactory();
                 = sipFactory.createAddressFactory();
                 = sipFactory.createMessageFactory();
                ListeningPoint lp = .createListeningPoint("127.0.0.1",
                        transport);
                Shootme listener = this;
                 = .createSipProvider(lp);
                ..println("udp provider " + );
                .addSipListener(listener);
            } catch (Exception ex) {
                ex.printStackTrace();
                fail("Unexpected exception");
            }
        }
        public void processIOException(IOExceptionEvent exceptionEvent) {
            fail("IOException");
        }
        public void processTransactionTerminated(
                TransactionTerminatedEvent transactionTerminatedEvent) {
            if (transactionTerminatedEvent.isServerTransaction())
                ..println("Transaction terminated event recieved"
                        + transactionTerminatedEvent.getServerTransaction());
            else
                ..println("Transaction terminated "
                        + transactionTerminatedEvent.getClientTransaction());
        }
        public void processDialogTerminated(
                DialogTerminatedEvent dialogTerminatedEvent) {
            Dialog d = dialogTerminatedEvent.getDialog();
            ..println("Local Party = " + d.getLocalParty());
        }
        public void terminate() {
            this..stop();
            this. = null;
        }
    }
    public class Shootist implements SipListener {
        private  SipProvider sipProvider;
        private AddressFactory addressFactory;
        private MessageFactory messageFactory;
        private  HeaderFactory headerFactory;
        private SipStack sipStack;
        private ContactHeader contactHeader;
        private ListeningPoint udpListeningPoint;
        private Dialog dialog;
        private boolean timeoutRecieved;
        boolean messageSeen = false;
        public int receivedResponses=0;
        public boolean inUse = false;
        public int sleep;
        public void processRequest(RequestEvent requestReceivedEvent) {
            Request request = requestReceivedEvent.getRequest();
            if(request.getMethod().equalsIgnoreCase("message")) {
                 = true;
            }
            try {
                Response response = .createResponse(200, request);
                requestReceivedEvent.getServerTransaction().sendResponse(response);
            } catch (Exception e) {
                e.printStackTrace();fail("Error");
            }
        }
        public void processResponse(ResponseEvent responseReceivedEvent) {
        	try {
        		if(!=false) {
        			fail("Concurrent responses should not happen");
        			throw new RuntimeException();
        		}
        		 = true;
        		if(%100==0) ..println("Receive " + );
        		if ( responseReceivedEvent.getResponse().getStatusCode() == 180) {
        			++;Thread.sleep();
        		}
        		if ( responseReceivedEvent.getResponse().getStatusCode() == .) {
        			Dialog d = responseReceivedEvent.getDialog();
        			try {
        				Request ack = d.createAck(1);
        				.sendRequest(ack);
        				.sendRequest(ack);
        				.sendRequest(ack);
        				.sendRequest(ack);
        				.sendRequest(ack);
        			} catch (Exception e) {
        				e.printStackTrace();
        				fail("Error sending ACK");
        			}
        		}
        	}catch(Exception e) {} finally {
        		 = false;
        	}
        }
        public void processTimeout(javax.sip.TimeoutEvent timeoutEvent) {
            ..println("Got a timeout " + timeoutEvent.getClientTransaction());
            this. = true;
        }
        public void init(String threadsString timeoutint sleepString transport) {
            SipFactory sipFactory = null;
            this. = sleep;
             = null;
            sipFactory = SipFactory.getInstance();
            sipFactory.setPathName("gov.nist");
            Properties properties = new Properties();
            // If you want to try TCP transport change the following to
            String peerHostPort = "127.0.0.1:5070";
           // properties.setProperty("javax.sip.OUTBOUND_PROXY", peerHostPort + "/"
           //         + transport);
            // If you want to use UDP then uncomment this.
            properties.setProperty("javax.sip.STACK_NAME""shootist");
            // The following properties are specific to nist-sip
            // and are not necessarily part of any other jain-sip
            // implementation.
            // You can set a max message size for tcp transport to
            // guard against denial of service attack.
            properties.setProperty("gov.nist.javax.sip.DEBUG_LOG",
                    "shootistdebug.txt");
            properties.setProperty("gov.nist.javax.sip.SERVER_LOG",
                    "shootistlog.txt");
            // Drop the client connection after we are done with the transaction.
//            properties.setProperty("gov.nist.javax.sip.CACHE_CLIENT_CONNECTIONS",
//                    "false");
            // Set to 0 (or NONE) in your production code for max speed.
            // You need 16 (or TRACE) for logging traces. 32 (or DEBUG) for debug + traces.
            // Your code will limp at 32 but it is best for debugging.
            properties.setProperty("gov.nist.javax.sip.TRACE_LEVEL""32");
            if(threads!=null) {
            	properties.setProperty("gov.nist.javax.sip.THREAD_POOL_SIZE"threads);
                properties.setProperty("gov.nist.javax.sip.TCP_POST_PARSING_THREAD_POOL_SIZE"threads);
            }
            properties.setProperty("gov.nist.javax.sip.CONGESTION_CONTROL_TIMEOUT"timeout);
            properties.setProperty("javax.sip.AUTOMATIC_DIALOG_SUPPORT""off");
            properties.setProperty("gov.nist.javax.sip.AUTOMATIC_DIALOG_ERROR_HANDLING","false");
            try {
                // Create SipStack object
                 = sipFactory.createSipStack(properties);
                ..println("createSipStack " + );
            } catch (PeerUnavailableException e) {
                // could not find
                // gov.nist.jain.protocol.ip.sip.SipStackImpl
                // in the classpath
                e.printStackTrace();
                ..println(e.getMessage());
                fail("Problem with setup");
            }
            try {
                 = sipFactory.createHeaderFactory();
                 = sipFactory.createAddressFactory();
                 = sipFactory.createMessageFactory();
                 = .createListeningPoint("127.0.0.1", 5060, transport);
                 = .createSipProvider();
                Shootist listener = this;
                .addSipListener(listener);
                String fromName = "BigGuy";
                String fromSipAddress = "here.com";
                String fromDisplayName = "The Master Blaster";
                String toSipAddress = "there.com";
                String toUser = "LittleGuy";
                String toDisplayName = "The Little Blister";
                // create >From Header
                SipURI fromAddress = .createSipURI(fromName,
                        fromSipAddress);
                Address fromNameAddress = .createAddress(fromAddress);
                fromNameAddress.setDisplayName(fromDisplayName);
                FromHeader fromHeader = .createFromHeader(
                        fromNameAddress"12345");
                // create To Header
                SipURI toAddress = 
                        .createSipURI(toUsertoSipAddress);
                Address toNameAddress = .createAddress(toAddress);
                toNameAddress.setDisplayName(toDisplayName);
                ToHeader toHeader = .createToHeader(toNameAddress,
                        null);
                // create Request URI
                SipURI requestURI = .createSipURI(toUser,
                        peerHostPort);
                // Create ViaHeaders
                ArrayList viaHeaders = new ArrayList();
                String ipAddress = .getIPAddress();
                ViaHeader viaHeader = .createViaHeader(ipAddress,
                        .getListeningPoint(transport).getPort(),
                        transportnull);
                // add via headers
                viaHeaders.add(viaHeader);
                // Create ContentTypeHeader
                ContentTypeHeader contentTypeHeader = 
                        .createContentTypeHeader("application""sdp");
                // Create a new CallId header
                CallIdHeader callIdHeader = .getNewCallId();
                // Create a new Cseq header
                CSeqHeader cSeqHeader = .createCSeqHeader(1L,
                        .);
                // Create a new MaxForwardsHeader
                MaxForwardsHeader maxForwards = 
                        .createMaxForwardsHeader(70);
                // Create the request.
                Request request = .createRequest(requestURI,
                        .callIdHeadercSeqHeaderfromHeader,
                        toHeaderviaHeadersmaxForwards);
                // Create contact headers
                String host = "127.0.0.1";
                SipURI contactUrl = .createSipURI(fromNamehost);
                contactUrl.setPort(.getPort());
                contactUrl.setLrParam();
                // Create the contact name address.
                SipURI contactURI = .createSipURI(fromNamehost);
                contactURI.setPort(.getListeningPoint(transport)
                        .getPort());
                Address contactAddress = .createAddress(contactURI);
                // Add the contact address.
                contactAddress.setDisplayName(fromName);
                 = .createContactHeader(contactAddress);
                request.addHeader();
                // You can add extension headers of your own making
                // to the outgoing SIP request.
                // Add the extension header.
                Header extensionHeader = .createHeader("My-Header",
                        "my header value");
                request.addHeader(extensionHeader);
                String sdpData = "v=0\r\n"
                        + "o=4855 13760799956958020 13760799956958020"
                        + " IN IP4  129.6.55.78\r\n" + "s=mysession session\r\n"
                        + "p=+46 8 52018010\r\n" + "c=IN IP4  129.6.55.78\r\n"
                        + "t=0 0\r\n" + "m=audio 6022 RTP/AVP 0 4 18\r\n"
                        + "a=rtpmap:0 PCMU/8000\r\n" + "a=rtpmap:4 G723/8000\r\n"
                        + "a=rtpmap:18 G729A/8000\r\n" + "a=ptime:20\r\n";
                byte[] contents = sdpData.getBytes();
                request.setContent(contentscontentTypeHeader);
                // You can add as many extension headers as you
                // want.
                extensionHeader = .createHeader("My-Other-Header",
                        "my new header value ");
                request.addHeader(extensionHeader);
                Header callInfoHeader = .createHeader("Call-Info",
                        "<http://www.antd.nist.gov>");
                request.addHeader(callInfoHeader);
                // Create the client transaction.
                ClientTransaction inviteTid = .getNewClientTransaction(request);
            	Dialog d = null;
				try {
					d = .getNewDialog(inviteTid);
catch (SipException e1) {
					// TODO Auto-generated catch block
				}
                // send the request out.
                inviteTid.sendRequest();
                 = inviteTid.getDialog();
            } catch (Exception ex) {
            	ex.printStackTrace();
                fail("cannot create or send initial invite");
            }
        }
        public void processIOException(IOExceptionEvent exceptionEvent) {
            ..println("IOException happened for "
                    + exceptionEvent.getHost() + " port = "
                    + exceptionEvent.getPort());
        }
        public void processTransactionTerminated(
                TransactionTerminatedEvent transactionTerminatedEvent) {
            ..println("Transaction terminated event recieved");
        }
        public void processDialogTerminated(
                DialogTerminatedEvent dialogTerminatedEvent) {
            ..println("dialogTerminatedEvent");
        }
        public void terminate() {
        	 = null;
            this..stop();
            this. = null;
        }
    }
    public void setUp() {
        this. = new Shootme();
        this. = new Shootist();
    }
    public void tearDown() {
        .terminate();
        .terminate();
    }
    public void testTCPZeroLostMessages() {
        this..init("tcp",1000);
        this..init("10""10000", 2, "tcp");
        try {
            Thread.sleep(10000);
        } catch (Exception ex) {
        }
        if(this..<=1) {
            fail("We excpeted more than 0" + this..);
        }
        if(this.. != 5) {
            fail("We expect 5 ACKs because retransmissions are not filtered in loose dialog validation.");
        }
    }
    
    
    public void testUDPHugeLoss() {
        this..init("udp",1000);
        this..init("10""10", 20, "udp");
        try {
            Thread.sleep(10000);
        } catch (Exception ex) {
        }
        if(this..<=1) {
            fail("We excpeted more than 0" + this..);
        }
       
    }
    
    public void testUDPIdle() {
        this..init("udp",1);
        this..init("10""10", 6000, "udp");
        try {
            Thread.sleep(10000);
        } catch (Exception ex) {
        }
        if(this.. < 5) {
            fail("We expect at least 5 ACKs because retransmissions are not filtered in loose dialog validation." + this..);
        }
    }
    
    public void testUDPNoThreadpool() {
        this..init("udp",100);
        this..init(null"1", 1, "udp");
        try {
            Thread.sleep(4000);
        } catch (Exception ex) {
        }
        if(this..<=1) {
            fail("We excpeted more than 0" + this..);
        }
        if(this.. != 5) {
            fail("We expect 5 ACKs because retransmissions are not filtered in loose dialog validation.");
        }
    }
    
    public void testTCPNoThreadpool() {
        this..init("tcp",1000);
        this..init(null"1", 1, "tcp");
        try {
            Thread.sleep(4000);
        } catch (Exception ex) {
        }
        if(this..<=1) {
            fail("We excpeted more than 0" + this..);
        }
        if(this.. != 5) {
            fail("We expect 5 ACKs because retransmissions are not filtered in loose dialog validation.");
        }
    }
    
    public void testTCPCongestionControlOff() {
        this..init("tcp",1000);
        this..init("10","0",1,"tcp");
        try {
            Thread.sleep(10000);
        } catch (Exception ex) {
        }
        if(this..<=1) {
            fail("We excpeted more than 0" + this..);
        }
        if(this.. != 5) {
            fail("We expect 5 ACKs because retransmissions are not filtered in loose dialog validation.");
        }
    }
    public void testTCPHugeLoss() {
        this..init("tcp",1000);
        this..init("10""10", 20, "tcp");
        try {
            Thread.sleep(10000);
        } catch (Exception ex) {
        }
        if(this..<=1) {
            fail("We excpeted more than 0" + this..);
        }
       
    }
New to GrepCode? Check out our FAQ X