Coverage Report

Created: 2025-10-14 06:14

next uncovered line (L), next uncovered region (R), next uncovered branch (B)
/src/uWebSockets/fuzzing/PerMessageDeflate.cpp
Line
Count
Source
1
/* This is a fuzz test of the permessage-deflate module */
2
3
#define WIN32_EXPORT
4
5
#include <cstdio>
6
#include <string>
7
#include <bitset>
8
9
/* We test the permessage deflate module */
10
#include "../src/PerMessageDeflate.h"
11
12
#include "helpers.h"
13
14
152
extern "C" int LLVMFuzzerTestOneInput(const uint8_t *data, size_t size) {
15
16
    /* First byte determines what compressor to use */
17
152
    if (size >= 1) {
18
19
152
        uWS::CompressOptions compressors[] = {
20
152
            uWS::DEDICATED_COMPRESSOR_3KB,
21
152
            uWS::DEDICATED_COMPRESSOR_4KB,
22
152
            uWS::DEDICATED_COMPRESSOR_8KB,
23
152
            uWS::DEDICATED_COMPRESSOR_16KB,
24
152
            uWS::DEDICATED_COMPRESSOR_32KB,
25
152
            uWS::DEDICATED_COMPRESSOR_64KB,
26
152
            uWS::DEDICATED_COMPRESSOR_128KB,
27
152
            uWS::DEDICATED_COMPRESSOR_256KB
28
152
        };
29
30
152
        auto compressor = compressors[data[0] % 8];
31
152
        data++;
32
152
        size--;
33
34
        /* Bits 0 - 256 are okay */
35
152
        std::bitset<257> b;
36
37
        /* If we could specify LARGE_BUFFER_SIZE small here we could force it to inflate in chunks,
38
        * triggering more line coverage. Currently it is set to 16kb which is always too much */
39
152
        struct StaticData {
40
152
            uWS::DeflationStream deflationStream;
41
152
            uWS::InflationStream inflationStream;
42
152
            uWS::ZlibContext zlibContext;
43
152
        } staticData = {compressor, compressor};
44
45
        /* Why is this padded? */
46
372k
        makeChunked(makePadded(data, size), size, [&staticData, &b](const uint8_t *data, size_t size) {
47
372k
            auto inflation = staticData.inflationStream.inflate(&staticData.zlibContext, std::string_view((char *) data, size), 256, true);
48
49
            /* Trigger ASAN flaws if length is more than 256 */
50
372k
            if (inflation.has_value()) {
51
372k
                b.set(inflation->length());
52
372k
            }
53
372k
        });
54
55
372k
        makeChunked(makePadded(data, size), size, [&staticData](const uint8_t *data, size_t size) {
56
            /* Always reset */
57
372k
            staticData.deflationStream.deflate(&staticData.zlibContext, std::string_view((char *) data, size), true);
58
372k
        });
59
60
152
    }
61
62
152
    return 0;
63
152
}
64