blob: 46bb0a440466e446dfc2bbb1fcd39f762e6e6da9 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
--- src/snowflake/connector/nanoarrow_cpp/ArrowIterator/nanoarrow_ipc.c.orig 2023-11-30 19:17:00 UTC
+++ src/snowflake/connector/nanoarrow_cpp/ArrowIterator/nanoarrow_ipc.c
@@ -21239,7 +21239,7 @@ static inline int ArrowIpcDecoderReadHeaderPrefix(stru
if (header_body_size_bytes == 0) {
ArrowErrorSet(error, "End of Arrow stream");
- return ENODATA;
+ return ENOATTR;
}
return NANOARROW_OK;
@@ -22194,7 +22194,7 @@ static int ArrowIpcArrayStreamReaderNextHeader(
// is one of the valid outcomes) but we set the error anyway in case it gets
// propagated higher (e.g., if the stream is empty and there's no schema message)
ArrowErrorSet(&private_data->error, "No data available on stream");
- return ENODATA;
+ return ENOATTR;
} else if (bytes_read != 8) {
ArrowErrorSet(&private_data->error,
"Expected at least 8 bytes in remainder of stream");
@@ -22338,7 +22338,7 @@ static int ArrowIpcArrayStreamReaderGetNext(struct Arr
// Read + decode the next header
int result = ArrowIpcArrayStreamReaderNextHeader(
private_data, NANOARROW_IPC_MESSAGE_TYPE_RECORD_BATCH);
- if (result == ENODATA) {
+ if (result == ENOATTR) {
// Stream is finished either because there is no input or because
// end of stream bytes were read.
out->release = NULL;
|