You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@turbine.apache.org by as...@apache.org on 2002/02/17 08:08:26 UTC
cvs commit: jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/engine CacheEventQueue.java
asmuts 02/02/16 23:08:26
Modified: src/java/org/apache/stratum/jcs/engine CacheEventQueue.java
Log:
changed log level for now
Revision Changes Path
1.7 +66 -18 jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/engine/CacheEventQueue.java
Index: CacheEventQueue.java
===================================================================
RCS file: /home/cvs/jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/engine/CacheEventQueue.java,v
retrieving revision 1.6
retrieving revision 1.7
diff -u -r1.6 -r1.7
--- CacheEventQueue.java 16 Feb 2002 02:37:22 -0000 1.6
+++ CacheEventQueue.java 17 Feb 2002 07:08:26 -0000 1.7
@@ -85,7 +85,9 @@
}
}
- /** */
+ /**
+ * Event Q is emtpy.
+ */
public synchronized void destroy()
{
if ( !destroyed )
@@ -102,29 +104,38 @@
t = null;
- log.warn( "Cache event queue destroyed: " + this );
+ log.info( "Cache event queue destroyed: " + this );
}
}
- /** */
+ /**
+ * @return
+ */
public String toString()
{
return "listenerId=" + listenerId + ", cacheName=" + cacheName;
}
- /** */
+ /**
+ * @return The {3} value
+ */
public boolean isAlive()
{
return ( !destroyed );
}
- /** */
+ /**
+ * @return The {3} value
+ */
public byte getListenerId()
{
return listenerId;
}
- /** */
+ /**
+ * @param ce The feature to be added to the PutEvent attribute
+ * @exception IOException
+ */
public synchronized void addPutEvent( ICacheElement ce )
throws IOException
{
@@ -134,7 +145,10 @@
}
}
- /** */
+ /**
+ * @param key The feature to be added to the RemoveEvent attribute
+ * @exception IOException
+ */
public void addRemoveEvent( Serializable key )
throws IOException
{
@@ -144,7 +158,9 @@
}
}
- /** */
+ /**
+ * @exception IOException
+ */
public synchronized void addRemoveAllEvent()
throws IOException
{
@@ -154,7 +170,9 @@
}
}
- /** */
+ /**
+ * @exception IOException
+ */
public synchronized void addDisposeEvent()
throws IOException
{
@@ -164,7 +182,11 @@
}
}
- /** Adds an event to the queue. */
+ /**
+ * Adds an event to the queue.
+ *
+ * @param event
+ */
private void put( AbstractCacheEvent event )
{
try
@@ -192,14 +214,18 @@
*/
private class QProcessor extends Thread
{
- /** Constructor for the QProcessor object */
+ /**
+ * Constructor for the QProcessor object
+ */
QProcessor()
{
setDaemon( true );
}
- /** Main processing method for the QProcessor object */
+ /**
+ * Main processing method for the QProcessor object
+ */
public void run()
{
Runnable r = null;
@@ -225,7 +251,9 @@
// declare failure as listener is permanently unreachable.
queue = null;
listener = null;
- log.warn( "QProcessor exiting for " + CacheEventQueue.this );
+ // The listener failure logging more the problem of the user
+ // of the q.
+ log.info( "QProcessor exiting for " + CacheEventQueue.this );
}
}
@@ -285,7 +313,11 @@
}
- /** Description of the Method */
+ /**
+ * Description of the Method
+ *
+ * @exception IOException
+ */
protected abstract void doRun()
throws IOException;
}
@@ -325,7 +357,11 @@
}
- /** Description of the Method */
+ /**
+ * Description of the Method
+ *
+ * @exception IOException
+ */
protected void doRun()
throws IOException
{
@@ -363,7 +399,11 @@
}
- /** Description of the Method */
+ /**
+ * Description of the Method
+ *
+ * @exception IOException
+ */
protected void doRun()
throws IOException
{
@@ -380,7 +420,11 @@
*/
private class RemoveAllEvent extends AbstractCacheEvent
{
- /** Description of the Method */
+ /**
+ * Description of the Method
+ *
+ * @exception IOException
+ */
protected void doRun()
throws IOException
{
@@ -397,7 +441,11 @@
*/
private class DisposeEvent extends AbstractCacheEvent
{
- /** Description of the Method */
+ /**
+ * Description of the Method
+ *
+ * @exception IOException
+ */
protected void doRun()
throws IOException
{
--
To unsubscribe, e-mail: <ma...@jakarta.apache.org>
For additional commands, e-mail: <ma...@jakarta.apache.org>