source: ThirdParty/JobMarket/src/unittests/SystemCommandJobUnitTest.cpp@ 91c409

/*
 * Project: JobMarket
 * Description: asynchronous Server/Controller/Client-approach to parallel computing, based on boost::asio
 * Copyright (C)  2010 Frederik Heber. All rights reserved.
 * 
 */

/*
 * SystemCommandJobUnitTest.cpp
 *
 *  Created on: Oct 23, 2011
 *      Author: heber
 */

// include config.h
#ifdef HAVE_CONFIG_H
#include <config.h>
#endif

#include <cppunit/CompilerOutputter.h>
#include <cppunit/extensions/TestFactoryRegistry.h>
#include <cppunit/ui/text/TestRunner.h>

// include headers that implement a archive in simple text format
#include <boost/archive/text_oarchive.hpp>
#include <boost/archive/text_iarchive.hpp>

#include "SystemCommandJobUnitTest.hpp"

#include "JobMarket/Jobs/SystemCommandJob.hpp"
#include "JobMarket/Results/FragmentResult.hpp"
#include "JobMarket/JobId.hpp"

#include "CodePatterns/Assert.hpp"
#include "CodePatterns/Log.hpp"

#ifdef HAVE_TESTRUNNER
#include "JobMarket/UnitTestMain.hpp"
#endif /*HAVE_TESTRUNNER*/

/********************************************** Test classes **************************************/

const std::string resultstring="nothing";

// Registers the fixture into the 'registry'
CPPUNIT_TEST_SUITE_REGISTRATION( SystemCommandJobTest );


void SystemCommandJobTest::setUp()
{
  // Throw assertions
  ASSERT_DO(Assert::Throw);

  setVerbosity(3);

  command = std::string("/bin/true");
  outputfile = std::string("do something");
}


void SystemCommandJobTest::tearDown()
{
}

/** UnitTest for operator==
 */
void SystemCommandJobTest::equalityTest()
{
  FragmentJob::ptr testJob( new SystemCommandJob(command, outputfile, 1) );
  FragmentJob::ptr sameIdJob( new SystemCommandJob(command, outputfile, 1) );
  FragmentJob::ptr otherIdJob( new SystemCommandJob(command, outputfile, 2) );

  CPPUNIT_ASSERT( *testJob == *sameIdJob );
  CPPUNIT_ASSERT( *testJob != *otherIdJob );
}

/** UnitTest for Work()
 */
void SystemCommandJobTest::WorkTest()
{
  FragmentJob::ptr testJob( new SystemCommandJob(command, outputfile, 1) );
  FragmentJob::ptr othertestJob( new SystemCommandJob(command, outputfile, 2) );

  FragmentResult::ptr testResult(testJob->Work());
  FragmentResult::ptr othertestResult(othertestJob->Work());

  CPPUNIT_ASSERT_EQUAL( (JobId_t)1, testResult->getId() );
  CPPUNIT_ASSERT_EQUAL( (JobId_t)2, othertestResult->getId() );
}

/** UnitTest for serialization
 */
void SystemCommandJobTest::serializationTest()
{
  FragmentJob::ptr testJob( new SystemCommandJob(command, outputfile, 1) );
  // write element to stream
  std::stringstream stream;
  boost::archive::text_oarchive oa(stream);
  oa << testJob;

  //std::cout << "Contents of archive is " << stream.str() << std::endl;

  // create and open an archive for input
  boost::archive::text_iarchive ia(stream);
  // read class state from archive
  FragmentJob::ptr otherJob;

  ia >> otherJob;

  const FragmentJob * const testJobptr = testJob.get();
  const FragmentJob * const otherJobptr = otherJob.get();
  const SystemCommandJob * const testSystemJobptr =
      dynamic_cast<const SystemCommandJob *>(testJobptr);
  const SystemCommandJob * const otherSystemJobptr =
      dynamic_cast<const SystemCommandJob *>(otherJobptr);
  CPPUNIT_ASSERT( testSystemJobptr != NULL );
  CPPUNIT_ASSERT( otherSystemJobptr != NULL );
  CPPUNIT_ASSERT( *testSystemJobptr == *otherSystemJobptr);
  // short is the following
  CPPUNIT_ASSERT( *dynamic_cast<const SystemCommandJob *>(testJob.get())
      == *dynamic_cast<const SystemCommandJob *>(otherJob.get()) );
}

/** UnitTest for extractString()
 */
void SystemCommandJobTest::extractStringTest()
{
  SystemCommandJob testJob(command, outputfile, 1);
  // extract and check that it just returns the string
  FragmentResult::ptr result = testJob.extractResult(resultstring);

  CPPUNIT_ASSERT( result->result == resultstring );
}