ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [02/51] [partial] ignite git commit: IGNITE-1513: Finalized build procedure.
Date Tue, 22 Sep 2015 15:01:36 GMT
http://git-wip-us.apache.org/repos/asf/ignite/blob/f0bac562/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Config/native-client-test-cache-store.xml
----------------------------------------------------------------------
diff --git a/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Config/native-client-test-cache-store.xml b/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Config/native-client-test-cache-store.xml
deleted file mode 100644
index 9af4611..0000000
--- a/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Config/native-client-test-cache-store.xml
+++ /dev/null
@@ -1,125 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-
-<!--
-  Licensed to the Apache Software Foundation (ASF) under one or more
-  contributor license agreements.  See the NOTICE file distributed with
-  this work for additional information regarding copyright ownership.
-  The ASF licenses this file to You under the Apache License, Version 2.0
-  (the "License"); you may not use this file except in compliance with
-  the License.  You may obtain a copy of the License at
-
-       http://www.apache.org/licenses/LICENSE-2.0
-
-  Unless required by applicable law or agreed to in writing, software
-  distributed under the License is distributed on an "AS IS" BASIS,
-  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-  See the License for the specific language governing permissions and
-  limitations under the License.
--->
-
-<beans xmlns="http://www.springframework.org/schema/beans"
-       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-       xmlns:util="http://www.springframework.org/schema/util"
-       xsi:schemaLocation="
-        http://www.springframework.org/schema/beans
-        http://www.springframework.org/schema/beans/spring-beans.xsd
-        http://www.springframework.org/schema/util
-        http://www.springframework.org/schema/util/spring-util.xsd">
-    <bean id="grid.cfg" class="org.apache.ignite.configuration.IgniteConfiguration">
-        <property name="localHost" value="127.0.0.1"/>
-        <property name="connectorConfiguration"><null/></property>
-
-        <property name="includeEventTypes">
-            <util:constant static-field="org.apache.ignite.events.EventType.EVTS_CACHE"/>
-        </property>
-
-        <property name="cacheConfiguration">
-            <list>
-                <bean class="org.apache.ignite.configuration.CacheConfiguration">
-                    <property name="name" value="portable_store"/>
-                    <property name="cacheMode" value="LOCAL"/>
-                    <property name="atomicityMode" value="TRANSACTIONAL"/>
-                    <property name="writeThrough" value="true"/>
-                    <property name="readThrough" value="true"/>
-
-                    <property name="cacheStoreFactory">
-                        <bean class="org.apache.ignite.platform.dotnet.PlatformDotNetCacheStoreFactory">
-                            <property name="assemblyName" value="Apache.Ignite.Core.Tests"/>
-                            <property name="className" value="Apache.Ignite.Core.Tests.Cache.Store.CacheTestStore"/>
-                        </bean>
-                    </property>
-                </bean>
-
-                <bean class="org.apache.ignite.configuration.CacheConfiguration">
-                    <property name="name" value="object_store"/>
-                    <property name="cacheMode" value="LOCAL"/>
-                    <property name="atomicityMode" value="TRANSACTIONAL"/>
-                    <property name="writeThrough" value="true"/>
-                    <property name="readThrough" value="true"/>
-                    <property name="keepPortableInStore" value="false"/>
-
-                    <property name="cacheStoreFactory">
-                        <bean class="org.apache.ignite.platform.dotnet.PlatformDotNetCacheStoreFactory">
-                            <property name="assemblyName" value="Apache.Ignite.Core.Tests"/>
-                            <property name="className" value="Apache.Ignite.Core.Tests.Cache.Store.CacheTestStore"/>
-                        </bean>
-                    </property>
-                </bean>
-
-                <bean class="org.apache.ignite.configuration.CacheConfiguration">
-                    <property name="name" value="template_store*"/>
-                    <property name="cacheMode" value="LOCAL"/>
-                    <property name="atomicityMode" value="TRANSACTIONAL"/>
-                    <property name="writeThrough" value="true"/>
-                    <property name="readThrough" value="true"/>
-                    <property name="keepPortableInStore" value="false"/>
-
-                    <property name="cacheStoreFactory">
-                        <bean class="org.apache.ignite.platform.dotnet.PlatformDotNetCacheStoreFactory">
-                            <property name="assemblyName" value="Apache.Ignite.Core.Tests"/>
-                            <property name="className" value="Apache.Ignite.Core.Tests.Cache.Store.CacheTestStore"/>
-                        </bean>
-                    </property>
-                </bean>
-
-                <bean class="org.apache.ignite.configuration.CacheConfiguration">
-                    <property name="name" value="custom_store"/>
-                    <property name="cacheMode" value="LOCAL"/>
-                    <property name="atomicityMode" value="TRANSACTIONAL"/>
-                    <property name="writeThrough" value="true"/>
-                    <property name="readThrough" value="true"/>
-                    
-                    <property name="cacheStoreFactory">
-                        <bean class="org.apache.ignite.platform.dotnet.PlatformDotNetCacheStoreFactory">
-                            <property name="assemblyName" value="Apache.Ignite.Core.Tests"/>
-                            <property name="className" value="Apache.Ignite.Core.Tests.Cache.Store.CacheTestStore"/>
-                            <property name="properties">
-                                <map>
-                                    <entry key="IntProperty">
-                                        <value type="java.lang.Integer">42</value>
-                                    </entry>
-                                    <entry key="StringProperty" value="String value"/>
-                                </map>
-                            </property>
-                        </bean>
-                    </property>
-                </bean>
-            </list>
-        </property>
-
-        <property name="discoverySpi">
-            <bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
-                <property name="ipFinder">
-                    <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder">
-                        <property name="addresses">
-                            <list>
-                                <!-- In distributed environment, replace with actual host IP address. -->
-                                <value>127.0.0.1:47500..47501</value>
-                            </list>
-                        </property>
-                    </bean>
-                </property>
-            </bean>
-        </property>
-    </bean>
-</beans>

http://git-wip-us.apache.org/repos/asf/ignite/blob/f0bac562/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Config/native-client-test-cache.xml
----------------------------------------------------------------------
diff --git a/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Config/native-client-test-cache.xml b/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Config/native-client-test-cache.xml
deleted file mode 100644
index c48e867..0000000
--- a/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Config/native-client-test-cache.xml
+++ /dev/null
@@ -1,194 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-
-<!--
-  Licensed to the Apache Software Foundation (ASF) under one or more
-  contributor license agreements.  See the NOTICE file distributed with
-  this work for additional information regarding copyright ownership.
-  The ASF licenses this file to You under the Apache License, Version 2.0
-  (the "License"); you may not use this file except in compliance with
-  the License.  You may obtain a copy of the License at
-
-       http://www.apache.org/licenses/LICENSE-2.0
-
-  Unless required by applicable law or agreed to in writing, software
-  distributed under the License is distributed on an "AS IS" BASIS,
-  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-  See the License for the specific language governing permissions and
-  limitations under the License.
--->
-
-<beans xmlns="http://www.springframework.org/schema/beans"
-       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-       xmlns:util="http://www.springframework.org/schema/util"
-       xsi:schemaLocation="
-        http://www.springframework.org/schema/beans
-        http://www.springframework.org/schema/beans/spring-beans.xsd
-        http://www.springframework.org/schema/util
-        http://www.springframework.org/schema/util/spring-util.xsd">
-    <bean id="grid.cfg" class="org.apache.ignite.configuration.IgniteConfiguration">
-        <property name="localHost" value="127.0.0.1"/>
-        <property name="connectorConfiguration"><null/></property>
-
-        <property name="includeEventTypes">
-            <util:constant static-field="org.apache.ignite.events.EventType.EVTS_CACHE"/>
-        </property>
-
-        <property name="cacheConfiguration">
-            <list>
-                <bean parent="cache-template">
-                    <property name="name" value="local"/>
-                    <property name="cacheMode" value="LOCAL"/>
-                    <property name="atomicityMode" value="TRANSACTIONAL"/>
-                    <property name="startSize" value="10"/>
-                </bean>
-
-                <bean parent="cache-template">
-                    <property name="name" value="local_atomic"/>
-                    <property name="cacheMode" value="LOCAL"/>
-                    <property name="atomicityMode" value="ATOMIC"/>
-                    <property name="startSize" value="10"/>
-                </bean>
-
-                <bean parent="cache-template">
-                    <property name="name" value="partitioned"/>
-                    <property name="cacheMode" value="PARTITIONED"/>
-                    <property name="atomicityMode" value="TRANSACTIONAL"/>
-                    <property name="startSize" value="10"/>
-                </bean>
-
-                <bean parent="cache-template">
-                    <property name="name" value="partitioned_atomic"/>
-                    <property name="cacheMode" value="PARTITIONED"/>
-                    <property name="atomicityMode" value="ATOMIC"/>
-                    <property name="atomicWriteOrderMode" value="PRIMARY"/>
-                    <property name="startSize" value="10"/>
-                </bean>
-
-                <bean parent="cache-template">
-                    <property name="name" value="partitioned_near"/>
-                    <property name="cacheMode" value="PARTITIONED"/>
-                    <property name="atomicityMode" value="TRANSACTIONAL"/>
-                    <property name="nearConfiguration">
-                        <bean class="org.apache.ignite.configuration.NearCacheConfiguration" />
-                    </property>
-                    <property name="startSize" value="10"/>
-                </bean>
-
-                <bean parent="cache-template">
-                    <property name="name" value="partitioned_atomic_near"/>
-                    <property name="cacheMode" value="PARTITIONED"/>
-                    <property name="atomicityMode" value="ATOMIC"/>
-                    <property name="atomicWriteOrderMode" value="PRIMARY"/>
-                    <property name="nearConfiguration">
-                        <bean class="org.apache.ignite.configuration.NearCacheConfiguration" />
-                    </property>
-                    <property name="startSize" value="10"/>
-                </bean>
-
-                <bean parent="cache-template">
-                    <property name="name" value="replicated"/>
-                    <property name="cacheMode" value="REPLICATED"/>
-                    <property name="atomicityMode" value="TRANSACTIONAL"/>
-                    <property name="startSize" value="10"/>
-                </bean>
-
-                <bean parent="cache-template">
-                    <property name="name" value="replicated_atomic"/>
-                    <property name="cacheMode" value="REPLICATED"/>
-                    <property name="atomicityMode" value="ATOMIC"/>
-                    <property name="atomicWriteOrderMode" value="PRIMARY"/>
-                    <property name="startSize" value="10"/>
-                </bean>
-                
-                <bean parent="cache-template">
-                    <property name="name" value="template*"/>
-                    <property name="startSize" value="10"/>
-                </bean>
-            </list>
-        </property>
-
-        <property name="swapSpaceSpi">
-            <bean class="org.apache.ignite.spi.swapspace.inmemory.GridTestSwapSpaceSpi"/>
-        </property>
-
-        <property name="discoverySpi">
-            <bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
-                <property name="ipFinder">
-                    <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder">
-                        <property name="addresses">
-                            <list>
-                                <!-- In distributed environment, replace with actual host IP address. -->
-                                <value>127.0.0.1:47500..47501</value>
-                            </list>
-                        </property>
-                    </bean>
-                </property>
-            </bean>
-        </property>
-
-        <property name="transactionConfiguration">
-            <bean class="org.apache.ignite.configuration.TransactionConfiguration">
-                <property name="txSerializableEnabled" value="true"/>
-            </bean>
-        </property>
-    </bean>
-
-    <bean id="cache-template" abstract="true" class="org.apache.ignite.configuration.CacheConfiguration">
-        <property name="rebalanceMode" value="SYNC"/>
-        <property name="writeSynchronizationMode" value="FULL_SYNC"/>
-        <property name="swapEnabled" value="true"/>
-        <property name="backups" value="1"/>
-        <property name="eagerTtl" value="true"/>
-
-        <!--
-        <property name="typeMetadata">
-            <list>
-                <bean class="org.apache.ignite.cache.CacheTypeMetadata">
-                    <property name="valueType" value="GridPortablePerson"/>
-                    <property name="ascendingFields">
-                        <map>
-                            <entry key="age" value="java.lang.Integer"/>
-                        </map>
-                    </property>
-                    <property name="queryFields">
-                        <map>
-                            <entry key="name" value="java.lang.String"/>
-                        </map>
-                    </property>
-                    <property name="textFields">
-                        <list>
-                            <value>address</value>
-                        </list>
-                    </property>
-                </bean>
-                <bean class="org.apache.ignite.cache.CacheTypeMetadata">
-                    <property name="valueType" value="GridImplicitPortablePerson"/>
-                    <property name="ascendingFields">
-                        <map>
-                            <entry key="age" value="java.lang.Integer"/>
-                        </map>
-                    </property>
-                    <property name="queryFields">
-                        <map>
-                            <entry key="name" value="java.lang.String"/>
-                        </map>
-                    </property>
-                </bean>
-                <bean class="org.apache.ignite.cache.CacheTypeMetadata">
-                    <property name="valueType" value="GridNoDefPortablePerson"/>
-                    <property name="ascendingFields">
-                        <map>
-                            <entry key="age" value="java.lang.Integer"/>
-                        </map>
-                    </property>
-                    <property name="queryFields">
-                        <map>
-                            <entry key="name" value="java.lang.String"/>
-                        </map>
-                    </property>
-                </bean>
-            </list>
-        </property>
-        -->
-    </bean>
-</beans>

