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 "asterisk/astosp.h"

Include dependency graph for app_osplookup.c:

Go to the source code of this file.

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

---

Detailed Description

Open Settlement Protocol (OSP) Applications.

Author:

Mark Spencer <markster@digium.com>

ExtRef:

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

ExtRef:

OpenSSL http://www.openssl.org

Definition in file app_osplookup.c.

---

Define Documentation

#define OSP_AST_ERROR   ((int)-1)

Definition at line 485 of file app_osplookup.c.

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

#define OSP_AST_OK   ((int)0)

Definition at line 484 of file app_osplookup.c.

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

#define OSP_AUDIT_URL   ((const char*)"localhost")

Definition at line 505 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_CALLID_H323   ((unsigned int)(1 << 1))

Definition at line 442 of file app_osplookup.c.

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

#define OSP_CALLID_IAX   ((unsigned int)(1 << 2))

Definition at line 443 of file app_osplookup.c.

Referenced by osp_create_callid(), and osplookup_exec().

#define OSP_CALLID_MAXNUM   ((unsigned int)3)

Definition at line 444 of file app_osplookup.c.

Referenced by osp_lookup().

#define OSP_CALLID_SIP   ((unsigned int)(1 << 0))

Definition at line 441 of file app_osplookup.c.

Referenced by osp_create_callid(), and osplookup_exec().

#define OSP_CALLID_UNDEF   ((unsigned int)0)

Definition at line 440 of file app_osplookup.c.

Referenced by osplookup_exec(), and ospnext_exec().

#define OSP_CONFIG_FILE   ((const char*)"osp.conf")

Definition at line 487 of file app_osplookup.c.

Referenced by osp_load().

#define OSP_CUSTOMER_ID   ((const char*)"")

Definition at line 509 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_DEF_AUTHPOLICY   OSP_AUTH_YES

Definition at line 504 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_DEF_FLOATSTATS   ((float)-1)

Definition at line 518 of file app_osplookup.c.

Referenced by osp_get_varfloat(), and osp_report_qos().

#define OSP_DEF_INTSTATS   ((int)-1)

Definition at line 517 of file app_osplookup.c.

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

#define OSP_DEF_MAXCONNECT   ((unsigned int)20)

Definition at line 492 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_DEF_MAXDESTS   ((unsigned int)5)

Definition at line 511 of file app_osplookup.c.

Referenced by osp_lookup().

#define OSP_DEF_PROTOCOL   OSP_PROT_SIP

Definition at line 513 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_DEF_PROVIDER   ((const char*)"default")

Definition at line 489 of file app_osplookup.c.

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

#define OSP_DEF_RETRYDELAY   ((unsigned int)0)

Definition at line 495 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_DEF_RETRYLIMIT   ((unsigned int)2)

Definition at line 498 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_DEF_SRVTYPE   OSP_SRV_VOICE

Definition at line 515 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_DEF_TIMELIMIT   ((unsigned int)0)

Definition at line 512 of file app_osplookup.c.

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

#define OSP_DEF_TIMEOUT   ((unsigned int)500)

Definition at line 501 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_DEF_WORKMODE   OSP_MODE_DIRECT

Definition at line 514 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_DEVICE_ID   ((const char*)"")

Definition at line 510 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_ERROR   ((int)-1)

Definition at line 483 of file app_osplookup.c.

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

#define OSP_FAILED   ((int)0)

Definition at line 482 of file app_osplookup.c.

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

#define OSP_GENERAL_CAT   ((const char*)"general")

Definition at line 488 of file app_osplookup.c.

Referenced by osp_load().

#define OSP_HTTP_PERSISTENCE   ((int)1)

Definition at line 508 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_INVALID_HANDLE   ((int)-1)

Definition at line 486 of file app_osplookup.c.

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

#define OSP_LOCAL_VALIDATION   ((int)1)

Definition at line 506 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_MAX_CERTS   ((unsigned int)10)

Definition at line 490 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_MAX_CUSTOMINFO   ((unsigned int)8)

Definition at line 516 of file app_osplookup.c.

Referenced by osp_lookup(), and osplookup_exec().

#define OSP_MAX_MAXCONNECT   ((unsigned int)1000)

Definition at line 494 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_MAX_RETRYDELAY   ((unsigned int)10)

Definition at line 497 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_MAX_RETRYLIMIT   ((unsigned int)100)

