(client) internal IXDNSLookup class requires a valid cancellation request function callback to be passed in
This commit is contained in:
parent
d82e05f72d
commit
6b98694caa
@ -1 +1 @@
|
|||||||
7.4.1
|
7.4.2
|
||||||
|
@ -1,6 +1,10 @@
|
|||||||
# Changelog
|
# Changelog
|
||||||
All notable changes to this project will be documented in this file.
|
All notable changes to this project will be documented in this file.
|
||||||
|
|
||||||
|
## [7.4.2] - 2019-12-02
|
||||||
|
|
||||||
|
- (client) internal IXDNSLookup class requires a valid cancellation request function callback to be passed in
|
||||||
|
|
||||||
## [7.4.1] - 2019-12-02
|
## [7.4.1] - 2019-12-02
|
||||||
|
|
||||||
- (client) fix an overflow in the exponential back off code
|
- (client) fix an overflow in the exponential back off code
|
||||||
|
@ -29,8 +29,13 @@ namespace ix
|
|||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
CancellationRequest cancellationRequest = []() -> bool
|
||||||
|
{
|
||||||
|
return false;
|
||||||
|
};
|
||||||
|
|
||||||
std::string errMsg;
|
std::string errMsg;
|
||||||
return _socket->connect(hostname, port, errMsg, nullptr);
|
return _socket->connect(hostname, port, errMsg, cancellationRequest);
|
||||||
}
|
}
|
||||||
|
|
||||||
void RedisClient::stop()
|
void RedisClient::stop()
|
||||||
|
@ -61,7 +61,7 @@ namespace ix
|
|||||||
errMsg = "no error";
|
errMsg = "no error";
|
||||||
|
|
||||||
// Maybe a cancellation request got in before the background thread terminated ?
|
// Maybe a cancellation request got in before the background thread terminated ?
|
||||||
if (isCancellationRequested && isCancellationRequested())
|
if (isCancellationRequested())
|
||||||
{
|
{
|
||||||
errMsg = "cancellation requested";
|
errMsg = "cancellation requested";
|
||||||
return nullptr;
|
return nullptr;
|
||||||
@ -107,7 +107,7 @@ namespace ix
|
|||||||
std::this_thread::sleep_for(std::chrono::milliseconds(_wait));
|
std::this_thread::sleep_for(std::chrono::milliseconds(_wait));
|
||||||
|
|
||||||
// Were we cancelled ?
|
// Were we cancelled ?
|
||||||
if (isCancellationRequested && isCancellationRequested())
|
if (isCancellationRequested())
|
||||||
{
|
{
|
||||||
errMsg = "cancellation requested";
|
errMsg = "cancellation requested";
|
||||||
return nullptr;
|
return nullptr;
|
||||||
@ -115,7 +115,7 @@ namespace ix
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Maybe a cancellation request got in before the bg terminated ?
|
// Maybe a cancellation request got in before the bg terminated ?
|
||||||
if (isCancellationRequested && isCancellationRequested())
|
if (isCancellationRequested())
|
||||||
{
|
{
|
||||||
errMsg = "cancellation requested";
|
errMsg = "cancellation requested";
|
||||||
return nullptr;
|
return nullptr;
|
||||||
|
@ -6,4 +6,4 @@
|
|||||||
|
|
||||||
#pragma once
|
#pragma once
|
||||||
|
|
||||||
#define IX_WEBSOCKET_VERSION "7.4.1"
|
#define IX_WEBSOCKET_VERSION "7.4.2"
|
||||||
|
Loading…
Reference in New Issue
Block a user