1 // rTorrent - BitTorrent client 2 // Copyright (C) 2005-2011, Jari Sundell 3 // 4 // This program is free software; you can redistribute it and/or modify 5 // it under the terms of the GNU General Public License as published by 6 // the Free Software Foundation; either version 2 of the License, or 7 // (at your option) any later version. 8 // 9 // This program is distributed in the hope that it will be useful, 10 // but WITHOUT ANY WARRANTY; without even the implied warranty of 11 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 12 // GNU General Public License for more details. 13 // 14 // You should have received a copy of the GNU General Public License 15 // along with this program; if not, write to the Free Software 16 // Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA 17 // 18 // In addition, as a special exception, the copyright holders give 19 // permission to link the code of portions of this program with the 20 // OpenSSL library under certain conditions as described in each 21 // individual source file, and distribute linked combinations 22 // including the two. 23 // 24 // You must obey the GNU General Public License in all respects for 25 // all of the code used other than OpenSSL. If you modify file(s) 26 // with this exception, you may extend this exception to your version 27 // of the file(s), but you are not obligated to do so. If you do not 28 // wish to do so, delete this exception statement from your version. 29 // If you delete this exception statement from all source files in the 30 // program, then also delete it here. 31 // 32 // Contact: Jari Sundell <jaris@ifi.uio.no> 33 // 34 // Skomakerveien 33 35 // 3185 Skoppum, NORWAY 36 37 #ifndef RTORRENT_CORE_HTTP_QUEUE_H 38 #define RTORRENT_CORE_HTTP_QUEUE_H 39 40 #include <list> 41 #include <iosfwd> 42 #include lt_tr1_functional 43 44 namespace core { 45 46 class CurlGet; 47 48 class HttpQueue : private std::list<CurlGet*> { 49 public: 50 typedef std::list<CurlGet*> base_type; 51 typedef std::function<CurlGet* ()> slot_factory; 52 typedef std::function<void (CurlGet*)> slot_curl_get; 53 typedef std::list<slot_curl_get> signal_curl_get; 54 55 using base_type::iterator; 56 using base_type::const_iterator; 57 using base_type::reverse_iterator; 58 using base_type::const_reverse_iterator; 59 60 using base_type::begin; 61 using base_type::end; 62 using base_type::rbegin; 63 using base_type::rend; 64 65 using base_type::empty; 66 using base_type::size; 67 HttpQueue()68 HttpQueue() {} ~HttpQueue()69 ~HttpQueue() { clear(); } 70 71 // Note that any slots connected to the CurlGet signals must be 72 // pushed in front of the erase slot added by HttpQueue::insert. 73 // 74 // Consider adding a flag to indicate whetever HttpQueue should 75 // delete the stream. 76 iterator insert(const std::string& url, std::iostream* s); 77 void erase(iterator itr); 78 79 void clear(); 80 set_slot_factory(slot_factory s)81 void set_slot_factory(slot_factory s) { m_slot_factory = s; } 82 signal_insert()83 signal_curl_get& signal_insert() { return m_signal_insert; } signal_erase()84 signal_curl_get& signal_erase() { return m_signal_erase; } 85 86 private: 87 slot_factory m_slot_factory; 88 signal_curl_get m_signal_insert; 89 signal_curl_get m_signal_erase; 90 }; 91 92 } 93 94 #endif 95