struct EngineInput
{
  EngineNode *src_node;
  guint       src_stream;
  EngineNode *real_node;
  guint       real_stream;
};

struct EngineJInput
{
  EngineNode *src_node;
  guint       src_stream;
  EngineNode *real_node;
  guint       real_stream;
};

struct EngineOutput
{
  gfloat *buffer;
  guint   n_outputs;
};

struct _BseJob
{
  EngineJobType       job_id;
  BseJob             *next;
  EngineNode         *node;
  gboolean            free_with_job;
  gchar              *message;
  _BseJob::$19::$21   data;
  BirnetMutex        *lock_mutex;
  BirnetCond         *lock_cond;
  gboolean           *lock_p;
  _BseJob::$19::$22   sync;
  EngineNode         *node;
  guint64             stamp;
  _BseJob::$19::$23   tick;
  EngineNode         *dest_node;
  guint               dest_ijstream;
  EngineNode         *src_node;
  guint               src_ostream;
  _BseJob::$19::$24   connection;
  EngineNode         *node;
  BseEngineAccessFunc access_func;
  gpointer            data;
  BseFreeFunc         free_func;
  _BseJob::$19::$25   access;
  BseEnginePollFunc   poll_func;
  guint               n_fds;
  GPollFD            *fds;
  _BseJob::$19::$26   poll;
  BseEngineTimerFunc  timer_func;
  _BseJob::$19::$27   timer;
  EngineNode         *node;
  EngineTimedJob     *tjob;
  _BseJob::$19::$28   timed_job;
};

struct _BseTrans
{
  BseJob   *jobs_head;
  BseJob   *jobs_tail;
  guint     comitted;
  BseTrans *cqt_next;
};

struct _EngineNode
{
  BseModule       module;
  BirnetRecMutex  rec_mutex;
  guint64         counter;
  EngineInput    *inputs;
  EngineJInput  **jinputs;
  EngineOutput   *outputs;
  EngineTimedJob *flow_jobs;
  EngineTimedJob *probe_jobs;
  EngineTimedJob *boundary_jobs;
  EngineTimedJob *tjob_head;
  EngineTimedJob *tjob_tail;
  guint64         next_active;
  EngineNode     *mnl_next;
  EngineNode     *mnl_prev;
  guint           integrated;
  guint           virtual_node;
  guint           is_consumer;
  guint           update_suspend;
  guint           in_suspend_call;
  guint           needs_reset;
  guint           cleared_ostreams;
  guint           sched_tag;
  guint           sched_recurse_tag;
  guint           sched_leaf_level;
  guint64         local_active;
  EngineNode     *toplevel_next;
  SfiRing        *output_nodes;
};