Rooba
/
boinc
mirror of https://github.com/BOINC/boinc.git
1
0
Fork 0
Code Issues 1 Packages Projects Releases Wiki Activity

VBOX: Base checkpoints on CPU time instead of elapsed time.

This commit is contained in:
Rom Walton 2014-05-29 10:01:56 -04:00
parent 274a2999fe
commit 45df1256fc
1 changed files with 23 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
samples/vboxwrapper/vboxwrapper.cpp
View File

@ -1023,14 +1023,20 @@ int main(int argc, char** argv) {
if (boinc_time_to_checkpoint()) { if (boinc_time_to_checkpoint()) {
// Only peform a VM checkpoint every ten minutes or so. // Only peform a VM checkpoint every ten minutes or so.
// //
if (elapsed_time >= checkpoint_cpu_time + random_checkpoint_factor + 600.0) { if (current_cpu_time >= checkpoint_cpu_time + random_checkpoint_factor + 600.0) {
// Basic interleave factor is only needed once. // Basic interleave factor is only needed once.
if (random_checkpoint_factor > 0) { if (random_checkpoint_factor > 0) {
random_checkpoint_factor = 0.0; random_checkpoint_factor = 0.0;
} }
if ((elapsed_time - last_status_report_time) >= 6000.0) { if ((current_cpu_time - last_status_report_time) >= 6000.0) {
last_status_report_time = elapsed_time; last_status_report_time = current_cpu_time;
fprintf(
stderr,
"%s Status Report: CPU Time: '%f'\n",
vboxwrapper_msg_prefix(buf, sizeof(buf)),
current_cpu_time
);
if (vm.job_duration) { if (vm.job_duration) {
fprintf( fprintf(
stderr, stderr,
@ -1048,29 +1054,25 @@ int main(int argc, char** argv) {
); );
} }
if (aid.global_prefs.daily_xfer_limit_mb) { if (aid.global_prefs.daily_xfer_limit_mb) {
if (vm.job_duration) { fprintf(
fprintf( stderr,
stderr, "%s Status Report: Network Bytes Sent (Total): '%f'\n",
"%s Status Report: Network Bytes Sent (Total): '%f'\n", vboxwrapper_msg_prefix(buf, sizeof(buf)),
vboxwrapper_msg_prefix(buf, sizeof(buf)), bytes_sent
bytes_sent );
); fprintf(
} stderr,
if (elapsed_time) { "%s Status Report: Network Bytes Received (Total): '%f'\n",
fprintf( vboxwrapper_msg_prefix(buf, sizeof(buf)),
stderr, bytes_received
"%s Status Report: Network Bytes Received (Total): '%f'\n", );
vboxwrapper_msg_prefix(buf, sizeof(buf)),
bytes_received
);
}
} }
vm.dumphypervisorstatusreports(); vm.dumphypervisorstatusreports();
} }
// Checkpoint // Checkpoint
retval = vm.createsnapshot(elapsed_time); retval = vm.createsnapshot(current_cpu_time);
if (retval) { if (retval) {
// Let BOINC clean-up the environment which should release any file/mutex locks and then attempt // Let BOINC clean-up the environment which should release any file/mutex locks and then attempt
// to resume from a previous snapshot. // to resume from a previous snapshot.
@ -1086,7 +1088,7 @@ int main(int argc, char** argv) {
} else { } else {
// tell BOINC we've successfully created a checkpoint. // tell BOINC we've successfully created a checkpoint.
// //
checkpoint_cpu_time = elapsed_time; checkpoint_cpu_time = current_cpu_time;
write_checkpoint(checkpoint_cpu_time, vm); write_checkpoint(checkpoint_cpu_time, vm);
boinc_checkpoint_completed(); boinc_checkpoint_completed();
} }