test_pktstream.cpp

Go to the documentation of this file.

//    OpenVPN -- An application to securely tunnel IP networks
//               over a single port, with support for SSL/TLS-based
//               session authentication and key exchange,
//               packet encryption, packet authentication, and
//               packet compression.
//
//    Copyright (C) 2012- OpenVPN Inc.
//
//    SPDX-License-Identifier: MPL-2.0 OR AGPL-3.0-only WITH openvpn3-openssl-exception
//
 
 
#include "test_common.hpp"
 
#include <openvpn/random/mtrandapi.hpp>
#include <openvpn/transport/pktstream.hpp>
 
using namespace openvpn;
 
// Return a random value in the range [1,512] but with
// the subrange [1, 16] having elevated probability.
static size_t rand_size(RandomAPI &prng)
{
    if (prng.randbool())
        return prng.randrange32(1, 16);
    else
        return prng.randrange32(1, 512);
}
 
template <typename PKTSTREAM>
static void do_test(const bool grow, const bool verbose)
{
#ifdef INSTRUMENTATION_SLOWDOWN
    const int n_iter = 500;
#else
    const int n_iter = 250000;
#endif
 
    const Frame::Context fc(256, 512, 256, 0, sizeof(size_t), grow ? BufAllocFlags::GROW : BufAllocFlags::NO_FLAGS);
    const Frame::Context fc_big(256, 4096, 256, 0, sizeof(size_t), grow ? BufAllocFlags::GROW : BufAllocFlags::NO_FLAGS);
 
    if (verbose)
    {
        OPENVPN_LOG("FC " << fc.info());
        OPENVPN_LOG("FC BIG " << fc_big.info());
    }
 
    MTRand::Ptr prng(new MTRand());
 
    size_t count = 0;
 
    for (int iter = 0; iter < n_iter; ++iter)
    {
        // build big
        BufferAllocated big;
        fc_big.prepare(big);
        size_t nbig = 0;
 
        {
            BufferAllocated src;
            while (true)
            {
                fc.prepare(src);
                const size_t r = rand_size(*prng);
                for (size_t i = 0; i < r; ++i)
                    src.push_back('a' + static_cast<unsigned char>(i % 26));
                PKTSTREAM::prepend_size(src);
                if (src.size() > fc_big.remaining_payload(big))
                    break;
                big.write(src.data(), src.size());
                ++nbig;
            }
        }
 
        // save big
        const Buffer bigorig(big);
 
        // deconstruct big
        BufferAllocated bigcmp;
        fc_big.prepare(bigcmp);
        size_t ncmp = 0;
 
        {
            PKTSTREAM pktstream;
            BufferAllocated in;
            while (big.size())
            {
                const size_t bytes = std::min(big.size(), rand_size(*prng));
                fc.prepare(in);
                in.write(big.data(), bytes);
                big.advance(bytes);
                BufferAllocated out;
                while (in.size())
                {
                    pktstream.put(in, fc);
                    while (pktstream.ready())
                    {
                        pktstream.get(out, fc);
                        PKTSTREAM::prepend_size(out);
                        bigcmp.write(out.data(), out.size());
                        ++ncmp;
                    }
                }
            }
        }
 
        // sum byte count
        count += bigorig.size();
 
        // check result
        ASSERT_EQ(nbig, ncmp);
        ASSERT_EQ(bigorig, bigcmp);
    }
 
    if (verbose)
        OPENVPN_LOG("count=" << count);
}
 
TEST(pktstream, test_16)
{
    do_test<PacketStream<std::uint16_t>>(false, false);
}
 
TEST(pktstream, test_32)
{
    do_test<PacketStream<std::uint32_t>>(false, false);
}
 
TEST(pktstream, test_16_residual)
{
    do_test<PacketStreamResidual<std::uint16_t>>(true, false);
}
 
TEST(pktstream, test_32_residual)
{
    do_test<PacketStreamResidual<std::uint32_t>>(true, false);
}
 
template <typename PKTSTREAM>
static void validate_size(const Frame::Context &fc, const size_t size, const bool expect_throw)
{
    bool actual_throw = false;
    try
    {
        PKTSTREAM::validate_size(size, fc);
    }
    catch (typename PKTSTREAM::embedded_packet_size_error &)
    {
        actual_throw = true;
    }
    if (expect_throw != actual_throw)
        THROW_FMT("validate_size: bad throw, expect=%s, actual=%s, FC=%s size=%s",
                  expect_throw,
                  actual_throw,
                  fc.info(),
                  size);
}
 
template <typename PKTSTREAM>
static void validate_size_test()
{
    const size_t payload = 2048;
    const size_t headroom = 16;
    const size_t tailroom = 0;
    const size_t align_block = 16;
    const Frame::Context fixed(headroom, payload, tailroom, 0, align_block, BufAllocFlags::NO_FLAGS);
    const Frame::Context grow(headroom, payload, tailroom, 0, align_block, BufAllocFlags::GROW);
    validate_size<PKTSTREAM>(fixed, 2048, false); // succeeds
    validate_size<PKTSTREAM>(fixed, 2049, true);  // exceeded payload, throw
    validate_size<PKTSTREAM>(grow, 2048, false);  // succeeds
    validate_size<PKTSTREAM>(grow, 2049, false);  // exceeded payload, but okay with growable buffer
}
 
TEST(pktstream, validate_size_16)
{
    validate_size_test<PacketStream<std::uint16_t>>();
}
 
TEST(pktstream, validate_size_32)
{
    validate_size_test<PacketStream<std::uint32_t>>();
}