http://git-wip-us.apache.org/repos/asf/ignite/blob/f0bac562/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Config/portable.xml
----------------------------------------------------------------------
diff --git a/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Config/portable.xml b/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Config/portable.xml
deleted file mode 100644
index f013749..0000000
--- a/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Config/portable.xml
+++ /dev/null
@@ -1,56 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-
-<!--
-  Licensed to the Apache Software Foundation (ASF) under one or more
-  contributor license agreements.  See the NOTICE file distributed with
-  this work for additional information regarding copyright ownership.
-  The ASF licenses this file to You under the Apache License, Version 2.0
-  (the "License"); you may not use this file except in compliance with
-  the License.  You may obtain a copy of the License at
-
-       http://www.apache.org/licenses/LICENSE-2.0
-
-  Unless required by applicable law or agreed to in writing, software
-  distributed under the License is distributed on an "AS IS" BASIS,
-  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-  See the License for the specific language governing permissions and
-  limitations under the License.
--->
-
-<beans xmlns="http://www.springframework.org/schema/beans"
-       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-       xsi:schemaLocation="http://www.springframework.org/schema/beans
-        http://www.springframework.org/schema/beans/spring-beans.xsd">
-    <bean id="grid.cfg" class="org.apache.ignite.configuration.IgniteConfiguration">
-        <property name="localHost" value="127.0.0.1"/>
-        <property name="connectorConfiguration"><null/></property>
-
-        <property name="gridName" value="grid"/>
-
-        <property name="metricsUpdateFrequency" value="1000"/>
-        <property name="metricsLogFrequency" value="0"/>
-
-        <property name="cacheConfiguration">
-            <list>
-                <bean class="org.apache.ignite.configuration.CacheConfiguration">
-                    <property name="name" value="cache"/>
-                </bean>
-            </list>
-        </property>
-      
-        <property name="discoverySpi">
-            <bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
-                <property name="ipFinder">
-                    <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder">
-                        <property name="addresses">
-                            <list>
-                                <!-- In distributed environment, replace with actual host IP address. -->
-                                <value>127.0.0.1:47500..47502</value>
-                            </list>
-                        </property>
-                    </bean>
-                </property>
-            </bean>
-        </property>
-    </bean>
-</beans>

http://git-wip-us.apache.org/repos/asf/ignite/blob/f0bac562/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Config/start-test-grid1.xml
----------------------------------------------------------------------
diff --git a/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Config/start-test-grid1.xml b/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Config/start-test-grid1.xml
deleted file mode 100644
index 8559173..0000000
--- a/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Config/start-test-grid1.xml
+++ /dev/null
@@ -1,54 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-
-<!--
-  Licensed to the Apache Software Foundation (ASF) under one or more
-  contributor license agreements.  See the NOTICE file distributed with
-  this work for additional information regarding copyright ownership.
-  The ASF licenses this file to You under the Apache License, Version 2.0
-  (the "License"); you may not use this file except in compliance with
-  the License.  You may obtain a copy of the License at
-
-       http://www.apache.org/licenses/LICENSE-2.0
-
-  Unless required by applicable law or agreed to in writing, software
-  distributed under the License is distributed on an "AS IS" BASIS,
-  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-  See the License for the specific language governing permissions and
-  limitations under the License.
--->
-
-<beans xmlns="http://www.springframework.org/schema/beans"
-       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-       xsi:schemaLocation="http://www.springframework.org/schema/beans
-        http://www.springframework.org/schema/beans/spring-beans.xsd">
-    <bean id="grid.cfg" class="org.apache.ignite.configuration.IgniteConfiguration">
-        <property name="localHost" value="127.0.0.1"/>
-        <property name="connectorConfiguration"><null/></property>
-
-        <property name="gridName" value="grid1"/>
-
-        <property name="cacheConfiguration">
-            <list>
-                <bean class="org.apache.ignite.configuration.CacheConfiguration">
-                    <property name="name" value="cache1"/>
-                    <property name="rebalanceMode" value="SYNC"/>
-                </bean>
-            </list>
-        </property>
-
-        <property name="discoverySpi">
-            <bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
-                <property name="ipFinder">
-                    <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder">
-                        <property name="addresses">
-                            <list>
-                                <!-- In distributed environment, replace with actual host IP address. -->
-                                <value>127.0.0.1:47500..47502</value>
-                            </list>
-                        </property>
-                    </bean>
-                </property>
-            </bean>
-        </property>
-    </bean>
-</beans>

http://git-wip-us.apache.org/repos/asf/ignite/blob/f0bac562/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Config/start-test-grid2.xml
----------------------------------------------------------------------
diff --git a/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Config/start-test-grid2.xml b/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Config/start-test-grid2.xml
deleted file mode 100644
index cb628fe..0000000
--- a/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Config/start-test-grid2.xml
+++ /dev/null
@@ -1,45 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-
-<!--
-  Licensed to the Apache Software Foundation (ASF) under one or more
-  contributor license agreements.  See the NOTICE file distributed with
-  this work for additional information regarding copyright ownership.
-  The ASF licenses this file to You under the Apache License, Version 2.0
-  (the "License"); you may not use this file except in compliance with
-  the License.  You may obtain a copy of the License at
-
-       http://www.apache.org/licenses/LICENSE-2.0
-
-  Unless required by applicable law or agreed to in writing, software
-  distributed under the License is distributed on an "AS IS" BASIS,
-  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-  See the License for the specific language governing permissions and
-  limitations under the License.
--->
-
-<beans xmlns="http://www.springframework.org/schema/beans"
-       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-       xsi:schemaLocation="http://www.springframework.org/schema/beans
-        http://www.springframework.org/schema/beans/spring-beans.xsd">
-    <bean id="grid.cfg" class="org.apache.ignite.configuration.IgniteConfiguration">
-        <property name="localHost" value="127.0.0.1"/>
-        <property name="connectorConfiguration"><null/></property>
-
-        <property name="gridName" value="grid2"/>
-
-        <property name="discoverySpi">
-            <bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
-                <property name="ipFinder">
-                    <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder">
-                        <property name="addresses">
-                            <list>
-                                <!-- In distributed environment, replace with actual host IP address. -->
-                                <value>127.0.0.1:47500..47502</value>
-                            </list>
-                        </property>
-                    </bean>
-                </property>
-            </bean>
-        </property>
-    </bean>
-</beans>

