123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657 |
- /* $Id: send_packets.c 2346 2009-05-19 00:14:52Z aturner $ */
- /*
- * Copyright (c) 2001-2008 Aaron Turner.
- * All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions
- * are met:
- *
- * 1. Redistributions of source code must retain the above copyright
- * notice, this list of conditions and the following disclaimer.
- * 2. Redistributions in binary form must reproduce the above copyright
- * notice, this list of conditions and the following disclaimer in the
- * documentation and/or other materials provided with the distribution.
- * 3. Neither the names of the copyright owners nor the names of its
- * contributors may be used to endorse or promote products derived from
- * this software without specific prior written permission.
- *
- * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESS OR IMPLIED
- * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
- * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
- * IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY
- * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
- * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE
- * GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
- * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER
- * IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR
- * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
- * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
- */
- #include "config.h"
- #include "defines.h"
- #include "common.h"
- #include <sys/time.h>
- #include <sys/types.h>
- #include <signal.h>
- #include <string.h>
- #include <netinet/in.h>
- #include <errno.h>
- #include <stdlib.h>
- #include <unistd.h>
- #include <fcntl.h>
- #include "tcpreplay.h"
- #ifdef TCPREPLAY
- #ifdef TCPREPLAY_EDIT
- #include "tcpreplay_edit_opts.h"
- #include "tcpedit/tcpedit.h"
- extern tcpedit_t *tcpedit;
- #else
- #include "tcpreplay_opts.h"
- #endif
- #endif /* TCPREPLAY */
- #include "send_packets.h"
- #include "sleep.h"
- extern tcpreplay_opt_t options;
- extern struct timeval begin, end;
- extern COUNTER bytes_sent, failed, pkts_sent;
- extern volatile int didsig;
- #ifdef DEBUG
- extern int debug;
- #endif
- static void do_sleep(struct timeval *time, struct timeval *last, int len,
- int accurate, sendpacket_t *sp, COUNTER counter, delta_t *ctx);
- static const u_char *get_next_packet(pcap_t *pcap, struct pcap_pkthdr *pkthdr,
- int file_idx, packet_cache_t **prev_packet);
- static u_int32_t get_user_count(sendpacket_t *sp, COUNTER counter);
- /**
- * the main loop function for tcpreplay. This is where we figure out
- * what to do with each packet
- */
- void
- send_packets(pcap_t *pcap, int cache_file_idx)
- {
- struct timeval last = { 0, 0 };
- COUNTER packetnum = 0;
- struct pcap_pkthdr pkthdr;
- const u_char *pktdata = NULL;
- sendpacket_t *sp = options.intf1;
- u_int32_t pktlen;
- packet_cache_t *cached_packet = NULL;
- packet_cache_t **prev_packet = NULL;
- #if defined TCPREPLAY && defined TCPREPLAY_EDIT
- struct pcap_pkthdr *pkthdr_ptr;
- #endif
- delta_t delta_ctx;
- init_delta_time(&delta_ctx);
-
- /* register signals */
- didsig = 0;
- if (options.speed.mode != SPEED_ONEATATIME) {
- (void)signal(SIGINT, catcher);
- } else {
- (void)signal(SIGINT, break_now);
- }
- if (options.enable_file_cache) {
- prev_packet = &cached_packet;
- } else {
- prev_packet = NULL;
- }
-
- /* MAIN LOOP
- * Keep sending while we have packets or until
- * we've sent enough packets
- */
- while ((pktdata = get_next_packet(pcap, &pkthdr, cache_file_idx, prev_packet)) != NULL) {
- /* die? */
- if (didsig)
- break_now(0);
- /* stop sending based on the limit -L? */
- if (options.limit_send > 0 && pkts_sent >= options.limit_send)
- return;
- packetnum++;
- #ifdef TCPREPLAY
- /* do we use the snaplen (caplen) or the "actual" packet len? */
- pktlen = HAVE_OPT(PKTLEN) ? pkthdr.len : pkthdr.caplen;
- #elif TCPBRIDGE
- pktlen = pkthdr.caplen;
- #else
- #error WTF??? We should not be here!
- #endif
- dbgx(2, "packet " COUNTER_SPEC " caplen %d", packetnum, pktlen);
-
- /* Dual nic processing */
- if (options.intf2 != NULL) {
- sp = (sendpacket_t *) cache_mode(options.cachedata, packetnum);
-
- /* sometimes we should not send the packet */
- if (sp == TCPR_DIR_NOSEND)
- continue;
- }
-
- /* do we need to print the packet via tcpdump? */
- #ifdef ENABLE_VERBOSE
- if (options.verbose)
- tcpdump_print(options.tcpdump, &pkthdr, pktdata);
- #endif
- #if defined TCPREPLAY && defined TCPREPLAY_EDIT
- pkthdr_ptr = &pkthdr;
- if (tcpedit_packet(tcpedit, &pkthdr_ptr, &pktdata, sp->cache_dir) == -1) {
- errx(-1, "Error editing packet #" COUNTER_SPEC ": %s", packetnum, tcpedit_geterr(tcpedit));
- }
- pktlen = HAVE_OPT(PKTLEN) ? pkthdr_ptr->len : pkthdr_ptr->caplen;
- #endif
- /*
- * we have to cast the ts, since OpenBSD sucks
- * had to be special and use bpf_timeval.
- * Only sleep if we're not in top speed mode (-t)
- */
- if (options.speed.mode != SPEED_TOPSPEED)
- do_sleep((struct timeval *)&pkthdr.ts, &last, pktlen, options.accurate, sp, packetnum, &delta_ctx);
- /* mark the time when we send the last packet */
- start_delta_time(&delta_ctx);
- dbgx(2, "Sending packet #" COUNTER_SPEC, packetnum);
-
- /* write packet out on network */
- if (sendpacket(sp, pktdata, pktlen) < (int)pktlen)
- warnx("Unable to send packet: %s", sendpacket_geterr(sp));
- /*
- * track the time of the "last packet sent". Again, because of OpenBSD
- * we have to do a mempcy rather then assignment.
- *
- * A number of 3rd party tools generate bad timestamps which go backwards
- * in time. Hence, don't update the "last" unless pkthdr.ts > last
- */
- if (timercmp(&last, &pkthdr.ts, <))
- memcpy(&last, &pkthdr.ts, sizeof(struct timeval));
- pkts_sent ++;
- bytes_sent += pktlen;
- } /* while */
- if (options.enable_file_cache) {
- options.file_cache[cache_file_idx].cached = TRUE;
- }
- }
- /**
- * Gets the next packet to be sent out. This will either read from the pcap file
- * or will retrieve the packet from the internal cache.
- *
- * The parameter prev_packet is used as the parent of the new entry in the cache list.
- * This should be NULL on the first call to this function for each file and
- * will be updated as new entries are added (or retrieved) from the cache list.
- */
- static const u_char *
- get_next_packet(pcap_t *pcap, struct pcap_pkthdr *pkthdr, int file_idx,
- packet_cache_t **prev_packet)
- {
- u_char *pktdata = NULL;
- u_int32_t pktlen;
- /* pcap may be null in cache mode! */
- /* packet_cache_t may be null in file read mode! */
- assert(pkthdr);
- /*
- * Check if we're caching files
- */
- if (options.enable_file_cache && (prev_packet != NULL)) {
- /*
- * Yes we are caching files - has this one been cached?
- */
- if (options.file_cache[file_idx].cached) {
- if (*prev_packet == NULL) {
- /*
- * Get the first packet in the cache list directly from the file
- */
- *prev_packet = options.file_cache[file_idx].packet_cache;
- } else {
- /*
- * Get the next packet in the cache list
- */
- *prev_packet = (*prev_packet)->next;
- }
-
- if (*prev_packet != NULL) {
- pktdata = (*prev_packet)->pktdata;
- memcpy(pkthdr, &((*prev_packet)->pkthdr), sizeof(struct pcap_pkthdr));
- }
- } else {
- /*
- * We should read the pcap file, and cache the results
- */
- pktdata = (u_char *)pcap_next(pcap, pkthdr);
- if (pktdata != NULL) {
- if (*prev_packet == NULL) {
- /*
- * Create the first packet in the list
- */
- *prev_packet = safe_malloc(sizeof(packet_cache_t));
- options.file_cache[file_idx].packet_cache = *prev_packet;
- } else {
- /*
- * Add a packet to the end of the list
- */
- (*prev_packet)->next = safe_malloc(sizeof(packet_cache_t));
- *prev_packet = (*prev_packet)->next;
- }
-
- if (*prev_packet != NULL) {
- (*prev_packet)->next = NULL;
- pktlen = pkthdr->len;
-
- (*prev_packet)->pktdata = safe_malloc(pktlen);
- memcpy((*prev_packet)->pktdata, pktdata, pktlen);
- memcpy(&((*prev_packet)->pkthdr), pkthdr, sizeof(struct pcap_pkthdr));
- }
- }
- }
- } else {
- /*
- * Read pcap file as normal
- */
- pktdata = (u_char *)pcap_next(pcap, pkthdr);
- }
- /* this get's casted to a const on the way out */
- return pktdata;
- }
- /**
- * determines based upon the cachedata which interface the given packet
- * should go out. Also rewrites any layer 2 data we might need to adjust.
- * Returns a void cased pointer to the options.intfX of the corresponding
- * interface.
- */
- void *
- cache_mode(char *cachedata, COUNTER packet_num)
- {
- void *sp = NULL;
- int result;
- if (packet_num > options.cache_packets)
- err(-1, "Exceeded number of packets in cache file.");
- result = check_cache(cachedata, packet_num);
- if (result == TCPR_DIR_NOSEND) {
- dbgx(2, "Cache: Not sending packet " COUNTER_SPEC ".", packet_num);
- return TCPR_DIR_NOSEND;
- }
- else if (result == TCPR_DIR_C2S) {
- dbgx(2, "Cache: Sending packet " COUNTER_SPEC " out primary interface.", packet_num);
- sp = options.intf1;
- }
- else if (result == TCPR_DIR_S2C) {
- dbgx(2, "Cache: Sending packet " COUNTER_SPEC " out secondary interface.", packet_num);
- sp = options.intf2;
- }
- else {
- err(-1, "check_cache() returned an error. Aborting...");
- }
- return sp;
- }
- /**
- * Given the timestamp on the current packet and the last packet sent,
- * calculate the appropriate amount of time to sleep and do so.
- */
- static void
- do_sleep(struct timeval *time, struct timeval *last, int len, int accurate,
- sendpacket_t *sp, COUNTER counter, delta_t *delta_ctx)
- {
- static struct timeval didsleep = { 0, 0 };
- static struct timeval start = { 0, 0 };
- #ifdef DEBUG
- static struct timeval totalsleep = { 0, 0 };
- #endif
- struct timespec adjuster = { 0, 0 };
- static struct timespec nap = { 0, 0 }, delta_time = {0, 0};
- struct timeval nap_for, now, sleep_until;
- struct timespec nap_this_time;
- static int32_t nsec_adjuster = -1, nsec_times = -1;
- float n;
- static u_int32_t send = 0; /* accellerator. # of packets to send w/o sleeping */
- u_int64_t ppnsec; /* packets per usec */
- static int first_time = 1; /* need to track the first time through for the pps accelerator */
- #ifdef TCPREPLAY
- adjuster.tv_nsec = options.sleep_accel * 1000;
- dbgx(4, "Adjuster: " TIMESPEC_FORMAT, adjuster.tv_sec, adjuster.tv_nsec);
- #else
- adjuster.tv_nsec = 0;
- #endif
-
- /* acclerator time? */
- if (send > 0) {
- send --;
- return;
- }
-
- /*
- * pps_multi accelerator. This uses the existing send accelerator above
- * and hence requires the funky math to get the expected timings.
- */
- if (options.speed.mode == SPEED_PACKETRATE && options.speed.pps_multi) {
- send = options.speed.pps_multi - 1;
- if (first_time) {
- first_time = 0;
- return;
- }
- }
-
- dbgx(4, "This packet time: " TIMEVAL_FORMAT, time->tv_sec, time->tv_usec);
- dbgx(4, "Last packet time: " TIMEVAL_FORMAT, last->tv_sec, last->tv_usec);
- if (gettimeofday(&now, NULL) < 0)
- errx(-1, "Error gettimeofday: %s", strerror(errno));
- dbgx(4, "Now time: " TIMEVAL_FORMAT, now.tv_sec, now.tv_usec);
- /* First time through for this file */
- if (pkts_sent == 0 || ((options.speed.mode != SPEED_MBPSRATE) && (counter == 0))) {
- start = now;
- timerclear(&sleep_until);
- timerclear(&didsleep);
- }
- else {
- timersub(&now, &start, &sleep_until);
- }
- /* If top speed, you shouldn't even be here */
- assert(options.speed.mode != SPEED_TOPSPEED);
- switch(options.speed.mode) {
- case SPEED_MULTIPLIER:
- /*
- * Replay packets a factor of the time they were originally sent.
- */
- if (timerisset(last)) {
- if (timercmp(time, last, <)) {
- /* Packet has gone back in time! Don't sleep and warn user */
- warnx("Packet #" COUNTER_SPEC " has gone back in time!", counter);
- timesclear(&nap);
- } else {
- /* time has increased or is the same, so handle normally */
- timersub(time, last, &nap_for);
- dbgx(3, "original packet delta time: " TIMEVAL_FORMAT, nap_for.tv_sec, nap_for.tv_usec);
-
- TIMEVAL_TO_TIMESPEC(&nap_for, &nap);
- dbgx(3, "original packet delta timv: " TIMESPEC_FORMAT, nap.tv_sec, nap.tv_nsec);
- timesdiv(&nap, options.speed.speed);
- dbgx(3, "original packet delta/div: " TIMESPEC_FORMAT, nap.tv_sec, nap.tv_nsec);
- }
- } else {
- /* Don't sleep if this is our first packet */
- timesclear(&nap);
- }
- break;
- case SPEED_MBPSRATE:
- /*
- * Ignore the time supplied by the capture file and send data at
- * a constant 'rate' (bytes per second).
- */
- if (pkts_sent != 0) {
- n = (float)len / (options.speed.speed * 1024 * 1024 / 8); /* convert Mbps to bps */
- nap.tv_sec = n;
- nap.tv_nsec = (n - nap.tv_sec) * 1000000000;
-
- dbgx(3, "packet size %d\t\tequals %f bps\t\tnap " TIMESPEC_FORMAT, len, n,
- nap.tv_sec, nap.tv_nsec);
- }
- else {
- /* don't sleep at all for the first packet */
- timesclear(&nap);
- }
- break;
- case SPEED_PACKETRATE:
- /* only need to calculate this the first time */
- if (! timesisset(&nap)) {
- /* run in packets/sec */
- ppnsec = 1000000000 / options.speed.speed * (options.speed.pps_multi > 0 ? options.speed.pps_multi : 1);
- NANOSEC_TO_TIMESPEC(ppnsec, &nap);
- dbgx(1, "sending %d packet(s) per %lu nsec", (options.speed.pps_multi > 0 ? options.speed.pps_multi : 1), nap.tv_nsec);
- }
- break;
-
- case SPEED_ONEATATIME:
- /* do we skip prompting for a key press? */
- if (send == 0) {
- send = get_user_count(sp, counter);
- }
- /* decrement our send counter */
- printf("Sending packet " COUNTER_SPEC " out: %s\n", counter,
- sp == options.intf1 ? options.intf1_name : options.intf2_name);
- send --;
- /* leave do_sleep() */
- return;
- break;
- default:
- errx(-1, "Unknown/supported speed mode: %d", options.speed.mode);
- break;
- }
- /*
- * since we apply the adjuster to the sleep time, we can't modify nap
- */
- nap_this_time.tv_sec = nap.tv_sec;
- nap_this_time.tv_nsec = nap.tv_nsec;
- dbgx(2, "nap_time before rounding: " TIMESPEC_FORMAT, nap_this_time.tv_sec, nap_this_time.tv_nsec);
- if (accurate != ACCURATE_ABS_TIME) {
- switch (options.speed.mode) {
- /* Mbps & Multipler are dynamic timings, so we round to the nearest usec */
- case SPEED_MBPSRATE:
- case SPEED_MULTIPLIER:
- ROUND_TIMESPEC_TO_MICROSEC(&nap_this_time);
- break;
- /* Packets/sec is static, so we weight packets for .1usec accuracy */
- case SPEED_PACKETRATE:
- if (nsec_adjuster < 0)
- nsec_adjuster = (nap_this_time.tv_nsec % 10000) / 1000;
-
- /* update in the range of 0-9 */
- nsec_times = (nsec_times + 1) % 10;
-
- if (nsec_times < nsec_adjuster) {
- /* sorta looks like a no-op, but gives us a nice round usec number */
- nap_this_time.tv_nsec = (nap_this_time.tv_nsec / 1000 * 1000) + 1000;
- } else {
- nap_this_time.tv_nsec -= (nap_this_time.tv_nsec % 1000);
- }
-
- dbgx(3, "(%d)\tnsec_times = %d\tnap adjust: %lu -> %lu", nsec_adjuster, nsec_times, nap.tv_nsec, nap_this_time.tv_nsec);
- break;
-
- default:
- errx(-1, "Unknown/supported speed mode: %d", options.speed.mode);
- }
- }
- dbgx(2, "nap_time before delta calc: " TIMESPEC_FORMAT, nap_this_time.tv_sec, nap_this_time.tv_nsec);
- get_delta_time(delta_ctx, &delta_time);
- dbgx(2, "delta: " TIMESPEC_FORMAT, delta_time.tv_sec, delta_time.tv_nsec);
- if (timesisset(&delta_time)) {
- if (timescmp(&nap_this_time, &delta_time, >)) {
- timessub(&nap_this_time, &delta_time, &nap_this_time);
- dbgx(3, "timesub: %lu %lu", delta_time.tv_sec, delta_time.tv_nsec);
- } else {
- timesclear(&nap_this_time);
- dbgx(3, "timesclear: " TIMESPEC_FORMAT, delta_time.tv_sec, delta_time.tv_nsec);
- }
- }
- /* apply the adjuster... */
- if (timesisset(&adjuster)) {
- if (timescmp(&nap_this_time, &adjuster, >)) {
- timessub(&nap_this_time, &adjuster, &nap_this_time);
- } else {
- timesclear(&nap_this_time);
- }
- }
-
- dbgx(2, "Sleeping: " TIMESPEC_FORMAT, nap_this_time.tv_sec, nap_this_time.tv_nsec);
- /* don't sleep if nap = {0, 0} */
- if (!timesisset(&nap_this_time))
- return;
-
- /*
- * Depending on the accurate method & packet rate computation method
- * We have multiple methods of sleeping, pick the right one...
- */
- switch (accurate) {
- #ifdef HAVE_SELECT
- case ACCURATE_SELECT:
- select_sleep(nap_this_time);
- break;
- #endif
- #ifdef HAVE_IOPERM
- case ACCURATE_IOPORT:
- ioport_sleep(nap_this_time);
- break;
- #endif
- #ifdef HAVE_RDTSC
- case ACCURATE_RDTSC:
- rdtsc_sleep(nap_this_time);
- break;
- #endif
- #ifdef HAVE_ABSOLUTE_TIME
- case ACCURATE_ABS_TIME:
- absolute_time_sleep(nap_this_time);
- break;
- #endif
- case ACCURATE_GTOD:
- gettimeofday_sleep(nap_this_time);
- break;
- case ACCURATE_NANOSLEEP:
- nanosleep_sleep(nap_this_time);
- break;
- /*
- timeradd(&didsleep, &nap_this_time, &didsleep);
- dbgx(4, "I will sleep " TIMEVAL_FORMAT, nap_this_time.tv_sec, nap_this_time.tv_usec);
- if (timercmp(&didsleep, &sleep_until, >)) {
- timersub(&didsleep, &sleep_until, &nap_this_time);
-
- TIMEVAL_TO_TIMESPEC(&nap_this_time, &sleep);
- dbgx(4, "Sleeping " TIMEVAL_FORMAT, nap_this_time.tv_sec, nap_this_time.tv_usec);
- #ifdef DEBUG
- timeradd(&totalsleep, &nap_this_time, &totalsleep);
- #endif
- if (nanosleep(&sleep, &ignore) == -1) {
- warnx("nanosleep error: %s", strerror(errno));
- }
- }
- break;
- */
- default:
- errx(-1, "Unknown timer mode %d", accurate);
- }
- #ifdef DEBUG
- dbgx(4, "Total sleep time: " TIMEVAL_FORMAT, totalsleep.tv_sec, totalsleep.tv_usec);
- #endif
- dbgx(2, "sleep delta: " TIMESPEC_FORMAT, delta_time.tv_sec, delta_time.tv_nsec);
- }
- /**
- * Ask the user how many packets they want to send.
- */
- static u_int32_t
- get_user_count(sendpacket_t *sp, COUNTER counter)
- {
- struct pollfd poller[1]; /* use poll to read from the keyboard */
- char input[EBUF_SIZE];
- u_int32_t send = 0;
-
- printf("**** Next packet #" COUNTER_SPEC " out %s. How many packets do you wish to send? ",
- counter, (sp == options.intf1 ? options.intf1_name : options.intf2_name));
- fflush(NULL);
- poller[0].fd = STDIN_FILENO;
- poller[0].events = POLLIN | POLLPRI | POLLNVAL;
- poller[0].revents = 0;
- if (fcntl(0, F_SETFL, fcntl(0, F_GETFL) & ~O_NONBLOCK))
- errx(-1, "Unable to clear non-blocking flag on stdin: %s", strerror(errno));
- /* wait for the input */
- if (poll(poller, 1, -1) < 0)
- errx(-1, "Error reading user input from stdin: %s", strerror(errno));
-
- /*
- * read to the end of the line or EBUF_SIZE,
- * Note, if people are stupid, and type in more text then EBUF_SIZE
- * then the next fgets() will pull in that data, which will have poor
- * results. fuck them.
- */
- if (fgets(input, sizeof(input), stdin) == NULL) {
- errx(-1, "Unable to process user input for fd %d: %s", fileno(stdin), strerror(errno));
- } else if (strlen(input) > 1) {
- send = strtoul(input, NULL, 0);
- }
- /* how many packets should we send? */
- if (send == 0) {
- dbg(1, "Input was less then 1 or non-numeric, assuming 1");
- /* assume send only one packet */
- send = 1;
- }
-
- return send;
- }
- /*
- Local Variables:
- mode:c
- indent-tabs-mode:nil
- c-basic-offset:4
- End:
- */
|