diff --git a/tests/perf/ping_pong.cc b/tests/perf/ping_pong.cc index 38973357b2..c008553a52 100644 --- a/tests/perf/ping_pong.cc +++ b/tests/perf/ping_pong.cc @@ -105,7 +105,7 @@ static void finishedPing(FinishedPingMsg* msg) { if (num_bytes != max_bytes) { auto pmsg = makeMessage>(); - theMsg()->sendMsg, pingPong>( + theMsg()->sendMsg, pingPong>( pong_node, pmsg.get() ); } @@ -133,7 +133,7 @@ static void pingPong(PingMsg* in_msg) { if (cnt >= num_pings) { auto msg = makeMessage>(num_bytes); - theMsg()->sendMsg, finishedPing>( + theMsg()->sendMsg, finishedPing>( 0, msg.get() ); } else { @@ -141,12 +141,12 @@ static void pingPong(PingMsg* in_msg) { theContext()->getNode() == ping_node ? pong_node : ping_node; #if REUSE_MESSAGE_PING_PONG // @todo: fix this memory allocation problem - theMsg()->sendMsg, pingPong>( + theMsg()->sendMsg, pingPong>( next, in_msg, [=]{ /*delete in_msg;*/ } ); #else auto m = makeMessage>(cnt + 1); - theMsg()->sendMsg, pingPong>(next, m.get()); + theMsg()->sendMsg, pingPong>(next, m.get()); #endif } } @@ -169,7 +169,7 @@ int main(int argc, char** argv) { if (my_node == 0) { auto m = makeMessage>(); - theMsg()->sendMsg, pingPong>(pong_node, m.get()); + theMsg()->sendMsg, pingPong>(pong_node, m.get()); } while (!rt->isTerminated()) { diff --git a/tests/unit/pool/test_pool_message_sizes.cc b/tests/unit/pool/test_pool_message_sizes.cc index 2a616eee9a..a887502a91 100644 --- a/tests/unit/pool/test_pool_message_sizes.cc +++ b/tests/unit/pool/test_pool_message_sizes.cc @@ -102,12 +102,12 @@ void TestPoolMessageSizes::testPoolFun(TestMsg* prev_msg) { if (count < max_test_count) { auto msg = makeMessage>(); - theMsg()->sendMsg, testPoolFun>( + theMsg()->sendMsg, testPoolFun>( next, msg.get() ); } else { auto msg = makeMessage>(); - theMsg()->sendMsg, testPoolFun>( + theMsg()->sendMsg, testPoolFun>( next, msg.get() ); count = 0;