// Berkeley Open Infrastructure for Network Computing // http://boinc.berkeley.edu // Copyright (C) 2005 University of California // // This 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. // // This software 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. // // To view the GNU Lesser General Public License visit // http://www.gnu.org/copyleft/lesser.html // or write to the Free Software Foundation, Inc., // 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA #if defined(_WIN32) && !defined(__STDWX_H__) && !defined(_BOINC_WIN_) && !defined(_AFX_STDAFX_H_) #include "boinc_win.h" #endif #ifndef _WIN32 #include "config.h" #include #include #include #endif #include "parse.h" #include "error_numbers.h" #include "prefs.h" GLOBAL_PREFS_MASK::GLOBAL_PREFS_MASK() { clear(); } void GLOBAL_PREFS_MASK::clear() { memset(this, 0, sizeof(GLOBAL_PREFS_MASK)); } bool GLOBAL_PREFS_MASK::are_prefs_set() { if (run_on_batteries) return true; if (run_if_user_active) return true; if (start_hour) return true; // 0..23; no restriction if start==end if (end_hour) return true; if (net_start_hour) return true; // 0..23; no restriction if start==end if (net_end_hour) return true; if (leave_apps_in_memory) return true; if (confirm_before_connecting) return true; if (hangup_if_dialed) return true; if (dont_verify_images) return true; if (work_buf_min_days) return true; if (max_cpus) return true; if (cpu_scheduling_period_minutes) return true; if (disk_interval) return true; if (disk_max_used_gb) return true; if (disk_max_used_pct) return true; if (disk_min_free_gb) return true; if (vm_max_used_frac) return true; if (ram_max_used_busy_frac) return true; if (ram_max_used_idle_frac) return true; if (idle_time_to_run) return true; if (max_bytes_sec_up) return true; if (max_bytes_sec_down) return true; if (cpu_usage_limit) return true; return false; } bool GLOBAL_PREFS_MASK::are_simple_prefs_set() { if (start_hour) return true; if (end_hour) return true; if (net_start_hour) return true; if (net_end_hour) return true; if (disk_max_used_gb) return true; if (cpu_usage_limit) return true; if (run_if_user_active) return true; if (run_on_batteries) return true; if (idle_time_to_run) return true; return false; } // The following values determine how the client behaves // if there are no global prefs (e.g. on our very first RPC). // These should impose minimal restrictions, // so that the client can do the RPC and get the global prefs from the server // void GLOBAL_PREFS::defaults() { run_on_batteries = true; run_if_user_active = true; start_hour = 0; end_hour = 0; net_start_hour = 0; net_end_hour = 0; leave_apps_in_memory = false; confirm_before_connecting = true; hangup_if_dialed = false; dont_verify_images = false; work_buf_min_days = 0.1; max_cpus = 16; cpu_scheduling_period_minutes = 60; disk_interval = 60; disk_max_used_gb = 10; disk_max_used_pct = 50; disk_min_free_gb = 0.1; vm_max_used_frac = 0.75; ram_max_used_busy_frac = 0.5; ram_max_used_idle_frac = 0.9; idle_time_to_run = 3; max_bytes_sec_up = 0; max_bytes_sec_down = 0; cpu_usage_limit = 100; // don't initialize source_project, source_scheduler, // mod_time, host_specific here // since they are outside of elements, // and this is called when find the right venue. // Also, don't memset to 0 } // before parsing void GLOBAL_PREFS::clear_bools() { run_on_batteries = false; run_if_user_active = false; leave_apps_in_memory = false; confirm_before_connecting = false; hangup_if_dialed = false; dont_verify_images = false; } GLOBAL_PREFS::GLOBAL_PREFS() { defaults(); } // Parse XML global prefs, setting defaults first. // The start tag has already been parsed. // int GLOBAL_PREFS::parse( XML_PARSER& xp, const char* host_venue, bool& found_venue, GLOBAL_PREFS_MASK& mask ) { defaults(); clear_bools(); strcpy(source_project, ""); strcpy(source_scheduler, ""); mod_time = 0; host_specific = false; return parse_override(xp, host_venue, found_venue, mask); } // Parse global prefs, overriding whatever is currently in the structure. // // If host_venue is nonempty and we find an element of the form // // ... // // where X==host_venue, then parse that and ignore the rest. // Otherwise ignore elements. // // The start tag has already been parsed. // int GLOBAL_PREFS::parse_override( XML_PARSER& xp, const char* host_venue, bool& found_venue, GLOBAL_PREFS_MASK& mask ) { char tag[256], buf2[256]; bool in_venue = false, in_correct_venue=false, is_tag; double dtemp; found_venue = false; mask.clear(); while (!xp.get(tag, sizeof(tag), is_tag)) { if (in_venue) { if (!strcmp(tag, "/venue")) { if (in_correct_venue) { return 0; } else { in_venue = false; continue; } } else { if (!in_correct_venue) continue; } } else { if (strstr(tag, "venue")) { in_venue = true; parse_attr(tag, "name", buf2, sizeof(buf2)); if (!strcmp(buf2, host_venue)) { defaults(); clear_bools(); in_correct_venue = true; found_venue = true; } else { in_correct_venue = false; } continue; } } if (xp.parse_str(tag, "source_project", source_project, sizeof(source_project))) { continue; } else if (xp.parse_str(tag, "source_scheduler", source_scheduler, sizeof(source_scheduler))) { continue; } else if (xp.parse_int(tag, "mod_time", mod_time)) { continue; } else if (!strcmp(tag, "/global_preferences")) { return 0; } else if (xp.parse_bool(tag, "run_on_batteries", run_on_batteries)) { mask.run_on_batteries = true; continue; } else if (xp.parse_bool(tag, "run_if_user_active", run_if_user_active)) { mask.run_if_user_active = true; continue; } else if (xp.parse_int(tag, "start_hour", start_hour)) { mask.start_hour = true; continue; } else if (xp.parse_int(tag, "end_hour", end_hour)) { mask.end_hour = true; continue; } else if (xp.parse_int(tag, "net_start_hour", net_start_hour)) { mask.net_start_hour = true; continue; } else if (xp.parse_int(tag, "net_end_hour", net_end_hour)) { mask.net_end_hour = true; continue; } else if (xp.parse_bool(tag, "leave_apps_in_memory", leave_apps_in_memory)) { mask.leave_apps_in_memory = true; continue; } else if (xp.parse_bool(tag, "confirm_before_connecting", confirm_before_connecting)) { mask.confirm_before_connecting = true; continue; } else if (xp.parse_bool(tag, "hangup_if_dialed", hangup_if_dialed)) { mask.hangup_if_dialed = true; continue; } else if (xp.parse_bool(tag, "dont_verify_images", dont_verify_images)) { mask.dont_verify_images = true; continue; } else if (xp.parse_double(tag, "work_buf_min_days", work_buf_min_days)) { if (work_buf_min_days < 0.01) work_buf_min_days = 0.01; mask.work_buf_min_days = true; continue; } else if (xp.parse_int(tag, "max_cpus", max_cpus)) { if (max_cpus < 1) max_cpus = 1; mask.max_cpus = true; continue; } else if (xp.parse_double(tag, "disk_interval", disk_interval)) { if (disk_interval<0) disk_interval = 0; mask.disk_interval = true; continue; } else if (xp.parse_double(tag, "cpu_scheduling_period_minutes", cpu_scheduling_period_minutes)) { if (cpu_scheduling_period_minutes < 0.0001) cpu_scheduling_period_minutes = 60; mask.cpu_scheduling_period_minutes = true; continue; } else if (xp.parse_double(tag, "disk_max_used_gb", disk_max_used_gb)) { mask.disk_max_used_gb = true; continue; } else if (xp.parse_double(tag, "disk_max_used_pct", disk_max_used_pct)) { mask.disk_max_used_pct = true; continue; } else if (xp.parse_double(tag, "disk_min_free_gb", disk_min_free_gb)) { mask.disk_min_free_gb = true; continue; } else if (xp.parse_double(tag, "vm_max_used_pct", dtemp)) { vm_max_used_frac = dtemp/100; mask.vm_max_used_frac = true; continue; } else if (xp.parse_double(tag, "ram_max_used_busy_pct", dtemp)) { ram_max_used_busy_frac = dtemp/100; mask.ram_max_used_busy_frac = true; continue; } else if (xp.parse_double(tag, "ram_max_used_idle_pct", dtemp)) { ram_max_used_idle_frac = dtemp/100; mask.ram_max_used_idle_frac = true; continue; } else if (xp.parse_double(tag, "idle_time_to_run", idle_time_to_run)) { mask.idle_time_to_run = true; continue; } else if (xp.parse_double(tag, "max_bytes_sec_up", max_bytes_sec_up)) { if (max_bytes_sec_up < 0) max_bytes_sec_up = 0; mask.max_bytes_sec_up = true; continue; } else if (xp.parse_double(tag, "max_bytes_sec_down", max_bytes_sec_down)) { if (max_bytes_sec_down < 0) max_bytes_sec_down = 0; mask.max_bytes_sec_down = true; continue; } else if (xp.parse_double(tag, "cpu_usage_limit", dtemp)) { if (dtemp > 0 && dtemp <= 100) { cpu_usage_limit = dtemp; mask.cpu_usage_limit = true; } continue; } else if (xp.parse_bool(tag, "host_specific", host_specific)) { continue; } } return ERR_XML_PARSE; } // Parse global prefs file // int GLOBAL_PREFS::parse_file( const char* filename, const char* host_venue, bool& found_venue ) { FILE* f; GLOBAL_PREFS_MASK mask; int retval; f = fopen(filename, "r"); if (!f) return ERR_FOPEN; MIOFILE mf; mf.init_file(f); XML_PARSER xp(&mf); if (!xp.parse_start("global_preferences")) { return ERR_XML_PARSE; } retval = parse(xp, host_venue, found_venue, mask); fclose(f); return retval; } // Write the global prefs that are actually in force // (our particular venue, modified by overwrite file). // This is used to write // 1) the app init data file // 2) GUI RPC get_state reply // Not used for scheduler request; there, we just copy the // global_prefs.xml file (which includes all venues). // int GLOBAL_PREFS::write(MIOFILE& f) { f.printf( "\n" " %d\n" "%s%s" " %d\n" " %d\n" " %d\n" " %d\n" "%s%s%s%s" " %f\n" " %d\n" " %f\n" " %f\n" " %f\n" " %f\n" " %f\n" " %f\n" " %f\n" " %f\n" " %f\n" " %f\n" " %f\n" " %f\n" "\n", mod_time, run_on_batteries?" \n":"", run_if_user_active?" \n":"", start_hour, end_hour, net_start_hour, net_end_hour, leave_apps_in_memory?" \n":"", confirm_before_connecting?" \n":"", hangup_if_dialed?" \n":"", dont_verify_images?" \n":"", work_buf_min_days, max_cpus, cpu_scheduling_period_minutes, disk_interval, disk_max_used_gb, disk_max_used_pct, disk_min_free_gb, vm_max_used_frac*100, ram_max_used_busy_frac*100, ram_max_used_idle_frac*100, idle_time_to_run, max_bytes_sec_up, max_bytes_sec_down, cpu_usage_limit ); return 0; } // write a subset of the global preferences, // as selected by the mask of bools // int GLOBAL_PREFS::write_subset(MIOFILE& f, GLOBAL_PREFS_MASK& mask) { if (!mask.are_prefs_set()) return 0; f.printf("\n"); if (mask.run_on_batteries) { f.printf(" %d\n", run_on_batteries?1:0 ); } if (mask.run_if_user_active) { f.printf(" %d\n", run_if_user_active?1:0 ); } if (mask.start_hour) { f.printf(" %d\n", start_hour); } if (mask.end_hour) { f.printf(" %d\n", end_hour); } if (mask.net_start_hour) { f.printf(" %d\n", net_start_hour); } if (mask.net_end_hour) { f.printf(" %d\n", net_end_hour); } if (mask.leave_apps_in_memory) { f.printf(" %d\n", leave_apps_in_memory?1:0 ); } if (mask.confirm_before_connecting) { f.printf(" %d\n", confirm_before_connecting?1:0 ); } if (mask.hangup_if_dialed) { f.printf(" %d\n", hangup_if_dialed?1:0 ); } if (mask.dont_verify_images) { f.printf(" %d\n", dont_verify_images?1:0 ); } if (mask.work_buf_min_days) { f.printf(" %f\n", work_buf_min_days); } if (mask.max_cpus) { f.printf(" %d\n", max_cpus); } if (mask.cpu_scheduling_period_minutes) { f.printf(" %f\n", cpu_scheduling_period_minutes); } if (mask.disk_interval) { f.printf(" %f\n", disk_interval); } if (mask.disk_max_used_gb) { f.printf(" %f\n", disk_max_used_gb); } if (mask.disk_max_used_pct) { f.printf(" %f\n", disk_max_used_pct); } if (mask.disk_min_free_gb) { f.printf(" %f\n", disk_min_free_gb); } if (mask.vm_max_used_frac) { f.printf(" %f\n", vm_max_used_frac*100); } if (mask.ram_max_used_busy_frac) { f.printf(" %f\n", ram_max_used_busy_frac*100); } if (mask.ram_max_used_idle_frac) { f.printf(" %f\n", ram_max_used_idle_frac*100); } if (mask.idle_time_to_run) { f.printf(" %f\n", idle_time_to_run); } if (mask.max_bytes_sec_up) { f.printf(" %f\n", max_bytes_sec_up); } if (mask.max_bytes_sec_down) { f.printf(" %f\n", max_bytes_sec_down); } if (mask.cpu_usage_limit) { f.printf(" %f\n", cpu_usage_limit); } f.printf("\n"); return 0; } const char *BOINC_RCSID_3fb442bb02 = "$Id$";