utils/dnp3_src/cpp/tests/opendnp3/src/TestMaster.cpp - master - tisit/OpenPLC_v3

utils/dnp3_src/cpp/tests/opendnp3/src/TestMaster.cpp
639 строк19 KB
thiagoralves
First commit. OpenPLC v3 beta 1
14 июн 2018, 20:43
14 июн 2018, 20:431b10e97
/*
 * Licensed to Green Energy Corp (www.greenenergycorp.com) under one or
 * more contributor license agreements. See the NOTICE file distributed
 * with this work for additional information regarding copyright ownership.
 * Green Energy Corp licenses this file to you under the Apache License,
 * Version 2.0 (the "License"); you may not use this file except in
 * compliance with the License.  You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 * This project was forked on 01/01/2013 by Automatak, LLC and modifications
 * may have been made to this file. Automatak, LLC licenses these modifications
 * to you under the terms of the License.
 */
#include <catch.hpp>

#include "mocks/MasterTestObject.h"
#include "mocks/MeasurementComparisons.h"

#include <testlib/HexConversions.h>
#include <dnp3mocks/MockTaskCallback.h>
#include <dnp3mocks/APDUHexBuilders.h>
#include <dnp3mocks/CallbackQueue.h>

#include <opendnp3/app/APDUResponse.h>
#include <opendnp3/app/APDUBuilders.h>

using namespace openpal;
using namespace opendnp3;
using namespace testlib;

#define SUITE(name) "MasterTestSuite - " name

TEST_CASE(SUITE("notifies application of state changes"))
{
	MasterParams params;
	params.disableUnsolOnStartup = false;
	MasterTestObject t(params);

	REQUIRE(t.application->stateChanges.empty());
	t.context->OnLowerLayerUp();

	REQUIRE(t.application->stateChanges.size() == 1);
	REQUIRE(t.application->stateChanges.front() == MockMasterApplication::State::OPEN);
	t.application->stateChanges.pop_front();

	t.context->OnLowerLayerDown();

	REQUIRE(t.application->stateChanges.size() == 1);
	REQUIRE(t.application->stateChanges.front() == MockMasterApplication::State::CLOSED);
	t.application->stateChanges.pop_front();
}

TEST_CASE(SUITE("IntegrityOnStartup"))
{
	MasterParams params;
	params.disableUnsolOnStartup = false;
	MasterTestObject t(params);
	t.context->OnLowerLayerUp();

	REQUIRE(t.exe->RunMany() > 0);

	REQUIRE(t.lower->PopWriteAsHex() == hex::IntegrityPoll(0));
}

TEST_CASE(SUITE("SolicitedResponseWithData"))
{
	MasterParams params;
	params.disableUnsolOnStartup = false;
	params.unsolClassMask = 0;
	MasterTestObject t(params);
	t.context->OnLowerLayerUp();

	t.exe->RunMany();

	REQUIRE(t.lower->PopWriteAsHex() == hex::IntegrityPoll(0));
	t.context->OnSendResult(true);
	REQUIRE(t.exe->NumPendingTimers() == 2);
	t.SendToMaster("C0 81 00 00 01 02 00 02 02 81"); //group 2 var 1, index = 2, 0x81 = Online, true
	REQUIRE(t.meas->TotalReceived() == 1);
	REQUIRE((Binary(true, 0x01) == t.meas->binarySOE[2].meas));
}