Definition at line 500 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_MAX_SPOINTS   ((unsigned int)10)

Definition at line 491 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_MAX_TIMEOUT   ((unsigned int)10000)

Definition at line 503 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_MIN_MAXCONNECT   ((unsigned int)1)

Definition at line 493 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_MIN_RETRYDELAY   ((unsigned int)0)

Definition at line 496 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_MIN_RETRYLIMIT   ((unsigned int)0)

Definition at line 499 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_MIN_TIMEOUT   ((unsigned int)200)

Definition at line 502 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_OK   ((int)1)

Definition at line 481 of file app_osplookup.c.

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

#define OSP_PROT_H323   ((const char*)"H323")

Definition at line 448 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_PROT_IAX   ((const char*)"IAX")

Definition at line 449 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_PROT_SIP   ((const char*)"SIP")

Definition at line 447 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_PROT_SKYPE   ((const char*)"SKYPE")

Definition at line 450 of file app_osplookup.c.

Referenced by osp_create_provider().

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

Definition at line 459 of file app_osplookup.c.

Referenced by osplookup_exec(), and ospnext_exec().

#define OSP_SIZE_INTSTR   ((unsigned int)16)

Definition at line 430 of file app_osplookup.c.

Referenced by ospauth_exec(), and ospfinished_exec().

#define OSP_SIZE_KEYSTR   ((unsigned int)1024)

Definition at line 432 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_SIZE_NORSTR   ((unsigned int)256)

Definition at line 431 of file app_osplookup.c.

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

#define OSP_SIZE_QOSSTR   ((unsigned int)1024)

Definition at line 437 of file app_osplookup.c.

Referenced by ospfinished_exec().

#define OSP_SIZE_TECHSTR   ((unsigned int)32)

Definition at line 434 of file app_osplookup.c.

#define OSP_SIZE_TOKSTR   ((unsigned int)4096)

Definition at line 433 of file app_osplookup.c.

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

#define OSP_SIZE_UUID   ((unsigned int)16)

Definition at line 435 of file app_osplookup.c.

Referenced by osp_create_uuid().

#define OSP_SIZE_UUIDSTR   ((unsigned int)36)

Definition at line 436 of file app_osplookup.c.

Referenced by osp_uuid2str().

#define OSP_SSL_LIFETIME   ((unsigned int)300)

Definition at line 507 of file app_osplookup.c.

Referenced by osp_create_provider().

#define OSP_TECH_H323   ((const char*)"H323")

Definition at line 454 of file app_osplookup.c.

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

#define OSP_TECH_IAX   ((const char*)"IAX2")

Definition at line 455 of file app_osplookup.c.

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

#define OSP_TECH_SIP   ((const char*)"SIP")

Definition at line 453 of file app_osplookup.c.

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

#define OSP_TECH_SKYPE   ((const char*)"SKYPE")

Definition at line 456 of file app_osplookup.c.

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

---

Enumeration Type Documentation

enum osp_authpolicy

Enumerator:

OSP_AUTH_NO
OSP_AUTH_YES
OSP_AUTH_EXC

Definition at line 462 of file app_osplookup.c.

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

enum osp_callleg

Enumerator:

OSP_CALL_INBOUND
OSP_CALL_OUTBOUND

Definition at line 583 of file app_osplookup.c.

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

enum osp_direction

Enumerator:

OSP_DIR_RX
OSP_DIR_TX
OSP_DIR_NUMBER

Definition at line 589 of file app_osplookup.c.

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

enum osp_srvtype

Enumerator:

OSP_SRV_VOICE
OSP_SRV_NPQUERY

Definition at line 475 of file app_osplookup.c.

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

enum osp_workmode

Enumerator:

OSP_MODE_DIRECT
OSP_MODE_INDIRECT

Definition at line 469 of file app_osplookup.c.

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

---

Function Documentation

static void __reg_module

(

void

)

[static]

Definition at line 3132 of file app_osplookup.c.

static void __unreg_module

(

void

)

[static]

Definition at line 3132 of file app_osplookup.c.

static OSPEFAILREASON asterisk2osp

(

int

cause

)

[static]

Convert Asterisk status to TC code.

Parameters:

cause

Asterisk hangup cause

Returns:

OSP TC code

Definition at line 1295 of file app_osplookup.c.

References cause.

Referenced by osp_finish(), and osp_next().

{
   return (OSPEFAILREASON)cause;
}

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

