app_osplookup.c File Reference

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 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

Macros
#define	AST_OSP_ERROR   ((char*)"ERROR") /* Return status, error */
#define	AST_OSP_FAILED   ((char*)"FAILED") /* Return status, failed */
#define	AST_OSP_SUCCESS   ((char*)"SUCCESS") /* Return status, success */
#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_OUTSTR   ((unsigned int)288) /* OSP out size for osp_convert_inout */
#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)
struct ast_module *	AST_MODULE_SELF_SYM (void)
static OSPEFAILREASON	asterisk2osp (int cause)
	Convert Asterisk status to TC code. More...
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. More...
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. More...
static unsigned int	osp_choose_timelimit (unsigned int in, unsigned int out)
	Choose min duration limit. More...
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. More...
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. More...
static int	osp_create_callid (unsigned int type, struct osp_callid *callid)
	Create a call ID according to the type. More...
static int	osp_create_provider (struct ast_config *cfg, const char *name)
	Create OSP provider handle according to configuration. More...
static int	osp_create_transaction (const char *name, int *trans, char *source, unsigned int srcsize)
	Create OSP transaction handle. More...
static int	osp_create_uuid (unsigned char *uuid, unsigned int *bufsize)
	Create a UUID. More...
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. More...
static int	osp_get_provider (const char *name, struct osp_provider **provider)
	Get OSP provider by name. More...
static float	osp_get_varfloat (const char *vstr)
	Get float from variable string. More...
static int	osp_get_varint (const char *vstr)
	Get integer from variable string. More...
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. More...
static int	osp_next (const char *name, int cause, struct osp_results *results)
	OSP Lookup Next function. More...
static int	osp_report_qos (int trans, enum osp_callleg leg, const char *qos)
	Report QoS. More...
static int	osp_unload (void)
static int	osp_uuid2str (unsigned char *uuid, char *buffer, unsigned int bufsize)
	UUID to string. More...
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. More...
static int	ospauth_exec (struct ast_channel *chan, const char *data)
	OSP Application OSPAuth. More...
static int	ospfinished_exec (struct ast_channel *chan, const char *data)
	OSP Application OSPFinish. More...
static int	osplookup_exec (struct ast_channel *chan, const char *data)
	OSP Application OSPLookup. More...
static int	ospnext_exec (struct ast_channel *chan, const char *data)
	OSP Application OSPNext. More...
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 = "30ef0c93b36035ec78c9cfd712d36d9b" , .support_level = AST_MODULE_SUPPORT_EXTENDED, .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 const 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, 0} }
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 marks.nosp@m.ter@.nosp@m.digiu.nosp@m.m.co.nosp@m.m

ExtRef:

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

OpenSSL http://www.openssl.org

Definition in file app_osplookup.c.

Macro Definition Documentation

AST_OSP_ERROR

#define AST_OSP_ERROR   ((char*)"ERROR") /* Return status, error */

Definition at line 441 of file app_osplookup.c.

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

AST_OSP_FAILED

#define AST_OSP_FAILED   ((char*)"FAILED") /* Return status, failed */

Definition at line 440 of file app_osplookup.c.

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

AST_OSP_SUCCESS

#define AST_OSP_SUCCESS   ((char*)"SUCCESS") /* Return status, success */

Definition at line 439 of file app_osplookup.c.

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

OSP_AST_ERROR

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

Definition at line 500 of file app_osplookup.c.

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

OSP_AST_OK

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

Definition at line 499 of file app_osplookup.c.

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

OSP_AUDIT_URL

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

Definition at line 520 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_CALLID_H323

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

Definition at line 457 of file app_osplookup.c.

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

OSP_CALLID_IAX

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

Definition at line 458 of file app_osplookup.c.

Referenced by osp_create_callid(), and osplookup_exec().

OSP_CALLID_MAXNUM

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

Definition at line 459 of file app_osplookup.c.

Referenced by osp_lookup().

OSP_CALLID_SIP

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

Definition at line 456 of file app_osplookup.c.

Referenced by osp_create_callid(), and osplookup_exec().

OSP_CALLID_UNDEF

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

