source: ThirdParty/JobMarket/src/unittests/FragmentResultUnitTest.cpp@ 51a013

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

/*
 * FragmentResultUnitTest.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 <boost/serialization/vector.hpp>

#include "FragmentResultUnitTest.hpp"

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

#include "CodePatterns/Assert.hpp"

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

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

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


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


void FragmentResultTest::tearDown()
{
}

/** UnitTest for operator==
 */
void FragmentResultTest::equalityTest()
{
  FragmentResult testResult(1);
  FragmentResult sameIdResult(1);
  FragmentResult otherIdResult(2);
  FragmentResult copiedResult(testResult);
  FragmentResult copiedchangedResult(testResult);
  copiedchangedResult.setId(3);

  CPPUNIT_ASSERT( testResult == sameIdResult );
  CPPUNIT_ASSERT( testResult != otherIdResult );
  CPPUNIT_ASSERT( testResult == copiedResult );
  CPPUNIT_ASSERT( testResult != copiedchangedResult );
}

/** UnitTest for serialization
 */
void FragmentResultTest::serializationTest()
{
  FragmentResult testResult(1);
  // write element to stream
  std::stringstream stream;
  boost::archive::text_oarchive oa(stream);
  oa << testResult;

  //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
  FragmentResult otherResult(JobId::IllegalJob);

  ia >> otherResult;

  CPPUNIT_ASSERT (testResult == otherResult);
}

/** UnitTest for serialization
 */
void FragmentResultTest::vectorserializationTest()
{
  std::vector<FragmentResult> testresults;
  FragmentResult testResult(1);
  testresults.push_back(testResult);
  // write element to stream
  std::stringstream stream;
  boost::archive::text_oarchive oa(stream);
  oa << testresults;

  //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
  std::vector<FragmentResult> othertestresults;

  ia >> othertestresults;

  CPPUNIT_ASSERT (testresults == othertestresults);
}