From d292162b00e8b7d631b9a05b60ffc093575a4f4f Mon Sep 17 00:00:00 2001 From: Tyler Neely Date: Wed, 17 Aug 2022 16:40:18 +0000 Subject: [PATCH] Use new RsmClient in raft test --- tests/simulation/raft.cpp | 18 ++++++++---------- 1 file changed, 8 insertions(+), 10 deletions(-) diff --git a/tests/simulation/raft.cpp b/tests/simulation/raft.cpp index 4216d3b79..8928f7300 100644 --- a/tests/simulation/raft.cpp +++ b/tests/simulation/raft.cpp @@ -187,13 +187,12 @@ void RunSimulation() { cas_req.new_value = i; - auto write_cas_response_opt = client.SendWriteRequest(cas_req); - if (!write_cas_response_opt) { + auto write_cas_response_result = client.SendWriteRequest(cas_req); + if (write_cas_response_result.HasError()) { + // timed out continue; } - auto write_cas_response = write_cas_response_opt.value(); - - CasResponse cas_response = write_cas_response.write_return; + CasResponse cas_response = write_cas_response_result.GetValue(); bool cas_succeeded = cas_response.cas_success; @@ -213,13 +212,12 @@ void RunSimulation() { GetRequest get_req; get_req.key = key; - auto read_get_response_opt = client.SendReadRequest(get_req); - if (!read_get_response_opt) { + auto read_get_response_result = client.SendReadRequest(get_req); + if (read_get_response_result.HasError()) { + // timed out continue; } - auto read_get_response = read_get_response_opt.value(); - - GetResponse get_response = read_get_response.read_return; + GetResponse get_response = read_get_response_result.GetValue(); MG_ASSERT(get_response.value == i);