diff --git a/checkin_notes b/checkin_notes index 50f0312975..6d8bb0817f 100644 --- a/checkin_notes +++ b/checkin_notes @@ -465,3 +465,9 @@ David Jan 14 2008 weak_auth.php sched/ handle_request.C + +David Jan 14 2008 + - scheduler: forgot to add a couple of files + + sched/ + time_stats_log.C,h diff --git a/sched/time_stats_log.C b/sched/time_stats_log.C new file mode 100644 index 0000000000..52ae8395a8 --- /dev/null +++ b/sched/time_stats_log.C @@ -0,0 +1,79 @@ +// Berkeley Open Infrastructure for Network Computing +// http://boinc.berkeley.edu +// Copyright (C) 2008 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 + +#include +#include + +#include "filesys.h" +#include "parse.h" + +#include "sched_msgs.h" + +#include "time_stats_log.h" + +static char* stats_buf = 0; + +// Got a flag in scheduler request. +// Copy the contents to a malloced buffer; +// don't write them to disk yet, since we haven't authenticated the host +// + +void handle_time_stats_log(FILE* fin) { + dup_element_contents(fin, "", &stats_buf); +} + +// The host has been authenticated, so write the stats. +// Use a directory hierarchy since there may be many hosts +// +void write_time_stats_log(SCHEDULER_REPLY& reply) { + char dirname[256], filename[256]; + + int hostid = reply.host.id; + int dirnum = hostid % 1000; + sprintf(dirname, "../time_stats_log/%d", dirnum); + if (!is_dir(dirname)) { + int retval = boinc_mkdir(dirname); + if (retval) { + log_messages.printf(SCHED_MSG_LOG::MSG_CRITICAL, + "Can't make time stats log dir %s: %d\n", dirname, retval + ); + perror("mkdir"); + return; + } + } + sprintf(filename, "../time_stats_log/%d/%d", dirnum, hostid); + FILE* f = fopen(filename, "w"); + if (!f) { + log_messages.printf(SCHED_MSG_LOG::MSG_CRITICAL, + "Can't create time stats file %s\n", filename + ); + return; + } + fputs(stats_buf, f); + fclose(f); +} + +bool have_time_stats_log(SCHEDULER_REPLY& reply) { + char filename[256]; + + int hostid = reply.host.id; + int dirnum = hostid % 1000; + sprintf(filename, "../time_stats_log/%d/%d", dirnum, hostid); + return is_file(filename); +} diff --git a/sched/time_stats_log.h b/sched/time_stats_log.h new file mode 100644 index 0000000000..3cc315e613 --- /dev/null +++ b/sched/time_stats_log.h @@ -0,0 +1,25 @@ +// Berkeley Open Infrastructure for Network Computing +// http://boinc.berkeley.edu +// Copyright (C) 2008 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 + +#include +#include "server_types.h" + +extern void handle_time_stats_log(FILE* fin); +extern void write_time_stats_log(SCHEDULER_REPLY& reply); +extern bool have_time_stats_log(SCHEDULER_REPLY& reply);