From 7a9de17f26709fcd7270afd90215e50196bf4395 Mon Sep 17 00:00:00 2001
From: abobrov <abobrov@localhost>
Date: Fri, 17 Apr 2009 11:56:04 +0000
Subject: [PATCH] - [Issue 2233] log notices when any given task starts and ends execution.
---
opends/src/server/org/opends/server/backends/task/TaskThread.java | 19 ++++++++++++++++---
1 files changed, 16 insertions(+), 3 deletions(-)
diff --git a/opends/src/server/org/opends/server/backends/task/TaskThread.java b/opends/src/server/org/opends/server/backends/task/TaskThread.java
index b9eb145..7f64c3b 100644
--- a/opends/src/server/org/opends/server/backends/task/TaskThread.java
+++ b/opends/src/server/org/opends/server/backends/task/TaskThread.java
@@ -36,6 +36,7 @@
import static org.opends.server.loggers.debug.DebugLogger.*;
import static org.opends.server.loggers.ErrorLogger.*;
import static org.opends.messages.BackendMessages.*;
+import static org.opends.messages.TaskMessages.*;
import static org.opends.server.util.StaticUtils.*;
@@ -69,7 +70,7 @@
// The object that will be used for signaling the thread when there is new
// work to perform.
- private Object notifyLock;
+ private final Object notifyLock;
@@ -168,6 +169,7 @@
* Operates in a loop, sleeping until there is no work to do, then
* processing the task and returning to the scheduler for more work.
*/
+ @Override
public void run()
{
while (! exitRequested)
@@ -196,8 +198,18 @@
{
if (!TaskState.isDone(getAssociatedTask().getTaskState()))
{
- TaskState returnState = getAssociatedTask().execute();
- getAssociatedTask().setTaskState(returnState);
+ Task task = getAssociatedTask();
+
+ Message message = NOTE_TASK_STARTED.get(
+ task.getDisplayName(), task.getTaskID());
+ logError(message);
+
+ TaskState returnState = task.execute();
+ task.setTaskState(returnState);
+
+ message = NOTE_TASK_FINISHED.get(
+ task.getDisplayName(), task.getTaskID());
+ logError(message);
}
}
catch (Exception e)
@@ -241,6 +253,7 @@
*
* @return debug information about this thread as a string.
*/
+ @Override
public Map<String, String> getDebugProperties()
{
Map<String, String> properties = super.getDebugProperties();
--
Gitblit v1.10.0