Package gov.nist.javax.sip

Examples of gov.nist.javax.sip.SipProviderImpl

1171
1172
1173
1174
1175
1176
1177
1178
1179
1180
1181
1182
1183
1184
                  if (lastResponseStatusCode / 100 >= 2 && !this.isAckSeen) {
                      resendLastResponseAsBytes();
                    }
                } else {
                    // alert the application to retransmit the last response
                    SipProviderImpl sipProvider = (SipProviderImpl) this.getSipProvider();
                    TimeoutEvent txTimeout = new TimeoutEvent(sipProvider, this,
                            Timeout.RETRANSMIT);
                    sipProvider.handleEvent(txTimeout, this);
                }

            }
        } catch (IOException e) {
            if (sipStack.isLoggingEnabled())
View Full Code Here
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
        }

        @Override
        public void runTask() {
            SIPClientTransaction ct = SIPClientTransaction.this;
            SipProviderImpl provider = ct.getSipProvider();
    
            if (ct.getState() != TransactionState.TERMINATED ) {
                TimeoutEvent tte = new TimeoutEvent(SIPClientTransaction.this.getSipProvider(),
                        SIPClientTransaction.this, Timeout.TRANSACTION);
                provider.handleEvent(tte, ct);
            } else {
                if ( SIPClientTransaction.this.getSIPStack().getStackLogger().isLoggingEnabled(LogWriter.TRACE_DEBUG) ) {
                    SIPClientTransaction.this.getSIPStack().getStackLogger().logDebug("state = " + ct.getState());
                }
            }
View Full Code Here
1144
1145
1146
1147
1148
1149
1150
1151
1152
1153
1154
1155
1156
1157
                    // Retransmit last response until ack.
                    if (lastResponse.getStatusCode() / 100 > 2 && !this.isAckSeen)
                        super.sendMessage(lastResponse);
                } else {
                    // alert the application to retransmit the last response
                    SipProviderImpl sipProvider = (SipProviderImpl) this.getSipProvider();
                    TimeoutEvent txTimeout = new TimeoutEvent(sipProvider, this,
                            Timeout.RETRANSMIT);
                    sipProvider.handleEvent(txTimeout, this);
                }

            }
        } catch (IOException e) {
            if (sipStack.isLoggingEnabled())
View Full Code Here
1679
1680
1681
1682
1683
1684
1685
1686
1687
1688
1689
1690
1691
1692
1693
1694
1695
1696
1697
1698
1699
1700
1701
1702
1703
1704
1705
1706
1707
1708
1709
1710
1711
1712
1713
1714
1715
1716
1717
1718
1719
1720
1721
1722
1723
1724
1725
1726
      if (method.equalsIgnoreCase(Request.INVITE)) {
        this
            .removeFromMergeTable((SIPServerTransaction) sipTransaction);
      }
      // Send a notification to the listener.
      SipProviderImpl sipProvider = (SipProviderImpl) sipTransaction
          .getSipProvider();
      if (removed != null
          && sipTransaction.testAndSetTransactionTerminatedEvent()) {
        TransactionTerminatedEvent event = new TransactionTerminatedEvent(
            sipProvider, (ServerTransaction) sipTransaction);

        sipProvider.handleEvent(event, sipTransaction);

      }
    } else {

      String key = sipTransaction.getTransactionId();
      Object removed = clientTransactionTable.remove(key);

      if (stackLogger.isLoggingEnabled(LogWriter.TRACE_DEBUG)) {
        stackLogger.logDebug("REMOVED client tx " + removed + " KEY = "
            + key);
        if (removed != null) {
          SIPClientTransaction clientTx = (SIPClientTransaction) removed;
          if (clientTx.getMethod().equals(Request.INVITE)
              && this.maxForkTime != 0) {
            RemoveForkedTransactionTimerTask ttask = new RemoveForkedTransactionTimerTask(
                clientTx);
            this.timer.schedule(ttask, this.maxForkTime * 1000);
          }
        }
      }

      // Send a notification to the listener.
      if (removed != null
          && sipTransaction.testAndSetTransactionTerminatedEvent()) {
        SipProviderImpl sipProvider = (SipProviderImpl) sipTransaction
            .getSipProvider();
        TransactionTerminatedEvent event = new TransactionTerminatedEvent(
            sipProvider, (ClientTransaction) sipTransaction);

        sipProvider.handleEvent(event, sipTransaction);
      }
        ((SIPClientTransaction)sipTransaction).stopExpiresTimer();

    }
  }
