2
0
mirror of https://gitlab.isc.org/isc-projects/bind9 synced 2025-08-22 10:10:06 +00:00
bind/tests/isc/work_test.c

79 lines
1.7 KiB
C
Raw Permalink Normal View History

2022-07-26 13:03:22 +02:00
/*
* Copyright (C) Internet Systems Consortium, Inc. ("ISC")
*
* SPDX-License-Identifier: MPL-2.0
*
* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, you can obtain one at https://mozilla.org/MPL/2.0/.
*
* See the COPYRIGHT file distributed with this work for additional
* information regarding copyright ownership.
*/
#include <inttypes.h>
2022-07-26 13:03:22 +02:00
#include <sched.h> /* IWYU pragma: keep */
#include <setjmp.h>
#include <stdarg.h>
#include <stddef.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include <unistd.h>
#define UNIT_TESTING
#include <cmocka.h>
#include <isc/atomic.h>
#include <isc/lib.h>
2022-07-26 13:03:22 +02:00
#include <isc/loop.h>
#include <isc/os.h>
#include <isc/result.h>
#include <isc/tid.h>
#include <isc/util.h>
#include <isc/work.h>
#include "work.c"
#include <tests/isc.h>
static atomic_uint scheduled = 0;
static void
work_cb(void *arg ISC_ATTR_UNUSED) {
2022-07-26 13:03:22 +02:00
atomic_fetch_add(&scheduled, 1);
assert_int_equal(isc_tid(), ISC_TID_UNKNOWN);
2022-07-26 13:03:22 +02:00
}
static void
after_work_cb(void *arg ISC_ATTR_UNUSED) {
2022-07-26 13:03:22 +02:00
assert_int_equal(atomic_load(&scheduled), 1);
isc_loopmgr_shutdown();
2022-07-26 13:03:22 +02:00
}
static void
work_enqueue_cb(void *arg ISC_ATTR_UNUSED) {
isc_tid_t tid = isc_loopmgr_nloops() - 1;
2022-07-26 13:03:22 +02:00
isc_loop_t *loop = isc_loop_get(tid);
2022-07-26 13:03:22 +02:00
isc_work_enqueue(loop, work_cb, after_work_cb, NULL);
2022-07-26 13:03:22 +02:00
}
ISC_RUN_TEST_IMPL(isc_work_enqueue) {
atomic_init(&scheduled, 0);
isc_loop_setup(isc_loop_main(), work_enqueue_cb, NULL);
2022-07-26 13:03:22 +02:00
isc_loopmgr_run();
2022-07-26 13:03:22 +02:00
assert_int_equal(atomic_load(&scheduled), 1);
}
ISC_TEST_LIST_START
ISC_TEST_ENTRY_CUSTOM(isc_work_enqueue, setup_loopmgr, teardown_loopmgr)
ISC_TEST_LIST_END
ISC_TEST_MAIN