Distributed Universal Number Discovery (DUNDi) More...
#include "asterisk.h"
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include "asterisk/frame.h"
#include "asterisk/utils.h"
#include "asterisk/dundi.h"
#include "dundi-parser.h"
Go to the source code of this file.
Data Structures | |
struct | dundi_ie |
Functions | |
static void | dump_answer (char *output, int maxlen, void *value, int len) |
static void | dump_byte (char *output, int maxlen, void *value, int len) |
static void | dump_cause (char *output, int maxlen, void *value, int len) |
static void | dump_cbypass (char *output, int maxlen, void *value, int len) |
static void | dump_eid (char *output, int maxlen, void *value, int len) |
static void | dump_encrypted (char *output, int maxlen, void *value, int len) |
static void | dump_hint (char *output, int maxlen, void *value, int len) |
static void | dump_ies (unsigned char *iedata, int spaces, int len) |
static void | dump_int (char *output, int maxlen, void *value, int len) |
static void | dump_raw (char *output, int maxlen, void *value, int len) |
static void | dump_short (char *output, int maxlen, void *value, int len) |
static void | dump_string (char *output, int maxlen, void *value, int len) |
char * | dundi_eid_to_str_short (char *s, int maxlen, dundi_eid *eid) |
int | dundi_eid_zero (dundi_eid *eid) |
char * | dundi_flags2str (char *buf, int bufsiz, int flags) |
char * | dundi_hint2str (char *buf, int bufsiz, int flags) |
const char * | dundi_ie2str (int ie) |
int | dundi_ie_append (struct dundi_ie_data *ied, unsigned char ie) |
int | dundi_ie_append_addr (struct dundi_ie_data *ied, unsigned char ie, struct sockaddr_in *sin) |
int | dundi_ie_append_answer (struct dundi_ie_data *ied, unsigned char ie, dundi_eid *eid, unsigned char protocol, unsigned short flags, unsigned short weight, char *data) |
int | dundi_ie_append_byte (struct dundi_ie_data *ied, unsigned char ie, unsigned char dat) |
int | dundi_ie_append_cause (struct dundi_ie_data *ied, unsigned char ie, unsigned char cause, char *data) |
int | dundi_ie_append_eid (struct dundi_ie_data *ied, unsigned char ie, dundi_eid *eid) |
int | dundi_ie_append_encdata (struct dundi_ie_data *ied, unsigned char ie, unsigned char *iv, void *data, int datalen) |
int | dundi_ie_append_hint (struct dundi_ie_data *ied, unsigned char ie, unsigned short flags, char *data) |
int | dundi_ie_append_int (struct dundi_ie_data *ied, unsigned char ie, unsigned int value) |
int | dundi_ie_append_raw (struct dundi_ie_data *ied, unsigned char ie, void *data, int datalen) |
int | dundi_ie_append_short (struct dundi_ie_data *ied, unsigned char ie, unsigned short value) |
int | dundi_ie_append_str (struct dundi_ie_data *ied, unsigned char ie, char *str) |
int | dundi_parse_ies (struct dundi_ies *ies, unsigned char *data, int datalen) |
void | dundi_set_error (void(*func)(const char *)) |
void | dundi_set_output (void(*func)(const char *)) |
void | dundi_showframe (struct dundi_hdr *fhi, int rx, struct sockaddr_in *sin, int datalen) |
int | dundi_str_short_to_eid (dundi_eid *eid, const char *s) |
static void | internalerror (const char *str) |
static void | internaloutput (const char *str) |
static char * | proto2str (int proto, char *buf, int bufsiz) |
Variables | |
static void(* | errorf )(const char *str) = internalerror |
static struct dundi_ie | infoelts [] |
static void(* | outputf )(const char *str) = internaloutput |
Distributed Universal Number Discovery (DUNDi)
Definition in file dundi-parser.c.
static void dump_answer | ( | char * | output, |
int | maxlen, | ||
void * | value, | ||
int | len | ||
) | [static] |
Definition at line 281 of file dundi-parser.c.
References ast_eid_to_str(), dundi_answer::data, dundi_flags2str(), dundi_answer::eid, dundi_answer::flags, proto2str(), dundi_answer::protocol, and dundi_answer::weight.
{ struct dundi_answer *answer; char proto[40]; char flags[40]; char eid_str[40]; char tmp[512]=""; int datalen; if (len < sizeof(*answer)) { snprintf(output, maxlen, "Invalid Answer"); return; } answer = (struct dundi_answer *)(value); datalen = len - offsetof(struct dundi_answer, data); if (datalen > sizeof(tmp) - 1) datalen = sizeof(tmp) - 1; memcpy(tmp, answer->data, datalen); tmp[datalen] = '\0'; ast_eid_to_str(eid_str, sizeof(eid_str), &answer->eid); snprintf(output, maxlen, "[%s] %d <%s/%s> from [%s]", dundi_flags2str(flags, sizeof(flags), ntohs(answer->flags)), ntohs(answer->weight), proto2str(answer->protocol, proto, sizeof(proto)), tmp, eid_str); }
static void dump_byte | ( | char * | output, |
int | maxlen, | ||
void * | value, | ||
int | len | ||
) | [static] |
Definition at line 213 of file dundi-parser.c.
References ast_copy_string().
{ if (len == (int)sizeof(unsigned char)) snprintf(output, maxlen, "%d", *((unsigned char *)value)); else ast_copy_string(output, "Invalid BYTE", maxlen); }
static void dump_cause | ( | char * | output, |
int | maxlen, | ||
void * | value, | ||
int | len | ||
) | [static] |
Definition at line 156 of file dundi-parser.c.
References ARRAY_LEN, ast_strlen_zero(), cause, dundi_cause::causecode, causes, dundi_cause::desc, and desc.
{ static char *causes[] = { "SUCCESS", "GENERAL", "DYNAMIC", "NOAUTH" , }; char tmp2[256]; struct dundi_cause *cause; int datalen; int causecode; if (len < sizeof(*cause)) { snprintf(output, maxlen, "<invalid contents>"); return; } cause = (struct dundi_cause*) value; causecode = cause->causecode; datalen = len - offsetof(struct dundi_cause, desc); if (datalen > sizeof(tmp2) - 1) datalen = sizeof(tmp2) - 1; memcpy(tmp2, cause->desc, datalen); tmp2[datalen] = '\0'; if (causecode < ARRAY_LEN(causes)) { if (ast_strlen_zero(tmp2)) snprintf(output, maxlen, "%s", causes[causecode]); else snprintf(output, maxlen, "%s: %s", causes[causecode], tmp2); } else { if (ast_strlen_zero(tmp2)) snprintf(output, maxlen, "%d", causecode); else snprintf(output, maxlen, "%d: %s", causecode, tmp2); } }
static void dump_cbypass | ( | char * | output, |
int | maxlen, | ||
void * | value, | ||
int | len | ||
) | [static] |
Definition at line 95 of file dundi-parser.c.
{
snprintf(output, maxlen, "Bypass Caches");
}
static void dump_eid | ( | char * | output, |
int | maxlen, | ||
void * | value, | ||
int | len | ||
) | [static] |
Definition at line 100 of file dundi-parser.c.
References ast_eid_to_str().
{ if (len == 6) ast_eid_to_str(output, maxlen, (dundi_eid *)value); else snprintf(output, maxlen, "Invalid EID len %d", len); }
static void dump_encrypted | ( | char * | output, |
int | maxlen, | ||
void * | value, | ||
int | len | ||
) | [static] |
Definition at line 312 of file dundi-parser.c.
{ char iv[33]; int x; if ((len > 16) && !(len % 16)) { /* Build up IV */ for (x=0;x<16;x++) { snprintf(iv + (x << 1), 3, "%02x", ((unsigned char *)value)[x]); } snprintf(output, maxlen, "[IV %s] %d encrypted blocks\n", iv, len / 16); } else snprintf(output, maxlen, "Invalid Encrypted Datalen %d", len); }
static void dump_hint | ( | char * | output, |
int | maxlen, | ||
void * | value, | ||
int | len | ||
) | [static] |
Definition at line 128 of file dundi-parser.c.
References ast_strlen_zero(), dundi_hint::data, ast_frame::datalen, dundi_hint2str(), and dundi_hint::flags.
{ char tmp2[256]; char tmp3[256]; int datalen; struct dundi_hint *hint; if (len < sizeof(*hint)) { snprintf(output, maxlen, "<invalid contents>"); return; } hint = (struct dundi_hint *) value;; datalen = len - offsetof(struct dundi_hint, data); if (datalen > sizeof(tmp3) - 1) datalen = sizeof(tmp3) - 1; memcpy(tmp3, hint->data, datalen); tmp3[datalen] = '\0'; dundi_hint2str(tmp2, sizeof(tmp2), ntohs(hint->flags)); if (ast_strlen_zero(tmp3)) snprintf(output, maxlen, "[%s]", tmp2); else snprintf(output, maxlen, "[%s] %s", tmp2, tmp3); }
static void dump_ies | ( | unsigned char * | iedata, |
int | spaces, | ||
int | len | ||
) | [static] |
Definition at line 380 of file dundi-parser.c.
References ARRAY_LEN, dundi_ie::dump, DUNDI_IE_ENCDATA, infoelts, name, and outputf.
Referenced by dundi_showframe().
{ int ielen; int ie; int x; int found; char interp[1024]; char tmp[1024]; if (len < 2) return; while(len >= 2) { ie = iedata[0]; ielen = iedata[1]; /* Encrypted data is the remainder */ if (ie == DUNDI_IE_ENCDATA) ielen = len - 2; if (ielen + 2> len) { snprintf(tmp, (int)sizeof(tmp), "Total IE length of %d bytes exceeds remaining frame length of %d bytes\n", ielen + 2, len); outputf(tmp); return; } found = 0; for (x = 0; x < ARRAY_LEN(infoelts); x++) { if (infoelts[x].ie == ie) { if (infoelts[x].dump) { infoelts[x].dump(interp, (int)sizeof(interp), iedata + 2, ielen); snprintf(tmp, (int)sizeof(tmp), " %s%-15.15s : %s\n", (spaces ? " " : "" ), infoelts[x].name, interp); outputf(tmp); } else { if (ielen) snprintf(interp, (int)sizeof(interp), "%d bytes", ielen); else strcpy(interp, "Present"); snprintf(tmp, (int)sizeof(tmp), " %s%-15.15s : %s\n", (spaces ? " " : "" ), infoelts[x].name, interp); outputf(tmp); } found++; } } if (!found) { snprintf(tmp, (int)sizeof(tmp), " %sUnknown IE %03d : Present\n", (spaces ? " " : "" ), ie); outputf(tmp); } iedata += (2 + ielen); len -= (2 + ielen); } outputf("\n"); }
static void dump_int | ( | char * | output, |
int | maxlen, | ||
void * | value, | ||
int | len | ||
) | [static] |
Definition at line 197 of file dundi-parser.c.
References ast_copy_string().
{ if (len == (int)sizeof(unsigned int)) snprintf(output, maxlen, "%lu", (unsigned long)ntohl(*((unsigned int *)value))); else ast_copy_string(output, "Invalid INT", maxlen); }
static void dump_raw | ( | char * | output, |
int | maxlen, | ||
void * | value, | ||
int | len | ||
) | [static] |
Definition at line 326 of file dundi-parser.c.
References len().
{ int x; unsigned char *u = value; output[maxlen - 1] = '\0'; strcpy(output, "[ "); for (x=0;x<len;x++) { snprintf(output + strlen(output), maxlen - strlen(output) - 1, "%02x ", u[x]); } strncat(output + strlen(output), "]", maxlen - strlen(output) - 1); }
static void dump_short | ( | char * | output, |
int | maxlen, | ||
void * | value, | ||
int | len | ||
) | [static] |
Definition at line 205 of file dundi-parser.c.
References ast_copy_string().
{ if (len == (int)sizeof(unsigned short)) snprintf(output, maxlen, "%d", ntohs(*((unsigned short *)value))); else ast_copy_string(output, "Invalid SHORT", maxlen); }
static void dump_string | ( | char * | output, |
int | maxlen, | ||
void * | value, | ||
int | len | ||
) | [static] |
Definition at line 87 of file dundi-parser.c.
char* dundi_eid_to_str_short | ( | char * | s, |
int | maxlen, | ||
dundi_eid * | eid | ||
) |
Definition at line 51 of file dundi-parser.c.
References ast_eid::eid, and s.
Referenced by cache_lookup(), cache_save(), cache_save_hint(), and handle_command_response().
int dundi_eid_zero | ( | dundi_eid * | eid | ) |
Definition at line 79 of file dundi-parser.c.
References ARRAY_LEN, and ast_eid::eid.
Referenced by build_transactions(), dundi_discover(), dundi_query(), dundi_show_requests(), and precache_trans().
char* dundi_flags2str | ( | char * | buf, |
int | bufsiz, | ||
int | flags | ||
) |
Definition at line 243 of file dundi-parser.c.
References ast_strlen_zero(), buf, DUNDI_FLAG_CANMATCH, DUNDI_FLAG_COMMERCIAL, DUNDI_FLAG_EXISTS, DUNDI_FLAG_IGNOREPAT, DUNDI_FLAG_MATCHMORE, DUNDI_FLAG_MOBILE, DUNDI_FLAG_NOCOMUNSOLICIT, DUNDI_FLAG_NOUNSOLICITED, and DUNDI_FLAG_RESIDENTIAL.
Referenced by cache_lookup_internal(), dump_answer(), dundi_do_lookup(), and dundi_show_mappings().
{ strcpy(buf, ""); buf[bufsiz-1] = '\0'; if (flags & DUNDI_FLAG_EXISTS) { strncat(buf, "EXISTS|", bufsiz - strlen(buf) - 1); } if (flags & DUNDI_FLAG_MATCHMORE) { strncat(buf, "MATCHMORE|", bufsiz - strlen(buf) - 1); } if (flags & DUNDI_FLAG_CANMATCH) { strncat(buf, "CANMATCH|", bufsiz - strlen(buf) - 1); } if (flags & DUNDI_FLAG_IGNOREPAT) { strncat(buf, "IGNOREPAT|", bufsiz - strlen(buf) - 1); } if (flags & DUNDI_FLAG_RESIDENTIAL) { strncat(buf, "RESIDENCE|", bufsiz - strlen(buf) - 1); } if (flags & DUNDI_FLAG_COMMERCIAL) { strncat(buf, "COMMERCIAL|", bufsiz - strlen(buf) - 1); } if (flags & DUNDI_FLAG_MOBILE) { strncat(buf, "MOBILE", bufsiz - strlen(buf) - 1); } if (flags & DUNDI_FLAG_NOUNSOLICITED) { strncat(buf, "NOUNSLCTD|", bufsiz - strlen(buf) - 1); } if (flags & DUNDI_FLAG_NOCOMUNSOLICIT) { strncat(buf, "NOCOMUNSLTD|", bufsiz - strlen(buf) - 1); } /* Get rid of trailing | */ if (ast_strlen_zero(buf)) strcpy(buf, "NONE|"); buf[strlen(buf)-1] = '\0'; return buf; }
char* dundi_hint2str | ( | char * | buf, |
int | bufsiz, | ||
int | flags | ||
) |
Definition at line 108 of file dundi-parser.c.
References ast_strlen_zero(), buf, DUNDI_HINT_DONT_ASK, DUNDI_HINT_TTL_EXPIRED, and DUNDI_HINT_UNAFFECTED.
Referenced by dump_hint().
{ strcpy(buf, ""); buf[bufsiz-1] = '\0'; if (flags & DUNDI_HINT_TTL_EXPIRED) { strncat(buf, "TTLEXPIRED|", bufsiz - strlen(buf) - 1); } if (flags & DUNDI_HINT_DONT_ASK) { strncat(buf, "DONTASK|", bufsiz - strlen(buf) - 1); } if (flags & DUNDI_HINT_UNAFFECTED) { strncat(buf, "UNAFFECTED|", bufsiz - strlen(buf) - 1); } /* Get rid of trailing | */ if (ast_strlen_zero(buf)) strcpy(buf, "NONE|"); buf[strlen(buf)-1] = '\0'; return buf; }
const char* dundi_ie2str | ( | int | ie | ) |
Definition at line 370 of file dundi-parser.c.
References ARRAY_LEN, infoelts, and dundi_ie::name.
Referenced by dundi_ie_append_answer(), dundi_ie_append_cause(), dundi_ie_append_encdata(), dundi_ie_append_hint(), dundi_ie_append_raw(), and dundi_parse_ies().
int dundi_ie_append | ( | struct dundi_ie_data * | ied, |
unsigned char | ie | ||
) |
Definition at line 620 of file dundi-parser.c.
References dundi_ie_append_raw().
Referenced by dundi_discover().
{ return dundi_ie_append_raw(ied, ie, NULL, 0); }
int dundi_ie_append_addr | ( | struct dundi_ie_data * | ied, |
unsigned char | ie, | ||
struct sockaddr_in * | sin | ||
) |
Definition at line 586 of file dundi-parser.c.
References dundi_ie_append_raw().
{ return dundi_ie_append_raw(ied, ie, sin, (int)sizeof(struct sockaddr_in)); }
int dundi_ie_append_answer | ( | struct dundi_ie_data * | ied, |
unsigned char | ie, | ||
dundi_eid * | eid, | ||
unsigned char | protocol, | ||
unsigned short | flags, | ||
unsigned short | weight, | ||
char * | data | ||
) |
Definition at line 559 of file dundi-parser.c.
References dundi_ie_data::buf, dundi_ie2str(), ast_eid::eid, errorf, and dundi_ie_data::pos.
Referenced by dundi_lookup_thread(), and precache_trans().
{ char tmp[256]; int datalen = data ? strlen(data) + 11 : 11; int x; unsigned short myw; if (datalen > ((int)sizeof(ied->buf) - ied->pos)) { snprintf(tmp, (int)sizeof(tmp), "Out of space for ie '%s' (%d), need %d have %d\n", dundi_ie2str(ie), ie, datalen, (int)sizeof(ied->buf) - ied->pos); errorf(tmp); return -1; } ied->buf[ied->pos++] = ie; ied->buf[ied->pos++] = datalen; for (x=0;x<6;x++) ied->buf[ied->pos++] = eid->eid[x]; ied->buf[ied->pos++] = protocol; myw = htons(flags); memcpy(ied->buf + ied->pos, &myw, 2); ied->pos += 2; myw = htons(weight); memcpy(ied->buf + ied->pos, &myw, 2); ied->pos += 2; memcpy(ied->buf + ied->pos, data, datalen-11); ied->pos += datalen-11; return 0; }
int dundi_ie_append_byte | ( | struct dundi_ie_data * | ied, |
unsigned char | ie, | ||
unsigned char | dat | ||
) |
Definition at line 615 of file dundi-parser.c.
References dundi_ie_append_raw().
Referenced by handle_command_response().
{ return dundi_ie_append_raw(ied, ie, &dat, 1); }
int dundi_ie_append_cause | ( | struct dundi_ie_data * | ied, |
unsigned char | ie, | ||
unsigned char | cause, | ||
char * | data | ||
) |
Definition at line 503 of file dundi-parser.c.
References dundi_ie_data::buf, cause, dundi_ie2str(), errorf, and dundi_ie_data::pos.
Referenced by dundi_answer_entity(), dundi_answer_query(), dundi_lookup_thread(), dundi_prop_precache(), and handle_command_response().
{ char tmp[256]; int datalen = data ? strlen(data) + 1 : 1; if (datalen > ((int)sizeof(ied->buf) - ied->pos)) { snprintf(tmp, (int)sizeof(tmp), "Out of space for ie '%s' (%d), need %d have %d\n", dundi_ie2str(ie), ie, datalen, (int)sizeof(ied->buf) - ied->pos); errorf(tmp); return -1; } ied->buf[ied->pos++] = ie; ied->buf[ied->pos++] = datalen; ied->buf[ied->pos++] = cause; memcpy(ied->buf + ied->pos, data, datalen-1); ied->pos += datalen-1; return 0; }
int dundi_ie_append_eid | ( | struct dundi_ie_data * | ied, |
unsigned char | ie, | ||
dundi_eid * | eid | ||
) |
Definition at line 610 of file dundi-parser.c.
References dundi_ie_append_raw().
Referenced by do_register(), dundi_discover(), dundi_encrypt(), dundi_ie_append_eid_appropriately(), dundi_query(), handle_command_response(), and precache_trans().
{ return dundi_ie_append_raw(ied, ie, (unsigned char *)eid, sizeof(dundi_eid)); }
int dundi_ie_append_encdata | ( | struct dundi_ie_data * | ied, |
unsigned char | ie, | ||
unsigned char * | iv, | ||
void * | data, | ||
int | datalen | ||
) |
Definition at line 539 of file dundi-parser.c.
References dundi_ie_data::buf, dundi_ie2str(), errorf, and dundi_ie_data::pos.
Referenced by dundi_encrypt(), and handle_command_response().
{ char tmp[256]; datalen += 16; if (datalen > ((int)sizeof(ied->buf) - ied->pos)) { snprintf(tmp, (int)sizeof(tmp), "Out of space for ie '%s' (%d), need %d have %d\n", dundi_ie2str(ie), ie, datalen, (int)sizeof(ied->buf) - ied->pos); errorf(tmp); return -1; } ied->buf[ied->pos++] = ie; ied->buf[ied->pos++] = datalen; memcpy(ied->buf + ied->pos, iv, 16); ied->pos += 16; if (data) { memcpy(ied->buf + ied->pos, data, datalen-16); ied->pos += datalen-16; } return 0; }
int dundi_ie_append_hint | ( | struct dundi_ie_data * | ied, |
unsigned char | ie, | ||
unsigned short | flags, | ||
char * | data | ||
) |
Definition at line 520 of file dundi-parser.c.
References dundi_ie_data::buf, dundi_ie2str(), errorf, and dundi_ie_data::pos.
Referenced by dundi_lookup_thread(), dundi_query_thread(), and precache_trans().
{ char tmp[256]; int datalen = data ? strlen(data) + 2 : 2; if (datalen > ((int)sizeof(ied->buf) - ied->pos)) { snprintf(tmp, (int)sizeof(tmp), "Out of space for ie '%s' (%d), need %d have %d\n", dundi_ie2str(ie), ie, datalen, (int)sizeof(ied->buf) - ied->pos); errorf(tmp); return -1; } ied->buf[ied->pos++] = ie; ied->buf[ied->pos++] = datalen; flags = htons(flags); memcpy(ied->buf + ied->pos, &flags, sizeof(flags)); ied->pos += 2; memcpy(ied->buf + ied->pos, data, datalen-1); ied->pos += datalen-2; return 0; }
int dundi_ie_append_int | ( | struct dundi_ie_data * | ied, |
unsigned char | ie, | ||
unsigned int | value | ||
) |
Definition at line 591 of file dundi-parser.c.
References dundi_ie_append_raw().
Referenced by dundi_encrypt().
{ unsigned int newval; newval = htonl(value); return dundi_ie_append_raw(ied, ie, &newval, (int)sizeof(newval)); }
int dundi_ie_append_raw | ( | struct dundi_ie_data * | ied, |
unsigned char | ie, | ||
void * | data, | ||
int | datalen | ||
) |
Definition at line 488 of file dundi-parser.c.
References dundi_ie_data::buf, dundi_ie2str(), errorf, and dundi_ie_data::pos.
Referenced by dundi_encrypt(), dundi_ie_append(), dundi_ie_append_addr(), dundi_ie_append_byte(), dundi_ie_append_eid(), dundi_ie_append_int(), dundi_ie_append_short(), dundi_ie_append_str(), and handle_command_response().
{ char tmp[256]; if (datalen > ((int)sizeof(ied->buf) - ied->pos)) { snprintf(tmp, (int)sizeof(tmp), "Out of space for ie '%s' (%d), need %d have %d\n", dundi_ie2str(ie), ie, datalen, (int)sizeof(ied->buf) - ied->pos); errorf(tmp); return -1; } ied->buf[ied->pos++] = ie; ied->buf[ied->pos++] = datalen; memcpy(ied->buf + ied->pos, data, datalen); ied->pos += datalen; return 0; }
int dundi_ie_append_short | ( | struct dundi_ie_data * | ied, |
unsigned char | ie, | ||
unsigned short | value | ||
) |
Definition at line 598 of file dundi-parser.c.
References dundi_ie_append_raw().
Referenced by do_register(), dundi_discover(), dundi_lookup_thread(), dundi_query(), handle_command_response(), and precache_trans().
{ unsigned short newval; newval = htons(value); return dundi_ie_append_raw(ied, ie, &newval, (int)sizeof(newval)); }
int dundi_ie_append_str | ( | struct dundi_ie_data * | ied, |
unsigned char | ie, | ||
char * | str | ||
) |
Definition at line 605 of file dundi-parser.c.
References dundi_ie_append_raw().
Referenced by dundi_discover(), dundi_query(), dundi_query_thread(), and precache_trans().
{ return dundi_ie_append_raw(ied, ie, str, strlen(str)); }
int dundi_parse_ies | ( | struct dundi_ies * | ies, |
unsigned char * | data, | ||
int | datalen | ||
) |
Definition at line 635 of file dundi-parser.c.
References dundi_ies::anscount, dundi_ies::answers, dundi_ies::called_context, dundi_ies::called_number, dundi_ies::cause, dundi_ies::causestr, dundi_ies::cbypass, dundi_ie2str(), DUNDI_IE_ANSWER, DUNDI_IE_CACHEBYPASS, DUNDI_IE_CALLED_CONTEXT, DUNDI_IE_CALLED_NUMBER, DUNDI_IE_CAUSE, DUNDI_IE_COUNTRY, DUNDI_IE_DEPARTMENT, DUNDI_IE_EID, DUNDI_IE_EID_DIRECT, DUNDI_IE_EMAIL, DUNDI_IE_ENCDATA, DUNDI_IE_EXPIRATION, DUNDI_IE_HINT, DUNDI_IE_IPADDR, DUNDI_IE_KEYCRC32, DUNDI_IE_LOCALITY, DUNDI_IE_ORGANIZATION, DUNDI_IE_PHONE, DUNDI_IE_REQEID, DUNDI_IE_SHAREDKEY, DUNDI_IE_SIGNATURE, DUNDI_IE_STATE_PROV, DUNDI_IE_TTL, DUNDI_IE_UNKNOWN, DUNDI_IE_VERSION, DUNDI_MAX_ANSWERS, DUNDI_MAX_STACK, dundi_ies::eid_direct, dundi_ies::eidcount, dundi_ies::eids, dundi_ies::encblock, dundi_ies::enclen, dundi_ies::encsharedkey, dundi_ies::encsig, errorf, dundi_ies::expiration, dundi_ies::hint, dundi_ies::keycrc32, len(), outputf, dundi_ies::q_country, dundi_ies::q_dept, dundi_ies::q_email, dundi_ies::q_ipaddr, dundi_ies::q_locality, dundi_ies::q_org, dundi_ies::q_phone, dundi_ies::q_stateprov, dundi_ies::reqeid, dundi_ies::ttl, dundi_ies::unknowncmd, and dundi_ies::version.
Referenced by handle_command_response().
{ /* Parse data into information elements */ int len; int ie; char tmp[256]; memset(ies, 0, (int)sizeof(struct dundi_ies)); ies->ttl = -1; ies->expiration = -1; ies->unknowncmd = -1; ies->cause = -1; while(datalen >= 2) { ie = data[0]; len = data[1]; if (len > datalen - 2) { errorf("Information element length exceeds message size\n"); return -1; } switch(ie) { case DUNDI_IE_EID: case DUNDI_IE_EID_DIRECT: if (len != (int)sizeof(dundi_eid)) { errorf("Improper entity identifer, expecting 6 bytes!\n"); } else if (ies->eidcount < DUNDI_MAX_STACK) { ies->eids[ies->eidcount] = (dundi_eid *)(data + 2); ies->eid_direct[ies->eidcount] = (ie == DUNDI_IE_EID_DIRECT); ies->eidcount++; } else errorf("Too many entities in stack!\n"); break; case DUNDI_IE_REQEID: if (len != (int)sizeof(dundi_eid)) { errorf("Improper requested entity identifer, expecting 6 bytes!\n"); } else ies->reqeid = (dundi_eid *)(data + 2); break; case DUNDI_IE_CALLED_CONTEXT: ies->called_context = (char *)data + 2; break; case DUNDI_IE_CALLED_NUMBER: ies->called_number = (char *)data + 2; break; case DUNDI_IE_ANSWER: if (len < sizeof(struct dundi_answer)) { snprintf(tmp, (int)sizeof(tmp), "Answer expected to be >=%d bytes long but was %d\n", (int)sizeof(struct dundi_answer), len); errorf(tmp); } else { if (ies->anscount < DUNDI_MAX_ANSWERS) ies->answers[ies->anscount++]= (struct dundi_answer *)(data + 2); else errorf("Ignoring extra answers!\n"); } break; case DUNDI_IE_TTL: if (len != (int)sizeof(unsigned short)) { snprintf(tmp, (int)sizeof(tmp), "Expecting ttl to be %d bytes long but was %d\n", (int)sizeof(unsigned short), len); errorf(tmp); } else ies->ttl = ntohs(*((unsigned short *)(data + 2))); break; case DUNDI_IE_VERSION: if (len != (int)sizeof(unsigned short)) { snprintf(tmp, (int)sizeof(tmp), "Expecting version to be %d bytes long but was %d\n", (int)sizeof(unsigned short), len); errorf(tmp); } else ies->version = ntohs(*((unsigned short *)(data + 2))); break; case DUNDI_IE_EXPIRATION: if (len != (int)sizeof(unsigned short)) { snprintf(tmp, (int)sizeof(tmp), "Expecting expiration to be %d bytes long but was %d\n", (int)sizeof(unsigned short), len); errorf(tmp); } else ies->expiration = ntohs(*((unsigned short *)(data + 2))); break; case DUNDI_IE_KEYCRC32: if (len != (int)sizeof(unsigned int)) { snprintf(tmp, (int)sizeof(tmp), "Expecting expiration to be %d bytes long but was %d\n", (int)sizeof(unsigned int), len); errorf(tmp); } else ies->keycrc32 = ntohl(*((unsigned int *)(data + 2))); break; case DUNDI_IE_UNKNOWN: if (len == 1) ies->unknowncmd = data[2]; else { snprintf(tmp, (int)sizeof(tmp), "Expected single byte Unknown command, but was %d long\n", len); errorf(tmp); } break; case DUNDI_IE_CAUSE: if (len >= 1) { ies->cause = data[2]; ies->causestr = (char *)data + 3; } else { snprintf(tmp, (int)sizeof(tmp), "Expected at least one byte cause, but was %d long\n", len); errorf(tmp); } break; case DUNDI_IE_HINT: if (len >= 2) { ies->hint = (struct dundi_hint *)(data + 2); } else { snprintf(tmp, (int)sizeof(tmp), "Expected at least two byte hint, but was %d long\n", len); errorf(tmp); } break; case DUNDI_IE_DEPARTMENT: ies->q_dept = (char *)data + 2; break; case DUNDI_IE_ORGANIZATION: ies->q_org = (char *)data + 2; break; case DUNDI_IE_LOCALITY: ies->q_locality = (char *)data + 2; break; case DUNDI_IE_STATE_PROV: ies->q_stateprov = (char *)data + 2; break; case DUNDI_IE_COUNTRY: ies->q_country = (char *)data + 2; break; case DUNDI_IE_EMAIL: ies->q_email = (char *)data + 2; break; case DUNDI_IE_PHONE: ies->q_phone = (char *)data + 2; break; case DUNDI_IE_IPADDR: ies->q_ipaddr = (char *)data + 2; break; case DUNDI_IE_ENCDATA: /* Recalculate len as the remainder of the message, regardless of theoretical length */ len = datalen - 2; if ((len > 16) && !(len % 16)) { ies->encblock = (struct dundi_encblock *)(data + 2); ies->enclen = len - 16; } else { snprintf(tmp, (int)sizeof(tmp), "Invalid encrypted data length %d\n", len); errorf(tmp); } break; case DUNDI_IE_SHAREDKEY: if (len == 128) { ies->encsharedkey = (unsigned char *)(data + 2); } else { snprintf(tmp, (int)sizeof(tmp), "Invalid encrypted shared key length %d\n", len); errorf(tmp); } break; case DUNDI_IE_SIGNATURE: if (len == 128) { ies->encsig = (unsigned char *)(data + 2); } else { snprintf(tmp, (int)sizeof(tmp), "Invalid encrypted signature length %d\n", len); errorf(tmp); } break; case DUNDI_IE_CACHEBYPASS: ies->cbypass = 1; break; default: snprintf(tmp, (int)sizeof(tmp), "Ignoring unknown information element '%s' (%d) of length %d\n", dundi_ie2str(ie), ie, len); outputf(tmp); } /* Overwrite information element with 0, to null terminate previous portion */ data[0] = 0; datalen -= (len + 2); data += (len + 2); } /* Null-terminate last field */ *data = '\0'; if (datalen) { errorf("Invalid information element contents, strange boundary\n"); return -1; } return 0; }
void dundi_set_error | ( | void(*)(const char *) | func | ) |
Definition at line 630 of file dundi-parser.c.
References errorf.
Referenced by load_module().
{ errorf = func; }
void dundi_set_output | ( | void(*)(const char *) | func | ) |
Definition at line 625 of file dundi-parser.c.
References outputf.
Referenced by load_module().
{ outputf = func; }
void dundi_showframe | ( | struct dundi_hdr * | fhi, |
int | rx, | ||
struct sockaddr_in * | sin, | ||
int | datalen | ||
) |
Definition at line 429 of file dundi-parser.c.
References ast_inet_ntoa(), dundi_hdr::cmdflags, dundi_hdr::cmdresp, commands, dundi_hdr::dtrans, dump_ies(), DUNDI_FLAG_RESERVED, DUNDI_FLAG_RETRANS, dundi_hdr::ies, dundi_hdr::iseqno, dundi_hdr::oseqno, outputf, and dundi_hdr::strans.
Referenced by dundi_send(), dundi_xmit(), handle_command_response(), and socket_read().
{ char *pref[] = { "Tx", "Rx", " ETx", " Erx" }; char *commands[] = { "ACK ", "DPDISCOVER ", "DPRESPONSE ", "EIDQUERY ", "EIDRESPONSE ", "PRECACHERQ ", "PRECACHERP ", "INVALID ", "UNKNOWN CMD ", "NULL ", "REQREQ ", "REGRESPONSE ", "CANCEL ", "ENCRYPT ", "ENCREJ " }; char class2[20]; char *class; char subclass2[20]; char *subclass; char tmp[256]; char retries[20]; if (ntohs(fhi->dtrans) & DUNDI_FLAG_RETRANS) strcpy(retries, "Yes"); else strcpy(retries, "No"); if ((ntohs(fhi->strans) & DUNDI_FLAG_RESERVED)) { /* Ignore frames with high bit set to 1 */ return; } if ((fhi->cmdresp & 0x3f) > (int)sizeof(commands)/(int)sizeof(char *)) { snprintf(class2, (int)sizeof(class2), "(%d?)", fhi->cmdresp); class = class2; } else { class = commands[(int)(fhi->cmdresp & 0x3f)]; } snprintf(subclass2, (int)sizeof(subclass2), "%02x", fhi->cmdflags); subclass = subclass2; snprintf(tmp, (int)sizeof(tmp), "%s-Frame Retry[%s] -- OSeqno: %3.3d ISeqno: %3.3d Type: %s (%s)\n", pref[rx], retries, fhi->oseqno, fhi->iseqno, class, fhi->cmdresp & 0x40 ? "Response" : "Command"); outputf(tmp); snprintf(tmp, (int)sizeof(tmp), "%s Flags: %s STrans: %5.5d DTrans: %5.5d [%s:%d]%s\n", (rx > 1) ? " " : "", subclass, ntohs(fhi->strans) & ~DUNDI_FLAG_RESERVED, ntohs(fhi->dtrans) & ~DUNDI_FLAG_RETRANS, ast_inet_ntoa(sin->sin_addr), ntohs(sin->sin_port), fhi->cmdresp & 0x80 ? " (Final)" : ""); outputf(tmp); dump_ies(fhi->ies, rx > 1, datalen); }
int dundi_str_short_to_eid | ( | dundi_eid * | eid, |
const char * | s | ||
) |
Definition at line 67 of file dundi-parser.c.
References ast_eid::eid.
Referenced by cache_lookup_internal().
static void internalerror | ( | const char * | str | ) | [static] |
Definition at line 43 of file dundi-parser.c.
{ fprintf(stderr, "WARNING: %s", str); }
static void internaloutput | ( | const char * | str | ) | [static] |
Definition at line 38 of file dundi-parser.c.
{ fputs(str, stdout); }
static char* proto2str | ( | int | proto, |
char * | buf, | ||
int | bufsiz | ||
) | [static] |
Definition at line 221 of file dundi-parser.c.
References buf, DUNDI_PROTO_H323, DUNDI_PROTO_IAX, DUNDI_PROTO_NONE, and DUNDI_PROTO_SIP.
Referenced by dump_answer().
{ switch(proto) { case DUNDI_PROTO_NONE: strncpy(buf, "None", bufsiz - 1); break; case DUNDI_PROTO_IAX: strncpy(buf, "IAX", bufsiz - 1); break; case DUNDI_PROTO_SIP: strncpy(buf, "SIP", bufsiz - 1); break; case DUNDI_PROTO_H323: strncpy(buf, "H.323", bufsiz - 1); break; default: snprintf(buf, bufsiz, "Unknown Proto(%d)", proto); } buf[bufsiz-1] = '\0'; return buf; }
Definition at line 49 of file dundi-parser.c.
Referenced by dundi_ie_append_answer(), dundi_ie_append_cause(), dundi_ie_append_encdata(), dundi_ie_append_hint(), dundi_ie_append_raw(), dundi_parse_ies(), and dundi_set_error().
Referenced by dump_ies(), and dundi_ie2str().
Definition at line 48 of file dundi-parser.c.
Referenced by dump_ies(), dundi_parse_ies(), dundi_set_output(), and dundi_showframe().