Definition at line 455 of file app_osplookup.c.

Referenced by osplookup_exec(), and ospnext_exec().

OSP_CONFIG_FILE

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

Definition at line 502 of file app_osplookup.c.

Referenced by osp_load().

OSP_CUSTOMER_ID

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

Definition at line 524 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_DEF_AUTHPOLICY

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

Definition at line 519 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_DEF_FLOATSTATS

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

Definition at line 533 of file app_osplookup.c.

Referenced by osp_get_varfloat(), and osp_report_qos().

OSP_DEF_INTSTATS

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

Definition at line 532 of file app_osplookup.c.

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

OSP_DEF_MAXCONNECT

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

Definition at line 507 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_DEF_MAXDESTS

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

Definition at line 526 of file app_osplookup.c.

Referenced by osp_lookup().

OSP_DEF_PROTOCOL

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

Definition at line 528 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_DEF_PROVIDER

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

Definition at line 504 of file app_osplookup.c.

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

OSP_DEF_RETRYDELAY

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

Definition at line 510 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_DEF_RETRYLIMIT

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

Definition at line 513 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_DEF_SRVTYPE

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

Definition at line 530 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_DEF_TIMELIMIT

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

Definition at line 527 of file app_osplookup.c.

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

OSP_DEF_TIMEOUT

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

Definition at line 516 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_DEF_WORKMODE

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

Definition at line 529 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_DEVICE_ID

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

Definition at line 525 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_ERROR

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

Definition at line 498 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().

OSP_FAILED

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

Definition at line 497 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().

OSP_GENERAL_CAT

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

Definition at line 503 of file app_osplookup.c.

Referenced by osp_load().

OSP_HTTP_PERSISTENCE

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

Definition at line 523 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_INVALID_HANDLE

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

Definition at line 501 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().

OSP_LOCAL_VALIDATION

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

Definition at line 521 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_MAX_CERTS

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

Definition at line 505 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_MAX_CUSTOMINFO

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

Definition at line 531 of file app_osplookup.c.

Referenced by osp_lookup(), and osplookup_exec().

OSP_MAX_MAXCONNECT

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

Definition at line 509 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_MAX_RETRYDELAY

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

Definition at line 512 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_MAX_RETRYLIMIT

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

Definition at line 515 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_MAX_SPOINTS

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

Definition at line 506 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_MAX_TIMEOUT

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

Definition at line 518 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_MIN_MAXCONNECT

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

Definition at line 508 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_MIN_RETRYDELAY

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

Definition at line 511 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_MIN_RETRYLIMIT

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

Definition at line 514 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_MIN_TIMEOUT

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

Definition at line 517 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_OK

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

Definition at line 496 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().

OSP_PROT_H323

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

Definition at line 463 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_PROT_IAX

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

Definition at line 464 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_PROT_SIP

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

Definition at line 462 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_PROT_SKYPE

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

Definition at line 465 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_SIP_HEADER

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

Definition at line 474 of file app_osplookup.c.

Referenced by osplookup_exec(), and ospnext_exec().

OSP_SIZE_INTSTR

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

Definition at line 444 of file app_osplookup.c.

Referenced by ospauth_exec(), and ospfinished_exec().

OSP_SIZE_KEYSTR

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

Definition at line 446 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_SIZE_NORSTR

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

Definition at line 445 of file app_osplookup.c.

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

OSP_SIZE_OUTSTR

#define OSP_SIZE_OUTSTR   ((unsigned int)288) /* OSP out size for osp_convert_inout */

Definition at line 452 of file app_osplookup.c.

Referenced by osp_lookup(), and osp_validate_token().

OSP_SIZE_QOSSTR

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

Definition at line 451 of file app_osplookup.c.

Referenced by ospfinished_exec().

OSP_SIZE_TECHSTR

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

Definition at line 448 of file app_osplookup.c.

OSP_SIZE_TOKSTR

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

Definition at line 447 of file app_osplookup.c.

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

OSP_SIZE_UUID

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

Definition at line 449 of file app_osplookup.c.

Referenced by osp_create_uuid().

OSP_SIZE_UUIDSTR

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

