aboutsummaryrefslogtreecommitdiffstats
path: root/channels/h323
diff options
context:
space:
mode:
authorjeremy <jeremy@f38db490-d61c-443f-a65b-d21fe96a405b>2004-03-20 14:29:36 +0000
committerjeremy <jeremy@f38db490-d61c-443f-a65b-d21fe96a405b>2004-03-20 14:29:36 +0000
commit1f645b070dd2035d064c50301a2ab37e878ffbd1 (patch)
tree6bd50038e94db958bdaa564dfb76c2f0a85bf4ea /channels/h323
parented4fdcadf544009437adbacb95efce1d141bffc1 (diff)
re-apply possible CCM fix. Someone still needs to test this
git-svn-id: http://svn.digium.com/svn/asterisk/trunk@2500 f38db490-d61c-443f-a65b-d21fe96a405b
Diffstat (limited to 'channels/h323')
-rwxr-xr-xchannels/h323/ast_h323.cpp61
-rwxr-xr-xchannels/h323/ast_h323.h21
2 files changed, 78 insertions, 4 deletions
diff --git a/channels/h323/ast_h323.cpp b/channels/h323/ast_h323.cpp
index 44e816350..ffb585539 100755
--- a/channels/h323/ast_h323.cpp
+++ b/channels/h323/ast_h323.cpp
@@ -687,7 +687,7 @@ H323Channel * MyH323Connection::CreateRealTimeLogicalChannel(const H323Capabilit
cout << " -- SessionID: " << sessionID << endl;
cout << " -- Direction: " << dir << endl;
}
- return new H323_ExternalRTPChannel(*this, capability, dir, sessionID, externalIpAddress, externalPort);
+ return new MyH323_ExternalRTPChannel(*this, capability, dir, sessionID, externalIpAddress, externalPort);
}
/** This callback function is invoked once upon creation of each
@@ -720,6 +720,63 @@ BOOL MyH323Connection::OnStartLogicalChannel(H323Channel & channel)
return TRUE;
}
+/* MyH323_ExternalRTPChannel */
+MyH323_ExternalRTPChannel::MyH323_ExternalRTPChannel(MyH323Connection & connection,
+ const H323Capability & capability,
+ Directions direction,
+ unsigned sessionID,
+ const PIPSocket::Address & ip,
+ WORD dataPort)
+ : H323_ExternalRTPChannel(connection, capability, direction, sessionID, ip, dataPort)
+{
+ if (h323debug) {
+ cout << " == New H.323 ExternalRTPChannel created." << endl;
+ }
+ return;
+}
+
+MyH323_ExternalRTPChannel::~MyH323_ExternalRTPChannel()
+{
+ if (h323debug) {
+ cout << " == H.323 ExternalRTPChannel deleted." << endl;
+ }
+ return;
+}
+
+BOOL MyH323_ExternalRTPChannel::OnReceivedPDU(
+ const H245_H2250LogicalChannelParameters & param,
+ unsigned & errorCode)
+{
+ if (h323debug) {
+ cout << " MyH323_ExternalRTPChannel::OnReceivedPDU " << endl;
+ }
+ return H323_ExternalRTPChannel::OnReceivedPDU( param, errorCode );
+}
+
+BOOL MyH323_ExternalRTPChannel::OnReceivedAckPDU(
+ const H245_H2250LogicalChannelAckParameters & param)
+{
+
+ PIPSocket::Address remoteIpAddress; // IP Address of remote endpoint
+ WORD remotePort; // remote endpoint Data port (control is dataPort+1)
+
+ if (h323debug) {
+ cout << " MyH323_ExternalRTPChannel::OnReceivedAckPDU " << endl;
+ }
+
+ if (H323_ExternalRTPChannel::OnReceivedAckPDU( param )) {
+ GetRemoteAddress(remoteIpAddress, remotePort);
+ if (h323debug) {
+ cout << " -- remoteIpAddress: " << remoteIpAddress << endl;
+ cout << " -- remotePort: " << remotePort << endl;
+ }
+ /* Notify Asterisk of remote RTP information */
+ on_start_logical_channel(connection.GetCallReference(), (const char *)remoteIpAddress.AsString(), remotePort);
+ return TRUE;
+ }
+ return FALSE;
+}
+
/** IMPLEMENTATION OF C FUNCTIONS */
@@ -1097,5 +1154,3 @@ void h323_native_bridge(const char *token, char *them, char *capability)
} /* extern "C" */
-
-
diff --git a/channels/h323/ast_h323.h b/channels/h323/ast_h323.h
index e079d960e..91ebab0ae 100755
--- a/channels/h323/ast_h323.h
+++ b/channels/h323/ast_h323.h
@@ -253,6 +253,26 @@ class MyH323Connection : public H323Connection {
BOOL bridging; // Used to help determine which IP to use
};
+class MyH323_ExternalRTPChannel : public H323_ExternalRTPChannel {
+
+ PCLASSINFO(MyH323_ExternalRTPChannel, H323_ExternalRTPChannel);
+
+ public:
+
+ MyH323_ExternalRTPChannel(MyH323Connection &, const H323Capability &, Directions,
+ unsigned, const PIPSocket::Address &, WORD);
+
+ ~MyH323_ExternalRTPChannel();
+
+ BOOL OnReceivedPDU(
+ const H245_H2250LogicalChannelParameters & param, /// Acknowledgement PDU
+ unsigned & errorCode /// Error on failure
+ );
+
+ BOOL OnReceivedAckPDU(const H245_H2250LogicalChannelAckParameters & param);
+
+};
+
/**
* The MyProcess is a necessary descendant PProcess class so that the H323EndPoint
* objected to be created from within that class. (Who owns main() problem).
@@ -269,4 +289,3 @@ class MyProcess : public PProcess {
};
-