|
@@ -10,7 +10,7 @@ class pdlog_clear_all
|
|
|
const pdlog_table_name = 'pd_log';
|
|
|
const step_length = 1000;
|
|
|
|
|
|
- public function clear()
|
|
|
+ public function clear($latest)
|
|
|
{
|
|
|
$lgid_getter = function ()
|
|
|
{
|
|
@@ -24,6 +24,10 @@ class pdlog_clear_all
|
|
|
};
|
|
|
|
|
|
[$succ,$minid,$maxid] = $lgid_getter();
|
|
|
+ if($latest > $minid) {
|
|
|
+ $minid = $latest;
|
|
|
+ }
|
|
|
+
|
|
|
if($succ) {
|
|
|
$this->delete_log($minid,$maxid);
|
|
|
}
|
|
@@ -122,11 +126,11 @@ class pdlog_clear_all
|
|
|
$count += count($logids);
|
|
|
Log::record("del pd_log lines={$count}",Log::DEBUG);
|
|
|
|
|
|
- $index += 1;
|
|
|
- if($index % 1000 === 0) {
|
|
|
- Log::record("del pd_log index={$index}",Log::DEBUG);
|
|
|
- sleep(1);
|
|
|
- }
|
|
|
+// $index += 1;
|
|
|
+// if($index % 1000 === 0) {
|
|
|
+// Log::record("del pd_log index={$index}",Log::DEBUG);
|
|
|
+// sleep(1);
|
|
|
+// }
|
|
|
}
|
|
|
}
|
|
|
};
|