varnish-cache/bin/varnishtest/vtc_h2_hpack.c
0
/*-
1
 * Copyright (c) 2008-2016 Varnish Software AS
2
 * All rights reserved.
3
 *
4
 * Author: Guillaume Quintard <guillaume.quintard@gmail.com>
5
 *
6
 * SPDX-License-Identifier: BSD-2-Clause
7
 *
8
 * Redistribution and use in source and binary forms, with or without
9
 * modification, are permitted provided that the following conditions
10
 * are met:
11
 * 1. Redistributions of source code must retain the above copyright
12
 *    notice, this list of conditions and the following disclaimer.
13
 * 2. Redistributions in binary form must reproduce the above copyright
14
 *    notice, this list of conditions and the following disclaimer in the
15
 *    documentation and/or other materials provided with the distribution.
16
 *
17
 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
18
 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
19
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
20
 * ARE DISCLAIMED.  IN NO EVENT SHALL AUTHOR OR CONTRIBUTORS BE LIABLE
21
 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
22
 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
23
 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
24
 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
25
 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
26
 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
27
 * SUCH DAMAGE.
28
 */
29
30
#include <stdint.h>
31
#include <stdio.h>
32
#include <stdlib.h>
33
#include <string.h>
34
35
36
#include "vdef.h"
37
38
#include "vas.h"
39
#include "vqueue.h"
40
41
#include "hpack.h"
42
#include "vtc_h2_priv.h"
43
44
struct symbol {
45
        uint32_t        val;
46
        uint8_t         size;
47
};
48
49
static const struct symbol coding_table[] = {
50
#define HPACK(i, v, l) {v, l},
51
#include "vtc_h2_enctbl.h"
52
#undef HPACK
53
        {0, 0}
54
};
55
56
#include "vtc_h2_dectbl.h"
57
58
#define MASK(pack, n) (pack >> (64 - n))
59
static int
60 33
huff_decode(char *str, int nm, struct hpk_iter *iter, int ilen)
61
{
62 33
        int l = 0;
63 33
        uint64_t pack = 0;
64 33
        unsigned pl = 0; /* pack length*/
65 33
        struct stbl *tbl = &tbl_0;
66
        struct ssym *sym;
67
68 33
        (void)nm;
69 381
        while (ilen > 0 || pl != 0) {
70
                /* make sure we have enough data*/
71 381
                if (pl < tbl->msk) {
72 81
                        if (ilen == 0) {
73 33
                                if (pl == 0 || (MASK(pack, pl) ==
74 33
                                                (unsigned)((1U << pl) - 1U))) {
75 33
                                        assert(tbl == &tbl_0);
76 33
                                        return (l);
77
                                }
78 0
                        }
79
                        /* fit as many bytes as we can in pack */
80 321
                        while (pl <= 56 && ilen > 0) {
81 546
                                pack |= (uint64_t)(*iter->buf & 0xff)
82 273
                                        << (56 - pl);
83 273
                                pl += 8;
84 273
                                iter->buf++;
85 273
                                ilen--;
86
                        }
87 48
                }
88 348
                assert(tbl);
89 348
                assert(tbl->msk);
90 348
                sym = &tbl->syms[MASK(pack, tbl->msk)];
91
92 348
                assert(sym->csm <= tbl->msk);
93
94 348
                if (sym->csm == 0 || pl < sym->csm)
95 0
                        return (0);
96
97 348
                assert(sym->csm <= 8);
98 348
                pack <<= sym->csm;
99 348
                assert(sym->csm <= pl);
100 348
                pl -= sym->csm;
101 348
                if (sym->nxt) {
102 0
                        tbl = sym->nxt;
103 0
                        continue;
104
                }
105 348
                str[l++] = sym->chr;
106 348
                tbl = &tbl_0;
107
        }
108 0
        return (l);
109 33
}
110
111
/* inspired from Dridi Boukelmoune's cashpack. */
112
static enum hpk_result
113 42
huff_encode(struct hpk_iter *iter, const char *str, int len)
114
{
115 42
        uint64_t pack = 0;
116 42
        int pl = 0; /* pack length*/
117
        uint32_t        v;
118
        uint8_t         s;
119
120 42
        assert(iter->buf < iter->end);
121
122 474
        while (len--) {
123 432
                v = coding_table[(uint8_t)*str].val;
124 432
                s = coding_table[(uint8_t)*str].size;
125
126 432
                pl += s;
127 432
                pack |= (uint64_t)v << (64 - pl);
128
129 732
                while (pl >= 8) {
130 300
                        if (iter->buf == iter->end)
131 0
                                return (hpk_done);
132 300
                        *iter->buf = (char)(pack >> 56);
133 300
                        iter->buf++;
134 300
                        pack <<= 8;
135 300
                        pl -= 8;
136
                }
137 432
                str++;
138
        }
139
140
        /* padding */
141 42
        if (pl) {
142 42
                assert(pl < 8);
143 42
                if (iter->buf == iter->end)
144 0
                        return (hpk_done);
145 42
                pl += 8;
146 42
                pack |= (uint64_t)0xff << (64 - pl);
147 42
                *iter->buf = (char)(pack >> 56);
148 42
                iter->buf++;
149 42
        }
150
151 42
        return (hpk_more);
152 42
}
153
154
static int
155 10980
huff_simulate(const char *str, int ilen, int huff)
156
{
157 10980
        int olen = 0;
158 10980
        if (!huff || !ilen)
159 10938
                return (ilen);
160 474
        while (ilen--) {
161 432
                olen += coding_table[(unsigned char)*str].size;
162 432
                str++;
163
        }
164 42
        return ((olen + 7) / 8);
165 10980
}
166
167
static enum hpk_result
168 5994
num_decode(uint32_t *result, struct hpk_iter *iter, uint8_t prefix)
169
{
170 5994
        uint8_t shift = 0;
171
172 5994
        assert(iter->buf < iter->end);
173 5994
        assert(prefix);
174 5994
        assert(prefix <= 8);
175
176 5994
        *result = 0;
177 5994
        *result = *iter->buf & (0xff >> (8-prefix));
178 5994
        if (*result < (1U << prefix) - 1U) {
179 4617
                iter->buf++;
180 4617
                return (ITER_DONE(iter));
181
        }
182 1377
        do {
183 1389
                iter->buf++;
184 1389
                if (iter->end == iter->buf)
185 0
                        return (hpk_err);
186
                /* check for overflow */
187 1389
                if ((UINT32_MAX - *result) >> shift < (*iter->buf & 0x7f))
188 0
                        return (hpk_err);
189
190 1389
                *result += (uint32_t)(*iter->buf & 0x7f) << shift;
191 1389
                shift += 7;
192 1389
        } while (*iter->buf & 0x80);
193 1377
        iter->buf++;
194
195 1377
        return (ITER_DONE(iter));
196 5994
}
197
198
static enum hpk_result
199 11154
num_encode(struct hpk_iter *iter, uint8_t prefix, uint32_t num)
200
{
201 11154
        assert(prefix);
202 11154
        assert(prefix <= 8);
203 11154
        assert(iter->buf < iter->end);
204
205 11154
        uint8_t pmax = (1U << prefix) - 1U;
206
207 11154
        *iter->buf &= 0xffU << prefix;
208 11154
        if (num <= pmax) {
209 8151
                *iter->buf++ |= num;
210 8151
                return (ITER_DONE(iter));
211 3003
        } else if (iter->end - iter->buf < 2)
212 0
                return (hpk_err);
213
214 3003
        iter->buf[0] |= pmax;
215 3003
        num -= pmax;
216 3003
        do {
217 6003
                iter->buf++;
218 6003
                if (iter->end == iter->buf)
219 0
                        return (hpk_err);
220 6003
                *iter->buf = num % 128;
221 6003
                *iter->buf |= 0x80;
222 6003
                num /= 128;
223 6003
        } while (num);
224 3003
        *iter->buf++ &= 127;
225 3003
        return (ITER_DONE(iter));
226 11154
}
227
228
static enum hpk_result
229 10980
str_encode(struct hpk_iter *iter, const struct hpk_txt *t)
230
{
231 10980
        int slen = huff_simulate(t->ptr, t->len, t->huff);
232 10980
        assert(iter->buf < iter->end);
233 10980
        if (t->huff)
234 42
                *iter->buf = 0x80;
235
        else
236 10938
                *iter->buf = 0;
237
238 10980
        if (hpk_err == num_encode(iter, 7, slen))
239 0
                return (hpk_err);
240
241 10980
        if (slen > iter->end - iter->buf)
242 0
                return (hpk_err);
243
244 10980
        if (t->huff) {
245 42
                return (huff_encode(iter, t->ptr, t->len));
246
        } else {
247 10938
                memcpy(iter->buf, t->ptr, slen);
248 10938
                iter->buf += slen;
249 10938
                return (ITER_DONE(iter));
250
        }
251 10980
}
252
253
static enum hpk_result
254 3288
str_decode(struct hpk_iter *iter, struct hpk_txt *t)
255
{
256
        uint32_t num;
257
        int huff;
258
259 3288
        assert(iter->buf < iter->end);
260
261 3288
        huff = (*iter->buf & 0x80);
262 3288
        if (hpk_more != num_decode(&num, iter, 7))
263 0
                return (hpk_err);
264 3288
        assert(iter->buf < iter->end);
265 3288
        if (num > (unsigned)(iter->end - iter->buf))
266 0
                return (hpk_err);
267 3288
        if (huff) { /*Huffman encoding */
268 33
                t->ptr = malloc((num * 8L) / 5L + 1L);
269 33
                AN(t->ptr);
270 33
                num = huff_decode(t->ptr, (num * 8) / 5, iter, num);
271 33
                if (!num) {
272 0
                        free(t->ptr);
273 0
                        return (hpk_err);
274
                }
275 33
                t->huff = 1;
276
                /* XXX: do we care? */
277 33
                t->ptr = realloc(t->ptr, num + 1L);
278 33
                AN(t->ptr);
279 33
        } else { /* literal string */
280 3255
                t->huff = 0;
281 3255
                t->ptr = malloc(num + 1L);
282 3255
                AN(t->ptr);
283 3255
                memcpy(t->ptr, iter->buf, num);
284 3255
                iter->buf += num;
285
        }
286
287 3288
        t->ptr[num] = '\0';
288 3288
        t->len = num;
289
290 3288
        return (ITER_DONE(iter));
291 3288
}
292
293
static inline void
294 2112
txtcpy(struct hpk_txt *to, const struct hpk_txt *from)
295
{
296
        //AZ(to->ptr);
297 2112
        to->ptr = malloc(from->len + 1L);
298 2112
        AN(to->ptr);
299 2112
        memcpy(to->ptr, from->ptr, from->len + 1L);
300 2112
        to->len = from->len;
301 2112
}
302
303
int
304 3807
gethpk_iterLen(const struct hpk_iter *iter)
305
{
306 3807
        return (iter->buf - iter->orig);
307
}
308
309
enum hpk_result
310 2706
HPK_DecHdr(struct hpk_iter *iter, struct hpk_hdr *header)
311
{
312 2706
        int pref = 0;
313
        const struct hpk_txt *t;
314
        uint32_t num;
315 2706
        int must_index = 0;
316 2706
        assert(iter);
317 2706
        assert(iter->buf < iter->end);
318
        /* Indexed Header Field */
319 2706
        if (*iter->buf & 128) {
320 345
                header->t = hpk_idx;
321 345
                if (hpk_err == num_decode(&num, iter, 7))
322 0
                        return (hpk_err);
323
324 345
                if (num) { /* indexed key and value*/
325 345
                        t = tbl_get_key(iter->ctx, num);
326 345
                        if (!t)
327 6
                                return (hpk_err);
328 339
                        txtcpy(&header->key, t);
329
330 339
                        t = tbl_get_value(iter->ctx, num);
331 339
                        if (!t) {
332 0
                                free(header->key.ptr);
333 0
                                return (hpk_err);
334
                        }
335
336 339
                        txtcpy(&header->value, t);
337
338 339
                        if (iter->buf < iter->end)
339 333
                                return (hpk_more);
340
                        else
341 6
                                return (hpk_done);
342
                } else
343 0
                        return (hpk_err);
344
345
        }
346
        /* Literal Header Field with Incremental Indexing */
347 2361
        else if (*iter->buf >> 6 == 1) {
348 54
                header->t = hpk_inc;
349 54
                pref = 6;
350 54
                must_index = 1;
351 54
        }
352
        /* Literal Header Field without Indexing */
353 2307
        else if (*iter->buf >> 4 == 0) {
354 618
                header->t = hpk_not;
355 618
                pref = 4;
356 618
        }
357
        /* Literal Header Field never Indexed */
358 1689
        else if (*iter->buf >> 4 == 1) {
359 1689
                header->t = hpk_never;
360 1689
                pref = 4;
361 1689
        }
362
        /* Dynamic Table Size Update */
363
        /* XXX if under max allowed value */
364 0
        else if (*iter->buf >> 5 == 1) {
365 0
                if (hpk_done != num_decode(&num, iter, 5))
366 0
                        return (hpk_err);
367 0
                return (HPK_ResizeTbl(iter->ctx, num));
368
        } else {
369 0
                return (hpk_err);
370
        }
371
372 2361
        assert(pref);
373 2361
        if (hpk_more != num_decode(&num, iter, pref))
374 0
                return (hpk_err);
375
376 2361
        header->i = num;
377 2361
        if (num) { /* indexed key */
378 1434
                t = tbl_get_key(iter->ctx, num);
379 1434
                if (!t)
380 0
                        return (hpk_err);
381 1434
                txtcpy(&header->key, t);
382 1434
        } else {
383 927
                if (hpk_more != str_decode(iter, &header->key)) {
384 0
                        free(header->key.ptr);
385 0
                        return (hpk_err);
386
                }
387
        }
388
389 2361
        if (hpk_err == str_decode(iter, &header->value)) {
390 0
                free(header->key.ptr);
391 0
                return (hpk_err);
392
        }
393
394 2361
        if (must_index)
395 54
                push_header(iter->ctx, header);
396 2361
        return (ITER_DONE(iter));
397 2706
}
398
399
enum hpk_result
400 5640
HPK_EncHdr(struct hpk_iter *iter, const struct hpk_hdr *h)
401
{
402
        int pref;
403 5640
        int must_index = 0;
404
        enum hpk_result ret;
405 5640
        switch (h->t) {
406
                case hpk_idx:
407 126
                        *iter->buf = 0x80;
408 126
                        assert(num_encode(iter, 7, h->i) != hpk_err);
409 126
                        return (ITER_DONE(iter));
410
                case hpk_inc:
411 66
                        *iter->buf = 0x40;
412 66
                        pref = 6;
413 66
                        must_index = 1;
414 66
                        break;
415
                case hpk_not:
416 5445
                        *iter->buf = 0x00;
417 5445
                        pref = 4;
418 5445
                        break;
419
                case hpk_never:
420 3
                        *iter->buf = 0x10;
421 3
                        pref = 4;
422 3
                        break;
423
                default:
424 0
                        INCOMPL();
425 0
        }
426 5514
        if (h->i) {
427 48
                if (hpk_more != num_encode(iter, pref, h->i))
428 0
                        return (hpk_err);
429 48
        } else {
430 5466
                iter->buf++;
431 5466
                if (hpk_more != str_encode(iter, &h->key))
432 0
                        return (hpk_err);
433
        }
434 5514
        ret = str_encode(iter, &h->value);
435 5514
        if (ret == hpk_err)
436 0
                return (hpk_err);
437 5514
        if (must_index)
438 66
                push_header(iter->ctx, h);
439 5514
        return (ret);
440
441 5640
}