Open Settlement Protocol (OSP) Applications. More...

#include "asterisk.h"
#include <osp/osp.h>
#include <osp/osputils.h>
#include <osp/ospb64.h>
#include "asterisk/paths.h"
#include "asterisk/lock.h"
#include "asterisk/config.h"
#include "asterisk/utils.h"
#include "asterisk/causes.h"
#include "asterisk/channel.h"
#include "asterisk/app.h"
#include "asterisk/module.h"
#include "asterisk/pbx.h"
#include "asterisk/cli.h"
#include "asterisk/astosp.h"

Include dependency graph for app_osplookup.c:

Go to the source code of this file.

Data Structures
struct	osp_callid
struct	osp_headers
struct	osp_metrics
struct	osp_npdata
struct	osp_provider
struct	osp_results
Defines
#define	OSP_AST_ERROR ((int)-1) /* Asterisk function call error */
#define	OSP_AST_OK ((int)0) /* Asterisk function call successful */
#define	OSP_AUDIT_URL ((const char)"localhost") / OSP default Audit URL */
#define	OSP_CALLID_H323 ((unsigned int)(1 << 1)) /* H.323 */
#define	OSP_CALLID_IAX ((unsigned int)(1 << 2)) /* IAX2 */
#define	OSP_CALLID_MAXNUM ((unsigned int)3) /* Max number of call ID types */
#define	OSP_CALLID_SIP ((unsigned int)(1 << 0)) /* SIP */
#define	OSP_CALLID_UNDEF ((unsigned int)0) /* Undefined */
#define	OSP_CONFIG_FILE ((const char)"osp.conf") / OSP configuration file name */
#define	OSP_CUSTOMER_ID ((const char)"") / OSP customer ID */
#define	OSP_DEF_AUTHPOLICY OSP_AUTH_YES /* OSP default auth policy, yes */
#define	OSP_DEF_FLOATSTATS ((float)-1) /* OSP default float statistic */
#define	OSP_DEF_INTSTATS ((int)-1) /* OSP default int statistic */
#define	OSP_DEF_MAXCONNECT ((unsigned int)20) /* OSP default max_connections */
#define	OSP_DEF_MAXDESTS ((unsigned int)12) /* OSP default max number of destinations */
#define	OSP_DEF_PROTOCOL OSP_PROT_SIP /* OSP default signaling protocol, SIP */
#define	OSP_DEF_PROVIDER ((const char)"default") / OSP default provider context name */
#define	OSP_DEF_RETRYDELAY ((unsigned int)0) /* OSP default retry delay */
#define	OSP_DEF_RETRYLIMIT ((unsigned int)2) /* OSP default retry times */
#define	OSP_DEF_SRVTYPE OSP_SRV_VOICE /* OSP default service type, voice */
#define	OSP_DEF_TIMELIMIT ((unsigned int)0) /* OSP default duration limit, no limit */
#define	OSP_DEF_TIMEOUT ((unsigned int)500) /* OSP default timeout in ms */
#define	OSP_DEF_WORKMODE OSP_MODE_DIRECT /* OSP default work mode, direct */
#define	OSP_DEVICE_ID ((const char)"") / OSP device ID */
#define	OSP_ERROR ((int)-1) /* OSP function call error */
#define	OSP_FAILED ((int)0) /* OSP function call failed */
#define	OSP_GENERAL_CAT ((const char)"general") / OSP global configuration context name */
#define	OSP_HTTP_PERSISTENCE ((int)1) /* In seconds */
#define	OSP_INVALID_HANDLE ((int)-1) /* Invalid OSP handle, provider, transaction etc. */
#define	OSP_LOCAL_VALIDATION ((int)1) /* Validate OSP token locally */
#define	OSP_MAX_CERTS ((unsigned int)10) /* OSP max number of cacerts */
#define	OSP_MAX_CUSTOMINFO ((unsigned int)8) /* OSP max number of custom info */
#define	OSP_MAX_MAXCONNECT ((unsigned int)1000) /* OSP max max_connections */
#define	OSP_MAX_RETRYDELAY ((unsigned int)10) /* OSP max retry delay */
#define	OSP_MAX_RETRYLIMIT ((unsigned int)100) /* OSP max retry times */
#define	OSP_MAX_SPOINTS ((unsigned int)10) /* OSP max number of service points */
#define	OSP_MAX_TIMEOUT ((unsigned int)10000) /* OSP max timeout in ms */
#define	OSP_MIN_MAXCONNECT ((unsigned int)1) /* OSP min max_connections */
#define	OSP_MIN_RETRYDELAY ((unsigned int)0) /* OSP min retry delay */
#define	OSP_MIN_RETRYLIMIT ((unsigned int)0) /* OSP min retry times */
#define	OSP_MIN_TIMEOUT ((unsigned int)200) /* OSP min timeout in ms */
#define	OSP_OK ((int)1) /* OSP function call successful */
#define	OSP_PROT_H323 ((const char)"H323") / H.323 Q.931 protocol name*/
#define	OSP_PROT_IAX ((const char)"IAX") / IAX2 protocol name */
#define	OSP_PROT_SIP ((const char)"SIP") / SIP protocol name */
#define	OSP_PROT_SKYPE ((const char)"SKYPE") / Skype protocol name */
#define	OSP_SIP_HEADER ((const char*)"P-OSP-Auth-Token")
#define	OSP_SIZE_INTSTR ((unsigned int)16) /* OSP signed/unsigned int string buffer size */
#define	OSP_SIZE_KEYSTR ((unsigned int)1024) /* OSP certificate string buffer size */
#define	OSP_SIZE_NORSTR ((unsigned int)256) /* OSP normal string buffer size */
#define	OSP_SIZE_QOSSTR ((unsigned int)1024) /* QoS string buffer size */
#define	OSP_SIZE_TECHSTR ((unsigned int)32) /* OSP signed/unsigned int string buffer size */
#define	OSP_SIZE_TOKSTR ((unsigned int)4096) /* OSP token string buffer size */
#define	OSP_SIZE_UUID ((unsigned int)16) /* UUID size */
#define	OSP_SIZE_UUIDSTR ((unsigned int)36) /* UUID string size */
#define	OSP_SSL_LIFETIME ((unsigned int)300) /* SSL life time, in seconds */
#define	OSP_TECH_H323 ((const char)"H323") / OH323 tech name */
#define	OSP_TECH_IAX ((const char)"IAX2") / IAX2 tech name */
#define	OSP_TECH_SIP ((const char)"SIP") / SIP tech name */
#define	OSP_TECH_SKYPE ((const char)"SKYPE") / Skype tech name */
Enumerations
enum	osp_authpolicy { OSP_AUTH_NO = 0, OSP_AUTH_YES, OSP_AUTH_EXC }
enum	osp_callleg { OSP_CALL_INBOUND, OSP_CALL_OUTBOUND }
enum	osp_direction { OSP_DIR_RX = 0, OSP_DIR_TX, OSP_DIR_NUMBER }
enum	osp_srvtype { OSP_SRV_VOICE = 0, OSP_SRV_NPQUERY }
enum	osp_workmode { OSP_MODE_DIRECT = 0, OSP_MODE_INDIRECT }
Functions
static void	__reg_module (void)
static void	__unreg_module (void)
static OSPEFAILREASON	asterisk2osp (int cause)
	Convert Asterisk status to TC code.
static char *	handle_cli_osp_show (struct ast_cli_entry e, int cmd, struct ast_cli_args a)
static int	load_module (void)
static int	osp_auth (const char name, int trans, const char source, const char calling, const char called, const char token, unsigned int *timelimit)
	OSP Authentication function.
static int	osp_check_destination (struct osp_provider provider, const char calling, const char called, const char destination, unsigned int tokenlen, const char token, OSPEFAILREASON reason, struct osp_results *results)
	Choose min duration limit.
static unsigned int	osp_choose_timelimit (unsigned int in, unsigned int out)
	Choose min duration limit.
static void	osp_convert_inout (const char src, char dest, unsigned int destsize)
	Convert "address:port" to "[x.x.x.x]:port" or "hostname:port" format.
static void	osp_convert_outin (const char src, char dest, unsigned int destsize)
	Convert "[x.x.x.x]:port" or "hostname:prot" to "address:port" format.
static int	osp_create_callid (unsigned int type, struct osp_callid *callid)
	Create a call ID according to the type.
static int	osp_create_provider (struct ast_config cfg, const char name)
	Create OSP provider handle according to configuration.
static int	osp_create_transaction (const char name, int trans, char *source, unsigned int srcsize)
	Create OSP transaction handle.
static int	osp_create_uuid (unsigned char uuid, unsigned int bufsize)
	Create a UUID.
static int	osp_finish (int trans, int recorded, int cause, time_t start, time_t connect, time_t end, unsigned int release, const char inqos, const char outqos)
	OSP Finish function.
static int	osp_get_provider (const char name, struct osp_provider *provider)
	Get OSP provider by name.
static float	osp_get_varfloat (const char *vstr)
	Get float from variable string.
static int	osp_get_varint (const char *vstr)
	Get integer from variable string.
static int	osp_load (int reload)
static int	osp_lookup (const char name, unsigned int callidtypes, const char actualsrc, const char srcdev, const char calling, const char called, const char snetid, struct osp_npdata np, struct osp_headers headers, const char cinfo[], struct osp_results results)
	OSP Lookup function.
static int	osp_next (const char name, int cause, struct osp_results results)
	OSP Lookup Next function.
static int	osp_report_qos (int trans, enum osp_callleg leg, const char *qos)
	Report QoS.
static int	osp_unload (void)
static int	osp_uuid2str (unsigned char uuid, char buffer, unsigned int bufsize)
	UUID to string.
static int	osp_validate_token (int trans, const char source, const char destination, const char calling, const char called, const char token, unsigned int timelimit)
	Validate OSP token of inbound call.
static int	ospauth_exec (struct ast_channel chan, const char data)
	OSP Application OSPAuth.
static int	ospfinished_exec (struct ast_channel chan, const char data)
	OSP Application OSPFinish.
static int	osplookup_exec (struct ast_channel chan, const char data)
	OSP Application OSPLookup.
static int	ospnext_exec (struct ast_channel chan, const char data)
	OSP Application OSPNext.
static int	reload (void)
static int	unload_module (void)
Variables
static struct ast_module_info	__mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_DEFAULT , .description = "Open Settlement Protocol Applications" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = AST_BUILDOPT_SUM, .load = load_module, .unload = unload_module, .reload = reload, }
static const char	app1 [] = "OSPAuth"
static const char	app2 [] = "OSPLookup"
static const char	app3 [] = "OSPNext"
static const char	app4 [] = "OSPFinish"
static struct ast_module_info *	ast_module_info = &__mod_info
const char *	B64CACert = "MIIBYDCCAQoCAQEwDQYJKoZIhvcNAQEEBQAwOzElMCMGA1UEAxMcb3NwdGVzdHNlcnZlci50cmFuc25leHVzLmNvbTESMBAGA1UEChMJT1NQU2VydmVyMB4XDTAyMDIwNDE4MjU1MloXDTEyMDIwMzE4MjU1MlowOzElMCMGA1UEAxMcb3NwdGVzdHNlcnZlci50cmFuc25leHVzLmNvbTESMBAGA1UEChMJT1NQU2VydmVyMFwwDQYJKoZIhvcNAQEBBQADSwAwSAJBAPGeGwV41EIhX0jEDFLRXQhDEr50OUQPq+f55VwQd0TQNts06BP29+UiNdRW3c3IRHdZcJdC1Cg68ME9cgeq0h8CAwEAATANBgkqhkiG9w0BAQQFAANBAGkzBSj1EnnmUxbaiG1N4xjIuLAWydun7o3bFk2tV8dBIhnuh445obYyk1EnQ27kI7eACCILBZqi2MHDOIMnoN0="
const char *	B64LCert = "MIIBeTCCASMCEHqkOHVRRWr+1COq3CR/xsowDQYJKoZIhvcNAQEEBQAwOzElMCMGA1UEAxMcb3NwdGVzdHNlcnZlci50cmFuc25leHVzLmNvbTESMBAGA1UEChMJT1NQU2VydmVyMB4XDTA1MDYyMzAwMjkxOFoXDTA2MDYyNDAwMjkxOFowRTELMAkGA1UEBhMCQVUxEzARBgNVBAgTClNvbWUtU3RhdGUxITAfBgNVBAoTGEludGVybmV0IFdpZGdpdHMgUHR5IEx0ZDBcMA0GCSqGSIb3DQEBAQUAA0sAMEgCQQCvLeZfj1G0wuJb8JTcVeZaZftncEmRluOnaME3ustd918lRMDYokZmtmDZN8SrP0yd1pfVqZ7NkmBACbBX0k7pAgMBAAEwDQYJKoZIhvcNAQEEBQADQQDnV8QNFVVJx/+7IselU0wsepqMurivXZzuxOmTEmTVDzCJx1xhA8jd3vGAj7XDIYiPub1PV23eY5a2ARJuw5w9"
const char *	B64PKey = "MIIBOgIBAAJBAK8t5l+PUbTC4lvwlNxV5lpl+2dwSZGW46dowTe6y133XyVEwNiiRma2YNk3xKs/TJ3Wl9Wpns2SYEAJsFfSTukCAwEAAQJAPz13vCm2GmZ8Zyp74usTxLCqSJZNyMRLHQWBM0g44Iuy4wE3vpi7Wq+xYuSOH2mu4OddnxswCP4QhaXVQavTAQIhAOBVCKXtppEw9UaOBL4vW0Ed/6EA/1D8hDW6St0h7EXJAiEAx+iRmZKhJD6VT84dtX5ZYNVk3j3dAcIOovpzUj9a0CECIEduTCapmZQ5xqAEsLXuVlxRtQgLTUD4ZxDElPn8x0MhAiBE2HlcND0+qDbvtwJQQOUzDgqg5xk3w8capboVdzAlQQIhAMC+lDL7+gDYkNAft5Mu+NObJmQs4Cr+DkDFsKqoxqrm"
static struct ast_cli_entry	cli_osp []
static int	osp_hardware = 0
static int	osp_initialized = 0
static ast_mutex_t	osp_lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, 1 }
static struct osp_provider *	osp_providers = NULL
static int	osp_security = 0
static unsigned int	osp_tokenformat = TOKEN_ALGO_SIGNED

Detailed Description

Open Settlement Protocol (OSP) Applications.

Author:: Mark Spencer <markster@digium.com>

ExtRef:: The OSP Toolkit: http://www.transnexus.com

ExtRef:: OpenSSL http://www.openssl.org

Definition in file app_osplookup.c.

Define Documentation

#define OSP_AST_ERROR ((int)-1) /* Asterisk function call error */

Definition at line 497 of file app_osplookup.c.

Referenced by ospauth_exec(), ospfinished_exec(), osplookup_exec(), and ospnext_exec().

#define OSP_AST_OK ((int)0) /* Asterisk function call successful */

Definition at line 496 of file app_osplookup.c.

Referenced by ospauth_exec(), ospfinished_exec(), osplookup_exec(), and ospnext_exec().

#define OSP_AUDIT_URL ((const char*)"localhost") /* OSP default Audit URL */

Definition at line 517 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_CALLID_H323 ((unsigned int)(1 << 1)) /* H.323 */

Definition at line 454 of file app_osplookup.c.

Referenced by osp_create_callid(), osplookup_exec(), and ospnext_exec().

#define OSP_CALLID_IAX ((unsigned int)(1 << 2)) /* IAX2 */

Definition at line 455 of file app_osplookup.c.

Referenced by osp_create_callid(), and osplookup_exec().

#define OSP_CALLID_MAXNUM ((unsigned int)3) /* Max number of call ID types */

Definition at line 456 of file app_osplookup.c.

Referenced by osp_lookup().

#define OSP_CALLID_SIP ((unsigned int)(1 << 0)) /* SIP */

Definition at line 453 of file app_osplookup.c.

Referenced by osp_create_callid(), and osplookup_exec().

#define OSP_CALLID_UNDEF ((unsigned int)0) /* Undefined */

Definition at line 452 of file app_osplookup.c.

Referenced by osplookup_exec(), and ospnext_exec().

#define OSP_CONFIG_FILE ((const char*)"osp.conf") /* OSP configuration file name */

Definition at line 499 of file app_osplookup.c.

Referenced by osp_load().

#define OSP_CUSTOMER_ID ((const char*)"") /* OSP customer ID */

Definition at line 521 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_DEF_AUTHPOLICY OSP_AUTH_YES /* OSP default auth policy, yes */

Definition at line 516 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_DEF_FLOATSTATS ((float)-1) /* OSP default float statistic */

Definition at line 530 of file app_osplookup.c.

Referenced by osp_get_varfloat(), and osp_report_qos().

#define OSP_DEF_INTSTATS ((int)-1) /* OSP default int statistic */

Definition at line 529 of file app_osplookup.c.

Referenced by osp_finish(), osp_get_varint(), and osp_report_qos().

#define OSP_DEF_MAXCONNECT ((unsigned int)20) /* OSP default max_connections */

Definition at line 504 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_DEF_MAXDESTS ((unsigned int)12) /* OSP default max number of destinations */

Definition at line 523 of file app_osplookup.c.

Referenced by osp_lookup().

#define OSP_DEF_PROTOCOL OSP_PROT_SIP /* OSP default signaling protocol, SIP */

Definition at line 525 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_DEF_PROVIDER ((const char*)"default") /* OSP default provider context name */

Definition at line 501 of file app_osplookup.c.

Referenced by ospauth_exec(), osplookup_exec(), and ospnext_exec().

#define OSP_DEF_RETRYDELAY ((unsigned int)0) /* OSP default retry delay */

Definition at line 507 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_DEF_RETRYLIMIT ((unsigned int)2) /* OSP default retry times */

Definition at line 510 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_DEF_SRVTYPE OSP_SRV_VOICE /* OSP default service type, voice */

Definition at line 527 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_DEF_TIMELIMIT ((unsigned int)0) /* OSP default duration limit, no limit */

Definition at line 524 of file app_osplookup.c.

Referenced by osp_auth(), osp_choose_timelimit(), osp_lookup(), osp_next(), ospauth_exec(), osplookup_exec(), and ospnext_exec().

#define OSP_DEF_TIMEOUT ((unsigned int)500) /* OSP default timeout in ms */

Definition at line 513 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_DEF_WORKMODE OSP_MODE_DIRECT /* OSP default work mode, direct */

Definition at line 526 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_DEVICE_ID ((const char*)"") /* OSP device ID */

Definition at line 522 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_ERROR ((int)-1) /* OSP function call error */

Definition at line 495 of file app_osplookup.c.

Referenced by osp_auth(), osp_check_destination(), osp_create_callid(), osp_create_provider(), osp_create_transaction(), osp_create_uuid(), osp_finish(), osp_lookup(), osp_next(), osp_uuid2str(), and osp_validate_token().

#define OSP_FAILED ((int)0) /* OSP function call failed */

Definition at line 494 of file app_osplookup.c.

Referenced by osp_auth(), osp_check_destination(), osp_create_callid(), osp_create_provider(), osp_create_transaction(), osp_finish(), osp_get_provider(), osp_lookup(), osp_next(), osp_report_qos(), and osp_validate_token().

#define OSP_GENERAL_CAT ((const char*)"general") /* OSP global configuration context name */

Definition at line 500 of file app_osplookup.c.

Referenced by osp_load().

#define OSP_HTTP_PERSISTENCE ((int)1) /* In seconds */

Definition at line 520 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_INVALID_HANDLE ((int)-1) /* Invalid OSP handle, provider, transaction etc. */