Definition at line 2985 of file app_osplookup.c.

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

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

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

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

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

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

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

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

   return CLI_SUCCESS;
}

static int load_module

(

void

)

[static]

Definition at line 3091 of file app_osplookup.c.

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

{
   int res;

   if (!osp_load(0))
      return AST_MODULE_LOAD_DECLINE;

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

   return res;
}

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

OSP Authentication function.

Parameters:

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

Returns:

OSP_OK Authenricated, OSP_FAILED Unauthenticated, OSP_ERROR Error

Definition at line 1312 of file app_osplookup.c.

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

Referenced by ospauth_exec().

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

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

   *trans = OSP_INVALID_HANDLE;
   *timelimit = OSP_DEF_TIMELIMIT;

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

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

   return res;
}

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

Choose min duration limit.

Parameters:

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

Returns:

OSP_OK Success, OSP_FAILED Failed, OSP_ERROR Error

Definition at line 1153 of file app_osplookup.c.

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

Referenced by osp_lookup(), and osp_next().

{
   int res;
   OSPE_DEST_OSPENABLED enabled;
   OSPE_DEST_PROTOCOL 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_DPROT_SIP:
      ast_debug(1, "OSP: protocol SIP\n");
      ast_copy_string(results->tech, OSP_TECH_SIP, sizeof(results->tech));
      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_DPROT_Q931:
      ast_debug(1, "OSP: protocol Q.931\n");
      ast_copy_string(results->tech, OSP_TECH_H323, sizeof(results->tech));
      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_DPROT_IAX:
      ast_debug(1, "OSP: protocol IAX\n");
      ast_copy_string(results->tech, OSP_TECH_IAX, sizeof(results->tech));
      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_DPROT_SKYPE:
      ast_debug(1, "OSP: protocol Skype\n");
      ast_copy_string(results->tech, OSP_TECH_SKYPE, sizeof(results->tech));
      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_DPROT_UNDEFINED:
   case OSPC_DPROT_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->tech, provider->defprotocol, sizeof(results->tech));
      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_DPROT_LRQ:
   case OSPC_DPROT_T37:
   case OSPC_DPROT_T38:
   case OSPC_DPROT_SMPP:
   case OSPC_DPROT_XMPP:
   default:
      ast_log(LOG_WARNING, "OSP: unsupported protocol '%d'\n", protocol);
      *reason = OSPC_FAIL_PROTOCOL_ERROR;
      results->token[0] = '\0';
      results->networkid[0] = '\0';
      results->nprn[0] = '\0';
      results->npcic[0] = '\0';
      results->npdi = 0;
      for (type = OSPC_OPNAME_START; type < OSPC_OPNAME_NUMBER; type++) {
         results->opname[type][0] = '\0';
      }
      res = OSP_FAILED;
      break;
   }

   return res;
}

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

Choose min duration limit.

Parameters:

in	Inbound duration limit
out	Outbound duration limit

Returns:

min duration limit

Definition at line 1128 of file app_osplookup.c.

References OSP_DEF_TIMELIMIT.

Referenced by osp_lookup(), and osp_next().

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

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

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

Parameters:

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

Definition at line 974 of file app_osplookup.c.

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

Referenced by osp_lookup(), and osp_validate_token().

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

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

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

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

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

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

Parameters:

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

Definition at line 1014 of file app_osplookup.c.

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

Referenced by osp_check_destination().

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

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

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

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

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

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

Create a call ID according to the type.

Parameters:

type	Call ID type
callid	Call ID buffer

Returns:

OSK_OK Created, OSP_FAILED Not create, OSP_ERROR Error

Definition at line 1431 of file app_osplookup.c.

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

Referenced by osp_lookup().

{
   int res;

   if (callid == NULL) {
      ast_log(LOG_ERROR, "Invalid parameters\n");
      res = 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;
   default:
      res = OSP_ERROR;
      break;
   }

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

   return res;
}

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

Create OSP provider handle according to configuration.

Parameters:

cfg	OSP configuration
name	OSP provider context name

Returns:

OSP_OK Success, OSP_FAILED Failed, OSP_ERROR Error

Definition at line 626 of file app_osplookup.c.

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

Referenced by osp_load().

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

   return res;
}

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

Create OSP transaction handle.

Parameters:

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

Returns:

OSK_OK Success, OSK_FAILED Failed, OSP_ERROR Error

