mirror of
https://github.com/akuker/RASCSI.git
synced 2024-11-22 16:33:17 +00:00
52c2aa474f
* Rebrand project to PiSCSI - rascsi ->piscsi - rasctl -> scsictl - rasdump -> scsidump - ras* -> piscsi* (rasutil -> piscsi_util, etc.) * Refined the formatting and wording of the app startup banner * Kept some references to rascsi and rasctl where backwards compatibility is concerned * Point to the new github repo URL Co-authored-by: nucleogenic <nr@nucleogenic.com> Co-authored-by: Uwe Seimet <Uwe.Seimet@seimet.de>
99 lines
2.6 KiB
C++
99 lines
2.6 KiB
C++
//---------------------------------------------------------------------------
|
|
//
|
|
// SCSI Target Emulator PiSCSI
|
|
// for Raspberry Pi
|
|
//
|
|
// Copyright (C) 2022 Uwe Seimet
|
|
//
|
|
//---------------------------------------------------------------------------
|
|
|
|
#include "mocks.h"
|
|
#include "shared/protobuf_serializer.h"
|
|
#include "shared/piscsi_exceptions.h"
|
|
#include "generated/piscsi_interface.pb.h"
|
|
#include <filesystem>
|
|
|
|
using namespace filesystem;
|
|
using namespace piscsi_interface;
|
|
|
|
TEST(ProtobufSerializerTest, SerializeMessage)
|
|
{
|
|
PbResult result;
|
|
ProtobufSerializer serializer;
|
|
|
|
const int fd = open("/dev/null", O_WRONLY);
|
|
EXPECT_NE(-1, fd);
|
|
serializer.SerializeMessage(fd, result);
|
|
EXPECT_THROW(serializer.SerializeMessage(-1, result), io_exception) << "Writing a message must fail";
|
|
close(fd);
|
|
}
|
|
|
|
TEST(ProtobufSerializerTest, DeserializeMessage)
|
|
{
|
|
PbResult result;
|
|
ProtobufSerializer serializer;
|
|
vector<byte> buf(1);
|
|
|
|
int fd = open("/dev/null", O_RDONLY);
|
|
EXPECT_NE(-1, fd);
|
|
EXPECT_THROW(serializer.DeserializeMessage(fd, result), io_exception) << "Reading the message header must fail";
|
|
close(fd);
|
|
|
|
auto [fd1, filename1] = OpenTempFile();
|
|
// Data size -1
|
|
buf = { byte{0xff}, byte{0xff}, byte{0xff}, byte{0xff} };
|
|
EXPECT_EQ(buf.size(), write(fd1, buf.data(), buf.size()));
|
|
close(fd1);
|
|
fd1 = open(filename1.c_str(), O_RDONLY);
|
|
EXPECT_NE(-1, fd1);
|
|
EXPECT_THROW(serializer.DeserializeMessage(fd1, result), io_exception) << "Invalid header was not rejected";
|
|
remove(filename1);
|
|
|
|
auto [fd2, filename2] = OpenTempFile();
|
|
// Data size 2
|
|
buf = { byte{0x02}, byte{0x00}, byte{0x00}, byte{0x00} };
|
|
EXPECT_EQ(buf.size(), write(fd2, buf.data(), buf.size()));
|
|
close(fd2);
|
|
fd2 = open(filename2.c_str(), O_RDONLY);
|
|
EXPECT_NE(-1, fd2);
|
|
EXPECT_THROW(serializer.DeserializeMessage(fd2, result), io_exception) << "Invalid data were not rejected";
|
|
remove(filename2);
|
|
}
|
|
|
|
TEST(ProtobufSerializerTest, SerializeDeserializeMessage)
|
|
{
|
|
PbResult result;
|
|
result.set_status(true);
|
|
ProtobufSerializer serializer;
|
|
|
|
auto [fd, filename] = OpenTempFile();
|
|
EXPECT_NE(-1, fd);
|
|
serializer.SerializeMessage(fd, result);
|
|
close(fd);
|
|
|
|
result.set_status(false);
|
|
fd = open(filename.c_str(), O_RDONLY);
|
|
EXPECT_NE(-1, fd);
|
|
serializer.DeserializeMessage(fd, result);
|
|
close(fd);
|
|
remove(filename);
|
|
|
|
EXPECT_TRUE(result.status());
|
|
}
|
|
|
|
TEST(ProtobufSerializerTest, ReadBytes)
|
|
{
|
|
ProtobufSerializer serializer;
|
|
vector<byte> buf(1);
|
|
|
|
int fd = open("/dev/null", O_RDONLY);
|
|
EXPECT_NE(-1, fd);
|
|
EXPECT_EQ(0, serializer.ReadBytes(fd, buf));
|
|
close(fd);
|
|
|
|
fd = open("/dev/zero", O_RDONLY);
|
|
EXPECT_NE(-1, fd);
|
|
EXPECT_EQ(1, serializer.ReadBytes(fd, buf));
|
|
close(fd);
|
|
}
|