From 6dbded74806832c1edce585d857cb7a124cf9f6a Mon Sep 17 00:00:00 2001 From: Mark Wooding Date: Wed, 13 Sep 2017 10:19:02 +0100 Subject: [PATCH] proxy/tripe-mitm.c: Reformat. --- proxy/tripe-mitm.c | 158 ++++++++++++++++++----------------------------------- 1 file changed, 52 insertions(+), 106 deletions(-) diff --git a/proxy/tripe-mitm.c b/proxy/tripe-mitm.c index bd57306d..7a2502b7 100644 --- a/proxy/tripe-mitm.c +++ b/proxy/tripe-mitm.c @@ -122,12 +122,9 @@ static void addpeer(unsigned ac, char **av) peer *p; int fd; - if (ac != 4) - die(1, "syntax: peer:NAME:PORT:ADDR:PORT"); - if (npeer >= 2) - die(1, "enough peers already"); - if (!key_bytag(&keys, av[0])) - die(1, "no key named `%s'", av[0]); + if (ac != 4) die(1, "syntax: peer:NAME:PORT:ADDR:PORT"); + if (npeer >= 2) die(1, "enough peers already"); + if (!key_bytag(&keys, av[0])) die(1, "no key named `%s'", av[0]); p = &peers[npeer++]; p->name = xstrdup(av[0]); if ((fd = socket(PF_INET, SOCK_DGRAM, 0)) < 0) @@ -184,8 +181,7 @@ static void dofork(filter *f, const octet *buf, size_t sz) static void addfork(filter *f, unsigned ac, char **av) { forkfilt *ff; - if (ac != 1) - die(1, "syntax: filt:fork:NAME"); + if (ac != 1) die(1, "syntax: filt:fork:NAME"); ff = CREATE(forkfilt); ff->name = xstrdup(av[0]); ff->fn = 0; @@ -201,23 +197,18 @@ static void nextfork(unsigned ac, char **av) forknode *fn, **ffn; peer *p; - if (ac < 1) - die(1, "syntax: next:NAME:..."); + if (ac < 1) die(1, "syntax: next:NAME:..."); for (i = 0; i < 2; i++) { p = &peers[i]; for (f = p->f; f; f = f->next) { - if (f->func != dofork) - continue; + if (f->func != dofork) continue; ff = f->state; - for (j = 0; j < ac; j++) { - if (strcmp(av[j], ff->name) == 0) - goto match; - } + for (j = 0; j < ac; j++) + if (strcmp(av[j], ff->name) == 0) goto match; continue; match: fn = CREATE(forknode); - for (ffn = &ff->fn; *ffn; ffn = &(*ffn)->next) - ; + for (ffn = &ff->fn; *ffn; ffn = &(*ffn)->next); fn->f = f->next; f->next = 0; fn->next = 0; @@ -248,13 +239,10 @@ static void docorrupt(filter *f, const octet *buf, size_t sz) static void addcorrupt(filter *f, unsigned ac, char **av) { corrupt *c; - if (ac > 1) - die(1, "syntax: filt:corrupt[:P-CORRUPT]"); + if (ac > 1) die(1, "syntax: filt:corrupt[:P-CORRUPT]"); c = CREATE(corrupt); - if (ac > 0) - c->p_corrupt = atoi(av[0]); - else - c->p_corrupt = 5; + if (ac > 0) c->p_corrupt = atoi(av[0]); + else c->p_corrupt = 5; f->state = c; f->func = docorrupt; } @@ -269,22 +257,17 @@ static void dodrop(filter *f, const octet *buf, size_t sz) { drop *d = f->state; - if (!RND(d->p_drop)) - puts("drop packet"); - else - PASS(f->next, buf, sz); + if (!RND(d->p_drop)) puts("drop packet"); + else PASS(f->next, buf, sz); } static void adddrop(filter *f, unsigned ac, char **av) { drop *d; - if (ac > 1) - die(1, "syntax: filt:drop[:P-DROP]"); + if (ac > 1) die(1, "syntax: filt:drop[:P-DROP]"); d = CREATE(drop); - if (ac > 0) - d->p_drop = atoi(av[0]); - else - d->p_drop = 5; + if (ac > 0) d->p_drop = atoi(av[0]); + else d->p_drop = 5; f->state = d; f->func = dodrop; } @@ -333,6 +316,8 @@ static void dsend(delaynode *dn, unsigned force) { delay *d = dn->d; delaynode *ddn; + unsigned i; + fputs(" send...\n", stdout); assert(dn->buf); PASS(d->f->next, dn->buf, dn->sz); @@ -355,7 +340,7 @@ static void dsend(delaynode *dn, unsigned force) ddn->flag = 0; printf(" move id %u from slot %u to slot %u", ddn->seq, ddn->i, dn->i); } - { unsigned i; for (i = 0; i < d->n; i++) assert(d->q[i].buf); } + for (i = 0; i < d->n; i++) assert(d->q[i].buf); fputs(" remove", stdout); } } @@ -400,19 +385,14 @@ static void adddelay(filter *f, unsigned ac, char **av) delay *d; unsigned i; - if (ac < 1 || ac > 3) - die(1, "syntax: filt:delay:QLEN[:MILLIS:P-REPLAY]"); + if (ac < 1 || ac > 3) die(1, "syntax: filt:delay:QLEN[:MILLIS:P-REPLAY]"); d = CREATE(delay); d->max = atoi(av[0]); - if (ac > 1) - d->t = strtoul(av[1], 0, 10); - else - d->t = 100; + if (ac > 1) d->t = strtoul(av[1], 0, 10); + else d->t = 100; d->t *= 1000; - if (ac > 2) - d->p_replay = atoi(av[2]); - else - d->p_replay = 20; + if (ac > 2) d->p_replay = atoi(av[2]); + else d->p_replay = 20; d->n = 0; d->q = xmalloc(d->max * sizeof(delaynode)); d->f = f; @@ -436,8 +416,7 @@ static void dosend(filter *f, const octet *buf, size_t sz) static void addsend(filter *f, unsigned ac, char **av) { - if (ac) - die(1, "syntax: filt:send"); + if (ac) die(1, "syntax: filt:send"); f->func = dosend; } @@ -457,21 +436,16 @@ static void dofilter(peer *from, peer *to, unsigned ac, char **av) { filter **ff, *f = CREATE(filter); const struct filtab *ft; - if (ac < 1) - die(1, "syntax: {l,r,}filt:NAME:..."); + if (ac < 1) die(1, "syntax: {l,r,}filt:NAME:..."); f->next = 0; f->p_from = from; f->p_to = to; f->state = 0; - for (ff = &from->f; *ff; ff = &(*ff)->next) - ; + for (ff = &from->f; *ff; ff = &(*ff)->next); *ff = f; - for (ft = filtab; ft->name; ft++) { - if (strcmp(av[0], ft->name) == 0) { - ft->func(f, ac - 1, av + 1); - return; - } - } + for (ft = filtab; ft->name; ft++) + if (strcmp(av[0], ft->name) == 0) + { ft->func(f, ac - 1, av + 1); return; } die(1, "unknown filter `%s'", av[0]); } @@ -500,8 +474,7 @@ static void floodtimer(struct timeval *tv, void *vv) sz /= 2; rng->ops->fill(rng, buf, sz); - if (f->type < 0x100) - buf[0] = f->type; + if (f->type < 0x100) buf[0] = f->type; puts("flood packet"); PASS(f->p->f, buf, sz); setflood(f); @@ -518,22 +491,15 @@ static void setflood(flood *f) static void doflood(peer *p, unsigned ac, char **av) { flood *f; - if (ac > 3) - die(1, "syntax: flood[:TYPE:MILLIS:SIZE]"); + if (ac > 3) die(1, "syntax: flood[:TYPE:MILLIS:SIZE]"); f = CREATE(flood); f->p = p; - if (ac > 0) - f->type = strtoul(av[0], 0, 16); - else - f->type = 0x100; - if (ac > 1) - f->t = atoi(av[1]); - else - f->t = 10; - if (ac > 2) - f->sz = atoi(av[2]); - else - f->sz = 128; + if (ac > 0) f->type = strtoul(av[0], 0, 16); + else f->type = 0x100; + if (ac > 1) f->t = atoi(av[1]); + else f->t = 10; + if (ac > 2) f->sz = atoi(av[2]); + else f->sz = 128; f->t *= 1000; setflood(f); } @@ -568,15 +534,11 @@ static void include(unsigned ac, char **av) { FILE *fp; dstr d = DSTR_INIT; - if (!ac) - die(1, "syntax: include:FILE:..."); + if (!ac) die(1, "syntax: include:FILE:..."); while (*av) { if ((fp = fopen(*av, "r")) == 0) die(1, "fopen `%s': %s", *av, strerror(errno)); - while (dstr_putline(&d, fp) != EOF) { - parse(d.buf); - DRESET(&d); - } + while (dstr_putline(&d, fp) != EOF) { parse(d.buf); DRESET(&d); } fclose(fp); av++; } @@ -607,8 +569,7 @@ static void parse(char *p) const struct cmdtab *ct; p = strtok(p, ":"); - if (!p || *p == '#') - return; + if (!p || *p == '#') return; do { v[c++] = p; p = strtok(0, ":"); @@ -679,30 +640,17 @@ int main(int argc, char *argv[]) { "keyring", OPTF_ARGREQ, 0, 'k' }, { 0, 0, 0, 0 } }; - if ((i = mdwopt(argc, argv, "hvuk:", opt, 0, 0, 0)) < 0) - break; + if ((i = mdwopt(argc, argv, "hvuk:", opt, 0, 0, 0)) < 0) break; switch (i) { - case 'h': - help(stdout); - exit(0); - case 'v': - version(stdout); - exit(0); - case 'u': - usage(stdout); - exit(0); - case 'k': - kfname = optarg; - break; - default: - f |= f_bogus; - break; + case 'h': help(stdout); exit(0); + case 'v': version(stdout); exit(0); + case 'u': usage(stdout); exit(0); + case 'k': kfname = optarg; break; + default: f |= f_bogus; break; } } - if (f & f_bogus) { - usage(stderr); - exit(1); - } + if (f & f_bogus) { usage(stderr); exit(1); } + rand_noisesrc(RAND_GLOBAL, &noise_source); rand_seed(RAND_GLOBAL, 160); rand_get(RAND_GLOBAL, buf, sizeof(buf)); @@ -710,10 +658,8 @@ int main(int argc, char *argv[]) sel_init(&sel); if (key_open(&keys, kfname, KOPEN_READ, key_moan, 0)) die(1, "couldn't open `%s': %s", kfname, strerror(errno)); - for (i = optind; i < argc; i++) - parse(argv[i]); - if (npeer != 2) - die(1, "need two peers"); + for (i = optind; i < argc; i++) parse(argv[i]); + if (npeer != 2) die(1, "need two peers"); for (;;) { if (sel_select(&sel) && errno != EINTR) die(1, "select failed: %s", strerror(errno)); -- 2.11.0