Code Review
/
ric-plt
/
lib
/
rmr.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Add content type for long description for twine
[ric-plt/lib/rmr.git]
/
test
/
test_nng_em.c
diff --git
a/test/test_nng_em.c
b/test/test_nng_em.c
index
88f5966
..
8c6a9ca
100644
(file)
--- a/
test/test_nng_em.c
+++ b/
test/test_nng_em.c
@@
-320,10
+320,10
@@
static int em_nng_sub0_open(nng_socket * s ) {
return return_value;
}
static int em_nng_recv(nng_socket s, void * v, size_t * t, int i ) {
return return_value;
}
static int em_nng_recv(nng_socket s, void * v, size_t * t, int i ) {
-
return return_value;
}
static int em_nng_send( nng_socket s, void* m, int l, int f ) {
return return_value;
}
static int em_nng_send( nng_socket s, void* m, int l, int f ) {
+ free( m ); // we must ditch the message as nng does (or reuses)
return return_value;
}
return return_value;
}
@@
-365,13
+365,11
@@
static int em_nng_msg_alloc( nng_msg** mp, size_t l ) {
*/
static void em_nng_free( void* p, size_t l ) {
if( p ) {
*/
static void em_nng_free( void* p, size_t l ) {
if( p ) {
- //fprintf( stderr, ">>>>> not freed: %p\n", p );
free( p );
}
}
static void em_nng_msg_free( void* p ) {
if( p ) {
free( p );
}
}
static void em_nng_msg_free( void* p ) {
if( p ) {
- //fprintf( stderr, ">>>>> not freed: %p\n", p );
free( p );
}
}
free( p );
}
}
@@
-542,6
+540,7
@@
static int em_nn_recvmsg (int s, struct nn_msghdr *msghdr, int flags ) {
}
static void em_nn_freemsg( void* ptr ) {
}
static void em_nn_freemsg( void* ptr ) {
+ free( ptr );
return;
}
return;
}