| 1643 | } |
| 1644 | |
| 1645 | BlockingReason Task::getSplitOrFuture( |
| 1646 | uint32_t splitGroupId, |
| 1647 | const core::PlanNodeId& planNodeId, |
| 1648 | exec::Split& split, |
| 1649 | ContinueFuture& future, |
| 1650 | int32_t maxPreloadSplits, |
| 1651 | std::function<void(std::shared_ptr<connector::ConnectorSplit>)> preload) { |
| 1652 | std::lock_guard<std::timed_mutex> l(mutex_); |
| 1653 | return getSplitOrFutureLocked( |
| 1654 | getPlanNodeSplitsStateLocked(planNodeId).groupSplitsStores[splitGroupId], |
| 1655 | split, |
| 1656 | future, |
| 1657 | maxPreloadSplits, |
| 1658 | preload); |
| 1659 | } |
| 1660 | |
| 1661 | BlockingReason Task::getSplitOrFutureLocked( |
| 1662 | SplitsStore& splitsStore, |
no outgoing calls
no test coverage detected