| 1943 | } |
| 1944 | |
| 1945 | static void runtime_worker_reset_after_join(cbm_daemon_runtime_worker_t *worker) { |
| 1946 | free(worker->application_request); |
| 1947 | worker->thread_started = false; |
| 1948 | worker->in_use = false; |
| 1949 | worker->joining = false; |
| 1950 | worker->connection = NULL; |
| 1951 | worker->client_id = CBM_DAEMON_CLIENT_ID_INVALID; |
| 1952 | worker->peer_process_id = 0; |
| 1953 | worker->admitted = false; |
| 1954 | worker->admission_committed = false; |
| 1955 | worker->final_response_inflight = false; |
| 1956 | worker->application_session = NULL; |
| 1957 | worker->application_session_opened = false; |
| 1958 | worker->application_cancelled = false; |
| 1959 | worker->application_thread_started = false; |
| 1960 | worker->application_request_token = CBM_DAEMON_RUNTIME_APPLICATION_TOKEN_INVALID; |
| 1961 | worker->last_application_request_token = CBM_DAEMON_RUNTIME_APPLICATION_TOKEN_INVALID; |
| 1962 | worker->application_request = NULL; |
| 1963 | worker->application_request_length = 0; |
| 1964 | atomic_store_explicit(&worker->done, false, memory_order_release); |
| 1965 | atomic_store_explicit(&worker->disconnecting, false, memory_order_release); |
| 1966 | atomic_store_explicit(&worker->application_thread_done, false, memory_order_release); |
| 1967 | } |
| 1968 | |
| 1969 | static void runtime_reap_completed_workers(cbm_daemon_runtime_service_t *service) { |
| 1970 | for (size_t i = 0; i < service->worker_capacity; i++) { |
no outgoing calls
no test coverage detected