-/* Opal endpoint interface for Freeswitch Modular Media Switching Software Library /\r
- * Soft-Switch Application\r
- *\r
- * Version: MPL 1.1\r
- *\r
- * Copyright (c) 2007 Tuyan Ozipek (tuyanozipek@gmail.com)\r
- *\r
- * The contents of this file are subject to the Mozilla Public License Version\r
- * 1.1 (the "License"); you may not use this file except in compliance with\r
- * the License. You may obtain a copy of the License at\r
- * http://www.mozilla.org/MPL/\r
- *\r
- * Software distributed under the License is distributed on an "AS IS" basis,\r
- * WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License\r
- * for the specific language governing rights and limitations under the\r
- * License.\r
- *\r
- * Contributor(s):\r
- * Tuyan Ozipek (tuyanozipek@gmail.com)\r
- * Lukasz Zwierko (lzwierko@gmail.com)\r
- * Robert Jongbloed (robertj@voxlucida.com.au)\r
- *\r
- */\r
-\r
-#include "mod_opal.h"\r
-#include <opal/patch.h>\r
-#include <rtp/rtp.h>\r
-#include <h323/h323pdu.h>\r
-#include <h323/gkclient.h>\r
-\r
-SWITCH_DECLARE_GLOBAL_STRING_FUNC(set_global_codec_string, mod_opal_globals.codec_string);\r
-SWITCH_DECLARE_GLOBAL_STRING_FUNC(set_global_context, mod_opal_globals.context);\r
-SWITCH_DECLARE_GLOBAL_STRING_FUNC(set_global_dialplan, mod_opal_globals.dialplan);\r
-\r
-\r
-#define CF_NEED_FLUSH (1 << 1)\r
-\r
-struct mod_opal_globals mod_opal_globals = { 0 };\r
-\r
-\r
-static switch_call_cause_t create_outgoing_channel(switch_core_session_t *session, switch_event_t *var_event,\r
- switch_caller_profile_t *outbound_profile, switch_core_session_t **new_session,\r
- switch_memory_pool_t **pool, switch_originate_flag_t flags);\r
-\r
-\r
-static FSProcess *opal_process = NULL;\r
-\r
-\r
-static const char ModuleName[] = "opal";\r
-\r
-\r
-static switch_status_t on_hangup(switch_core_session_t *session);\r
-static switch_status_t on_destroy(switch_core_session_t *session);\r
-\r
-\r
-static switch_io_routines_t opalfs_io_routines = {\r
- /*.outgoing_channel */ create_outgoing_channel,\r
- /*.read_frame */ FSConnection::read_audio_frame,\r
- /*.write_frame */ FSConnection::write_audio_frame,\r
- /*.kill_channel */ FSConnection::kill_channel,\r
- /*.send_dtmf */ FSConnection::send_dtmf,\r
- /*.receive_message */ FSConnection::receive_message,\r
- /*.receive_event */ FSConnection::receive_event,\r
- /*.state_change */ FSConnection::state_change,\r
- /*.read_video_frame */ FSConnection::read_video_frame,\r
- /*.write_video_frame */ FSConnection::write_video_frame\r
-};\r
-\r
-static switch_state_handler_table_t opalfs_event_handlers = {\r
- /*.on_init */ FSConnection::on_init,\r
- /*.on_routing */ FSConnection::on_routing,\r
- /*.on_execute */ FSConnection::on_execute,\r
- /*.on_hangup */ on_hangup,\r
- /*.on_exchange_media */ FSConnection::on_exchange_media,\r
- /*.on_soft_execute */ FSConnection::on_soft_execute,\r
- /*.on_consume_media*/ NULL,\r
- /*.on_hibernate*/ NULL,\r
- /*.on_reset*/ NULL,\r
- /*.on_park*/ NULL,\r
- /*.on_reporting*/ NULL,\r
- /*.on_destroy*/ on_destroy\r
-};\r
-\r
-\r
-SWITCH_BEGIN_EXTERN_C\r
-/*******************************************************************************/\r
-\r
-SWITCH_MODULE_LOAD_FUNCTION(mod_opal_load);\r
-SWITCH_MODULE_SHUTDOWN_FUNCTION(mod_opal_shutdown);\r
-SWITCH_MODULE_DEFINITION(mod_opal, mod_opal_load, mod_opal_shutdown, NULL);\r
-\r
-SWITCH_MODULE_LOAD_FUNCTION(mod_opal_load) {\r
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CONSOLE, "Starting loading mod_opal\n");\r
-\r
- /* Prevent the loading of OPAL codecs via "plug ins", this is a directory\r
- full of DLLs that will be loaded automatically. */\r
- putenv((char *)"PTLIBPLUGINDIR=/no/thanks");\r
-\r
-\r
- *module_interface = switch_loadable_module_create_module_interface(pool, modname);\r
- if (!*module_interface) {\r
- return SWITCH_STATUS_MEMERR;\r
- }\r
-\r
- opal_process = new FSProcess();\r
- if (opal_process == NULL) {\r
- return SWITCH_STATUS_MEMERR;\r
- }\r
-\r
- if (opal_process->Initialise(*module_interface)) {\r
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CONSOLE, "Opal manager initialized and running\n");\r
- //unloading causes a seg in linux\r
- return SWITCH_STATUS_NOUNLOAD;\r
- //return SWITCH_STATUS_SUCCESS;\r
- }\r
-\r
- delete opal_process;\r
- opal_process = NULL;\r
- return SWITCH_STATUS_FALSE;\r
-}\r
-\r
-\r
-SWITCH_MODULE_SHUTDOWN_FUNCTION(mod_opal_shutdown) {\r
- \r
- switch_safe_free(mod_opal_globals.context);\r
- switch_safe_free(mod_opal_globals.dialplan);\r
- switch_safe_free(mod_opal_globals.codec_string);\r
- delete opal_process;\r
- opal_process = NULL;\r
- return SWITCH_STATUS_SUCCESS;\r
-}\r
-\r
-SWITCH_END_EXTERN_C\r
-/*******************************************************************************/\r
-\r
-\r
-\r
-static switch_call_cause_t create_outgoing_channel(switch_core_session_t *session,\r
- switch_event_t *var_event,\r
- switch_caller_profile_t *outbound_profile,\r
- switch_core_session_t **new_session, switch_memory_pool_t **pool, switch_originate_flag_t flags)\r
-{\r
- if (opal_process == NULL) {\r
- return SWITCH_CAUSE_CRASH;\r
- }\r
-\r
- PString token;\r
-\r
- FSManager & manager = opal_process->GetManager();\r
- if (!manager.SetUpCall("local:", outbound_profile->destination_number, token, outbound_profile)) {\r
- return SWITCH_CAUSE_INVALID_NUMBER_FORMAT;\r
- }\r
-\r
- PSafePtr < OpalCall > call = manager.FindCallWithLock(token);\r
-\r
- if (call == NULL) {\r
- return SWITCH_CAUSE_PROTOCOL_ERROR;\r
- }\r
-\r
- PSafePtr < FSConnection > connection = call->GetConnectionAs < FSConnection > (0);\r
-\r
- if (connection == NULL) {\r
- return SWITCH_CAUSE_PROTOCOL_ERROR;\r
- }\r
-\r
- *new_session = connection->GetSession();\r
-\r
- return SWITCH_CAUSE_SUCCESS;\r
-}\r
-\r
-\r
-///////////////////////////////////////////////////////////////////////\r
-\r
-#if PTRACING\r
-\r
-class FSTrace : public ostream {\r
- public:\r
- FSTrace()\r
- : ostream(&buffer)\r
- {\r
- }\r
-\r
- private:\r
- class Buffer : public streambuf {\r
- char buffer[250];\r
-\r
- public:\r
- Buffer()\r
- {\r
- setg(buffer, buffer, &buffer[sizeof(buffer)-2]);\r
- setp(buffer, &buffer[sizeof(buffer)-2]);\r
- }\r
-\r
- virtual int sync()\r
- {\r
- return overflow(EOF);\r
- }\r
-\r
- virtual int underflow()\r
- {\r
- return EOF;\r
- }\r
-\r
- virtual int overflow(int c)\r
- {\r
- const char *fmt = "%s";\r
- char *func = NULL;\r
-\r
- int bufSize = pptr() - pbase();\r
-\r
- if (c != EOF) {\r
- *pptr() = (char)c;\r
- bufSize++;\r
- }\r
- \r
- if (bufSize != 0) {\r
- char *bufPtr = pbase();\r
- char *bufEndPtr = NULL;\r
- setp(bufPtr, epptr());\r
- bufPtr[bufSize] = '\0';\r
- int line = 0;\r
- char *p;\r
- \r
- char *file = NULL;\r
- switch_log_level_t level;\r
-\r
- \r
- switch (strtoul(bufPtr, &file, 10)) {\r
- case 1 :\r
- level = SWITCH_LOG_INFO;\r
- break;\r
- default :\r
- level = SWITCH_LOG_DEBUG;\r
- break;\r
- }\r
-\r
- if (file) {\r
- while (isspace(*file)) file++;\r
- \r
- if (file && (bufPtr = strchr(file, '(')) && (bufEndPtr = strchr(bufPtr, ')'))) {\r
- char *e;\r
-\r
- for(p = bufPtr; p && *p; p++) {\r
- if (*p == '\t') {\r
- *p = ' ';\r
- }\r
- }\r
-\r
- *bufPtr++ = '\0';\r
- line = atoi(bufPtr);\r
- while (bufEndPtr && isspace(*(++bufEndPtr)));\r
- bufPtr = bufEndPtr;\r
- if (bufPtr && (e = strchr(bufPtr, ' ')) || (e = strchr(bufPtr, '\t'))) {\r
- func = bufPtr;\r
- bufPtr = e;\r
- *bufPtr++ = '\0';\r
- }\r
- }\r
- }\r
- \r
- switch_text_channel_t tchannel = SWITCH_CHANNEL_ID_LOG;\r
-\r
- if (!bufPtr) {\r
- bufPtr = pbase();\r
- level = SWITCH_LOG_DEBUG;\r
- }\r
-\r
- if (bufPtr) {\r
- if (end_of(bufPtr) != '\n') {\r
- fmt = "%s\n";\r
- }\r
- if (!(file && func && line)) tchannel = SWITCH_CHANNEL_ID_LOG_CLEAN;\r
-\r
- switch_log_printf(tchannel, file, func, line, NULL, level, fmt, bufPtr);\r
- }\r
- \r
- }\r
-\r
- return 0;\r
- }\r
- } buffer;\r
-};\r
-\r
-#endif\r
-\r
-\r
-///////////////////////////////////////////////////////////////////////\r
-\r
-FSProcess::FSProcess()\r
- : PLibraryProcess("Vox Lucida Pty. Ltd.", "mod_opal", 1, 0, AlphaCode, 1)\r
- , m_manager(NULL)\r
-{\r
-}\r
-\r
-\r
-FSProcess::~FSProcess()\r
-{\r
- delete m_manager;\r
-}\r
-\r
-\r
-bool FSProcess::Initialise(switch_loadable_module_interface_t *iface)\r
-{\r
- m_manager = new FSManager();\r
- return m_manager != NULL && m_manager->Initialise(iface);\r
-}\r
-\r
-\r
-///////////////////////////////////////////////////////////////////////\r
-\r
-FSManager::FSManager()\r
-{\r
- // These are deleted by the OpalManager class, no need to have destructor\r
- m_h323ep = new H323EndPoint(*this);\r
- m_iaxep = new IAX2EndPoint(*this);\r
- m_fsep = new FSEndPoint(*this);\r
-}\r
-\r
-\r
-bool FSManager::Initialise(switch_loadable_module_interface_t *iface)\r
-{\r
- ReadConfig(false);\r
-\r
-#if PTRACING\r
- PTrace::SetLevel(mod_opal_globals.trace_level); //just for fun and eyecandy ;)\r
- PTrace::SetOptions(PTrace::TraceLevel);\r
- PTrace::SetStream(new FSTrace);\r
-#endif\r
-\r
- m_FreeSwitch = (switch_endpoint_interface_t *) switch_loadable_module_create_interface(iface, SWITCH_ENDPOINT_INTERFACE);\r
- m_FreeSwitch->interface_name = ModuleName;\r
- m_FreeSwitch->io_routines = &opalfs_io_routines;\r
- m_FreeSwitch->state_handler = &opalfs_event_handlers;\r
-\r
- silenceDetectParams.m_mode = OpalSilenceDetector::NoSilenceDetection;\r
-\r
- if (m_listeners.empty()) {\r
- m_h323ep->StartListener("");\r
- } else {\r
- for (std::list < FSListener >::iterator it = m_listeners.begin(); it != m_listeners.end(); ++it) {\r
- if (!m_h323ep->StartListener(it->listenAddress)) {\r
- PTRACE(3, "mod_opal\tCannot start listener for " << it->name);\r
- }\r
- }\r
- }\r
-\r
- AddRouteEntry("h323:.* = local:<da>"); // config option for direct routing\r
- AddRouteEntry("iax2:.* = local:<da>"); // config option for direct routing\r
- AddRouteEntry("local:.* = h323:<da>"); // config option for direct routing\r
-\r
- // Make sure all known codecs are instantiated,\r
- // these are ones we know how to translate into H.323 capabilities\r
- GetOpalG728();\r
- GetOpalG729();\r
- GetOpalG729A();\r
- GetOpalG729B();\r
- GetOpalG729AB();\r
- GetOpalG7231_6k3();\r
- GetOpalG7231_5k3();\r
- GetOpalG7231A_6k3();\r
- GetOpalG7231A_5k3();\r
- GetOpalGSM0610();\r
- GetOpalGSMAMR();\r
- GetOpaliLBC();\r
-\r
- /* For compatibility with the algorithm in FSConnection::SetCodecs() we need\r
- to set all audio media formats to be 1 frame per packet */\r
- OpalMediaFormatList allCodecs = OpalMediaFormat::GetAllRegisteredMediaFormats();\r
- for (OpalMediaFormatList::iterator it = allCodecs.begin(); it != allCodecs.end(); ++it) {\r
- if (it->GetMediaType() == OpalMediaType::Audio()) {\r
- it->SetOptionInteger(OpalAudioFormat::RxFramesPerPacketOption(), 1);\r
- it->SetOptionInteger(OpalAudioFormat::TxFramesPerPacketOption(), 1);\r
- }\r
- }\r
-\r
- if (!m_gkAddress.IsEmpty()) {\r
- if (m_h323ep->UseGatekeeper(m_gkAddress, m_gkIdentifer, m_gkInterface))\r
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Started gatekeeper: %s\n",\r
- (const char *)m_h323ep->GetGatekeeper()->GetName());\r
- else\r
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR,\r
- "Could not start gatekeeper: addr=\"%s\", id=\"%s\", if=\"%s\"\n",\r
- (const char *)m_gkAddress,\r
- (const char *)m_gkIdentifer,\r
- (const char *)m_gkInterface);\r
- }\r
-\r
- return TRUE;\r
-}\r
-\r
-\r
-switch_status_t FSManager::ReadConfig(int reload)\r
-{\r
- const char *cf = "opal.conf";\r
- switch_status_t status = SWITCH_STATUS_SUCCESS;\r
-\r
- switch_memory_pool_t *pool = NULL;\r
- if ((status = switch_core_new_memory_pool(&pool)) != SWITCH_STATUS_SUCCESS) {\r
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CRIT, "Memory Error!\n");\r
- return status;\r
- }\r
-\r
- set_global_context("default");\r
- set_global_dialplan("XML");\r
-\r
- switch_event_t *params = NULL;\r
- switch_event_create(¶ms, SWITCH_EVENT_REQUEST_PARAMS);\r
- switch_assert(params);\r
- switch_event_add_header_string(params, SWITCH_STACK_BOTTOM, "profile", switch_str_nil(""));\r
- switch_xml_t cfg;\r
- switch_xml_t xml = switch_xml_open_cfg(cf, &cfg, params);\r
- if (xml == NULL) {\r
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "open of %s failed\n", cf);\r
- return SWITCH_STATUS_FALSE;\r
- }\r
-\r
- switch_xml_t xmlSettings = switch_xml_child(cfg, "settings");\r
- if (xmlSettings) {\r
- for (switch_xml_t xmlParam = switch_xml_child(xmlSettings, "param"); xmlParam != NULL; xmlParam = xmlParam->next) {\r
- const char *var = switch_xml_attr_soft(xmlParam, "name");\r
- const char *val = switch_xml_attr_soft(xmlParam, "value");\r
-\r
- if (!strcasecmp(var, "trace-level")) {\r
- int level = atoi(val);\r
- if (level > 0) {\r
- mod_opal_globals.trace_level = level;\r
- }\r
- } else if (!strcasecmp(var, "context")) {\r
- set_global_context(val);\r
- } else if (!strcasecmp(var, "dialplan")) {\r
- set_global_dialplan(val);\r
- } else if (!strcasecmp(var, "codec-prefs")) {\r
- set_global_codec_string(val);\r
- } else if (!strcasecmp(var, "jitter-size")) {\r
- char * next;\r
- unsigned minJitter = strtoul(val, &next, 10);\r
- if (minJitter >= 10) {\r
- unsigned maxJitter = minJitter;\r
- if (*next == ',')\r
- maxJitter = atoi(next+1);\r
- SetAudioJitterDelay(minJitter, maxJitter); // In milliseconds\r
- }\r
- } else if (!strcasecmp(var, "gk-address")) {\r
- m_gkAddress = val;\r
- } else if (!strcasecmp(var, "gk-identifer")) {\r
- m_gkIdentifer = val;\r
- } else if (!strcasecmp(var, "gk-interface")) {\r
- m_gkInterface = val;\r
- }\r
- }\r
- }\r
-\r
- switch_xml_t xmlListeners = switch_xml_child(cfg, "listeners");\r
- if (xmlListeners != NULL) {\r
- for (switch_xml_t xmlListener = switch_xml_child(xmlListeners, "listener"); xmlListener != NULL; xmlListener = xmlListener->next) {\r
-\r
- m_listeners.push_back(FSListener());\r
- FSListener & listener = m_listeners.back();\r
-\r
- listener.name = switch_xml_attr_soft(xmlListener, "name");\r
- if (listener.name.IsEmpty())\r
- listener.name = "unnamed";\r
-\r
- PIPSocket::Address ip;\r
- WORD port = 1720;\r
-\r
- for (switch_xml_t xmlParam = switch_xml_child(xmlListener, "param"); xmlParam != NULL; xmlParam = xmlParam->next) {\r
- const char *var = switch_xml_attr_soft(xmlParam, "name");\r
- const char *val = switch_xml_attr_soft(xmlParam, "value");\r
- //switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Var - '%s' and Val - '%s' \n", var, val);\r
- if (!strcasecmp(var, "h323-ip"))\r
- ip = val;\r
- else if (!strcasecmp(var, "h323-port"))\r
- port = (WORD) atoi(val);\r
- }\r
-\r
- listener.listenAddress = OpalTransportAddress(ip, port);\r
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Created Listener '%s'\n", (const char *) listener.name);\r
- }\r
- }\r
-\r
- switch_event_destroy(¶ms);\r
-\r
- if (xml)\r
- switch_xml_free(xml);\r
-\r
- return status;\r
-}\r
-\r
-\r
-OpalCall * FSManager::CreateCall(void * /*userData*/)\r
-{\r
- return new FSCall(*this);\r
-}\r
-\r
-\r
-///////////////////////////////////////////////////////////////////////\r
-\r
-FSEndPoint::FSEndPoint(FSManager & manager)\r
-: OpalLocalEndPoint(manager)\r
-{\r
- PTRACE(3, "mod_opal\t FSEndPoint Created!");\r
-}\r
-\r
-\r
-bool FSEndPoint::OnIncomingCall(OpalLocalConnection & connection)\r
-{\r
- return ((FSConnection &) connection).OnIncoming();\r
-}\r
-\r
-\r
-OpalLocalConnection *FSEndPoint::CreateConnection(OpalCall & call, void *userData, unsigned options, OpalConnection::StringOptions* stringOptions)\r
-{\r
- FSManager & mgr = (FSManager &) GetManager();\r
- switch_core_session_t *fsSession = switch_core_session_request(mgr.GetSwitchInterface(), \r
- (switch_caller_profile_t *)userData ? SWITCH_CALL_DIRECTION_OUTBOUND : SWITCH_CALL_DIRECTION_INBOUND, NULL);\r
- if (fsSession == NULL)\r
- return NULL;\r
-\r
- switch_channel_t *fsChannel = switch_core_session_get_channel(fsSession);\r
-\r
- if (fsChannel == NULL) {\r
- switch_core_session_destroy(&fsSession);\r
- return NULL;\r
- }\r
-\r
- return new FSConnection(call, *this, userData, options, stringOptions, (switch_caller_profile_t *)userData, fsSession, fsChannel);\r
-}\r
-\r
-\r
-///////////////////////////////////////////////////////////////////////\r
-\r
-FSCall::FSCall(OpalManager & manager)\r
- : OpalCall(manager)\r
-{\r
-}\r
-\r
-\r
-PBoolean FSCall::OnSetUp(OpalConnection & connection)\r
-{\r
- // Transfer FS caller_id_number & caller_id_name from the FSConnection\r
- // to the protocol connectionm (e.g. H.323) so gets sent correctly\r
- // in outgoing packets\r
- PSafePtr<FSConnection> local = GetConnectionAs<FSConnection>();\r
- if (local != NULL) {\r
- PSafePtr<OpalConnection> proto = local->GetOtherPartyConnection();\r
- if (proto != NULL) {\r
- proto->SetLocalPartyName(local->GetLocalPartyName());\r
- proto->SetDisplayName(local->GetDisplayName());\r
- }\r
- }\r
-\r
- return OpalCall::OnSetUp(connection);\r
-}\r
-\r
-\r
-///////////////////////////////////////////////////////////////////////\r
-\r
-\r
-FSConnection::FSConnection(OpalCall & call, FSEndPoint & endpoint, void* userData, unsigned options, OpalConnection::StringOptions* stringOptions, switch_caller_profile_t *outbound_profile, switch_core_session_t *fsSession, switch_channel_t *fsChannel)\r
- : OpalLocalConnection(call, endpoint, userData, options, stringOptions)\r
- , m_endpoint(endpoint)\r
- , m_fsSession(fsSession)\r
- , m_fsChannel(fsChannel)\r
-{\r
- opal_private_t *tech_pvt;\r
-\r
- tech_pvt = (opal_private_t *) switch_core_session_alloc(m_fsSession, sizeof(*tech_pvt));\r
- tech_pvt->me = this;\r
- switch_core_session_set_private(m_fsSession, tech_pvt);\r
-\r
- if (outbound_profile != NULL) {\r
- SetLocalPartyName(outbound_profile->caller_id_number);\r
- SetDisplayName(outbound_profile->caller_id_name);\r
-\r
- switch_caller_profile_t *caller_profile = switch_caller_profile_clone(m_fsSession, outbound_profile);\r
- switch_channel_set_caller_profile(m_fsChannel, caller_profile);\r
-\r
- PString name = "opal/";\r
- name += outbound_profile->destination_number;\r
- switch_channel_set_name(m_fsChannel, name);\r
-\r
- switch_channel_set_flag(m_fsChannel, CF_OUTBOUND);\r
- switch_channel_set_state(m_fsChannel, CS_INIT);\r
- }\r
-}\r
-\r
-\r
-bool FSConnection::OnIncoming()\r
-{\r
- if (m_fsSession == NULL) {\r
- PTRACE(1, "mod_opal\tSession request failed.");\r
- return false;\r
- }\r
-\r
- switch_core_session_add_stream(m_fsSession, NULL);\r
-\r
- switch_channel_t *channel = switch_core_session_get_channel(m_fsSession);\r
- if (channel == NULL) {\r
- PTRACE(1, "mod_opal\tSession does not have a channel");\r
- return false;\r
- }\r
-\r
- PURL url = GetRemotePartyURL();\r
- switch_caller_profile_t *caller_profile = switch_caller_profile_new(switch_core_session_get_pool(m_fsSession),\r
- url.GetUserName(),\r
- /** username */\r
- mod_opal_globals.dialplan,\r
- /** dial plan */\r
- GetRemotePartyName(),\r
- /** caller_id_name */\r
- GetRemotePartyNumber(),\r
- /** caller_id_number */\r
- url.GetHostName(),\r
- /** network addr */\r
- NULL,\r
- /** ANI */\r
- NULL,\r
- /** ANI II */\r
- NULL,\r
- /** RDNIS */\r
- ModuleName,\r
- /** source */\r
- mod_opal_globals.context,\r
- /** set context */\r
- GetCalledPartyNumber()\r
- /** destination_number */\r
- );\r
- if (caller_profile == NULL) {\r
- PTRACE(1, "mod_opal\tCould not create caller profile");\r
- return false;\r
- }\r
-\r
- PTRACE(4, "mod_opal\tCreated switch caller profile:\n"\r
- " username = " << caller_profile->username << "\n"\r
- " dialplan = " << caller_profile->dialplan << "\n"\r
- " caller_id_name = " << caller_profile->caller_id_name << "\n"\r
- " caller_id_number = " << caller_profile->caller_id_number << "\n"\r
- " network_addr = " << caller_profile->network_addr << "\n"\r
- " source = " << caller_profile->source << "\n"\r
- " context = " << caller_profile->context << "\n" " destination_number= " << caller_profile->destination_number);\r
- switch_channel_set_caller_profile(channel, caller_profile);\r
-\r
- char name[256] = "opal/in:";\r
- switch_copy_string(name + 8, caller_profile->destination_number, sizeof(name)-8);\r
- switch_channel_set_name(channel, name);\r
- switch_channel_set_state(channel, CS_INIT);\r
-\r
- if (switch_core_session_thread_launch(m_fsSession) != SWITCH_STATUS_SUCCESS) {\r
- PTRACE(1, "mod_opal\tCould not launch session thread");\r
- return false;\r
- }\r
-\r
- return true;\r
-}\r
-\r
-\r
-void FSConnection::OnReleased()\r
-{\r
- opal_private_t *tech_pvt = (opal_private_t *) switch_core_session_get_private(m_fsSession);\r
- \r
- /* so FS on_hangup will not try to deref a landmine */\r
- tech_pvt->me = NULL;\r
- \r
- m_rxAudioOpened.Signal(); // Just in case\r
- m_txAudioOpened.Signal();\r
- H225_ReleaseCompleteReason dummy;\r
- switch_channel_hangup(switch_core_session_get_channel(m_fsSession),\r
- (switch_call_cause_t)H323TranslateFromCallEndReason(GetCallEndReason(), dummy)); \r
- OpalLocalConnection::OnReleased();\r
-}\r
-\r
-\r
-void FSConnection::OnAlerting()\r
-{\r
- switch_channel_mark_ring_ready(m_fsChannel);\r
- return OpalLocalConnection::OnAlerting();\r
-}\r
-\r
-PBoolean FSConnection::SetAlerting(const PString & calleeName, PBoolean withMedia)\r
-{\r
- return OpalLocalConnection::SetAlerting(calleeName, withMedia);\r
-}\r
-\r
-\r
-void FSConnection::OnEstablished()\r
-{\r
- OpalLocalConnection::OnEstablished();\r
-}\r
-\r
-\r
-PBoolean FSConnection::SendUserInputTone(char tone, unsigned duration)\r
-{\r
- switch_dtmf_t dtmf = { tone, duration };\r
- return switch_channel_queue_dtmf(m_fsChannel, &dtmf) == SWITCH_STATUS_SUCCESS;\r
-}\r
-\r
-\r
-PBoolean FSConnection::SendUserInputString(const PString & value)\r
-{\r
- return OpalConnection::SendUserInputString(value);\r
-}\r
-\r
-\r
-OpalMediaFormatList FSConnection::GetMediaFormats() const\r
-{\r
- if (m_switchMediaFormats.IsEmpty()) {\r
- const_cast<FSConnection *>(this)->SetCodecs();\r
- }\r
- \r
- return m_switchMediaFormats;\r
-}\r
-\r
-\r
-void FSConnection::SetCodecs()\r
-{\r
- int numCodecs = 0;\r
- const switch_codec_implementation_t *codecs[SWITCH_MAX_CODECS]; \r
- const char *codec_string = NULL, *abs, *ocodec;\r
- char *tmp_codec_string = NULL;\r
- char *codec_order[SWITCH_MAX_CODECS];\r
- int codec_order_last;\r
-\r
-\r
- if ((abs = switch_channel_get_variable(m_fsChannel, "absolute_codec_string"))) {\r
- codec_string = abs;\r
- } else {\r
- if ((abs = switch_channel_get_variable(m_fsChannel, "codec_string"))) {\r
- codec_string = abs;\r
- }\r
-\r
- if ((ocodec = switch_channel_get_variable(m_fsChannel, SWITCH_ORIGINATOR_CODEC_VARIABLE))) {\r
- codec_string = switch_core_session_sprintf(m_fsSession, "%s,%s", ocodec, codec_string);\r
- }\r
- }\r
- \r
- if (!codec_string) {\r
- codec_string = mod_opal_globals.codec_string;\r
- }\r
-\r
- if (codec_string) {\r
- if ((tmp_codec_string = strdup(codec_string))) {\r
- codec_order_last = switch_separate_string(tmp_codec_string, ',', codec_order, SWITCH_MAX_CODECS);\r
- numCodecs = switch_loadable_module_get_codecs_sorted(codecs, SWITCH_MAX_CODECS, codec_order, codec_order_last);\r
- \r
- }\r
- } else {\r
- numCodecs = switch_loadable_module_get_codecs(codecs, sizeof(codecs) / sizeof(codecs[0]));\r
- }\r
- \r
- for (int i = 0; i < numCodecs; i++) {\r
- const switch_codec_implementation_t *codec = codecs[i];\r
-\r
- // See if we have a match by PayloadType/rate/name\r
- OpalMediaFormat switchFormat((RTP_DataFrame::PayloadTypes)codec->ianacode,\r
- codec->samples_per_second,\r
- codec->iananame);\r
- if (!switchFormat.IsValid()) {\r
- // See if we have a match by name alone\r
- switchFormat = codec->iananame;\r
- if (!switchFormat.IsValid()) {\r
- PTRACE(2, "mod_opal\tCould not match FS codec " << codec->iananame << " to OPAL media format.");\r
- continue;\r
- }\r
- }\r
- \r
-\r
- // Did we match or create a new media format?\r
- if (switchFormat.IsValid() && codec->codec_type == SWITCH_CODEC_TYPE_AUDIO) {\r
- PTRACE(2, "mod_opal\tMatched FS codec " << codec->iananame << " to OPAL media format " << switchFormat);\r
-\r
- // Calculate frames per packet, do not use codec->codec_frames_per_packet as that field\r
- // has slightly different semantics when used in streamed codecs such as G.711\r
- int fpp = codec->samples_per_packet/switchFormat.GetFrameTime();\r
-\r
- /* Set the frames/packet to maximum of what is in the FS table. The OPAL negotiations will\r
- drop the value from there. This might fail if there are "holes" in the FS table, e.g.\r
- if for some reason G.723.1 has 30ms and 90ms but not 60ms, then the OPAL negotiations\r
- could end up with 60ms and the codec cannot be created. The "holes" are unlikely in\r
- all but streamed codecs such as G.711, where it is theoretically possible for OPAL to\r
- come up with 32ms and there is only 30ms and 40ms in the FS table. We deem these\r
- scenarios succifiently rare that we can safely ignore them ... for now. */\r
-\r
- if (fpp > switchFormat.GetOptionInteger(OpalAudioFormat::RxFramesPerPacketOption())) {\r
- switchFormat.SetOptionInteger(OpalAudioFormat::RxFramesPerPacketOption(), fpp);\r
- }\r
-\r
- if (fpp > switchFormat.GetOptionInteger(OpalAudioFormat::TxFramesPerPacketOption())) {\r
- switchFormat.SetOptionInteger(OpalAudioFormat::TxFramesPerPacketOption(), fpp);\r
- }\r
- }\r
-\r
- m_switchMediaFormats += switchFormat;\r
- }\r
- \r
- switch_safe_free(tmp_codec_string);\r
-}\r
-\r
-\r
-OpalMediaStream *FSConnection::CreateMediaStream(const OpalMediaFormat & mediaFormat, unsigned sessionID, PBoolean isSource)\r
-{\r
- return new FSMediaStream(*this, mediaFormat, sessionID, isSource);\r
-}\r
-\r
-\r
-PBoolean FSConnection::OnOpenMediaStream(OpalMediaStream & stream)\r
-{\r
- if (!OpalConnection::OnOpenMediaStream(stream)) {\r
- return false;\r
- }\r
-\r
- if (stream.GetMediaFormat().GetMediaType() != OpalMediaType::Audio()) {\r
- return true;\r
- }\r
-\r
- if (stream.IsSource()) {\r
- m_rxAudioOpened.Signal();\r
- } else {\r
- m_txAudioOpened.Signal();\r
- }\r
-\r
- if (GetMediaStream(stream.GetSessionID(), stream.IsSink()) != NULL) {\r
- // Have open media in both directions.\r
- if (GetPhase() == AlertingPhase) {\r
- switch_channel_mark_pre_answered(m_fsChannel);\r
- } else if (GetPhase() < ReleasingPhase) {\r
- switch_channel_mark_answered(m_fsChannel);\r
- }\r
- }\r
-\r
- return true;\r
-}\r
-\r
-\r
-switch_status_t FSConnection::on_init()\r
-{\r
- switch_channel_t *channel = switch_core_session_get_channel(m_fsSession);\r
- if (channel == NULL) {\r
- return SWITCH_STATUS_FALSE;\r
- }\r
-\r
- PTRACE(3, "mod_opal\tStarted routing for connection " << *this);\r
- switch_channel_set_state(channel, CS_ROUTING);\r
- return SWITCH_STATUS_SUCCESS;\r
-}\r
-\r
-\r
-switch_status_t FSConnection::on_routing()\r
-{\r
- PTRACE(3, "mod_opal\tRouting connection " << *this);\r
- return SWITCH_STATUS_SUCCESS;\r
-}\r
-\r
-\r
-switch_status_t FSConnection::on_execute()\r
-{\r
- PTRACE(3, "mod_opal\tExecuting connection " << *this);\r
- return SWITCH_STATUS_SUCCESS;\r
-}\r
-\r
-static switch_status_t on_destroy(switch_core_session_t *session)\r
-{\r
- //switch_channel_t *channel = switch_core_session_get_channel(session);\r
- opal_private_t *tech_pvt = (opal_private_t *) switch_core_session_get_private(session);\r
- \r
- if (tech_pvt) {\r
- if (tech_pvt->read_codec.implementation) {\r
- switch_core_codec_destroy(&tech_pvt->read_codec);\r
- }\r
-\r
- if (tech_pvt->write_codec.implementation) {\r
- switch_core_codec_destroy(&tech_pvt->write_codec);\r
- }\r
-\r
- if (tech_pvt->vid_read_codec.implementation) {\r
- switch_core_codec_destroy(&tech_pvt->vid_read_codec);\r
- }\r
-\r
- if (tech_pvt->vid_write_codec.implementation) {\r
- switch_core_codec_destroy(&tech_pvt->vid_write_codec);\r
- }\r
-\r
- if (tech_pvt->read_timer.timer_interface) {\r
- switch_core_timer_destroy(&tech_pvt->read_timer);\r
- }\r
-\r
- if (tech_pvt->vid_read_timer.timer_interface) {\r
- switch_core_timer_destroy(&tech_pvt->vid_read_timer);\r
- }\r
- }\r
-\r
- return SWITCH_STATUS_SUCCESS;\r
-}\r
-\r
-/* this function has to be called with the original session beause the FSConnection might already be destroyed and we \r
- will can't have it be a method of a dead object\r
- */\r
-static switch_status_t on_hangup(switch_core_session_t *session)\r
-{\r
- switch_channel_t *channel = switch_core_session_get_channel(session);\r
- opal_private_t *tech_pvt = (opal_private_t *) switch_core_session_get_private(session);\r
- \r
- /* if this is still here it was our idea to hangup not opal's */\r
- if (tech_pvt->me) {\r
- Q931::CauseValues cause = (Q931::CauseValues)switch_channel_get_cause_q850(channel);\r
- tech_pvt->me->SetQ931Cause(cause);\r
- tech_pvt->me->ClearCallSynchronous(NULL, H323TranslateToCallEndReason(cause, UINT_MAX));\r
- tech_pvt->me = NULL;\r
- }\r
-\r
- return SWITCH_STATUS_SUCCESS;\r
-}\r
-\r
-\r
-switch_status_t FSConnection::on_exchange_media()\r
-{\r
- PTRACE(3, "mod_opal\tLoopback on connection " << *this);\r
- return SWITCH_STATUS_SUCCESS;\r
-}\r
-\r
-\r
-switch_status_t FSConnection::on_soft_execute()\r
-{\r
- PTRACE(3, "mod_opal\tTransmit on connection " << *this);\r
- return SWITCH_STATUS_SUCCESS;\r
-}\r
-\r
-\r
-switch_status_t FSConnection::kill_channel(int sig)\r
-{\r
- PTRACE(3, "mod_opal\tKill " << sig << " on connection " << *this);\r
-\r
- switch (sig) {\r
- case SWITCH_SIG_BREAK:\r
- break;\r
- case SWITCH_SIG_KILL:\r
- m_rxAudioOpened.Signal();\r
- m_txAudioOpened.Signal();\r
- break;\r
- default:\r
- break;\r
- }\r
-\r
- return SWITCH_STATUS_SUCCESS;\r
-}\r
-\r
-\r
-switch_status_t FSConnection::send_dtmf(const switch_dtmf_t *dtmf)\r
-{\r
- OnUserInputTone(dtmf->digit, dtmf->duration);\r
- return SWITCH_STATUS_SUCCESS;\r
-}\r
-\r
-\r
-switch_status_t FSConnection::receive_message(switch_core_session_message_t *msg)\r
-{\r
- switch_channel_t *channel = switch_core_session_get_channel(m_fsSession);\r
-\r
-\r
- /*\r
- SWITCH_MESSAGE_INDICATE_PROGRESS: establish early media now and return SWITCH_STATUS_FALSE if you can't\r
- SWITCH_MESSAGE_INDICATE_ANSWER: answer and set up media now if it's not already and return SWITCH_STATUS_FALSE if you can't\r
-\r
- Neither message means anything on an outbound call....\r
-\r
- It would only happen if someone called switch_channel_answer() instead of switch_channel_mark_answered() on an outbound call.\r
- it should not do anything if someone does it by accident somewhere hense this in both cases:\r
-\r
- if (switch_channel_test_flag(channel, CF_OUTBOUND)) {\r
- return SWITCH_STATUS_FALSE;\r
- }\r
-\r
-\r
- When we get these messages the core will trust that you have triggered FSMediaStream::Open and are ready for media if we do not\r
- have media we MUST return SWITCH_STATUS_FALSE or it will cause a CRASH.\r
-\r
-\r
-\r
- */\r
- switch (msg->message_id) {\r
- case SWITCH_MESSAGE_INDICATE_BRIDGE:\r
- case SWITCH_MESSAGE_INDICATE_UNBRIDGE:\r
- case SWITCH_MESSAGE_INDICATE_AUDIO_SYNC:\r
- switch_channel_set_private_flag(channel, CF_NEED_FLUSH);\r
- break;\r
-\r
- case SWITCH_MESSAGE_INDICATE_RINGING:\r
- case SWITCH_MESSAGE_INDICATE_PROGRESS:\r
- case SWITCH_MESSAGE_INDICATE_ANSWER:\r
- {\r
- switch_caller_profile_t * profile = switch_channel_get_caller_profile(channel);\r
- if (profile != NULL && profile->caller_extension != NULL)\r
- {\r
- PSafePtr<OpalConnection> other = GetOtherPartyConnection();\r
- if (other != NULL) {\r
- other->SetLocalPartyName(profile->caller_extension->extension_number);\r
- other->SetDisplayName(profile->caller_extension->extension_name);\r
- }\r
- SetLocalPartyName(profile->caller_extension->extension_number);\r
- SetDisplayName(profile->caller_extension->extension_name);\r
- }\r
- }\r
- break;\r
-\r
- default:\r
- break;\r
- }\r
-\r
- switch (msg->message_id) {\r
- case SWITCH_MESSAGE_INDICATE_RINGING:\r
- SetPhase(OpalConnection::AlertingPhase);\r
- OnAlerting();\r
- break;\r
-\r
- case SWITCH_MESSAGE_INDICATE_DEFLECT:\r
- {\r
- PSafePtr<OpalConnection> other = GetOtherPartyConnection();\r
- if (other != NULL)\r
- other->TransferConnection(msg->string_arg);\r
- break;\r
- }\r
-\r
- case SWITCH_MESSAGE_INDICATE_PROGRESS:\r
- case SWITCH_MESSAGE_INDICATE_ANSWER:\r
- {\r
- int fixed = 0;\r
- \r
- if (switch_channel_test_flag(channel, CF_OUTBOUND)) {\r
- return SWITCH_STATUS_FALSE;\r
- }\r
-\r
- if (msg->message_id == SWITCH_MESSAGE_INDICATE_PROGRESS) {\r
- if (fixed) {\r
- /* this should send alerting + media and wait for it to be established and return SUCCESS or FAIL\r
- depending on if media was able to be established. Need code to tell the other side we want early media here.\r
- */\r
- GetCall().OpenSourceMediaStreams(*this, OpalMediaType::Audio());\r
- SetPhase(OpalConnection::AlertingPhase);\r
- /* how do i say please establish early media ? */\r
- OnAlerting();\r
- } else {\r
- /* hack to avoid getting stuck, pre_answer will imply answer */\r
- OnConnectedInternal();\r
- }\r
- } else {\r
- OnConnectedInternal();\r
- }\r
-\r
- // Wait for media\r
- PTRACE(2, "mod_opal\tAwaiting media start on connection " << *this);\r
- m_rxAudioOpened.Wait();\r
- m_txAudioOpened.Wait();\r
- \r
- if (GetPhase() >= ReleasingPhase) {\r
- // Call got aborted\r
- switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(m_fsSession), SWITCH_LOG_ERROR, "Call abandoned!\n");\r
- return SWITCH_STATUS_FALSE;\r
- }\r
-\r
- PTRACE(4, "mod_opal\tMedia started on connection " << *this);\r
-\r
- if (msg->message_id == SWITCH_MESSAGE_INDICATE_PROGRESS) {\r
- if (!switch_channel_test_flag(m_fsChannel, CF_EARLY_MEDIA)) {\r
- switch_channel_mark_pre_answered(m_fsChannel);\r
- }\r
- } else {\r
- if (!switch_channel_test_flag(m_fsChannel, CF_EARLY_MEDIA)) {\r
- switch_channel_mark_answered(m_fsChannel);\r
- }\r
- }\r
-\r
- }\r
- break;\r
-\r
- default:\r
- PTRACE(3, "mod_opal\tReceived message " << msg->message_id << " on connection " << *this);\r
- }\r
-\r
- return SWITCH_STATUS_SUCCESS;\r
-}\r
-\r
-\r
-switch_status_t FSConnection::receive_event(switch_event_t *event)\r
-{\r
- PTRACE(3, "mod_opal\tReceived event " << event->event_id << " on connection " << *this);\r
- return SWITCH_STATUS_SUCCESS;\r
-}\r
-\r
-\r
-switch_status_t FSConnection::state_change()\r
-{\r
- PTRACE(3, "mod_opal\tState changed on connection " << *this);\r
- return SWITCH_STATUS_SUCCESS;\r
-}\r
-\r
-\r
-switch_status_t FSConnection::read_audio_frame(switch_frame_t **frame, switch_io_flag_t flags, int stream_id)\r
-{\r
- return read_frame(OpalMediaType::Audio(), frame, flags);\r
-}\r
-\r
-\r
-switch_status_t FSConnection::write_audio_frame(switch_frame_t *frame, switch_io_flag_t flags, int stream_id)\r
-{\r
- return write_frame(OpalMediaType::Audio(), frame, flags);\r
-}\r
-\r
-\r
-switch_status_t FSConnection::read_video_frame(switch_frame_t **frame, switch_io_flag_t flag, int stream_id)\r
-{\r
- return read_frame(OpalMediaType::Video(), frame, flag);\r
-}\r
-\r
-\r
-switch_status_t FSConnection::write_video_frame(switch_frame_t *frame, switch_io_flag_t flag, int stream_id)\r
-{\r
- return write_frame(OpalMediaType::Video(), frame, flag);\r
-}\r
-\r
-\r
-switch_status_t FSConnection::read_frame(const OpalMediaType & mediaType, switch_frame_t **frame, switch_io_flag_t flags)\r
-{\r
- PSafePtr < FSMediaStream > stream = PSafePtrCast < OpalMediaStream, FSMediaStream > (GetMediaStream(mediaType, false));\r
- return stream != NULL ? stream->read_frame(frame, flags) : SWITCH_STATUS_FALSE;\r
-}\r
-\r
-\r
-switch_status_t FSConnection::write_frame(const OpalMediaType & mediaType, const switch_frame_t *frame, switch_io_flag_t flags)\r
-{\r
- PSafePtr < FSMediaStream > stream = PSafePtrCast < OpalMediaStream, FSMediaStream > (GetMediaStream(mediaType, true));\r
- return stream != NULL ? stream->write_frame(frame, flags) : SWITCH_STATUS_FALSE;\r
-}\r
-\r
-\r
-///////////////////////////////////////////////////////////////////////\r
-\r
-FSMediaStream::FSMediaStream(FSConnection & conn, const OpalMediaFormat & mediaFormat, unsigned sessionID, bool isSource)\r
- : OpalMediaStream(conn, mediaFormat, sessionID, isSource)\r
- , m_fsSession(conn.GetSession())\r
- , m_readRTP(0, 512)\r
- , m_callOnStart(true)\r
-{\r
- memset(&m_readFrame, 0, sizeof(m_readFrame));\r
- m_readFrame.codec = m_switchCodec;\r
- m_readFrame.flags = SFF_RAW_RTP;\r
-}\r
-\r
-\r
-PBoolean FSMediaStream::Open()\r
-{\r
- opal_private_t *tech_pvt = (opal_private_t *) switch_core_session_get_private(m_fsSession);\r
-\r
- if (IsOpen()) {\r
- return true;\r
- }\r
-\r
- bool isAudio;\r
- if (mediaFormat.GetMediaType() == OpalMediaType::Audio()) {\r
- isAudio = true;\r
- } else if (mediaFormat.GetMediaType() == OpalMediaType::Video()) {\r
- isAudio = false;\r
- } else {\r
- return OpalMediaStream::Open();\r
- }\r
-\r
- m_fsChannel = switch_core_session_get_channel(m_fsSession);\r
- \r
- int ptime = mediaFormat.GetOptionInteger(OpalAudioFormat::TxFramesPerPacketOption()) * mediaFormat.GetFrameTime() / mediaFormat.GetTimeUnits();\r
-\r
-\r
- if (IsSink()) {\r
- m_switchCodec = isAudio ? &tech_pvt->read_codec : &tech_pvt->vid_read_codec;\r
- m_switchTimer = isAudio ? &tech_pvt->read_timer : &tech_pvt->vid_read_timer;\r
- } else {\r
- m_switchCodec = isAudio ? &tech_pvt->write_codec : &tech_pvt->vid_write_codec;\r
- }\r
-\r
- // The following is performed on two different instances of this object.\r
- if (switch_core_codec_init(m_switchCodec, mediaFormat.GetEncodingName(), NULL, // FMTP\r
- mediaFormat.GetClockRate(), ptime, 1, // Channels\r
- SWITCH_CODEC_FLAG_ENCODE | SWITCH_CODEC_FLAG_DECODE, NULL, // Settings\r
- switch_core_session_get_pool(m_fsSession)) != SWITCH_STATUS_SUCCESS) {\r
- // Could not select a codecs using negotiated frames/packet, so try using default.\r
- if (switch_core_codec_init(m_switchCodec, mediaFormat.GetEncodingName(), NULL, // FMTP\r
- mediaFormat.GetClockRate(), 0, 1, // Channels\r
- SWITCH_CODEC_FLAG_ENCODE | SWITCH_CODEC_FLAG_DECODE, NULL, // Settings\r
- switch_core_session_get_pool(m_fsSession)) != SWITCH_STATUS_SUCCESS) {\r
- PTRACE(1, "mod_opal " << switch_channel_get_name(m_fsChannel)<< " Cannot initialise " << (IsSink()? "read" : "write") << ' '\r
- << mediaFormat.GetMediaType() << " codec " << mediaFormat << " for connection " << *this);\r
- switch_channel_hangup(m_fsChannel, SWITCH_CAUSE_INCOMPATIBLE_DESTINATION);\r
- return false;\r
- }\r
- PTRACE(2, "mod_opal " << switch_channel_get_name(m_fsChannel)<< " Unsupported ptime of " << ptime << " on " << (IsSink()? "read" : "write") << ' '\r
- << mediaFormat.GetMediaType() << " codec " << mediaFormat << " for connection " << *this);\r
- }\r
-\r
- PTRACE(1, "mod_opal " << switch_channel_get_name(m_fsChannel)<< " initialise " << \r
- switch_channel_get_name(m_fsChannel) << (IsSink()? "read" : "write") << ' '\r
- << mediaFormat.GetMediaType() << " codec " << mediaFormat << " for connection " << *this);\r
-\r
- if (IsSink()) {\r
- m_readFrame.rate = mediaFormat.GetClockRate();\r
-\r
- if (isAudio) {\r
- switch_core_session_set_read_codec(m_fsSession, m_switchCodec);\r
- if (switch_core_timer_init(m_switchTimer,\r
- "soft",\r
- m_switchCodec->implementation->microseconds_per_packet / 1000,\r
- m_switchCodec->implementation->samples_per_packet,\r
- switch_core_session_get_pool(m_fsSession)) != SWITCH_STATUS_SUCCESS) {\r
- switch_core_codec_destroy(m_switchCodec);\r
- m_switchCodec = NULL;\r
- return false;\r
- }\r
- } else {\r
- switch_core_session_set_video_read_codec(m_fsSession, m_switchCodec);\r
- switch_channel_set_flag(m_fsChannel, CF_VIDEO);\r
- }\r
- } else {\r
- if (isAudio) {\r
- switch_core_session_set_write_codec(m_fsSession, m_switchCodec);\r
- } else {\r
- switch_core_session_set_video_write_codec(m_fsSession, m_switchCodec);\r
- switch_channel_set_flag(m_fsChannel, CF_VIDEO);\r
- }\r
- }\r
-\r
- PTRACE(3, "mod_opal\tSet " << (IsSink()? "read" : "write") << ' '\r
- << mediaFormat.GetMediaType() << " codec to << " << mediaFormat << " for connection " << *this);\r
-\r
- return OpalMediaStream::Open();\r
-}\r
-\r
-\r
-PBoolean FSMediaStream::Close()\r
-{\r
- if (!IsOpen())\r
- return false;\r
-\r
- /* forget these FS will properly destroy them for us */\r
-\r
- m_switchTimer = NULL;\r
- m_switchCodec = NULL;\r
-\r
- return OpalMediaStream::Close();\r
-}\r
-\r
-\r
-PBoolean FSMediaStream::IsSynchronous() const\r
-{\r
- return true;\r
-}\r
-\r
-\r
-PBoolean FSMediaStream::RequiresPatchThread(OpalMediaStream *) const\r
-{\r
- return false;\r
-}\r
-\r
-bool FSMediaStream::CheckPatchAndLock()\r
-{\r
- if (GetConnection().GetPhase() >= GetConnection().ReleasingPhase || !IsOpen())\r
- return false;\r
-\r
- if (LockReadWrite()) {\r
- if (!GetPatch() || !IsOpen()) {\r
- UnlockReadWrite();\r
- return false;\r
- }\r
- return true;\r
- } else {\r
- return false;\r
- }\r
-}\r
-\r
-switch_status_t FSMediaStream::read_frame(switch_frame_t **frame, switch_io_flag_t flags)\r
-{\r
-\r
- if (!m_switchCodec) {\r
- return SWITCH_STATUS_FALSE;\r
- }\r
-\r
- if (m_callOnStart) {\r
- /*\r
- There is a race here... sometimes we make it here and GetPatch() is NULL\r
- if we wait it shows up in 1ms, maybe there is a better way to wait.\r
- \r
- */\r
- while(!GetPatch()) {\r
- if (!m_fsChannel || !switch_channel_up(m_fsChannel)) {\r
- return SWITCH_STATUS_FALSE;\r
- }\r
- switch_cond_next();\r
- }\r
- if (CheckPatchAndLock()) {\r
- GetPatch()->OnStartMediaPatch();\r
- m_callOnStart = false;\r
- UnlockReadWrite();\r
- } else {\r
- return SWITCH_STATUS_FALSE; \r
- }\r
- }\r
-\r
- m_readFrame.flags = 0;\r
-\r
- /*\r
- while (switch_channel_ready(m_fsChannel)) {\r
- if (CheckPatchAndLock()) {\r
- if (!GetPatch()->GetSource().ReadPacket(m_readRTP)) {\r
- UnlockReadWrite();\r
- return SWITCH_STATUS_FALSE;\r
- } \r
- UnlockReadWrite();\r
- } else {\r
- return SWITCH_STATUS_FALSE; \r
- }\r
- \r
- if ((m_readFrame.datalen = m_readRTP.GetPayloadSize()) || switch_core_timer_check(&m_switchTimer, SWITCH_FALSE) == SWITCH_STATUS_SUCCESS) {\r
- if (m_readFrame.datalen) {\r
- } else {\r
- m_readFrame.flags = SFF_CNG;\r
- }\r
- break;\r
- }\r
-\r
- switch_yield(1000);\r
- }\r
- */\r
-\r
- if (switch_channel_test_private_flag(m_fsChannel, CF_NEED_FLUSH)) {\r
- switch_channel_clear_private_flag(m_fsChannel, CF_NEED_FLUSH);\r
- for(;;) {\r
- if (CheckPatchAndLock()) {\r
- if (!GetPatch()->GetSource().ReadPacket(m_readRTP)) {\r
- UnlockReadWrite();\r
- return SWITCH_STATUS_FALSE;\r
- } \r
- UnlockReadWrite();\r
- } else {\r
- return SWITCH_STATUS_FALSE; \r
- }\r
-\r
- if (!m_readRTP.GetPayloadSize()) {\r
- m_readFrame.flags = SFF_CNG;\r
- break;\r
- }\r
- }\r
- } else {\r
-\r
- if (CheckPatchAndLock()) {\r
- if (!m_switchTimer || !GetPatch()->GetSource().ReadPacket(m_readRTP)) {\r
- UnlockReadWrite();\r
- return SWITCH_STATUS_FALSE;\r
- } \r
- UnlockReadWrite();\r
- } else {\r
- return SWITCH_STATUS_FALSE; \r
- }\r
- \r
- switch_core_timer_next(m_switchTimer);\r
- \r
- if (!(m_readFrame.datalen = m_readRTP.GetPayloadSize())) {\r
- m_readFrame.flags = SFF_CNG;\r
- }\r
- }\r
-\r
- if (!switch_channel_ready(m_fsChannel)) {\r
- return SWITCH_STATUS_FALSE;\r
- }\r
-\r
- if (!switch_core_codec_ready(m_switchCodec)) {\r
- return SWITCH_STATUS_FALSE;\r
- }\r
-\r
- //switch_core_timer_step(&m_switchTimer);\r
-\r
- if (m_readFrame.payload == RTP_DataFrame::CN || m_readFrame.payload == RTP_DataFrame::Cisco_CN) {\r
- m_readFrame.flags = SFF_CNG;\r
- }\r
-\r
- if (m_readFrame.flags & SFF_CNG) {\r
- m_readFrame.buflen = sizeof(m_buf);\r
- m_readFrame.data = m_buf;\r
- m_readFrame.packet = NULL;\r
- m_readFrame.packetlen = 0;\r
- m_readFrame.timestamp = 0;\r
- m_readFrame.m = SWITCH_FALSE;\r
- m_readFrame.seq = 0;\r
- m_readFrame.ssrc = 0;\r
- m_readFrame.codec = m_switchCodec;\r
- } else {\r
- m_readFrame.buflen = m_readRTP.GetSize();\r
- m_readFrame.data = m_readRTP.GetPayloadPtr();\r
- m_readFrame.packet = m_readRTP.GetPointer();\r
- m_readFrame.packetlen = m_readRTP.GetHeaderSize() + m_readFrame.datalen;\r
- m_readFrame.payload = (switch_payload_t) m_readRTP.GetPayloadType();\r
- m_readFrame.timestamp = m_readRTP.GetTimestamp();\r
- m_readFrame.m = (switch_bool_t) m_readRTP.GetMarker();\r
- m_readFrame.seq = m_readRTP.GetSequenceNumber();\r
- m_readFrame.ssrc = m_readRTP.GetSyncSource();\r
- m_readFrame.codec = m_switchCodec;\r
- }\r
-\r
- *frame = &m_readFrame;\r
-\r
- return SWITCH_STATUS_SUCCESS;\r
-}\r
-\r
-\r
-switch_status_t FSMediaStream::write_frame(const switch_frame_t *frame, switch_io_flag_t flags)\r
-{\r
- if (!switch_channel_ready(m_fsChannel)) {\r
- return SWITCH_STATUS_FALSE;\r
- }\r
-\r
- if (m_callOnStart) {\r
- if (CheckPatchAndLock()) {\r
- GetPatch()->OnStartMediaPatch();\r
- m_callOnStart = false;\r
- UnlockReadWrite();\r
- } else {\r
- return SWITCH_STATUS_FALSE; \r
- }\r
- }\r
-\r
- if ((frame->flags & SFF_CNG)) {\r
- return SWITCH_STATUS_SUCCESS;\r
- }\r
-\r
- if ((frame->flags & SFF_RAW_RTP) != 0) {\r
- RTP_DataFrame rtp((const BYTE *) frame->packet, frame->packetlen, false);\r
-\r
- if (CheckPatchAndLock()) {\r
- if (GetPatch()->PushFrame(rtp)) {\r
- UnlockReadWrite();\r
- return SWITCH_STATUS_SUCCESS;\r
- }\r
- UnlockReadWrite();\r
- } else {\r
- return SWITCH_STATUS_FALSE; \r
- }\r
- } \r
- \r
- /* If we reach this code it means a call to an ivr or something else that does not generate timestamps\r
- Its possible that frame->timestamp is set but not guarenteed and is best ignored for the time being.\r
- We are probably relying on the rtp stack to generate the timestamp and ssrc for us at this point.\r
- As a quick hack I am going to keep a sample counter and increment it by frame->samples but it would be \r
- better if we could engage whatever it is in opal that makes it generate the timestamp.\r
- */\r
-\r
- RTP_DataFrame rtp(frame->datalen);\r
- rtp.SetPayloadType(mediaFormat.GetPayloadType());\r
-\r
- m_timeStamp += frame->samples;\r
- rtp.SetTimestamp(m_timeStamp);\r
- \r
- //rtp.SetTimestamp(frame->timestamp);\r
- //rtp.SetSyncSource(frame->ssrc);\r
- //rtp.SetMarker(frame->m);\r
-\r
- memcpy(rtp.GetPayloadPtr(), frame->data, frame->datalen);\r
-\r
- if (CheckPatchAndLock()) {\r
- if (GetPatch()->PushFrame(rtp)) {\r
- UnlockReadWrite();\r
- return SWITCH_STATUS_SUCCESS;\r
- }\r
- UnlockReadWrite();\r
- } else {\r
- return SWITCH_STATUS_FALSE; \r
- }\r
-\r
-\r
- return SWITCH_STATUS_FALSE;\r
-}\r
-\r
-\r
-/* For Emacs:\r
- * Local Variables:\r
- * mode:c\r
- * indent-tabs-mode:nil\r
- * tab-width:4\r
- * c-basic-offset:4\r
- * End:\r
- * For VIM:\r
- * vim:set softtabstop=4 shiftwidth=4 tabstop=4:s:\r
- */\r
+/* Opal endpoint interface for Freeswitch Modular Media Switching Software Library /
+ * Soft-Switch Application
+ *
+ * Version: MPL 1.1
+ *
+ * Copyright (c) 2007 Tuyan Ozipek (tuyanozipek@gmail.com)
+ *
+ * The contents of this file are subject to the Mozilla Public License Version
+ * 1.1 (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ * http://www.mozilla.org/MPL/
+ *
+ * Software distributed under the License is distributed on an "AS IS" basis,
+ * WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
+ * for the specific language governing rights and limitations under the
+ * License.
+ *
+ * Contributor(s):
+ * Tuyan Ozipek (tuyanozipek@gmail.com)
+ * Lukasz Zwierko (lzwierko@gmail.com)
+ * Robert Jongbloed (robertj@voxlucida.com.au)
+ *
+ */
+
+#include "mod_opal.h"
+#include <opal/patch.h>
+#include <rtp/rtp.h>
+#include <h323/h323pdu.h>
+#include <h323/gkclient.h>
+
+SWITCH_DECLARE_GLOBAL_STRING_FUNC(set_global_codec_string, mod_opal_globals.codec_string);
+SWITCH_DECLARE_GLOBAL_STRING_FUNC(set_global_context, mod_opal_globals.context);
+SWITCH_DECLARE_GLOBAL_STRING_FUNC(set_global_dialplan, mod_opal_globals.dialplan);
+
+
+#define CF_NEED_FLUSH (1 << 1)
+
+struct mod_opal_globals mod_opal_globals = { 0 };
+
+
+static switch_call_cause_t create_outgoing_channel(switch_core_session_t *session, switch_event_t *var_event,
+ switch_caller_profile_t *outbound_profile, switch_core_session_t **new_session,
+ switch_memory_pool_t **pool, switch_originate_flag_t flags);
+
+
+static FSProcess *opal_process = NULL;
+
+
+static const char ModuleName[] = "opal";
+
+
+static switch_status_t on_hangup(switch_core_session_t *session);
+static switch_status_t on_destroy(switch_core_session_t *session);
+
+
+static switch_io_routines_t opalfs_io_routines = {
+ /*.outgoing_channel */ create_outgoing_channel,
+ /*.read_frame */ FSConnection::read_audio_frame,
+ /*.write_frame */ FSConnection::write_audio_frame,
+ /*.kill_channel */ FSConnection::kill_channel,
+ /*.send_dtmf */ FSConnection::send_dtmf,
+ /*.receive_message */ FSConnection::receive_message,
+ /*.receive_event */ FSConnection::receive_event,
+ /*.state_change */ FSConnection::state_change,
+ /*.read_video_frame */ FSConnection::read_video_frame,
+ /*.write_video_frame */ FSConnection::write_video_frame
+};
+
+static switch_state_handler_table_t opalfs_event_handlers = {
+ /*.on_init */ FSConnection::on_init,
+ /*.on_routing */ FSConnection::on_routing,
+ /*.on_execute */ FSConnection::on_execute,
+ /*.on_hangup */ on_hangup,
+ /*.on_exchange_media */ FSConnection::on_exchange_media,
+ /*.on_soft_execute */ FSConnection::on_soft_execute,
+ /*.on_consume_media*/ NULL,
+ /*.on_hibernate*/ NULL,
+ /*.on_reset*/ NULL,
+ /*.on_park*/ NULL,
+ /*.on_reporting*/ NULL,
+ /*.on_destroy*/ on_destroy
+};
+
+
+SWITCH_BEGIN_EXTERN_C
+/*******************************************************************************/
+
+SWITCH_MODULE_LOAD_FUNCTION(mod_opal_load);
+SWITCH_MODULE_SHUTDOWN_FUNCTION(mod_opal_shutdown);
+SWITCH_MODULE_DEFINITION(mod_opal, mod_opal_load, mod_opal_shutdown, NULL);
+
+SWITCH_MODULE_LOAD_FUNCTION(mod_opal_load) {
+ switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CONSOLE, "Starting loading mod_opal\n");
+
+ /* Prevent the loading of OPAL codecs via "plug ins", this is a directory
+ full of DLLs that will be loaded automatically. */
+ putenv((char *)"PTLIBPLUGINDIR=/no/thanks");
+
+
+ *module_interface = switch_loadable_module_create_module_interface(pool, modname);
+ if (!*module_interface) {
+ return SWITCH_STATUS_MEMERR;
+ }
+
+ opal_process = new FSProcess();
+ if (opal_process == NULL) {
+ return SWITCH_STATUS_MEMERR;
+ }
+
+ if (opal_process->Initialise(*module_interface)) {
+ switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CONSOLE, "Opal manager initialized and running\n");
+ //unloading causes a seg in linux
+ return SWITCH_STATUS_NOUNLOAD;
+ //return SWITCH_STATUS_SUCCESS;
+ }
+
+ delete opal_process;
+ opal_process = NULL;
+ return SWITCH_STATUS_FALSE;
+}
+
+
+SWITCH_MODULE_SHUTDOWN_FUNCTION(mod_opal_shutdown) {
+
+ switch_safe_free(mod_opal_globals.context);
+ switch_safe_free(mod_opal_globals.dialplan);
+ switch_safe_free(mod_opal_globals.codec_string);
+ delete opal_process;
+ opal_process = NULL;
+ return SWITCH_STATUS_SUCCESS;
+}
+
+SWITCH_END_EXTERN_C
+/*******************************************************************************/
+
+
+
+static switch_call_cause_t create_outgoing_channel(switch_core_session_t *session,
+ switch_event_t *var_event,
+ switch_caller_profile_t *outbound_profile,
+ switch_core_session_t **new_session, switch_memory_pool_t **pool, switch_originate_flag_t flags)
+{
+ if (opal_process == NULL) {
+ return SWITCH_CAUSE_CRASH;
+ }
+
+ PString token;
+
+ FSManager & manager = opal_process->GetManager();
+ if (!manager.SetUpCall("local:", outbound_profile->destination_number, token, outbound_profile)) {
+ return SWITCH_CAUSE_INVALID_NUMBER_FORMAT;
+ }
+
+ PSafePtr < OpalCall > call = manager.FindCallWithLock(token);
+
+ if (call == NULL) {
+ return SWITCH_CAUSE_PROTOCOL_ERROR;
+ }
+
+ PSafePtr < FSConnection > connection = call->GetConnectionAs < FSConnection > (0);
+
+ if (connection == NULL) {
+ return SWITCH_CAUSE_PROTOCOL_ERROR;
+ }
+
+ *new_session = connection->GetSession();
+
+ return SWITCH_CAUSE_SUCCESS;
+}
+
+
+///////////////////////////////////////////////////////////////////////
+
+#if PTRACING
+
+class FSTrace : public ostream {
+ public:
+ FSTrace()
+ : ostream(&buffer)
+ {
+ }
+
+ private:
+ class Buffer : public streambuf {
+ char buffer[250];
+
+ public:
+ Buffer()
+ {
+ setg(buffer, buffer, &buffer[sizeof(buffer)-2]);
+ setp(buffer, &buffer[sizeof(buffer)-2]);
+ }
+
+ virtual int sync()
+ {
+ return overflow(EOF);
+ }
+
+ virtual int underflow()
+ {
+ return EOF;
+ }
+
+ virtual int overflow(int c)
+ {
+ const char *fmt = "%s";
+ char *func = NULL;
+
+ int bufSize = pptr() - pbase();
+
+ if (c != EOF) {
+ *pptr() = (char)c;
+ bufSize++;
+ }
+
+ if (bufSize != 0) {
+ char *bufPtr = pbase();
+ char *bufEndPtr = NULL;
+ setp(bufPtr, epptr());
+ bufPtr[bufSize] = '\0';
+ int line = 0;
+ char *p;
+
+ char *file = NULL;
+ switch_log_level_t level;
+
+
+ switch (strtoul(bufPtr, &file, 10)) {
+ case 1 :
+ level = SWITCH_LOG_INFO;
+ break;
+ default :
+ level = SWITCH_LOG_DEBUG;
+ break;
+ }
+
+ if (file) {
+ while (isspace(*file)) file++;
+
+ if (file && (bufPtr = strchr(file, '(')) && (bufEndPtr = strchr(bufPtr, ')'))) {
+ char *e;
+
+ for(p = bufPtr; p && *p; p++) {
+ if (*p == '\t') {
+ *p = ' ';
+ }
+ }
+
+ *bufPtr++ = '\0';
+ line = atoi(bufPtr);
+ while (bufEndPtr && isspace(*(++bufEndPtr)));
+ bufPtr = bufEndPtr;
+ if (bufPtr && (e = strchr(bufPtr, ' ')) || (e = strchr(bufPtr, '\t'))) {
+ func = bufPtr;
+ bufPtr = e;
+ *bufPtr++ = '\0';
+ }
+ }
+ }
+
+ switch_text_channel_t tchannel = SWITCH_CHANNEL_ID_LOG;
+
+ if (!bufPtr) {
+ bufPtr = pbase();
+ level = SWITCH_LOG_DEBUG;
+ }
+
+ if (bufPtr) {
+ if (end_of(bufPtr) != '\n') {
+ fmt = "%s\n";
+ }
+ if (!(file && func && line)) tchannel = SWITCH_CHANNEL_ID_LOG_CLEAN;
+
+ switch_log_printf(tchannel, file, func, line, NULL, level, fmt, bufPtr);
+ }
+
+ }
+
+ return 0;
+ }
+ } buffer;
+};
+
+#endif
+
+
+///////////////////////////////////////////////////////////////////////
+
+FSProcess::FSProcess()
+ : PLibraryProcess("Vox Lucida Pty. Ltd.", "mod_opal", 1, 0, AlphaCode, 1)
+ , m_manager(NULL)
+{
+}
+
+
+FSProcess::~FSProcess()
+{
+ delete m_manager;
+}
+
+
+bool FSProcess::Initialise(switch_loadable_module_interface_t *iface)
+{
+ m_manager = new FSManager();
+ return m_manager != NULL && m_manager->Initialise(iface);
+}
+
+
+///////////////////////////////////////////////////////////////////////
+
+FSManager::FSManager()
+{
+ // These are deleted by the OpalManager class, no need to have destructor
+ m_h323ep = new H323EndPoint(*this);
+ m_iaxep = new IAX2EndPoint(*this);
+ m_fsep = new FSEndPoint(*this);
+}
+
+
+bool FSManager::Initialise(switch_loadable_module_interface_t *iface)
+{
+ ReadConfig(false);
+
+#if PTRACING
+ PTrace::SetLevel(mod_opal_globals.trace_level); //just for fun and eyecandy ;)
+ PTrace::SetOptions(PTrace::TraceLevel);
+ PTrace::SetStream(new FSTrace);
+#endif
+
+ m_FreeSwitch = (switch_endpoint_interface_t *) switch_loadable_module_create_interface(iface, SWITCH_ENDPOINT_INTERFACE);
+ m_FreeSwitch->interface_name = ModuleName;
+ m_FreeSwitch->io_routines = &opalfs_io_routines;
+ m_FreeSwitch->state_handler = &opalfs_event_handlers;
+
+ silenceDetectParams.m_mode = OpalSilenceDetector::NoSilenceDetection;
+
+ if (m_listeners.empty()) {
+ m_h323ep->StartListener("");
+ } else {
+ for (std::list < FSListener >::iterator it = m_listeners.begin(); it != m_listeners.end(); ++it) {
+ if (!m_h323ep->StartListener(it->listenAddress)) {
+ PTRACE(3, "mod_opal\tCannot start listener for " << it->name);
+ }
+ }
+ }
+
+ AddRouteEntry("h323:.* = local:<da>"); // config option for direct routing
+ AddRouteEntry("iax2:.* = local:<da>"); // config option for direct routing
+ AddRouteEntry("local:.* = h323:<da>"); // config option for direct routing
+
+ // Make sure all known codecs are instantiated,
+ // these are ones we know how to translate into H.323 capabilities
+ GetOpalG728();
+ GetOpalG729();
+ GetOpalG729A();
+ GetOpalG729B();
+ GetOpalG729AB();
+ GetOpalG7231_6k3();
+ GetOpalG7231_5k3();
+ GetOpalG7231A_6k3();
+ GetOpalG7231A_5k3();
+ GetOpalGSM0610();
+ GetOpalGSMAMR();
+ GetOpaliLBC();
+
+ /* For compatibility with the algorithm in FSConnection::SetCodecs() we need
+ to set all audio media formats to be 1 frame per packet */
+ OpalMediaFormatList allCodecs = OpalMediaFormat::GetAllRegisteredMediaFormats();
+ for (OpalMediaFormatList::iterator it = allCodecs.begin(); it != allCodecs.end(); ++it) {
+ if (it->GetMediaType() == OpalMediaType::Audio()) {
+ it->SetOptionInteger(OpalAudioFormat::RxFramesPerPacketOption(), 1);
+ it->SetOptionInteger(OpalAudioFormat::TxFramesPerPacketOption(), 1);
+ }
+ }
+
+ if (!m_gkAddress.IsEmpty()) {
+ if (m_h323ep->UseGatekeeper(m_gkAddress, m_gkIdentifer, m_gkInterface))
+ switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Started gatekeeper: %s\n",
+ (const char *)m_h323ep->GetGatekeeper()->GetName());
+ else
+ switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR,
+ "Could not start gatekeeper: addr=\"%s\", id=\"%s\", if=\"%s\"\n",
+ (const char *)m_gkAddress,
+ (const char *)m_gkIdentifer,
+ (const char *)m_gkInterface);
+ }
+
+ return TRUE;
+}
+
+
+switch_status_t FSManager::ReadConfig(int reload)
+{
+ const char *cf = "opal.conf";
+ switch_status_t status = SWITCH_STATUS_SUCCESS;
+
+ switch_memory_pool_t *pool = NULL;
+ if ((status = switch_core_new_memory_pool(&pool)) != SWITCH_STATUS_SUCCESS) {
+ switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CRIT, "Memory Error!\n");
+ return status;
+ }
+
+ set_global_context("default");
+ set_global_dialplan("XML");
+
+ switch_event_t *params = NULL;
+ switch_event_create(¶ms, SWITCH_EVENT_REQUEST_PARAMS);
+ switch_assert(params);
+ switch_event_add_header_string(params, SWITCH_STACK_BOTTOM, "profile", switch_str_nil(""));
+ switch_xml_t cfg;
+ switch_xml_t xml = switch_xml_open_cfg(cf, &cfg, params);
+ if (xml == NULL) {
+ switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "open of %s failed\n", cf);
+ return SWITCH_STATUS_FALSE;
+ }
+
+ switch_xml_t xmlSettings = switch_xml_child(cfg, "settings");
+ if (xmlSettings) {
+ for (switch_xml_t xmlParam = switch_xml_child(xmlSettings, "param"); xmlParam != NULL; xmlParam = xmlParam->next) {
+ const char *var = switch_xml_attr_soft(xmlParam, "name");
+ const char *val = switch_xml_attr_soft(xmlParam, "value");
+
+ if (!strcasecmp(var, "trace-level")) {
+ int level = atoi(val);
+ if (level > 0) {
+ mod_opal_globals.trace_level = level;
+ }
+ } else if (!strcasecmp(var, "context")) {
+ set_global_context(val);
+ } else if (!strcasecmp(var, "dialplan")) {
+ set_global_dialplan(val);
+ } else if (!strcasecmp(var, "codec-prefs")) {
+ set_global_codec_string(val);
+ } else if (!strcasecmp(var, "jitter-size")) {
+ char * next;
+ unsigned minJitter = strtoul(val, &next, 10);
+ if (minJitter >= 10) {
+ unsigned maxJitter = minJitter;
+ if (*next == ',')
+ maxJitter = atoi(next+1);
+ SetAudioJitterDelay(minJitter, maxJitter); // In milliseconds
+ }
+ } else if (!strcasecmp(var, "gk-address")) {
+ m_gkAddress = val;
+ } else if (!strcasecmp(var, "gk-identifer")) {
+ m_gkIdentifer = val;
+ } else if (!strcasecmp(var, "gk-interface")) {
+ m_gkInterface = val;
+ }
+ }
+ }
+
+ switch_xml_t xmlListeners = switch_xml_child(cfg, "listeners");
+ if (xmlListeners != NULL) {
+ for (switch_xml_t xmlListener = switch_xml_child(xmlListeners, "listener"); xmlListener != NULL; xmlListener = xmlListener->next) {
+
+ m_listeners.push_back(FSListener());
+ FSListener & listener = m_listeners.back();
+
+ listener.name = switch_xml_attr_soft(xmlListener, "name");
+ if (listener.name.IsEmpty())
+ listener.name = "unnamed";
+
+ PIPSocket::Address ip;
+ WORD port = 1720;
+
+ for (switch_xml_t xmlParam = switch_xml_child(xmlListener, "param"); xmlParam != NULL; xmlParam = xmlParam->next) {
+ const char *var = switch_xml_attr_soft(xmlParam, "name");
+ const char *val = switch_xml_attr_soft(xmlParam, "value");
+ //switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Var - '%s' and Val - '%s' \n", var, val);
+ if (!strcasecmp(var, "h323-ip"))
+ ip = val;
+ else if (!strcasecmp(var, "h323-port"))
+ port = (WORD) atoi(val);
+ }
+
+ listener.listenAddress = OpalTransportAddress(ip, port);
+ switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Created Listener '%s'\n", (const char *) listener.name);
+ }
+ }
+
+ switch_event_destroy(¶ms);
+
+ if (xml)
+ switch_xml_free(xml);
+
+ return status;
+}
+
+
+OpalCall * FSManager::CreateCall(void * /*userData*/)
+{
+ return new FSCall(*this);
+}
+
+
+///////////////////////////////////////////////////////////////////////
+
+FSEndPoint::FSEndPoint(FSManager & manager)
+: OpalLocalEndPoint(manager)
+{
+ PTRACE(3, "mod_opal\t FSEndPoint Created!");
+}
+
+
+bool FSEndPoint::OnIncomingCall(OpalLocalConnection & connection)
+{
+ return ((FSConnection &) connection).OnIncoming();
+}
+
+
+OpalLocalConnection *FSEndPoint::CreateConnection(OpalCall & call, void *userData, unsigned options, OpalConnection::StringOptions* stringOptions)
+{
+ FSManager & mgr = (FSManager &) GetManager();
+ switch_core_session_t *fsSession = switch_core_session_request(mgr.GetSwitchInterface(),
+ (switch_caller_profile_t *)userData ? SWITCH_CALL_DIRECTION_OUTBOUND : SWITCH_CALL_DIRECTION_INBOUND, NULL);
+ if (fsSession == NULL)
+ return NULL;
+
+ switch_channel_t *fsChannel = switch_core_session_get_channel(fsSession);
+
+ if (fsChannel == NULL) {
+ switch_core_session_destroy(&fsSession);
+ return NULL;
+ }
+
+ return new FSConnection(call, *this, userData, options, stringOptions, (switch_caller_profile_t *)userData, fsSession, fsChannel);
+}
+
+
+///////////////////////////////////////////////////////////////////////
+
+FSCall::FSCall(OpalManager & manager)
+ : OpalCall(manager)
+{
+}
+
+
+PBoolean FSCall::OnSetUp(OpalConnection & connection)
+{
+ // Transfer FS caller_id_number & caller_id_name from the FSConnection
+ // to the protocol connectionm (e.g. H.323) so gets sent correctly
+ // in outgoing packets
+ PSafePtr<FSConnection> local = GetConnectionAs<FSConnection>();
+ if (local != NULL) {
+ PSafePtr<OpalConnection> proto = local->GetOtherPartyConnection();
+ if (proto != NULL) {
+ proto->SetLocalPartyName(local->GetLocalPartyName());
+ proto->SetDisplayName(local->GetDisplayName());
+ }
+ }
+
+ return OpalCall::OnSetUp(connection);
+}
+
+
+///////////////////////////////////////////////////////////////////////
+
+
+FSConnection::FSConnection(OpalCall & call, FSEndPoint & endpoint, void* userData, unsigned options, OpalConnection::StringOptions* stringOptions, switch_caller_profile_t *outbound_profile, switch_core_session_t *fsSession, switch_channel_t *fsChannel)
+ : OpalLocalConnection(call, endpoint, userData, options, stringOptions)
+ , m_endpoint(endpoint)
+ , m_fsSession(fsSession)
+ , m_fsChannel(fsChannel)
+{
+ opal_private_t *tech_pvt;
+
+ tech_pvt = (opal_private_t *) switch_core_session_alloc(m_fsSession, sizeof(*tech_pvt));
+ tech_pvt->me = this;
+ switch_core_session_set_private(m_fsSession, tech_pvt);
+
+ if (outbound_profile != NULL) {
+ SetLocalPartyName(outbound_profile->caller_id_number);
+ SetDisplayName(outbound_profile->caller_id_name);
+
+ switch_caller_profile_t *caller_profile = switch_caller_profile_clone(m_fsSession, outbound_profile);
+ switch_channel_set_caller_profile(m_fsChannel, caller_profile);
+
+ PString name = "opal/";
+ name += outbound_profile->destination_number;
+ switch_channel_set_name(m_fsChannel, name);
+
+ switch_channel_set_flag(m_fsChannel, CF_OUTBOUND);
+ switch_channel_set_state(m_fsChannel, CS_INIT);
+ }
+}
+
+
+bool FSConnection::OnIncoming()
+{
+ if (m_fsSession == NULL) {
+ PTRACE(1, "mod_opal\tSession request failed.");
+ return false;
+ }
+
+ switch_core_session_add_stream(m_fsSession, NULL);
+
+ switch_channel_t *channel = switch_core_session_get_channel(m_fsSession);
+ if (channel == NULL) {
+ PTRACE(1, "mod_opal\tSession does not have a channel");
+ return false;
+ }
+
+ PURL url = GetRemotePartyURL();
+ switch_caller_profile_t *caller_profile = switch_caller_profile_new(switch_core_session_get_pool(m_fsSession),
+ url.GetUserName(),
+ /** username */
+ mod_opal_globals.dialplan,
+ /** dial plan */
+ GetRemotePartyName(),
+ /** caller_id_name */
+ GetRemotePartyNumber(),
+ /** caller_id_number */
+ url.GetHostName(),
+ /** network addr */
+ NULL,
+ /** ANI */
+ NULL,
+ /** ANI II */
+ NULL,
+ /** RDNIS */
+ ModuleName,
+ /** source */
+ mod_opal_globals.context,
+ /** set context */
+ GetCalledPartyNumber()
+ /** destination_number */
+ );
+ if (caller_profile == NULL) {
+ PTRACE(1, "mod_opal\tCould not create caller profile");
+ return false;
+ }
+
+ PTRACE(4, "mod_opal\tCreated switch caller profile:\n"
+ " username = " << caller_profile->username << "\n"
+ " dialplan = " << caller_profile->dialplan << "\n"
+ " caller_id_name = " << caller_profile->caller_id_name << "\n"
+ " caller_id_number = " << caller_profile->caller_id_number << "\n"
+ " network_addr = " << caller_profile->network_addr << "\n"
+ " source = " << caller_profile->source << "\n"
+ " context = " << caller_profile->context << "\n" " destination_number= " << caller_profile->destination_number);
+ switch_channel_set_caller_profile(channel, caller_profile);
+
+ char name[256] = "opal/in:";
+ switch_copy_string(name + 8, caller_profile->destination_number, sizeof(name)-8);
+ switch_channel_set_name(channel, name);
+ switch_channel_set_state(channel, CS_INIT);
+
+ if (switch_core_session_thread_launch(m_fsSession) != SWITCH_STATUS_SUCCESS) {
+ PTRACE(1, "mod_opal\tCould not launch session thread");
+ return false;
+ }
+
+ return true;
+}
+
+
+void FSConnection::OnReleased()
+{
+ opal_private_t *tech_pvt = (opal_private_t *) switch_core_session_get_private(m_fsSession);
+
+ /* so FS on_hangup will not try to deref a landmine */
+ tech_pvt->me = NULL;
+
+ m_rxAudioOpened.Signal(); // Just in case
+ m_txAudioOpened.Signal();
+ H225_ReleaseCompleteReason dummy;
+ switch_channel_hangup(switch_core_session_get_channel(m_fsSession),
+ (switch_call_cause_t)H323TranslateFromCallEndReason(GetCallEndReason(), dummy));
+ OpalLocalConnection::OnReleased();
+}
+
+
+void FSConnection::OnAlerting()
+{
+ switch_channel_mark_ring_ready(m_fsChannel);
+ return OpalLocalConnection::OnAlerting();
+}
+
+PBoolean FSConnection::SetAlerting(const PString & calleeName, PBoolean withMedia)
+{
+ return OpalLocalConnection::SetAlerting(calleeName, withMedia);
+}
+
+
+void FSConnection::OnEstablished()
+{
+ OpalLocalConnection::OnEstablished();
+}
+
+
+PBoolean FSConnection::SendUserInputTone(char tone, unsigned duration)
+{
+ switch_dtmf_t dtmf = { tone, duration };
+ return switch_channel_queue_dtmf(m_fsChannel, &dtmf) == SWITCH_STATUS_SUCCESS;
+}
+
+
+PBoolean FSConnection::SendUserInputString(const PString & value)
+{
+ return OpalConnection::SendUserInputString(value);
+}
+
+
+OpalMediaFormatList FSConnection::GetMediaFormats() const
+{
+ if (m_switchMediaFormats.IsEmpty()) {
+ const_cast<FSConnection *>(this)->SetCodecs();
+ }
+
+ return m_switchMediaFormats;
+}
+
+
+void FSConnection::SetCodecs()
+{
+ int numCodecs = 0;
+ const switch_codec_implementation_t *codecs[SWITCH_MAX_CODECS];
+ const char *codec_string = NULL, *abs, *ocodec;
+ char *tmp_codec_string = NULL;
+ char *codec_order[SWITCH_MAX_CODECS];
+ int codec_order_last;
+
+
+ if ((abs = switch_channel_get_variable(m_fsChannel, "absolute_codec_string"))) {
+ codec_string = abs;
+ } else {
+ if ((abs = switch_channel_get_variable(m_fsChannel, "codec_string"))) {
+ codec_string = abs;
+ }
+
+ if ((ocodec = switch_channel_get_variable(m_fsChannel, SWITCH_ORIGINATOR_CODEC_VARIABLE))) {
+ codec_string = switch_core_session_sprintf(m_fsSession, "%s,%s", ocodec, codec_string);
+ }
+ }
+
+ if (!codec_string) {
+ codec_string = mod_opal_globals.codec_string;
+ }
+
+ if (codec_string) {
+ if ((tmp_codec_string = strdup(codec_string))) {
+ codec_order_last = switch_separate_string(tmp_codec_string, ',', codec_order, SWITCH_MAX_CODECS);
+ numCodecs = switch_loadable_module_get_codecs_sorted(codecs, SWITCH_MAX_CODECS, codec_order, codec_order_last);
+
+ }
+ } else {
+ numCodecs = switch_loadable_module_get_codecs(codecs, sizeof(codecs) / sizeof(codecs[0]));
+ }
+
+ for (int i = 0; i < numCodecs; i++) {
+ const switch_codec_implementation_t *codec = codecs[i];
+
+ // See if we have a match by PayloadType/rate/name
+ OpalMediaFormat switchFormat((RTP_DataFrame::PayloadTypes)codec->ianacode,
+ codec->samples_per_second,
+ codec->iananame);
+ if (!switchFormat.IsValid()) {
+ // See if we have a match by name alone
+ switchFormat = codec->iananame;
+ if (!switchFormat.IsValid()) {
+ PTRACE(2, "mod_opal\tCould not match FS codec " << codec->iananame << " to OPAL media format.");
+ continue;
+ }
+ }
+
+
+ // Did we match or create a new media format?
+ if (switchFormat.IsValid() && codec->codec_type == SWITCH_CODEC_TYPE_AUDIO) {
+ PTRACE(2, "mod_opal\tMatched FS codec " << codec->iananame << " to OPAL media format " << switchFormat);
+
+ // Calculate frames per packet, do not use codec->codec_frames_per_packet as that field
+ // has slightly different semantics when used in streamed codecs such as G.711
+ int fpp = codec->samples_per_packet/switchFormat.GetFrameTime();
+
+ /* Set the frames/packet to maximum of what is in the FS table. The OPAL negotiations will
+ drop the value from there. This might fail if there are "holes" in the FS table, e.g.
+ if for some reason G.723.1 has 30ms and 90ms but not 60ms, then the OPAL negotiations
+ could end up with 60ms and the codec cannot be created. The "holes" are unlikely in
+ all but streamed codecs such as G.711, where it is theoretically possible for OPAL to
+ come up with 32ms and there is only 30ms and 40ms in the FS table. We deem these
+ scenarios succifiently rare that we can safely ignore them ... for now. */
+
+ if (fpp > switchFormat.GetOptionInteger(OpalAudioFormat::RxFramesPerPacketOption())) {
+ switchFormat.SetOptionInteger(OpalAudioFormat::RxFramesPerPacketOption(), fpp);
+ }
+
+ if (fpp > switchFormat.GetOptionInteger(OpalAudioFormat::TxFramesPerPacketOption())) {
+ switchFormat.SetOptionInteger(OpalAudioFormat::TxFramesPerPacketOption(), fpp);
+ }
+ }
+
+ m_switchMediaFormats += switchFormat;
+ }
+
+ switch_safe_free(tmp_codec_string);
+}
+
+
+OpalMediaStream *FSConnection::CreateMediaStream(const OpalMediaFormat & mediaFormat, unsigned sessionID, PBoolean isSource)
+{
+ return new FSMediaStream(*this, mediaFormat, sessionID, isSource);
+}
+
+
+PBoolean FSConnection::OnOpenMediaStream(OpalMediaStream & stream)
+{
+ if (!OpalConnection::OnOpenMediaStream(stream)) {
+ return false;
+ }
+
+ if (stream.GetMediaFormat().GetMediaType() != OpalMediaType::Audio()) {
+ return true;
+ }
+
+ if (stream.IsSource()) {
+ m_rxAudioOpened.Signal();
+ } else {
+ m_txAudioOpened.Signal();
+ }
+
+ if (GetMediaStream(stream.GetSessionID(), stream.IsSink()) != NULL) {
+ // Have open media in both directions.
+ if (GetPhase() == AlertingPhase) {
+ switch_channel_mark_pre_answered(m_fsChannel);
+ } else if (GetPhase() < ReleasingPhase) {
+ switch_channel_mark_answered(m_fsChannel);
+ }
+ }
+
+ return true;
+}
+
+
+switch_status_t FSConnection::on_init()
+{
+ switch_channel_t *channel = switch_core_session_get_channel(m_fsSession);
+ if (channel == NULL) {
+ return SWITCH_STATUS_FALSE;
+ }
+
+ PTRACE(3, "mod_opal\tStarted routing for connection " << *this);
+ switch_channel_set_state(channel, CS_ROUTING);
+ return SWITCH_STATUS_SUCCESS;
+}
+
+
+switch_status_t FSConnection::on_routing()
+{
+ PTRACE(3, "mod_opal\tRouting connection " << *this);
+ return SWITCH_STATUS_SUCCESS;
+}
+
+
+switch_status_t FSConnection::on_execute()
+{
+ PTRACE(3, "mod_opal\tExecuting connection " << *this);
+ return SWITCH_STATUS_SUCCESS;
+}
+
+static switch_status_t on_destroy(switch_core_session_t *session)
+{
+ //switch_channel_t *channel = switch_core_session_get_channel(session);
+ opal_private_t *tech_pvt = (opal_private_t *) switch_core_session_get_private(session);
+
+ if (tech_pvt) {
+ if (tech_pvt->read_codec.implementation) {
+ switch_core_codec_destroy(&tech_pvt->read_codec);
+ }
+
+ if (tech_pvt->write_codec.implementation) {
+ switch_core_codec_destroy(&tech_pvt->write_codec);
+ }
+
+ if (tech_pvt->vid_read_codec.implementation) {
+ switch_core_codec_destroy(&tech_pvt->vid_read_codec);
+ }
+
+ if (tech_pvt->vid_write_codec.implementation) {
+ switch_core_codec_destroy(&tech_pvt->vid_write_codec);
+ }
+
+ if (tech_pvt->read_timer.timer_interface) {
+ switch_core_timer_destroy(&tech_pvt->read_timer);
+ }
+
+ if (tech_pvt->vid_read_timer.timer_interface) {
+ switch_core_timer_destroy(&tech_pvt->vid_read_timer);
+ }
+ }
+
+ return SWITCH_STATUS_SUCCESS;
+}
+
+/* this function has to be called with the original session beause the FSConnection might already be destroyed and we
+ will can't have it be a method of a dead object
+ */
+static switch_status_t on_hangup(switch_core_session_t *session)
+{
+ switch_channel_t *channel = switch_core_session_get_channel(session);
+ opal_private_t *tech_pvt = (opal_private_t *) switch_core_session_get_private(session);
+
+ /* if this is still here it was our idea to hangup not opal's */
+ if (tech_pvt->me) {
+ Q931::CauseValues cause = (Q931::CauseValues)switch_channel_get_cause_q850(channel);
+ tech_pvt->me->SetQ931Cause(cause);
+ tech_pvt->me->ClearCallSynchronous(NULL, H323TranslateToCallEndReason(cause, UINT_MAX));
+ tech_pvt->me = NULL;
+ }
+
+ return SWITCH_STATUS_SUCCESS;
+}
+
+
+switch_status_t FSConnection::on_exchange_media()
+{
+ PTRACE(3, "mod_opal\tLoopback on connection " << *this);
+ return SWITCH_STATUS_SUCCESS;
+}
+
+
+switch_status_t FSConnection::on_soft_execute()
+{
+ PTRACE(3, "mod_opal\tTransmit on connection " << *this);
+ return SWITCH_STATUS_SUCCESS;
+}
+
+
+switch_status_t FSConnection::kill_channel(int sig)
+{
+ PTRACE(3, "mod_opal\tKill " << sig << " on connection " << *this);
+
+ switch (sig) {
+ case SWITCH_SIG_BREAK:
+ break;
+ case SWITCH_SIG_KILL:
+ m_rxAudioOpened.Signal();
+ m_txAudioOpened.Signal();
+ break;
+ default:
+ break;
+ }
+
+ return SWITCH_STATUS_SUCCESS;
+}
+
+
+switch_status_t FSConnection::send_dtmf(const switch_dtmf_t *dtmf)
+{
+ OnUserInputTone(dtmf->digit, dtmf->duration);
+ return SWITCH_STATUS_SUCCESS;
+}
+
+
+switch_status_t FSConnection::receive_message(switch_core_session_message_t *msg)
+{
+ switch_channel_t *channel = switch_core_session_get_channel(m_fsSession);
+
+
+ /*
+ SWITCH_MESSAGE_INDICATE_PROGRESS: establish early media now and return SWITCH_STATUS_FALSE if you can't
+ SWITCH_MESSAGE_INDICATE_ANSWER: answer and set up media now if it's not already and return SWITCH_STATUS_FALSE if you can't
+
+ Neither message means anything on an outbound call....
+
+ It would only happen if someone called switch_channel_answer() instead of switch_channel_mark_answered() on an outbound call.
+ it should not do anything if someone does it by accident somewhere hense this in both cases:
+
+ if (switch_channel_test_flag(channel, CF_OUTBOUND)) {
+ return SWITCH_STATUS_FALSE;
+ }
+
+
+ When we get these messages the core will trust that you have triggered FSMediaStream::Open and are ready for media if we do not
+ have media we MUST return SWITCH_STATUS_FALSE or it will cause a CRASH.
+
+
+
+ */
+ switch (msg->message_id) {
+ case SWITCH_MESSAGE_INDICATE_BRIDGE:
+ case SWITCH_MESSAGE_INDICATE_UNBRIDGE:
+ case SWITCH_MESSAGE_INDICATE_AUDIO_SYNC:
+ switch_channel_set_private_flag(channel, CF_NEED_FLUSH);
+ break;
+
+ case SWITCH_MESSAGE_INDICATE_RINGING:
+ case SWITCH_MESSAGE_INDICATE_PROGRESS:
+ case SWITCH_MESSAGE_INDICATE_ANSWER:
+ {
+ switch_caller_profile_t * profile = switch_channel_get_caller_profile(channel);
+ if (profile != NULL && profile->caller_extension != NULL)
+ {
+ PSafePtr<OpalConnection> other = GetOtherPartyConnection();
+ if (other != NULL) {
+ other->SetLocalPartyName(profile->caller_extension->extension_number);
+ other->SetDisplayName(profile->caller_extension->extension_name);
+ }
+ SetLocalPartyName(profile->caller_extension->extension_number);
+ SetDisplayName(profile->caller_extension->extension_name);
+ }
+ }
+ break;
+
+ default:
+ break;
+ }
+
+ switch (msg->message_id) {
+ case SWITCH_MESSAGE_INDICATE_RINGING:
+ SetPhase(OpalConnection::AlertingPhase);
+ OnAlerting();
+ break;
+
+ case SWITCH_MESSAGE_INDICATE_DEFLECT:
+ {
+ PSafePtr<OpalConnection> other = GetOtherPartyConnection();
+ if (other != NULL)
+ other->TransferConnection(msg->string_arg);
+ break;
+ }
+
+ case SWITCH_MESSAGE_INDICATE_PROGRESS:
+ case SWITCH_MESSAGE_INDICATE_ANSWER:
+ {
+ int fixed = 0;
+
+ if (switch_channel_test_flag(channel, CF_OUTBOUND)) {
+ return SWITCH_STATUS_FALSE;
+ }
+
+ if (msg->message_id == SWITCH_MESSAGE_INDICATE_PROGRESS) {
+ if (fixed) {
+ /* this should send alerting + media and wait for it to be established and return SUCCESS or FAIL
+ depending on if media was able to be established. Need code to tell the other side we want early media here.
+ */
+ GetCall().OpenSourceMediaStreams(*this, OpalMediaType::Audio());
+ SetPhase(OpalConnection::AlertingPhase);
+ /* how do i say please establish early media ? */
+ OnAlerting();
+ } else {
+ /* hack to avoid getting stuck, pre_answer will imply answer */
+ OnConnectedInternal();
+ }
+ } else {
+ OnConnectedInternal();
+ }
+
+ // Wait for media
+ PTRACE(2, "mod_opal\tAwaiting media start on connection " << *this);
+ m_rxAudioOpened.Wait();
+ m_txAudioOpened.Wait();
+
+ if (GetPhase() >= ReleasingPhase) {
+ // Call got aborted
+ switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(m_fsSession), SWITCH_LOG_ERROR, "Call abandoned!\n");
+ return SWITCH_STATUS_FALSE;
+ }
+
+ PTRACE(4, "mod_opal\tMedia started on connection " << *this);
+
+ if (msg->message_id == SWITCH_MESSAGE_INDICATE_PROGRESS) {
+ if (!switch_channel_test_flag(m_fsChannel, CF_EARLY_MEDIA)) {
+ switch_channel_mark_pre_answered(m_fsChannel);
+ }
+ } else {
+ if (!switch_channel_test_flag(m_fsChannel, CF_EARLY_MEDIA)) {
+ switch_channel_mark_answered(m_fsChannel);
+ }
+ }
+
+ }
+ break;
+
+ default:
+ PTRACE(3, "mod_opal\tReceived message " << msg->message_id << " on connection " << *this);
+ }
+
+ return SWITCH_STATUS_SUCCESS;
+}
+
+
+switch_status_t FSConnection::receive_event(switch_event_t *event)
+{
+ PTRACE(3, "mod_opal\tReceived event " << event->event_id << " on connection " << *this);
+ return SWITCH_STATUS_SUCCESS;
+}
+
+
+switch_status_t FSConnection::state_change()
+{
+ PTRACE(3, "mod_opal\tState changed on connection " << *this);
+ return SWITCH_STATUS_SUCCESS;
+}
+
+
+switch_status_t FSConnection::read_audio_frame(switch_frame_t **frame, switch_io_flag_t flags, int stream_id)
+{
+ return read_frame(OpalMediaType::Audio(), frame, flags);
+}
+
+
+switch_status_t FSConnection::write_audio_frame(switch_frame_t *frame, switch_io_flag_t flags, int stream_id)
+{
+ return write_frame(OpalMediaType::Audio(), frame, flags);
+}
+
+
+switch_status_t FSConnection::read_video_frame(switch_frame_t **frame, switch_io_flag_t flag, int stream_id)
+{
+ return read_frame(OpalMediaType::Video(), frame, flag);
+}
+
+
+switch_status_t FSConnection::write_video_frame(switch_frame_t *frame, switch_io_flag_t flag, int stream_id)
+{
+ return write_frame(OpalMediaType::Video(), frame, flag);
+}
+
+
+switch_status_t FSConnection::read_frame(const OpalMediaType & mediaType, switch_frame_t **frame, switch_io_flag_t flags)
+{
+ PSafePtr < FSMediaStream > stream = PSafePtrCast < OpalMediaStream, FSMediaStream > (GetMediaStream(mediaType, false));
+ return stream != NULL ? stream->read_frame(frame, flags) : SWITCH_STATUS_FALSE;
+}
+
+
+switch_status_t FSConnection::write_frame(const OpalMediaType & mediaType, const switch_frame_t *frame, switch_io_flag_t flags)
+{
+ PSafePtr < FSMediaStream > stream = PSafePtrCast < OpalMediaStream, FSMediaStream > (GetMediaStream(mediaType, true));
+ return stream != NULL ? stream->write_frame(frame, flags) : SWITCH_STATUS_FALSE;
+}
+
+
+///////////////////////////////////////////////////////////////////////
+
+FSMediaStream::FSMediaStream(FSConnection & conn, const OpalMediaFormat & mediaFormat, unsigned sessionID, bool isSource)
+ : OpalMediaStream(conn, mediaFormat, sessionID, isSource)
+ , m_fsSession(conn.GetSession())
+ , m_readRTP(0, 512)
+ , m_callOnStart(true)
+{
+ memset(&m_readFrame, 0, sizeof(m_readFrame));
+ m_readFrame.codec = m_switchCodec;
+ m_readFrame.flags = SFF_RAW_RTP;
+}
+
+
+PBoolean FSMediaStream::Open()
+{
+ opal_private_t *tech_pvt = (opal_private_t *) switch_core_session_get_private(m_fsSession);
+
+ if (IsOpen()) {
+ return true;
+ }
+
+ bool isAudio;
+ if (mediaFormat.GetMediaType() == OpalMediaType::Audio()) {
+ isAudio = true;
+ } else if (mediaFormat.GetMediaType() == OpalMediaType::Video()) {
+ isAudio = false;
+ } else {
+ return OpalMediaStream::Open();
+ }
+
+ m_fsChannel = switch_core_session_get_channel(m_fsSession);
+
+ int ptime = mediaFormat.GetOptionInteger(OpalAudioFormat::TxFramesPerPacketOption()) * mediaFormat.GetFrameTime() / mediaFormat.GetTimeUnits();
+
+
+ if (IsSink()) {
+ m_switchCodec = isAudio ? &tech_pvt->read_codec : &tech_pvt->vid_read_codec;
+ m_switchTimer = isAudio ? &tech_pvt->read_timer : &tech_pvt->vid_read_timer;
+ } else {
+ m_switchCodec = isAudio ? &tech_pvt->write_codec : &tech_pvt->vid_write_codec;
+ }
+
+ // The following is performed on two different instances of this object.
+ if (switch_core_codec_init(m_switchCodec, mediaFormat.GetEncodingName(), NULL, // FMTP
+ mediaFormat.GetClockRate(), ptime, 1, // Channels
+ SWITCH_CODEC_FLAG_ENCODE | SWITCH_CODEC_FLAG_DECODE, NULL, // Settings
+ switch_core_session_get_pool(m_fsSession)) != SWITCH_STATUS_SUCCESS) {
+ // Could not select a codecs using negotiated frames/packet, so try using default.
+ if (switch_core_codec_init(m_switchCodec, mediaFormat.GetEncodingName(), NULL, // FMTP
+ mediaFormat.GetClockRate(), 0, 1, // Channels
+ SWITCH_CODEC_FLAG_ENCODE | SWITCH_CODEC_FLAG_DECODE, NULL, // Settings
+ switch_core_session_get_pool(m_fsSession)) != SWITCH_STATUS_SUCCESS) {
+ PTRACE(1, "mod_opal " << switch_channel_get_name(m_fsChannel)<< " Cannot initialise " << (IsSink()? "read" : "write") << ' '
+ << mediaFormat.GetMediaType() << " codec " << mediaFormat << " for connection " << *this);
+ switch_channel_hangup(m_fsChannel, SWITCH_CAUSE_INCOMPATIBLE_DESTINATION);
+ return false;
+ }
+ PTRACE(2, "mod_opal " << switch_channel_get_name(m_fsChannel)<< " Unsupported ptime of " << ptime << " on " << (IsSink()? "read" : "write") << ' '
+ << mediaFormat.GetMediaType() << " codec " << mediaFormat << " for connection " << *this);
+ }
+
+ PTRACE(1, "mod_opal " << switch_channel_get_name(m_fsChannel)<< " initialise " <<
+ switch_channel_get_name(m_fsChannel) << (IsSink()? "read" : "write") << ' '
+ << mediaFormat.GetMediaType() << " codec " << mediaFormat << " for connection " << *this);
+
+ if (IsSink()) {
+ m_readFrame.rate = mediaFormat.GetClockRate();
+
+ if (isAudio) {
+ switch_core_session_set_read_codec(m_fsSession, m_switchCodec);
+ if (switch_core_timer_init(m_switchTimer,
+ "soft",
+ m_switchCodec->implementation->microseconds_per_packet / 1000,
+ m_switchCodec->implementation->samples_per_packet,
+ switch_core_session_get_pool(m_fsSession)) != SWITCH_STATUS_SUCCESS) {
+ switch_core_codec_destroy(m_switchCodec);
+ m_switchCodec = NULL;
+ return false;
+ }
+ } else {
+ switch_core_session_set_video_read_codec(m_fsSession, m_switchCodec);
+ switch_channel_set_flag(m_fsChannel, CF_VIDEO);
+ }
+ } else {
+ if (isAudio) {
+ switch_core_session_set_write_codec(m_fsSession, m_switchCodec);
+ } else {
+ switch_core_session_set_video_write_codec(m_fsSession, m_switchCodec);
+ switch_channel_set_flag(m_fsChannel, CF_VIDEO);
+ }
+ }
+
+ PTRACE(3, "mod_opal\tSet " << (IsSink()? "read" : "write") << ' '
+ << mediaFormat.GetMediaType() << " codec to << " << mediaFormat << " for connection " << *this);
+
+ return OpalMediaStream::Open();
+}
+
+
+PBoolean FSMediaStream::Close()
+{
+ if (!IsOpen())
+ return false;
+
+ /* forget these FS will properly destroy them for us */
+
+ m_switchTimer = NULL;
+ m_switchCodec = NULL;
+
+ return OpalMediaStream::Close();
+}
+
+
+PBoolean FSMediaStream::IsSynchronous() const
+{
+ return true;
+}
+
+
+PBoolean FSMediaStream::RequiresPatchThread(OpalMediaStream *) const
+{
+ return false;
+}
+
+bool FSMediaStream::CheckPatchAndLock()
+{
+ if (GetConnection().GetPhase() >= GetConnection().ReleasingPhase || !IsOpen())
+ return false;
+
+ if (LockReadWrite()) {
+ if (!GetPatch() || !IsOpen()) {
+ UnlockReadWrite();
+ return false;
+ }
+ return true;
+ } else {
+ return false;
+ }
+}
+
+switch_status_t FSMediaStream::read_frame(switch_frame_t **frame, switch_io_flag_t flags)
+{
+
+ if (!m_switchCodec) {
+ return SWITCH_STATUS_FALSE;
+ }
+
+ if (m_callOnStart) {
+ /*
+ There is a race here... sometimes we make it here and GetPatch() is NULL
+ if we wait it shows up in 1ms, maybe there is a better way to wait.
+
+ */
+ while(!GetPatch()) {
+ if (!m_fsChannel || !switch_channel_up(m_fsChannel)) {
+ return SWITCH_STATUS_FALSE;
+ }
+ switch_cond_next();
+ }
+ if (CheckPatchAndLock()) {
+ GetPatch()->OnStartMediaPatch();
+ m_callOnStart = false;
+ UnlockReadWrite();
+ } else {
+ return SWITCH_STATUS_FALSE;
+ }
+ }
+
+ m_readFrame.flags = 0;
+
+ /*
+ while (switch_channel_ready(m_fsChannel)) {
+ if (CheckPatchAndLock()) {
+ if (!GetPatch()->GetSource().ReadPacket(m_readRTP)) {
+ UnlockReadWrite();
+ return SWITCH_STATUS_FALSE;
+ }
+ UnlockReadWrite();
+ } else {
+ return SWITCH_STATUS_FALSE;
+ }
+
+ if ((m_readFrame.datalen = m_readRTP.GetPayloadSize()) || switch_core_timer_check(&m_switchTimer, SWITCH_FALSE) == SWITCH_STATUS_SUCCESS) {
+ if (m_readFrame.datalen) {
+ } else {
+ m_readFrame.flags = SFF_CNG;
+ }
+ break;
+ }
+
+ switch_yield(1000);
+ }
+ */
+
+ if (switch_channel_test_private_flag(m_fsChannel, CF_NEED_FLUSH)) {
+ switch_channel_clear_private_flag(m_fsChannel, CF_NEED_FLUSH);
+ for(;;) {
+ if (CheckPatchAndLock()) {
+ if (!GetPatch()->GetSource().ReadPacket(m_readRTP)) {
+ UnlockReadWrite();
+ return SWITCH_STATUS_FALSE;
+ }
+ UnlockReadWrite();
+ } else {
+ return SWITCH_STATUS_FALSE;
+ }
+
+ if (!m_readRTP.GetPayloadSize()) {
+ m_readFrame.flags = SFF_CNG;
+ break;
+ }
+ }
+ } else {
+
+ if (CheckPatchAndLock()) {
+ if (!m_switchTimer || !GetPatch()->GetSource().ReadPacket(m_readRTP)) {
+ UnlockReadWrite();
+ return SWITCH_STATUS_FALSE;
+ }
+ UnlockReadWrite();
+ } else {
+ return SWITCH_STATUS_FALSE;
+ }
+
+ switch_core_timer_next(m_switchTimer);
+
+ if (!(m_readFrame.datalen = m_readRTP.GetPayloadSize())) {
+ m_readFrame.flags = SFF_CNG;
+ }
+ }
+
+ if (!switch_channel_ready(m_fsChannel)) {
+ return SWITCH_STATUS_FALSE;
+ }
+
+ if (!switch_core_codec_ready(m_switchCodec)) {
+ return SWITCH_STATUS_FALSE;
+ }
+
+ //switch_core_timer_step(&m_switchTimer);
+
+ if (m_readFrame.payload == RTP_DataFrame::CN || m_readFrame.payload == RTP_DataFrame::Cisco_CN) {
+ m_readFrame.flags = SFF_CNG;
+ }
+
+ if (m_readFrame.flags & SFF_CNG) {
+ m_readFrame.buflen = sizeof(m_buf);
+ m_readFrame.data = m_buf;
+ m_readFrame.packet = NULL;
+ m_readFrame.packetlen = 0;
+ m_readFrame.timestamp = 0;
+ m_readFrame.m = SWITCH_FALSE;
+ m_readFrame.seq = 0;
+ m_readFrame.ssrc = 0;
+ m_readFrame.codec = m_switchCodec;
+ } else {
+ m_readFrame.buflen = m_readRTP.GetSize();
+ m_readFrame.data = m_readRTP.GetPayloadPtr();
+ m_readFrame.packet = m_readRTP.GetPointer();
+ m_readFrame.packetlen = m_readRTP.GetHeaderSize() + m_readFrame.datalen;
+ m_readFrame.payload = (switch_payload_t) m_readRTP.GetPayloadType();
+ m_readFrame.timestamp = m_readRTP.GetTimestamp();
+ m_readFrame.m = (switch_bool_t) m_readRTP.GetMarker();
+ m_readFrame.seq = m_readRTP.GetSequenceNumber();
+ m_readFrame.ssrc = m_readRTP.GetSyncSource();
+ m_readFrame.codec = m_switchCodec;
+ }
+
+ *frame = &m_readFrame;
+
+ return SWITCH_STATUS_SUCCESS;
+}
+
+
+switch_status_t FSMediaStream::write_frame(const switch_frame_t *frame, switch_io_flag_t flags)
+{
+ if (!switch_channel_ready(m_fsChannel)) {
+ return SWITCH_STATUS_FALSE;
+ }
+
+ if (m_callOnStart) {
+ if (CheckPatchAndLock()) {
+ GetPatch()->OnStartMediaPatch();
+ m_callOnStart = false;
+ UnlockReadWrite();
+ } else {
+ return SWITCH_STATUS_FALSE;
+ }
+ }
+
+ if ((frame->flags & SFF_CNG)) {
+ return SWITCH_STATUS_SUCCESS;
+ }
+
+ if ((frame->flags & SFF_RAW_RTP) != 0) {
+ RTP_DataFrame rtp((const BYTE *) frame->packet, frame->packetlen, false);
+
+ if (CheckPatchAndLock()) {
+ if (GetPatch()->PushFrame(rtp)) {
+ UnlockReadWrite();
+ return SWITCH_STATUS_SUCCESS;
+ }
+ UnlockReadWrite();
+ } else {
+ return SWITCH_STATUS_FALSE;
+ }
+ }
+
+ /* If we reach this code it means a call to an ivr or something else that does not generate timestamps
+ Its possible that frame->timestamp is set but not guarenteed and is best ignored for the time being.
+ We are probably relying on the rtp stack to generate the timestamp and ssrc for us at this point.
+ As a quick hack I am going to keep a sample counter and increment it by frame->samples but it would be
+ better if we could engage whatever it is in opal that makes it generate the timestamp.
+ */
+
+ RTP_DataFrame rtp(frame->datalen);
+ rtp.SetPayloadType(mediaFormat.GetPayloadType());
+
+ m_timeStamp += frame->samples;
+ rtp.SetTimestamp(m_timeStamp);
+
+ //rtp.SetTimestamp(frame->timestamp);
+ //rtp.SetSyncSource(frame->ssrc);
+ //rtp.SetMarker(frame->m);
+
+ memcpy(rtp.GetPayloadPtr(), frame->data, frame->datalen);
+
+ if (CheckPatchAndLock()) {
+ if (GetPatch()->PushFrame(rtp)) {
+ UnlockReadWrite();
+ return SWITCH_STATUS_SUCCESS;
+ }
+ UnlockReadWrite();
+ } else {
+ return SWITCH_STATUS_FALSE;
+ }
+
+
+ return SWITCH_STATUS_FALSE;
+}
+
+
+/* For Emacs:
+ * Local Variables:
+ * mode:c
+ * indent-tabs-mode:nil
+ * tab-width:4
+ * c-basic-offset:4
+ * End:
+ * For VIM:
+ * vim:set softtabstop=4 shiftwidth=4 tabstop=4:s:
+ */
projects / thirdparty / freeswitch.git / commitdiff
