blob: b4a2aae626c0a4a462b7650b5facddbbe02e1acc [file] [log] [blame]
using System;
using System.Diagnostics;
using System.Threading;
namespace GemStone.GemFire.Cache.UnitTests.NewAPI
{
using NUnit.Framework;
using GemStone.GemFire.DUnitFramework;
using GemStone.GemFire.Cache.Generic;
using Region = GemStone.GemFire.Cache.Generic.IRegion<Object, Object>;
public class RegionOperation
{
protected IRegion<object, object> m_region;
public Region Region
{
get
{
return m_region;
}
}
public RegionOperation(string RegionName)
{
Serializable.RegisterPdxType(PdxTests.PdxTypes1.CreateDeserializable);
Serializable.RegisterPdxType(PdxTests.PdxTypes8.CreateDeserializable);
m_region = CacheHelper.GetRegion<object, object>(RegionName);
}
public void PutOp(int key, Object CallbackArg)
{
Object value = "value";
for (int i = 1; i <= key; i++)
{
Util.Log("PutOp:key={0},value={1}",i,value);
m_region.Put(i,value,CallbackArg);
//m_region[10000 + i] = new PdxTests.PdxTypes1();
m_region[10000 + i] = new PdxTests.PdxTypes8();
}
}
public void InvalidateOp(int key, Object CallbackArg)
{
for (int i = 1; i <= key; i++)
{
Util.Log("InvalidateOp:key={0}", i);
m_region.GetLocalView().Invalidate(i, CallbackArg);
}
}
public void DestroyOp(int key, Object CallbackArg)
{
for (int i = 1; i <= key; i++)
{
Util.Log("DestroyOp:key={0}", i);
m_region.Remove(i, CallbackArg);
}
}
public void DestroyOpWithPdxValue(int key, Object CallbackArg)
{
for (int i = 1; i <= key; i++)
{
Util.Log("DestroyOpWithPdxValue:key={0}", i);
m_region.Remove(i, CallbackArg);
m_region.Remove(10000 + i, null);
}
}
public void RemoveOp(int key, Object CallbackArg)
{
string value = "value";
for (int i = 1; i <= key; i++) {
Util.Log("PutOp:key={0},value={1}", i, value);
m_region.Remove(i, value, CallbackArg);
}
}
}
}