Home | History | Annotate | Line # | Download | only in isc
      1  1.1  christos /*	$NetBSD: dnsstream_utils_test.c,v 1.2 2025/01/26 16:25:49 christos Exp $	*/
      2  1.1  christos 
      3  1.1  christos /*
      4  1.1  christos  * Copyright (C) Internet Systems Consortium, Inc. ("ISC")
      5  1.1  christos  *
      6  1.1  christos  * SPDX-License-Identifier: MPL-2.0
      7  1.1  christos  *
      8  1.1  christos  * This Source Code Form is subject to the terms of the Mozilla Public
      9  1.1  christos  * License, v. 2.0. If a copy of the MPL was not distributed with this
     10  1.1  christos  * file, you can obtain one at https://mozilla.org/MPL/2.0/.
     11  1.1  christos  *
     12  1.1  christos  * See the COPYRIGHT file distributed with this work for additional
     13  1.1  christos  * information regarding copyright ownership.
     14  1.1  christos  */
     15  1.1  christos 
     16  1.1  christos #include <inttypes.h>
     17  1.1  christos #include <sched.h> /* IWYU pragma: keep */
     18  1.1  christos #include <setjmp.h>
     19  1.1  christos #include <stdarg.h>
     20  1.1  christos #include <stdbool.h>
     21  1.1  christos #include <stddef.h>
     22  1.1  christos #include <stdlib.h>
     23  1.1  christos #include <time.h>
     24  1.1  christos #include <unistd.h>
     25  1.1  christos 
     26  1.1  christos #define UNIT_TESTING
     27  1.1  christos #include <cmocka.h>
     28  1.1  christos 
     29  1.1  christos #include <isc/buffer.h>
     30  1.1  christos #include <isc/dnsstream.h>
     31  1.1  christos #include <isc/mem.h>
     32  1.1  christos #include <isc/os.h>
     33  1.1  christos #include <isc/random.h>
     34  1.1  christos 
     35  1.1  christos #include "dnsstream_utils_test_data.h"
     36  1.1  christos 
     37  1.1  christos #include <tests/isc.h>
     38  1.1  christos 
     39  1.1  christos #define STATIC_BUFFER_SIZE  (512)
     40  1.1  christos #define DYNAMIC_BUFFER_SIZE (STATIC_BUFFER_SIZE + ISC_BUFFER_INCR)
     41  1.1  christos 
     42  1.1  christos static int
     43  1.1  christos setup_test_dnsbuf(void **state) {
     44  1.1  christos 	isc_buffer_t **pdnsbuf = (isc_buffer_t **)state;
     45  1.1  christos 	isc_buffer_allocate(mctx, pdnsbuf, STATIC_BUFFER_SIZE);
     46  1.1  christos 
     47  1.1  christos 	return 0;
     48  1.1  christos }
     49  1.1  christos 
     50  1.1  christos static int
     51  1.1  christos teardown_test_dnsbuf(void **state) {
     52  1.1  christos 	isc_buffer_free((isc_buffer_t **)state);
     53  1.1  christos 
     54  1.1  christos 	return 0;
     55  1.1  christos }
     56  1.1  christos 
     57  1.1  christos static bool
     58  1.1  christos dnsasm_dummy(isc_dnsstream_assembler_t *dnsasm, const isc_result_t result,
     59  1.1  christos 	     isc_region_t *restrict region, void *cbarg, void *userarg) {
     60  1.1  christos 	UNUSED(dnsasm);
     61  1.1  christos 	UNUSED(result);
     62  1.1  christos 	UNUSED(region);
     63  1.1  christos 	UNUSED(cbarg);
     64  1.1  christos 	UNUSED(userarg);
     65  1.1  christos 	return true;
     66  1.1  christos }
     67  1.1  christos 
     68  1.1  christos static int
     69  1.1  christos setup_test_dnsasm(void **state) {
     70  1.1  christos 	isc_dnsstream_assembler_t **pdnsasm =
     71  1.1  christos 		(isc_dnsstream_assembler_t **)state;
     72  1.1  christos 	*pdnsasm = isc_dnsstream_assembler_new(mctx, dnsasm_dummy, NULL);
     73  1.1  christos 
     74  1.1  christos 	return 0;
     75  1.1  christos }
     76  1.1  christos 
     77  1.1  christos static int
     78  1.1  christos teardown_test_dnsasm(void **state) {
     79  1.1  christos 	isc_dnsstream_assembler_free((isc_dnsstream_assembler_t **)state);
     80  1.1  christos 
     81  1.1  christos 	return 0;
     82  1.1  christos }
     83  1.1  christos 
     84  1.1  christos ISC_RUN_TEST_IMPL(dnsbuffer_generic_test) {
     85  1.1  christos 	uint8_t buf[STATIC_BUFFER_SIZE / 2] = { 0 };
     86  1.1  christos 	isc_buffer_t *dnsbuf = (isc_buffer_t *)*state;
     87  1.1  christos 	isc_region_t reg = { 0 };
     88  1.1  christos 	size_t n = 0;
     89  1.1  christos 
     90  1.1  christos 	for (size_t i = 0; i < sizeof(buf); i++) {
     91  1.1  christos 		buf[i] = (uint8_t)i;
     92  1.1  christos 	}
     93  1.1  christos 
     94  1.1  christos 	/* sanity checks */
     95  1.1  christos 	assert_true(isc_buffer_length(dnsbuf) == STATIC_BUFFER_SIZE);
     96  1.1  christos 	assert_true(isc_buffer_usedlength(dnsbuf) == 0);
     97  1.1  christos 	assert_true(isc_buffer_remaininglength(dnsbuf) == 0);
     98  1.1  christos 
     99  1.1  christos 	isc_buffer_putmem(dnsbuf, buf, sizeof(buf));
    100  1.1  christos 
    101  1.1  christos 	assert_true(isc_buffer_usedlength(dnsbuf) == sizeof(buf));
    102  1.1  christos 	assert_true(isc_buffer_remaininglength(dnsbuf) == sizeof(buf));
    103  1.1  christos 
    104  1.1  christos 	assert_true(isc_buffer_current(dnsbuf) == dnsbuf->base);
    105  1.1  christos 
    106  1.1  christos 	isc_buffer_clear(dnsbuf);
    107  1.1  christos 
    108  1.1  christos 	assert_true(isc_buffer_length(dnsbuf) == STATIC_BUFFER_SIZE);
    109  1.1  christos 	assert_true(isc_buffer_usedlength(dnsbuf) == 0);
    110  1.1  christos 	assert_true(isc_buffer_remaininglength(dnsbuf) == 0);
    111  1.1  christos 
    112  1.1  christos 	isc_buffer_putmem(dnsbuf, buf, sizeof(buf));
    113  1.1  christos 
    114  1.1  christos 	assert_true(isc_buffer_usedlength(dnsbuf) == sizeof(buf));
    115  1.1  christos 	assert_true(isc_buffer_remaininglength(dnsbuf) == sizeof(buf));
    116  1.1  christos 
    117  1.1  christos 	assert_true(isc_buffer_current(dnsbuf) == dnsbuf->base);
    118  1.1  christos 
    119  1.1  christos 	for (size_t i = 0; i < sizeof(buf); i++, isc_buffer_forward(dnsbuf, 1))
    120  1.1  christos 	{
    121  1.1  christos 		uint8_t *p = isc_buffer_current(dnsbuf);
    122  1.1  christos 
    123  1.1  christos 		assert_true(*p == i);
    124  1.1  christos 	}
    125  1.1  christos 
    126  1.1  christos 	assert_true(isc_buffer_remaininglength(dnsbuf) == 0);
    127  1.1  christos 	assert_true(isc_buffer_usedlength(dnsbuf) == sizeof(buf));
    128  1.1  christos 
    129  1.1  christos 	isc_buffer_putmem(dnsbuf, buf, sizeof(buf));
    130  1.1  christos 
    131  1.1  christos 	assert_true(isc_buffer_remaininglength(dnsbuf) == sizeof(buf));
    132  1.1  christos 	assert_true(isc_buffer_usedlength(dnsbuf) == sizeof(buf) * 2);
    133  1.1  christos 
    134  1.1  christos 	assert_true(isc_buffer_length(dnsbuf) == STATIC_BUFFER_SIZE);
    135  1.1  christos 
    136  1.1  christos 	for (size_t i = 0; i < sizeof(buf); i++, isc_buffer_forward(dnsbuf, 1))
    137  1.1  christos 	{
    138  1.1  christos 		uint8_t *p = isc_buffer_current(dnsbuf);
    139  1.1  christos 
    140  1.1  christos 		assert_true(*p == i);
    141  1.1  christos 	}
    142  1.1  christos 
    143  1.1  christos 	isc_buffer_putmem(dnsbuf, buf, sizeof(buf));
    144  1.1  christos 
    145  1.1  christos 	assert_true(isc_buffer_length(dnsbuf) == DYNAMIC_BUFFER_SIZE);
    146  1.1  christos 
    147  1.1  christos 	for (size_t i = 0; i < sizeof(buf); i++, isc_buffer_forward(dnsbuf, 1))
    148  1.1  christos 	{
    149  1.1  christos 		uint8_t *p = isc_buffer_current(dnsbuf);
    150  1.1  christos 
    151  1.1  christos 		assert_true(*p == i);
    152  1.1  christos 	}
    153  1.1  christos 
    154  1.1  christos 	assert_true(isc_buffer_remaininglength(dnsbuf) == 0);
    155  1.1  christos 	isc_buffer_trycompact(dnsbuf);
    156  1.1  christos 
    157  1.1  christos 	assert_true(isc_buffer_length(dnsbuf) == DYNAMIC_BUFFER_SIZE);
    158  1.1  christos 
    159  1.1  christos 	isc_buffer_putmem(dnsbuf, buf, sizeof(buf));
    160  1.1  christos 
    161  1.1  christos 	isc_buffer_remainingregion(dnsbuf, &reg);
    162  1.1  christos 	assert_true(isc_buffer_remaininglength(dnsbuf) == reg.length);
    163  1.1  christos 	assert_true(reg.length == sizeof(buf));
    164  1.1  christos 
    165  1.1  christos 	for (size_t i = 0; i < reg.length; i++) {
    166  1.1  christos 		uint8_t d = (uint8_t)reg.base[i];
    167  1.1  christos 
    168  1.1  christos 		assert_true(d == i);
    169  1.1  christos 	}
    170  1.1  christos 
    171  1.1  christos 	isc_buffer_forward(dnsbuf, reg.length);
    172  1.1  christos 	assert_true(isc_buffer_remaininglength(dnsbuf) == 0);
    173  1.1  christos 
    174  1.1  christos 	isc_buffer_putmem(dnsbuf, buf, sizeof(buf));
    175  1.1  christos 	assert_true(isc_buffer_remaininglength(dnsbuf) == sizeof(buf));
    176  1.1  christos 
    177  1.1  christos 	isc_buffer_clear(dnsbuf);
    178  1.1  christos 
    179  1.1  christos 	assert_true(isc_buffer_length(dnsbuf) == DYNAMIC_BUFFER_SIZE);
    180  1.1  christos 
    181  1.1  christos 	assert_true(isc_buffer_remaininglength(dnsbuf) == 0);
    182  1.1  christos 
    183  1.1  christos 	n = DYNAMIC_BUFFER_SIZE / sizeof(buf) + 1;
    184  1.1  christos 	for (size_t i = 0; i < n; i++) {
    185  1.1  christos 		isc_buffer_putmem(dnsbuf, buf, sizeof(buf));
    186  1.1  christos 	}
    187  1.1  christos 
    188  1.1  christos 	assert_true(isc_buffer_length(dnsbuf) > DYNAMIC_BUFFER_SIZE);
    189  1.1  christos 	assert_true(isc_buffer_length(dnsbuf) >= n * sizeof(buf));
    190  1.1  christos 
    191  1.1  christos 	assert_true(isc_buffer_remaininglength(dnsbuf) == n * sizeof(buf));
    192  1.1  christos 
    193  1.1  christos 	for (size_t i = 0; i < n; i++) {
    194  1.1  christos 		for (size_t k = 0; k < sizeof(buf);
    195  1.1  christos 		     k++, isc_buffer_forward(dnsbuf, 1))
    196  1.1  christos 		{
    197  1.1  christos 			uint8_t *p = isc_buffer_current(dnsbuf);
    198  1.1  christos 
    199  1.1  christos 			assert_true(*p == k);
    200  1.1  christos 		}
    201  1.1  christos 	}
    202  1.1  christos }
    203  1.1  christos 
    204  1.1  christos ISC_RUN_TEST_IMPL(dnsbuffer_resize_alloc_test) {
    205  1.1  christos 	uint8_t buf[STATIC_BUFFER_SIZE / 2] = { 0 };
    206  1.1  christos 	isc_buffer_t *dnsbuf = (isc_buffer_t *)*state;
    207  1.1  christos 	size_t i = 0, n = 0;
    208  1.1  christos 
    209  1.1  christos 	for (i = 0; i < sizeof(buf); i++) {
    210  1.1  christos 		buf[i] = (uint8_t)i;
    211  1.1  christos 	}
    212  1.1  christos 
    213  1.1  christos 	isc_buffer_putmem(dnsbuf, buf, sizeof(buf));
    214  1.1  christos 
    215  1.1  christos 	for (i = 0; i < (sizeof(buf) / 3) * 2;
    216  1.1  christos 	     i++, isc_buffer_forward(dnsbuf, 1))
    217  1.1  christos 	{
    218  1.1  christos 		uint8_t *p = isc_buffer_current(dnsbuf);
    219  1.1  christos 
    220  1.1  christos 		assert_true(*p == i);
    221  1.1  christos 	}
    222  1.1  christos 
    223  1.1  christos 	assert_true(isc_buffer_length(dnsbuf) == STATIC_BUFFER_SIZE);
    224  1.1  christos 
    225  1.1  christos 	n = DYNAMIC_BUFFER_SIZE / sizeof(buf) + 1;
    226  1.1  christos 	for (size_t k = 0; k < n; k++) {
    227  1.1  christos 		isc_buffer_putmem(dnsbuf, buf, sizeof(buf));
    228  1.1  christos 	}
    229  1.1  christos 
    230  1.1  christos 	assert_true(isc_buffer_length(dnsbuf) >= STATIC_BUFFER_SIZE);
    231  1.1  christos 
    232  1.1  christos 	for (; i < sizeof(buf); i++, isc_buffer_forward(dnsbuf, 1)) {
    233  1.1  christos 		uint8_t *p = isc_buffer_current(dnsbuf);
    234  1.1  christos 
    235  1.1  christos 		assert_true(*p == i);
    236  1.1  christos 	}
    237  1.1  christos }
    238  1.1  christos 
    239  1.1  christos ISC_RUN_TEST_IMPL(dnsbuffer_be_test) {
    240  1.1  christos 	isc_buffer_t *dnsbuf = (isc_buffer_t *)*state;
    241  1.1  christos 	const uint16_t u16 = 0xBEEF;
    242  1.1  christos 	uint16_t *pu16;
    243  1.1  christos 	uint16_t u16v;
    244  1.1  christos 
    245  1.1  christos 	assert_true(isc_buffer_remaininglength(dnsbuf) == 0);
    246  1.1  christos 
    247  1.1  christos 	isc_buffer_putuint16(dnsbuf, u16);
    248  1.1  christos 
    249  1.1  christos 	assert_true(isc_buffer_remaininglength(dnsbuf) == sizeof(u16));
    250  1.1  christos 
    251  1.1  christos 	pu16 = (uint16_t *)isc_buffer_current(dnsbuf);
    252  1.1  christos 	assert_true(*pu16 == htons(u16));
    253  1.1  christos 
    254  1.1  christos 	assert_int_equal(isc_buffer_peekuint16(dnsbuf, &u16v), ISC_R_SUCCESS);
    255  1.1  christos 	assert_int_equal(u16v, u16);
    256  1.1  christos 	assert_true(isc_buffer_remaininglength(dnsbuf) == sizeof(u16));
    257  1.1  christos 
    258  1.1  christos 	assert_true(isc_buffer_getuint16(dnsbuf) == u16);
    259  1.1  christos 	assert_true(isc_buffer_remaininglength(dnsbuf) == 0);
    260  1.1  christos }
    261  1.1  christos 
    262  1.1  christos typedef struct verify_cbdata {
    263  1.1  christos 	uint8_t *verify_message;
    264  1.1  christos 	bool cont_on_success;
    265  1.1  christos 	bool clear_on_success;
    266  1.1  christos } verify_cbdata_t;
    267  1.1  christos 
    268  1.1  christos static bool
    269  1.1  christos verify_dnsmsg(isc_dnsstream_assembler_t *dnsasm, const isc_result_t result,
    270  1.1  christos 	      isc_region_t *restrict region, void *cbarg, void *userarg) {
    271  1.1  christos 	size_t *processed = (size_t *)userarg;
    272  1.1  christos 	verify_cbdata_t *vdata = (verify_cbdata_t *)cbarg;
    273  1.1  christos 	uint8_t *message = (uint8_t *)vdata->verify_message;
    274  1.1  christos 
    275  1.1  christos 	UNUSED(dnsasm);
    276  1.1  christos 
    277  1.1  christos 	assert_true(result == isc_dnsstream_assembler_result(dnsasm));
    278  1.1  christos 
    279  1.1  christos 	if (vdata->verify_message != NULL) {
    280  1.1  christos 		message += sizeof(uint16_t);
    281  1.1  christos 	}
    282  1.1  christos 
    283  1.1  christos 	if (result != ISC_R_SUCCESS) {
    284  1.1  christos 		return true;
    285  1.1  christos 	}
    286  1.1  christos 
    287  1.1  christos 	if (vdata->verify_message != NULL &&
    288  1.1  christos 	    memcmp(message, region->base, region->length) == 0)
    289  1.1  christos 	{
    290  1.1  christos 		*processed += 1;
    291  1.1  christos 	} else {
    292  1.1  christos 		*processed += 1;
    293  1.1  christos 	}
    294  1.1  christos 
    295  1.1  christos 	if (vdata->clear_on_success) {
    296  1.1  christos 		isc_dnsstream_assembler_clear(
    297  1.1  christos 			(isc_dnsstream_assembler_t *)dnsasm);
    298  1.1  christos 	}
    299  1.1  christos 
    300  1.1  christos 	return vdata->cont_on_success;
    301  1.1  christos }
    302  1.1  christos 
    303  1.1  christos typedef struct verify_regions_cbdata {
    304  1.1  christos 	isc_region_t *packets;
    305  1.1  christos 	bool cont_on_success;
    306  1.1  christos } verify_regions_cbdata_t;
    307  1.1  christos 
    308  1.1  christos static bool
    309  1.1  christos verify_dnsmsg_regions(isc_dnsstream_assembler_t *dnsasm,
    310  1.1  christos 		      const isc_result_t result, isc_region_t *restrict region,
    311  1.1  christos 		      void *cbarg, void *userarg) {
    312  1.1  christos 	size_t *processed = (size_t *)userarg;
    313  1.1  christos 	verify_regions_cbdata_t *vdata = (verify_regions_cbdata_t *)cbarg;
    314  1.1  christos 	uint8_t *message = (uint8_t *)vdata->packets[0].base;
    315  1.1  christos 
    316  1.1  christos 	UNUSED(dnsasm);
    317  1.1  christos 
    318  1.1  christos 	assert_true(result == isc_dnsstream_assembler_result(dnsasm));
    319  1.1  christos 
    320  1.1  christos 	if (vdata->packets != NULL) {
    321  1.1  christos 		message += sizeof(uint16_t);
    322  1.1  christos 	}
    323  1.1  christos 
    324  1.1  christos 	if (result != ISC_R_SUCCESS) {
    325  1.1  christos 		return true;
    326  1.1  christos 	}
    327  1.1  christos 
    328  1.1  christos 	if (vdata->packets != NULL &&
    329  1.1  christos 	    memcmp(message, region->base, region->length) == 0)
    330  1.1  christos 	{
    331  1.1  christos 		*processed += 1;
    332  1.1  christos 	} else {
    333  1.1  christos 		*processed += 1;
    334  1.1  christos 	}
    335  1.1  christos 
    336  1.1  christos 	vdata->packets++;
    337  1.1  christos 
    338  1.1  christos 	return vdata->cont_on_success;
    339  1.1  christos }
    340  1.1  christos 
    341  1.1  christos ISC_RUN_TEST_IMPL(dnsasm_sequence_test) {
    342  1.1  christos 	isc_dnsstream_assembler_t *dnsasm = (isc_dnsstream_assembler_t *)*state;
    343  1.1  christos 	verify_cbdata_t cbdata = { 0 };
    344  1.1  christos 	size_t verified = 0;
    345  1.1  christos 
    346  1.1  christos 	cbdata.cont_on_success = true;
    347  1.1  christos 
    348  1.1  christos 	cbdata.verify_message = (uint8_t *)request;
    349  1.1  christos 	isc_dnsstream_assembler_setcb(dnsasm, verify_dnsmsg, (void *)&cbdata);
    350  1.1  christos 	isc_dnsstream_assembler_incoming(dnsasm, &verified, (void *)request,
    351  1.1  christos 					 sizeof(request));
    352  1.1  christos 	assert_true(verified == 1);
    353  1.1  christos 	assert_true(isc_dnsstream_assembler_result(dnsasm) == ISC_R_SUCCESS);
    354  1.1  christos 
    355  1.1  christos 	cbdata.verify_message = (uint8_t *)response;
    356  1.1  christos 	isc_dnsstream_assembler_setcb(dnsasm, verify_dnsmsg, (void *)&cbdata);
    357  1.1  christos 	isc_dnsstream_assembler_incoming(dnsasm, &verified, (void *)response,
    358  1.1  christos 					 sizeof(response));
    359  1.1  christos 	assert_true(verified == 2);
    360  1.1  christos 	assert_true(isc_dnsstream_assembler_result(dnsasm) == ISC_R_SUCCESS);
    361  1.1  christos 
    362  1.1  christos 	cbdata.verify_message = (uint8_t *)request_large;
    363  1.1  christos 	isc_dnsstream_assembler_setcb(dnsasm, verify_dnsmsg, (void *)&cbdata);
    364  1.1  christos 	isc_dnsstream_assembler_incoming(dnsasm, &verified,
    365  1.1  christos 					 (void *)request_large,
    366  1.1  christos 					 sizeof(request_large));
    367  1.1  christos 	assert_true(verified == 3);
    368  1.1  christos 	assert_true(isc_dnsstream_assembler_result(dnsasm) == ISC_R_SUCCESS);
    369  1.1  christos 
    370  1.1  christos 	cbdata.verify_message = (uint8_t *)response_large;
    371  1.1  christos 	isc_dnsstream_assembler_setcb(dnsasm, verify_dnsmsg, (void *)&cbdata);
    372  1.1  christos 	isc_dnsstream_assembler_incoming(dnsasm, &verified,
    373  1.1  christos 					 (void *)response_large,
    374  1.1  christos 					 sizeof(response_large));
    375  1.1  christos 	assert_true(verified == 4);
    376  1.1  christos 	assert_true(isc_dnsstream_assembler_result(dnsasm) == ISC_R_SUCCESS);
    377  1.1  christos }
    378  1.1  christos 
    379  1.1  christos ISC_RUN_TEST_IMPL(dnsasm_multiple_messages_test) {
    380  1.1  christos 	isc_dnsstream_assembler_t *dnsasm = (isc_dnsstream_assembler_t *)*state;
    381  1.1  christos 	isc_buffer_t dnsbuf;
    382  1.1  christos 	verify_cbdata_t cbdata = { 0 };
    383  1.1  christos 	size_t verified = 0;
    384  1.1  christos 
    385  1.1  christos 	isc_buffer_init(&dnsbuf, NULL, 0);
    386  1.1  christos 	isc_buffer_setmctx(&dnsbuf, mctx);
    387  1.1  christos 	isc_buffer_putmem(&dnsbuf, (void *)request, sizeof(request));
    388  1.1  christos 	isc_buffer_putmem(&dnsbuf, (void *)response, sizeof(response));
    389  1.1  christos 	isc_buffer_putmem(&dnsbuf, (void *)request_large,
    390  1.1  christos 			  sizeof(request_large));
    391  1.1  christos 	isc_buffer_putmem(&dnsbuf, (void *)response_large,
    392  1.1  christos 			  sizeof(response_large));
    393  1.1  christos 
    394  1.1  christos 	cbdata.cont_on_success = false;
    395  1.1  christos 
    396  1.1  christos 	/*
    397  1.1  christos 	 * feed the data to the message assembler and handle the first message
    398  1.1  christos 	 */
    399  1.1  christos 	cbdata.verify_message = (uint8_t *)request;
    400  1.1  christos 	isc_dnsstream_assembler_setcb(dnsasm, verify_dnsmsg, (void *)&cbdata);
    401  1.1  christos 	isc_dnsstream_assembler_incoming(dnsasm, &verified,
    402  1.1  christos 					 isc_buffer_current(&dnsbuf),
    403  1.1  christos 					 isc_buffer_remaininglength(&dnsbuf));
    404  1.1  christos 
    405  1.1  christos 	isc_buffer_clearmctx(&dnsbuf);
    406  1.1  christos 	isc_buffer_invalidate(&dnsbuf);
    407  1.1  christos 	assert_true(verified == 1);
    408  1.1  christos 	assert_true(isc_dnsstream_assembler_result(dnsasm) == ISC_R_SUCCESS);
    409  1.1  christos 
    410  1.1  christos 	/*
    411  1.1  christos 	 * handle the next message (and so on)
    412  1.1  christos 	 */
    413  1.1  christos 	cbdata.verify_message = (uint8_t *)response;
    414  1.1  christos 	isc_dnsstream_assembler_incoming(dnsasm, &verified, NULL, 0);
    415  1.1  christos 	assert_true(verified == 2);
    416  1.1  christos 	assert_true(isc_dnsstream_assembler_result(dnsasm) == ISC_R_SUCCESS);
    417  1.1  christos 
    418  1.1  christos 	cbdata.verify_message = (uint8_t *)request_large;
    419  1.1  christos 	isc_dnsstream_assembler_incoming(dnsasm, &verified, NULL, 0);
    420  1.1  christos 	assert_true(verified == 3);
    421  1.1  christos 	assert_true(isc_dnsstream_assembler_result(dnsasm) == ISC_R_SUCCESS);
    422  1.1  christos 
    423  1.1  christos 	cbdata.verify_message = (uint8_t *)response_large;
    424  1.1  christos 	isc_dnsstream_assembler_incoming(dnsasm, &verified, NULL, 0);
    425  1.1  christos 	assert_true(verified == 4);
    426  1.1  christos 	assert_true(isc_dnsstream_assembler_result(dnsasm) == ISC_R_SUCCESS);
    427  1.1  christos 
    428  1.1  christos 	/*
    429  1.1  christos 	 * no unprocessed data left
    430  1.1  christos 	 */
    431  1.1  christos 	isc_dnsstream_assembler_incoming(dnsasm, &verified, NULL, 0);
    432  1.1  christos 	assert_true(verified == 4);
    433  1.1  christos 	assert_true(isc_dnsstream_assembler_result(dnsasm) == ISC_R_NOMORE);
    434  1.1  christos }
    435  1.1  christos 
    436  1.1  christos ISC_RUN_TEST_IMPL(dnsasm_torn_apart_test) {
    437  1.1  christos 	isc_dnsstream_assembler_t *dnsasm = (isc_dnsstream_assembler_t *)*state;
    438  1.1  christos 	verify_cbdata_t cbdata = { 0 };
    439  1.1  christos 	size_t verified = 0;
    440  1.1  christos 	size_t left = 0;
    441  1.1  christos 
    442  1.1  christos 	cbdata.verify_message = (uint8_t *)response_large;
    443  1.1  christos 	isc_dnsstream_assembler_setcb(dnsasm, verify_dnsmsg, (void *)&cbdata);
    444  1.1  christos 	isc_dnsstream_assembler_incoming(dnsasm, &verified, response_large,
    445  1.1  christos 					 sizeof(response_large) / 3 * 2);
    446  1.1  christos 
    447  1.1  christos 	assert_true(verified == 0);
    448  1.1  christos 	assert_true(isc_dnsstream_assembler_result(dnsasm) == ISC_R_NOMORE);
    449  1.1  christos 
    450  1.1  christos 	left = sizeof(response_large) -
    451  1.1  christos 	       isc_dnsstream_assembler_remaininglength(dnsasm);
    452  1.1  christos 	isc_dnsstream_assembler_incoming(
    453  1.1  christos 		dnsasm, &verified,
    454  1.1  christos 		&response_large[isc_dnsstream_assembler_remaininglength(dnsasm)],
    455  1.1  christos 		left);
    456  1.1  christos 	assert_true(verified == 1);
    457  1.1  christos 	assert_true(isc_dnsstream_assembler_result(dnsasm) == ISC_R_SUCCESS);
    458  1.1  christos }
    459  1.1  christos 
    460  1.1  christos ISC_RUN_TEST_IMPL(dnsasm_error_data_test) {
    461  1.1  christos 	isc_dnsstream_assembler_t *dnsasm = (isc_dnsstream_assembler_t *)*state;
    462  1.1  christos 	verify_cbdata_t cbdata = { 0 };
    463  1.1  christos 	size_t verified = 0;
    464  1.1  christos 	isc_buffer_t dnsbuf;
    465  1.1  christos 	uint16_t bad_data = 0;
    466  1.1  christos 
    467  1.1  christos 	isc_buffer_init(&dnsbuf, NULL, 0);
    468  1.1  christos 	isc_buffer_setmctx(&dnsbuf, mctx);
    469  1.1  christos 
    470  1.1  christos 	isc_buffer_putmem(&dnsbuf, (void *)request, sizeof(request));
    471  1.1  christos 	isc_buffer_putmem(&dnsbuf, (void *)&bad_data, sizeof(bad_data));
    472  1.1  christos 	isc_buffer_putmem(&dnsbuf, (void *)&bad_data, sizeof(bad_data));
    473  1.1  christos 	isc_buffer_putmem(&dnsbuf, (void *)response_large,
    474  1.1  christos 			  sizeof(response_large));
    475  1.1  christos 
    476  1.1  christos 	cbdata.cont_on_success = false;
    477  1.1  christos 
    478  1.1  christos 	cbdata.verify_message = (uint8_t *)request;
    479  1.1  christos 	isc_dnsstream_assembler_setcb(dnsasm, verify_dnsmsg, (void *)&cbdata);
    480  1.1  christos 	isc_dnsstream_assembler_incoming(dnsasm, &verified,
    481  1.1  christos 					 isc_buffer_current(&dnsbuf),
    482  1.1  christos 					 isc_buffer_remaininglength(&dnsbuf));
    483  1.1  christos 
    484  1.1  christos 	isc_buffer_clearmctx(&dnsbuf);
    485  1.1  christos 	isc_buffer_invalidate(&dnsbuf);
    486  1.1  christos 
    487  1.1  christos 	assert_true(verified == 1);
    488  1.1  christos 	assert_true(isc_dnsstream_assembler_result(dnsasm) == ISC_R_SUCCESS);
    489  1.1  christos 
    490  1.1  christos 	assert_true(isc_dnsstream_assembler_remaininglength(dnsasm) > 0);
    491  1.1  christos 	isc_dnsstream_assembler_incoming(dnsasm, &verified, NULL, 0);
    492  1.1  christos 
    493  1.1  christos 	assert_true(verified == 1);
    494  1.1  christos 	assert_true(isc_dnsstream_assembler_result(dnsasm) == ISC_R_RANGE);
    495  1.1  christos 	assert_true(isc_dnsstream_assembler_remaininglength(dnsasm) == 0);
    496  1.1  christos 
    497  1.1  christos 	isc_dnsstream_assembler_incoming(dnsasm, &verified, NULL, 0);
    498  1.1  christos 	assert_true(verified == 1);
    499  1.1  christos 	assert_true(isc_dnsstream_assembler_result(dnsasm) == ISC_R_NOMORE);
    500  1.1  christos }
    501  1.1  christos 
    502  1.1  christos ISC_RUN_TEST_IMPL(dnsasm_torn_randomly_test) {
    503  1.1  christos 	isc_dnsstream_assembler_t *dnsasm = (isc_dnsstream_assembler_t *)*state;
    504  1.1  christos 	verify_cbdata_t cbdata = { 0 };
    505  1.1  christos 	verify_regions_cbdata_t cbdata_regions = { 0 };
    506  1.1  christos 	isc_buffer_t dnsbuf;
    507  1.1  christos 	size_t packetno;
    508  1.1  christos 	isc_region_t packets[] = {
    509  1.1  christos 		{ (void *)request, sizeof(request) },
    510  1.1  christos 		{ (void *)response, sizeof(response) },
    511  1.1  christos 		{ (void *)request_large, sizeof(request_large) },
    512  1.1  christos 		{ (void *)response_large, sizeof(response_large) },
    513  1.1  christos 		{ (void *)request, sizeof(request) },
    514  1.1  christos 		{ (void *)response_large, sizeof(response_large) },
    515  1.1  christos 		{ (void *)request_large, sizeof(request_large) },
    516  1.1  christos 		{ (void *)response_large, sizeof(response_large) },
    517  1.1  christos 		{ (void *)request, sizeof(request) },
    518  1.1  christos 	};
    519  1.1  christos 	const size_t npackets = sizeof(packets) / sizeof(packets[0]);
    520  1.1  christos 
    521  1.1  christos 	isc_buffer_init(&dnsbuf, NULL, 0);
    522  1.1  christos 	isc_buffer_setmctx(&dnsbuf, mctx);
    523  1.1  christos 
    524  1.1  christos 	for (size_t i = 0; i < npackets; i++) {
    525  1.1  christos 		isc_buffer_putmem(&dnsbuf, packets[i].base, packets[i].length);
    526  1.1  christos 	}
    527  1.1  christos 
    528  1.1  christos 	/* process packet by packet */
    529  1.1  christos 	packetno = 0;
    530  1.1  christos 	cbdata.cont_on_success = false;
    531  1.1  christos 	isc_dnsstream_assembler_setcb(dnsasm, verify_dnsmsg, (void *)&cbdata);
    532  1.1  christos 
    533  1.1  christos 	/* process random amount of data */
    534  1.1  christos 	for (; isc_buffer_remaininglength(&dnsbuf) > 0;) {
    535  1.1  christos 		size_t sz = 1 + isc_random_uniform(
    536  1.1  christos 					isc_buffer_remaininglength(&dnsbuf));
    537  1.1  christos 
    538  1.1  christos 		for (bool start = true; packetno < npackets; start = false) {
    539  1.1  christos 			cbdata.verify_message =
    540  1.1  christos 				(uint8_t *)packets[packetno].base;
    541  1.1  christos 
    542  1.1  christos 			if (start) {
    543  1.1  christos 				isc_dnsstream_assembler_incoming(
    544  1.1  christos 					dnsasm, &packetno,
    545  1.1  christos 					isc_buffer_current(&dnsbuf), sz);
    546  1.1  christos 			} else {
    547  1.1  christos 				isc_dnsstream_assembler_incoming(
    548  1.1  christos 					dnsasm, &packetno, NULL, 0);
    549  1.1  christos 			}
    550  1.1  christos 
    551  1.1  christos 			if (isc_dnsstream_assembler_result(dnsasm) ==
    552  1.1  christos 			    ISC_R_NOMORE)
    553  1.1  christos 			{
    554  1.1  christos 				break;
    555  1.1  christos 			}
    556  1.1  christos 		}
    557  1.1  christos 
    558  1.1  christos 		isc_buffer_forward(&dnsbuf, sz);
    559  1.1  christos 	}
    560  1.1  christos 
    561  1.1  christos 	assert_true(packetno == npackets);
    562  1.1  christos 	assert_true(isc_dnsstream_assembler_remaininglength(dnsasm) == 0);
    563  1.1  christos 	assert_true(isc_buffer_remaininglength(&dnsbuf) == 0);
    564  1.1  christos 
    565  1.1  christos 	for (size_t i = 0; i < npackets; i++) {
    566  1.1  christos 		isc_buffer_putmem(&dnsbuf, packets[i].base, packets[i].length);
    567  1.1  christos 	}
    568  1.1  christos 
    569  1.1  christos 	/* try to process multiple packets at once, when possible */
    570  1.1  christos 	packetno = 0;
    571  1.1  christos 	cbdata_regions.cont_on_success = true;
    572  1.1  christos 	cbdata_regions.packets = packets;
    573  1.1  christos 
    574  1.1  christos 	isc_dnsstream_assembler_setcb(dnsasm, verify_dnsmsg_regions,
    575  1.1  christos 				      (void *)&cbdata_regions);
    576  1.1  christos 
    577  1.1  christos 	/* process random amount of data */
    578  1.1  christos 	for (; isc_buffer_remaininglength(&dnsbuf) > 0;) {
    579  1.1  christos 		size_t sz = 1 + isc_random_uniform(
    580  1.1  christos 					isc_buffer_remaininglength(&dnsbuf));
    581  1.1  christos 
    582  1.1  christos 		isc_dnsstream_assembler_incoming(
    583  1.1  christos 			dnsasm, &packetno, isc_buffer_current(&dnsbuf), sz);
    584  1.1  christos 
    585  1.1  christos 		isc_buffer_forward(&dnsbuf, sz);
    586  1.1  christos 	}
    587  1.1  christos 
    588  1.1  christos 	assert_true(packetno == npackets);
    589  1.1  christos 	assert_true(isc_dnsstream_assembler_remaininglength(dnsasm) == 0);
    590  1.1  christos 	assert_true(isc_buffer_remaininglength(&dnsbuf) == 0);
    591  1.1  christos 
    592  1.1  christos 	isc_buffer_clearmctx(&dnsbuf);
    593  1.1  christos 	isc_buffer_invalidate(&dnsbuf);
    594  1.1  christos 	dnsasm->cbarg = NULL; /* to make GCC happy about dangling pointers */
    595  1.1  christos }
    596  1.1  christos 
    597  1.1  christos ISC_RUN_TEST_IMPL(dnsasm_clear_buffer_within_cb_test) {
    598  1.1  christos 	isc_dnsstream_assembler_t *dnsasm = (isc_dnsstream_assembler_t *)*state;
    599  1.1  christos 	verify_cbdata_t cbdata = { 0 };
    600  1.1  christos 	size_t verified = 0;
    601  1.1  christos 	isc_buffer_t dnsbuf;
    602  1.1  christos 
    603  1.1  christos 	isc_buffer_init(&dnsbuf, NULL, 0);
    604  1.1  christos 	isc_buffer_setmctx(&dnsbuf, mctx);
    605  1.1  christos 
    606  1.1  christos 	isc_buffer_putmem(&dnsbuf, (void *)request, sizeof(request));
    607  1.1  christos 	isc_buffer_putmem(&dnsbuf, (void *)&response, sizeof(response));
    608  1.1  christos 	isc_buffer_putmem(&dnsbuf, (void *)request, sizeof(request));
    609  1.1  christos 	cbdata.cont_on_success = true;
    610  1.1  christos 	cbdata.clear_on_success = true;
    611  1.1  christos 
    612  1.1  christos 	cbdata.verify_message = (uint8_t *)request;
    613  1.1  christos 	isc_dnsstream_assembler_setcb(dnsasm, verify_dnsmsg, (void *)&cbdata);
    614  1.1  christos 	isc_dnsstream_assembler_incoming(dnsasm, &verified,
    615  1.1  christos 					 isc_buffer_current(&dnsbuf),
    616  1.1  christos 					 isc_buffer_remaininglength(&dnsbuf));
    617  1.1  christos 
    618  1.1  christos 	isc_buffer_clearmctx(&dnsbuf);
    619  1.1  christos 	isc_buffer_invalidate(&dnsbuf);
    620  1.1  christos 
    621  1.1  christos 	assert_true(verified == 1);
    622  1.1  christos 	assert_true(isc_dnsstream_assembler_result(dnsasm) == ISC_R_UNSET);
    623  1.1  christos 
    624  1.1  christos 	assert_true(isc_dnsstream_assembler_remaininglength(dnsasm) == 0);
    625  1.1  christos }
    626  1.1  christos 
    627  1.1  christos ISC_TEST_LIST_START
    628  1.1  christos ISC_TEST_ENTRY_CUSTOM(dnsbuffer_generic_test, setup_test_dnsbuf,
    629  1.1  christos 		      teardown_test_dnsbuf)
    630  1.1  christos ISC_TEST_ENTRY_CUSTOM(dnsbuffer_resize_alloc_test, setup_test_dnsbuf,
    631  1.1  christos 		      teardown_test_dnsbuf)
    632  1.1  christos ISC_TEST_ENTRY_CUSTOM(dnsbuffer_be_test, setup_test_dnsbuf,
    633  1.1  christos 		      teardown_test_dnsbuf)
    634  1.1  christos ISC_TEST_ENTRY_CUSTOM(dnsasm_sequence_test, setup_test_dnsasm,
    635  1.1  christos 		      teardown_test_dnsasm)
    636  1.1  christos ISC_TEST_ENTRY_CUSTOM(dnsasm_multiple_messages_test, setup_test_dnsasm,
    637  1.1  christos 		      teardown_test_dnsasm)
    638  1.1  christos ISC_TEST_ENTRY_CUSTOM(dnsasm_torn_apart_test, setup_test_dnsasm,
    639  1.1  christos 		      teardown_test_dnsasm)
    640  1.1  christos ISC_TEST_ENTRY_CUSTOM(dnsasm_error_data_test, setup_test_dnsasm,
    641  1.1  christos 		      teardown_test_dnsasm)
    642  1.1  christos ISC_TEST_ENTRY_CUSTOM(dnsasm_torn_randomly_test, setup_test_dnsasm,
    643  1.1  christos 		      teardown_test_dnsasm)
    644  1.1  christos ISC_TEST_ENTRY_CUSTOM(dnsasm_clear_buffer_within_cb_test, setup_test_dnsasm,
    645  1.1  christos 		      teardown_test_dnsasm)
    646  1.1  christos ISC_TEST_LIST_END
    647  1.1  christos 
    648  1.1  christos ISC_TEST_MAIN
    649