res_pjproject.h File Reference

#include <pj/types.h>
#include <pj/pool.h>

Include dependency graph for res_pjproject.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions
void	ast_pjproject_caching_pool_destroy (pj_caching_pool *cp)
	Destroy caching pool factory and all cached pools. More...
void	ast_pjproject_caching_pool_init (pj_caching_pool *cp, const pj_pool_factory_policy *policy, pj_size_t max_capacity)
	Initialize the caching pool factory. More...
int	ast_pjproject_get_buildopt (char *option, char *format_string,...)
	Retrieve a pjproject build option. More...
void	ast_pjproject_log_intercept_begin (int fd)
	Begin PJPROJECT log interception for CLI output. More...
void	ast_pjproject_log_intercept_end (void)
	End PJPROJECT log interception for CLI output. More...
int	ast_sockaddr_from_pj_sockaddr (struct ast_sockaddr *addr, const pj_sockaddr *pjaddr)
	Fill an ast_sockaddr from a pj_sockaddr. More...
int	ast_sockaddr_pj_sockaddr_cmp (const struct ast_sockaddr *addr, const pj_sockaddr *pjaddr)
	Compare an ast_sockaddr to a pj_sockaddr. More...
int	ast_sockaddr_to_pj_sockaddr (const struct ast_sockaddr *addr, pj_sockaddr *pjaddr)
	Fill a pj_sockaddr from an ast_sockaddr. More...

Function Documentation

ast_pjproject_caching_pool_destroy()

void ast_pjproject_caching_pool_destroy

(

pj_caching_pool *

cp

)

Destroy caching pool factory and all cached pools.

Since

13.21.0

Parameters

cp	Caching pool factory to destroy

Definition at line 529 of file res_pjproject.c.

{
    pj_caching_pool_destroy(cp);
}

Referenced by unload_module(), and unload_pjsip().

ast_pjproject_caching_pool_init()

void ast_pjproject_caching_pool_init	(	pj_caching_pool *	cp,
		const pj_pool_factory_policy *	policy,
		pj_size_t	max_capacity
	)

Initialize the caching pool factory.

Since

13.21.0

Parameters

cp	Caching pool factory to initialize
policy	Pool factory policy
max_capacity	Total capacity to be retained in the cache. Zero disables caching.

Definition at line 522 of file res_pjproject.c.

{
    /* Passing a max_capacity of zero disables caching pools */
    pj_caching_pool_init(cp, policy, ast_option_pjproject_cache_pools ? max_capacity : 0);
}

References ast_option_pjproject_cache_pools.

Referenced by load_module(), and load_pjsip().

ast_pjproject_get_buildopt()

int ast_pjproject_get_buildopt	(	char *	option,
		char *	format_string,
			...
	)

Retrieve a pjproject build option.

Parameters

option	The build option requested
format_string	A scanf-style format string to parse the option value into
...	Pointers to variables to receive the values parsed

Return values

The	number of values parsed

Since

13.8.0

Note

The option requested must be from those returned by pj_dump_config() which can be displayed with the 'pjsip show buildopts' CLI command.

Sample Usage:

int max_hostname;
 
ast_sip_get_pjproject_buildopt("PJ_MAX_HOSTNAME", "%d", &max_hostname);

Definition at line 281 of file res_pjproject.c.

{
    int res = 0;
    char *format_temp;
    int i;
 
    format_temp = ast_alloca(strlen(option) + strlen(" : ") + strlen(format_string) + 1);
    sprintf(format_temp, "%s : %s", option, format_string);
 
    for (i = 0; i < AST_VECTOR_SIZE(&buildopts); i++) {
        va_list arg_ptr;
        va_start(arg_ptr, format_string);
        res = vsscanf(AST_VECTOR_GET(&buildopts, i), format_temp, arg_ptr);
        va_end(arg_ptr);
        if (res) {
            break;
        }
    }
 
    return res;
}

References ast_alloca, AST_VECTOR_GET, and AST_VECTOR_SIZE.

Referenced by ast_sip_initialize_sorcery_location(), and load_module().

ast_pjproject_log_intercept_begin()

void ast_pjproject_log_intercept_begin

(

int

fd

)

Begin PJPROJECT log interception for CLI output.

Since

13.8.0

Parameters

fd	CLI file descriptior to send intercepted output.

Note

ast_pjproject_log_intercept_begin() and ast_pjproject_log_intercept_end() must always be called in pairs.

Definition at line 304 of file res_pjproject.c.

{
    /* Protect from other CLI instances trying to do this at the same time. */
    ast_mutex_lock(&pjproject_log_intercept_lock);
 
    pjproject_log_intercept.thread = pthread_self();
    pjproject_log_intercept.fd = fd;
}

References ast_mutex_lock, pjproject_log_intercept_data::fd, pjproject_log_intercept, pjproject_log_intercept_lock, and pjproject_log_intercept_data::thread.

Referenced by do_cli_dump_endpt().

ast_pjproject_log_intercept_end()

void ast_pjproject_log_intercept_end

(

void

)

End PJPROJECT log interception for CLI output.

Since

13.8.0

Note

ast_pjproject_log_intercept_begin() and ast_pjproject_log_intercept_end() must always be called in pairs.

Definition at line 313 of file res_pjproject.c.

{
    pjproject_log_intercept.fd = -1;
    pjproject_log_intercept.thread = AST_PTHREADT_NULL;
 
    ast_mutex_unlock(&pjproject_log_intercept_lock);
}

References ast_mutex_unlock, AST_PTHREADT_NULL, pjproject_log_intercept_data::fd, pjproject_log_intercept, pjproject_log_intercept_lock, and pjproject_log_intercept_data::thread.

Referenced by do_cli_dump_endpt().

