harness.cpp File Reference

#include <iostream>
#include <memory>
#include <fstream>
#include <iomanip>
#include <sstream>
#include <vector>
#include <map>
#include <list>
#include <set>
#include <iterator>
#include <algorithm>
#include <typeinfo>
#include <sys/ioctl.h>
#include <signal.h>
#include <termios.h>
#include <errno.h>
#include <string.h>
#include <fix8/f8includes.hpp>
#include <fix8/usage.hpp>
#include <fix8/consolemenu.hpp>
#include "Myfix_types.hpp"
#include "Myfix_router.hpp"
#include "Myfix_classes.hpp"
#include "myfix.hpp"

Go to the source code of this file.

Namespaces
	FIX8
	FIX8::TEX

Functions
void	print_usage ()
const string	GETARGLIST ("hl:svqc:R:S:rp:L:")
bool	term_received (false)
bool	quiet (false)
void	sig_handler (int sig)
int	main (int argc, char **argv)

Detailed Description

This is a complete working example of a FIX client/server using FIX8.

Usage: harness [-LRSchlpqrsv]
-L,–lines set number of screen lines in the console menu (default 50)
-R,–receive set next expected receive sequence number
-S,–send set next send sequence number
-c,–config xml config (default: myfix_client.xml or myfix_server.xml)
-h,–help help, this screen
-l,–log global log filename
-q,–quiet do not print fix output
-r,–reliable start in reliable mode
-s,–server run in server mode (default client mode)
-v,–version print version then exit


To use start the server:

% harness -sl server

In another terminal session, start the client:

% harness -l client

Notes

1. If you have configured with –enable-msgrecycle, the example will reuse allocated messages.
   
2. If you have configured with –enable-customfields, the example will add custom fields
   defined below.
   
3. The client has a simple menu. Press ? to see options.
   
4. The server will wait for the client to logout before exiting.
   
5. The server uses myfix_client.xml and the client uses myfix_server.xml for configuration settings.
   
6. The example uses the files FIX50SP2.xml and FIXT11.xml in ./schema
   
   

Definition in file harness.cpp.

Function Documentation

const string GETARGLIST

(

"hl:svqc:R:S:rp:L:"

)

Referenced by main(), and print_usage().

int main	(	int	argc,
		char **	argv
	)

Definition at line 176 of file harness.cpp.

References FIX8::TEX::ctx(), FIX8_PACKAGE, FIX8_VERSION, MyMenu::get_tty(), GETARGLIST(), glout_info, FIX8::hypersleep< h_seconds >(), RandDev::init(), next_receive(), next_send(), print_usage(), quiet(), FIX8::tty_save_state::set_raw_mode(), sig_handler(), term_received(), and FIX8::f8Exception::what().

