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)