TEST_CASE(SUITE("UnsolDisableEnableOnStartup"))
{
	MasterParams params;
	MasterTestObject t(params);
	t.context->OnLowerLayerUp();

	REQUIRE(t.exe->RunMany() > 0);

	// disable unsol on grp 60 var2, var3, var4
	REQUIRE(t.lower->PopWriteAsHex() == hex::ClassTask(FunctionCode::DISABLE_UNSOLICITED, 0, ClassField::AllEventClasses()));
	t.context->OnSendResult(true);
	t.SendToMaster(hex::EmptyResponse(0));

	t.exe->RunMany();

	REQUIRE(t.lower->PopWriteAsHex() == hex::IntegrityPoll(1));
	t.context->OnSendResult(true);
	t.SendToMaster(hex::EmptyResponse(1));

	t.exe->RunMany();

	REQUIRE(t.lower->PopWriteAsHex() == hex::ClassTask(FunctionCode::ENABLE_UNSOLICITED, 2, ClassField::AllEventClasses()));
	t.context->OnSendResult(true);
	t.SendToMaster(hex::EmptyResponse(2));

	t.exe->RunMany();

	REQUIRE(t.exe->NumPendingTimers() == 1);
}

TEST_CASE(SUITE("TimeoutDuringStartup"))
{
	MasterParams params;
	MasterTestObject t(params);
	t.context->OnLowerLayerUp();

	REQUIRE(t.exe->RunMany() > 0);
	REQUIRE(t.lower->PopWriteAsHex() == hex::ClassTask(FunctionCode::DISABLE_UNSOLICITED, 0, ClassField::AllEventClasses()));
	t.context->OnSendResult(true);

	// timeout the task
	REQUIRE(t.exe->AdvanceToNextTimer());
	REQUIRE(t.exe->RunMany());

	REQUIRE(t.lower->NumWrites() == 0);
	REQUIRE(t.exe->AdvanceToNextTimer());
	REQUIRE(t.exe->RunMany());

	// repeat the disable unsol
	REQUIRE(t.lower->PopWriteAsHex() == hex::ClassTask(FunctionCode::DISABLE_UNSOLICITED, 1, ClassField::AllEventClasses()));
}

TEST_CASE(SUITE("SolicitedResponseTimeout"))
{
	MasterTestObject t(NoStartupTasks());
	auto scan = t.context->AddClassScan(ClassField::AllClasses(), TimeDuration::Seconds(5));
	t.context->OnLowerLayerUp();

	t.exe->RunMany();
	REQUIRE(t.exe->AdvanceToNextTimer());
	t.exe->RunMany();

	REQUIRE(t.lower->PopWriteAsHex() == hex::IntegrityPoll(0));
	t.context->OnSendResult(true);
	REQUIRE(t.exe->AdvanceToNextTimer());
	REQUIRE(t.exe->RunMany() > 0);

	REQUIRE(t.exe->NumPendingTimers() == 2);
	REQUIRE(t.exe->AdvanceToNextTimer());
	REQUIRE(t.exe->RunMany() > 0);
	REQUIRE(t.lower->PopWriteAsHex() == hex::IntegrityPoll(1));
}

TEST_CASE(SUITE("AllObjectsScan"))
{
	MasterTestObject t(NoStartupTasks());
	auto scan = t.context->AddAllObjectsScan(GroupVariationID(110, 0), TimeDuration::Seconds(1));
	t.context->OnLowerLayerUp();

	t.exe->RunMany();
	REQUIRE(t.exe->AdvanceToNextTimer());
	t.exe->RunMany();

	REQUIRE(t.lower->PopWriteAsHex() == "C0 01 6E 00 06");
}

TEST_CASE(SUITE("ClassScanCanRepeat"))
{
	MasterParams params = NoStartupTasks();
	MasterTestObject t(params);
	t.context->OnLowerLayerUp();

	t.exe->RunMany();

	auto scan = t.context->AddClassScan(~0, TimeDuration::Seconds(10));

	REQUIRE(t.exe->RunMany() > 0);

	REQUIRE(t.lower->PopWriteAsHex() == hex::IntegrityPoll(0));
	t.context->OnSendResult(true);
	t.SendToMaster(hex::EmptyResponse(0));

	t.exe->RunMany();

	// 2nd poll
	REQUIRE(t.exe->NumPendingTimers() == 2);
	REQUIRE(t.exe->NextTimerExpiration().milliseconds == 10000);
	t.exe->AdvanceTime(TimeDuration::Seconds(10));
	REQUIRE(t.exe->RunMany() > 0);
	REQUIRE(t.lower->PopWriteAsHex() == hex::IntegrityPoll(1));
}

