ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject ignite git commit: Minor fixes.
Date Thu, 28 Jul 2016 14:40:21 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-3553 e998d0b46 -> 922da43f5


Minor fixes.


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

Branch: refs/heads/ignite-3553
Commit: 922da43f5cf936bdcad9619fc758957462297215
Parents: e998d0b
Author: vozerov-gridgain <vozerov@gridgain.com>
Authored: Thu Jul 28 17:39:16 2016 +0300
Committer: vozerov-gridgain <vozerov@gridgain.com>
Committed: Thu Jul 28 17:39:16 2016 +0300

----------------------------------------------------------------------
 .../processors/igfs/client/IgfsClientAbstractCallable.java     | 6 +++++-
 .../processors/igfs/client/IgfsClientAffinityCallable.java     | 4 ++++
 .../processors/igfs/client/IgfsClientSetTimesCallable.java     | 2 ++
 .../processors/igfs/client/IgfsClientUpdateCallable.java       | 2 +-
 4 files changed, 12 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/922da43f/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/client/IgfsClientAbstractCallable.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/client/IgfsClientAbstractCallable.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/client/IgfsClientAbstractCallable.java
index 92bdf30..1d7183c 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/client/IgfsClientAbstractCallable.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/client/IgfsClientAbstractCallable.java
@@ -99,7 +99,7 @@ public abstract class IgfsClientAbstractCallable<T> implements IgniteCallable<T>
                 return new IgfsClientRenameCallable();
 
             case IgfsClientSetTimesCallable.TYPE_ID:
-                return new IgfsClientUpdateCallable();
+                return new IgfsClientSetTimesCallable();
 
             case IgfsClientSizeCallable.TYPE_ID:
                 return new IgfsClientSizeCallable();
@@ -264,12 +264,16 @@ public abstract class IgfsClientAbstractCallable<T> implements
IgniteCallable<T>
             case 0:
                 igfsName = reader.readString("igfsName");
 
+                break;
+
             case 1:
                 String pathStr = reader.readString("path");
 
                 if (reader.isLastRead())
                     path = new IgfsPath(pathStr);
 
+                break;
+
             default:
                 readFrom0(reader, fieldId - BASE_FIELDS_CNT);
         }

http://git-wip-us.apache.org/repos/asf/ignite/blob/922da43f/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/client/IgfsClientAffinityCallable.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/client/IgfsClientAffinityCallable.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/client/IgfsClientAffinityCallable.java
index 3fc00fb..2a25f68 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/client/IgfsClientAffinityCallable.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/client/IgfsClientAffinityCallable.java
@@ -119,9 +119,13 @@ public class IgfsClientAffinityCallable extends IgfsClientAbstractCallable<Colle
             case 0:
                 start = reader.readLong("start");
 
+                break;
+
             case 1:
                 len = reader.readLong("len");
 
+                break;
+
             default:
                 assert fieldId == 2;
 

http://git-wip-us.apache.org/repos/asf/ignite/blob/922da43f/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/client/IgfsClientSetTimesCallable.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/client/IgfsClientSetTimesCallable.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/client/IgfsClientSetTimesCallable.java
index b746427..3a39ee6 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/client/IgfsClientSetTimesCallable.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/client/IgfsClientSetTimesCallable.java
@@ -109,6 +109,8 @@ public class IgfsClientSetTimesCallable extends IgfsClientAbstractCallable<Void>
             case 0:
                 accessTime = reader.readLong("accessTime");
 
+                break;
+
             default:
                 assert fieldId == 1;
 

http://git-wip-us.apache.org/repos/asf/ignite/blob/922da43f/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/client/IgfsClientUpdateCallable.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/client/IgfsClientUpdateCallable.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/client/IgfsClientUpdateCallable.java
index 57886fe..40f6bfd 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/client/IgfsClientUpdateCallable.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/client/IgfsClientUpdateCallable.java
@@ -96,7 +96,7 @@ public class IgfsClientUpdateCallable extends IgfsClientAbstractCallable<IgfsFil
     @Override protected void readFrom0(MessageReader reader, int fieldId) {
         assert fieldId == 0;
 
-        props = reader.readMap("recursive", MessageCollectionItemType.STRING, MessageCollectionItemType.STRING,
false);
+        props = reader.readMap("props", MessageCollectionItemType.STRING, MessageCollectionItemType.STRING,
false);
     }
 
     /** {@inheritDoc} */


Mime
View raw message