Consumer.cpp

Go to the documentation of this file.

/* ---------------------------------------------------------------------------
    Phission : 
        Realtime Vision Processing System

    Copyright (C) 2003 Philip D.S. Thoren (pthoren@cs.uml.edu)
    University of Massachusetts at Lowell,
    Laboratory for Artificial Intelligence and Robotics

    This file is part of Phission.

 ---------------------------------------------------------------------------*/
#include <phNodeControllerClient.h>

/* -------------------------------------------------------------------------- */
/* usage: Print out all the usage switches available. */
/* -------------------------------------------------------------------------- */
void usage()
{
    printf("\n\nUsage:\n\t./client <options>\n\toptions:\n");
    printf("\t--host <host> : Define the NC host\n");
    printf("\t--port <port> : Define the NC client port\n");
    printf("\n");
    fflush(stdout);
    exit(1);
}

/* -------------------------------------------------------------------------- *
 * main: The client's main processing block. 
 * -------------------------------------------------------------------------- */
int main( int argc, char *argv[] )
{
    phFUNCTION("main::client")

    int count = 0;
    int limit = 0;

    char    *host   = NULL;
    int     port    = 80;
    
    int verbose = 0;

    phNodeControllerClient *node_controller = NULL;
    
    phArgTable      *arg_parser = new phArgTable();
    
    /* Setup and parse all the arguments */
    /* phARG_CHAR, phARG_INT, phARG_UINT, phARG_LONG,
     * phARG_ULONG, phARG_BOOL, phARG_FUNC */
    rc = arg_parser->add("--host",&host,phARG_CHAR);
    phCHECK_RC(rc,NULL,"arg_parser->add");
    
    rc = arg_parser->add("--port",&port,phARG_INT);
    phCHECK_RC(rc,NULL,"arg_parser->add");

    rc = arg_parser->add("--help",(void*)&usage,phARG_FUNC);
    phCHECK_RC(rc,NULL,"arg_parser->add");

    rc = arg_parser->parse(argc,argv);
    phCHECK_RC(rc,NULL,"arg_parser->parse");
  
    /* Check the arguments */
    /* Check to make sure a host was specified */
    if (host == NULL)
    {
        printf("Error: Hostname must be specified\n");
        usage();
    }

    /* Check to make sure the port is valid */
    if ((port <= 0) || (port >= 65535))
    {
        printf("Error: Port value is invalid - valid values (1,65535)\n");
        usage();
    }

    /* Print out the progress of the client */
    if (verbose)
        printf("Attempting to connect to %s on port %d\n",
                host, port );
   
    node_controller = new phNodeControllerClient(host,port);
    
    rc = node_controller->connect();
    phCHECK_RC(rc,NULL,"node_controller->connect failed.");
    
    if (verbose)
        printf("Connected...\n");
   
    while ((node_controller->isConnected()) && (limit < 10))
    {
        rc = node_controller->request(count % 4);
        phPRINT_RC(rc,NULL,"request(%d)",count % 4);
  
        /* phThread::mSleep(1000); */
        
        rc = node_controller->release(count % 4);
        phPRINT_RC(rc,NULL,"release(%d)",count % 4);
        
        //count++;
        limit++;
        /* main loop */
        phYield();
        phYield();
        phYield();
    }    
    
    phDelete(node_controller);
    phFree(host);
    
    phPROGRESS("Finished Successfully.\n");
    
    return phSUCCESS;    

    /* Error return path */
error:
    phPROGRESS("Finished w/Failure.\n");
    phDelete(node_controller);
    phFree(host);
    
    phDelete(arg_parser);

    return phFAIL;
}

Copyright (C) 2002 - 2007

Philip D.S. Thoren ( pthoren@users.sourceforge.net ) University Of Massachusetts at Lowell Robotics Lab

---