Definition at line 927 of file app_osplookup.c.

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

Referenced by osp_auth(), and osp_lookup().

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

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

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

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

   return res;
}

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

Create a UUID.

Parameters:

uuid	UUID buffer
bufsize	UUID buffer size

Returns:

OSK_OK Created, OSP_ERROR Error

Definition at line 1376 of file app_osplookup.c.

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

Referenced by osp_create_callid().

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

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

   return res;
}

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

OSP Finish function.

Parameters:

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

Returns:

OSP_OK Success, OSP_FAILED Failed, OSP_ERROR Error

Definition at line 2155 of file app_osplookup.c.

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

Referenced by ospfinished_exec().

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

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

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

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

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

   return res;
}

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

Get OSP provider by name.

Parameters:

name	OSP provider context name
provider	OSP provider structure

Returns:

OSP_OK Success, OSP_FAILED Failed, OSP_ERROR Error

Definition at line 896 of file app_osplookup.c.

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

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

{
   int res = OSP_FAILED;
   struct osp_provider* p;

   *provider = NULL;

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

   return res;
}

static float osp_get_varfloat

(

const char *

vstr

)

[static]

Get float from variable string.

Parameters:

vstr	Variable string

Returns:

OSP_DEF_FLOATSTATS Error

Definition at line 1907 of file app_osplookup.c.

References ast_strlen_zero(), OSP_DEF_FLOATSTATS, and value.

Referenced by osp_report_qos().

{
   char* tmp;
   float value = OSP_DEF_FLOATSTATS;

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

   return value;
}

static int osp_get_varint

(

const char *

vstr

)

[static]

Get integer from variable string.

Parameters:

vstr	Variable string

Returns:

OSP_DEF_INTSTATS Error

Definition at line 1884 of file app_osplookup.c.

References ast_strlen_zero(), OSP_DEF_INTSTATS, and value.

Referenced by osp_report_qos().

{
   char* tmp;
   int value = OSP_DEF_INTSTATS;

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

   return value;
}

static int osp_load

(

int

reload

)

[static]

Definition at line 2918 of file app_osplookup.c.

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

Referenced by load_module(), and reload().

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

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

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

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

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

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

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

      osp_initialized = 1;

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

   return 1;
}

static int osp_lookup	(	const char *	name,
		unsigned int	callidtypes,
		const char *	actualsrc,
		const char *	srcdev,
		const char *	calling,
		const char *	called,
		const char *	snetid,
		struct osp_npdata *	np,
		struct osp_diversion *	div,
		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
div	SIP Diversion header parameters
cinfo	Custom info
results	Lookup results

Returns:

OSP_OK Found , OSP_FAILED No route, OSP_ERROR Error

Definition at line 1478 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, dummy(), osp_diversion::host, osp_results::inhandle, osp_results::intimelimit, osp_callid::len, LOG_ERROR, LOG_WARNING, osp_results::networkid, osp_results::npcic, osp_npdata::npdi, osp_results::npdi, osp_results::nprn, osp_results::numdests, osp_npdata::opname, osp_results::opname, OSP_CALLID_MAXNUM, osp_check_destination(), osp_choose_timelimit(), osp_convert_inout(), osp_create_callid(), osp_create_transaction(), OSP_DEF_MAXDESTS, OSP_DEF_TIMELIMIT, OSP_ERROR, OSP_FAILED, osp_get_provider(), OSP_INVALID_HANDLE, OSP_MAX_CUSTOMINFO, OSP_MODE_INDIRECT, OSP_OK, OSP_SIZE_NORSTR, OSP_SIZE_TOKSTR, OSP_SRV_NPQUERY, osp_results::outcallid, osp_results::outhandle, osp_results::outtimelimit, osp_npdata::rn, osp_provider::source, osp_provider::srvtype, osp_results::tech, osp_results::token, type, osp_diversion::user, and osp_provider::workmode.

Referenced by osplookup_exec().

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

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

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

   results->outhandle = OSP_INVALID_HANDLE;
   results->tech[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 (!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]);
   }

   osp_convert_inout(div->host, host, sizeof(host));
   OSPPTransactionSetDiversion(results->outhandle, div->user, host);

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

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

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

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

   if (provider->srvtype == OSP_SRV_NPQUERY) {
      OSPPTransactionSetServiceType(results->outhandle, OSPC_SERVICE_NPQUERY);
      if (!ast_strlen_zero(dest)) {
         preferred[0] = dest;
      }
      results->numdests = 1;
   } else {
      OSPPTransactionSetServiceType(results->outhandle, OSPC_SERVICE_VOICE);
      results->numdests = OSP_DEF_MAXDESTS;
   }
   error = OSPPTransactionRequestAuthorisation(results->outhandle,
      src,
      dev,
      calling ? calling : "",
      OSPC_NFORMAT_E164,
      callednum,
      OSPC_NFORMAT_E164,
      NULL,
      callidnum,
      callids,
      preferred,
      &results->numdests,
      &dummy,
      NULL);

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

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

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

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

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

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

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

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

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

   return res;
}

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

