/common/home/bel/bella/lnx/exports/build/current/all/cop-libs/vx/ixf_i.h

#ifndef _IXF_I_H
#define _IXF_I_H

#include <stdarg.h>

/*
 * internal types and function prototypes
 */
#include "isintf.h"
#include "rsintf.h"
#include "ix_tools.h"
#include "uv.h"
#include "xfer.h"
#include "xfreader.h"

#ifdef IXF_INT
#include "ssdef.h"
#endif

#define FV_ERROR 0x01
#define FV_DEBUG 0x02
#define FV_SYS 0x04
#define FV_NET 0x08
#define FV_UV 0x10
#define FV_LOG 0x20
#define FV_CAP 0x40
#define FV_ALL 0xFFFFFFFF

#define NET_NODE_ENV "NET_NODE"
#define NET_IP_ENV "NET_IP"

#define CONFIG_ENV "BELA_CONFIGDIR"

#define IXF_MAX_PROC 256
#define IXF_MAX_EXITHDL 32
#define IXF_MAX_REFL 8

// max number of netman packets to queue
#define IXF_MAX_NETMANQUEUE 128

#define IXF_NETMAN_PACKET_TAG 0xFF

typedef struct
{
  int done;
  ix_log_t *plog;

  int msgqueue;

  is_port_t procinf[IXF_MAX_PROC];
  rs_reg_t rs;
  int regdone;
  xf_refl_t * refl_list[IXF_MAX_REFL];
  UV_CHANGE_CB uv_user_cb;

  ix_net_t *pudp;
  ix_net_t *ptcp;
  int netman_evid;
  int netman_blocked;
  char *netman_packet_buffer;
  ix_queue_t *netman_queue;
  ix_cs_t *netman_cs;

  int cap_evid;
  int cap_rc;
  ix_cs_t *cap_cs;

  ix_qio_t *getch_qio;
} ixf_t;


typedef struct
{
  void *fb;     // fortran data buffer
  int  evn;       // event number 
} ixf_buf_t;


// c_max_multipacket_data_len
#define IXF_PROC_NAME_LEN 6
#define IXF_C_MAX_MP_DATA_LEN 8700
#define IXF_NET_LEN (8700 + 44 + 2)
#define IXF_DATA_PC 0xF0
#define IXF_ERROR_PC 0x70

typedef struct 
{
  union
  {
    struct
    {
      int io_status;
      int dev_status;
    };
    struct
    {
      short io_status_lo;
      short io_status_hi;
      int   dev_status;
    };
    struct
    {
      short ret_status;
      short term_offset; // location of line terminator
      short term_value;  // value of terminator
      short term_size;   // size of terminator
    };
  };
} ixf_iosb_t;

// net packet structure of fortran programs
typedef struct
{
  int16_t dest_node;                          // DestinationNode
  unsigned char dest_proc[IXF_PROC_NAME_LEN]; // DestinationProcess
  unsigned char dest_proc_ext[IXF_PROC_NAME_LEN]; // DProcess_Ext
  int16_t src_node;                           // SourceNode
  unsigned char src_proc[IXF_PROC_NAME_LEN];  // SourceProcess
  unsigned char src_proc_ext[IXF_PROC_NAME_LEN];  // SProcess_Ext
  int16_t packet_ident;                       // PacketIdent
  int16_t ret_status;                         // ReturnStatus
  int16_t msg_number;                         // MessageNumber
  int16_t byte_count;                         // ByteCount
  int16_t packet_code;                        // PacketCode
  int16_t ack_last;                           // Union of Acknowledge and 
                                              // LastMsgNr
  int16_t data_index;                         // Structure of data_index and
  int16_t data_len;                           // data_len
} ixf_net_header_t;

typedef struct
{
  int16_t reserved;                            // filler for alignment
  int16_t typefield;                           // TypeField
  ixf_net_header_t h;                          // H
  unsigned char data[IXF_C_MAX_MP_DATA_LEN];   // CData
} ixf_net_t;

struct  descriptor_s
{
        unsigned short  len;
        unsigned char   type;   
        unsigned char   clas;   
        char            *s;
};


#define DSC$K_DTYPE_T 14
#define DSC$K_CLASS_S 1
#define DESCRIPTOR(name,str,length) { name.len = length; \
  name.type = DSC$K_DTYPE_T; \
  name.clas = DSC$K_CLASS_S; \
  name.s = str; }

#undef max
#define max(x,y) ((x) > (y) ? (x) : (y))

#undef min
#define min(x,y) ((x) < (y) ? (x) : (y))

/*
int h_get_reginfo( int node, char *proc, rs_reg_t *preg );
int h_get_reginfo_direct( int node, char *proc, rs_reg_t *pinfo );
int h_mark_reginfo_invalid( int node, char *proc );
*/

int ixf_sendme( char * buf,  int len );
int ixf_uv_intern( char *name );
int ixf_uv_cb ( char *adr, int type, UV_VALUE val, int cnt, void *userarg );
int ixf_add_cb ( char *path, char *file );
int ixf_rm_cb ( char *filepath );
int ixf_init_log(void);

/* netman.c */
int save_netman_packet( ix_net_t *pnet );

#endif

---