ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [32/50] ignite git commit: Mnors.
Date Thu, 08 Sep 2016 14:46:14 GMT
Mnors.


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

Branch: refs/heads/ignite-3199-1
Commit: 9807ee352ecd7cdbfd175a532f2a4c70eb65bd84
Parents: 5543901
Author: vozerov-gridgain <vozerov@gridgain.com>
Authored: Wed Sep 7 20:22:53 2016 +0300
Committer: vozerov-gridgain <vozerov@gridgain.com>
Committed: Wed Sep 7 20:22:53 2016 +0300

----------------------------------------------------------------------
 .../platform/websession/LockEntryProcessor.java           | 10 ++++++++--
 .../platform/websession/SetAndUnlockEntryProcessor.java   | 10 ++++++++--
 .../platform/websession/UnlockEntryProcessor.java         | 10 ++++++++--
 3 files changed, 24 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/9807ee35/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/websession/LockEntryProcessor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/websession/LockEntryProcessor.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/websession/LockEntryProcessor.java
index 03ae929..7cf3016 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/websession/LockEntryProcessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/websession/LockEntryProcessor.java
@@ -18,6 +18,7 @@
 package org.apache.ignite.internal.processors.platform.websession;
 
 import org.apache.ignite.cache.CacheEntryProcessor;
+import org.apache.ignite.internal.util.typedef.internal.S;
 
 import javax.cache.processor.EntryProcessorException;
 import javax.cache.processor.MutableEntry;
@@ -30,7 +31,7 @@ public class LockEntryProcessor implements CacheEntryProcessor<String,
SessionSt
     private static final long serialVersionUID = 0L;
 
     /** {@inheritDoc} */
-    @Override public Object process(MutableEntry<String, SessionStateData> entry, Object...
objects)
+    @Override public Object process(MutableEntry<String, SessionStateData> entry, Object...
args)
         throws EntryProcessorException {
         // Arg contains lock info: node id + thread id
         // Return result is either BinarizableSessionStateStoreData (when not locked) or
lockAge (when locked)
@@ -45,7 +46,7 @@ public class LockEntryProcessor implements CacheEntryProcessor<String,
SessionSt
         if (data.locked())
             return data.lockTime();
 
-        LockInfo lockInfo = (LockInfo)objects[0];
+        LockInfo lockInfo = (LockInfo)args[0];
 
         // Not locked: lock and return result
         data.lock(lockInfo);
@@ -55,4 +56,9 @@ public class LockEntryProcessor implements CacheEntryProcessor<String,
SessionSt
 
         return data;
     }
+
+    /** {@inheritDoc */
+    @Override public String toString() {
+        return S.toString(LockEntryProcessor.class, this);
+    }
 }

http://git-wip-us.apache.org/repos/asf/ignite/blob/9807ee35/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/websession/SetAndUnlockEntryProcessor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/websession/SetAndUnlockEntryProcessor.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/websession/SetAndUnlockEntryProcessor.java
index 6ac8ed1..19f3a38 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/websession/SetAndUnlockEntryProcessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/websession/SetAndUnlockEntryProcessor.java
@@ -18,6 +18,7 @@
 package org.apache.ignite.internal.processors.platform.websession;
 
 import org.apache.ignite.cache.CacheEntryProcessor;
+import org.apache.ignite.internal.util.typedef.internal.S;
 
 import javax.cache.processor.EntryProcessorException;
 import javax.cache.processor.MutableEntry;
@@ -30,7 +31,7 @@ public class SetAndUnlockEntryProcessor implements CacheEntryProcessor<String,
S
     private static final long serialVersionUID = 0L;
 
     /** {@inheritDoc} */
-    @Override public Object process(MutableEntry<String, SessionStateData> entry, Object...
objects)
+    @Override public Object process(MutableEntry<String, SessionStateData> entry, Object...
args)
         throws EntryProcessorException {
         assert entry.exists();
 
@@ -39,7 +40,7 @@ public class SetAndUnlockEntryProcessor implements CacheEntryProcessor<String,
S
         assert data != null;
         assert data.lockNodeId() != null;
 
-        SessionStateData newData = (SessionStateData)objects[0];
+        SessionStateData newData = (SessionStateData)args[0];
 
         if (!data.lockNodeId().equals(newData.lockNodeId()))
             throw new IllegalStateException("Can not unlock session data: lock node id check
failed.");
@@ -58,4 +59,9 @@ public class SetAndUnlockEntryProcessor implements CacheEntryProcessor<String,
S
 
         return null;
     }
+
+    /** {@inheritDoc */
+    @Override public String toString() {
+        return S.toString(SetAndUnlockEntryProcessor.class, this);
+    }
 }

http://git-wip-us.apache.org/repos/asf/ignite/blob/9807ee35/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/websession/UnlockEntryProcessor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/websession/UnlockEntryProcessor.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/websession/UnlockEntryProcessor.java
index f6aa798..1075958 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/websession/UnlockEntryProcessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/websession/UnlockEntryProcessor.java
@@ -18,6 +18,7 @@
 package org.apache.ignite.internal.processors.platform.websession;
 
 import org.apache.ignite.cache.CacheEntryProcessor;
+import org.apache.ignite.internal.util.typedef.internal.S;
 
 import javax.cache.processor.EntryProcessorException;
 import javax.cache.processor.MutableEntry;
@@ -30,7 +31,7 @@ public class UnlockEntryProcessor implements CacheEntryProcessor<String,
Session
     private static final long serialVersionUID = 0L;
 
     /** {@inheritDoc} */
-    @Override public Object process(MutableEntry<String, SessionStateData> entry, Object...
objects)
+    @Override public Object process(MutableEntry<String, SessionStateData> entry, Object...
args)
         throws EntryProcessorException {
         assert entry.exists();
 
@@ -39,7 +40,7 @@ public class UnlockEntryProcessor implements CacheEntryProcessor<String,
Session
         assert data != null;
         assert data.lockNodeId() != null;
 
-        LockInfo lockInfo = (LockInfo)objects[0];
+        LockInfo lockInfo = (LockInfo)args[0];
 
         if (!data.lockNodeId().equals(lockInfo.nodeId()))
             throw new IllegalStateException("Can not unlock session data: lock node id check
failed.");
@@ -54,4 +55,9 @@ public class UnlockEntryProcessor implements CacheEntryProcessor<String,
Session
 
         return null;
     }
+
+    /** {@inheritDoc */
+    @Override public String toString() {
+        return S.toString(UnlockEntryProcessor.class, this);
+    }
 }


Mime
View raw message