OSP Lookup Next function.

Parameters:

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

Returns:

OSP_OK Found , OSP_FAILED No route, OSP_ERROR Error

Definition at line 1760 of file app_osplookup.c.

References ast_debug, ast_log(), asterisk2osp(), osp_callid::buf, osp_results::called, osp_results::calling, osp_results::dest, osp_results::inhandle, osp_results::intimelimit, osp_callid::len, LOG_ERROR, osp_results::networkid, osp_results::npcic, osp_results::npdi, osp_results::nprn, osp_results::numdests, osp_results::opname, osp_check_destination(), osp_choose_timelimit(), OSP_DEF_TIMELIMIT, OSP_ERROR, OSP_FAILED, osp_get_provider(), OSP_INVALID_HANDLE, OSP_OK, OSP_SIZE_NORSTR, OSP_SIZE_TOKSTR, osp_results::outcallid, osp_results::outhandle, osp_results::outtimelimit, osp_results::tech, 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");
      res = OSP_ERROR;
   }

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

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

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

   reason = asterisk2osp(cause);

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

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

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

   return res;
}

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

Report QoS.

Parameters:

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

Returns:

OSP_OK Success, OSP_FAILED Failed, OSP_ERROR Error

Definition at line 1932 of file app_osplookup.c.

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

Referenced by osp_finish().

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

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

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

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

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

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

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

      if (leg == OSP_CALL_INBOUND) {
         OSPPTransactionSetPackets(trans, OSPC_SMETRIC_RTP, OSPC_SFLOW_DOWNSTREAM, totalpackets[OSP_DIR_RX]);
         OSPPTransactionSetPackets(trans, OSPC_SMETRIC_RTCP, OSPC_SFLOW_UPSTREAM, 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_SFLOW_DOWNSTREAM, 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_SFLOW_UPSTREAM, 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_SFLOW_DOWNSTREAM,
            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_SFLOW_UPSTREAM,
            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_SFLOW_UPSTREAM, totalpackets[OSP_DIR_RX]);
         OSPPTransactionSetPackets(trans, OSPC_SMETRIC_RTCP, OSPC_SFLOW_DOWNSTREAM, totalpackets[OSP_DIR_TX]);
         OSPPTransactionSetLost(trans, OSPC_SMETRIC_RTP, OSPC_SFLOW_UPSTREAM, lost[OSP_DIR_RX].value, OSP_DEF_INTSTATS);
         OSPPTransactionSetLost(trans, OSPC_SMETRIC_RTCP, OSPC_SFLOW_DOWNSTREAM, 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_SFLOW_UPSTREAM,
            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_SFLOW_DOWNSTREAM,
            OSP_DEF_INTSTATS,
            (int)jitter[OSP_DIR_TX].min,
            (int)jitter[OSP_DIR_TX].max,
            value,
            jitter[OSP_DIR_TX].sdev);
      }
      if (rtt.value >= 0) {
         value = rtt.value;
      } else {
         value = (int)rtt.avg;
      }
      OSPPTransactionSetRoundTripDelay(trans, OSP_DEF_INTSTATS, (int)rtt.min, (int)rtt.max, value, rtt.sdev);

      res = OSP_OK;
   }

   return res;
}

static int osp_unload

(

void

)

[static]

Definition at line 2892 of file app_osplookup.c.

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

Referenced by osp_load(), and unload_module().

{
   struct osp_provider* provider;
   struct osp_provider* next;

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

      OSPPCleanup();

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

   return 0;
}

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

UUID to string.

Parameters:

uuid	UUID
buffer	String buffer
bufsize	String buffer size

Returns:

OSP_OK Successed, OSP_ERROR Error