ast_sockaddr_from_pj_sockaddr()

int ast_sockaddr_from_pj_sockaddr	(	struct ast_sockaddr *	addr,
		const pj_sockaddr *	pjaddr
	)

Fill an ast_sockaddr from a pj_sockaddr.

Since

13.24.0

Parameters

addr	The target address to receive the copied address
pjaddr	The source address to copy

Return values

0	Success
-1	Failure

Definition at line 559 of file res_pjproject.c.

{
    if (pjaddr->addr.sa_family == pj_AF_INET()) {
        struct sockaddr_in *sin = (struct sockaddr_in *) &addr->ss;
#if defined(HAVE_STRUCT_SOCKADDR_IN_SIN_LEN)
        sin->sin_len = sizeof(struct sockaddr_in);
#endif
        sin->sin_family = AF_INET;
#if defined(HAVE_PJPROJECT_BUNDLED) && !defined(HAVE_PJPROJECT_BUNDLED_OOT)
        sin->sin_addr = pjaddr->ipv4.sin_addr;
#else
        sin->sin_addr.s_addr = pjaddr->ipv4.sin_addr.s_addr;
#endif
        sin->sin_port   = pjaddr->ipv4.sin_port;
        memset(sin->sin_zero, 0, sizeof(sin->sin_zero));
        addr->len = sizeof(struct sockaddr_in);
    } else if (pjaddr->addr.sa_family == pj_AF_INET6()) {
        struct sockaddr_in6 *sin = (struct sockaddr_in6 *) &addr->ss;
#if defined(HAVE_STRUCT_SOCKADDR_IN6_SIN6_LEN)
        sin->sin6_len = sizeof(struct sockaddr_in6);
#endif
        sin->sin6_family   = AF_INET6;
        sin->sin6_port     = pjaddr->ipv6.sin6_port;
        sin->sin6_flowinfo = pjaddr->ipv6.sin6_flowinfo;
        sin->sin6_scope_id = pjaddr->ipv6.sin6_scope_id;
        memcpy(&sin->sin6_addr, &pjaddr->ipv6.sin6_addr, sizeof(sin->sin6_addr));
        addr->len = sizeof(struct sockaddr_in6);
    } else {
        memset(addr, 0, sizeof(*addr));
        return -1;
    }
    return 0;
}

References ast_sockaddr::len, and ast_sockaddr::ss.

Referenced by ast_sockaddr_pj_sockaddr_cmp().

ast_sockaddr_pj_sockaddr_cmp()

int ast_sockaddr_pj_sockaddr_cmp	(	const struct ast_sockaddr *	addr,
		const pj_sockaddr *	pjaddr
	)

Compare an ast_sockaddr to a pj_sockaddr.

Parameters

addr	pointer to ast_sockaddr structure
pjaddr	pointer to pj_sockaddr structure

Return values

-1	addr is lexicographically smaller than pjaddr
0	addr is equal to pjaddr
1	pjaddr is lexicographically smaller than addr

Definition at line 593 of file res_pjproject.c.

{
    struct ast_sockaddr temp_pjaddr;
    int rc = 0;
 
    rc = ast_sockaddr_from_pj_sockaddr(&temp_pjaddr, pjaddr);
    if (rc != 0) {
        return -1;
    }
 
    rc = ast_sockaddr_cmp(addr, &temp_pjaddr);
    if (DEBUG_ATLEAST(4)) {
        char *a_str = ast_strdupa(ast_sockaddr_stringify(addr));
        char *pj_str = ast_strdupa(ast_sockaddr_stringify(&temp_pjaddr));
        ast_debug(4, "Comparing %s -> %s  rc: %d\n", a_str, pj_str, rc);
    }
 
    return rc;
}

References ast_debug, ast_sockaddr_cmp(), ast_sockaddr_from_pj_sockaddr(), ast_sockaddr_stringify(), ast_strdupa, and DEBUG_ATLEAST.

Referenced by __rtp_recvfrom().

ast_sockaddr_to_pj_sockaddr()

int ast_sockaddr_to_pj_sockaddr	(	const struct ast_sockaddr *	addr,
		pj_sockaddr *	pjaddr
	)

Fill a pj_sockaddr from an ast_sockaddr.

Since

13.24.0

Parameters

addr	The source address to copy
pjaddr	The target address to receive the copied address

Return values

0	Success
-1	Failure

Definition at line 534 of file res_pjproject.c.

{
    if (addr->ss.ss_family == AF_INET) {
        struct sockaddr_in *sin = (struct sockaddr_in *) &addr->ss;
        pjaddr->ipv4.sin_family = pj_AF_INET();
#if defined(HAVE_PJPROJECT_BUNDLED) && !defined(HAVE_PJPROJECT_BUNDLED_OOT)
        pjaddr->ipv4.sin_addr = sin->sin_addr;
#else
        pjaddr->ipv4.sin_addr.s_addr = sin->sin_addr.s_addr;
#endif
        pjaddr->ipv4.sin_port   = sin->sin_port;
    } else if (addr->ss.ss_family == AF_INET6) {
        struct sockaddr_in6 *sin = (struct sockaddr_in6 *) &addr->ss;
        pjaddr->ipv6.sin6_family   = pj_AF_INET6();
        pjaddr->ipv6.sin6_port     = sin->sin6_port;
        pjaddr->ipv6.sin6_flowinfo = sin->sin6_flowinfo;
        pjaddr->ipv6.sin6_scope_id = sin->sin6_scope_id;
        memcpy(&pjaddr->ipv6.sin6_addr, &sin->sin6_addr, sizeof(pjaddr->ipv6.sin6_addr));
    } else {
        memset(pjaddr, 0, sizeof(*pjaddr));
        return -1;
    }
    return 0;
}

References ast_sockaddr::ss.