diff options
author | tilghman <tilghman@f38db490-d61c-443f-a65b-d21fe96a405b> | 2006-07-10 19:05:48 +0000 |
---|---|---|
committer | tilghman <tilghman@f38db490-d61c-443f-a65b-d21fe96a405b> | 2006-07-10 19:05:48 +0000 |
commit | 9ded857bf6bed71f477322c64d4813ebb7856e37 (patch) | |
tree | 33176ce63675a2ab5cbbbf7cf1c5bc5f313bf7d1 /udptl.c | |
parent | 0ba03dd946dd3a888651da225930033e0e26c973 (diff) |
Whitespace changes only
git-svn-id: http://svn.digium.com/svn/asterisk/trunk@37345 f38db490-d61c-443f-a65b-d21fe96a405b
Diffstat (limited to 'udptl.c')
-rw-r--r-- | udptl.c | 154 |
1 files changed, 77 insertions, 77 deletions
@@ -57,8 +57,8 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$") static int udptlstart = 0; static int udptlend = 0; -static int udptldebug = 0; /* Are we debugging? */ -static struct sockaddr_in udptldebugaddr; /* Debug packets to/from this host */ +static int udptldebug = 0; /* Are we debugging? */ +static struct sockaddr_in udptldebugaddr; /* Debug packets to/from this host */ #ifdef SO_NO_CHECK static int nochecksums = 0; #endif @@ -150,7 +150,7 @@ static inline int udptl_debug_test_addr(struct sockaddr_in *addr) if (((ntohs(udptldebugaddr.sin_port) != 0) && (udptldebugaddr.sin_port != addr->sin_port)) || (udptldebugaddr.sin_addr.s_addr != addr->sin_addr.s_addr)) - return 0; + return 0; } return 1; } @@ -190,7 +190,7 @@ static int decode_open_type(uint8_t *buf, int limit, int *len, const uint8_t **p int i; const uint8_t **pbuf; - for (octet_idx = 0, *p_num_octets = 0; ; octet_idx += octet_cnt) { + for (octet_idx = 0, *p_num_octets = 0; ; octet_idx += octet_cnt) { if ((stat = decode_length(buf, limit, len, &octet_cnt)) < 0) return -1; if (octet_cnt > 0) { @@ -232,7 +232,7 @@ static int encode_length(uint8_t *buf, int *len, int value) return value; } /* Fragmentation */ - multiplier = (value < 0x10000) ? (value >> 14) : 4; + multiplier = (value < 0x10000) ? (value >> 14) : 4; /* Set the first 2 bits of the octet */ buf[*len] = 0xC0 | multiplier; (*len)++; @@ -253,7 +253,7 @@ static int encode_open_type(uint8_t *buf, int *len, const uint8_t *data, int num num_octets = 1; } /* Encode the open type */ - for (octet_idx = 0; ; num_octets -= enclen, octet_idx += enclen) { + for (octet_idx = 0; ; num_octets -= enclen, octet_idx += enclen) { if ((enclen = encode_length(buf, len, num_octets)) < 0) return -1; if (enclen > 0) { @@ -320,7 +320,7 @@ static int udptl_rx_packet(struct ast_udptl *s, uint8_t *buf, int len) do { if ((stat2 = decode_length(buf, len, &ptr, &count)) < 0) return -1; - for (i = 0; i < count; i++) { + for (i = 0; i < count; i++) { if ((stat = decode_open_type(buf, len, &ptr, &bufs[total_count + i], &lengths[total_count + i])) != 0) return -1; } @@ -328,7 +328,7 @@ static int udptl_rx_packet(struct ast_udptl *s, uint8_t *buf, int len) } while (stat2 > 0); /* Step through in reverse order, so we go oldest to newest */ - for (i = total_count; i > 0; i--) { + for (i = total_count; i > 0; i--) { if (seq_no - i >= s->rx_seq_no) { /* This one wasn't seen before */ /* Decode the secondary IFP packet */ @@ -378,7 +378,7 @@ static int udptl_rx_packet(struct ast_udptl *s, uint8_t *buf, int len) if (ifp_len > LOCAL_FAX_MAX_DATAGRAM) return -1; /* Update any missed slots in the buffer */ - for ( ; seq_no > s->rx_seq_no; s->rx_seq_no++) { + for ( ; seq_no > s->rx_seq_no; s->rx_seq_no++) { x = s->rx_seq_no & UDPTL_BUF_MASK; s->rx[x].buf_len = -1; s->rx[x].fec_len[0] = 0; @@ -413,7 +413,7 @@ static int udptl_rx_packet(struct ast_udptl *s, uint8_t *buf, int len) s->rx[x].fec_entries = entries; /* Decode the elements */ - for (i = 0; i < entries; i++) { + for (i = 0; i < entries; i++) { if ((stat = decode_open_type(buf, len, &ptr, &data, &s->rx[x].fec_len[i])) != 0) return -1; if (s->rx[x].fec_len[i] > LOCAL_FAX_MAX_DATAGRAM) @@ -423,29 +423,29 @@ static int udptl_rx_packet(struct ast_udptl *s, uint8_t *buf, int len) memcpy(s->rx[x].fec[i], data, s->rx[x].fec_len[i]); #if 0 fprintf(stderr, "FEC: "); - for (j = 0; j < s->rx[x].fec_len[i]; j++) + for (j = 0; j < s->rx[x].fec_len[i]; j++) fprintf(stderr, "%02X ", data[j]); fprintf(stderr, "\n"); #endif - } + } /* See if we can reconstruct anything which is missing */ /* TODO: this does not comprehensively hunt back and repair everything that is possible */ - for (l = x; l != ((x - (16 - span*entries)) & UDPTL_BUF_MASK); l = (l - 1) & UDPTL_BUF_MASK) { + for (l = x; l != ((x - (16 - span*entries)) & UDPTL_BUF_MASK); l = (l - 1) & UDPTL_BUF_MASK) { if (s->rx[l].fec_len[0] <= 0) continue; - for (m = 0; m < s->rx[l].fec_entries; m++) { + for (m = 0; m < s->rx[l].fec_entries; m++) { limit = (l + m) & UDPTL_BUF_MASK; - for (which = -1, k = (limit - s->rx[l].fec_span*s->rx[l].fec_entries) & UDPTL_BUF_MASK; k != limit; k = (k + s->rx[l].fec_entries) & UDPTL_BUF_MASK) { + for (which = -1, k = (limit - s->rx[l].fec_span * s->rx[l].fec_entries) & UDPTL_BUF_MASK; k != limit; k = (k + s->rx[l].fec_entries) & UDPTL_BUF_MASK) { if (s->rx[k].buf_len <= 0) - which = (which == -1) ? k : -2; + which = (which == -1) ? k : -2; } if (which >= 0) { /* Repairable */ - for (j = 0; j < s->rx[l].fec_len[m]; j++) { + for (j = 0; j < s->rx[l].fec_len[m]; j++) { s->rx[which].buf[j] = s->rx[l].fec[m][j]; - for (k = (limit - s->rx[l].fec_span*s->rx[l].fec_entries) & UDPTL_BUF_MASK; k != limit; k = (k + s->rx[l].fec_entries) & UDPTL_BUF_MASK) - s->rx[which].buf[j] ^= (s->rx[k].buf_len > j) ? s->rx[k].buf[j] : 0; + for (k = (limit - s->rx[l].fec_span * s->rx[l].fec_entries) & UDPTL_BUF_MASK; k != limit; k = (k + s->rx[l].fec_entries) & UDPTL_BUF_MASK) + s->rx[which].buf[j] ^= (s->rx[k].buf_len > j) ? s->rx[k].buf[j] : 0; } s->rx[which].buf_len = s->rx[l].fec_len[m]; repaired[which] = TRUE; @@ -453,7 +453,7 @@ static int udptl_rx_packet(struct ast_udptl *s, uint8_t *buf, int len) } } /* Now play any new packets forwards in time */ - for (l = (x + 1) & UDPTL_BUF_MASK, j = seq_no - UDPTL_BUF_MASK; l != x; l = (l + 1) & UDPTL_BUF_MASK, j++) { + for (l = (x + 1) & UDPTL_BUF_MASK, j = seq_no - UDPTL_BUF_MASK; l != x; l = (l + 1) & UDPTL_BUF_MASK, j++) { if (repaired[l]) { //fprintf(stderr, "Fixed packet %d, len %d\n", j, l); s->f[ifp_no].frametype = AST_FRAME_MODEM; @@ -553,7 +553,7 @@ static int udptl_build_packet(struct ast_udptl *s, uint8_t *buf, uint8_t *ifp, i if (encode_length(buf, &len, entries) < 0) return -1; /* Encode the elements */ - for (i = 0; i < entries; i++) { + for (i = 0; i < entries; i++) { j = (entry - i - 1) & UDPTL_BUF_MASK; if (encode_open_type(buf, &len, s->tx[j].buf, s->tx[j].buf_len) < 0) return -1; @@ -577,19 +577,19 @@ static int udptl_build_packet(struct ast_udptl *s, uint8_t *buf, uint8_t *ifp, i /* The number of entries is defined as a length, but will only ever be a small value. Treat it as such. */ buf[len++] = entries; - for (m = 0; m < entries; m++) { + for (m = 0; m < entries; m++) { /* Make an XOR'ed entry the maximum length */ limit = (entry + m) & UDPTL_BUF_MASK; high_tide = 0; - for (i = (limit - span*entries) & UDPTL_BUF_MASK; i != limit; i = (i + entries) & UDPTL_BUF_MASK) { + for (i = (limit - span*entries) & UDPTL_BUF_MASK; i != limit; i = (i + entries) & UDPTL_BUF_MASK) { if (high_tide < s->tx[i].buf_len) { - for (j = 0; j < high_tide; j++) + for (j = 0; j < high_tide; j++) fec[j] ^= s->tx[i].buf[j]; - for ( ; j < s->tx[i].buf_len; j++) + for ( ; j < s->tx[i].buf_len; j++) fec[j] = s->tx[i].buf[j]; high_tide = s->tx[i].buf_len; } else { - for (j = 0; j < s->tx[i].buf_len; j++) + for (j = 0; j < s->tx[i].buf_len; j++) fec[j] ^= s->tx[i].buf[j]; } } @@ -700,68 +700,68 @@ void ast_udptl_offered_from_local(struct ast_udptl* udptl, int local) int ast_udptl_get_error_correction_scheme(struct ast_udptl* udptl) { - if (udptl) - return udptl->error_correction_scheme; - else { - ast_log(LOG_WARNING, "udptl structure is null\n"); - return -1; - } + if (udptl) + return udptl->error_correction_scheme; + else { + ast_log(LOG_WARNING, "udptl structure is null\n"); + return -1; + } } void ast_udptl_set_error_correction_scheme(struct ast_udptl* udptl, int ec) { - if (udptl) { - switch (ec) { - case UDPTL_ERROR_CORRECTION_FEC: - udptl->error_correction_scheme = UDPTL_ERROR_CORRECTION_FEC; - break; - case UDPTL_ERROR_CORRECTION_REDUNDANCY: - udptl->error_correction_scheme = UDPTL_ERROR_CORRECTION_REDUNDANCY; - break; - case UDPTL_ERROR_CORRECTION_NONE: - udptl->error_correction_scheme = UDPTL_ERROR_CORRECTION_NONE; - break; - default: - ast_log(LOG_WARNING, "error correction parameter invalid"); - }; - } else - ast_log(LOG_WARNING, "udptl structure is null\n"); + if (udptl) { + switch (ec) { + case UDPTL_ERROR_CORRECTION_FEC: + udptl->error_correction_scheme = UDPTL_ERROR_CORRECTION_FEC; + break; + case UDPTL_ERROR_CORRECTION_REDUNDANCY: + udptl->error_correction_scheme = UDPTL_ERROR_CORRECTION_REDUNDANCY; + break; + case UDPTL_ERROR_CORRECTION_NONE: + udptl->error_correction_scheme = UDPTL_ERROR_CORRECTION_NONE; + break; + default: + ast_log(LOG_WARNING, "error correction parameter invalid"); + }; + } else + ast_log(LOG_WARNING, "udptl structure is null\n"); } int ast_udptl_get_local_max_datagram(struct ast_udptl* udptl) { - if (udptl) - return udptl->local_max_datagram_size; - else { - ast_log(LOG_WARNING, "udptl structure is null\n"); - return -1; - } + if (udptl) + return udptl->local_max_datagram_size; + else { + ast_log(LOG_WARNING, "udptl structure is null\n"); + return -1; + } } int ast_udptl_get_far_max_datagram(struct ast_udptl* udptl) { - if (udptl) - return udptl->far_max_datagram_size; - else { - ast_log(LOG_WARNING, "udptl structure is null\n"); - return -1; - } + if (udptl) + return udptl->far_max_datagram_size; + else { + ast_log(LOG_WARNING, "udptl structure is null\n"); + return -1; + } } void ast_udptl_set_local_max_datagram(struct ast_udptl* udptl, int max_datagram) { - if (udptl) - udptl->local_max_datagram_size = max_datagram; - else - ast_log(LOG_WARNING, "udptl structure is null\n"); + if (udptl) + udptl->local_max_datagram_size = max_datagram; + else + ast_log(LOG_WARNING, "udptl structure is null\n"); } void ast_udptl_set_far_max_datagram(struct ast_udptl* udptl, int max_datagram) { - if (udptl) - udptl->far_max_datagram_size = max_datagram; - else - ast_log(LOG_WARNING, "udptl structure is null\n"); + if (udptl) + udptl->far_max_datagram_size = max_datagram; + else + ast_log(LOG_WARNING, "udptl structure is null\n"); } struct ast_udptl *ast_udptl_new_with_bindaddr(struct sched_context *sched, struct io_context *io, int callbackmode, struct in_addr addr) @@ -789,7 +789,7 @@ struct ast_udptl *ast_udptl_new_with_bindaddr(struct sched_context *sched, struc memset(&udptl->rx, 0, sizeof(udptl->rx)); memset(&udptl->tx, 0, sizeof(udptl->tx)); - for (i = 0; i <= UDPTL_BUF_MASK; i++) { + for (i = 0; i <= UDPTL_BUF_MASK; i++) { udptl->rx[i].buf_len = -1; udptl->tx[i].buf_len = -1; } @@ -913,7 +913,7 @@ int ast_udptl_write(struct ast_udptl *s, struct ast_frame *f) /* Cook up the UDPTL packet, with the relevant EC info. */ len = udptl_build_packet(s, buf, f->data, f->datalen); - if (len > 0 && s->them.sin_port && s->them.sin_addr.s_addr) { + if (len > 0 && s->them.sin_port && s->them.sin_addr.s_addr) { if ((res = sendto(s->fd, buf, len, 0, (struct sockaddr *) &s->them, sizeof(s->them))) < 0) ast_log(LOG_NOTICE, "UDPTL Transmission error to %s:%d: %s\n", ast_inet_ntoa(iabuf, sizeof(iabuf), s->them.sin_addr), ntohs(s->them.sin_port), strerror(errno)); #if 0 @@ -935,7 +935,7 @@ void ast_udptl_proto_unregister(struct ast_udptl_protocol *proto) cur = protos; prev = NULL; - while(cur) { + while (cur) { if (cur == proto) { if (prev) prev->next = proto->next; @@ -953,7 +953,7 @@ int ast_udptl_proto_register(struct ast_udptl_protocol *proto) struct ast_udptl_protocol *cur; cur = protos; - while(cur) { + while (cur) { if (cur->type == proto->type) { ast_log(LOG_WARNING, "Tried to register same protocol '%s' twice\n", cur->type); return -1; @@ -1044,7 +1044,7 @@ int ast_udptl_bridge(struct ast_channel *c0, struct ast_channel *c1, int flags, cs[1] = c1; cs[2] = NULL; for (;;) { - if ((c0->tech_pvt != pvt0) || + if ((c0->tech_pvt != pvt0) || (c1->tech_pvt != pvt1) || (c0->masq || c0->masqr || c1->masq || c1->masqr)) { ast_log(LOG_DEBUG, "Oooh, something is weird, backing out\n"); @@ -1147,7 +1147,7 @@ static int udptl_do_debug(int fd, int argc, char *argv[]) ast_cli(fd, "UDPTL Debugging Enabled\n"); return RESULT_SUCCESS; } - + static int udptl_no_debug(int fd, int argc, char *argv[]) { if (argc !=3) @@ -1165,13 +1165,13 @@ static char no_debug_usage[] = "Usage: udptl no debug\n" " Disable all UDPTL debugging\n"; -static struct ast_cli_entry cli_debug_ip = +static struct ast_cli_entry cli_debug_ip = {{ "udptl", "debug", "ip", NULL } , udptl_do_debug, "Enable UDPTL debugging on IP", debug_usage }; -static struct ast_cli_entry cli_debug = +static struct ast_cli_entry cli_debug = {{ "udptl", "debug", NULL } , udptl_do_debug, "Enable UDPTL debugging", debug_usage }; -static struct ast_cli_entry cli_no_debug = +static struct ast_cli_entry cli_no_debug = {{ "udptl", "no", "debug", NULL } , udptl_no_debug, "Disable UDPTL debugging", no_debug_usage }; void ast_udptl_reload(void) |