[Libreoffice-commits] online.git: loolwsd/DocumentBroker.cpp loolwsd/LOOLWSD.cpp
Ashod Nakashian
ashod.nakashian at collabora.co.uk
Mon Nov 14 05:31:15 UTC 2016
loolwsd/DocumentBroker.cpp | 1 -
loolwsd/LOOLWSD.cpp | 15 +++++++++++++--
2 files changed, 13 insertions(+), 3 deletions(-)
New commits:
commit 92ca5225a56bd511ac81bbb456f12f2670625a5b
Author: Ashod Nakashian <ashod.nakashian at collabora.co.uk>
Date: Sun Nov 13 16:14:58 2016 -0500
loolwsd: logs and consistent formatting
Change-Id: If32bb829b125678c6e8f83c39a3812098f3b38a3
Reviewed-on: https://gerrit.libreoffice.org/30827
Reviewed-by: Ashod Nakashian <ashnakash at gmail.com>
Tested-by: Ashod Nakashian <ashnakash at gmail.com>
diff --git a/loolwsd/DocumentBroker.cpp b/loolwsd/DocumentBroker.cpp
index 5412c4b..51badf4 100644
--- a/loolwsd/DocumentBroker.cpp
+++ b/loolwsd/DocumentBroker.cpp
@@ -68,7 +68,6 @@ void ChildProcess::socketProcessor()
LOG_DBG("Child [" << getPid() << "] WS terminated. Notifying DocBroker.");
-
// Notify the broker that we're done.
auto docBroker = _docBroker.lock();
if (docBroker && !_stop)
diff --git a/loolwsd/LOOLWSD.cpp b/loolwsd/LOOLWSD.cpp
index 4655a91..bb2bd85 100644
--- a/loolwsd/LOOLWSD.cpp
+++ b/loolwsd/LOOLWSD.cpp
@@ -1926,7 +1926,11 @@ int LOOLWSD::main(const std::vector<std::string>& /*args*/)
findFreeMasterPort(MasterPortNumber) :
getMasterSocket(MasterPortNumber));
if (!psvs2)
+ {
+ LOG_FTL("Failed to listen on master port (" <<
+ MasterPortNumber << ") or find a free port. Exiting.");
return Application::EXIT_SOFTWARE;
+ }
HTTPServer srv2(new PrisonerRequestHandlerFactory(), threadPool, *psvs2, params2);
LOG_INF("Starting prisoner server listening on " << MasterPortNumber);
@@ -1946,7 +1950,11 @@ int LOOLWSD::main(const std::vector<std::string>& /*args*/)
findFreeServerPort(ClientPortNumber) :
getServerSocket(ClientPortNumber, true));
if (!psvs)
+ {
+ LOG_FTL("Failed to listen on client port (" <<
+ ClientPortNumber << ") or find a free port. Exiting.");
return Application::EXIT_SOFTWARE;
+ }
HTTPServer srv(new ClientRequestHandlerFactory(), threadPool, *psvs, params1);
LOG_INF("Starting master server listening on " << ClientPortNumber);
@@ -1962,7 +1970,9 @@ int LOOLWSD::main(const std::vector<std::string>& /*args*/)
{
UnitWSD::get().invokeTest();
if (TerminationFlag)
+ {
break;
+ }
const pid_t pid = waitpid(forKitPid, &status, WUNTRACED | WNOHANG);
if (pid > 0)
@@ -2018,7 +2028,7 @@ int LOOLWSD::main(const std::vector<std::string>& /*args*/)
// No child processes.
LOG_FTL("No Forkit instance. Terminating.");
TerminationFlag = true;
- continue;
+ break;
}
}
else // pid == 0, no children have died
@@ -2058,6 +2068,7 @@ int LOOLWSD::main(const std::vector<std::string>& /*args*/)
{
LOG_INF((time(nullptr) - startTimeSpan) << " seconds gone, finishing as requested.");
TerminationFlag = true;
+ break;
}
#endif
}
@@ -2070,7 +2081,7 @@ int LOOLWSD::main(const std::vector<std::string>& /*args*/)
threadPool.joinAll();
// Terminate child processes
- LOG_INF("Requesting child process " << forKitPid << " to terminate.");
+ LOG_INF("Requesting forkit process " << forKitPid << " to terminate.");
Util::requestTermination(forKitPid);
for (auto& child : NewChildren)
{
More information about the Libreoffice-commits
mailing list