view/runCtrl/TestTransmitCtrl.cpp

/*!
  \file
  \brief TransmitCtrll のテスト

  \author Satofumi KAMIMURA

  $Id$
*/

#include "TestTransmitCtrl.h"
#include "TransmitCtrl.h"
#include "ThreadCreator.h"
#include "transferCtrl.h"


CPPUNIT_TEST_SUITE_REGISTRATION(TestTransmitCtrl);
CPPUNIT_TEST_SUITE_NAMED_REGISTRATION(TestTransmitCtrl, "TestTransmitCtrl");

using namespace beego;


void TestTransmitCtrl::setUp(void) {

  run_sim = new tRunCtrlSimulator;
  run_sim->activate();
  port.disconnect();
  run_sim->connect(&port);
}


void TestTransmitCtrl::tearDown(void) {
  delete run_sim;
}


void TestTransmitCtrl::accessTest(void) {

  // 書き込んだ内容を読み出して確認する
  TransmitCtrl transmit(&port, reinterpret_cast<unsigned char*>(&host_run));
  enum {
    Timeout = 100,
  };

  // 読み出し
  host_run.wdt.active = 3;
  transmit.initPacket(READ_PACKET);
  transmit.addVariable(reinterpret_cast<unsigned char*>(&host_run.wdt.active),
                       sizeof(host_run.wdt.active));
  bool ret = transmit.send(NULL);
  CPPUNIT_ASSERT_EQUAL(ret, true);
  run_sim->runMainTask();

  ret = transmit.recv(Timeout);
  CPPUNIT_ASSERT_EQUAL(ret, true);
  CPPUNIT_ASSERT_EQUAL(0, static_cast<int>(host_run.wdt.active));

  // 書き込み
  transmit.initPacket(WRITE_PACKET);
  ADD_WRITE_VARIABLE(transmit, host_run.wdt.active, 1);
  transmit.send(NULL);
  run_sim->runMainTask();
  transmit.recv(Timeout);
  CPPUNIT_ASSERT_EQUAL(1, static_cast<int>(host_run.wdt.active));

  // 読み出し
  host_run.wdt.active = 0;
  CPPUNIT_ASSERT_EQUAL(0, static_cast<int>(host_run.wdt.active));
  transmit.initPacket(READ_PACKET);
  ADD_READ_VARIABLE(transmit, host_run.wdt.active);
  transmit.send(NULL);
  run_sim->runMainTask();
  transmit.recv(Timeout);
  CPPUNIT_ASSERT_EQUAL(1, static_cast<int>(host_run.wdt.active));
}


void TestTransmitCtrl::minusTest(void) {

  // 負の値の読み書きテスト
  TransmitCtrl transmit(&port, reinterpret_cast<unsigned char*>(&host_run));
  enum {
    Timeout = 100,
  };

  // 書き込み
  transmit.initPacket(WRITE_PACKET);
  ADD_WRITE_VARIABLE(transmit, host_run.wdt.active, -1);
  transmit.send(NULL);
  run_sim->runMainTask();
  transmit.recv(Timeout);
  CPPUNIT_ASSERT_EQUAL(-1, static_cast<int>(host_run.wdt.active));

  // 読み出し
  host_run.wdt.active = 0;
  CPPUNIT_ASSERT_EQUAL(0, static_cast<int>(host_run.wdt.active));
  transmit.initPacket(READ_PACKET);
  ADD_READ_VARIABLE(transmit, host_run.wdt.active);
  transmit.send(NULL);
  run_sim->runMainTask();
  transmit.recv(Timeout);
  CPPUNIT_ASSERT_EQUAL(-1, static_cast<int>(host_run.wdt.active));
}


void TestTransmitCtrl::frontChunkTest(void) {

  // ゴミデータ + 正常データを送信して、応答が返されるかを確認する
  TransmitCtrl transmit(&port, reinterpret_cast<unsigned char*>(&host_run));
  enum {
    Timeout = 100,
  };

  transmit.initPacket(WRITE_PACKET);
  ADD_WRITE_VARIABLE(transmit, host_run.wdt.active, 5);
  bool ret = transmit.send(NULL);
  CPPUNIT_ASSERT_EQUAL(true, ret);
  run_sim->runMainTask();
  ret = transmit.recv(Timeout);
  CPPUNIT_ASSERT_EQUAL(true, ret);

  // ゴミデータの混入
  port.send("gomi", 4);

  // 読み出し
  host_run.wdt.active = 0;
  CPPUNIT_ASSERT_EQUAL(0, static_cast<int>(host_run.wdt.active));
  transmit.initPacket(READ_PACKET);
  ADD_READ_VARIABLE(transmit, host_run.wdt.active);
  transmit.send(NULL);
  run_sim->runMainTask();
  run_sim->runMainTask();
  ret = transmit.recv(Timeout);
  CPPUNIT_ASSERT_EQUAL(true, ret);
  CPPUNIT_ASSERT_EQUAL(5, static_cast<int>(host_run.wdt.active));
}