{
   int val, lines(50);
   bool server(false), reliable(false);
   string clcf, replay_file;
   unsigned next_send(0), next_receive(0);

   // for xterm or if tput is available, export LINES so we can use here
   const char *gresult(getenv("LINES"));
   if (gresult && *gresult)
   {
      const string result(gresult);
      const int nlines(stoi(result));
      if (nlines > 10)
         lines = nlines - 4;
   }

#ifdef FIX8_HAVE_GETOPT_LONG
   option long_options[]
   {
      { "help",      0, 0, 'h' },
      { "version",   0, 0, 'v' },
      { "log",       1, 0, 'l' },
      { "config",    1, 0, 'c' },
      { "replay",    1, 0, 'p' },
      { "server",    0, 0, 's' },
      { "send",      1, 0, 'S' },
      { "receive",   1, 0, 'R' },
      { "lines",     1, 0, 'L' },
      { "quiet",     0, 0, 'q' },
      { "reliable",  0, 0, 'r' },
      { 0 },
   };

   while ((val = getopt_long (argc, argv, GETARGLIST.c_str(), long_options, 0)) != -1)
#else
   while ((val = getopt (argc, argv, GETARGLIST.c_str())) != -1)
#endif
   {
      switch (val)
      {
      case 'v':
         cout << argv[0] << " for " FIX8_PACKAGE " version " FIX8_VERSION << endl;
         cout << "Released under the GNU LESSER GENERAL PUBLIC LICENSE, Version 3. See <http://fsf.org/> for details." << endl;
         return 0;
      case ':': case '?': return 1;
      case 'h': print_usage(); return 0;
      case 'l': GlobalLogger::set_global_filename(optarg); break;
      case 'p': replay_file = optarg; break;
      case 'c': clcf = optarg; break;
      case 's': server = true; break;
      case 'S': next_send = stoul(optarg); break;
      case 'R': next_receive = stoul(optarg); break;
      case 'L': lines = stoul(optarg); break;
      case 'q': quiet = true; break;
      case 'r': reliable = true; break;
      default: break;
      }
   }

   RandDev::init();

   signal(SIGTERM, sig_handler);
   signal(SIGINT, sig_handler);
#ifndef _MSC_VER
    signal(SIGQUIT, sig_handler);
#endif

   try
   {
      const string conf_file(server ? clcf.empty() ? "myfix_server.xml" : clcf : clcf.empty() ? "myfix_client.xml" : clcf);

      if (server)
      {
         unique_ptr<ServerSessionBase> ms(new ServerSession<myfix_session_server>(TEX::ctx(), conf_file, "TEX1"));

         for (unsigned scnt(0); !term_received; )
         {
            if (!ms->poll())
               continue;
            unique_ptr<FIX8::SessionInstanceBase> inst(ms->create_server_instance());
            if (!quiet)
               inst->session_ptr()->control() |= Session::printnohb;
            glout_info << "client(" << ++scnt << ") connection established.";
            inst->start(true, next_send, next_receive);
            cout << "Session(" << scnt << ") finished." << endl;
            inst->stop();
         }
      }
      else
      {
         unique_ptr<ClientSessionBase>
            mc(reliable ? new ReliableClientSession<myfix_session_client>(TEX::ctx(), conf_file, "DLD1")
                        : new ClientSession<myfix_session_client>(TEX::ctx(), conf_file, "DLD1"));
         if (!quiet)
            mc->session_ptr()->control() |= Session::printnohb;

         if (!reliable)
         {
            const LoginParameters& lparam(mc->session_ptr()->get_login_parameters());
            mc->start(false, next_send, next_receive, lparam._davi());
         }
         else
            mc->start(false);

         ConsoleMenu cm(TEX::ctx(), cin, cout, lines);
         MyMenu mymenu(*mc->session_ptr(), 0, cout, &cm);
         mymenu.get_tty().set_raw_mode();
         hypersleep<h_seconds>(1);

         // permit replaying of test message sets
         if (!replay_file.empty() && mymenu.load_msgs(replay_file))
            mymenu.send_lst();

         for(; !term_received;)
         {
            cout << endl;
            if (mymenu.get_msg_cnt())
               cout << '[' << mymenu.get_msg_cnt() << "] msgs; ";
            cout << "?=help > " << flush;
            char ch{};
            mymenu.get_istr().get(ch);
            cout << ch << endl;
            if (mymenu.get_istr().bad() || ch == 0x3 || !mymenu.process(ch))
               break;
         }

         mymenu.get_tty().unset_raw_mode();
      }
   }
   catch (f8Exception& e)
   {
      cerr << "exception: " << e.what() << endl;
   }
   catch (exception& e) // also catches Poco::Net::NetException
   {
      cerr << "exception: " << e.what() << endl;
   }

   if (term_received)
      cout << "terminated." << endl;
   return 0;
}

void print_usage

(

)

Definition at line 379 of file harness.cpp.

References UsageMan::add(), GETARGLIST(), UsageMan::print(), and UsageMan::setdesc().

Referenced by main().

{
   UsageMan um("harness", GETARGLIST, "");
   um.setdesc("harness -- menu driven f8 test client/server");
   um.add('s', "server", "run in server mode (default client mode)");
   um.add('h', "help", "help, this screen");
   um.add('v', "version", "print version then exit");
   um.add('l', "log", "global log filename");
   um.add('p', "replay", "name of fix input file to send on connect");
   um.add('c', "config", "xml config (default: myfix_client.xml or myfix_server.xml)");
   um.add('q', "quiet", "do not print fix output");
   um.add('R', "receive", "set next expected receive sequence number");
   um.add('L', "lines", "set number of screen lines in the console menu (default 50)");
   um.add('S', "send", "set next send sequence number");
   um.add('r', "reliable", "start in reliable mode");
   um.print(cerr);
}

bool quiet

(

false

)

Referenced by main().

void sig_handler

(

int

sig

)

Definition at line 160 of file harness.cpp.

References term_received().

Referenced by main().

{
   switch (sig)
   {
   case SIGTERM:
   case SIGINT:
#ifndef _MSC_VER
   case SIGQUIT:
#endif
      term_received = true;
      signal(sig, sig_handler);
      break;
   }
}

bool term_received

(

false

)

Referenced by main(), and sig_handler().