| 500 | } |
| 501 | |
| 502 | void local_endpoint::receive_cbk(boost::system::error_code const& _ec, size_t _bytes) { |
| 503 | if (_ec) { |
| 504 | VSOMEIP_WARNING_P << "Escalating the error: " << _ec.message() << " socket > " << status(); |
| 505 | if (_ec != boost::asio::error::operation_aborted) { |
| 506 | escalate(); |
| 507 | } |
| 508 | return; |
| 509 | } |
| 510 | if (std::unique_lock lock{mutex_}; !process(_bytes, lock)) { |
| 511 | escalate_internal(lock); |
| 512 | } |
| 513 | } |
| 514 | |
| 515 | bool local_endpoint::is_allowed() { |
| 516 | auto end = [&] { |