[coro_http_client][improve]some improvment (#485)

include/ylt/coro_http/coro_http_client.hpp

@@ -32,6 +32,7 @@ using req_content_type = cinatra::req_content_type;
 using resp_data = cinatra::resp_data;
 using http_method = cinatra::http_method;
 using http_header = cinatra::http_header;
+using uri_t = cinatra::uri_t;
 template <typename String = std::string>
 using req_context = cinatra::req_context<String>;
 }  // namespace coro_http

include/ylt/thirdparty/cinatra/coro_http_client.hpp

@@ -81,12 +81,12 @@ struct http_header;
 
 struct resp_data {
   std::error_code net_err;
-  int status;
+  int status = 0;
+  bool eof = false;
   std::string_view resp_body;
   std::span<http_header> resp_headers;
-  bool eof;
 #ifdef BENCHMARK_TEST
-  uint64_t total;
+  uint64_t total = 0;
 #endif
 };
 
@@ -104,7 +104,7 @@ struct multipart_t {
   size_t size = 0;
 };
 
-class coro_http_client {
+class coro_http_client : public std::enable_shared_from_this<coro_http_client> {
  public:
   struct config {
     std::optional<std::chrono::steady_clock::duration> conn_timeout_duration;
@@ -1578,6 +1578,7 @@ class coro_http_client {
   async_simple::coro::Lazy<void> async_read_ws() {
     resp_data data{};
 
+    auto self = this->shared_from_this();
     read_buf_.consume(read_buf_.size());
     size_t header_size = 2;
     std::shared_ptr sock = socket_;

src/coro_io/tests/test_client_pool.cpp

@@ -220,10 +220,10 @@ TEST_CASE("test client pools parallel r/w") {
       CHECK(cli->get_host_name() == std::to_string(i));
     }
     auto rw = [&pool](int i) -> Lazy<void> {
-      ELOG_DEBUG << "start to insert {" << i << "} to hash table.";
+      //      ELOG_DEBUG << "start to insert {" << i << "} to hash table.";
       auto cli = pool[std::to_string(i)];
       CHECK(cli->get_host_name() == std::to_string(i));
-      ELOG_DEBUG << "end to insert {" << i << "} to hash table.";
+      //      ELOG_DEBUG << "end to insert {" << i << "} to hash table.";
       co_return;
     };