compiler-codegen/nova_rt/driver.h - main - nv-lang/nova

compiler-codegen/nova_rt/driver.h
124 строки5 KB
Evgeniy Golovin
fix(221.1 №398, №224): supervised(cancel:/timeout:/deadline:) не будило driver-armed Time.sleep прямо в теле
07 авг 2026, 04:34
07 авг 2026, 04:341e8ae31
// SPDX-License-Identifier: MIT OR Apache-2.0
#ifndef NOVA_RT_DRIVER_H
#define NOVA_RT_DRIVER_H

/* Plan 83.11: Centralized I/O driver — architectural pivot (port Tokio 1.x).
 *
 * Single dedicated driver thread owns one uv_loop_t. Workers (NovaWorker[])
 * submit jobs (arm timer, cancel scope, etc) via lock-protected MPSC queue
 * + uv_async_send wake. Driver processes jobs single-threaded — eliminates
 * cross-thread races by construction.
 *
 * See docs/plans/83.11-design.md for full architecture.
 * See docs/plans/83.11-centralized-io-driver.md §3.0 for Tokio source mapping. */

#include "sync.h"
#include "alloc.h"
#include <uv.h>

#ifdef __cplusplus
extern "C" {
#endif

/* Forward decls — circular include with fibers.h. */
struct NovaSleepState;
struct NovaFiberQueue;
struct NovaBlockingState;

typedef enum {
    NOVA_DRV_JOB_ARM_SLEEP        = 1,
    NOVA_DRV_JOB_CANCEL_SCOPE     = 2,
    NOVA_DRV_JOB_CANCEL_TIMER     = 3,
    NOVA_DRV_JOB_ARM_BLOCKING     = 4,
    /* №398 (docs/plans/221.1-bug-sweep.md К1; D442 amendment): targeted
     * counterpart of NOVA_DRV_JOB_CANCEL_SCOPE for a SINGLE (scope, slot) —
     * needed because a direct (non-`spawn`) `Time.sleep` in a `supervised{}`
     * body arms itself under the OWNER's ambient scope/slot (see fibers.h
     * `_nova_sleep_via_driver`'s `cancel_scope` derivation — for a fiber
     * that has not been freshly `spawn`-ed, `NovaSpawnCtxBase::_nova_parent_
     * scope` still points at the OUTER scope the fiber was originally
     * spawned into, not the innermost `supervised(cancel:)` scope it is
     * lexically inside of), while `nova_scope_deliver_cancel`'s existing
     * `_nova_cancel_via_driver(q)` only walks `q`'s OWN `armed_sleeps_head`.
     * This job walks the OWNER scope's list but only touches the ONE entry
     * matching `slot` — mirrors `nova_sched_cancel_pending_slot`'s
     * single-slot contract (nova_sched.h) for the driver-armed-sleep
     * bookkeeping that mechanism doesn't know about. */
    NOVA_DRV_JOB_CANCEL_SLOT      = 5,
    /* Sentinel — driver shutdown internal signal */
    NOVA_DRV_JOB__SHUTDOWN_SENTINEL = 99,
} NovaDriverJobKind;

typedef struct NovaDriverJob {
    NovaDriverJobKind kind;
    union {
        struct {
            struct NovaSleepState* st;
            uint64_t               ms;
        } arm_sleep;
        struct {
            struct NovaFiberQueue* scope;
        } cancel_scope;
        struct {
            struct NovaSleepState* st;
        } cancel_timer;
        struct {
            struct NovaBlockingState* st;
            void (*work)(void*);
            void* arg;
        } arm_blocking;
        struct {
            struct NovaFiberQueue* scope;
            int                    slot;
        } cancel_slot;  /* №398 */
    } u;
    struct NovaDriverJob* next;  /* linked-list MPSC */
} NovaDriverJob;

/* MPSC mutex+linked-list queue. V1 simplicity over lock-free crossbeam-style.
 * Profile в Ф.8 — if hot, switch to MPSC ring buffer. */
typedef struct {
    nova_mutex_t   mu;
    NovaDriverJob* head;
    NovaDriverJob* tail;
} NovaDriverJobQueue;

typedef struct {
    uv_loop_t           loop;            /* dedicated driver UV loop */
    uv_thread_t         thread;
    uv_async_t          job_async;       /* worker→driver job submission wake */
    uv_async_t          shutdown_async;  /* shutdown signal handle */
    NovaDriverJobQueue  jobs;
    nova_atomic_bool    stop;            /* shutdown flag */
    nova_atomic_bool    started;         /* init completed flag */
} NovaDriver;

extern NovaDriver _nova_driver;

/* Initialize driver — called from nova_runtime_init AFTER worker pool
 * materialization (workers exist before driver routes wake events to them).
 * Idempotent: second call is no-op. */
void nova_driver_init(void);

/* Stop driver thread — called from nova_runtime_shutdown BEFORE worker join.
 * Drains in-flight jobs, closes UV handles, joins thread. Idempotent. */
void nova_driver_shutdown(void);

/* Submit job to driver. Lock-protected MPSC push + uv_async_send wake.
 * Job memory must be heap-allocated by caller (nova_alloc); driver frees
 * after processing.
 *
 * Returns 0 on success, -1 if driver not started or shutting down (job is
 * NOT freed in that case — caller responsibility либо leak acceptable on
 * shutdown path). */
int nova_driver_submit_job(NovaDriverJob* job);

/* Fast inline check — used by Time.sleep dispatch to route to driver path
 * (post Plan 83.11 Ф.3) vs legacy per-worker UV path (bootstrap). */
bool nova_driver_is_started(void);

#ifdef __cplusplus
}
#endif

#endif /* NOVA_RT_DRIVER_H */