You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2016/09/08 14:46:14 UTC
[32/50] ignite git commit: Mnors.
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 <vo...@gridgain.com>
Authored: Wed Sep 7 20:22:53 2016 +0300
Committer: vozerov-gridgain <vo...@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);
+ }
}