TEST_CASE(SUITE("SolicitedResponseLayerDown"))
{
	MasterTestObject t(NoStartupTasks());
	auto scan = t.context->AddClassScan(ClassField::AllClasses(), TimeDuration::Seconds(5));
	t.context->OnLowerLayerUp();

	t.exe->RunMany();

	REQUIRE(t.exe->AdvanceToNextTimer());
	REQUIRE(t.exe->RunMany() > 0);
	REQUIRE(t.lower->PopWriteAsHex() == hex::IntegrityPoll(0));
	t.context->OnLowerLayerDown();

	t.context->OnLowerLayerUp();
	t.exe->RunMany();

	REQUIRE(t.exe->AdvanceToNextTimer());
	REQUIRE(t.exe->RunMany() > 0);
	REQUIRE(t.lower->PopWriteAsHex() == hex::IntegrityPoll(0));
}

TEST_CASE(SUITE("SolicitedMultiFragResponse"))
{
	auto config = NoStartupTasks();
	config.startupIntegrityClassMask = ClassField::AllClasses();
	MasterTestObject t(config);
	t.context->OnLowerLayerUp();

	REQUIRE(t.exe->RunMany() > 0);

	REQUIRE(t.lower->PopWriteAsHex() ==  hex::IntegrityPoll(0));
	t.context->OnSendResult(true);
	t.SendToMaster("80 81 00 00 01 02 00 02 02 81"); // partial response FIR = 1, FIN = 0
	REQUIRE(1 == t.meas->TotalReceived());
	REQUIRE((Binary(true, 0x01) == t.meas->binarySOE[2].meas));
	REQUIRE(0 == t.lower->NumWrites());
	t.SendToMaster("41 81 00 00 01 02 00 03 03 02"); // final response FIR = 0, FIN = 1
	REQUIRE(2 == t.meas->TotalReceived());
	REQUIRE((Binary(false, 0x02) == t.meas->binarySOE[3].meas));
}

TEST_CASE(SUITE("EventPoll"))
{
	MasterTestObject t(NoStartupTasks());

	auto class12 = t.context->AddClassScan(ClassField(ClassField::CLASS_1 | ClassField::CLASS_2), TimeDuration::Milliseconds(10));
	auto class3 = t.context->AddClassScan(ClassField(ClassField::CLASS_3), TimeDuration::Milliseconds(20));

	t.context->OnLowerLayerUp();

	REQUIRE(t.exe->RunMany() > 0);

	REQUIRE(t.lower->PopWriteAsHex() ==  "C0 01 3C 02 06 3C 03 06");
	t.context->OnSendResult(true);
	t.SendToMaster("C0 81 00 00 02 01 17 01 02 81"); //group 2 var 1, index = 2, 0x81 = Online, true

	REQUIRE(t.meas->TotalReceived() == 1);
	REQUIRE((Binary(true, 0x01) == t.meas->binarySOE[2].meas));

	REQUIRE(t.exe->RunMany() > 0);

	REQUIRE(t.lower->PopWriteAsHex() == "C1 01 3C 04 06");
	t.context->OnSendResult(true);
	t.SendToMaster("C1 81 00 00 02 01 17 01 03 01"); //group 2 var 1, index = 3, 0x81 = Online, true

	REQUIRE(t.meas->TotalReceived() == 2);
	REQUIRE((Binary(false, 0x01) == t.meas->binarySOE[3].meas));
}

TEST_CASE(SUITE("ParsesOctetStringResponseWithFiveCharacters"))
{
	MasterTestObject t(NoStartupTasks());
	t.context->OnLowerLayerUp();

	// Group 111 (0x6F) Variation (length), 1 byte count / 1 byte index (4), count of 1, "hello" == [0x68, 0x65, 0x6C, 0x6C, 0x6F]
	t.SendToMaster("D0 82 00 00 6F 05 17 01 04 68 65 6C 6C 6F");

	REQUIRE("68 65 6C 6C 6F" ==  ToHex(t.meas->octetStringSOE[4].meas.ToRSlice()));
}