Definition at line 450 of file app_osplookup.c.

Referenced by osp_uuid2str().

OSP_SSL_LIFETIME

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

Definition at line 522 of file app_osplookup.c.

Referenced by osp_create_provider().

OSP_TECH_H323

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

Definition at line 469 of file app_osplookup.c.

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

OSP_TECH_IAX

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

Definition at line 470 of file app_osplookup.c.

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

OSP_TECH_SIP

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

Definition at line 468 of file app_osplookup.c.

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

OSP_TECH_SKYPE

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

Definition at line 471 of file app_osplookup.c.

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

Enumeration Type Documentation

osp_authpolicy

enum osp_authpolicy

Enumerator
OSP_AUTH_NO
OSP_AUTH_YES
OSP_AUTH_EXC

Definition at line 477 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 */
};

osp_callleg

enum osp_callleg

Enumerator
OSP_CALL_INBOUND
OSP_CALL_OUTBOUND

Definition at line 602 of file app_osplookup.c.

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

osp_direction

enum osp_direction

Enumerator
OSP_DIR_RX
OSP_DIR_TX
OSP_DIR_NUMBER

Definition at line 608 of file app_osplookup.c.

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

osp_srvtype

enum osp_srvtype

Enumerator
OSP_SRV_VOICE
OSP_SRV_NPQUERY

Definition at line 490 of file app_osplookup.c.

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

osp_workmode

enum osp_workmode

Enumerator
OSP_MODE_DIRECT
OSP_MODE_INDIRECT

Definition at line 484 of file app_osplookup.c.

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

Function Documentation

__reg_module()

static void __reg_module ( void  )

static

Definition at line 3170 of file app_osplookup.c.

__unreg_module()

static void __unreg_module ( void  )

static

Definition at line 3170 of file app_osplookup.c.

AST_MODULE_SELF_SYM()

struct ast_module* AST_MODULE_SELF_SYM

(

void

)

Definition at line 3170 of file app_osplookup.c.

asterisk2osp()

static OSPEFAILREASON asterisk2osp ( int  cause )

static

Convert Asterisk status to TC code.

Parameters

cause

Asterisk hangup cause

Returns

OSP TC code

Definition at line 1313 of file app_osplookup.c.

Referenced by osp_finish(), and osp_next().

{
 return (OSPEFAILREASON)cause;
}

handle_cli_osp_show()

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

static

Definition at line 3022 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, osp_provider::name, osp_provider::next, NULL, osp_hardware, osp_initialized, osp_lock, osp_security, osp_tokenformat, osp_provider::privatekey, provider, 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;
}

load_module()

static int load_module ( void  )

static

Definition at line 3128 of file app_osplookup.c.

References app1, app2, app3, app4, ast_cli_register_multiple, AST_MODULE_LOAD_DECLINE, ast_register_application_xml, osp_load(), ospauth_exec(), ospfinished_exec(), osplookup_exec(), and ospnext_exec().

Referenced by reload().

{
 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;
}

osp_auth()

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 1330 of file app_osplookup.c.

References ast_debug, ast_log, ast_strlen_zero, osp_provider::authpolicy, LOG_ERROR, NULL, 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, osp_validate_token(), and provider.

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;
}

osp_check_destination()

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 1171 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, error(), LOG_ERROR, LOG_WARNING, osp_results::networkid, osp_results::npcic, osp_results::npdi, osp_results::nprn, NULL, 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;
}

osp_choose_timelimit()

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 1146 of file app_osplookup.c.

References in, OSP_DEF_TIMELIMIT, and out.

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;
 }
}

osp_convert_inout()

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 992 of file app_osplookup.c.

References ast_copy_string(), ast_strlen_zero, NULL, 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';
 }
 }
}

osp_convert_outin()

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 1032 of file app_osplookup.c.

References ast_copy_string(), ast_strlen_zero, end, NULL, 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';
 }
 }
}

osp_create_callid()

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 1451 of file app_osplookup.c.

References ast_log, osp_callid::buf, osp_callid::len, LOG_ERROR, NULL, 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;
}

