Function TEST_F

src/tests/operation_status_update_manager_tests.cpp:142–173

This test verifies that the status update manager will not retry a terminal status update after it has been acknowledged.

// This test verifies that the status update manager will not retry a terminal
// status update after it has been acknowledged.
TEST_F(OperationStatusUpdateManagerTest, UpdateAndAck)
{
  Future<UpdateOperationStatusMessage> forwardedStatusUpdate;
  EXPECT_CALL(statusUpdateProcessor, update(_))
    .WillOnce(FutureArg<0>(&forwardedStatusUpdate));

  const id::UUID operationUuid = id::UUID::random();
  const id::UUID statusUuid = id::UUID::random();

  UpdateOperationStatusMessage statusUpdate =
    createUpdateOperationStatusMessage(
        statusUuid, operationUuid, OperationState::OPERATION_FINISHED);

  // Send a checkpointed operation status update.
  AWAIT_ASSERT_READY(statusUpdateManager->update(statusUpdate, true));

  UpdateOperationStatusMessage expectedStatusUpdate(statusUpdate);
  expectedStatusUpdate.mutable_latest_status()->CopyFrom(statusUpdate.status());

  // Verify that the status update is forwarded.
  AWAIT_EXPECT_EQ(expectedStatusUpdate, forwardedStatusUpdate);

  // Acknowledge the update, this is a terminal update, so `acknowledgement`
  // should return `false`.
  AWAIT_EXPECT_FALSE(
      statusUpdateManager->acknowledgement(operationUuid, statusUuid));

  // Advance the clock, the status update has been acknowledged, so it shouldn't
  // trigger a retry.
  Clock::advance(slave::STATUS_UPDATE_RETRY_INTERVAL_MIN);
  Clock::settle();
}


// This test verifies that the status update manager will not retry a