Coverage Report

Created: 2026-01-17 06:12

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
156
extern "C" int LLVMFuzzerTestOneInput(const uint8_t *data, size_t size) {
15
16
    /* First byte determines what compressor to use */
17
156
    if (size >= 1) {
18
19
156
        uWS::CompressOptions compressors[] = {
20
156
            uWS::DEDICATED_COMPRESSOR_3KB,
21
156
            uWS::DEDICATED_COMPRESSOR_4KB,
22
156
            uWS::DEDICATED_COMPRESSOR_8KB,
23
156
            uWS::DEDICATED_COMPRESSOR_16KB,
24
156
            uWS::DEDICATED_COMPRESSOR_32KB,
25
156
            uWS::DEDICATED_COMPRESSOR_64KB,
26
156
            uWS::DEDICATED_COMPRESSOR_128KB,
27
156
            uWS::DEDICATED_COMPRESSOR_256KB
28
156
        };
29
30
156
        auto compressor = compressors[data[0] % 8];
31
156
        data++;
32
156
        size--;
33
34
        /* Bits 0 - 256 are okay */
35
156
        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
156
        struct StaticData {
40
156
            uWS::DeflationStream deflationStream;
41
156
            uWS::InflationStream inflationStream;
42
156
            uWS::ZlibContext zlibContext;
43
156
        } staticData = {compressor, compressor};
44
45
        /* Why is this padded? */
46
388k
        makeChunked(makePadded(data, size), size, [&staticData, &b](const uint8_t *data, size_t size) {
47
388k
            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
388k
            if (inflation.has_value()) {
51
388k
                b.set(inflation->length());
52
388k
            }
53
388k
        });
54
55
388k
        makeChunked(makePadded(data, size), size, [&staticData](const uint8_t *data, size_t size) {
56
            /* Always reset */
57
388k
            staticData.deflationStream.deflate(&staticData.zlibContext, std::string_view((char *) data, size), true);
58
388k
        });
59
60
156
    }
61
62
156
    return 0;
63
156
}
64