/* * 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 */ #include "pkg.h" Tpkg **Ppkg_array; Tpkg proxy_fetcher_pkg; Tpkg request_server_pkg; //#define R_DOWNLOAD_STARTED 0 //#define R_ADDED_TO_PROXY_QUEUE 100 //#define R_ALREADY_WAS_IN_QUEUE 101 //#define R_WAIT_FOR_LOCAL_MIRRORS 102 //#define R_NO_FREE_NETWORK_CONNECTION_FOUND 103 //#define R_ERROR_ADDING_TO_PROXY_QUEUE 200 int Tpkg::push_back_distfile(json_object* json_obj_distfile){ try{ Tdistfile * Pcur_distfile=new Tdistfile(); if (Pcur_distfile->load_distfile_from_json(json_obj_distfile)){ error_log("Error in pkg.cpp: push_back_distfile(): while loading distfile"); return R_PF_ERROR_ADDING_TO_PROXY_QUEUE; }else{ debug("pkg.cpp: push_back_distfile(): json import ok - pushback distfile"); Pdistfile_list.push_back(Pcur_distfile); distfile_count++; return R_PF_ADDED_TO_PROXY_QUEUE; } }catch(...){ error_log("Error in pkg.cpp: pushback_distfile()"); return R_PF_ERROR_ADDING_TO_PROXY_QUEUE; } } int Tpkg::find_distfile(string distfile_name){ try{ for (ulong distfile_num=0; distfile_numname==distfile_name){ switch (Pdistfile_list[distfile_num]->get_status()){ case DDOWNLOADED: { debug("find_distfile(): distfile: "+distfile_name+" was downloaded"); return R_PF_DOWNLOADED; }; case DFAILED:{ debug("find_distfile(): failed to download distfile: "+distfile_name); return R_PF_FAILED; } default:{ debug("find_distfile(): distfile: "+distfile_name+" was already in queue"); return R_PF_ALREADY_WAS_IN_QUEUE; } } } } return R_PF_NOT_REQUESTED_YET; }catch(...){ error_log("Error in pkg.cpp: find_distfile()"); } debug("Error in pkg.cpp: find_distfile(): distfile: "+distfile_name); return R_PF_ERROR_ADDING_TO_PROXY_QUEUE; } void Tpkg::load_distfile_list(json_object* json_array_distfile_list){ try{ ulong distfile_counter=json_object_array_length(json_array_distfile_list); for(uint distfile_array_item_num=0;distfile_array_item_numload_distfile_from_json(json_object_array_get_idx(json_array_distfile_list,distfile_array_item_num)); } }catch(...){ error_log("Error in pkg.cpp: load_distfile_list()"); } } */ void Tpkg::load_pkg_from_json(json_object* json_obj_pkg){ try{ // printf("\t%d %s\n",array_item_num, json_object_to_json_string(json_obj_pkg)); name=json_object_to_json_string(json_object_object_get(json_obj_pkg,"pkg_name")); category=json_object_to_json_string(json_object_object_get(json_obj_pkg,"CATEGORY")); load_distfile_list(json_object_object_get(json_obj_pkg,"distfile_list")); }catch(...){ error_log("Error in pkg.cpp: load_pkg_from_json()"); } } Tpkg::~Tpkg(){ try{ for (uint i=0;i