Definition at line 498 of file app_osplookup.c.

Referenced by osp_auth(), osp_create_provider(), osp_create_transaction(), osp_finish(), osp_lookup(), osp_next(), ospfinished_exec(), osplookup_exec(), and ospnext_exec().

#define OSP_LOCAL_VALIDATION ((int)1) /* Validate OSP token locally */

Definition at line 518 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_MAX_CERTS ((unsigned int)10) /* OSP max number of cacerts */

Definition at line 502 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_MAX_CUSTOMINFO ((unsigned int)8) /* OSP max number of custom info */

Definition at line 528 of file app_osplookup.c.

Referenced by osp_lookup(), and osplookup_exec().

#define OSP_MAX_MAXCONNECT ((unsigned int)1000) /* OSP max max_connections */

Definition at line 506 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_MAX_RETRYDELAY ((unsigned int)10) /* OSP max retry delay */

Definition at line 509 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_MAX_RETRYLIMIT ((unsigned int)100) /* OSP max retry times */

Definition at line 512 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_MAX_SPOINTS ((unsigned int)10) /* OSP max number of service points */

Definition at line 503 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_MAX_TIMEOUT ((unsigned int)10000) /* OSP max timeout in ms */

Definition at line 515 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_MIN_MAXCONNECT ((unsigned int)1) /* OSP min max_connections */

Definition at line 505 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_MIN_RETRYDELAY ((unsigned int)0) /* OSP min retry delay */

Definition at line 508 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_MIN_RETRYLIMIT ((unsigned int)0) /* OSP min retry times */

Definition at line 511 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_MIN_TIMEOUT ((unsigned int)200) /* OSP min timeout in ms */

Definition at line 514 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_OK ((int)1) /* OSP function call successful */

Definition at line 493 of file app_osplookup.c.

Referenced by osp_auth(), osp_check_destination(), osp_create_callid(), osp_create_provider(), osp_create_transaction(), osp_create_uuid(), osp_finish(), osp_get_provider(), osp_lookup(), osp_next(), osp_report_qos(), osp_uuid2str(), osp_validate_token(), ospauth_exec(), ospfinished_exec(), osplookup_exec(), and ospnext_exec().

#define OSP_PROT_H323 ((const char*)"H323") /* H.323 Q.931 protocol name*/

Definition at line 460 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_PROT_IAX ((const char*)"IAX") /* IAX2 protocol name */

Definition at line 461 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_PROT_SIP ((const char*)"SIP") /* SIP protocol name */

Definition at line 459 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_PROT_SKYPE ((const char*)"SKYPE") /* Skype protocol name */

Definition at line 462 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_SIP_HEADER ((const char*)"P-OSP-Auth-Token")

Definition at line 471 of file app_osplookup.c.

Referenced by osplookup_exec(), and ospnext_exec().

#define OSP_SIZE_INTSTR ((unsigned int)16) /* OSP signed/unsigned int string buffer size */

Definition at line 442 of file app_osplookup.c.

Referenced by ospauth_exec(), and ospfinished_exec().

#define OSP_SIZE_KEYSTR ((unsigned int)1024) /* OSP certificate string buffer size */

Definition at line 444 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_SIZE_NORSTR ((unsigned int)256) /* OSP normal string buffer size */

Definition at line 443 of file app_osplookup.c.

Referenced by osp_auth(), osp_check_destination(), osp_convert_inout(), osp_convert_outin(), osp_lookup(), osp_next(), osp_report_qos(), and osp_validate_token().

#define OSP_SIZE_QOSSTR ((unsigned int)1024) /* QoS string buffer size */

Definition at line 449 of file app_osplookup.c.

Referenced by ospfinished_exec().

#define OSP_SIZE_TECHSTR ((unsigned int)32) /* OSP signed/unsigned int string buffer size */

Definition at line 446 of file app_osplookup.c.

#define OSP_SIZE_TOKSTR ((unsigned int)4096) /* OSP token string buffer size */

Definition at line 445 of file app_osplookup.c.

Referenced by osp_lookup(), osp_next(), osp_validate_token(), osplookup_exec(), and ospnext_exec().

#define OSP_SIZE_UUID ((unsigned int)16) /* UUID size */

Definition at line 447 of file app_osplookup.c.

Referenced by osp_create_uuid().

#define OSP_SIZE_UUIDSTR ((unsigned int)36) /* UUID string size */

Definition at line 448 of file app_osplookup.c.

Referenced by osp_uuid2str().

#define OSP_SSL_LIFETIME ((unsigned int)300) /* SSL life time, in seconds */

Definition at line 519 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_TECH_H323 ((const char*)"H323") /* OH323 tech name */

Definition at line 466 of file app_osplookup.c.

Referenced by osp_check_destination(), osp_lookup(), osplookup_exec(), and ospnext_exec().

#define OSP_TECH_IAX ((const char*)"IAX2") /* IAX2 tech name */

Definition at line 467 of file app_osplookup.c.

Referenced by osp_check_destination(), osp_lookup(), osplookup_exec(), and ospnext_exec().

#define OSP_TECH_SIP ((const char*)"SIP") /* SIP tech name */

Definition at line 465 of file app_osplookup.c.

Referenced by osp_check_destination(), osp_lookup(), osplookup_exec(), and ospnext_exec().

#define OSP_TECH_SKYPE ((const char*)"SKYPE") /* Skype tech name */

Definition at line 468 of file app_osplookup.c.

Referenced by osp_check_destination(), osp_lookup(), osplookup_exec(), and ospnext_exec().

Enumeration Type Documentation

enum osp_authpolicy

Enumerator:

OSP_AUTH_NO
OSP_AUTH_YES
OSP_AUTH_EXC

Definition at line 474 of file app_osplookup.c.

                    {
   OSP_AUTH_NO = 0,  /* Accept any call */
   OSP_AUTH_YES,     /* Accept call with valid OSP token or without OSP token */
   OSP_AUTH_EXC      /* Only accept call with valid OSP token */
};

enum osp_callleg

Enumerator:

OSP_CALL_INBOUND
OSP_CALL_OUTBOUND

Definition at line 599 of file app_osplookup.c.

                 {
   OSP_CALL_INBOUND, /* Inbound call leg */
   OSP_CALL_OUTBOUND /* Outbound call leg */
};

enum osp_direction

Enumerator:

OSP_DIR_RX
OSP_DIR_TX
OSP_DIR_NUMBER

Definition at line 605 of file app_osplookup.c.

                   {
   OSP_DIR_RX = 0,      /* Receive */
   OSP_DIR_TX,       /* Send */
   OSP_DIR_NUMBER    /* Number of directions */
};

enum osp_srvtype

Enumerator:

OSP_SRV_VOICE
OSP_SRV_NPQUERY

Definition at line 487 of file app_osplookup.c.

                 {
   OSP_SRV_VOICE = 0,   /* Normal voice service */
   OSP_SRV_NPQUERY      /* Ported number query service */
};

enum osp_workmode

Enumerator:

OSP_MODE_DIRECT
OSP_MODE_INDIRECT

Definition at line 481 of file app_osplookup.c.

                  {
   OSP_MODE_DIRECT= 0,  /* Direct */
   OSP_MODE_INDIRECT /* Indirect */
};

Function Documentation

static void __reg_module ( void ) [static]

Definition at line 3165 of file app_osplookup.c.

static void __unreg_module ( void ) [static]

Definition at line 3165 of file app_osplookup.c.

static OSPEFAILREASON asterisk2osp ( int cause ) [static]

Convert Asterisk status to TC code.

Parameters:

cause Asterisk hangup cause

Returns:: OSP TC code

Definition at line 1310 of file app_osplookup.c.

Referenced by osp_finish(), and osp_next().

{
   return (OSPEFAILREASON)cause;
}

static char* handle_cli_osp_show	(	struct ast_cli_entry *	e,
		int	cmd,
		struct ast_cli_args *	a
	)		`[static]`

Definition at line 3018 of file app_osplookup.c.

References ast_cli_args::argc, ast_cli_args::argv, ast_cli(), ast_mutex_lock, ast_mutex_unlock, osp_provider::authpolicy, osp_provider::cacerts, osp_provider::canum, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, osp_provider::defprotocol, ast_cli_args::fd, osp_provider::handle, osp_provider::localcert, osp_provider::maxconnect, name, osp_provider::name, osp_provider::next, osp_lock, osp_provider::privatekey, osp_provider::retrydelay, osp_provider::retrylimit, osp_provider::source, osp_provider::spnum, osp_provider::spoints, osp_provider::srvtype, osp_provider::timeout, ast_cli_entry::usage, and osp_provider::workmode.

{
   int i;
   int found = 0;
   struct osp_provider* provider;
   const char* name = NULL;
   const char* tokenalgo;

   switch (cmd) {
   case CLI_INIT:
      e->command = "osp show";
      e->usage =
         "Usage: osp show\n"
         "       Displays information on Open Settlement Protocol support\n";
      return NULL;
   case CLI_GENERATE:
      return NULL;
   }

   if ((a->argc < 2) || (a->argc > 3)) {
      return CLI_SHOWUSAGE;
   }

   if (a->argc > 2) {
      name = a->argv[2];
   }

   if (!name) {
      switch (osp_tokenformat) {
      case TOKEN_ALGO_BOTH:
         tokenalgo = "Both";
         break;
      case TOKEN_ALGO_UNSIGNED:
         tokenalgo = "Unsigned";
         break;
      case TOKEN_ALGO_SIGNED:
      default:
         tokenalgo = "Signed";
         break;
      }
      ast_cli(a->fd, "OSP: %s/%s/%s/%s\n",
         osp_initialized ? "Initialized" : "Uninitialized",
         osp_hardware ? "Accelerated" : "Normal",
         osp_security ? "Enabled" : "Disabled",
         tokenalgo);
   }

   ast_mutex_lock(&osp_lock);
   for (provider = osp_providers; provider; provider = provider->next) {
      if (!name || !strcasecmp(provider->name, name)) {
         if (found) {
            ast_cli(a->fd, "\n");
         }
         ast_cli(a->fd, " == OSP Provider '%s' == \n", provider->name);
         if (osp_security) {
            ast_cli(a->fd, "Local Private Key: %s\n", provider->privatekey);
            ast_cli(a->fd, "Local Certificate: %s\n", provider->localcert);
            for (i = 0; i < provider->canum; i++) {
               ast_cli(a->fd, "CA Certificate %d:  %s\n", i + 1, provider->cacerts[i]);
            }
         }
         for (i = 0; i < provider->spnum; i++) {
            ast_cli(a->fd, "Service Point %d:   %s\n", i + 1, provider->spoints[i]);
         }
         ast_cli(a->fd, "Max Connections:   %d\n", provider->maxconnect);
         ast_cli(a->fd, "Retry Delay:       %d seconds\n", provider->retrydelay);
         ast_cli(a->fd, "Retry Limit:       %d\n", provider->retrylimit);
         ast_cli(a->fd, "Timeout:           %d milliseconds\n", provider->timeout);
         ast_cli(a->fd, "Source:            %s\n", strlen(provider->source) ? provider->source : "<unspecified>");
         ast_cli(a->fd, "Auth Policy        %d\n", provider->authpolicy);
         ast_cli(a->fd, "Default protocol   %s\n", provider->defprotocol);
         ast_cli(a->fd, "Work mode          %d\n", provider->workmode);
         ast_cli(a->fd, "Service type       %d\n", provider->srvtype);
         ast_cli(a->fd, "OSP Handle:        %d\n", provider->handle);
         found++;
      }
   }
   ast_mutex_unlock(&osp_lock);

   if (!found) {
      if (name) {
         ast_cli(a->fd, "Unable to find OSP provider '%s'\n", name);
      } else {
         ast_cli(a->fd, "No OSP providers configured\n");
      }
   }

   return CLI_SUCCESS;
}

static int load_module ( void ) [static]

Definition at line 3124 of file app_osplookup.c.

References ast_cli_register_multiple(), AST_MODULE_LOAD_DECLINE, ast_register_application_xml, osp_load(), ospauth_exec(), ospfinished_exec(), osplookup_exec(), and ospnext_exec().

{
   int res;

   if (!osp_load(0))
      return AST_MODULE_LOAD_DECLINE;

   ast_cli_register_multiple(cli_osp, sizeof(cli_osp) / sizeof(struct ast_cli_entry));
   res = ast_register_application_xml(app1, ospauth_exec);
   res |= ast_register_application_xml(app2, osplookup_exec);
   res |= ast_register_application_xml(app3, ospnext_exec);
   res |= ast_register_application_xml(app4, ospfinished_exec);

   return res;
}

static int osp_auth	(	const char *	name,
		int *	trans,
		const char *	source,
		const char *	calling,
		const char *	called,
		const char *	token,
		unsigned int *	timelimit
	)		`[static]`

OSP Authentication function.

Parameters:

name	OSP provider context name
trans	OSP transaction handle, output
source	Source of inbound call
calling	Calling number
called	Called number
token	OSP token, may be empty
timelimit	Call duration limit, output

Returns:: OSP_OK Authenricated, OSP_FAILED Unauthenticated, OSP_ERROR Error

Definition at line 1327 of file app_osplookup.c.

References ast_debug, ast_log(), ast_strlen_zero(), osp_provider::authpolicy, LOG_ERROR, OSP_AUTH_EXC, OSP_AUTH_NO, OSP_AUTH_YES, osp_create_transaction(), OSP_DEF_TIMELIMIT, OSP_ERROR, OSP_FAILED, osp_get_provider(), OSP_INVALID_HANDLE, OSP_OK, OSP_SIZE_NORSTR, and osp_validate_token().

Referenced by ospauth_exec().

{
   int res;
   struct osp_provider* provider = NULL;
   char dest[OSP_SIZE_NORSTR];

   if ((trans == NULL) || (timelimit == NULL)) {
      ast_log(LOG_ERROR, "Invalid parameters\n");
      return OSP_ERROR;
   }

   *trans = OSP_INVALID_HANDLE;
   *timelimit = OSP_DEF_TIMELIMIT;

   if ((res = osp_get_provider(name, &provider)) <= 0) {
      ast_debug(1, "OSP: Unabe to find OSP provider '%s'\n", name);
      return res;
   }

   switch (provider->authpolicy) {
   case OSP_AUTH_NO:
      res = OSP_OK;
      break;
   case OSP_AUTH_EXC:
      if (ast_strlen_zero(token)) {
         res = OSP_FAILED;
      } else if ((res = osp_create_transaction(name, trans, dest, sizeof(dest))) <= 0) {
         ast_debug(1, "OSP: Unable to generate transaction handle\n");
         *trans = OSP_INVALID_HANDLE;
         res = OSP_FAILED;
      } else if((res = osp_validate_token(*trans, source, dest, calling, called, token, timelimit)) <= 0) {
         OSPPTransactionRecordFailure(*trans, OSPC_FAIL_CALL_REJECTED);
      }
      break;
   case OSP_AUTH_YES:
   default:
      if (ast_strlen_zero(token)) {
         res = OSP_OK;
      } else if ((res = osp_create_transaction(name, trans, dest, sizeof(dest))) <= 0) {
         ast_debug(1, "OSP: Unable to generate transaction handle\n");
         *trans = OSP_INVALID_HANDLE;
         res = OSP_FAILED;
      } else if((res = osp_validate_token(*trans, source, dest, calling, called, token, timelimit)) <= 0) {
         OSPPTransactionRecordFailure(*trans, OSPC_FAIL_CALL_REJECTED);
      }
      break;
   }

   return res;
}

static int osp_check_destination	(	struct osp_provider *	provider,
		const char *	calling,
		const char *	called,
		const char *	destination,
		unsigned int	tokenlen,
		const char *	token,
		OSPEFAILREASON *	reason,
		struct osp_results *	results
	)		`[static]`

Choose min duration limit.

Parameters:

provider	OSP provider
calling	Calling number
called	Called number
destination	Destination IP in '[x.x.x.x]' format
tokenlen	OSP token length
token	OSP token
reason	Failure reason, output
results	OSP lookup results, in/output

Returns:: OSP_OK Success, OSP_FAILED Failed, OSP_ERROR Error

Definition at line 1168 of file app_osplookup.c.

References ast_base64encode(), ast_copy_string(), ast_debug, ast_log(), osp_results::called, osp_results::calling, osp_provider::defprotocol, osp_results::dest, enabled, LOG_ERROR, LOG_WARNING, osp_results::networkid, osp_results::npcic, osp_results::npdi, osp_results::nprn, osp_results::opname, osp_convert_outin(), OSP_ERROR, OSP_FAILED, OSP_OK, OSP_SIZE_NORSTR, OSP_TECH_H323, OSP_TECH_IAX, OSP_TECH_SIP, OSP_TECH_SKYPE, osp_results::outhandle, osp_results::outtech, osp_results::token, and type.

Referenced by osp_lookup(), and osp_next().

