| 959 | } |
| 960 | |
| 961 | bool ProcessSession::outgoingConnectionsFull(const std::string& relationship) { |
| 962 | std::set<std::shared_ptr<Connectable>> connections = process_context_->getProcessorNode()->getOutGoingConnections(relationship); |
| 963 | Connection * connection = nullptr; |
| 964 | for (const auto& conn : connections) { |
| 965 | connection = dynamic_cast<Connection*>(conn.get()); |
| 966 | if (connection && connection->isFull()) { |
| 967 | return true; |
| 968 | } |
| 969 | } |
| 970 | return false; |
| 971 | } |
| 972 | |
| 973 | bool ProcessSession::existsFlowFileInRelationship(const Relationship &relationship) { |
| 974 | return std::any_of(_transferRelationship.begin(), _transferRelationship.end(), |
no test coverage detected