Function TEST_P_TEMP_DISABLED_ON_WINDOWS

src/tests/scheduler_tests.cpp:312–372

This test verifies that the scheduler can subscribe after a master failover.

// This test verifies that the scheduler can subscribe after a master failover.
TEST_P_TEMP_DISABLED_ON_WINDOWS(SchedulerTest, MasterFailover)
{
  Try<Owned<cluster::Master>> master = StartMaster();
  ASSERT_SOME(master);

  auto scheduler = std::make_shared<v1::MockHTTPScheduler>();
  auto detector = std::make_shared<StandaloneMasterDetector>(master.get()->pid);

  EXPECT_CALL(*scheduler, connected(_))
    .WillOnce(v1::scheduler::SendSubscribe(v1::DEFAULT_FRAMEWORK_INFO))
    .WillRepeatedly(Return());

  Future<Event::Subscribed> subscribed;
  EXPECT_CALL(*scheduler, subscribed(_, _))
    .WillOnce(FutureArg<1>(&subscribed))
    .WillRepeatedly(Return());

  EXPECT_CALL(*scheduler, heartbeat(_))
    .WillRepeatedly(Return()); // Ignore heartbeats.

  ContentType contentType = GetParam();

  v1::scheduler::TestMesos mesos(
      master.get()->pid, contentType, scheduler, detector);

  AWAIT_READY(subscribed);

  v1::FrameworkID frameworkId = subscribed->framework_id();

  Future<Nothing> disconnected;
  EXPECT_CALL(*scheduler, disconnected(_))
    .WillOnce(FutureSatisfy(&disconnected))
    .WillRepeatedly(Return()); // Ignore future invocations.

  // Failover the master.
  // Also wipe the leading master from the detector, so the scheduler
  // does not try to reconnect while the master actor is not routable.
  master->reset();
  detector->appoint(None());

  master = StartMaster();
  ASSERT_SOME(master);

  AWAIT_READY(disconnected);

  EXPECT_CALL(*scheduler, connected(_))
    .WillOnce(
        v1::scheduler::SendSubscribe(v1::DEFAULT_FRAMEWORK_INFO, frameworkId));

  Future<Event::Subscribed> subscribed2;
  EXPECT_CALL(*scheduler, subscribed(_, _))
    .WillOnce(FutureArg<1>(&subscribed2))
    .WillRepeatedly(Return());

  // Give the master leadership now that our scheduler expectations are set up.
  detector->appoint(master.get()->pid);

  AWAIT_READY(subscribed2);