Function cancel_dispatch_common

tests/unit-tests/dds/DCPS/DispatchService.cpp:372–410

namespace {

void cancel_dispatch_common(OpenDDS::DCPS::DispatchService& dispatcher)
{
  SimpleTestObj test_obj_1;
  SimpleTestObj test_obj_2;

  const OpenDDS::DCPS::MonotonicTimePoint now = OpenDDS::DCPS::MonotonicTimePoint::now();

  dispatcher.schedule(test_obj_1, now + OpenDDS::DCPS::TimeDuration::from_double(0.09));
  dispatcher.schedule(test_obj_1, now + OpenDDS::DCPS::TimeDuration::from_double(0.05));
  dispatcher.schedule(test_obj_1, now + OpenDDS::DCPS::TimeDuration::from_double(0.08));
  dispatcher.schedule(test_obj_2, now + OpenDDS::DCPS::TimeDuration::from_double(0.07));
  dispatcher.schedule(test_obj_2, now + OpenDDS::DCPS::TimeDuration::from_double(0.06));
  dispatcher.schedule(test_obj_2, now + OpenDDS::DCPS::TimeDuration::from_double(0.04));

  EXPECT_EQ(dispatcher.cancel(test_obj_1), 3u);
  EXPECT_EQ(dispatcher.cancel(test_obj_2), 3u);

  long t1 = dispatcher.schedule(test_obj_1, now + OpenDDS::DCPS::TimeDuration::from_double(0.09));
  long t2 = dispatcher.schedule(test_obj_1, now + OpenDDS::DCPS::TimeDuration::from_double(0.05));
  long t3 = dispatcher.schedule(test_obj_1, now + OpenDDS::DCPS::TimeDuration::from_double(0.08));
  /*long t4 =*/ dispatcher.schedule(test_obj_1, now + OpenDDS::DCPS::TimeDuration::from_double(0.07));
  /*long t5 =*/ dispatcher.schedule(test_obj_1, now + OpenDDS::DCPS::TimeDuration::from_double(0.06));
  long t6 = dispatcher.schedule(test_obj_1, now + OpenDDS::DCPS::TimeDuration::from_double(0.04));

  EXPECT_EQ(dispatcher.cancel(t6), 1u);
  EXPECT_EQ(dispatcher.cancel(t1), 1u);
  EXPECT_EQ(dispatcher.cancel(t2), 1u);
  void* arg = 0;
  EXPECT_EQ(dispatcher.cancel(t3, &arg), 1u);
  EXPECT_EQ(arg, &test_obj_1);

  EXPECT_EQ(dispatcher.cancel(-1), 0u);

  test_obj_1.wait(2u);
  const OpenDDS::DCPS::MonotonicTimePoint after2 = OpenDDS::DCPS::MonotonicTimePoint::now();

  EXPECT_GE(after2, now + OpenDDS::DCPS::TimeDuration::from_double(0.07));
  EXPECT_EQ(test_obj_1.call_count(), 2u);
}

}