mgk60.h File Reference

Go to the source code of this file.

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

Define Documentation

#define DEFERROR ( a,
b   )     a,

Definition at line 16 of file Mgk/include/mgk60.h.

#define LASTERROR   E_NUMERRORS

Definition at line 17 of file Mgk/include/mgk60.h.

#define MGK_ALL_OUTPUT_CONNECTIONS   (unsigned int)(-1)

Definition at line 211 of file Mgk/include/mgk60.h.

#define MGK_I_BADVAL   (-1)

Definition at line 39 of file Mgk/include/mgk60.h.

#define MGK_LOCALHOST   ((mgk_hostp)(0))

Definition at line 76 of file Mgk/include/mgk60.h.

#define MGK_MAX_NODE_PRIORITY   255

Definition at line 114 of file Mgk/include/mgk60.h.

#define MGK_MAX_PORT_COUNT   256

Definition at line 113 of file Mgk/include/mgk60.h.

#define MGK_NODE_STOP_PRIORITY   0

Definition at line 115 of file Mgk/include/mgk60.h.

#define MGK_P_BADVAL   (0)

Definition at line 43 of file Mgk/include/mgk60.h.

#define mgk_portmask_bit ( m,
 )     (((m)[(i) / BITS(int)] & (1 << ((i) % BITS(int)))) ? 1 : 0)

Definition at line 132 of file Mgk/include/mgk60.h.

#define mgk_set_portmask_bit ( m,
i,
 ) 
Value:
((v) ?                                                  \
    (((m)[(i) / BITS(int)] |= (1 << ((i) % BITS(int)))),1) :    \
    (((m)[(i) / BITS(int)] &= ~(1 << ((i) % BITS(int)))),0))

Definition at line 134 of file Mgk/include/mgk60.h.

#define MGK_U_BADVAL   ((unsigned int)(-1))

Definition at line 41 of file Mgk/include/mgk60.h.

#define T_ARRAY ( items   )     (64U | (items << 8))

Definition at line 91 of file Mgk/include/mgk60.h.

#define T_BUFFER   32U

Definition at line 90 of file Mgk/include/mgk60.h.

#define T_CHAR   1U

Definition at line 84 of file Mgk/include/mgk60.h.

#define T_DOUBLE   7U

Definition at line 89 of file Mgk/include/mgk60.h.

#define T_FLOAT   6U

Definition at line 88 of file Mgk/include/mgk60.h.

#define T_INTEGER   4U

Definition at line 86 of file Mgk/include/mgk60.h.

#define T_LONGINT   5U

Definition at line 87 of file Mgk/include/mgk60.h.

#define T_NODATA   (unsigned int)(-1)

Definition at line 82 of file Mgk/include/mgk60.h.

#define T_SHORTINT   2U

Definition at line 85 of file Mgk/include/mgk60.h.

#define T_STRING   (T_CHAR | T_ARRAY(-1))

Definition at line 95 of file Mgk/include/mgk60.h.

#define T_UNKNOWN   0U

Definition at line 83 of file Mgk/include/mgk60.h.

#define TRC_ALL   1023

Definition at line 276 of file Mgk/include/mgk60.h.

#define TRC_BCHECK   8

Definition at line 269 of file Mgk/include/mgk60.h.

#define TRC_BUFFER   4

Definition at line 268 of file Mgk/include/mgk60.h.

#define TRC_COMMUN   32

Definition at line 271 of file Mgk/include/mgk60.h.

#define TRC_CQUEUE   128

Definition at line 273 of file Mgk/include/mgk60.h.

#define TRC_DEFAULT   (TRC_ALL & ~(TRC_BCHECK | TRC_LOWCOMM | TRC_CQUEUE))

Definition at line 277 of file Mgk/include/mgk60.h.

#define TRC_LOWCOMM   64

Definition at line 272 of file Mgk/include/mgk60.h.

#define TRC_MALLOC   16

Definition at line 270 of file Mgk/include/mgk60.h.

#define TRC_MISC   512

Definition at line 275 of file Mgk/include/mgk60.h.

#define TRC_PROPAG   1

Definition at line 266 of file Mgk/include/mgk60.h.

#define TRC_SCHED   2

Definition at line 267 of file Mgk/include/mgk60.h.

#define TRC_USER   256

Definition at line 274 of file Mgk/include/mgk60.h.


Typedef Documentation

typedef void(* mgk_actor_abort_handler)(mgk_nodep node, int code)

Definition at line 279 of file Mgk/include/mgk60.h.

typedef unsigned int mgk_data_type

Definition at line 80 of file Mgk/include/mgk60.h.

typedef unsigned int * mgk_data_typep

