| 93 | } |
| 94 | |
| 95 | void socket_engine_base::inplace_modify_fd(dpp::socket fd, uint8_t extra_flags) { |
| 96 | bool should_modify; |
| 97 | socket_events s{}; |
| 98 | { |
| 99 | std::lock_guard lk(fds_mutex); |
| 100 | auto i = fds.find(fd); |
| 101 | should_modify = i != fds.end() && (i->second->flags & extra_flags) != extra_flags; |
| 102 | if (should_modify) { |
| 103 | i->second->flags |= extra_flags; |
| 104 | s = *(i->second); |
| 105 | } |
| 106 | } |
| 107 | if (should_modify) { |
| 108 | update_socket(s); |
| 109 | } |
| 110 | } |
| 111 | |
| 112 | void socket_engine_base::prune() { |
| 113 | if (time(nullptr) != last_time) { |
no test coverage detected