# IGNITE-379 Fix tests don't check sessionEnd without transaction.

Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/d99f2726
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/d99f2726
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/d99f2726

Branch: refs/heads/ignite-471
Commit: d99f272623c40f3bd669f648843f0f5ac44dfc40
Parents: 36bc59a
Author: sevdokimov <sevdoki...@gridgain.com>
Authored: Tue Mar 24 19:19:51 2015 +0300
Committer: sevdokimov <sevdoki...@gridgain.com>
Committed: Tue Mar 24 19:19:51 2015 +0300

----------------------------------------------------------------------
 .../cache/integration/IgniteCacheStoreSessionAbstractTest.java | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d99f2726/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/integration/IgniteCacheStoreSessionAbstractTest.java
----------------------------------------------------------------------
diff --git 
a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/integration/IgniteCacheStoreSessionAbstractTest.java
 
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/integration/IgniteCacheStoreSessionAbstractTest.java
index 53ec1f6..7784003 100644
--- 
a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/integration/IgniteCacheStoreSessionAbstractTest.java
+++ 
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/integration/IgniteCacheStoreSessionAbstractTest.java
@@ -253,9 +253,11 @@ public abstract class IgniteCacheStoreSessionAbstractTest 
extends IgniteCacheAbs
 
         /** {@inheritDoc} */
         @Override public void sessionEnd(boolean commit) throws 
CacheWriterException {
-            log.info("Tx end [commit=" + commit + ", tx=" + 
session().transaction() + ']');
+            if (session().isWithinTransaction()) {
+                log.info("Tx end [commit=" + commit + ", tx=" + 
session().transaction() + ']');
 
-            checkSession("sessionEnd");
+                checkSession("sessionEnd");
+            }
         }
 
         /** {@inheritDoc} */

Reply via email to