This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/arrow-nanoarrow.git
The following commit(s) were added to refs/heads/main by this push:
new 705dc5d ipc: Update dist/ for commit
373744c299d4df8a38cfe745724cbfe4f062d9c5
705dc5d is described below
commit 705dc5d4190cab261d915861f7c43e241711bd16
Author: GitHub Actions <[email protected]>
AuthorDate: Mon Mar 27 18:23:44 2023 +0000
ipc: Update dist/ for commit 373744c299d4df8a38cfe745724cbfe4f062d9c5
---
dist/nanoarrow_ipc.c | 10 ++--------
1 file changed, 2 insertions(+), 8 deletions(-)
diff --git a/dist/nanoarrow_ipc.c b/dist/nanoarrow_ipc.c
index 07a9b2e..c783dcb 100644
--- a/dist/nanoarrow_ipc.c
+++ b/dist/nanoarrow_ipc.c
@@ -22021,12 +22021,6 @@ static int ArrowIpcArrayStreamReaderGetNext(struct
ArrowArrayStream* stream,
struct ArrowArray* out) {
struct ArrowIpcArrayStreamReaderPrivate* private_data =
(struct ArrowIpcArrayStreamReaderPrivate*)stream->private_data;
- // Check if we are all done
- if (private_data->input.release == NULL) {
- out->release = NULL;
- return NANOARROW_OK;
- }
-
private_data->error.message[0] = '\0';
NANOARROW_RETURN_NOT_OK(ArrowIpcArrayStreamReaderReadSchemaIfNeeded(private_data));
@@ -22034,8 +22028,8 @@ static int ArrowIpcArrayStreamReaderGetNext(struct
ArrowArrayStream* stream,
int result = ArrowIpcArrayStreamReaderNextHeader(
private_data, NANOARROW_IPC_MESSAGE_TYPE_RECORD_BATCH);
if (result == ENODATA) {
- // If the stream is finished, release the input
- private_data->input.release(&private_data->input);
+ // Stream is finished either because there is no input or because
+ // end of stream bytes were read.
out->release = NULL;
return NANOARROW_OK;
}