vmhost.h

Go to the documentation of this file.

#ifndef _CEPTR_VMHOST_H
#define _CEPTR_VMHOST_H

#include "receptor.h"

#define SELF_RECEPTOR_ADDR -1

typedef struct thread {
    int state;
    pthread_t pthread;
} thread;

typedef struct ActiveReceptor {
    Xaddr x;
    Receptor *r;
} ActiveReceptor;

typedef struct ReceptorRoute {
    Receptor *r;
    SemanticID s;
} ReceptorRoute;

#define MAX_ACTIVE_RECEPTORS 1000
#define MAX_RECEPTORS 1000

struct VMHost {
    ReceptorRoute routing_table[MAX_RECEPTORS];
    int receptor_count;
    Receptor *r;                
    SemTable *sem;              
    ActiveReceptor active_receptors[MAX_ACTIVE_RECEPTORS];       
    int active_receptor_count;
    Scape *installed_receptors;
    thread vm_thread;
    thread clock_thread;
    int process_state;
    char *dir;
};
typedef struct VMHost VMHost;

/******************  create and destroy virtual machine */
VMHost *__v_init(Receptor *r,SemTable *sem);
VMHost * _v_new();
void _v_free(VMHost *r);

Xaddr _v_load_receptor_package(VMHost *v,T *p);
Xaddr _v_install_r(VMHost *v,Xaddr package,T *bindings,char *label);
Xaddr _v_new_receptor(VMHost *v,Receptor *parent,Symbol s, Receptor *r);
void _v_activate(VMHost *v, Xaddr x);
void _v_send(VMHost *v,ReceptorAddress from,ReceptorAddress to,Aspect aspect,Symbol carrier,T *contents);
void _v_send_signals(VMHost *v,T *signals);

void _v_deliver_signals(VMHost *v, Receptor *sender);

void * __v_process(void *arg);

void _v_instantiate_builtins(VMHost *v);
void _v_start_vmhost(VMHost *v);

/******************  thread handling */
void _v_start_thread(thread *t,void *(*start_routine)(void*), void *arg);
void _v_join_thread(thread *t);

#endif