}
memset( ctx, 0, sizeof( *ctx ) );
+ ctx->snarf_rt_fd = -1;
return ctx;
}
if( ctx == NULL ) {
return NULL;
}
-
memset( ctx, 0, sizeof( *ctx ) );
-
+
+ ctx->ephash = rmr_sym_alloc( 129 );
+
ctx->mring = uta_mk_ring( 4096 ); // message ring is always on for si
ctx->zcb_mring = uta_mk_ring( 128 ); // zero copy buffer mbuf ring to reduce malloc/free calls
ctx->si_ctx = malloc( 1024 );
+ ctx->my_name = strdup( "hostname1" );
+ ctx->my_ip = strdup( "123.45.67.89" );
+ ctx->snarf_rt_fd = -1;
+
+ ctx->rtgate = (pthread_mutex_t *) malloc( sizeof( *ctx->rtgate ) );
+ if( ctx->rtgate != NULL ) {
+ pthread_mutex_init( ctx->rtgate, NULL );
+ }
+
return ctx;
}