Definition at line 80 of file Mgk/include/mgk60.h.

Definition at line 46 of file Mgk/include/mgk60.h.

typedef void* mgk_hostp

Definition at line 52 of file Mgk/include/mgk60.h.

typedef void* mgk_nodep

Definition at line 118 of file Mgk/include/mgk60.h.

typedef void(* mgk_port_overflow_handler)(mgk_nodep node, int port, int outflag, int outdest, int curlen, int maxlen)

Definition at line 280 of file Mgk/include/mgk60.h.

typedef int mgk_portmask[(MGK_MAX_PORT_COUNT+BITS(int)-1)/BITS(int)]

Definition at line 130 of file Mgk/include/mgk60.h.

typedef void(* mgk_script)(void)

Definition at line 121 of file Mgk/include/mgk60.h.


Enumeration Type Documentation

Enumerator:
E_GENERROR 
E_SUCCESS 
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 

Definition at line 18 of file Mgk/include/mgk60.h.

Enumerator:
AT_IFALL 
AT_IFANY 
AT_SPEC 
AT_IFALL 
AT_IFANY 
AT_SPEC 

Definition at line 124 of file Mgk/include/mgk60.h.


Function Documentation

void mgk_abort_node ( int  code  ) 

Definition at line 154 of file propag.c.

mgk_error_code mgk_add_node_trigger_mask ( mgk_nodep  node,
mgk_portmask  mask 
)

Definition at line 204 of file build.c.

mgk_error_code mgk_add_node_trigger_mask_disp ( mgk_nodep  node,
mgk_portmask  mask,
mgk_script  fn 
)

Definition at line 178 of file build.c.

mgk_error_code mgk_add_node_trigger_mask_disp_indirect ( mgk_nodep  node,
mgk_portmask  mask,
char *  scriptname 
)

Definition at line 250 of file build.c.

void* mgk_allocate_buffer ( unsigned int  size,
int  do_zero 
)

Definition at line 31 of file buffer.c.

unsigned int mgk_buffer_size ( void *  buffer  ) 

Definition at line 122 of file buffer.c.

mgk_error_code mgk_clear_node_input_port ( mgk_nodep  node,
unsigned int  port,
unsigned int  count 
)

Definition at line 200 of file data.c.

mgk_error_code mgk_clear_node_output_port ( mgk_nodep  node,
unsigned int  port,
unsigned int  whichconn,
unsigned int  count 
)

Definition at line 267 of file data.c.

mgk_error_code mgk_connect_nodes ( mgk_nodep  src,
unsigned int  srcport,
mgk_nodep  dst,
unsigned int  dstport 
)

Definition at line 220 of file connect.c.

mgk_error_code mgk_connect_nodes_len ( mgk_nodep  src,
unsigned int  srcport,
mgk_nodep  dst,
unsigned int  dstport,
unsigned int  maxlen 
)

Definition at line 227 of file connect.c.

void* mgk_copy_buffer ( void *  buffer  ) 

Definition at line 64 of file buffer.c.

mgk_nodep mgk_create_node ( mgk_script  fn,
unsigned int  nin,
unsigned int  nout,
unsigned int  priority,
mgk_trigger_mode  tmode 
)

Definition at line 44 of file build.c.

mgk_nodep mgk_create_node_indirect ( char *  scriptname,
unsigned int  nin,
unsigned int  nout,
unsigned int  priority,
mgk_trigger_mode  tmode,
mgk_hostp  host 
)

Definition at line 112 of file build.c.

mgk_nodep mgk_current_node ( void   ) 

PROPAG.C ---- dataflow propagation routines

Definition at line 9 of file propag.c.

mgk_error_code mgk_disconnect_nodes ( mgk_nodep  src,
unsigned int  srcport,
mgk_nodep  dst,
unsigned int  dstport 
)

Definition at line 446 of file connect.c.

void mgk_enable_warnings ( int  flag  ) 
mgk_error_code mgk_free_buffer ( void *  buffer  ) 

Definition at line 91 of file buffer.c.

mgk_hostp mgk_get_host ( unsigned int  which  ) 

Definition at line 26 of file hosts.c.

mgk_error_code mgk_get_host_info ( mgk_hostp  host  ) 
int mgk_get_number_of_hosts ( void   ) 

HOSTS.C ----- host related calls

Definition at line 8 of file hosts.c.

unsigned int mgk_ifany_trigger ( void   ) 

Definition at line 163 of file propag.c.

mgk_error_code mgk_initialize ( int *  argc,
char ***  argv 
)

Definition at line 25 of file init.c.

int mgk_is_a_buffer ( void *  buffer  ) 

