loon: daq_bin2roto.c File Reference

00056 {
00057 
00058    /* this is C ... all declarations must come first */
00059    const char* iphost = "localhost";
00060    const char* default_producer = "DCP";       /* default producer */
00061    const int   default_port     = 9011;        /* default port     */
00062    const char* producer = default_producer;
00063    const char* autosave_config = 0;
00064    const char* compress_config = 0;
00065    const char* basketsize_config = 0;
00066    int port = default_port;
00067    int whoami = MINOS_ROOTER_DCP;       
00068    int bsize = MAXBUFFER;
00069    long* buffer = 0;
00070    int nerr = 0;
00071    int mxrec = 0;
00072    int nodelay_flag = 1;  /* on by default */
00073    int echoMsgLog = 0;
00074    int copt;
00075 
00076    /*
00077     * parse the options and filenames
00078     * -i and -p take args
00079     */
00080    while ((copt = getopt(argc, argv, "i:b:c:C:B:w:p:ev:n:D:h")) != EOF) {
00081       switch (copt) {
00082       case 'i':  /* internet host */
00083          iphost = optarg;
00084          break;
00085       case 'b':  /* buffer size */
00086          bsize = atoi(optarg);
00087          break;
00088       case 'c':  /* autosave config string */
00089          autosave_config = optarg;
00090          break;
00091       case 'C':  /* compression config string */
00092          compress_config = optarg;
00093          break;
00094       case 'B':  /* basketsize config string */
00095          basketsize_config = optarg;
00096          break;
00097       case 'w':  /* whoami:  DCP, DCS, other */
00098          producer = optarg;
00099          break;
00100       case 'p':  /* port # */
00101          port = atoi(optarg);
00102          break;
00103       case 'e':  /* msgLog messages to stdout as well */
00104          echoMsgLog = 1;
00105          break;
00106       case 'v':  /* verbosity */
00107          roto_verbose = atoi(optarg);
00108          break;
00109       case 'n':  /* maximum number of records */
00110          mxrec = atoi(optarg);
00111          break;
00112       case 'D':  /* set nodelay_flag? */
00113          nodelay_flag = atoi(optarg);
00114          break;
00115       case 'h':  /* help */
00116          printf(" usage: %s -i<hostname> -b<buffer size> -w<whoami> -p<port #> <filenames..>\n", argv[0]);
00117          printf("   -i: hostname where rotorooter is running\n");
00118          printf("   -b: buffer size to use\n");
00119          printf("   -w: DCP or DCS\n");
00120          printf("   -p: port number rotorooter is listening on\n");
00121          printf("   -v: how verbose to be\n");
00122          printf("   -c: autosave config \"streamName,nrec,nsec[;streamName,nrec,nsec]\"\n");
00123          printf("   -C: compression config \"streamName,level[;streamName,level]\"\n");
00124          printf("   -B: basketsize config \"streamName,size[;streamName,size]\"\n");
00125 
00126          printf("   -n: maximum number of records from each file\n");
00127 
00128          printf("   -h: print this message\n");
00129          exit(1);
00130       default:
00131          printf(" unrecognized option '%c' ignored\n",(char)optopt);
00132          break;
00133       }
00134    }
00135 
00136    msgLogInit(argv[0]);
00137    msgLogNodeIdSet(whoami);
00138    msgLogLocalEchoSet(echoMsgLog);
00139    logDebugLevelSet(3);
00140    logNotice("starting %s",argv[0]);
00141 
00142    /* allocate a buffer to use */
00143    buffer = (long*) malloc(bsize);
00144    if (!buffer) {
00145       printf("failed to allocate buffer of size %d\n",bsize);
00146       exit(1);
00147    }
00148    if (roto_verbose>1) printf("allocated buffer of size %d\n",bsize);
00149 
00150    /* open a connection to the Rotorooter */
00151    if (0 == strcmp(producer,default_producer) && 
00152        port == default_port) {
00153       /* standard connection */
00154       if (roto_verbose>1) 
00155          printf("connect via roto_open_DCP_connection\n");
00156       nerr += roto_open_DCP_connection(iphost);
00157    } else {
00158       /* non-standard connection requested (either producer or port) */
00159       if (0 == strcmp(producer,"DCP")) {
00160          whoami  = MINOS_ROOTER_DCP;
00161       }
00162       else if (0 == strcmp(producer,"DCS")) {
00163          whoami = MINOS_ROOTER_DCS;
00164       }
00165       else if (0 == strcmp(producer,"BEAMMON")) {
00166          whoami = MINOS_ROOTER_BEAMMON;
00167       }
00168       else 
00169          whoami = MINOS_ROOTER_UNIDENTIFIED_CLIENT;
00170 
00171       if (roto_verbose>1) 
00172          printf("connect via roto_open_connection: port %d, whoami %s (0x%2.2x)\n",port,producer,whoami);
00173       nerr += roto_open_connection(iphost,port,whoami);
00174    }
00175    if (nerr) exit(nerr);
00176    
00177    nerr += roto_set_connection_nodelay(nodelay_flag);
00178 
00179    if (autosave_config) nerr += config_autosave(autosave_config);
00180    if (compress_config) nerr += config_compress(compress_config);
00181    if (basketsize_config) nerr += config_basketsize(basketsize_config);
00182 
00183    /* process each file in turn */
00184    while (optind < argc) {
00185       nerr += send_whole_file(argv[optind++],buffer,bsize,mxrec);
00186    }   
00187 
00188    /* close the connection */
00189    nerr += roto_close_connection();
00190 
00191    /* set my buffer free */
00192    free(buffer);
00193 
00194    logNotice("stopping %s",argv[0]);
00195    msgLogCleanup();
00196 
00197    exit(nerr);
00198 }

Defines
#define	MAXBUFFER 8388608
Functions
int	send_whole_file (const char fname, long buffer, int bsize, int mxrec)
int	config_autosave (const char *config)
int	config_compress (const char *config)
int	config_basketsize (const char *config)
int	main (int argc, char **argv)
daq_bin2roto.c File Reference

Defines

Functions

Define Documentation

Function Documentation
