mirror/opustags
1
0
Fork 0
mirror of https://github.com/fmang/opustags.git synced 2024-11-10 07:27:22 +01:00
Code Issues Packages Projects Releases Wiki Activity

t: test the ogg writer

Browse Source
This commit is contained in:
Frédéric Mangano-Tarumi 2018-11-18 10:15:49 -05:00
parent cc83a438ae
commit 5445c5bc7c
1 changed files with 104 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

108
t/ogg.cc
View File

@ -3,10 +3,12 @@
static void check_ref_ogg()
{
FILE* input = fopen("gobble.opus", "r");
if (input == nullptr)
FILE* input_file = fopen("gobble.opus", "r");
if (input_file == nullptr)
throw failure("could not open gobble.opus");
ot::ogg_reader reader(input);
std::unique_ptr<FILE, decltype(&fclose)> input(input_file, &fclose);
ot::ogg_reader reader(input.get());
ot::status rc = reader.read_page();
if (rc != ot::status::ok)
@ -42,9 +44,107 @@ static void check_ref_ogg()
throw failure("did not correctly detect the end of stream");
}
static ogg_packet make_packet(const char* contents)
{
ogg_packet op {};
op.bytes = strlen(contents);
op.packet = (unsigned char*) contents;
return op;
}
static bool same_packet(const ogg_packet& lhs, const ogg_packet& rhs)
{
return lhs.bytes == rhs.bytes && memcmp(lhs.packet, rhs.packet, lhs.bytes) == 0;
}
/**
* Build an in-memory Ogg stream using ogg_writer, and then read it with ogg_reader.
*/
static void check_memory_ogg()
{
const ogg_packet first_packet = make_packet("First");
const ogg_packet second_packet = make_packet("Second");
const ogg_packet third_packet = make_packet("Third");
std::vector<unsigned char> my_ogg(128);
size_t my_ogg_size;
ot::status rc;
FILE* output_mem = fmemopen(my_ogg.data(), my_ogg.size(), "w");
if (output_mem == nullptr)
throw failure("could not open the output stream");
std::unique_ptr<FILE, decltype(&fclose)> output(output_mem, &fclose);
{
ot::ogg_writer writer(output.get());
rc = writer.prepare_stream(1234);
if (rc != ot::status::ok)
throw failure("could not prepare the stream for the first page");
writer.write_packet(first_packet);
if (rc != ot::status::ok)
throw failure("could not write the first packet");
writer.flush_page();
if (rc != ot::status::ok)
throw failure("could not flush the first page");
writer.prepare_stream(1234);
if (rc != ot::status::ok)
throw failure("could not prepare the stream for the second page");
writer.write_packet(second_packet);
if (rc != ot::status::ok)
throw failure("could not write the second packet");
writer.write_packet(third_packet);
if (rc != ot::status::ok)
throw failure("could not write the third packet");
writer.flush_page();
if (rc != ot::status::ok)
throw failure("could not flush the second page");
my_ogg_size = ftell(output.get());
if (my_ogg_size != 73)
throw failure("unexpected output size");
}
output.reset();
FILE* input_mem = fmemopen(my_ogg.data(), my_ogg_size, "r");
if (input_mem == nullptr)
throw failure("could not open the input stream");
std::unique_ptr<FILE, decltype(&fclose)> input(input_mem, &fclose);
{
ot::ogg_reader reader(input.get());
rc = reader.read_page();
if (rc != ot::status::ok)
throw failure("could not read the first page");
rc = reader.read_packet();
if (rc != ot::status::ok)
throw failure("could not read the first packet");
if (!same_packet(reader.packet, first_packet))
throw failure("unexpected content in the first packet");
rc = reader.read_packet();
if (rc != ot::status::end_of_page)
throw failure("unexpected second packet in the first page");
rc = reader.read_page();
if (rc != ot::status::ok)
throw failure("could not read the second page");
rc = reader.read_packet();
if (rc != ot::status::ok)
throw failure("could not read the second packet");
if (!same_packet(reader.packet, second_packet))
throw failure("unexpected content in the second packet");
rc = reader.read_packet();
if (rc != ot::status::ok)
throw failure("could not read the third packet");
if (!same_packet(reader.packet, third_packet))
throw failure("unexpected content in the third packet");
rc = reader.read_packet();
if (rc != ot::status::end_of_page)
throw failure("unexpected third packet in the second page");
rc = reader.read_page();
if (rc != ot::status::end_of_stream)
throw failure("unexpected third page");
}
}
int main(int argc, char **argv)
{
std::cout << "1..1\n";
std::cout << "1..2\n";
run(check_ref_ogg, "check a reference ogg stream");
run(check_memory_ogg, "build and check a fresh stream");
return 0;
}