/**
 * \file    Supplier.cpp
 * \brief   RTCORBA Client, sends ping commands to Receiver
 *
 * \author  Manuel Traut
 * \version 2009-06-23
 *
 */

#include <iostream>
#include <string>
#include <unistd.h>
#include <orbsvcs/CosNamingC.h>
#include <tao/RTCORBA/RTCORBA.h>

#include "pingC.h"

static Linutronix::Ping_var ping;
static std::string str;

int main(int argc, char* argv[])
{
	if (argc > 1)
		str = argv[1];
	else
		str = "no argument given";

	try{
		// initialize ORB
		CORBA::ORB_var orb = CORBA::ORB_init(argc, argv, "ClientORB");
		std::cout<<"ORB ok"<<std::endl;

		// get RTORB
		CORBA::Object_var rtorb = orb->resolve_initial_references("RTORB");
		RTCORBA::RTORB_var rt_orb = RTCORBA::RTORB::_narrow(rtorb.in());
		std::cout<<"RTORB ok"<<std::endl;

		// NamingService
		CORBA::Object_var naming_obj =
			orb->resolve_initial_references("NameService");

		CosNaming::NamingContext_var naming_context =
			CosNaming::NamingContext::_narrow(naming_obj.in());

		std::cout<<"NamingService ok"<<std::endl;

		CosNaming::Name name(1);
		name.length(1);
		name[0].id = CORBA::string_dup("Receiver");

		// receive Object
		CORBA::Object_var ping_obj = naming_context->resolve(name);
		ping = Linutronix::Ping::_narrow(ping_obj.in());
		std::cout<<"TransferOjekt ok"<<std::endl;

		// Private Connection Policy
		CORBA::PolicyList pc_policy(1);
		pc_policy.length(1);
		pc_policy[0] = rt_orb->create_private_connection_policy();

		CORBA::Object_var new_tran =
			ping->_set_policy_overrides(pc_policy, CORBA::SET_OVERRIDE);

		ping = Linutronix::Ping::_narrow(new_tran.in());
		std::cout<<"PrivateConnection ok"<<std::endl;

		struct timespec time_tx;
		struct timespec time_done;

		for(unsigned int i = 0; i < 100; i++)
		{
			clock_gettime(CLOCK_MONOTONIC, &time_tx);
			ping->send((const char*)str.c_str());
			clock_gettime(CLOCK_MONOTONIC, &time_done);
			std::cout<<time_tx.tv_sec<<":"<<time_tx.tv_nsec/1000<<"\n";
			std::cout<<time_done.tv_sec<<":"<<time_done.tv_nsec/1000<<"\n\n";
		}

		// destroy ORB
		orb->destroy();

	} catch(CORBA::Exception &any) {
		std::cout<<"Exception occured: "<<any<<std::endl;
	}
	return 0;
}