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
