tursom/memgraph
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Use new RsmClient in raft test

Browse Source
This commit is contained in:
Tyler Neely 2022-08-17 16:40:18 +00:00
parent 9c4556618a
commit d292162b00
1 changed files with 8 additions and 10 deletions

18
tests/simulation/raft.cpp
View File

@ -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);