| 136 | } |
| 137 | |
| 138 | void Connectable::notifyWork() { |
| 139 | // Do nothing if we are not event-driven |
| 140 | if (strategy_ != EVENT_DRIVEN) { |
| 141 | return; |
| 142 | } |
| 143 | |
| 144 | { |
| 145 | has_work_.store(isWorkAvailable()); |
| 146 | |
| 147 | if (has_work_.load()) { |
| 148 | work_condition_.notify_one(); |
| 149 | } |
| 150 | } |
| 151 | } |
| 152 | |
| 153 | std::set<std::shared_ptr<Connectable>> Connectable::getOutGoingConnections(const std::string &relationship) const { |
| 154 | std::set<std::shared_ptr<Connectable>> empty; |