osp_create_provider()

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 644 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, B64CACert, B64LCert, B64PKey, osp_provider::cacerts, osp_provider::canum, osp_provider::defprotocol, error(), 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, NULL, 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_security, OSP_SIZE_KEYSTR, OSP_SRV_NPQUERY, OSP_SRV_VOICE, OSP_SSL_LIFETIME, osp_provider::privatekey, provider, 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;
}

osp_create_transaction()

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 945 of file app_osplookup.c.

References ast_copy_string(), ast_debug, ast_log, ast_mutex_lock, ast_mutex_unlock, error(), osp_provider::handle, LOG_ERROR, osp_provider::name, osp_provider::next, NULL, OSP_ERROR, OSP_FAILED, OSP_INVALID_HANDLE, osp_lock, OSP_OK, provider, 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;
}

osp_create_uuid()

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 1394 of file app_osplookup.c.

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

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;
}

osp_finish()

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 2188 of file app_osplookup.c.

References ast_debug, asterisk2osp(), dummy(), error(), NULL, 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;
}

osp_get_provider()

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 914 of file app_osplookup.c.

References ast_debug, ast_mutex_lock, ast_mutex_unlock, osp_provider::name, osp_provider::next, NULL, 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;
}

osp_get_varfloat()

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 1946 of file app_osplookup.c.

References ast_strlen_zero, NULL, OSP_DEF_FLOATSTATS, tmp(), 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;
}

osp_get_varint()

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 1923 of file app_osplookup.c.

References ast_strlen_zero, NULL, OSP_DEF_INTSTATS, tmp(), 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;
}

osp_load()

static int osp_load ( int  reload )

static

Definition at line 2955 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, error(), LOG_ERROR, LOG_WARNING, NULL, OSP_CONFIG_FILE, osp_create_provider(), OSP_GENERAL_CAT, osp_hardware, osp_initialized, osp_security, osp_tokenformat, 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;
}

osp_lookup()

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 1499 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(), error(), host, 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, NULL, 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_OUTSTR, 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, provider, osp_npdata::rn, osp_headers::rpiduser, osp_provider::source, osp_provider::srvtype, tmp(), 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_OUTSTR];
 char dev[OSP_SIZE_OUTSTR];
 char host[OSP_SIZE_OUTSTR];
 unsigned int i, type;
 struct osp_callid callid;
 unsigned int callidnum;
 OSPT_CALL_ID* callids[OSP_CALLID_MAXNUM];
 char dest[OSP_SIZE_OUTSTR];
 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;
}

osp_next()

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 1799 of file app_osplookup.c.

References ast_debug, ast_log, asterisk2osp(), osp_callid::buf, osp_results::called, osp_results::calling, osp_results::dest, error(), osp_results::inhandle, osp_results::intimelimit, osp_callid::len, LOG_ERROR, osp_results::networkid, osp_results::npcic, osp_results::npdi, osp_results::nprn, NULL, 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, provider, 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;
}

osp_report_qos()

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 1971 of file app_osplookup.c.

References ast_copy_string(), ast_debug, ast_strlen_zero, osp_metrics::avg, item, max, osp_metrics::max, min, osp_metrics::min, NULL, 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, tmp(), 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;
}

osp_unload()

static int osp_unload ( void  )

static

Definition at line 2929 of file app_osplookup.c.

References ast_free, ast_mutex_lock, ast_mutex_unlock, osp_provider::handle, osp_provider::next, NULL, osp_hardware, osp_initialized, osp_lock, osp_security, osp_tokenformat, and provider.

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;
}

osp_uuid2str()

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 1423 of file app_osplookup.c.

References ast_log, LOG_ERROR, NULL, 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, "%02hhx%02hhx%02hhx%02hhx-%02hhx%02hhx-"
 "%02hhx%02hhx-%02hhx%02hhx-"
 "%02hhx%02hhx%02hhx%02hhx%02hhx%02hhx",
 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;
}

osp_validate_token()

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 1081 of file app_osplookup.c.

References ast_base64decode(), ast_debug, ast_log, dummy(), error(), LOG_ERROR, LOG_WARNING, NULL, osp_convert_inout(), OSP_ERROR, OSP_FAILED, OSP_OK, OSP_SIZE_OUTSTR, OSP_SIZE_TOKSTR, and osp_tokenformat.

