| 260 | } |
| 261 | |
| 262 | void udp_server_endpoint_impl::stop_unlocked() { |
| 263 | // The caller must hold the lock |
| 264 | |
| 265 | if (is_stopped_) { |
| 266 | VSOMEIP_INFO_P << instance_name_ << "Already stopped"; |
| 267 | return; |
| 268 | } |
| 269 | |
| 270 | lifecycle_idx_ += 1; |
| 271 | multicast_lifecycle_idx_ += 1; |
| 272 | is_stopped_ = true; |
| 273 | |
| 274 | unicast_socket_.reset(); |
| 275 | multicast_socket_.reset(); |
| 276 | tp_reassembler_->stop(); |
| 277 | } |
| 278 | |
| 279 | void udp_server_endpoint_impl::receive_unicast_unlocked(std::shared_ptr<message_buffer_t> _unicast_recv_buffer) { |
| 280 | // The caller must hold the lock |