libnsm/test/libnsm_pci_links_test.cpp

/*
 * SPDX-FileCopyrightText: Copyright (c) 2023-2024 NVIDIA CORPORATION &
 * AFFILIATES. All rights reserved. SPDX-License-Identifier: Apache-2.0
 *
 * Licensed 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.
 */

#include "base.h"
#include "pci-links.h"
#include <gmock/gmock.h>
#include <gtest/gtest.h>

#include "common-tests.hpp"

TEST(queryScalarGroupTelemetryV1, testGoodEncodeRequest)
{
	std::vector<uint8_t> requestMsg(
	    sizeof(nsm_msg_hdr) +
	    sizeof(nsm_query_scalar_group_telemetry_v1_req));

	auto request = reinterpret_cast<nsm_msg *>(requestMsg.data());
	uint8_t device_id = 0;
	uint8_t group_index = 0;

	auto rc = encode_query_scalar_group_telemetry_v1_req(
	    0, device_id, group_index, request);

	struct nsm_query_scalar_group_telemetry_v1_req *req =
	    (struct nsm_query_scalar_group_telemetry_v1_req *)request->payload;

	EXPECT_EQ(rc, NSM_SW_SUCCESS);

	EXPECT_EQ(1, request->hdr.request);
	EXPECT_EQ(0, request->hdr.datagram);
	EXPECT_EQ(NSM_TYPE_PCI_LINK, request->hdr.nvidia_msg_type);

	EXPECT_EQ(NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, req->hdr.command);
	EXPECT_EQ(2 * sizeof(uint8_t), req->hdr.data_size);
	EXPECT_EQ(device_id, req->device_id);
	EXPECT_EQ(group_index, req->group_index);
}

TEST(queryScalarGroupTelemetryV1, testGoodDecodeRequest)
{
	std::vector<uint8_t> requestMsg{
	    0x10,
	    0xDE,	       // PCI VID: NVIDIA 0x10DE
	    0x80,	       // RQ=1, D=0, RSVD=0, INSTANCE_ID=0
	    0x89,	       // OCP_TYPE=8, OCP_VER=9
	    NSM_TYPE_PCI_LINK, // NVIDIA_MSG_TYPE
	    NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, // command
	    2,					 // data size
	    0,					 // device_id
	    0					 // group_index
	};

	auto request = reinterpret_cast<nsm_msg *>(requestMsg.data());

	size_t msg_len = requestMsg.size();

	uint8_t device_id = 0;
	uint8_t group_index = 1;
	auto rc = decode_query_scalar_group_telemetry_v1_req(
	    request, msg_len, &device_id, &group_index);

	EXPECT_EQ(rc, NSM_SW_SUCCESS);
	EXPECT_EQ(0, device_id);
	EXPECT_EQ(0, group_index);
}

TEST(queryScalarGroupTelemetryV1Group0, testGoodEncodeResponse)
{
	std::vector<uint8_t> responseMsg(
	    sizeof(nsm_msg_hdr) +
		sizeof(nsm_query_scalar_group_telemetry_v1_group_0_resp),
	    0);
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());

	uint16_t reason_code = ERR_NULL;

	struct nsm_query_scalar_group_telemetry_group_0 data;
	data.pci_vendor_id = 3;
	data.pci_device_id = 3;
	data.pci_subsystem_vendor_id = 3;
	data.pci_subsystem_device_id = 3;
	struct nsm_query_scalar_group_telemetry_group_0 data_test = data;

	auto rc = encode_query_scalar_group_telemetry_v1_group0_resp(
	    0, NSM_SUCCESS, reason_code, &data, response);

	struct nsm_query_scalar_group_telemetry_v1_group_0_resp *resp =
	    reinterpret_cast<
		struct nsm_query_scalar_group_telemetry_v1_group_0_resp *>(
		response->payload);

	EXPECT_EQ(rc, NSM_SW_SUCCESS);

	EXPECT_EQ(0, response->hdr.request);
	EXPECT_EQ(0, response->hdr.datagram);
	EXPECT_EQ(NSM_TYPE_PCI_LINK, response->hdr.nvidia_msg_type);

	EXPECT_EQ(NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, resp->hdr.command);
	EXPECT_EQ(sizeof(nsm_query_scalar_group_telemetry_group_0),
		  le16toh(resp->hdr.data_size));
	EXPECT_EQ(data_test.pci_vendor_id, le32toh(data.pci_vendor_id));
	EXPECT_EQ(data_test.pci_device_id, le32toh(data.pci_device_id));
	EXPECT_EQ(data_test.pci_subsystem_vendor_id,
		  le32toh(data.pci_subsystem_vendor_id));
	EXPECT_EQ(data_test.pci_subsystem_vendor_id,
		  le32toh(data.pci_subsystem_vendor_id));
}

TEST(queryScalarGroupTelemetryV1Group0, testGoodDecodeResponse)
{
	std::vector<uint8_t> data_byte{
	    0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
	    0x02, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
	};

	std::vector<uint8_t> responseMsg{
	    0x10,
	    0xDE,	       // PCI VID: NVIDIA 0x10DE
	    0x00,	       // RQ=0, D=0, RSVD=0, INSTANCE_ID=0
	    0x89,	       // OCP_TYPE=8, OCP_VER=9
	    NSM_TYPE_PCI_LINK, // NVIDIA_MSG_TYPE
	    NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, // command
	    0,					 // completion code
	    0,
	    0,
	    16,
	    0 // data size
	};
	auto data =
	    reinterpret_cast<nsm_query_scalar_group_telemetry_group_0 *>(
		data_byte.data());
	auto data_test = data;
	responseMsg.insert(responseMsg.end(), data_byte.begin(),
			   data_byte.end());
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	size_t msg_len = responseMsg.size();

	uint8_t cc = NSM_SUCCESS;
	uint16_t reason_code = ERR_NULL;
	uint16_t data_size = 0;
	auto rc = decode_query_scalar_group_telemetry_v1_group0_resp(
	    response, msg_len, &cc, &data_size, &reason_code, data);

	EXPECT_EQ(rc, NSM_SW_SUCCESS);
	EXPECT_EQ(cc, NSM_SUCCESS);
	EXPECT_EQ(data_size, 16);
	EXPECT_EQ(le32toh(data_test->pci_vendor_id), data->pci_vendor_id);
	EXPECT_EQ(le32toh(data_test->pci_device_id), data->pci_device_id);
	EXPECT_EQ(le32toh(data_test->pci_subsystem_vendor_id),
		  data->pci_subsystem_vendor_id);
	EXPECT_EQ(le32toh(data_test->pci_subsystem_device_id),
		  data->pci_subsystem_device_id);
}

