mirror of
https://gitlab.isc.org/isc-projects/kea
synced 2025-08-31 14:05:33 +00:00
[#1239] make http client ConnectionPool thread safe
This commit is contained in:
@@ -385,7 +385,7 @@ public:
|
|||||||
std::lock_guard<std::mutex> lk(mutex_);
|
std::lock_guard<std::mutex> lk(mutex_);
|
||||||
return (queueRequestInternal(url, request, response,
|
return (queueRequestInternal(url, request, response,
|
||||||
request_timeout, request_callback,
|
request_timeout, request_callback,
|
||||||
connect_callback, close_callback));
|
connect_callback, close_callback));
|
||||||
} else {
|
} else {
|
||||||
return (queueRequestInternal(url, request, response,
|
return (queueRequestInternal(url, request, response,
|
||||||
request_timeout, request_callback,
|
request_timeout, request_callback,
|
||||||
@@ -432,9 +432,9 @@ public:
|
|||||||
void closeIfOutOfBandwidth(int socket_fd) {
|
void closeIfOutOfBandwidth(int socket_fd) {
|
||||||
if (MultiThreadingMgr::instance().getMode()) {
|
if (MultiThreadingMgr::instance().getMode()) {
|
||||||
std::lock_guard<std::mutex> lk(mutex_);
|
std::lock_guard<std::mutex> lk(mutex_);
|
||||||
closeIfOutOfBandwidth(socket_fd);
|
closeIfOutOfBandwidthInternal(socket_fd);
|
||||||
} else {
|
} else {
|
||||||
closeIfOutOfBandwidth(socket_fd);
|
closeIfOutOfBandwidthInternal(socket_fd);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user