From 2538b63c6f03f9c1f53ea874bf19af9c93ecf0b6 Mon Sep 17 00:00:00 2001
From: Lana Alber <lana@ssl.berkeley.edu>
Date: Wed, 20 Oct 2004 20:54:14 +0000
Subject: [PATCH] *** empty log message ***

svn path=/trunk/boinc/; revision=4362
---
 sched/db_purge.C | 13 ++++++++++++-
 1 file changed, 12 insertions(+), 1 deletion(-)

diff --git a/sched/db_purge.C b/sched/db_purge.C
index b844af62c3..eb53680ca2 100644
--- a/sched/db_purge.C
+++ b/sched/db_purge.C
@@ -62,6 +62,10 @@ FILE            *wu_index_stream;
 FILE            *re_index_stream;
 int             time_int;
 
+int             purged_workunits= 0, purged_results= 0, 
+                max_number_workunits_to_purge;
+
+
 int open_archive(char* filename_prefix, FILE*& f){
     int   retval=0;
     char  path[256];
@@ -263,7 +267,6 @@ int purge_and_archive_results(DB_WORKUNIT& wu, int& number_results) {
 // return nonzer if did anything
 //
 bool do_pass() {
-    int purged_workunits= 0, purged_results= 0;
     int retval= 0;
    
     check_stop_daemons();
@@ -301,6 +304,10 @@ bool do_pass() {
         log_messages.printf(SCHED_MSG_LOG::CRITICAL,"Purged workunit [%d] from database\n", wu.id);
 
         purged_workunits++;
+        
+        if (purged_workunits >= max_number_workunits_to_purge)
+            break;
+
     }
     
     log_messages.printf(SCHED_MSG_LOG::CRITICAL,
@@ -324,6 +331,8 @@ int main(int argc, char** argv) {
             one_pass = true;
         } else if (!strcmp(argv[i], "-d")) {
             log_messages.set_debug_level(atoi(argv[++i]));
+        } else if (!strcmp(argv[i], "-max")) {
+            max_number_workunits_to_purge= atoi(argv[++i]);
         } else {
             log_messages.printf(SCHED_MSG_LOG::CRITICAL,
                 "Unrecognized arg: %s\n", 
@@ -395,6 +404,8 @@ int main(int argc, char** argv) {
         do_pass();
     } else {
         while (1) {
+            if (purged_workunits >= max_number_workunits_to_purge)
+                break;
             if (!do_pass()) sleep(10);
         }
     }