[hornetq-commits] JBoss hornetq SVN: r8391 - in trunk/src/main/org/hornetq/core: replication/impl and 1 other directory.
Author: clebert.suconic(a)jboss.com
Date: 2009-11-23 22:50:27 -0500 (Mon, 23 Nov 2009)
New Revision: 8391
Modified:
trunk/src/main/org/hornetq/core/persistence/impl/journal/OperationContextImpl.java
trunk/src/main/org/hornetq/core/replication/impl/ReplicationManagerImpl.java
Log:
Tweaks
Modified:
trunk/src/main/org/hornetq/core/persistence/impl/journal/OperationContextImpl.java
===================================================================
---
trunk/src/main/org/hornetq/core/persistence/impl/journal/OperationContextImpl.java 2009-11-24
03:26:19 UTC (rev 8390)
+++
trunk/src/main/org/hornetq/core/persistence/impl/journal/OperationContextImpl.java 2009-11-24
03:50:27 UTC (rev 8391)
@@ -25,9 +25,15 @@
/**
*
- * This class will hold operations when there are IO operations...
- * and it will
+ * Each instance of OperationContextImpl is associated with an executor (usually an
ordered Executor).
*
+ * Tasks are hold until the operations are complete and executed in the natural order as
soon as the operations are returned
+ * from replication and storage.
+ *
+ * If there are no pending IO operations, the tasks are just executed at the callers
thread without any context switch.
+ *
+ * So, if you are doing operations that are not dependent on IO (e.g
NonPersistentMessages) you wouldn't have any context switch.
+ *
* @author <mailto:clebert.suconic@jboss.org">Clebert Suconic</a>
*/
public class OperationContextImpl implements OperationContext
Modified: trunk/src/main/org/hornetq/core/replication/impl/ReplicationManagerImpl.java
===================================================================
---
trunk/src/main/org/hornetq/core/replication/impl/ReplicationManagerImpl.java 2009-11-24
03:26:19 UTC (rev 8390)
+++
trunk/src/main/org/hornetq/core/replication/impl/ReplicationManagerImpl.java 2009-11-24
03:50:27 UTC (rev 8391)
@@ -26,7 +26,6 @@
import org.hornetq.core.logging.Logger;
import org.hornetq.core.paging.PagedMessage;
import org.hornetq.core.persistence.OperationContext;
-import org.hornetq.core.persistence.StorageManager;
import org.hornetq.core.persistence.impl.journal.OperationContextImpl;
import org.hornetq.core.remoting.Channel;
import org.hornetq.core.remoting.ChannelHandler;