{
   int res;
   OSPE_DEST_OSPENABLED enabled;
   OSPE_PROTOCOL_NAME protocol;
   char dest[OSP_SIZE_NORSTR];
   OSPE_OPERATOR_NAME type;
   int error;

   if ((provider == NULL) || (reason == NULL) || (results == NULL)) {
      ast_log(LOG_ERROR, "Invalid parameters\n");
      return OSP_ERROR;
   }

   if ((error = OSPPTransactionIsDestOSPEnabled(results->outhandle, &enabled)) != OSPC_ERR_NO_ERROR) {
      ast_debug(1, "OSP: Unable to get destination OSP version, error '%d'\n", error);
      *reason = OSPC_FAIL_NORMAL_UNSPECIFIED;
      return OSP_ERROR;
   }

   if (enabled == OSPC_DOSP_FALSE) {
      results->token[0] = '\0';
   } else {
      ast_base64encode(results->token, (const unsigned char*)token, tokenlen, sizeof(results->token) - 1);
   }

   if ((error = OSPPTransactionGetDestinationNetworkId(results->outhandle, sizeof(results->networkid), results->networkid)) != OSPC_ERR_NO_ERROR) {
      ast_debug(1, "OSP: Unable to get destination network ID, error '%d'\n", error);
      results->networkid[0] = '\0';
   }

   error = OSPPTransactionGetNumberPortabilityParameters(results->outhandle,
      sizeof(results->nprn),
      results->nprn,
      sizeof(results->npcic),
      results->npcic,
      &results->npdi);
   if (error != OSPC_ERR_NO_ERROR) {
      ast_debug(1, "OSP: Unable to get number portability parameters, error '%d'\n", error);
      results->nprn[0] = '\0';
      results->npcic[0] = '\0';
      results->npdi = 0;
   }

   for (type = OSPC_OPNAME_START; type < OSPC_OPNAME_NUMBER; type++) {
      error = OSPPTransactionGetOperatorName(results->outhandle, type, sizeof(results->opname[type]), results->opname[type]);
      if (error != OSPC_ERR_NO_ERROR) {
         ast_debug(1, "OSP: Unable to get operator name of type '%d', error '%d'\n", type, error);
         results->opname[type][0] = '\0';
      }
   }

   if ((error = OSPPTransactionGetDestProtocol(results->outhandle, &protocol)) != OSPC_ERR_NO_ERROR) {
      ast_debug(1, "OSP: Unable to get destination protocol, error '%d'\n", error);
      *reason = OSPC_FAIL_NORMAL_UNSPECIFIED;
      results->token[0] = '\0';
      results->networkid[0] = '\0';
      results->nprn[0] = '\0';
      results->npcic[0] = '\0';
      results->npdi = 0;
      for (type = OSPC_OPNAME_START; type < OSPC_OPNAME_NUMBER; type++) {
         results->opname[type][0] = '\0';
      }
      return OSP_ERROR;
   }

   res = OSP_OK;
   osp_convert_outin(destination, dest, sizeof(dest));
   switch(protocol) {
   case OSPC_PROTNAME_SIP:
      ast_debug(1, "OSP: protocol SIP\n");
      ast_copy_string(results->outtech, OSP_TECH_SIP, sizeof(results->outtech));
      ast_copy_string(results->dest, dest, sizeof(results->dest));
      ast_copy_string(results->calling, calling, sizeof(results->calling));
      ast_copy_string(results->called, called, sizeof(results->called));
      break;
   case OSPC_PROTNAME_Q931:
      ast_debug(1, "OSP: protocol Q.931\n");
      ast_copy_string(results->outtech, OSP_TECH_H323, sizeof(results->outtech));
      ast_copy_string(results->dest, dest, sizeof(results->dest));
      ast_copy_string(results->calling, calling, sizeof(results->calling));
      ast_copy_string(results->called, called, sizeof(results->called));
      break;
   case OSPC_PROTNAME_IAX:
      ast_debug(1, "OSP: protocol IAX\n");
      ast_copy_string(results->outtech, OSP_TECH_IAX, sizeof(results->outtech));
      ast_copy_string(results->dest, dest, sizeof(results->dest));
      ast_copy_string(results->calling, calling, sizeof(results->calling));
      ast_copy_string(results->called, called, sizeof(results->called));
      break;
   case OSPC_PROTNAME_SKYPE:
      ast_debug(1, "OSP: protocol Skype\n");
      ast_copy_string(results->outtech, OSP_TECH_SKYPE, sizeof(results->outtech));
      ast_copy_string(results->dest, dest, sizeof(results->dest));
      ast_copy_string(results->calling, calling, sizeof(results->calling));
      ast_copy_string(results->called, called, sizeof(results->called));
      break;
   case OSPC_PROTNAME_UNDEFINED:
   case OSPC_PROTNAME_UNKNOWN:
      ast_debug(1, "OSP: unknown/undefined protocol '%d'\n", protocol);
      ast_debug(1, "OSP: use default protocol '%s'\n", provider->defprotocol);
      ast_copy_string(results->outtech, provider->defprotocol, sizeof(results->outtech));
      ast_copy_string(results->dest, dest, sizeof(results->dest));
      ast_copy_string(results->calling, calling, sizeof(results->calling));
      ast_copy_string(results->called, called, sizeof(results->called));
      break;
   case OSPC_PROTNAME_LRQ:
   case OSPC_PROTNAME_T37:
   case OSPC_PROTNAME_T38:
   case OSPC_PROTNAME_SMPP:
   case OSPC_PROTNAME_XMPP:
   default:
      ast_log(LOG_WARNING, "OSP: unsupported protocol '%d'\n", protocol);
      *reason = OSPC_FAIL_PROTOCOL_ERROR;
      results->token[0] = '\0';
      results->networkid[0] = '\0';
      results->nprn[0] = '\0';
      results->npcic[0] = '\0';
      results->npdi = 0;
      for (type = OSPC_OPNAME_START; type < OSPC_OPNAME_NUMBER; type++) {
         results->opname[type][0] = '\0';
      }
      res = OSP_FAILED;
      break;
   }

   return res;
}

static unsigned int osp_choose_timelimit	(	unsigned int	in,
		unsigned int	out
	)		`[static]`

Choose min duration limit.

Parameters:

in	Inbound duration limit
out	Outbound duration limit

Returns:: min duration limit

Definition at line 1143 of file app_osplookup.c.

References OSP_DEF_TIMELIMIT.

Referenced by osp_lookup(), and osp_next().

{
   if (in == OSP_DEF_TIMELIMIT) {
      return out;
   } else if (out == OSP_DEF_TIMELIMIT) {
      return in;
   } else {
      return in < out ? in : out;
   }
}

static void osp_convert_inout	(	const char *	src,
		char *	dest,
		unsigned int	destsize
	)		`[static]`

Convert "address:port" to "[x.x.x.x]:port" or "hostname:port" format.

Parameters:

src	Source address string
dest	Destination address string
destsize	Size of dest buffer

Definition at line 989 of file app_osplookup.c.

References ast_copy_string(), ast_strlen_zero(), and OSP_SIZE_NORSTR.

Referenced by osp_lookup(), and osp_validate_token().

{
   struct in_addr inp;
   char buffer[OSP_SIZE_NORSTR];
   char* port;

   if ((dest != NULL) && (destsize > 0)) {
      if (!ast_strlen_zero(src)) {
         ast_copy_string(buffer, src, sizeof(buffer));

         if((port = strchr(buffer, ':')) != NULL) {
            *port = '\0';
            port++;
         }

         if (inet_pton(AF_INET, buffer, &inp) == 1) {
            if (port != NULL) {
               snprintf(dest, destsize, "[%s]:%s", buffer, port);
            } else {
               snprintf(dest, destsize, "[%s]", buffer);
            }
            dest[destsize - 1] = '\0';
         } else {
            ast_copy_string(dest, src, destsize);
         }
      } else {
         *dest = '\0';
      }
   }
}

static void osp_convert_outin	(	const char *	src,
		char *	dest,
		unsigned int	destsize
	)		`[static]`

Convert "[x.x.x.x]:port" or "hostname:prot" to "address:port" format.

Parameters:

src	Source address string
dest	Destination address string
destsize	Size of dest buffer

Definition at line 1029 of file app_osplookup.c.

References ast_copy_string(), ast_strlen_zero(), and OSP_SIZE_NORSTR.

Referenced by osp_check_destination().

{
   char buffer[OSP_SIZE_NORSTR];
   char* end;
   char* port;

   if ((dest != NULL) && (destsize > 0)) {
      if (!ast_strlen_zero(src)) {
         ast_copy_string(buffer, src, sizeof(buffer));

         if (buffer[0] == '[') {
            if((port = strchr(buffer + 1, ':')) != NULL) {
               *port = '\0';
               port++;
            }

            if ((end = strchr(buffer + 1, ']')) != NULL) {
               *end = '\0';
            }

            if (port != NULL) {
               snprintf(dest, destsize, "%s:%s", buffer + 1, port);
               dest[destsize - 1] = '\0';
            } else {
               ast_copy_string(dest, buffer + 1, destsize);
            }
         } else {
            ast_copy_string(dest, src, destsize);
         }
      } else {
         *dest = '\0';
      }
   }
}

static int osp_create_callid	(	unsigned int	type,
		struct osp_callid *	callid
	)		`[static]`

Create a call ID according to the type.

Parameters:

type	Call ID type
callid	Call ID buffer

Returns:: OSK_OK Created, OSP_FAILED Not create, OSP_ERROR Error

Definition at line 1446 of file app_osplookup.c.

References ast_log(), osp_callid::buf, osp_callid::len, LOG_ERROR, OSP_CALLID_H323, OSP_CALLID_IAX, OSP_CALLID_SIP, osp_create_uuid(), OSP_ERROR, OSP_FAILED, and OSP_OK.

Referenced by osp_lookup().

{
   int res;

   if (callid == NULL) {
      ast_log(LOG_ERROR, "Invalid parameters\n");
      return OSP_ERROR;
   }

   callid->len = sizeof(callid->buf);
   switch (type) {
   case OSP_CALLID_H323:
      res = osp_create_uuid(callid->buf, &callid->len);
      break;
   case OSP_CALLID_SIP:
   case OSP_CALLID_IAX:
      res = OSP_FAILED;
      break;
   default:
      res = OSP_ERROR;
      break;
   }

   if ((res != OSP_OK) && (callid->len != 0)) {
      callid->buf[0] = '\0';
      callid->len = 0;
   }

   return res;
}

static int osp_create_provider	(	struct ast_config *	cfg,
		const char *	name
	)		`[static]`

Create OSP provider handle according to configuration.

Parameters:

cfg	OSP configuration
name	OSP provider context name

Returns:: OSP_OK Success, OSP_FAILED Failed, OSP_ERROR Error

Definition at line 641 of file app_osplookup.c.

References ast_calloc, ast_config_AST_KEY_DIR, ast_copy_string(), ast_debug, ast_free, ast_log(), ast_mutex_lock, ast_mutex_unlock, ast_variable_browse(), osp_provider::authpolicy, osp_provider::cacerts, osp_provider::canum, osp_provider::defprotocol, osp_provider::handle, ast_variable::lineno, osp_provider::localcert, LOG_ERROR, LOG_WARNING, osp_provider::maxconnect, ast_variable::name, osp_provider::name, ast_variable::next, osp_provider::next, OSP_AUDIT_URL, OSP_AUTH_EXC, OSP_AUTH_NO, OSP_AUTH_YES, OSP_CUSTOMER_ID, OSP_DEF_AUTHPOLICY, OSP_DEF_MAXCONNECT, OSP_DEF_PROTOCOL, OSP_DEF_RETRYDELAY, OSP_DEF_RETRYLIMIT, OSP_DEF_SRVTYPE, OSP_DEF_TIMEOUT, OSP_DEF_WORKMODE, OSP_DEVICE_ID, OSP_ERROR, OSP_FAILED, OSP_HTTP_PERSISTENCE, OSP_INVALID_HANDLE, OSP_LOCAL_VALIDATION, osp_lock, OSP_MAX_CERTS, OSP_MAX_MAXCONNECT, OSP_MAX_RETRYDELAY, OSP_MAX_RETRYLIMIT, OSP_MAX_SPOINTS, OSP_MAX_TIMEOUT, OSP_MIN_MAXCONNECT, OSP_MIN_RETRYDELAY, OSP_MIN_RETRYLIMIT, OSP_MIN_TIMEOUT, OSP_MODE_DIRECT, OSP_MODE_INDIRECT, OSP_OK, OSP_PROT_H323, OSP_PROT_IAX, OSP_PROT_SIP, OSP_PROT_SKYPE, osp_providers, OSP_SIZE_KEYSTR, OSP_SRV_NPQUERY, OSP_SRV_VOICE, OSP_SSL_LIFETIME, osp_provider::privatekey, osp_provider::retrydelay, osp_provider::retrylimit, osp_provider::source, osp_provider::spnum, osp_provider::spoints, osp_provider::srvtype, osp_provider::timeout, ast_variable::value, var, and osp_provider::workmode.

Referenced by osp_load().

{
   int res = OSP_FAILED;
   struct ast_variable* var;
   struct osp_provider* provider;
   OSPTPRIVATEKEY privatekey;
   OSPT_CERT localcert;
   OSPT_CERT cacerts[OSP_MAX_CERTS];
   const OSPT_CERT* pcacerts[OSP_MAX_CERTS];
   const char* pspoints[OSP_MAX_SPOINTS];
   unsigned char privatekeydata[OSP_SIZE_KEYSTR];
   unsigned char localcertdata[OSP_SIZE_KEYSTR];
   unsigned char cacertdata[OSP_SIZE_KEYSTR];
   int i, num, error = OSPC_ERR_NO_ERROR;

   if (!(provider = ast_calloc(1, sizeof(*provider)))) {
      ast_log(LOG_ERROR, "Out of memory\n");
      return OSP_ERROR;
   }

   /* ast_calloc has set 0 in provider */
   provider->handle = OSP_INVALID_HANDLE;
   ast_copy_string(provider->name, name, sizeof(provider->name));
   snprintf(provider->privatekey, sizeof(provider->privatekey), "%s/%s-privatekey.pem", ast_config_AST_KEY_DIR, name);
   snprintf(provider->localcert, sizeof(provider->localcert), "%s/%s-localcert.pem", ast_config_AST_KEY_DIR, name);
   snprintf(provider->cacerts[0], sizeof(provider->cacerts[0]), "%s/%s-cacert_0.pem", ast_config_AST_KEY_DIR, name);
   provider->maxconnect = OSP_DEF_MAXCONNECT;
   provider->retrydelay = OSP_DEF_RETRYDELAY;
   provider->retrylimit = OSP_DEF_RETRYLIMIT;
   provider->timeout = OSP_DEF_TIMEOUT;
   provider->authpolicy = OSP_DEF_AUTHPOLICY;
   provider->defprotocol = OSP_DEF_PROTOCOL;
   provider->workmode = OSP_DEF_WORKMODE;
   provider->srvtype = OSP_DEF_SRVTYPE;

   for (var = ast_variable_browse(cfg, name); var != NULL; var = var->next) {
      if (!strcasecmp(var->name, "privatekey")) {
         if (osp_security) {
            if (var->value[0] == '/') {
               ast_copy_string(provider->privatekey, var->value, sizeof(provider->privatekey));
            } else {
               snprintf(provider->privatekey, sizeof(provider->privatekey), "%s/%s", ast_config_AST_KEY_DIR, var->value);
            }
            ast_debug(1, "OSP: privatekey '%s'\n", provider->privatekey);
         }
      } else if (!strcasecmp(var->name, "localcert")) {
         if (osp_security) {
            if (var->value[0] == '/') {
               ast_copy_string(provider->localcert, var->value, sizeof(provider->localcert));
            } else {
               snprintf(provider->localcert, sizeof(provider->localcert), "%s/%s", ast_config_AST_KEY_DIR, var->value);
            }
            ast_debug(1, "OSP: localcert '%s'\n", provider->localcert);
         }
      } else if (!strcasecmp(var->name, "cacert")) {
         if (osp_security) {
            if (provider->canum < OSP_MAX_CERTS) {
               if (var->value[0] == '/') {
                  ast_copy_string(provider->cacerts[provider->canum], var->value, sizeof(provider->cacerts[provider->canum]));
               } else {
                  snprintf(provider->cacerts[provider->canum], sizeof(provider->cacerts[provider->canum]), "%s/%s", ast_config_AST_KEY_DIR, var->value);
               }
               ast_debug(1, "OSP: cacerts[%d]: '%s'\n", provider->canum, provider->cacerts[provider->canum]);
               provider->canum++;
            } else {
               ast_log(LOG_WARNING, "OSP: Too many CA Certificates at line %d\n", var->lineno);
            }
         }
      } else if (!strcasecmp(var->name, "servicepoint")) {
         if (provider->spnum < OSP_MAX_SPOINTS) {
            ast_copy_string(provider->spoints[provider->spnum], var->value, sizeof(provider->spoints[provider->spnum]));
            ast_debug(1, "OSP: servicepoint[%d]: '%s'\n", provider->spnum, provider->spoints[provider->spnum]);
            provider->spnum++;
         } else {
            ast_log(LOG_WARNING, "OSP: Too many Service Points at line %d\n", var->lineno);
         }
      } else if (!strcasecmp(var->name, "maxconnect")) {
         if ((sscanf(var->value, "%30d", &num) == 1) && (num >= OSP_MIN_MAXCONNECT) && (num <= OSP_MAX_MAXCONNECT)) {
            provider->maxconnect = num;
            ast_debug(1, "OSP: maxconnect '%d'\n", num);
         } else {
            ast_log(LOG_WARNING, "OSP: maxconnect should be an integer from %d to %d, not '%s' at line %d\n",
               OSP_MIN_MAXCONNECT, OSP_MAX_MAXCONNECT, var->value, var->lineno);
         }
      } else if (!strcasecmp(var->name, "retrydelay")) {
         if ((sscanf(var->value, "%30d", &num) == 1) && (num >= OSP_MIN_RETRYDELAY) && (num <= OSP_MAX_RETRYDELAY)) {
            provider->retrydelay = num;
            ast_debug(1, "OSP: retrydelay '%d'\n", num);
         } else {
            ast_log(LOG_WARNING, "OSP: retrydelay should be an integer from %d to %d, not '%s' at line %d\n",
               OSP_MIN_RETRYDELAY, OSP_MAX_RETRYDELAY, var->value, var->lineno);
         }
      } else if (!strcasecmp(var->name, "retrylimit")) {
         if ((sscanf(var->value, "%30d", &num) == 1) && (num >= OSP_MIN_RETRYLIMIT) && (num <= OSP_MAX_RETRYLIMIT)) {
            provider->retrylimit = num;
            ast_debug(1, "OSP: retrylimit '%d'\n", num);
         } else {
            ast_log(LOG_WARNING, "OSP: retrylimit should be an integer from %d to %d, not '%s' at line %d\n",
               OSP_MIN_RETRYLIMIT, OSP_MAX_RETRYLIMIT, var->value, var->lineno);
         }
      } else if (!strcasecmp(var->name, "timeout")) {
         if ((sscanf(var->value, "%30d", &num) == 1) && (num >= OSP_MIN_TIMEOUT) && (num <= OSP_MAX_TIMEOUT)) {
            provider->timeout = num;
            ast_debug(1, "OSP: timeout '%d'\n", num);
         } else {
            ast_log(LOG_WARNING, "OSP: timeout should be an integer from %d to %d, not '%s' at line %d\n",
               OSP_MIN_TIMEOUT, OSP_MAX_TIMEOUT, var->value, var->lineno);
         }
      } else if (!strcasecmp(var->name, "source")) {
         ast_copy_string(provider->source, var->value, sizeof(provider->source));
         ast_debug(1, "OSP: source '%s'\n", provider->source);
      } else if (!strcasecmp(var->name, "authpolicy")) {
         if ((sscanf(var->value, "%30d", &num) == 1) && ((num == OSP_AUTH_NO) || (num == OSP_AUTH_YES) || (num == OSP_AUTH_EXC))) {
            provider->authpolicy = num;
            ast_debug(1, "OSP: authpolicy '%d'\n", num);
         } else {
            ast_log(LOG_WARNING, "OSP: authpolicy should be %d, %d or %d, not '%s' at line %d\n",
               OSP_AUTH_NO, OSP_AUTH_YES, OSP_AUTH_EXC, var->value, var->lineno);
         }
      } else if (!strcasecmp(var->name, "defprotocol")) {
         if (!strcasecmp(var->value, OSP_PROT_SIP)) {
            provider->defprotocol = OSP_PROT_SIP;
            ast_debug(1, "OSP: default protocol SIP\n");
         } else if (!strcasecmp(var->value, OSP_PROT_H323)) {
            provider->defprotocol = OSP_PROT_H323;
            ast_debug(1, "OSP: default protocol H.323\n");
         } else if (!strcasecmp(var->value, OSP_PROT_IAX)) {
            provider->defprotocol = OSP_PROT_IAX;
            ast_debug(1, "OSP: default protocol IAX\n");
         } else if (!strcasecmp(var->value, OSP_PROT_SKYPE)) {
            provider->defprotocol = OSP_PROT_SKYPE;
            ast_debug(1, "OSP: default protocol Skype\n");
         } else {
            ast_log(LOG_WARNING, "OSP: default protocol should be %s, %s, %s or %s not '%s' at line %d\n",
               OSP_PROT_SIP, OSP_PROT_H323, OSP_PROT_IAX, OSP_PROT_SKYPE, var->value, var->lineno);
         }
      } else if (!strcasecmp(var->name, "workmode")) {
         if ((sscanf(var->value, "%30d", &num) == 1) && ((num == OSP_MODE_DIRECT) || (num == OSP_MODE_INDIRECT))) {
            provider->workmode = num;
            ast_debug(1, "OSP: workmode '%d'\n", num);
         } else {
            ast_log(LOG_WARNING, "OSP: workmode should be %d or %d, not '%s' at line %d\n",
               OSP_MODE_DIRECT, OSP_MODE_INDIRECT, var->value, var->lineno);
         }
      } else if (!strcasecmp(var->name, "servicetype")) {
         if ((sscanf(var->value, "%30d", &num) == 1) && ((num == OSP_SRV_VOICE) || (num == OSP_SRV_NPQUERY))) {
            provider->srvtype = num;
            ast_debug(1, "OSP: servicetype '%d'\n", num);
         } else {
            ast_log(LOG_WARNING, "OSP: servicetype should be %d or %d, not '%s' at line %d\n",
               OSP_SRV_VOICE, OSP_SRV_NPQUERY, var->value, var->lineno);
         }
      }
   }

   if (provider->canum == 0) {
      provider->canum = 1;
   }

   for (i = 0; i < provider->spnum; i++) {
      pspoints[i] = provider->spoints[i];
   }

   if (osp_security) {
      privatekey.PrivateKeyData = NULL;
      privatekey.PrivateKeyLength = 0;

      localcert.CertData = NULL;
      localcert.CertDataLength = 0;

      for (i = 0; i < provider->canum; i++) {
         cacerts[i].CertData = NULL;
         cacerts[i].CertDataLength = 0;
      }

      if ((error = OSPPUtilLoadPEMPrivateKey((unsigned char*)provider->privatekey, &privatekey)) != OSPC_ERR_NO_ERROR) {
         ast_log(LOG_WARNING, "OSP: Unable to load privatekey '%s', error '%d'\n", provider->privatekey, error);
      } else if ((error = OSPPUtilLoadPEMCert((unsigned char*)provider->localcert, &localcert)) != OSPC_ERR_NO_ERROR) {
         ast_log(LOG_WARNING, "OSP: Unable to load localcert '%s', error '%d'\n", provider->localcert, error);
      } else {
         for (i = 0; i < provider->canum; i++) {
            if ((error = OSPPUtilLoadPEMCert((unsigned char*)provider->cacerts[i], &cacerts[i])) != OSPC_ERR_NO_ERROR) {
               ast_log(LOG_WARNING, "OSP: Unable to load cacert '%s', error '%d'\n", provider->cacerts[i], error);
               break;
            } else {
               pcacerts[i] = &cacerts[i];
            }
         }
      }
   } else {
      privatekey.PrivateKeyData = privatekeydata;
      privatekey.PrivateKeyLength = sizeof(privatekeydata);

      localcert.CertData = localcertdata;
      localcert.CertDataLength = sizeof(localcertdata);

      cacerts[0].CertData = cacertdata;
      cacerts[0].CertDataLength = sizeof(cacertdata);
      pcacerts[0] = &cacerts[0];

      if ((error = OSPPBase64Decode(B64PKey, strlen(B64PKey), privatekey.PrivateKeyData, &privatekey.PrivateKeyLength)) != OSPC_ERR_NO_ERROR) {
         ast_log(LOG_WARNING, "OSP: Unable to decode private key, error '%d'\n", error);
      } else if ((error = OSPPBase64Decode(B64LCert, strlen(B64LCert), localcert.CertData, &localcert.CertDataLength)) != OSPC_ERR_NO_ERROR) {
         ast_log(LOG_WARNING, "OSP: Unable to decode local cert, error '%d'\n", error);
      } else if ((error = OSPPBase64Decode(B64CACert, strlen(B64CACert), cacerts[0].CertData, &cacerts[0].CertDataLength)) != OSPC_ERR_NO_ERROR) {
         ast_log(LOG_WARNING, "OSP: Unable to decode cacert, error '%d'\n", error);
      }
   }

   if (error == OSPC_ERR_NO_ERROR) {
      error = OSPPProviderNew(provider->spnum,
         pspoints,
         NULL,
         OSP_AUDIT_URL,
         &privatekey,
         &localcert,
         provider->canum,
         pcacerts,
         OSP_LOCAL_VALIDATION,
         OSP_SSL_LIFETIME,
         provider->maxconnect,
         OSP_HTTP_PERSISTENCE,
         provider->retrydelay,
         provider->retrylimit,
         provider->timeout,
         OSP_CUSTOMER_ID,
         OSP_DEVICE_ID,
         &provider->handle);
      if (error != OSPC_ERR_NO_ERROR) {
         ast_log(LOG_WARNING, "OSP: Unable to create provider '%s', error '%d'\n", name, error);
         res = OSP_ERROR;
      } else {
         ast_debug(1, "OSP: provider '%s'\n", name);
         ast_mutex_lock(&osp_lock);
         provider->next = osp_providers;
         osp_providers = provider;
         ast_mutex_unlock(&osp_lock);
         res = OSP_OK;
      }
   }

   if (osp_security) {
      for (i = 0; i < provider->canum; i++) {
         if (cacerts[i].CertData) {
            ast_free(cacerts[i].CertData);
         }
      }
      if (localcert.CertData) {
         ast_free(localcert.CertData);
      }
      if (privatekey.PrivateKeyData) {
         ast_free(privatekey.PrivateKeyData);
      }
   }

   if (res != OSP_OK) {
      ast_free(provider);
   }

   return res;
}

