From d3b2147e9d7c99ee7b79a9fe0be999287e07b744 Mon Sep 17 00:00:00 2001 From: Cristian Ferretti <37232625+jcferretti@users.noreply.github.com> Date: Tue, 5 Sep 2023 11:35:25 -0400 Subject: [PATCH] Update R client to some macro renaming in C++ client. (#4439) --- R/rdeephaven/src/client.cpp | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/R/rdeephaven/src/client.cpp b/R/rdeephaven/src/client.cpp index ea0c15f6dea..ff0076234c8 100644 --- a/R/rdeephaven/src/client.cpp +++ b/R/rdeephaven/src/client.cpp @@ -288,7 +288,7 @@ class TableHandleWrapper { std::shared_ptr fsr = internal_tbl_hdl.GetFlightStreamReader(); std::vector> empty_record_batches; - deephaven::client::utility::OkOrThrow(DEEPHAVEN_EXPR_MSG(fsr->ReadAll(&empty_record_batches))); + deephaven::client::utility::OkOrThrow(DEEPHAVEN_LOCATION_EXPR(fsr->ReadAll(&empty_record_batches))); std::shared_ptr record_batch_reader = arrow::RecordBatchReader::Make(empty_record_batches).ValueOrDie(); ArrowArrayStream* stream_ptr = new ArrowArrayStream(); @@ -438,17 +438,17 @@ class ClientWrapper { auto ticket = internal_tbl_hdl_mngr.NewTicket(); auto fd = deephaven::client::utility::ConvertTicketToFlightDescriptor(ticket); - deephaven::client::utility::OkOrThrow(DEEPHAVEN_EXPR_MSG(wrapper.FlightClient()->DoPut(options, fd, schema, &fsw, &fmr))); + deephaven::client::utility::OkOrThrow(DEEPHAVEN_LOCATION_EXPR(wrapper.FlightClient()->DoPut(options, fd, schema, &fsw, &fmr))); while(true) { std::shared_ptr this_batch; - deephaven::client::utility::OkOrThrow(DEEPHAVEN_EXPR_MSG(record_batch_reader->ReadNext(&this_batch))); + deephaven::client::utility::OkOrThrow(DEEPHAVEN_LOCATION_EXPR(record_batch_reader->ReadNext(&this_batch))); if (this_batch == nullptr) { break; } - deephaven::client::utility::OkOrThrow(DEEPHAVEN_EXPR_MSG(fsw->WriteRecordBatch(*this_batch))); + deephaven::client::utility::OkOrThrow(DEEPHAVEN_LOCATION_EXPR(fsw->WriteRecordBatch(*this_batch))); } - deephaven::client::utility::OkOrThrow(DEEPHAVEN_EXPR_MSG(fsw->DoneWriting())); - deephaven::client::utility::OkOrThrow(DEEPHAVEN_EXPR_MSG(fsw->Close())); + deephaven::client::utility::OkOrThrow(DEEPHAVEN_LOCATION_EXPR(fsw->DoneWriting())); + deephaven::client::utility::OkOrThrow(DEEPHAVEN_LOCATION_EXPR(fsw->Close())); auto new_tbl_hdl = internal_tbl_hdl_mngr.MakeTableHandleFromTicket(ticket); return new TableHandleWrapper(new_tbl_hdl);