Implement 'ready(...)' Check for Async Response Objects

deanberris · deanberris · commit b07773b499e1 · 2010-11-15T18:28:51.000+08:00
This Closes #24 -- now an ADL-found function 'ready' can be used to check whether a response object that is the result of an asynchronous function call to HTTP methods on the asynchronous client is ready.
diff --git a/boost/network/protocol/http/message/async_message.hpp b/boost/network/protocol/http/message/async_message.hpp
@@ -17,6 +17,13 @@
 
 namespace boost { namespace network { namespace http {
 
+    namespace impl {
+
+        template <class Tag>
+        struct ready_wrapper;
+
+    } /* impl */
+
     template <class Tag>
     struct async_message {
 
@@ -137,7 +144,7 @@ namespace boost { namespace network { namespace http {
         mutable std::set<string_type> removed_headers;
         mutable boost::shared_future<string_type> body_;
 
-        friend struct boost::network::detail::wrapper_base<Tag, async_message<Tag> >;
+        friend struct boost::network::http::impl::ready_wrapper<Tag>;
     };
 
     template <class Tag>
diff --git a/boost/network/protocol/http/message/wrappers/ready.hpp b/boost/network/protocol/http/message/wrappers/ready.hpp
@@ -0,0 +1,45 @@
+#ifndef BOOST_NETWORK_PROTOCOL_HTTP_MESSAGE_WRAPPERS_READY_HPP_20100618
+#define BOOST_NETWORK_PROTOCOL_HTTP_MESSAGE_WRAPPERS_READY_HPP_20100618
+
+// Copyright 2010 Dean Michael Berris. 
+// Distributed under the Boost Software License, Version 1.0.
+// (See accompanying file LICENSE_1_0.txt or copy at
+// http://www.boost.org/LICENSE_1_0.txt)
+
+#include <boost/network/detail/wrapper_base.hpp>
+
+namespace boost { namespace network { namespace http {
+
+    template <class Tag>
+    struct async_message;
+
+    namespace impl {
+        template <class Tag>
+        struct ready_wrapper : boost::network::detail::wrapper_base_const<Tag, async_message<Tag> > {
+            typedef boost::network::detail::wrapper_base_const<Tag, async_message<Tag> >
+                wrapper_base;
+            explicit ready_wrapper(async_message<Tag> const & message)
+            : wrapper_base(message) {}
+            operator bool () {
+                return 
+                    wrapper_base::_message.version_.is_ready()
+                    && wrapper_base::_message.status_.is_ready()
+                    && wrapper_base::_message.status_message_.is_ready()
+                    && wrapper_base::_message.headers_.is_ready()
+                    && wrapper_base::_message.body_.is_ready();
+            }
+        };
+    } // namespace impl
+
+    template <class Tag>
+    inline bool ready(async_message<Tag> const & message) {
+        return impl::ready_wrapper<Tag>(message);
+    }
+    
+} /* http */
+    
+} /* network */
+    
+} /* boost */
+
+#endif /* BOOST_NETWORK_PROTOCOL_HTTP_MESSAGE_WRAPPERS_READY_HPP_20100618 */
diff --git a/boost/network/protocol/http/response.hpp b/boost/network/protocol/http/response.hpp
@@ -30,6 +30,7 @@
 #include <boost/network/protocol/http/message/wrappers/status_message.hpp>
 #include <boost/network/protocol/http/message/wrappers/destination.hpp>
 #include <boost/network/protocol/http/message/wrappers/source.hpp>
+#include <boost/network/protocol/http/message/wrappers/ready.hpp>
 
 #include <boost/network/protocol/http/message.hpp>
 #include <boost/network/protocol/http/message/async_message.hpp>
diff --git a/libs/network/test/CMakeLists.txt b/libs/network/test/CMakeLists.txt
@@ -29,6 +29,7 @@ if (Boost_FOUND)
         url_test
         http_url_test
         utils_thread_pool
+        http_async_message_ready
         )
     foreach (test ${TESTS})
         set_source_files_properties(${test}.cpp
diff --git a/libs/network/test/http_async_message_ready.cpp b/libs/network/test/http_async_message_ready.cpp
@@ -0,0 +1,18 @@
+
+// Copyright 2010 Dean Michael Berris. 
+// Distributed under the Boost Software License, Version 1.0.
+// (See accompanying file LICENSE_1_0.txt or copy at
+// http://www.boost.org/LICENSE_1_0.txt)
+
+#define BOOST_TEST_MODULE HTTP Async Response Test
+#include <boost/test/unit_test.hpp>
+#include <boost/network/include/http/client.hpp>
+
+namespace http = boost::network::http;
+
+BOOST_AUTO_TEST_CASE(unready_state_response) {
+    typedef http::basic_response<http::tags::http_async_8bit_udp_resolve> response;
+    response r;
+    BOOST_CHECK(!ready(r));
+}
+

Original file line number	Diff line number	Diff line change
`@@ -29,6 +29,7 @@ if (Boost_FOUND)`
`29`	`29`	`url_test`
`30`	`30`	`http_url_test`
`31`	`31`	`utils_thread_pool`
	`32`	`+ http_async_message_ready`
`32`	`33`	`)`
`33`	`34`	`foreach (test ${TESTS})`
`34`	`35`	`set_source_files_properties(${test}.cpp`