View Full Code Here
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
    }

    @Override
    public void runTask() {
      SIPClientTransaction ct = SIPClientTransactionImpl.this;
      SipProviderImpl provider = ct.getSipProvider();

      if (ct.getState() != TransactionState.TERMINATED) {
        TimeoutEvent tte = new TimeoutEvent(provider, ct, Timeout.TRANSACTION);
        provider.handleEvent(tte, ct);
      } else {
        if (logger.isLoggingEnabled(LogWriter.TRACE_DEBUG)) {
          logger.logDebug("state = " + ct.getState());
        }
      }
View Full Code Here
1130
1131
1132
1133
1134
1135
1136
1137
1138
1139
1140
1141
1142
1143
                    if (lastResponseStatusCode / 100 >= 2 && !this.isAckSeen) {
                        resendLastResponseAsBytes();
                    }
                } else {
                    // alert the application to retransmit the last response
                    SipProviderImpl sipProvider = (SipProviderImpl) this.getSipProvider();
                    TimeoutEvent txTimeout = new TimeoutEvent(sipProvider, this,
                            Timeout.RETRANSMIT);
                    sipProvider.handleEvent(txTimeout, this);
                }

            }
        } catch (IOException e) {
            if (logger.isLoggingEnabled())
View Full Code Here
823
824
825
826
827
828
829
830
831
832
833
834
835
                        "~~~ Starting processing of KeepAliveTimeoutEvent( " + peerAddress.getHostAddress() + "," + peerPort + ")...");
            }
            close(true, true);
            if(sipStack instanceof SipStackImpl) {
              for (Iterator<SipProviderImpl> it = ((SipStackImpl)sipStack).getSipProviders(); it.hasNext();) {
                  SipProviderImpl nextProvider = (SipProviderImpl) it.next();
                  SipListener sipListener= nextProvider.getSipListener();
                  ListeningPoint[] listeningPoints = nextProvider.getListeningPoints();
                  for(ListeningPoint listeningPoint : listeningPoints) {
                  if(sipListener!= null && sipListener instanceof SipListenerExt
                      // making sure that we don't notify each listening point but only the one on which the timeout happened 
                      && listeningPoint.getIPAddress().equalsIgnoreCase(myAddress) && listeningPoint.getPort() == myPort &&
                        listeningPoint.getTransport().equalsIgnoreCase(getTransport())) {
View Full Code Here
1283
1284
1285
1286
1287
1288
1289
1290
1291
1292
1293
1294
1295
1296
1297
1298
1299
1300
1301
1302
1303
1304
1305
1306
1307
1308
1309
1310
1311
1312
1313
1314
1315
            this.removePendingTransaction((SIPServerTransaction) sipTransaction);
            if (this.isDialogCreated(method)) {
                this.removeFromMergeTable((SIPServerTransaction) sipTransaction);
            }
            // Send a notification to the listener.
            SipProviderImpl sipProvider = (SipProviderImpl) sipTransaction.getSipProvider();
            if (removed != null && sipTransaction.testAndSetTransactionTerminatedEvent()) {
                TransactionTerminatedEvent event = new TransactionTerminatedEvent(sipProvider,
                        (ServerTransaction) sipTransaction);

                sipProvider.handleEvent(event, sipTransaction);

            }
        } else {

            String key = sipTransaction.getTransactionId();
            Object removed = clientTransactionTable.remove(key);

            if (logWriter.isLoggingEnabled()) {
                logWriter.logDebug("REMOVED client tx " + removed + " KEY = " + key);
            }

            // Send a notification to the listener.
            if (removed != null && sipTransaction.testAndSetTransactionTerminatedEvent()) {
                SipProviderImpl sipProvider = (SipProviderImpl) sipTransaction.getSipProvider();
                TransactionTerminatedEvent event = new TransactionTerminatedEvent(sipProvider,
                        (ClientTransaction) sipTransaction);

                sipProvider.handleEvent(event, sipTransaction);
            }

        }
    }
View Full Code Here
1116
1117
1118
1119
1120
1121
1122
1123
1124
1125
1126
1127
1128
1129
                    // Retransmit last response until ack.
                    if (lastResponse.getStatusCode() / 100 > 2)
                        super.sendMessage(lastResponse);
                } else {
                    // alert the application to retransmit the last response
                    SipProviderImpl sipProvider = (SipProviderImpl) this.getSipProvider();
                    TimeoutEvent txTimeout = new TimeoutEvent(sipProvider, this,
                            Timeout.RETRANSMIT);
                    sipProvider.handleEvent(txTimeout, this);
                }

            }
        } catch (IOException e) {
            if (sipStack.isLoggingEnabled())
View Full Code Here
1272
1273
1274
1275
1276
1277
1278
1279
1280
1281
1282
1283
1284
1285
1286
1287
1288
1289
1290
1291
1292
1293
1294
1295
1296
1297
1298
1299
1300
1301
1302
1303
1304
            this.removePendingTransaction((SIPServerTransaction) sipTransaction);
            if (this.isDialogCreated(method)) {
                this.removeFromMergeTable((SIPServerTransaction) sipTransaction);
            }
            // Send a notification to the listener.
            SipProviderImpl sipProvider = (SipProviderImpl) sipTransaction.getSipProvider();
            if (removed != null && sipTransaction.testAndSetTransactionTerminatedEvent()) {
                TransactionTerminatedEvent event = new TransactionTerminatedEvent(sipProvider,
                        (ServerTransaction) sipTransaction);

                sipProvider.handleEvent(event, sipTransaction);

            }
        } else {

            String key = sipTransaction.getTransactionId();
            Object removed = clientTransactionTable.remove(key);

            if (logWriter.isLoggingEnabled()) {
                logWriter.logDebug("REMOVED client tx " + removed + " KEY = " + key);
            }

            // Send a notification to the listener.
            if (removed != null && sipTransaction.testAndSetTransactionTerminatedEvent()) {
                SipProviderImpl sipProvider = (SipProviderImpl) sipTransaction.getSipProvider();
                TransactionTerminatedEvent event = new TransactionTerminatedEvent(sipProvider,
                        (ClientTransaction) sipTransaction);

                sipProvider.handleEvent(event, sipTransaction);
            }

        }
    }
View Full Code Here
TOP

Related Classes of gov.nist.javax.sip.SipProviderImpl

  • gov.nist.javax.sip.DialogTimeoutEvent.Reason
  • gov.nist.javax.sip.header.CallID
  • gov.nist.javax.sip.header.Via
  • gov.nist.javax.sip.message.SIPRequest
  • gov.nist.javax.sip.message.SIPResponse
  • gov.nist.javax.sip.stack.ConnectionOrientedMessageChannel$KeepAliveTimeoutTimerTask
  • gov.nist.javax.sip.stack.HopImpl
  • gov.nist.javax.sip.stack.MessageChannel
  • gov.nist.javax.sip.stack.SIPClientTransaction
  • gov.nist.javax.sip.stack.SIPClientTransaction$ExpiresTimerTask
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.