static int osp_create_transaction	(	const char *	name,
		int *	trans,
		char *	source,
		unsigned int	srcsize
	)		`[static]`

Create OSP transaction handle.

Parameters:

name	OSP provider context name
trans	OSP transaction handle, output
source	Source of provider, output
srcsize	Size of source buffer, in

Returns:: OSK_OK Success, OSK_FAILED Failed, OSP_ERROR Error

Definition at line 942 of file app_osplookup.c.

References ast_copy_string(), ast_debug, ast_log(), ast_mutex_lock, ast_mutex_unlock, osp_provider::handle, LOG_ERROR, osp_provider::name, osp_provider::next, OSP_ERROR, OSP_FAILED, OSP_INVALID_HANDLE, osp_lock, OSP_OK, and osp_provider::source.

Referenced by osp_auth(), and osp_lookup().

{
   int res = OSP_FAILED;
   struct osp_provider* provider;
   int error;

   if ((trans == NULL) || (source == NULL) || (srcsize <= 0)) {
      ast_log(LOG_ERROR, "Invalid parameters\n");
      return OSP_ERROR;
   }

   *trans = OSP_INVALID_HANDLE;
   *source = '\0';

   ast_mutex_lock(&osp_lock);
   for (provider = osp_providers; provider; provider = provider->next) {
      if (!strcasecmp(provider->name, name)) {
         error = OSPPTransactionNew(provider->handle, trans);
         if (error == OSPC_ERR_NO_ERROR) {
            ast_debug(1, "OSP: transaction '%d'\n", *trans);
            ast_copy_string(source, provider->source, srcsize);
            ast_debug(1, "OSP: source '%s'\n", source);
            res = OSP_OK;
         } else {
            *trans = OSP_INVALID_HANDLE;
            ast_debug(1, "OSP: Unable to create transaction handle, error '%d'\n", error);
            *source = '\0';
            res = OSP_ERROR;
         }
         break;
      }
   }
   ast_mutex_unlock(&osp_lock);

   return res;
}

static int osp_create_uuid	(	unsigned char *	uuid,
		unsigned int *	bufsize
	)		`[static]`

Create a UUID.

Parameters:

uuid	UUID buffer
bufsize	UUID buffer size

Returns:: OSK_OK Created, OSP_ERROR Error

Definition at line 1391 of file app_osplookup.c.

References ast_log(), ast_random(), LOG_ERROR, OSP_ERROR, OSP_OK, and OSP_SIZE_UUID.

Referenced by osp_create_callid().

{
   int i, res;
   long int tmp[OSP_SIZE_UUID / sizeof(long int)];

   if ((uuid != NULL) && (*bufsize >= OSP_SIZE_UUID)) {
      for (i = 0; i < OSP_SIZE_UUID / sizeof(long int); i++) {
         tmp[i] = ast_random();
      }
      memcpy(uuid, tmp, OSP_SIZE_UUID);
      *bufsize = OSP_SIZE_UUID;
      res = OSP_OK;
   } else {
      ast_log(LOG_ERROR, "Invalid parameters\n");
      res = OSP_ERROR;
   }

   return res;
}

static int osp_finish	(	int	trans,
		int	recorded,
		int	cause,
		time_t	start,
		time_t	connect,
		time_t	end,
		unsigned int	release,
		const char *	inqos,
		const char *	outqos
	)		`[static]`

OSP Finish function.

Parameters:

trans	OSP in/outbound transaction handle
recorded	If failure reason has been recorded
cause	Asterisk hangup cause
start	Call start time
connect	Call connect time
end	Call end time
release	Who release first, 0 source, 1 destination
inqos	Inbound QoS string
outqos	Outbound QoS string

Returns:: OSP_OK Success, OSP_FAILED Failed, OSP_ERROR Error

Definition at line 2183 of file app_osplookup.c.

References ast_debug, asterisk2osp(), dummy(), OSP_CALL_INBOUND, OSP_CALL_OUTBOUND, OSP_DEF_INTSTATS, OSP_ERROR, OSP_FAILED, OSP_INVALID_HANDLE, OSP_OK, and osp_report_qos().

Referenced by ospfinished_exec().

{
   int res;
   OSPEFAILREASON reason;
   time_t alert = 0;
   unsigned isPddInfoPresent = 0;
   unsigned pdd = 0;
   unsigned int dummy = 0;
   int error;

   if (trans == OSP_INVALID_HANDLE) {
      return OSP_FAILED;
   }

   OSPPTransactionSetRoleInfo(trans, OSPC_RSTATE_STOP, OSPC_RFORMAT_OSP, OSPC_RVENDOR_ASTERISK);

   if (!recorded) {
      reason = asterisk2osp(cause);
      OSPPTransactionRecordFailure(trans, reason);
   }

   osp_report_qos(trans, OSP_CALL_INBOUND, inqos);
   osp_report_qos(trans, OSP_CALL_OUTBOUND, outqos);

   error = OSPPTransactionReportUsage(trans,
      difftime(end, connect),
      start,
      end,
      alert,
      connect,
      isPddInfoPresent,
      pdd,
      release,
      NULL,
      OSP_DEF_INTSTATS,
      OSP_DEF_INTSTATS,
      OSP_DEF_INTSTATS,
      OSP_DEF_INTSTATS,
      &dummy,
      NULL);
   if (error == OSPC_ERR_NO_ERROR) {
      ast_debug(1, "OSP: Usage reported\n");
      res = OSP_OK;
   } else {
      ast_debug(1, "OSP: Unable to report usage, error '%d'\n", error);
      res = OSP_ERROR;
   }
   OSPPTransactionDelete(trans);

   return res;
}

static int osp_get_provider	(	const char *	name,
		struct osp_provider **	provider
	)		`[static]`

Get OSP provider by name.

Parameters:

name	OSP provider context name
provider	OSP provider structure

Returns:: OSP_OK Success, OSP_FAILED Failed, OSP_ERROR Error

Definition at line 911 of file app_osplookup.c.

References ast_debug, ast_mutex_lock, ast_mutex_unlock, osp_provider::name, osp_provider::next, OSP_FAILED, osp_lock, and OSP_OK.

Referenced by osp_auth(), osp_lookup(), and osp_next().

{
   int res = OSP_FAILED;
   struct osp_provider* p;

   *provider = NULL;

   ast_mutex_lock(&osp_lock);
   for (p = osp_providers; p != NULL; p = p->next) {
      if (!strcasecmp(p->name, name)) {
         *provider = p;
         ast_debug(1, "OSP: find provider '%s'\n", name);
         res = OSP_OK;
         break;
      }
   }
   ast_mutex_unlock(&osp_lock);

   return res;
}

static float osp_get_varfloat ( const char * vstr ) [static]

Get float from variable string.

Parameters:

vstr	Variable string

Returns:: OSP_DEF_FLOATSTATS Error

Definition at line 1941 of file app_osplookup.c.

References ast_strlen_zero(), OSP_DEF_FLOATSTATS, and value.

Referenced by osp_report_qos().

{
   char* tmp;
   float value = OSP_DEF_FLOATSTATS;

   if (!ast_strlen_zero(vstr)) {
      if ((tmp = strchr(vstr, '=')) != NULL) {
         tmp++;
         if (sscanf(tmp, "%30f", &value) != 1) {
            value = OSP_DEF_FLOATSTATS;
         }
      }
   }

   return value;
}

static int osp_get_varint ( const char * vstr ) [static]

Get integer from variable string.

Parameters:

vstr	Variable string

Returns:: OSP_DEF_INTSTATS Error

Definition at line 1918 of file app_osplookup.c.

References ast_strlen_zero(), OSP_DEF_INTSTATS, and value.

Referenced by osp_report_qos().

{
   char* tmp;
   int value = OSP_DEF_INTSTATS;

   if (!ast_strlen_zero(vstr)) {
      if ((tmp = strchr(vstr, '=')) != NULL) {
         tmp++;
         if (sscanf(tmp, "%30d", &value) != 1) {
            value = OSP_DEF_INTSTATS;
         }
      }
   }

   return value;
}

static int osp_load ( int reload ) [static]

Definition at line 2951 of file app_osplookup.c.

References ast_category_browse(), ast_config_destroy(), ast_config_load, ast_debug, ast_log(), ast_true(), ast_variable_retrieve(), CONFIG_FLAG_FILEUNCHANGED, CONFIG_STATUS_FILEINVALID, CONFIG_STATUS_FILEUNCHANGED, LOG_ERROR, LOG_WARNING, OSP_CONFIG_FILE, osp_create_provider(), OSP_GENERAL_CAT, and osp_unload().

Referenced by load_module(), and reload().

{
   const char* cvar;
   unsigned int ivar;
   struct ast_config* cfg;
   struct ast_flags config_flags = { reload ? CONFIG_FLAG_FILEUNCHANGED : 0 };
   int error = OSPC_ERR_NO_ERROR;

   if ((cfg = ast_config_load(OSP_CONFIG_FILE, config_flags)) == CONFIG_STATUS_FILEUNCHANGED) {
      return 0;
   } else if (cfg == CONFIG_STATUS_FILEINVALID) {
      ast_log(LOG_ERROR, "Config file %s is in an invalid format.  Aborting.\n", OSP_CONFIG_FILE);
      return 0;
   }

   if (cfg) {
      if (reload) {
         osp_unload();
      }

      if ((cvar = ast_variable_retrieve(cfg, OSP_GENERAL_CAT, "accelerate")) && ast_true(cvar)) {
         if ((error = OSPPInit(1)) != OSPC_ERR_NO_ERROR) {
            ast_log(LOG_WARNING, "OSP: Unable to enable hardware acceleration, error='%d'\n", error);
            OSPPInit(0);
         } else {
            osp_hardware = 1;
         }
      } else {
         OSPPInit(0);
      }
      ast_debug(1, "OSP: osp_hardware '%d'\n", osp_hardware);

      if ((cvar = ast_variable_retrieve(cfg, OSP_GENERAL_CAT, "securityfeatures")) && ast_true(cvar)) {
         osp_security = 1;
      }
      ast_debug(1, "OSP: osp_security '%d'\n", osp_security);

      if ((cvar = ast_variable_retrieve(cfg, OSP_GENERAL_CAT, "tokenformat"))) {
         if ((sscanf(cvar, "%30d", &ivar) == 1) &&
            ((ivar == TOKEN_ALGO_SIGNED) || (ivar == TOKEN_ALGO_UNSIGNED) || (ivar == TOKEN_ALGO_BOTH)))
         {
            osp_tokenformat = ivar;
         } else {
            ast_log(LOG_WARNING, "tokenformat should be an integer from %d, %d or %d, not '%s'\n",
               TOKEN_ALGO_SIGNED, TOKEN_ALGO_UNSIGNED, TOKEN_ALGO_BOTH, cvar);
         }
      }
      ast_debug(1, "OSP: osp_tokenformat '%d'\n", osp_tokenformat);

      for (cvar = ast_category_browse(cfg, NULL); cvar != NULL; cvar = ast_category_browse(cfg, cvar)) {
         if (strcasecmp(cvar, OSP_GENERAL_CAT)) {
            osp_create_provider(cfg, cvar);
         }
      }

      osp_initialized = 1;

      ast_config_destroy(cfg);
   } else {
      ast_log(LOG_WARNING, "OSP: Unable to find configuration. OSP support disabled\n");
      return 0;
   }
   ast_debug(1, "OSP: osp_initialized '%d'\n", osp_initialized);

   return 1;
}

static int osp_lookup	(	const char *	name,
		unsigned int	callidtypes,
		const char *	actualsrc,
		const char *	srcdev,
		const char *	calling,
		const char *	called,
		const char *	snetid,
		struct osp_npdata *	np,
		struct osp_headers *	headers,
		const char *	cinfo[],
		struct osp_results *	results
	)		`[static]`

OSP Lookup function.

Parameters:

name	OSP provider context name
callidtypes	Call ID types
actualsrc	Actual source device in indirect mode
srcdev	Source device of outbound call
calling	Calling number
called	Called number
snetid	Source network ID
np	NP parameters
headers	SIP header parameters
cinfo	Custom info
results	Lookup results

Returns:: OSP_OK Found , OSP_FAILED No route, OSP_ERROR Error

Definition at line 1494 of file app_osplookup.c.

References ast_copy_string(), ast_debug, ast_log(), ast_strlen_zero(), osp_callid::buf, osp_results::called, osp_results::calling, osp_npdata::cic, osp_results::dest, osp_headers::divhost, osp_headers::divuser, dummy(), osp_results::inhandle, osp_results::intech, osp_results::intimelimit, osp_callid::len, LOG_ERROR, LOG_WARNING, osp_results::networkid, osp_results::npcic, osp_npdata::npdi, osp_results::npdi, osp_results::nprn, osp_results::numdests, osp_npdata::opname, osp_results::opname, OSP_CALLID_MAXNUM, osp_check_destination(), osp_choose_timelimit(), osp_convert_inout(), osp_create_callid(), osp_create_transaction(), OSP_DEF_MAXDESTS, OSP_DEF_TIMELIMIT, OSP_ERROR, OSP_FAILED, osp_get_provider(), OSP_INVALID_HANDLE, OSP_MAX_CUSTOMINFO, OSP_MODE_INDIRECT, OSP_OK, OSP_SIZE_NORSTR, OSP_SIZE_TOKSTR, OSP_SRV_NPQUERY, OSP_TECH_H323, OSP_TECH_IAX, OSP_TECH_SIP, OSP_TECH_SKYPE, osp_results::outcallid, osp_results::outhandle, osp_results::outtech, osp_results::outtimelimit, osp_headers::paiuser, osp_headers::pciuser, osp_npdata::rn, osp_headers::rpiduser, osp_provider::source, osp_provider::srvtype, osp_results::token, type, and osp_provider::workmode.

Referenced by osplookup_exec().

