pvinfo.cpp File Reference

#include <iostream>
#include <pva/client.h>
#include <pv/caProvider.h>
#include <stdio.h>
#include <epicsStdlib.h>
#include <epicsGetopt.h>
#include <epicsThread.h>
#include <pv/logger.h>
#include <pv/lock.h>
#include <vector>
#include <string>
#include <sstream>
#include <pv/event.h>
#include <epicsExit.h>
#include "pvutils.h"

Include dependency graph for pvinfo.cpp:

Go to the source code of this file.

Functions
int	main (int argc, char *argv[])

Function Documentation

int main	(	int	argc,
		char *	argv[]
	)

Definition at line 103 of file pvinfo.cpp.

{
    int opt;                    /* getopt() current option */
    bool debug = false;

    setvbuf(stdout,NULL,_IOLBF,BUFSIZ);    /* Set stdout to line buffering */

    while ((opt = getopt(argc, argv, ":hVw:p:dc")) != -1) {
        switch (opt) {
        case 'h':               /* Print usage */
            usage();
            return 0;
        case 'V':               /* Print version */
        {
            fprintf(stdout, "pvAccess %u.%u.%u%s\n",
                    EPICS_PVA_MAJOR_VERSION,
                    EPICS_PVA_MINOR_VERSION,
                    EPICS_PVA_MAINTENANCE_VERSION,
                    (EPICS_PVA_DEVELOPMENT_FLAG)?"-SNAPSHOT":"");
            fprintf(stdout, "pvData %u.%u.%u%s\n",
                    EPICS_PVD_MAJOR_VERSION,
                    EPICS_PVD_MINOR_VERSION,
                    EPICS_PVD_MAINTENANCE_VERSION,
                    (EPICS_PVD_DEVELOPMENT_FLAG)?"-SNAPSHOT":"");
            fprintf(stdout, "Base %s\n", EPICS_VERSION_FULL);
            return 0;
        }
        case 'w':               /* Set PVA timeout value */
        {
            double temp;
            if((epicsScanDouble(optarg, &temp)) != 1 || timeout <= 0.0)
            {
                fprintf(stderr, "'%s' is not a valid timeout value "
                        "- ignored. ('pvget -h' for help.)\n", optarg);
            } else {
                timeout = temp;
            }
        }
            break;
        case 'p':               /* Set default provider */
            defaultProvider = optarg;
            break;
        case 'd':               /* Debug log level */
            debug = true;
            break;
        case 'c':               /* Clean-up and report used instance count */
            break;
        case '?':
            fprintf(stderr,
                    "Unrecognized option: '-%c'. ('pvinfo -h' for help.)\n",
                    optopt);
            return 1;
        case ':':
            fprintf(stderr,
                    "Option '-%c' requires an argument. ('pvinfo -h' for help.)\n",
                    optopt);
            return 1;
        default :
            usage();
            return 1;
        }
    }

    if (argc == optind)
    {
        fprintf(stderr, "No pv name(s) specified. ('pvinfo -h' for help.)\n");
        return 1;
    }

    SET_LOG_LEVEL(debug ? pva::logLevelDebug : pva::logLevelError);

    std::vector<std::tr1::shared_ptr<GetInfo> > infos;

    pva::ca::CAClientFactory::start();

        {
        pvac::ClientProvider prov(defaultProvider);

        for(int i = optind; i<argc; i++) {
            pvac::ClientChannel chan(prov.connect(argv[i]));
            std::tr1::shared_ptr<GetInfo> info(new GetInfo(chan));
            info->op = chan.info(info.get());
            infos.push_back(info);
        }

        Tracker::prepare(); // install signal handler

        {
            Guard G(Tracker::doneLock);
            while(Tracker::inprog.size() && !Tracker::abort) {
                UnGuard U(G);
                if(timeout<=0)
                    Tracker::doneEvt.wait();
                else if(!Tracker::doneEvt.wait(timeout)) {
                    haderror = 1;
                    std::cerr<<"Timeout\n";
                    break;
                }
            }
        }
    }

    return haderror ? 1 : 0;
}