(client) internal IXDNSLookup class requires a valid cancellation request function callback to be passed in
This commit is contained in:
		| @@ -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" | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user