TEST_CASE(SUITE("ParsesOctetStringResponseSizeOfOne"))
{
	MasterTestObject t(NoStartupTasks());
	t.context->AddClassScan(~0, TimeDuration::Seconds(1));
	t.context->OnLowerLayerUp();

	REQUIRE(t.exe->RunMany() > 0);

	REQUIRE(t.lower->PopWriteAsHex() == hex::IntegrityPoll(0));
	t.context->OnSendResult(true);

	// octet strings shouldn't be found in class 0 polls, but we'll test that we can process them anyway
	// Group 110 (0x6E) Variation(length), start = 3, stop = 3
	t.SendToMaster("C0 81 00 00 6E 01 00 03 03 AA");

	REQUIRE("AA" ==  ToHex(t.meas->octetStringSOE[3].meas.ToRSlice()));
}

TEST_CASE(SUITE("ParsesGroup2Var3Correctly"))
{
	auto config = NoStartupTasks();
	config.startupIntegrityClassMask = ClassField(~0);
	MasterTestObject t(config);
	t.context->OnLowerLayerUp();

	REQUIRE(t.exe->RunMany() > 0);

	REQUIRE(t.lower->PopWriteAsHex() == hex::IntegrityPoll(0));
	t.context->OnSendResult(true);

	// g51v1, t = 3,
	// g2v3, index 7, t = 2, true/online
	// g2v3, index 8, t = 3, true/online
	t.SendToMaster("C0 81 00 00 33 01 07 01 03 00 00 00 00 00 02 03 17 01 07 81 02 00 02 03 17 01 08 81 03 00");

	REQUIRE(t.meas->binarySOE.size() == 2);
	{
		auto record = t.meas->binarySOE[7];
		REQUIRE(record.meas.time == 5);
		REQUIRE(record.info.gv == GroupVariation::Group2Var3);
	}
	{
		auto record = t.meas->binarySOE[8];
		REQUIRE(record.meas.time == 6);
		REQUIRE(record.info.gv == GroupVariation::Group2Var3);
	}
}

TEST_CASE(SUITE("ParsesGroup50Var4"))
{
	auto config = NoStartupTasks();
	config.startupIntegrityClassMask = ClassField(~0);
	MasterTestObject t(config);
	t.context->OnLowerLayerUp();

	REQUIRE(t.exe->RunMany() > 0);

	REQUIRE(t.lower->PopWriteAsHex() == hex::IntegrityPoll(0));
	t.context->OnSendResult(true);

	t.SendToMaster("C0 81 00 00 32 04 00 00 00 09 00 00 00 00 00 03 00 00 00 05");

	REQUIRE(1 == t.meas->timeAndIntervalSOE.size());
	REQUIRE(t.meas->timeAndIntervalSOE[0].meas.interval == 3);
	REQUIRE(t.meas->timeAndIntervalSOE[0].meas.time == 9);
	REQUIRE(t.meas->timeAndIntervalSOE[0].meas.GetUnitsEnum() == IntervalUnits::Days);
}

TEST_CASE(SUITE("RestartViaNullUnsol"))
{
	MasterParams params;

	// disable all the automated behaviors except for restart IIN
	params.disableUnsolOnStartup = false;
	params.startupIntegrityClassMask = ClassField::None();
	params.unsolClassMask = ClassField::None();
	params.startupIntegrityClassMask = ClassField::None(); //disable integrity poll

	MasterTestObject t(params);
	t.context->OnLowerLayerUp();

	REQUIRE(t.exe->RunMany() > 0);
	REQUIRE(t.lower->NumWrites() == 0);
	t.SendToMaster("F0 82 80 00");
	REQUIRE(t.lower->PopWriteAsHex() == hex::Confirm(0, true));
	t.context->OnSendResult(true);
	REQUIRE(t.lower->PopWriteAsHex() == "C0 02 50 01 00 07 07 00");
}

