[Freeswitch-svn] [commit] r6066 - freeswitch/trunk/src/mod/endpoints/mod_opal
Freeswitch SVN
lzwierko at freeswitch.org
Sat Oct 27 06:41:52 EDT 2007
Author: lzwierko
Date: Sat Oct 27 06:41:52 2007
New Revision: 6066
Modified:
freeswitch/trunk/src/mod/endpoints/mod_opal/mod_opalh323.cpp
freeswitch/trunk/src/mod/endpoints/mod_opal/opalh323_backend.cpp
freeswitch/trunk/src/mod/endpoints/mod_opal/opalh323_backend.h
Log:
Modified: freeswitch/trunk/src/mod/endpoints/mod_opal/mod_opalh323.cpp
==============================================================================
--- freeswitch/trunk/src/mod/endpoints/mod_opal/mod_opalh323.cpp (original)
+++ freeswitch/trunk/src/mod/endpoints/mod_opal/mod_opalh323.cpp Sat Oct 27 06:41:52 2007
@@ -32,13 +32,68 @@
#include "mod_opalh323.h"
+#inlcude "opalh323_backend.h"
+#include <switch.h>
+
+/*
+ * IO routines handlers definitions
+ */
+static switch_call_cause_t opalh323_outgoing_channel(switch_core_session_t *, switch_caller_profile_t *, switch_core_session_t **, switch_memory_pool_t **);
+static switch_status_t opalh323_read_frame(switch_core_session_t *, switch_frame_t **, int, switch_io_flag_t, int);
+static switch_status_t opalh323_write_frame(switch_core_session_t *, switch_frame_t *, int, switch_io_flag_t, int);
+static switch_status_t opalh323_kill_channel(switch_core_session_t *, int);
+static switch_status_t opalh323_waitfor_read(switch_core_session_t *, int, int);
+static switch_status_t opalh323_waitfor_write(switch_core_session_t *, int, int);
+static switch_status_t opalh323_send_dtmf(switch_core_session_t *, char *);
+static switch_status_t opalh323_receive_message(switch_core_session_t *, switch_core_session_message_t *);
+static switch_status_t opalh323_receive_event(switch_core_session_t *, switch_event_t *);
+static switch_status_t opalh323_state_change(switch_core_session_t *);
+static switch_status_t opalh323_read_video_frame(switch_core_session_t *, switch_frame_t **, int, switch_io_flag_t, int);
+static switch_status_t opalh323_write_video_frame(switch_core_session_t *, switch_frame_t *, int, switch_io_flag_t, int);
+/*
+ * Event handlers declaration
+ */
+static switch_status_t opalh323_on_init(switch_core_session_t *session);
+static switch_status_t opalh323_on_ring(switch_core_session_t *session);
+static switch_status_t opalh323_on_execute(switch_core_session_t *session);
+static switch_status_t opalh323_on_hangup(switch_core_session_t *session);
+static switch_status_t opalh323_on_loopback(switch_core_session_t *session);
+static switch_status_t opalh323_on_transmit(switch_core_session_t *session);
+
+/**
+ * Declaration of private variables
+ */
+static FSOpalManager *opalh323_manager = NULL;
+static switch_memory_pool_t *opalh323_pool = NULL;
+static switch_endpoint_interface_t *opalh323_endpoint_interface;
-/* All gluer frontend function for Freeswitch must be
- * "C" functions. Because OPAL is written in C++
- * I implemented module gluer functions as extern "C"
+/*
+ * IO routines handlers set declaration
*/
-extern "C" {
-
+static switch_io_routines_t opalh323_io_routines = {
+ /*.outgoing_channel */ opalh323_outgoing_channel,
+ /*.read_frame */ opalh323_read_frame,
+ /*.write_frame */ opalh323_write_frame,
+ /*.kill_channel */ opalh323_kill_channel,
+ /*.waitfor_read */ opalh323_waitfor_read,
+ /*.waitfor_read */ opalh323_waitfor_write,
+ /*.send_dtmf */ opalh323_send_dtmf,
+ /*.receive_message */ opalh323_receive_message,
+ /*.receive_event */ opalh323_receive_event,
+ /*.state_change*/ opalh323_state_change,
+ /*.read_video_frame*/ opalh323_read_video_frame,
+ /*.write_video_frame*/ opalh323_write_video_frame
+};
+
+static switch_state_handler_table_t opalh323_event_handlers = {
+ /*.on_init */ opalh323_on_init,
+ /*.on_ring */ opalh323_on_ring,
+ /*.on_execute */ opalh323_on_execute,
+ /*.on_hangup */ opalh323_on_hangup,
+ /*.on_loopback */ opalh323_on_loopback,
+ /*.on_transmit */ opalh323_on_transmit
+};
+
/*
* Loadable FreeSWITCH module functions declaration
*/
@@ -61,6 +116,35 @@
*/
SWITCH_MODULE_LOAD_FUNCTION(mod_opalh323_load)
{
+
+ /* frontend initialization*/
+ *module_interface =NULL;
+ *module_interface = switch_loadable_module_create_module_interface(pool, modname);
+
+ assert(*module_interface);
+ if(!module_interface)
+ {
+ return SWITCH_STATUS_MEMERR;
+ }
+ opalh323_endpoint_interface = switch_loadable_module_create_interface(*module_interface, SWITCH_ENDPOINT_INTERFACE);
+ opalh323_endpoint_interface->interface_name = "OPALH323";
+ opalh323_endpoint_interface->io_routines = &opalh323_io_routines;
+ opalh323_endpoint_interface->state_handler = &opalh323_event_handlers;
+
+ /* backend initialization */
+ opalh323_manager = new FSOpalManager();
+ assert(opalh323_manager);
+ if(!opalh323_manager)
+ {
+ return SWITCH_STATUS_MEMERR;
+ }
+
+ if(!opalh323_manager->initialize(pool))
+ {
+ delete opalh323_manager;
+ return SWITCH_STATUS_FALSE; /* if can't initialize return general error */
+ }
+
/* indicate that the module should continue to be loaded */
return SWITCH_STATUS_SUCCESS;
}
@@ -71,29 +155,19 @@
* it dealocates OPAL core
*
*/
-SWITCH_MODULE_SHUTDOWN_FUNCTION(mod_sofia_shutdown)
+SWITCH_MODULE_SHUTDOWN_FUNCTION(mod_opalh323_shutdown)
{
+
+ /* deallocate OPAL manager */
+ delete opalh323_manager;
+
return SWITCH_STATUS_SUCCESS;
}
+
/*
- * IO routines handlers
+ * IO routines handlers definitions
*/
-static switch_io_routines_t opalh323_io_routines = {
- /*.outgoing_channel */ opalh323_outgoing_channel,
- /*.read_frame */ opalh323_read_frame,
- /*.write_frame */ opalh323_write_frame,
- /*.kill_channel */ opalh323_kill_channel,
- /*.waitfor_read */ opalh323_waitfor_read,
- /*.waitfor_read */ opalh323_waitfor_write,
- /*.send_dtmf */ opalh323_send_dtmf,
- /*.receive_message */ opalh323_receive_message,
- /*.receive_event */ opalh323_receive_event,
- /*.state_change*/ opalh323_state_change,
- /*.read_video_frame*/ opalh323_read_video_frame,
- /*.write_video_frame*/ opalh323_write_video_frame
-};
-
static switch_call_cause_t opalh323_outgoing_channel(switch_core_session_t *, switch_caller_profile_t *, switch_core_session_t **, switch_memory_pool_t **)
{
return 0;
@@ -157,14 +231,6 @@
/*
* Event handlers
*/
-static switch_state_handler_table_t opalh323_event_handlers = {
- /*.on_init */ opalh323_on_init,
- /*.on_ring */ opalh323_on_ring,
- /*.on_execute */ opalh323_on_execute,
- /*.on_hangup */ opalh323_on_hangup,
- /*.on_loopback */ opalh323_on_loopback,
- /*.on_transmit */ opalh323_on_transmit
-};
static switch_status_t opalh323_on_init(switch_core_session_t *session)
{
@@ -195,7 +261,3 @@
{
return SWITCH_STATUS_SUCCESS;
}
-
-
-
-}
Modified: freeswitch/trunk/src/mod/endpoints/mod_opal/opalh323_backend.cpp
==============================================================================
--- freeswitch/trunk/src/mod/endpoints/mod_opal/opalh323_backend.cpp (original)
+++ freeswitch/trunk/src/mod/endpoints/mod_opal/opalh323_backend.cpp Sat Oct 27 06:41:52 2007
@@ -27,3 +27,227 @@
* Initial revision
*/
+#include <switch.h>
+#include "opalh323_backend.h"
+#include <include/h323/h323ep.h>
+
+/**
+ * Private structre
+ */
+
+typedef struct OpalH323Private_s
+{
+ OpalConnection *m_opalConnection; /** pointer to OpalConnection object */
+ switch_mutex_t *m_mutex; /** mutex for synchonizing access to session object */
+
+} OpalH323Private_t;
+
+
+
+/** Default constructor
+ *
+ */
+FSOpalManager::FSOpalManager() :
+ m_isInitialized(false),
+ m_pH323Endpoint(NULL);
+ m_pMemoryPool(NULL)
+{
+
+}
+
+/** Destructor
+ *
+ */
+~FSOpalManager::FSOpalManager()
+{
+ /**
+ * Destroy all allocated resources, if any
+ */
+ if(m_isInitialized)
+ {
+ delete m_pH323Endpoint;
+ m_pH323Endpoint = NULL;
+ m_isInitialized = false;
+ }
+}
+
+ /**
+ * Method does real initialization of the manager
+ */
+bool FSOpalManager::initialize(
+ switch_memory_pool_t *i_memoryPool,
+ switch_endpoint_interface_t *i_endpointInterface
+ )
+{
+ bool result = true;
+
+ /* check if everything is not initialized */
+ assert(m_isInitialized);
+ assert(!m_pH323Endpoint);
+ assert(!m_pMemoryPool)
+
+ /* check input parameters */
+ assert(i_memoryPool);
+ assert(i_endpointInterface);
+
+
+
+ m_pMemoryPool = i_memoryPool;
+ m_pEndpointInterface = i_endpointInterface;
+
+ /* create h323 endpoint */
+ m_pH323Endpoint = new H323EndPoint(this); ///TODO, replace prefix and signaling port by values from configuration
+ if(!m_pH323Endpoint)
+ {
+ assert(0);
+ return false;
+ }
+
+ /**
+ * To do-> add codecs to capabilities (for call contol)
+ * m_pH323Endpoint->AddCapability();
+ */
+
+ m_pH323Endpoint->DisableFastStart(false); ///TODO this should be configurable
+ m_pH323Endpoint->DisableH245Tunneling(false); ///TODO this should be configurable
+
+ ///TODO gatekeeper use should be configurable, I think that sevral options should be implemented in config file: use, dont use, use one of specified with priorities, try to reconnect to the topmost...
+ ///TODO m_pH323Endpoint->SetInitialBandwidth(initialBandwidth);
+ ///TODO m_pH323Endpoint->SetVendorIdentifierInfo()
+
+ ///TODO address should be configurable, should allow creaeing listeners on multiple interfaces
+ OpalTransportAddress opalTransportAddress("0.0.0.0",1720); //for time being create listener on all ip's and default port
+ result = m_pH323Endpoint->StartListeners(opalTransportAddress);
+ assert(result);
+ if(!result)
+ {
+ delete m_pH323Endpoint:
+ return false;
+ }
+
+ /* at this point OPAL is ready to go */
+ m_isInitialized = true;
+ return true;
+}
+
+
+BOOL FSOpalManager::OnIncomingConnection(
+ OpalConnection & connection, ///< Connection that is calling
+ unsigned options, ///< options for new connection (can't use default as overrides will fail)
+ OpalConnection::StringOptions * stringOptions
+ )
+{
+ //TODO check if options and stringOptions fields ever apply
+ retrun OnIncomingConnection(connection);
+}
+
+BOOL FSOpalManager::OnIncomingConnection(
+ OpalConnection & connection, ///< Connection that is calling
+ unsigned options ///< options for new connection (can't use default as overrides will fail)
+ )
+{
+ //TODO, check if options field ever applies
+ retrun OnIncomingConnection(connection);
+}
+
+BOOL FSOpalManager::OnIncomingConnection(
+ OpalConnection & connection ///< Connection that is calling
+ )
+{
+ /* allocate new session in switch core*/
+ switch_core_session_t *session = switch_core_session_request(m_pEndpointInterface , NULL);
+ assert(session);
+ if(!sesion)
+ {
+ ///TODO add cause to the connection
+ switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CRIT, "Could not allocate session object?\n");
+ return FALSE;
+ }
+
+ /* allocate private resources */
+ OpalH323Private_t *tech_pvt = (OpalH323Private_t *)switch_core_session_alloc(session, sizeof(OpalH323Private_t));
+ assert(tech_pvt);
+ if(!tech_pvt)
+ {
+ ///TODO add cause to the connection
+ switch_core_session_destroy(&session);
+ switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CRIT, "Could not allocate private object?\n");
+ return false;
+ }
+ tech_pvt->m_opalConnection = &connection;
+ switch_mutex_init(&tech_pvt->m_mutex, SWITCH_MUTEX_NESTED, switch_core_session_get_pool(session));
+ /** save private data under hash and in session */
+
+ /***Mark incoming call as AnsweredPending ??? */
+
+
+}
+
+
+
+
+
+
+
+/**
+ * FS ON_INIT callback handler
+ *
+ */
+switch_status_t FSOpalManager::callback_on_init(switch_core_session_t *io_session)
+{
+ assert(m_isInitialized);
+ return SWITCH_STATUS_SUCCESS;
+}
+
+/**
+ * FS ON_INIT callback handler
+ *
+ */
+switch_status_t FSOpalManager::callback_on_ring(switch_core_session_t *io_session)
+{
+ assert(m_isInitialized);
+ return SWITCH_STATUS_SUCCESS;
+}
+
+/**
+ * FS ON_EXECUTE callback handler
+ *
+ */
+switch_status_t FSOpalManager::callback_on_execute(switch_core_session_t *io_session)
+{
+ assert(m_isInitialized);
+ return SWITCH_STATUS_SUCCESS;
+}
+
+/**
+ * FS ON_HANGUP callback handler
+ *
+ */
+switch_status_t FSOpalManager::callback_on_hangup(switch_core_session_t *io_session)
+{
+ assert(m_isInitialized);
+ return SWITCH_STATUS_SUCCESS;
+}
+
+/**
+ * FS ON_LOOPBACK callback handler
+ *
+ */
+
+switch_status_t FSOpalManager::callback_on_loopback(switch_core_session_t *io_session)
+{
+ assert(m_isInitialized);
+ return SWITCH_STATUS_SUCCESS;
+}
+
+/**
+ * FS ON_TRANSMIT callback handler
+ *
+ */
+switch_status_t FSOpalManager::callback_on_transmit(switch_core_session_t *io_session)
+{
+ assert(m_isInitialized);
+ return SWITCH_STATUS_SUCCESS;
+}
+
+
Modified: freeswitch/trunk/src/mod/endpoints/mod_opal/opalh323_backend.h
==============================================================================
--- freeswitch/trunk/src/mod/endpoints/mod_opal/opalh323_backend.h (original)
+++ freeswitch/trunk/src/mod/endpoints/mod_opal/opalh323_backend.h Sat Oct 27 06:41:52 2007
@@ -26,3 +26,68 @@
* Revision 1.00 2007/10/24 07:29:52 lzwierko
* Initial revision
*/
+
+#ifndef __FREESWITCH_OPALH323_BACKEND__
+#define __FREESWITCH_OPALH323_BACKEND__
+
+#include <switch.h>
+#include <opal/manager.h>
+#include <opal/endpoint.h>
+#include <opal/mediastrm.h>
+
+
+class H323EndPoint;
+
+/** This class is OpalManager implementation
+ * for FreeSWITCH OpalH323 module.
+ * All methods are inherited from base OpalManagerClass.
+ * Event callbacks will be filed with valid code
+ * Additional functions have been implemented to be called, or called by
+ */
+class FSOpalManager : public OpalManager
+{
+ PCLASSINFO(FSOpalManager, PObject);
+
+public:
+
+ /** Default constructor
+ *
+ */
+ FSOpalManager();
+
+ /** Destructor
+ *
+ */
+ ~FSOpalManager();
+
+ /**
+ * Method does real initialization of the manager
+ */
+ bool initialize(
+ switch_memory_pool_t* i_memoryPool,
+ switch_endpoint_interface_t *i_endpointInterface
+ );
+
+ /** FS callback handlers declarations
+ *
+ */
+ switch_status_t callback_on_init(switch_core_session_t *io_session);
+ switch_status_t callback_on_ring(switch_core_session_t *io_session);
+ switch_status_t callback_on_execute(switch_core_session_t *io_session);
+ switch_status_t callback_on_hangup(switch_core_session_t *io_session);
+ switch_status_t callback_on_loopback(switch_core_session_t *io_session);
+ switch_status_t callback_on_transmit(switch_core_session_t *io_session);
+
+private:
+
+ bool m_isInitilized; /* true if module has been initialized properly */
+ H323Endpoint *m_pH323Endpoint; /* h323 endpoint control */
+ switch_memory_pool_t *m_pMemoryPool; /* FS memory pool */
+ switch_endpoint_interface_t *m_pEndpointInterface; /* FS endpoint inerface */
+
+
+};
+
+
+
+#endif
More information about the Freeswitch-svn
mailing list