Add more logging messages Queue Server, a=chris
Add more logging messages Queue Server, a=chris
diff --git a/src/executables/QueueServer.php b/src/executables/QueueServer.php
index cbe5177c9..e249ade3b 100755
--- a/src/executables/QueueServer.php
+++ b/src/executables/QueueServer.php
@@ -577,17 +577,20 @@ class QueueServer implements CrawlConstants, Join
L\logLineTimestamp($lines[0]);
}
$error_log = C\CRASH_LOG_NAME;
- if (!file_exists($error_log) || filesize($error_log)>
+ L\crawlLog( "!!!!Writing to $error_log " .
+ "crash message about $process...");
+ if (!file_exists($error_log) || filesize($error_log) >
C\MAX_LOG_FILE_SIZE) {
file_put_contents($error_log, $out_msg);
} else {
file_put_contents($error_log, $out_msg, FILE_APPEND);
}
- $init_args = [substr($this->process_name, 2) . ".php", "start",
- "none", $process];
- CrawlDaemon::init( $init_args, $this->process_name, -3);
+ $init_args = ["QueueServer.php", "start", $this->channel, $process];
+ L\crawlLog( "!!!!Writing to $error_log ".
+ "crash message about $process...");
+ CrawlDaemon::init( $init_args, "QueueServer", -3);
if ($info[self::STATUS] != self::WAITING_START_MESSAGE_STATE) {
- L\crawlLog("Sleeping before trying to restart other process crawl");
+ L\crawlLog("Sleeping before sending restart message other process");
sleep(2 * C\QUEUE_SLEEP_TIME);
$crawl_params = [];
$crawl_params[self::STATUS] = "RESUME_CRAWL";
@@ -598,7 +601,7 @@ class QueueServer implements CrawlConstants, Join
$process_message_file = C\CRAWL_DIR . "/schedules/" .
$this->process_name . "Messages.txt";
file_put_contents($process_message_file, $info_string);
- chmod(C\CRAWL_DIR."/schedules/" . $this->process_name .
+ chmod(C\CRAWL_DIR . "/schedules/" . $this->process_name .
"Messages.txt", 0777);
}
}
@@ -1004,7 +1007,8 @@ class QueueServer implements CrawlConstants, Join
} else if (!$is_scheduler) {
$msg = "Restart failed!!! ";
if (!isset($info[self::CRAWL_TIME])) {
- $msg .="crawl time of crawl to restart not given\n";
+ $msg .=
+ "crawl time of crawl to restart not given\n";
}
if (!file_exists(C\CRAWL_DIR.'/cache/'.
self::queue_base_name . $info[self::CRAWL_TIME])) {
@@ -1227,7 +1231,7 @@ class QueueServer implements CrawlConstants, Join
if ($plugin == "") {continue; }
$plugin_instance_name =
lcfirst($plugin)."Plugin";
- $plugin_name = C\NS_PLUGINS . $plugin."Plugin";
+ $plugin_name = C\NS_PLUGINS . $plugin . "Plugin";
$this->$plugin_instance_name =
new $plugin_name();
if (method_exists($plugin_name, "setConfiguration") &&
@@ -1917,6 +1921,7 @@ class QueueServer implements CrawlConstants, Join
"index bundle.");
$this->index_archive->forceSave();
$this->index_archive = null;
+ $this->hourly_crawl_data = [];
$num_freed = L\garbageCollect();
L\crawlLog("...Indexer force running garbage collector " .
"after reset. This freed " . $num_freed . " bytes.");
diff --git a/src/library/CrawlDaemon.php b/src/library/CrawlDaemon.php
index 4ac836328..654b8552a 100644
--- a/src/library/CrawlDaemon.php
+++ b/src/library/CrawlDaemon.php
@@ -153,7 +153,9 @@ class CrawlDaemon implements CrawlConstants
"php $name.php start //starts the $name as a daemon\n" .
"php $name.php stop //stops the $name daemon\n" .
"php $name.php terminal //runs $name within the current\n" .
- "\tprocess, not as a daemon, output going to the terminal\n";
+ "\tprocess, not as a daemon, output going to the terminal\n" .
+ "Additional arguments are described in Yioop documentation.\n";
+
self::$name = $name;
if (isset($argv[2]) && $argv[2] != "none") {
self::$subname = $argv[2];