Merge branches 'ignite-843' and 'master' of https://git-wip-us.apache.org/repos/asf/ignite into ignite-843
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/57779501 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/57779501 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/57779501 Branch: refs/heads/ignite-843 Commit: 5777950187975c799ea66b9d2d75c7afca7731af Parents: fcf3101 5a948dc Author: Alexey Kuznetsov <[email protected]> Authored: Wed Sep 2 08:59:48 2015 +0700 Committer: Alexey Kuznetsov <[email protected]> Committed: Wed Sep 2 08:59:48 2015 +0700 ---------------------------------------------------------------------- idea/ignite_codeStyle.xml | 11 +- modules/core/pom.xml | 6 +- .../internal/GridEventConsumeHandler.java | 15 +- .../managers/communication/GridIoManager.java | 50 +- .../GridLifecycleAwareMessageFilter.java | 38 - .../eventstorage/GridEventStorageManager.java | 16 +- .../processors/cache/GridCacheAdapter.java | 5 +- .../processors/cache/GridCacheProcessor.java | 27 +- .../cache/GridLoadCacheCloseablePredicate.java | 30 - .../distributed/dht/GridDhtCacheAdapter.java | 6 +- .../GridDhtPartitionsExchangeFuture.java | 94 +- .../CacheQueryCloseableScanBiPredicate.java | 30 - .../cache/query/GridCacheQueryManager.java | 52 +- .../CacheContinuousQueryFilterEx.java | 31 - .../continuous/CacheContinuousQueryHandler.java | 5 +- .../platform/PlatformAwareEventFilter.java | 39 - .../processors/platform/PlatformContext.java | 37 +- .../platform/PlatformEventFilterListener.java | 39 + .../processors/platform/PlatformException.java | 71 + .../platform/PlatformExtendedException.java | 57 + .../platform/PlatformLocalEventListener.java | 28 - .../platform/PlatformNativeException.java | 77 + .../platform/PlatformNoCallbackException.java | 50 + .../cache/PlatformCacheEntryFilter.java | 11 +- .../cache/PlatformCacheEntryProcessor.java | 27 + .../cache/query/PlatformContinuousQuery.java | 6 +- .../query/PlatformContinuousQueryFilter.java | 30 + .../callback/PlatformCallbackGateway.java | 10 +- .../cluster/PlatformClusterNodeFilter.java | 28 + .../datastreamer/PlatformStreamReceiver.java | 27 + .../platform/message/PlatformMessageFilter.java | 40 + .../internal/util/GridStripedSpinBusyLock.java | 127 + .../cache/IgniteDynamicCacheAndNodeStop.java | 95 + .../CachePutAllFailoverAbstractTest.java | 234 ++ .../distributed/CachePutAllFailoverTxTest.java | 30 + .../testsuites/IgniteCacheTestSuite2.java | 4 +- .../platform/src/main/cpp/common/Makefile.am | 45 + .../platform/src/main/cpp/common/configure.ac | 62 + .../src/main/cpp/common/ignite-common.pc.in | 9 + .../src/main/cpp/common/include/Makefile.am | 22 + .../common/include/ignite/common/concurrent.h | 210 ++ .../cpp/common/include/ignite/common/exports.h | 145 ++ .../cpp/common/include/ignite/common/java.h | 652 ++++++ .../cpp/common/os/linux/include/Makefile.am | 21 + .../os/linux/include/ignite/common/common.h | 81 + .../linux/include/ignite/common/concurrent_os.h | 394 ++++ .../src/main/cpp/common/os/linux/src/common.cpp | 59 + .../cpp/common/os/linux/src/concurrent_os.cpp | 175 ++ .../os/win/include/ignite/common/common.h | 56 + .../win/include/ignite/common/concurrent_os.h | 406 ++++ .../src/main/cpp/common/os/win/src/common.cpp | 65 + .../cpp/common/os/win/src/concurrent_os.cpp | 151 ++ .../src/main/cpp/common/project/README.TXT | 1 + .../src/main/cpp/common/project/vs/README.TXT | 1 + .../main/cpp/common/project/vs/common.vcxproj | 202 ++ .../common/project/vs/common.vcxproj.filters | 54 + .../src/main/cpp/common/project/vs/module.def | 99 + .../src/main/cpp/common/project/vs/targetver.h | 25 + .../src/main/cpp/common/src/concurrent.cpp | 94 + .../src/main/cpp/common/src/exports.cpp | 413 ++++ .../platform/src/main/cpp/common/src/java.cpp | 2204 ++++++++++++++++++ .../platform/PlatformAbstractTarget.java | 34 +- .../platform/PlatformContextImpl.java | 621 +++++ .../processors/platform/PlatformException.java | 71 - .../platform/PlatformExtendedException.java | 39 - .../platform/PlatformNoCallbackException.java | 50 - .../platform/cache/PlatformCache.java | 44 +- .../cache/PlatformCacheEntryFilterImpl.java | 5 +- .../cache/PlatformCacheEntryProcessor.java | 220 -- .../cache/PlatformCacheEntryProcessorImpl.java | 220 ++ .../PlatformCachePartialUpdateException.java | 24 +- .../PlatformContinuousQueryRemoteFilter.java | 20 +- .../cluster/PlatformClusterNodeFilter.java | 79 - .../cluster/PlatformClusterNodeFilterImpl.java | 78 + .../platform/compute/PlatformAbstractTask.java | 1 + .../compute/PlatformNativeException.java | 77 - .../datastreamer/PlatformDataStreamer.java | 2 +- .../datastreamer/PlatformStreamReceiver.java | 120 - .../PlatformStreamReceiverImpl.java | 119 + .../platform/events/PlatformEventFilter.java | 164 -- .../events/PlatformEventFilterListenerImpl.java | 163 ++ .../platform/events/PlatformEvents.java | 15 +- .../messaging/PlatformMessageFilter.java | 110 - .../messaging/PlatformMessageFilterImpl.java | 110 + .../messaging/PlatformMessageLocalFilter.java | 9 +- .../platform/messaging/PlatformMessaging.java | 7 +- .../transactions/PlatformTransactions.java | 2 +- .../platform/utils/PlatformFutureUtils.java | 82 +- .../platform/utils/PlatformUtils.java | 2 +- parent/pom.xml | 10 + 90 files changed, 8245 insertions(+), 1382 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/57779501/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/57779501/parent/pom.xml ----------------------------------------------------------------------