Definition at line 116 of file buffer.c.

int mgk_is_a_host ( mgk_hostp  host  ) 

Definition at line 37 of file hosts.c.

mgk_hostp mgk_local_host ( void   ) 

Definition at line 43 of file hosts.c.

int mgk_local_host_index ( void   ) 

Definition at line 14 of file hosts.c.

void* mgk_node_context ( mgk_nodep  node,
mgk_data_typep  typep 
)

Definition at line 479 of file build.c.

mgk_nodep mgk_node_input_connection ( mgk_nodep  node,
unsigned int  port,
unsigned int  whichconn,
unsigned int *  connport 
)

Definition at line 227 of file topo.c.

unsigned int mgk_node_input_connection_count ( mgk_nodep  node,
unsigned int  port 
)

Definition at line 107 of file topo.c.

unsigned int mgk_node_input_count ( mgk_nodep  node  ) 

TOPO.C ----- calls to inspect graph topology

Definition at line 11 of file topo.c.

unsigned int mgk_node_input_port_length ( mgk_nodep  node,
unsigned int  port 
)

Definition at line 348 of file data.c.

mgk_nodep mgk_node_output_connection ( mgk_nodep  node,
unsigned int  port,
unsigned int  whichconn,
unsigned int *  connport 
)

Definition at line 289 of file topo.c.

unsigned int mgk_node_output_connection_count ( mgk_nodep  node,
unsigned int  port 
)

Definition at line 150 of file topo.c.

unsigned int mgk_node_output_count ( mgk_nodep  node  ) 

Definition at line 43 of file topo.c.

unsigned int mgk_node_output_port_length ( mgk_nodep  node,
unsigned int  port,
unsigned int  whichconn 
)

Definition at line 403 of file data.c.

unsigned int mgk_node_priority ( mgk_nodep  node  ) 

Definition at line 353 of file build.c.

void* mgk_peek_node_input_port ( mgk_nodep  node,
unsigned int  port,
unsigned int  streampos,
mgk_data_typep  typep 
)

Definition at line 478 of file data.c.

void* mgk_peek_node_output_port ( mgk_nodep  node,
unsigned int  port,
unsigned int  whichconn,
unsigned int  streampos,
mgk_data_typep  typep 
)

Definition at line 564 of file data.c.

void mgk_perror ( char *   ) 
mgk_error_code mgk_propagate ( unsigned int  port,
void *  data,
mgk_data_type  type 
)

Definition at line 50 of file propag.c.

mgk_error_code mgk_protect_buffer ( void *  buffer  ) 

Definition at line 120 of file propag.c.

void* mgk_receive ( unsigned int  port,
mgk_data_typep  typep 
)

Definition at line 15 of file propag.c.

void mgk_register_script ( mgk_script  fn,
char *  name 
)

Definition at line 22 of file script.c.

unsigned int mgk_run ( unsigned int  num_nodes_to_run  ) 

RUN.C ---- execute a few dataflow nodes

Definition at line 8 of file run.c.

void mgk_set_comm_priority ( unsigned int  commpri  ) 

Definition at line 24 of file run.c.

unsigned int mgk_set_default_connection_length ( unsigned int  newlen  ) 

Definition at line 16 of file connect.c.

void mgk_set_node_abort_handler ( mgk_actor_abort_handler  hd  ) 
mgk_error_code mgk_set_node_context ( mgk_nodep  node,
void *  context,
mgk_data_type  type 
)

Definition at line 401 of file build.c.

mgk_error_code mgk_set_node_priority ( mgk_nodep  node,
unsigned int  priority 
)

Definition at line 299 of file build.c.

void mgk_set_overflow_handler ( mgk_port_overflow_handler  hd  ) 
void mgk_set_tracing ( int  tmode,
int  stepflag 
)
mgk_error_code mgk_trigger_mask ( mgk_portmask  mask  ) 

Definition at line 190 of file propag.c.

mgk_error_code mgk_unprotect_buffer ( void *  buffer  ) 

Definition at line 137 of file propag.c.

void mgk_wait_for_comm_event ( void   ) 

Definition at line 30 of file run.c.

mgk_error_code mgk_write_node_input_port ( void *  data,
mgk_data_type  type,
mgk_nodep  node,
unsigned int  port 
)

Definition at line 11 of file data.c.

mgk_error_code mgk_write_node_output_port ( void *  data,
mgk_data_type  type,
mgk_nodep  node,
unsigned int  port,
unsigned int  whichconn 
)

Definition at line 93 of file data.c.


Variable Documentation

Definition at line 17 of file init.c.

Generated on Thu May 30 15:42:57 2013 for GME by  doxygen 1.6.3