]> Kevux Git Server - controller/commitdiff
Update: Use the f_thread defines.
authorKevin Day <Kevin@kevux.org>
Mon, 15 Dec 2025 00:47:04 +0000 (18:47 -0600)
committerKevin Day <Kevin@kevux.org>
Mon, 15 Dec 2025 00:47:04 +0000 (18:47 -0600)
Do not directly use the `PTHEAD_*` defines.
Instead use the ones provided by `f_thread`.

sources/c/program/controller/init/signal.c
sources/c/program/controller/main/thread/cleanup.c
sources/c/program/controller/main/thread/control.c
sources/c/program/controller/main/thread/entry.c
sources/c/program/controller/main/thread/instance.c
sources/c/program/controller/main/thread/rule.c
sources/c/program/controller/main/thread/signal.c

index b39f15ed01210755fc3d4b96df086b1153b7c044..77b5ec549fa72f1dc673e764f149a39338d54b8e 100644 (file)
@@ -31,7 +31,7 @@ extern "C" {
       if (f_signal_wait_until(&main->program.signal.set, &time, &information) == F_time_out) continue;
 
       // Prevent thread from being interrupted and auto-cancelled.
-      f_thread_cancel_state_set(PTHREAD_CANCEL_DEFERRED, 0);
+      f_thread_cancel_state_set(f_thread_cancel_defer_d, 0);
 
       state = 0;
 
index b0765906d2363afb09eef24c7050c9d8279bcd11..539425851947c22b7d1a7c4e3f0e1410bd3d098f 100644 (file)
@@ -9,7 +9,7 @@ extern "C" {
 
     if (!argument) return 0;
 
-    f_thread_cancel_state_set(PTHREAD_CANCEL_DEFERRED, 0);
+    f_thread_cancel_state_set(f_thread_cancel_defer_d, 0);
     f_thread_name_set(f_thread_caller(), controller_thread_cleanup_s);
 
     controller_main_t * const main = (controller_main_t *) argument;
@@ -39,7 +39,7 @@ extern "C" {
       status = controller_mutex_condition_or_sleep(&main->thread.lock.reap, &main->thread.lock.reap_condition, &delay);
 
       // Prevent thread from being interrupted and auto-cancelled.
-      f_thread_cancel_state_set(PTHREAD_CANCEL_DEFERRED, 0);
+      f_thread_cancel_state_set(f_thread_cancel_defer_d, 0);
 
       // Reaping child processes is not critical, so don't care if the reap flag cannot be unset.
       if (!controller_thread_signal_get(&main->thread) && F_status_is_error_not(status)) {
index e8f39eef96904e4aed97b9e4efd059cf73ee7525..93628b5373d15309a8e2a74ac64cced9cdf21b44 100644 (file)
@@ -9,7 +9,7 @@ extern "C" {
 
     if (!argument) return 0;
 
-    f_thread_cancel_state_set(PTHREAD_CANCEL_DEFERRED, 0);
+    f_thread_cancel_state_set(f_thread_cancel_defer_d, 0);
     f_thread_name_set(f_thread_caller(), controller_thread_control_s);
 
     controller_main_t * const main = (controller_main_t *) argument;
index 152527173dc0c66605e54c4a800e0cc69bda6b62..9e55d65f8ed818b776872f5a4107d408d3ed0b20 100644 (file)
@@ -9,7 +9,7 @@ extern "C" {
 
     if (!argument) return 0;
 
-    f_thread_cancel_state_set(PTHREAD_CANCEL_DEFERRED, 0);
+    f_thread_cancel_state_set(f_thread_cancel_defer_d, 0);
     f_thread_name_set(f_thread_caller(), controller_thread_entry_s);
 
     controller_main_t * const main = (controller_main_t *) argument;
@@ -117,7 +117,7 @@ extern "C" {
 
     if (!argument) return 0;
 
-    f_thread_cancel_state_set(PTHREAD_CANCEL_DEFERRED, 0);
+    f_thread_cancel_state_set(f_thread_cancel_defer_d, 0);
 
     controller_main_t * const main = (controller_main_t *) argument;
     f_status_t * const status = &main->thread.status;
index fe6ba7b58850136c02b396f2d2aa1e2cf60b557b..dc1d250b01d0e1c7ceab1a3d03afef4417e3f8fe 100644 (file)
@@ -491,7 +491,7 @@ extern "C" {
 
     if (!argument) return 0;
 
-    f_thread_cancel_state_set(PTHREAD_CANCEL_DEFERRED, 0);
+    f_thread_cancel_state_set(f_thread_cancel_defer_d, 0);
     f_thread_name_set(f_thread_caller(), controller_thread_instance_s);
 
     controller_thread_instance((controller_instance_t * const) argument, F_true);
@@ -505,7 +505,7 @@ extern "C" {
 
     if (!argument) return 0;
 
-    f_thread_cancel_state_set(PTHREAD_CANCEL_DEFERRED, 0);
+    f_thread_cancel_state_set(f_thread_cancel_defer_d, 0);
     f_thread_name_set(f_thread_caller(), controller_thread_instance_s);
 
     controller_thread_instance((controller_instance_t * const) argument, F_false);
index e64c2c709bf8f25e2285567d0fda3921471cd8fe..a1d903f9a008e170b0c7087d73def91ec049b0a6 100644 (file)
@@ -9,7 +9,7 @@ extern "C" {
 
     if (!argument) return 0;
 
-    f_thread_cancel_state_set(PTHREAD_CANCEL_DEFERRED, 0);
+    f_thread_cancel_state_set(f_thread_cancel_defer_d, 0);
     f_thread_name_set(f_thread_caller(), controller_thread_rule_s);
 
     controller_main_t * const main = (controller_main_t *) argument;
index b6bedfee35cae012c8b1e18cf284e91466a6d9a8..1d9772b6d9e233b811daff9f73daa4cfa404e4e5 100644 (file)
@@ -31,7 +31,7 @@ extern "C" {
       if (f_signal_wait_until(&main->program.signal.set, &time, &information) == F_time_out) continue;
 
       // Prevent thread from being interrupted and auto-cancelled.
-      f_thread_cancel_state_set(PTHREAD_CANCEL_DEFERRED, 0);
+      f_thread_cancel_state_set(f_thread_cancel_defer_d, 0);
 
       state = 0;
 
@@ -197,7 +197,7 @@ extern "C" {
 #ifndef _di_controller_thread_signal_normal_
   void * controller_thread_signal_normal(void * const argument) {
 
-    f_thread_cancel_state_set(PTHREAD_CANCEL_DEFERRED, 0);
+    f_thread_cancel_state_set(f_thread_cancel_defer_d, 0);
     f_thread_name_set(f_thread_caller(), controller_thread_signal_s);
 
     if (argument) {
@@ -215,7 +215,7 @@ extern "C" {
 #ifndef _di_controller_thread_signal_other_
   void * controller_thread_signal_other(void * const argument) {
 
-    f_thread_cancel_state_set(PTHREAD_CANCEL_DEFERRED, 0);
+    f_thread_cancel_state_set(f_thread_cancel_defer_d, 0);
     f_thread_name_set(f_thread_caller(), controller_thread_signal_s);
 
     if (argument) {