Converted curl/http to be thread-safe.

src/core/http_queue.cc

@@ -8,13 +8,13 @@
 namespace core {
 
 HttpQueue::iterator
-HttpQueue::insert(const std::string& url, std::iostream* s) {
-  auto itr = base_type::insert(end(), torrent::net_thread::http_stack()->create(url, s));
+HttpQueue::insert(const std::string& url, std::iostream* stream) {
+  auto itr = base_type::insert(end(), torrent::net::HttpGet(url, stream));
 
   itr->add_done_slot([this, itr]() { erase(itr); });
   itr->add_failed_slot([this, itr](auto) { erase(itr); });
 
-  itr->start();
+  torrent::net_thread::http_stack()->start_get(*itr);
 
   for (auto& slot : m_signal_insert)
     slot(*itr);

src/core/http_queue.h

@@ -38,7 +38,7 @@ public:
   //
   // Consider adding a flag to indicate whetever HttpQueue should
   // delete the stream.
-  iterator    insert(const std::string& url, std::iostream* s);
+  iterator    insert(const std::string& url, std::iostream* stream);
   void        erase(iterator itr);
 
   void        clear();

src/display/window_http_queue.cc

@@ -126,7 +126,7 @@ WindowHttpQueue::receive_erase(torrent::net::HttpGet http_get) {
   if (itr == m_container.end())
     throw std::logic_error("WindowHttpQueue::receive_erase(...) tried to remove an object we don't have");
 
-  itr->m_http = nullptr;
+  itr->m_http = torrent::net::HttpGet();
   itr->m_timer = torrent::this_thread::cached_time() + 4s;
 
   mark_dirty();