JControlHost.cc File Reference

Example program to test JNET::JControlHost. More...

#include <string>
#include <iostream>
#include <iomanip>
#include <sstream>
#include "JNet/JControlHost.hh"
#include "JSystem/JNetwork.hh"
#include "Jeep/JParser.hh"
#include "Jeep/JMessage.hh"

Go to the source code of this file.

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

Detailed Description

Example program to test JNET::JControlHost.

Author

mdejong

Definition in file JControlHost.cc.

Function Documentation

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

Definition at line 19 of file JControlHost.cc.

{
  using namespace std;
  using namespace JPP;

  string  hostname;
  JTag    tag;
  string  message;
  bool    any;
  int     debug;

  try {

    JParser<> zap("Example program to test communication with JControlHost server.");

    zap['H'] = make_field(hostname)        = "localhost";
    zap['T'] = make_field(tag)             = JTag("ME");
    zap['m'] = make_field(message)         = "hello world";
    zap['Y'] = make_field(any);
    zap['d'] = make_field(debug)           = 3;

    zap(argc, argv);
  }
  catch(const exception &error) {
    FATAL(error.what() << endl);
  }


  const string pid = argv[0];

  try {

    JControlHost socket(hostname);

    DEBUG("Subscription: " << tag << endl);

    socket.MyId(pid);

    if (any) {
      socket.Subscribe(JSubscriptionAny(tag));
    }    
    else {
      socket.Subscribe(JSubscriptionAll(tag));
    }
        
   socket.SendMeAlways();

    DEBUG("Send message: "
          << "tag <"    << tag     << "> " 
          << "string <" << message << ">" << endl);
    
    socket.PutFullString(tag, message);

    {
      DEBUG("Test GetFullString()." << endl);

      JPrefix prefix;
      string  buffer;

      for (useconds_t i = 0; i != 10000; ++i) {

        if (socket.CheckHead(prefix) > 0) {
      
          DEBUG("Got message: "
                << "time "   << i                << " us " 
                << "tag <"   << prefix.getTag()  << "> " 
                << "length " << prefix.getSize() << endl);

          
          socket.GetFullString(buffer);
      
          NOTICE("string <" << buffer << ">" << endl);

          ASSERT(buffer == message);

          break;

        } else

          usleep(1);
      }

      if (prefix.toString() == "") {
        FATAL("Timeout." << endl);
      }
    }


    {
      DEBUG("Test WhereIs()." << endl);

      string answer;

      ControlHost::WhereIs(hostname, pid, answer);

      istringstream is(answer);

      for (string buffer; is >> buffer; ) {

        NOTICE("Host: " << buffer << endl);

        ASSERT(buffer == getHostname(getIPnumber()));
      }
    }


    try {
       
      DEBUG("Test Throw(true)." << endl);
     
      socket.close();
      
      try {
        
        ControlHost::Throw(true);
        
        socket.PutFullString(tag[0], message);

        ASSERT(false);
      }
      catch(const JException& error) {

        NOTICE("Exception test: " << error.what() << endl);

        ASSERT(true);
      }
      

      DEBUG("Test Throw(false)." << endl);

      ControlHost::Throw(false);
      
      int retcd = socket.PutFullString(tag[0], message);
      
      NOTICE("Return code test: " << retcd << endl);

      ASSERT(retcd != 0);
    }
    catch(const JSocketException& error) {
      NOTICE("Exception test failed: " << error.what() << endl);
    }
  }
  catch(const JSocketException& error) {
    FATAL(error.what() << endl);
  }

  return 0;
}