You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@arrow.apache.org by "Yaron Gvili (Jira)" <ji...@apache.org> on 2022/11/11 08:32:00 UTC

[jira] [Created] (ARROW-18310) [C++] Use atomic backpressure counter

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)