- Sofaswitch-svn - FreeSWITCH Mailing Lists

[commit] r393 - sofaswitch/trunk/voip
by SofaSWITCH SVN 07 Aug '07

07 Aug '07

Author: derek Date: Mon Aug 6 21:03:57 2007 New Revision: 393 Modified: sofaswitch/trunk/voip/jocall.cxx sofaswitch/trunk/voip/jocall.h sofaswitch/trunk/voip/mymanager.cxx sofaswitch/trunk/voip/supervisor.cxx sofaswitch/trunk/voip/supervisor.h sofaswitch/trunk/voip/udpconnection.cxx sofaswitch/trunk/voip/udpconnection.h Log: Get h323 voice calls to mirror back. We make a h.323 call to ourselves, which we then detect coming back to us... Good.. Modified: sofaswitch/trunk/voip/jocall.cxx ============================================================================== --- sofaswitch/trunk/voip/jocall.cxx (original) +++ sofaswitch/trunk/voip/jocall.cxx Mon Aug 6 21:03:57 2007 @@ -158,6 +158,11 @@ OpalCall::OnReleased(connection); } +void MyOpalCall::SendThisMessageTo(const PString & message, const PString & destination) +{ + comms.SendThisMessageTo(message, destination); +} + void MyOpalCall::OnCleared() { PTRACE(2, "on cleared of this call " << myToken); @@ -176,7 +181,13 @@ void MyOpalCall::IncomingCall(const PString &remoteNode) { PTRACE(3, "Jocal - incoming call to query the remote controller on "); +} + +void MyOpalCall::QueryAcceptIncomingCall(const PString & remoteController, const PString &remoteParty) +{ + PString message = PString("QueryAcceptIncoming ") + remoteParty; + SendThisMessageTo(message, remoteController); } void MyOpalCall::AcceptThisCall(BOOL doAccept) Modified: sofaswitch/trunk/voip/jocall.h ============================================================================== --- sofaswitch/trunk/voip/jocall.h (original) +++ sofaswitch/trunk/voip/jocall.h Mon Aug 6 21:03:57 2007 @@ -134,6 +134,11 @@ void SendThisDtmf(const PString & userInput ///DTMF to send ); + /**This OpalCall descendant is controlled by some remote controller. In + this method, this descendant can send a message to that remote + controller about something */ + void SendThisMessageTo(const PString & message, const PString & destination); + /**Make the OpalConnections in this call accept/reject this incoming call. This will move the status of the incoming call to connecting/releasing @@ -161,6 +166,10 @@ /**Report the ID (as used by sofaswitch) of this comms instance. */ PString GetOurId() { return comms.GetOurId(); } + /**Send a message to the remote controller about an incoming call - and ask + for permission to answer it */ + void QueryAcceptIncomingCall(const PString & remoteController, const PString &remoteParty); + protected: /**Link to our controll manager */ Modified: sofaswitch/trunk/voip/mymanager.cxx ============================================================================== --- sofaswitch/trunk/voip/mymanager.cxx (original) +++ sofaswitch/trunk/voip/mymanager.cxx Mon Aug 6 21:03:57 2007 @@ -75,6 +75,7 @@ #include "mymanager.h" #include "supervisor.h" #include "udpep.h" +#include "udpconnection.h" #define new PNEW /////////////////////////////////////////////////////////////// @@ -443,11 +444,19 @@ OpalConnection::StringOptions * stringOptions ) { + PTRACE(3, "Manager\tOnIncomingConnection from " << connection); + if (connection.GetRemotePartyName().Find("udp Sound") != P_MAX_INDEX) return OpalManager::OnIncomingConnection(connection, options, stringOptions); - PString message = PString("QueryAcceptIncoming ") + connection.GetRemotePartyName(); - supervisor.SendThisMessageTo(message, GetControllerId()); + /*We, the manager, have an incoming call. It has to be queried back to the + remote controller, from the node handling the call itself. We do not want + to be responsible for handling setup/teardown of each call The remote + controller will send the answer to the newly created connection, who will + answer it. It is none of the supervisor's business the managing of answer + call yes/no. */ + + ((MyOpalCall &)connection.GetCall()).QueryAcceptIncomingCall(GetControllerId(), connection.GetRemotePartyName()); return OpalManager::OnIncomingConnection(connection, options, stringOptions); } Modified: sofaswitch/trunk/voip/supervisor.cxx ============================================================================== --- sofaswitch/trunk/voip/supervisor.cxx (original) +++ sofaswitch/trunk/voip/supervisor.cxx Mon Aug 6 21:03:57 2007 @@ -67,6 +67,16 @@ PTRACE(3, "Supervisor thread has ended"); } +void Supervisor::ProcessAnswer(PStringArray &cmds, PString & sender) +{ + PAssertAlways("Supervisor should not attempt to answer a call"); +} + +void Supervisor::ProcessTransferUdp(PStringArray &cmds, PString & sender) +{ + PAssertAlways("Supervisor should not attempt to transfer a call"); +} + void Supervisor::ProcessCallNode(PStringArray & cmds, PString & sender) { PTRACE(3, "Supervisor:: we can start a call to " << sender); @@ -115,7 +125,7 @@ void Supervisor::ProcessHangup(PStringArray &cmds, PString & sender) { - SendThisMessageTo(cmds[0] + PString(" is not handled by the supervisor - send it to the relevant call "), sender); + PAssertAlways("Supervisor should not process a Hangup message"); } Modified: sofaswitch/trunk/voip/supervisor.h ============================================================================== --- sofaswitch/trunk/voip/supervisor.h (original) +++ sofaswitch/trunk/voip/supervisor.h Mon Aug 6 21:03:57 2007 @@ -70,6 +70,10 @@ /**we have received a Call other Node command, so do it and reply accordingly*/ virtual void ProcessCallNode(PStringArray & cmds, PString & sender); + /**This method is overridden as an error handler. The supervisor should never + receive this message */ + void ProcessTransferUdp(PStringArray &cmds, PString & sender); + /**we have received a query status command, so do it and reply accordingly*/ virtual void ProcessStatusQuery(PStringArray &cmds, PString & sender); @@ -90,7 +94,7 @@ virtual void ProcessRequestNewId(PStringArray &cmds, PString & sender); /**Placed here - the child class has this method as pure virtual... */ - virtual void ProcessAnswer(PStringArray &cmds, PString & sender) { } + virtual void ProcessAnswer(PStringArray &cmds, PString & sender); /**Some MessageFrame instances do not have the permission to quit now. This virtual method determines if this instance is permitted to Modified: sofaswitch/trunk/voip/udpconnection.cxx ============================================================================== --- sofaswitch/trunk/voip/udpconnection.cxx (original) +++ sofaswitch/trunk/voip/udpconnection.cxx Mon Aug 6 21:03:57 2007 @@ -223,6 +223,23 @@ OpalConnection::Release(reason); } +void OpalUdpSsConnection::SendThisMessageTo(const PString & message, const PString & destination) +{ + ((MyOpalCall &)GetCall()).SendThisMessageTo(message, destination); +} + +void OpalUdpSsConnection::QueryAcceptIncomingCall(const PString & destination) +{ + PSafePtr<OpalConnection> otherConn = ownerCall.GetOtherPartyConnection(*this); + if (otherConn == NULL) { + PTRACE(3, "SETUP\t Cannot query on accept incoming call. Probably because we are making a call."); + return; + } + + PString message = PString("QueryAcceptIncoming ") + otherConn->GetRemotePartyName(); + + ((MyOpalCall &)GetCall()).SendThisMessageTo(message, destination); +} PSoundChannel * OpalUdpSsConnection::CreateSoundChannel(BOOL isSource) { Modified: sofaswitch/trunk/voip/udpconnection.h ============================================================================== --- sofaswitch/trunk/voip/udpconnection.h (original) +++ sofaswitch/trunk/voip/udpconnection.h Mon Aug 6 21:03:57 2007 @@ -194,6 +194,15 @@ CallEndReason reason = EndedByLocalUser ///< Reason for call release ); + /**This connection is controlled by some remote controller. This + connection has to send a message to that remote controller about + something */ + void SendThisMessageTo(const PString & message, const PString & destination); + + /**There is an incoming call, which has created this udp connection. The incoming + call is coming in on a sip/iax2/h.323 connection. We have to send a message to the + remote controller, which is done through the MyOpalCall structure */ + void QueryAcceptIncomingCall(const PString & destination); //@}

1 0

[commit] r392 - in sofaswitch/trunk/sofa: include/sofa src
by SofaSWITCH SVN 06 Aug '07

06 Aug '07

Author: derek Date: Mon Aug 6 01:10:17 2007 New Revision: 392 Modified: sofaswitch/trunk/sofa/include/sofa/messages.h sofaswitch/trunk/sofa/include/sofa/messlist.h sofaswitch/trunk/sofa/src/messages.cxx sofaswitch/trunk/sofa/src/messlist.cxx Log: Make the ProcessAnswer method virtual. Fix follow on things. Modified: sofaswitch/trunk/sofa/include/sofa/messages.h ============================================================================== --- sofaswitch/trunk/sofa/include/sofa/messages.h (original) +++ sofaswitch/trunk/sofa/include/sofa/messages.h Mon Aug 6 01:10:17 2007 @@ -185,7 +185,7 @@ /**we have received a command advising us how to answer to the incoming call, so we act as required and reply accordingly*/ - virtual void ProcessAnswer(PStringArray &cmds, PString & sender); + virtual void ProcessAnswer(PStringArray &cmds, PString & sender) = 0; /**we have received a command advising us that we are to install udp comms with a particular remote node id. Now, we have to reply Modified: sofaswitch/trunk/sofa/include/sofa/messlist.h ============================================================================== --- sofaswitch/trunk/sofa/include/sofa/messlist.h (original) +++ sofaswitch/trunk/sofa/include/sofa/messlist.h Mon Aug 6 01:10:17 2007 @@ -172,8 +172,11 @@ /**Do the work of actually building a new MessageFrame. This method will be overridden, to create descendants of MessageFrames, and - store them in this list. */ - virtual MessageFrame *BuildMessageFrame(); + store them in this list. + + This method is pure virtual. We DEMAND that the user provides their own + interpretation of this method.*/ + virtual MessageFrame *BuildMessageFrame() = 0; #ifdef DOC_PLUS_PLUS /**The thread, which runs to create new and ready to go instances, runs in here */ Modified: sofaswitch/trunk/sofa/src/messages.cxx ============================================================================== --- sofaswitch/trunk/sofa/src/messages.cxx (original) +++ sofaswitch/trunk/sofa/src/messages.cxx Mon Aug 6 01:10:17 2007 @@ -680,12 +680,13 @@ SendThisMessageTo(PString("Command ") + cmds[0] + PString(" not handled"), sender); } +/* void MessageFrame::ProcessAnswer(PStringArray &cmds, PString & sender) { PTRACE(3, "Messages\tCommand::ProcessAnswer(PStringArray &cmds, PString & sender) Is not overridden. It should be\n"); SendThisMessageTo(PString("Command ") + cmds[0] + PString(" not handled"), sender); } - +*/ void MessageFrame::ProcessTransferUdp(PStringArray &cmds, PString & sender) { Modified: sofaswitch/trunk/sofa/src/messlist.cxx ============================================================================== --- sofaswitch/trunk/sofa/src/messlist.cxx (original) +++ sofaswitch/trunk/sofa/src/messlist.cxx Mon Aug 6 01:10:17 2007 @@ -119,6 +119,7 @@ return NULL; } + MessageFrame *MessageFrameList::GetTheNextMessageFrame() { PWaitAndSignal m(mutex); @@ -257,6 +258,8 @@ return NULL; } +/* + MessageFrame *MessageFrameListProvider::BuildMessageFrame() { PTRACE(3, "Build a mesasge frame "); @@ -266,6 +269,9 @@ mf->WaitUntilInitialised(); return mf; } +*/ + + ///////////////////////////////////////////////////////////////////////////// MessageFrameListPending::MessageFrameListPending() {

1 0

[commit] r391 - sofaswitch/trunk/voip
by SofaSWITCH SVN 06 Aug '07

06 Aug '07

Author: derek Date: Mon Aug 6 01:04:35 2007 New Revision: 391 Modified: sofaswitch/trunk/voip/supervisor.h Log: Add method, so it compiles correctly. Modified: sofaswitch/trunk/voip/supervisor.h ============================================================================== --- sofaswitch/trunk/voip/supervisor.h (original) +++ sofaswitch/trunk/voip/supervisor.h Mon Aug 6 01:04:35 2007 @@ -88,7 +88,9 @@ communications nodes, that will be controlled only by the remote node */ virtual void ProcessRequestNewId(PStringArray &cmds, PString & sender); - + + /**Placed here - the child class has this method as pure virtual... */ + virtual void ProcessAnswer(PStringArray &cmds, PString & sender) { } /**Some MessageFrame instances do not have the permission to quit now. This virtual method determines if this instance is permitted to

1 0

[commit] r390 - in sofaswitch/trunk: callflow/src callflow/tests overview sofa/src voip
by SofaSWITCH SVN 06 Aug '07

06 Aug '07

Author: derek Date: Mon Aug 6 00:21:14 2007 New Revision: 390 Modified: sofaswitch/trunk/callflow/src/python.cpp sofaswitch/trunk/callflow/tests/makevoipcall.src sofaswitch/trunk/callflow/tests/mirrorvoip.src sofaswitch/trunk/overview/chap2.sgml sofaswitch/trunk/sofa/src/messages.cxx sofaswitch/trunk/voip/jocall.h sofaswitch/trunk/voip/mymanager.cxx sofaswitch/trunk/voip/mymanager.h sofaswitch/trunk/voip/udpconnection.cxx sofaswitch/trunk/voip/udpconnection.h sofaswitch/trunk/voip/udpep.cxx sofaswitch/trunk/voip/udpep.h Log: Tidy ups. Work on making udp channel/ep consistant with opal. Tidy up python icon look. fix typos in docs. Modified: sofaswitch/trunk/callflow/src/python.cpp ============================================================================== --- sofaswitch/trunk/callflow/src/python.cpp (original) +++ sofaswitch/trunk/callflow/src/python.cpp Mon Aug 6 00:21:14 2007 @@ -39,17 +39,17 @@ dc.SetPen(*wxBLACK_PEN); wxPoint p1(m_rect.GetPosition()); - wxPoint pA(p1.x + 16, p1.y + 12); + wxPoint pA(p1.x + 16, p1.y + 13); wxPoint pB(p1.x + 16, p1.y + 0); wxPoint pC(p1.x + 16, p1.y + 60); - wxPoint pD(p1.x + 16, p1.y + 46); + wxPoint pD(p1.x + 16, p1.y + 43); DrawArrow(dc, pB, ArrowDown, InputPointConnected(0) ? Connected : Loose); DrawArrow(dc, pC, ArrowDown, OutputPointConnected(0) ? Connected : Loose); dc.DrawLine(pA, pB); dc.DrawLine(pD, pC); - dc.DrawBitmap(Python_xpm, p1.x, p1.y + 16, true); + dc.DrawBitmap(Python_xpm, p1.x, p1.y + 13, true); DndShape::Draw(dc); } Modified: sofaswitch/trunk/callflow/tests/makevoipcall.src ============================================================================== --- sofaswitch/trunk/callflow/tests/makevoipcall.src (original) +++ sofaswitch/trunk/callflow/tests/makevoipcall.src Mon Aug 6 00:21:14 2007 @@ -1,3 +1,3 @@ -9271711271,711,316,711<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>229752 extra <special>Tool Tip<ms>Register for events from voip node<ms><special>Node to receive events from (Python code)<ms>"voip"<ms><special> <Shape>9165522165,522,165,598,251,601<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>9248502248,502,251,601<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>9206141206,141,272,141<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>1889 extra <special>Tool Tip<ms>Start Processing<ms><special> <Shape>7225646 extra <special>Tool Tip<ms>End Call<ms><special>Worker node to activate (python code)<ms>self.voipNode<ms><special> <Shape>20229740 extra <special>Tool Tip<ms>Death<ms><special> <Shape>20336305 extra <special>Tool Tip<ms>Death<ms><special> <Shape>2244139 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>2169538 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>14153429 extra <special>Tool Tip<ms>Wait for DTMF data<ms><special>Event sought (Python code)<ms><ms><special>Event sought (Regular Exp)<ms>DTMF<ms><special>Python variable: source of the event<ms>self.eventSource<ms><special>Python variable: name of the event<ms>self.eventName<ms><special>Python variable: generated data<ms>self.dtmfData<ms><special> <Shape>2211306 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>9166479166,479<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>9203451203,451,248,452<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>19168499 extra <special>Tool Tip<ms>Send Dtmf to the voip node<ms><special>Worker node to activate (python code)<ms>self.voipNode<ms><special>DTMF to send to worker node (python code)<ms>self.dtmfData<ms><special> <Shape>795148 extra <special>Tool Tip<ms>End Call<ms><special>Worker node for termination (Python code)<ms>self.soundNode<ms><special> <Shape>9166171166,171,166,281<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>2291710 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>5140472 extra <special>Tool Tip<ms>Test for dtmf data of "9"<ms><special>Test (Python code)<ms>self.dtmfData=="9"<ms><special> <Shape>14235452 extra <special>Tool Tip<ms>Wait for voip call to end<ms><special>Event sought (Python code)<ms><ms><special>Event sought (Regular Exp)<ms>Terminating<ms><special>Python variable: source of the event<ms>self.eventSource<ms><special>Python variable: name of the event<ms>self.eventName<ms><special>Python variable: generated data<ms>self.eventData<ms><special> <Shape>6141330 extra <special>Tool Tip<ms>Make Call to a remote entity<ms><special>Worker node to activate (python code)<ms>self.voipNode<ms><special>Call destination (python code)<ms>self.scriptArgs<ms><special> <Shape>118996 extra <special>Tool Tip<ms>Request Node<ms><special>Request node from (Python code)<ms>"voip"<ms><special>Timer period (seconds)<ms>1<ms><special>Info to send to remote node (Python code)<ms><ms><special>Python variable: generated data<ms>self.voipNode<ms><special> <Shape>9139116139,116,181,121<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>9120198120,198,120,253,359,253<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>99914699,146,101,269,166,281<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>2258468 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>5141281 extra <special>Tool Tip<ms>TEST: have a sound and voip node.<ms><special>Test (Python code)<ms>(self.voipNode != None) and (self.soundNode != None)<ms><special> <Shape>7163164 extra <special>Tool Tip<ms>End Call<ms><special>Worker node for termination (Python code)<ms>self.voipNode<ms><special> <Shape>12334253 extra <special>Tool Tip<ms>Timer<ms><special>Timer period (seconds, Python code)<ms>0.2<ms><special>Timer label (Python code)<ms>"expire timer"<ms><special> <Shape>12224689 extra <special>Tool Tip<ms>Timer which initates a shutdown, after some tidyup - messages etc have been sent.<ms><special>Timer period (seconds, Python code)<ms>1<ms><special>Timer label (Python code)<ms>"endeverything"<ms><special> <Shape>15141381 extra <special>Tool Tip<ms>Transfer Media between the voip and sound node<ms><special>First SofaSwitch worker (python)<ms>self.voipNode<ms><special>Second SofaSwitch worker (python)<ms>self.soundNode<ms><special> <Shape>15226601 extra <special>Tool Tip<ms>Make sound node -talk to noone<ms><special>First SofaSwitch worker (python)<ms>"sound"<ms><special>Second SofaSwitch worker (python)<ms>"noone"<ms><special> <Shape>9188214188,214,188,251,359,252<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>11156121 extra <special>Tool Tip<ms>Request Node<ms><special>Request node from (Python code)<ms>"sound"<ms><special>Timer period (seconds)<ms>1<ms><special>Info to send to remote node (Python code)<ms><ms><special>Python variable: generated data<ms>self.soundNode<ms><special> <Shape>9191306191,306,237,307<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>2360272 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape> +11156121 extra <special>Tool Tip<ms>Request Node<ms><special>Request node from (Python code)<ms>"sound"<ms><special>Timer period (seconds)<ms>1<ms><special>Info to send to remote node (Python code)<ms><ms><special>Python variable: generated data<ms>self.soundNode<ms><special> <Shape>19168499 extra <special>Tool Tip<ms>Send Dtmf to the voip node<ms><special>Worker node to activate (python code)<ms>self.voipNode<ms><special>DTMF to send to worker node (python code)<ms>self.dtmfData<ms><special> <Shape>5141281 extra <special>Tool Tip<ms>TEST: have a sound and voip node.<ms><special>Test (Python code)<ms>(self.voipNode != None) and (self.soundNode != None)<ms><special> <Shape>9166171166,171,166,281<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>2291710 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>9120198120,198,120,253,359,253<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>9166479166,479<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>9165522165,522,165,598,251,601<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>9188214188,214,188,251,359,252<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>9139116139,116,181,121<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>7225646 extra <special>Tool Tip<ms>End Call<ms><special>Worker node to activate (python code)<ms>self.voipNode<ms><special> <Shape>9191306191,306,237,307<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>15226601 extra <special>Tool Tip<ms>Make sound node +talk to noone<ms><special>First SofaSwitch worker (python)<ms>"sound"<ms><special>Second SofaSwitch worker (python)<ms>"noone"<ms><special> <Shape>795148 extra <special>Tool Tip<ms>End Call<ms><special>Worker node for termination (Python code)<ms>self.soundNode<ms><special> <Shape>9271711271,711,316,711<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>6141330 extra <special>Tool Tip<ms>Make Call to a remote entity<ms><special>Worker node to activate (python code)<ms>self.voipNode<ms><special>Call destination (python code)<ms>self.scriptArgs<ms><special> <Shape>14235452 extra <special>Tool Tip<ms>Wait for voip call to end<ms><special>Event sought (Python code)<ms><ms><special>Event sought (Regular Exp)<ms>Terminating<ms><special>Python variable: source of the event<ms>self.eventSource<ms><special>Python variable: name of the event<ms>self.eventName<ms><special>Python variable: generated data<ms>self.eventData<ms><special> <Shape>9248502248,502,251,601<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>2360272 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>9206141206,141,272,141<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>5140472 extra <special>Tool Tip<ms>Test for dtmf data of "9"<ms><special>Test (Python code)<ms>self.dtmfData=="9"<ms><special> <Shape>118996 extra <special>Tool Tip<ms>Request Node<ms><special>Request node from (Python code)<ms>"voip"<ms><special>Timer period (seconds)<ms>1<ms><special>Info to send to remote node (Python code)<ms><ms><special>Python variable: generated data<ms>self.voipNode<ms><special> <Shape>12224689 extra <special>Tool Tip<ms>Timer which initates a shutdown, after some tidyup + messages etc have been sent.<ms><special>Timer period (seconds, Python code)<ms>1<ms><special>Timer label (Python code)<ms>"endeverything"<ms><special> <Shape>15141381 extra <special>Tool Tip<ms>Transfer Media between the voip and sound node<ms><special>First SofaSwitch worker (python)<ms>self.voipNode<ms><special>Second SofaSwitch worker (python)<ms>self.soundNode<ms><special> <Shape>2211306 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>12334253 extra <special>Tool Tip<ms>Timer<ms><special>Timer period (seconds, Python code)<ms>0.2<ms><special>Timer label (Python code)<ms>"expire timer"<ms><special> <Shape>14153429 extra <special>Tool Tip<ms>Wait for DTMF data<ms><special>Event sought (Python code)<ms><ms><special>Event sought (Regular Exp)<ms>DTMF<ms><special>Python variable: source of the event<ms>self.eventSource<ms><special>Python variable: name of the event<ms>self.eventName<ms><special>Python variable: generated data<ms>self.dtmfData<ms><special> <Shape>20229740 extra <special>Tool Tip<ms>Death<ms><special> <Shape>2169538 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>18943 extra <special>Tool Tip<ms>Start Processing<ms><special> <Shape>2258468 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>99914699,146,101,269,166,281<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>7163164 extra <special>Tool Tip<ms>End Call<ms><special>Worker node for termination (Python code)<ms>self.voipNode<ms><special> <Shape>2244139 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>9203451203,451,248,452<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>20336305 extra <special>Tool Tip<ms>Death<ms><special> <Shape> Modified: sofaswitch/trunk/callflow/tests/mirrorvoip.src ============================================================================== --- sofaswitch/trunk/callflow/tests/mirrorvoip.src (original) +++ sofaswitch/trunk/callflow/tests/mirrorvoip.src Mon Aug 6 00:21:14 2007 @@ -1 +1 @@ -9311507358,507,311,526<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>2288572 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>22268100 extra <special>Tool Tip<ms>Register for events from voip<ms><special>Node to receive events from (Python code)<ms>"voip"<ms><special> <Shape>14347405 extra <special>Tool Tip<ms>Eventer<ms><special>Event sought (Python code)<ms><ms><special>Event sought (Regular Exp)<ms>Terminating<ms><special>Python variable: source of the event<ms>self.eventSource<ms><special>Python variable: name of the event<ms>self.eventName<ms><special>Python variable: generated data<ms>self.eventData<ms><special> <Shape>9319402319,402,363,402<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>22265291 extra <special>Tool Tip<ms>Register for events from voip2<ms><special>Node to receive events from (Python code)<ms>self.voipNode<ms><special> <Shape>125958 extra <special>Tool Tip<ms>Start Processing<ms><special> <Shape>10295523 extra <special>Tool Tip<ms>Python<ms><special>Python Code<ms>print " "<ms><special> <Shape>14269380 extra <special>Tool Tip<ms>Wait for hangup of the voip call<ms><special>Event sought (Python code)<ms><ms><special>Event sought (Regular Exp)<ms>Hangup<ms><special>Python variable: source of the event<ms>self.eventSource<ms><special>Python variable: name of the event<ms>self.eventName<ms><special>Python variable: generated data<ms>self.hangupdata<ms><special> <Shape>10267192 extra <special>Tool Tip<ms>report: incoming voip call<ms><special>Python Code<ms>print "have received an incoming voip call from ",self.remotePerson<ms><special> <Shape>2375425 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>9283483283,483,311,526<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>10342447 extra <special>Tool Tip<ms>Python<ms><special>Python Code<ms>print "Terminating-- the voip call has ended with ", self.remotePerson<ms><special> <Shape>23257247 extra <special>Tool tip<ms>Accept incoming voip call at sofa node<ms><special>SofaSwitch node to advise as to accepting the call (Python code)<ms>self.voipNode<ms><special>Answer call yes or no (Python code)<ms>"yes"<ms><special> <Shape>14271144 extra <special>Tool Tip<ms>Wait for an incoming voip call<ms><special>Event sought (Python code)<ms><ms><special>Event sought (Regular Exp)<ms>QueryAccept<ms><special>Python variable: source of the event<ms>self.voipNode<ms><special>Python variable: name of the event<ms>self.eventName<ms><special>Python variable: generated data<ms>self.remotePerson<ms><special> <Shape>2297162 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>15257333 extra <special>Tool Tip<ms>Transfer Media<ms><special>First SofaSwitch worker (python)<ms>self.voipNode<ms><special>Second SofaSwitch worker (python)<ms>self.voipNode<ms><special> <Shape>10267423 extra <special>Tool Tip<ms>Python<ms><special>Python Code<ms>print "HANGUP the voip call has ended with ", self.remotePerson<ms><special> <Shape> +2375425 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>125958 extra <special>Tool Tip<ms>Start Processing<ms><special> <Shape>14271144 extra <special>Tool Tip<ms>Wait for an incoming voip call<ms><special>Event sought (Python code)<ms><ms><special>Event sought (Regular Exp)<ms>QueryAccept<ms><special>Python variable: source of the event<ms>self.voipNode<ms><special>Python variable: name of the event<ms>self.eventName<ms><special>Python variable: generated data<ms>self.remotePerson<ms><special> <Shape>10295523 extra <special>Tool Tip<ms>Python<ms><special>Python Code<ms>print " "<ms><special> <Shape>9319402319,402,363,402<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>14269380 extra <special>Tool Tip<ms>Wait for hangup of the voip call<ms><special>Event sought (Python code)<ms><ms><special>Event sought (Regular Exp)<ms>Hangup<ms><special>Python variable: source of the event<ms>self.eventSource<ms><special>Python variable: name of the event<ms>self.eventName<ms><special>Python variable: generated data<ms>self.hangupdata<ms><special> <Shape>22265291 extra <special>Tool Tip<ms>Register for events from the node who is calling us.<ms><special>Node to receive events from (Python code)<ms>self.voipNode<ms><special> <Shape>10267192 extra <special>Tool Tip<ms>report: incoming voip call<ms><special>Python Code<ms>print "have received an incoming voip call from ",self.remotePerson<ms><special> <Shape>15257333 extra <special>Tool Tip<ms>Transfer Media<ms><special>First SofaSwitch worker (python)<ms>self.voipNode<ms><special>Second SofaSwitch worker (python)<ms>self.voipNode<ms><special> <Shape>10267423 extra <special>Tool Tip<ms>Python<ms><special>Python Code<ms>print "HANGUP the voip call has ended with ", self.remotePerson<ms><special> <Shape>9311507358,507,311,526<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>9283483283,483,311,526<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>23257247 extra <special>Tool tip<ms>Accept incoming voip call at sofa node<ms><special>SofaSwitch node to advise as to accepting the call (Python code)<ms>self.voipNode<ms><special>Answer call yes or no (Python code)<ms>"yes"<ms><special> <Shape>22268100 extra <special>Tool Tip<ms>Register for events from voip<ms><special>Node to receive events from (Python code)<ms>"voip"<ms><special> <Shape>2288572 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>14347405 extra <special>Tool Tip<ms>Wait for voip node to terminate<ms><special>Event sought (Python code)<ms><ms><special>Event sought (Regular Exp)<ms>Terminating<ms><special>Python variable: source of the event<ms>self.eventSource<ms><special>Python variable: name of the event<ms>self.eventName<ms><special>Python variable: generated data<ms>self.eventData<ms><special> <Shape>2297162 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>10342447 extra <special>Tool Tip<ms>Python<ms><special>Python Code<ms>print "Terminating-- the voip call has ended with ", self.remotePerson<ms><special> <Shape> Modified: sofaswitch/trunk/overview/chap2.sgml ============================================================================== --- sofaswitch/trunk/overview/chap2.sgml (original) +++ sofaswitch/trunk/overview/chap2.sgml Mon Aug 6 00:21:14 2007 @@ -87,7 +87,7 @@ </para></entry></row> <row><entry><para>Controller</para></entry> <entry><para> -is responsible for generating control mesasges to +is responsible for generating control messaes to get things to happen. It is this entity who initiates responses from the &sofaswitch; system as real world events happen. There may be multiple active Controllers - this is a Modified: sofaswitch/trunk/sofa/src/messages.cxx ============================================================================== --- sofaswitch/trunk/sofa/src/messages.cxx (original) +++ sofaswitch/trunk/sofa/src/messages.cxx Mon Aug 6 00:21:14 2007 @@ -682,7 +682,8 @@ void MessageFrame::ProcessAnswer(PStringArray &cmds, PString & sender) { - SendThisMessageTo(PString("Command ") + cmds[0] + PString(" not handled"), sender); + PTRACE(3, "Messages\tCommand::ProcessAnswer(PStringArray &cmds, PString & sender) Is not overridden. It should be\n"); + SendThisMessageTo(PString("Command ") + cmds[0] + PString(" not handled"), sender); } Modified: sofaswitch/trunk/voip/jocall.h ============================================================================== --- sofaswitch/trunk/voip/jocall.h (original) +++ sofaswitch/trunk/voip/jocall.h Mon Aug 6 00:21:14 2007 @@ -44,6 +44,28 @@ class MyManager; + +/** + This class describes the userdata passed to the Managers method for + setting up a call. We encapsulate the user data into this one class, and + can therefore pass it in to the OpalManager::SetUpCall method as a + pointer, and use the Opal methods for setting up a call. +*/ +class CallUserData : public PObject +{ + PCLASSINFO(CallUserData, PObject); + public: + /**The Sofa Switch identifying string to label the remote entity who asked + for this call to be setup. This string could be "c12" */ + PString remoteCont; + + /**This string describes the Sofa Switch label of the id assigned to this + call. It is used when we are processing an incoming call, and have to + join a Comms instance to a running call */ + PString preferredId; +}; + + /** A class the combines the OpalCall structure from OPAL with our protocol handling all messages. Modified: sofaswitch/trunk/voip/mymanager.cxx ============================================================================== --- sofaswitch/trunk/voip/mymanager.cxx (original) +++ sofaswitch/trunk/voip/mymanager.cxx Mon Aug 6 00:21:14 2007 @@ -443,9 +443,13 @@ OpalConnection::StringOptions * stringOptions ) { + if (connection.GetRemotePartyName().Find("udp Sound") != P_MAX_INDEX) + return OpalManager::OnIncomingConnection(connection, options, stringOptions); + PString message = PString("QueryAcceptIncoming ") + connection.GetRemotePartyName(); supervisor.SendThisMessageTo(message, GetControllerId()); - return TRUE; + + return OpalManager::OnIncomingConnection(connection, options, stringOptions); } void MyManager::AcceptThisCall(const PString & uniqueCallId, BOOL doAccept) @@ -637,7 +641,11 @@ if (!str.IsEmpty()) { PString localDev("udpss:*"); - SetUpCall(localDev, str, controllerIdString, preferredId); + PString callToken; + CallUserData uData; + uData.remoteCont = controllerIdString; + uData.preferredId = preferredId; + SetUpCall(localDev, str, callToken, &uData); } return; @@ -815,57 +823,6 @@ OpalManager::OnUserInputString(connection, value); } - -BOOL MyManager::SetUpCall(const PString & partyA, - const PString & partyB, - const PString & remoteController, - const PString & preferredId) -{ - PTRACE(3, "OpalMan\tSet up call from " << partyA - << " to " << partyB - << " by remote controller " << remoteController ); - - OpalCall * call = CreateCall(remoteController, preferredId); - if (call == NULL) { - PTRACE(1, "ERror, failed to setup a call"); - return FALSE; - } - - call->SetPartyB(partyB); - unsigned int options = 0; - int userData ; - OpalConnection::StringOptions stringOptions; - - OpalConnection *c1; - if (!MakeConnection(*call, partyA, &userData, options, &stringOptions)) { - PTRACE(3, "Manager\tFailed to make connection to " << partyA); - goto CallSetupFailed; - } - - c1 = call->GetConnection(0); - if (c1 == NULL) { - PTRACE(3, "SofaMan\t c1 is NULLLLLLL"); - goto CallSetupFailed; - } - - if (!c1->SetUpConnection()) { - PTRACE(3, "Manager\tFailed to setup connetion"); - goto CallSetupFailed; - } - - PTRACE(3, "SofaMan\tSetUpCall succeeded, call=" << *call); - return TRUE; - - - CallSetupFailed: - call->Clear(); - PStringStream msg; - msg << "FAILED to make a connection to connect " << partyA << " and " << partyB; - cerr << msg << endl; - PTRACE(1, msg); - return FALSE; -} - OpalCall * MyManager::CreateCall() { PTRACE(3, "Manager\tCreate a call with any CallID"); @@ -887,8 +844,16 @@ return frame; } -OpalCall * MyManager::CreateCall(const PString & remoteCont, const PString & preferredId) +OpalCall * MyManager::CreateCall(void * userData) { + PString remoteCont; + PString preferredId; + if (userData != NULL) { + CallUserData &uData = *((CallUserData *)userData); + remoteCont = uData.remoteCont; + preferredId = uData.preferredId; + } + PTRACE(3, "Manager\tCreate a call with a CallID of " << preferredId); Comms *c = NULL; if (!preferredId.IsEmpty()) { Modified: sofaswitch/trunk/voip/mymanager.h ============================================================================== --- sofaswitch/trunk/voip/mymanager.h (original) +++ sofaswitch/trunk/voip/mymanager.h Mon Aug 6 00:21:14 2007 @@ -150,27 +150,22 @@ /**Return the id of the remote controller */ PString GetControllerId(); - /**Set up a call between two parties. - This is used to initiate a call. Incoming calls are "answered" using a - different mechanism. - */ - virtual BOOL SetUpCall(const PString & partyA, /*!< The A party of call */ - const PString & partyB, /*!< The B party of call */ - const PString & remoteController, /*!<the controller who started this call */ - const PString & preferredId /*!<the id to assign to this call */ - ); - - /**Create a call object. - This function allows an application to have the system create - desccendants of the OpalCall class. This call will be controlled by an ID. + This method allows an application to have the system create + desccendants of the OpalCall class. + + This method is used to handle incoming voip calls. */ virtual OpalCall * CreateCall(); /**Same as CreateCall(), but assign a particular Comms structure, with a particular remoteController to this call. This routine - is used on creating outgoing calls. */ - virtual OpalCall * CreateCall(const PString & remoteController, const PString & preferredId); + is used when creating outgoing calls. + + The default behavious returns an instance of MyOpalCall. + */ + virtual OpalCall * CreateCall(void * userData ///< user data passed to SetUpCall + ); /**Destroy a call object. This gets called from background thread that garbage collects all calls Modified: sofaswitch/trunk/voip/udpconnection.cxx ============================================================================== --- sofaswitch/trunk/voip/udpconnection.cxx (original) +++ sofaswitch/trunk/voip/udpconnection.cxx Mon Aug 6 00:21:14 2007 @@ -88,52 +88,41 @@ DecOpalUdpSsConnection(); } -BOOL OpalUdpSsConnection::OnIncomingConnection(unsigned int options, - OpalConnection::StringOptions *stringOptions) -{ - PTRACE(3, "UdpSsConnection\t " << *this << " onIncoming connection"); - return endpoint.OnIncomingConnection(*this, options, stringOptions); -} - BOOL OpalUdpSsConnection::SetUpConnection() { - PSafePtr<OpalConnection> otherConn = ownerCall.GetOtherPartyConnection(*this); - - if (otherConn == NULL) { - PTRACE(3, "UdpSsConenction\t error - other party is NULL"); - PAssertAlways("Other Connection is NULL"); + // Check if we are A-Party in thsi call, so need to do things differently + if (ownerCall.GetConnection(0) == this) { + phase = SetUpPhase; + if (!OnIncomingConnection(0, NULL)) { + Release(EndedByCallerAbort); + return FALSE; } - remotePartyName = otherConn->GetRemotePartyName(); - remotePartyAddress = otherConn->GetRemotePartyAddress(); - PString remoteApplication = otherConn->GetRemoteApplication(); - - PTRACE(3, "UdpSs\tSetUpConnection, Remote party name " << remotePartyName << ')'); - PTRACE(3, "UdpSs\tSetUpConnection, Remote party address" << remotePartyAddress << ')'); - PTRACE(3, "UdpSs\tSetUpConnection, Remote application " << remoteApplication << ')'); - - // Check if we are A-Party in thsi call, so need to do things differently - if (ownerCall.GetConnection(0) == this) { - phase = SetUpPhase; - if (!OnIncomingConnection(0, NULL)) { - Release(EndedByCallerAbort); - return FALSE; - } - - PTRACE(2, "PCSS\tOutgoing call routed to " << ownerCall.GetPartyB() << " for " << *this); - if (!ownerCall.OnSetUp(*this)) { - Release(EndedByNoAccept); - return FALSE; - } - - PTRACE(3, "PCSS\tSetUpConnection(" << remotePartyName << ')'); - phase = AlertingPhase; - endpoint.OnShowIncoming(*this); - OnAlerting(); + PTRACE(3, "PCSS\tOutgoing call routed to " << ownerCall.GetPartyB() << " for " << *this); + if (!ownerCall.OnSetUp(*this)) { + Release(EndedByNoAccept); + return FALSE; } return TRUE; + } + + { + PSafePtr<OpalConnection> otherConn = ownerCall.GetOtherPartyConnection(*this); + if (otherConn == NULL) + return FALSE; + + remotePartyName = otherConn->GetRemotePartyName(); + remotePartyAddress = otherConn->GetRemotePartyAddress(); + remoteProductInfo = otherConn->GetRemoteProductInfo(); + } + + PTRACE(3, "PCSS\tSetUpConnection(" << remotePartyName << ')'); + phase = AlertingPhase; + OnAlerting(); + + return endpoint.OnShowIncoming(*this); } @@ -267,21 +256,6 @@ } -void OpalUdpSsConnection::InitiateCall() -{ - PTRACE(3, "Initiate call "); - phase = SetUpPhase; - - if (!OnIncomingConnection(0, NULL)) - Release(EndedByCallerAbort); - else { - PTRACE(2, "UdpSs\tOutgoing call routed to " << ownerCall.GetPartyB() << " for " << *this); - if (!ownerCall.OnSetUp(*this)) - Release(EndedByNoAccept); - } -} - - void OpalUdpSsConnection::AcceptIncoming() { if (!LockReadOnly()) Modified: sofaswitch/trunk/voip/udpconnection.h ============================================================================== --- sofaswitch/trunk/voip/udpconnection.h (original) +++ sofaswitch/trunk/voip/udpconnection.h Mon Aug 6 00:21:14 2007 @@ -71,11 +71,6 @@ /**@name Overrides from OpalConnection */ //@{ - /**Indicates this connection instance is about to join another connection - instance */ - virtual BOOL OnIncomingConnection(unsigned int, - OpalConnection::StringOptions*); - /**Start an outgoing connection. This function will initiate the connection to the remote entity, for example in H.323 it sends a SETUP, in SIP it sends an INVITE etc. @@ -177,10 +172,6 @@ /**@name New operations */ //@{ - /**Call is initiated as the A-Party. - */ - virtual void InitiateCall(); - /**Accept the incoming connection. */ virtual void AcceptIncoming(); Modified: sofaswitch/trunk/voip/udpep.cxx ============================================================================== --- sofaswitch/trunk/voip/udpep.cxx (original) +++ sofaswitch/trunk/voip/udpep.cxx Mon Aug 6 00:21:14 2007 @@ -78,7 +78,9 @@ BOOL OpalUdpSsEndPoint::MakeConnection(OpalCall & call, const PString & remoteParty, - void * userData) + void * userData, + unsigned int /*options*/, + OpalConnection::StringOptions * /*stringOptions*/) { // First strip of the prefix if present PINDEX prefixLength = 0; @@ -94,37 +96,10 @@ } connectionsActive.SetAt(conToken, connection); - - // If we are the A-party then need to initiate a call now in this thread and - // go through the routing engine via OnIncomingConnection. If we are the - // B-Party then SetUpConnection() gets called in the context of the A-party - // thread. - if (call.GetConnection(0) == connection) - connection->InitiateCall(); return TRUE; } - - - -BOOL OpalUdpSsEndPoint::MakeConnection(OpalCall & call, - const PString & remoteParty, - void * userData, - unsigned int /*options*/, - OpalConnection::StringOptions *stringOptions) -{ - return MakeConnection(call, remoteParty, userData); -} - -BOOL OpalUdpSsEndPoint::MakeConnection(OpalCall & call, - const PString & remoteParty, - void *userData, - unsigned int /*options*/) -{ - return MakeConnection(call, remoteParty, userData); -} - PString OpalUdpSsEndPoint::OnGetDestination(const OpalUdpSsConnection & /*connection*/) { @@ -168,11 +143,16 @@ } -void OpalUdpSsEndPoint::AcceptIncomingConnection(const PString & token) +BOOL OpalUdpSsEndPoint::AcceptIncomingConnection(const PString & token) { PSafePtr<OpalUdpSsConnection> connection = GetUdpSsConnectionWithLock(token, PSafeReadOnly); - if (connection != NULL) - connection->AcceptIncoming(); + if (connection == NULL) { + PTRACE(2, "OpalSsEp\tAcceptIncoming connection on " << token << "return false as connection not found"); + return FALSE; + } + + connection->AcceptIncoming(); + return TRUE; } @@ -189,25 +169,13 @@ return PSafePtrCast<OpalConnection, OpalUdpSsConnection>(GetConnectionWithLock(token, mode)); } - -void OpalUdpSsEndPoint::OnShowIncoming(const OpalUdpSsConnection & connection) -{ - PTRACE(3, "INCOMING CALL from remote node"); - incomingConnectionToken = connection.GetToken(); -} - - - -BOOL OpalUdpSsEndPoint::OnIncomingConnection(OpalConnection& conn, - unsigned int options, - OpalConnection::StringOptions *stringOptions) +BOOL OpalUdpSsEndPoint::OnShowIncoming(const OpalUdpSsConnection & connection) { - return TRUE; + PTRACE(3, "INCOMING CALL from remote node " << connection.GetToken()); + return TRUE; } - - BOOL OpalUdpSsEndPoint::OnShowOutgoing(const OpalUdpSsConnection & connection) { //PTime now; Modified: sofaswitch/trunk/voip/udpep.h ============================================================================== --- sofaswitch/trunk/voip/udpep.h (original) +++ sofaswitch/trunk/voip/udpep.h Mon Aug 6 00:21:14 2007 @@ -103,25 +103,10 @@ virtual BOOL MakeConnection( OpalCall & call, ///< Owner of connection const PString & party, ///< Remote party to call - void * userData = NULL ///< Arbitrary data to pass to connection + void * userData = NULL, ///< Arbitrary data to pass to connection + unsigned int options = 0,///< options to pass to conneciton + OpalConnection::StringOptions * stringOptions = NULL ); - virtual BOOL MakeConnection( - OpalCall & call, ///< Owner of connection - const PString & party, ///< Remote party to call - void * userData, ///< Arbitrary data to pass to connection - unsigned int options ///< options to pass to conneciton - ); - virtual BOOL MakeConnection( - OpalCall & call, ///< Owner of connection - const PString & party, ///< Remote party to call - void * userData, ///< Arbitrary data to pass to connection - unsigned int options, ///< options to pass to conneciton - OpalConnection::StringOptions * stringOptions - ); - - - - /**Get the data formats this endpoint is capable of operating. This provides a list of media data format names that may be used by an @@ -173,19 +158,16 @@ The default implementation is pure. */ - virtual void OnShowIncoming( + virtual BOOL OnShowIncoming( const OpalUdpSsConnection & connection /// Connection having event ); /**Accept the incoming connection. */ - virtual void AcceptIncomingConnection( + virtual BOOL AcceptIncomingConnection( const PString & connectionToken /// Token of connection to accept call ); - /**A connection is coming in - or being added to this endpoint */ - virtual BOOL OnIncomingConnection(OpalConnection&, unsigned int, - OpalConnection::StringOptions*); /**Call back to indicate that remote is ringing. If FALSE is returned the call is aborted.

1 0

[commit] r389 - sofaswitch/trunk/voip
by SofaSWITCH SVN 03 Aug '07

03 Aug '07

Author: derek Date: Fri Aug 3 00:41:32 2007 New Revision: 389 Modified: sofaswitch/trunk/voip/jocall.cxx sofaswitch/trunk/voip/mymanager.cxx sofaswitch/trunk/voip/udpconnection.cxx sofaswitch/trunk/voip/udpep.cxx Log: Fiddles - try to bring into line with Opal Requirements. Modified: sofaswitch/trunk/voip/jocall.cxx ============================================================================== --- sofaswitch/trunk/voip/jocall.cxx (original) +++ sofaswitch/trunk/voip/jocall.cxx Fri Aug 3 00:41:32 2007 @@ -118,13 +118,8 @@ } } } - PTRACE(3, "Final value of Call::OnSetUp is " << ok); - return ok; - - PTRACE(2, "OnSetup of connection. " << connection.GetToken()); - BOOL res = OpalCall::OnSetUp(connection); - PTRACE(2, "finished onsetup of connection/call and it gave " << res); - return res; + PTRACE(2, "finished onsetup of connection/call and it gave " << 1); + return TRUE; } BOOL MyOpalCall::OnAlerting(OpalConnection & connection) Modified: sofaswitch/trunk/voip/mymanager.cxx ============================================================================== --- sofaswitch/trunk/voip/mymanager.cxx (original) +++ sofaswitch/trunk/voip/mymanager.cxx Fri Aug 3 00:41:32 2007 @@ -832,10 +832,32 @@ } call->SetPartyB(partyB); + unsigned int options = 0; + int userData ; + OpalConnection::StringOptions stringOptions; + + OpalConnection *c1; + if (!MakeConnection(*call, partyA, &userData, options, &stringOptions)) { + PTRACE(3, "Manager\tFailed to make connection to " << partyA); + goto CallSetupFailed; + } + + c1 = call->GetConnection(0); + if (c1 == NULL) { + PTRACE(3, "SofaMan\t c1 is NULLLLLLL"); + goto CallSetupFailed; + } + + if (!c1->SetUpConnection()) { + PTRACE(3, "Manager\tFailed to setup connetion"); + goto CallSetupFailed; + } + + PTRACE(3, "SofaMan\tSetUpCall succeeded, call=" << *call); + return TRUE; + - if (MakeConnection(*call, partyA, NULL)) - return TRUE; - + CallSetupFailed: call->Clear(); PStringStream msg; msg << "FAILED to make a connection to connect " << partyA << " and " << partyB; Modified: sofaswitch/trunk/voip/udpconnection.cxx ============================================================================== --- sofaswitch/trunk/voip/udpconnection.cxx (original) +++ sofaswitch/trunk/voip/udpconnection.cxx Fri Aug 3 00:41:32 2007 @@ -98,47 +98,42 @@ BOOL OpalUdpSsConnection::SetUpConnection() { - remotePartyName = ownerCall.GetOtherPartyConnection(*this)->GetRemotePartyName(); - remotePartyAddress = ownerCall.GetOtherPartyConnection(*this)->GetRemotePartyAddress(); - PString remoteApplication = ownerCall.GetOtherPartyConnection(*this)->GetRemoteApplication(); + PSafePtr<OpalConnection> otherConn = ownerCall.GetOtherPartyConnection(*this); + + if (otherConn == NULL) { + PTRACE(3, "UdpSsConenction\t error - other party is NULL"); + PAssertAlways("Other Connection is NULL"); + } + + remotePartyName = otherConn->GetRemotePartyName(); + remotePartyAddress = otherConn->GetRemotePartyAddress(); + PString remoteApplication = otherConn->GetRemoteApplication(); PTRACE(3, "UdpSs\tSetUpConnection, Remote party name " << remotePartyName << ')'); PTRACE(3, "UdpSs\tSetUpConnection, Remote party address" << remotePartyAddress << ')'); PTRACE(3, "UdpSs\tSetUpConnection, Remote application " << remoteApplication << ')'); - - // Check if we are A-Party in thsi call, so need to do things differently - if (ownerCall.GetConnection(0) == this) { - phase = SetUpPhase; - if (!OnIncomingConnection(0, NULL)) { - Release(EndedByCallerAbort); - return FALSE; - } - - PTRACE(2, "PCSS\tOutgoing call routed to " << ownerCall.GetPartyB() << " for " << *this); - if (!ownerCall.OnSetUp(*this)) { - Release(EndedByNoAccept); - return FALSE; + + // Check if we are A-Party in thsi call, so need to do things differently + if (ownerCall.GetConnection(0) == this) { + phase = SetUpPhase; + if (!OnIncomingConnection(0, NULL)) { + Release(EndedByCallerAbort); + return FALSE; + } + + PTRACE(2, "PCSS\tOutgoing call routed to " << ownerCall.GetPartyB() << " for " << *this); + if (!ownerCall.OnSetUp(*this)) { + Release(EndedByNoAccept); + return FALSE; + } + + PTRACE(3, "PCSS\tSetUpConnection(" << remotePartyName << ')'); + phase = AlertingPhase; + endpoint.OnShowIncoming(*this); + OnAlerting(); } return TRUE; - } - - { - PSafePtr<OpalConnection> otherConn = ownerCall.GetOtherPartyConnection(*this); - if (otherConn == NULL) - return FALSE; - - remotePartyName = otherConn->GetRemotePartyName(); - remotePartyAddress = otherConn->GetRemotePartyAddress(); - remoteApplication = otherConn->GetRemoteApplication(); - } - - PTRACE(3, "PCSS\tSetUpConnection(" << remotePartyName << ')'); - phase = AlertingPhase; - endpoint.OnShowIncoming(*this); - OnAlerting(); - - return TRUE; } Modified: sofaswitch/trunk/voip/udpep.cxx ============================================================================== --- sofaswitch/trunk/voip/udpep.cxx (original) +++ sofaswitch/trunk/voip/udpep.cxx Fri Aug 3 00:41:32 2007 @@ -202,7 +202,7 @@ unsigned int options, OpalConnection::StringOptions *stringOptions) { - return manager.OnIncomingConnection(conn, options, stringOptions); + return TRUE; }

1 0

[commit] r388 - sofaswitch/trunk/voip
by SofaSWITCH SVN 03 Aug '07

03 Aug '07

Author: derek Date: Thu Aug 2 21:49:27 2007 New Revision: 388 Modified: sofaswitch/trunk/voip/mymanager.cxx sofaswitch/trunk/voip/udpep.cxx Log: Minor fixes to get it to compile. Modified: sofaswitch/trunk/voip/mymanager.cxx ============================================================================== --- sofaswitch/trunk/voip/mymanager.cxx (original) +++ sofaswitch/trunk/voip/mymanager.cxx Thu Aug 2 21:49:27 2007 @@ -1,5 +1,5 @@ /* - * mymanager.cxx + * mymanager.cxx * * The override of the OpalManager, which does the necessary comms with the remote conroller * Modified: sofaswitch/trunk/voip/udpep.cxx ============================================================================== --- sofaswitch/trunk/voip/udpep.cxx (original) +++ sofaswitch/trunk/voip/udpep.cxx Thu Aug 2 21:49:27 2007 @@ -194,11 +194,6 @@ { PTRACE(3, "INCOMING CALL from remote node"); incomingConnectionToken = connection.GetToken(); - - PTime now; - PString remoteParty = connection.GetRemotePartyName(); - - ((MyOpalCall &)connection.GetCall()).IncomingCall(remoteParty); }

1 0

[commit] r387 - sofaswitch/trunk/voip
by SofaSWITCH SVN 03 Aug '07

03 Aug '07

Author: derek Date: Thu Aug 2 21:24:33 2007 New Revision: 387 Modified: sofaswitch/trunk/voip/jocall.cxx sofaswitch/trunk/voip/mymanager.cxx sofaswitch/trunk/voip/mymanager.h Log: Work on getting the alerting right. Modified: sofaswitch/trunk/voip/jocall.cxx ============================================================================== --- sofaswitch/trunk/voip/jocall.cxx (original) +++ sofaswitch/trunk/voip/jocall.cxx Thu Aug 2 21:24:33 2007 @@ -181,8 +181,7 @@ void MyOpalCall::IncomingCall(const PString &remoteNode) { PTRACE(3, "Jocal - incoming call to query the remote controller on "); - comms.SendThisMessageTo(PString("QueryAcceptIncoming ") + remoteNode, - manager.GetControllerId()); + } void MyOpalCall::AcceptThisCall(BOOL doAccept) Modified: sofaswitch/trunk/voip/mymanager.cxx ============================================================================== --- sofaswitch/trunk/voip/mymanager.cxx (original) +++ sofaswitch/trunk/voip/mymanager.cxx Thu Aug 2 21:24:33 2007 @@ -437,6 +437,17 @@ } +BOOL MyManager::OnIncomingConnection( + OpalConnection & connection, ///< Connection that is calling + unsigned options, ///< options for new connection + OpalConnection::StringOptions * stringOptions + ) +{ + PString message = PString("QueryAcceptIncoming ") + connection.GetRemotePartyName(); + supervisor.SendThisMessageTo(message, GetControllerId()); + return TRUE; +} + void MyManager::AcceptThisCall(const PString & uniqueCallId, BOOL doAccept) { PTRACE(3, "Accept this call if we can find it " << uniqueCallId); Modified: sofaswitch/trunk/voip/mymanager.h ============================================================================== --- sofaswitch/trunk/voip/mymanager.h (original) +++ sofaswitch/trunk/voip/mymanager.h Thu Aug 2 21:24:33 2007 @@ -80,6 +80,20 @@ /**Where we sit, while waiting for commands & events */ void Main(PArgList & args); + /**Call back for answering an incoming call. + This function is used for an application to control the answering of + incoming calls. + + If TRUE is returned then the connection continues. If FALSE then the + connection is aborted. + + Note this function should not block for any length of time. + */ + virtual BOOL OnIncomingConnection( + OpalConnection & connection, ///< Connection that is calling + unsigned options, ///< options for new connection + OpalConnection::StringOptions * stringOptions + ); /**A call has been established, and now is running with media in both directions */ virtual void OnEstablishedCall(

1 0

[commit] r386 - sofaswitch/trunk/callflow/tests
by SofaSWITCH SVN 01 Aug '07

01 Aug '07

Author: derek Date: Wed Aug 1 19:30:10 2007 New Revision: 386 Added: sofaswitch/trunk/callflow/tests/mirrorvoip.src Modified: sofaswitch/trunk/callflow/tests/makevoipcall.src Log: Modify the Make voip call to not mirror sound to sound at the end of the call. Add the echo voip module, to answer an incoming voip call, and echo the received voice back to the sending node. Modified: sofaswitch/trunk/callflow/tests/makevoipcall.src ============================================================================== --- sofaswitch/trunk/callflow/tests/makevoipcall.src (original) +++ sofaswitch/trunk/callflow/tests/makevoipcall.src Wed Aug 1 19:30:10 2007 @@ -1,3 +1,3 @@ -15141381 extra <special>Tool Tip<ms>Transfer Media between the voip and sound node<ms><special>First SofaSwitch worker (python)<ms>self.voipNode<ms><special>Second SofaSwitch worker (python)<ms>self.soundNode<ms><special> <Shape>9120198120,198,120,253,359,253<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>118996 extra <special>Tool Tip<ms>Request Node<ms><special>Request node from (Python code)<ms>"voip"<ms><special>Timer period (seconds)<ms>1<ms><special>Info to send to remote node (Python code)<ms><ms><special>Python variable: generated data<ms>self.voipNode<ms><special> <Shape>6141330 extra <special>Tool Tip<ms>Make Call to a remote entity<ms><special>Worker node to activate (python code)<ms>self.voipNode<ms><special>Call destination (python code)<ms>self.scriptArgs<ms><special> <Shape>2360272 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>20336305 extra <special>Tool Tip<ms>Death<ms><special> <Shape>9248502248,502,251,601<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>9203451203,451,248,452<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>795148 extra <special>Tool Tip<ms>End Call<ms><special>Worker node for termination (Python code)<ms>self.soundNode<ms><special> <Shape>9188214188,214,188,251,359,252<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>2169538 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>9165522165,522,165,598,251,601<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>9166171166,171,166,281<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>229752 extra <special>Tool Tip<ms>Register for events from voip node<ms><special>Node to receive events from (Python code)<ms>"voip"<ms><special> <Shape>9206141206,141,272,141<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>12224689 extra <special>Tool Tip<ms>Timer which initates a shutdown, after some tidyup - messages etc have been sent.<ms><special>Timer period (seconds, Python code)<ms>1<ms><special>Timer label (Python code)<ms>"endeverything"<ms><special> <Shape>2244139 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>12334253 extra <special>Tool Tip<ms>Timer<ms><special>Timer period (seconds, Python code)<ms>2<ms><special>Timer label (Python code)<ms>self.myId + "thistimer"<ms><special>Python variable: Timer expire info<ms><ms><special> <Shape>1889 extra <special>Tool Tip<ms>Start Processing<ms><special> <Shape>9271711271,711,316,711<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>14153429 extra <special>Tool Tip<ms>Wait for DTMF data<ms><special>Event sought (Python code)<ms><ms><special>Event sought (Regular Exp)<ms>DTMF<ms><special>Python variable: source of the event<ms>self.eventSource<ms><special>Python variable: name of the event<ms>self.eventName<ms><special>Python variable: generated data<ms>self.dtmfData<ms><special> <Shape>7163164 extra <special>Tool Tip<ms>End Call<ms><special>Worker node for termination (Python code)<ms>self.voipNode<ms><special> <Shape>9166479166,479<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>9191306191,306,237,307<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>9139116139,116,181,121<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>2211306 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>11156121 extra <special>Tool Tip<ms>Request Node<ms><special>Request node from (Python code)<ms>"sound"<ms><special>Timer period (seconds)<ms>1<ms><special>Info to send to remote node (Python code)<ms><ms><special>Python variable: generated data<ms>self.soundNode<ms><special> <Shape>14235452 extra <special>Tool Tip<ms>Wait for voip call to end<ms><special>Event sought (Python code)<ms><ms><special>Event sought (Regular Exp)<ms>Terminating<ms><special>Python variable: source of the event<ms>self.eventSource<ms><special>Python variable: name of the event<ms>self.eventName<ms><special>Python variable: generated data<ms>self.eventData<ms><special> <Shape>99914699,146,101,269,166,281<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>20229740 extra <special>Tool Tip<ms>Death<ms><special> <Shape>2258468 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>2291710 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>7225646 extra <special>Tool Tip<ms>End Call<ms><special>Worker node to activate (python code)<ms>self.voipNode<ms><special> <Shape>15226601 extra <special>Tool Tip<ms>Make sound node -talk to itself<ms><special>First SofaSwitch worker (python)<ms>"sound"<ms><special>Second SofaSwitch worker (python)<ms>"sound"<ms><special> <Shape>19168499 extra <special>Tool Tip<ms>Send Dtmf to the voip node<ms><special>Worker node to activate (python code)<ms>self.voipNode<ms><special>DTMF to send to worker node (python code)<ms>self.dtmfData<ms><special> <Shape>5141281 extra <special>Tool Tip<ms>TEST: have a sound and voip node.<ms><special>Test (Python code)<ms>(self.voipNode != None) and (self.soundNode != None)<ms><special> <Shape>5140472 extra <special>Tool Tip<ms>Test for dtmf data of "9"<ms><special>Test (Python code)<ms>self.dtmfData=="9"<ms><special> <Shape> +9271711271,711,316,711<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>229752 extra <special>Tool Tip<ms>Register for events from voip node<ms><special>Node to receive events from (Python code)<ms>"voip"<ms><special> <Shape>9165522165,522,165,598,251,601<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>9248502248,502,251,601<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>9206141206,141,272,141<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>1889 extra <special>Tool Tip<ms>Start Processing<ms><special> <Shape>7225646 extra <special>Tool Tip<ms>End Call<ms><special>Worker node to activate (python code)<ms>self.voipNode<ms><special> <Shape>20229740 extra <special>Tool Tip<ms>Death<ms><special> <Shape>20336305 extra <special>Tool Tip<ms>Death<ms><special> <Shape>2244139 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>2169538 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>14153429 extra <special>Tool Tip<ms>Wait for DTMF data<ms><special>Event sought (Python code)<ms><ms><special>Event sought (Regular Exp)<ms>DTMF<ms><special>Python variable: source of the event<ms>self.eventSource<ms><special>Python variable: name of the event<ms>self.eventName<ms><special>Python variable: generated data<ms>self.dtmfData<ms><special> <Shape>2211306 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>9166479166,479<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>9203451203,451,248,452<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>19168499 extra <special>Tool Tip<ms>Send Dtmf to the voip node<ms><special>Worker node to activate (python code)<ms>self.voipNode<ms><special>DTMF to send to worker node (python code)<ms>self.dtmfData<ms><special> <Shape>795148 extra <special>Tool Tip<ms>End Call<ms><special>Worker node for termination (Python code)<ms>self.soundNode<ms><special> <Shape>9166171166,171,166,281<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>2291710 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>5140472 extra <special>Tool Tip<ms>Test for dtmf data of "9"<ms><special>Test (Python code)<ms>self.dtmfData=="9"<ms><special> <Shape>14235452 extra <special>Tool Tip<ms>Wait for voip call to end<ms><special>Event sought (Python code)<ms><ms><special>Event sought (Regular Exp)<ms>Terminating<ms><special>Python variable: source of the event<ms>self.eventSource<ms><special>Python variable: name of the event<ms>self.eventName<ms><special>Python variable: generated data<ms>self.eventData<ms><special> <Shape>6141330 extra <special>Tool Tip<ms>Make Call to a remote entity<ms><special>Worker node to activate (python code)<ms>self.voipNode<ms><special>Call destination (python code)<ms>self.scriptArgs<ms><special> <Shape>118996 extra <special>Tool Tip<ms>Request Node<ms><special>Request node from (Python code)<ms>"voip"<ms><special>Timer period (seconds)<ms>1<ms><special>Info to send to remote node (Python code)<ms><ms><special>Python variable: generated data<ms>self.voipNode<ms><special> <Shape>9139116139,116,181,121<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>9120198120,198,120,253,359,253<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>99914699,146,101,269,166,281<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>2258468 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>5141281 extra <special>Tool Tip<ms>TEST: have a sound and voip node.<ms><special>Test (Python code)<ms>(self.voipNode != None) and (self.soundNode != None)<ms><special> <Shape>7163164 extra <special>Tool Tip<ms>End Call<ms><special>Worker node for termination (Python code)<ms>self.voipNode<ms><special> <Shape>12334253 extra <special>Tool Tip<ms>Timer<ms><special>Timer period (seconds, Python code)<ms>0.2<ms><special>Timer label (Python code)<ms>"expire timer"<ms><special> <Shape>12224689 extra <special>Tool Tip<ms>Timer which initates a shutdown, after some tidyup + messages etc have been sent.<ms><special>Timer period (seconds, Python code)<ms>1<ms><special>Timer label (Python code)<ms>"endeverything"<ms><special> <Shape>15141381 extra <special>Tool Tip<ms>Transfer Media between the voip and sound node<ms><special>First SofaSwitch worker (python)<ms>self.voipNode<ms><special>Second SofaSwitch worker (python)<ms>self.soundNode<ms><special> <Shape>15226601 extra <special>Tool Tip<ms>Make sound node +talk to noone<ms><special>First SofaSwitch worker (python)<ms>"sound"<ms><special>Second SofaSwitch worker (python)<ms>"noone"<ms><special> <Shape>9188214188,214,188,251,359,252<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>11156121 extra <special>Tool Tip<ms>Request Node<ms><special>Request node from (Python code)<ms>"sound"<ms><special>Timer period (seconds)<ms>1<ms><special>Info to send to remote node (Python code)<ms><ms><special>Python variable: generated data<ms>self.soundNode<ms><special> <Shape>9191306191,306,237,307<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>2360272 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape> Added: sofaswitch/trunk/callflow/tests/mirrorvoip.src ============================================================================== --- (empty file) +++ sofaswitch/trunk/callflow/tests/mirrorvoip.src Wed Aug 1 19:30:10 2007 @@ -0,0 +1 @@ +9311507358,507,311,526<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>2288572 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>22268100 extra <special>Tool Tip<ms>Register for events from voip<ms><special>Node to receive events from (Python code)<ms>"voip"<ms><special> <Shape>14347405 extra <special>Tool Tip<ms>Eventer<ms><special>Event sought (Python code)<ms><ms><special>Event sought (Regular Exp)<ms>Terminating<ms><special>Python variable: source of the event<ms>self.eventSource<ms><special>Python variable: name of the event<ms>self.eventName<ms><special>Python variable: generated data<ms>self.eventData<ms><special> <Shape>9319402319,402,363,402<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>22265291 extra <special>Tool Tip<ms>Register for events from voip2<ms><special>Node to receive events from (Python code)<ms>self.voipNode<ms><special> <Shape>125958 extra <special>Tool Tip<ms>Start Processing<ms><special> <Shape>10295523 extra <special>Tool Tip<ms>Python<ms><special>Python Code<ms>print " "<ms><special> <Shape>14269380 extra <special>Tool Tip<ms>Wait for hangup of the voip call<ms><special>Event sought (Python code)<ms><ms><special>Event sought (Regular Exp)<ms>Hangup<ms><special>Python variable: source of the event<ms>self.eventSource<ms><special>Python variable: name of the event<ms>self.eventName<ms><special>Python variable: generated data<ms>self.hangupdata<ms><special> <Shape>10267192 extra <special>Tool Tip<ms>report: incoming voip call<ms><special>Python Code<ms>print "have received an incoming voip call from ",self.remotePerson<ms><special> <Shape>2375425 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>9283483283,483,311,526<special>Tool Tip<ms>Join blocks shape<ms><special> <Shape>10342447 extra <special>Tool Tip<ms>Python<ms><special>Python Code<ms>print "Terminating-- the voip call has ended with ", self.remotePerson<ms><special> <Shape>23257247 extra <special>Tool tip<ms>Accept incoming voip call at sofa node<ms><special>SofaSwitch node to advise as to accepting the call (Python code)<ms>self.voipNode<ms><special>Answer call yes or no (Python code)<ms>"yes"<ms><special> <Shape>14271144 extra <special>Tool Tip<ms>Wait for an incoming voip call<ms><special>Event sought (Python code)<ms><ms><special>Event sought (Regular Exp)<ms>QueryAccept<ms><special>Python variable: source of the event<ms>self.voipNode<ms><special>Python variable: name of the event<ms>self.eventName<ms><special>Python variable: generated data<ms>self.remotePerson<ms><special> <Shape>2297162 extra <special>Tool Tip<ms>Suspend Processing<ms><special> <Shape>15257333 extra <special>Tool Tip<ms>Transfer Media<ms><special>First SofaSwitch worker (python)<ms>self.voipNode<ms><special>Second SofaSwitch worker (python)<ms>self.voipNode<ms><special> <Shape>10267423 extra <special>Tool Tip<ms>Python<ms><special>Python Code<ms>print "HANGUP the voip call has ended with ", self.remotePerson<ms><special> <Shape>

1 0

[commit] r385 - sofaswitch/trunk/callflow/src
by SofaSWITCH SVN 01 Aug '07

01 Aug '07

Author: derek Date: Wed Aug 1 19:18:46 2007 New Revision: 385 Modified: sofaswitch/trunk/callflow/src/python.cpp Log: Tidy up postion of input point. Modified: sofaswitch/trunk/callflow/src/python.cpp ============================================================================== --- sofaswitch/trunk/callflow/src/python.cpp (original) +++ sofaswitch/trunk/callflow/src/python.cpp Wed Aug 1 19:18:46 2007 @@ -44,7 +44,7 @@ wxPoint pC(p1.x + 16, p1.y + 60); wxPoint pD(p1.x + 16, p1.y + 46); - DrawArrow(dc, pA, ArrowDown, InputPointConnected(0) ? Connected : Loose); + DrawArrow(dc, pB, ArrowDown, InputPointConnected(0) ? Connected : Loose); DrawArrow(dc, pC, ArrowDown, OutputPointConnected(0) ? Connected : Loose); dc.DrawLine(pA, pB); dc.DrawLine(pD, pC);

1 0

[commit] r384 - sofaswitch/trunk/voip
by SofaSWITCH SVN 01 Aug '07

01 Aug '07

Author: derek Date: Wed Aug 1 19:11:47 2007 New Revision: 384 Modified: sofaswitch/trunk/voip/comms.cxx Log: Send a message to say the call has been hungup. Modified: sofaswitch/trunk/voip/comms.cxx ============================================================================== --- sofaswitch/trunk/voip/comms.cxx (original) +++ sofaswitch/trunk/voip/comms.cxx Wed Aug 1 19:11:47 2007 @@ -239,6 +239,10 @@ void Comms::AdviseCallRelease() { + PTRACE(3, "Advise of call hangup on " << GetOurId() << " and " << remoteController); + PString advise = PString("Hangup ") + GetOurId(); + SendThisMessageTo(advise, remoteController); + PWaitAndSignal m(opalCallLock); if (myOpalCall != NULL) { myOpalCall->SafeDereference();

1 0