-/* 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, switch_call_cause_t *cancel_cause);
-
-
-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, switch_call_cause_t *cancel_cause)
-{
- 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, SOF_NONE, 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_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_direction(channel) == SWITCH_CALL_DIRECTION_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_direction(channel) == SWITCH_CALL_DIRECTION_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:
- */
+/* 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
+ * Copyright (c) 2008-2012 Vox Lucida Pty. Ltd. (robertj@voxlucida.com.au)\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
+\r
+/* FreeSWITCH does not correctly handle an H.323 subtely, that is that a\r
+ MAXIMUM audio frames per packet is nototiated, and there is no\r
+ requirement for the remote to actually send that many. So, in say GSM, we\r
+ negotiate up to 3 frames or 60ms of data and the remote actually sends one\r
+ (20ms) frame per packet. Perfectly legal but blows up the media handling\r
+ in FS.\r
+\r
+ Eventually we will get around to bundling the packets, but not yet. This\r
+ compile flag will just force one frame/packet for all audio codecs.\r
+ */\r
+#define IMPLEMENT_MULTI_FAME_AUDIO 0\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,\r
+ switch_memory_pool_t **pool,\r
+ switch_originate_flag_t flags,\r
+ switch_call_cause_t *cancel_cause);\r
+\r
+\r
+static FSProcess *opal_process = NULL;\r
+\r
+\r
+static PConstString const ModuleName("opal");\r
+static char const ConfigFile[] = "opal.conf";\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 */ FSConnection::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*/ FSConnection::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
+{\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_UNLOAD;\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
+ delete opal_process;\r
+ opal_process = NULL;\r
+ return SWITCH_STATUS_SUCCESS;\r
+}\r
+\r
+SWITCH_END_EXTERN_C\r
+/*******************************************************************************/\r
+\r
+///////////////////////////////////////////////////////////////////////\r
+\r
+#if PTRACING\r
+\r
+class FSTrace : public std::ostream\r
+{\r
+private:\r
+ class Buffer : public std::stringbuf\r
+ {\r
+ virtual int sync()\r
+ {\r
+ std::string s = str();\r
+ if (s.empty())\r
+ return 0;\r
+\r
+ //Due to explicit setting of flags we know exactly what we are getting\r
+ #define THREAD_ID_INDEX 2\r
+ #define FILE_NAME_INDEX 3\r
+ #define FILE_LINE_INDEX 4\r
+#if PTLIB_CHECK_VERSION(2,11,1)\r
+ #define CONTEXT_ID_REGEX "([0-9]+|- - - - - - -)\t"\r
+ #define LOG_PRINTF_FORMAT "{%s,%s} %s"\r
+ #define FULL_TEXT_INDEX 6\r
+#else\r
+ #define CONTEXT_ID_REGEX\r
+ #define LOG_PRINTF_FORMAT "{%s} %s"\r
+ #define FULL_TEXT_INDEX 5\r
+#endif\r
+ PStringArray fields(7);\r
+ static PRegularExpression logRE("^([0-9]+)\t *(.+)\t *([^(]+)\\(([0-9]+)\\)\t"CONTEXT_ID_REGEX"(.*)",\r
+ PRegularExpression::Extended);\r
+ if (!logRE.Execute(s.c_str(), fields)) {\r
+ fields[1] = "4";\r
+ fields[THREAD_ID_INDEX] = "unknown";\r
+ fields[FILE_NAME_INDEX] = __FILE__;\r
+ fields[FILE_LINE_INDEX] = __LINE__;\r
+ fields[FULL_TEXT_INDEX] = s;\r
+ }\r
+\r
+ switch_log_level_t level;\r
+ switch (fields[1].AsUnsigned()) {\r
+ case 0 :\r
+ level = SWITCH_LOG_ALERT;\r
+ break;\r
+ case 1 :\r
+ level = SWITCH_LOG_ERROR;\r
+ break;\r
+ case 2 :\r
+ level = SWITCH_LOG_WARNING;\r
+ break;\r
+ case 3 :\r
+ level = SWITCH_LOG_INFO;\r
+ break;\r
+ default :\r
+ level = SWITCH_LOG_DEBUG;\r
+ break;\r
+ }\r
+\r
+ fields[4].Replace("\t", " ", true);\r
+#if PTLIB_CHECK_VERSION(2,11,1)\r
+ fields[5].Replace("- - - - - - -", "-"),\r
+#endif\r
+ switch_log_printf(SWITCH_CHANNEL_ID_LOG,\r
+ fields[FILE_NAME_INDEX],\r
+ "PTLib-OPAL",\r
+ fields[FILE_LINE_INDEX].AsUnsigned(),\r
+ NULL,\r
+ level,\r
+ LOG_PRINTF_FORMAT,\r
+ fields[THREAD_ID_INDEX].GetPointer(),\r
+#if PTLIB_CHECK_VERSION(2,11,1)\r
+ fields[5].GetPointer(),\r
+#endif\r
+ fields[FULL_TEXT_INDEX].GetPointer());\r
+\r
+ // Reset string\r
+ str(std::string());\r
+ return 0;\r
+ }\r
+ } buffer;\r
+\r
+public:\r
+ FSTrace()\r
+ : ostream(&buffer)\r
+ {\r
+ }\r
+};\r
+\r
+#endif // PTRACING\r
+\r
+\r
+///////////////////////////////////////////////////////////////////////\r
+\r
+FSProcess::FSProcess()\r
+ : PLibraryProcess("Vox Lucida Pty. Ltd.", MODNAME, 1, 1, BetaCode, 1)\r
+ , m_manager(NULL)\r
+{\r
+}\r
+\r
+\r
+FSProcess::~FSProcess()\r
+{\r
+ delete m_manager;\r
+#if PTRACING\r
+ PTrace::SetStream(NULL); // This will delete the FSTrace object\r
+#endif\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
+ : m_context("default")\r
+ , m_dialplan("XML")\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
+ 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(OpalTransportAddress(it->m_address, it->m_port))) {\r
+ PTRACE(2, "mod_opal\tCannot start listener for " << it->m_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
+#if !IMPLEMENT_MULTI_FAME_AUDIO\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
+ OpalMediaFormat::SetRegisteredMediaFormat(*it);\r
+ }\r
+ }\r
+#endif // IMPLEMENT_MULTI_FAME_AUDIO\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
+ switch_event_t *request_params = NULL;\r
+ switch_event_create(&request_params, SWITCH_EVENT_REQUEST_PARAMS);\r
+ switch_assert(request_params);\r
+ switch_event_add_header_string(request_params, SWITCH_STACK_BOTTOM, "profile", switch_str_nil(""));\r
+\r
+ switch_xml_t cfg;\r
+ switch_xml_t xml = switch_xml_open_cfg(ConfigFile, &cfg, request_params);\r
+ if (xml == NULL) {\r
+ switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "open of %s failed\n", ConfigFile);\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
+ PConstCaselessString const var(switch_xml_attr_soft(xmlParam, "name"));\r
+ PConstString const val(switch_xml_attr_soft(xmlParam, "value"));\r
+\r
+ if (var == "context") {\r
+ m_context = val;\r
+ } else if (var == "dialplan") {\r
+ m_dialplan = val;\r
+ } else if (var == "codec-prefs") {\r
+ m_codecPrefs = val;\r
+ } else if (var == "disable-transcoding") {\r
+ m_disableTranscoding = switch_true(val);\r
+ } else if (var == "jitter-size") {\r
+ SetAudioJitterDelay(val.AsUnsigned(), val.Mid(val.Find(',')+1).AsUnsigned()); // In milliseconds\r
+ } else if (var == "gk-address") {\r
+ m_gkAddress = val;\r
+ } else if (var == "gk-identifer") {\r
+ m_gkIdentifer = val;\r
+ } else if (var == "gk-interface") {\r
+ m_gkInterface = val;\r
+#if PTRACING\r
+ } else if (var == "trace-level") {\r
+ unsigned level = val.AsUnsigned();\r
+ if (level > 0) {\r
+ PTrace::SetLevel(level);\r
+ PTrace::ClearOptions(0xffffffff); // Everything off\r
+ PTrace::SetOptions( // Except these\r
+ PTrace::TraceLevel|PTrace::FileAndLine|PTrace::Thread\r
+#if PTLIB_CHECK_VERSION(2,11,1)\r
+ |PTrace::ContextIdentifier\r
+#endif\r
+ );\r
+ PTrace::SetStream(new FSTrace);\r
+ }\r
+#endif\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.m_name = switch_xml_attr_soft(xmlListener, "name");\r
+ if (listener.m_name.IsEmpty())\r
+ listener.m_name = "unnamed";\r
+\r
+ for (switch_xml_t xmlParam = switch_xml_child(xmlListener, "param"); xmlParam != NULL; xmlParam = xmlParam->next) {\r
+ PConstCaselessString const var(switch_xml_attr_soft(xmlParam, "name"));\r
+ PConstString const val(switch_xml_attr_soft(xmlParam, "value"));\r
+ if (var == "h323-ip")\r
+ listener.m_address = val;\r
+ else if (var == "h323-port")\r
+ listener.m_port = (uint16_t)val.AsUnsigned();\r
+ }\r
+\r
+ switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Created Listener '%s'\n", (const char *) listener.m_name);\r
+ }\r
+ }\r
+\r
+ switch_event_destroy(&request_params);\r
+\r
+ if (xml)\r
+ switch_xml_free(xml);\r
+\r
+ return SWITCH_STATUS_SUCCESS;\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,\r
+ switch_memory_pool_t **pool,\r
+ switch_originate_flag_t flags,\r
+ switch_call_cause_t *cancel_cause)\r
+{\r
+ if (opal_process == NULL)\r
+ return SWITCH_CAUSE_CRASH;\r
+\r
+ FSConnection::outgoing_params params;\r
+ params.var_event = var_event;\r
+ params.outbound_profile = outbound_profile;\r
+ params.new_session = new_session;\r
+ params.pool = pool;\r
+ params.flags = flags;\r
+ params.cancel_cause = cancel_cause;\r
+ params.fail_cause = SWITCH_CAUSE_INVALID_NUMBER_FORMAT;\r
+\r
+ if (opal_process->GetManager().SetUpCall("local:", outbound_profile->destination_number, ¶ms) != NULL)\r
+ return SWITCH_CAUSE_SUCCESS;\r
+\r
+ if (*new_session != NULL)\r
+ switch_core_session_destroy(new_session);\r
+ return params.fail_cause;\r
+}\r
+\r
+\r
+///////////////////////////////////////////////////////////////////////\r
+\r
+FSEndPoint::FSEndPoint(FSManager & manager)\r
+ : OpalLocalEndPoint(manager)\r
+ , m_manager(manager)\r
+{\r
+ PTRACE(4, "mod_opal\tFSEndPoint created.");\r
+}\r
+\r
+\r
+OpalLocalConnection *FSEndPoint::CreateConnection(OpalCall & call, void *userData, unsigned options, OpalConnection::StringOptions* stringOptions)\r
+{\r
+ return new FSConnection(call, *this, options, stringOptions, (FSConnection::outgoing_params *)userData);\r
+}\r
+\r
+\r
+///////////////////////////////////////////////////////////////////////\r
+\r
+FSConnection::FSConnection(OpalCall & call,\r
+ FSEndPoint & endpoint,\r
+ unsigned options,\r
+ OpalConnection::StringOptions* stringOptions,\r
+ outgoing_params * params)\r
+ : OpalLocalConnection(call, endpoint, NULL, options, stringOptions)\r
+ , m_endpoint(endpoint)\r
+ , m_fsSession(NULL)\r
+ , m_fsChannel(NULL)\r
+ , m_flushAudio(false)\r
+{\r
+ memset(&m_read_timer, 0, sizeof(m_read_timer));\r
+ memset(&m_read_codec, 0, sizeof(m_read_codec));\r
+ memset(&m_write_codec, 0, sizeof(m_write_codec));\r
+ memset(&m_vid_read_timer, 0, sizeof(m_vid_read_timer));\r
+ memset(&m_vid_read_codec, 0, sizeof(m_vid_read_codec));\r
+ memset(&m_vid_write_codec, 0, sizeof(m_vid_write_codec));\r
+\r
+ if (params != NULL) {\r
+ // If we fail, this is the cause\r
+ params->fail_cause = SWITCH_CAUSE_DESTINATION_OUT_OF_ORDER;\r
+\r
+ if ((m_fsSession = switch_core_session_request(endpoint.GetManager().GetSwitchInterface(),\r
+ SWITCH_CALL_DIRECTION_INBOUND, params->flags, params->pool)) == NULL) {\r
+ PTRACE(1, "mod_opal\tCannot create session for outgoing call.");\r
+ return;\r
+ }\r
+ }\r
+ else {\r
+ if ((m_fsSession = switch_core_session_request(endpoint.GetManager().GetSwitchInterface(),\r
+ SWITCH_CALL_DIRECTION_INBOUND, SOF_NONE, NULL)) == NULL) {\r
+ PTRACE(1, "mod_opal\tCannot create session for incoming call.");\r
+ return;\r
+ }\r
+ }\r
+\r
+ if ((m_fsChannel = switch_core_session_get_channel(m_fsSession)) == NULL) {\r
+ switch_core_session_destroy(&m_fsSession);\r
+ return;\r
+ }\r
+\r
+ switch_core_session_set_private(m_fsSession, this);\r
+ SafeReference(); // Make sure cannot be deleted until on_destroy()\r
+\r
+ if (params != NULL) {\r
+ switch_caller_profile_t *caller_profile = switch_caller_profile_clone(m_fsSession, params->outbound_profile);\r
+ switch_channel_set_caller_profile(m_fsChannel, caller_profile);\r
+ SetLocalPartyName(caller_profile->caller_id_number);\r
+ SetDisplayName(caller_profile->caller_id_name);\r
+\r
+ *params->new_session = m_fsSession;\r
+ }\r
+\r
+ switch_channel_set_state(m_fsChannel, CS_INIT);\r
+}\r
+\r
+\r
+bool FSConnection::OnOutgoingSetUp()\r
+{\r
+ if (m_fsSession == NULL || m_fsChannel == NULL) {\r
+ PTRACE(1, "mod_opal\tSession request failed.");\r
+ return false;\r
+ }\r
+\r
+ // Transfer FS caller_id_number & caller_id_name from the FSConnection\r
+ // to the protocol connection (e.g. H.323) so gets sent correctly\r
+ // in outgoing packets\r
+ PSafePtr<OpalConnection> proto = GetOtherPartyConnection();\r
+ if (proto == NULL) {\r
+ PTRACE(1, "mod_opal\tNo protocol connection in call.");\r
+ return false;\r
+ }\r
+\r
+ proto->SetLocalPartyName(GetLocalPartyName());\r
+ proto->SetDisplayName(GetDisplayName());\r
+\r
+ switch_channel_set_name(m_fsChannel, ModuleName + '/' + GetRemotePartyURL());\r
+ return true;\r
+}\r
+\r
+\r
+bool FSConnection::OnIncoming()\r
+{\r
+ if (m_fsSession == NULL || m_fsChannel == 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
+ PURL url = GetRemotePartyURL();\r
+ switch_caller_profile_t *caller_profile = switch_caller_profile_new(\r
+ switch_core_session_get_pool(m_fsSession),\r
+ url.GetUserName(), /** username */\r
+ m_endpoint.GetManager().GetDialPlan(), /** dial plan */\r
+ GetRemotePartyName(), /** caller_id_name */\r
+ GetRemotePartyNumber(), /** caller_id_number */\r
+ url.GetHostName(), /** network addr */\r
+ NULL, /** ANI */\r
+ NULL, /** ANI II */\r
+ NULL, /** RDNIS */\r
+ ModuleName, /** source */\r
+ m_endpoint.GetManager().GetContext(), /** set context */\r
+ GetCalledPartyNumber() /** 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"\r
+ " destination_number= " << caller_profile->destination_number);\r
+ switch_channel_set_caller_profile(m_fsChannel, caller_profile);\r
+\r
+ switch_channel_set_name(m_fsChannel, ModuleName + '/' + url.GetScheme() + ':' + caller_profile->destination_number);\r
+\r
+ if (switch_core_session_thread_launch(m_fsSession) != SWITCH_STATUS_SUCCESS) {\r
+ PTRACE(1, "mod_opal\tCould not launch session thread");\r
+ switch_core_session_destroy(&m_fsSession);\r
+ m_fsChannel = NULL;\r
+ return false;\r
+ }\r
+\r
+ return true;\r
+}\r
+\r
+\r
+void FSConnection::OnReleased()\r
+{\r
+ m_rxAudioOpened.Signal(); // Just in case\r
+ m_txAudioOpened.Signal();\r
+\r
+ if (m_fsChannel == NULL) {\r
+ PTRACE(3, "mod_opal\tHanging up FS side");\r
+ switch_channel_hangup(m_fsChannel, (switch_call_cause_t)callEndReason.q931);\r
+ }\r
+\r
+ OpalLocalConnection::OnReleased();\r
+}\r
+\r
+\r
+PBoolean FSConnection::SetAlerting(const PString & calleeName, PBoolean withMedia)\r
+{\r
+ if (PAssertNULL(m_fsChannel) == NULL)\r
+ return false;\r
+\r
+ switch_channel_mark_ring_ready(m_fsChannel);\r
+ return OpalLocalConnection::SetAlerting(calleeName, withMedia);\r
+}\r
+\r
+\r
+PBoolean FSConnection::SendUserInputTone(char tone, unsigned duration)\r
+{\r
+ if (PAssertNULL(m_fsChannel) == NULL)\r
+ return false;\r
+\r
+ switch_dtmf_t dtmf = { tone, duration };\r
+ return switch_channel_queue_dtmf(m_fsChannel, &dtmf) == SWITCH_STATUS_SUCCESS;\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
+\r
+ PString codec_string = switch_channel_get_variable(m_fsChannel, "absolute_codec_string");\r
+ if (codec_string.IsEmpty()) {\r
+ codec_string = switch_channel_get_variable(m_fsChannel, "codec_string");\r
+ if (codec_string.IsEmpty()) {\r
+ codec_string = m_endpoint.GetManager().GetCodecPrefs();\r
+ if (codec_string.IsEmpty()) {\r
+ numCodecs = switch_loadable_module_get_codecs(codecs, sizeof(codecs) / sizeof(codecs[0]));\r
+ for (int i = 0; i < numCodecs; i++) {\r
+ if (i > 0)\r
+ codec_string += ',';\r
+ codec_string += codecs[i]->iananame;\r
+ }\r
+ PTRACE(4, "mod_opal\tDefault to all loaded codecs=" << codec_string);\r
+ }\r
+ else {\r
+ PTRACE(4, "mod_opal\tSettings codec-prefs=" << codec_string);\r
+ }\r
+ }\r
+ else {\r
+ PTRACE(4, "mod_opal\tChannel codec_string=" << codec_string);\r
+ }\r
+\r
+ PString orig_codec = switch_channel_get_variable(m_fsChannel, SWITCH_ORIGINATOR_CODEC_VARIABLE);\r
+ if (!orig_codec.IsEmpty()) {\r
+ if (m_endpoint.GetManager().GetDisableTranscoding()) {\r
+ codec_string = orig_codec;\r
+ PTRACE(4, "mod_opal\tNo transcoding, forced to originator codec=" << orig_codec);\r
+ }\r
+ else {\r
+ codec_string.Splice(orig_codec+',', 0);\r
+ PTRACE(4, "mod_opal\tSetting preference to originator codec=" << orig_codec);\r
+ }\r
+ }\r
+ }\r
+ else {\r
+ PTRACE(4, "mod_opal\tChannel absolute_codec_string=" << codec_string);\r
+ }\r
+\r
+ {\r
+ char *codec_order[SWITCH_MAX_CODECS];\r
+ int codec_order_last = switch_separate_string((char *)codec_string.GetPointer(), ',', 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
+ 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 "\r
+ << codec->iananame << '@' << codec->samples_per_second\r
+ << " (pt=" << (unsigned)codec->ianacode << ")"\r
+ " to an OPAL media format.");\r
+ continue;\r
+ }\r
+ }\r
+\r
+ PTRACE(4, "mod_opal\tMatched FS codec " << codec->iananame << " to OPAL media format " << switchFormat);\r
+\r
+#if IMPLEMENT_MULTI_FAME_AUDIO\r
+ // Did we match or create a new media format?\r
+ if (switchFormat.IsValid() && codec->codec_type == SWITCH_CODEC_TYPE_AUDIO) {\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 sufficiently 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
+#endif // IMPLEMENT_MULTI_FAME_AUDIO\r
+\r
+ m_switchMediaFormats += switchFormat;\r
+ }\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
+void FSConnection::OnPatchMediaStream(PBoolean isSource, OpalMediaPatch & patch)\r
+{\r
+ OpalConnection::OnPatchMediaStream(isSource, patch);\r
+\r
+ if (PAssertNULL(m_fsChannel) == NULL)\r
+ return;\r
+\r
+ if (patch.GetSource().GetMediaFormat().GetMediaType() != OpalMediaType::Audio())\r
+ return;\r
+\r
+ if (switch_channel_direction(m_fsChannel) == SWITCH_CALL_DIRECTION_INBOUND) {\r
+ if (isSource)\r
+ m_rxAudioOpened.Signal();\r
+ else\r
+ m_txAudioOpened.Signal();\r
+ }\r
+ else if (GetMediaStream(OpalMediaType::Audio(), !isSource) != NULL) {\r
+ // Have open media in both directions.\r
+ if (IsEstablished())\r
+ switch_channel_mark_answered(m_fsChannel);\r
+ else if (!IsReleased())\r
+ switch_channel_mark_pre_answered(m_fsChannel);\r
+ }\r
+}\r
+\r
+\r
+switch_status_t FSConnection::on_init()\r
+{\r
+ if (PAssertNULL(m_fsChannel) == NULL)\r
+ return SWITCH_STATUS_FALSE;\r
+\r
+ PTRACE(4, "mod_opal\tStarted routing for connection " << *this);\r
+ switch_channel_set_state(m_fsChannel, CS_ROUTING);\r
+ return SWITCH_STATUS_SUCCESS;\r
+}\r
+\r
+\r
+switch_status_t FSConnection::on_routing()\r
+{\r
+ if (PAssertNULL(m_fsChannel) == NULL)\r
+ return SWITCH_STATUS_FALSE;\r
+\r
+ PTRACE(4, "mod_opal\tRouting connection " << *this);\r
+ return SWITCH_STATUS_SUCCESS;\r
+}\r
+\r
+\r
+switch_status_t FSConnection::on_execute()\r
+{\r
+ if (PAssertNULL(m_fsChannel) == NULL)\r
+ return SWITCH_STATUS_FALSE;\r
+\r
+ PTRACE(4, "mod_opal\tExecuting connection " << *this);\r
+ return SWITCH_STATUS_SUCCESS;\r
+}\r
+\r
+\r
+switch_status_t FSConnection::on_destroy()\r
+{\r
+ PTRACE(3, "mod_opal\tFS on_destroy for connection " << *this);\r
+\r
+ m_fsChannel = NULL; // Will be destoyed by FS, so don't use it any more.\r
+\r
+ switch_core_codec_destroy(&m_read_codec);\r
+ switch_core_codec_destroy(&m_write_codec);\r
+ switch_core_codec_destroy(&m_vid_read_codec);\r
+ switch_core_codec_destroy(&m_vid_write_codec);\r
+ switch_core_timer_destroy(&m_read_timer);\r
+ switch_core_timer_destroy(&m_vid_read_timer);\r
+\r
+ switch_core_session_set_private(m_fsSession, NULL);\r
+ SafeDereference();\r
+\r
+ return SWITCH_STATUS_SUCCESS;\r
+}\r
+\r
+\r
+switch_status_t FSConnection::on_hangup()\r
+{\r
+ if (PAssertNULL(m_fsChannel) == NULL)\r
+ return SWITCH_STATUS_FALSE;\r
+\r
+ /* if this is still here it was our idea to hangup not opal's */\r
+ ClearCallSynchronous(NULL, H323TranslateToCallEndReason(\r
+ (Q931::CauseValues)switch_channel_get_cause_q850(m_fsChannel), UINT_MAX));\r
+\r
+ return SWITCH_STATUS_SUCCESS;\r
+}\r
+\r
+\r
+switch_status_t FSConnection::on_exchange_media()\r
+{\r
+ PTRACE(4, "mod_opal\tExchanging media on connection " << *this);\r
+ return SWITCH_STATUS_SUCCESS;\r
+}\r
+\r
+\r
+switch_status_t FSConnection::on_soft_execute()\r
+{\r
+ PTRACE(4, "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
+ switch (sig) {\r
+ case SWITCH_SIG_KILL:\r
+ m_rxAudioOpened.Signal();\r
+ m_txAudioOpened.Signal();\r
+ PTRACE(4, "mod_opal\tSignal channel KILL on connection " << *this);\r
+ break;\r
+ case SWITCH_SIG_XFER:\r
+ case SWITCH_SIG_BREAK:\r
+ default:\r
+ PTRACE(4, "mod_opal\tSignal channel " << sig << " on connection " << *this);\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
+ if (PAssertNULL(m_fsChannel) == NULL)\r
+ return SWITCH_STATUS_FALSE;\r
+\r
+ switch (msg->message_id) {\r
+ case SWITCH_MESSAGE_INDICATE_RINGING:\r
+ case SWITCH_MESSAGE_INDICATE_PROGRESS:\r
+ case SWITCH_MESSAGE_INDICATE_ANSWER:\r
+ case SWITCH_MESSAGE_INDICATE_DEFLECT:\r
+ if (switch_channel_direction(m_fsChannel) == SWITCH_CALL_DIRECTION_INBOUND) {\r
+ switch_caller_profile_t * profile = switch_channel_get_caller_profile(m_fsChannel);\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
+ else {\r
+ return SWITCH_STATUS_FALSE;\r
+ }\r
+ break;\r
+\r
+ default:\r
+ break;\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
+ m_flushAudio = true;\r
+ break;\r
+\r
+ case SWITCH_MESSAGE_INDICATE_RINGING:\r
+ AlertingIncoming();\r
+ break;\r
+\r
+ case SWITCH_MESSAGE_INDICATE_PROGRESS:\r
+ AutoStartMediaStreams();\r
+ AlertingIncoming();\r
+\r
+ if (!WaitForMedia())\r
+ return SWITCH_STATUS_FALSE;\r
+\r
+ if (!switch_channel_test_flag(m_fsChannel, CF_EARLY_MEDIA)) {\r
+ switch_channel_mark_pre_answered(m_fsChannel);\r
+ }\r
+ break;\r
+\r
+ case SWITCH_MESSAGE_INDICATE_ANSWER:\r
+ AcceptIncoming();\r
+\r
+ if (!WaitForMedia())\r
+ return SWITCH_STATUS_FALSE;\r
+\r
+ if (!switch_channel_test_flag(m_fsChannel, CF_ANSWERED)) {\r
+ switch_channel_mark_answered(m_fsChannel);\r
+ }\r
+ break;\r
+\r
+ case SWITCH_MESSAGE_INDICATE_DEFLECT:\r
+ ownerCall.Transfer(msg->string_arg, GetOtherPartyConnection());\r
+ break;\r
+\r
+ default:\r
+ PTRACE(3, "mod_opal\tReceived unhandled message " << msg->message_id << " on connection " << *this);\r
+ }\r
+\r
+ return SWITCH_STATUS_SUCCESS;\r
+}\r
+\r
+\r
+bool FSConnection::WaitForMedia()\r
+{\r
+ PTRACE(4, "mod_opal\tAwaiting media start on connection " << *this);\r
+ m_rxAudioOpened.Wait();\r
+ m_txAudioOpened.Wait();\r
+\r
+ if (IsReleased()) {\r
+ // Call got aborted\r
+ switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(m_fsSession), SWITCH_LOG_ERROR, "Call abandoned!\n");\r
+ return false;\r
+ }\r
+\r
+ PTRACE(3, "mod_opal\tMedia started on connection " << *this);\r
+ return true;\r
+}\r
+\r
+\r
+switch_status_t FSConnection::receive_event(switch_event_t *event)\r
+{\r
+ PTRACE(4, "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(4, "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_connection(conn)\r
+ , m_readRTP(0, SWITCH_RECOMMENDED_BUFFER_SIZE)\r
+{\r
+ memset(&m_readFrame, 0, sizeof(m_readFrame));\r
+}\r
+\r
+\r
+PBoolean FSMediaStream::Open()\r
+{\r
+ if (IsOpen()) {\r
+ return true;\r
+ }\r
+\r
+ switch_core_session_t *fsSession = m_connection.GetSession();\r
+ switch_channel_t *fsChannel = m_connection.GetChannel();\r
+ if (PAssertNULL(fsSession) == NULL || PAssertNULL(fsChannel) == NULL)\r
+ return false;\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 false;\r
+ }\r
+\r
+ int ptime = mediaFormat.GetOptionInteger(OpalAudioFormat::TxFramesPerPacketOption()) * mediaFormat.GetFrameTime() / mediaFormat.GetTimeUnits();\r
+\r
+ if (IsSink()) {\r
+ m_switchCodec = isAudio ? &m_connection.m_read_codec : &m_connection.m_vid_read_codec;\r
+ m_switchTimer = isAudio ? &m_connection.m_read_timer : &m_connection.m_vid_read_timer;\r
+ m_readFrame.codec = m_switchCodec;\r
+ m_readFrame.rate = mediaFormat.GetClockRate();\r
+ } else {\r
+ m_switchCodec = isAudio ? &m_connection.m_write_codec : &m_connection.m_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(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(fsSession)) != SWITCH_STATUS_SUCCESS) {\r
+ PTRACE(1, "mod_opal\t" << switch_channel_get_name(fsChannel)\r
+ << " cannot initialise " << (IsSink()? "read" : "write") << ' '\r
+ << mediaFormat.GetMediaType() << " codec " << mediaFormat << " for connection " << *this);\r
+ switch_channel_hangup(fsChannel, SWITCH_CAUSE_INCOMPATIBLE_DESTINATION);\r
+ return false;\r
+ }\r
+ PTRACE(2, "mod_opal\t" << switch_channel_get_name(fsChannel)\r
+ << " unsupported ptime of " << ptime << " on " << (IsSink()? "read" : "write") << ' '\r
+ << mediaFormat.GetMediaType() << " codec " << mediaFormat << " for connection " << *this);\r
+ }\r
+\r
+ if (IsSink()) {\r
+ if (isAudio) {\r
+ switch_core_session_set_read_codec(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(fsSession)) != SWITCH_STATUS_SUCCESS) {\r
+ PTRACE(1, "mod_opal\t" << switch_channel_get_name(fsChannel)\r
+ << " timer init failed on " << (IsSink()? "read" : "write") << ' '\r
+ << mediaFormat.GetMediaType() << " codec " << mediaFormat << " for connection " << *this);\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(fsSession, m_switchCodec);\r
+ switch_channel_set_flag(fsChannel, CF_VIDEO);\r
+ }\r
+ } else {\r
+ if (isAudio) {\r
+ switch_core_session_set_write_codec(fsSession, m_switchCodec);\r
+ } else {\r
+ switch_core_session_set_video_write_codec(fsSession, m_switchCodec);\r
+ switch_channel_set_flag(fsChannel, CF_VIDEO);\r
+ }\r
+ }\r
+\r
+ PTRACE(3, "mod_opal\t" << switch_channel_get_name(fsChannel)\r
+ << " initialised " << (IsSink()? "read" : "write") << ' '\r
+ << mediaFormat.GetMediaType() << " codec " << mediaFormat << " for connection " << *this);\r
+\r
+ return OpalMediaStream::Open();\r
+}\r
+\r
+\r
+void FSMediaStream::InternalClose()\r
+{\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
+\r
+int FSMediaStream::StartReadWrite(PatchPtr & mediaPatch) const\r
+{\r
+ if (!IsOpen()) {\r
+ PTRACE(2, "mod_opal\tNot open!");\r
+ return -1;\r
+ }\r
+\r
+ if (!m_switchCodec) {\r
+ PTRACE(2, "mod_opal\tNo codec!");\r
+ return -1;\r
+ }\r
+\r
+ if (!m_connection.IsChannelReady()) {\r
+ PTRACE(2, "mod_opal\tChannel not ready!");\r
+ return -1;\r
+ }\r
+\r
+ // We make referenced copy of pointer so can't be deleted out from under us\r
+ mediaPatch = m_mediaPatch;\r
+ if (mediaPatch == NULL) {\r
+ /*There is a race here... sometimes we make it here and m_mediaPatch is NULL\r
+ if we wait it shows up in 1ms, maybe there is a better way to wait. */\r
+ PTRACE(3, "mod_opal\tPatch not ready!");\r
+ return 1;\r
+ }\r
+\r
+ return 0;\r
+}\r
+\r
+\r
+switch_status_t FSMediaStream::read_frame(switch_frame_t **frame, switch_io_flag_t flags)\r
+{\r
+ PatchPtr mediaPatch;\r
+ switch (StartReadWrite(mediaPatch)) {\r
+ case -1 :\r
+ return SWITCH_STATUS_FALSE;\r
+ case 1 :\r
+ return SWITCH_STATUS_SUCCESS;\r
+ }\r
+\r
+ if (m_connection.NeedFlushAudio()) {\r
+ mediaPatch->GetSource().EnableJitterBuffer(); // This flushes data and resets jitter buffer\r
+ m_readRTP.SetPayloadSize(0);\r
+ } else {\r
+ m_readRTP.SetTimestamp(m_readFrame.timestamp + m_switchCodec->implementation->samples_per_packet);\r
+\r
+ if (!mediaPatch->GetSource().ReadPacket(m_readRTP)) {\r
+ return SWITCH_STATUS_FALSE;\r
+ }\r
+ }\r
+\r
+ if (m_switchTimer != NULL) {\r
+ switch_core_timer_next(m_switchTimer);\r
+ }\r
+\r
+ if (m_switchCodec != NULL) {\r
+ if (!switch_core_codec_ready(m_switchCodec)) {\r
+ PTRACE(2, "mod_opal\tread_frame: codec not ready!");\r
+ return SWITCH_STATUS_FALSE;\r
+ }\r
+ }\r
+\r
+ m_readFrame.packet = m_readRTP.GetPointer();\r
+ m_readFrame.packetlen = m_readRTP.GetHeaderSize() + m_readFrame.datalen;\r
+\r
+#if IMPLEMENT_MULTI_FAME_AUDIO\r
+ // Repackage frames in incoming packet to agree with what FS expects.\r
+ // Not implmented yet!!!!!!!!!\r
+ // Cheating and only supporting one frame per packet\r
+#endif\r
+\r
+ m_readFrame.buflen = m_readRTP.GetSize();\r
+ m_readFrame.data = m_readRTP.GetPayloadPtr();\r
+ m_readFrame.datalen = m_readRTP.GetPayloadSize();\r
+ m_readFrame.timestamp = m_readRTP.GetTimestamp();\r
+ m_readFrame.seq = m_readRTP.GetSequenceNumber();\r
+ m_readFrame.ssrc = m_readRTP.GetSyncSource();\r
+ m_readFrame.m = m_readRTP.GetMarker() ? SWITCH_TRUE : SWITCH_FALSE;\r
+ m_readFrame.payload = (switch_payload_t)m_readRTP.GetPayloadType();\r
+ m_readFrame.flags = m_readFrame.datalen == 0 ||\r
+ m_readFrame.payload == RTP_DataFrame::CN ||\r
+ m_readFrame.payload == RTP_DataFrame::Cisco_CN ? SFF_CNG : 0;\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
+ PatchPtr mediaPatch;\r
+ switch (StartReadWrite(mediaPatch)) {\r
+ case -1 :\r
+ return SWITCH_STATUS_FALSE;\r
+ case 1 :\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
+ return mediaPatch->PushFrame(rtp) ? SWITCH_STATUS_SUCCESS : SWITCH_STATUS_FALSE;\r
+ }\r
+\r
+ RTP_DataFrame rtp(frame->datalen);\r
+ memcpy(rtp.GetPayloadPtr(), frame->data, frame->datalen);\r
+\r
+ rtp.SetPayloadType(mediaFormat.GetPayloadType());\r
+\r
+ /* Not sure what FS is going to give us!\r
+ Suspect it depends on the mod on the other side sending it. */\r
+ if (frame->timestamp != 0)\r
+ timestamp = frame->timestamp;\r
+ else if (frame->samples != 0)\r
+ timestamp += frame->samples;\r
+ else\r
+ timestamp += m_switchCodec->implementation->samples_per_packet;\r
+ rtp.SetTimestamp(timestamp);\r
+\r
+ return mediaPatch->PushFrame(rtp) ? SWITCH_STATUS_SUCCESS : 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)
- *
- */
-
-
-#ifndef __FREESWITCH_MOD_OPAL__
-#define __FREESWITCH_MOD_OPAL__
-
-#if defined(__GNUC__) && defined(HAVE_VISIBILITY)
-#pragma GCC visibility push(default)
-#endif
-
-#include <ptlib.h>
-#include <opal/manager.h>
-#include <opal/localep.h>
-#include <h323/h323ep.h>
-#include <iax2/iax2ep.h>
-
-#if defined(__GNUC__) && defined(HAVE_VISIBILITY)
-#pragma GCC visibility pop
-#endif
-
-#undef strcasecmp
-#undef strncasecmp
-
-#define HAVE_APR
-#include <switch.h>
-#include <switch_version.h>
-#define MODNAME "mod_opal"
-
-
-class FSEndPoint;
-class FSManager;
-
-
-struct mod_opal_globals {
- int trace_level;
- char *codec_string;
- char *context;
- char *dialplan;
-};
-
-extern struct mod_opal_globals mod_opal_globals;
-
-
-class FSProcess:public PLibraryProcess {
- PCLASSINFO(FSProcess, PLibraryProcess);
-
- public:
- FSProcess();
- ~FSProcess();
-
- bool Initialise(switch_loadable_module_interface_t *iface);
-
- FSManager & GetManager() const {
- return *m_manager;
- } protected:
- FSManager * m_manager;
-};
-
-
-struct FSListener {
- FSListener() {
- } PString name;
- OpalTransportAddress listenAddress;
- PString localUserName;
- PString gatekeeper;
-};
-
-
-class FSCall:public OpalCall {
- PCLASSINFO(FSCall, OpalCall);
- public:
- FSCall(OpalManager & manager);
- virtual PBoolean OnSetUp(OpalConnection & connection);
-};
-
-
-class FSManager:public OpalManager {
- PCLASSINFO(FSManager, OpalManager);
-
- public:
- FSManager();
-
- bool Initialise(switch_loadable_module_interface_t *iface);
-
- switch_status_t ReadConfig(int reload);
-
- switch_endpoint_interface_t *GetSwitchInterface() const {
- return m_FreeSwitch;
- } virtual OpalCall *CreateCall(void *userData);
-
- private:
- switch_endpoint_interface_t *m_FreeSwitch;
-
- H323EndPoint *m_h323ep;
- IAX2EndPoint *m_iaxep;
- FSEndPoint *m_fsep;
-
- PString m_gkAddress;
- PString m_gkIdentifer;
- PString m_gkInterface;
-
- list < FSListener > m_listeners;
-};
-
-
-class FSConnection;
-typedef struct {
- switch_timer_t read_timer;
- switch_codec_t read_codec;
- switch_codec_t write_codec;
-
- switch_timer_t vid_read_timer;
- switch_codec_t vid_read_codec;
- switch_codec_t vid_write_codec;
- FSConnection *me;
-} opal_private_t;
-
-
-class FSEndPoint:public OpalLocalEndPoint {
- PCLASSINFO(FSEndPoint, OpalLocalEndPoint);
- public:
- FSEndPoint(FSManager & manager);
-
- virtual bool OnIncomingCall(OpalLocalConnection &);
- virtual OpalLocalConnection *CreateConnection(OpalCall & call, void *userData, unsigned options, OpalConnection::StringOptions * stringOptions);
-};
-
-
-#define DECLARE_CALLBACK0(name) \
- static switch_status_t name(switch_core_session_t *session) { \
- opal_private_t *tech_pvt = (opal_private_t *) switch_core_session_get_private(session); \
- return tech_pvt && tech_pvt->me != NULL ? tech_pvt->me->name() : SWITCH_STATUS_FALSE; } \
-switch_status_t name()
-
-#define DECLARE_CALLBACK1(name, type1, name1) \
- static switch_status_t name(switch_core_session_t *session, type1 name1) { \
- opal_private_t *tech_pvt = (opal_private_t *) switch_core_session_get_private(session); \
- return tech_pvt && tech_pvt->me != NULL ? tech_pvt->me->name(name1) : SWITCH_STATUS_FALSE; } \
-switch_status_t name(type1 name1)
-
-#define DECLARE_CALLBACK3(name, type1, name1, type2, name2, type3, name3) \
- static switch_status_t name(switch_core_session_t *session, type1 name1, type2 name2, type3 name3) { \
- opal_private_t *tech_pvt = (opal_private_t *) switch_core_session_get_private(session); \
- return tech_pvt && tech_pvt->me != NULL ? tech_pvt->me->name(name1, name2, name3) : SWITCH_STATUS_FALSE; } \
-switch_status_t name(type1 name1, type2 name2, type3 name3)
-
-
-
-
-class FSConnection:public OpalLocalConnection {
- PCLASSINFO(FSConnection, OpalLocalConnection)
-
- public:
- 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);
-
- virtual bool OnIncoming();
- virtual void OnReleased();
- virtual PBoolean SetAlerting(const PString & calleeName, PBoolean withMedia);
- virtual void OnAlerting();
- virtual void OnEstablished();
- virtual OpalMediaStream *CreateMediaStream(const OpalMediaFormat &, unsigned, PBoolean);
- virtual PBoolean OnOpenMediaStream(OpalMediaStream & stream);
- virtual OpalMediaFormatList GetMediaFormats() const;
- virtual PBoolean SendUserInputTone(char tone, unsigned duration);
- virtual PBoolean SendUserInputString(const PString & value);
-
- void SetCodecs();
-
- DECLARE_CALLBACK0(on_init);
- DECLARE_CALLBACK0(on_routing);
- DECLARE_CALLBACK0(on_execute);
-
- DECLARE_CALLBACK0(on_exchange_media);
- DECLARE_CALLBACK0(on_soft_execute);
-
- DECLARE_CALLBACK1(kill_channel, int, sig);
- DECLARE_CALLBACK1(send_dtmf, const switch_dtmf_t *, dtmf);
- DECLARE_CALLBACK1(receive_message, switch_core_session_message_t *, msg);
- DECLARE_CALLBACK1(receive_event, switch_event_t *, event);
- DECLARE_CALLBACK0(state_change);
- DECLARE_CALLBACK3(read_audio_frame, switch_frame_t **, frame, switch_io_flag_t, flags, int, stream_id);
- DECLARE_CALLBACK3(write_audio_frame, switch_frame_t *, frame, switch_io_flag_t, flags, int, stream_id);
- DECLARE_CALLBACK3(read_video_frame, switch_frame_t **, frame, switch_io_flag_t, flag, int, stream_id);
- DECLARE_CALLBACK3(write_video_frame, switch_frame_t *, frame, switch_io_flag_t, flag, int, stream_id);
-
- switch_status_t read_frame(const OpalMediaType & mediaType, switch_frame_t **frame, switch_io_flag_t flags);
- switch_status_t write_frame(const OpalMediaType & mediaType, const switch_frame_t *frame, switch_io_flag_t flags);
-
- switch_core_session_t *GetSession() const {
- return m_fsSession;
- } private:
- FSEndPoint & m_endpoint;
- switch_core_session_t *m_fsSession;
- switch_channel_t *m_fsChannel;
- PSyncPoint m_rxAudioOpened;
- PSyncPoint m_txAudioOpened;
- OpalMediaFormatList m_switchMediaFormats;
-};
-
-
-class FSMediaStream:public OpalMediaStream {
- PCLASSINFO(FSMediaStream, OpalMediaStream);
- public:
- FSMediaStream(FSConnection & conn, const OpalMediaFormat & mediaFormat, ///< Media format for stream
- unsigned sessionID, ///< Session number for stream
- bool isSource ///< Is a source stream
- );
-
- virtual PBoolean Open();
- virtual PBoolean Close();
- virtual PBoolean IsSynchronous() const;
- virtual PBoolean RequiresPatchThread(OpalMediaStream *) const;
-
- switch_status_t read_frame(switch_frame_t **frame, switch_io_flag_t flags);
- switch_status_t write_frame(const switch_frame_t *frame, switch_io_flag_t flags);
-
- private:
- switch_core_session_t *m_fsSession;
- switch_channel_t *m_fsChannel;
- switch_timer_t *m_switchTimer;
- switch_codec_t *m_switchCodec;
- switch_frame_t m_readFrame;
- unsigned char m_buf[SWITCH_RECOMMENDED_BUFFER_SIZE];
- RTP_DataFrame m_readRTP;
- bool m_callOnStart;
- uint32_t m_timeStamp;
-
- bool CheckPatchAndLock();
-};
-
-
-#endif /* __FREESWITCH_MOD_OPAL__ */
-
-/* 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:
- */
+/* 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
+ * Copyright (c) 2008-2012 Vox Lucida Pty. Ltd. (robertj@voxlucida.com.au)\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
+\r
+#ifndef __FREESWITCH_MOD_OPAL__\r
+#define __FREESWITCH_MOD_OPAL__\r
+\r
+#if defined(__GNUC__) && defined(HAVE_VISIBILITY)\r
+#pragma GCC visibility push(default)\r
+#endif\r
+\r
+#include <ptlib.h>\r
+#include <opal/manager.h>\r
+#include <opal/localep.h>\r
+#include <h323/h323ep.h>\r
+#include <iax2/iax2ep.h>\r
+\r
+#if defined(__GNUC__) && defined(HAVE_VISIBILITY)\r
+#pragma GCC visibility pop\r
+#endif\r
+\r
+#undef strcasecmp\r
+#undef strncasecmp\r
+\r
+\r
+#if _MSC_VER < 1600\r
+/*The following insanity is because libteletone_generate.h defines int8_t in\r
+ a slightly different manner to most other cases (SDL, PCAP, Java V8, stdint.h\r
+ etc) and does not provide a mechanism to prevent it's inclusion. Then, to\r
+ cap it off, VS2008 barfs on the difference. VS2010 seems OK with it.\r
+\r
+ Sigh.\r
+ */\r
+#pragma include_alias(<libteletone.h>, <../../libs/libteletone/src/libteletone.h>)\r
+#pragma include_alias(<libteletone_generate.h>, <../../libs/libteletone/src/libteletone_generate.h>)\r
+#pragma include_alias(<libteletone_detect.h>, <../../libs/libteletone/src/libteletone_detect.h>)\r
+#define int8_t signed int8_t\r
+#include <libteletone_generate.h>\r
+#undef int8_t\r
+#endif // End of insanity\r
+\r
+\r
+#define HAVE_APR\r
+#define uint32_t uint32_t // Avoid conflict in stdint definitions\r
+#include <switch.h>\r
+#undef uint32_t\r
+\r
+#include <switch_version.h>\r
+\r
+\r
+#define MODNAME "mod_opal"\r
+\r
+\r
+class FSEndPoint;\r
+class FSManager;\r
+\r
+\r
+class FSProcess : public PLibraryProcess\r
+{\r
+ PCLASSINFO(FSProcess, PLibraryProcess);\r
+ public:\r
+ FSProcess();\r
+ ~FSProcess();\r
+\r
+ bool Initialise(switch_loadable_module_interface_t *iface);\r
+\r
+ FSManager & GetManager() const\r
+ {\r
+ return *m_manager;\r
+ }\r
+\r
+ protected:\r
+ FSManager * m_manager;\r
+};\r
+\r
+\r
+struct FSListener\r
+{\r
+ FSListener() : m_port(H323EndPoint::DefaultTcpSignalPort) { }\r
+\r
+ PString m_name;\r
+ PIPSocket::Address m_address;\r
+ uint16_t m_port;\r
+};\r
+\r
+\r
+class FSManager : public OpalManager\r
+{\r
+ PCLASSINFO(FSManager, OpalManager);\r
+\r
+ public:\r
+ FSManager();\r
+\r
+ bool Initialise(switch_loadable_module_interface_t *iface);\r
+\r
+ switch_status_t ReadConfig(int reload);\r
+\r
+ switch_endpoint_interface_t *GetSwitchInterface() const { return m_FreeSwitch; }\r
+ const PString & GetContext() const { return m_context; }\r
+ const PString & GetDialPlan() const { return m_dialplan; }\r
+ const PString & GetCodecPrefs() const { return m_codecPrefs; }\r
+ bool GetDisableTranscoding() const { return m_disableTranscoding; }\r
+\r
+ private:\r
+ switch_endpoint_interface_t *m_FreeSwitch;\r
+\r
+ H323EndPoint *m_h323ep;\r
+ IAX2EndPoint *m_iaxep;\r
+ FSEndPoint *m_fsep;\r
+\r
+ PString m_context;\r
+ PString m_dialplan;\r
+ PString m_codecPrefs;\r
+ bool m_disableTranscoding;\r
+ PString m_gkAddress;\r
+ PString m_gkIdentifer;\r
+ PString m_gkInterface;\r
+\r
+ list <FSListener> m_listeners;\r
+};\r
+\r
+\r
+class FSEndPoint : public OpalLocalEndPoint\r
+{\r
+ PCLASSINFO(FSEndPoint, OpalLocalEndPoint);\r
+ public:\r
+ FSEndPoint(FSManager & manager);\r
+\r
+ virtual OpalLocalConnection *CreateConnection(OpalCall & call, void *userData, unsigned options, OpalConnection::StringOptions * stringOptions);\r
+\r
+ FSManager & GetManager() const { return m_manager; }\r
+\r
+ protected:\r
+ FSManager & m_manager;\r
+};\r
+\r
+\r
+class FSConnection;\r
+\r
+\r
+class FSMediaStream : public OpalMediaStream\r
+{\r
+ PCLASSINFO(FSMediaStream, OpalMediaStream);\r
+ public:\r
+ FSMediaStream(\r
+ FSConnection & conn,\r
+ const OpalMediaFormat & mediaFormat, ///< Media format for stream\r
+ unsigned sessionID, ///< Session number for stream\r
+ bool isSource ///< Is a source stream\r
+ );\r
+\r
+ virtual PBoolean Open();\r
+ virtual PBoolean IsSynchronous() const;\r
+ virtual PBoolean RequiresPatchThread(OpalMediaStream *) const;\r
+\r
+ switch_status_t read_frame(switch_frame_t **frame, switch_io_flag_t flags);\r
+ switch_status_t write_frame(const switch_frame_t *frame, switch_io_flag_t flags);\r
+\r
+ protected:\r
+ virtual void InternalClose();\r
+ int StartReadWrite(PatchPtr & mediaPatch) const;\r
+\r
+ private:\r
+ bool CheckPatchAndLock();\r
+\r
+ FSConnection &m_connection;\r
+ switch_timer_t *m_switchTimer;\r
+ switch_codec_t *m_switchCodec;\r
+ switch_frame_t m_readFrame;\r
+ RTP_DataFrame m_readRTP;\r
+};\r
+\r
+\r
+#define DECLARE_CALLBACK0(name) \\r
+ static switch_status_t name(switch_core_session_t *session) { \\r
+ FSConnection *tech_pvt = (FSConnection *) switch_core_session_get_private(session); \\r
+ return tech_pvt != NULL ? tech_pvt->name() : SWITCH_STATUS_FALSE; } \\r
+ switch_status_t name()\r
+\r
+#define DECLARE_CALLBACK1(name, type1, name1) \\r
+ static switch_status_t name(switch_core_session_t *session, type1 name1) { \\r
+ FSConnection *tech_pvt = (FSConnection *) switch_core_session_get_private(session); \\r
+ return tech_pvt != NULL ? tech_pvt->name(name1) : SWITCH_STATUS_FALSE; } \\r
+ switch_status_t name(type1 name1)\r
+\r
+#define DECLARE_CALLBACK3(name, type1, name1, type2, name2, type3, name3) \\r
+ static switch_status_t name(switch_core_session_t *session, type1 name1, type2 name2, type3 name3) { \\r
+ FSConnection *tech_pvt = (FSConnection *) switch_core_session_get_private(session); \\r
+ return tech_pvt != NULL ? tech_pvt->name(name1, name2, name3) : SWITCH_STATUS_FALSE; } \\r
+ switch_status_t name(type1 name1, type2 name2, type3 name3)\r
+\r
+\r
+\r
+\r
+class FSConnection : public OpalLocalConnection\r
+{\r
+ PCLASSINFO(FSConnection, OpalLocalConnection)\r
+\r
+ public:\r
+ struct outgoing_params {\r
+ switch_event_t *var_event;\r
+ switch_caller_profile_t *outbound_profile;\r
+ switch_core_session_t **new_session;\r
+ switch_memory_pool_t **pool;\r
+ switch_originate_flag_t flags;\r
+ switch_call_cause_t *cancel_cause;\r
+ switch_call_cause_t fail_cause;\r
+ };\r
+\r
+ FSConnection(OpalCall & call,\r
+ FSEndPoint & endpoint,\r
+ unsigned options,\r
+ OpalConnection::StringOptions * stringOptions,\r
+ outgoing_params * params);\r
+\r
+ virtual bool OnOutgoingSetUp();\r
+ virtual bool OnIncoming();\r
+ virtual void OnReleased();\r
+ virtual PBoolean SetAlerting(const PString & calleeName, PBoolean withMedia);\r
+ virtual OpalMediaStream *CreateMediaStream(const OpalMediaFormat &, unsigned, PBoolean);\r
+ virtual void OnPatchMediaStream(PBoolean isSource, OpalMediaPatch & patch);\r
+ virtual OpalMediaFormatList GetMediaFormats() const;\r
+ virtual PBoolean SendUserInputTone(char tone, unsigned duration);\r
+\r
+ DECLARE_CALLBACK0(on_init);\r
+ DECLARE_CALLBACK0(on_destroy);\r
+ DECLARE_CALLBACK0(on_routing);\r
+ DECLARE_CALLBACK0(on_execute);\r
+ DECLARE_CALLBACK0(on_hangup);\r
+\r
+ DECLARE_CALLBACK0(on_exchange_media);\r
+ DECLARE_CALLBACK0(on_soft_execute);\r
+\r
+ DECLARE_CALLBACK1(kill_channel, int, sig);\r
+ DECLARE_CALLBACK1(send_dtmf, const switch_dtmf_t *, dtmf);\r
+ DECLARE_CALLBACK1(receive_message, switch_core_session_message_t *, msg);\r
+ DECLARE_CALLBACK1(receive_event, switch_event_t *, event);\r
+ DECLARE_CALLBACK0(state_change);\r
+ DECLARE_CALLBACK3(read_audio_frame, switch_frame_t **, frame, switch_io_flag_t, flags, int, stream_id);\r
+ DECLARE_CALLBACK3(write_audio_frame, switch_frame_t *, frame, switch_io_flag_t, flags, int, stream_id);\r
+ DECLARE_CALLBACK3(read_video_frame, switch_frame_t **, frame, switch_io_flag_t, flag, int, stream_id);\r
+ DECLARE_CALLBACK3(write_video_frame, switch_frame_t *, frame, switch_io_flag_t, flag, int, stream_id);\r
+\r
+ __inline switch_core_session_t *GetSession() const\r
+ {\r
+ return m_fsSession;\r
+ }\r
+\r
+ __inline switch_channel_t *GetChannel() const\r
+ {\r
+ return m_fsChannel;\r
+ }\r
+\r
+ bool IsChannelReady() const\r
+ {\r
+ return m_fsChannel != NULL && switch_channel_ready(m_fsChannel);\r
+ }\r
+\r
+ bool NeedFlushAudio()\r
+ {\r
+ if (!m_flushAudio)\r
+ return false;\r
+ m_flushAudio = false;\r
+ return true;\r
+ }\r
+\r
+ protected:\r
+ void SetCodecs();\r
+ bool WaitForMedia();\r
+\r
+ switch_status_t read_frame(const OpalMediaType & mediaType, switch_frame_t **frame, switch_io_flag_t flags);\r
+ switch_status_t write_frame(const OpalMediaType & mediaType, const switch_frame_t *frame, switch_io_flag_t flags);\r
+\r
+ private:\r
+ FSEndPoint &m_endpoint;\r
+ switch_core_session_t *m_fsSession;\r
+ switch_channel_t *m_fsChannel;\r
+ PSyncPoint m_rxAudioOpened;\r
+ PSyncPoint m_txAudioOpened;\r
+ OpalMediaFormatList m_switchMediaFormats;\r
+\r
+ // If FS ever supports more than one audio and one video, this needs to change\r
+ switch_timer_t m_read_timer;\r
+ switch_codec_t m_read_codec;\r
+ switch_codec_t m_write_codec;\r
+\r
+ switch_timer_t m_vid_read_timer;\r
+ switch_codec_t m_vid_read_codec;\r
+ switch_codec_t m_vid_write_codec;\r
+\r
+ bool m_flushAudio;\r
+\r
+ friend PBoolean FSMediaStream::Open();\r
+};\r
+\r
+\r
+#endif /* __FREESWITCH_MOD_OPAL__ */\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
projects / thirdparty / freeswitch.git / commitdiff
