workqueue.h

#ifndef WORKQUEUE_H
#define WORKQUEUE_H

#include "db.h"
#include "trie.h"

typedef enum WorkQueueOp { NONE, ASSERT, RETRACT, RUN_WHEN, RUN_SUBSCRIBE, EVAL } WorkQueueOp;
typedef struct WorkQueueItem {
    WorkQueueOp op;

    // Clause pointers are the responsibility of the user of the
    // workqueue to keep alive (and to free once a work item is
    // processed). The workqueue does not itself copy or own or free
    // the Clause* you give it.
    union {
        struct {
            Clause* clause;
            // Caller is also responsible for freeing sourceFileName
            // on dequeue.
            char* sourceFileName;
            int sourceLineNumber;
        } assert;
        struct { Clause* pattern; } retract;
        struct {
            // The StatementRefs may be invalidated while this Run is
            // still in the workqueue -- if either is invalidated,
            // then the Run is invalidated.
            StatementRef when;
            Clause* whenPattern;
            StatementRef stmt;
        } runWhen;
        struct {
            // The subscribeRef may be invalidated while this Run is
            // still in the workqueue -- if so, then the Run is invalidated.
            StatementRef subscribeRef;
            Clause* subscribePattern;
            Clause* notifyClause;
        } runSubscribe;
        struct {
            char* code;
        } eval;
    };
} WorkQueueItem;

typedef struct WorkQueue WorkQueue;

// Global module initialization. Must call first.
void workQueueInit();

// Constructs a new work queue.
WorkQueue* workQueueNew();

// Removes the bottom item from work queue:
WorkQueueItem workQueueTake(WorkQueue* q);

// Adds an item to the bottom of work queue:
void workQueuePush(WorkQueue* q, WorkQueueItem item);

// Removes the top item from work queue:
WorkQueueItem workQueueSteal(WorkQueue* q);

int unsafe_workQueueCopy(WorkQueueItem* into, int maxn,
                         WorkQueue* q);

#endif