| /* |
| * 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. |
| */ |
| |
| using System; |
| using System.Collections.Generic; |
| using System.Collections; |
| using System.Threading; |
| using System.Linq; |
| |
| namespace Apache.Geode.Client.UnitTests |
| { |
| using NUnit.Framework; |
| using Apache.Geode.DUnitFramework; |
| |
| using Apache.Geode.Client; |
| using Region = Apache.Geode.Client.IRegion<Object, Object>; |
| |
| public class MyResultCollector<TResult> : Client.IResultCollector<TResult> |
| { |
| #region Private members |
| private bool m_resultReady = false; |
| ICollection<TResult> m_results = null; |
| private int m_addResultCount = 0; |
| private int m_getResultCount = 0; |
| private int m_endResultCount = 0; |
| #endregion |
| public int GetAddResultCount() |
| { |
| return m_addResultCount; |
| } |
| public int GetGetResultCount() |
| { |
| return m_getResultCount; |
| } |
| public int GetEndResultCount() |
| { |
| return m_endResultCount; |
| } |
| public MyResultCollector() |
| { |
| m_results = new List<TResult>(); |
| } |
| public void AddResult(TResult result) |
| { |
| Util.Log(" in MyResultCollector " + result + " : " + result.GetType()); |
| m_addResultCount++; |
| m_results.Add(result); |
| } |
| public ICollection<TResult> GetResult() |
| { |
| return GetResult(TimeSpan.FromSeconds(50)); |
| } |
| public ICollection<TResult> GetResult(TimeSpan timeout) |
| { |
| m_getResultCount++; |
| |
| lock (this) { |
| if (!m_resultReady) { |
| if (timeout > TimeSpan.Zero) { |
| if (!Monitor.Wait(this, timeout)) { |
| throw new FunctionExecutionException("Timeout waiting for result."); |
| } |
| } else { |
| throw new FunctionExecutionException("Results not ready."); |
| } |
| } |
| } |
| |
| return m_results; |
| } |
| |
| public void EndResults() |
| { |
| m_endResultCount++; |
| |
| lock (this) { |
| m_resultReady = true; |
| Monitor.Pulse(this); |
| } |
| } |
| |
| public void ClearResults(/*bool unused*/) |
| { |
| m_results.Clear(); |
| m_addResultCount = 0; |
| m_getResultCount = 0; |
| m_endResultCount = 0; |
| m_resultReady = false; |
| } |
| } |
| |
| |
| [TestFixture] |
| [Category("group3")] |
| [Category("unicast_only")] |
| [Category("generics")] |
| public class ThinClientFunctionExecutionTests : ThinClientRegionSteps |
| { |
| #region Private members |
| |
| private UnitProcess m_client1; |
| private UnitProcess m_client2; |
| private static string[] FunctionExecutionRegionNames = { "partition_region", "partition_region1" }; |
| private static string poolName = "__TEST_POOL1__"; |
| private static string serverGroup = "ServerGroup1"; |
| private static string QERegionName = "partition_region"; |
| private static string getFuncName = "MultiGetFunction"; |
| private static string getFuncIName = "MultiGetFunctionI"; |
| private static string OnServerHAExceptionFunction = "OnServerHAExceptionFunction"; |
| private static string OnServerHAShutdownFunction = "OnServerHAShutdownFunction"; |
| private static string RegionOperationsHAFunction = "RegionOperationsHAFunction"; |
| private static string RegionOperationsHAFunctionPrSHOP = "RegionOperationsHAFunctionPrSHOP"; |
| private static string exFuncNameSendException = "executeFunction_SendException"; |
| private static string FEOnRegionPrSHOP = "FEOnRegionPrSHOP"; |
| private static string FEOnRegionPrSHOP_OptimizeForWrite = "FEOnRegionPrSHOP_OptimizeForWrite"; |
| private static string putFuncName = "MultiPutFunction"; |
| private static string putFuncIName = "MultiPutFunctionI"; |
| |
| #endregion |
| |
| protected override ClientBase[] GetClients() |
| { |
| m_client1 = new UnitProcess(); |
| m_client2 = new UnitProcess(); |
| return new ClientBase[] { m_client1, m_client2 }; |
| } |
| [TearDown] |
| public override void EndTest() |
| { |
| try |
| { |
| m_client1.Call(CacheHelper.Close); |
| m_client2.Call(CacheHelper.Close); |
| CacheHelper.ClearEndpoints(); |
| CacheHelper.ClearLocators(); |
| } |
| finally |
| { |
| CacheHelper.StopJavaServers(); |
| CacheHelper.StopJavaLocators(); |
| } |
| base.EndTest(); |
| } |
| |
| public void InitClient() |
| { |
| CacheHelper.Init(); |
| } |
| |
| public void createRegionAndAttachPool(string regionName, string poolName) |
| { |
| CacheHelper.CreateTCRegion_Pool<object, object>(regionName, true, true, null, null, poolName, false, serverGroup); |
| } |
| public void createPool(string name, string locators, string serverGroup, |
| int redundancy, bool subscription, bool prSingleHop, bool threadLocal = false) |
| { |
| CacheHelper.CreatePool<object, object>(name, locators, serverGroup, redundancy, subscription, prSingleHop, threadLocal); |
| } |
| |
| //public void StepOne(string endpoints) |
| //{ |
| |
| // CacheHelper.CreateTCRegion(QERegionName, true, true, |
| // null, endpoints, true); |
| |
| // Region region = CacheHelper.GetVerifyRegion(QERegionName); |
| // for (int i = 0; i < 34; i++) |
| // { |
| // region["KEY--" + i] = "VALUE--" + i; |
| // } |
| |
| // string[] routingObj = new string[17]; |
| // int j = 0; |
| // for (int i = 0; i < 34; i++) |
| // { |
| // if (i % 2 == 0) continue; |
| // routingObj[j] = "KEY--" + i; |
| // j++; |
| // } |
| // Util.Log("routingObj count= {0}.", routingObj.Length); |
| |
| // bool args = true; |
| // Boolean getResult = true; |
| // //test data dependant function execution |
| // // test get function with result |
| // Execution<object> exc = FunctionService<object>.OnRegion<object, object> (region); |
| // IResultCollector<object> rc = exc.WithArgs<bool>(args).WithFilter<string>(routingObj).Execute( |
| //getFuncName, getResult); |
| // ICollection<object> executeFunctionResult = rc.GetResult(); |
| // List<object> resultList = new List<object>(); |
| // //resultList.Clear(); |
| |
| // foreach (List<object> item in executeFunctionResult) |
| // { |
| |
| // foreach (object item2 in item) |
| // { |
| // resultList.Add(item2); |
| // } |
| // } |
| // Util.Log("on region: result count= {0}.", resultList.Count); |
| // Assert.IsTrue(resultList.Count == 17, "result count check failed"); |
| // for (int i = 0; i < resultList.Count; i++) |
| // { |
| // Util.Log("on region:get:result[{0}]={1}.", i, (string)resultList[i]); |
| // } |
| // // Bring down the region |
| // region.GetLocalView().DestroyRegion(); |
| //} |
| |
| public void PoolStepOne(string locators) |
| { |
| IRegion<object, object> region = CacheHelper.GetVerifyRegion<object, object>(QERegionName); |
| for (int i = 0; i < 230; i++) |
| { |
| region["KEY--" + i] = "VALUE--" + i; |
| } |
| |
| Object[] routingObj = new Object[17]; |
| int j = 0; |
| for (int i = 0; i < 34; i++) |
| { |
| if (i % 2 == 0) continue; |
| routingObj[j] = "KEY--" + i; |
| j++; |
| } |
| Util.Log("routingObj count= {0}.", routingObj.Length); |
| |
| object args = true; |
| //test data dependant function execution |
| // test get function with result |
| |
| Apache.Geode.Client.Execution<object> exc = Client.FunctionService<object>.OnRegion<object, object>(region); |
| Client.IResultCollector<object> rc = exc.WithArgs<object>(args).WithFilter<object>(routingObj).Execute(getFuncName); |
| ICollection<object> executeFunctionResult = rc.GetResult(); |
| List<object> resultList = new List<object>(); |
| //resultList.Clear(); |
| |
| foreach (List<object> item in executeFunctionResult) |
| { |
| foreach (object item2 in item) |
| { |
| resultList.Add(item2); |
| } |
| } |
| Util.Log("on region: result count= {0}.", resultList.Count); |
| Assert.IsTrue(resultList.Count == 34, "result count check failed"); |
| for (int i = 0; i < resultList.Count; i++) |
| { |
| Util.Log("on region:get:result[{0}]={1}.", i, (string)resultList[i]); |
| } |
| |
| //---------------------Test for function execution with sendException------------------------// |
| for (int i = 1; i <= 230; i++) { |
| region["execKey-" + i] = i; |
| } |
| Util.Log("Put on region complete for execKeys"); |
| |
| List<Object> arrList = new List<Object>(20); |
| for (int i = 100; i < 120; i++) { |
| arrList.Add("execKey-" + i); |
| } |
| |
| Object[] filter = new Object[20]; |
| j = 0; |
| for (int i = 100; i < 120; i++) { |
| filter[j] = "execKey-" + i; |
| j++; |
| } |
| Util.Log("filter count= {0}.", filter.Length); |
| |
| args = true; |
| |
| exc = Client.FunctionService<object>.OnRegion<object, object>(region); |
| |
| rc = exc.WithArgs<object>(args).WithFilter<object>(filter).Execute(exFuncNameSendException); |
| |
| executeFunctionResult = rc.GetResult(); |
| |
| Assert.IsTrue(executeFunctionResult.Count == 1, "executeFunctionResult count check failed"); |
| |
| foreach (UserFunctionExecutionException item in executeFunctionResult) { |
| Util.Log("Item returned for bool arguement is {0} ", item.Message); |
| } |
| |
| Util.Log("Executing exFuncNameSendException on region for execKeys for bool arguement done."); |
| |
| rc = exc.WithArgs<object>(arrList).WithFilter<object>(filter).Execute(exFuncNameSendException); |
| executeFunctionResult = rc.GetResult(); |
| |
| Util.Log("exFuncNameSendException for arrList result->size() = {0} ", executeFunctionResult.Count); |
| |
| Assert.IsTrue(executeFunctionResult.Count == arrList.Count + 1, "region get: resultList count is not as arrList count + exception"); |
| |
| foreach (object item in executeFunctionResult) { |
| Util.Log("Items returned for arrList arguement is {0} ", item); |
| } |
| |
| Util.Log("Executing exFuncNameSendException on region for execKeys for arrList arguement done."); |
| |
| MyResultCollector<object> myRC1 = new MyResultCollector<object>(); |
| rc = exc.WithArgs<object>(args).WithCollector(myRC1).Execute(exFuncNameSendException); |
| executeFunctionResult = rc.GetResult(); |
| Util.Log("add result count= {0}.", myRC1.GetAddResultCount()); |
| Util.Log("get result count= {0}.", myRC1.GetGetResultCount()); |
| Util.Log("end result count= {0}.", myRC1.GetEndResultCount()); |
| Assert.IsTrue(myRC1.GetAddResultCount() == 1, "add result count check failed"); |
| Assert.IsTrue(myRC1.GetGetResultCount() == 1, "get result count check failed"); |
| Assert.IsTrue(myRC1.GetEndResultCount() == 1, "end result count check failed"); |
| Util.Log("on Region with collector: result count= {0}.", executeFunctionResult.Count); |
| Assert.IsTrue(executeFunctionResult.Count == 1, "result count check failed"); |
| foreach (object item in executeFunctionResult) { |
| Util.Log("on Region with collector: get:result {0}", (item as UserFunctionExecutionException).Message); |
| } |
| |
| //---------------------Test for function execution with sendException Done-----------------------// |
| |
| Pool/*<object, object>*/ pl = CacheHelper.DCache.GetPoolManager().Find(poolName); |
| //test date independant fucntion execution on one server |
| // test get function with result |
| |
| exc = Client.FunctionService<object>.OnServer(pl); |
| ArrayList args1 = new ArrayList(); |
| for (int i = 0; i < routingObj.Length; i++) |
| { |
| Util.Log("routingObj[{0}]={1}.", i, (string)routingObj[i]); |
| args1.Add(routingObj[i]); |
| } |
| rc = exc.WithArgs<ArrayList>(args1).Execute(getFuncIName); |
| executeFunctionResult = rc.GetResult(); |
| |
| resultList.Clear(); |
| foreach (List<object> item in executeFunctionResult) |
| { |
| |
| foreach (object item2 in item) |
| { |
| resultList.Add(item2); |
| } |
| } |
| Util.Log("on one server: result count= {0}.", resultList.Count); |
| Assert.IsTrue(resultList.Count == 17, "result count check failed"); |
| for (int i = 0; i < resultList.Count; i++) |
| { |
| Util.Log("on one server: get:result[{0}]={1}.", i, (string)resultList[i]); |
| } |
| |
| //test data independant fucntion execution on all servers |
| // test get function with result |
| |
| exc = Client.FunctionService<object>.OnServers(pl); |
| rc = exc.WithArgs<ArrayList>(args1).Execute(getFuncIName); |
| executeFunctionResult = rc.GetResult(); |
| resultList.Clear(); |
| |
| foreach (List<object> item in executeFunctionResult) |
| { |
| foreach (object item2 in item) |
| { |
| resultList.Add(item2); |
| } |
| } |
| Util.Log("on all servers: result count= {0}.", resultList.Count); |
| Assert.IsTrue(resultList.Count == 34, "result count check failed"); |
| for (int i = 0; i < resultList.Count; i++) |
| { |
| Util.Log("on all servers: get:result[{0}]={1}.", i, (string)resultList[i]); |
| } |
| //TODO::enable it once the StringArray conversion is fixed. |
| //test withCollector |
| MyResultCollector<object> myRC = new MyResultCollector<object>(); |
| rc = exc.WithArgs<ArrayList>(args1).WithCollector(myRC).Execute(getFuncIName); |
| //executeFunctionResult = rc.GetResult(); |
| Util.Log("add result count= {0}.", myRC.GetAddResultCount()); |
| Util.Log("get result count= {0}.", myRC.GetGetResultCount()); |
| Util.Log("end result count= {0}.", myRC.GetEndResultCount()); |
| Util.Log("on all servers with collector: result count= {0}.", executeFunctionResult.Count); |
| Assert.IsTrue(myRC.GetResult().Count == 2, "result count check failed"); |
| |
| IList res = (IList)myRC.GetResult(); |
| |
| foreach (object o in res) |
| { |
| IList resList = (IList)o; |
| Util.Log("results " + resList.Count); |
| |
| Assert.AreEqual(17, resList.Count); |
| } |
| |
| MyResultCollector<object> myRC2 = new MyResultCollector<object>(); |
| rc = exc.WithArgs<object>(args).WithCollector(myRC2).Execute(exFuncNameSendException); |
| executeFunctionResult = rc.GetResult(); |
| Util.Log("add result count= {0}.", myRC2.GetAddResultCount()); |
| Util.Log("get result count= {0}.", myRC2.GetGetResultCount()); |
| Util.Log("end result count= {0}.", myRC2.GetEndResultCount()); |
| Assert.IsTrue(myRC2.GetAddResultCount() == 2, "add result count check failed"); |
| Assert.IsTrue(myRC2.GetGetResultCount() == 1, "get result count check failed"); |
| Assert.IsTrue(myRC2.GetEndResultCount() == 1, "end result count check failed"); |
| Util.Log("on Region with collector: result count= {0}.", executeFunctionResult.Count); |
| Assert.IsTrue(executeFunctionResult.Count == 2, "result count check failed"); |
| foreach (object item in executeFunctionResult) { |
| Util.Log("on Region with collector: get:result {0}", (item as UserFunctionExecutionException).Message); |
| } |
| |
| } |
| |
| public void genericFEResultIntTest(string locators) |
| { |
| IRegion<int, int> region = CacheHelper.GetVerifyRegion<int, int>(QERegionName); |
| Pool pl = CacheHelper.DCache.GetPoolManager().Find(poolName); |
| |
| for (int n = 0; n < 34; n++) |
| { |
| region[n] = n; |
| } |
| |
| ICollection<int> routingObj = new List<int>(); |
| |
| int j = 0; |
| for (int i = 0; i < 34; i++) |
| { |
| if (i % 2 == 0) continue; |
| routingObj.Add(i); |
| j++; |
| } |
| Console.WriteLine("routingObj count= {0}.", routingObj.Count); |
| |
| int args1 = 0; |
| |
| MyResultCollector<int> myRC = new MyResultCollector<int>(); |
| Apache.Geode.Client.Execution<int> exc = Client.FunctionService<int>.OnServers/*OnRegion<string, string>*/(pl/*region*/); |
| Client.IResultCollector<int> rc = exc.WithArgs<int>(args1).WithCollector(myRC).Execute("SingleStrGetFunction"); |
| |
| Util.Log("add result count= {0}.", myRC.GetAddResultCount()); |
| Util.Log("get result count= {0}.", myRC.GetGetResultCount()); |
| Util.Log("end result count= {0}.", myRC.GetEndResultCount()); |
| |
| Assert.IsTrue(myRC.GetResult().Count == 2, "result count check failed"); |
| |
| ICollection<int> res = myRC.GetResult(); |
| Assert.AreEqual(2, res.Count); |
| |
| foreach (int o in res) |
| { |
| Util.Log("results " + o); |
| } |
| |
| } |
| |
| public void genericFEResultStringTest(string locators) |
| { |
| IRegion<string, string> region = CacheHelper.GetVerifyRegion<string, string>(QERegionName); |
| Pool pl = CacheHelper.DCache.GetPoolManager().Find(poolName); |
| |
| for (int n = 0; n < 34; n++) |
| { |
| region["KEY--" + n] = "VALUE--" + n; |
| } |
| |
| ICollection<string> routingObj = new List<string>(); |
| |
| int j = 0; |
| for (int i = 0; i < 34; i++) |
| { |
| if (i % 2 == 0) continue; |
| routingObj.Add("KEY--" + i); |
| j++; |
| } |
| Console.WriteLine("routingObj count= {0}.", routingObj.Count); |
| |
| ArrayList args1 = new ArrayList(); |
| |
| int count = 0; |
| foreach (string str in routingObj) |
| { |
| Util.Log("string at index {0} = {1}.", count, str); |
| args1.Add(str); |
| count++; |
| } |
| |
| MyResultCollector<string> myRC = new MyResultCollector<string>(); |
| Apache.Geode.Client.Execution<string> exc = Client.FunctionService<string>.OnServers/*OnRegion<string, string>*/(pl/*region*/); |
| Client.IResultCollector<string> rc = exc.WithArgs<ArrayList>(args1).WithCollector(myRC).Execute("SingleStrGetFunction"); |
| |
| Util.Log("add result count= {0}.", myRC.GetAddResultCount()); |
| Util.Log("get result count= {0}.", myRC.GetGetResultCount()); |
| Util.Log("end result count= {0}.", myRC.GetEndResultCount()); |
| |
| Assert.IsTrue(myRC.GetResult().Count == 2, "result count check failed"); |
| |
| ICollection<string> res = myRC.GetResult(); |
| Assert.AreEqual(2, res.Count); |
| foreach (string o in res) |
| { |
| Util.Log("results " + o); |
| } |
| |
| } |
| |
| public void genericFEResultDCStringTest(string locators) |
| { |
| IRegion<string, string> region = CacheHelper.GetVerifyRegion<string, string>(QERegionName); |
| Pool pl = CacheHelper.DCache.GetPoolManager().Find(poolName); |
| |
| for (int n = 0; n < 34; n++) |
| { |
| region["KEY--" + n] = "VALUE--" + n; |
| } |
| |
| ICollection<string> routingObj = new List<string>(); |
| |
| int j = 0; |
| for (int i = 0; i < 34; i++) |
| { |
| if (i % 2 == 0) continue; |
| routingObj.Add("KEY--" + i); |
| j++; |
| } |
| Console.WriteLine("routingObj count= {0}.", routingObj.Count); |
| |
| ArrayList args1 = new ArrayList(); |
| |
| int count = 0; |
| foreach (string str in routingObj) |
| { |
| Util.Log("string at index {0} = {1}.", count, str); |
| args1.Add(str); |
| count++; |
| } |
| |
| Apache.Geode.Client.Execution<string> exc = Client.FunctionService<string>.OnServers/*OnRegion<string, string>*/(pl/*region*/); |
| Client.IResultCollector<string> rc = exc.WithArgs<ArrayList>(args1).Execute("SingleStrGetFunction"); |
| |
| Assert.IsTrue(rc.GetResult().Count == 2, "result count check failed"); |
| |
| ICollection<string> res = rc.GetResult(); |
| Assert.AreEqual(2, res.Count); |
| foreach (string o in res) |
| { |
| Util.Log("results " + o); |
| } |
| |
| } |
| |
| public void genericFEResultDCPdxTest(string locators) |
| { |
| CacheHelper.DCache.TypeRegistry.RegisterPdxType(PdxTests.PdxTypes1.CreateDeserializable); |
| CacheHelper.DCache.TypeRegistry.RegisterPdxType(PdxTests.PdxTypes8.CreateDeserializable); |
| IRegion<string, IPdxSerializable> region = CacheHelper.GetVerifyRegion<string, IPdxSerializable>(QERegionName); |
| Pool pl = CacheHelper.DCache.GetPoolManager().Find(poolName); |
| |
| for (int n = 0; n < 34; n++) |
| { |
| region["KEY--pdx" + n] = new PdxTests.PdxTypes8(); |
| } |
| |
| ICollection<string> routingObj = new List<string>(); |
| |
| int j = 0; |
| for (int i = 0; i < 34; i++) |
| { |
| if (i % 2 == 0) continue; |
| routingObj.Add("KEY--pdx" + i); |
| j++; |
| } |
| Console.WriteLine("routingObj count= {0}.", routingObj.Count); |
| |
| ArrayList args1 = new ArrayList(); |
| |
| int count = 0; |
| foreach (string str in routingObj) |
| { |
| Util.Log("string at index {0} = {1}.", count, str); |
| args1.Add(str); |
| count++; |
| } |
| |
| Apache.Geode.Client.Execution<object> exc = Client.FunctionService<object>.OnServers/*OnRegion<string, string>*/(pl/*region*/); |
| Client.IResultCollector<object> rc = exc.WithArgs<ArrayList>(args1).Execute("PdxFunctionTest"); |
| |
| Assert.IsTrue(rc.GetResult().Count == 2, "result count check failed"); |
| |
| ICollection<object> res = rc.GetResult(); |
| Assert.AreEqual(2, res.Count); |
| foreach (ICollection o in res) |
| { |
| Util.Log("results " + o); |
| Assert.IsTrue(o.Count == 1); |
| foreach (IPdxSerializable ip in o) |
| { |
| Assert.IsNotNull(ip); |
| } |
| } |
| |
| } |
| |
| public void HAStepOne() |
| { |
| |
| Region region = CacheHelper.GetVerifyRegion<object, object>(QERegionName); |
| for (int i = 0; i < 226; i++) |
| { |
| region["KEY--" + i] = "VALUE--" + i; |
| } |
| |
| object[] routingObj = new object[17]; |
| int j = 0; |
| for (int i = 0; i < 34; i++) |
| { |
| if (i % 2 == 0) continue; |
| routingObj[j] = "KEY--" + i; |
| j++; |
| } |
| Util.Log("routingObj count= {0}.", routingObj.Length); |
| |
| bool args = true; |
| //test data dependant function execution |
| // test get function with result |
| Apache.Geode.Client.Execution<object> exc = Client.FunctionService<object>.OnRegion<object, object>(region); |
| Client.IResultCollector<object> rc = exc.WithArgs<bool>(args).WithFilter<object>(routingObj).Execute(getFuncName); |
| ICollection<object> executeFunctionResult = rc.GetResult(); |
| List<object> resultList = new List<object>(); |
| //resultList.Clear(); |
| |
| Util.Log("executeFunctionResult Length = {0}", executeFunctionResult.Count); |
| |
| foreach (List<object> item in executeFunctionResult) |
| { |
| |
| foreach (object item2 in item) |
| { |
| resultList.Add(item2); |
| } |
| } |
| |
| Util.Log("on region: result count= {0}.", resultList.Count); |
| Assert.IsTrue(resultList.Count == 34, "result count check failed"); |
| for (int i = 0; i < resultList.Count; i++) |
| { |
| Util.Log("on region:get:result[{0}]={1}.", i, (string)resultList[i]); |
| } |
| |
| // Bring down the region |
| region.GetLocalView().DestroyRegion(); |
| } |
| |
| public void OnRegionHA() |
| { |
| Region region = CacheHelper.GetVerifyRegion<object, object>(QERegionName); |
| for (int i = 0; i < 230; i++) |
| { |
| region[i] = "VALUE--" + i; |
| } |
| |
| Object[] routingObj = new Object[17]; |
| ArrayList args1 = new ArrayList(); |
| int j = 0; |
| for (int i = 0; i < 34; i++) |
| { |
| if (i % 2 == 0) continue; |
| routingObj[j] = i; |
| j++; |
| } |
| Util.Log("routingObj count= {0}.", routingObj.Length); |
| |
| for (int i = 0; i < routingObj.Length; i++) |
| { |
| Util.Log("routingObj[{0}]={1}.", i, (int)routingObj[i]); |
| args1.Add(routingObj[i]); |
| } |
| |
| //test data independant function execution with result OnRegion |
| |
| Apache.Geode.Client.Execution<object> exc = Client.FunctionService<object>.OnRegion<object, object>(region); |
| |
| Assert.IsTrue(exc != null, "onRegion Returned NULL"); |
| |
| Client.IResultCollector<object> rc = exc.WithArgs<ArrayList>(args1).Execute(RegionOperationsHAFunctionPrSHOP, TimeSpan.FromSeconds(15)); |
| |
| ICollection<object> executeFunctionResult = rc.GetResult(); |
| List<Object> resultList = new List<Object>(); |
| Console.WriteLine("executeFunctionResult.Length = {0}", executeFunctionResult.Count); |
| |
| foreach (List<object> item in executeFunctionResult) |
| { |
| foreach (object item2 in item) |
| { |
| resultList.Add(item2); |
| } |
| } |
| |
| Util.Log("on region: result count= {0}.", resultList.Count); |
| Assert.IsTrue(resultList.Count == 17, "result count check failed"); |
| for (int i = 0; i < resultList.Count; i++) |
| { |
| Util.Log("on region:get:result[{0}]={1}.", i, (string)resultList[i]); |
| Assert.IsTrue((string)resultList[i] != null, "onRegion Returned NULL"); |
| } |
| } |
| |
| |
| public void OnRegionHAStepOne() |
| { |
| Region region = CacheHelper.GetVerifyRegion<object, object>(QERegionName); |
| for (int i = 0; i < 226; i++) |
| { |
| region["KEY--" + i] = "VALUE--" + i; |
| } |
| |
| Object[] routingObj = new Object[17]; |
| ArrayList args1 = new ArrayList(); |
| int j = 0; |
| for (int i = 0; i < 34; i++) |
| { |
| if (i % 2 == 0) continue; |
| routingObj[j] = "KEY--" + i; |
| j++; |
| } |
| Util.Log("routingObj count= {0}.", routingObj.Length); |
| |
| for (int i = 0; i < routingObj.Length; i++) |
| { |
| Console.WriteLine("routingObj[{0}]={1}.", i, (string)routingObj[i]); |
| args1.Add(routingObj[i]); |
| } |
| |
| //test data independant function execution with result onServer |
| |
| Apache.Geode.Client.Execution<object> exc = Client.FunctionService<object>.OnRegion<object, object>(region); |
| |
| Assert.IsTrue(exc != null, "onRegion Returned NULL"); |
| |
| Client.IResultCollector<object> rc = exc.WithArgs<ArrayList>(args1).Execute(RegionOperationsHAFunction, TimeSpan.FromSeconds(15)); |
| |
| ICollection<object> executeFunctionResult = rc.GetResult(); |
| List<Object> resultList = new List<Object>(); |
| Console.WriteLine("executeFunctionResult.Length = {0}", executeFunctionResult.Count); |
| |
| foreach (List<object> item in executeFunctionResult) |
| { |
| foreach (object item2 in item) |
| { |
| resultList.Add(item2); |
| } |
| } |
| |
| Util.Log("on region: result count= {0}.", resultList.Count); |
| Assert.IsTrue(resultList.Count == 17, "result count check failed"); |
| for (int i = 0; i < resultList.Count; i++) |
| { |
| Util.Log("on region:get:result[{0}]={1}.", i, (string)resultList[i]); |
| Assert.IsTrue((string)resultList[i] != null, "onServer Returned NULL"); |
| } |
| |
| ///////////////OnRegion with Single filter Key //////////////// |
| |
| Object[] filter = new Object[1]; |
| filter[0] = "KEY--" + 10; |
| rc = exc.WithArgs<ArrayList>(args1).WithFilter<Object>(filter).Execute(RegionOperationsHAFunction, TimeSpan.FromSeconds(15)); |
| |
| executeFunctionResult = rc.GetResult(); |
| resultList = new List<Object>(); |
| Console.WriteLine("executeFunctionResult.Length = {0}", executeFunctionResult.Count); |
| |
| foreach (List<object> item in executeFunctionResult) |
| { |
| foreach (object item2 in item) |
| { |
| resultList.Add(item2); |
| } |
| } |
| |
| Util.Log("on region: result count= {0}.", resultList.Count); |
| Assert.IsTrue(resultList.Count == 17, "result count check failed"); |
| for (int i = 0; i < resultList.Count; i++) |
| { |
| Util.Log("on region:get:result[{0}]={1}.", i, (string)resultList[i]); |
| Assert.IsTrue((string)resultList[i] != null, "onServer Returned NULL"); |
| } |
| |
| ///////////////OnRegion with Single filter Key Done//////////////// |
| } |
| |
| |
| public void OnRegionPrSHOPSingleFilterKey() |
| { |
| Region region = CacheHelper.GetVerifyRegion<object, object>(QERegionName); |
| |
| for (int i = 0; i < 230; i++) |
| { |
| region[i] = "VALUE--" + i; |
| } |
| Util.Log("Put on region complete "); |
| ///////////////////// OnRegion with single filter key ///////////////////////////// |
| Object[] filter = new Object[1]; |
| for (int i = 0; i < 230; i++) |
| { |
| filter[0] = i; |
| Util.Log("filter count= {0}.", filter.Length); |
| |
| |
| Execution<object> exc = Client.FunctionService<object>.OnRegion<object, object>(region); |
| IResultCollector<object> rc = exc.WithFilter<object>(filter).Execute(FEOnRegionPrSHOP); |
| ICollection<object> executeFunctionResult = rc.GetResult(); |
| Util.Log("OnRegionPrSHOPSingleFilterKey for filter executeFunctionResult.Count = {0} ", executeFunctionResult.Count); |
| Assert.AreEqual(1, executeFunctionResult.Count, "executeFunctionResult count check failed"); |
| foreach (Boolean item in executeFunctionResult) |
| { |
| Util.Log("on region:FEOnRegionPrSHOP:= {0}.", item); |
| Assert.AreEqual(true, item, "FEOnRegionPrSHOP item not true"); |
| } |
| Util.Log("FEOnRegionPrSHOP done"); |
| |
| rc = exc.WithFilter<object>(filter).Execute(FEOnRegionPrSHOP_OptimizeForWrite); |
| executeFunctionResult = rc.GetResult(); |
| Util.Log("OnRegionPrSHOPSingleFilterKey for FEOnRegionPrSHOP_OptimizeForWrite executeFunctionResult.Count = {0} ", executeFunctionResult.Count); |
| Assert.AreEqual(1, executeFunctionResult.Count, "executeFunctionResult.Count check failed"); |
| foreach (Boolean item in executeFunctionResult) |
| { |
| Util.Log("on region:FEOnRegionPrSHOP_OptimizeForWrite:= {0}.", item); |
| Assert.AreEqual(true, item, "FEOnRegionPrSHOP_OptimizeForWrite item not true"); |
| } |
| Util.Log("FEOnRegionPrSHOP_OptimizeForWrite done"); |
| } |
| ///////////////////// OnRegion with single filter key done///////////////////////////// |
| } |
| |
| public void FEOnRegionTx() |
| { |
| Region region = CacheHelper.GetVerifyRegion<object, object>(QERegionName); |
| CacheTransactionManager csTx = CacheHelper.CSTXManager; |
| csTx.Begin(); |
| Util.Log("Transaction begun."); |
| |
| for (int i = 0; i < 230; i++) |
| { |
| region["KEY--" + i] = "VALUE--" + i; |
| } |
| Util.Log("Put on region complete "); |
| |
| int j = 0; |
| Object[] filter = new Object[20]; |
| for (int i = 0; i < 20; i++) |
| { |
| filter[j] = "KEY--" + i; |
| j++; |
| } |
| Util.Log("filter count= {0}.", filter.Length); |
| |
| |
| Execution<object> exc = Client.FunctionService<object>.OnRegion<object, object>(region); |
| |
| IResultCollector<object> rc = exc.WithFilter<object>(filter).Execute(putFuncName); |
| |
| Util.Log("Executing ExecuteFunctionOnRegion on region for execKeys for arrList arguement done."); |
| |
| csTx.Commit(); |
| Util.Log("Transaction commited"); |
| |
| for (int i = 0; i < filter.Length; i++) |
| { |
| String str = (String)filter[i]; |
| String val = (String)region[str]; |
| Util.Log("Filter Key = {0}, get Value = {1} ", str, val); |
| if (!str.Equals(val)) |
| Assert.Fail("Value after function execution and transaction is incorrect"); |
| } |
| } |
| |
| public void ExecuteFEOnRegionMultiFilterKeyStepOne() |
| { |
| Region region = CacheHelper.GetVerifyRegion<object, object>(QERegionName); |
| |
| for (int k = 0; k < 210; k++) |
| { |
| int j = 0; |
| Object[] filter = new Object[20]; |
| for (int i = k; i < k + 20; i++) |
| { |
| filter[j] = i; |
| j++; |
| } |
| Util.Log("filter count= {0}.", filter.Length); |
| |
| object args = true; |
| |
| Execution<object> exc = Client.FunctionService<object>.OnRegion<object, object>(region); |
| |
| IResultCollector<object> rc = exc.WithFilter<object>(filter).Execute(getFuncName); |
| ICollection<object> executeFunctionResult = rc.GetResult(); |
| |
| Util.Log("ExecuteFEOnRegionMultiFilterKeyStepOne for filter executeFunctionResult.Count = {0} ", executeFunctionResult.Count); |
| |
| List<object> resultList = new List<object>(); |
| foreach (List<object> item in executeFunctionResult) |
| { |
| foreach (object item2 in item) |
| { |
| resultList.Add(item2); |
| } |
| } |
| |
| Util.Log("on region: result count= {0}.", resultList.Count); |
| Assert.AreEqual(40, resultList.Count, "result count check failed"); |
| for (int i = 0; i < resultList.Count; i++) |
| { |
| Util.Log("on region:get:= {0}.", resultList[i]); |
| } |
| |
| Util.Log("Executing ExecuteFEOnRegionMultiFilterKeyStepOne on region for execKeys for arrList arguement done."); |
| |
| MyResultCollector<object> myRC1 = new MyResultCollector<object>(); |
| rc = exc.WithFilter<object>(filter).WithCollector(myRC1).Execute(getFuncName); |
| executeFunctionResult = rc.GetResult(); |
| Util.Log("add result count= {0}.", myRC1.GetAddResultCount()); |
| Util.Log("get result count= {0}.", myRC1.GetGetResultCount()); |
| Util.Log("end result count= {0}.", myRC1.GetEndResultCount()); |
| Assert.AreEqual(4, myRC1.GetAddResultCount(), "add result count check failed"); |
| Assert.AreEqual(1, myRC1.GetGetResultCount(), "get result count check failed"); |
| Assert.AreEqual(1, myRC1.GetEndResultCount(), "end result count check failed"); |
| Util.Log("on Region with collector: result count= {0}.", executeFunctionResult.Count); |
| |
| resultList.Clear(); |
| foreach (List<object> item in executeFunctionResult) |
| { |
| foreach (object item2 in item) |
| { |
| resultList.Add(item2); |
| } |
| } |
| |
| Util.Log("on region: result count with custom ResultCollector = {0}.", resultList.Count); |
| Assert.AreEqual(40, resultList.Count, "result count check failed"); |
| for (int i = 0; i < resultList.Count; i++) |
| { |
| Util.Log("on region:get:= {0}.", resultList[i]); |
| } |
| } |
| } |
| |
| public void ExecuteFEOnRegionMultiFilterKeyStepTwo() |
| { |
| Region region = CacheHelper.GetVerifyRegion<object, object>(QERegionName); |
| |
| for (int i = 0; i < 230; i++) |
| { |
| region[i] = "VALUE--" + i; |
| } |
| Util.Log("Put on region complete "); |
| |
| for (int k = 0; k < 210; k++) |
| { |
| int j = 0; |
| Object[] filter = new Object[20]; |
| for (int i = k; i < k + 20; i++) |
| { |
| filter[j] = i; |
| j++; |
| } |
| Util.Log("filter count= {0}.", filter.Length); |
| |
| object args = true; |
| |
| Execution<object> exc = Client.FunctionService<object>.OnRegion<object, object>(region); |
| |
| IResultCollector<object> rc = exc.WithFilter<object>(filter).Execute(getFuncName); |
| ICollection<object> executeFunctionResult = rc.GetResult(); |
| |
| Util.Log("ExecuteFEOnRegionMultiFilterKeyStepTwo for filter executeFunctionResult.Count = {0} ", executeFunctionResult.Count); |
| |
| List<object> resultList = new List<object>(); |
| foreach (List<object> item in executeFunctionResult) |
| { |
| foreach (object item2 in item) |
| { |
| resultList.Add(item2); |
| } |
| } |
| |
| Util.Log("on region: result count= {0}.", resultList.Count); |
| Assert.AreEqual(40, resultList.Count, "result count check failed"); |
| for (int i = 0; i < resultList.Count; i++) |
| { |
| Util.Log("on region:get:= {0}.", resultList[i]); |
| } |
| |
| Util.Log("Executing ExecuteFEOnRegionMultiFilterKeyStepTwo on region for execKeys for arrList arguement done."); |
| |
| MyResultCollector<object> myRC1 = new MyResultCollector<object>(); |
| rc = exc.WithFilter<object>(filter).WithCollector(myRC1).Execute(getFuncName); |
| executeFunctionResult = rc.GetResult(); |
| Util.Log("add result count= {0}.", myRC1.GetAddResultCount()); |
| Util.Log("get result count= {0}.", myRC1.GetGetResultCount()); |
| Util.Log("end result count= {0}.", myRC1.GetEndResultCount()); |
| Assert.AreEqual(4, myRC1.GetAddResultCount(), "add result count check failed"); |
| Assert.AreEqual(1, myRC1.GetGetResultCount(), "get result count check failed"); |
| Assert.AreEqual(1, myRC1.GetEndResultCount(), "end result count check failed"); |
| Util.Log("on Region with collector: result count= {0}.", executeFunctionResult.Count); |
| |
| resultList.Clear(); |
| foreach (List<object> item in executeFunctionResult) |
| { |
| foreach (object item2 in item) |
| { |
| resultList.Add(item2); |
| } |
| } |
| |
| Util.Log("on region: result count with custom ResultCollector = {0}.", resultList.Count); |
| Assert.AreEqual(40, resultList.Count, "result count check failed"); |
| for (int i = 0; i < resultList.Count; i++) |
| { |
| Util.Log("on region:get:= {0}.", resultList[i]); |
| } |
| } |
| } |
| |
| public void OnRegionMultiFilterKeyPrSHOP() |
| { |
| Region region = CacheHelper.GetVerifyRegion<object, object>(QERegionName); |
| region.GetSubscriptionService().RegisterAllKeys(); |
| for (int i = 0; i < 230; i++) |
| { |
| region[i] = "VALUE--" + i; |
| } |
| Util.Log("Put on region complete "); |
| |
| for (int k = 0; k < 210; k++) |
| { |
| Object[] filter = new Object[20]; |
| int j = 0; |
| for (int i = k; i < k + 20; i++) |
| { |
| filter[j] = i; |
| j++; |
| } |
| Util.Log("filter count= {0}.", filter.Length); |
| |
| object args = true; |
| |
| Execution<object> exc = Client.FunctionService<object>.OnRegion<object, object>(region); |
| |
| IResultCollector<object> rc = exc.WithFilter<object>(filter).Execute(FEOnRegionPrSHOP); |
| ICollection<object> executeFunctionResult = rc.GetResult(); |
| Util.Log("OnRegionMultiFilterKeyPrSHOP for filter executeFunctionResult.Count = {0} ", executeFunctionResult.Count); |
| Assert.AreEqual(2, executeFunctionResult.Count, "executeFunctionResult count check failed"); |
| foreach (Boolean item in executeFunctionResult) |
| { |
| Util.Log("on region:OnRegionMultiFilterKeyPrSHOP:= {0}.", item); |
| Assert.AreEqual(true, item, "FEOnRegionPrSHOP item not true"); |
| } |
| Util.Log("OnRegionMultiFilterKeyPrSHOP done"); |
| |
| rc = exc.WithFilter<object>(filter).Execute(FEOnRegionPrSHOP_OptimizeForWrite); |
| executeFunctionResult = rc.GetResult(); |
| Util.Log("OnRegionMultiFilterKeyPrSHOP for FEOnRegionPrSHOP_OptimizeForWrite executeFunctionResult.Count = {0} ", executeFunctionResult.Count); |
| Assert.AreEqual(3, executeFunctionResult.Count, "executeFunctionResult.Count check failed"); |
| foreach (Boolean item in executeFunctionResult) |
| { |
| Util.Log("on region:FEOnRegionPrSHOP_OptimizeForWrite:= {0}.", item); |
| Assert.AreEqual(true, item, "FEOnRegionPrSHOP_OptimizeForWrite item not true"); |
| } |
| Util.Log("FEOnRegionPrSHOP_OptimizeForWrite done"); |
| |
| MyResultCollector<object> myRC1 = new MyResultCollector<object>(); |
| rc = exc.WithFilter<object>(filter).WithCollector(myRC1).Execute(FEOnRegionPrSHOP); |
| executeFunctionResult = rc.GetResult(); |
| Util.Log("add result count= {0}.", myRC1.GetAddResultCount()); |
| Util.Log("get result count= {0}.", myRC1.GetGetResultCount()); |
| Util.Log("end result count= {0}.", myRC1.GetEndResultCount()); |
| Assert.AreEqual(2, myRC1.GetAddResultCount(), "add result count check failed"); |
| Assert.AreEqual(1, myRC1.GetGetResultCount(), "get result count check failed"); |
| Assert.AreEqual(1, myRC1.GetEndResultCount(), "end result count check failed"); |
| executeFunctionResult = rc.GetResult(); |
| Util.Log("OnRegionMultiFilterKeyPrSHOP for filter executeFunctionResult.Count = {0} ", executeFunctionResult.Count); |
| Assert.AreEqual(2, executeFunctionResult.Count, "executeFunctionResult count check failed"); |
| foreach (Boolean item in executeFunctionResult) |
| { |
| Util.Log("on region:FEOnRegionPrSHOP:= {0}.", item); |
| Assert.AreEqual(true, item, "FEOnRegionPrSHOP item not true"); |
| } |
| Util.Log("FEOnRegionPrSHOP with ResultCollector done"); |
| |
| MyResultCollector<object> myRC2 = new MyResultCollector<object>(); |
| rc = exc.WithFilter<object>(filter).WithCollector(myRC2).Execute(FEOnRegionPrSHOP_OptimizeForWrite); |
| executeFunctionResult = rc.GetResult(); |
| Util.Log("add result count= {0}.", myRC2.GetAddResultCount()); |
| Util.Log("get result count= {0}.", myRC2.GetGetResultCount()); |
| Util.Log("end result count= {0}.", myRC2.GetEndResultCount()); |
| Assert.AreEqual(3, myRC2.GetAddResultCount(), "add result count check failed"); |
| Assert.AreEqual(1, myRC2.GetGetResultCount(), "get result count check failed"); |
| Assert.AreEqual(1, myRC2.GetEndResultCount(), "end result count check failed"); |
| executeFunctionResult = rc.GetResult(); |
| Util.Log("OnRegionMultiFilterKeyPrSHOP for FEOnRegionPrSHOP_OptimizeForWrite executeFunctionResult.Count = {0} ", executeFunctionResult.Count); |
| Assert.AreEqual(3, executeFunctionResult.Count, "executeFunctionResult.Count check failed"); |
| foreach (Boolean item in executeFunctionResult) |
| { |
| Util.Log("on region:FEOnRegionPrSHOP_OptimizeForWrite:= {0}.", item); |
| Assert.AreEqual(true, item, "FEOnRegionPrSHOP_OptimizeForWrite item not true"); |
| } |
| Util.Log("FEOnRegionPrSHOP_OptimizeForWrite with ResultCollector done"); |
| } |
| |
| Execution<object> exe = Client.FunctionService<object>.OnRegion<object, object>(region); |
| |
| //w/o filter |
| IResultCollector<object> collector = exe.Execute(FEOnRegionPrSHOP); |
| ICollection<Object> FunctionResult = collector.GetResult(); |
| Util.Log("OnRegionMultiFilterKeyPrSHOP for filter FunctionResult.Count = {0} ", FunctionResult.Count); |
| Assert.AreEqual(2, FunctionResult.Count, "FunctionResult count check failed"); |
| foreach (Boolean item in FunctionResult) |
| { |
| Util.Log("on region:FEOnRegionPrSHOP:= {0}.", item); |
| Assert.AreEqual(true, item, "FEOnRegionPrSHOP item not true"); |
| } |
| collector.ClearResults(); |
| Util.Log("FEOnRegionPrSHOP without filter done"); |
| |
| // w/o filter |
| MyResultCollector<object> rC = new MyResultCollector<object>(); |
| IResultCollector<Object> Rcollector = exe.WithCollector(rC).Execute(FEOnRegionPrSHOP); |
| FunctionResult = Rcollector.GetResult(); |
| Util.Log("add result count= {0}.", rC.GetAddResultCount()); |
| Util.Log("get result count= {0}.", rC.GetGetResultCount()); |
| Util.Log("end result count= {0}.", rC.GetEndResultCount()); |
| Assert.AreEqual(2, rC.GetAddResultCount(), "add result count check failed"); |
| Assert.AreEqual(1, rC.GetGetResultCount(), "get result count check failed"); |
| Assert.AreEqual(1, rC.GetEndResultCount(), "end result count check failed"); |
| FunctionResult = Rcollector.GetResult(); |
| Util.Log("OnRegionMultiFilterKeyPrSHOP for filter FunctionResult.Count = {0} ", FunctionResult.Count); |
| Assert.AreEqual(2, FunctionResult.Count, "executeFunctionResult count check failed"); |
| foreach (Boolean item in FunctionResult) |
| { |
| Util.Log("on region:FEOnRegionPrSHOP:= {0}.", item); |
| Assert.AreEqual(true, item, "FEOnRegionPrSHOP item not true"); |
| } |
| Util.Log("FEOnRegionPrSHOP with ResultCollector without filter done"); |
| |
| //w/o filter |
| collector.ClearResults(); |
| collector = exe.Execute(FEOnRegionPrSHOP_OptimizeForWrite); |
| Util.Log("OnRegionMultiFilterKeyPrSHOP for FEOnRegionPrSHOP_OptimizeForWrite executeFunctionResult.Count = {0} ", collector.GetResult().Count); |
| Assert.AreEqual(3, collector.GetResult().Count, "executeFunctionResult.Count check failed"); |
| foreach (Boolean item in collector.GetResult()) |
| { |
| Util.Log("on region:FEOnRegionPrSHOP_OptimizeForWrite:= {0}.", item); |
| Assert.AreEqual(true, item, "FEOnRegionPrSHOP_OptimizeForWrite item not true"); |
| } |
| Util.Log("FEOnRegionPrSHOP_OptimizeForWrite done w/o filter"); |
| |
| //w/o filter |
| MyResultCollector<object> rC2 = new MyResultCollector<object>(); |
| Rcollector = exe.WithCollector(rC2).Execute(FEOnRegionPrSHOP_OptimizeForWrite); |
| FunctionResult = Rcollector.GetResult(); |
| Util.Log("add result count= {0}.", rC2.GetAddResultCount()); |
| Util.Log("get result count= {0}.", rC2.GetGetResultCount()); |
| Util.Log("end result count= {0}.", rC2.GetEndResultCount()); |
| Assert.AreEqual(3, rC2.GetAddResultCount(), "add result count check failed"); |
| Assert.AreEqual(1, rC2.GetGetResultCount(), "get result count check failed"); |
| Assert.AreEqual(1, rC2.GetEndResultCount(), "end result count check failed"); |
| Util.Log("OnRegionMultiFilterKeyPrSHOP for FEOnRegionPrSHOP_OptimizeForWrite FunctionResult.Count = {0} ", FunctionResult.Count); |
| Assert.AreEqual(3, FunctionResult.Count, "executeFunctionResult.Count check failed"); |
| foreach (Boolean item in FunctionResult) |
| { |
| Util.Log("on region:FEOnRegionPrSHOP_OptimizeForWrite:= {0}.", item); |
| Assert.AreEqual(true, item, "FEOnRegionPrSHOP_OptimizeForWrite item not true"); |
| } |
| Util.Log("FEOnRegionPrSHOP_OptimizeForWrite with ResultCollector w/o filter done"); |
| |
| for (int i = 0; i < 500; i++) |
| { |
| region["KEY--" + i] = "VALUE--" + i; |
| } |
| Util.Log("Put on region complete "); |
| |
| Object[] fil = new Object[500]; |
| int x = 0; |
| for (int i = 0; i < 500; i++) |
| { |
| fil[x] = "KEY--" + i; |
| x++; |
| } |
| Util.Log("filter count= {0}.", fil.Length); |
| |
| // Fire N Forget with filter keys |
| exe = Client.FunctionService<object>.OnRegion<object, object>(region); |
| exe.WithFilter<object>(fil).Execute(putFuncName); |
| Util.Log("Executing ExecuteFunctionOnRegion on region for execKeys for arrList arguement done."); |
| Thread.Sleep(4000); //wait for results to be updated |
| |
| for (int i = 0; i < fil.Length; i++) |
| { |
| String str = (String)fil[i]; |
| String val = (String)region[str]; |
| Util.Log("Filter Key = {0}, get Value = {1} ", str, val); |
| if (!str.Equals(val)) |
| Assert.Fail("Value after function execution is incorrect"); |
| } |
| |
| // Fire N Forget without filter keys |
| ArrayList args1 = new ArrayList(); |
| for (int i = 10; i < 200; i++) |
| { |
| args1.Add("KEY--" + i); |
| } |
| exe = Client.FunctionService<object>.OnRegion<object, object>(region); |
| exe.WithArgs<ArrayList>(args1).Execute(putFuncIName); |
| Util.Log("Executing ExecuteFunctionOnRegion on region for execKeys for arrList arguement done."); |
| Thread.Sleep(4000); ////wait for results to be updated |
| |
| for (int i = 0; i < args1.Count; i++) |
| { |
| String str = (String)args1[i]; |
| String val = (String)region[str]; |
| Util.Log("Arg Key = {0}, get Value = {1} ", str, val); |
| if (!str.Equals(val)) |
| Assert.Fail("Value after function execution is incorrect"); |
| } |
| } |
| |
| public void OnServerHAStepOne() |
| { |
| |
| Region region = CacheHelper.GetVerifyRegion<object, object>(QERegionName); |
| for (int i = 0; i < 34; i++) |
| { |
| region["KEY--" + i] = "VALUE--" + i; |
| } |
| |
| object[] routingObj = new object[17]; |
| |
| ArrayList args1 = new ArrayList(); |
| |
| int j = 0; |
| for (int i = 0; i < 34; i++) |
| { |
| if (i % 2 == 0) continue; |
| routingObj[j] = "KEY--" + i; |
| j++; |
| } |
| Util.Log("routingObj count= {0}.", routingObj.Length); |
| |
| for (int i = 0; i < routingObj.Length; i++) |
| { |
| Console.WriteLine("routingObj[{0}]={1}.", i, (string)routingObj[i]); |
| args1.Add(routingObj[i]); |
| } |
| |
| //test data independant function execution with result onServer |
| Pool/*<TKey, TValue>*/ pool = CacheHelper.DCache.GetPoolManager().Find(poolName); |
| |
| Apache.Geode.Client.Execution<object> exc = Client.FunctionService<object>.OnServer(pool); |
| Assert.IsTrue(exc != null, "onServer Returned NULL"); |
| |
| Client.IResultCollector<object> rc = exc.WithArgs<ArrayList>(args1).Execute(OnServerHAExceptionFunction, TimeSpan.FromSeconds(15)); |
| |
| ICollection<object> executeFunctionResult = rc.GetResult(); |
| |
| List<object> resultList = new List<object>(); |
| |
| Console.WriteLine("executeFunctionResult.Length = {0}", executeFunctionResult.Count); |
| |
| foreach (List<object> item in executeFunctionResult) |
| { |
| foreach (object item2 in item) |
| { |
| resultList.Add(item2); |
| } |
| } |
| |
| Util.Log("on region: result count= {0}.", resultList.Count); |
| Assert.IsTrue(resultList.Count == 17, "result count check failed"); |
| for (int i = 0; i < resultList.Count; i++) |
| { |
| Util.Log("on region:get:result[{0}]={1}.", i, (string)resultList[i]); |
| Assert.IsTrue(((string)resultList[i]) != null, "onServer Returned NULL"); |
| } |
| |
| rc = exc.WithArgs<ArrayList>(args1).Execute(OnServerHAShutdownFunction, TimeSpan.FromSeconds(15)); |
| |
| ICollection<object> executeFunctionResult1 = rc.GetResult(); |
| |
| List<object> resultList1 = new List<object>(); |
| |
| foreach (List<object> item in executeFunctionResult1) |
| { |
| foreach (object item2 in item) |
| { |
| resultList1.Add(item2); |
| } |
| } |
| |
| Util.Log("on region: result count= {0}.", resultList1.Count); |
| |
| Console.WriteLine("resultList1.Count = {0}", resultList1.Count); |
| |
| Assert.IsTrue(resultList1.Count == 17, "result count check failed"); |
| for (int i = 0; i < resultList1.Count; i++) |
| { |
| Util.Log("on region:get:result[{0}]={1}.", i, (string)resultList1[i]); |
| Assert.IsTrue(((string)resultList1[i]) != null, "onServer Returned NULL"); |
| } |
| |
| // Bring down the region |
| //region.LocalDestroyRegion(); |
| } |
| |
| void runOnServerHAExecuteFunction() |
| { |
| CacheHelper.SetupJavaServers(true, "func_cacheserver1_pool.xml", |
| "func_cacheserver2_pool.xml", "func_cacheserver3_pool.xml"); |
| CacheHelper.StartJavaLocator(1, "GFELOC"); |
| Util.Log("Locator 1 started."); |
| CacheHelper.StartJavaServerWithLocators(1, "GFECS1", 1); |
| Util.Log("Cacheserver 1 started."); |
| CacheHelper.StartJavaServerWithLocators(2, "GFECS2", 1); |
| Util.Log("Cacheserver 2 started."); |
| CacheHelper.StartJavaServerWithLocators(3, "GFECS3", 1); |
| Util.Log("Cacheserver 3 started."); |
| |
| m_client1.Call(createPool, poolName, CacheHelper.Locators, serverGroup, 1, true, true, /*threadLocal*/true); |
| m_client1.Call(createRegionAndAttachPool, QERegionName, poolName); |
| Util.Log("Client 1 (pool locator) regions created"); |
| |
| m_client1.Call(OnServerHAStepOne); |
| |
| m_client1.Call(Close); |
| Util.Log("Client 1 closed"); |
| |
| CacheHelper.StopJavaServer(1); |
| Util.Log("Cacheserver 1 stopped."); |
| |
| CacheHelper.StopJavaServer(2); |
| Util.Log("Cacheserver 2 stopped."); |
| |
| CacheHelper.StopJavaServer(3); |
| Util.Log("Cacheserver 3 stopped."); |
| |
| CacheHelper.StopJavaLocator(1); |
| Util.Log("Locator 1 stopped."); |
| |
| CacheHelper.ClearEndpoints(); |
| CacheHelper.ClearLocators(); |
| } |
| |
| void runFEOnRegionPrSHOPSingleFilterKey() |
| { |
| CacheHelper.SetupJavaServers(true, "func_cacheserver1_pool.xml", |
| "func_cacheserver2_pool.xml", "func_cacheserver3_pool.xml"); |
| CacheHelper.StartJavaLocator(1, "GFELOC"); |
| Util.Log("Locator 1 started."); |
| CacheHelper.StartJavaServerWithLocators(1, "GFECS1", 1); |
| Util.Log("Cacheserver 1 started."); |
| CacheHelper.StartJavaServerWithLocators(2, "GFECS2", 1); |
| Util.Log("Cacheserver 2 started."); |
| CacheHelper.StartJavaServerWithLocators(3, "GFECS3", 1); |
| Util.Log("Cacheserver 3 started."); |
| m_client1.Call(createPool, poolName, CacheHelper.Locators, serverGroup, 1, true, true, true); |
| m_client1.Call(createRegionAndAttachPool, QERegionName, poolName); |
| Util.Log("Client 1 (pool locator) regions created"); |
| |
| m_client1.Call(OnRegionPrSHOPSingleFilterKey); |
| |
| m_client1.Call(Close); |
| Util.Log("Client 1 closed"); |
| |
| CacheHelper.StopJavaServer(1); |
| Util.Log("Cacheserver 1 stopped."); |
| |
| CacheHelper.StopJavaServer(2); |
| Util.Log("Cacheserver 2 stopped."); |
| |
| CacheHelper.StopJavaServer(3); |
| Util.Log("Cacheserver 3 stopped."); |
| |
| CacheHelper.StopJavaLocator(1); |
| Util.Log("Locator 1 stopped."); |
| |
| CacheHelper.ClearEndpoints(); |
| CacheHelper.ClearLocators(); |
| } |
| |
| void runOnRegionHAExecuteFunction() |
| { |
| CacheHelper.SetupJavaServers(true, "func_cacheserver1_pool.xml", |
| "func_cacheserver2_pool.xml"); |
| CacheHelper.StartJavaLocator(1, "GFELOC"); |
| Util.Log("Locator 1 started."); |
| CacheHelper.StartJavaServerWithLocators(1, "GFECS1", 1); |
| Util.Log("Cacheserver 1 started."); |
| CacheHelper.StartJavaServerWithLocators(2, "GFECS2", 1); |
| Util.Log("Cacheserver 2 started."); |
| |
| m_client1.Call(createPool, poolName, CacheHelper.Locators, serverGroup, 1, true, /*singleHop*/false, /*threadLocal*/false); |
| m_client1.Call(createRegionAndAttachPool, QERegionName, poolName); |
| Util.Log("Client 1 (pool locator) regions created"); |
| |
| m_client1.Call(OnRegionHAStepOne); |
| |
| m_client1.Call(Close); |
| Util.Log("Client 1 closed"); |
| |
| CacheHelper.StopJavaServer(1); |
| Util.Log("Cacheserver 1 stopped."); |
| |
| CacheHelper.StopJavaServer(2); |
| Util.Log("Cacheserver 2 stopped."); |
| |
| CacheHelper.StopJavaLocator(1); |
| Util.Log("Locator 1 stopped."); |
| |
| CacheHelper.ClearEndpoints(); |
| CacheHelper.ClearLocators(); |
| } |
| |
| void runOnRegionHAExecuteFunctionPrSHOP() |
| { |
| CacheHelper.SetupJavaServers(true, "func_cacheserver1_pool.xml", |
| "func_cacheserver2_pool.xml"); |
| CacheHelper.StartJavaLocator(1, "GFELOC"); |
| Util.Log("Locator 1 started."); |
| CacheHelper.StartJavaServerWithLocators(1, "GFECS1", 1); |
| Util.Log("Cacheserver 1 started."); |
| CacheHelper.StartJavaServerWithLocators(2, "GFECS2", 1); |
| Util.Log("Cacheserver 2 started."); |
| |
| m_client1.Call(createPool, poolName, CacheHelper.Locators, serverGroup, 1, true, /*singleHop*/true, /*threadLocal*/true); |
| m_client1.Call(createRegionAndAttachPool, QERegionName, poolName); |
| Util.Log("Client 1 (pool locator) regions created"); |
| |
| m_client1.Call(OnRegionHA); |
| |
| m_client1.Call(Close); |
| Util.Log("Client 1 closed"); |
| |
| CacheHelper.StopJavaServer(1); |
| Util.Log("Cacheserver 1 stopped."); |
| |
| CacheHelper.StopJavaServer(2); |
| Util.Log("Cacheserver 2 stopped."); |
| |
| CacheHelper.StopJavaLocator(1); |
| Util.Log("Locator 1 stopped."); |
| |
| CacheHelper.ClearEndpoints(); |
| CacheHelper.ClearLocators(); |
| } |
| |
| void runExecuteFunctionOnRegionMultiFilterKey(bool singleHop) |
| { |
| CacheHelper.SetupJavaServers(true, "func_cacheserver1_pool.xml", |
| "func_cacheserver2_pool.xml", "func_cacheserver3_pool.xml"); |
| CacheHelper.StartJavaLocator(1, "GFELOC"); |
| Util.Log("Locator 1 started."); |
| CacheHelper.StartJavaServerWithLocators(1, "GFECS1", 1); |
| Util.Log("Cacheserver 1 started."); |
| CacheHelper.StartJavaServerWithLocators(2, "GFECS2", 1); |
| Util.Log("Cacheserver 2 started."); |
| CacheHelper.StartJavaServerWithLocators(3, "GFECS3", 1); |
| Util.Log("Cacheserver 3 started."); |
| |
| m_client1.Call(createPool, poolName, CacheHelper.Locators, serverGroup, 1, true, singleHop, /*threadLocal*/false); |
| m_client1.Call(createRegionAndAttachPool, QERegionName, poolName); |
| Util.Log("Client 1 (pool locator) regions created"); |
| |
| m_client1.Call(ExecuteFEOnRegionMultiFilterKeyStepOne); |
| m_client1.Call(ExecuteFEOnRegionMultiFilterKeyStepTwo); |
| |
| m_client1.Call(Close); |
| Util.Log("Client 1 closed"); |
| |
| CacheHelper.StopJavaServer(1); |
| Util.Log("Cacheserver 1 stopped."); |
| |
| CacheHelper.StopJavaServer(2); |
| Util.Log("Cacheserver 2 stopped."); |
| |
| CacheHelper.StopJavaServer(3); |
| Util.Log("Cacheserver 3 stopped."); |
| |
| CacheHelper.StopJavaLocator(1); |
| Util.Log("Locator 1 stopped."); |
| |
| CacheHelper.ClearEndpoints(); |
| CacheHelper.ClearLocators(); |
| } |
| |
| void runFEOnRegionTx(bool singleHop) |
| { |
| CacheHelper.SetupJavaServers(true, "func_cacheserver1_pool.xml"); |
| CacheHelper.StartJavaLocator(1, "GFELOC"); |
| Util.Log("Locator 1 started."); |
| CacheHelper.StartJavaServerWithLocators(1, "GFECS1", 1); |
| Util.Log("Cacheserver 1 started."); |
| |
| m_client1.Call(createPool, poolName, CacheHelper.Locators, serverGroup, 1, true, singleHop, /*threadLocal*/true); |
| m_client1.Call(createRegionAndAttachPool, QERegionName, poolName); |
| Util.Log("Client 1 (pool locator) regions created"); |
| |
| m_client1.Call(FEOnRegionTx); |
| |
| m_client1.Call(Close); |
| Util.Log("Client 1 closed"); |
| |
| CacheHelper.StopJavaServer(1); |
| Util.Log("Cacheserver 1 stopped."); |
| |
| CacheHelper.StopJavaLocator(1); |
| Util.Log("Locator 1 stopped."); |
| |
| CacheHelper.ClearEndpoints(); |
| CacheHelper.ClearLocators(); |
| } |
| |
| void runFEOnRegionPrSHOPMultiFilterKey(bool singleHop) |
| { |
| CacheHelper.SetupJavaServers(true, "func_cacheserver1_pool.xml", |
| "func_cacheserver2_pool.xml", "func_cacheserver3_pool.xml"); |
| CacheHelper.StartJavaLocator(1, "GFELOC"); |
| Util.Log("Locator 1 started."); |
| CacheHelper.StartJavaServerWithLocators(1, "GFECS1", 1); |
| Util.Log("Cacheserver 1 started."); |
| CacheHelper.StartJavaServerWithLocators(2, "GFECS2", 1); |
| Util.Log("Cacheserver 2 started."); |
| CacheHelper.StartJavaServerWithLocators(3, "GFECS3", 1); |
| Util.Log("Cacheserver 3 started."); |
| |
| m_client1.Call(createPool, poolName, CacheHelper.Locators, serverGroup, 1, true, singleHop, /*threadLocal*/true); |
| m_client1.Call(createRegionAndAttachPool, QERegionName, poolName); |
| Util.Log("Client 1 (pool locator) regions created"); |
| |
| m_client1.Call(OnRegionMultiFilterKeyPrSHOP); |
| |
| m_client1.Call(Close); |
| Util.Log("Client 1 closed"); |
| |
| CacheHelper.StopJavaServer(1); |
| Util.Log("Cacheserver 1 stopped."); |
| |
| CacheHelper.StopJavaServer(2); |
| Util.Log("Cacheserver 2 stopped."); |
| |
| CacheHelper.StopJavaServer(3); |
| Util.Log("Cacheserver 3 stopped."); |
| |
| CacheHelper.StopJavaLocator(1); |
| Util.Log("Locator 1 stopped."); |
| |
| CacheHelper.ClearEndpoints(); |
| CacheHelper.ClearLocators(); |
| } |
| |
| [Test] |
| public void PoolExecuteFunctionTest() |
| { |
| CacheHelper.SetupJavaServers(true, "func_cacheserver1_pool.xml", |
| "func_cacheserver2_pool.xml"); |
| CacheHelper.StartJavaLocator(1, "GFELOC"); |
| Util.Log("Locator 1 started."); |
| CacheHelper.StartJavaServerWithLocators(1, "GFECS1", 1); |
| Util.Log("Cacheserver 1 started."); |
| CacheHelper.StartJavaServerWithLocators(2, "GFECS2", 1); |
| Util.Log("Cacheserver 2 started."); |
| m_client1.Call(createPool, poolName, CacheHelper.Locators, serverGroup, 0, true, /*singleHop*/false, /*threadLocal*/false); |
| m_client1.Call(createRegionAndAttachPool, QERegionName, poolName); |
| |
| m_client1.Call(PoolStepOne, CacheHelper.Locators); |
| m_client1.Call(genericFEResultIntTest, CacheHelper.Locators); |
| m_client1.Call(genericFEResultStringTest, CacheHelper.Locators); |
| m_client1.Call(genericFEResultDCStringTest, CacheHelper.Locators); |
| m_client1.Call(genericFEResultDCPdxTest, CacheHelper.Locators); |
| |
| Util.Log("PoolStepOne complete."); |
| m_client1.Call(Close); |
| |
| CacheHelper.StopJavaServer(1); |
| Util.Log("Cacheserver 1 stopped."); |
| |
| CacheHelper.StopJavaServer(2); |
| Util.Log("Cacheserver 2 stopped."); |
| |
| CacheHelper.StopJavaLocator(1); |
| Util.Log("Locator 1 stopped."); |
| } |
| |
| [Test] |
| public void PoolExecuteFunctionTestPrSHOP() |
| { |
| CacheHelper.SetupJavaServers(true, "func_cacheserver1_pool.xml", |
| "func_cacheserver2_pool.xml"); |
| CacheHelper.StartJavaLocator(1, "GFELOC"); |
| Util.Log("Locator 1 started."); |
| CacheHelper.StartJavaServerWithLocators(1, "GFECS1", 1); |
| Util.Log("Cacheserver 1 started."); |
| CacheHelper.StartJavaServerWithLocators(2, "GFECS2", 1); |
| Util.Log("Cacheserver 2 started."); |
| m_client1.Call(createPool, poolName, CacheHelper.Locators, serverGroup, 0, true, /*singleHop*/true, /*threadLocal*/true); |
| m_client1.Call(createRegionAndAttachPool, QERegionName, poolName); |
| |
| m_client1.Call(PoolStepOne, CacheHelper.Locators); |
| m_client1.Call(genericFEResultIntTest, CacheHelper.Locators); |
| m_client1.Call(genericFEResultStringTest, CacheHelper.Locators); |
| m_client1.Call(genericFEResultDCStringTest, CacheHelper.Locators); |
| m_client1.Call(genericFEResultDCPdxTest, CacheHelper.Locators); |
| |
| Util.Log("PoolStepOne complete."); |
| m_client1.Call(Close); |
| |
| CacheHelper.StopJavaServer(1); |
| Util.Log("Cacheserver 1 stopped."); |
| |
| CacheHelper.StopJavaServer(2); |
| Util.Log("Cacheserver 2 stopped."); |
| |
| CacheHelper.StopJavaLocator(1); |
| Util.Log("Locator 1 stopped."); |
| } |
| |
| [Test] |
| public void HAExecuteFunctionTest() |
| { |
| CacheHelper.SetupJavaServers(true, "func_cacheserver1_pool.xml", |
| "func_cacheserver2_pool.xml", "func_cacheserver3_pool.xml"); |
| CacheHelper.StartJavaLocator(1, "GFELOC"); |
| Util.Log("Locator 1 started."); |
| CacheHelper.StartJavaServerWithLocators(1, "GFECS1", 1); |
| Util.Log("Cacheserver 1 started."); |
| CacheHelper.StartJavaServerWithLocators(2, "GFECS2", 1); |
| Util.Log("Cacheserver 2 started."); |
| CacheHelper.StartJavaServerWithLocators(3, "GFECS3", 1); |
| Util.Log("Cacheserver 3 started."); |
| m_client1.Call(createPool, poolName, CacheHelper.Locators, serverGroup, 1, true, /*singleHop*/false, /*threadLocal*/false); |
| m_client1.Call(createRegionAndAttachPool, QERegionName, poolName); |
| |
| m_client1.Call(HAStepOne); |
| Util.Log("HAStepOne complete."); |
| |
| CacheHelper.StopJavaServer(1); |
| Util.Log("Cacheserver 1 stopped."); |
| |
| CacheHelper.StopJavaServer(2); |
| Util.Log("Cacheserver 2 stopped."); |
| CacheHelper.StopJavaServer(3); |
| Util.Log("Cacheserver 3 stopped."); |
| |
| CacheHelper.StopJavaLocator(1); |
| Util.Log("Locator 1 stopped."); |
| } |
| |
| [Test] |
| public void HAExecuteFunctionTestPrSHOP() |
| { |
| CacheHelper.SetupJavaServers(true, "func_cacheserver1_pool.xml", |
| "func_cacheserver2_pool.xml", "func_cacheserver3_pool.xml"); |
| CacheHelper.StartJavaLocator(1, "GFELOC"); |
| Util.Log("Locator 1 started."); |
| CacheHelper.StartJavaServerWithLocators(1, "GFECS1", 1); |
| Util.Log("Cacheserver 1 started."); |
| CacheHelper.StartJavaServerWithLocators(2, "GFECS2", 1); |
| Util.Log("Cacheserver 2 started."); |
| CacheHelper.StartJavaServerWithLocators(3, "GFECS3", 1); |
| Util.Log("Cacheserver 3 started."); |
| m_client1.Call(createPool, poolName, CacheHelper.Locators, serverGroup, 1, true, /*singleHop*/true, true); |
| m_client1.Call(createRegionAndAttachPool, QERegionName, poolName); |
| |
| m_client1.Call(HAStepOne); |
| Util.Log("HAStepOne complete."); |
| |
| CacheHelper.StopJavaServer(1); |
| Util.Log("Cacheserver 1 stopped."); |
| |
| CacheHelper.StopJavaServer(2); |
| Util.Log("Cacheserver 2 stopped."); |
| |
| CacheHelper.StopJavaServer(3); |
| Util.Log("Cacheserver 3 stopped."); |
| |
| CacheHelper.StopJavaLocator(1); |
| Util.Log("Locator 1 stopped."); |
| } |
| |
| [Test] |
| public void OnServerHAExecuteFunctionTest() |
| { |
| runOnServerHAExecuteFunction(); |
| } |
| |
| [Test] |
| public void OnRegionHAExecuteFunctionTest() |
| { |
| runOnRegionHAExecuteFunction(); |
| } |
| |
| [Test] |
| public void TestFEOnRegionPrSHOPSingleFilterKey() |
| { |
| runFEOnRegionPrSHOPSingleFilterKey(); |
| } |
| |
| [Test] |
| public void OnRegionHAExecuteFunctionTestPrSHOP() |
| { |
| runOnRegionHAExecuteFunctionPrSHOP(); |
| } |
| |
| [Test] |
| public void ExecuteFunctionOnRegionMultiFilterKey() |
| { |
| runExecuteFunctionOnRegionMultiFilterKey(false); |
| } |
| |
| [Test] |
| public void ExecuteFunctionOnRegionMultiFilterKeySingleHop() |
| { |
| runExecuteFunctionOnRegionMultiFilterKey(true); |
| } |
| |
| [Test] |
| public void TestFEOnRegionPrSHOPMultiFilterKey() |
| { |
| runFEOnRegionPrSHOPMultiFilterKey(true); |
| } |
| |
| [Test] |
| public void TestFEOnRegionTransaction() |
| { |
| runFEOnRegionTx(false); |
| } |
| |
| [Test] |
| public void TestFEOnRegionTransactionSingleHop() |
| { |
| runFEOnRegionTx(true); |
| } |
| } |
| } |
