#include <stdlib.h>
#include <stdio.h>
#include <unistd.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/socket.h>
#include <string.h>
#include <errno.h>
#include <netinet/ip.h>
#include <sys/ioctl.h>
#include <net/if.h>
#include <zlib.h>
#include "asterisk.h"
#include "asterisk/file.h"
#include "asterisk/logger.h"
#include "asterisk/channel.h"
#include "asterisk/config.h"
#include "asterisk/options.h"
#include "asterisk/pbx.h"
#include "asterisk/module.h"
#include "asterisk/frame.h"
#include "asterisk/cli.h"
#include "asterisk/lock.h"
#include "asterisk/md5.h"
#include "asterisk/dundi.h"
#include "asterisk/sched.h"
#include "asterisk/io.h"
#include "asterisk/utils.h"
#include "asterisk/crypto.h"
#include "asterisk/astdb.h"
#include "asterisk/acl.h"
#include "asterisk/aes.h"
#include "dundi-parser.h"
Include dependency graph for pbx_dundi.c:
Go to the source code of this file.
Data Structures | |
| struct | dundi_hint_metadata |
| struct | dundi_mapping |
| struct | dundi_packet |
| struct | dundi_peer |
| struct | dundi_precache_queue |
| struct | dundi_query_state |
| struct | dundi_request |
| struct | dundi_transaction |
| struct | permission |
Defines | |
| #define | DUNDI_FLAG_INTERNAL_NOPARTIAL (1 << 17) |
| #define | DUNDI_MODEL_INBOUND (1 << 0) |
| #define | DUNDI_MODEL_OUTBOUND (1 << 1) |
| #define | DUNDI_MODEL_SYMMETRIC (DUNDI_MODEL_INBOUND | DUNDI_MODEL_OUTBOUND) |
| #define | DUNDI_SECRET_TIME DUNDI_DEFAULT_CACHE_TIME |
| #define | DUNDI_TIMING_HISTORY 10 |
| #define | FLAG_DEAD (1 << 1) |
| #define | FLAG_ENCRYPT (1 << 4) |
| #define | FLAG_FINAL (1 << 2) |
| #define | FLAG_ISQUAL (1 << 3) |
| #define | FLAG_ISREG (1 << 0) |
| #define | FLAG_SENDFULLKEY (1 << 5) |
| #define | FLAG_STOREHIST (1 << 6) |
| #define | FORMAT "%-12.12s %-12.12s %02d:%02d:%02d\n" |
| #define | FORMAT "%-12.12s %-7d %-12.12s %-10.10s %-5.5s %-25.25s\n" |
| #define | FORMAT "%-15s %-15s %-15s %-3.3d %-3.3d\n" |
| #define | FORMAT "%-16.16s:%5d %-5.5d %-5.5d %-3.3d %-3.3d %-3.3d\n" |
| #define | FORMAT "%-20.20s %-15.15s %s %-10.10s %-8.8s %-15.15s\n" |
| #define | FORMAT2 "%-12.12s %-12.12s %-10.10s\n" |
| #define | FORMAT2 "%-12.12s %-7.7s %-12.12s %-10.10s %-5.5s %-25.25s\n" |
| #define | FORMAT2 "%-15s %-15s %-15s %-3.3s %-3.3s\n" |
| #define | FORMAT2 "%-22.22s %-5.5s %-5.5s %-3.3s %-3.3s %-3.3s\n" |
| #define | FORMAT2 "%-20.20s %-15.15s %-10.10s %-8.8s %-15.15s\n" |
| #define | KEY_IN 1 |
| #define | KEY_OUT 0 |
| #define | MAX_OPTS 128 |
| #define | MAX_PACKET_SIZE 8192 |
| #define | MAX_RESULTS 64 |
Functions | |
| static void | abort_request (struct dundi_request *dr) |
| static int | ack_trans (struct dundi_transaction *trans, int iseqno) |
| static struct permission * | append_permission (struct permission *p, char *s, int allow) |
| static int | append_transaction (struct dundi_request *dr, struct dundi_peer *p, int ttl, dundi_eid *avoid[]) |
| static void | apply_peer (struct dundi_transaction *trans, struct dundi_peer *p) |
| AST_MUTEX_DEFINE_STATIC (pclock) | |
| AST_MUTEX_DEFINE_STATIC (peerlock) | |
| static unsigned long | avoid_crc32 (dundi_eid *avoid[]) |
| static void | build_iv (unsigned char *iv) |
| static void | build_mapping (char *name, char *value) |
| static void | build_peer (dundi_eid *eid, struct ast_variable *v, int *globalpcmode) |
| static void | build_secret (char *secret, int seclen) |
| static void | build_transactions (struct dundi_request *dr, int ttl, int order, int *foundcache, int *skipped, int blockempty, int nocache, int modeselect, dundi_eid *skip, dundi_eid *avoid[], int directs[]) |
| static int | cache_lookup (struct dundi_request *req, dundi_eid *peer_eid, unsigned long crc32, int *lowexpiration) |
| static int | cache_lookup_internal (time_t now, struct dundi_request *req, char *key, char *eid_str_full, int *lowexpiration) |
| static int | cache_save (dundi_eid *eidpeer, struct dundi_request *req, int start, int unaffected, int expiration, int push) |
| static int | cache_save_hint (dundi_eid *eidpeer, struct dundi_request *req, struct dundi_hint *hint, int expiration) |
| static void | cancel_request (struct dundi_request *dr) |
| static int | check_key (struct dundi_peer *peer, unsigned char *newkey, unsigned char *newsig, unsigned long keycrc32) |
| static void | check_password (void) |
| static int | check_request (struct dundi_request *dr) |
| static char * | complete_peer_4 (char *line, char *word, int pos, int state) |
| static char * | complete_peer_helper (char *line, char *word, int pos, int state, int rpos) |
| static struct dundi_transaction * | create_transaction (struct dundi_peer *p) |
| static int | decrypt_memcpy (unsigned char *dst, unsigned char *src, int len, unsigned char *iv, aes_decrypt_ctx *dcx) |
| char * | description (void) |
| Provides a description of the module. | |
| static void | destroy_map (struct dundi_mapping *map) |
| static void | destroy_packet (struct dundi_packet *pack, int needfree) |
| static void | destroy_packets (struct dundi_packet *p) |
| static void | destroy_peer (struct dundi_peer *peer) |
| static void | destroy_permissions (struct permission *p) |
| static void | destroy_trans (struct dundi_transaction *trans, int fromtimeout) |
| static int | discover_transactions (struct dundi_request *dr) |
| static int | do_autokill (void *data) |
| static int | do_qualify (void *data) |
| static int | do_register (void *data) |
| static int | do_register_expire (void *data) |
| static int | dundi_ack (struct dundi_transaction *trans, int final) |
| static int | dundi_answer_entity (struct dundi_transaction *trans, struct dundi_ies *ies, char *ccontext) |
| static int | dundi_answer_query (struct dundi_transaction *trans, struct dundi_ies *ies, char *ccontext) |
| static int | dundi_canmatch (struct ast_channel *chan, const char *context, const char *exten, int priority, const char *callerid, const char *data) |
| static void | dundi_debug_output (const char *data) |
| static struct dundi_hdr * | dundi_decrypt (struct dundi_transaction *trans, unsigned char *dst, int *dstlen, struct dundi_hdr *ohdr, struct dundi_encblock *src, int srclen) |
| static int | dundi_discover (struct dundi_transaction *trans) |
| static int | dundi_do_debug (int fd, int argc, char *argv[]) |
| static int | dundi_do_lookup (int fd, int argc, char *argv[]) |
| static int | dundi_do_precache (int fd, int argc, char *argv[]) |
| static int | dundi_do_query (int fd, int argc, char *argv[]) |
| static int | dundi_do_store_history (int fd, int argc, char *argv[]) |
| static int | dundi_encrypt (struct dundi_transaction *trans, struct dundi_packet *pack) |
| static void | dundi_error_output (const char *data) |
| static int | dundi_exec (struct ast_channel *chan, const char *context, const char *exten, int priority, const char *callerid, int newstack, const char *data) |
| static int | dundi_exists (struct ast_channel *chan, const char *context, const char *exten, int priority, const char *callerid, const char *data) |
| static int | dundi_flush (int fd, int argc, char *argv[]) |
| static int | dundi_helper (struct ast_channel *chan, const char *context, const char *exten, int priority, const char *data, int flag) |
| static void | dundi_ie_append_eid_appropriately (struct dundi_ie_data *ied, char *context, dundi_eid *eid, dundi_eid *us) |
| int | dundi_lookup (struct dundi_result *result, int maxret, struct ast_channel *chan, const char *dcontext, const char *number, int cbypass) |
| Lookup the given number in the given dundi context (or e164 if unspecified) using the given callerid (if specified) and return up to maxret results in the array specified. returns the number of results found or -1 on a hangup of teh channel. | |
| static int | dundi_lookup_exec (struct ast_channel *chan, void *data) |
| static int | dundi_lookup_internal (struct dundi_result *result, int maxret, struct ast_channel *chan, const char *dcontext, const char *number, int ttl, int blockempty, struct dundi_hint_metadata *md, int *expiration, int cybpass, int modeselect, dundi_eid *skip, dundi_eid *avoid[], int direct[]) |
| static int | dundi_lookup_local (struct dundi_result *dr, struct dundi_mapping *map, char *called_number, dundi_eid *us_eid, int anscnt, struct dundi_hint_metadata *hmd) |
| static void * | dundi_lookup_thread (void *data) |
| static int | dundi_matchmore (struct ast_channel *chan, const char *context, const char *exten, int priority, const char *callerid, const char *data) |
| static int | dundi_no_debug (int fd, int argc, char *argv[]) |
| static int | dundi_no_store_history (int fd, int argc, char *argv[]) |
| int | dundi_precache (const char *context, const char *number) |
| Pre-cache to push upstream peers. | |
| static void | dundi_precache_full (void) |
| static int | dundi_precache_internal (const char *context, const char *number, int ttl, dundi_eid *avoids[]) |
| static void * | dundi_precache_thread (void *data) |
| static int | dundi_prop_precache (struct dundi_transaction *trans, struct dundi_ies *ies, char *ccontext) |
| static int | dundi_query (struct dundi_transaction *trans) |
| int | dundi_query_eid (struct dundi_entity_info *dei, const char *dcontext, dundi_eid eid) |
| Retrieve information on a specific EID. | |
| static int | dundi_query_eid_internal (struct dundi_entity_info *dei, const char *dcontext, dundi_eid *eid, struct dundi_hint_metadata *hmd, int ttl, int blockempty, dundi_eid *avoid[]) |
| static void * | dundi_query_thread (void *data) |
| static void | dundi_reject (struct dundi_hdr *h, struct sockaddr_in *sin) |
| static int | dundi_rexmit (void *data) |
| static int | dundi_send (struct dundi_transaction *trans, int cmdresp, int flags, int final, struct dundi_ie_data *ied) |
| static int | dundi_show_entityid (int fd, int argc, char *argv[]) |
| static int | dundi_show_mappings (int fd, int argc, char *argv[]) |
| static int | dundi_show_peer (int fd, int argc, char *argv[]) |
| static int | dundi_show_peers (int fd, int argc, char *argv[]) |
| static int | dundi_show_precache (int fd, int argc, char *argv[]) |
| static int | dundi_show_requests (int fd, int argc, char *argv[]) |
| static int | dundi_show_trans (int fd, int argc, char *argv[]) |
| static int | dundi_xmit (struct dundi_packet *pack) |
| static char * | dundifunc_read (struct ast_channel *chan, char *cmd, char *data, char *buf, size_t len) |
| static int | encrypt_memcpy (unsigned char *dst, unsigned char *src, int len, unsigned char *iv, aes_encrypt_ctx *ecx) |
| static struct dundi_peer * | find_peer (dundi_eid *eid) |
| static struct dundi_transaction * | find_transaction (struct dundi_hdr *hdr, struct sockaddr_in *sin) |
| static int | get_trans_id (void) |
| static int | handle_command_response (struct dundi_transaction *trans, struct dundi_hdr *hdr, int datalen, int encrypted) |
| static int | handle_frame (struct dundi_hdr *h, struct sockaddr_in *sin, int datalen) |
| static int | has_permission (struct permission *ps, char *cont) |
| char * | key () |
| Returns the ASTERISK_GPL_KEY. | |
| int | load_module (void) |
| Initialize the module. | |
| static void | load_password (void) |
| static void | mark_mappings (void) |
| static void | mark_peers (void) |
| static char * | model2str (int model) |
| static void * | network_thread (void *ignore) |
| static int | optimize_transactions (struct dundi_request *dr, int order) |
| static void | populate_addr (struct dundi_peer *peer, dundi_eid *eid) |
| static int | precache_trans (struct dundi_transaction *trans, struct dundi_mapping *maps, int mapcount, int *minexp, int *foundanswers) |
| static int | precache_transactions (struct dundi_request *dr, struct dundi_mapping *maps, int mapcount, int *expiration, int *foundanswers) |
| static void * | process_precache (void *ign) |
| static void | prune_mappings (void) |
| static void | prune_peers (void) |
| static void | qualify_peer (struct dundi_peer *peer, int schedonly) |
| static int | query_transactions (struct dundi_request *dr) |
| static int | register_request (struct dundi_request *dr, struct dundi_request **pending) |
| int | reload (void) |
| Reload stuff. | |
| static void | reschedule_precache (const char *number, const char *context, int expiration) |
| static int | rescomp (const void *a, const void *b) |
| static void | reset_global_eid (void) |
| static int | reset_transaction (struct dundi_transaction *trans) |
| static void | save_secret (const char *newkey, const char *oldkey) |
| static int | set_config (char *config_file, struct sockaddr_in *sin) |
| static int | socket_read (int *id, int fd, short events, void *cbdata) |
| static void | sort_results (struct dundi_result *results, int count) |
| static int | start_network_thread (void) |
| static int | str2tech (char *str) |
| static char * | tech2str (int tech) |
| int | unload_module (void) |
| Cleanup all module structures, sockets, etc. | |
| static void | unregister_request (struct dundi_request *dr) |
| static int | update_key (struct dundi_peer *peer) |
| int | usecount (void) |
| Provides a usecount. | |
Variables | |
| dundi_transaction * | alltrans |
| static char * | app = "DUNDiLookup" |
| char | ast_config_AST_KEY_DIR [] |
| static int | authdebug = 0 |
| static struct ast_cli_entry | cli_debug |
| static struct ast_cli_entry | cli_flush |
| static struct ast_cli_entry | cli_lookup |
| static struct ast_cli_entry | cli_no_debug |
| static struct ast_cli_entry | cli_no_store_history |
| static struct ast_cli_entry | cli_precache |
| static struct ast_cli_entry | cli_queryeid |
| static struct ast_cli_entry | cli_show_entityid |
| static struct ast_cli_entry | cli_show_mappings |
| static struct ast_cli_entry | cli_show_peer |
| static struct ast_cli_entry | cli_show_peers |
| static struct ast_cli_entry | cli_show_precache |
| static struct ast_cli_entry | cli_show_requests |
| static struct ast_cli_entry | cli_show_trans |
| static struct ast_cli_entry | cli_store_history |
| static char | country [80] |
| static char | cursecret [80] |
| static char | debug_usage [] |
| static int | default_expiration = 60 |
| static char | dept [80] |
| static char * | descrip |
| static int | dundi_cache_time = DUNDI_DEFAULT_CACHE_TIME |
| static struct ast_custom_function | dundi_function |
| static int | dundi_key_ttl = DUNDI_DEFAULT_KEY_EXPIRE |
| static struct ast_switch | dundi_switch |
| static int | dundi_ttl = DUNDI_DEFAULT_TTL |
| static int | dundidebug = 0 |
| static char | email [80] |
| static dundi_eid | empty_eid = { { 0, 0, 0, 0, 0, 0 } } |
| static char | flush_usage [] |
| static int | global_autokilltimeout = 0 |
| static dundi_eid | global_eid |
| static int | global_storehistory = 0 |
| static struct io_context * | io |
| static char | ipaddr [80] |
| LOCAL_USER_DECL | |
| static char | locality [80] |
| static char | lookup_usage [] |
| static struct dundi_mapping * | mappings |
| static int | netsocket = -1 |
| static pthread_t | netthreadid = AST_PTHREADT_NULL |
| static char | no_debug_usage [] |
| static char | no_store_history_usage [] |
| static char | org [80] |
| static struct dundi_precache_queue * | pcq |
| static struct dundi_peer * | peers |
| static char | phone [80] |
| static char | precache_usage [] |
| static pthread_t | precachethreadid = AST_PTHREADT_NULL |
| static char | query_usage [] |
| dundi_request * | requests |
| static time_t | rotatetime |
| static struct sched_context * | sched |
| static char | secretpath [80] |
| static char | show_entityid_usage [] |
| static char | show_mappings_usage [] |
| static char | show_peer_usage [] |
| static char | show_peers_usage [] |
| static char | show_precache_usage [] |
| static char | show_requests_usage [] |
| static char | show_trans_usage [] |
| STANDARD_LOCAL_USER | |
| static char | stateprov [80] |
| static char | store_history_usage [] |
| static char * | synopsis = "Look up a number with DUNDi" |
| static char * | tdesc = "Distributed Universal Number Discovery (DUNDi)" |
| static int | tos = 0 |
Definition in file pbx_dundi.c.
| #define DUNDI_FLAG_INTERNAL_NOPARTIAL (1 << 17) |
Definition at line 111 of file pbx_dundi.c.
Referenced by build_mapping(), and dundi_lookup_local().
| #define DUNDI_MODEL_INBOUND (1 << 0) |
Definition at line 96 of file pbx_dundi.c.
Referenced by build_peer(), dundi_show_peer(), handle_command_response(), and model2str().
| #define DUNDI_MODEL_OUTBOUND (1 << 1) |
Definition at line 97 of file pbx_dundi.c.
Referenced by build_peer(), build_transactions(), dundi_show_peer(), model2str(), and set_config().
| #define DUNDI_MODEL_SYMMETRIC (DUNDI_MODEL_INBOUND | DUNDI_MODEL_OUTBOUND) |
| #define DUNDI_SECRET_TIME DUNDI_DEFAULT_CACHE_TIME |
| #define DUNDI_TIMING_HISTORY 10 |
Definition at line 101 of file pbx_dundi.c.
Referenced by destroy_trans(), dundi_flush(), and dundi_show_peer().
| #define FLAG_DEAD (1 << 1) |
Definition at line 104 of file pbx_dundi.c.
Referenced by dundi_lookup_thread(), dundi_precache_thread(), dundi_query_thread(), and precache_transactions().
| #define FLAG_ENCRYPT (1 << 4) |
Definition at line 107 of file pbx_dundi.c.
Referenced by apply_peer(), dundi_send(), and handle_command_response().
| #define FLAG_FINAL (1 << 2) |
Definition at line 105 of file pbx_dundi.c.
Referenced by dundi_send(), handle_frame(), and reset_transaction().
| #define FLAG_ISQUAL (1 << 3) |
Definition at line 106 of file pbx_dundi.c.
Referenced by destroy_trans(), dundi_rexmit(), and qualify_peer().
| #define FLAG_ISREG (1 << 0) |
| #define FLAG_SENDFULLKEY (1 << 5) |
Definition at line 108 of file pbx_dundi.c.
Referenced by create_transaction(), and dundi_encrypt().
| #define FLAG_STOREHIST (1 << 6) |
Definition at line 109 of file pbx_dundi.c.
Referenced by create_transaction(), and destroy_trans().
| #define FORMAT "%-12.12s %-12.12s %02d:%02d:%02d\n" |
| #define FORMAT "%-12.12s %-7d %-12.12s %-10.10s %-5.5s %-25.25s\n" |
| #define FORMAT "%-15s %-15s %-15s %-3.3d %-3.3d\n" |
| #define FORMAT "%-16.16s:%5d %-5.5d %-5.5d %-3.3d %-3.3d %-3.3d\n" |
| #define FORMAT "%-20.20s %-15.15s %s %-10.10s %-8.8s %-15.15s\n" |
| #define FORMAT2 "%-12.12s %-12.12s %-10.10s\n" |
| #define FORMAT2 "%-12.12s %-7.7s %-12.12s %-10.10s %-5.5s %-25.25s\n" |
| #define FORMAT2 "%-15s %-15s %-15s %-3.3s %-3.3s\n" |
| #define FORMAT2 "%-22.22s %-5.5s %-5.5s %-3.3s %-3.3s %-3.3s\n" |
| #define FORMAT2 "%-20.20s %-15.15s %-10.10s %-8.8s %-15.15s\n" |
| #define KEY_IN 1 |
Definition at line 120 of file pbx_dundi.c.
| #define KEY_OUT 0 |
Definition at line 119 of file pbx_dundi.c.
| #define MAX_OPTS 128 |
| #define MAX_PACKET_SIZE 8192 |
| #define MAX_RESULTS 64 |
Definition at line 74 of file pbx_dundi.c.
Referenced by dundi_do_lookup(), dundi_exec(), dundi_helper(), dundi_lookup_exec(), dundi_lookup_thread(), dundi_precache_internal(), dundi_prop_precache(), dundifunc_read(), and precache_trans().
| static void abort_request | ( | struct dundi_request * | dr | ) | [static] |
Definition at line 3386 of file pbx_dundi.c.
References ast_mutex_lock(), ast_mutex_unlock(), destroy_trans(), and dr.
Referenced by dundi_lookup_internal().
03387 { 03388 ast_mutex_lock(&peerlock); 03389 while(dr->trans) 03390 destroy_trans(dr->trans, 0); 03391 ast_mutex_unlock(&peerlock); 03392 }
| static int ack_trans | ( | struct dundi_transaction * | trans, | |
| int | iseqno | |||
| ) | [static] |
Definition at line 1924 of file pbx_dundi.c.
References ast_log(), ast_sched_del(), dundi_transaction::autokillid, destroy_packet(), destroy_packets(), dundi_packet::h, dundi_transaction::lasttrans, LOG_WARNING, dundi_packet::next, dundi_hdr::oseqno, and dundi_transaction::packets.
Referenced by handle_frame().
01925 { 01926 /* Ack transmitted packet corresponding to iseqno */ 01927 struct dundi_packet *pack; 01928 pack = trans->packets; 01929 while(pack) { 01930 if ((pack->h->oseqno + 1) % 255 == iseqno) { 01931 destroy_packet(pack, 0); 01932 if (trans->lasttrans) { 01933 ast_log(LOG_WARNING, "Whoa, there was still a last trans?\n"); 01934 destroy_packets(trans->lasttrans); 01935 } 01936 trans->lasttrans = pack; 01937 if (trans->autokillid > -1) 01938 ast_sched_del(sched, trans->autokillid); 01939 trans->autokillid = -1; 01940 return 1; 01941 } 01942 pack = pack->next; 01943 } 01944 return 0; 01945 }
| static struct permission* append_permission | ( | struct permission * | p, | |
| char * | s, | |||
| int | allow | |||
| ) | [static] |
Definition at line 4102 of file pbx_dundi.c.
References malloc, and permission::next.
Referenced by build_peer().
04103 { 04104 struct permission *start; 04105 start = p; 04106 if (p) { 04107 while(p->next) 04108 p = p->next; 04109 } 04110 if (p) { 04111 p->next = malloc(sizeof(struct permission) + strlen(s) + 1); 04112 p = p->next; 04113 } else { 04114 p = malloc(sizeof(struct permission) + strlen(s) + 1); 04115 } 04116 if (p) { 04117 memset(p, 0, sizeof(struct permission)); 04118 memcpy(p->name, s, strlen(s) + 1); 04119 p->allow = allow; 04120 } 04121 return start ? start : p; 04122 }
| static int append_transaction | ( | struct dundi_request * | dr, | |
| struct dundi_peer * | p, | |||
| int | ttl, | |||
| dundi_eid * | avoid[] | |||
| ) | [static] |
Definition at line 3339 of file pbx_dundi.c.
References dundi_peer::addr, ast_log(), ast_strlen_zero(), create_transaction(), dr, dundi_eid_to_str(), DUNDI_MAX_STACK, dundi_peer::eid, dundi_transaction::eidcount, dundi_transaction::eids, dundi_peer::lastms, LOG_DEBUG, dundi_peer::maxms, dundi_transaction::next, dundi_transaction::parent, and dundi_transaction::ttl.
Referenced by build_transactions().
03340 { 03341 struct dundi_transaction *trans; 03342 int x; 03343 char eid_str[20]; 03344 char eid_str2[20]; 03345 /* Ignore if not registered */ 03346 if (!p->addr.sin_addr.s_addr) 03347 return 0; 03348 if (p->maxms && ((p->lastms < 0) || (p->lastms >= p->maxms))) 03349 return 0; 03350 if (ast_strlen_zero(dr->number)) 03351 ast_log(LOG_DEBUG, "Will query peer '%s' for '%s' (context '%s')\n", dundi_eid_to_str(eid_str, sizeof(eid_str), &p->eid), dundi_eid_to_str(eid_str2, sizeof(eid_str2), &dr->query_eid), dr->dcontext); 03352 else 03353 ast_log(LOG_DEBUG, "Will query peer '%s' for '%s@%s'\n", dundi_eid_to_str(eid_str, sizeof(eid_str), &p->eid), dr->number, dr->dcontext); 03354 trans = create_transaction(p); 03355 if (!trans) 03356 return -1; 03357 trans->next = dr->trans; 03358 trans->parent = dr; 03359 trans->ttl = ttl; 03360 for (x=0;avoid[x] && (x <DUNDI_MAX_STACK);x++) 03361 trans->eids[x] = *avoid[x]; 03362 trans->eidcount = x; 03363 dr->trans = trans; 03364 return 0; 03365 }
| static void apply_peer | ( | struct dundi_transaction * | trans, | |
| struct dundi_peer * | p | |||
| ) | [static] |
Definition at line 1267 of file pbx_dundi.c.
References dundi_peer::addr, dundi_transaction::addr, ast_set_flag, ast_strlen_zero(), dundi_transaction::autokilltimeout, DUNDI_DEFAULT_RETRANS_TIMER, dundi_peer::eid, FLAG_ENCRYPT, global_autokilltimeout, dundi_peer::inkey, dundi_peer::lastms, dundi_peer::maxms, dundi_transaction::retranstimer, dundi_transaction::them_eid, dundi_peer::us_eid, and dundi_transaction::us_eid.
Referenced by create_transaction().
01268 { 01269 if (!trans->addr.sin_addr.s_addr) 01270 memcpy(&trans->addr, &p->addr, sizeof(trans->addr)); 01271 trans->us_eid = p->us_eid; 01272 trans->them_eid = p->eid; 01273 /* Enable encryption if appropriate */ 01274 if (!ast_strlen_zero(p->inkey)) 01275 ast_set_flag(trans, FLAG_ENCRYPT); 01276 if (p->maxms) { 01277 trans->autokilltimeout = p->maxms; 01278 trans->retranstimer = DUNDI_DEFAULT_RETRANS_TIMER; 01279 if (p->lastms > 1) { 01280 trans->retranstimer = p->lastms * 2; 01281 /* Keep it from being silly */ 01282 if (trans->retranstimer < 150) 01283 trans->retranstimer = 150; 01284 } 01285 if (trans->retranstimer > DUNDI_DEFAULT_RETRANS_TIMER) 01286 trans->retranstimer = DUNDI_DEFAULT_RETRANS_TIMER; 01287 } else 01288 trans->autokilltimeout = global_autokilltimeout; 01289 }
| AST_MUTEX_DEFINE_STATIC | ( | pclock | ) |
| AST_MUTEX_DEFINE_STATIC | ( | peerlock | ) |
| static unsigned long avoid_crc32 | ( | dundi_eid * | avoid[] | ) | [static] |
Definition at line 3524 of file pbx_dundi.c.
References dundi_request::crc32.
Referenced by dundi_lookup_internal().
03525 { 03526 /* Idea is that we're calculating a checksum which is independent of 03527 the order that the EID's are listed in */ 03528 unsigned long acrc32 = 0; 03529 int x; 03530 for (x=0;avoid[x];x++) { 03531 /* Order doesn't matter */ 03532 if (avoid[x+1]) { 03533 acrc32 ^= crc32(0L, (unsigned char *)avoid[x], sizeof(dundi_eid)); 03534 } 03535 } 03536 return acrc32; 03537 }
| static void build_iv | ( | unsigned char * | iv | ) | [static] |
Definition at line 503 of file pbx_dundi.c.
Referenced by build_secret(), dundi_encrypt(), and update_key().
00504 { 00505 /* XXX Would be nice to be more random XXX */ 00506 unsigned int *fluffy; 00507 int x; 00508 fluffy = (unsigned int *)(iv); 00509 for (x=0;x<4;x++) 00510 fluffy[x] = rand(); 00511 }
| static void build_mapping | ( | char * | name, | |
| char * | value | |||
| ) | [static] |
Definition at line 4126 of file pbx_dundi.c.
References ast_log(), ast_strdupa, ast_strlen_zero(), dundi_mapping::dead, DUNDI_FLAG_COMMERCIAL, DUNDI_FLAG_INTERNAL_NOPARTIAL, DUNDI_FLAG_MOBILE, DUNDI_FLAG_NOCOMUNSOLICIT, DUNDI_FLAG_NOUNSOLICITED, DUNDI_FLAG_RESIDENTIAL, LOG_WARNING, malloc, map, mappings, MAX_OPTS, str2tech(), and t.
Referenced by set_config().
04127 { 04128 char *t, *fields[