Repository: ignite Updated Branches: refs/heads/ignite-4565-ddl e316c4b74 -> 6a7aace9c
Minors. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/6a7aace9 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/6a7aace9 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/6a7aace9 Branch: refs/heads/ignite-4565-ddl Commit: 6a7aace9c813490fb49a87221d0a96564949600e Parents: e316c4b Author: devozerov <[email protected]> Authored: Fri Mar 10 11:12:09 2017 +0300 Committer: devozerov <[email protected]> Committed: Fri Mar 10 11:12:09 2017 +0300 ---------------------------------------------------------------------- .../processors/query/index/QueryIndexHandler.java | 16 +++++++--------- 1 file changed, 7 insertions(+), 9 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/6a7aace9/modules/core/src/main/java/org/apache/ignite/internal/processors/query/index/QueryIndexHandler.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/index/QueryIndexHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/index/QueryIndexHandler.java index 1623fc6..109adf1 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/index/QueryIndexHandler.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/index/QueryIndexHandler.java @@ -26,7 +26,6 @@ import org.apache.ignite.internal.IgniteInternalFuture; import org.apache.ignite.internal.processors.query.QueryIndexDescriptorImpl; import org.apache.ignite.internal.processors.query.QueryTypeDescriptorImpl; import org.apache.ignite.internal.util.future.GridFinishedFuture; -import org.apache.ignite.internal.util.future.GridFutureAdapter; import org.apache.ignite.internal.util.typedef.F; import java.util.Collection; @@ -51,7 +50,6 @@ public class QueryIndexHandler { private final Map<QueryIndexKey, Descriptor> idxs = new ConcurrentHashMap<>(); /** Client futures. */ - // TODO: Special future which is aware of index key, handle it during cache, type undeploy and disconnect. private final Map<UUID, QueryIndexClientFuture> cliFuts = new ConcurrentHashMap<>(); /** RW lock. */ @@ -97,6 +95,13 @@ public class QueryIndexHandler { } /** + * Handle disconnect. + */ + public void onDisconnected() { + // TODO: Complete client futures, clear state. + } + + /** * Handle cache creation. * * @param space Space. @@ -212,13 +217,6 @@ public class QueryIndexHandler { } /** - * Handle disconnect. - */ - public void onDisconnected() { - // TODO - } - - /** * Handle dynamic index creation. * * @param space Space.
