aboutsummaryrefslogtreecommitdiffstats
path: root/fnet/src/tests/frt
diff options
context:
space:
mode:
authorHåvard Pettersen <havardpe@yahooinc.com>2022-05-23 14:48:13 +0000
committerHåvard Pettersen <havardpe@yahooinc.com>2022-05-23 14:48:13 +0000
commit5e762977b910c78ec939a6708354a3dc56484968 (patch)
treec51713f74cd039f7de2379a24e3626f30f00e44e /fnet/src/tests/frt
parentb5ed98198b96556e6be40604f8ab93b54c71e645 (diff)
avoid calling function on nullptr
Diffstat (limited to 'fnet/src/tests/frt')
-rw-r--r--fnet/src/tests/frt/detach_supervisor/detach_supervisor_test.cpp14
1 files changed, 7 insertions, 7 deletions
diff --git a/fnet/src/tests/frt/detach_supervisor/detach_supervisor_test.cpp b/fnet/src/tests/frt/detach_supervisor/detach_supervisor_test.cpp
index 953b2e7432e..3207094e56d 100644
--- a/fnet/src/tests/frt/detach_supervisor/detach_supervisor_test.cpp
+++ b/fnet/src/tests/frt/detach_supervisor/detach_supervisor_test.cpp
@@ -75,7 +75,7 @@ struct RpcFixture : FRT_Invokable {
req->SubRef();
return target;
};
- int check_result(FRT_RPCRequest *req, uint64_t expect) {
+ static int check_result(FRT_RPCRequest *req, uint64_t expect) {
int num_ok = 0;
if (!req->CheckReturnTypes("l")) {
ASSERT_EQUAL(req->GetErrorCode(), FRTE_RPC_CONNECTION);
@@ -87,15 +87,15 @@ struct RpcFixture : FRT_Invokable {
req->SubRef();
return num_ok;
}
- int verify_rpc(FNET_Connection *conn) {
- auto *req = orb.AllocRPCRequest();
+ static int verify_rpc(FNET_Connection *conn) {
+ auto *req = FRT_Supervisor::AllocRPCRequest();
req->SetMethodName("inc");
req->GetParams()->AddInt64(7);
FRT_Supervisor::InvokeSync(conn->Owner()->GetScheduler(), conn, req, 300.0);
return check_result(req, 8);
}
- int verify_rpc(FRT_Target *target) {
- auto *req = orb.AllocRPCRequest();
+ static int verify_rpc(FRT_Target *target) {
+ auto *req = FRT_Supervisor::AllocRPCRequest();
req->SetMethodName("inc");
req->GetParams()->AddInt64(4);
target->InvokeSync(req, 300.0);
@@ -135,8 +135,8 @@ TEST_MT_FFFFF("require that supervisor can be detached from transport", 4, Basic
std::this_thread::sleep_for(50ms);
self.reset(); // <--- detach supervisor for server 1
TEST_BARRIER(); // #4
- EXPECT_EQUAL(self->verify_rpc(target), 0); // outgoing 2way target should be closed
- EXPECT_EQUAL(self->verify_rpc(client_target), 1); // pure client target should not be closed
+ EXPECT_EQUAL(RpcFixture::verify_rpc(target), 0); // outgoing 2way target should be closed
+ EXPECT_EQUAL(RpcFixture::verify_rpc(client_target), 1); // pure client target should not be closed
TEST_BARRIER(); // #5
target->SubRef();
client_target->SubRef();