{
   int res;
   struct osp_provider* provider = NULL;
   OSPE_PROTOCOL_NAME protocol;
   char source[OSP_SIZE_NORSTR];
   char callingnum[OSP_SIZE_NORSTR];
   char callednum[OSP_SIZE_NORSTR];
   char destination[OSP_SIZE_NORSTR];
   char* tmp;
   unsigned int tokenlen;
   char token[OSP_SIZE_TOKSTR];
   char src[OSP_SIZE_NORSTR];
   char dev[OSP_SIZE_NORSTR];
   char host[OSP_SIZE_NORSTR];
   unsigned int i, type;
   struct osp_callid callid;
   unsigned int callidnum;
   OSPT_CALL_ID* callids[OSP_CALLID_MAXNUM];
   char dest[OSP_SIZE_NORSTR];
   const char* preferred[2] = { NULL };
   unsigned int dummy = 0;
   OSPEFAILREASON reason;
   int error;

   if (results == NULL) {
      ast_log(LOG_ERROR, "Invalid parameters\n");
      return OSP_ERROR;
   }

   osp_convert_inout(results->dest, dest, sizeof(dest));

   results->outhandle = OSP_INVALID_HANDLE;
   results->outtech[0] = '\0';
   results->calling[0] = '\0';
   results->called[0] = '\0';
   results->token[0] = '\0';
   results->networkid[0] = '\0';
   results->nprn[0] = '\0';
   results->npcic[0] = '\0';
   results->npdi = 0;
   for (type = OSPC_OPNAME_START; type < OSPC_OPNAME_NUMBER; type++) {
      results->opname[type][0] = '\0';
   }
   results->numdests = 0;
   results->outtimelimit = OSP_DEF_TIMELIMIT;

   if ((res = osp_get_provider(name, &provider)) <= 0) {
      ast_debug(1, "OSP: Unabe to find OSP provider '%s'\n", name);
      return res;
   }

   if ((res = osp_create_transaction(name, &results->outhandle, source, sizeof(source))) <= 0) {
      ast_debug(1, "OSP: Unable to generate transaction handle\n");
      results->outhandle = OSP_INVALID_HANDLE;
      if (results->inhandle != OSP_INVALID_HANDLE) {
         OSPPTransactionRecordFailure(results->inhandle, OSPC_FAIL_NORMAL_UNSPECIFIED);
      }
      return OSP_ERROR;
   }

   if (!strcasecmp(results->intech, OSP_TECH_SIP)) {
      protocol = OSPC_PROTNAME_SIP;
   } else if (!strcasecmp(results->intech, OSP_TECH_H323)) {
      protocol = OSPC_PROTNAME_Q931;
   } else if (!strcasecmp(results->intech, OSP_TECH_IAX)) {
      protocol = OSPC_PROTNAME_IAX;
   } else if (!strcasecmp(results->intech, OSP_TECH_SKYPE)) {
      protocol = OSPC_PROTNAME_SKYPE;
   } else {
      protocol = OSPC_PROTNAME_SIP;
   }
   OSPPTransactionSetProtocol(results->outhandle, OSPC_PROTTYPE_SOURCE, protocol);

   if (!ast_strlen_zero(snetid)) {
      OSPPTransactionSetNetworkIds(results->outhandle, snetid, "");
   }

   OSPPTransactionSetNumberPortability(results->outhandle, np->rn, np->cic, np->npdi);

   for (type = OSPC_OPNAME_START; type < OSPC_OPNAME_NUMBER; type++) {
      OSPPTransactionSetOperatorName(results->outhandle, type, np->opname[type]);
   }

    OSPPTransactionSetRemotePartyId(results->outhandle, OSPC_NFORMAT_E164, headers->rpiduser);
    OSPPTransactionSetAssertedId(results->outhandle, OSPC_NFORMAT_E164, headers->paiuser);
   osp_convert_inout(headers->divhost, host, sizeof(host));
   OSPPTransactionSetDiversion(results->outhandle, headers->divuser, host);
    OSPPTransactionSetChargeInfo(results->outhandle, OSPC_NFORMAT_E164, headers->pciuser);

   if (cinfo != NULL) {
      for (i = 0; i < OSP_MAX_CUSTOMINFO; i++) {
         if (!ast_strlen_zero(cinfo[i])) {
            OSPPTransactionSetCustomInfo(results->outhandle, i, cinfo[i]);
         }
      }
   }

   ast_copy_string(callednum, called, sizeof(callednum));
   if((tmp = strchr(callednum, ';')) != NULL) {
      *tmp = '\0';
   }

   callidnum = 0;
   callids[0] = NULL;
   for (i = 0; i < OSP_CALLID_MAXNUM; i++) {
      type = 1 << i;
      if (callidtypes & type) {
         error = osp_create_callid(type, &callid);
         if (error == 1) {
            callids[callidnum] = OSPPCallIdNew(callid.len, callid.buf);
            callidnum++;
         }
      }
   }

   if (provider->workmode == OSP_MODE_INDIRECT) {
      osp_convert_inout(srcdev, src, sizeof(src));
      if (ast_strlen_zero(actualsrc)) {
         osp_convert_inout(srcdev, dev, sizeof(dev));
      } else {
         osp_convert_inout(actualsrc, dev, sizeof(dev));
      }
   } else {
      osp_convert_inout(source, src, sizeof(src));
      osp_convert_inout(srcdev, dev, sizeof(dev));
   }

   if (provider->srvtype == OSP_SRV_NPQUERY) {
      OSPPTransactionSetServiceType(results->outhandle, OSPC_SERVICE_NPQUERY);
      if (!ast_strlen_zero(dest)) {
         preferred[0] = dest;
      }
      results->numdests = 1;
   } else {
      OSPPTransactionSetServiceType(results->outhandle, OSPC_SERVICE_VOICE);
      results->numdests = OSP_DEF_MAXDESTS;
   }

   error = OSPPTransactionRequestAuthorisation(results->outhandle,
      src,
      dev,
      calling ? calling : "",
      OSPC_NFORMAT_E164,
      callednum,
      OSPC_NFORMAT_E164,
      NULL,
      callidnum,
      callids,
      preferred,
      &results->numdests,
      &dummy,
      NULL);

   for (i = 0; i < callidnum; i++) {
      OSPPCallIdDelete(&callids[i]);
   }

   if (error != OSPC_ERR_NO_ERROR) {
      ast_log(LOG_WARNING, "OSP: Unable to request authorization, error '%d'\n", error);
      results->numdests = 0;
      if (results->inhandle != OSP_INVALID_HANDLE) {
         OSPPTransactionRecordFailure(results->inhandle, OSPC_FAIL_NORMAL_UNSPECIFIED);
      }
      return OSP_ERROR;
   }

   if (!results->numdests) {
      ast_debug(1, "OSP: No more destination\n");
      if (results->inhandle != OSP_INVALID_HANDLE) {
         OSPPTransactionRecordFailure(results->inhandle, OSPC_FAIL_NO_ROUTE_TO_DEST);
      }
      return OSP_FAILED;
   }

   results->outcallid.len = sizeof(results->outcallid.buf);
   tokenlen = sizeof(token);
   error = OSPPTransactionGetFirstDestination(results->outhandle,
      0,
      NULL,
      NULL,
      &results->outtimelimit,
      &results->outcallid.len,
      results->outcallid.buf,
      sizeof(callednum),
      callednum,
      sizeof(callingnum),
      callingnum,
      sizeof(destination),
      destination,
      0,
      NULL,
      &tokenlen,
      token);
   if (error != OSPC_ERR_NO_ERROR) {
      ast_debug(1, "OSP: Unable to get first route, error '%d'\n", error);
      results->numdests = 0;
      results->outtimelimit = OSP_DEF_TIMELIMIT;
      if (results->inhandle != OSP_INVALID_HANDLE) {
         OSPPTransactionRecordFailure(results->inhandle, OSPC_FAIL_NO_ROUTE_TO_DEST);
      }
      return OSP_ERROR;
   }

   results->numdests--;
   results->outtimelimit = osp_choose_timelimit(results->intimelimit, results->outtimelimit);
   ast_debug(1, "OSP: outtimelimit '%d'\n", results->outtimelimit);
   ast_debug(1, "OSP: calling '%s'\n", callingnum);
   ast_debug(1, "OSP: called '%s'\n", callednum);
   ast_debug(1, "OSP: destination '%s'\n", destination);
   ast_debug(1, "OSP: token size '%d'\n", tokenlen);

   if ((res = osp_check_destination(provider, callingnum, callednum, destination, tokenlen, token, &reason, results)) > 0) {
      return OSP_OK;
   }

   if (!results->numdests) {
      ast_debug(1, "OSP: No more destination\n");
      results->outtimelimit = OSP_DEF_TIMELIMIT;
      OSPPTransactionRecordFailure(results->outhandle, reason);
      if (results->inhandle != OSP_INVALID_HANDLE) {
         OSPPTransactionRecordFailure(results->inhandle, OSPC_FAIL_NO_ROUTE_TO_DEST);
      }
      return OSP_FAILED;
   }

   while(results->numdests) {
      results->outcallid.len = sizeof(results->outcallid.buf);
      tokenlen = sizeof(token);
      error = OSPPTransactionGetNextDestination(results->outhandle,
         reason,
         0,
         NULL,
         NULL,
         &results->outtimelimit,
         &results->outcallid.len,
         results->outcallid.buf,
         sizeof(callednum),
         callednum,
         sizeof(callingnum),
         callingnum,
         sizeof(destination),
         destination,
         0,
         NULL,
         &tokenlen,
         token);
      if (error == OSPC_ERR_NO_ERROR) {
         results->numdests--;
         results->outtimelimit = osp_choose_timelimit(results->intimelimit, results->outtimelimit);
         ast_debug(1, "OSP: outtimelimit '%d'\n", results->outtimelimit);
         ast_debug(1, "OSP: calling '%s'\n", callingnum);
         ast_debug(1, "OSP: called '%s'\n", callednum);
         ast_debug(1, "OSP: destination '%s'\n", destination);
         ast_debug(1, "OSP: token size '%d'\n", tokenlen);

         if ((res = osp_check_destination(provider, callingnum, callednum, destination, tokenlen, token, &reason, results)) > 0) {
            break;
         } else if (!results->numdests) {
            ast_debug(1, "OSP: No more destination\n");
            OSPPTransactionRecordFailure(results->outhandle, reason);
            if (results->inhandle != OSP_INVALID_HANDLE) {
               OSPPTransactionRecordFailure(results->inhandle, OSPC_FAIL_NO_ROUTE_TO_DEST);
            }
            res = OSP_FAILED;
            break;
         }
      } else {
         ast_debug(1, "OSP: Unable to get route, error '%d'\n", error);
         results->numdests = 0;
         results->outtimelimit = OSP_DEF_TIMELIMIT;
         if (results->inhandle != OSP_INVALID_HANDLE) {
            OSPPTransactionRecordFailure(results->inhandle, OSPC_FAIL_NORMAL_UNSPECIFIED);
         }
         res = OSP_ERROR;
         break;
      }
   }

   return res;
}

static int osp_next	(	const char *	name,
		int	cause,
		struct osp_results *	results
	)		`[static]`

OSP Lookup Next function.

Parameters:

name	OSP provider name
cause	Asterisk hangup cause
results	Lookup results, in/output

Returns:: OSP_OK Found , OSP_FAILED No route, OSP_ERROR Error

Definition at line 1794 of file app_osplookup.c.

References ast_debug, ast_log(), asterisk2osp(), osp_callid::buf, osp_results::called, osp_results::calling, osp_results::dest, osp_results::inhandle, osp_results::intimelimit, osp_callid::len, LOG_ERROR, osp_results::networkid, osp_results::npcic, osp_results::npdi, osp_results::nprn, osp_results::numdests, osp_results::opname, osp_check_destination(), osp_choose_timelimit(), OSP_DEF_TIMELIMIT, OSP_ERROR, OSP_FAILED, osp_get_provider(), OSP_INVALID_HANDLE, OSP_OK, OSP_SIZE_NORSTR, OSP_SIZE_TOKSTR, osp_results::outcallid, osp_results::outhandle, osp_results::outtech, osp_results::outtimelimit, osp_results::token, and type.

Referenced by ospnext_exec().

{
   int res;
   struct osp_provider* provider = NULL;
   char calling[OSP_SIZE_NORSTR];
   char called[OSP_SIZE_NORSTR];
   char dest[OSP_SIZE_NORSTR];
   unsigned int tokenlen;
   char token[OSP_SIZE_TOKSTR];
   OSPEFAILREASON reason;
   OSPE_OPERATOR_NAME type;
   int error;

   if (results == NULL) {
      ast_log(LOG_ERROR, "Invalid parameters\n");
      return OSP_ERROR;
   }

   results->outtech[0] = '\0';
   results->dest[0] = '\0';
   results->calling[0] = '\0';
   results->called[0] = '\0';
   results->token[0] = '\0';
   results->networkid[0] = '\0';
   results->nprn[0] = '\0';
   results->npcic[0] = '\0';
   results->npdi = 0;
   for (type = OSPC_OPNAME_START; type < OSPC_OPNAME_NUMBER; type++) {
      results->opname[type][0] = '\0';
   }
   results->outtimelimit = OSP_DEF_TIMELIMIT;

   if ((res = osp_get_provider(name, &provider)) <= 0) {
      ast_debug(1, "OSP: Unabe to find OSP provider '%s'\n", name);
      return res;
   }

   if (results->outhandle == OSP_INVALID_HANDLE) {
      ast_debug(1, "OSP: Transaction handle undefined\n");
      results->numdests = 0;
      if (results->inhandle != OSP_INVALID_HANDLE) {
         OSPPTransactionRecordFailure(results->inhandle, OSPC_FAIL_NORMAL_UNSPECIFIED);
      }
      return OSP_ERROR;
   }

   reason = asterisk2osp(cause);

   if (!results->numdests) {
      ast_debug(1, "OSP: No more destination\n");
      OSPPTransactionRecordFailure(results->outhandle, reason);
      if (results->inhandle != OSP_INVALID_HANDLE) {
         OSPPTransactionRecordFailure(results->inhandle, OSPC_FAIL_NO_ROUTE_TO_DEST);
      }
      return OSP_FAILED;
   }

   while(results->numdests) {
      results->outcallid.len = sizeof(results->outcallid.buf);
      tokenlen = sizeof(token);
      error = OSPPTransactionGetNextDestination(
         results->outhandle,
         reason,
         0,
         NULL,
         NULL,
         &results->outtimelimit,
         &results->outcallid.len,
         results->outcallid.buf,
         sizeof(called),
         called,
         sizeof(calling),
         calling,
         sizeof(dest),
         dest,
         0,
         NULL,
         &tokenlen,
         token);
      if (error == OSPC_ERR_NO_ERROR) {
         results->numdests--;
         results->outtimelimit = osp_choose_timelimit(results->intimelimit, results->outtimelimit);
         ast_debug(1, "OSP: outtimelimit '%d'\n", results->outtimelimit);
         ast_debug(1, "OSP: calling '%s'\n", calling);
         ast_debug(1, "OSP: called '%s'\n", called);
         ast_debug(1, "OSP: destination '%s'\n", dest);
         ast_debug(1, "OSP: token size '%d'\n", tokenlen);

         if ((res = osp_check_destination(provider, calling, called, dest, tokenlen, token, &reason, results)) > 0) {
            res = OSP_OK;
            break;
         } else if (!results->numdests) {
            ast_debug(1, "OSP: No more destination\n");
            OSPPTransactionRecordFailure(results->outhandle, reason);
            if (results->inhandle != OSP_INVALID_HANDLE) {
               OSPPTransactionRecordFailure(results->inhandle, OSPC_FAIL_NO_ROUTE_TO_DEST);
            }
            res = OSP_FAILED;
            break;
         }
      } else {
         ast_debug(1, "OSP: Unable to get route, error '%d'\n", error);
         results->token[0] = '\0';
         results->numdests = 0;
         results->outtimelimit = OSP_DEF_TIMELIMIT;
         if (results->inhandle != OSP_INVALID_HANDLE) {
            OSPPTransactionRecordFailure(results->inhandle, OSPC_FAIL_NORMAL_UNSPECIFIED);
         }
         res = OSP_ERROR;
         break;
      }
   }

   return res;
}

static int osp_report_qos	(	int	trans,
		enum osp_callleg	leg,
		const char *	qos
	)		`[static]`

Report QoS.

Parameters:

trans	OSP in/outbound transaction handle
leg	Inbound/outbound
qos	QoS string

Returns:: OSP_OK Success, OSP_FAILED Failed, OSP_ERROR Error

Definition at line 1966 of file app_osplookup.c.

References ast_copy_string(), ast_debug, ast_strlen_zero(), osp_metrics::avg, osp_metrics::max, osp_metrics::min, OSP_CALL_INBOUND, OSP_DEF_FLOATSTATS, OSP_DEF_INTSTATS, OSP_DIR_NUMBER, OSP_DIR_RX, OSP_DIR_TX, OSP_FAILED, osp_get_varfloat(), osp_get_varint(), OSP_OK, OSP_SIZE_NORSTR, osp_metrics::sdev, value, and osp_metrics::value.

Referenced by osp_finish().

