#ifndef TTCaptain_H
#define TTCaptain_H

#include <ctime>
#include <vector>
#include <algorithm>
#include <iostream>
#include <fstream>
#include <sstream>
#include <iterator>
#include <numeric>

#include <cppvm.h>

using std::vector;

const int maxrow = 5;
const double range = 5;

////////////////////////////////////////////////////////////////////////////////////////////////////////
//TCaptain Class Deklaration
////////////////////////////////////////////////////////////////////////////////////////////////////////
class TCaptain
{

	void open_Matrix();
	char *fname;

	std::ostream_iterator<double, char> *out;

protected:
	cppvmConnection Conn;
	std::stringstream sts;
	std::ofstream oFile;

//simulation vars
	int max;
	int tid;
	vector<double> vec;
	vector<vector<double> > matrix;
	vector<double>::iterator vit;
	vector<vector<double> >::iterator mit;

	//serialisation array
	double *ioarray;

	inline virtual void Step();

	inline void save_Vec();

public:
	TCaptain( const int inmax, char *ifn, cppvmConnection inConn);
	~TCaptain(){ oFile.close(); delete out;}

	virtual void makeitso();
};

////////////////////////////////////////////////////////////////////////////////////////////////////////
//TCaptain Class implementation
////////////////////////////////////////////////////////////////////////////////////////////////////////
//Standard Constructor
TCaptain::TCaptain( const int inmax, char * ifn, cppvmConnection inConn) :
	max( inmax), fname( ifn), Conn( inConn)
{
	vec.resize( maxrow, 0.);

	time_t t;
	srand( static_cast<unsigned> ( time( &t)));

	oFile.open( fname, std::ios_base::out | std::ios_base::trunc);

	out = new std::ostream_iterator<double, char>( oFile, "\t");

	ioarray = new double[maxrow];
}

////////////////////////////////////////////////////////////////////////////////////////////////////////
//reset the vector
void TCaptain::Step()
{
	for( vit = vec.begin(); vit!=vec.end(); ++vit)
		( *vit)= ( rand()*range/RAND_MAX) - range*0.5;
	save_Vec();
}

////////////////////////////////////////////////////////////////////////////////////////////////////////
//do what has to be done
void TCaptain::makeitso()
{
	cppvmSpawnConnection Sailor("withcpp_slr");
	cppvmSendStream Comm( Sailor, CPPvmSNBchild);

	tid = Comm.getTid();
	open_Matrix();

	for( mit = matrix.begin(); mit!=matrix.end(); ++mit) Comm<<( *mit);

	for( int i = 0; i<max; ++i)
	{
		Step();
		std::copy( vec.begin(), vec.end(), ioarray);
		pvm_psend( tid, 0, ioarray, maxrow, PVM_DOUBLE);
	}
}

////////////////////////////////////////////////////////////////////////////////////////////////////////
//load the matrix
void TCaptain::open_Matrix()
{
	std::ifstream RFile;
	char tr2[2000];

	RFile.open( "matriksch");
	sts.clear();
	while( RFile.good())
	{
		vec.clear();
		RFile.getline( tr2, 2000);
		sts<<tr2;
		std::copy( std::istream_iterator<double>( sts), std::istream_iterator<double>(),
			std::back_inserter( vec));
		sts.clear();
		matrix.push_back( *( new vector<double>( vec)));
	}

	vec.clear();
	vec.resize( maxrow, 0.);
	RFile.close();
}

////////////////////////////////////////////////////////////////////////////////////////////////////////
//save the vector
void TCaptain::save_Vec()
{
	std::copy( vec.begin(), vec.end(), *out);
	oFile<<std::endl;
}

#endif