| 118 | } |
| 119 | |
| 120 | bool Connection::isFull() { |
| 121 | std::lock_guard<std::mutex> lock(mutex_); |
| 122 | |
| 123 | if (max_queue_size_ <= 0 && max_data_queue_size_ <= 0) |
| 124 | // No back pressure setting |
| 125 | return false; |
| 126 | |
| 127 | if (max_queue_size_ > 0 && queue_.size() >= max_queue_size_) |
| 128 | return true; |
| 129 | |
| 130 | if (max_data_queue_size_ > 0 && queued_data_size_ >= max_data_queue_size_) |
| 131 | return true; |
| 132 | |
| 133 | return false; |
| 134 | } |
| 135 | |
| 136 | void Connection::put(const std::shared_ptr<core::FlowFile>& flow) { |
| 137 | if (drop_empty_ && flow->getSize() == 0) { |
no test coverage detected