/*
 * 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.ObjectModel;
using System.Text;
using System.Threading;
using Apache.Geode.DUnitFramework;
using NUnit.Framework;

namespace Apache.Geode.Client.UnitTests
{
  [Serializable]
  public class CustomPartitionResolver<TValue> : IPartitionResolver<int, TValue>
  {
    public string GetName()
    {
      return "CustomPartitionResolver";
    }

    public object GetRoutingObject(EntryEvent<int, TValue> key)
    {
      Util.Log("CustomPartitionResolver::GetRoutingObject");
      return key.Key + 5;
    }

    public static CustomPartitionResolver<TValue> Create()
    {
      return new CustomPartitionResolver<TValue>();
    }
  }

  [Serializable]
  public class CustomPartitionResolver1<TValue> : IFixedPartitionResolver<int, TValue>
  {
    public string GetName()
    {
      return "CustomPartitionResolver1";
    }

    public object GetRoutingObject(EntryEvent<int, TValue> key)
    {
      Util.Log("CustomPartitionResolver1::GetRoutingObject");
      var nkey = key.Key;

      return nkey + 5;
    }

    public static CustomPartitionResolver1<TValue> Create()
    {
      return new CustomPartitionResolver1<TValue>();
    }

    public string GetPartitionName(EntryEvent<int, TValue> entryEvent)
    {
      Util.Log("CustomPartitionResolver1::GetPartitionName");
      var newkey = entryEvent.Key % 6;
      if (newkey == 0)
      {
        return "P1";
      }

      if (newkey == 1)
      {
        return "P2";
      }

      if (newkey == 2)
      {
        return "P3";
      }

      if (newkey == 3)
      {
        return "P4";
      }

      if (newkey == 4)
      {
        return "P5";
      }

      if (newkey == 5)
      {
        return "P6";
      }

      return "Invalid";
    }
  }

  [Serializable]
  public class CustomPartitionResolver2<TValue> : IFixedPartitionResolver<int, TValue>
  {
    public string GetName()
    {
      return "CustomPartitionResolver2";
    }

    public object GetRoutingObject(EntryEvent<int, TValue> key)
    {
      Util.Log("CustomPartitionResolver2::GetRoutingObject");
      return key.Key + 4;
    }

    public static CustomPartitionResolver2<TValue> Create()
    {
      return new CustomPartitionResolver2<TValue>();
    }

    public string GetPartitionName(EntryEvent<int, TValue> entryEvent)
    {
      Util.Log("CustomPartitionResolver2::GetPartitionName");
      var key = entryEvent.Key.ToString();
      var numKey = Convert.ToInt32(key);
      var newkey = numKey % 6;
      if (newkey == 0)
      {
        return "P1";
      }

      if (newkey == 1)
      {
        return "P2";
      }

      if (newkey == 2)
      {
        return "P3";
      }

      if (newkey == 3)
      {
        return "P4";
      }

      if (newkey == 4)
      {
        return "P5";
      }

      if (newkey == 5)
      {
        return "P6";
      }

      return "Invalid";
    }
  }

  [Serializable]
  public class CustomPartitionResolver3<TValue> : IFixedPartitionResolver<int, TValue>
  {
    public string GetName()
    {
      return "CustomPartitionResolver3";
    }

    public object GetRoutingObject(EntryEvent<int, TValue> key)
    {
      Util.Log("CustomPartitionResolver3::GetRoutingObject");
      return key.Key % 5;
    }

    public static CustomPartitionResolver3<TValue> Create()
    {
      return new CustomPartitionResolver3<TValue>();
    }

    public string GetPartitionName(EntryEvent<int, TValue> entryEvent)
    {
      Util.Log("CustomPartitionResolver3::GetPartitionName");
      var key = entryEvent.Key.ToString();
      var numKey = Convert.ToInt32(key);
      var newkey = numKey % 3;
      if (newkey == 0)
      {
        return "P1";
      }

      if (newkey == 1)
      {
        return "P2";
      }

      if (newkey == 2)
      {
        return "P3";
      }

      return "Invalid";
    }
  }

  public class TradeKey : ICacheableKey
  {
    public int MId;
    public int MAccountid;

    public TradeKey()
    {
    }

    public TradeKey(int id)
    {
      MId = id;
      MAccountid = 1 + id;
    }

    public TradeKey(int id, int accId)
    {
      MId = id;
      MAccountid = accId;
    }

    public void FromData(DataInput input)
    {
      MId = input.ReadInt32();
      MAccountid = input.ReadInt32();
    }

    public void ToData(DataOutput output)
    {
      output.WriteInt32(MId);
      output.WriteInt32(MAccountid);
    }


    public ulong ObjectSize
    {
      get
      {
        uint objectSize = 0;
        objectSize += sizeof(int);
        objectSize += sizeof(int);
        return objectSize;
      }
    }

    public static ISerializable CreateDeserializable()
    {
      return new TradeKey();
    }

    public bool Equals(ICacheableKey other)
    {
      if (other == null)
        return false;
      var bc = other as TradeKey;
      if (bc == null)
        return false;

      if (bc == this)
        return true;

      if (bc.MId == MId)
      {
        return true;
      }
      return false;
    }

    public override int GetHashCode()
    {
      return base.GetHashCode();
    }
  }

  [Serializable]
  public class TradeKeyResolver : IPartitionResolver<TradeKey, object>
  {
    public string GetName()
    {
      return "TradeKeyResolver";
    }

    public object GetRoutingObject(EntryEvent<TradeKey, object> key)
    {
      Util.Log("TradeKeyResolver::GetRoutingObject");
      var tkey = key.Key;
      Util.Log("TradeKeyResolver::GetRoutingObject done {0} ", tkey.MId + 5);
      return tkey.MId + 5;
    }

    public static TradeKeyResolver Create()
    {
      return new TradeKeyResolver();
    }
  }

  [TestFixture]
  [Category("group4")]
  [Category("unicast_only")]
  [Category("generics")]
  public class ThinClientRegionTests : ThinClientRegionSteps
  {
    #region Private members

    private UnitProcess _client1, _client2;

    #endregion

    protected override ClientBase[] GetClients()
    {
      _client1 = new UnitProcess();
      _client2 = new UnitProcess();
      return new ClientBase[] { _client1, _client2 };
    }

    [TestFixtureTearDown]
    public override void EndTests()
    {
      CacheHelper.StopJavaServers();
      base.EndTests();
    }

    [TearDown]
    public override void EndTest()
    {
      try
      {
        _client1.Call(DestroyRegions);
        _client2.Call(DestroyRegions);
        CacheHelper.ClearEndpoints();
        CacheHelper.ClearLocators();
      }
      finally
      {
        CacheHelper.StopJavaServers();
        CacheHelper.StopJavaLocators();
      }
      base.EndTest();
    }

    private void EmptyByteArrayTest()
    {
      var region = CacheHelper.GetVerifyRegion<int, byte[]>(RegionNames3[0]);

      var regServ = region.RegionService;

      var cache = regServ as Cache;

      Assert.IsNotNull(cache);

      region[0] = new byte[0];
      Util.Log("Put empty byteArray in region");
      Assert.AreEqual(0, region[0].Length);

      region[1] = new byte[2];
      Util.Log("Put non empty byteArray in region");

      Assert.AreEqual(2, region[1].Length);

      region[2] = Encoding.ASCII.GetBytes("TestString");
      Util.Log("Put string in region");

      Assert.AreEqual(0, "TestString".CompareTo(Encoding.ASCII.GetString(region[2])));
      Util.Log("EmptyByteArrayTest completed successfully");
    }

    private void CheckAndPutKey()
    {
      var region0 = CacheHelper.GetVerifyRegion<object, object>(m_regionNames[0]);

      var regServ = region0.RegionService;

      var cache = regServ as Cache;

      Assert.IsNotNull(cache);

      if (region0.ContainsKey("keyKey01"))
      {
        Assert.Fail("Did not expect keyKey01 to be on Server");
      }
      region0["keyKey01"] = "valueValue01";
      if (!region0.ContainsKey("keyKey01"))
      {
        Assert.Fail("Expected keyKey01 to be on Server");
      }
    }

    private void GetInterests()
    {
      string[] testregex = { "Key-*1", "Key-*2", "Key-*3", "Key-*4", "Key-*5", "Key-*6" };
      var region0 = CacheHelper.GetVerifyRegion<object, object>(m_regionNames[0]);
      region0.GetSubscriptionService().RegisterRegex(testregex[0]);
      region0.GetSubscriptionService().RegisterRegex(testregex[1]);
      ICollection<object> myCollection1 = new Collection<object>();
      myCollection1.Add(m_keys[0]);
      region0.GetSubscriptionService().RegisterKeys(myCollection1);

      ICollection<object> myCollection2 = new Collection<object>();
      myCollection2.Add(m_keys[1]);
      region0.GetSubscriptionService().RegisterKeys(myCollection2);

      var regvCol = region0.GetSubscriptionService().GetInterestListRegex();
      var regv = new string[regvCol.Count];
      regvCol.CopyTo(regv, 0);

      if (regv.Length != 2)
      {
        Assert.Fail("regex list length is not 2");
      }
      for (var i = 0; i < regv.Length; i++)
      {
        Util.Log("regv[{0}]={1}", i, regv[i]);
        var found = false;
        for (var j = 0; j < regv.Length; j++)
        {
          if (regv[i].Equals(testregex[j]))
          {
            found = true;
            break;
          }
        }
        if (!found)
        {
          Assert.Fail("Unexpected regex");
        }
      }

      var keyvCol = region0.GetSubscriptionService().GetInterestList();
      var keyv = new string[keyvCol.Count];
      keyvCol.CopyTo(keyv, 0);

      if (keyv.Length != 2)
      {
        Assert.Fail("interest list length is not 2");
      }
      for (var i = 0; i < keyv.Length; i++)
      {
        Util.Log("keyv[{0}]={1}", i, keyv[i]);
        var found = false;
        for (var j = 0; j < keyv.Length; j++)
        {
          if (keyv[i].Equals(m_keys[j]))
          {
            found = true;
            break;
          }
        }
        if (!found)
        {
          Assert.Fail("Unexpected key");
        }
      }
    }

    private void RunDistOps()
    {
      CacheHelper.SetupJavaServers(true, "cacheserver.xml");
      CacheHelper.StartJavaLocator(1, "GFELOC");
      Util.Log("Locator 1 started.");
      CacheHelper.StartJavaServerWithLocators(1, "GFECS1", 1);
      Util.Log("Cacheserver 1 started.");

      _client1.Call(CreateNonExistentRegion, CacheHelper.Locators);
      _client1.Call(CreateTCRegions_Pool, RegionNames,
        CacheHelper.Locators, "__TESTPOOL1_", false);
      Util.Log("StepOne (pool locators) complete.");

      _client2.Call(CreateTCRegions_Pool, RegionNames,
        CacheHelper.Locators, "__TESTPOOL1_", false);
      Util.Log("StepTwo (pool locators) complete.");

      _client1.Call(StepThree);
      Util.Log("StepThree complete.");

      _client2.Call(StepFour);
      Util.Log("StepFour complete.");

      _client1.Call(CheckServerKeys);
      _client1.Call(StepFive, true);
      Util.Log("StepFive complete.");

      _client2.Call(StepSix, true);
      Util.Log("StepSix complete.");

      _client1.Call(Close);
      Util.Log("Client 1 closed");
      _client2.Call(Close);
      Util.Log("Client 2 closed");

      CacheHelper.StopJavaServer(1);
      Util.Log("Cacheserver 1 stopped.");

      CacheHelper.StopJavaLocator(1);
      Util.Log("Locator 1 stopped.");

      CacheHelper.ClearEndpoints();
      CacheHelper.ClearLocators();
    }

    private void RunDistOps2()
    {
      CacheHelper.SetupJavaServers(true, "cacheserver.xml", "cacheserver2.xml", "cacheserver3.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.");

      _client1.Call(CreateTCRegions_Pool, RegionNames,
        CacheHelper.Locators, "__TESTPOOL1_", false);
      Util.Log("StepOne (pool locators) complete.");

      _client2.Call(CreateTCRegions_Pool, RegionNames,
        CacheHelper.Locators, "__TESTPOOL1_", false);
      Util.Log("StepTwo (pool locators) complete.");

      _client1.Call(StepThree);
      Util.Log("StepThree complete.");

      _client2.Call(StepFour);
      Util.Log("StepFour complete.");

      _client1.Call(StepFive, true);
      Util.Log("StepFive complete.");

      _client2.Call(StepSix, true);
      Util.Log("StepSix complete.");
      //m_client1.Call(GetAll, pool, locator);

      _client1.Call(Close);
      Util.Log("Client 1 closed");
      _client2.Call(Close);
      Util.Log("Client 2 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();
    }

    private void RunNotification()
    {
      CacheHelper.SetupJavaServers(true, "cacheserver.xml");
      CacheHelper.StartJavaLocator(1, "GFELOC");
      CacheHelper.StartJavaServerWithLocators(1, "GFECS1", 1);
      Util.Log("Cacheserver 1 started.");

      _client1.Call(CreateTCRegions_Pool, RegionNames,
        CacheHelper.Locators, "__TESTPOOL1_", true);
      Util.Log("StepOne (pool locators) complete.");

      _client2.Call(CreateTCRegions_Pool, RegionNames,
        CacheHelper.Locators, "__TESTPOOL1_", true);
      Util.Log("StepTwo (pool locators) complete.");

      _client1.Call(RegisterAllKeysR0WithoutValues);
      _client1.Call(RegisterAllKeysR1WithoutValues);

      _client2.Call(RegisterAllKeysR0WithoutValues);
      _client2.Call(RegisterAllKeysR1WithoutValues);

      _client1.Call(StepThree);
      Util.Log("StepThree complete.");

      _client2.Call(StepFour);
      Util.Log("StepFour complete.");

      _client1.Call(StepFive, true);
      Util.Log("StepFive complete.");

      _client2.Call(StepSixNotify, false);
      Util.Log("StepSix complete.");

      _client1.Call(StepSevenNotify, false);
      Util.Log("StepSeven complete.");

      _client2.Call(StepEightNotify, false);
      Util.Log("StepEight complete.");

      _client1.Call(StepNineNotify, false);
      Util.Log("StepNine complete.");

      _client2.Call(StepTen);
      Util.Log("StepTen complete.");

      _client1.Call(StepEleven);
      Util.Log("StepEleven complete.");

      _client1.Call(Close);
      Util.Log("Client 1 closed");
      _client2.Call(Close);
      Util.Log("Client 2 closed");

      CacheHelper.StopJavaServer(1);
      Util.Log("Cacheserver 1 stopped.");

      CacheHelper.StopJavaLocator(1);
      Util.Log("Locator 1 stopped.");

      CacheHelper.ClearEndpoints();
      CacheHelper.ClearLocators();
    }

    private void RunPartitionResolver()
    {
      CacheHelper.SetupJavaServers(true, "cacheserver1_pr.xml",
          "cacheserver2_pr.xml", "cacheserver3_pr.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.");

      var putGetTest = new PutGetTests();
      // Create and Add partition resolver to the regions.
      //CustomPartitionResolver<object> cpr = CustomPartitionResolver<object>.Create();

      _client1.Call(CreateTCRegions_Pool2_WithPartitionResolver, RegionNames,
        CacheHelper.Locators, "__TESTPOOL1_", false, true);
      Util.Log("Client 1 (pool locators) regions created");
      _client2.Call(CreateTCRegions_Pool2_WithPartitionResolver, RegionNames,
        CacheHelper.Locators, "__TESTPOOL1_", false, true);
      Util.Log("Client 2 (pool locators) regions created");

      _client1.Call(putGetTest.SetRegion, RegionNames[1]);
      _client2.Call(putGetTest.SetRegion, RegionNames[1]);
      putGetTest.DoPRSHPartitionResolverTasks(_client1, _client2, RegionNames[1]);

      _client1.Call(putGetTest.SetRegion, RegionNames[0]);
      _client2.Call(putGetTest.SetRegion, RegionNames[0]);
      putGetTest.DoPRSHPartitionResolverTasks(_client1, _client2, RegionNames[0]);

      _client1.Call(Close);
      Util.Log("Client 1 closed");

      _client2.Call(Close);
      Util.Log("Client 2 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();
    }

    private void RunTradeKeyResolver()
    {
      CacheHelper.SetupJavaServers(true, "cacheserver1_TradeKey.xml",
        "cacheserver2_TradeKey.xml", "cacheserver3_TradeKey.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.");

      _client1.Call(CreateTCRegion2, TradeKeyRegion, true, true, TradeKeyResolver.Create(),
        CacheHelper.Locators, true);
      Util.Log("Client 1 (pool locators) region created");

      var putGetTest = new PutGetTests();
      _client1.Call(putGetTest.DoPRSHTradeResolverTasks, TradeKeyRegion);

      _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();
    }

    private void ClearRegionListenersStep1()
    {
      var region0 = CacheHelper.GetVerifyRegion<object, object>(m_regionNames[0]);
      region0.GetSubscriptionService().RegisterAllKeys();
      var attrMutator = region0.AttributesMutator;
      var listener = new TallyListener<object, object>();
      attrMutator.SetCacheListener(listener);
      var writer = new TallyWriter<object, object>();
      attrMutator.SetCacheWriter(writer);
    }

    private void ClearRegionStep1()
    {
      var region0 = CacheHelper.GetVerifyRegion<object, object>(m_regionNames[0]);
      region0.GetSubscriptionService().RegisterAllKeys();
      CreateEntry(m_regionNames[0], m_keys[0], m_nvals[0]);
      CreateEntry(m_regionNames[0], m_keys[1], m_nvals[1]);
      if (region0.Count != 2)
      {
        Assert.Fail("Expected region size 2");
      }
    }

    private void ClearRegionListenersStep2()
    {
      var region0 = CacheHelper.GetVerifyRegion<object, object>(m_regionNames[0]);
      if (region0.Count != 2)
      {
        Assert.Fail("Expected region size 2");
      }
    }

    private void ClearRegionStep2()
    {
      //Console.WriteLine("IRegion<object, object> Name = {0}", m_regionNames[0]);

      var region0 = CacheHelper.GetVerifyRegion<object, object>(m_regionNames[0]);
      if (region0 == null)
      {
        Console.WriteLine("Region0 is Null");
      }
      else
      {
        //Console.WriteLine("NIL:Before clear call");
        region0.Clear();
        //Console.WriteLine("NIL:After clear call");

        if (region0.Count != 0)
        {
          Assert.Fail("Expected region size 0");
        }
      }
      Thread.Sleep(20000);
    }

    private void ClearRegionListenersStep3()
    {
      var region0 = CacheHelper.GetVerifyRegion<object, object>(m_regionNames[0]);
      if (region0.Count != 0)
      {
        Assert.Fail("Expected region size 0");
      }
      var attr = region0.Attributes;
      var listener = attr.CacheListener as TallyListener<object, object>;
      var writer = attr.CacheWriter as TallyWriter<object, object>;
      if (listener.Clears != 1)
      {
        Assert.Fail("Expected listener clear count 1");
      }
      if (writer.Clears != 1)
      {
        Assert.Fail("Expected writer clear count 1");
      }
      CreateEntry(m_regionNames[0], m_keys[0], m_nvals[0]);
      CreateEntry(m_regionNames[0], m_keys[1], m_nvals[1]);
      if (region0.Count != 2)
      {
        Assert.Fail("Expected region size 2");
      }
      region0.GetLocalView().Clear();
      if (listener.Clears != 2)
      {
        Assert.Fail("Expected listener clear count 2");
      }
      if (writer.Clears != 2)
      {
        Assert.Fail("Expected writer clear count 2");
      }
      if (region0.Count != 0)
      {
        Assert.Fail("Expected region size 0");
      }
    }

    private void ClearRegionStep3()
    {
      var region0 = CacheHelper.GetVerifyRegion<object, object>(m_regionNames[0]);
      if (region0.Count != 2)
      {
        Assert.Fail("Expected region size 2");
      }

      if (!region0.ContainsKey(m_keys[0]))
      {
        Assert.Fail("m_key[0] is not on Server");
      }
      if (!region0.ContainsKey(m_keys[1]))
      {
        Assert.Fail("m_key[1] is not on Server");
      }
    }

    private void PutAllStep3()
    {
      var region0 = CacheHelper.GetVerifyRegion<object, object>(m_regionNames[0]);
      var resultKeys = new List<object>();
      object key0 = m_keys[0];
      object key1 = m_keys[1];
      resultKeys.Add(key0);
      resultKeys.Add(key1);
      region0.GetSubscriptionService().RegisterKeys(resultKeys.ToArray());
      Util.Log("Step three completes");
    }

    private void PutAllStep4()
    {
      var map0 = new Dictionary<object, object>();
      var map1 = new Dictionary<object, object>();
      object key0 = m_keys[0];
      object key1 = m_keys[1];
      var val0 = m_vals[0];
      var val1 = m_vals[1];
      map0.Add(key0, val0);
      map0.Add(key1, val1);

      object key2 = m_keys[2];
      object key3 = m_keys[3];
      var val2 = m_vals[2];
      var val3 = m_vals[3];
      map1.Add(key2, val2);
      map1.Add(key3, val3);
      var region0 = CacheHelper.GetVerifyRegion<object, object>(m_regionNames[0]);
      var region1 = CacheHelper.GetVerifyRegion<object, object>(m_regionNames[1]);
      region0.PutAll(map0);
      region1.PutAll(map1);
      Util.Log("Put All Complets");
    }

    private void PutAllStep5()
    {
      VerifyCreated(m_regionNames[0], m_keys[0]);
      VerifyCreated(m_regionNames[0], m_keys[1]);

      VerifyEntry(m_regionNames[0], m_keys[0], m_vals[0]);
      VerifyEntry(m_regionNames[0], m_keys[1], m_vals[1]);

      DoNetsearch(m_regionNames[1], m_keys[2], m_vals[2], true);
      DoNetsearch(m_regionNames[1], m_keys[3], m_vals[3], true);

      Util.Log("StepFive complete.");
    }

    private void PutAllStep6()
    {
      var map0 = new Dictionary<object, object>();
      var map1 = new Dictionary<object, object>();

      object key0 = m_keys[0];
      object key1 = m_keys[1];
      var val0 = m_nvals[0];
      var val1 = m_nvals[1];
      map0.Add(key0, val0);
      map0.Add(key1, val1);

      object key2 = m_keys[2];
      object key3 = m_keys[3];
      var val2 = m_nvals[2];
      var val3 = m_nvals[3];
      map1.Add(key2, val2);
      map1.Add(key3, val3);
      var region0 = CacheHelper.GetVerifyRegion<object, object>(m_regionNames[0]);
      var region1 = CacheHelper.GetVerifyRegion<object, object>(m_regionNames[1]);
      region0.PutAll(map0);
      region1.PutAll(map1);
      Util.Log("Step6 Complets");
    }

    private void PutAllStep7() //client 1
    {
      //Region0 is changed at client 1 because keys[0] and keys[1] were registered.PutAllStep3
      VerifyEntry(m_regionNames[0], m_keys[0], m_nvals[0]);
      VerifyEntry(m_regionNames[0], m_keys[1], m_nvals[1]);
      // region1 is not changed at client beacuse no regsiter interest.
      VerifyEntry(m_regionNames[1], m_keys[2], m_vals[2]);
      VerifyEntry(m_regionNames[1], m_keys[3], m_vals[3]);
      Util.Log("PutAllStep7 complete.");
    }

    private void RunPutAll()
    {
      CacheHelper.SetupJavaServers(true, "cacheserver_notify_subscription.xml",
        "cacheserver_notify_subscription2.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.");

      _client1.Call(CreateTCRegions_Pool, RegionNames,
        CacheHelper.Locators, "__TESTPOOL1_", true);  //Client Notification true for client 1
      _client2.Call(CreateTCRegions_Pool, RegionNames,
        CacheHelper.Locators, "__TESTPOOL1_", true);  //Cleint notification true for client 2

      Util.Log("IRegion<object, object> creation complete.");

      _client1.Call(PutAllStep3);
      Util.Log("PutAllStep3 complete.");

      _client2.Call(PutAllStep4);
      Util.Log("PutAllStep4 complete.");

      _client1.Call(PutAllStep5);
      Util.Log("PutAllStep5 complete.");

      _client2.Call(PutAllStep6);
      Util.Log("PutAllStep6 complete.");

      _client1.Call(PutAllStep7);
      Util.Log("PutAllStep7 complete.");

      _client1.Call(Close);
      Util.Log("Client 1 closed");
      _client2.Call(Close);
      Util.Log("Client 2 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();
    }

    #region Tests

    [Test]
    public void PutEmptyByteArrayTest()
    {
      CacheHelper.SetupJavaServers("cacheserver.xml");
      CacheHelper.StartJavaLocator(1, "GFELOC");
      CacheHelper.StartJavaServerWithLocators(1, "GFECS1", 1);
      Util.Log("Cacheserver 1 started.");
      _client1.Call(CreateTCRegions_Pool, RegionNames3,
        CacheHelper.Locators, "__TESTPOOL1_", true);
      Util.Log("StepOne of region creation complete.");

      _client1.Call(EmptyByteArrayTest);
      Util.Log("EmptyByteArrayTest completed.");

      CacheHelper.StopJavaServer(1);
      Util.Log("Cacheserver 1 stopped.");
      CacheHelper.StopJavaLocator(1);
    }

    [Test]
    public void CheckKeyOnServer()
    {
      CacheHelper.SetupJavaServers("cacheserver.xml");
      CacheHelper.StartJavaLocator(1, "GFELOC");
      CacheHelper.StartJavaServerWithLocators(1, "GFECS1", 1);
      Util.Log("Cacheserver 1 started.");

      _client1.Call(CreateTCRegions_Pool, RegionNames,
        CacheHelper.Locators, "__TESTPOOL1_", true);
      Util.Log("StepOne of region creation complete.");

      _client1.Call(CheckAndPutKey);
      Util.Log("Check for ContainsKeyOnServer complete.");

      CacheHelper.StopJavaServer(1);
      Util.Log("Cacheserver 1 stopped.");
      CacheHelper.StopJavaLocator(1);
    }

    [Test]
    public void GetInterestsOnClient()
    {
      CacheHelper.SetupJavaServers("cacheserver_notify_subscription.xml");
      CacheHelper.StartJavaLocator(1, "GFELOC");
      CacheHelper.StartJavaServerWithLocators(1, "GFECS1", 1);
      Util.Log("Cacheserver 1 started.");

      _client1.Call(CreateTCRegions_Pool, RegionNames,
        CacheHelper.Locators, "__TESTPOOL1_", true);


      Util.Log("StepOne of region creation complete.");

      _client1.Call(GetInterests);
      Util.Log("StepTwo of check for GetInterestsOnClient complete.");

      CacheHelper.StopJavaServer(1);
      Util.Log("Cacheserver 1 stopped.");
      CacheHelper.StopJavaLocator(1);
    }

    [Test]
    public void DistOps()
    {
      RunDistOps();
    }

    [Test]
    public void DistOps2()
    {
      RunDistOps2();
    }

    [Test]
    public void Notification()
    {
      RunNotification();
    }

    [Test]
    public void CheckPartitionResolver()
    {
      RunPartitionResolver();
    }

    [Test]
    public void TradeKeyPartitionResolver()
    {
      RunTradeKeyResolver();
    }

    [Test]
    public void RegionClearTest()
    {
      CacheHelper.SetupJavaServers("cacheserver_notify_subscription.xml");
      CacheHelper.StartJavaLocator(1, "GFELOC");
      CacheHelper.StartJavaServerWithLocators(1, "GFECS1", 1);
      Util.Log("Cacheserver 1 started.");

      _client1.Call(CreateTCRegions_Pool, RegionNames,
        CacheHelper.Locators, "__TESTPOOL1_", true);
      Util.Log("client 1 StepOne of region creation complete.");
      _client2.Call(CreateTCRegions_Pool, RegionNames,
        CacheHelper.Locators, "__TESTPOOL1_", true);
      Util.Log("client 2 StepOne of region creation complete.");

      _client1.Call(ClearRegionListenersStep1);
      _client2.Call(ClearRegionStep1);
      _client1.Call(ClearRegionListenersStep2);
      _client2.Call(ClearRegionStep2);
      _client1.Call(ClearRegionListenersStep3);
      _client2.Call(ClearRegionStep3);
      Util.Log("StepTwo of check for RegionClearTest complete.");

      CacheHelper.StopJavaServer(1);
      Util.Log("Cacheserver 1 stopped.");
      CacheHelper.StopJavaLocator(1);
    }

    [Test]
    public void PutAll()
    {
      RunPutAll();
    }

    #endregion
  }
}