Definition at line 1405 of file app_osplookup.c.

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

Referenced by osplookup_exec(), and ospnext_exec().

{
   int res;

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

   return res;
}

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

Validate OSP token of inbound call.

Parameters:

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

Returns:

OSP_OK Success, OSP_FAILED Failed, OSP_ERROR Error

Definition at line 1063 of file app_osplookup.c.

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

Referenced by osp_auth().

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

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

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

   return res;
}

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

OSP Application OSPAuth.

Parameters:

chan	Channel
data	Parameter

Returns:

OSP_AST_OK Success, OSP_AST_ERROR Error

Definition at line 2222 of file app_osplookup.c.

References args, AST_APP_ARG, 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(), ast_channel::caller, ast_var_t::entries, ast_channel::exten, ast_party_caller::id, LOG_ERROR, ast_party_id::number, OSP_AST_ERROR, OSP_AST_OK, osp_auth(), OSP_DEF_PROVIDER, OSP_DEF_TIMELIMIT, OSP_OK, OSP_SIZE_INTSTR, pbx_builtin_setvar_helper(), S_COR, status, ast_party_number::str, ast_party_number::valid, and ast_channel::varshead.

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

   if (!(tmp = ast_strdupa(data))) {
      ast_log(LOG_ERROR, "Out of memory\n");
      return OSP_AST_ERROR;
   }

   AST_STANDARD_APP_ARGS(args, tmp);

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

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

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

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

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

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

   return res;
}

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

OSP Application OSPFinish.

Parameters:

chan	Channel
data	Parameter

Returns:

OSP_AST_OK Success, OSP_AST_ERROR Error

Definition at line 2770 of file app_osplookup.c.

References ast_cdr::answer, args, AST_APP_ARG, AST_CAUSE_NO_ROUTE_DESTINATION, AST_CAUSE_NORMAL_CLEARING, ast_check_hangup(), 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_var_name(), ast_var_value(), cause, ast_channel::cdr, ast_var_t::entries, LOG_ERROR, OSP_AST_ERROR, OSP_AST_OK, osp_finish(), OSP_INVALID_HANDLE, OSP_OK, OSP_SIZE_INTSTR, OSP_SIZE_QOSSTR, pbx_builtin_setvar_helper(), ast_cdr::start, status, and ast_channel::varshead.

Referenced by load_module().

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

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

   if (!(tmp = ast_strdupa(data))) {
      ast_log(LOG_ERROR, "Out of memory\n");
      return OSP_AST_ERROR;
   }

   AST_STANDARD_APP_ARGS(args, tmp);

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

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

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

   release = ast_check_hangup(chan) ? 0 : 1;

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

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

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

   return res;
}

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

OSP Application OSPLookup.

Parameters:

chan	Channel
data	Parameter

Returns:

OSP_AST_OK Success, OSP_AST_ERROR Error

Definition at line 2305 of file app_osplookup.c.

References args, AST_APP_ARG, ast_autoservice_start(), ast_autoservice_stop(), 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, ast_channel::caller, osp_results::calling, osp_npdata::cic, osp_results::dest, exten, osp_diversion::host, ast_party_caller::id, osp_results::inhandle, 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, ast_party_id::number, osp_results::numdests, osp_npdata::opname, osp_results::opname, OSP_AST_ERROR, OSP_AST_OK, OSP_CALLID_H323, OSP_CALLID_IAX, OSP_CALLID_SIP, OSP_CALLID_UNDEF, OSP_DEF_PROVIDER, OSP_DEF_TIMELIMIT, OSP_INVALID_HANDLE, osp_lookup(), OSP_MAX_CUSTOMINFO, OSP_OK, OSP_SIP_HEADER, OSP_SIZE_TOKSTR, OSP_TECH_H323, OSP_TECH_IAX, OSP_TECH_SIP, OSP_TECH_SKYPE, osp_uuid2str(), osp_results::outcallid, osp_results::outhandle, osp_results::outtimelimit, pbx_builtin_setvar_helper(), osp_npdata::rn, S_COR, status, ast_party_number::str, osp_results::tech, osp_results::token, type, osp_diversion::user, ast_party_number::valid, and ast_channel::varshead.

Referenced by load_module().