TEST(queryScalarGroupTelemetryV1Group0, testBadDecodeResponse)
{
	std::vector<uint8_t> data_byte{
	    0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
	    0x02, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
	};

	std::vector<uint8_t> responseMsg{
	    0x10,
	    0xDE,	       // PCI VID: NVIDIA 0x10DE
	    0x00,	       // RQ=0, D=0, RSVD=0, INSTANCE_ID=0
	    0x89,	       // OCP_TYPE=8, OCP_VER=9
	    NSM_TYPE_PCI_LINK, // NVIDIA_MSG_TYPE
	    NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, // command
	    0,					 // completion code
	    0,
	    0,
	    15, // incorrect data size
	    0	// data size
	};
	auto data =
	    reinterpret_cast<nsm_query_scalar_group_telemetry_group_0 *>(
		data_byte.data());
	responseMsg.insert(responseMsg.end(), data_byte.begin(),
			   data_byte.end());
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	size_t msg_len = responseMsg.size();

	uint8_t cc = NSM_SUCCESS;
	uint16_t reason_code = ERR_NULL;
	uint16_t data_size = 0;

	auto rc = decode_query_scalar_group_telemetry_v1_group0_resp(
	    NULL, msg_len, &cc, &data_size, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_scalar_group_telemetry_v1_group0_resp(
	    response, msg_len, NULL, &data_size, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_scalar_group_telemetry_v1_group0_resp(
	    response, msg_len, &cc, NULL, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_scalar_group_telemetry_v1_group0_resp(
	    response, msg_len - data_byte.size(), &cc, &data_size, &reason_code,
	    data);
	EXPECT_EQ(rc, NSM_SW_ERROR_LENGTH);

	rc = decode_query_scalar_group_telemetry_v1_group0_resp(
	    response, msg_len, &cc, &data_size, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_LENGTH);
}

TEST(queryScalarGroupTelemetryV1Group1, testGoodEncodeResponse)
{
	std::vector<uint8_t> responseMsg(
	    sizeof(nsm_msg_hdr) +
		sizeof(nsm_query_scalar_group_telemetry_v1_group_1_resp),
	    0);
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());

	uint16_t reason_code = ERR_NULL;

	struct nsm_query_scalar_group_telemetry_group_1 data;
	data.negotiated_link_speed = 3;
	data.negotiated_link_width = 3;
	data.target_link_speed = 3;
	data.max_link_speed = 3;
	data.max_link_width = 3;
	struct nsm_query_scalar_group_telemetry_group_1 data_test = data;

	auto rc = encode_query_scalar_group_telemetry_v1_group1_resp(
	    0, NSM_SUCCESS, reason_code, &data, response);

	struct nsm_query_scalar_group_telemetry_v1_group_1_resp *resp =
	    reinterpret_cast<
		struct nsm_query_scalar_group_telemetry_v1_group_1_resp *>(
		response->payload);

	EXPECT_EQ(rc, NSM_SW_SUCCESS);

	EXPECT_EQ(0, response->hdr.request);
	EXPECT_EQ(0, response->hdr.datagram);
	EXPECT_EQ(NSM_TYPE_PCI_LINK, response->hdr.nvidia_msg_type);

	EXPECT_EQ(NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, resp->hdr.command);
	EXPECT_EQ(sizeof(nsm_query_scalar_group_telemetry_group_1),
		  le16toh(resp->hdr.data_size));
	EXPECT_EQ(data_test.negotiated_link_speed,
		  le32toh(data.negotiated_link_speed));
}

TEST(queryScalarGroupTelemetryV1Group1, testGoodDecodeResponse)
{
	std::vector<uint8_t> data_byte{
	    0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0x00,
	    0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x0A, 0x09, 0x08, 0x07,
	};

	std::vector<uint8_t> responseMsg{
	    0x10,
	    0xDE,	       // PCI VID: NVIDIA 0x10DE
	    0x00,	       // RQ=0, D=0, RSVD=0, INSTANCE_ID=0
	    0x89,	       // OCP_TYPE=8, OCP_VER=9
	    NSM_TYPE_PCI_LINK, // NVIDIA_MSG_TYPE
	    NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, // command
	    0,					 // completion code
	    0,
	    0,
	    20,
	    0 // data size
	};
	auto data =
	    reinterpret_cast<nsm_query_scalar_group_telemetry_group_1 *>(
		data_byte.data());
	auto data_test = data;
	responseMsg.insert(responseMsg.end(), data_byte.begin(),
			   data_byte.end());
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	size_t msg_len = responseMsg.size();

	uint8_t cc = NSM_SUCCESS;
	uint16_t reason_code = ERR_NULL;
	uint16_t data_size = 0;
	auto rc = decode_query_scalar_group_telemetry_v1_group1_resp(
	    response, msg_len, &cc, &data_size, &reason_code, data);

	EXPECT_EQ(rc, NSM_SW_SUCCESS);
	EXPECT_EQ(cc, NSM_SUCCESS);
	EXPECT_EQ(data_size, 20);
	EXPECT_EQ(le32toh(data_test->negotiated_link_speed),
		  data->negotiated_link_speed);
}

TEST(queryScalarGroupTelemetryV1Group1, testBadDecodeResponse)
{
	std::vector<uint8_t> data_byte{
	    0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0x00,
	    0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x0A, 0x09, 0x08, 0x07,
	};

	std::vector<uint8_t> responseMsg{
	    0x10,
	    0xDE,	       // PCI VID: NVIDIA 0x10DE
	    0x00,	       // RQ=0, D=0, RSVD=0, INSTANCE_ID=0
	    0x89,	       // OCP_TYPE=8, OCP_VER=9
	    NSM_TYPE_PCI_LINK, // NVIDIA_MSG_TYPE
	    NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, // command
	    0,					 // completion code
	    0,
	    0,
	    14, // incorrect data size
	    0	// data size
	};
	auto data =
	    reinterpret_cast<nsm_query_scalar_group_telemetry_group_1 *>(
		data_byte.data());
	responseMsg.insert(responseMsg.end(), data_byte.begin(),
			   data_byte.end());
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	size_t msg_len = responseMsg.size();

	uint8_t cc = NSM_SUCCESS;
	uint16_t reason_code = ERR_NULL;
	uint16_t data_size = 0;

	auto rc = decode_query_scalar_group_telemetry_v1_group1_resp(
	    NULL, msg_len, &cc, &data_size, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_scalar_group_telemetry_v1_group1_resp(
	    response, msg_len, NULL, &data_size, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_scalar_group_telemetry_v1_group1_resp(
	    response, msg_len, &cc, NULL, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_scalar_group_telemetry_v1_group1_resp(
	    response, msg_len - data_byte.size(), &cc, &data_size, &reason_code,
	    data);
	EXPECT_EQ(rc, NSM_SW_ERROR_LENGTH);

	rc = decode_query_scalar_group_telemetry_v1_group1_resp(
	    response, msg_len, &cc, &data_size, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_LENGTH);
}

TEST(queryScalarGroupTelemetryV1Group2, testGoodEncodeResponse)
{
	std::vector<uint8_t> responseMsg(
	    sizeof(nsm_msg_hdr) +
		sizeof(nsm_query_scalar_group_telemetry_v1_group_2_resp),
	    0);
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());

	uint16_t reason_code = ERR_NULL;

	struct nsm_query_scalar_group_telemetry_group_2 data;
	data.non_fatal_errors = 1111;
	data.fatal_errors = 2222;
	data.unsupported_request_count = 3333;
	data.correctable_errors = 4444;

	struct nsm_query_scalar_group_telemetry_group_2 data_test = data;
	auto rc = encode_query_scalar_group_telemetry_v1_group2_resp(
	    0, NSM_SUCCESS, reason_code, &data, response);

	struct nsm_query_scalar_group_telemetry_v1_group_2_resp *resp =
	    reinterpret_cast<
		struct nsm_query_scalar_group_telemetry_v1_group_2_resp *>(
		response->payload);

	EXPECT_EQ(rc, NSM_SW_SUCCESS);

	EXPECT_EQ(0, response->hdr.request);
	EXPECT_EQ(0, response->hdr.datagram);
	EXPECT_EQ(NSM_TYPE_PCI_LINK, response->hdr.nvidia_msg_type);

	EXPECT_EQ(NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, resp->hdr.command);
	EXPECT_EQ(sizeof(nsm_query_scalar_group_telemetry_group_2),
		  le16toh(resp->hdr.data_size));
	EXPECT_EQ(data_test.correctable_errors,
		  le32toh(data.correctable_errors));
}

TEST(queryScalarGroupTelemetryV1Group2, testGoodDecodeResponse)
{
	std::vector<uint8_t> data_byte{
	    0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
	    0x02, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
	};

	std::vector<uint8_t> responseMsg{
	    0x10,
	    0xDE,	       // PCI VID: NVIDIA 0x10DE
	    0x00,	       // RQ=0, D=0, RSVD=0, INSTANCE_ID=0
	    0x89,	       // OCP_TYPE=8, OCP_VER=9
	    NSM_TYPE_PCI_LINK, // NVIDIA_MSG_TYPE
	    NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, // command
	    0,					 // completion code
	    0,
	    0,
	    16,
	    0 // data size
	};
	auto data =
	    reinterpret_cast<nsm_query_scalar_group_telemetry_group_2 *>(
		data_byte.data());
	auto data_test = data;
	responseMsg.insert(responseMsg.end(), data_byte.begin(),
			   data_byte.end());
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	size_t msg_len = responseMsg.size();

	uint8_t cc = NSM_SUCCESS;
	uint16_t reason_code = ERR_NULL;
	uint16_t data_size = 0;
	auto rc = decode_query_scalar_group_telemetry_v1_group2_resp(
	    response, msg_len, &cc, &data_size, &reason_code, data);

	EXPECT_EQ(rc, NSM_SW_SUCCESS);
	EXPECT_EQ(cc, NSM_SUCCESS);
	EXPECT_EQ(data_size, 16);
	EXPECT_EQ(le32toh(data_test->correctable_errors),
		  data->correctable_errors);
}

TEST(queryScalarGroupTelemetryV1Group2, testBadDecodeResponse)
{
	std::vector<uint8_t> data_byte{
	    0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
	    0x02, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
	};

	std::vector<uint8_t> responseMsg{
	    0x10,
	    0xDE,	       // PCI VID: NVIDIA 0x10DE
	    0x00,	       // RQ=0, D=0, RSVD=0, INSTANCE_ID=0
	    0x89,	       // OCP_TYPE=8, OCP_VER=9
	    NSM_TYPE_PCI_LINK, // NVIDIA_MSG_TYPE
	    NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, // command
	    0,					 // completion code
	    0,
	    0,
	    14, // incorrect data size
	    0	// data size
	};
	auto data =
	    reinterpret_cast<nsm_query_scalar_group_telemetry_group_2 *>(
		data_byte.data());
	responseMsg.insert(responseMsg.end(), data_byte.begin(),
			   data_byte.end());
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	size_t msg_len = responseMsg.size();

	uint8_t cc = NSM_SUCCESS;
	uint16_t reason_code = ERR_NULL;
	uint16_t data_size = 0;

	auto rc = decode_query_scalar_group_telemetry_v1_group2_resp(
	    NULL, msg_len, &cc, &data_size, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_scalar_group_telemetry_v1_group2_resp(
	    response, msg_len, NULL, &data_size, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_scalar_group_telemetry_v1_group2_resp(
	    response, msg_len, &cc, NULL, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_scalar_group_telemetry_v1_group2_resp(
	    response, msg_len - data_byte.size(), &cc, &data_size, &reason_code,
	    data);
	EXPECT_EQ(rc, NSM_SW_ERROR_LENGTH);

	rc = decode_query_scalar_group_telemetry_v1_group2_resp(
	    response, msg_len, &cc, &data_size, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_LENGTH);
}

TEST(queryScalarGroupTelemetryV1Group3, testGoodEncodeResponse)
{
	std::vector<uint8_t> responseMsg(
	    sizeof(nsm_msg_hdr) +
		sizeof(nsm_query_scalar_group_telemetry_v1_group_3_resp),
	    0);
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	uint16_t reason_code = ERR_NULL;
	struct nsm_query_scalar_group_telemetry_group_3 data;
	data.L0ToRecoveryCount = 8769;
	struct nsm_query_scalar_group_telemetry_group_3 data_test = data;
	auto rc = encode_query_scalar_group_telemetry_v1_group3_resp(
	    0, NSM_SUCCESS, reason_code, &data, response);

	struct nsm_query_scalar_group_telemetry_v1_group_3_resp *resp =
	    reinterpret_cast<
		struct nsm_query_scalar_group_telemetry_v1_group_3_resp *>(
		response->payload);

	EXPECT_EQ(rc, NSM_SW_SUCCESS);

	EXPECT_EQ(0, response->hdr.request);
	EXPECT_EQ(0, response->hdr.datagram);
	EXPECT_EQ(NSM_TYPE_PCI_LINK, response->hdr.nvidia_msg_type);

	EXPECT_EQ(NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, resp->hdr.command);
	EXPECT_EQ(sizeof(nsm_query_scalar_group_telemetry_group_3),
		  le16toh(resp->hdr.data_size));
	EXPECT_EQ(data_test.L0ToRecoveryCount, le32toh(data.L0ToRecoveryCount));
}

TEST(queryScalarGroupTelemetryV1Group3, testGoodDecodeResponse)
{
	std::vector<uint8_t> data_byte{
	    0x01,
	    0x00,
	    0x00,
	    0x00,
	};

	std::vector<uint8_t> responseMsg{
	    0x10,
	    0xDE,	       // PCI VID: NVIDIA 0x10DE
	    0x00,	       // RQ=0, D=0, RSVD=0, INSTANCE_ID=0
	    0x89,	       // OCP_TYPE=8, OCP_VER=9
	    NSM_TYPE_PCI_LINK, // NVIDIA_MSG_TYPE
	    NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, // command
	    0,					 // completion code
	    0,
	    0,
	    4,
	    0 // data size
	};
	auto data =
	    reinterpret_cast<nsm_query_scalar_group_telemetry_group_3 *>(
		data_byte.data());
	auto data_test = data;
	responseMsg.insert(responseMsg.end(), data_byte.begin(),
			   data_byte.end());
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	size_t msg_len = responseMsg.size();

	uint8_t cc = NSM_SUCCESS;
	uint16_t reason_code = ERR_NULL;
	uint16_t data_size = 0;
	auto rc = decode_query_scalar_group_telemetry_v1_group3_resp(
	    response, msg_len, &cc, &data_size, &reason_code, data);

	EXPECT_EQ(rc, NSM_SW_SUCCESS);
	EXPECT_EQ(cc, NSM_SUCCESS);
	EXPECT_EQ(data_size, 4);
	EXPECT_EQ(le32toh(data_test->L0ToRecoveryCount),
		  data->L0ToRecoveryCount);
}

TEST(queryScalarGroupTelemetryV1Group3, testBadDecodeResponse)
{
	std::vector<uint8_t> data_byte{
	    0x01,
	    0x00,
	    0x00,
	    0x00,
	};

	std::vector<uint8_t> responseMsg{
	    0x10,
	    0xDE,	       // PCI VID: NVIDIA 0x10DE
	    0x00,	       // RQ=0, D=0, RSVD=0, INSTANCE_ID=0
	    0x89,	       // OCP_TYPE=8, OCP_VER=9
	    NSM_TYPE_PCI_LINK, // NVIDIA_MSG_TYPE
	    NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, // command
	    0,					 // completion code
	    0,
	    0,
	    3, // wrong data size
	    0  // data size
	};
	auto data =
	    reinterpret_cast<nsm_query_scalar_group_telemetry_group_3 *>(
		data_byte.data());

	responseMsg.insert(responseMsg.end(), data_byte.begin(),
			   data_byte.end());
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	size_t msg_len = responseMsg.size();

	uint8_t cc = NSM_SUCCESS;
	uint16_t reason_code = ERR_NULL;
	uint16_t data_size = 0;

	auto rc = decode_query_scalar_group_telemetry_v1_group3_resp(
	    NULL, msg_len, &cc, &data_size, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_scalar_group_telemetry_v1_group3_resp(
	    response, msg_len, NULL, &data_size, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_scalar_group_telemetry_v1_group3_resp(
	    response, msg_len, &cc, NULL, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_scalar_group_telemetry_v1_group3_resp(
	    response, msg_len - data_byte.size(), &cc, &data_size, &reason_code,
	    data);
	EXPECT_EQ(rc, NSM_SW_ERROR_LENGTH);

	rc = decode_query_scalar_group_telemetry_v1_group3_resp(
	    response, msg_len, &cc, &data_size, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_LENGTH);
}

TEST(queryScalarGroupTelemetryV1Group4, testGoodEncodeResponse)
{
	std::vector<uint8_t> responseMsg(
	    sizeof(nsm_msg_hdr) +
		sizeof(nsm_query_scalar_group_telemetry_v1_group_4_resp),
	    0);
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	uint16_t reason_code = ERR_NULL;

	struct nsm_query_scalar_group_telemetry_group_4 data;
	data.recv_err_cnt = 100;
	data.NAK_recv_cnt = 200;
	data.NAK_sent_cnt = 300;
	data.bad_TLP_cnt = 400;
	data.replay_rollover_cnt = 500;
	data.FC_timeout_err_cnt = 600;
	data.replay_cnt = 700;

	struct nsm_query_scalar_group_telemetry_group_4 data_test = data;
	auto rc = encode_query_scalar_group_telemetry_v1_group4_resp(
	    0, NSM_SUCCESS, reason_code, &data, response);

	struct nsm_query_scalar_group_telemetry_v1_group_4_resp *resp =
	    reinterpret_cast<
		struct nsm_query_scalar_group_telemetry_v1_group_4_resp *>(
		response->payload);

	EXPECT_EQ(rc, NSM_SW_SUCCESS);

	EXPECT_EQ(0, response->hdr.request);
	EXPECT_EQ(0, response->hdr.datagram);
	EXPECT_EQ(NSM_TYPE_PCI_LINK, response->hdr.nvidia_msg_type);

	EXPECT_EQ(NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, resp->hdr.command);
	EXPECT_EQ(sizeof(nsm_query_scalar_group_telemetry_group_4),
		  le16toh(resp->hdr.data_size));
	EXPECT_EQ(data_test.recv_err_cnt, le32toh(data.recv_err_cnt));
}

TEST(queryScalarGroupTelemetryV1Group4, testGoodDecodeResponse)
{
	std::vector<uint8_t> data_byte{
	    0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0x00,
	    0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x03, 0x00, 0x00, 0x00,
	    0x00, 0x00, 0x00, 0x00, 0x04, 0x00, 0x00, 0x00,
	};

	std::vector<uint8_t> responseMsg{
	    0x10,
	    0xDE,	       // PCI VID: NVIDIA 0x10DE
	    0x00,	       // RQ=0, D=0, RSVD=0, INSTANCE_ID=0
	    0x89,	       // OCP_TYPE=8, OCP_VER=9
	    NSM_TYPE_PCI_LINK, // NVIDIA_MSG_TYPE
	    NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, // command
	    0,					 // completion code
	    0,
	    0,
	    28,
	    0 // data size
	};
	auto data =
	    reinterpret_cast<nsm_query_scalar_group_telemetry_group_4 *>(
		data_byte.data());
	auto data_test = data;
	responseMsg.insert(responseMsg.end(), data_byte.begin(),
			   data_byte.end());
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	size_t msg_len = responseMsg.size();

	uint8_t cc = NSM_SUCCESS;
	uint16_t reason_code = ERR_NULL;
	uint16_t data_size = 0;
	auto rc = decode_query_scalar_group_telemetry_v1_group4_resp(
	    response, msg_len, &cc, &data_size, &reason_code, data);

	EXPECT_EQ(rc, NSM_SW_SUCCESS);
	EXPECT_EQ(cc, NSM_SUCCESS);

	EXPECT_EQ(data_size, 28);
	EXPECT_EQ(le32toh(data_test->bad_TLP_cnt), data->bad_TLP_cnt);
}

TEST(queryScalarGroupTelemetryV1Group4, testBadDecodeResponse)
{
	std::vector<uint8_t> data_byte{
	    0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0x00,
	    0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x03, 0x00, 0x00, 0x00,
	    0x00, 0x00, 0x00, 0x00, 0x04, 0x00, 0x00, 0x00,
	};

	std::vector<uint8_t> responseMsg{
	    0x10,
	    0xDE,	       // PCI VID: NVIDIA 0x10DE
	    0x00,	       // RQ=0, D=0, RSVD=0, INSTANCE_ID=0
	    0x89,	       // OCP_TYPE=8, OCP_VER=9
	    NSM_TYPE_PCI_LINK, // NVIDIA_MSG_TYPE
	    NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, // command
	    0,					 // completion code
	    0,
	    0,
	    27, // wrong data size
	    0	// data size
	};
	auto data =
	    reinterpret_cast<nsm_query_scalar_group_telemetry_group_4 *>(
		data_byte.data());
	responseMsg.insert(responseMsg.end(), data_byte.begin(),
			   data_byte.end());
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	size_t msg_len = responseMsg.size();

	uint8_t cc = NSM_SUCCESS;
	uint16_t reason_code = ERR_NULL;
	uint16_t data_size = 0;

	auto rc = decode_query_scalar_group_telemetry_v1_group4_resp(
	    NULL, msg_len, &cc, &data_size, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_scalar_group_telemetry_v1_group4_resp(
	    response, msg_len, NULL, &data_size, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_scalar_group_telemetry_v1_group4_resp(
	    response, msg_len, &cc, NULL, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_scalar_group_telemetry_v1_group4_resp(
	    response, msg_len - data_byte.size(), &cc, &data_size, &reason_code,
	    data);
	EXPECT_EQ(rc, NSM_SW_ERROR_LENGTH);

	rc = decode_query_scalar_group_telemetry_v1_group4_resp(
	    response, msg_len, &cc, &data_size, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_LENGTH);
}

TEST(queryScalarGroupTelemetryV1Group5, testGoodEncodeResponse)
{
	std::vector<uint8_t> responseMsg(
	    sizeof(nsm_msg_hdr) +
		sizeof(nsm_query_scalar_group_telemetry_v1_group_5_resp),
	    0);
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	uint16_t reason_code = ERR_NULL;
	struct nsm_query_scalar_group_telemetry_group_5 data;
	data.PCIeTXDwords = 8769000;
	data.PCIeRXDwords = 876654;

	struct nsm_query_scalar_group_telemetry_group_5 data_test = data;
	auto rc = encode_query_scalar_group_telemetry_v1_group5_resp(
	    0, NSM_SUCCESS, reason_code, &data, response);

	struct nsm_query_scalar_group_telemetry_v1_group_5_resp *resp =
	    reinterpret_cast<
		struct nsm_query_scalar_group_telemetry_v1_group_5_resp *>(
		response->payload);

	EXPECT_EQ(rc, NSM_SW_SUCCESS);

	EXPECT_EQ(0, response->hdr.request);
	EXPECT_EQ(0, response->hdr.datagram);
	EXPECT_EQ(NSM_TYPE_PCI_LINK, response->hdr.nvidia_msg_type);

	EXPECT_EQ(NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, resp->hdr.command);
	EXPECT_EQ(sizeof(nsm_query_scalar_group_telemetry_group_5),
		  le16toh(resp->hdr.data_size));
	EXPECT_EQ(data_test.PCIeTXDwords, le32toh(data.PCIeTXDwords));
}

TEST(queryScalarGroupTelemetryV1Group5, testGoodDecodeResponse)
{
	std::vector<uint8_t> data_byte{
	    0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
	};

	std::vector<uint8_t> responseMsg{
	    0x10,
	    0xDE,	       // PCI VID: NVIDIA 0x10DE
	    0x00,	       // RQ=0, D=0, RSVD=0, INSTANCE_ID=0
	    0x89,	       // OCP_TYPE=8, OCP_VER=9
	    NSM_TYPE_PCI_LINK, // NVIDIA_MSG_TYPE
	    NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, // command
	    0,					 // completion code
	    0,
	    0,
	    8,
	    0 // data size
	};
	auto data =
	    reinterpret_cast<nsm_query_scalar_group_telemetry_group_5 *>(
		data_byte.data());
	auto data_test = data;
	responseMsg.insert(responseMsg.end(), data_byte.begin(),
			   data_byte.end());
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	size_t msg_len = responseMsg.size();

	uint8_t cc = NSM_SUCCESS;
	uint16_t reason_code = ERR_NULL;
	uint16_t data_size = 0;
	auto rc = decode_query_scalar_group_telemetry_v1_group5_resp(
	    response, msg_len, &cc, &data_size, &reason_code, data);

	EXPECT_EQ(rc, NSM_SW_SUCCESS);
	EXPECT_EQ(cc, NSM_SUCCESS);
	EXPECT_EQ(data_size, 8);
	EXPECT_EQ(le32toh(data_test->PCIeRXDwords), data->PCIeRXDwords);
}

TEST(queryScalarGroupTelemetryV1Group5, testBadDecodeResponse)
{
	std::vector<uint8_t> data_byte{
	    0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
	};

	std::vector<uint8_t> responseMsg{
	    0x10,
	    0xDE,	       // PCI VID: NVIDIA 0x10DE
	    0x00,	       // RQ=0, D=0, RSVD=0, INSTANCE_ID=0
	    0x89,	       // OCP_TYPE=8, OCP_VER=9
	    NSM_TYPE_PCI_LINK, // NVIDIA_MSG_TYPE
	    NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, // command
	    0,					 // completion code
	    0,
	    0,
	    7,
	    0 // data size
	};
	auto data =
	    reinterpret_cast<nsm_query_scalar_group_telemetry_group_5 *>(
		data_byte.data());
	responseMsg.insert(responseMsg.end(), data_byte.begin(),
			   data_byte.end());
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	size_t msg_len = responseMsg.size();
	uint8_t cc = NSM_SUCCESS;
	uint16_t reason_code = ERR_NULL;
	uint16_t data_size = 0;

	auto rc = decode_query_scalar_group_telemetry_v1_group5_resp(
	    NULL, msg_len, &cc, &data_size, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_scalar_group_telemetry_v1_group5_resp(
	    response, msg_len, NULL, &data_size, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_scalar_group_telemetry_v1_group5_resp(
	    response, msg_len, &cc, NULL, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_scalar_group_telemetry_v1_group5_resp(
	    response, msg_len - data_byte.size(), &cc, &data_size, &reason_code,
	    data);
	EXPECT_EQ(rc, NSM_SW_ERROR_LENGTH);

	rc = decode_query_scalar_group_telemetry_v1_group5_resp(
	    response, msg_len, &cc, &data_size, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_LENGTH);
}

TEST(queryScalarGroupTelemetryV1Group6, testGoodEncodeResponse)
{
	std::vector<uint8_t> responseMsg(
	    sizeof(nsm_msg_hdr) +
		sizeof(nsm_query_scalar_group_telemetry_v1_group_6_resp),
	    0);
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());

	uint16_t reason_code = ERR_NULL;

	struct nsm_query_scalar_group_telemetry_group_6 data;
	data.invalid_flit_counter = 3;
	data.ltssm_state = 3;
	struct nsm_query_scalar_group_telemetry_group_6 data_test = data;

	auto rc = encode_query_scalar_group_telemetry_v1_group6_resp(
	    0, NSM_SUCCESS, reason_code, &data, response);

	struct nsm_query_scalar_group_telemetry_v1_group_6_resp *resp =
	    reinterpret_cast<
		struct nsm_query_scalar_group_telemetry_v1_group_6_resp *>(
		response->payload);

	EXPECT_EQ(rc, NSM_SW_SUCCESS);

	EXPECT_EQ(0, response->hdr.request);
	EXPECT_EQ(0, response->hdr.datagram);
	EXPECT_EQ(NSM_TYPE_PCI_LINK, response->hdr.nvidia_msg_type);

	EXPECT_EQ(NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, resp->hdr.command);
	EXPECT_EQ(sizeof(nsm_query_scalar_group_telemetry_group_6),
		  le16toh(resp->hdr.data_size));
	EXPECT_EQ(data_test.invalid_flit_counter,
		  le32toh(data.invalid_flit_counter));
	EXPECT_EQ(data_test.ltssm_state, le32toh(data.ltssm_state));
}

TEST(queryScalarGroupTelemetryV1Group6, testGoodDecodeResponse)
{
	std::vector<uint8_t> data_byte{
	    0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
	};

	std::vector<uint8_t> responseMsg{
	    0x10,
	    0xDE,	       // PCI VID: NVIDIA 0x10DE
	    0x00,	       // RQ=0, D=0, RSVD=0, INSTANCE_ID=0
	    0x89,	       // OCP_TYPE=8, OCP_VER=9
	    NSM_TYPE_PCI_LINK, // NVIDIA_MSG_TYPE
	    NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, // command
	    0,					 // completion code
	    0,
	    0,
	    8,
	    0 // data size
	};
	auto data =
	    reinterpret_cast<nsm_query_scalar_group_telemetry_group_6 *>(
		data_byte.data());
	auto data_test = data;
	responseMsg.insert(responseMsg.end(), data_byte.begin(),
			   data_byte.end());
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	size_t msg_len = responseMsg.size();

	uint8_t cc = NSM_SUCCESS;
	uint16_t reason_code = ERR_NULL;
	uint16_t data_size = 0;
	auto rc = decode_query_scalar_group_telemetry_v1_group6_resp(
	    response, msg_len, &cc, &data_size, &reason_code, data);

	EXPECT_EQ(rc, NSM_SW_SUCCESS);
	EXPECT_EQ(cc, NSM_SUCCESS);
	EXPECT_EQ(data_size, 8);
	EXPECT_EQ(le32toh(data_test->invalid_flit_counter),
		  data->invalid_flit_counter);
	EXPECT_EQ(le32toh(data_test->ltssm_state), data->ltssm_state);
}

TEST(queryScalarGroupTelemetryV1Group6, testBadDecodeResponse)
{
	std::vector<uint8_t> data_byte{
	    0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0x00,
	    0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x0A, 0x09, 0x08, 0x07,
	};

	std::vector<uint8_t> responseMsg{
	    0x10,
	    0xDE,	       // PCI VID: NVIDIA 0x10DE
	    0x00,	       // RQ=0, D=0, RSVD=0, INSTANCE_ID=0
	    0x89,	       // OCP_TYPE=8, OCP_VER=9
	    NSM_TYPE_PCI_LINK, // NVIDIA_MSG_TYPE
	    NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, // command
	    0,					 // completion code
	    0,
	    0,
	    7, // incorrect data size
	    0  // data size
	};
	auto data =
	    reinterpret_cast<nsm_query_scalar_group_telemetry_group_6 *>(
		data_byte.data());
	responseMsg.insert(responseMsg.end(), data_byte.begin(),
			   data_byte.end());
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	size_t msg_len = responseMsg.size();

	uint8_t cc = NSM_SUCCESS;
	uint16_t reason_code = ERR_NULL;
	uint16_t data_size = 0;

	auto rc = decode_query_scalar_group_telemetry_v1_group6_resp(
	    NULL, msg_len, &cc, &data_size, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_scalar_group_telemetry_v1_group6_resp(
	    response, msg_len, NULL, &data_size, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_scalar_group_telemetry_v1_group6_resp(
	    response, msg_len, &cc, NULL, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_scalar_group_telemetry_v1_group6_resp(
	    response, msg_len - data_byte.size(), &cc, &data_size, &reason_code,
	    data);
	EXPECT_EQ(rc, NSM_SW_ERROR_LENGTH);

	rc = decode_query_scalar_group_telemetry_v1_group6_resp(
	    response, msg_len, &cc, &data_size, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_LENGTH);
}

TEST(queryScalarGroupTelemetryV1Group8, testGoodEncodeResponse)
{
	std::vector<uint8_t> responseMsg(
	    sizeof(nsm_msg_hdr) +
		sizeof(nsm_query_scalar_group_telemetry_v1_group_8_resp),
	    0);
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());

	uint16_t reason_code = ERR_NULL;

	struct nsm_query_scalar_group_telemetry_group_8 data;
	for (int idx = 1; idx <= TOTAL_PCIE_LANE_COUNT; idx++) {
		data.error_counts[idx - 1] = 200 * idx;
	}
	struct nsm_query_scalar_group_telemetry_group_8 data_test = data;

	auto rc = encode_query_scalar_group_telemetry_v1_group8_resp(
	    0, NSM_SUCCESS, reason_code, &data, response);

	struct nsm_query_scalar_group_telemetry_v1_group_8_resp *resp =
	    reinterpret_cast<
		struct nsm_query_scalar_group_telemetry_v1_group_8_resp *>(
		response->payload);

	EXPECT_EQ(rc, NSM_SW_SUCCESS);

	EXPECT_EQ(0, response->hdr.request);
	EXPECT_EQ(0, response->hdr.datagram);
	EXPECT_EQ(NSM_TYPE_PCI_LINK, response->hdr.nvidia_msg_type);

	EXPECT_EQ(NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, resp->hdr.command);
	EXPECT_EQ(sizeof(nsm_query_scalar_group_telemetry_group_8),
		  le16toh(resp->hdr.data_size));
	EXPECT_EQ(data_test.error_counts[0], le32toh(data.error_counts[0]));
}

TEST(queryScalarGroupTelemetryV1Group8, testGoodDecodeResponse)
{
	std::vector<uint8_t> data_byte;
	for (int idx = 0; idx < TOTAL_PCIE_LANE_COUNT; idx++) {
		data_byte.push_back(idx * 0);
		data_byte.push_back(idx * 1);
		data_byte.push_back(idx * 2);
		data_byte.push_back(idx * 3);
	}

	std::vector<uint8_t> responseMsg{
	    0x10,
	    0xDE,	       // PCI VID: NVIDIA 0x10DE
	    0x00,	       // RQ=0, D=0, RSVD=0, INSTANCE_ID=0
	    0x89,	       // OCP_TYPE=8, OCP_VER=9
	    NSM_TYPE_PCI_LINK, // NVIDIA_MSG_TYPE
	    NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, // command
	    0,					 // completion code
	    0,
	    0,
	    TOTAL_PCIE_LANE_COUNT * 4,
	    0 // data size
	};
	auto data =
	    reinterpret_cast<nsm_query_scalar_group_telemetry_group_8 *>(
		data_byte.data());
	auto data_test = data;
	responseMsg.insert(responseMsg.end(), data_byte.begin(),
			   data_byte.end());
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	size_t msg_len = responseMsg.size();

	uint8_t cc = NSM_SUCCESS;
	uint16_t reason_code = ERR_NULL;
	uint16_t data_size = 0;
	auto rc = decode_query_scalar_group_telemetry_v1_group8_resp(
	    response, msg_len, &cc, &data_size, &reason_code, data);

	EXPECT_EQ(rc, NSM_SW_SUCCESS);
	EXPECT_EQ(cc, NSM_SUCCESS);

	EXPECT_EQ(data_size, TOTAL_PCIE_LANE_COUNT * 4);
	EXPECT_EQ(le32toh(data_test->error_counts[0]), data->error_counts[0]);
}

TEST(queryScalarGroupTelemetryV1Group8, testBadDecodeResponse)
{
	std::vector<uint8_t> data_byte;
	for (int idx = 0; idx < TOTAL_PCIE_LANE_COUNT; idx++) {
		data_byte.push_back(idx * 0);
		data_byte.push_back(idx * 1);
		data_byte.push_back(idx * 2);
		data_byte.push_back(idx * 3);
	}

	std::vector<uint8_t> responseMsg{
	    0x10,
	    0xDE,	       // PCI VID: NVIDIA 0x10DE
	    0x00,	       // RQ=0, D=0, RSVD=0, INSTANCE_ID=0
	    0x89,	       // OCP_TYPE=8, OCP_VER=9
	    NSM_TYPE_PCI_LINK, // NVIDIA_MSG_TYPE
	    NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, // command
	    0,					 // completion code
	    0,
	    0,
	    TOTAL_PCIE_LANE_COUNT * 4 - 1,
	    0 // data size
	};
	auto data =
	    reinterpret_cast<nsm_query_scalar_group_telemetry_group_8 *>(
		data_byte.data());

	responseMsg.insert(responseMsg.end(), data_byte.begin(),
			   data_byte.end());
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	size_t msg_len = responseMsg.size();

	uint8_t cc = NSM_SUCCESS;
	uint16_t reason_code = ERR_NULL;
	uint16_t data_size = 0;
	auto rc = decode_query_scalar_group_telemetry_v1_group8_resp(
	    NULL, msg_len, &cc, &data_size, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_scalar_group_telemetry_v1_group8_resp(
	    response, msg_len, NULL, &data_size, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_scalar_group_telemetry_v1_group8_resp(
	    response, msg_len, &cc, NULL, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_scalar_group_telemetry_v1_group8_resp(
	    response, msg_len - data_byte.size(), &cc, &data_size, &reason_code,
	    data);
	EXPECT_EQ(rc, NSM_SW_ERROR_LENGTH);

	rc = decode_query_scalar_group_telemetry_v1_group8_resp(
	    response, msg_len, &cc, &data_size, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_LENGTH);
}

TEST(queryScalarGroupTelemetryV1Group9, testGoodEncodeResponse)
{
	std::vector<uint8_t> responseMsg(
	    sizeof(nsm_msg_hdr) +
		sizeof(nsm_query_scalar_group_telemetry_v1_group_9_resp),
	    0);
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());

	uint16_t reason_code = ERR_NULL;

	struct nsm_query_scalar_group_telemetry_group_9 data;
	data.aer_uncorrectable_error_status = 2456;
	data.aer_correctable_error_status = 3425;
	struct nsm_query_scalar_group_telemetry_group_9 data_test = data;

	auto rc = encode_query_scalar_group_telemetry_v1_group9_resp(
	    0, NSM_SUCCESS, reason_code, &data, response);

	struct nsm_query_scalar_group_telemetry_v1_group_9_resp *resp =
	    reinterpret_cast<
		struct nsm_query_scalar_group_telemetry_v1_group_9_resp *>(
		response->payload);

	EXPECT_EQ(rc, NSM_SW_SUCCESS);

	EXPECT_EQ(0, response->hdr.request);
	EXPECT_EQ(0, response->hdr.datagram);
	EXPECT_EQ(NSM_TYPE_PCI_LINK, response->hdr.nvidia_msg_type);

	EXPECT_EQ(NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, resp->hdr.command);
	EXPECT_EQ(sizeof(nsm_query_scalar_group_telemetry_group_9),
		  le16toh(resp->hdr.data_size));
	EXPECT_EQ(data_test.aer_correctable_error_status,
		  le32toh(data.aer_correctable_error_status));
	EXPECT_EQ(data_test.aer_uncorrectable_error_status,
		  le32toh(data.aer_uncorrectable_error_status));
}

TEST(queryScalarGroupTelemetryV1Group9, testGoodDecodeResponse)
{
	std::vector<uint8_t> data_byte{
	    0x01, 0x02, 0x03, 0x04, 0x05, 0x06, 0x07, 0x08,
	};

	std::vector<uint8_t> responseMsg{
	    0x10,
	    0xDE,	       // PCI VID: NVIDIA 0x10DE
	    0x00,	       // RQ=0, D=0, RSVD=0, INSTANCE_ID=0
	    0x89,	       // OCP_TYPE=8, OCP_VER=9
	    NSM_TYPE_PCI_LINK, // NVIDIA_MSG_TYPE
	    NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, // command
	    0,					 // completion code
	    0,
	    0,
	    8,
	    0 // data size
	};
	auto data =
	    reinterpret_cast<nsm_query_scalar_group_telemetry_group_9 *>(
		data_byte.data());
	auto data_test = data;
	responseMsg.insert(responseMsg.end(), data_byte.begin(),
			   data_byte.end());
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	size_t msg_len = responseMsg.size();

	uint8_t cc = NSM_SUCCESS;
	uint16_t reason_code = ERR_NULL;
	uint16_t data_size = 0;
	auto rc = decode_query_scalar_group_telemetry_v1_group9_resp(
	    response, msg_len, &cc, &data_size, &reason_code, data);

	EXPECT_EQ(rc, NSM_SW_SUCCESS);
	EXPECT_EQ(cc, NSM_SUCCESS);

	EXPECT_EQ(data_size, 8);
	EXPECT_EQ(le32toh(data_test->aer_uncorrectable_error_status),
		  data->aer_uncorrectable_error_status);
	EXPECT_EQ(le32toh(data_test->aer_correctable_error_status),
		  data->aer_correctable_error_status);
}

TEST(queryScalarGroupTelemetryV1Group9, testBadDecodeResponse)
{
	std::vector<uint8_t> data_byte{
	    0x01, 0x02, 0x03, 0x04, 0x05, 0x06, 0x07, 0x08,
	};

	std::vector<uint8_t> responseMsg{
	    0x10,
	    0xDE,	       // PCI VID: NVIDIA 0x10DE
	    0x00,	       // RQ=0, D=0, RSVD=0, INSTANCE_ID=0
	    0x89,	       // OCP_TYPE=8, OCP_VER=9
	    NSM_TYPE_PCI_LINK, // NVIDIA_MSG_TYPE
	    NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, // command
	    0,					 // completion code
	    0,
	    0,
	    9,
	    0 // data size
	};
	auto data =
	    reinterpret_cast<nsm_query_scalar_group_telemetry_group_9 *>(
		data_byte.data());

	responseMsg.insert(responseMsg.end(), data_byte.begin(),
			   data_byte.end());
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	size_t msg_len = responseMsg.size();

	uint8_t cc = NSM_SUCCESS;
	uint16_t reason_code = ERR_NULL;
	uint16_t data_size = 0;
	auto rc = decode_query_scalar_group_telemetry_v1_group9_resp(
	    NULL, msg_len, &cc, &data_size, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_scalar_group_telemetry_v1_group9_resp(
	    response, msg_len, NULL, &data_size, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_scalar_group_telemetry_v1_group9_resp(
	    response, msg_len, &cc, NULL, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_scalar_group_telemetry_v1_group9_resp(
	    response, msg_len - data_byte.size(), &cc, &data_size, &reason_code,
	    data);
	EXPECT_EQ(rc, NSM_SW_ERROR_LENGTH);

	rc = decode_query_scalar_group_telemetry_v1_group9_resp(
	    response, msg_len, &cc, &data_size, &reason_code, data);
	EXPECT_EQ(rc, NSM_SW_ERROR_LENGTH);
}

TEST(pcieFundamentalReset, testGoodEncodeRequest)
{
	std::vector<uint8_t> requestMsg(
	    sizeof(nsm_msg_hdr) +
	    sizeof(nsm_assert_pcie_fundamental_reset_req));

	auto request = reinterpret_cast<nsm_msg *>(requestMsg.data());
	uint8_t device_index = 1;
	uint8_t action = 0;
	auto rc = encode_assert_pcie_fundamental_reset_req(0, device_index,
							   action, request);
	struct nsm_assert_pcie_fundamental_reset_req *req =
	    reinterpret_cast<struct nsm_assert_pcie_fundamental_reset_req *>(
		request->payload);

	EXPECT_EQ(rc, NSM_SW_SUCCESS);

	EXPECT_EQ(1, request->hdr.request);
	EXPECT_EQ(0, request->hdr.datagram);
	EXPECT_EQ(NSM_TYPE_PCI_LINK, request->hdr.nvidia_msg_type);

	EXPECT_EQ(NSM_ASSERT_PCIE_FUNDAMENTAL_RESET, req->hdr.command);
	EXPECT_EQ(2, req->hdr.data_size);
	EXPECT_EQ(device_index, req->device_index);
	EXPECT_EQ(action, req->action);
}

TEST(pcieFundamentalReset, testGoodDecodeRequest)
{
	std::vector<uint8_t> requestMsg{
	    0x10,
	    0xDE,	       // PCI VID: NVIDIA 0x10DE
	    0x80,	       // RQ=1, D=0, RSVD=0, INSTANCE_ID=0
	    0x89,	       // OCP_TYPE=8, OCP_VER=9
	    NSM_TYPE_PCI_LINK, // NVIDIA_MSG_TYPE
	    NSM_ASSERT_PCIE_FUNDAMENTAL_RESET, // command
	    2,				       // data size
	    1,				       // device_index
	    0				       // action
	};

	auto request = reinterpret_cast<nsm_msg *>(requestMsg.data());
	size_t msg_len = requestMsg.size();
	uint8_t device_index;
	uint8_t action;
	auto rc = decode_assert_pcie_fundamental_reset_req(
	    request, msg_len, &device_index, &action);
	EXPECT_EQ(rc, NSM_SW_SUCCESS);
	EXPECT_EQ(1, device_index);
	EXPECT_EQ(0, action);
}

TEST(pcieFundamentalReset, testGoodEncodeResponse)
{
	std::vector<uint8_t> responseMsg(
	    sizeof(nsm_msg_hdr) + sizeof(struct nsm_common_resp), 0);
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	uint16_t reason_code = ERR_NULL;

	auto rc = encode_assert_pcie_fundamental_reset_resp(
	    0, NSM_SUCCESS, reason_code, response);

	struct nsm_common_resp *resp =
	    reinterpret_cast<struct nsm_common_resp *>(response->payload);

	EXPECT_EQ(rc, NSM_SW_SUCCESS);

	EXPECT_EQ(0, response->hdr.request);
	EXPECT_EQ(0, response->hdr.datagram);
	EXPECT_EQ(NSM_TYPE_PCI_LINK, response->hdr.nvidia_msg_type);

	EXPECT_EQ(NSM_ASSERT_PCIE_FUNDAMENTAL_RESET, resp->command);
	EXPECT_EQ(0, le16toh(resp->data_size));
}

TEST(pcieFundamentalReset, testGoodDecodeResponse)
{
	std::vector<uint8_t> responseMsg{
	    0x10,
	    0xDE,	       // PCI VID: NVIDIA 0x10DE
	    0x00,	       // RQ=0, D=0, RSVD=0, INSTANCE_ID=0
	    0x89,	       // OCP_TYPE=8, OCP_VER=9
	    NSM_TYPE_PCI_LINK, // NVIDIA_MSG_TYPE
	    NSM_ASSERT_PCIE_FUNDAMENTAL_RESET, // command
	    0,				       // completion code
	    0,				       // reserved
	    0,				       // reserved
	    0,
	    0 // data size
	};

	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	size_t msg_len = responseMsg.size();

	uint8_t cc = NSM_SUCCESS;
	uint16_t reason_code = ERR_NULL;
	uint16_t data_size = 0;

	auto rc = decode_assert_pcie_fundamental_reset_resp(
	    response, msg_len, &cc, &data_size, &reason_code);

	EXPECT_EQ(rc, NSM_SW_SUCCESS);
	EXPECT_EQ(cc, NSM_SUCCESS);
	EXPECT_EQ(0, data_size);
}

TEST(pcieFundamentalReset, testBadDecodeResponse)
{
	std::vector<uint8_t> responseMsg{
	    0x10,
	    0xDE,	       // PCI VID: NVIDIA 0x10DE
	    0x00,	       // RQ=0, D=0, RSVD=0, INSTANCE_ID=0
	    0x89,	       // OCP_TYPE=8, OCP_VER=9
	    NSM_TYPE_PCI_LINK, // NVIDIA_MSG_TYPE
	    NSM_ASSERT_PCIE_FUNDAMENTAL_RESET, // command
	    0,				       // completion code
	    0,				       // reserved
	    0,				       // reserved
	    0,				       // data size
	    0				       // data size
	};

	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	size_t msg_len = responseMsg.size();

	uint8_t cc = NSM_SUCCESS;
	uint16_t reason_code = ERR_NULL;
	uint16_t data_size = 0;

	auto rc = decode_assert_pcie_fundamental_reset_resp(
	    NULL, msg_len, &cc, &data_size, &reason_code);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_assert_pcie_fundamental_reset_resp(
	    response, msg_len, NULL, &data_size, &reason_code);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_assert_pcie_fundamental_reset_resp(response, msg_len, &cc,
						       NULL, &reason_code);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_assert_pcie_fundamental_reset_resp(
	    response, msg_len - 1, &cc, &data_size, &reason_code);
	EXPECT_EQ(rc, NSM_SW_ERROR_LENGTH);
}

TEST(clearScalarDataSource, testGoodEncodeRequest)
{
	std::vector<uint8_t> requestMsg(sizeof(nsm_msg_hdr) +
					sizeof(nsm_clear_data_source_v1_req));

	auto request = reinterpret_cast<nsm_msg *>(requestMsg.data());
	uint8_t device_index = 1;
	uint8_t groupId = 8;
	uint8_t dsId = 2;
	auto rc = encode_clear_data_source_v1_req(0, device_index, groupId,
						  dsId, request);
	struct nsm_clear_data_source_v1_req *req =
	    reinterpret_cast<struct nsm_clear_data_source_v1_req *>(
		request->payload);

	EXPECT_EQ(rc, NSM_SW_SUCCESS);

	EXPECT_EQ(1, request->hdr.request);
	EXPECT_EQ(0, request->hdr.datagram);
	EXPECT_EQ(NSM_TYPE_PCI_LINK, request->hdr.nvidia_msg_type);

	EXPECT_EQ(NSM_CLEAR_DATA_SOURCE_V1, req->hdr.command);
	EXPECT_EQ(3, req->hdr.data_size);
	EXPECT_EQ(device_index, req->device_index);
	EXPECT_EQ(groupId, req->groupId);
	EXPECT_EQ(dsId, req->dsId);
}

TEST(clearScalarDataSource, testGoodDecodeRequest)
{
	std::vector<uint8_t> requestMsg{
	    0x10,
	    0xDE,		      // PCI VID: NVIDIA 0x10DE
	    0x80,		      // RQ=1, D=0, RSVD=0, INSTANCE_ID=0
	    0x89,		      // OCP_TYPE=8, OCP_VER=9
	    NSM_TYPE_PCI_LINK,	      // NVIDIA_MSG_TYPE
	    NSM_CLEAR_DATA_SOURCE_V1, // command
	    3,			      // data size
	    1,			      // device_index
	    5,			      // groupId
	    2			      // dsId
	};

	auto request = reinterpret_cast<nsm_msg *>(requestMsg.data());
	size_t msg_len = requestMsg.size();
	uint8_t device_index;
	uint8_t groupId;
	uint8_t dsId;
	auto rc = decode_clear_data_source_v1_req(
	    request, msg_len, &device_index, &groupId, &dsId);
	EXPECT_EQ(rc, NSM_SW_SUCCESS);
	EXPECT_EQ(1, device_index);
	EXPECT_EQ(5, groupId);
	EXPECT_EQ(2, dsId);
}

TEST(clearScalarDataSource, testGoodEncodeResponse)
{
	std::vector<uint8_t> responseMsg(
	    sizeof(nsm_msg_hdr) + sizeof(struct nsm_common_resp), 0);
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	uint16_t reason_code = ERR_NULL;

	auto rc = encode_clear_data_source_v1_resp(0, NSM_SUCCESS, reason_code,
						   response);

	struct nsm_common_resp *resp =
	    reinterpret_cast<struct nsm_common_resp *>(response->payload);

	EXPECT_EQ(rc, NSM_SW_SUCCESS);

	EXPECT_EQ(0, response->hdr.request);
	EXPECT_EQ(0, response->hdr.datagram);
	EXPECT_EQ(NSM_TYPE_PCI_LINK, response->hdr.nvidia_msg_type);

	EXPECT_EQ(NSM_CLEAR_DATA_SOURCE_V1, resp->command);
	EXPECT_EQ(0, le16toh(resp->data_size));
}

TEST(clearScalarDataSource, testGoodDecodeResponse)
{
	std::vector<uint8_t> responseMsg{
	    0x10,
	    0xDE,		      // PCI VID: NVIDIA 0x10DE
	    0x00,		      // RQ=0, D=0, RSVD=0, INSTANCE_ID=0
	    0x89,		      // OCP_TYPE=8, OCP_VER=9
	    NSM_TYPE_PCI_LINK,	      // NVIDIA_MSG_TYPE
	    NSM_CLEAR_DATA_SOURCE_V1, // command
	    0,			      // completion code
	    0,			      // reserved
	    0,			      // reserved
	    0,
	    0 // data size
	};

	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	size_t msg_len = responseMsg.size();

	uint8_t cc = NSM_SUCCESS;
	uint16_t reason_code = ERR_NULL;
	uint16_t data_size = 0;

	auto rc = decode_clear_data_source_v1_resp(response, msg_len, &cc,
						   &data_size, &reason_code);

	EXPECT_EQ(rc, NSM_SW_SUCCESS);
	EXPECT_EQ(cc, NSM_SUCCESS);
	EXPECT_EQ(0, data_size);
}

TEST(clearScalarDataSource, testBadDecodeResponse)
{
	std::vector<uint8_t> responseMsg{
	    0x10,
	    0xDE,		      // PCI VID: NVIDIA 0x10DE
	    0x00,		      // RQ=0, D=0, RSVD=0, INSTANCE_ID=0
	    0x89,		      // OCP_TYPE=8, OCP_VER=9
	    NSM_TYPE_PCI_LINK,	      // NVIDIA_MSG_TYPE
	    NSM_CLEAR_DATA_SOURCE_V1, // command
	    0,			      // completion code
	    0,			      // reserved
	    0,			      // reserved
	    0,			      // data size
	    0			      // data size
	};

	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	size_t msg_len = responseMsg.size();

	uint8_t cc = NSM_SUCCESS;
	uint16_t reason_code = ERR_NULL;
	uint16_t data_size = 0;

	auto rc = decode_clear_data_source_v1_resp(NULL, msg_len, &cc,
						   &data_size, &reason_code);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_clear_data_source_v1_resp(response, msg_len, NULL,
					      &data_size, &reason_code);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_clear_data_source_v1_resp(response, msg_len, &cc, NULL,
					      &reason_code);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_clear_data_source_v1_resp(response, msg_len - 1, &cc,
					      &data_size, &reason_code);
	EXPECT_EQ(rc, NSM_SW_ERROR_LENGTH);
}

TEST(QueryAvailableAndClearableScalarDataSource, testGoodEncodeRequest)
{
	std::vector<uint8_t> requestMsg(
	    sizeof(nsm_msg_hdr) +
	    sizeof(nsm_query_available_clearable_scalar_data_sources_v1_req));

	auto request = reinterpret_cast<nsm_msg *>(requestMsg.data());
	uint8_t device_index = 1;
	uint8_t groupId = 8;
	auto rc = encode_query_available_clearable_scalar_data_sources_v1_req(
	    0, device_index, groupId, request);
	struct nsm_query_available_clearable_scalar_data_sources_v1_req *req =
	    reinterpret_cast<
		struct nsm_query_available_clearable_scalar_data_sources_v1_req
		    *>(request->payload);

	EXPECT_EQ(rc, NSM_SW_SUCCESS);

	EXPECT_EQ(1, request->hdr.request);
	EXPECT_EQ(0, request->hdr.datagram);
	EXPECT_EQ(NSM_TYPE_PCI_LINK, request->hdr.nvidia_msg_type);

	EXPECT_EQ(NSM_QUERY_AVAILABLE_CLEARABLE_SCALAR_DATA_SOURCES,
		  req->hdr.command);
	EXPECT_EQ(2, req->hdr.data_size);
	EXPECT_EQ(device_index, req->device_index);
	EXPECT_EQ(groupId, req->group_id);
}

TEST(QueryAvailableAndClearableScalarDataSource, testGoodDecodeRequest)
{
	std::vector<uint8_t> requestMsg{
	    0x10,
	    0xDE,	       // PCI VID: NVIDIA 0x10DE
	    0x80,	       // RQ=1, D=0, RSVD=0, INSTANCE_ID=0
	    0x89,	       // OCP_TYPE=8, OCP_VER=9
	    NSM_TYPE_PCI_LINK, // NVIDIA_MSG_TYPE
	    NSM_QUERY_AVAILABLE_CLEARABLE_SCALAR_DATA_SOURCES, // command
	    2,						       // data size
	    1,						       // device_index
	    5						       // groupId
	};

	auto request = reinterpret_cast<nsm_msg *>(requestMsg.data());
	size_t msg_len = requestMsg.size();
	uint8_t device_index;
	uint8_t groupId;
	auto rc = decode_query_available_clearable_scalar_data_sources_v1_req(
	    request, msg_len, &device_index, &groupId);
	EXPECT_EQ(rc, NSM_SW_SUCCESS);
	EXPECT_EQ(1, device_index);
	EXPECT_EQ(5, groupId);
}

TEST(QueryAvailableAndClearableScalarDataSource, testGoodEncodeResponse)
{
	uint16_t data_size = 5;
	bitfield8_t available_source[2];
	bitfield8_t clearable_source[2];
	uint8_t mask_length = 2;

	available_source[0].byte = 25;
	available_source[1].byte = 95;
	clearable_source[0].byte = 75;
	clearable_source[1].byte = 35;

	std::vector<uint8_t> responseMsg(
	    sizeof(nsm_msg_hdr) +
		sizeof(
		    struct
		    nsm_query_available_clearable_scalar_data_sources_v1_resp) +
		mask_length * 2,
	    0);
	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	uint16_t reason_code = ERR_NULL;

	auto rc = encode_query_available_clearable_scalar_data_sources_v1_resp(
	    0, NSM_SUCCESS, reason_code, data_size, mask_length,
	    (uint8_t *)available_source, (uint8_t *)clearable_source, response);

	struct nsm_query_available_clearable_scalar_data_sources_v1_resp *resp =
	    reinterpret_cast<
		struct nsm_query_available_clearable_scalar_data_sources_v1_resp
		    *>(response->payload);

	EXPECT_EQ(rc, NSM_SW_SUCCESS);

	EXPECT_EQ(0, response->hdr.request);
	EXPECT_EQ(0, response->hdr.datagram);
	EXPECT_EQ(NSM_TYPE_PCI_LINK, response->hdr.nvidia_msg_type);

	EXPECT_EQ(NSM_QUERY_AVAILABLE_CLEARABLE_SCALAR_DATA_SOURCES,
		  resp->hdr.command);
	EXPECT_EQ(5, le16toh(resp->hdr.data_size));
	EXPECT_EQ(2, resp->mask_length);
	EXPECT_EQ(25, resp->data[0]);
	EXPECT_EQ(95, resp->data[1]);
	EXPECT_EQ(75, resp->data[2]);
	EXPECT_EQ(35, resp->data[3]);
}

TEST(QueryAvailableAndClearableScalarDataSource, testGoodDecodeResponse)
{
	std::vector<uint8_t> responseMsg{
	    0x10,
	    0xDE,	       // PCI VID: NVIDIA 0x10DE
	    0x00,	       // RQ=0, D=0, RSVD=0, INSTANCE_ID=0
	    0x89,	       // OCP_TYPE=8, OCP_VER=9
	    NSM_TYPE_PCI_LINK, // NVIDIA_MSG_TYPE
	    NSM_QUERY_AVAILABLE_CLEARABLE_SCALAR_DATA_SOURCES, // command
	    0, // completion code
	    0, // reserved
	    0, // reserved
	    5,
	    0,	// data size
	    2,	// mask length
	    25, // available data source
	    95, // available data source
	    35, // clearable data source
	    75	// clearable data source
	};

	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	size_t msg_len = responseMsg.size();

	uint8_t cc = NSM_SUCCESS;
	uint16_t reason_code = ERR_NULL;
	uint16_t data_size = 0;
	uint8_t mask_length;
	bitfield8_t available_source[5];
	bitfield8_t clearable_source[5];

	auto rc = decode_query_available_clearable_scalar_data_sources_v1_resp(
	    response, msg_len, &cc, &data_size, &reason_code, &mask_length,
	    (uint8_t *)available_source, (uint8_t *)clearable_source);

	EXPECT_EQ(rc, NSM_SW_SUCCESS);
	EXPECT_EQ(cc, NSM_SUCCESS);
	EXPECT_EQ(5, data_size);
	EXPECT_EQ(25, available_source[0].byte);
	EXPECT_EQ(95, available_source[1].byte);
	EXPECT_EQ(35, clearable_source[0].byte);
	EXPECT_EQ(75, clearable_source[1].byte);
}

TEST(QueryAvailableAndClearableScalarDataSource, testBadDecodeResponse)
{
	std::vector<uint8_t> responseMsg{
	    0x10,
	    0xDE,	       // PCI VID: NVIDIA 0x10DE
	    0x00,	       // RQ=0, D=0, RSVD=0, INSTANCE_ID=0
	    0x89,	       // OCP_TYPE=8, OCP_VER=9
	    NSM_TYPE_PCI_LINK, // NVIDIA_MSG_TYPE
	    NSM_QUERY_AVAILABLE_CLEARABLE_SCALAR_DATA_SOURCES, // command
	    0, // completion code
	    0, // reserved
	    0, // reserved
	    4,
	    0,	// data size
	    2,	// mask length
	    25, // available data source
	    95, // available data source
	    35, // clearable data source
	    75	// clearable data source
	};

	auto response = reinterpret_cast<nsm_msg *>(responseMsg.data());
	size_t msg_len = responseMsg.size();

	uint8_t cc = NSM_SUCCESS;
	uint16_t reason_code = ERR_NULL;
	uint16_t data_size = 0;
	uint8_t mask_length;
	bitfield8_t available_source[2];
	bitfield8_t clearable_source[2];

	auto rc = decode_query_available_clearable_scalar_data_sources_v1_resp(
	    NULL, msg_len, &cc, &data_size, &reason_code, &mask_length,
	    (uint8_t *)available_source, (uint8_t *)clearable_source);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_available_clearable_scalar_data_sources_v1_resp(
	    response, msg_len, &cc, &data_size, &reason_code, NULL,
	    (uint8_t *)available_source, (uint8_t *)clearable_source);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_available_clearable_scalar_data_sources_v1_resp(
	    response, msg_len, &cc, &data_size, &reason_code, &mask_length,
	    NULL, (uint8_t *)clearable_source);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_available_clearable_scalar_data_sources_v1_resp(
	    response, msg_len, &cc, &data_size, &reason_code, &mask_length,
	    (uint8_t *)available_source, NULL);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_available_clearable_scalar_data_sources_v1_resp(
	    response, msg_len, NULL, &data_size, &reason_code, &mask_length,
	    (uint8_t *)available_source, (uint8_t *)clearable_source);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_available_clearable_scalar_data_sources_v1_resp(
	    response, msg_len, &cc, NULL, &reason_code, &mask_length,
	    (uint8_t *)available_source, (uint8_t *)clearable_source);
	EXPECT_EQ(rc, NSM_SW_ERROR_NULL);

	rc = decode_query_available_clearable_scalar_data_sources_v1_resp(
	    response, msg_len - 5, &cc, &data_size, &reason_code, &mask_length,
	    (uint8_t *)available_source, (uint8_t *)clearable_source);
	EXPECT_EQ(rc, NSM_SW_ERROR_LENGTH);

	rc = decode_query_available_clearable_scalar_data_sources_v1_resp(
	    response, msg_len, &cc, &data_size, &reason_code, &mask_length,
	    (uint8_t *)available_source, (uint8_t *)clearable_source);
	EXPECT_EQ(rc, NSM_SW_ERROR_DATA);
}

TEST(ListAvailablePciePorts, testRequest)
{
	testEncodeCommonRequest(&encode_list_available_pcie_ports_req,
				NSM_TYPE_PCI_LINK,
				NSM_LIST_AVAILABLE_PCIE_PORTS);
	testDecodeCommonRequest(&decode_list_available_pcie_ports_req,
				NSM_TYPE_PCI_LINK,
				NSM_LIST_AVAILABLE_PCIE_PORTS);
}

TEST(ListAvailablePciePorts, testResponse)
{
	const size_t payloadSize =
	    sizeof(uint16_t) + sizeof(nsm_pcie_upstream_port_info) * 2;
	Response responseMsg(sizeof(nsm_common_resp) + payloadSize);
	auto &resp = *reinterpret_cast<nsm_list_available_pcie_ports_resp *>(
	    responseMsg.data());
	Response expectedResponseMsg(sizeof(nsm_common_resp) + payloadSize);
	auto &info = reinterpret_cast<nsm_list_available_pcie_ports_resp *>(
			 expectedResponseMsg.data())
			 ->port_info;
	nsm_pcie_upstream_port_info ports[2] = {
	    {.type = 1, .downstream_ports_count = 2},
	    {.type = 0, .downstream_ports_count = 2}};
	info.ports_count = 2;
	memcpy(info.ports, ports,
	       info.ports_count * sizeof(nsm_pcie_upstream_port_info));

	testEncodeResponse<nsm_list_available_pcie_ports_info>(
	    &encode_list_available_pcie_ports_resp, NSM_TYPE_PCI_LINK,
	    NSM_LIST_AVAILABLE_PCIE_PORTS, info, resp.port_info, payloadSize);
	EXPECT_EQ(resp.port_info.ports_count, info.ports_count);
	EXPECT_EQ(resp.port_info.ports[0].type, info.ports[0].type);
	EXPECT_EQ(resp.port_info.ports[0].downstream_ports_count,
		  info.ports[0].downstream_ports_count);

	testDecodeResponse<nsm_list_available_pcie_ports_info>(
	    &decode_list_available_pcie_ports_resp, NSM_TYPE_PCI_LINK,
	    NSM_LIST_AVAILABLE_PCIE_PORTS, info, resp.port_info, payloadSize);
	EXPECT_EQ(resp.port_info.ports_count, info.ports_count);
	EXPECT_EQ(resp.port_info.ports[0].type, info.ports[0].type);
	EXPECT_EQ(resp.port_info.ports[0].downstream_ports_count,
		  info.ports[0].downstream_ports_count);
}

TEST(ListAvailablePciePorts, testBadDataResponse)
{
	Response responseMsg(NSM_LIST_AVAILABLE_PCIE_PORTS_RESPONSE_MIN_LEN);
	auto resp = reinterpret_cast<nsm_msg *>(responseMsg.data());
	uint8_t cc = NSM_SUCCESS;
	uint16_t reasonCode = ERR_NULL;
	nsm_list_available_pcie_ports_info info{1, {{2, 2}}};

	auto rc = encode_list_available_pcie_ports_resp(
	    0, NSM_SUCCESS, reasonCode, &info, resp);
	EXPECT_EQ(rc, NSM_SW_SUCCESS);

	rc = decode_list_available_pcie_ports_resp(resp, responseMsg.size(),
						   &cc, &reasonCode, &info);
	EXPECT_EQ(rc, NSM_SW_ERROR_DATA);
}

TEST(MultiportQueryScalarGroupTelemetry, testRequest)
{
	const nsm_multiport_query_scalar_group_telemetry_v2_req_data data = {
	    1, NSM_PORT_TYPE_DOWNSTREAM, 0, GROUP_ID_10};
	nsm_multiport_query_scalar_group_telemetry_v2_req req;

	testEncodeRequest<
	    nsm_multiport_query_scalar_group_telemetry_v2_req_data>(
	    &encode_multiport_query_scalar_group_telemetry_v2_req,
	    NSM_TYPE_PCI_LINK, NSM_MULTIPORT_QUERY_SCALAR_GROUP_TELEMETRY_V2,
	    data, req.data);

	testDecodeRequest<
	    nsm_multiport_query_scalar_group_telemetry_v2_req_data>(
	    &decode_multiport_query_scalar_group_telemetry_v1_req,
	    NSM_TYPE_PCI_LINK, NSM_MULTIPORT_QUERY_SCALAR_GROUP_TELEMETRY_V2,
	    data, req.data);

	EXPECT_EQ(NSM_PORT_TYPE_DOWNSTREAM, req.data.type);
	EXPECT_EQ(1, req.data.upstream_port_index);
	EXPECT_EQ(0, req.data.index);
	EXPECT_EQ(GROUP_ID_10, req.data.group_index);
}

TEST(QueryScalarGroupTelemetryGroup10, testResponse)
{
	const nsm_query_scalar_group_telemetry_group_10 data = {
	    DS_ID_0, DS_ID_1, DS_ID_2, DS_ID_3, DS_ID_4,  DS_ID_5,
	    DS_ID_6, DS_ID_7, DS_ID_8, DS_ID_9, DS_ID_10,
	};
	nsm_query_scalar_group_telemetry_v1_group_10_resp resp;

	testEncodeResponse<nsm_query_scalar_group_telemetry_group_10>(
	    &encode_query_scalar_group_telemetry_v1_group10_resp,
	    NSM_TYPE_PCI_LINK, NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, data,
	    resp.data);

	testDecodeResponse<nsm_query_scalar_group_telemetry_group_10>(
	    &decode_query_scalar_group_telemetry_v1_group10_resp,
	    NSM_TYPE_PCI_LINK, NSM_QUERY_SCALAR_GROUP_TELEMETRY_V1, data,
	    resp.data);

	EXPECT_EQ(DS_ID_0, resp.data.outbound_read_tlp_count);
	EXPECT_EQ(DS_ID_1,
		  resp.data.dwords_transferred_in_outbound_read_tlp_high);
	EXPECT_EQ(DS_ID_2,
		  resp.data.dwords_transferred_in_outbound_read_tlp_low);
	EXPECT_EQ(DS_ID_3, resp.data.outbound_write_tlp_count);
	EXPECT_EQ(DS_ID_4,
		  resp.data.dwords_transferred_in_outbound_write_tlp_high);
	EXPECT_EQ(DS_ID_5,
		  resp.data.dwords_transferred_in_outbound_write_tlp_low);
	EXPECT_EQ(DS_ID_6, resp.data.outbound_completion_tlp_count);
	EXPECT_EQ(DS_ID_7, resp.data.dwords_transferred_in_outbound_completion);
	EXPECT_EQ(DS_ID_8, resp.data.read_requests_dropped_tag_unavailable);
	EXPECT_EQ(DS_ID_9, resp.data.read_requests_dropped_credit_exhaustion);
	EXPECT_EQ(DS_ID_10, resp.data.read_requests_dropped_credit_not_posted);
}