You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@arrow.apache.org by ro...@apache.org on 2018/04/12 22:41:04 UTC
[arrow] branch master updated: ARROW-2437: [C++] Add ReadMessage
without aligned argument.
This is an automated email from the ASF dual-hosted git repository.
robertnishihara pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/arrow.git
The following commit(s) were added to refs/heads/master by this push:
new 0f87c12 ARROW-2437: [C++] Add ReadMessage without aligned argument.
0f87c12 is described below
commit 0f87c12d45250ee763ac8c43b7e57e8f06a0b9f3
Author: Robert Nishihara <ro...@gmail.com>
AuthorDate: Thu Apr 12 15:40:55 2018 -0700
ARROW-2437: [C++] Add ReadMessage without aligned argument.
cc @xhochy
Author: Robert Nishihara <ro...@gmail.com>
Closes #1874 from robertnishihara/updatesignature and squashes the following commits:
6a10d5d <Robert Nishihara> Add ReadMessage without aligned argument.
---
cpp/src/arrow/ipc/message.cc | 3 +++
cpp/src/arrow/ipc/message.h | 9 ++++++++-
2 files changed, 11 insertions(+), 1 deletion(-)
diff --git a/cpp/src/arrow/ipc/message.cc b/cpp/src/arrow/ipc/message.cc
index 896221e..5173ae1 100644
--- a/cpp/src/arrow/ipc/message.cc
+++ b/cpp/src/arrow/ipc/message.cc
@@ -248,6 +248,9 @@ Status ReadMessage(io::InputStream* file, std::unique_ptr<Message>* message,
return Message::ReadFrom(metadata, file, message);
}
+Status ReadMessage(io::InputStream* file, std::unique_ptr<Message>* message) {
+ return ReadMessage(file, message, false /* aligned */);
+}
// ----------------------------------------------------------------------
// Implement InputStream message reader
diff --git a/cpp/src/arrow/ipc/message.h b/cpp/src/arrow/ipc/message.h
index 4e0089b..de195d4 100644
--- a/cpp/src/arrow/ipc/message.h
+++ b/cpp/src/arrow/ipc/message.h
@@ -183,7 +183,14 @@ Status ReadMessage(const int64_t offset, const int32_t metadata_length,
/// in a stream)
ARROW_EXPORT
Status ReadMessage(io::InputStream* stream, std::unique_ptr<Message>* message,
- bool aligned = false);
+ bool aligned);
+
+/// \brief Read encapulated RPC message (metadata and body) from InputStream.
+///
+/// This is a version of ReadMessage that does not have the aligned argument
+/// for backwards compatibility.
+ARROW_EXPORT
+Status ReadMessage(io::InputStream* stream, std::unique_ptr<Message>* message);
} // namespace ipc
} // namespace arrow
--
To stop receiving notification emails like this one, please contact
robertnishihara@apache.org.