ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [5/5] incubator-ignite git commit: # ignite-710 minor
Date Wed, 22 Apr 2015 13:50:51 GMT
# ignite-710 minor


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

Branch: refs/heads/ignite-710
Commit: b0e6c73f054341caf910839cf03214b6182f3353
Parents: 24aa806
Author: sboikov <sboikov@gridgain.com>
Authored: Wed Apr 22 16:50:35 2015 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Wed Apr 22 16:50:35 2015 +0300

----------------------------------------------------------------------
 .../internal/processors/datastreamer/DataStreamerRequest.java  | 6 ++++++
 1 file changed, 6 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b0e6c73f/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerRequest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerRequest.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerRequest.java
index 6f48118..0d24ee0 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerRequest.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerRequest.java
@@ -102,6 +102,7 @@ public class DataStreamerRequest implements Message {
      * @param ldrParticipants Loader participants.
      * @param clsLdrId Class loader ID.
      * @param forceLocDep Force local deployment.
+     * @param topVer Topology version.
      */
     public DataStreamerRequest(long reqId,
         byte[] resTopicBytes,
@@ -117,6 +118,8 @@ public class DataStreamerRequest implements Message {
         IgniteUuid clsLdrId,
         boolean forceLocDep,
         @NotNull AffinityTopologyVersion topVer) {
+        assert topVer != null;
+
         this.reqId = reqId;
         this.resTopicBytes = resTopicBytes;
         this.cacheName = cacheName;
@@ -224,6 +227,9 @@ public class DataStreamerRequest implements Message {
         return forceLocDep;
     }
 
+    /**
+     * @return Topology version.
+     */
     public AffinityTopologyVersion topologyVersion() {
         return topVer;
     }


Mime
View raw message