Merge remote-tracking branch 'origin/ignite-5075-cc' into ignite-5075-cc
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/e36163fc Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/e36163fc Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/e36163fc Branch: refs/heads/ignite-5075-cc-debug Commit: e36163fc4e3abe8eb780bc03877c13265f9adea4 Parents: 8cbcef6 ab5aead Author: sboikov <[email protected]> Authored: Thu May 25 20:39:58 2017 +0300 Committer: sboikov <[email protected]> Committed: Thu May 25 20:39:58 2017 +0300 ---------------------------------------------------------------------- .../CacheContinuousQueryAcknowledgeBuffer.java | 120 ++++ .../CacheContinuousQueryDeployableObject.java | 110 ++++ .../continuous/CacheContinuousQueryEntry.java | 59 +- .../CacheContinuousQueryEventBuffer.java | 271 +++++++-- .../continuous/CacheContinuousQueryHandler.java | 606 ++++--------------- .../CacheContinuousQueryHandlerV2.java | 6 +- .../CacheContinuousQueryPartitionRecovery.java | 267 ++++++++ .../continuous/GridContinuousProcessor.java | 7 +- ...tinuousQueryAsyncFailoverAtomicSelfTest.java | 1 - .../CacheContinuousQueryEventBufferTest.java | 65 +- ...ContinuousQueryFailoverAbstractSelfTest.java | 79 ++- ...niteCacheContinuousQueryBackupQueueTest.java | 13 +- 12 files changed, 919 insertions(+), 685 deletions(-) ----------------------------------------------------------------------
