Changeset 2336

Timestamp:

05/14/08 23:35:50 (18 months ago)

Author:

bchoate

Message:

Conditioned support for Devel::Leak::Object reporting.

Files:

• branches/release-38/lib/MT/TheSchwartz.pm (modified) (3 diffs)

branches/release-38/lib/MT/TheSchwartz.pm

@@ -15 +15 @@
 
 our $RANDOMIZE_JOBS = 0;
+our $OBJECT_REPORT = 0;
 
 sub instance {
@@ -37 +38 @@
     my $workers = delete $param{workers} if exists $param{workers};
     $RANDOMIZE_JOBS = delete $param{randomize} if exists $param{randomize};
+
+    # Reports object usage inbetween jobs if Devel::Leak::Object is loaded
+    $OBJECT_REPORT = 1 if $Devel::Leak::Object::VERSION;
 
     my $client = $class->SUPER::new(%param);
@@ -129 +133 @@
     my $last_task_run = 0;
     my $did_work = 0;
+
+    if ($OBJECT_REPORT) {
+        Devel::Leak::Object::status();
+        print "\n\n";
+    }
+
     while (1) {
         if ($client->work_once) {
             $did_work = 1;
-        } else {
-            if ($did_work) {
-                my $driver = MT::Object->driver;
-                $driver->clear_cache
-                    if $driver->can('clear_cache');
-                MT->request->reset();
-                $did_work = 0;
+        }
+
+        if ($last_task_run + 60 * 5 < time) {
+            MT->run_tasks();
+            $did_work = 1;
+            $last_task_run = time;
+        }
+
+        if ($did_work) {
+            my $driver = MT::Object->driver;
+            $driver->clear_cache
+                if $driver->can('clear_cache');
+            MT->request->reset();
+            $did_work = 0;
+            if ($OBJECT_REPORT) {
+                Devel::Leak::Object::status();
+                print "\n\n";
             }
-
-            if ($last_task_run + 60 * 5 < time) {
-                MT->run_tasks();
-                $last_task_run = time;
-            }
-        }
+        }
+
         sleep $delay;
     }