change http client timeout to support microseconds

Author: kreuzerkrieg

Release/include/cpprest/http_client.h

@@ -191,19 +191,20 @@ class http_client_config
     /// Get the timeout
     /// </summary>
     /// <returns>The timeout (in seconds) used for each send and receive operation on the client.</returns>
-    utility::seconds timeout() const
+    const auto& timeout() const
     {
         return m_timeout;
     }
 
-    /// <summary>
-    /// Set the timeout
-    /// </summary>
-    /// <param name="timeout">The timeout (in seconds) used for each send and receive operation on the client.</param>
-    void set_timeout(const utility::seconds &timeout)
-    {
-        m_timeout = timeout;
-    }
+	/// <summary>
+	/// Set the timeout
+	/// </summary>
+	/// <param name="timeout">The timeout (duration from microseconds range and up) used for each send and receive operation on the client.</param>
+	template <class T>
+	void set_timeout(const T &timeout)
+	{
+		m_timeout = std::chrono::duration_cast<std::chrono::microseconds>(timeout);
+	}
 
     /// <summary>
     /// Get the client chunk size.
@@ -317,7 +318,7 @@ class http_client_config
     // Whether or not to guarantee ordering, i.e. only using one underlying TCP connection.
     bool m_guarantee_order;
 
-    utility::seconds m_timeout;
+    std::chrono::microseconds m_timeout;
     size_t m_chunksize;
 
 #if !defined(__cplusplus_winrt)

Release/src/http/client/http_client_asio.cpp

@@ -329,7 +329,7 @@ class asio_context : public request_context, public std::enable_shared_from_this
     : request_context(client, request)
     , m_content_length(0)
     , m_needChunked(false)
-    , m_timer(static_cast<int>(client->client_config().timeout().count()))
+    , m_timer(client->client_config().timeout())
     , m_connection(connection)
 #if defined(__APPLE__) || (defined(ANDROID) || defined(__ANDROID__))
     , m_openssl_failed(false)
@@ -1059,8 +1059,8 @@ class asio_context : public request_context, public std::enable_shared_from_this
     {
     public:
 
-        timeout_timer(int seconds) :
-        m_duration(boost::posix_time::milliseconds(seconds * 1000)),
+        timeout_timer(const std::chrono::microseconds& timeout) :
+        m_duration(timeout),
         m_state(created),
         m_timer(crossplat::threadpool::shared_instance().service())
         {}
@@ -1131,10 +1131,10 @@ class asio_context : public request_context, public std::enable_shared_from_this
             timedout
         };
 
-        boost::posix_time::milliseconds m_duration;
+        std::chrono::microseconds m_duration;
         timer_state m_state;
         std::weak_ptr<asio_context> m_ctx;
-        boost::asio::deadline_timer m_timer;
+        boost::asio::steady_timer m_timer;
     };
 
     uint64_t m_content_length;

Release/src/http/client/http_client_winhttp.cpp

@@ -395,8 +395,10 @@ class winhttp_client : public _http_client_communicator
         }
 
         // Set timeouts.
-        const auto timeout = config.timeout();
-        const int milliseconds = 1000 * static_cast<int>(timeout.count());
+        int milliseconds = static_cast<int>(
+			std::chrono::duration_cast<std::chrono::milliseconds>(config.timeout()).count()
+			);
+		milliseconds = std::max<decltype(milliseconds)>(milliseconds, 1);
         if(!WinHttpSetTimeouts(m_hSession,
             milliseconds,
             milliseconds,

Release/src/http/client/http_client_winrt.cpp

@@ -463,9 +463,11 @@ class winrt_client : public _http_client_communicator
         }
 
         // Set timeout.
-        const auto timeout = config.timeout();
-        const int secs = static_cast<int>(timeout.count());
-        hr = winrt_context->m_hRequest->SetProperty(XHR_PROP_TIMEOUT, secs * 1000);
+        ULONGLONG timeout = static_cast<ULONGLONG>(
+			std::chrono::duration_cast<std::chrono::milliseconds>(config.timeout()).count()
+			);
+		timeout = std::max<decltype(timeout)>(timeout, std::numeric_limits<decltype(timeout)>::min() + 1);
+        hr = winrt_context->m_hRequest->SetProperty(XHR_PROP_TIMEOUT, timeout);
         if (FAILED(hr))
         {
             request->report_error(hr, L"Failure to set HTTP request properties");

Release/tests/functional/http/client/client_construction.cpp

@@ -171,7 +171,8 @@ TEST_FIXTURE(uri_address, get_client_config)
     http_client client(m_uri, config);
 
     const http_client_config& config2 = client.client_config();
-    VERIFY_ARE_EQUAL(config2.timeout().count(), timeout.count());
+    VERIFY_ARE_EQUAL(std::chrono::duration_cast<decltype(timeout)>(config2.timeout()).count(),
+		timeout.count());
     VERIFY_ARE_EQUAL(config2.chunksize(), 1024);
 }