source: zzuf/trunk/src/zzuf.c @ 2343

Last change on this file since 2343 was 2343, checked in by Sam Hocevar, 12 years ago
  • Allow to omit the right-hand side of the seed range, for indefinite fuzzing attempts.
  • Property svn:keywords set to Id
File size: 35.0 KB
Line 
1/*
2 *  zzuf - general purpose fuzzer
3 *  Copyright (c) 2002, 2007 Sam Hocevar <sam@zoy.org>
4 *                All Rights Reserved
5 *
6 *  $Id: zzuf.c 2343 2008-05-19 11:24:56Z sam $
7 *
8 *  This program is free software. It comes without any warranty, to
9 *  the extent permitted by applicable law. You can redistribute it
10 *  and/or modify it under the terms of the Do What The Fuck You Want
11 *  To Public License, Version 2, as published by Sam Hocevar. See
12 *  http://sam.zoy.org/wtfpl/COPYING for more details.
13 */
14
15/*
16 *  main.c: main program
17 */
18
19#include "config.h"
20
21#if defined HAVE_STDINT_H
22#   include <stdint.h>
23#elif defined HAVE_INTTYPES_H
24#   include <inttypes.h>
25#endif
26#if !defined HAVE_GETOPT_LONG
27#   include "mygetopt.h"
28#elif defined HAVE_GETOPT_H
29#   include <getopt.h>
30#endif
31#include <stdio.h>
32#include <stdlib.h>
33#if defined HAVE_UNISTD_H
34#   include <unistd.h>
35#endif
36#if defined HAVE_REGEX_H
37#   include <regex.h>
38#endif
39#if defined HAVE_WINSOCK2_H
40#   include <winsock2.h>
41#endif
42#if defined HAVE_WINDOWS_H
43#   include <windows.h>
44#endif
45#if defined HAVE_IO_H
46#   include <io.h>
47#endif
48#include <string.h>
49#include <fcntl.h>
50#include <errno.h>
51#include <signal.h>
52#if defined HAVE_SYS_WAIT_H
53#   include <sys/wait.h>
54#endif
55#if defined HAVE_SYS_RESOURCE_H
56#   include <sys/resource.h>
57#endif
58
59#include "libzzuf.h"
60#include "opts.h"
61#include "random.h"
62#include "fd.h"
63#include "fuzz.h"
64#include "md5.h"
65#include "timer.h"
66
67#if defined HAVE_GETOPT_LONG
68#   define mygetopt getopt_long
69#   define myoptind optind
70#   define myoptarg optarg
71#   define myoption option
72#endif
73
74#if !defined SIGKILL
75#   define SIGKILL 9
76#endif
77
78#if defined RLIMIT_AS
79#   define ZZUF_RLIMIT_MEM RLIMIT_AS
80#elif defined RLIMIT_VMEM
81#   define ZZUF_RLIMIT_MEM RLIMIT_VMEM
82#elif defined RLIMIT_DATA
83#   define ZZUF_RLIMIT_MEM RLIMIT_DATA
84#else
85#   undef ZZUF_RLIMIT_MEM
86#endif
87
88#if defined RLIMIT_CPU
89#   define ZZUF_RLIMIT_CPU RLIMIT_CPU
90#else
91#   undef ZZUF_RLIMIT_CPU
92#endif
93
94/* We use file descriptor 17 as the debug channel */
95#define DEBUG_FILENO 17
96#define DEBUG_FILENO_STR "17"
97
98static void loop_stdin(struct opts *);
99static int run_process(struct opts *, int[][2]);
100
101static void spawn_children(struct opts *);
102static void clean_children(struct opts *);
103static void read_children(struct opts *);
104
105#if !defined HAVE_SETENV
106static void setenv(char const *, char const *, int);
107#endif
108#if defined HAVE_WAITPID
109static char const *sig2str(int);
110#endif
111#if defined HAVE_WINDOWS_H
112static int dll_inject(void *, void *);
113static void *get_entry(char const *);
114#endif
115static void finfo(FILE *, struct opts *, uint32_t);
116#if defined HAVE_REGEX_H
117static char *merge_regex(char *, char *);
118static char *merge_file(char *, char *);
119#endif
120static void version(void);
121static void usage(void);
122
123#if defined HAVE_WINDOWS_H
124static inline void addcpy(void *buf, void *x)
125{
126    memcpy(buf, &x, 4);
127}
128#endif
129
130#define ZZUF_FD_SET(fd, p_fdset, maxfd) \
131    if(fd >= 0) \
132    { \
133        FD_SET((unsigned int)fd, p_fdset); \
134        if(fd > maxfd) \
135            maxfd = fd; \
136    }
137
138#define ZZUF_FD_ISSET(fd, p_fdset) \
139    ((fd >= 0) && (FD_ISSET(fd, p_fdset)))
140
141int main(int argc, char *argv[])
142{
143    struct opts _opts, *opts = &_opts;
144    char *tmp;
145#if defined HAVE_REGEX_H
146    char *include = NULL, *exclude = NULL;
147    int cmdline = 0;
148#endif
149    int network = 0;
150    int i;
151
152    _zz_opts_init(opts);
153
154    for(;;)
155    {
156#if defined HAVE_REGEX_H
157#   define OPTSTR_REGEX "cE:I:"
158#else
159#   define OPTSTR_REGEX ""
160#endif
161#if defined HAVE_SETRLIMIT && defined ZZUF_RLIMIT_MEM
162#   define OPTSTR_RLIMIT_MEM "M:"
163#else
164#   define OPTSTR_RLIMIT_MEM ""
165#endif
166#if defined HAVE_SETRLIMIT && defined ZZUF_RLIMIT_CPU
167#   define OPTSTR_RLIMIT_CPU "T:"
168#else
169#   define OPTSTR_RLIMIT_CPU ""
170#endif
171#define OPTSTR "+" OPTSTR_REGEX OPTSTR_RLIMIT_MEM OPTSTR_RLIMIT_CPU \
172                "Ab:B:C:dD:f:F:il:mnp:P:qr:R:s:St:vxhV"
173#define MOREINFO "Try `%s --help' for more information.\n"
174        int option_index = 0;
175        static struct myoption long_options[] =
176        {
177            /* Long option, needs arg, flag, short option */
178            { "autoinc",     0, NULL, 'A' },
179            { "bytes",       1, NULL, 'b' },
180            { "max-bytes",   1, NULL, 'B' },
181#if defined HAVE_REGEX_H
182            { "cmdline",     0, NULL, 'c' },
183#endif
184            { "max-crashes", 1, NULL, 'C' },
185            { "debug",       0, NULL, 'd' },
186            { "delay",       1, NULL, 'D' },
187#if defined HAVE_REGEX_H
188            { "exclude",     1, NULL, 'E' },
189#endif
190            { "fuzzing",     1, NULL, 'f' },
191            { "max-forks",   1, NULL, 'F' },
192            { "stdin",       0, NULL, 'i' },
193#if defined HAVE_REGEX_H
194            { "include",     1, NULL, 'I' },
195#endif
196            { "list",        1, NULL, 'l' },
197            { "md5",         0, NULL, 'm' },
198            { "max-memory",  1, NULL, 'M' },
199            { "network",     0, NULL, 'n' },
200            { "ports",       1, NULL, 'p' },
201            { "protect",     1, NULL, 'P' },
202            { "quiet",       0, NULL, 'q' },
203            { "ratio",       1, NULL, 'r' },
204            { "refuse",      1, NULL, 'R' },
205            { "seed",        1, NULL, 's' },
206            { "signal",      0, NULL, 'S' },
207            { "max-time",    1, NULL, 't' },
208            { "max-cpu",     1, NULL, 'T' },
209            { "verbose",     0, NULL, 'v' },
210            { "check-exit",  0, NULL, 'x' },
211            { "help",        0, NULL, 'h' },
212            { "version",     0, NULL, 'V' },
213            { NULL,          0, NULL,  0  }
214        };
215        int c = mygetopt(argc, argv, OPTSTR, long_options, &option_index);
216
217        if(c == -1)
218            break;
219
220        switch(c)
221        {
222        case 'A': /* --autoinc */
223            setenv("ZZUF_AUTOINC", "1", 1);
224            break;
225        case 'b': /* --bytes */
226            opts->bytes = myoptarg;
227            break;
228        case 'B': /* --max-bytes */
229            opts->maxbytes = atoi(myoptarg);
230            break;
231#if defined HAVE_REGEX_H
232        case 'c': /* --cmdline */
233            cmdline = 1;
234            break;
235#endif
236        case 'C': /* --max-crashes */
237            opts->maxcrashes = atoi(myoptarg);
238            if(opts->maxcrashes <= 0)
239                opts->maxcrashes = 0;
240            break;
241        case 'd': /* --debug */
242            setenv("ZZUF_DEBUG", DEBUG_FILENO_STR, 1);
243            break;
244        case 'D': /* --delay */
245            opts->delay = (int64_t)(atof(myoptarg) * 1000000.0);
246            break;
247#if defined HAVE_REGEX_H
248        case 'E': /* --exclude */
249            exclude = merge_regex(exclude, myoptarg);
250            if(!exclude)
251            {
252                fprintf(stderr, "%s: invalid regex -- `%s'\n",
253                        argv[0], myoptarg);
254                _zz_opts_fini(opts);
255                return EXIT_FAILURE;
256            }
257            break;
258#endif
259        case 'f': /* --fuzzing */
260            opts->fuzzing = myoptarg;
261            break;
262        case 'F': /* --max-forks */
263            opts->maxchild = atoi(myoptarg) > 1 ? atoi(myoptarg) : 1;
264            break;
265        case 'i': /* --stdin */
266            setenv("ZZUF_STDIN", "1", 1);
267            break;
268#if defined HAVE_REGEX_H
269        case 'I': /* --include */
270            include = merge_regex(include, myoptarg);
271            if(!include)
272            {
273                fprintf(stderr, "%s: invalid regex -- `%s'\n",
274                        argv[0], myoptarg);
275                _zz_opts_fini(opts);
276                return EXIT_FAILURE;
277            }
278            break;
279#endif
280        case 'l': /* --list */
281            opts->list = myoptarg;
282            break;
283        case 'm': /* --md5 */
284            opts->md5 = 1;
285            break;
286#if defined HAVE_SETRLIMIT && defined ZZUF_RLIMIT_MEM
287        case 'M': /* --max-memory */
288            setenv("ZZUF_MEMORY", "1", 1);
289            opts->maxmem = atoi(myoptarg);
290            break;
291#endif
292        case 'n': /* --network */
293            setenv("ZZUF_NETWORK", "1", 1);
294            network = 1;
295            break;
296        case 'p': /* --ports */
297            opts->ports = myoptarg;
298            break;
299        case 'P': /* --protect */
300            opts->protect = myoptarg;
301            break;
302        case 'q': /* --quiet */
303            opts->quiet = 1;
304            break;
305        case 'r': /* --ratio */
306            tmp = strchr(myoptarg, ':');
307            opts->minratio = atof(myoptarg);
308            opts->maxratio = tmp ? atof(tmp + 1) : opts->minratio;
309            break;
310        case 'R': /* --refuse */
311            opts->refuse = myoptarg;
312            break;
313        case 's': /* --seed */
314            tmp = strchr(myoptarg, ':');
315            opts->seed = atol(myoptarg);
316            opts->endseed = tmp ? tmp[1] ? (uint32_t)atoi(tmp + 1)
317                                         : (uint32_t)-1UL
318                                : opts->seed + 1;
319            break;
320        case 'S': /* --signal */
321            setenv("ZZUF_SIGNAL", "1", 1);
322            break;
323        case 't': /* --max-time */
324            opts->maxtime = (int64_t)(atof(myoptarg) * 1000000.0);
325            break;
326#if defined HAVE_SETRLIMIT && defined ZZUF_RLIMIT_CPU
327        case 'T': /* --max-cpu */
328            opts->maxcpu = (int)(atof(myoptarg) + 0.5);
329            break;
330#endif
331        case 'x': /* --check-exit */
332            opts->checkexit = 1;
333            break;
334        case 'v': /* --verbose */
335            opts->verbose = 1;
336            break;
337        case 'h': /* --help */
338            usage();
339            _zz_opts_fini(opts);
340            return 0;
341        case 'V': /* --version */
342            version();
343            _zz_opts_fini(opts);
344            return 0;
345        default:
346            fprintf(stderr, "%s: invalid option -- %c\n", argv[0], c);
347            printf(MOREINFO, argv[0]);
348            _zz_opts_fini(opts);
349            return EXIT_FAILURE;
350        }
351    }
352
353    if(opts->ports && !network)
354    {
355        fprintf(stderr, "%s: port option (-p) requires network fuzzing (-n)\n",
356                argv[0]);
357        printf(MOREINFO, argv[0]);
358        _zz_opts_fini(opts);
359        return EXIT_FAILURE;
360    }
361
362    _zz_setratio(opts->minratio, opts->maxratio);
363    _zz_setseed(opts->seed);
364
365    /* If asked to read from the standard input */
366    if(myoptind >= argc)
367    {
368        if(opts->verbose)
369        {
370            finfo(stderr, opts, opts->seed);
371            fprintf(stderr, "reading from stdin\n");
372        }
373
374        if(opts->endseed != opts->seed + 1)
375        {
376            fprintf(stderr, "%s: seed ranges are incompatible with "
377                            "stdin fuzzing\n", argv[0]);
378            printf(MOREINFO, argv[0]);
379            _zz_opts_fini(opts);
380            return EXIT_FAILURE;
381        }
382
383        loop_stdin(opts);
384
385        _zz_opts_fini(opts);
386        return EXIT_SUCCESS;
387    }
388
389    /* If asked to launch programs */
390#if defined HAVE_REGEX_H
391    if(cmdline)
392    {
393        int dashdash = 0;
394
395        for(i = myoptind + 1; i < argc; i++)
396        {
397            if(dashdash)
398                include = merge_file(include, argv[i]);
399            else if(!strcmp("--", argv[i]))
400                dashdash = 1;
401            else if(argv[i][0] != '-')
402                include = merge_file(include, argv[i]);
403        }
404    }
405
406    if(include)
407        setenv("ZZUF_INCLUDE", include, 1);
408    if(exclude)
409        setenv("ZZUF_EXCLUDE", exclude, 1);
410#endif
411
412    if(opts->fuzzing)
413        setenv("ZZUF_FUZZING", opts->fuzzing, 1);
414    if(opts->bytes)
415        setenv("ZZUF_BYTES", opts->bytes, 1);
416    if(opts->list)
417        setenv("ZZUF_LIST", opts->list, 1);
418    if(opts->ports)
419        setenv("ZZUF_PORTS", opts->ports, 1);
420    if(opts->protect)
421        setenv("ZZUF_PROTECT", opts->protect, 1);
422    if(opts->refuse)
423        setenv("ZZUF_REFUSE", opts->refuse, 1);
424
425    /* Allocate memory for children handling */
426    opts->child = malloc(opts->maxchild * sizeof(struct child));
427    for(i = 0; i < opts->maxchild; i++)
428        opts->child[i].status = STATUS_FREE;
429    opts->nchild = 0;
430
431    /* Create new argv */
432    opts->oldargv = argv;
433    opts->newargv = malloc((argc - myoptind + 1) * sizeof(char *));
434    memcpy(opts->newargv, argv + myoptind, (argc - myoptind) * sizeof(char *));
435    opts->newargv[argc - myoptind] = (char *)NULL;
436
437    /* Main loop */
438    while(opts->nchild || opts->seed < opts->endseed)
439    {
440        /* Spawn new children, if necessary */
441        spawn_children(opts);
442
443        /* Cleanup dead or dying children */
444        clean_children(opts);
445
446        /* Read data from children */
447        read_children(opts);
448
449        if(opts->maxcrashes && opts->crashes >= opts->maxcrashes
450            && opts->nchild == 0)
451            break;
452    }
453
454    /* Clean up */
455    _zz_opts_fini(opts);
456
457    return opts->crashes ? EXIT_FAILURE : EXIT_SUCCESS;
458}
459
460static void loop_stdin(struct opts *opts)
461{
462    uint8_t md5sum[16];
463    struct md5 *ctx = NULL;
464
465    if(opts->md5)
466        ctx = _zz_md5_init();
467
468    if(opts->fuzzing)
469        _zz_fuzzing(opts->fuzzing);
470    if(opts->bytes)
471        _zz_bytes(opts->bytes);
472    if(opts->list)
473        _zz_list(opts->list);
474    if(opts->ports)
475        _zz_ports(opts->ports);
476    if(opts->protect)
477        _zz_protect(opts->protect);
478    if(opts->refuse)
479        _zz_refuse(opts->refuse);
480
481    _zz_fd_init();
482    _zz_register(0);
483
484    for(;;)
485    {
486        uint8_t buf[BUFSIZ];
487        int ret, off = 0, nw = 0;
488
489        ret = read(0, buf, BUFSIZ);
490        if(ret <= 0)
491            break;
492
493        _zz_fuzz(0, buf, ret);
494        _zz_addpos(0, ret);
495
496        if(opts->md5)
497            _zz_md5_add(ctx, buf, ret);
498        else while(ret)
499        {
500            if((nw = write(1, buf + off, (unsigned int)ret)) < 0)
501                break;
502            ret -= nw;
503            off += nw;
504        }
505    }
506
507    if(opts->md5)
508    {
509        _zz_md5_fini(md5sum, ctx);
510        finfo(stdout, opts, opts->seed);
511        fprintf(stdout, "%.02x%.02x%.02x%.02x%.02x%.02x%.02x%.02x%.02x%.02x"
512                "%.02x%.02x%.02x%.02x%.02x%.02x\n", md5sum[0], md5sum[1],
513                md5sum[2], md5sum[3], md5sum[4], md5sum[5], md5sum[6],
514                md5sum[7], md5sum[8], md5sum[9], md5sum[10], md5sum[11],
515                md5sum[12], md5sum[13], md5sum[14], md5sum[15]);
516        fflush(stdout);
517    }
518
519    _zz_unregister(0);
520    _zz_fd_fini();
521}
522
523static void finfo(FILE *fp, struct opts *opts, uint32_t seed)
524{
525    if(opts->minratio == opts->maxratio)
526        fprintf(fp, "zzuf[s=%i,r=%g]: ", seed, opts->minratio);
527    else
528        fprintf(fp, "zzuf[s=%i,r=%g:%g]: ", seed,
529                opts->minratio, opts->maxratio);
530}
531
532#if defined HAVE_REGEX_H
533static char *merge_file(char *regex, char *file)
534{
535    char *newfile = malloc(5 + 2 * strlen(file) + 1 + 1), *tmp = newfile;
536
537    *tmp++ = '(';
538    *tmp++ = '^';
539    *tmp++ = '|';
540    *tmp++ = '/';
541    *tmp++ = ')';
542    while(*file)
543    {
544        if(strchr("^.[$()|*+?{\\", *file))
545            *tmp++ = '\\';
546        *tmp++ = *file++;
547    }
548    *tmp++ = '$';
549    *tmp++ = '\0';
550
551    tmp = merge_regex(regex, newfile);
552    free(newfile);
553    return tmp;
554}
555
556static char *merge_regex(char *regex, char *string)
557{
558    regex_t optre;
559
560    if(regex)
561    {
562        regex = realloc(regex, strlen(regex) + strlen(string) + 1 + 1);
563        sprintf(regex + strlen(regex) - 1, "|%s)", string);
564    }
565    else
566    {
567        regex = malloc(1 + strlen(string) + 1 + 1);
568        sprintf(regex, "(%s)", string);
569    }
570
571    if(regcomp(&optre, regex, REG_EXTENDED) != 0)
572    {
573        free(regex);
574        return NULL;
575    }
576    regfree(&optre);
577
578    return regex;
579}
580#endif
581
582static void spawn_children(struct opts *opts)
583{
584    int pipes[3][2];
585    int64_t now = _zz_time();
586    pid_t pid;
587    int i, j;
588
589    if(opts->nchild == opts->maxchild)
590        return; /* no slot */
591
592    if(opts->seed == opts->endseed)
593        return; /* job finished */
594
595    if(opts->maxcrashes && opts->crashes >= opts->maxcrashes)
596        return; /* all jobs crashed */
597
598    if(opts->delay > 0 && opts->lastlaunch + opts->delay > now)
599        return; /* too early */
600
601    /* Find the empty slot */
602    for(i = 0; i < opts->maxchild; i++)
603        if(opts->child[i].status == STATUS_FREE)
604            break;
605
606    /* Prepare communication pipe */
607    for(j = 0; j < 3; j++)
608    {
609        int ret;
610#if defined HAVE_PIPE
611        ret = pipe(pipes[j]);
612#elif defined HAVE__PIPE
613        ret = _pipe(pipes[j], 512, _O_BINARY | O_NOINHERIT);
614#endif
615        if(ret < 0)
616        {
617            perror("pipe");
618            return;
619        }
620    }
621
622    pid = run_process(opts, pipes);
623    if(pid < 0)
624        return;
625
626    /* We’re the parent, acknowledge spawn */
627    opts->child[i].date = now;
628    opts->child[i].pid = pid;
629    for(j = 0; j < 3; j++)
630    {
631        close(pipes[j][1]);
632        opts->child[i].fd[j] = pipes[j][0];
633    }
634    opts->child[i].bytes = 0;
635    opts->child[i].seed = opts->seed;
636    opts->child[i].ratio = _zz_getratio();
637    opts->child[i].status = STATUS_RUNNING;
638    if(opts->md5)
639        opts->child[i].ctx = _zz_md5_init();
640
641    if(opts->verbose)
642    {
643        finfo(stderr, opts, opts->child[i].seed);
644        fprintf(stderr, "launched `%s'\n", opts->newargv[0]);
645    }
646
647    opts->lastlaunch = now;
648    opts->nchild++;
649    opts->seed++;
650
651    _zz_setseed(opts->seed);
652}
653
654static void clean_children(struct opts *opts)
655{
656#if defined HAVE_KILL
657    int64_t now = _zz_time();
658#endif
659    int i, j;
660
661#if defined HAVE_KILL
662    /* Terminate children if necessary */
663    for(i = 0; i < opts->maxchild; i++)
664    {
665        if(opts->child[i].status == STATUS_RUNNING
666            && opts->maxbytes >= 0
667            && opts->child[i].bytes > opts->maxbytes)
668        {
669            if(opts->verbose)
670            {
671                finfo(stderr, opts, opts->child[i].seed);
672                fprintf(stderr, "data output exceeded, sending SIGTERM\n");
673            }
674            kill(opts->child[i].pid, SIGTERM);
675            opts->child[i].date = now;
676            opts->child[i].status = STATUS_SIGTERM;
677        }
678
679        if(opts->child[i].status == STATUS_RUNNING
680            && opts->maxtime >= 0
681            && now > opts->child[i].date + opts->maxtime)
682        {
683            if(opts->verbose)
684            {
685                finfo(stderr, opts, opts->child[i].seed);
686                fprintf(stderr, "running time exceeded, sending SIGTERM\n");
687            }
688            kill(opts->child[i].pid, SIGTERM);
689            opts->child[i].date = now;
690            opts->child[i].status = STATUS_SIGTERM;
691        }
692    }
693
694    /* Kill children if necessary (still there after 2 seconds) */
695    for(i = 0; i < opts->maxchild; i++)
696    {
697        if(opts->child[i].status == STATUS_SIGTERM
698            && now > opts->child[i].date + 2000000)
699        {
700            if(opts->verbose)
701            {
702                finfo(stderr, opts, opts->child[i].seed);
703                fprintf(stderr, "not responding, sending SIGKILL\n");
704            }
705            kill(opts->child[i].pid, SIGKILL);
706            opts->child[i].status = STATUS_SIGKILL;
707        }
708    }
709#endif
710
711    /* Collect dead children */
712    for(i = 0; i < opts->maxchild; i++)
713    {
714        uint8_t md5sum[16];
715#if defined HAVE_WAITPID
716        int status;
717        pid_t pid;
718#endif
719
720        if(opts->child[i].status != STATUS_SIGKILL
721            && opts->child[i].status != STATUS_SIGTERM
722            && opts->child[i].status != STATUS_EOF)
723            continue;
724
725#if defined HAVE_WAITPID
726        pid = waitpid(opts->child[i].pid, &status, WNOHANG);
727        if(pid <= 0)
728            continue;
729
730        if(opts->checkexit && WIFEXITED(status) && WEXITSTATUS(status))
731        {
732            finfo(stderr, opts, opts->child[i].seed);
733            fprintf(stderr, "exit %i\n", WEXITSTATUS(status));
734            opts->crashes++;
735        }
736        else if(WIFSIGNALED(status)
737                 && !(WTERMSIG(status) == SIGTERM
738                       && opts->child[i].status == STATUS_SIGTERM))
739        {
740            char const *message = "";
741
742            if(WTERMSIG(status) == SIGKILL && opts->maxmem >= 0)
743                message = " (memory exceeded?)";
744#   if defined SIGXCPU
745            else if(WTERMSIG(status) == SIGXCPU && opts->maxcpu >= 0)
746                message = " (CPU time exceeded?)";
747#   endif
748            else if(WTERMSIG(status) == SIGKILL && opts->maxcpu >= 0)
749                message = " (CPU time exceeded?)";
750
751            finfo(stderr, opts, opts->child[i].seed);
752            fprintf(stderr, "signal %i%s%s\n",
753                    WTERMSIG(status), sig2str(WTERMSIG(status)), message);
754            opts->crashes++;
755        }
756#endif
757
758        for(j = 0; j < 3; j++)
759            if(opts->child[i].fd[j] >= 0)
760                close(opts->child[i].fd[j]);
761
762        if(opts->md5)
763        {
764            _zz_md5_fini(md5sum, opts->child[i].ctx);
765            finfo(stdout, opts, opts->child[i].seed);
766            fprintf(stdout, "%.02x%.02x%.02x%.02x%.02x%.02x%.02x%.02x%.02x"
767                    "%.02x%.02x%.02x%.02x%.02x%.02x%.02x\n", md5sum[0],
768                    md5sum[1], md5sum[2], md5sum[3], md5sum[4], md5sum[5],
769                    md5sum[6], md5sum[7], md5sum[8], md5sum[9], md5sum[10],
770                    md5sum[11], md5sum[12], md5sum[13], md5sum[14], md5sum[15]);
771            fflush(stdout);
772        }
773        opts->child[i].status = STATUS_FREE;
774        opts->nchild--;
775    }
776}
777
778static void read_children(struct opts *opts)
779{
780    struct timeval tv;
781    fd_set fdset;
782    int i, j, ret, maxfd = 0;
783
784    /* Read data from all sockets */
785    FD_ZERO(&fdset);
786    for(i = 0; i < opts->maxchild; i++)
787    {
788        if(opts->child[i].status != STATUS_RUNNING)
789            continue;
790
791        for(j = 0; j < 3; j++)
792            ZZUF_FD_SET(opts->child[i].fd[j], &fdset, maxfd);
793    }
794    tv.tv_sec = 0;
795    tv.tv_usec = 1000;
796
797    ret = select(maxfd + 1, &fdset, NULL, NULL, &tv);
798    if(ret < 0 && errno)
799        perror("select");
800    if(ret <= 0)
801        return;
802
803    /* XXX: cute (i, j) iterating hack */
804    for(i = 0, j = 0; i < opts->maxchild; i += (j == 2), j = (j + 1) % 3)
805    {
806        uint8_t buf[BUFSIZ];
807
808        if(opts->child[i].status != STATUS_RUNNING)
809            continue;
810
811        if(!ZZUF_FD_ISSET(opts->child[i].fd[j], &fdset))
812            continue;
813
814        ret = read(opts->child[i].fd[j], buf, BUFSIZ - 1);
815        if(ret > 0)
816        {
817            /* We got data */
818            if(j != 0)
819                opts->child[i].bytes += ret;
820
821            if(opts->md5 && j == 2)
822                _zz_md5_add(opts->child[i].ctx, buf, ret);
823            else if(!opts->quiet || j == 0)
824                write((j < 2) ? STDERR_FILENO : STDOUT_FILENO, buf, ret);
825        }
826        else if(ret == 0)
827        {
828            /* End of file reached */
829            close(opts->child[i].fd[j]);
830            opts->child[i].fd[j] = -1;
831
832            if(opts->child[i].fd[0] == -1
833                && opts->child[i].fd[1] == -1
834                && opts->child[i].fd[2] == -1)
835                opts->child[i].status = STATUS_EOF;
836        }
837    }
838}
839
840#if !defined HAVE_SETENV
841static void setenv(char const *name, char const *value, int overwrite)
842{
843    char *str;
844
845    if(!overwrite && getenv(name))
846        return;
847
848    str = malloc(strlen(name) + 1 + strlen(value) + 1);
849    sprintf(str, "%s=%s", name, value);
850    putenv(str);
851}
852#endif
853
854#if defined HAVE_WAITPID
855static char const *sig2str(int signum)
856{
857    switch(signum)
858    {
859#ifdef SIGQUIT
860        case SIGQUIT:  return " (SIGQUIT)"; /* 3 */
861#endif
862        case SIGILL:   return " (SIGILL)";  /* 4 */
863#ifdef SIGTRAP
864        case SIGTRAP:  return " (SIGTRAP)"; /* 5 */
865#endif
866        case SIGABRT:  return " (SIGABRT)"; /* 6 */
867#ifdef SIGBUS
868        case SIGBUS:   return " (SIGBUS)";  /* 7 */
869#endif
870        case SIGFPE:   return " (SIGFPE)";  /* 8 */
871        case SIGSEGV:  return " (SIGSEGV)"; /* 11 */
872        case SIGPIPE:  return " (SIGPIPE)"; /* 13 */
873#ifdef SIGEMT
874        case SIGEMT:   return " (SIGEMT)";  /* ? */
875#endif
876#ifdef SIGXCPU
877        case SIGXCPU:  return " (SIGXCPU)"; /* 24 */
878#endif
879#ifdef SIGXFSZ
880        case SIGXFSZ:  return " (SIGXFSZ)"; /* 25 */
881#endif
882#ifdef SIGSYS
883        case SIGSYS:   return " (SIGSYS)";  /* 31 */
884#endif
885    }
886
887    return "";
888}
889#endif
890
891static int run_process(struct opts *opts, int pipes[][2])
892{
893    char buf[64];
894#if defined HAVE_FORK
895    static int const files[] = { DEBUG_FILENO, STDERR_FILENO, STDOUT_FILENO };
896    char *libpath, *tmp;
897    int pid, j, len = strlen(opts->oldargv[0]);
898#   if defined __APPLE__
899#       define FILENAME "libzzuf.dylib"
900#       define EXTRAINFO ""
901#       define PRELOAD "DYLD_INSERT_LIBRARIES"
902    setenv("DYLD_FORCE_FLAT_NAMESPACE", "1", 1);
903#   elif defined __osf__
904#       define FILENAME "libzzuf.so"
905#       define EXTRAINFO ":DEFAULT"
906#       define PRELOAD "_RLD_LIST"
907#   else
908#       define FILENAME "libzzuf.so"
909#       define EXTRAINFO ""
910#       define PRELOAD "LD_PRELOAD"
911#   endif
912#elif HAVE_WINDOWS_H
913    PROCESS_INFORMATION pinfo;
914    STARTUPINFO sinfo;
915    HANDLE pid;
916    void *epaddr;
917#endif
918    int ret;
919
920#if defined HAVE_FORK
921    /* Fork and launch child */
922    pid = fork();
923    if(pid < -1)
924        perror("fork");
925    if(pid != 0)
926        return pid;
927
928    /* We loop in reverse order so that files[0] is done last,
929     * just in case one of the other dup2()ed fds had the value */
930    for(j = 3; j--; )
931    {
932        close(pipes[j][0]);
933        if(pipes[j][1] != files[j])
934        {
935            dup2(pipes[j][1], files[j]);
936            close(pipes[j][1]);
937        }
938    }
939#endif
940
941#if defined HAVE_SETRLIMIT && defined ZZUF_RLIMIT_MEM
942    if(opts->maxmem >= 0)
943    {
944        struct rlimit rlim;
945        rlim.rlim_cur = opts->maxmem * 1000000;
946        rlim.rlim_max = opts->maxmem * 1000000;
947        setrlimit(ZZUF_RLIMIT_MEM, &rlim);
948    }
949#endif
950
951#if defined HAVE_SETRLIMIT && defined ZZUF_RLIMIT_CPU
952    if(opts->maxcpu >= 0)
953    {
954        struct rlimit rlim;
955        rlim.rlim_cur = opts->maxcpu;
956        rlim.rlim_max = opts->maxcpu + 5;
957        setrlimit(ZZUF_RLIMIT_CPU, &rlim);
958    }
959#endif
960
961    /* Set environment variables */
962    sprintf(buf, "%i", opts->seed);
963    setenv("ZZUF_SEED", buf, 1);
964    sprintf(buf, "%g", opts->minratio);
965    setenv("ZZUF_MINRATIO", buf, 1);
966    sprintf(buf, "%g", opts->maxratio);
967    setenv("ZZUF_MAXRATIO", buf, 1);
968
969#if defined HAVE_FORK
970    /* Meaningless but makes sure there is space for everything */
971    libpath = malloc(len + strlen(LIBDIR "/.libs/" FILENAME EXTRAINFO) + 1);
972    strcpy(libpath, opts->oldargv[0]);
973
974    /* Replace "/path/binaryname" with "/path/.libs/libzzuf.$(EXT)"
975     *     and "binaryname" with ".libs/libzzuf.$(EXT)"
976     * Write the result in libpath. */
977    tmp = strrchr(libpath, '/');
978    strcpy(tmp ? tmp + 1 : libpath, ".libs/" FILENAME);
979
980    ret = access(libpath, R_OK);
981    if(ret < 0)
982        strcpy(libpath, LIBDIR "/" FILENAME);
983
984    /* OSF1 only */
985    strcat(libpath, EXTRAINFO);
986
987    /* Do not clobber previous LD_PRELOAD values */
988    tmp = getenv(PRELOAD);
989    if(tmp && *tmp)
990    {
991        char *bigbuf = malloc(strlen(tmp) + strlen(libpath) + 2);
992        sprintf(bigbuf, "%s:%s", tmp, libpath);
993        free(libpath);
994        libpath = bigbuf;
995    }
996
997    setenv(PRELOAD, libpath, 1);
998    free(libpath);
999
1000    if(execvp(opts->newargv[0], opts->newargv))
1001    {
1002        perror(opts->newargv[0]);
1003        exit(EXIT_FAILURE);
1004    }
1005
1006    exit(EXIT_SUCCESS);
1007    /* no return */
1008    return 0;
1009#elif HAVE_WINDOWS_H
1010    pid = GetCurrentProcess();
1011
1012    /* Get entry point */
1013    epaddr = get_entry(opts->newargv[0]);
1014    if(!epaddr)
1015        return -1;
1016
1017    memset(&sinfo, 0, sizeof(sinfo));
1018    sinfo.cb = sizeof(sinfo);
1019    DuplicateHandle(pid, (HANDLE)_get_osfhandle(pipes[0][1]), pid,
1020        /* FIXME */ &sinfo.hStdInput, 0, TRUE, DUPLICATE_SAME_ACCESS);
1021    DuplicateHandle(pid, (HANDLE)_get_osfhandle(pipes[1][1]), pid,
1022                    &sinfo.hStdError, 0, TRUE, DUPLICATE_SAME_ACCESS);
1023    DuplicateHandle(pid, (HANDLE)_get_osfhandle(pipes[2][1]), pid,
1024                    &sinfo.hStdOutput, 0, TRUE, DUPLICATE_SAME_ACCESS);
1025    sinfo.dwFlags = STARTF_USESTDHANDLES;
1026    ret = CreateProcess(NULL, opts->newargv[0], NULL, NULL, FALSE,
1027                        CREATE_SUSPENDED, NULL, NULL, &sinfo, &pinfo);
1028    if(!ret)
1029        return -1;
1030
1031    /* Insert the replacement code */
1032    ret = dll_inject(pinfo.hProcess, epaddr);
1033    if(ret < 0)
1034    {
1035        TerminateProcess(pinfo.hProcess, -1);
1036        return -1;
1037    }
1038
1039    ret = ResumeThread(pinfo.hThread);
1040    if(ret < 0)
1041    {
1042        TerminateProcess(pinfo.hProcess, -1);
1043        return -1;
1044    }
1045
1046    return (long int)pinfo.hProcess;
1047#endif
1048}
1049
1050#if defined HAVE_WINDOWS_H
1051static int dll_inject(void *process, void *epaddr)
1052{
1053    uint8_t old_ep[7];
1054    uint8_t new_ep[] = "\xb8<01>\xff\xe0";
1055    uint8_t loader[] = "libzzuf.dll\0<0000c>\xb8<14>\x50\xb8<1a>\xff\xd0"
1056                       "\xb8\0\0\0\0\x50\xb8\x07\x00\x00\x00\x50\xb8<2d>"
1057                       "\x50\xb8<33>\x50\xb8<39>\xff\xd0\x50\xb8<41>\xff"
1058                       "\xd0\xb8<48>\xff\xe0";
1059    void *lib;
1060    uint8_t *loaderaddr;
1061    DWORD tmp;
1062
1063    /* Save the old entry-point code */
1064    ReadProcessMemory(process, epaddr, old_ep, 7, &tmp);
1065    if(tmp != 7)
1066        return -1;
1067
1068    loaderaddr = VirtualAllocEx(process, NULL, 78, MEM_COMMIT,
1069                                PAGE_EXECUTE_READWRITE);
1070    if(!loaderaddr)
1071        return -1;
1072
1073    addcpy(new_ep + 0x01, loaderaddr + 0x0c + 7);
1074    WriteProcessMemory(process, epaddr, new_ep, 7, &tmp);
1075    if(tmp != 7)
1076        return -1;
1077
1078    lib = LoadLibrary("kernel32.dll");
1079    if(!lib)
1080        return -1;
1081
1082    memcpy(loader + 0x0c, old_ep, 7);
1083    addcpy(loader + 0x14, loaderaddr + 0x00); /* offset for dll string */
1084    addcpy(loader + 0x1a, GetProcAddress(lib, "LoadLibraryA"));
1085    addcpy(loader + 0x2d, loaderaddr + 0x0c);
1086    addcpy(loader + 0x33, epaddr);
1087    addcpy(loader + 0x39, GetProcAddress(lib, "GetCurrentProcess"));
1088    addcpy(loader + 0x41, GetProcAddress(lib, "WriteProcessMemory"));
1089    addcpy(loader + 0x48, epaddr);
1090    FreeLibrary(lib);
1091
1092    WriteProcessMemory(process, loaderaddr, loader, 78, &tmp);
1093    if(tmp != 78)
1094        return -1;
1095
1096    return 0;
1097}
1098
1099static void *get_entry(char const *name)
1100{
1101    PIMAGE_DOS_HEADER dos;
1102    PIMAGE_NT_HEADERS nt;
1103    void *file, *map, *base;
1104
1105    file = CreateFile(name, GENERIC_READ, FILE_SHARE_READ,
1106                      NULL, OPEN_EXISTING, 0, NULL);
1107    if(file == INVALID_HANDLE_VALUE)
1108        return NULL;
1109
1110    map = CreateFileMapping(file, NULL, PAGE_READONLY, 0, 0, NULL);
1111    if(!map)
1112    {
1113        CloseHandle(file);
1114        return NULL;
1115    }
1116
1117    base = MapViewOfFile(map, FILE_MAP_READ, 0, 0, 0);
1118    if(!base)
1119    {
1120        CloseHandle(map);
1121        CloseHandle(file);
1122        return NULL;
1123    }
1124
1125    /* Sanity checks */
1126    dos = (PIMAGE_DOS_HEADER)base;
1127    nt = (PIMAGE_NT_HEADERS)((char *)base + dos->e_lfanew);
1128    if(dos->e_magic != IMAGE_DOS_SIGNATURE
1129      || nt->Signature != IMAGE_NT_SIGNATURE
1130      || nt->FileHeader.Machine != IMAGE_FILE_MACHINE_I386
1131      || nt->OptionalHeader.Magic != 0x10b /* IMAGE_NT_OPTIONAL_HDR32_MAGIC */)
1132    {
1133        UnmapViewOfFile(base);
1134        CloseHandle(map);
1135        CloseHandle(file);
1136        return NULL;
1137    }
1138
1139    return (void *)(uintptr_t)(nt->OptionalHeader.ImageBase +
1140                                 nt->OptionalHeader.AddressOfEntryPoint);
1141}
1142#endif
1143
1144static void version(void)
1145{
1146    printf("zzuf %s\n", PACKAGE_VERSION);
1147    printf("Copyright (C) 2002, 2007-2008 Sam Hocevar <sam@zoy.org>\n");
1148    printf("This is free software.  You may redistribute copies of it under the\n");
1149    printf("terms of the Do What The Fuck You Want To Public License, Version 2\n");
1150    printf("<http://sam.zoy.org/wtfpl/>.\n");
1151    printf("There is NO WARRANTY, to the extent permitted by law.\n");
1152    printf("\n");
1153    printf("Written by Sam Hocevar. Report bugs to <sam@zoy.org>.\n");
1154}
1155
1156static void usage(void)
1157{
1158#if defined HAVE_REGEX_H
1159    printf("Usage: zzuf [-AcdimnqSvx] [-s seed|-s start:stop] [-r ratio|-r min:max]\n");
1160#else
1161    printf("Usage: zzuf [-AdimnqSvx] [-s seed|-s start:stop] [-r ratio|-r min:max]\n");
1162#endif
1163    printf("              [-f fuzzing] [-D delay] [-F forks] [-C crashes] [-B bytes]\n");
1164    printf("              [-t seconds] ");
1165#if defined HAVE_SETRLIMIT && defined ZZUF_RLIMIT_CPU
1166    printf(                           "[-T seconds] ");
1167#endif
1168#if defined HAVE_SETRLIMIT && defined ZZUF_RLIMIT_MEM
1169    printf(                                        "[-M megabytes] ");
1170#endif
1171    printf(                                                       "[-b ranges] [-p ports]\n");
1172    printf("              [-P protect] [-R refuse] [-l list]");
1173#if defined HAVE_REGEX_H
1174    printf(                                                " [-I include] [-E exclude]");
1175#endif
1176    printf("\n");
1177    printf("              [PROGRAM [--] [ARGS]...]\n");
1178    printf("       zzuf -h | --help\n");
1179    printf("       zzuf -V | --version\n");
1180    printf("Run PROGRAM with optional arguments ARGS and fuzz its input.\n");
1181    printf("\n");
1182    printf("Mandatory arguments to long options are mandatory for short options too.\n");
1183    printf("  -A, --autoinc             increment seed each time a new file is opened\n");
1184    printf("  -b, --bytes <ranges>      only fuzz bytes at offsets within <ranges>\n");
1185    printf("  -B, --max-bytes <n>       kill children that output more than <n> bytes\n");
1186#if defined HAVE_REGEX_H
1187    printf("  -c, --cmdline             only fuzz files specified in the command line\n");
1188#endif
1189    printf("  -C, --max-crashes <n>     stop after <n> children have crashed (default 1)\n");
1190    printf("  -d, --debug               print debug messages\n");
1191    printf("  -D, --delay               delay between forks\n");
1192#if defined HAVE_REGEX_H
1193    printf("  -E, --exclude <regex>     do not fuzz files matching <regex>\n");
1194#endif
1195    printf("  -f, --fuzzing <mode>      use fuzzing mode <mode> ([xor] set unset)\n");
1196    printf("  -F, --max-forks <n>       number of concurrent children (default 1)\n");
1197    printf("  -i, --stdin               fuzz standard input\n");
1198#if defined HAVE_REGEX_H
1199    printf("  -I, --include <regex>     only fuzz files matching <regex>\n");
1200#endif
1201    printf("  -l, --list <list>         only fuzz Nth descriptor with N in <list>\n");
1202    printf("  -m, --md5                 compute the output's MD5 hash\n");
1203#if defined HAVE_SETRLIMIT && defined ZZUF_RLIMIT_MEM
1204    printf("  -M, --max-memory <n>      maximum child virtual memory size in MB\n");
1205#endif
1206    printf("  -n, --network             fuzz network input\n");
1207    printf("  -p, --ports <list>        only fuzz network destination ports in <list>\n");
1208    printf("  -P, --protect <list>      protect bytes and characters in <list>\n");
1209    printf("  -q, --quiet               do not print children's messages\n");
1210    printf("  -r, --ratio <ratio>       bit fuzzing ratio (default %g)\n", DEFAULT_RATIO);
1211    printf("      --ratio <start:stop>  specify a ratio range\n");
1212    printf("  -R, --refuse <list>       refuse bytes and characters in <list>\n");
1213    printf("  -s, --seed <seed>         random seed (default %i)\n", DEFAULT_SEED);
1214    printf("      --seed <start:stop>   specify a seed range\n");
1215    printf("  -S, --signal              prevent children from diverting crashing signals\n");
1216    printf("  -t, --max-time <n>        kill children that run for more than <n> seconds\n");
1217    printf("  -T, --max-cpu <n>         kill children that use more than <n> CPU seconds\n");
1218    printf("  -v, --verbose             print information during the run\n");
1219    printf("  -x, --check-exit          report processes that exit with a non-zero status\n");
1220    printf("  -h, --help                display this help and exit\n");
1221    printf("  -V, --version             output version information and exit\n");
1222    printf("\n");
1223    printf("Written by Sam Hocevar. Report bugs to <sam@zoy.org>.\n");
1224}
1225
Note: See TracBrowser for help on using the repository browser.