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

Posted to jira@arrow.apache.org by "Weston Pace (Jira)" <ji...@apache.org> on 2022/11/14 16:41:00 UTC

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

     [ https://issues.apache.org/jira/browse/ARROW-18310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Weston Pace resolved ARROW-18310.
---------------------------------
    Resolution: Fixed

Issue resolved by pull request 14622
[https://github.com/apache/arrow/pull/14622]

> [C++] Use atomic backpressure counter
> -------------------------------------
>
>                 Key: ARROW-18310
>                 URL: https://issues.apache.org/jira/browse/ARROW-18310
>             Project: Apache Arrow
>          Issue Type: Bug
>          Components: C++
>            Reporter: Yaron Gvili
>            Assignee: Yaron Gvili
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 11.0.0, 10.0.1
>
>          Time Spent: 50m
>  Remaining Estimate: 0h
>
> 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)