You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by iv...@apache.org on 2015/07/28 13:54:22 UTC
incubator-ignite git commit: #ignite-gg-10610: add security check for
data streamer update job.
Repository: incubator-ignite
Updated Branches:
refs/heads/ignite-gg-10610 67f9cce4e -> e64e89613
#ignite-gg-10610: add security check for data streamer update job.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/e64e8961
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/e64e8961
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/e64e8961
Branch: refs/heads/ignite-gg-10610
Commit: e64e896137ab9fc715423ea7b65c07f3642c5447
Parents: 67f9cce
Author: ivasilinets <iv...@gridgain.com>
Authored: Tue Jul 28 14:54:12 2015 +0300
Committer: ivasilinets <iv...@gridgain.com>
Committed: Tue Jul 28 14:54:12 2015 +0300
----------------------------------------------------------------------
.../internal/processors/datastreamer/DataStreamerUpdateJob.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/e64e8961/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerUpdateJob.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerUpdateJob.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerUpdateJob.java
index 21ba3ac..e6ae4ac 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerUpdateJob.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerUpdateJob.java
@@ -22,6 +22,7 @@ import org.apache.ignite.internal.*;
import org.apache.ignite.internal.processors.cache.*;
import org.apache.ignite.internal.util.lang.*;
import org.apache.ignite.internal.util.typedef.*;
+import org.apache.ignite.plugin.security.*;
import org.apache.ignite.stream.*;
import org.jetbrains.annotations.*;
@@ -92,6 +93,9 @@ class DataStreamerUpdateJob implements GridPlainCallable<Object> {
cache.context().awaitStarted();
+ if (ctx.security().enabled())
+ ctx.security().authorize(cacheName, SecurityPermission.STREAMING_ADD, null);
+
if (skipStore)
cache = (IgniteCacheProxy<?, ?>)cache.withSkipStore();