aboutsummaryrefslogtreecommitdiffstats
path: root/rttcatcher.c
diff options
context:
space:
mode:
authorGuillaume Horel <guillaume.horel@serenitascapital.com>2015-11-04 13:55:26 -0500
committerGuillaume Horel <guillaume.horel@serenitascapital.com>2015-11-04 13:55:26 -0500
commitded46d4768498c7d27fedcc438fe80a59ad63d0c (patch)
tree1158247ec3b9580a3deaa320334c2d777050b6b9 /rttcatcher.c
parenta5309fed914fdaa7697f2d369e7dcd02309063ab (diff)
downloadmrsync-ded46d4768498c7d27fedcc438fe80a59ad63d0c.tar.gz
move code into a src directory
Diffstat (limited to 'rttcatcher.c')
-rw-r--r--rttcatcher.c118
1 files changed, 0 insertions, 118 deletions
diff --git a/rttcatcher.c b/rttcatcher.c
deleted file mode 100644
index 1af74f1..0000000
--- a/rttcatcher.c
+++ /dev/null
@@ -1,118 +0,0 @@
-/*
- Copyright (C) 2006 Renaissance Technologies Corp.
- main developer: HP Wei <hp@rentec.com>
- Copyright (C) 2005 Renaissance Technologies Corp.
- Copyright (C) 2001 Renaissance Technologies Corp.
- main developer: HP Wei <hp@rentec.com>
- Codes in this file are extracted and modified from multicatcher.c.
-
- Copyright (C) 2000 Aaron Hillegass <aaron@classmax.com>
-
- This program is free software; you can redistribute it and/or modify
- it under the terms of the GNU General Public License as published by
- the Free Software Foundation; either version 2, or (at your option)
- any later version.
-
- This program is distributed in the hope that it will be useful,
- but WITHOUT ANY WARRANTY; without even the implied warranty of
- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- GNU General Public License for more details.
-
- You should have received a copy of the GNU General Public License
- along with this program; see the file COPYING.
- If not, write to the Free Software Foundation,
- 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
-*/
-
-#include "rttmain.h"
-
-char * my_MCAST_ADDR = MCAST_ADDR;
-int my_FLOW_PORT = FLOW_PORT;
-int my_PORT = PORT;
-char * my_IFname = MCAST_IF;
-
-void usage()
-{
- fprintf(stderr,
- "rttcatcher (to receive pages on the target. version %s\n"
- " Option list:\n"
- " [ -v flag to turn on verbose]\n"
- " -------- mcast options --------------------------------------\n"
- " [ -A <my_mcast_address default=%s)> ]\n"
- " [ -P <my_PORT default=%d> ]\n"
- " [ -I <my_MCAST_IF default=NULL> ]\n",
- VERSION, MCAST_ADDR, PORT);
-}
-
-int main(int argc, char *argv[])
-{
- int old_mode; /* hp: from char to int for mode */
- int mode;
- int c;
-
- verbose = 0;
- while ((c = getopt(argc, argv, "vA:P:I:")) != EOF) {
- switch (c) {
- case 'v':
- verbose = 1;
- break;
- case 'A':
- my_MCAST_ADDR = optarg;
- break;
- case 'P':
- my_PORT = atoi(optarg);
- my_FLOW_PORT = my_PORT -1;
- break;
- case 'I':
- my_IFname = optarg;
- break;
- case '?':
- usage();
- exit(-1);
- }
- }
-
- init_page_reader();
- init_complaint_sender();
-
- /* initialize random numbers */
- srand(time(NULL) + getpid());
-
- /* Wait forever if necessary for first packet */
- set_delay(0, -1);
- mode = old_mode = TEST; /* hp: add mode */
-
- while(1) { /* loop for all incoming pages */
- if (verbose)
- fprintf(stderr, "Starting listen loop with mode %d\n", mode);
-
- mode = read_handle_page();
- if (verbose) fprintf(stderr, "in mode %d\n", mode);
-
- if (mode == ALL_DONE_CMD) break;
-
- /* got no data? */
- if (mode == TIMED_OUT) {
- if (verbose) fprintf(stderr, "*");
- continue;
- } /* end if TIMED_OUT */
-
- /* changing modes? */
- if ((old_mode != SENDING_DATA) && (mode == SENDING_DATA)){
- /* Taking data, wait at least 3 to 8 seconds */
- set_delay( 3 + rand() % 8, 200);
- if (verbose) fprintf(stderr, "Receiving data\n");
- old_mode = mode;
- continue;
- }
-
- /* all other modes */
- old_mode = mode;
-
- } /* end of incoming page loop */
-
- if (verbose) fprintf(stderr, "Done!\n");
- return 0;
-}
-
-