asmuts 02/05/14 08:23:42
Modified: src/java/org/apache/jcs/engine/control/event
ElementEventQueue.java
Log:
Fixed the same event q bug here.
Revision Changes Path
1.3 +26 -2
jakarta-turbine-jcs/src/java/org/apache/jcs/engine/control/event/ElementEventQueue.java
Index: ElementEventQueue.java
===================================================================
RCS file:
/home/cvs/jakarta-turbine-jcs/src/java/org/apache/jcs/engine/control/event/ElementEventQueue.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- ElementEventQueue.java 13 May 2002 22:16:18 -0000 1.2
+++ ElementEventQueue.java 14 May 2002 15:23:42 -0000 1.3
@@ -114,6 +114,12 @@
if ( !destroyed )
{
ElementEventRunner runner = new ElementEventRunner( hand, event );
+
+ if ( log.isDebugEnabled() )
+ {
+ log.debug( "runner = " + runner );
+ }
+
put( runner );
}
}
@@ -149,17 +155,29 @@
{
if ( log.isDebugEnabled() )
{
- log.debug( "Waiting for something to come in to the Q" );
+ log.debug( "Waiting for something to come into the Q" );
}
queueLock.wait();
+
+ if ( log.isDebugEnabled() )
+ {
+ log.debug( "Something came into the Q" );
+ }
+
}
// we have the lock, and the list is not empty
Node node = head.next;
- AbstractElementEventRunner value = head.event;
+ AbstractElementEventRunner value = node.event;
+
+ if ( log.isDebugEnabled() )
+ {
+ log.debug( "head.event = " + head.event );
+ log.debug( "node.event = " + node.event );
+ }
// Node becomes the new head (head is always empty)
@@ -206,6 +224,12 @@
try
{
r = take();
+
+ if ( log.isDebugEnabled() )
+ {
+ log.debug( "r from take() = " + r );
+ }
+
}
catch ( InterruptedException e )
{
--
To unsubscribe, e-mail: <mailto:[EMAIL PROTECTED]>
For additional commands, e-mail: <mailto:[EMAIL PROTECTED]>
