Author: cziegeler
Date: Tue Dec 15 14:54:27 2009
New Revision: 890813
URL: http://svn.apache.org/viewvc?rev=890813&view=rev
Log:
Add some debug logging
Modified:
sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/JobEventHandler.java
Modified:
sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/JobEventHandler.java
URL:
http://svn.apache.org/viewvc/sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/JobEventHandler.java?rev=890813&r1=890812&r2=890813&view=diff
==============================================================================
---
sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/JobEventHandler.java
(original)
+++
sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/JobEventHandler.java
Tue Dec 15 14:54:27 2009
@@ -477,11 +477,13 @@
}
if ( info != null && this.running ) {
+ logger.debug("Processing new job {}", info.event);
// check for local only jobs and remove them from the queue if
they're meant
// for another application node
final String appId =
(String)info.event.getProperty(EventUtil.PROPERTY_APPLICATION);
if ( info.event.getProperty(EventUtil.PROPERTY_JOB_RUN_LOCAL)
!= null
&& appId != null && !this.applicationId.equals(appId) ) {
+ logger.debug("Discarding job {} : local job for a
different application node.", info.event);
info = null;
}
@@ -489,6 +491,7 @@
if ( info != null &&
info.event.getProperty(EventUtil.PROPERTY_JOB_QUEUE_NAME) != null ) {
final String queueName =
(String)info.event.getProperty(EventUtil.PROPERTY_JOB_QUEUE_NAME);
synchronized ( this.jobQueues ) {
+ logger.debug("Queuing job {} into queue {}.",
info.event, queueName);
BlockingQueue<EventInfo> jobQueue =
this.jobQueues.get(queueName);
if ( jobQueue == null ) {
final JobBlockingQueue jq = new JobBlockingQueue();
@@ -636,6 +639,7 @@
boolean putback = false;
boolean wait = false;
synchronized (this.backgroundLock) {
+ logger.debug("Executing job {}.", info.event);
try {
this.backgroundSession.refresh(false);
// check if the node still exists
@@ -662,6 +666,7 @@
} else {
// check number of parallel jobs for main queue
if ( jobQueue == null && this.parallelJobCount >=
this.maximumParallelJobs ) {
+ logger.debug("Rescheduling job {} - maximum
parallel job count of {} reached!", info.event, this.maximumParallelJobs);
process = false;
wait = true;
}
@@ -715,6 +720,7 @@
// if this is the main queue and we have reached the max number of
parallel jobs
// we wait a little bit before continuing
if ( wait ) {
+ logger.debug("Sleeping for {} seconds.", sleepTime);
try {
Thread.sleep(sleepTime * 1000);
} catch (InterruptedException ie) {
@@ -724,6 +730,7 @@
}
// if we have to put back the job, we do it now
if ( putback ) {
+ logger.debug("Putting job {} back into the queue.", info.event);
final EventInfo eInfo = info;
final Date fireDate = new Date();
fireDate.setTime(System.currentTimeMillis() + this.sleepTime *
1000);
@@ -903,6 +910,7 @@
final boolean parallelProcessing =
event.getProperty(EventUtil.PROPERTY_JOB_QUEUE_NAME) != null
||
event.getProperty(EventUtil.PROPERTY_JOB_PARALLEL) != null;
final String jobTopic =
(String)event.getProperty(EventUtil.PROPERTY_JOB_TOPIC);
+ logger.debug("Starting job {}", event);
boolean unlock = true;
try {
if ( isMainQueue && parallelProcessing ) {
