/* * Copyright (C) 2010 Robin H.Johnson, Ovechko Kostyantyn . * * Project: IDFetch. * Developer: Ovechko Kostyantyn Olexandrovich (Kharkiv State Technical University of Construction and Architecture, Ukraine). * Mentor: Robin H. Johnson (Gentoo Linux: Developer, Trustee & Infrastructure Lead). * Mentoring organization: Gentoo Linux. * Sponsored by GSOC 2010. * * This file is part of Segget. * * Segget is free software; you can redistribute it and/or * modify it under the terms of the GNU Lesser General Public * License as published by the Free Software Foundation; either * version 2.1 of the License, or (at your option) any later version. * * Segget is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * Lesser General Public License for more details. * * You should have received a copy of the GNU Lesser General Public * License along with Segget; if not, write to the Free Software * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA */ #ifndef __CONNECTION_H__ #define __CONNECTION_H__ #include #include class Tsegment; #include "segment.h" #include "networkbroker.h" #include "scriptserver.h" using namespace std; #define MAX_CONNECTS 20 class Tconnection{ static uint total_connections; private: Tnetwork_distfile_broker_phases connection_start_time_network_phase_for_pf_networks; public: uint network_num; uint mirror_num; string url; ulong total_dld_bytes; ulong bytes_per_last_interval; uint connection_num; ulong max_speed_limit; bool active; timeval start_time; Tsegment *segment; Tconnection(): connection_start_time_network_phase_for_pf_networks(E_USE_AS_LOCAL_MIRRORS), network_num(0), mirror_num(0), url(""), total_dld_bytes(0), bytes_per_last_interval(0), connection_num(0), max_speed_limit(0), active(0), start_time(), segment(0) {}; Tconnection(const Tconnection &L); // copy constructor Tconnection & operator=(const Tconnection &L); int start(CURLM *cm, uint network_number, uint distfile_num, Tsegment *started_segment, uint best_mirror_num); void stop(CURLcode connection_result); void inc_bytes_per_last_interval(ulong new_bytes_count); void show_connection_progress(ulong time_diff); string get_html_connection_progress(); }; extern long script_waiting_connection_num; extern Tconnection connection_array[MAX_CONNECTS]; void init_connections(); #endif