http://git-wip-us.apache.org/repos/asf/geode-native/blob/da389793/src/tests/cli/NewFwkLib/SmokePerf/SmokePerf.cs ---------------------------------------------------------------------- diff --git a/src/tests/cli/NewFwkLib/SmokePerf/SmokePerf.cs b/src/tests/cli/NewFwkLib/SmokePerf/SmokePerf.cs deleted file mode 100644 index 6e96cf9..0000000 --- a/src/tests/cli/NewFwkLib/SmokePerf/SmokePerf.cs +++ /dev/null @@ -1,1580 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -using System; -using System.Collections.Generic; -using System.Text; -using System.IO; -using System.Text.RegularExpressions; -using System.Threading; -using Apache.Geode.Client.Tests; -namespace Apache.Geode.Client.FwkLib -{ - using Apache.Geode.DUnitFramework; - using Apache.Geode.Client; - //using Region = Apache.Geode.Client.IRegion<Object, Object>; - public class PerfCacheListener<TKey, TVal> : CacheListenerAdapter<TKey, TVal>, IDisposable - { - public static Int64 LAT_MARK = 0x55667788; - public static Int64 LATENCY_SPIKE_THRESHOLD = 10000000; - protected PerfStat statistics = null; - public PerfCacheListener(PerfStat perfstat) - { - statistics = perfstat; - } - - public void RecordLatency(object objValue) - { - DateTime startTime = DateTime.Now; - long now = startTime.Ticks * (1000000 / TimeSpan.TicksPerMillisecond); - long then; - if (objValue is byte[]) - { - then = ArrayOfByte.GetTimestamp(objValue as byte[]); - } - else - { - then = ((TimeStampdObject)objValue).GetTimestamp(); - } - long latency = now - then; - if (latency > LATENCY_SPIKE_THRESHOLD) - { - statistics.IncLatencySpikes(1); - } - if (latency < 0) - { - statistics.IncNegativeLatencies(1); - } - else - { - statistics.IncUpdateLatency(latency); - } - } - protected virtual void Dispose(bool disposing) - { - } - #region IDisposable Members - public void Dispose() - { - Dispose(true); - GC.SuppressFinalize(this); - } - - #endregion - - ~PerfCacheListener() - { - Dispose(false); - } - } - - public class LatencyListeners<TKey, TVal> : PerfCacheListener<TKey, TVal> - { - - public LatencyListeners(PerfStat perfstat) - : base(perfstat) - { - Util.Log("LatencyListeners constructor"); - } - - public override void AfterUpdate(EntryEvent<TKey, TVal> ev) - { - - FwkTest<TKey, TVal>.CurrentTest.FwkInfo("rjk LatencyListeners AfterUpdate invoked "); - TKey key = ev.Key; - TVal value = ev.NewValue; - Util.Log("rjk: LatencyListeners AfterUpdate - 11"); - RecordLatency(value); - Util.Log("rjk: LatencyListeners AfterUpdate - 12"); - - } - } - - public class CQLatencyListener<TKey, TVal> : PerfCacheListener<TKey, TVal>, ICqListener<TKey, object> - { - public CQLatencyListener(PerfStat perfstat) - : base(perfstat) - { - } - public void OnEvent(CqEvent<TKey, object> ev) - { - /*TVal*/ object value = ev.getNewValue(); - RecordLatency(value); - } - public void OnError(CqEvent<TKey, object> ev) - { - } - public void Close() - { - } - } - - public class PerfCacheLoader<TKey, TVal> : ICacheLoader<TKey, TVal> - { - private Int32 m_loads = 0; - public PerfCacheLoader() - : base() - { - } - #region Public accessors - public Int32 Loads - { - get - { - return m_loads; - } - } - #endregion - public TVal Load(IRegion<TKey, TVal> region, TKey key, object helper) - { - m_loads++; - return default(TVal); - } - public virtual void Close(IRegion<TKey, TVal> region) { } - - // VJR: added dummy load/close placeholders. - /* - public IGeodeSerializable Load( Apache.Geode.Client.Region region, ICacheableKey key, IGeodeSerializable helper) - { - return new CacheableInt32(m_loads++); - } - public virtual void Close( Apache.Geode.Client.Region region) { } - */ - } - - public class DurableCacheListener<TKey, TVal> : CacheListenerAdapter<TKey, TVal>, IDisposable - { - private Int32 m_ops = 0; - private string m_clntName; - - private void check(EntryEvent<TKey, TVal> ev) - { - TKey key = ev.Key; - TVal value = ev.NewValue; - m_ops++; - } - - public DurableCacheListener() - { - m_ops = 0; - m_clntName = String.Format("ClientName_{0}", Util.ClientNum); - Util.BBSet("DURABLEBB", m_clntName, 0); - } - - ~DurableCacheListener() - { - Dispose(false); - } - - void dumpToBB() - { - FwkTest<TKey, TVal> currTest = FwkTest<TKey, TVal>.CurrentTest; - string bbkey = m_clntName; - int current = 0; - try - { - current = (int)Util.BBGet("DURABLEBB", bbkey); - } - catch (Apache.Geode.DUnitFramework.KeyNotFoundException) - { - currTest.FwkInfo("Key not found for DURABLEBB {0}", bbkey); - } - current += m_ops; - Util.BBSet("DURABLEBB", bbkey, current); - currTest.FwkInfo("Current count for " + bbkey + " is " + current); - } - - public override void AfterCreate(EntryEvent<TKey, TVal> ev) - { - check(ev); - } - - public override void AfterUpdate(EntryEvent<TKey, TVal> ev) - { - check(ev); - } - - public override void AfterRegionDestroy(RegionEvent<TKey, TVal> ev) - { - dumpToBB(); - } - - protected virtual void Dispose(bool disposing) - { - } - - #region IDisposable Members - - public void Dispose() - { - Dispose(true); - GC.SuppressFinalize(this); - } - - #endregion - } - - public class SmokePerf<TKey, TVal> : FwkTest<TKey, TVal> - { - //private string bb = "Trim_BB"; - private static readonly DateTime EpochTime = new DateTime(1970, 1, 1, 0, 0, 0, DateTimeKind.Utc); - private static readonly DateTime EpochTimeLocal = EpochTime.ToLocalTime(); - protected TKey[] m_keysA; - protected int m_maxKeys; - protected int m_keyIndexBegin; - - protected TVal[] m_cValues; - protected int m_maxValues; - protected char m_keyType = 'i'; - protected bool m_isObjectRegistered = false; - protected static List<IDictionary<TKey,TVal>> maps = new List<IDictionary<TKey,TVal>>(); - - protected const string ClientCount = "clientCount"; - protected const string TimedInterval = "timedInterval"; - protected const string DistinctKeys = "distinctKeys"; - protected const string NumThreads = "numThreads"; - protected const string ValueSizes = "valueSizes"; - protected const string OpsSecond = "opsSecond"; - protected const string KeyType = "keyType"; - protected const string KeySize = "keySize"; - protected const string KeyIndexBegin = "keyIndexBegin"; - protected const string RegisterKeys = "registerKeys"; - protected const string RegisterRegex = "registerRegex"; - protected const string UnregisterRegex = "unregisterRegex"; - protected const string ExpectedCount = "expectedCount"; - protected const string InterestPercent = "interestPercent"; - protected const string KeyStart = "keyStart"; - protected const string KeyEnd = "keyEnd"; - - #region Protected methods - - protected void ClearKeys() - { - if (m_keysA != null) - { - for (int i = 0; i < m_keysA.Length; i++) - { - if (m_keysA[i] != null) - { - //m_keysA[i].Dispose(); - m_keysA[i] = default(TKey); - } - } - m_keysA = null; - m_maxKeys = 0; - } - } - protected int InitKeys(bool useDefault, bool useAllClientID) - { - string typ = GetStringValue(KeyType); // int is only value to use - char newType = (typ == null || typ.Length == 0) ? 's' : typ[0]; - - int low = GetUIntValue(KeyIndexBegin); - low = (low > 0) ? low : 0; - //ResetKey(DistinctKeys); - int numKeys = GetUIntValue(DistinctKeys); // check distinct keys first - if (numKeys <= 0) - { - if (useDefault) - { - numKeys = 5000; - } - else - { - //FwkSevere("Failed to initialize keys with numKeys: {0}", numKeys); - return numKeys; - } - } - ResetKey("clientCount"); - int numClients = GetUIntValue("clientCount"); - //Int32 id = 0; - string id = null; - if (numClients > 0) - { - id = Util.ClientId; - //if (id < 0) - // id = -id; - numKeys = numKeys / numClients; - } - if (numKeys < 1) - FwkException("SmokePerf::InitKeys:Key is less than 0 for each client. Provide max number of distinctKeys"); - - int high = numKeys + low; - FwkInfo("InitKeys:: numKeys: {0}; low: {1}", numKeys, low); - if ((newType == m_keyType) && (numKeys == m_maxKeys) && - (m_keyIndexBegin == low)) - { - return numKeys; - } - - ClearKeys(); - m_maxKeys = numKeys; - m_keyIndexBegin = low; - m_keyType = newType; - if (m_keyType == 'i') - { - InitIntKeys(low, high); - } - else - { - int keySize = GetUIntValue(KeySize); - keySize = (keySize > 0) ? keySize : 10; - string keyBase = new string('A', keySize); - InitStrKeys(low, high, keyBase, id, useAllClientID); - } - for (int j = 0; j < numKeys; j++) - { - int randIndx = Util.Rand(numKeys); - if (randIndx != j) - { - TKey tmp = m_keysA[j]; - m_keysA[j] = m_keysA[randIndx]; - m_keysA[randIndx] = tmp; - } - } - return m_maxKeys; - } - - protected int InitKeys() - { - return InitKeys(true, false); - } - - protected void InitStrKeys(int low, int high, string keyBase, string clientId, bool useAllClientID) - { - m_keysA = (TKey[])(object) new String[m_maxKeys]; - ResetKey("clientCount"); - int numClients = GetUIntValue("clientCount"); - if (numClients < 0) - numClients = 0; - string id = clientId.Substring(clientId.LastIndexOf('.') + 1); - FwkInfo("m_maxKeys: {0}; low: {1}; high: {2} Client id {3} numClient {4}", - m_maxKeys, low, high, id, numClients); - //string id = clientId.Substring(0, clientId.LastIndexOf(".")); - //int epCount = (int)Util.BBGet(FwkTest.JavaServerBB, FwkTest.JavaServerEPCountKey); - for (int i = low; i < high; i++) - { - if (useAllClientID) - { - id = Convert.ToString(Util.Rand(1, (numClients + 1))); - } - m_keysA[i - low] = (TKey)(object)(keyBase.ToString() +id + i.ToString("D10")); - //FwkInfo("rjk: generating key {0}", m_keysA[i - low]); - } - } - - protected void InitIntKeys(int low, int high) - { - m_keysA = (TKey[])(object)new Int32[m_maxKeys]; - FwkInfo("m_maxKeys: {0}; low: {1}; high: {2}", - m_maxKeys, low, high); - for (int i = low; i < high; i++) - { - m_keysA[i - low] = (TKey)(object)i; - } - } - protected int InitBatchKeys(bool useDefault) - { - int low = 0; - //ResetKey(DistinctKeys); - int numKeys = GetUIntValue(DistinctKeys); // check distinct keys first - if (numKeys <= 0) - { - if (useDefault) - { - numKeys = 5000; - } - else - { - //FwkSevere("Failed to initialize keys with numKeys: {0}", numKeys); - return numKeys; - } - } - int batchSize = GetUIntValue("BatchSize"); - batchSize = (batchSize <= 0) ? 500 : batchSize; - int high = 0; - ClearKeys(); - m_maxKeys = numKeys; - int batches = numKeys / batchSize; - m_keysA = (TKey[])(object) new String[m_maxKeys]; - high = batchSize; - FwkInfo("m_MaxKeys: {0} low: {1} high: {2}", m_maxKeys, low, high); - for (int i = 0; i < batches; i++) - { - for (int j = low; j < high; j++) - { - string buf = String.Format("_{0}_{1}", i, j); - m_keysA[j] = (TKey)(object)buf; - } - low += batchSize; - high += batchSize; - FwkInfo("low: {0} high: {1}", low, high); - } - for (int j = 0; j < numKeys; j++) - { - int randIndx = Util.Rand(numKeys); - if (randIndx != j) - { - TKey tmp = m_keysA[j]; - m_keysA[j] = m_keysA[randIndx]; - m_keysA[randIndx] = tmp; - } - } - - return m_maxKeys; - } - - protected int InitValues(int numKeys) - { - return InitValues(numKeys, 0, true); - } - - protected int InitValues(int numKeys, int size, bool useDefault) - { - if (size == 0) - { - size = GetUIntValue(ValueSizes); - } - if (size <= 0) - { - if (useDefault) - { - size = 55; - } - else - { - return size; - } - } - return size; - } - protected IRegion<TKey, TVal> GetRegion() - { - return (IRegion<TKey, TVal>)GetRegion(null); - - } - protected IRegion<TKey, TVal> GetRegion(string regionName) - { - IRegion<TKey, TVal> region; - if (regionName == null) - { - regionName = GetStringValue("regionName"); - } - if (regionName == null) - { - region = (IRegion<TKey, TVal>)GetRootRegion(); - if (region == null) - { - IRegion<TKey, TVal>[] rootRegions = CacheHelper<TKey, TVal>.DCache.RootRegions<TKey, TVal>(); - if (rootRegions != null && rootRegions.Length > 0) - { - region = rootRegions[Util.Rand(rootRegions.Length)]; - } - } - } - else - { - region = CacheHelper<TKey, TVal>.GetRegion(regionName); - } - return region; - } - #endregion - - #region private utility methods - - public static long GetDateTimeMillis(DateTime dt) - { - long numTicks; - long numMillis, residualTicks; - - if (dt.Kind != DateTimeKind.Utc) - { - numTicks = dt.Ticks - EpochTimeLocal.Ticks; - } - else - { - numTicks = dt.Ticks - EpochTime.Ticks; - } - numMillis = numTicks / TimeSpan.TicksPerMillisecond; - residualTicks = numTicks % TimeSpan.TicksPerMillisecond; - // round-off to nearest millisecond in case of residual ticks - if ((residualTicks * 2) >= TimeSpan.TicksPerMillisecond) - { - ++numMillis; - } - return numMillis; - } - - private object SafeBBGet(string bb, string key) - { - try - { - return Util.BBGet(bb, key); - } - catch (Apache.Geode.DUnitFramework.KeyNotFoundException) - { - return null; - } - } - private void checkTrimForOps(string msg,StreamWriter sw) - { - String st = ""; - - if (File.Exists("trim.spec")) - { - StreamReader sr = File.OpenText("trim.spec"); - st = sr.ReadToEnd(); - sr.Close(); - } - string regMatch = "trimspec operations start="; - if (!(Regex.IsMatch(st, regMatch))) - { - sw.WriteLine(msg); - } - } - - private void SetTrimTime(string op) - { - SetTrimTime(op, false); - } - private void SetTrimTime(string op, bool endTime) - { - DateTime startTime; - string trTime = null; - string TemptrTime = null; - TimeSpan diff = new TimeSpan(0, 0, 30); - if (endTime) - { - startTime = DateTime.Now.Subtract(diff); - //startTime = DateTime.Now; - trTime = op + "_" + "EndTime"; - TemptrTime = op + "_" + "TempEndTime"; - } - else - { - startTime = DateTime.Now.Add(diff); - trTime = op + "_" + "StartTime"; - TemptrTime = op + "_" + "TempStartTime"; - } - //long tnanoSec = startTime.Ticks * (1000000 / TimeSpan.TicksPerMillisecond); - //long tnanoSec = startTime.ToFileTimeUtc(); - long curruntMillis = GetDateTimeMillis(startTime); - long trim_Time = 0; - try - { - trim_Time = (long)Util.BBGet("Trim_BB", TemptrTime); - } - catch (Apache.Geode.DUnitFramework.KeyNotFoundException) - { - FwkInfo("Key not found for Trim_BB {0}", TemptrTime); - } - string timeZone = TimeZone.CurrentTimeZone.IsDaylightSavingTime(DateTime.Now) ? TimeZone.CurrentTimeZone.DaylightName : TimeZone.CurrentTimeZone.StandardName; - string shortTZ = " "; - for (Int32 i = 0; i < timeZone.Length; i++) - { - if (Char.IsUpper(timeZone[i])) - shortTZ += timeZone[i]; - } - string timeFormat = startTime.ToString("yyyy/MM/dd HH:mm:ss.FFF") + - shortTZ + " (" + curruntMillis.ToString() + ")"; - if (trim_Time > 0) - { - //if (((tnanoSec > Convert.ToInt64(trim_Time)) && !endTime) || ((tnanoSec < Convert.ToInt64(trim_Time)) && endTime)) - if (((curruntMillis > trim_Time) && !endTime) || ((curruntMillis < trim_Time) && endTime)) - { - Util.BBSet("Trim_BB", trTime, timeFormat); - Util.BBSet("Trim_BB", TemptrTime, curruntMillis); - } - } - else - { - Util.BBSet("Trim_BB", trTime, timeFormat); - Util.BBSet("Trim_BB", TemptrTime, curruntMillis); - } - } - private string GetQuery(int i) - { - IRegion<TKey,TVal> region = GetRegion(); - int strBatchSize = GetUIntValue("BatchSize"); - int maxkeys = GetUIntValue("distinctKeys"); - if ((maxkeys % strBatchSize) != 0) - FwkException("Keys does not evenly divide"); - int batches = maxkeys / strBatchSize; - int batchNum = (i + 1) % batches; - string query = "SELECT * FROM " + region.FullPath + " obj WHERE obj.batch = " + Convert.ToString(batchNum); - return query; - } - #endregion - - #region Public methods - public static ICacheLoader<TKey,TVal> createCacheLoader() - { - return new PerfCacheLoader<TKey, TVal>(); - } - public static ICacheListener<TKey, TVal> CreateDurableCacheListenerSP() - { - return new DurableCacheListener<TKey, TVal>(); - } - public static ICacheListener<TKey, TVal> CreateLatencyListener() - { - return new LatencyListeners<TKey, TVal>(InitPerfStat.perfstat[0]); - } - - public virtual void DoCreateRegion() - { - FwkInfo("In DoCreateRegion()"); - try - { - if (!m_isObjectRegistered) - { - Serializable.RegisterTypeGeneric(PSTObject.CreateDeserializable); - Serializable.RegisterTypeGeneric(FastAssetAccount.CreateDeserializable); - Serializable.RegisterTypeGeneric(FastAsset.CreateDeserializable); - Serializable.RegisterTypeGeneric(BatchObject.CreateDeserializable); - Serializable.RegisterTypeGeneric(DeltaFastAssetAccount.CreateDeserializable); - Serializable.RegisterTypeGeneric(DeltaPSTObject.CreateDeserializable); - m_isObjectRegistered = true; - } - IRegion<TKey, TVal> region = CreateRootRegion(); - if (region == null) - { - FwkException("DoCreateRegion() could not create region."); - } - FwkInfo("DoCreateRegion() Created region '{0}'", region.Name); - } - catch (Exception ex) - { - FwkException("DoCreateRegion() Caught Exception: {0}", ex); - } - FwkInfo("DoCreateRegion() complete."); - } - - public void DoCloseCache() - { - FwkInfo("DoCloseCache() Closing cache and disconnecting from" + - " distributed system."); - CacheHelper<TKey, TVal>.Close(); - } - - public void DoGenerateTrimSpec() - { - FwkInfo("In DoGenerateTrimSpec()"); - - try - { - StreamWriter sw = new StreamWriter("trim.spec"); - if (SafeBBGet("Trim_BB", "creates_EndTime") != null) - { - string msg = "trimspec creates end=" + (string)SafeBBGet("Trim_BB", "creates_EndTime") + "\n;"; - sw.WriteLine(msg); - } - if (SafeBBGet("Trim_BB", "reg_EndTime") != null) - { - string msg = "trimspec registerInterests end=" + (string)SafeBBGet("Trim_BB", "reg_EndTime") + "\n;"; - sw.WriteLine(msg); - } - if ((SafeBBGet("Trim_BB", "put_StartTime") != null) && (SafeBBGet( - "Trim_BB", "put_EndTime") != null)) - { - string msg = "trimspec puts start=" + (string)SafeBBGet("Trim_BB", - "put_StartTime") + " end=" + (string)SafeBBGet("Trim_BB", - "put_EndTime") + "\n;"; - sw.WriteLine(msg); - string msg1 = "trimspec operations start=" - + (string)SafeBBGet("Trim_BB", "put_StartTime") + " end=" - + (string)SafeBBGet("Trim_BB", "put_EndTime") + "\n;"; - sw.WriteLine(msg1); - //checkTrimForOps(msg1,sw); - } - if ((SafeBBGet("Trim_BB", "connects_StartTime") != null) && (SafeBBGet( - "Trim_BB", "connects_EndTime") != null)) - { - string msg = "trimspec connects start=" + (string)SafeBBGet("Trim_BB", - "connects_StartTime") + " end=" + (string)SafeBBGet("Trim_BB", - "connects_EndTime") + "\n;"; - sw.WriteLine(msg); - string msg1 = "trimspec operations start=" + SafeBBGet("Trim_BB", - "connects_StartTime") + " end=" + SafeBBGet("Trim_BB", "connects_EndTime") + "\n;"; - sw.WriteLine(msg1); - } - if ((SafeBBGet("Trim_BB", "get_StartTime") != null) && (SafeBBGet( - "Trim_BB", "get_EndTime") != null)) - { - string msg = "trimspec gets start=" + (string)SafeBBGet("Trim_BB", - "get_StartTime") + " end=" + (string)SafeBBGet("Trim_BB", - "get_EndTime") + "\n;"; - sw.WriteLine(msg); - string msg1 = "trimspec operations start=" - + (string)SafeBBGet("Trim_BB", "get_StartTime") + " end=" - + (string)SafeBBGet("Trim_BB", "get_EndTime") + "\n;"; - sw.WriteLine(msg1); - } - if ((SafeBBGet("Trim_BB", "putgets_StartTime") != null) && (SafeBBGet( - "Trim_BB", "putgets_EndTime") != null)) - { - string msg = "trimspec putgets start=" + (string)SafeBBGet("Trim_BB", - "putgets_StartTime") + " end=" + (string)SafeBBGet("Trim_BB", - "putgets_EndTime") + "\n;"; - sw.WriteLine(msg); - string msg1 = "trimspec operations start=" + (string)SafeBBGet("Trim_BB", - "putgets_StartTime") + " end=" + (string)SafeBBGet("Trim_BB", - "putgets_EndTime") + "\n;"; - sw.WriteLine(msg1); - } - if ((SafeBBGet("Trim_BB", "queries_StartTime") != null) && (SafeBBGet( - "Trim_BB", "queries_EndTime") != null)) - { - string msg = "trimspec queries start=" + (string)SafeBBGet("Trim_BB", - "queries_StartTime") + " end=" + (string)SafeBBGet("Trim_BB", - "queries_EndTime") + "\n;"; - sw.WriteLine(msg); - string msg1 = "trimspec operations start=" - + (string)SafeBBGet("Trim_BB", "queries_StartTime") + " end=" - + (string)SafeBBGet("Trim_BB", "queries_EndTime") + "\n;"; - sw.WriteLine(msg1); - } - if ((SafeBBGet("Trim_BB", "updates_StartTime") != null) && (SafeBBGet( - "Trim_BB", "updates_EndTime") != null)) - { - string msg = "trimspec updates start=" + (string)SafeBBGet("Trim_BB", - "updates_StartTime") + " end=" + (string)SafeBBGet("Trim_BB", - "updates_EndTime") + "\n;"; - sw.WriteLine(msg); - string msg1 = "trimspec operations start=" - + (string)SafeBBGet("Trim_BB", "updates_StartTime") + " end=" - + (string)SafeBBGet("Trim_BB", "updates_EndTime") + "\n;"; - sw.WriteLine(msg1); - } - sw.Close(); - } - catch (Exception ex) - { - FwkException("DoGenerateTrimSpec() Caught Exception: {0}", ex); - } - - } - public void DoOpenStatistic() - { - FwkInfo("In DoOpenStatistic()"); - try - { - CreateCacheConnect(); - ResetKey(NumThreads); - int numThreads = GetUIntValue(NumThreads); - numThreads = (numThreads < 0) ? 1 : numThreads; - InitPerfStat initStat = new InitPerfStat(); - RunTask(initStat, numThreads, 0, -1, -1, null); - Thread.Sleep(3000); - } - catch (Exception ex) - { - FwkException("DoOpenStatistic() Caught Exception: {0}", ex); - } - } - public void DoCloseStatistic() - { - FwkInfo("In DoCloseStatistic()"); - try - { - for (int i = 0; i < InitPerfStat.perfstat.Length; i++) - { - InitPerfStat.perfstat[i] = null; - } - FwkInfo("Closed statistics"); - } - catch (Exception ex) - { - FwkException("DoCloseStatistic() Caught Exception: {0}", ex); - } - } - public virtual void DoCreatePool() - { - FwkInfo("In DoCreatePool()"); - try - { - CreatePool(); - } - catch (Exception ex) - { - FwkException("DoCreatePool() Caught Exception: {0}", ex); - } - FwkInfo("DoCreatePool() complete."); - } - - public void DoRegisterAllKeys() - { - FwkInfo("In DoRegisterAllKeys()"); - try - { - IRegion<TKey, TVal> region = GetRegion(); - FwkInfo("DoRegisterAllKeys() region name is {0}", region.Name); - ResetKey("getInitialValues"); - bool isGetInitialValues = GetBoolValue("getInitialValues"); - bool checkReceiveVal = GetBoolValue("checkReceiveVal"); - bool isReceiveValues = true; - if (checkReceiveVal) - { - ResetKey("receiveValue"); - isReceiveValues = GetBoolValue("receiveValue"); - } - region.GetSubscriptionService().RegisterAllKeys(false, null, isGetInitialValues, isReceiveValues); - SetTrimTime("reg", true); - } - catch (Exception ex) - { - FwkException("DoRegisterAllKeys() Caught Exception: {0}", ex); - } - FwkInfo("DoRegisterAllKeys() complete."); - } - - public void DoPopulateRegion() - { - FwkInfo("In DoPopulateRegion()"); - try - { - IRegion<TKey, TVal> region = GetRegion(); - ResetKey(DistinctKeys); - ResetKey(ValueSizes); - int numKeys = InitKeys(); - int size = GetUIntValue(ValueSizes); - ResetKey("ObjectType"); - string objectname = GetStringValue("ObjectType"); - ResetKey("encodeKey"); - ResetKey("encodeTimestamp"); - ResetKey(NumThreads); - ResetKey("AssetAccountSize"); - ResetKey("AssetMaxVal"); - ResetKey("isMainWorkLoad"); - bool encodeKey = GetBoolValue("encodeKey"); - bool encodeTimestamp = GetBoolValue("encodeTimestamp"); - bool mainworkLoad = GetBoolValue("isMainWorkLoad"); - int assetAccountSize = GetUIntValue("AssetAccountSize"); - if (assetAccountSize < 0) - assetAccountSize = 0; - int assetMaxVal = GetUIntValue("AssetMaxVal"); - if (assetMaxVal < 0) - assetMaxVal = 0; - CreateTasks<TKey, TVal> creates = new CreateTasks<TKey, TVal>(region, m_keysA, size, objectname, encodeKey, - encodeTimestamp, mainworkLoad, assetAccountSize, assetMaxVal); - FwkInfo("Populating region."); - RunTask(creates, 1, m_maxKeys, -1, -1, null); - FwkInfo("Populated region."); - SetTrimTime("creates", true); - } - catch (Exception ex) - { - FwkException("DoPopulateRegion() Caught Exception: {0}", ex); - } - FwkInfo("DoPopulateRegion() complete."); - } - - public void DoPuts() - { - FwkInfo("In DoPuts()"); - try - { - IRegion<TKey, TVal> region = GetRegion(); - int numClients = GetUIntValue(ClientCount); - int timedInterval = GetTimeValue(TimedInterval) * 1000; - if (timedInterval <= 0) - { - timedInterval = 5000; - } - int maxTime = 10 * timedInterval; - - // Loop over key set sizes - ResetKey("encodeKey"); - ResetKey("encodeTimestamp"); - ResetKey("ObjectType"); - bool encodeKey = GetBoolValue("encodeKey"); - bool encodeTimestamp = GetBoolValue("encodeTimestamp"); - string objectname = GetStringValue("ObjectType"); - ResetKey("isMainWorkLoad"); - bool mainworkLoad = GetBoolValue("isMainWorkLoad"); - ResetKey("distinctKeys"); - ResetKey("BatchSize"); - ResetKey("opsSecond"); - int opsSec = GetUIntValue("opsSecond"); - opsSec = (opsSec < 1) ? 0 : opsSec; - int numKeys; - ClientTask puts = null; - while ((numKeys = InitKeys(false, true)) > 0) - { // keys loop - // Loop over value sizes - ResetKey(ValueSizes); - int valSize; - while ((valSize = InitValues(numKeys, 0, false)) > 0) - { // value loop - // Loop over threads - ResetKey(NumThreads); - int numThreads; - while ((numThreads = GetUIntValue(NumThreads)) > 0) - { - if (opsSec > 0) - { - puts = new MeteredPutTask<TKey, TVal>(region, m_keysA, valSize, - objectname, encodeKey, encodeTimestamp, mainworkLoad, opsSec); - } - else - { - puts = new PutTasks<TKey, TVal>(region, m_keysA, valSize, - objectname, encodeKey, encodeTimestamp, mainworkLoad); - } - try - { - SetTrimTime("put"); - RunTask(puts, numThreads, -1, timedInterval, maxTime, null); - SetTrimTime("put", true); - } - catch (ClientTimeoutException) - { - FwkException("In DoPuts() Timed run timed out."); - } - - // real work complete for this pass thru the loop - - Thread.Sleep(3000); // Put a marker of inactivity in the stats - } - Thread.Sleep(3000); // Put a marker of inactivity in the stats - } // value loop - Thread.Sleep(3000); // Put a marker of inactivity in the stats - } // keys loop - } - catch (Exception ex) - { - FwkException("DoPuts() Caught Exception: {0}", ex); - } - Thread.Sleep(3000); // Put a marker of inactivity in the stats - FwkInfo("DoPuts() complete."); - } - - public void DoGets() - { - FwkInfo("In DoGets()"); - try - { - IRegion<TKey, TVal> region = GetRegion(); - int numClients = GetUIntValue(ClientCount); - int timedInterval = GetTimeValue(TimedInterval) * 1000; - if (timedInterval <= 0) - { - timedInterval = 5000; - } - int maxTime = 10 * timedInterval; - - ResetKey(DistinctKeys); - InitKeys(false, true); - - int valSize = GetUIntValue(ValueSizes); - - // Loop over threads - ResetKey(NumThreads); - int numThreads; - ResetKey("isMainWorkLoad"); - bool mainworkLoad = GetBoolValue("isMainWorkLoad"); - - while ((numThreads = GetUIntValue(NumThreads)) > 0) - { // thread loop - - // And we do the real work now - GetTask<TKey, TVal> gets = new GetTask<TKey, TVal>(region, m_keysA, mainworkLoad); - try - { - SetTrimTime("get"); - RunTask(gets, numThreads, -1, timedInterval, maxTime, null); - SetTrimTime("get", true); - } - catch (ClientTimeoutException) - { - FwkException("In DoGets() Timed run timed out."); - } - - Thread.Sleep(3000); - } // thread loop - } - catch (Exception ex) - { - FwkException("DoGets() Caught Exception: {0}", ex); - } - Thread.Sleep(3000); - FwkInfo("DoGets() complete."); - } - - public void DoCyclePoolTask() - { - - FwkInfo("In Smokeperf::DoCyclePoolTask"); - try - { - int timedInterval = GetUIntValue("timedInterval"); - if (timedInterval <= 0) - { - timedInterval = 5; - } - ResetKey("isMainWorkLoad"); - bool mainworkLoad = GetBoolValue("isMainWorkLoad"); - int sleepMs = GetTimeValue("sleepMs"); - DateTime now = DateTime.Now; - DateTime end = now.AddSeconds(timedInterval); - //PoolFactory pf = CreatePoolFactoryAndSetAttribute(); - ResetKey("poolSpec"); - string poolRegionData = GetStringValue("poolSpec"); - //poolRegionData = poolRegionData + "New"; - //Properties prop = GetNewPoolAttributes(poolRegionData); - string poolName = null; - PoolFactory pf = PoolManager.CreateFactory(); - SetPoolAttributes(pf, poolRegionData, ref poolName); - long startTime; - SetTrimTime("connects"); - while (now < end) - { - startTime = InitPerfStat.perfstat[0].StartConnect(); - Pool pool = pf.Create(poolName); - //FwkInfo("rjk: durable client id is {0}", DistributedSystem.SystemProperties.DurableClientId); - if (pool != null) - { - pool.Destroy(); - } - InitPerfStat.perfstat[0].EndConnect(startTime, mainworkLoad); - Thread.Sleep(sleepMs); - now = DateTime.Now; - } - SetTrimTime("connects", true); - } - catch (Exception ex) - { - FwkException("Smokeperf::DoCyclePoolTask FAILED -- caught exception: {0}", ex); - } - FwkInfo("DoCyclePoolTask() complete."); - } - // BridgeConnection ( old endpoint) related task is depricated in the product. so no use of this Method - // Used in perf073,075,100. - public void DoCycleBridgeConnectionTask() - { - FwkInfo("In Smokeperf::DoCycleBridgeConnectionTask"); - string name = GetStringValue("regionName"); - if (name.Length <= 0) - { - FwkException("Region name not specified in test."); - } - ResetKey("isMainWorkLoad"); - bool mainworkLoad = GetBoolValue("isMainWorkLoad"); - try - { - int timedInterval = GetUIntValue("timedInterval"); - if (timedInterval <= 0) - { - timedInterval = 5; - } - int sleepMs = GetTimeValue("sleepMs"); - DateTime now = DateTime.Now; - DateTime end = now.AddSeconds(timedInterval); - long startTime; - SetTrimTime("connects"); - while (now < end) - { - startTime = InitPerfStat.perfstat[0].StartConnect(); - IRegion<TKey, TVal> region = CreateRootRegion(); - region.GetLocalView().DestroyRegion(); - InitPerfStat.perfstat[0].EndConnect(startTime, mainworkLoad); - Thread.Sleep(sleepMs); - now = DateTime.Now; - } - SetTrimTime("connects", true); - } - catch (Exception ex) - { - FwkException("Smokeperf::DoCycleBridgeConnectionTask FAILED -- caught exception: {0}", ex); - } - FwkInfo("DoCycleBridgeConnectionTask() complete."); - } - - public void DoMixPutGetDataTask() - { - FwkInfo("In DoMixPutGetDataTask()"); - try - { - IRegion<TKey, TVal> region = GetRegion(); - int numClients = GetUIntValue(ClientCount); - int timedInterval = GetTimeValue(TimedInterval) * 1000; - if (timedInterval <= 0) - { - timedInterval = 5000; - } - int maxTime = 10 * timedInterval; - - // Loop over key set sizes - ResetKey("encodeKey"); - ResetKey("encodeTimestamp"); - ResetKey("ObjectType"); - bool encodeKey = GetBoolValue("encodeKey"); - bool encodeTimestamp = GetBoolValue("encodeTimestamp"); - string objectname = GetStringValue("ObjectType"); - ResetKey("putPercentage"); - int putPercentage = GetUIntValue("putPercentage"); - ResetKey("isMainWorkLoad"); - bool mainworkLoad = GetBoolValue("isMainWorkLoad"); - ResetKey("distinctKeys"); - int numKeys; - while ((numKeys = InitKeys(false, true)) > 0) - { // keys loop - // Loop over value sizes - ResetKey(ValueSizes); - int valSize; - while ((valSize = InitValues(numKeys, 0, false)) > 0) - { // value loop - // Loop over threads - ResetKey(NumThreads); - int numThreads; - while ((numThreads = GetUIntValue(NumThreads)) > 0) - { - PutGetMixTask<TKey, TVal> putGet = new PutGetMixTask<TKey, TVal>(region, m_keysA, valSize, objectname, encodeKey, - encodeTimestamp, mainworkLoad, putPercentage); - - try - { - SetTrimTime("putgets"); - RunTask(putGet, numThreads, -1, timedInterval, maxTime, null); - SetTrimTime("putgets", true); - } - catch (ClientTimeoutException) - { - FwkException("In DoMixPutGetDataTask() Timed run timed out."); - } - - // real work complete for this pass thru the loop - - Thread.Sleep(3000); // Put a marker of inactivity in the stats - } - Thread.Sleep(3000); // Put a marker of inactivity in the stats - } // value loop - Thread.Sleep(3000); // Put a marker of inactivity in the stats - } // keys loop - } - catch (Exception ex) - { - FwkException("DoMixPutGetDataTask() Caught Exception: {0}", ex); - } - Thread.Sleep(3000); // Put a marker of inactivity in the stats - FwkInfo("DoMixPutGetDataTask() complete."); - } - - public void DoQueryRegionDataTask() - { - FwkInfo("In Smokeperf::DoQueryRegionDataTask()"); - - try - { - IRegion<TKey, TVal> region = GetRegion(); - int numClients = GetUIntValue(ClientCount); - int timedInterval = GetTimeValue(TimedInterval) * 1000; - if (timedInterval <= 0) - { - timedInterval = 5000; - } - int maxTime = 10 * timedInterval; - - - // Loop over key set sizes - ResetKey("query"); - string queryStr = GetStringValue("query"); // set the query string in xml - if (queryStr.Length <= 0) - queryStr = "select distinct * from " + region.FullPath; - ResetKey(NumThreads); - int numThreads; - while ((numThreads = GetUIntValue(NumThreads)) > 0) - { // thread loop - RegionQueryTask<TKey, TVal> query = new RegionQueryTask<TKey, TVal>(region, queryStr); - SetTrimTime("queries"); - RunTask(query, numThreads, -1, timedInterval, maxTime, null); - SetTrimTime("queries", true); - Thread.Sleep(3000); - } // thread loop - } - catch (Exception ex) - { - FwkException("Smokeperf::DoQueryRegionDataTask() Caught Exception: {0}", ex); - } - FwkInfo("Smokeperf::DoQueryRegionDataTask() complete."); - } - - public void DoRegisterCQs() - { - FwkInfo("In Smokeperf::DoRegisterCQs()"); - - try - { - IRegion<TKey, TVal> region = GetRegion(); - int numCQ = GetUIntValue("numCQs"); - numCQ = (numCQ <= 0) ? 1 : numCQ; - for (int i = 0; i < numCQ; i++) - { - string cqname = String.Format("cq{0}", i); - string query = GetQuery(i); - Pool pool = PoolManager.Find("_Test_Pool1"); - QueryService<TKey, object> qs = null;// pool.GetQueryService<TKey, object>(); //rjk to do fixed - CqAttributesFactory<TKey, object> cqFac = new CqAttributesFactory<TKey, object>(); - ICqListener<TKey, object> cqLstner = new CQLatencyListener<TKey, TVal>(InitPerfStat.perfstat[0]); - cqFac.AddCqListener(cqLstner); - CqAttributes<TKey, object> cqAttr = cqFac.Create(); - FwkInfo("Registering CQ named {0} with query: {1}", cqname, query); - CqQuery<TKey, object> qry = qs.NewCq(cqname, query, cqAttr, false); - ISelectResults<object> results = qry.ExecuteWithInitialResults(300); - - FwkInfo("Successfully executed CQ named {0}", cqname); - } - - } - catch (Exception ex) - { - FwkException("Smokeperf::DoRegisterCQs() Caught Exception: {0}", ex); - } - FwkInfo("Smokeperf::DoRegisterCQs() complete."); - } - - public void DoPutBatchObj() - { - FwkInfo("In DoPutBatchObj()"); - try - { - IRegion<TKey, TVal> region = GetRegion(); - int numClients = GetUIntValue(ClientCount); - int timedInterval = GetTimeValue(TimedInterval) * 1000; - if (timedInterval <= 0) - { - timedInterval = 5000; - } - int maxTime = 10 * timedInterval; - - // Loop over key set sizes - ResetKey("encodeKey"); - ResetKey("encodeTimestamp"); - ResetKey("ObjectType"); - bool encodeKey = GetBoolValue("encodeKey"); - bool encodeTimestamp = GetBoolValue("encodeTimestamp"); - string objectname = GetStringValue("ObjectType"); - int putPercentage = GetUIntValue("putPercentage"); - ResetKey("isMainWorkLoad"); - bool mainworkLoad = GetBoolValue("isMainWorkLoad"); - ResetKey("distinctKeys"); - ResetKey("BatchSize"); - int batchsize = GetUIntValue("BatchSize"); - int numKeys = 0; - if (batchsize > 0) - numKeys = InitBatchKeys(false); - else - numKeys = InitKeys(false, true); - while (numKeys > 0) - { // keys loop - // Loop over value sizes - ResetKey(ValueSizes); - int valSize; - while ((valSize = InitValues(numKeys, 0, false)) > 0) - { // value loop - // Loop over threads - ResetKey(NumThreads); - int numThreads; - while ((numThreads = GetUIntValue(NumThreads)) > 0) - { - PutBatchObjectTask<TKey, TVal> puts = new PutBatchObjectTask<TKey, TVal>(region, m_keysA, valSize, objectname, - encodeKey, encodeTimestamp, mainworkLoad, batchsize, valSize); - - try - { - bool isCreate = GetBoolValue("isCreate"); - if (isCreate) - { - FwkInfo("Creating entries."); - RunTask(puts, 1, m_maxKeys, -1, -1, null); - } - else - { - SetTrimTime("put"); - RunTask(puts, numThreads, -1, timedInterval, maxTime, null); - SetTrimTime("put", true); - } - } - catch (ClientTimeoutException) - { - FwkException("In DoPutBatchObj() Timed run timed out."); - } - - // real work complete for this pass thru the loop - - } - - } // value loop - batchsize = GetUIntValue("BatchSize"); - if (batchsize > 0) - numKeys = InitBatchKeys(false); - else - numKeys = InitKeys(false, true); - if (numKeys > 0) - { - Thread.Sleep(3000); // Put a marker of inactivity in the stats - } - } // keys loop - - } - catch (Exception ex) - { - FwkException("DoPutBatchObj() Caught Exception: {0}", ex); - } - Thread.Sleep(3000); // Put a marker of inactivity in the stats - FwkInfo("DoPutBatchObj() complete."); - } - - public void DoCycleDurableClientTask() - { - FwkInfo("In Smokeperf::DoCycleDurableClientTask()"); - //resetValue("isMainWorkLoad"); - //bool mainworkLoad = getBoolValue("isMainWorkLoad"); - try - { - int timedInterval = GetTimeValue("timedInterval"); - if (timedInterval <= 0) - { - timedInterval = 5; - } - ResetKey("isDurableReg"); - //ResetKey("poolName"); - bool isDurable = GetBoolValue("isDurableReg"); - //string poolName = GetStringValue("poolName"); - //if (poolName.Length <= 0) - // poolName = "_Test_Pool1"; - DateTime now = DateTime.Now; - DateTime end = now.AddSeconds(timedInterval); - long startTime; - SetTrimTime("connects"); - while (now < end) - { - startTime = InitPerfStat.perfstat[0].StartConnect(); - DoCreatePool(); - ResetKey("regionSpec"); - DoCreateRegion(); - IRegion<TKey, TVal> region = GetRegion(); - region.GetSubscriptionService().RegisterRegex(".*", isDurable); - CacheHelper<TKey, TVal>.DCache.ReadyForEvents(); - InitPerfStat.perfstat[0].EndConnect(startTime, false); - string oper_cnt_key = string.Format("ClientName_{0}", Util.ClientNum); - int cur_cnt = (int)Util.BBGet("DURABLEBB", oper_cnt_key); - InitPerfStat.perfstat[0].IncUpdateEvents(cur_cnt); - InitPerfStat.perfstat[0].SetOpTime(InitPerfStat.perfstat[0].GetConnectTime()); - InitPerfStat.perfstat[0].SetOps(cur_cnt + InitPerfStat.perfstat[0].GetOps()); - CacheHelper<TKey, TVal>.DCache.Close(true); - //pool->destroy(); - region = null; - CacheHelper<TKey, TVal>.DCache = null; - //CacheHelper.SetDCacheNull(); - Thread.Sleep(10000); - now = DateTime.Now; - } - SetTrimTime("connects", true); - } - catch (Exception ex) - { - FwkException("Smokeperf::DoCycleDurableClientTask FAILED -- caught exception: {0}", ex); - } - } - public void DoCreateEntryMapTask() - { - - FwkInfo("In Smokeperf::DoCreateEntryMapTask()"); - - try - { - IRegion<TKey, TVal> region = GetRegion(); - int timedInterval = GetTimeValue("timedInterval"); - if (timedInterval <= 0) - { - timedInterval = 5; - } - // Loop over key set sizes - ResetKey("encodeKey"); - ResetKey("encodeTimestamp"); - ResetKey("ObjectType"); - bool encodeKey = GetBoolValue("encodeKey"); - bool encodeTimestamp = GetBoolValue("encodeTimestamp"); - string objectname = GetStringValue("ObjectType"); - ResetKey("isMainWorkLoad"); - bool mainworkLoad = GetBoolValue("isMainWorkLoad"); - ResetKey("distinctKeys"); - int numKeys = InitKeys(false, true); - ResetKey("valueSizes"); - int valSize = InitValues(numKeys, 0, false); - ResetKey("numThreads"); - int numThreads = GetUIntValue("numThreads"); - CreatePutAllMap<TKey, TVal> createMap = new CreatePutAllMap<TKey, TVal>(region, m_keysA, - valSize, objectname, maps, encodeKey, encodeTimestamp, - mainworkLoad); - - FwkInfo("Running timed task."); - RunTask(createMap, numThreads, m_maxKeys, -1, -1, null); - - } - catch (Exception ex) - { - FwkException("Smokeperf::DoCreateEntryMapTask() Caught Exception: {0}", ex); - } - ClearKeys(); - Thread.Sleep(3); // Put a marker of inactivity in the stats - FwkInfo("Smokeperf::createEntryMapTask() complete."); - } - - public void DoPutAllEntryMapTask() - { - FwkInfo("In DoPutAllEntryMapTask()"); - try - { - IRegion<TKey, TVal> region = GetRegion(); - int numClients = GetUIntValue(ClientCount); - int timedInterval = GetTimeValue(TimedInterval) * 1000; - if (timedInterval <= 0) - { - timedInterval = 5000; - } - int maxTime = 10 * timedInterval; - - // Loop over key set sizes - ResetKey("encodeKey"); - ResetKey("encodeTimestamp"); - ResetKey("ObjectType"); - bool encodeKey = GetBoolValue("encodeKey"); - bool encodeTimestamp = GetBoolValue("encodeTimestamp"); - string objectname = GetStringValue("ObjectType"); - ResetKey("isMainWorkLoad"); - bool mainworkLoad = GetBoolValue("isMainWorkLoad"); - ResetKey("distinctKeys"); - ResetKey("BatchSize"); - ResetKey("opsSecond"); - int opsSec = GetUIntValue("opsSecond"); - opsSec = (opsSec < 1) ? 0 : opsSec; - int numKeys = InitKeys(false, true); - ResetKey(ValueSizes); - int valSize = InitValues(numKeys, 0, false); - - ResetKey(NumThreads); - int numThreads = GetUIntValue(NumThreads); - CreatePutAllMap<TKey, TVal> createMap = new CreatePutAllMap<TKey, TVal>(region, m_keysA, - valSize, objectname, maps, encodeKey, encodeTimestamp, - mainworkLoad); - - FwkInfo("Running timed task."); - RunTask(createMap, numThreads, m_maxKeys, -1, -1, null); - - PutAllMap<TKey, TVal> putall = new PutAllMap<TKey, TVal>(region, m_keysA, valSize, objectname, maps, encodeKey, - encodeTimestamp, mainworkLoad); - - - try - { - SetTrimTime("put"); - RunTask(putall, numThreads, -1, timedInterval, maxTime, null); - SetTrimTime("put", true); - } - catch (ClientTimeoutException) - { - FwkException("In DoPutAllEntryMapTask() Timed run timed out."); - } - - } - catch (Exception ex) - { - FwkException("DoPutAllEntryMapTask() Caught Exception: {0}", ex); - } - Thread.Sleep(3000); // Put a marker of inactivity in the stats - FwkInfo("DoPutAllEntryMapTask() complete."); - } - public void DoUpdateDeltaData() - { - FwkInfo("In DoUpdateDeltaData()"); - try - { - IRegion<TKey, TVal> region = GetRegion(); - int numClients = GetUIntValue(ClientCount); - int timedInterval = GetTimeValue(TimedInterval) * 1000; - if (timedInterval <= 0) - { - timedInterval = 5000; - } - int maxTime = 10 * timedInterval; - - // Loop over key set sizes - ResetKey("encodeKey"); - ResetKey("encodeTimestamp"); - ResetKey("ObjectType"); - bool encodeKey = GetBoolValue("encodeKey"); - bool encodeTimestamp = GetBoolValue("encodeTimestamp"); - string objectname = GetStringValue("ObjectType"); - ResetKey("isMainWorkLoad"); - bool mainworkLoad = GetBoolValue("isMainWorkLoad"); - ResetKey("distinctKeys"); - ResetKey("BatchSize"); - ResetKey("opsSecond"); - ResetKey("AssetAccountSize"); - ResetKey("AssetMaxVal"); - int assetAccountSize = GetUIntValue("AssetAccountSize"); - if (assetAccountSize < 0) - assetAccountSize = 0; - int assetMaxVal = GetUIntValue("AssetMaxVal"); - if (assetMaxVal < 0) - assetMaxVal = 0; - int numKeys; - while ((numKeys = InitKeys(false, true)) > 0) - { // keys loop - // Loop over value sizes - ResetKey(ValueSizes); - int valSize; - while ((valSize = InitValues(numKeys, 0, false)) > 0) - { // value loop - // Loop over threads - ResetKey(NumThreads); - int numThreads; - while ((numThreads = GetUIntValue(NumThreads)) > 0) - { - UpdateDeltaTask<TKey, TVal> puts = new UpdateDeltaTask<TKey, TVal>(region, m_keysA, valSize, objectname, encodeKey, - encodeTimestamp, mainworkLoad, assetAccountSize, assetMaxVal); - try - { - SetTrimTime("updates"); - RunTask(puts, numThreads, -1, timedInterval, maxTime, null); - SetTrimTime("updates", true); - } - catch (ClientTimeoutException) - { - FwkException("In DoUpdateDeltaData() Timed run timed out."); - } - - // real work complete for this pass thru the loop - - Thread.Sleep(3000); // Put a marker of inactivity in the stats - } - Thread.Sleep(3000); // Put a marker of inactivity in the stats - } // value loop - Thread.Sleep(3000); // Put a marker of inactivity in the stats - } // keys loop - } - catch (Exception ex) - { - FwkException("DoUpdateDeltaData() Caught Exception: {0}", ex); - } - Thread.Sleep(3000); // Put a marker of inactivity in the stats - FwkInfo("DoUpdateDeltaData() complete."); - } - #endregion - } -}
http://git-wip-us.apache.org/repos/asf/geode-native/blob/da389793/src/tests/cli/NewFwkLib/SmokePerf/SmokeTasks.cs ---------------------------------------------------------------------- diff --git a/src/tests/cli/NewFwkLib/SmokePerf/SmokeTasks.cs b/src/tests/cli/NewFwkLib/SmokePerf/SmokeTasks.cs deleted file mode 100644 index 0935e0f..0000000 --- a/src/tests/cli/NewFwkLib/SmokePerf/SmokeTasks.cs +++ /dev/null @@ -1,829 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -using System; -using System.Collections.Generic; -using System.Text; -using System.Threading; -using Apache.Geode.Client.Tests; -using Apache.Geode.DUnitFramework; - -namespace Apache.Geode.Client.FwkLib -{ - using Apache.Geode.Client; - //using Region = Apache.Geode.Client.IRegion<Object, Object>; - public class InitPerfStat : ClientTask - { - public Int32 m_cnt; - public static PerfStat[] perfstat = new PerfStat[10]; - public InitPerfStat() - : base() - { - m_cnt = 0; - } - - public override void DoTask(int iters, object data) - { - Int32 localcnt = m_cnt; - Interlocked.Increment(ref m_cnt); - perfstat[localcnt] = new PerfStat(Thread.CurrentThread.ManagedThreadId); - } - } - - - public class PutAllTask<TKey, TVal> : ClientTask - { - #region Private members - - private IRegion<TKey, TVal> m_region; - private TKey[] m_keys; - private TVal[] m_values; - - #endregion - - #region Public accessors - - public TVal[] Values - { - get - { - return m_values; - } - set - { - m_values = value; - } - } - - #endregion - - public PutAllTask(IRegion<TKey, TVal> region, TKey[] keys, - TVal[] values) - : base() - { - m_region = region as IRegion<TKey, TVal>; - m_keys = keys as TKey[]; - m_values = values as TVal[]; - } - - public override void DoTask(int iters, object data) - { - if (m_keys != null && m_keys.Length > 0) - { - int numKeys = m_keys.Length; - int offset = Util.Rand(numKeys); - int count = offset; - IDictionary<TKey, TVal> map = new Dictionary<TKey, TVal>(); - //CacheableHashMap map = new CacheableHashMap(); - map.Clear(); - Util.Log("PutAllTask::DoTask: starting {0} iterations.", iters); - while (Running && (iters-- != 0)) - { - int idx = count % numKeys; - try - { - map.Add(m_keys[idx], m_values[idx]); - } - catch (Exception ex) - { - Util.Log(Util.LogLevel.Error, - "Exception while putting key[{0}] for region {1} in iteration " + - "{2}: {3}", idx, m_region.Name, (count - offset), ex); - throw; - } - count++; - } - DateTime startTime = DateTime.Now; - m_region.PutAll(map, 60); - DateTime endTime = DateTime.Now; - TimeSpan elapsedTime = endTime - startTime; - FwkTest<TKey, TVal>.CurrentTest.FwkInfo("Time Taken to execute putAll for {0}" + - " is {1}ms", numKeys, elapsedTime.TotalMilliseconds); - Interlocked.Add(ref m_iters, count - offset); - } - } - } - public class GetTask<TKey, TVal> : ClientTask - { - #region Private members - - private IRegion<TKey, TVal> m_region; - private TKey[] m_keys; - bool m_isMainWorkLoad; - public Int32 m_cnt; - - #endregion - - public GetTask(IRegion<TKey, TVal> region, TKey[] keys, bool isMainWorkLoad) - : base() - { - m_region = region as IRegion<TKey, TVal>; - m_keys = keys as TKey[]; - m_isMainWorkLoad = isMainWorkLoad; - m_cnt = 0; - } - - public override void DoTask(int iters, object data) - { - if (m_keys != null && m_keys.Length > 0) - { - Int32 localcnt = m_cnt; - Interlocked.Increment(ref m_cnt); - int numKeys = m_keys.Length; - int offset = Util.Rand(numKeys); - int count = offset; - long startTime; - while (Running && (iters-- != 0)) - { - object val = null; - int idx = count % numKeys; - try - { - startTime = InitPerfStat.perfstat[localcnt].StartGet(); - val = m_region[m_keys[idx]]; - //val = m_region.Get(m_keys[idx],null); - InitPerfStat.perfstat[localcnt].EndGet(startTime, m_isMainWorkLoad); - } - catch (Exception ex) - { - Util.Log(Util.LogLevel.Error, - "Exception while getting key[{0}] for region {1} in iteration " + - "{2}: {3}", idx, m_region.Name, (count - offset), ex); - throw; - } - if (val == null) - { - string exStr = string.Format("Key[{0}] not found in region {1}", - m_keys[idx], m_region.Name); - Util.Log(Util.LogLevel.Error, exStr); - throw new EntryNotFoundException(exStr); - } - count++; - } - Interlocked.Add(ref m_iters, count - offset); - } - } - } - - public class CreateTasks<TKey, TVal> : ClientTask - { - #region Private members - - private IRegion<TKey, TVal> m_region; - private TKey[] m_keys; - private TVal[] m_values; - private Int32 m_cnt; - private Int32 m_size; - private string m_objectType; - private bool m_encodeKey; - private bool m_encodeTimestamp; - private bool m_isMainWorkLoad; - private Int32 m_assetAcSize; - private Int32 m_assetmaxVal; - - #endregion - - #region Public accessors - - public TVal[] Values - { - get - { - return m_values; - } - set - { - m_values = value; - } - } - - #endregion - - public CreateTasks(IRegion<TKey, TVal> region, TKey[] keys, Int32 size, string objectType, - bool encodeKey, bool encodeTimestamp, bool isMainWorkLoad, Int32 assetACsize, Int32 assetMaxVal) - : base() - { - m_region = region as IRegion<TKey, TVal>; - m_keys = keys as TKey[]; - m_values = null; - m_cnt = 0; - m_size = size; - m_objectType = objectType; - m_encodeKey = encodeKey; - m_encodeTimestamp = encodeTimestamp; - m_isMainWorkLoad = isMainWorkLoad; - m_assetAcSize = assetACsize; - m_assetmaxVal = assetMaxVal; - } - - public override void DoTask(int iters, object data) - { - if (m_keys != null && m_keys.Length > 0) - { - Int32 localcnt = m_cnt; - Interlocked.Increment(ref m_cnt); - int numKeys = m_keys.Length; - int offset = Util.Rand(numKeys); - int count = offset; - long startTime; - Util.Log("CreateTasks::DoTask: starting {0} iterations.", iters); - while (Running && (iters-- != 0)) - { - int idx = count % numKeys; - try - { - TVal obj = ObjectHelper<TKey, TVal>.CreateObject(m_objectType, m_size, m_encodeKey, - m_encodeTimestamp, m_assetAcSize, m_assetmaxVal, idx); - startTime = InitPerfStat.perfstat[localcnt].StartCreate(); - //Util.Log("Create Keys is {0} object is {1}", m_keys[idx],obj.ToString()); - m_region.Add(m_keys[idx], obj); - InitPerfStat.perfstat[localcnt].EndCreate(startTime, m_isMainWorkLoad); - } - catch (Exception ex) - { - Util.Log(Util.LogLevel.Error, - "Exception while putting key[{0}] for region {1} in iteration " + - "{2}: {3}", idx, m_region.Name, (count - offset), ex); - throw; - } - count++; - } - Interlocked.Add(ref m_iters, count - offset); - } - } - } - - public class PutTasks<TKey, TVal> : ClientTask - { - #region Private members - - private IRegion<TKey, TVal> m_region; - private TKey[] m_keys; - private Int32 m_cnt; - private Int32 m_size; - private string m_objectType; - private bool m_encodeKey; - private bool m_encodeTimestamp; - private bool m_isMainWorkLoad; - - #endregion - - public PutTasks(IRegion<TKey, TVal> region, TKey[] keys, Int32 size, string objectType, - bool encodeKey, bool encodeTimestamp, bool isMainWorkLoad) - : base() - { - m_region = region as IRegion<TKey, TVal>; - m_keys = keys as TKey[]; - m_cnt = 0; - m_size = size; - m_objectType = objectType; - m_encodeKey = encodeKey; - m_encodeTimestamp = encodeTimestamp; - m_isMainWorkLoad = isMainWorkLoad; - } - - public override void DoTask(int iters, object data) - { - if (m_keys != null && m_keys.Length > 0) - { - Int32 localcnt = m_cnt; - Interlocked.Increment(ref m_cnt); - int numKeys = m_keys.Length; - int offset = Util.Rand(numKeys); - int count = offset; - long startTime; - Util.Log("PutTasks::DoTask: starting {0} iterations.", iters); - while (Running && (iters-- != 0)) - { - int idx = count % numKeys; - try - { - TVal obj = ObjectHelper<TKey, TVal>.CreateObject(m_objectType, m_size, m_encodeKey, - m_encodeTimestamp, 0, 0, 0); - startTime = InitPerfStat.perfstat[localcnt].StartPut(); - m_region[m_keys[idx]] = obj;//.Put(m_keys[idx], obj); - InitPerfStat.perfstat[localcnt].EndPut(startTime, m_isMainWorkLoad); - } - catch (Exception ex) - { - Util.Log(Util.LogLevel.Error, - "Exception while putting key[{0}] for region {1} in iteration " + - "{2}: {3}", idx, m_region.Name, (count - offset), ex); - throw; - } - count++; - - } - Interlocked.Add(ref m_iters, count - offset); - } - } - } - - public class MeteredPutTask<TKey, TVal> : ClientTask - { - #region Private members - - private IRegion<TKey, TVal> m_region; - private TKey[] m_keys; - private int m_opsSec; - private Int32 m_cnt; - private Int32 m_size; - private string m_objectType; - private bool m_encodeKey; - private bool m_encodeTimestamp; - private bool m_isMainWorkLoad; - - #endregion - - - public MeteredPutTask(IRegion<TKey, TVal> region, TKey[] keys, Int32 size, string objectType, - bool encodeKey, bool encodeTimestamp, bool isMainWorkLoad, int opsSec) - : base() - { - m_region = region as IRegion<TKey, TVal>; - m_keys = keys as TKey[]; - m_opsSec = opsSec; - m_cnt = 0; - m_size = size; - m_objectType = objectType; - m_encodeKey = encodeKey; - m_encodeTimestamp = encodeTimestamp; - m_isMainWorkLoad = isMainWorkLoad; - } - - public override void DoTask(int iters, object data) - { - if (m_keys != null && m_keys.Length > 0) - { - Int32 localcnt = m_cnt; - Interlocked.Increment(ref m_cnt); - int numKeys = m_keys.Length; - int offset = Util.Rand(numKeys); - int count = offset; - long startTime; - int idx; - PaceMeter pm = new PaceMeter(m_opsSec); - while (Running && (iters-- != 0)) - { - idx = count % numKeys; - try - { - TVal obj = ObjectHelper<TKey, TVal>.CreateObject(m_objectType, m_size, m_encodeKey, - m_encodeTimestamp, 0, 0, 0); - startTime = InitPerfStat.perfstat[localcnt].StartPut(); - m_region[m_keys[idx]] = obj;//.Put(m_keys[idx], obj); - InitPerfStat.perfstat[localcnt].EndPut(startTime, m_isMainWorkLoad); - pm.CheckPace(); - } - catch (Exception ex) - { - Util.Log(Util.LogLevel.Error, - "Exception while putting key[{0}] for region {1} in iteration " + - "{2}: {3}", idx, m_region.Name, (count - offset), ex); - throw; - } - count++; - } - Interlocked.Add(ref m_iters, count - offset); - } - } - } - - public class PutGetMixTask<TKey, TVal> : ClientTask - { - #region Private members - - private IRegion<TKey, TVal> m_region; - private TKey[] m_keys; - private Int32 m_cnt; - private Int32 m_size; - private string m_objectType; - private bool m_encodeKey; - private bool m_encodeTimestamp; - private bool m_isMainWorkLoad; - private Int32 m_putPercentage; - - #endregion - - public PutGetMixTask(IRegion<TKey, TVal> region, TKey[] keys, Int32 size, string objectType, - bool encodeKey, bool encodeTimestamp, bool isMainWorkLoad,Int32 putpercentage) - : base() - { - m_region = region as IRegion<TKey, TVal>; - m_keys = keys as TKey[]; - m_cnt = 0; - m_size = size; - m_objectType = objectType; - m_encodeKey = encodeKey; - m_encodeTimestamp = encodeTimestamp; - m_isMainWorkLoad = isMainWorkLoad; - m_putPercentage = putpercentage; - } - - public override void DoTask(int iters, object data) - { - if (m_keys != null && m_keys.Length > 0) - { - Int32 localcnt = m_cnt; - Interlocked.Increment(ref m_cnt); - int numKeys = m_keys.Length; - int offset = Util.Rand(numKeys); - int count = offset; - long startTime; - Util.Log("PutGetMixTask::DoTask: starting {0} iterations.", iters); - while (Running && (iters-- != 0)) - { - int n = Util.Rand(1, 100); - int idx = count % numKeys; - - if (n < m_putPercentage) - { - TVal obj = ObjectHelper<TKey, TVal>.CreateObject(m_objectType, m_size, m_encodeKey, - m_encodeTimestamp, 0, 0, 0); - startTime = InitPerfStat.perfstat[localcnt].StartPut(); - m_region[m_keys[idx]] = obj;//.Put(m_keys[idx], obj); - InitPerfStat.perfstat[localcnt].EndPut(startTime, m_isMainWorkLoad); - } - else - { - TVal val = default(TVal); - startTime = InitPerfStat.perfstat[localcnt].StartGet(); - val = m_region[m_keys[idx]]; - InitPerfStat.perfstat[localcnt].EndGet(startTime, m_isMainWorkLoad); - - if (val == null) - { - string exStr = string.Format("Key[{0}] not found in region {1}", - m_keys[idx], m_region.Name); - Util.Log(Util.LogLevel.Error, exStr); - throw new EntryNotFoundException(exStr); - } - } - count++; - } - Interlocked.Add(ref m_iters, count - offset); - } - } - } - - public class RegionQueryTask<TKey, TVal> : ClientTask - { - private IRegion<TKey, TVal> m_region; - private Int32 m_cnt; - private string m_queryString; - public RegionQueryTask(IRegion<TKey, TVal> region, string queryString) - : base() - { - m_region = region as IRegion<TKey, TVal>; - m_cnt = 0; - m_queryString = queryString; - } - - public override void DoTask(int iters, object data) - { - Int32 localcnt = m_cnt; - Interlocked.Increment(ref m_cnt); - int offset = Util.Rand(100); - int count = offset; - long startTime; - while (Running && (iters-- != 0)) - { - startTime = InitPerfStat.perfstat[localcnt].StartQuery(); - ISelectResults<object> sptr = m_region.Query<object>(m_queryString, 600); - InitPerfStat.perfstat[localcnt].EndQuery(startTime, false); - count++; - } - Interlocked.Add(ref m_iters, count - offset); - } - } - - public class PutBatchObjectTask<TKey, TVal> : ClientTask - { - #region Private members - - private IRegion<TKey, TVal> m_region; - private TKey[] m_keys; - private Int32 m_cnt; - private Int32 m_size; - private string m_objectType; - private bool m_encodeKey; - private bool m_encodeTimestamp; - private bool m_isMainWorkLoad; - private Int32 m_batchSize; - private Int32 m_batchObjSize; - - #endregion - - public PutBatchObjectTask(IRegion<TKey, TVal> region, TKey[] keys, Int32 size, string objectType, - bool encodeKey, bool encodeTimestamp, bool isMainWorkLoad,Int32 batchSize, Int32 objsize) - : base() - { - m_region = region as IRegion<TKey, TVal>; - m_keys = keys as TKey[]; - m_cnt = 0; - m_size = size; - m_objectType = objectType; - m_encodeKey = encodeKey; - m_encodeTimestamp = encodeTimestamp; - m_isMainWorkLoad = isMainWorkLoad; - m_batchSize = batchSize; - m_batchObjSize = objsize; - } - - public override void DoTask(int iters, object data) - { - if (m_keys != null && m_keys.Length > 0) - { - Int32 localcnt = m_cnt; - Interlocked.Increment(ref m_cnt); - int numKeys = m_keys.Length; - int offset = Util.Rand(numKeys); - int count = offset; - long startTime; - Util.Log("PutBatchObjectTask::DoTask: starting {0} iterations.", iters); - while (Running && (iters-- != 0)) - { - int idx = count % numKeys; - try - { - TVal obj = ObjectHelper<TKey, TVal>.CreateObject(m_objectType, m_size, m_encodeKey, m_encodeTimestamp, - m_batchSize, m_batchObjSize, idx); - startTime = InitPerfStat.perfstat[localcnt].StartPut(); - m_region[m_keys[idx]] = obj; - InitPerfStat.perfstat[localcnt].EndPut(startTime, m_isMainWorkLoad); - } - catch (Exception ex) - { - Util.Log(Util.LogLevel.Error, - "Exception while putting key[{0}] for region {1} in iteration " + - "{2}: {3}", idx, m_region.Name, (count - offset), ex); - throw; - } - count++; - } - Interlocked.Add(ref m_iters, count - offset); - } - } - } - - public class CreatePutAllMap<TKey, TVal> : ClientTask - { - #region Private members - - private IRegion<TKey, TVal> m_region; - private TKey[] m_keys; - private Int32 m_cnt; - private Int32 m_size; - private string m_objectType; - private List<IDictionary<TKey, TVal>> m_maps; - private bool m_encodeKey; - private bool m_encodeTimestamp; - private bool m_isMainWorkLoad; - - #endregion - - public CreatePutAllMap(IRegion<TKey, TVal> region, TKey[] keys, Int32 size, string objectType, - List<IDictionary<TKey, TVal>> maps, bool encodeKey, bool encodeTimestamp, bool isMainWorkLoad) - : base() - { - m_region = region as IRegion<TKey, TVal>; - m_keys = keys as TKey[]; - m_cnt = 0; - m_size = size; - m_objectType = objectType; - m_maps = maps; - m_encodeKey = encodeKey; - m_encodeTimestamp = encodeTimestamp; - m_isMainWorkLoad = isMainWorkLoad; - } - - public override void DoTask(int iters, object data) - { - if (m_keys != null && m_keys.Length > 0) - { - Int32 localcnt = m_cnt; - Interlocked.Increment(ref m_cnt); - int numKeys = m_keys.Length; - int offset = Util.Rand(numKeys); - int count = offset; - IDictionary<TKey,TVal> hmoc = new Dictionary<TKey,TVal>(); - lock (m_maps) - { - m_maps.Add(hmoc); - } - Util.Log("CreatePutAllMap::DoTask: starting {0} iterations. size of map list {1}", iters,m_maps.Count); - while (Running && (iters-- != 0)) - { - int idx = count % numKeys; - try - { - TVal obj = ObjectHelper<TKey, TVal>.CreateObject(m_objectType, m_size, m_encodeKey, m_encodeTimestamp, 0, 0, 0); - //Util.Log("rjk CreatePutAllMap key[{0}] is {1}", idx, m_keys[idx]); - ((IDictionary<object,object>)(m_maps[localcnt])).Add(m_keys[idx], obj); - } - catch (Exception ex) - { - Util.Log(Util.LogLevel.Error, - "Exception while putting key[{0}] for region {1} in iteration " + - "{2}: {3}", idx, m_region.Name, (count - offset), ex); - throw; - } - count++; - } - Interlocked.Add(ref m_iters, count - offset); - } - } - } - - public class PutAllMap<TKey, TVal> : ClientTask - { - #region Private members - - private IRegion<TKey, TVal> m_region; - private TKey[] m_keys; - private Int32 m_cnt; - private Int32 m_size; - private string m_objectType; - private List<IDictionary<TKey, TVal>> m_maps; - private bool m_encodeKey; - private bool m_encodeTimestamp; - private bool m_isMainWorkLoad; - - - #endregion - - public PutAllMap(IRegion<TKey, TVal> region, TKey[] keys, Int32 size, string objectType, - List<IDictionary<TKey, TVal>> maps, bool encodeKey, bool encodeTimestamp, bool isMainWorkLoad) - : base() - { - m_region = region as IRegion<TKey, TVal>; - m_keys = keys as TKey[]; - m_cnt = 0; - m_size = size; - m_objectType = objectType; - m_maps = maps as List<IDictionary<TKey, TVal>>; - m_encodeKey = encodeKey; - m_encodeTimestamp = encodeTimestamp; - m_isMainWorkLoad = isMainWorkLoad; - } - - public override void DoTask(int iters, object data) - { - if (m_keys != null && m_keys.Length > 0) - { - Int32 localcnt = m_cnt; - Interlocked.Increment(ref m_cnt); - int numKeys = m_keys.Length; - int offset = Util.Rand(numKeys); - int count = offset; - long startTime; - Util.Log("PutAllMap::DoTask: starting {0} iterations. size of map list {1}", iters,m_maps.Count); - while (Running && (iters-- != 0)) - { - try - { - startTime = InitPerfStat.perfstat[localcnt].StartPut(); - /* - foreach (CacheableHashMap map in m_maps) - { - Util.Log("PutAllMap:: mape keys = {0} size ={1}", map.Keys,map.Count); - } - CacheableHashMap putAllmap; - lock (m_maps) - { - putAllmap = m_maps[localcnt]; - } - foreach (ICacheableKey key in putAllmap.Keys) - { - Util.Log("PutAllMap:: key = {0} ", key); - } - foreach (IGeodeSerializable val in putAllmap.Values) - { - Util.Log("PutAllMap:: value = {0} ", val); - } - - foreach (KeyValuePair<ICacheableKey, IGeodeSerializable> item in putAllmap) - { - Util.Log("PutAllMap:: key = {0} value = {1} localcont = {2}", item.Key, item.Value, localcnt); - } - */ - m_region.PutAll(m_maps[localcnt], 60); - InitPerfStat.perfstat[localcnt].EndPut(startTime, m_isMainWorkLoad); - - } - catch (Exception ex) - { - Util.Log(Util.LogLevel.Error, - "Exception while putAll map[{0}] for region {1} in iteration " + - "{2}: {3}", localcnt, m_region.Name, (count - offset), ex); - throw; - } - count++; - } - Interlocked.Add(ref m_iters, count - offset); - } - } - } - - public class UpdateDeltaTask<TKey, TVal> : ClientTask - { - #region Private members - - private IRegion<TKey, TVal> m_region; - private TKey[] m_keys; - private Int32 m_cnt; - private Int32 m_size; - private string m_objectType; - private bool m_encodeKey; - private bool m_encodeTimestamp; - private bool m_isMainWorkLoad; - private Int32 m_assetAcSize; - private Int32 m_assetmaxVal; - - #endregion - - public UpdateDeltaTask(IRegion<TKey, TVal> region, TKey[] keys, Int32 size, string objectType, - bool encodeKey, bool encodeTimestamp, bool isMainWorkLoad, Int32 assetACsize, Int32 assetMaxVal) - : base() - { - m_region = region as IRegion<TKey, TVal>; - m_keys = keys as TKey[]; - m_cnt = 0; - m_size = size; - m_objectType = objectType; - m_encodeKey = encodeKey; - m_encodeTimestamp = encodeTimestamp; - m_isMainWorkLoad = isMainWorkLoad; - m_assetAcSize = assetACsize; - m_assetmaxVal = assetMaxVal; - } - - public override void DoTask(int iters, object data) - { - if (m_keys != null && m_keys.Length > 0) - { - Int32 localcnt = m_cnt; - Interlocked.Increment(ref m_cnt); - int numKeys = m_keys.Length; - int offset = Util.Rand(numKeys); - int count = offset; - long startTime; - TVal obj = default(TVal); - Util.Log("UpdateDeltaTask::DoTask: starting {0} iterations.", iters); - while (Running && (iters-- != 0)) - { - int idx = count % numKeys; - startTime = InitPerfStat.perfstat[localcnt].StartUpdate(); - if (m_encodeKey) - { - obj = m_region[m_keys[idx]]; - if (obj == null) - { - string exStr = string.Format("Key[{0}] has not been created in region {1}", - m_keys[idx], m_region.Name); - Util.Log(Util.LogLevel.Error, exStr); - throw new EntryNotFoundException(exStr); - } - } - else { - obj = ObjectHelper<TKey, TVal>.CreateObject(m_objectType, m_size, m_encodeKey, m_encodeTimestamp, m_assetAcSize, m_assetmaxVal, idx); - } - DeltaFastAssetAccount obj1 = obj as DeltaFastAssetAccount; - if(obj1 == null) - { - DeltaPSTObject obj2 = obj as DeltaPSTObject; - if (obj2 == null) - { - m_region[m_keys[idx]] = obj; - } - else{ - obj2.Update(); - } - } - else - { - obj1.Update(); - } - InitPerfStat.perfstat[localcnt].EndUpdate(startTime, m_isMainWorkLoad); - count++; - } - Interlocked.Add(ref m_iters, count - offset); - } - } - } - -} http://git-wip-us.apache.org/repos/asf/geode-native/blob/da389793/src/tests/cli/PkcsWrapper/PkcsAuthInitMN.hpp ---------------------------------------------------------------------- diff --git a/src/tests/cli/PkcsWrapper/PkcsAuthInitMN.hpp b/src/tests/cli/PkcsWrapper/PkcsAuthInitMN.hpp index 249863a..bf8d665 100644 --- a/src/tests/cli/PkcsWrapper/PkcsAuthInitMN.hpp +++ b/src/tests/cli/PkcsWrapper/PkcsAuthInitMN.hpp @@ -20,6 +20,7 @@ #include <memory> #include "native_shared_ptr.hpp" #include "PkcsAuthInit.hpp" +//#include "IAuthInitialize.hpp" using namespace System; http://git-wip-us.apache.org/repos/asf/geode-native/blob/da389793/src/tests/cli/QueryHelper/QueryHelperN.cs ---------------------------------------------------------------------- diff --git a/src/tests/cli/QueryHelper/QueryHelperN.cs b/src/tests/cli/QueryHelper/QueryHelperN.cs index d1198a0..3f71876 100644 --- a/src/tests/cli/QueryHelper/QueryHelperN.cs +++ b/src/tests/cli/QueryHelper/QueryHelperN.cs @@ -36,7 +36,7 @@ namespace Apache.Geode.Client.Tests private int m_portfolioNumSets; private int m_positionSetSize; private int m_positionNumSets; - + private Cache m_cache; private static QueryHelper<TKey, TVal> m_instance = null; #endregion @@ -77,19 +77,20 @@ namespace Apache.Geode.Client.Tests #endregion - private QueryHelper() + private QueryHelper(Cache cache) { m_portfolioSetSize = 20; m_portfolioNumSets = 1; m_positionSetSize = 20; m_positionNumSets = 1; + m_cache = cache; } - public static QueryHelper<TKey, TVal> GetHelper() + public static QueryHelper<TKey, TVal> GetHelper(Cache cache) { if (m_instance == null) { - m_instance = new QueryHelper<TKey,TVal>(); + m_instance = new QueryHelper<TKey,TVal>(cache); } return m_instance; } @@ -459,8 +460,8 @@ namespace Apache.Geode.Client.Tests return false; } - DataOutput o1 = new DataOutput(); - DataOutput o2 = new DataOutput(); + DataOutput o1 = m_cache.CreateDataOutput(); + DataOutput o2 = m_cache.CreateDataOutput(); p1.ToData(o1); p2.ToData(o2); http://git-wip-us.apache.org/repos/asf/geode-native/blob/da389793/src/tests/cli/QueryHelper/QueryStringsM.cpp ---------------------------------------------------------------------- diff --git a/src/tests/cli/QueryHelper/QueryStringsM.cpp b/src/tests/cli/QueryHelper/QueryStringsM.cpp index aab1745..f00ac81 100644 --- a/src/tests/cli/QueryHelper/QueryStringsM.cpp +++ b/src/tests/cli/QueryHelper/QueryStringsM.cpp @@ -15,10 +15,6 @@ * limitations under the License. */ -#include "begin_native.hpp" -#include <memory> -#include "end_native.hpp" - #include "QueryStringsM.hpp" #include "impl/ManagedString.hpp" http://git-wip-us.apache.org/repos/asf/geode-native/blob/da389793/src/tests/cpp/fwklib/FrameworkTest.cpp ---------------------------------------------------------------------- diff --git a/src/tests/cpp/fwklib/FrameworkTest.cpp b/src/tests/cpp/fwklib/FrameworkTest.cpp index d2af77f..1a1994d 100644 --- a/src/tests/cpp/fwklib/FrameworkTest.cpp +++ b/src/tests/cpp/fwklib/FrameworkTest.cpp @@ -338,7 +338,7 @@ void FrameworkTest::localDestroyRegion(RegionPtr& region) { void FrameworkTest::parseEndPoints(int32_t ep, std::string label, bool isServer) { std::string poolName = "_Test_Pool"; - PoolFactoryPtr pfPtr = PoolManager::createFactory(); + PoolFactoryPtr pfPtr = m_cache->getPoolManager().createFactory(); std::string tag = getStringValue("TAG"); std::string bb("GFE_BB"); @@ -402,14 +402,14 @@ void FrameworkTest::parseEndPoints(int32_t ep, std::string label, if (!tag.empty()) { poolName.append(tag); // check if pool already exists - pptr = PoolManager::find(poolName.c_str()); + pptr = m_cache->getPoolManager().find(poolName.c_str()); if (pptr == nullptr) { pptr = pfPtr->create(poolName.c_str()); } } // create default pool else { - pptr = PoolManager::find(poolName.c_str()); + pptr = m_cache->getPoolManager().find(poolName.c_str()); if (pptr == nullptr) { pptr = pfPtr->create(poolName.c_str()); } @@ -444,12 +444,12 @@ void FrameworkTest::createPool() { } QueryServicePtr FrameworkTest::checkQueryService() { - PoolFactoryPtr pfPtr = PoolManager::createFactory(); + PoolFactoryPtr pfPtr = m_cache->getPoolManager().createFactory(); std::string bb("GFE_BB"); std::string keys("testScheme"); std::string mode = bbGetString(bb, keys); if (mode == "poolwithendpoints" || mode == "poolwithlocator") { - PoolPtr pool = PoolManager::find("_Test_Pool"); + PoolPtr pool = m_cache->getPoolManager().find("_Test_Pool"); return pool->getQueryService(); } else { return m_cache->getQueryService(); http://git-wip-us.apache.org/repos/asf/geode-native/blob/da389793/src/tests/cpp/fwklib/FwkObjects.cpp ---------------------------------------------------------------------- diff --git a/src/tests/cpp/fwklib/FwkObjects.cpp b/src/tests/cpp/fwklib/FwkObjects.cpp index 374f296..adbb754 100644 --- a/src/tests/cpp/fwklib/FwkObjects.cpp +++ b/src/tests/cpp/fwklib/FwkObjects.cpp @@ -576,7 +576,10 @@ Attributes::Attributes(const DOMNode* node) FwkPool::FwkPool(const DOMNode* node) : m_locators(false), m_servers(false) { // Init Factory - m_poolFactory = PoolManager::createFactory(); + auto cacheFactory = CacheFactory::createCacheFactory(); + m_cache = cacheFactory->create(); + m_poolManager = new PoolManager(*m_cache); + m_poolFactory = m_poolManager->createFactory(); // Set Attrs to Pool setAttributesToFactory(node);