TEST_CASE(SUITE("DisableAutomatedRestartClear"))
{
	MasterParams params;

	// disable all the automated behaviors
	params.ignoreRestartIIN = true;
	params.disableUnsolOnStartup = false;
	params.startupIntegrityClassMask = ClassField::None();
	params.unsolClassMask = ClassField::None();
	params.startupIntegrityClassMask = ClassField::None(); //disable integrity poll

	MasterTestObject t(params);
	t.context->OnLowerLayerUp();

	REQUIRE(t.exe->RunMany() > 0);
	REQUIRE(t.lower->NumWrites() == 0);
	t.SendToMaster("F0 82 80 00");
	REQUIRE(t.lower->PopWriteAsHex() == hex::Confirm(0, true));
	t.context->OnSendResult(true);
	REQUIRE(t.lower->NumWrites() == 0);
}

TEST_CASE(SUITE("RestartDuringStartup"))
{

	MasterParams params;
	params.startupIntegrityClassMask = 0; //disable integrity poll
	MasterTestObject t(params);
	t.context->OnLowerLayerUp();

	REQUIRE(t.exe->RunMany() > 0);

	REQUIRE(t.lower->PopWriteAsHex() == hex::ClassTask(FunctionCode::DISABLE_UNSOLICITED, 0, ClassField::AllEventClasses()));
	t.context->OnSendResult(false);

	t.SendToMaster(hex::EmptyResponse(0, IINField(IINBit::DEVICE_RESTART)));

	t.exe->RunMany();

	REQUIRE(t.lower->PopWriteAsHex() == hex::ClearRestartIIN(1));
	t.context->OnSendResult(false);
	t.SendToMaster(hex::EmptyResponse(1));

	REQUIRE(t.exe->RunMany() > 0);

	REQUIRE(t.lower->PopWriteAsHex() == hex::ClassTask(FunctionCode::ENABLE_UNSOLICITED, 2, ClassField::AllEventClasses()));
}

TEST_CASE(SUITE("RestartAndTimeBits"))
{
	auto params = NoStartupTasks();
	params.timeSyncMode = TimeSyncMode::SerialTimeSync;
	MasterTestObject t(params);
	t.context->OnLowerLayerUp();

	t.application->time = 100;
	t.exe->RunMany();

	REQUIRE(t.lower->NumWrites() == 0);

	t.SendToMaster(hex::NullUnsolicited(0, IINField(IINBit::DEVICE_RESTART) | IINField(IINBit::NEED_TIME)));

	REQUIRE(t.lower->PopWriteAsHex() == hex::UnsolConfirm(0));
	t.context->OnSendResult(true);

	REQUIRE(t.lower->PopWriteAsHex() == hex::ClearRestartIIN(0));
	t.context->OnSendResult(true);
	t.SendToMaster(hex::EmptyResponse(0, IINField::Empty()));

	t.exe->RunMany();

	REQUIRE(t.lower->PopWriteAsHex() == hex::MeasureDelay(1));
	t.context->OnSendResult(true);
	t.application->time += 100; //advance time by 100ms so that the master sees 100ms for a response
	t.SendToMaster("C1 81 10 00 34 02 07 01 0A 00"); // still need time, 52 Var 2, delay == 10ms

	t.exe->RunMany();

	// Write group 50 var 1
	// 200-100-10/2 = 45 => 45 + 200 - 0xF5
	REQUIRE(t.lower->PopWriteAsHex() == "C2 02 32 01 07 01 F5 00 00 00 00 00");
	t.context->OnSendResult(true);
	t.SendToMaster(hex::EmptyResponse(0, IINField::Empty())); // time bit is now clear

	t.exe->RunMany();

	REQUIRE(t.lower->NumWrites() ==  0); // no more packets
}