http://git-wip-us.apache.org/repos/asf/ignite/blob/f0bac562/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Config/start-test-grid3.xml
----------------------------------------------------------------------
diff --git a/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Config/start-test-grid3.xml b/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Config/start-test-grid3.xml
deleted file mode 100644
index 753fad1..0000000
--- a/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Config/start-test-grid3.xml
+++ /dev/null
@@ -1,43 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-
-<!--
-  Licensed to the Apache Software Foundation (ASF) under one or more
-  contributor license agreements.  See the NOTICE file distributed with
-  this work for additional information regarding copyright ownership.
-  The ASF licenses this file to You under the Apache License, Version 2.0
-  (the "License"); you may not use this file except in compliance with
-  the License.  You may obtain a copy of the License at
-
-       http://www.apache.org/licenses/LICENSE-2.0
-
-  Unless required by applicable law or agreed to in writing, software
-  distributed under the License is distributed on an "AS IS" BASIS,
-  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-  See the License for the specific language governing permissions and
-  limitations under the License.
--->
-
-<beans xmlns="http://www.springframework.org/schema/beans"
-       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-       xsi:schemaLocation="http://www.springframework.org/schema/beans
-        http://www.springframework.org/schema/beans/spring-beans.xsd">
-    <bean id="grid.cfg" class="org.apache.ignite.configuration.IgniteConfiguration">
-        <property name="localHost" value="127.0.0.1"/>
-        <property name="connectorConfiguration"><null/></property>
-
-        <property name="discoverySpi">
-            <bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
-                <property name="ipFinder">
-                    <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder">
-                        <property name="addresses">
-                            <list>
-                                <!-- In distributed environment, replace with actual host IP address. -->
-                                <value>127.0.0.1:47500..47502</value>
-                            </list>
-                        </property>
-                    </bean>
-                </property>
-            </bean>
-        </property>
-    </bean>
-</beans>