{
   int res = OSP_FAILED;
   enum osp_direction dir;
   char buffer[OSP_SIZE_NORSTR];
   char* tmp;
   char* item;
   int totalpackets[OSP_DIR_NUMBER];
   struct osp_metrics lost[OSP_DIR_NUMBER];
   struct osp_metrics jitter[OSP_DIR_NUMBER];
   struct osp_metrics rtt;
   int value;

   if (!ast_strlen_zero(qos)) {
      for (dir = OSP_DIR_RX; dir < OSP_DIR_NUMBER; dir++) {
         totalpackets[dir] = OSP_DEF_INTSTATS;
      }

      for (dir = OSP_DIR_RX; dir < OSP_DIR_NUMBER; dir++) {
         lost[dir].value = OSP_DEF_INTSTATS;
         lost[dir].min = OSP_DEF_FLOATSTATS;
         lost[dir].max = OSP_DEF_FLOATSTATS;
         lost[dir].avg = OSP_DEF_FLOATSTATS;
         lost[dir].sdev = OSP_DEF_FLOATSTATS;
      }

      for (dir = OSP_DIR_RX; dir < OSP_DIR_NUMBER; dir++) {
         jitter[dir].value = OSP_DEF_INTSTATS;
         jitter[dir].min = OSP_DEF_FLOATSTATS;
         jitter[dir].max = OSP_DEF_FLOATSTATS;
         jitter[dir].avg = OSP_DEF_FLOATSTATS;
         jitter[dir].sdev = OSP_DEF_FLOATSTATS;
      }

      rtt.value = OSP_DEF_INTSTATS;
      rtt.min = OSP_DEF_FLOATSTATS;
      rtt.max = OSP_DEF_FLOATSTATS;
      rtt.avg = OSP_DEF_FLOATSTATS;
      rtt.sdev = OSP_DEF_FLOATSTATS;

      ast_copy_string(buffer, qos, sizeof(buffer));
      for (item = strtok_r(buffer, ";", &tmp); item; item = strtok_r(NULL, ";", &tmp)) {
         if (!strncasecmp(item, "rxcount", strlen("rxcount"))) {
            totalpackets[OSP_DIR_RX] = osp_get_varint(item);
         } else if (!strncasecmp(item, "txcount", strlen("txcount"))) {
            totalpackets[OSP_DIR_TX] = osp_get_varint(item);
         } else if (!strncasecmp(item, "lp", strlen("lp"))) {
            lost[OSP_DIR_RX].value = osp_get_varint(item);
         } else if (!strncasecmp(item, "minrxlost", strlen("minrxlost"))) {
            lost[OSP_DIR_RX].min = osp_get_varfloat(item);
         } else if (!strncasecmp(item, "maxrxlost", strlen("maxrxlost"))) {
            lost[OSP_DIR_RX].max = osp_get_varfloat(item);
         } else if (!strncasecmp(item, "avgrxlost", strlen("avgrxlost"))) {
            lost[OSP_DIR_RX].avg = osp_get_varfloat(item);
         } else if (!strncasecmp(item, "stdevrxlost", strlen("stdevrxlost"))) {
            lost[OSP_DIR_RX].sdev = osp_get_varfloat(item);
         } else if (!strncasecmp(item, "rlp", strlen("rlp"))) {
            lost[OSP_DIR_TX].value = osp_get_varint(item);
         } else if (!strncasecmp(item, "reported_minlost", strlen("reported_minlost"))) {
            lost[OSP_DIR_TX].min = osp_get_varfloat(item);
         } else if (!strncasecmp(item, "reported_maxlost", strlen("reported_maxlost"))) {
            lost[OSP_DIR_TX].max = osp_get_varfloat(item);
         } else if (!strncasecmp(item, "reported_avglost", strlen("reported_avglost"))) {
            lost[OSP_DIR_TX].avg = osp_get_varfloat(item);
         } else if (!strncasecmp(item, "reported_stdevlost", strlen("reported_stdevlost"))) {
            lost[OSP_DIR_TX].sdev = osp_get_varfloat(item);
         } else if (!strncasecmp(item, "rxjitter", strlen("rxjitter"))) {
            jitter[OSP_DIR_RX].value = osp_get_varint(item);
         } else if (!strncasecmp(item, "minrxjitter", strlen("minrxjitter"))) {
            jitter[OSP_DIR_RX].min = osp_get_varfloat(item);
         } else if (!strncasecmp(item, "maxrxjitter", strlen("maxrxjitter"))) {
            jitter[OSP_DIR_RX].max = osp_get_varfloat(item);
         } else if (!strncasecmp(item, "avgrxjitter", strlen("avgjitter"))) {
            jitter[OSP_DIR_RX].avg = osp_get_varfloat(item);
         } else if (!strncasecmp(item, "stdevrxjitter", strlen("stdevjitter"))) {
            jitter[OSP_DIR_RX].sdev = osp_get_varfloat(item);
         } else if (!strncasecmp(item, "txjitter", strlen("txjitter"))) {
            jitter[OSP_DIR_TX].value = osp_get_varint(item);
         } else if (!strncasecmp(item, "reported_minjitter", strlen("reported_minjitter"))) {
            jitter[OSP_DIR_TX].min = osp_get_varfloat(item);
         } else if (!strncasecmp(item, "reported_maxjitter", strlen("reported_maxjitter"))) {
            jitter[OSP_DIR_TX].max = osp_get_varfloat(item);
         } else if (!strncasecmp(item, "reported_avgjitter", strlen("reported_avgjitter"))) {
            jitter[OSP_DIR_TX].avg = osp_get_varfloat(item);
         } else if (!strncasecmp(item, "reported_stdevjitter", strlen("reported_stdevjitter"))) {
            jitter[OSP_DIR_TX].sdev = osp_get_varfloat(item);
         } else if (!strncasecmp(item, "rtt", strlen("rtt"))) {
            rtt.value = osp_get_varint(item);
         } else if (!strncasecmp(item, "minrtt", strlen("minrtt"))) {
            rtt.min = osp_get_varfloat(item);
         } else if (!strncasecmp(item, "maxrtt", strlen("maxrtt"))) {
            rtt.max = osp_get_varfloat(item);
         } else if (!strncasecmp(item, "avgrtt", strlen("avgrtt"))) {
            rtt.avg = osp_get_varfloat(item);
         } else if (!strncasecmp(item, "stdevrtt", strlen("stdevrtt"))) {
            rtt.sdev = osp_get_varfloat(item);
         }
      }

      ast_debug(1, "OSP: call leg '%d'\n", leg);
      ast_debug(1, "OSP: rxcount '%d'\n", totalpackets[OSP_DIR_RX]);
      ast_debug(1, "OSP: txcount '%d'\n", totalpackets[OSP_DIR_TX]);
      ast_debug(1, "OSP: lp '%d'\n",lost[OSP_DIR_RX].value);
      ast_debug(1, "OSP: minrxlost '%f'\n", lost[OSP_DIR_RX].min);
      ast_debug(1, "OSP: maxrxlost '%f'\n", lost[OSP_DIR_RX].max);
      ast_debug(1, "OSP: avgrxlost '%f'\n", lost[OSP_DIR_RX].avg);
      ast_debug(1, "OSP: stdevrxlost '%f'\n", lost[OSP_DIR_RX].sdev);
      ast_debug(1, "OSP: rlp '%d'\n", lost[OSP_DIR_TX].value);
      ast_debug(1, "OSP: reported_minlost '%f'\n", lost[OSP_DIR_TX].min);
      ast_debug(1, "OSP: reported_maxlost '%f'\n", lost[OSP_DIR_TX].max);
      ast_debug(1, "OSP: reported_avglost '%f'\n", lost[OSP_DIR_TX].avg);
      ast_debug(1, "OSP: reported_stdevlost '%f'\n", lost[OSP_DIR_TX].sdev);
      ast_debug(1, "OSP: rxjitter '%d'\n", jitter[OSP_DIR_RX].value);
      ast_debug(1, "OSP: minrxjitter '%f'\n", jitter[OSP_DIR_RX].min);
      ast_debug(1, "OSP: maxrxjitter '%f'\n", jitter[OSP_DIR_RX].max);
      ast_debug(1, "OSP: avgrxjitter '%f'\n", jitter[OSP_DIR_RX].avg);
      ast_debug(1, "OSP: stdevrxjitter '%f'\n", jitter[OSP_DIR_RX].sdev);
      ast_debug(1, "OSP: txjitter '%d'\n", jitter[OSP_DIR_TX].value);
      ast_debug(1, "OSP: reported_minjitter '%f'\n", jitter[OSP_DIR_TX].min);
      ast_debug(1, "OSP: reported_maxjitter '%f'\n", jitter[OSP_DIR_TX].max);
      ast_debug(1, "OSP: reported_avgjitter '%f'\n", jitter[OSP_DIR_TX].avg);
      ast_debug(1, "OSP: reported_stdevjitter '%f'\n", jitter[OSP_DIR_TX].sdev);
      ast_debug(1, "OSP: rtt '%d'\n", rtt.value);
      ast_debug(1, "OSP: minrtt '%f'\n", rtt.min);
      ast_debug(1, "OSP: maxrtt '%f'\n", rtt.max);
      ast_debug(1, "OSP: avgrtt '%f'\n", rtt.avg);
      ast_debug(1, "OSP: stdevrtt '%f'\n", rtt.sdev);

      if (leg == OSP_CALL_INBOUND) {
         OSPPTransactionSetPackets(trans, OSPC_SMETRIC_RTP, OSPC_SDIR_SRCREP, totalpackets[OSP_DIR_RX]);
         OSPPTransactionSetPackets(trans, OSPC_SMETRIC_RTCP, OSPC_SDIR_DESTREP, totalpackets[OSP_DIR_TX]);
         if (lost[OSP_DIR_RX].value >= 0) {
            value = lost[OSP_DIR_RX].value;
         } else {
            value = (int)lost[OSP_DIR_RX].avg;
         }
         OSPPTransactionSetLost(trans, OSPC_SMETRIC_RTP, OSPC_SDIR_SRCREP, value, OSP_DEF_INTSTATS);
         if (lost[OSP_DIR_TX].value >= 0) {
            value = lost[OSP_DIR_TX].value;
         } else {
            value = (int)lost[OSP_DIR_TX].avg;
         }
         OSPPTransactionSetLost(trans, OSPC_SMETRIC_RTCP, OSPC_SDIR_DESTREP, value, OSP_DEF_INTSTATS);
         if (jitter[OSP_DIR_RX].value >= 0) {
            value = jitter[OSP_DIR_RX].value;
         } else {
            value = (int)jitter[OSP_DIR_RX].avg;
         }
         OSPPTransactionSetJitter(trans,
            OSPC_SMETRIC_RTP,
            OSPC_SDIR_SRCREP,
            OSP_DEF_INTSTATS,
            (int)jitter[OSP_DIR_RX].min,
            (int)jitter[OSP_DIR_RX].max,
            value, jitter[OSP_DIR_RX].sdev);
         if (jitter[OSP_DIR_TX].value >= 0) {
            value = jitter[OSP_DIR_TX].value;
         } else {
            value = (int)jitter[OSP_DIR_TX].avg;
         }
         OSPPTransactionSetJitter(trans, OSPC_SMETRIC_RTCP, OSPC_SDIR_DESTREP,
            OSP_DEF_INTSTATS, (int)jitter[OSP_DIR_TX].min, (int)jitter[OSP_DIR_TX].max, value, jitter[OSP_DIR_TX].sdev);
      } else {
         OSPPTransactionSetPackets(trans, OSPC_SMETRIC_RTP, OSPC_SDIR_DESTREP, totalpackets[OSP_DIR_RX]);
         OSPPTransactionSetPackets(trans, OSPC_SMETRIC_RTCP, OSPC_SDIR_SRCREP, totalpackets[OSP_DIR_TX]);
         OSPPTransactionSetLost(trans, OSPC_SMETRIC_RTP, OSPC_SDIR_DESTREP, lost[OSP_DIR_RX].value, OSP_DEF_INTSTATS);
         OSPPTransactionSetLost(trans, OSPC_SMETRIC_RTCP, OSPC_SDIR_SRCREP, lost[OSP_DIR_TX].value, OSP_DEF_INTSTATS);
         if (jitter[OSP_DIR_RX].value >= 0) {
            value = jitter[OSP_DIR_RX].value;
         } else {
            value = (int)jitter[OSP_DIR_RX].avg;
         }
         OSPPTransactionSetJitter(trans,
            OSPC_SMETRIC_RTP,
            OSPC_SDIR_DESTREP,
            OSP_DEF_INTSTATS,
            (int)jitter[OSP_DIR_RX].min,
            (int)jitter[OSP_DIR_RX].max,
            value,
            jitter[OSP_DIR_RX].sdev);
         if (jitter[OSP_DIR_TX].value >= 0) {
            value = jitter[OSP_DIR_TX].value;
         } else {
            value = (int)jitter[OSP_DIR_TX].avg;
         }
         OSPPTransactionSetJitter(trans,
            OSPC_SMETRIC_RTCP,
            OSPC_SDIR_SRCREP,
            OSP_DEF_INTSTATS,
            (int)jitter[OSP_DIR_TX].min,
            (int)jitter[OSP_DIR_TX].max,
            value,
            jitter[OSP_DIR_TX].sdev);
      }

      res = OSP_OK;
   }

   return res;
}

static int osp_unload ( void ) [static]

Definition at line 2925 of file app_osplookup.c.

References ast_free, ast_mutex_lock, ast_mutex_unlock, osp_provider::handle, osp_provider::next, and osp_lock.

Referenced by osp_load(), and unload_module().

{
   struct osp_provider* provider;
   struct osp_provider* next;

   if (osp_initialized) {
      ast_mutex_lock(&osp_lock);
      for (provider = osp_providers; provider; provider = next) {
         next = provider->next;
         OSPPProviderDelete(provider->handle, 0);
         ast_free(provider);
      }
      osp_providers = NULL;
      ast_mutex_unlock(&osp_lock);

      OSPPCleanup();

      osp_tokenformat = TOKEN_ALGO_SIGNED;
      osp_security = 0;
      osp_hardware = 0;
      osp_initialized = 0;
   }

   return 0;
}

static int osp_uuid2str	(	unsigned char *	uuid,
		char *	buffer,
		unsigned int	bufsize
	)		`[static]`

UUID to string.

Parameters:

uuid	UUID
buffer	String buffer
bufsize	String buffer size

Returns:: OSP_OK Successed, OSP_ERROR Error

Definition at line 1420 of file app_osplookup.c.

References ast_log(), LOG_ERROR, OSP_ERROR, OSP_OK, and OSP_SIZE_UUIDSTR.

Referenced by osplookup_exec(), and ospnext_exec().

{
   int res;

   if ((uuid != NULL) && (bufsize > OSP_SIZE_UUIDSTR)) {
      snprintf(buffer, bufsize, "%02x%02x%02x%02x-%02x%02x-%02x%02x-%02x%02x-%02x%02x%02x%02x%02x%02x",
         uuid[0], uuid[1], uuid[2], uuid[3], uuid[4], uuid[5], uuid[6], uuid[7],
         uuid[8], uuid[9], uuid[10], uuid[11], uuid[12], uuid[13], uuid[14], uuid[15]);
      res = OSP_OK;
   } else {
      ast_log(LOG_ERROR, "Invalid parameters\n");
      res = OSP_ERROR;
   }

   return res;
}

static int osp_validate_token	(	int	trans,
		const char *	source,
		const char *	destination,
		const char *	calling,
		const char *	called,
		const char *	token,
		unsigned int *	timelimit
	)		`[static]`

Validate OSP token of inbound call.

Parameters:

trans	OSP transaction handle
source	Source of inbound call
destination	Destination of inbound call
calling	Calling number
called	Called number
token	OSP token, may be empty
timelimit	Call duration limit, output

Returns:: OSP_OK Success, OSP_FAILED Failed, OSP_ERROR Error

Definition at line 1078 of file app_osplookup.c.

References ast_base64decode(), ast_debug, ast_log(), dummy(), LOG_ERROR, LOG_WARNING, osp_convert_inout(), OSP_ERROR, OSP_FAILED, OSP_OK, OSP_SIZE_NORSTR, and OSP_SIZE_TOKSTR.

Referenced by osp_auth().

{
   int res;
   int tokenlen;
   unsigned char tokenstr[OSP_SIZE_TOKSTR];
   char src[OSP_SIZE_NORSTR];
   char dest[OSP_SIZE_NORSTR];
   unsigned int authorised;
   unsigned int dummy = 0;
   int error;

   if (timelimit == NULL) {
      ast_log(LOG_ERROR, "Invalid parameters\n");
      return OSP_ERROR;
   }

   tokenlen = ast_base64decode(tokenstr, token, strlen(token));
   osp_convert_inout(source, src, sizeof(src));
   osp_convert_inout(destination, dest, sizeof(dest));
   error = OSPPTransactionValidateAuthorisation(trans,
      src,
      dest,
      NULL,
      NULL,
      calling ? calling : "",
      OSPC_NFORMAT_E164,
      called,
      OSPC_NFORMAT_E164,
      0,
      NULL,
      tokenlen,
      (char*)tokenstr,
      &authorised,
      timelimit,
      &dummy,
      NULL,
      osp_tokenformat);
   if (error != OSPC_ERR_NO_ERROR) {
      ast_log(LOG_WARNING, "OSP: Unable to validate inbound token, error '%d'\n", error);
      *timelimit = 0;
      res = OSP_ERROR;
   } else if (authorised) {
      ast_debug(1, "OSP: Authorised\n");
      res = OSP_OK;
   } else {
      ast_debug(1, "OSP: Unauthorised\n");
      res = OSP_FAILED;
   }

   return res;
}

static int ospauth_exec	(	struct ast_channel *	chan,
		const char *	data
	)		`[static]`

OSP Application OSPAuth.

Parameters:

chan	Channel
data	Parameter

Returns:: OSP_AST_OK Success, OSP_AST_ERROR Error

Definition at line 2252 of file app_osplookup.c.

References args, AST_APP_ARG, ast_channel_caller(), ast_channel_exten(), ast_channel_varshead(), ast_debug, AST_DECLARE_APP_ARGS, AST_LIST_TRAVERSE, AST_OSP_ERROR, AST_OSP_FAILED, AST_OSP_SUCCESS, AST_STANDARD_APP_ARGS, ast_strlen_zero(), ast_var_name(), ast_var_value(), ast_var_t::entries, OSP_AST_ERROR, OSP_AST_OK, osp_auth(), OSP_DEF_PROVIDER, OSP_DEF_TIMELIMIT, OSP_OK, OSP_SIZE_INTSTR, pbx_builtin_setvar_helper(), S_COR, and status.

Referenced by load_module().

{
   int res;
   const char* provider = OSP_DEF_PROVIDER;
   struct varshead* headp;
   struct ast_var_t* current;
   const char* source = "";
   const char* token = "";
   int handle;
   unsigned int timelimit;
   char buffer[OSP_SIZE_INTSTR];
   const char* status;
   char* tmp;

   AST_DECLARE_APP_ARGS(args,
      AST_APP_ARG(provider);
      AST_APP_ARG(options);
   );

   tmp = ast_strdupa(data);

   AST_STANDARD_APP_ARGS(args, tmp);

   if (!ast_strlen_zero(args.provider)) {
      provider = args.provider;
   }
   ast_debug(1, "OSPAuth: provider '%s'\n", provider);

   headp = ast_channel_varshead(chan);
   AST_LIST_TRAVERSE(headp, current, entries) {
      if (!strcasecmp(ast_var_name(current), "OSPINPEERIP")) {
         source = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINTOKEN")) {
         token = ast_var_value(current);
      }
   }

   ast_debug(1, "OSPAuth: source '%s'\n", source);
   ast_debug(1, "OSPAuth: token size '%zd'\n", strlen(token));

   res = osp_auth(provider, &handle, source,
      S_COR(ast_channel_caller(chan)->id.number.valid, ast_channel_caller(chan)->id.number.str, NULL),
      ast_channel_exten(chan), token, &timelimit);
   if (res > 0) {
      status = AST_OSP_SUCCESS;
   } else {
      timelimit = OSP_DEF_TIMELIMIT;
      if (!res) {
         status = AST_OSP_FAILED;
      } else {
         status = AST_OSP_ERROR;
      }
   }

   snprintf(buffer, sizeof(buffer), "%d", handle);
   pbx_builtin_setvar_helper(chan, "OSPINHANDLE", buffer);
   ast_debug(1, "OSPAuth: OSPINHANDLE '%s'\n", buffer);
   snprintf(buffer, sizeof(buffer), "%d", timelimit);
   pbx_builtin_setvar_helper(chan, "OSPINTIMELIMIT", buffer);
   ast_debug(1, "OSPAuth: OSPINTIMELIMIT '%s'\n", buffer);
   pbx_builtin_setvar_helper(chan, "OSPAUTHSTATUS", status);
   ast_debug(1, "OSPAuth: %s\n", status);

   if(res != OSP_OK) {
      res = OSP_AST_ERROR;
   } else {
      res = OSP_AST_OK;
   }

   return res;
}

static int ospfinished_exec	(	struct ast_channel *	chan,
		const char *	data
	)		`[static]`

OSP Application OSPFinish.

Parameters:

chan	Channel
data	Parameter

Returns:: OSP_AST_OK Success, OSP_AST_ERROR Error

Definition at line 2806 of file app_osplookup.c.

References ast_cdr::answer, args, AST_APP_ARG, AST_CAUSE_NO_ROUTE_DESTINATION, AST_CAUSE_NORMAL_CLEARING, ast_channel_cdr(), ast_channel_varshead(), ast_check_hangup(), ast_copy_string(), ast_debug, AST_DECLARE_APP_ARGS, AST_LIST_TRAVERSE, AST_OSP_ERROR, AST_OSP_FAILED, AST_OSP_SUCCESS, AST_STANDARD_APP_ARGS, ast_strlen_zero(), ast_var_name(), ast_var_value(), ast_var_t::entries, OSP_AST_ERROR, OSP_AST_OK, osp_finish(), OSP_INVALID_HANDLE, OSP_OK, OSP_SIZE_INTSTR, OSP_SIZE_QOSSTR, pbx_builtin_setvar_helper(), ast_cdr::start, and status.

Referenced by load_module().

