#include "rmr.h" // we use some of rmr defs in building dummy messages, so we need these
#include "rmr_agnostic.h"
-// ---------------------- emulated nng functions ---------------------------
+// ---------------------- emulated SI95 functions ---------------------------
#ifndef _em_si // this is the same define as the nng emulation code uses to give warning if both included
#include "test_common_em.c" // common emulation needed for all (epoll, gethostname...)
+// --- some globals --------------------------------------------------------
+int em_reset_call_flag = 0; // allows a send to turn off the call flag (see em_disable_call_flg())
+
+// ------------- emulated message header -----------------------------------
+
+/*
+ This is a copy from agnostic.h. we need to reset flags in some situations
+ so we have to have this, under a different name to avoid disaster.
+*/
+typedef struct {
+ int32_t mtype; // message type ("long" network integer)
+ int32_t plen; // payload length (sender data length in payload)
+ int32_t rmr_ver; // our internal message version number
+ unsigned char xid[RMR_MAX_XID]; // space for user transaction id or somesuch
+ unsigned char sid[RMR_MAX_SID]; // sender ID for return to sender needs
+ unsigned char src[RMR_MAX_SRC]; // name:port of the sender (source)
+ unsigned char meid[RMR_MAX_MEID]; // managed element id.
+ struct timespec ts; // timestamp ???
+
+ // V2 extension
+ int32_t flags; // HFL_* constants
+ int32_t len0; // length of the RMr header data
+ int32_t len1; // length of the tracing data
+ int32_t len2; // length of data 1 (d1)
+ int32_t len3; // length of data 2 (d2)
+ int32_t sub_id; // subscription id (-1 invalid)
+
+ // v3 extension
+ unsigned char srcip[RMR_MAX_SRC]; // ip address and port of the source
+} em_mhdr_t;
+
//--------------------------------------------------------------------------
/*
These are the current references in the RMR code; all others are internal
void *em_cb_data = NULL;
static void em_sicbreg( struct ginfo_blk *gptr, int type, int ((*fptr)()), void * dptr ) {
if( em_cb_data == NULL ) {
- fprintf( stderr, "<SIEM> calldback dptr saved for type %d\n", type );
+ fprintf( stderr, "<SIEM> calldback dptr %p saved for type %d\n", dptr, type );
em_cb_data = dptr;
}
return;
/*
If em_send_failures is true, this will fail a small part of the time
to simualte connection failures.
+
+ If the port number is < 1000 it will fail -- allowing for specific,single
+ failure cases.
*/
static int em_next_fd = 0;
static int em_siconnect( struct ginfo_blk *gptr, char *abuf ) {
static int count = 0;
+ char* tok;
if( em_send_failures && (count++ % 15 == 14) ) {
//fprintf( stderr, "<SIEM> siem is failing connect attempt\n\n" );
return -1;
}
- fprintf( stderr, "<SIEM> siem is emulating connect attempt return fd=%d\n", em_next_fd );
- em_next_fd++;
+ if( (tok = strchr( abuf, ':' )) != NULL && atoi( tok+1 ) < 1000 ) {
+ fprintf( stderr, "<SIEM> siem is emulating connect to (%s) with a failure; port <1000\n", abuf );
+ return -1;
+ }
+
+ fprintf( stderr, "<SIEM> siem is emulating connect to (%s) attempt return fd=%d\n", abuf, em_next_fd );
+ if( em_next_fd < 50 ) {
+ em_next_fd++;
+ }
return em_next_fd-1;
}
return 0;
}
-static struct tp_blk *em_silisten_prep( struct ginfo_blk *gptr, int type, char* abuf, int family ) {
+static struct tp_blk *em_silisten_prep( int type, char* abuf, int family ) {
return NULL;
}
return;
}
+/*
+ Calling this function causes the send emulation to turn off the call
+ flag in the RMR header. Turning that flag off makes the arriving message
+ look as though it might be a response to a call rather than a call itself.
+ This is needed since we loop back messages.
+*/
+static void em_disable_call_flg() {
+ em_reset_call_flag = 1;
+ fprintf( stderr, "<SIEM> reset call flag setting is: %d\n", em_reset_call_flag );
+}
+
+/*
+ Opposite of disable_call_flg; the flag is not touched.
+*/
+static void em_allow_call_flg() {
+ em_reset_call_flag = 0;
+ fprintf( stderr, "<SIEM> reset call flag setting is: %d\n", em_reset_call_flag );
+}
+
// callback prototype to drive to simulate 'receive'
static int mt_data_cb( void* datap, int fd, char* buf, int buflen );
+
/*
Emulate sending a message. If the global em_send_failures is set,
then every so often we fail with an EAGAIN to drive that part
return SIEM_BLOCKED;
}
+ if( em_reset_call_flag ) { // for call testing we need to flip the flag off to see it "return"
+ em_mhdr_t* hdr;
+
+ hdr = (em_mhdr_t *) (ubuf+50); // past the transport header bytes
+ hdr->flags &= ~HFL_CALL_MSG; // flip off the call flag
+ }
+
uss++;
if( em_cb_data != NULL ) {
Code Review / ric-plt / lib / rmr.git / blobdiff