JControlHost.cc

Go to the documentation of this file.

#include <string>
#include <iostream>
#include <iomanip>
#include <sstream>
 
#include "JNet/JControlHost.hh"
#include "JSystem/JNetwork.hh"
 
#include "Jeep/JParser.hh"
#include "Jeep/JMessage.hh"
 
 
/**
 * \file
 *
 * Example program to test JNET::JControlHost.
 * \author mdejong
 */
int main(int argc, char* argv[])
{
  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;
}