{
   int res = OSP_OK;
   int cause = 0;
   struct varshead* headp;
   struct ast_var_t* current;
   int inhandle = OSP_INVALID_HANDLE;
   int outhandle = OSP_INVALID_HANDLE;
   int recorded = 0;
   time_t start, connect, end;
   unsigned int release;
   char buffer[OSP_SIZE_INTSTR];
   char inqos[OSP_SIZE_QOSSTR] = { 0 };
   char outqos[OSP_SIZE_QOSSTR] = { 0 };
   const char* status;
   char* tmp;

   AST_DECLARE_APP_ARGS(args,
      AST_APP_ARG(cause);
      AST_APP_ARG(options);
   );

   tmp = ast_strdupa(data);

   AST_STANDARD_APP_ARGS(args, tmp);

   headp = ast_channel_varshead(chan);
   AST_LIST_TRAVERSE(headp, current, entries) {
      if (!strcasecmp(ast_var_name(current), "OSPINHANDLE")) {
         if (sscanf(ast_var_value(current), "%30d", &inhandle) != 1) {
            inhandle = OSP_INVALID_HANDLE;
         }
      } else if (!strcasecmp(ast_var_name(current), "OSPOUTHANDLE")) {
         if (sscanf(ast_var_value(current), "%30d", &outhandle) != 1) {
            outhandle = OSP_INVALID_HANDLE;
         }
      } else if (!recorded &&
         (!strcasecmp(ast_var_name(current), "OSPAUTHSTATUS") ||
         !strcasecmp(ast_var_name(current), "OSPLOOKUPSTATUS") ||
         !strcasecmp(ast_var_name(current), "OSPNEXTSTATUS")))
      {
         if (strcasecmp(ast_var_value(current), AST_OSP_SUCCESS)) {
            recorded = 1;
         }
      } else if (!strcasecmp(ast_var_name(current), "OSPINAUDIOQOS")) {
         ast_copy_string(inqos, ast_var_value(current), sizeof(inqos));
      } else if (!strcasecmp(ast_var_name(current), "OSPOUTAUDIOQOS")) {
         ast_copy_string(outqos, ast_var_value(current), sizeof(outqos));
      }
   }
   ast_debug(1, "OSPFinish: OSPINHANDLE '%d'\n", inhandle);
   ast_debug(1, "OSPFinish: OSPOUTHANDLE '%d'\n", outhandle);
   ast_debug(1, "OSPFinish: recorded '%d'\n", recorded);
   ast_debug(1, "OSPFinish: OSPINAUDIOQOS '%s'\n", inqos);
   ast_debug(1, "OSPFinish: OSPOUTAUDIOQOS '%s'\n", outqos);

   if (!ast_strlen_zero(args.cause) && sscanf(args.cause, "%30d", &cause) != 1) {
      cause = 0;
   }
   ast_debug(1, "OSPFinish: cause '%d'\n", cause);

   if (ast_channel_cdr(chan)) {
      start = ast_channel_cdr(chan)->start.tv_sec;
      connect = ast_channel_cdr(chan)->answer.tv_sec;
      if (connect) {
         end = time(NULL);
      } else {
         end = connect;
      }
   } else {
      start = 0;
      connect = 0;
      end = 0;
   }
   ast_debug(1, "OSPFinish: start '%ld'\n", start);
   ast_debug(1, "OSPFinish: connect '%ld'\n", connect);
   ast_debug(1, "OSPFinish: end '%ld'\n", end);

   release = ast_check_hangup(chan) ? 0 : 1;

   if (osp_finish(outhandle, recorded, cause, start, connect, end, release, inqos, outqos) <= 0) {
      ast_debug(1, "OSPFinish: Unable to report usage for outbound call\n");
   }
   switch (cause) {
   case AST_CAUSE_NORMAL_CLEARING:
      break;
   default:
      cause = AST_CAUSE_NO_ROUTE_DESTINATION;
      break;
   }
   if (osp_finish(inhandle, recorded, cause, start, connect, end, release, inqos, outqos) <= 0) {
      ast_debug(1, "OSPFinish: Unable to report usage for inbound call\n");
   }
   snprintf(buffer, sizeof(buffer), "%d", OSP_INVALID_HANDLE);
   pbx_builtin_setvar_helper(chan, "OSPOUTHANDLE", buffer);
   pbx_builtin_setvar_helper(chan, "OSPINHANDLE", buffer);

   if (res > 0) {
      status = AST_OSP_SUCCESS;
   } else if (!res) {
      status = AST_OSP_FAILED;
   } else {
      status = AST_OSP_ERROR;
   }
   pbx_builtin_setvar_helper(chan, "OSPFINISHSTATUS", status);

   if(res != OSP_OK) {
      res = OSP_AST_ERROR;
   } else {
      res = OSP_AST_OK;
   }

   return res;
}

static int osplookup_exec	(	struct ast_channel *	chan,
		const char *	data
	)		`[static]`

OSP Application OSPLookup.

Parameters:

chan	Channel
data	Parameter

Returns:: OSP_AST_OK Success, OSP_AST_ERROR Error

Definition at line 2332 of file app_osplookup.c.

References args, AST_APP_ARG, ast_autoservice_start(), ast_autoservice_stop(), ast_channel_caller(), ast_channel_varshead(), ast_copy_string(), ast_debug, AST_DECLARE_APP_ARGS, AST_LIST_TRAVERSE, ast_log(), AST_OSP_ERROR, AST_OSP_FAILED, AST_OSP_SUCCESS, AST_STANDARD_APP_ARGS, ast_strlen_zero(), ast_true(), ast_var_name(), ast_var_value(), osp_callid::buf, osp_results::called, osp_results::calling, osp_npdata::cic, osp_results::dest, osp_headers::divhost, osp_headers::divuser, exten, osp_results::inhandle, osp_results::intech, osp_results::intimelimit, osp_callid::len, LOG_WARNING, osp_results::networkid, osp_results::npcic, osp_npdata::npdi, osp_results::npdi, osp_results::nprn, osp_results::numdests, osp_npdata::opname, osp_results::opname, OSP_AST_ERROR, OSP_AST_OK, OSP_CALLID_H323, OSP_CALLID_IAX, OSP_CALLID_SIP, OSP_CALLID_UNDEF, OSP_DEF_PROVIDER, OSP_DEF_TIMELIMIT, OSP_INVALID_HANDLE, osp_lookup(), OSP_MAX_CUSTOMINFO, OSP_OK, OSP_SIP_HEADER, OSP_SIZE_TOKSTR, OSP_TECH_H323, OSP_TECH_IAX, OSP_TECH_SIP, OSP_TECH_SKYPE, osp_uuid2str(), osp_results::outcallid, osp_results::outhandle, osp_results::outtech, osp_results::outtimelimit, osp_headers::paiuser, pbx_builtin_setvar_helper(), osp_headers::pciuser, osp_npdata::rn, osp_headers::rpiduser, S_COR, status, osp_results::token, and type.

Referenced by load_module().

{
   int res;
   const char* provider = OSP_DEF_PROVIDER;
   unsigned int callidtypes = OSP_CALLID_UNDEF;
   struct varshead* headp;
   struct ast_var_t* current;
   const char* actualsrc = "";
   const char* srcdev = "";
   const char* snetid = "";
   struct osp_npdata np;
   OSPE_OPERATOR_NAME type;
   struct osp_headers headers;
   unsigned int i;
   const char* cinfo[OSP_MAX_CUSTOMINFO] = { NULL };
   char buffer[OSP_SIZE_TOKSTR];
   struct osp_results results;
   const char* status;
   char* tmp;

   AST_DECLARE_APP_ARGS(args,
      AST_APP_ARG(exten);
      AST_APP_ARG(provider);
      AST_APP_ARG(options);
   );

   if (ast_strlen_zero(data)) {
      ast_log(LOG_WARNING, "OSPLookup: Arg required, OSPLookup(exten[,provider[,options]])\n");
      return OSP_AST_ERROR;
   }

   tmp = ast_strdupa(data);

   AST_STANDARD_APP_ARGS(args, tmp);

   ast_debug(1, "OSPLookup: exten '%s'\n", args.exten);

   if (!ast_strlen_zero(args.provider)) {
      provider = args.provider;
   }
   ast_debug(1, "OSPlookup: provider '%s'\n", provider);

   if (args.options) {
      if (strchr(args.options, 'h')) {
         callidtypes |= OSP_CALLID_H323;
      }
      if (strchr(args.options, 's')) {
         callidtypes |= OSP_CALLID_SIP;
      }
      if (strchr(args.options, 'i')) {
         callidtypes |= OSP_CALLID_IAX;
      }
   }
   ast_debug(1, "OSPLookup: call id types '%d'\n", callidtypes);

   results.inhandle = OSP_INVALID_HANDLE;
   results.intimelimit = OSP_DEF_TIMELIMIT;
   results.dest[0] = '\0';

   np.rn = "";
   np.cic = "";
   np.npdi = 0;
   for (type = OSPC_OPNAME_START; type < OSPC_OPNAME_NUMBER; type++) {
      np.opname[type] = "";
   }

   headers.rpiduser = "";
   headers.paiuser = "";
   headers.divuser = "";
   headers.divhost = "";
   headers.pciuser = "";

   headp = ast_channel_varshead(chan);
   AST_LIST_TRAVERSE(headp, current, entries) {
      if (!strcasecmp(ast_var_name(current), "OSPINACTUALSRC")) {
         actualsrc = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINPEERIP")) {
         srcdev = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINTECH")) {
         ast_copy_string(results.intech, ast_var_value(current), sizeof(results.intech));
      } else if (!strcasecmp(ast_var_name(current), "OSPINHANDLE")) {
         if (sscanf(ast_var_value(current), "%30d", &results.inhandle) != 1) {
            results.inhandle = OSP_INVALID_HANDLE;
         }
      } else if (!strcasecmp(ast_var_name(current), "OSPINTIMELIMIT")) {
         if (sscanf(ast_var_value(current), "%30d", &results.intimelimit) != 1) {
            results.intimelimit = OSP_DEF_TIMELIMIT;
         }
      } else if (!strcasecmp(ast_var_name(current), "OSPINNETWORKID")) {
         snetid = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINNPRN")) {
         np.rn = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINNPCIC")) {
         np.cic = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINNPDI")) {
         if (ast_true(ast_var_value(current))) {
            np.npdi = 1;
         }
      } else if (!strcasecmp(ast_var_name(current), "OSPINSPID")) {
         np.opname[OSPC_OPNAME_SPID] = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINOCN")) {
         np.opname[OSPC_OPNAME_OCN] = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINSPN")) {
         np.opname[OSPC_OPNAME_SPN] = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINALTSPN")) {
         np.opname[OSPC_OPNAME_ALTSPN] = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINMCC")) {
         np.opname[OSPC_OPNAME_MCC] = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINMNC")) {
         np.opname[OSPC_OPNAME_MNC] = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINTOHOST")) {
         ast_copy_string(results.dest, ast_var_value(current), sizeof(results.dest));
      } else if (!strcasecmp(ast_var_name(current), "OSPINRPIDUSER")) {
         headers.rpiduser = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINPAIUSER")) {
         headers.paiuser = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINDIVUSER")) {
         headers.divuser = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINDIVHOST")) {
         headers.divhost = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINPCIUSER")) {
         headers.pciuser = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINCUSTOMINFO1")) {
         cinfo[0] = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINCUSTOMINFO2")) {
         cinfo[1] = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINCUSTOMINFO3")) {
         cinfo[2] = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINCUSTOMINFO4")) {
         cinfo[3] = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINCUSTOMINFO5")) {
         cinfo[4] = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINCUSTOMINFO6")) {
         cinfo[5] = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINCUSTOMINFO7")) {
         cinfo[6] = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINCUSTOMINFO8")) {
         cinfo[7] = ast_var_value(current);
      }
   }
   ast_debug(1, "OSPLookup: actual source device '%s'\n", actualsrc);
   ast_debug(1, "OSPLookup: source device '%s'\n", srcdev);
   ast_debug(1, "OSPLookup: OSPINTECH '%s'\n", results.intech);
   ast_debug(1, "OSPLookup: OSPINHANDLE '%d'\n", results.inhandle);
   ast_debug(1, "OSPLookup: OSPINTIMELIMIT '%d'\n", results.intimelimit);
   ast_debug(1, "OSPLookup: OSPINNETWORKID '%s'\n", snetid);
   ast_debug(1, "OSPLookup: OSPINNPRN '%s'\n", np.rn);
   ast_debug(1, "OSPLookup: OSPINNPCIC '%s'\n", np.cic);
   ast_debug(1, "OSPLookup: OSPINNPDI '%d'\n", np.npdi);
   ast_debug(1, "OSPLookup: OSPINSPID '%s'\n", np.opname[OSPC_OPNAME_SPID]);
   ast_debug(1, "OSPLookup: OSPINOCN '%s'\n", np.opname[OSPC_OPNAME_OCN]);
   ast_debug(1, "OSPLookup: OSPINSPN '%s'\n", np.opname[OSPC_OPNAME_SPN]);
   ast_debug(1, "OSPLookup: OSPINALTSPN '%s'\n", np.opname[OSPC_OPNAME_ALTSPN]);
   ast_debug(1, "OSPLookup: OSPINMCC '%s'\n", np.opname[OSPC_OPNAME_MCC]);
   ast_debug(1, "OSPLookup: OSPINMNC '%s'\n", np.opname[OSPC_OPNAME_MNC]);
   ast_debug(1, "OSPLookup: OSPINTOHOST '%s'\n", results.dest);
   ast_debug(1, "OSPLookup: OSPINRPIDUSER '%s'\n", headers.rpiduser);
   ast_debug(1, "OSPLookup: OSPINPAIUSER '%s'\n", headers.paiuser);
   ast_debug(1, "OSPLookup: OSPINDIVUSER '%s'\n", headers.divuser);
   ast_debug(1, "OSPLookup: OSPINDIVHOST'%s'\n", headers.divhost);
   ast_debug(1, "OSPLookup: OSPINPCIUSER '%s'\n", headers.pciuser);
   for (i = 0; i < OSP_MAX_CUSTOMINFO; i++) {
      if (!ast_strlen_zero(cinfo[i])) {
         ast_debug(1, "OSPLookup: OSPINCUSTOMINFO%d '%s'\n", i, cinfo[i]);
      }
   }

   if (ast_autoservice_start(chan) < 0) {
      return OSP_AST_ERROR;
   }

   res = osp_lookup(provider, callidtypes, actualsrc, srcdev,
      S_COR(ast_channel_caller(chan)->id.number.valid, ast_channel_caller(chan)->id.number.str, NULL),
      args.exten, snetid, &np, &headers, cinfo, &results);
   if (res > 0) {
      status = AST_OSP_SUCCESS;
   } else {
      results.outtech[0] = '\0';
      results.dest[0] = '\0';
      results.calling[0] = '\0';
      results.called[0] = '\0';
      results.token[0] = '\0';
      results.networkid[0] = '\0';
      results.nprn[0] = '\0';
      results.npcic[0] = '\0';
      results.npdi = 0;
      for (type = OSPC_OPNAME_START; type < OSPC_OPNAME_NUMBER; type++) {
         results.opname[type][0] = '\0';
      }
      results.numdests = 0;
      results.outtimelimit = OSP_DEF_TIMELIMIT;
      results.outcallid.buf[0] = '\0';
      results.outcallid.len = 0;
      if (!res) {
         status = AST_OSP_FAILED;
      } else {
         status = AST_OSP_ERROR;
      }
   }

   snprintf(buffer, sizeof(buffer), "%d", results.outhandle);
   pbx_builtin_setvar_helper(chan, "OSPOUTHANDLE", buffer);
   ast_debug(1, "OSPLookup: OSPOUTHANDLE '%s'\n", buffer);
   pbx_builtin_setvar_helper(chan, "OSPOUTTECH", results.outtech);
   ast_debug(1, "OSPLookup: OSPOUTTECH '%s'\n", results.outtech);
   pbx_builtin_setvar_helper(chan, "OSPDESTINATION", results.dest);
   ast_debug(1, "OSPLookup: OSPDESTINATION '%s'\n", results.dest);
   pbx_builtin_setvar_helper(chan, "OSPOUTCALLING", results.calling);
   ast_debug(1, "OSPLookup: OSPOUTCALLING '%s'\n", results.calling);
   pbx_builtin_setvar_helper(chan, "OSPOUTCALLED", results.called);
   ast_debug(1, "OSPLookup: OSPOUTCALLED '%s'\n", results.called);
   pbx_builtin_setvar_helper(chan, "OSPOUTNETWORKID", results.networkid);
   ast_debug(1, "OSPLookup: OSPOUTNETWORKID '%s'\n", results.networkid);
   pbx_builtin_setvar_helper(chan, "OSPOUTNPRN", results.nprn);
   ast_debug(1, "OSPLookup: OSPOUTNPRN '%s'\n", results.nprn);
   pbx_builtin_setvar_helper(chan, "OSPOUTNPCIC", results.npcic);
   ast_debug(1, "OSPLookup: OSPOUTNPCIC '%s'\n", results.npcic);
   snprintf(buffer, sizeof(buffer), "%d", results.npdi);
   pbx_builtin_setvar_helper(chan, "OSPOUTNPDI", buffer);
   ast_debug(1, "OSPLookup: OSPOUTNPDI'%s'\n", buffer);
   pbx_builtin_setvar_helper(chan, "OSPOUTSPID", results.opname[OSPC_OPNAME_SPID]);
   ast_debug(1, "OSPLookup: OSPOUTSPID '%s'\n", results.opname[OSPC_OPNAME_SPID]);
   pbx_builtin_setvar_helper(chan, "OSPOUTOCN", results.opname[OSPC_OPNAME_OCN]);
   ast_debug(1, "OSPLookup: OSPOUTOCN '%s'\n", results.opname[OSPC_OPNAME_OCN]);
   pbx_builtin_setvar_helper(chan, "OSPOUTSPN", results.opname[OSPC_OPNAME_SPN]);
   ast_debug(1, "OSPLookup: OSPOUTSPN '%s'\n", results.opname[OSPC_OPNAME_SPN]);
   pbx_builtin_setvar_helper(chan, "OSPOUTALTSPN", results.opname[OSPC_OPNAME_ALTSPN]);
   ast_debug(1, "OSPLookup: OSPOUTALTSPN '%s'\n", results.opname[OSPC_OPNAME_ALTSPN]);
   pbx_builtin_setvar_helper(chan, "OSPOUTMCC", results.opname[OSPC_OPNAME_MCC]);
   ast_debug(1, "OSPLookup: OSPOUTMCC '%s'\n", results.opname[OSPC_OPNAME_MCC]);
   pbx_builtin_setvar_helper(chan, "OSPOUTMNC", results.opname[OSPC_OPNAME_MNC]);
   ast_debug(1, "OSPLookup: OSPOUTMNC '%s'\n", results.opname[OSPC_OPNAME_MNC]);
   pbx_builtin_setvar_helper(chan, "OSPOUTTOKEN", results.token);
   ast_debug(1, "OSPLookup: OSPOUTTOKEN size '%zd'\n", strlen(results.token));
   snprintf(buffer, sizeof(buffer), "%d", results.numdests);
   pbx_builtin_setvar_helper(chan, "OSPDESTREMAILS", buffer);
   ast_debug(1, "OSPLookup: OSPDESTREMAILS '%s'\n", buffer);
   snprintf(buffer, sizeof(buffer), "%d", results.outtimelimit);
   pbx_builtin_setvar_helper(chan, "OSPOUTTIMELIMIT", buffer);
   ast_debug(1, "OSPLookup: OSPOUTTIMELIMIT '%s'\n", buffer);
   snprintf(buffer, sizeof(buffer), "%d", callidtypes);
   pbx_builtin_setvar_helper(chan, "OSPOUTCALLIDTYPES", buffer);
   ast_debug(1, "OSPLookup: OSPOUTCALLIDTYPES '%s'\n", buffer);
   pbx_builtin_setvar_helper(chan, "OSPLOOKUPSTATUS", status);
   ast_debug(1, "OSPLookup: %s\n", status);

   if (!strcasecmp(results.outtech, OSP_TECH_SIP)) {
      snprintf(buffer, sizeof(buffer), "%s/%s@%s", results.outtech, results.called, results.dest);
      pbx_builtin_setvar_helper(chan, "OSPDIALSTR", buffer);
      if (!ast_strlen_zero(results.token)) {
         snprintf(buffer, sizeof(buffer), "%s: %s", OSP_SIP_HEADER, results.token);
         pbx_builtin_setvar_helper(chan, "_SIPADDHEADER", buffer);
         ast_debug(1, "OSPLookup: SIPADDHEADER size '%zd'\n", strlen(buffer));
      }
   } else if (!strcasecmp(results.outtech, OSP_TECH_H323)) {
      if ((callidtypes & OSP_CALLID_H323) && (results.outcallid.len != 0)) {
         osp_uuid2str(results.outcallid.buf, buffer, sizeof(buffer));
      } else {
         buffer[0] = '\0';
      }
      pbx_builtin_setvar_helper(chan, "OSPOUTCALLID", buffer);
      snprintf(buffer, sizeof(buffer), "%s/%s@%s", results.outtech, results.called, results.dest);
      pbx_builtin_setvar_helper(chan, "OSPDIALSTR", buffer);
   } else if (!strcasecmp(results.outtech, OSP_TECH_IAX)) {
      snprintf(buffer, sizeof(buffer), "%s/%s/%s", results.outtech, results.dest, results.called);
      pbx_builtin_setvar_helper(chan, "OSPDIALSTR", buffer);
   } else if (!strcasecmp(results.outtech, OSP_TECH_SKYPE)) {
      snprintf(buffer, sizeof(buffer), "%s/%s", results.outtech, results.called);
      pbx_builtin_setvar_helper(chan, "OSPDIALSTR", buffer);
   }

   if (ast_autoservice_stop(chan) < 0) {
      return OSP_AST_ERROR;
   }

   if(res != OSP_OK) {
      res = OSP_AST_ERROR;
   } else {
      res = OSP_AST_OK;
   }

   return res;
}

