Yaron Gvili created ARROW-18310:
-----------------------------------
Summary: [C++] Use atomic backpressure counter
Key: ARROW-18310
URL: https://issues.apache.org/jira/browse/ARROW-18310
Project: Apache Arrow
Issue Type: Improvement
Components: C++
Reporter: Yaron Gvili
There are a few places in the code (sink_node.cc, source_node.cc, file_base.cc)
where the backpressure counter is of type `int32_t`. This prevents
`ExecNode::Pause(...)` and `ExecNode::Resume(...)` from being thread-safe. The
proposal is to make these backpressure counters be of type
`std::atomic<int32_t>`.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)