TEST_CASE(SUITE("ReceiveCTOSynchronized"))
{
	auto params = NoStartupTasks();
	MasterTestObject t(params);
	t.context->OnLowerLayerUp();

	t.SendToMaster("D0 82 00 00 33 01 07 01 03 00 00 00 00 00 02 03 28 01 00 07 00 81 01 00");

	REQUIRE(t.meas->TotalReceived() == 1);
	auto record = t.meas->binarySOE[7];
	bool equal = record.meas == Binary(true, 0x01, DNPTime(0x04)); //timestamp is 4
	REQUIRE(equal);
	REQUIRE(record.info.tsmode == TimestampMode::SYNCHRONIZED);
}

TEST_CASE(SUITE("ReceiveCTOUnsynchronized"))
{
	auto params = NoStartupTasks();
	MasterTestObject t(params);
	t.context->OnLowerLayerUp();

	// same as above, but with Group 51 Var 2
	t.SendToMaster("D0 82 00 00 33 02 07 01 03 00 00 00 00 00 02 03 28 01 00 07 00 81 01 00");

	REQUIRE(t.meas->TotalReceived() == 1);
	auto record = t.meas->binarySOE[7];
	bool equal = record.meas == Binary(true, 0x01, DNPTime(0x04)); //timestamp is 4
	REQUIRE(equal);
	REQUIRE(record.info.tsmode == TimestampMode::UNSYNCHRONIZED);
}

TEST_CASE(SUITE("ReceiveIINinResponses"))
{
	auto params = NoStartupTasks();
	MasterTestObject t(params);
	t.context->OnLowerLayerUp();

	auto scan = t.context->AddClassScan(ClassField(~0), TimeDuration::Seconds(1));
	REQUIRE(t.exe->RunMany() > 0);
	REQUIRE(t.lower->PopWriteAsHex() == hex::IntegrityPoll(0));
	t.context->OnSendResult(true);

	// response with IIN retart bit
	t.SendToMaster("C0 81 80 00");

	REQUIRE(t.application->rxIIN.size() == 1);
	REQUIRE(t.application->rxIIN[0].IsSet(IINBit::DEVICE_RESTART));
}

TEST_CASE(SUITE("ReceiveIINUnsol"))
{
	auto params = NoStartupTasks();
	MasterTestObject t(params);
	t.context->OnLowerLayerUp();

	t.SendToMaster(hex::NullUnsolicited(0, IINField(IINBit::DEVICE_TROUBLE)));

	REQUIRE(t.application->rxIIN.size() == 1);
	REQUIRE(t.application->rxIIN[0].IsSet(IINBit::DEVICE_TROUBLE));
}

TEST_CASE(SUITE("EventScanOnEventsAvailableIIN"))
{
	auto params = NoStartupTasks();
	params.eventScanOnEventsAvailableClassMask = ClassField::CLASS_1 | ClassField::CLASS_2;
	MasterTestObject t(params);

	t.context->OnLowerLayerUp();

	t.SendToMaster(hex::EmptyResponse(0, IINField(IINBit::CLASS1_EVENTS)));

	t.exe->RunMany();

	REQUIRE(t.lower->PopWriteAsHex() == hex::EventPoll(0, params.eventScanOnEventsAvailableClassMask));
	t.context->OnSendResult(true);

	t.SendToMaster(hex::EmptyResponse(0, IINField(IINBit::CLASS2_EVENTS)));

	t.exe->RunMany();

	REQUIRE(t.lower->PopWriteAsHex() == hex::EventPoll(1, params.eventScanOnEventsAvailableClassMask));
	t.context->OnSendResult(true);

	t.SendToMaster(hex::EmptyResponse(1, IINField(IINBit::CLASS3_EVENTS)));

	t.exe->RunMany();

	REQUIRE(t.lower->NumWrites() == 0);
}

