mirror of
https://gitlab.isc.org/isc-projects/kea
synced 2025-09-02 15:05:16 +00:00
[master] Merge branch 'trac5336'
This commit is contained in:
@@ -213,9 +213,11 @@ UnixDomainSocketImpl::sendHandler(const UnixDomainSocket::Handler& remote_handle
|
|||||||
if ((ec.value() == boost::asio::error::would_block) ||
|
if ((ec.value() == boost::asio::error::would_block) ||
|
||||||
(ec.value() == boost::asio::error::try_again)) {
|
(ec.value() == boost::asio::error::try_again)) {
|
||||||
doSend(buffer, remote_handler);
|
doSend(buffer, remote_handler);
|
||||||
}
|
|
||||||
|
} else {
|
||||||
remote_handler(ec, length);
|
remote_handler(ec, length);
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
void
|
void
|
||||||
UnixDomainSocketImpl::asyncReceive(void* data, const size_t length,
|
UnixDomainSocketImpl::asyncReceive(void* data, const size_t length,
|
||||||
@@ -246,9 +248,11 @@ UnixDomainSocketImpl::receiveHandler(const UnixDomainSocket::Handler& remote_han
|
|||||||
if ((ec.value() == boost::asio::error::would_block) ||
|
if ((ec.value() == boost::asio::error::would_block) ||
|
||||||
(ec.value() == boost::asio::error::try_again)) {
|
(ec.value() == boost::asio::error::try_again)) {
|
||||||
doReceive(buffer, remote_handler);
|
doReceive(buffer, remote_handler);
|
||||||
}
|
|
||||||
|
} else {
|
||||||
remote_handler(ec, length);
|
remote_handler(ec, length);
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
void
|
void
|
||||||
UnixDomainSocketImpl::shutdown() {
|
UnixDomainSocketImpl::shutdown() {
|
||||||
|
Reference in New Issue
Block a user