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 2017/03/21 11:36:11 UTC
ignite git commit: Added pre-completed ops.
Repository: ignite
Updated Branches:
refs/heads/ignite-4565-ddl d5b41960d -> 2905fd139
Added pre-completed ops.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/2905fd13
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/2905fd13
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/2905fd13
Branch: refs/heads/ignite-4565-ddl
Commit: 2905fd1393bb15ce9b07328b7d6d364b72e5fa1c
Parents: d5b4196
Author: devozerov <vo...@gridgain.com>
Authored: Tue Mar 21 14:35:58 2017 +0300
Committer: devozerov <vo...@gridgain.com>
Committed: Tue Mar 21 14:35:58 2017 +0300
----------------------------------------------------------------------
.../processors/query/ddl/IndexOperationHandler.java | 12 +++++++++++-
1 file changed, 11 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/2905fd13/modules/core/src/main/java/org/apache/ignite/internal/processors/query/ddl/IndexOperationHandler.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/ddl/IndexOperationHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/ddl/IndexOperationHandler.java
index 116b613..83545dc 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/ddl/IndexOperationHandler.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/ddl/IndexOperationHandler.java
@@ -66,14 +66,24 @@ public class IndexOperationHandler {
* @param ctx Context.
* @param qryProc Query processor.
* @param op Target operation.
+ * @param dummy Whether this is dummy request which should be considered completed right-away. This is the case for
+ * client nodes and for server node in-progress operations received through discovery data.
*/
- public IndexOperationHandler(GridKernalContext ctx, GridQueryProcessor qryProc, AbstractIndexOperation op) {
+ public IndexOperationHandler(GridKernalContext ctx, GridQueryProcessor qryProc, AbstractIndexOperation op,
+ boolean dummy) {
this.ctx = ctx;
this.qryProc = qryProc;
this.op = op;
log = ctx.log(IndexOperationHandler.class);
+
opFut = new GridFutureAdapter();
+
+ if (dummy) {
+ init = true;
+
+ opFut.onDone();
+ }
}
/**