ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ivasilin...@apache.org
Subject incubator-ignite git commit: #ignite-gg-10610: add security check for data streamer update job.
Date Tue, 28 Jul 2015 11:54:22 GMT
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 <ivasilinets@gridgain.com>
Authored: Tue Jul 28 14:54:12 2015 +0300
Committer: ivasilinets <ivasilinets@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();
 


Mime
View raw message