{
   int res, cres;
   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_diversion div;
   unsigned int i;
   const char* cinfo[OSP_MAX_CUSTOMINFO] = { NULL };
   char buffer[OSP_SIZE_TOKSTR];
   struct osp_results results;
   const char* status;
   char* tmp;

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

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

   if (!(tmp = ast_strdupa(data))) {
      ast_log(LOG_ERROR, "Out of memory\n");
      return OSP_AST_ERROR;
   }

   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] = "";
   }

   div.user = "";
   div.host = "";

   headp = &chan->varshead;
   AST_LIST_TRAVERSE(headp, current, entries) {
      if (!strcasecmp(ast_var_name(current), "OSPINACTUALSRC")) {
         actualsrc = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINPEERIP")) {
         srcdev = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINHANDLE")) {
         if (sscanf(ast_var_value(current), "%30d", &results.inhandle) != 1) {
            results.inhandle = OSP_INVALID_HANDLE;
         }
      } else if (!strcasecmp(ast_var_name(current), "OSPINTIMELIMIT")) {
         if (sscanf(ast_var_value(current), "%30d", &results.intimelimit) != 1) {
            results.intimelimit = OSP_DEF_TIMELIMIT;
         }
      } else if (!strcasecmp(ast_var_name(current), "OSPINNETWORKID")) {
         snetid = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINNPRN")) {
         np.rn = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINNPCIC")) {
         np.cic = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINNPDI")) {
         if (ast_true(ast_var_value(current))) {
            np.npdi = 1;
         }
      } else if (!strcasecmp(ast_var_name(current), "OSPINSPID")) {
         np.opname[OSPC_OPNAME_SPID] = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINOCN")) {
         np.opname[OSPC_OPNAME_OCN] = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINSPN")) {
         np.opname[OSPC_OPNAME_SPN] = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINALTSPN")) {
         np.opname[OSPC_OPNAME_ALTSPN] = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINMCC")) {
         np.opname[OSPC_OPNAME_MCC] = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINMNC")) {
         np.opname[OSPC_OPNAME_MNC] = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINTOHOST")) {
         ast_copy_string(results.dest, ast_var_value(current), sizeof(results.dest));
      } else if (!strcasecmp(ast_var_name(current), "OSPINDIVUSER")) {
         div.user = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINDIVHOST")) {
         div.host = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINCUSTOMINFO1")) {
         cinfo[0] = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINCUSTOMINFO2")) {
         cinfo[1] = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINCUSTOMINFO3")) {
         cinfo[2] = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINCUSTOMINFO4")) {
         cinfo[3] = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINCUSTOMINFO5")) {
         cinfo[4] = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINCUSTOMINFO6")) {
         cinfo[5] = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINCUSTOMINFO7")) {
         cinfo[6] = ast_var_value(current);
      } else if (!strcasecmp(ast_var_name(current), "OSPINCUSTOMINFO8")) {
         cinfo[7] = ast_var_value(current);
      }
   }
   ast_debug(1, "OSPLookup: actual source device '%s'\n", actualsrc);
   ast_debug(1, "OSPLookup: source device '%s'\n", srcdev);
   ast_debug(1, "OSPLookup: 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: OSPINDIVUSER '%s'\n", div.user);
   ast_debug(1, "OSPLookup: OSPINDIVHOST'%s'\n", div.host);
   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 ((cres = ast_autoservice_start(chan)) < 0) {
      return OSP_AST_ERROR;
   }

   res = osp_lookup(provider, callidtypes, actualsrc, srcdev,
      S_COR(chan->caller.id.number.valid, chan->caller.id.number.str, NULL),
      args.exten, snetid, &np, &div, cinfo, &results);
   if (res > 0) {
      status = AST_OSP_SUCCESS;
   } else {
      results.tech[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.tech);
   ast_debug(1, "OSPLookup: OSPOUTTECH '%s'\n", results.tech);
   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.tech, OSP_TECH_SIP)) {
      snprintf(buffer, sizeof(buffer), "%s/%s@%s", results.tech, 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.tech, 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.tech, results.called, results.dest);
      pbx_builtin_setvar_helper(chan, "OSPDIALSTR", buffer);
   } else if (!strcasecmp(results.tech, OSP_TECH_IAX)) {
      snprintf(buffer, sizeof(buffer), "%s/%s/%s", results.tech, results.dest, results.called);
      pbx_builtin_setvar_helper(chan, "OSPDIALSTR", buffer);
   } else if (!strcasecmp(results.tech, OSP_TECH_SKYPE)) {
      snprintf(buffer, sizeof(buffer), "%s/%s", results.tech, results.called);
      pbx_builtin_setvar_helper(chan, "OSPDIALSTR", buffer);
   }

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

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

   return res;
}

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