Referenced by osp_auth().

{
 int res;
 int tokenlen;
 unsigned char tokenstr[OSP_SIZE_TOKSTR];
 char src[OSP_SIZE_OUTSTR];
 char dest[OSP_SIZE_OUTSTR];
 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;
}

ospauth_exec()

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 2257 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_strdupa, ast_strlen_zero, ast_var_name(), ast_var_value(), ast_var_t::entries, osp_provider::handle, NULL, options, OSP_AST_ERROR, OSP_AST_OK, osp_auth(), OSP_DEF_PROVIDER, OSP_DEF_TIMELIMIT, OSP_OK, OSP_SIZE_INTSTR, pbx_builtin_setvar_helper(), provider, S_COR, osp_provider::source, status, and tmp().

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 (!strcmp(ast_var_name(current), "OSPINPEERIP")) {
 source = ast_var_value(current);
 } else if (!strcmp(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;
}

ospfinished_exec()

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 2811 of file app_osplookup.c.

References args, AST_APP_ARG, AST_CAUSE_NO_ROUTE_DESTINATION, AST_CAUSE_NORMAL_CLEARING, ast_channel_answertime(), ast_channel_creationtime(), 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_strdupa, ast_strlen_zero, ast_tvzero(), ast_var_name(), ast_var_value(), end, ast_var_t::entries, NULL, options, OSP_AST_ERROR, OSP_AST_OK, osp_finish(), OSP_INVALID_HANDLE, OSP_OK, OSP_SIZE_INTSTR, OSP_SIZE_QOSSTR, pbx_builtin_setvar_helper(), status, and tmp().

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 = 0, connect = 0, end = 0;
 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 (!strcmp(ast_var_name(current), "OSPINHANDLE")) {
 if (sscanf(ast_var_value(current), "%30d", &inhandle) != 1) {
 inhandle = OSP_INVALID_HANDLE;
 }
 } else if (!strcmp(ast_var_name(current), "OSPOUTHANDLE")) {
 if (sscanf(ast_var_value(current), "%30d", &outhandle) != 1) {
 outhandle = OSP_INVALID_HANDLE;
 }
 } else if (!recorded &&
 (!strcmp(ast_var_name(current), "OSPAUTHSTATUS") ||
 !strcmp(ast_var_name(current), "OSPLOOKUPSTATUS") ||
 !strcmp(ast_var_name(current), "OSPNEXTSTATUS")))
 {
 if (strcmp(ast_var_value(current), AST_OSP_SUCCESS)) {
 recorded = 1;
 }
 } else if (!strcmp(ast_var_name(current), "OSPINAUDIOQOS")) {
 ast_copy_string(inqos, ast_var_value(current), sizeof(inqos));
 } else if (!strcmp(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_tvzero(ast_channel_creationtime(chan))) {
 start = ast_channel_creationtime(chan).tv_sec;
 }
 if (!ast_tvzero(ast_channel_answertime(chan))) {
 connect = ast_channel_answertime(chan).tv_sec;
 }
 if (connect) {
 end = time(NULL);
 } else {
 end = connect;
 }

 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;
}

osplookup_exec()

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 2337 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_strdupa, 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, NULL, osp_results::numdests, osp_npdata::opname, osp_results::opname, options, 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, provider, osp_npdata::rn, osp_headers::rpiduser, S_COR, status, tmp(), 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 + strlen(": ") + strlen(OSP_SIP_HEADER)];
 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 (!strcmp(ast_var_name(current), "OSPINACTUALSRC")) {
 actualsrc = ast_var_value(current);
 } else if (!strcmp(ast_var_name(current), "OSPINPEERIP")) {
 srcdev = ast_var_value(current);
 } else if (!strcmp(ast_var_name(current), "OSPINTECH")) {
 ast_copy_string(results.intech, ast_var_value(current), sizeof(results.intech));
 } else if (!strcmp(ast_var_name(current), "OSPINHANDLE")) {
 if (sscanf(ast_var_value(current), "%30d", &results.inhandle) != 1) {
 results.inhandle = OSP_INVALID_HANDLE;
 }
 } else if (!strcmp(ast_var_name(current), "OSPINTIMELIMIT")) {
 if (sscanf(ast_var_value(current), "%30d", &results.intimelimit) != 1) {
 results.intimelimit = OSP_DEF_TIMELIMIT;
 }
 } else if (!strcmp(ast_var_name(current), "OSPINNETWORKID")) {
 snetid = ast_var_value(current);
 } else if (!strcmp(ast_var_name(current), "OSPINNPRN")) {
 np.rn = ast_var_value(current);
 } else if (!strcmp(ast_var_name(current), "OSPINNPCIC")) {
 np.cic = ast_var_value(current);
 } else if (!strcmp(ast_var_name(current), "OSPINNPDI")) {
 if (ast_true(ast_var_value(current))) {
 np.npdi = 1;
 }
 } else if (!strcmp(ast_var_name(current), "OSPINSPID")) {
 np.opname[OSPC_OPNAME_SPID] = ast_var_value(current);
 } else if (!strcmp(ast_var_name(current), "OSPINOCN")) {
 np.opname[OSPC_OPNAME_OCN] = ast_var_value(current);
 } else if (!strcmp(ast_var_name(current), "OSPINSPN")) {
 np.opname[OSPC_OPNAME_SPN] = ast_var_value(current);
 } else if (!strcmp(ast_var_name(current), "OSPINALTSPN")) {
 np.opname[OSPC_OPNAME_ALTSPN] = ast_var_value(current);
 } else if (!strcmp(ast_var_name(current), "OSPINMCC")) {
 np.opname[OSPC_OPNAME_MCC] = ast_var_value(current);
 } else if (!strcmp(ast_var_name(current), "OSPINMNC")) {
 np.opname[OSPC_OPNAME_MNC] = ast_var_value(current);
 } else if (!strcmp(ast_var_name(current), "OSPINTOHOST")) {
 ast_copy_string(results.dest, ast_var_value(current), sizeof(results.dest));
 } else if (!strcmp(ast_var_name(current), "OSPINRPIDUSER")) {
 headers.rpiduser = ast_var_value(current);
 } else if (!strcmp(ast_var_name(current), "OSPINPAIUSER")) {
 headers.paiuser = ast_var_value(current);
 } else if (!strcmp(ast_var_name(current), "OSPINDIVUSER")) {
 headers.divuser = ast_var_value(current);
 } else if (!strcmp(ast_var_name(current), "OSPINDIVHOST")) {
 headers.divhost = ast_var_value(current);
 } else if (!strcmp(ast_var_name(current), "OSPINPCIUSER")) {
 headers.pciuser = ast_var_value(current);
 } else if (!strcmp(ast_var_name(current), "OSPINCUSTOMINFO1")) {
 cinfo[0] = ast_var_value(current);
 } else if (!strcmp(ast_var_name(current), "OSPINCUSTOMINFO2")) {
 cinfo[1] = ast_var_value(current);
 } else if (!strcmp(ast_var_name(current), "OSPINCUSTOMINFO3")) {
 cinfo[2] = ast_var_value(current);
 } else if (!strcmp(ast_var_name(current), "OSPINCUSTOMINFO4")) {
 cinfo[3] = ast_var_value(current);
 } else if (!strcmp(ast_var_name(current), "OSPINCUSTOMINFO5")) {
 cinfo[4] = ast_var_value(current);
 } else if (!strcmp(ast_var_name(current), "OSPINCUSTOMINFO6")) {
 cinfo[5] = ast_var_value(current);
 } else if (!strcmp(ast_var_name(current), "OSPINCUSTOMINFO7")) {
 cinfo[6] = ast_var_value(current);
 } else if (!strcmp(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;
}

ospnext_exec()

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 2629 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_strdupa, 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, options, 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(), provider, status, tmp(), 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 + strlen(": ") + strlen(OSP_SIP_HEADER)];
 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 (!strcmp(ast_var_name(current), "OSPINHANDLE")) {
 if (sscanf(ast_var_value(current), "%30d", &results.inhandle) != 1) {
 results.inhandle = OSP_INVALID_HANDLE;
 }
 } else if (!strcmp(ast_var_name(current), "OSPOUTHANDLE")) {
 if (sscanf(ast_var_value(current), "%30d", &results.outhandle) != 1) {
 results.outhandle = OSP_INVALID_HANDLE;
 }
 } else if (!strcmp(ast_var_name(current), "OSPINTIMELIMIT")) {
 if (sscanf(ast_var_value(current), "%30d", &results.intimelimit) != 1) {
 results.intimelimit = OSP_DEF_TIMELIMIT;
 }
 } else if (!strcmp(ast_var_name(current), "OSPOUTCALLIDTYPES")) {
 if (sscanf(ast_var_value(current), "%30d", &callidtypes) != 1) {
 callidtypes = OSP_CALLID_UNDEF;
 }
 } else if (!strcmp(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;
}

reload()

static int reload ( void  )

static

Definition at line 3158 of file app_osplookup.c.

References AST_MODFLAG_DEFAULT, AST_MODULE_INFO(), AST_MODULE_SUPPORT_EXTENDED, ASTERISK_GPL_KEY, load_module(), osp_load(), and unload_module().

{
 osp_load(1);

 return 0;
}

unload_module()

static int unload_module ( void  )

static

Definition at line 3144 of file app_osplookup.c.

References app1, app2, app3, app4, ast_cli_unregister_multiple(), ast_unregister_application(), and osp_unload().

Referenced by reload().

{
 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

__mod_info

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 = "30ef0c93b36035ec78c9cfd712d36d9b" , .support_level = AST_MODULE_SUPPORT_EXTENDED, .load = load_module, .unload = unload_module, .reload = reload, }

static

Definition at line 3170 of file app_osplookup.c.

app1

const char app1[] = "OSPAuth"

static

Definition at line 3113 of file app_osplookup.c.

Referenced by load_module(), and unload_module().

app2

const char app2[] = "OSPLookup"

static

Definition at line 3116 of file app_osplookup.c.

Referenced by load_module(), and unload_module().

app3

const char app3[] = "OSPNext"

static

Definition at line 3119 of file app_osplookup.c.

Referenced by load_module(), and unload_module().

app4

const char app4[] = "OSPFinish"

static

Definition at line 3122 of file app_osplookup.c.

Referenced by load_module(), and unload_module().

ast_module_info

const struct ast_module_info* ast_module_info = &__mod_info

static

Definition at line 3170 of file app_osplookup.c.

B64CACert

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

Definition at line 634 of file app_osplookup.c.

Referenced by osp_create_provider().

B64LCert

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

Definition at line 633 of file app_osplookup.c.

Referenced by osp_create_provider().

B64PKey

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

Definition at line 632 of file app_osplookup.c.

Referenced by osp_create_provider().

cli_osp

struct ast_cli_entry cli_osp[]

static

Initial value:

= {
 { .handler = handle_cli_osp_show , .summary = "Displays OSF information" ,}
}

Definition at line 3124 of file app_osplookup.c.

osp_hardware

int osp_hardware = 0

static

Definition at line 626 of file app_osplookup.c.

Referenced by handle_cli_osp_show(), osp_load(), and osp_unload().

osp_initialized

int osp_initialized = 0

static

Definition at line 625 of file app_osplookup.c.

Referenced by handle_cli_osp_show(), osp_load(), and osp_unload().

osp_lock

ast_mutex_t osp_lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} }

static

Definition at line 624 of file app_osplookup.c.

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

osp_providers

struct osp_provider* osp_providers = NULL

static

Definition at line 628 of file app_osplookup.c.

Referenced by osp_create_provider().

osp_security

int osp_security = 0

static

Definition at line 627 of file app_osplookup.c.

Referenced by handle_cli_osp_show(), osp_create_provider(), osp_load(), and osp_unload().

osp_tokenformat

unsigned int osp_tokenformat = TOKEN_ALGO_SIGNED

static

Definition at line 629 of file app_osplookup.c.

Referenced by handle_cli_osp_show(), osp_load(), osp_unload(), and osp_validate_token().