http://git-wip-us.apache.org/repos/asf/ignite/blob/f0bac562/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Dataload/DataStreamerTest.cs
----------------------------------------------------------------------
diff --git a/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Dataload/DataStreamerTest.cs b/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Dataload/DataStreamerTest.cs
deleted file mode 100644
index 245ed5f..0000000
--- a/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Dataload/DataStreamerTest.cs
+++ /dev/null
@@ -1,592 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-namespace Apache.Ignite.Core.Tests.Dataload
-{
-    using System;
-    using System.Collections.Generic;
-    using System.Diagnostics;
-    using System.Linq;
-    using System.Threading;
-    using Apache.Ignite.Core.Cache;
-    using Apache.Ignite.Core.Datastream;
-    using Apache.Ignite.Core.Impl;
-    using Apache.Ignite.Core.Portable;
-    using Apache.Ignite.Core.Tests.Cache;
-    using NUnit.Framework;
-
-    /// <summary>
-    /// Data streamer tests.
-    /// </summary>
-    public class DataStreamerTest
-    {
-        /** Node name. */
-        protected const string GridName = "grid";
-
-        /** Cache name. */
-        protected const string CacheName = "partitioned";
-
-        /** Node. */
-        private IIgnite _grid;
-
-        /** Cache. */
-        private ICache<int, int?> _cache;
-
-        /// <summary>
-        /// Initialization routine.
-        /// </summary>
-        [TestFixtureSetUp]
-        public virtual void InitClient()
-        {
-            _grid = Ignition.Start(GetIgniteConfiguration(GridName));
-
-            Ignition.Start(GetIgniteConfiguration(GridName + "_1"));
-
-            _cache = _grid.GetCache<int, int?>(CacheName);
-        }
-
-        /// <summary>
-        ///
-        /// </summary>
-        [TestFixtureTearDown]
-        public virtual void StopGrids()
-        {
-            Ignition.StopAll(true);
-        }
-
-        /// <summary>
-        ///
-        /// </summary>
-        [SetUp]
-        public virtual void BeforeTest()
-        {
-            Console.WriteLine("Test started: " + TestContext.CurrentContext.Test.Name);
-
-            for (int i = 0; i < 100; i++)
-                _cache.Remove(i);
-        }
-
-        [TearDown]
-        public void AfterTest()
-        {
-            TestUtils.AssertHandleRegistryIsEmpty(_grid, 1000);
-        }
-
-        /// <summary>
-        /// Test data streamer property configuration. Ensures that at least no exceptions are thrown.
-        /// </summary>
-        [Test]
-        public void TestPropertyPropagation()
-        {
-            using (IDataStreamer<int, int> ldr = _grid.GetDataStreamer<int, int>(CacheName))
-            {
-                ldr.AllowOverwrite = true;
-                Assert.IsTrue(ldr.AllowOverwrite);
-                ldr.AllowOverwrite = false;
-                Assert.IsFalse(ldr.AllowOverwrite);
-
-                ldr.SkipStore = true;
-                Assert.IsTrue(ldr.SkipStore);
-                ldr.SkipStore = false;
-                Assert.IsFalse(ldr.SkipStore);
-
-                ldr.PerNodeBufferSize = 1;
-                Assert.AreEqual(1, ldr.PerNodeBufferSize);
-                ldr.PerNodeBufferSize = 2;
-                Assert.AreEqual(2, ldr.PerNodeBufferSize);
-
-                ldr.PerNodeParallelOperations = 1;
-                Assert.AreEqual(1, ldr.PerNodeParallelOperations);
-                ldr.PerNodeParallelOperations = 2;
-                Assert.AreEqual(2, ldr.PerNodeParallelOperations);
-            }
-        }
-
-        /// <summary>
-        /// Test data add/remove.
-        /// </summary>
-        [Test]        
-        public void TestAddRemove()
-        {
-            using (IDataStreamer<int, int> ldr = _grid.GetDataStreamer<int, int>(CacheName))
-            {
-                ldr.AllowOverwrite = true;
-
-                // Additions.
-                ldr.AddData(1, 1);
-                ldr.Flush();                
-                Assert.AreEqual(1, _cache.Get(1));
-
-                ldr.AddData(new KeyValuePair<int, int>(2, 2));
-                ldr.Flush();
-                Assert.AreEqual(2, _cache.Get(2));
-
-                ldr.AddData(new List<KeyValuePair<int, int>> { new KeyValuePair<int, int>(3, 3), new KeyValuePair<int, int>(4, 4) });
-                ldr.Flush();
-                Assert.AreEqual(3, _cache.Get(3));
-                Assert.AreEqual(4, _cache.Get(4));
-
-                // Removal.
-                ldr.RemoveData(1);
-                ldr.Flush();
-                Assert.IsNull(_cache.Get(1));
-
-                // Mixed.
-                ldr.AddData(5, 5);                
-                ldr.RemoveData(2);
-                ldr.AddData(new KeyValuePair<int, int>(7, 7));
-                ldr.AddData(6, 6);
-                ldr.RemoveData(4);
-                ldr.AddData(new List<KeyValuePair<int, int>> { new KeyValuePair<int, int>(9, 9), new KeyValuePair<int, int>(10, 10) });
-                ldr.AddData(new KeyValuePair<int, int>(8, 8));
-                ldr.RemoveData(3);
-                ldr.AddData(new List<KeyValuePair<int, int>> { new KeyValuePair<int, int>(11, 11), new KeyValuePair<int, int>(12, 12) });
-
-                ldr.Flush();
-
-                for (int i = 2; i < 5; i++)
-                    Assert.IsNull(_cache.Get(i));
-
-                for (int i = 5; i < 13; i++)
-                    Assert.AreEqual(i, _cache.Get(i));
-            }
-        }
-
-        /// <summary>
-        /// Test "tryFlush".
-        /// </summary>
-        [Test]
-        public void TestTryFlush()
-        {
-            using (IDataStreamer<int, int> ldr = _grid.GetDataStreamer<int, int>(CacheName))
-            {
-                var fut = ldr.AddData(1, 1);
-
-                ldr.TryFlush();
-
-                fut.Get();
-
-                Assert.AreEqual(1, _cache.Get(1));
-            }
-        }
-
-        /// <summary>
-        /// Test buffer size adjustments.
-        /// </summary>
-        [Test]
-        public void TestBufferSize()
-        {
-            using (IDataStreamer<int, int> ldr = _grid.GetDataStreamer<int, int>(CacheName))
-            {
-                var fut = ldr.AddData(1, 1);
-
-                Thread.Sleep(100);
-
-                Assert.IsFalse(fut.IsDone);
-
-                ldr.PerNodeBufferSize = 2;
-
-                ldr.AddData(2, 2);
-                ldr.AddData(3, 3);
-                ldr.AddData(4, 4).Get();
-                fut.Get();
-
-                Assert.AreEqual(1, _cache.Get(1));
-                Assert.AreEqual(2, _cache.Get(2));
-                Assert.AreEqual(3, _cache.Get(3));
-                Assert.AreEqual(4, _cache.Get(4));
-
-                ldr.AddData(new List<KeyValuePair<int, int>>
-                {
-                    new KeyValuePair<int, int>(5, 5), 
-                    new KeyValuePair<int, int>(6, 6),
-                    new KeyValuePair<int, int>(7, 7), 
-                    new KeyValuePair<int, int>(8, 8)
-                }).Get();
-
-                Assert.AreEqual(5, _cache.Get(5));
-                Assert.AreEqual(6, _cache.Get(6));
-                Assert.AreEqual(7, _cache.Get(7));
-                Assert.AreEqual(8, _cache.Get(8));
-            }
-        }
-
-        /// <summary>
-        /// Test close.
-        /// </summary>
-        [Test]
-        public void TestClose()
-        {
-            using (IDataStreamer<int, int> ldr = _grid.GetDataStreamer<int, int>(CacheName))
-            {
-                var fut = ldr.AddData(1, 1);
-
-                ldr.Close(false);
-
-                fut.Get();
-
-                Assert.AreEqual(1, _cache.Get(1));
-            }
-        }
-
-        /// <summary>
-        /// Test close with cancellation.
-        /// </summary>
-        [Test]
-        public void TestCancel()
-        {
-            using (IDataStreamer<int, int> ldr = _grid.GetDataStreamer<int, int>(CacheName))
-            {
-                var fut = ldr.AddData(1, 1);
-
-                ldr.Close(true);
-
-                fut.Get();
-
-                Assert.IsNull(_cache.Get(1));
-            }
-        }
-
-        /// <summary>
-        /// Tests that streamer gets collected when there are no references to it.
-        /// </summary>
-        [Test]
-        public void TestFinalizer()
-        {
-            var streamer = _grid.GetDataStreamer<int, int>(CacheName);
-            var streamerRef = new WeakReference(streamer);
-
-            Assert.IsNotNull(streamerRef.Target);
-
-            // ReSharper disable once RedundantAssignment
-            streamer = null;
-
-            GC.Collect();
-            GC.WaitForPendingFinalizers();
-
-            Assert.IsNull(streamerRef.Target);
-        }
-
-        /// <summary>
-        /// Test auto-flush feature.
-        /// </summary>
-        [Test]
-        public void TestAutoFlush()
-        {
-            using (IDataStreamer<int, int> ldr = _grid.GetDataStreamer<int, int>(CacheName))
-            {
-                // Test auto flush turning on.
-                var fut = ldr.AddData(1, 1);
-                Thread.Sleep(100);
-                Assert.IsFalse(fut.IsDone);
-                ldr.AutoFlushFrequency = 1000;                
-                fut.Get();
-
-                // Test forced flush after frequency change.
-                fut = ldr.AddData(2, 2);
-                ldr.AutoFlushFrequency = long.MaxValue;                
-                fut.Get();
-
-                // Test another forced flush after frequency change.
-                fut = ldr.AddData(3, 3);
-                ldr.AutoFlushFrequency = 1000;
-                fut.Get();
-
-                // Test flush before stop.
-                fut = ldr.AddData(4, 4);
-                ldr.AutoFlushFrequency = 0;
-                fut.Get();
-
-                // Test flush after second turn on.
-                fut = ldr.AddData(5, 5);
-                ldr.AutoFlushFrequency = 1000;
-                fut.Get();
-
-                Assert.AreEqual(1, _cache.Get(1));
-                Assert.AreEqual(2, _cache.Get(2));
-                Assert.AreEqual(3, _cache.Get(3));
-                Assert.AreEqual(4, _cache.Get(4));
-                Assert.AreEqual(5, _cache.Get(5));
-            }
-        }
-
-        /// <summary>
-        /// Test multithreaded behavior. 
-        /// </summary>
-        [Test]
-        [Category(TestUtils.CategoryIntensive)]
-        public void TestMultithreaded()
-        {
-            int entriesPerThread = 100000;
-            int threadCnt = 8;
-
-            for (int i = 0; i < 5; i++)
-            {
-                _cache.Clear();
-
-                Assert.AreEqual(0, _cache.GetSize());
-
-                Stopwatch watch = new Stopwatch();
-
-                watch.Start();
-
-                using (IDataStreamer<int, int> ldr = _grid.GetDataStreamer<int, int>(CacheName))
-                {
-                    ldr.PerNodeBufferSize = 1024;
-
-                    int ctr = 0;
-
-                    TestUtils.RunMultiThreaded(() =>
-                    {
-                        int threadIdx = Interlocked.Increment(ref ctr);
-
-                        int startIdx = (threadIdx - 1) * entriesPerThread;
-                        int endIdx = startIdx + entriesPerThread;
-
-                        for (int j = startIdx; j < endIdx; j++)
-                        {
-                            // ReSharper disable once AccessToDisposedClosure
-                            ldr.AddData(j, j);
-
-                            if (j % 100000 == 0)
-                                Console.WriteLine("Put [thread=" + threadIdx + ", cnt=" + j  + ']');
-                        }
-                    }, threadCnt);
-                }
-
-                Console.WriteLine("Iteration " + i + ": " + watch.ElapsedMilliseconds);
-
-                watch.Reset();
-
-                for (int j = 0; j < threadCnt * entriesPerThread; j++)
-                    Assert.AreEqual(j, j);
-            }
-        }
-
-        /// <summary>
-        /// Tests custom receiver.
-        /// </summary>
-        [Test]
-        public void TestStreamReceiver()
-        {
-            TestStreamReceiver(new StreamReceiverPortable());
-            TestStreamReceiver(new StreamReceiverSerializable());
-        }
-
-        /// <summary>
-        /// Tests StreamVisitor.
-        /// </summary>
-        [Test]
-        public void TestStreamVisitor()
-        {
-            TestStreamReceiver(new StreamVisitor<int, int>((c, e) => c.Put(e.Key, e.Value + 1)));
-        }
-
-        /// <summary>
-        /// Tests StreamTransformer.
-        /// </summary>
-        [Test]
-        public void TestStreamTransformer()
-        {
-            TestStreamReceiver(new StreamTransformer<int, int, int, int>(new EntryProcessorSerializable()));
-            TestStreamReceiver(new StreamTransformer<int, int, int, int>(new EntryProcessorPortable()));
-        }
-
-        /// <summary>
-        /// Tests specified receiver.
-        /// </summary>
-        private void TestStreamReceiver(IStreamReceiver<int, int> receiver)
-        {
-            using (var ldr = _grid.GetDataStreamer<int, int>(CacheName))
-            {
-                ldr.AllowOverwrite = true;
-
-                ldr.Receiver = new StreamReceiverPortable();
-
-                ldr.Receiver = receiver;  // check double assignment
-
-                Assert.AreEqual(ldr.Receiver, receiver);
-
-                for (var i = 0; i < 100; i++)
-                    ldr.AddData(i, i);
-
-                ldr.Flush();
-
-                for (var i = 0; i < 100; i++)
-                    Assert.AreEqual(i + 1, _cache.Get(i));
-            }
-        }
-
-        /// <summary>
-        /// Tests the stream receiver in keepPortable mode.
-        /// </summary>
-        [Test]
-        public void TestStreamReceiverKeepPortable()
-        {
-            // ReSharper disable once LocalVariableHidesMember
-            var cache = _grid.GetCache<int, PortableEntry>(CacheName);
-
-            using (var ldr0 = _grid.GetDataStreamer<int, int>(CacheName))
-            using (var ldr = ldr0.WithKeepPortable<int, IPortableObject>())
-            {
-                ldr.Receiver = new StreamReceiverKeepPortable();
-
-                ldr.AllowOverwrite = true;
-
-                for (var i = 0; i < 100; i++)
-                    ldr.AddData(i, _grid.GetPortables().ToPortable<IPortableObject>(new PortableEntry {Val = i}));
-
-                ldr.Flush();
-
-                for (var i = 0; i < 100; i++)
-                    Assert.AreEqual(i + 1, cache.Get(i).Val);
-            }
-        }
-
-        /// <summary>
-        /// Gets the Ignite configuration.
-        /// </summary>
-        /// <param name="gridName">Grid name.</param>
-        private static IgniteConfigurationEx GetIgniteConfiguration(string gridName)
-        {
-            return new IgniteConfigurationEx
-            {
-                GridName = gridName,
-                SpringConfigUrl = "config\\native-client-test-cache.xml",
-                JvmClasspath = TestUtils.CreateTestClasspath(),
-                PortableConfiguration = new PortableConfiguration
-                {
-                    TypeConfigurations = new List<PortableTypeConfiguration>
-                    {
-                        new PortableTypeConfiguration(typeof (CacheTestKey)),
-                        new PortableTypeConfiguration(typeof (TestReferenceObject)),
-                        new PortableTypeConfiguration(typeof (StreamReceiverPortable)),
-                        new PortableTypeConfiguration(typeof (EntryProcessorPortable)),
-                        new PortableTypeConfiguration(typeof (PortableEntry))
-                    }
-                },
-                JvmOptions = TestUtils.TestJavaOptions().Concat(new[]
-                {
-                    "-Xms3096m",
-                    "-Xmx3096m",
-                    "-XX:+UseParNewGC",
-                    "-XX:+UseConcMarkSweepGC",
-                    "-XX:+UseTLAB",
-                    "-XX:NewSize=128m",
-                    "-XX:MaxNewSize=128m",
-                    "-XX:MaxTenuringThreshold=0",
-                    "-XX:SurvivorRatio=1024",
-                    "-XX:+UseCMSInitiatingOccupancyOnly",
-                    "-XX:CMSInitiatingOccupancyFraction=60"
-                }).ToArray()
-            };
-        }
-
-        /// <summary>
-        /// Test portable receiver.
-        /// </summary>
-        private class StreamReceiverPortable : IStreamReceiver<int, int>
-        {
-            /** <inheritdoc /> */
-            public void Receive(ICache<int, int> cache, ICollection<ICacheEntry<int, int>> entries)
-            {
-                cache.PutAll(entries.ToDictionary(x => x.Key, x => x.Value + 1));
-            }
-        }
-
-        /// <summary>
-        /// Test portable receiver.
-        /// </summary>
-        [Serializable]
-        private class StreamReceiverKeepPortable : IStreamReceiver<int, IPortableObject>
-        {
-            /** <inheritdoc /> */
-            public void Receive(ICache<int, IPortableObject> cache, ICollection<ICacheEntry<int, IPortableObject>> entries)
-            {
-                var portables = cache.Ignite.GetPortables();
-
-                cache.PutAll(entries.ToDictionary(x => x.Key, x =>
-                    portables.ToPortable<IPortableObject>(new PortableEntry
-                    {
-                        Val = x.Value.Deserialize<PortableEntry>().Val + 1
-                    })));
-            }
-        }
-
-        /// <summary>
-        /// Test serializable receiver.
-        /// </summary>
-        [Serializable]
-        private class StreamReceiverSerializable : IStreamReceiver<int, int>
-        {
-            /** <inheritdoc /> */
-            public void Receive(ICache<int, int> cache, ICollection<ICacheEntry<int, int>> entries)
-            {
-                cache.PutAll(entries.ToDictionary(x => x.Key, x => x.Value + 1));
-            }
-        }
-
-        /// <summary>
-        /// Test entry processor.
-        /// </summary>
-        [Serializable]
-        private class EntryProcessorSerializable : ICacheEntryProcessor<int, int, int, int>
-        {
-            /** <inheritdoc /> */
-            public int Process(IMutableCacheEntry<int, int> entry, int arg)
-            {
-                entry.Value = entry.Key + 1;
-                
-                return 0;
-            }
-        }
-
-        /// <summary>
-        /// Test entry processor.
-        /// </summary>
-        private class EntryProcessorPortable : ICacheEntryProcessor<int, int, int, int>, IPortableMarshalAware
-        {
-            /** <inheritdoc /> */
-            public int Process(IMutableCacheEntry<int, int> entry, int arg)
-            {
-                entry.Value = entry.Key + 1;
-                
-                return 0;
-            }
-
-            /** <inheritdoc /> */
-            public void WritePortable(IPortableWriter writer)
-            {
-                // No-op.
-            }
-
-            /** <inheritdoc /> */
-            public void ReadPortable(IPortableReader reader)
-            {
-                // No-op.
-            }
-        }
-
-        /// <summary>
-        /// Portablecache entry.
-        /// </summary>
-        private class PortableEntry
-        {
-            public int Val { get; set; }
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/ignite/blob/f0bac562/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/EventsTest.cs
----------------------------------------------------------------------
diff --git a/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/EventsTest.cs b/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/EventsTest.cs
deleted file mode 100644
index aa103d4..0000000
--- a/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/EventsTest.cs
+++ /dev/null
@@ -1,961 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-namespace Apache.Ignite.Core.Tests
-{
-    using System;
-    using System.Collections.Concurrent;
-    using System.Collections.Generic;
-    using System.Linq;
-    using System.Threading;
-    using System.Threading.Tasks;
-    using Apache.Ignite.Core.Cache.Query;
-    using Apache.Ignite.Core.Common;
-    using Apache.Ignite.Core.Events;
-    using Apache.Ignite.Core.Impl;
-    using Apache.Ignite.Core.Impl.Events;
-    using Apache.Ignite.Core.Portable;
-    using Apache.Ignite.Core.Tests.Compute;
-    using NUnit.Framework;
-
-    /// <summary>
-    /// <see cref="IEvents"/> tests.
-    /// </summary>
-    public class EventsTest
-    {
-        /** */
-        private IIgnite _grid1;
-
-        /** */
-        private IIgnite _grid2;
-
-        /** */
-        private IIgnite _grid3;
-
-        /** */
-        private IIgnite[] _grids;
-        
-        /** */
-        public static int IdGen;
-
-        [TestFixtureTearDown]
-        public void FixtureTearDown()
-        {
-            StopGrids();
-        }
-
-        /// <summary>
-        /// Executes before each test.
-        /// </summary>
-        [SetUp]
-        public void SetUp()
-        {
-            StartGrids();
-            EventsTestHelper.ListenResult = true;
-        }
-
-        /// <summary>
-        /// Executes after each test.
-        /// </summary>
-        [TearDown]
-        public virtual void TearDown()
-        {
-            try
-            {
-                TestUtils.AssertHandleRegistryIsEmpty(1000, _grid1, _grid2, _grid3);
-            }
-            catch (Exception)
-            {
-                // Restart grids to cleanup
-                StopGrids();
-
-                throw;
-            }
-            finally
-            {
-                EventsTestHelper.AssertFailures();
-
-                if (TestContext.CurrentContext.Test.Name.StartsWith("TestEventTypes"))
-                    StopGrids(); // clean events for other tests
-            }
-        }
-
-        /// <summary>
-        /// Tests enable/disable of event types.
-        /// </summary>
-        [Test]
-        public void TestEnableDisable()
-        {
-            var events = _grid1.GetEvents();
-
-            Assert.AreEqual(0, events.GetEnabledEvents().Length);
-
-            Assert.IsFalse(EventType.EvtsCache.Any(events.IsEnabled));
-
-            events.EnableLocal(EventType.EvtsCache);
-
-            Assert.AreEqual(EventType.EvtsCache, events.GetEnabledEvents());
-
-            Assert.IsTrue(EventType.EvtsCache.All(events.IsEnabled));
-
-            events.EnableLocal(EventType.EvtsTaskExecution);
-
-            events.DisableLocal(EventType.EvtsCache);
-
-            Assert.AreEqual(EventType.EvtsTaskExecution, events.GetEnabledEvents());
-        }
-
-        /// <summary>
-        /// Tests LocalListen.
-        /// </summary>
-        [Test]
-        public void TestLocalListen()
-        {
-            var events = _grid1.GetEvents();
-            var listener = EventsTestHelper.GetListener();
-            var eventType = EventType.EvtsTaskExecution;
-
-            events.EnableLocal(eventType);
-
-            events.LocalListen(listener, eventType);
-
-            CheckSend(3);  // 3 events per task * 3 grids
-
-            // Check unsubscription for specific event
-            events.StopLocalListen(listener, EventType.EvtTaskReduced);
-
-            CheckSend(2);
-
-            // Unsubscribe from all events
-            events.StopLocalListen(listener);
-
-            CheckNoEvent();
-
-            // Check unsubscription by filter
-            events.LocalListen(listener, EventType.EvtTaskReduced);
-
-            CheckSend();
-
-            EventsTestHelper.ListenResult = false;
-
-            CheckSend();  // one last event will be received for each listener
-
-            CheckNoEvent();
-        }
-
-        /// <summary>
-        /// Tests LocalListen.
-        /// </summary>
-        [Test]
-        [Ignore("IGNITE-879")]
-        public void TestLocalListenRepeatedSubscription()
-        {
-            var events = _grid1.GetEvents();
-            var listener = EventsTestHelper.GetListener();
-            var eventType = EventType.EvtsTaskExecution;
-
-            events.EnableLocal(eventType);
-
-            events.LocalListen(listener, eventType);
-
-            CheckSend(3);  // 3 events per task * 3 grids
-
-            events.LocalListen(listener, eventType);
-            events.LocalListen(listener, eventType);
-
-            CheckSend(9);
-
-            events.StopLocalListen(listener, eventType);
-
-            CheckSend(6);
-
-            events.StopLocalListen(listener, eventType);
-
-            CheckSend(3);
-            
-            events.StopLocalListen(listener, eventType);
-
-            CheckNoEvent();
-        }
-
-        /// <summary>
-        /// Tests all available event types/classes.
-        /// </summary>
-        [Test, TestCaseSource("TestCases")]
-        public void TestEventTypes(EventTestCase testCase)
-        {
-            var events = _grid1.GetEvents();
-
-            events.EnableLocal(testCase.EventType);
-
-            var listener = EventsTestHelper.GetListener();
-
-            events.LocalListen(listener, testCase.EventType);
-
-            EventsTestHelper.ClearReceived(testCase.EventCount);
-
-            testCase.GenerateEvent(_grid1);
-
-            EventsTestHelper.VerifyReceive(testCase.EventCount, testCase.EventObjectType, testCase.EventType);
-
-            if (testCase.VerifyEvents != null)
-                testCase.VerifyEvents(EventsTestHelper.ReceivedEvents.Reverse(), _grid1);
-
-            // Check stop
-            events.StopLocalListen(listener);
-
-            EventsTestHelper.ClearReceived(0);
-
-            testCase.GenerateEvent(_grid1);
-
-            Thread.Sleep(EventsTestHelper.Timeout);
-        }
-
-        /// <summary>
-        /// Test cases for TestEventTypes: type id + type + event generator.
-        /// </summary>
-        public IEnumerable<EventTestCase> TestCases
-        {
-            get
-            {
-                yield return new EventTestCase
-                {
-                    EventType = EventType.EvtsCache,
-                    EventObjectType = typeof (CacheEvent),
-                    GenerateEvent = g => g.GetCache<int, int>(null).Put(1, 1),
-                    VerifyEvents = (e, g) => VerifyCacheEvents(e, g),
-                    EventCount = 1
-                };
-
-                yield return new EventTestCase
-                {
-                    EventType = EventType.EvtsTaskExecution,
-                    EventObjectType = typeof (TaskEvent),
-                    GenerateEvent = g => GenerateTaskEvent(g),
-                    VerifyEvents = (e, g) => VerifyTaskEvents(e),
-                    EventCount = 3
-                };
-
-                yield return new EventTestCase
-                {
-                    EventType = EventType.EvtsJobExecution,
-                    EventObjectType = typeof (JobEvent),
-                    GenerateEvent = g => GenerateTaskEvent(g),
-                    EventCount = 9
-                };
-
-                yield return new EventTestCase
-                {
-                    EventType = new[] {EventType.EvtCacheQueryExecuted},
-                    EventObjectType = typeof (CacheQueryExecutedEvent),
-                    GenerateEvent = g => GenerateCacheQueryEvent(g),
-                    EventCount = 1
-                };
-
-                yield return new EventTestCase
-                {
-                    EventType = new[] { EventType.EvtCacheQueryObjectRead },
-                    EventObjectType = typeof (CacheQueryReadEvent),
-                    GenerateEvent = g => GenerateCacheQueryEvent(g),
-                    EventCount = 1
-                };
-            }
-        }
-
-        /// <summary>
-        /// Tests the LocalQuery.
-        /// </summary>
-        [Test]
-        public void TestLocalQuery()
-        {
-            var events = _grid1.GetEvents();
-
-            var eventType = EventType.EvtsTaskExecution;
-
-            events.EnableLocal(eventType);
-
-            var oldEvents = events.LocalQuery();
-
-            GenerateTaskEvent();
-
-            // "Except" works because of overridden equality
-            var qryResult = events.LocalQuery(eventType).Except(oldEvents).ToList();
-
-            Assert.AreEqual(3, qryResult.Count);
-        }
-
-        /// <summary>
-        /// Tests the WaitForLocal.
-        /// </summary>
-        [Test]
-        public void TestWaitForLocal([Values(true, false)] bool async)
-        {
-            var events = _grid1.GetEvents();
-
-            var timeout = TimeSpan.FromSeconds(3);
-
-            if (async)
-                events = events.WithAsync();
-
-            var eventType = EventType.EvtsTaskExecution;
-
-            events.EnableLocal(eventType);
-
-            Func<Func<IEvent>, Task<IEvent>> getWaitTask;
-
-            if (async)
-                getWaitTask = func =>
-                {
-                    Assert.IsNull(func());
-                    var task = events.GetFuture<IEvent>().ToTask();
-                    GenerateTaskEvent();
-                    return task;
-                };
-            else
-                getWaitTask = func =>
-                {
-                    var task = Task.Factory.StartNew(func);
-                    Thread.Sleep(500); // allow task to start and begin waiting for events
-                    GenerateTaskEvent();
-                    return task;
-                };
-
-            // No params
-            var waitTask = getWaitTask(() => events.WaitForLocal());
-
-            waitTask.Wait(timeout);
-
-            // Event types
-            waitTask = getWaitTask(() => events.WaitForLocal(EventType.EvtTaskReduced));
-
-            Assert.IsTrue(waitTask.Wait(timeout));
-            Assert.IsInstanceOf(typeof(TaskEvent), waitTask.Result);
-            Assert.AreEqual(EventType.EvtTaskReduced, waitTask.Result.Type);
-
-            // Filter
-            waitTask = getWaitTask(() => events.WaitForLocal(
-                new EventFilter<IEvent>((g, e) => e.Type == EventType.EvtTaskReduced)));
-
-            Assert.IsTrue(waitTask.Wait(timeout));
-            Assert.IsInstanceOf(typeof(TaskEvent), waitTask.Result);
-            Assert.AreEqual(EventType.EvtTaskReduced, waitTask.Result.Type);
-
-            // Filter & types
-            waitTask = getWaitTask(() => events.WaitForLocal(
-                new EventFilter<IEvent>((g, e) => e.Type == EventType.EvtTaskReduced), EventType.EvtTaskReduced));
-
-            Assert.IsTrue(waitTask.Wait(timeout));
-            Assert.IsInstanceOf(typeof(TaskEvent), waitTask.Result);
-            Assert.AreEqual(EventType.EvtTaskReduced, waitTask.Result.Type);
-        }
-
-        /// <summary>
-        /// Tests RemoteListen.
-        /// </summary>
-        [Test]
-        public void TestRemoteListen(
-            [Values(true, false)] bool async, 
-            [Values(true, false)] bool portable,
-            [Values(true, false)] bool autoUnsubscribe)
-        {
-            foreach (var g in _grids)
-            {
-                g.GetEvents().EnableLocal(EventType.EvtsJobExecution);
-                g.GetEvents().EnableLocal(EventType.EvtsTaskExecution);
-            }
-
-            var events = _grid1.GetEvents();
-
-            var expectedType = EventType.EvtJobStarted;
-
-            var remoteFilter = portable 
-                ?  (IEventFilter<IEvent>) new RemoteEventPortableFilter(expectedType) 
-                :  new RemoteEventFilter(expectedType);
-
-            var localListener = EventsTestHelper.GetListener();
-
-            if (async)
-                events = events.WithAsync();
-
-            var listenId = events.RemoteListen(localListener: localListener, remoteFilter: remoteFilter,
-                autoUnsubscribe: autoUnsubscribe);
-
-            if (async)
-                listenId = events.GetFuture<Guid>().Get();
-
-            CheckSend(3, typeof(JobEvent), expectedType);
-
-            _grid3.GetEvents().DisableLocal(EventType.EvtsJobExecution);
-
-            CheckSend(2, typeof(JobEvent), expectedType);
-
-            events.StopRemoteListen(listenId);
-
-            if (async)
-                events.GetFuture().Get();
-
-            CheckNoEvent();
-
-            // Check unsubscription with listener
-            events.RemoteListen(localListener: localListener, remoteFilter: remoteFilter,
-                autoUnsubscribe: autoUnsubscribe);
-
-            if (async)
-                events.GetFuture<Guid>().Get();
-
-            CheckSend(2, typeof(JobEvent), expectedType);
-
-            EventsTestHelper.ListenResult = false;
-
-            CheckSend(1, typeof(JobEvent), expectedType);  // one last event
-
-            CheckNoEvent();
-        }
-
-        /// <summary>
-        /// Tests RemoteQuery.
-        /// </summary>
-        [Test]
-        public void TestRemoteQuery([Values(true, false)] bool async)
-        {
-            foreach (var g in _grids)
-                g.GetEvents().EnableLocal(EventType.EvtsJobExecution);
-
-            var events = _grid1.GetEvents();
-
-            var eventFilter = new RemoteEventFilter(EventType.EvtJobStarted);
-
-            var oldEvents = events.RemoteQuery(eventFilter);
-
-            if (async)
-                events = events.WithAsync();
-
-            GenerateTaskEvent();
-
-            var remoteQuery = events.RemoteQuery(eventFilter, EventsTestHelper.Timeout, EventType.EvtsJobExecution);
-
-            if (async)
-            {
-                Assert.IsNull(remoteQuery);
-
-                remoteQuery = events.GetFuture<List<IEvent>>().Get().ToList();
-            }
-
-            var qryResult = remoteQuery.Except(oldEvents).Cast<JobEvent>().ToList();
-
-            Assert.AreEqual(_grids.Length, qryResult.Count);
-
-            Assert.IsTrue(qryResult.All(x => x.Type == EventType.EvtJobStarted));
-        }
-
-        /// <summary>
-        /// Tests serialization.
-        /// </summary>
-        [Test]
-        public void TestSerialization()
-        {
-            var grid = (Ignite) _grid1;
-            var comp = (Impl.Compute.Compute) grid.GetCluster().ForLocal().GetCompute();
-            var locNode = grid.GetCluster().GetLocalNode();
-
-            var expectedGuid = Guid.Parse("00000000-0000-0001-0000-000000000002");
-            var expectedGridGuid = new IgniteGuid(expectedGuid, 3);
-
-            using (var inStream = IgniteManager.Memory.Allocate().Stream())
-            {
-                var result = comp.ExecuteJavaTask<bool>("org.apache.ignite.platform.PlatformEventsWriteEventTask",
-                    inStream.MemoryPointer);
-
-                Assert.IsTrue(result);
-
-                inStream.SynchronizeInput();
-
-                var reader = grid.Marshaller.StartUnmarshal(inStream);
-
-                var cacheEvent = EventReader.Read<CacheEvent>(reader);
-                CheckEventBase(cacheEvent);
-                Assert.AreEqual("cacheName", cacheEvent.CacheName);
-                Assert.AreEqual(locNode, cacheEvent.EventNode);
-                Assert.AreEqual(1, cacheEvent.Partition);
-                Assert.AreEqual(true, cacheEvent.IsNear);
-                Assert.AreEqual(2, cacheEvent.Key);
-                Assert.AreEqual(expectedGridGuid, cacheEvent.Xid);
-                Assert.AreEqual(3, cacheEvent.LockId);
-                Assert.AreEqual(4, cacheEvent.NewValue);
-                Assert.AreEqual(true, cacheEvent.HasNewValue);
-                Assert.AreEqual(5, cacheEvent.OldValue);
-                Assert.AreEqual(true, cacheEvent.HasOldValue);
-                Assert.AreEqual(expectedGuid, cacheEvent.SubjectId);
-                Assert.AreEqual("cloClsName", cacheEvent.ClosureClassName);
-                Assert.AreEqual("taskName", cacheEvent.TaskName);
-
-                var qryExecEvent = EventReader.Read<CacheQueryExecutedEvent>(reader);
-                CheckEventBase(qryExecEvent);
-                Assert.AreEqual("qryType", qryExecEvent.QueryType);
-                Assert.AreEqual("cacheName", qryExecEvent.CacheName);
-                Assert.AreEqual("clsName", qryExecEvent.ClassName);
-                Assert.AreEqual("clause", qryExecEvent.Clause);
-                Assert.AreEqual(expectedGuid, qryExecEvent.SubjectId);
-                Assert.AreEqual("taskName", qryExecEvent.TaskName);
-
-                var qryReadEvent = EventReader.Read<CacheQueryReadEvent>(reader);
-                CheckEventBase(qryReadEvent);
-                Assert.AreEqual("qryType", qryReadEvent.QueryType);
-                Assert.AreEqual("cacheName", qryReadEvent.CacheName);
-                Assert.AreEqual("clsName", qryReadEvent.ClassName);
-                Assert.AreEqual("clause", qryReadEvent.Clause);
-                Assert.AreEqual(expectedGuid, qryReadEvent.SubjectId);
-                Assert.AreEqual("taskName", qryReadEvent.TaskName);
-                Assert.AreEqual(1, qryReadEvent.Key);
-                Assert.AreEqual(2, qryReadEvent.Value);
-                Assert.AreEqual(3, qryReadEvent.OldValue);
-                Assert.AreEqual(4, qryReadEvent.Row);
-
-                var cacheRebalancingEvent = EventReader.Read<CacheRebalancingEvent>(reader);
-                CheckEventBase(cacheRebalancingEvent);
-                Assert.AreEqual("cacheName", cacheRebalancingEvent.CacheName);
-                Assert.AreEqual(1, cacheRebalancingEvent.Partition);
-                Assert.AreEqual(locNode, cacheRebalancingEvent.DiscoveryNode);
-                Assert.AreEqual(2, cacheRebalancingEvent.DiscoveryEventType);
-                Assert.AreEqual(3, cacheRebalancingEvent.DiscoveryTimestamp);
-                
-                var checkpointEvent = EventReader.Read<CheckpointEvent>(reader);
-                CheckEventBase(checkpointEvent);
-                Assert.AreEqual("cpKey", checkpointEvent.Key);
-                
-                var discoEvent = EventReader.Read<DiscoveryEvent>(reader);
-                CheckEventBase(discoEvent);
-                Assert.AreEqual(grid.TopologyVersion, discoEvent.TopologyVersion);
-                Assert.AreEqual(grid.GetNodes(), discoEvent.TopologyNodes);
-
-                var jobEvent = EventReader.Read<JobEvent>(reader);
-                CheckEventBase(jobEvent);
-                Assert.AreEqual(expectedGridGuid, jobEvent.JobId);
-                Assert.AreEqual("taskClsName", jobEvent.TaskClassName);
-                Assert.AreEqual("taskName", jobEvent.TaskName);
-                Assert.AreEqual(locNode, jobEvent.TaskNode);
-                Assert.AreEqual(expectedGridGuid, jobEvent.TaskSessionId);
-                Assert.AreEqual(expectedGuid, jobEvent.TaskSubjectId);
-
-                var spaceEvent = EventReader.Read<SwapSpaceEvent>(reader);
-                CheckEventBase(spaceEvent);
-                Assert.AreEqual("space", spaceEvent.Space);
-
-                var taskEvent = EventReader.Read<TaskEvent>(reader);
-                CheckEventBase(taskEvent);
-                Assert.AreEqual(true,taskEvent.Internal);
-                Assert.AreEqual(expectedGuid, taskEvent.SubjectId);
-                Assert.AreEqual("taskClsName", taskEvent.TaskClassName);
-                Assert.AreEqual("taskName", taskEvent.TaskName);
-                Assert.AreEqual(expectedGridGuid, taskEvent.TaskSessionId);
-            }
-        }
-
-        /// <summary>
-        /// Checks base event fields serialization.
-        /// </summary>
-        /// <param name="evt">The evt.</param>
-        private void CheckEventBase(IEvent evt)
-        {
-            var locNode = _grid1.GetCluster().GetLocalNode();
-
-            Assert.AreEqual(locNode, evt.Node);
-            Assert.AreEqual("msg", evt.Message);
-            Assert.AreEqual(EventType.EvtSwapSpaceCleared, evt.Type);
-            Assert.IsNotNullOrEmpty(evt.Name);
-            Assert.AreNotEqual(Guid.Empty, evt.Id.GlobalId);
-            Assert.IsTrue((evt.TimeStamp - DateTime.Now).TotalSeconds < 10);
-        }
-
-        /// <summary>
-        /// Sends events in various ways and verifies correct receive.
-        /// </summary>
-        /// <param name="repeat">Expected event count multiplier.</param>
-        /// <param name="eventObjectType">Expected event object type.</param>
-        /// <param name="eventType">Type of the event.</param>
-        private void CheckSend(int repeat = 1, Type eventObjectType = null, params int[] eventType)
-        {
-            EventsTestHelper.ClearReceived(repeat);
-
-            GenerateTaskEvent();
-
-            EventsTestHelper.VerifyReceive(repeat, eventObjectType ?? typeof (TaskEvent),
-                eventType.Any() ? eventType : EventType.EvtsTaskExecution);
-        }
-
-        /// <summary>
-        /// Checks that no event has arrived.
-        /// </summary>
-        private void CheckNoEvent()
-        {
-            // this will result in an exception in case of a event
-            EventsTestHelper.ClearReceived(0);
-
-            GenerateTaskEvent();
-
-            Thread.Sleep(EventsTestHelper.Timeout);
-
-            EventsTestHelper.AssertFailures();
-        }
-
-        /// <summary>
-        /// Gets the Ignite configuration.
-        /// </summary>
-        private static IgniteConfiguration Configuration(string springConfigUrl)
-        {
-            return new IgniteConfiguration
-            {
-                SpringConfigUrl = springConfigUrl,
-                JvmClasspath = TestUtils.CreateTestClasspath(),
-                JvmOptions = TestUtils.TestJavaOptions(),
-                PortableConfiguration = new PortableConfiguration
-                {
-                    TypeConfigurations = new List<PortableTypeConfiguration>
-                    {
-                        new PortableTypeConfiguration(typeof (RemoteEventPortableFilter))
-                    }
-                }
-            };
-        }
-
-        /// <summary>
-        /// Generates the task event.
-        /// </summary>
-        private void GenerateTaskEvent(IIgnite grid = null)
-        {
-            (grid ?? _grid1).GetCompute().Broadcast(new ComputeAction());
-        }
-
-        /// <summary>
-        /// Verifies the task events.
-        /// </summary>
-        private static void VerifyTaskEvents(IEnumerable<IEvent> events)
-        {
-            var e = events.Cast<TaskEvent>().ToArray();
-
-            // started, reduced, finished
-            Assert.AreEqual(
-                new[] {EventType.EvtTaskStarted, EventType.EvtTaskReduced, EventType.EvtTaskFinished},
-                e.Select(x => x.Type).ToArray());
-        }
-
-        /// <summary>
-        /// Generates the cache query event.
-        /// </summary>
-        private static void GenerateCacheQueryEvent(IIgnite g)
-        {
-            var cache = g.GetCache<int, int>(null);
-
-            cache.Clear();
-
-            cache.Put(1, 1);
-
-            cache.Query(new ScanQuery<int, int>()).GetAll();
-        }
-
-        /// <summary>
-        /// Verifies the cache events.
-        /// </summary>
-        private static void VerifyCacheEvents(IEnumerable<IEvent> events, IIgnite grid)
-        {
-            var e = events.Cast<CacheEvent>().ToArray();
-
-            foreach (var cacheEvent in e)
-            {
-                Assert.AreEqual(null, cacheEvent.CacheName);
-                Assert.AreEqual(null, cacheEvent.ClosureClassName);
-                Assert.AreEqual(null, cacheEvent.TaskName);
-                Assert.AreEqual(grid.GetCluster().GetLocalNode(), cacheEvent.EventNode);
-                Assert.AreEqual(grid.GetCluster().GetLocalNode(), cacheEvent.Node);
-
-                Assert.AreEqual(false, cacheEvent.HasOldValue);
-                Assert.AreEqual(null, cacheEvent.OldValue);
-
-                if (cacheEvent.Type == EventType.EvtCacheObjectPut)
-                {
-                    Assert.AreEqual(true, cacheEvent.HasNewValue);
-                    Assert.AreEqual(1, cacheEvent.NewValue);
-                }
-                else if (cacheEvent.Type == EventType.EvtCacheEntryCreated)
-                {
-                    Assert.AreEqual(false, cacheEvent.HasNewValue);
-                    Assert.AreEqual(null, cacheEvent.NewValue);
-                }
-                else
-                {
-                    Assert.Fail("Unexpected event type");
-                }
-            }
-        }
-
-        /// <summary>
-        /// Starts the grids.
-        /// </summary>
-        private void StartGrids()
-        {
-            if (_grid1 != null)
-                return;
-
-            _grid1 = Ignition.Start(Configuration("config\\compute\\compute-grid1.xml"));
-            _grid2 = Ignition.Start(Configuration("config\\compute\\compute-grid2.xml"));
-            _grid3 = Ignition.Start(Configuration("config\\compute\\compute-grid3.xml"));
-
-            _grids = new[] {_grid1, _grid2, _grid3};
-        }
-
-        /// <summary>
-        /// Stops the grids.
-        /// </summary>
-        private void StopGrids()
-        {
-            _grid1 = _grid2 = _grid3 = null;
-            _grids = null;
-            
-            Ignition.StopAll(true);
-        }
-    }
-
-    /// <summary>
-    /// Event test helper class.
-    /// </summary>
-    [Serializable]
-    public static class EventsTestHelper
-    {
-        /** */
-        public static readonly ConcurrentStack<IEvent> ReceivedEvents = new ConcurrentStack<IEvent>();
-        
-        /** */
-        public static readonly ConcurrentStack<string> Failures = new ConcurrentStack<string>();
-
-        /** */
-        public static readonly CountdownEvent ReceivedEvent = new CountdownEvent(0);
-
-        /** */
-        public static readonly ConcurrentStack<Guid> LastNodeIds = new ConcurrentStack<Guid>();
-
-        /** */
-        public static volatile bool ListenResult = true;
-
-        /** */
-        public static readonly TimeSpan Timeout = TimeSpan.FromMilliseconds(800);
-
-        /// <summary>
-        /// Clears received event information.
-        /// </summary>
-        /// <param name="expectedCount">The expected count of events to be received.</param>
-        public static void ClearReceived(int expectedCount)
-        {
-            ReceivedEvents.Clear();
-            ReceivedEvent.Reset(expectedCount);
-            LastNodeIds.Clear();
-        }
-
-        /// <summary>
-        /// Verifies received events against events events.
-        /// </summary>
-        public static void VerifyReceive(int count, Type eventObjectType, params int[] eventTypes)
-        {
-            // check if expected event count has been received; Wait returns false if there were none.
-            Assert.IsTrue(ReceivedEvent.Wait(Timeout), 
-                "Failed to receive expected number of events. Remaining count: " + ReceivedEvent.CurrentCount);
-            
-            Assert.AreEqual(count, ReceivedEvents.Count);
-
-            Assert.IsTrue(ReceivedEvents.All(x => x.GetType() == eventObjectType));
-
-            Assert.IsTrue(ReceivedEvents.All(x => eventTypes.Contains(x.Type)));
-
-            AssertFailures();
-        }
-
-        /// <summary>
-        /// Gets the event listener.
-        /// </summary>
-        /// <returns>New instance of event listener.</returns>
-        public static IEventFilter<IEvent> GetListener()
-        {
-            return new EventFilter<IEvent>(Listen);
-        }
-
-        /// <summary>
-        /// Combines accumulated failures and throws an assertion, if there are any.
-        /// Clears accumulated failures.
-        /// </summary>
-        public static void AssertFailures()
-        {
-            try
-            {
-                if (Failures.Any())
-                    Assert.Fail(Failures.Reverse().Aggregate((x, y) => string.Format("{0}\n{1}", x, y)));
-            }
-            finally 
-            {
-                Failures.Clear();
-            }
-        }
-
-        /// <summary>
-        /// Listen method.
-        /// </summary>
-        /// <param name="id">Originating node ID.</param>
-        /// <param name="evt">Event.</param>
-        private static bool Listen(Guid id, IEvent evt)
-        {
-            try
-            {
-                LastNodeIds.Push(id);
-                ReceivedEvents.Push(evt);
-
-                ReceivedEvent.Signal();
-                
-                return ListenResult;
-            }
-            catch (Exception ex)
-            {
-                // When executed on remote nodes, these exceptions will not go to sender, 
-                // so we have to accumulate them.
-                Failures.Push(string.Format("Exception in Listen (msg: {0}, id: {1}): {2}", evt, id, ex));
-                throw;
-            }
-        }
-    }
-
-    /// <summary>
-    /// Test event filter.
-    /// </summary>
-    [Serializable]
-    public class EventFilter<T> : IEventFilter<T> where T : IEvent
-    {
-        /** */
-        private readonly Func<Guid, T, bool> _invoke;
-
-        /// <summary>
-        /// Initializes a new instance of the <see cref="RemoteListenEventFilter"/> class.
-        /// </summary>
-        /// <param name="invoke">The invoke delegate.</param>
-        public EventFilter(Func<Guid, T, bool> invoke)
-        {
-            _invoke = invoke;
-        }
-
-        /** <inheritdoc /> */
-        bool IEventFilter<T>.Invoke(Guid nodeId, T evt)
-        {
-            return _invoke(nodeId, evt);
-        }
-
-        /** <inheritdoc /> */
-        public bool Invoke(Guid nodeId, T evt)
-        {
-            throw new Exception("Invalid method");
-        }
-    }
-
-    /// <summary>
-    /// Remote event filter.
-    /// </summary>
-    [Serializable]
-    public class RemoteEventFilter : IEventFilter<IEvent>
-    {
-        /** */
-        private readonly int _type;
-
-        public RemoteEventFilter(int type)
-        {
-            _type = type;
-        }
-
-        /** <inheritdoc /> */
-        public bool Invoke(Guid nodeId, IEvent evt)
-        {
-            return evt.Type == _type;
-        }
-    }
-
-    /// <summary>
-    /// Portable remote event filter.
-    /// </summary>
-    public class RemoteEventPortableFilter : IEventFilter<IEvent>, IPortableMarshalAware
-    {
-        /** */
-        private int _type;
-
-        /// <summary>
-        /// Initializes a new instance of the <see cref="RemoteEventPortableFilter"/> class.
-        /// </summary>
-        /// <param name="type">The event type.</param>
-        public RemoteEventPortableFilter(int type)
-        {
-            _type = type;
-        }
-
-        /** <inheritdoc /> */
-        public bool Invoke(Guid nodeId, IEvent evt)
-        {
-            return evt.Type == _type;
-        }
-
-        /** <inheritdoc /> */
-        public void WritePortable(IPortableWriter writer)
-        {
-            writer.RawWriter().WriteInt(_type);
-        }
-
-        /** <inheritdoc /> */
-        public void ReadPortable(IPortableReader reader)
-        {
-            _type = reader.RawReader().ReadInt();
-        }
-    }
-
-    /// <summary>
-    /// Event test case.
-    /// </summary>
-    public class EventTestCase
-    {
-        /// <summary>
-        /// Gets or sets the type of the event.
-        /// </summary>
-        public int[] EventType { get; set; }
-
-        /// <summary>
-        /// Gets or sets the type of the event object.
-        /// </summary>
-        public Type EventObjectType { get; set; }
-
-        /// <summary>
-        /// Gets or sets the generate event action.
-        /// </summary>
-        public Action<IIgnite> GenerateEvent { get; set; }
-
-        /// <summary>
-        /// Gets or sets the verify events action.
-        /// </summary>
-        public Action<IEnumerable<IEvent>, IIgnite> VerifyEvents { get; set; }
-
-        /// <summary>
-        /// Gets or sets the event count.
-        /// </summary>
-        public int EventCount { get; set; }
-
-        /** <inheritdoc /> */
-        public override string ToString()
-        {
-            return EventObjectType.ToString();
-        }
-    }
-}

http://git-wip-us.apache.org/repos/asf/ignite/blob/f0bac562/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Examples/Example.cs
----------------------------------------------------------------------
diff --git a/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Examples/Example.cs b/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Examples/Example.cs
deleted file mode 100644
index edb04cb..0000000
--- a/modules/platform/src/test/dotnet/Apache.Ignite.Core.Tests/Examples/Example.cs
+++ /dev/null
@@ -1,137 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-namespace Apache.Ignite.Core.Tests.Examples
-{
-    using System;
-    using System.Collections.Generic;
-    using System.IO;
-    using System.Linq;
-    using System.Text.RegularExpressions;
-    using Apache.Ignite.Examples.Compute;
-    using Apache.Ignite.ExamplesDll.Compute;
-    using NUnit.Framework;
-
-    /// <summary>
-    /// Represents an Example to be tested.
-    /// </summary>
-    public class Example
-    {
-        /** All examples */
-        private static readonly Example[] Examples = GetExamples().ToArray();
-
-        /** Execute action */
-        private Action _runAction;
-
-        /** Config url */
-        public string SpringConfigUrl { get; private set; }
-
-        /** Source path */
-        public string SourceFilePath { get; private set; }
-
-        /** Dll load flag */
-        public bool NeedsTestDll { get; private set; }
-
-        /** Name */
-        public string Name { get; private set; }
-
-        /// <summary>
-        /// Runs this example.
-        /// </summary>
-        public void Run()
-        {
-            try
-            {
-                _runAction();
-            }
-            catch (InvalidOperationException ex)
-            {
-                // Each example has a ReadKey at the end, which throws an exception in test environment.
-                if (ex.Message != "Cannot read keys when either application does not have a console or " +
-                    "when console input has been redirected from a file. Try Console.Read.")
-                    throw;
-            }
-        }
-
-        /// <summary>
-        /// Gets all examples.
-        /// </summary>
-        public static IEnumerable<Example> All
-        {
-            get { return Examples; }
-        }
-
-        /// <summary>
-        /// Gets all examples.
-        /// </summary>
-        private static IEnumerable<Example> GetExamples()
-        {
-            var examplesAsm = typeof (ClosureExample).Assembly;
-
-            var sourceFiles = Directory.GetFiles(PathUtil.ExamplesSourcePath, "*.cs", SearchOption.AllDirectories);
-
-            Assert.IsTrue(sourceFiles.Any());
-
-            var types = examplesAsm.GetTypes().Where(x => x.GetMethod("Main") != null).ToArray();
-
-            Assert.IsTrue(types.Any());
-
-            var examplesDllName = typeof(AverageSalaryJob).Assembly.GetName().Name;
-
-            foreach (var type in types)
-            {
-                var sourceFile = sourceFiles.Single(x => x.EndsWith(string.Format("\\{0}.cs", type.Name)));
-
-                var sourceCode = File.ReadAllText(sourceFile);
-
-                yield return new Example
-                {
-                    SourceFilePath = sourceFile,
-                    SpringConfigUrl = PathUtil.GetFullConfigPath(GetSpringConfigUrl(sourceCode)),
-                    NeedsTestDll = sourceCode.Contains(examplesDllName),
-                    _runAction = GetRunAction(type),
-                    Name = type.Name
-                };
-            }
-        }
-
-        /// <summary>
-        /// Gets the run action.
-        /// </summary>
-        private static Action GetRunAction(Type type)
-        {
-            return (Action) Delegate.CreateDelegate(typeof (Action), type.GetMethod("Main"));
-        }
-
-        /// <summary>
-        /// Gets the spring configuration URL.
-        /// </summary>
-        private static string GetSpringConfigUrl(string code)
-        {
-            var match = Regex.Match(code, "-springConfigUrl=(.*?.xml)");
-
-            return match.Success ? match.Groups[1].Value : null;
-        }
-
-        /** <inheritdoc /> */
-        public override string ToString()
-        {
-            // This will be displayed in TeamCity and R# test runner
-            return Name;
-        }
-    }
-}
\ No newline at end of file


Mime
View raw message