Classes |
struct | mgk_hostinfo |
Defines |
#define | DEFERROR(a, b) a, |
#define | LASTERROR E_NUMERRORS |
#define | MGK_I_BADVAL (-1) |
#define | MGK_U_BADVAL ((unsigned int)(-1)) |
#define | MGK_P_BADVAL (0) |
#define | MGK_LOCALHOST ((mgk_hostp)(0)) |
#define | T_NODATA (unsigned int)(-1) |
#define | T_UNKNOWN 0U |
#define | T_CHAR 1U |
#define | T_SHORTINT 2U |
#define | T_INTEGER 4U |
#define | T_LONGINT 5U |
#define | T_FLOAT 6U |
#define | T_DOUBLE 7U |
#define | T_BUFFER 32U |
#define | T_ARRAY(items) (64U | (items << 8)) |
#define | T_STRING (T_CHAR | T_ARRAY(-1)) |
#define | MGK_MAX_PORT_COUNT 256 |
#define | MGK_MAX_NODE_PRIORITY 255 |
#define | MGK_NODE_STOP_PRIORITY 0 |
#define | mgk_portmask_bit(m, i) (((m)[(i) / BITS(int)] & (1 << ((i) % BITS(int)))) ? 1 : 0) |
#define | mgk_set_portmask_bit(m, i, v) |
#define | MGK_ALL_OUTPUT_CONNECTIONS (unsigned int)(-1) |
#define | TRC_PROPAG 1 |
#define | TRC_SCHED 2 |
#define | TRC_BUFFER 4 |
#define | TRC_BCHECK 8 |
#define | TRC_MALLOC 16 |
#define | TRC_COMMUN 32 |
#define | TRC_LOWCOMM 64 |
#define | TRC_CQUEUE 128 |
#define | TRC_USER 256 |
#define | TRC_MISC 512 |
#define | TRC_ALL 1023 |
#define | TRC_DEFAULT (TRC_ALL & ~(TRC_BCHECK | TRC_LOWCOMM | TRC_CQUEUE)) |
Typedefs |
typedef enum __mgk_error_codes | mgk_error_code |
typedef void * | mgk_hostp |
typedef unsigned int | mgk_data_type |
typedef unsigned int * | mgk_data_typep |
typedef void * | mgk_nodep |
typedef void(* | mgk_script )(void) |
typedef int | mgk_portmask [(MGK_MAX_PORT_COUNT+BITS(int)-1)/BITS(int)] |
typedef void(* | mgk_actor_abort_handler )(mgk_nodep node, int code) |
typedef void(* | mgk_port_overflow_handler )(mgk_nodep node, int port, int outflag, int outdest, int curlen, int maxlen) |
Enumerations |
enum | __mgk_error_codes {
E_GENERROR = -1,
E_SUCCESS = 0,
E_SCRIPTNOTFOUND,
E_NOTNODE,
E_NOTBUFFER,
E_BUFFERUSED,
E_NOTHOST,
E_BADPORTIX,
E_BADTRIGGER,
E_PORTCONN,
E_BADDATA,
E_NOMEM,
E_NOTRUNNING,
E_COMM,
E_NUMERRORS,
LASTERROR
} |
enum | mgk_trigger_mode {
AT_IFALL,
AT_IFANY,
AT_SPEC,
AT_IFALL,
AT_IFANY,
AT_SPEC
} |
Functions |
int | mgk_get_number_of_hosts (void) |
int | mgk_local_host_index (void) |
mgk_hostp | mgk_get_host (unsigned int which) |
mgk_error_code | mgk_get_host_info (mgk_hostp host) |
int | mgk_is_a_host (mgk_hostp host) |
mgk_hostp | mgk_local_host (void) |
void * | mgk_allocate_buffer (unsigned int size, int do_zero) |
void * | mgk_copy_buffer (void *buffer) |
mgk_error_code | mgk_free_buffer (void *buffer) |
int | mgk_is_a_buffer (void *buffer) |
unsigned int | mgk_buffer_size (void *buffer) |
void | mgk_register_script (mgk_script fn, char *name) |
mgk_nodep | mgk_create_node (mgk_script fn, unsigned int nin, unsigned int nout, unsigned int priority, mgk_trigger_mode tmode) |
mgk_nodep | mgk_create_node_indirect (char *scriptname, unsigned int nin, unsigned int nout, unsigned int priority, mgk_trigger_mode tmode, mgk_hostp host) |
mgk_error_code | mgk_add_node_trigger_mask (mgk_nodep node, mgk_portmask mask) |
mgk_error_code | mgk_add_node_trigger_mask_disp (mgk_nodep node, mgk_portmask mask, mgk_script fn) |
mgk_error_code | mgk_add_node_trigger_mask_disp_indirect (mgk_nodep node, mgk_portmask mask, char *scriptname) |
mgk_error_code | mgk_set_node_priority (mgk_nodep node, unsigned int priority) |
unsigned int | mgk_node_priority (mgk_nodep node) |
mgk_error_code | mgk_set_node_context (mgk_nodep node, void *context, mgk_data_type type) |
void * | mgk_node_context (mgk_nodep node, mgk_data_typep typep) |
mgk_error_code | mgk_connect_nodes (mgk_nodep src, unsigned int srcport, mgk_nodep dst, unsigned int dstport) |
mgk_error_code | mgk_connect_nodes_len (mgk_nodep src, unsigned int srcport, mgk_nodep dst, unsigned int dstport, unsigned int maxlen) |
unsigned int | mgk_set_default_connection_length (unsigned int newlen) |
mgk_error_code | mgk_disconnect_nodes (mgk_nodep src, unsigned int srcport, mgk_nodep dst, unsigned int dstport) |
unsigned int | mgk_node_input_count (mgk_nodep node) |
unsigned int | mgk_node_output_count (mgk_nodep node) |
unsigned int | mgk_node_input_connection_count (mgk_nodep node, unsigned int port) |
unsigned int | mgk_node_output_connection_count (mgk_nodep node, unsigned int port) |
mgk_nodep | mgk_node_input_connection (mgk_nodep node, unsigned int port, unsigned int whichconn, unsigned int *connport) |
mgk_nodep | mgk_node_output_connection (mgk_nodep node, unsigned int port, unsigned int whichconn, unsigned int *connport) |
mgk_error_code | mgk_write_node_input_port (void *data, mgk_data_type type, mgk_nodep node, unsigned int port) |
mgk_error_code | mgk_write_node_output_port (void *data, mgk_data_type type, mgk_nodep node, unsigned int port, unsigned int whichconn) |
mgk_error_code | mgk_clear_node_input_port (mgk_nodep node, unsigned int port, unsigned int count) |
mgk_error_code | mgk_clear_node_output_port (mgk_nodep node, unsigned int port, unsigned int whichconn, unsigned int count) |
unsigned int | mgk_node_input_port_length (mgk_nodep node, unsigned int port) |
unsigned int | mgk_node_output_port_length (mgk_nodep node, unsigned int port, unsigned int whichconn) |
void * | mgk_peek_node_input_port (mgk_nodep node, unsigned int port, unsigned int streampos, mgk_data_typep typep) |
void * | mgk_peek_node_output_port (mgk_nodep node, unsigned int port, unsigned int whichconn, unsigned int streampos, mgk_data_typep typep) |
mgk_nodep | mgk_current_node (void) |
void * | mgk_receive (unsigned int port, mgk_data_typep typep) |
mgk_error_code | mgk_propagate (unsigned int port, void *data, mgk_data_type type) |
mgk_error_code | mgk_protect_buffer (void *buffer) |
mgk_error_code | mgk_unprotect_buffer (void *buffer) |
void | mgk_abort_node (int code) |
unsigned int | mgk_ifany_trigger (void) |
mgk_error_code | mgk_trigger_mask (mgk_portmask mask) |
void | mgk_perror (char *) |
void | mgk_set_node_abort_handler (mgk_actor_abort_handler hd) |
void | mgk_set_overflow_handler (mgk_port_overflow_handler hd) |
void | mgk_set_tracing (int tmode, int stepflag) |
void | mgk_enable_warnings (int flag) |
mgk_error_code | mgk_initialize (int *argc, char ***argv) |
unsigned int | mgk_run (unsigned int num_nodes_to_run) |
void | mgk_set_comm_priority (unsigned int commpri) |
void | mgk_wait_for_comm_event (void) |
Variables |
mgk_error_code | mgk_errno |