udpfeed.c File Reference

#include <unistd.h>
#include "gwlib/gwlib.h"

Go to the source code of this file.

Macros
#define	UDP_MAXIMUM   (65535 - 40)

Functions
static void	help (void)
static void	send_file (int udpsock, char *filename, Octstr *address)
int	main (int argc, char **argv)

Variables
static unsigned char	usage []
static Octstr *	hostname
static int	port = 9200
static double	interval = 1.0
static long	maxsize = UDP_MAXIMUM

Macro Definition Documentation

UDP_MAXIMUM

#define UDP_MAXIMUM   (65535 - 40)

Definition at line 69 of file udpfeed.c.

Referenced by main().

Function Documentation

help()

static void help ( void  )

static

Definition at line 89 of file udpfeed.c.

References info(), and usage.

Referenced by main().

                       {
    info(0, "\n%s", usage);
}

main()

int main	(	int	argc,
		char **	argv
	)

Definition at line 114 of file udpfeed.c.

References error(), getopt(), gwlib_init(), gwlib_shutdown(), gwthread_sleep(), help(), hostname, interval, maxsize, octstr_create, octstr_destroy(), optarg, optind, send_file(), udp_client_socket(), udp_create_address(), UDP_MAXIMUM, and warning().

                                {
    int opt;
    Octstr *address;
    int udpsock;

    gwlib_init();

    /* Set defaults that can't be set statically */
    hostname = octstr_create("localhost");

    while ((opt = getopt(argc, argv, "hg:p:i:m:")) != EOF) {
        switch(opt) {
        case 'g':
            octstr_destroy(hostname);
            hostname = octstr_create(optarg);
            break;

        case 'p':
            port = atoi(optarg);
            break;

        case 'i':
            interval = atof(optarg);
            break;

        case 'm':
            maxsize = atol(optarg);
            if (maxsize > UDP_MAXIMUM) {
                maxsize = UDP_MAXIMUM;
                warning(0, "-m: truncated to UDP maximum of"
                    "%ld bytes.", maxsize);
            }
            break;

        case 'h':
            help();
            exit(0);
            break;

        case '?':
        default:
            error(0, "Unknown option '%c'", opt);
            help();
            exit(1);
            break;
        }
    }

    address = udp_create_address(hostname, port);
    udpsock = udp_client_socket();
    if (udpsock < 0)
        exit(1);

    for ( ; optind < argc; optind++) {
        send_file(udpsock, argv[optind], address);
        if (interval > 0 && optind + 1 < argc)
            gwthread_sleep(interval);
    }

    octstr_destroy(address);
    octstr_destroy(hostname);
    gwlib_shutdown();
        return 0;
}

send_file()

static void send_file ( int  udpsock, char *  filename, Octstr *  address  )

static

Definition at line 93 of file udpfeed.c.

References filename, info(), maxsize, octstr_destroy(), octstr_len(), octstr_read_file(), octstr_truncate(), udp_sendto(), and warning().

Referenced by main().

                                                                    {
    Octstr *contents;

    contents = octstr_read_file(filename);
    if (contents == NULL) {
        info(0, "Skipping \"%s\".", filename);
        return;
    }

    info(0, "Sending \"%s\", %ld octets.", filename, octstr_len(contents));

    if (octstr_len(contents) > maxsize) {
        octstr_truncate(contents, maxsize);
        warning(0, "Truncating to %ld octets.", maxsize);
    }

    udp_sendto(udpsock, contents, address);

    octstr_destroy(contents);
}

Variable Documentation

hostname

Octstr* hostname

static

Definition at line 84 of file udpfeed.c.

Referenced by main().

interval

double interval = 1.0

static

Definition at line 86 of file udpfeed.c.

Referenced by main().

maxsize

long maxsize = UDP_MAXIMUM

static

Definition at line 87 of file udpfeed.c.

Referenced by main(), and send_file().

port

int port = 9200

static

Definition at line 85 of file udpfeed.c.

usage

unsigned char usage[]

static

Initial value:

= "\
Usage: udpfeed [options] files...\n\
\n\
where options are:\n\
\n\
-h      help\n\
-g hostname name of IP number of host to send to (default: localhost)\n\
-p port     port number to send to (default: 9200)\n\
-i interval delay between packers (default: 1.0 seconds)\n\
\n\
Each file will be sent as a single packet.\n\
"

Definition at line 71 of file udpfeed.c.

Referenced by help().