static int ospnext_exec	(	struct ast_channel *	chan,
		const char *	data
	)		`[static]`

OSP Application OSPNext.

Parameters:

chan	Channel
data	Parameter

Returns:: OSP_AST_OK Success, OSP_AST_ERROR Error

Definition at line 2624 of file app_osplookup.c.

References args, AST_APP_ARG, ast_channel_varshead(), ast_debug, AST_DECLARE_APP_ARGS, AST_LIST_TRAVERSE, ast_log(), AST_OSP_ERROR, AST_OSP_FAILED, AST_OSP_SUCCESS, AST_STANDARD_APP_ARGS, ast_strlen_zero(), ast_var_name(), ast_var_value(), osp_callid::buf, osp_results::called, osp_results::calling, osp_results::dest, osp_results::inhandle, osp_results::intimelimit, osp_callid::len, LOG_WARNING, osp_results::networkid, osp_results::npcic, osp_results::npdi, osp_results::nprn, osp_results::numdests, osp_results::opname, OSP_AST_ERROR, OSP_AST_OK, OSP_CALLID_H323, OSP_CALLID_UNDEF, OSP_DEF_PROVIDER, OSP_DEF_TIMELIMIT, OSP_INVALID_HANDLE, osp_next(), OSP_OK, OSP_SIP_HEADER, OSP_SIZE_TOKSTR, OSP_TECH_H323, OSP_TECH_IAX, OSP_TECH_SIP, OSP_TECH_SKYPE, osp_uuid2str(), osp_results::outcallid, osp_results::outhandle, osp_results::outtech, osp_results::outtimelimit, pbx_builtin_setvar_helper(), status, osp_results::token, and type.

Referenced by load_module().

{
   int res;
   const char* provider = OSP_DEF_PROVIDER;
   int cause = 0;
   struct varshead* headp;
   struct ast_var_t* current;
   struct osp_results results;
   OSPE_OPERATOR_NAME type;
   char buffer[OSP_SIZE_TOKSTR];
   unsigned int callidtypes = OSP_CALLID_UNDEF;
   const char* status;
   char* tmp;

   AST_DECLARE_APP_ARGS(args,
      AST_APP_ARG(cause);
      AST_APP_ARG(provider);
      AST_APP_ARG(options);
   );

   if (ast_strlen_zero(data)) {
      ast_log(LOG_WARNING, "OSPNext: Arg required, OSPNext(cause[,provider[,options]])\n");
      return OSP_AST_ERROR;
   }

   tmp = ast_strdupa(data);

   AST_STANDARD_APP_ARGS(args, tmp);

   if (!ast_strlen_zero(args.cause) && sscanf(args.cause, "%30d", &cause) != 1) {
      cause = 0;
   }
   ast_debug(1, "OSPNext: cause '%d'\n", cause);

   if (!ast_strlen_zero(args.provider)) {
      provider = args.provider;
   }
   ast_debug(1, "OSPlookup: provider '%s'\n", provider);

   results.inhandle = OSP_INVALID_HANDLE;
   results.outhandle = OSP_INVALID_HANDLE;
   results.intimelimit = OSP_DEF_TIMELIMIT;
   results.numdests = 0;

   headp = ast_channel_varshead(chan);
   AST_LIST_TRAVERSE(headp, current, entries) {
      if (!strcasecmp(ast_var_name(current), "OSPINHANDLE")) {
         if (sscanf(ast_var_value(current), "%30d", &results.inhandle) != 1) {
            results.inhandle = OSP_INVALID_HANDLE;
         }
      } else if (!strcasecmp(ast_var_name(current), "OSPOUTHANDLE")) {
         if (sscanf(ast_var_value(current), "%30d", &results.outhandle) != 1) {
            results.outhandle = OSP_INVALID_HANDLE;
         }
      } else if (!strcasecmp(ast_var_name(current), "OSPINTIMELIMIT")) {
         if (sscanf(ast_var_value(current), "%30d", &results.intimelimit) != 1) {
            results.intimelimit = OSP_DEF_TIMELIMIT;
         }
      } else if (!strcasecmp(ast_var_name(current), "OSPOUTCALLIDTYPES")) {
         if (sscanf(ast_var_value(current), "%30d", &callidtypes) != 1) {
            callidtypes = OSP_CALLID_UNDEF;
         }
      } else if (!strcasecmp(ast_var_name(current), "OSPDESTREMAILS")) {
         if (sscanf(ast_var_value(current), "%30d", &results.numdests) != 1) {
            results.numdests = 0;
         }
      }
   }
   ast_debug(1, "OSPNext: OSPINHANDLE '%d'\n", results.inhandle);
   ast_debug(1, "OSPNext: OSPOUTHANDLE '%d'\n", results.outhandle);
   ast_debug(1, "OSPNext: OSPINTIMELIMIT '%d'\n", results.intimelimit);
   ast_debug(1, "OSPNext: OSPOUTCALLIDTYPES '%d'\n", callidtypes);
   ast_debug(1, "OSPNext: OSPDESTREMAILS '%d'\n", results.numdests);

   if ((res = osp_next(provider, cause, &results)) > 0) {
      status = AST_OSP_SUCCESS;
   } else {
      results.outtech[0] = '\0';
      results.dest[0] = '\0';
      results.calling[0] = '\0';
      results.called[0] = '\0';
      results.token[0] = '\0';
      results.networkid[0] = '\0';
      results.nprn[0] = '\0';
      results.npcic[0] = '\0';
      results.npdi = 0;
      for (type = OSPC_OPNAME_START; type < OSPC_OPNAME_NUMBER; type++) {
         results.opname[type][0] = '\0';
      }
      results.numdests = 0;
      results.outtimelimit = OSP_DEF_TIMELIMIT;
      results.outcallid.buf[0] = '\0';
      results.outcallid.len = 0;
      if (!res) {
         status = AST_OSP_FAILED;
      } else {
         status = AST_OSP_ERROR;
      }
   }

   pbx_builtin_setvar_helper(chan, "OSPOUTTECH", results.outtech);
   ast_debug(1, "OSPNext: OSPOUTTECH '%s'\n", results.outtech);
   pbx_builtin_setvar_helper(chan, "OSPDESTINATION", results.dest);
   ast_debug(1, "OSPNext: OSPDESTINATION '%s'\n", results.dest);
   pbx_builtin_setvar_helper(chan, "OSPOUTCALLING", results.calling);
   ast_debug(1, "OSPNext: OSPOUTCALLING '%s'\n", results.calling);
   pbx_builtin_setvar_helper(chan, "OSPOUTCALLED", results.called);
   ast_debug(1, "OSPNext: OSPOUTCALLED'%s'\n", results.called);
   pbx_builtin_setvar_helper(chan, "OSPOUTNETWORKID", results.networkid);
   ast_debug(1, "OSPLookup: OSPOUTNETWORKID '%s'\n", results.networkid);
   pbx_builtin_setvar_helper(chan, "OSPOUTNPRN", results.nprn);
   ast_debug(1, "OSPLookup: OSPOUTNPRN '%s'\n", results.nprn);
   pbx_builtin_setvar_helper(chan, "OSPOUTNPCIC", results.npcic);
   ast_debug(1, "OSPLookup: OSPOUTNPCIC '%s'\n", results.npcic);
   snprintf(buffer, sizeof(buffer), "%d", results.npdi);
   pbx_builtin_setvar_helper(chan, "OSPOUTNPDI", buffer);
   ast_debug(1, "OSPLookup: OSPOUTNPDI'%s'\n", buffer);
   pbx_builtin_setvar_helper(chan, "OSPOUTSPID", results.opname[OSPC_OPNAME_SPID]);
   ast_debug(1, "OSPLookup: OSPOUTSPID '%s'\n", results.opname[OSPC_OPNAME_SPID]);
   pbx_builtin_setvar_helper(chan, "OSPOUTOCN", results.opname[OSPC_OPNAME_OCN]);
   ast_debug(1, "OSPLookup: OSPOUTOCN '%s'\n", results.opname[OSPC_OPNAME_OCN]);
   pbx_builtin_setvar_helper(chan, "OSPOUTSPN", results.opname[OSPC_OPNAME_SPN]);
   ast_debug(1, "OSPLookup: OSPOUTSPN '%s'\n", results.opname[OSPC_OPNAME_SPN]);
   pbx_builtin_setvar_helper(chan, "OSPOUTALTSPN", results.opname[OSPC_OPNAME_ALTSPN]);
   ast_debug(1, "OSPLookup: OSPOUTALTSPN '%s'\n", results.opname[OSPC_OPNAME_ALTSPN]);
   pbx_builtin_setvar_helper(chan, "OSPOUTMCC", results.opname[OSPC_OPNAME_MCC]);
   ast_debug(1, "OSPLookup: OSPOUTMCC '%s'\n", results.opname[OSPC_OPNAME_MCC]);
   pbx_builtin_setvar_helper(chan, "OSPOUTMNC", results.opname[OSPC_OPNAME_MNC]);
   ast_debug(1, "OSPLookup: OSPOUTMNC '%s'\n", results.opname[OSPC_OPNAME_MNC]);
   pbx_builtin_setvar_helper(chan, "OSPOUTTOKEN", results.token);
   ast_debug(1, "OSPNext: OSPOUTTOKEN size '%zd'\n", strlen(results.token));
   snprintf(buffer, sizeof(buffer), "%d", results.numdests);
   pbx_builtin_setvar_helper(chan, "OSPDESTREMAILS", buffer);
   ast_debug(1, "OSPNext: OSPDESTREMAILS '%s'\n", buffer);
   snprintf(buffer, sizeof(buffer), "%d", results.outtimelimit);
   pbx_builtin_setvar_helper(chan, "OSPOUTTIMELIMIT", buffer);
   ast_debug(1, "OSPNext: OSPOUTTIMELIMIT '%s'\n", buffer);
   pbx_builtin_setvar_helper(chan, "OSPNEXTSTATUS", status);
   ast_debug(1, "OSPNext: %s\n", status);

   if (!strcasecmp(results.outtech, OSP_TECH_SIP)) {
      snprintf(buffer, sizeof(buffer), "%s/%s@%s", results.outtech, results.called, results.dest);
      pbx_builtin_setvar_helper(chan, "OSPDIALSTR", buffer);
      if (!ast_strlen_zero(results.token)) {
         snprintf(buffer, sizeof(buffer), "%s: %s", OSP_SIP_HEADER, results.token);
         pbx_builtin_setvar_helper(chan, "_SIPADDHEADER", buffer);
         ast_debug(1, "OSPLookup: SIPADDHEADER size '%zd'\n", strlen(buffer));
      }
   } else if (!strcasecmp(results.outtech, OSP_TECH_H323)) {
      if ((callidtypes & OSP_CALLID_H323) && (results.outcallid.len != 0)) {
         osp_uuid2str(results.outcallid.buf, buffer, sizeof(buffer));
      } else {
         buffer[0] = '\0';
      }
      pbx_builtin_setvar_helper(chan, "OSPOUTCALLID", buffer);
      snprintf(buffer, sizeof(buffer), "%s/%s@%s", results.outtech, results.called, results.dest);
      pbx_builtin_setvar_helper(chan, "OSPDIALSTR", buffer);
   } else if (!strcasecmp(results.outtech, OSP_TECH_IAX)) {
      snprintf(buffer, sizeof(buffer), "%s/%s/%s", results.outtech, results.dest, results.called);
      pbx_builtin_setvar_helper(chan, "OSPDIALSTR", buffer);
   } else if (!strcasecmp(results.outtech, OSP_TECH_SKYPE)) {
      snprintf(buffer, sizeof(buffer), "%s/%s", results.outtech, results.called);
      pbx_builtin_setvar_helper(chan, "OSPDIALSTR", buffer);
   }

   if(res != OSP_OK) {
      res = OSP_AST_ERROR;
   } else {
      res = OSP_AST_OK;
   }

   return res;
}

static int reload ( void ) [static]

Definition at line 3154 of file app_osplookup.c.

References osp_load().

{
   osp_load(1);

   return 0;
}

static int unload_module ( void ) [static]

Definition at line 3140 of file app_osplookup.c.

References ast_cli_unregister_multiple(), ast_unregister_application(), and osp_unload().

{
   int res;

   res = ast_unregister_application(app4);
   res |= ast_unregister_application(app3);
   res |= ast_unregister_application(app2);
   res |= ast_unregister_application(app1);
   ast_cli_unregister_multiple(cli_osp, sizeof(cli_osp) / sizeof(struct ast_cli_entry));
   osp_unload();

   return res;
}

Variable Documentation

struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_DEFAULT , .description = "Open Settlement Protocol Applications" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = AST_BUILDOPT_SUM, .load = load_module, .unload = unload_module, .reload = reload, } [static]

Definition at line 3165 of file app_osplookup.c.

const char app1[] = "OSPAuth" [static]

Definition at line 3109 of file app_osplookup.c.

Referenced by app_cmp().

const char app2[] = "OSPLookup" [static]

Definition at line 3112 of file app_osplookup.c.

const char app3[] = "OSPNext" [static]

Definition at line 3115 of file app_osplookup.c.

const char app4[] = "OSPFinish" [static]

Definition at line 3118 of file app_osplookup.c.

struct ast_module_info* ast_module_info = &__mod_info [static]

Definition at line 3165 of file app_osplookup.c.

const char* B64CACert = "MIIBYDCCAQoCAQEwDQYJKoZIhvcNAQEEBQAwOzElMCMGA1UEAxMcb3NwdGVzdHNlcnZlci50cmFuc25leHVzLmNvbTESMBAGA1UEChMJT1NQU2VydmVyMB4XDTAyMDIwNDE4MjU1MloXDTEyMDIwMzE4MjU1MlowOzElMCMGA1UEAxMcb3NwdGVzdHNlcnZlci50cmFuc25leHVzLmNvbTESMBAGA1UEChMJT1NQU2VydmVyMFwwDQYJKoZIhvcNAQEBBQADSwAwSAJBAPGeGwV41EIhX0jEDFLRXQhDEr50OUQPq+f55VwQd0TQNts06BP29+UiNdRW3c3IRHdZcJdC1Cg68ME9cgeq0h8CAwEAATANBgkqhkiG9w0BAQQFAANBAGkzBSj1EnnmUxbaiG1N4xjIuLAWydun7o3bFk2tV8dBIhnuh445obYyk1EnQ27kI7eACCILBZqi2MHDOIMnoN0="

Definition at line 631 of file app_osplookup.c.

const char* B64LCert = "MIIBeTCCASMCEHqkOHVRRWr+1COq3CR/xsowDQYJKoZIhvcNAQEEBQAwOzElMCMGA1UEAxMcb3NwdGVzdHNlcnZlci50cmFuc25leHVzLmNvbTESMBAGA1UEChMJT1NQU2VydmVyMB4XDTA1MDYyMzAwMjkxOFoXDTA2MDYyNDAwMjkxOFowRTELMAkGA1UEBhMCQVUxEzARBgNVBAgTClNvbWUtU3RhdGUxITAfBgNVBAoTGEludGVybmV0IFdpZGdpdHMgUHR5IEx0ZDBcMA0GCSqGSIb3DQEBAQUAA0sAMEgCQQCvLeZfj1G0wuJb8JTcVeZaZftncEmRluOnaME3ustd918lRMDYokZmtmDZN8SrP0yd1pfVqZ7NkmBACbBX0k7pAgMBAAEwDQYJKoZIhvcNAQEEBQADQQDnV8QNFVVJx/+7IselU0wsepqMurivXZzuxOmTEmTVDzCJx1xhA8jd3vGAj7XDIYiPub1PV23eY5a2ARJuw5w9"

Definition at line 630 of file app_osplookup.c.

const char* B64PKey = "MIIBOgIBAAJBAK8t5l+PUbTC4lvwlNxV5lpl+2dwSZGW46dowTe6y133XyVEwNiiRma2YNk3xKs/TJ3Wl9Wpns2SYEAJsFfSTukCAwEAAQJAPz13vCm2GmZ8Zyp74usTxLCqSJZNyMRLHQWBM0g44Iuy4wE3vpi7Wq+xYuSOH2mu4OddnxswCP4QhaXVQavTAQIhAOBVCKXtppEw9UaOBL4vW0Ed/6EA/1D8hDW6St0h7EXJAiEAx+iRmZKhJD6VT84dtX5ZYNVk3j3dAcIOovpzUj9a0CECIEduTCapmZQ5xqAEsLXuVlxRtQgLTUD4ZxDElPn8x0MhAiBE2HlcND0+qDbvtwJQQOUzDgqg5xk3w8capboVdzAlQQIhAMC+lDL7+gDYkNAft5Mu+NObJmQs4Cr+DkDFsKqoxqrm"

Definition at line 629 of file app_osplookup.c.

struct ast_cli_entry cli_osp[] [static]

Initial value:

 {
   AST_CLI_DEFINE(handle_cli_osp_show, "Displays OSF information")
}

Definition at line 3120 of file app_osplookup.c.

int osp_hardware = 0 [static]

Definition at line 623 of file app_osplookup.c.

int osp_initialized = 0 [static]

Definition at line 622 of file app_osplookup.c.

ast_mutex_t osp_lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, 1 } [static]

Definition at line 621 of file app_osplookup.c.

Referenced by handle_cli_osp_show(), osp_create_provider(), osp_create_transaction(), osp_get_provider(), and osp_unload().

struct osp_provider* osp_providers = NULL [static]

Definition at line 625 of file app_osplookup.c.

Referenced by osp_create_provider().

int osp_security = 0 [static]

Definition at line 624 of file app_osplookup.c.

unsigned int osp_tokenformat = TOKEN_ALGO_SIGNED [static]

Definition at line 626 of file app_osplookup.c.

Asterisk developer's documentation

Data Structures

Defines

Enumerations

Functions

Variables

Detailed Description

Define Documentation

Enumeration Type Documentation

Function Documentation

Variable Documentation