OSP Application OSPNext.

Parameters:

chan	Channel
data	Parameter

Returns:

OSP_AST_OK Success, OSP_AST_ERROR Error

Definition at line 2585 of file app_osplookup.c.

References args, AST_APP_ARG, 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, cause, osp_results::dest, osp_results::inhandle, osp_results::intimelimit, osp_callid::len, LOG_ERROR, LOG_WARNING, osp_results::networkid, osp_results::npcic, osp_results::npdi, osp_results::nprn, osp_results::numdests, osp_results::opname, OSP_AST_ERROR, OSP_AST_OK, OSP_CALLID_H323, OSP_CALLID_UNDEF, OSP_DEF_PROVIDER, OSP_DEF_TIMELIMIT, OSP_INVALID_HANDLE, osp_next(), OSP_OK, OSP_SIP_HEADER, OSP_SIZE_TOKSTR, OSP_TECH_H323, OSP_TECH_IAX, OSP_TECH_SIP, OSP_TECH_SKYPE, osp_uuid2str(), osp_results::outcallid, osp_results::outhandle, osp_results::outtimelimit, pbx_builtin_setvar_helper(), status, osp_results::tech, osp_results::token, type, and ast_channel::varshead.

Referenced by load_module().

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

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

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

   if (!(tmp = ast_strdupa(data))) {
      ast_log(LOG_ERROR, "Out of memory\n");
      return OSP_AST_ERROR;
   }

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

   if ((res = osp_next(provider, cause, &results)) > 0) {
      status = AST_OSP_SUCCESS;
   } else {
      results.tech[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.tech);
   ast_debug(1, "OSPNext: OSPOUTTECH '%s'\n", results.tech);
   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.tech, OSP_TECH_SIP)) {
      snprintf(buffer, sizeof(buffer), "%s/%s@%s", results.tech, 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.tech, 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.tech, results.called, results.dest);
      pbx_builtin_setvar_helper(chan, "OSPDIALSTR", buffer);
   } else if (!strcasecmp(results.tech, OSP_TECH_IAX)) {
      snprintf(buffer, sizeof(buffer), "%s/%s/%s", results.tech, results.dest, results.called);
      pbx_builtin_setvar_helper(chan, "OSPDIALSTR", buffer);
   } else if (!strcasecmp(results.tech, OSP_TECH_SKYPE)) {
      snprintf(buffer, sizeof(buffer), "%s/%s", results.tech, results.called);
      pbx_builtin_setvar_helper(chan, "OSPDIALSTR", buffer);
   }

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

   return res;
}

static int reload

(

void

)

[static]

Definition at line 3121 of file app_osplookup.c.

References osp_load().

{
   osp_load(1);

   return 0;
}

static int unload_module

(

void

)

[static]

Definition at line 3107 of file app_osplookup.c.

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

{
   int res;

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

   return res;
}

---

Variable Documentation

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

Definition at line 3132 of file app_osplookup.c.

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

Definition at line 3076 of file app_osplookup.c.

Referenced by app_cmp().

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

Definition at line 3079 of file app_osplookup.c.

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

Definition at line 3082 of file app_osplookup.c.

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

Definition at line 3085 of file app_osplookup.c.

struct ast_module_info* ast_module_info = &__mod_info [static]

Definition at line 3132 of file app_osplookup.c.

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

Definition at line 616 of file app_osplookup.c.

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

Definition at line 615 of file app_osplookup.c.

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

Definition at line 614 of file app_osplookup.c.

struct ast_cli_entry cli_osp[] [static]

Initial value:

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

Definition at line 3087 of file app_osplookup.c.

int osp_hardware = 0 [static]

Definition at line 608 of file app_osplookup.c.

int osp_initialized = 0 [static]

Definition at line 607 of file app_osplookup.c.

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

Definition at line 606 of file app_osplookup.c.

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

struct osp_provider* osp_providers = NULL [static]

Definition at line 610 of file app_osplookup.c.

Referenced by osp_create_provider().

int osp_security = 0 [static]

Definition at line 609 of file app_osplookup.c.

unsigned int osp_tokenformat = TOKEN_ALGO_SIGNED [static]

Definition at line 611 of file app_osplookup.c.