#define _uta_private_h
// if pmode is off we don't compile in some checks in hopes of speeding things up
-#ifndef PARINOID_CHECKS
-# define PARINOID_CHECKS 0
+#ifndef PARANOID_CHECKS
+# define PARANOID_CHECKS 0
#endif
#define RF_NOTIFIED 0x01 // notification made about river issue
#define RF_DROP 0x02 // this message is large and being dropped
+#define TP_SZFIELD_LEN ((sizeof(uint32_t)*2)+1) // number of bytes needed for msg size in transport header
+#define TP_SZ_MARKER '$' // marker indicating net byte order used
+
+
#define SI_MAX_ADDR_LEN 512
/*
pthread_t rtc_th; // thread info for the rtc listener
pthread_t mtc_th; // thread info for the multi-thread call receive process
+ // added for route manager request/states
+ rmr_whid_t rtg_whid; // wormhole id to the route manager for acks/requests
+ char* table_id; // table ID of the route table load in progress
+
// added for SI95 support
si_ctx_t* si_ctx; // the socket context
int nrivers; // allocated rivers
river_t* rivers; // inbound flows (index is the socket fd)
int max_ibm; // max size of an inbound message (river accum alloc size)
void* zcb_mring; // zero copy buffer mbuf ring
- void* fd2ep; // the symtab mapping file des to endpoints for cleanup on disconnect
+ void* fd2ep; // the symtab mapping file des to endpoints for cleanup on disconnect
+ pthread_mutex_t *fd2ep_gate; // we must gate add/deletes to the fd2 symtab
};
typedef uta_ctx_t uta_ctx;
// --- rt table things ---------------------------
static void uta_ep_failed( endpoint_t* ep );
-static int uta_link2( si_ctx_t* si_ctx, endpoint_t* ep );
+static int uta_link2( uta_ctx_t *ctx, endpoint_t* ep );
+
static int rt_link2_ep( void* vctx, endpoint_t* ep );
static rtable_ent_t* uta_get_rte( route_table_t *rt, int sid, int mtype, int try_alt );
static inline int xlate_si_state( int state, int def_state );
static void ref_tpbuf( rmr_mbuf_t* msg, size_t alen ) ;
static inline rmr_mbuf_t* clone_msg( rmr_mbuf_t* old_msg );
static rmr_mbuf_t* rcv_msg( uta_ctx_t* ctx, rmr_mbuf_t* old_msg );
-static void* rcv_payload( uta_ctx_t* ctx, rmr_mbuf_t* old_msg );
static inline rmr_mbuf_t* realloc_msg( rmr_mbuf_t* old_msg, int tr_len );
static rmr_mbuf_t* send2ep( uta_ctx_t* ctx, endpoint_t* ep, rmr_mbuf_t* msg );