This is an automated email from the ASF dual-hosted git repository. apitrou pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/arrow.git.
from 7301f68 ARROW-11560: [C++][FlightRPC] fix mutex error on SIGINT add 79ae4f6 ARROW-8732: [C++] Add basic cancellation API No new revisions were added by this update. Summary of changes: cpp/src/arrow/CMakeLists.txt | 1 + cpp/src/arrow/csv/reader.cc | 64 +++++-- cpp/src/arrow/csv/reader.h | 7 +- cpp/src/arrow/dataset/file_csv.cc | 5 +- cpp/src/arrow/io/interfaces.cc | 3 +- cpp/src/arrow/io/interfaces.h | 27 ++- cpp/src/arrow/status.cc | 3 + cpp/src/arrow/status.h | 9 + cpp/src/arrow/testing/gtest_util.cc | 25 +++ cpp/src/arrow/testing/gtest_util.h | 22 +++ cpp/src/arrow/util/CMakeLists.txt | 7 +- cpp/src/arrow/util/cancel.cc | 226 ++++++++++++++++++++++++ cpp/src/arrow/util/cancel.h | 102 +++++++++++ cpp/src/arrow/util/cancel_test.cc | 308 +++++++++++++++++++++++++++++++++ cpp/src/arrow/util/io_util.cc | 65 +++++++ cpp/src/arrow/util/io_util.h | 36 ++++ cpp/src/arrow/util/io_util_test.cc | 73 ++++++++ cpp/src/arrow/util/task_group.cc | 70 ++++++-- cpp/src/arrow/util/task_group.h | 10 +- cpp/src/arrow/util/task_group_test.cc | 57 ++++++ cpp/src/arrow/util/thread_pool.cc | 32 +++- cpp/src/arrow/util/thread_pool.h | 59 +++++-- cpp/src/arrow/util/thread_pool_test.cc | 196 +++++++++++++++------ python/pyarrow/__init__.py | 6 +- python/pyarrow/_csv.pyx | 35 ++-- python/pyarrow/error.pxi | 109 ++++++++++++ python/pyarrow/includes/common.pxd | 1 + python/pyarrow/includes/libarrow.pxd | 24 ++- python/pyarrow/lib.pxd | 8 + python/pyarrow/tests/test_csv.py | 35 ++++ 30 files changed, 1491 insertions(+), 134 deletions(-) create mode 100644 cpp/src/arrow/util/cancel.cc create mode 100644 cpp/src/arrow/util/cancel.h create mode 100644 cpp/src/arrow/util/cancel_test.cc