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.