view/connection/TestUdpipCtrl.cpp

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

  \author Satofumi KAMIMURA

  $Id$
*/

#include "TestUdpipCtrl.h"
#include "UdpipCtrl.h"

CPPUNIT_TEST_SUITE_REGISTRATION(UdpipCtrlTest);
CPPUNIT_TEST_SUITE_NAMED_REGISTRATION(UdpipCtrlTest, "UdpipCtrlTest");

using namespace beego;


enum { Port = 9763 };


/*!
  \brief 送受信テスト
*/
void UdpipCtrlTest::readWriteTest(void) {

  UdpipCtrl udp_send(UdpipCtrl::ClientMode);
  UdpipCtrl udp_recv(Port);

  // 接続
  bool ret = udp_send.connect("localhost", Port);
  CPPUNIT_ASSERT_EQUAL(true, ret);

  // １文字送信、受信
  int n = udp_send.send("A", 1);
  CPPUNIT_ASSERT_EQUAL(1, n);

  char ch;
  for (int i = 0; i < 10; ++i) {
    n = udp_recv.recv(&ch, 1, 10);
    if (n > 0) {
      break;
    }
  }
  CPPUNIT_ASSERT_EQUAL(1, n);
  CPPUNIT_ASSERT_EQUAL('A', ch);
}


void UdpipCtrlTest::bindTest(void) {

  // ２ポートを bind して、送受信できるかを試す

  // 送信ポート
  UdpipCtrl udp_send;

  // ２つの送信ポートの割り当て
  bool ret = udp_send.connect("localhost", Port);
  CPPUNIT_ASSERT_EQUAL(true, ret);
  ret = udp_send.connect("localhost", Port + 1);
  CPPUNIT_ASSERT_EQUAL(true, ret);

  // 受信ポート
  UdpipCtrl udp_recv_1(Port);
  UdpipCtrl udp_recv_2(Port + 1);

  // 送信
  int n = udp_send.send("B", 1);
  CPPUNIT_ASSERT_EQUAL(2, n);

  // 受信
  char recv_ch;
  n = udp_recv_1.recv(&recv_ch, 1, 10);
  CPPUNIT_ASSERT_EQUAL(1, n);
  CPPUNIT_ASSERT_EQUAL(recv_ch, 'B');

  n = udp_recv_2.recv(&recv_ch, 1, 10);
  CPPUNIT_ASSERT_EQUAL(1, n);
  CPPUNIT_ASSERT_EQUAL(recv_ch, 'B');
}


#if 0
void UdpipCtrlTest::bufferTest(void) {

  // 連続送信がバッファリングされるかのテスト
  // !!!
  // UdpipCtrl の受信周りをリングバッファ管理してから、テストを行う

  CPPUNIT_FAIL("Not implemented.");
}
#endif