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, ®); 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