| 224 | } |
| 225 | |
| 226 | bool Processor::flowFilesOutGoingFull() { |
| 227 | std::lock_guard<std::mutex> lock(mutex_); |
| 228 | |
| 229 | for (const auto& connection_pair : out_going_connections_) { |
| 230 | // We already has connection for this relationship |
| 231 | std::set<std::shared_ptr<Connectable>> existedConnection = connection_pair.second; |
| 232 | const bool has_full_connection = std::any_of(begin(existedConnection), end(existedConnection), [](const std::shared_ptr<Connectable>& conn) { |
| 233 | auto connection = std::dynamic_pointer_cast<Connection>(conn); |
| 234 | return connection && connection->isFull(); |
| 235 | }); |
| 236 | if (has_full_connection) { return true; } |
| 237 | } |
| 238 | |
| 239 | return false; |
| 240 | } |
| 241 | |
| 242 | void Processor::onTrigger(ProcessContext *context, ProcessSessionFactory *sessionFactory) { |
| 243 | auto session = sessionFactory->createSession(); |
no test coverage detected