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/07/28 14:40:21 UTC
ignite git commit: Minor fixes.
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 <vo...@gridgain.com>
Authored: Thu Jul 28 17:39:16 2016 +0300
Committer: vozerov-gridgain <vo...@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} */