TEST_CASE(SUITE("AdhocScanWorksWithUnsolicitedDisabled"))
{
	MasterParams params = NoStartupTasks();
	params.disableUnsolOnStartup = true;
	MasterTestObject t(params);
	t.context->OnLowerLayerUp();

	t.context->ScanClasses(ClassField::AllEventClasses());

	REQUIRE(t.exe->RunMany() > 0);
	REQUIRE(t.lower->PopWriteAsHex() == hex::ClassTask(FunctionCode::DISABLE_UNSOLICITED, 0, ClassField::AllEventClasses()));
	t.context->OnSendResult(true);
	t.SendToMaster(hex::EmptyResponse(0));

	REQUIRE(t.exe->RunMany() > 0);
	REQUIRE(t.lower->PopWriteAsHex() == hex::ClassTask(FunctionCode::READ, 1, ClassField::AllEventClasses()));
}

TEST_CASE(SUITE("AdhocScanFailsImmediatelyIfMasterOffline"))
{
	MasterParams params = NoStartupTasks();
	MasterTestObject t(params);

	MockTaskCallback callback;
	t.context->ScanClasses(ClassField::AllEventClasses(), TaskConfig::With(callback));

	REQUIRE(callback.numStart == 0);
	REQUIRE(callback.results.size() == 1);
	REQUIRE(callback.results[0] == TaskCompletion::FAILURE_NO_COMMS);
	REQUIRE(callback.numDestroyed == 1);
}

TEST_CASE(SUITE("MasterWritesTimeAndInterval"))
{
	MasterParams params = NoStartupTasks();
	MasterTestObject t(params);
	t.context->OnLowerLayerUp();

	MockTaskCallback callback;

	t.context->Write(TimeAndInterval(DNPTime(3), 4, IntervalUnits::Days), 7, TaskConfig::With(callback));
	REQUIRE(t.exe->RunMany() > 0);
	REQUIRE(t.lower->PopWriteAsHex() == "C0 02 32 04 28 01 00 07 00 03 00 00 00 00 00 04 00 00 00 05");
	t.context->OnSendResult(true);
	t.SendToMaster("C0 81 00 00");
	REQUIRE(t.lower->PopWriteAsHex() == "");

	REQUIRE(callback.numStart == 1);
	REQUIRE(callback.results.size() == 1);
	REQUIRE(callback.results[0] == TaskCompletion::SUCCESS);
}

TEST_CASE(SUITE("Cold restart fails with empty response"))
{
	MasterParams params = NoStartupTasks();
	MasterTestObject t(params);
	t.context->OnLowerLayerUp();

	CallbackQueue<RestartOperationResult> queue;

	t.context->Restart(RestartType::COLD, queue.Callback());
	REQUIRE(t.exe->RunMany() > 0);
	REQUIRE(t.lower->PopWriteAsHex() == "C0 0D"); // cold restart
	t.context->OnSendResult(true);
	t.SendToMaster("C0 81 00 00");
	REQUIRE(t.lower->PopWriteAsHex() == "");

	REQUIRE(queue.responses.size() == 1);
	REQUIRE(queue.responses[0].summary == TaskCompletion::FAILURE_BAD_RESPONSE);
}

TEST_CASE(SUITE("Warm restart fails with empty response"))
{
	MasterParams params = NoStartupTasks();
	MasterTestObject t(params);
	t.context->OnLowerLayerUp();

	CallbackQueue<RestartOperationResult> queue;

	t.context->Restart(RestartType::WARM, queue.Callback());
	REQUIRE(t.exe->RunMany() > 0);
	REQUIRE(t.lower->PopWriteAsHex() == "C0 0E"); // warm restart
	t.context->OnSendResult(true);
	t.SendToMaster("C0 81 00 00 34 01 07 01 BB BB");
	REQUIRE(t.lower->PopWriteAsHex() == "");

	REQUIRE(queue.responses.size() == 1);
	REQUIRE(queue.responses[0].summary == TaskCompletion::SUCCESS);
	REQUIRE(queue.responses[0].restartTime.GetMilliseconds() == (0xBBBB * 1000));
}