+
+/*
+ Always successful if a message was passed in.
+*/
+extern rmr_mbuf_t* RMR_rts_msg( void* ctx, rmr_mbuf_t* msg ) {
+ if( msg != NULL ) {
+ msg->state = 0;
+ }
+
+ return msg;
+}
+
+/*
+ Generates "short" reads 9 out of 10 times so that we can
+ drive the buffer construction code that otherwise wouldn't
+ be driven since long reads are usually the case.
+*/
+extern int Read( int fd, char* dest, int max ) {
+ static int count = -1;
+
+ count++;
+
+ if( count % 10 ) {
+ return read( fd, dest, max ); // return long read
+ }
+
+ return read( fd, dest, 3 ); // short read
+}
+
+// ----------- defines that point included code here --------------------
+#define rmr_torcv_msg RMR_torcv_msg
+#define rmr_rts_msg RMR_rts_msg
+#define read Read