You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ak...@apache.org on 2015/08/31 16:10:56 UTC
[03/18] ignite git commit: Platforms: minor refactoring.
Platforms: minor refactoring.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/e6de574a
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/e6de574a
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/e6de574a
Branch: refs/heads/ignite-843
Commit: e6de574afd23bf2442ce816d181a7484ddbb6fcd
Parents: 8b625a3
Author: vozerov-gridgain <vo...@gridgain.com>
Authored: Mon Aug 31 09:38:16 2015 +0300
Committer: vozerov-gridgain <vo...@gridgain.com>
Committed: Mon Aug 31 09:38:16 2015 +0300
----------------------------------------------------------------------
.../processors/platform/PlatformTarget.java | 22 ++++++++++++++++++++
.../platform/PlatformAbstractTarget.java | 21 ++++---------------
2 files changed, 26 insertions(+), 17 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/e6de574a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/PlatformTarget.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/PlatformTarget.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/PlatformTarget.java
index 1d54b4e..b444247 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/PlatformTarget.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/PlatformTarget.java
@@ -17,6 +17,7 @@
package org.apache.ignite.internal.processors.platform;
+import org.apache.ignite.*;
import org.jetbrains.annotations.*;
/**
@@ -73,4 +74,25 @@ public interface PlatformTarget {
* @throws Exception In case of failure.
*/
public void inOutOp(int type, long inMemPtr, long outMemPtr, @Nullable Object arg) throws Exception;
+
+ /**
+ * Start listening for the future.
+ *
+ * @param futId Future ID.
+ * @param typ Result type.
+ * @throws IgniteCheckedException In case of failure.
+ */
+ @SuppressWarnings("UnusedDeclaration")
+ public void listenFuture(final long futId, int typ) throws Exception;
+
+ /**
+ * Start listening for the future for specific operation type.
+ *
+ * @param futId Future ID.
+ * @param typ Result type.
+ * @param opId Operation ID required to pick correct result writer.
+ * @throws IgniteCheckedException In case of failure.
+ */
+ @SuppressWarnings("UnusedDeclaration")
+ public void listenFutureForOperation(final long futId, int typ, int opId) throws Exception;
}
http://git-wip-us.apache.org/repos/asf/ignite/blob/e6de574a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/PlatformAbstractTarget.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/PlatformAbstractTarget.java b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/PlatformAbstractTarget.java
index b68b16e..903df0a 100644
--- a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/PlatformAbstractTarget.java
+++ b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/PlatformAbstractTarget.java
@@ -142,26 +142,13 @@ public abstract class PlatformAbstractTarget implements PlatformTarget {
return platformCtx;
}
- /**
- * Start listening for the future.
- *
- * @param futId Future ID.
- * @param typ Result type.
- */
- @SuppressWarnings("UnusedDeclaration")
- public void listenFuture(final long futId, int typ) throws IgniteCheckedException {
+ /** {@inheritDoc} */
+ @Override public void listenFuture(final long futId, int typ) throws Exception {
PlatformFutureUtils.listen(platformCtx, currentFutureWrapped(), futId, typ, null);
}
- /**
- * Start listening for the future.
- *
- * @param futId Future ID.
- * @param typ Result type.
- * @param opId Operation ID required to pick correct result writer.
- */
- @SuppressWarnings("UnusedDeclaration")
- public void listenFuture(final long futId, int typ, int opId) throws IgniteCheckedException {
+ /** {@inheritDoc} */
+ @Override public void listenFutureForOperation(final long futId, int typ, int opId) throws Exception {
PlatformFutureUtils.listen(platformCtx, currentFutureWrapped(), futId, typ, futureWriter(opId));
}