diff options
Diffstat (limited to '')
-rw-r--r-- | ThirdParty/SmartThreadPool/STPPerformanceCounter.cs | 606 |
1 files changed, 303 insertions, 303 deletions
diff --git a/ThirdParty/SmartThreadPool/STPPerformanceCounter.cs b/ThirdParty/SmartThreadPool/STPPerformanceCounter.cs index 0663d1d..bd68499 100644 --- a/ThirdParty/SmartThreadPool/STPPerformanceCounter.cs +++ b/ThirdParty/SmartThreadPool/STPPerformanceCounter.cs | |||
@@ -26,188 +26,188 @@ namespace Amib.Threading.Internal | |||
26 | #if !(_WINDOWS_CE) && !(_SILVERLIGHT) && !(WINDOWS_PHONE) | 26 | #if !(_WINDOWS_CE) && !(_SILVERLIGHT) && !(WINDOWS_PHONE) |
27 | 27 | ||
28 | internal enum STPPerformanceCounterType | 28 | internal enum STPPerformanceCounterType |
29 | { | 29 | { |
30 | // Fields | 30 | // Fields |
31 | ActiveThreads = 0, | 31 | ActiveThreads = 0, |
32 | InUseThreads = 1, | 32 | InUseThreads = 1, |
33 | OverheadThreads = 2, | 33 | OverheadThreads = 2, |
34 | OverheadThreadsPercent = 3, | 34 | OverheadThreadsPercent = 3, |
35 | OverheadThreadsPercentBase = 4, | 35 | OverheadThreadsPercentBase = 4, |
36 | 36 | ||
37 | WorkItems = 5, | 37 | WorkItems = 5, |
38 | WorkItemsInQueue = 6, | 38 | WorkItemsInQueue = 6, |
39 | WorkItemsProcessed = 7, | 39 | WorkItemsProcessed = 7, |
40 | 40 | ||
41 | WorkItemsQueuedPerSecond = 8, | 41 | WorkItemsQueuedPerSecond = 8, |
42 | WorkItemsProcessedPerSecond = 9, | 42 | WorkItemsProcessedPerSecond = 9, |
43 | 43 | ||
44 | AvgWorkItemWaitTime = 10, | 44 | AvgWorkItemWaitTime = 10, |
45 | AvgWorkItemWaitTimeBase = 11, | 45 | AvgWorkItemWaitTimeBase = 11, |
46 | 46 | ||
47 | AvgWorkItemProcessTime = 12, | 47 | AvgWorkItemProcessTime = 12, |
48 | AvgWorkItemProcessTimeBase = 13, | 48 | AvgWorkItemProcessTimeBase = 13, |
49 | 49 | ||
50 | WorkItemsGroups = 14, | 50 | WorkItemsGroups = 14, |
51 | 51 | ||
52 | LastCounter = 14, | 52 | LastCounter = 14, |
53 | } | 53 | } |
54 | 54 | ||
55 | 55 | ||
56 | /// <summary> | 56 | /// <summary> |
57 | /// Summary description for STPPerformanceCounter. | 57 | /// Summary description for STPPerformanceCounter. |
58 | /// </summary> | 58 | /// </summary> |
59 | internal class STPPerformanceCounter | 59 | internal class STPPerformanceCounter |
60 | { | 60 | { |
61 | // Fields | 61 | // Fields |
62 | private readonly PerformanceCounterType _pcType; | 62 | private readonly PerformanceCounterType _pcType; |
63 | protected string _counterHelp; | 63 | protected string _counterHelp; |
64 | protected string _counterName; | 64 | protected string _counterName; |
65 | 65 | ||
66 | // Methods | 66 | // Methods |
67 | public STPPerformanceCounter( | 67 | public STPPerformanceCounter( |
68 | string counterName, | 68 | string counterName, |
69 | string counterHelp, | 69 | string counterHelp, |
70 | PerformanceCounterType pcType) | 70 | PerformanceCounterType pcType) |
71 | { | 71 | { |
72 | _counterName = counterName; | 72 | _counterName = counterName; |
73 | _counterHelp = counterHelp; | 73 | _counterHelp = counterHelp; |
74 | _pcType = pcType; | 74 | _pcType = pcType; |
75 | } | 75 | } |
76 | 76 | ||
77 | public void AddCounterToCollection(CounterCreationDataCollection counterData) | 77 | public void AddCounterToCollection(CounterCreationDataCollection counterData) |
78 | { | 78 | { |
79 | CounterCreationData counterCreationData = new CounterCreationData( | 79 | CounterCreationData counterCreationData = new CounterCreationData( |
80 | _counterName, | 80 | _counterName, |
81 | _counterHelp, | 81 | _counterHelp, |
82 | _pcType); | 82 | _pcType); |
83 | 83 | ||
84 | counterData.Add(counterCreationData); | 84 | counterData.Add(counterCreationData); |
85 | } | 85 | } |
86 | 86 | ||
87 | // Properties | 87 | // Properties |
88 | public string Name | 88 | public string Name |
89 | { | 89 | { |
90 | get | 90 | get |
91 | { | 91 | { |
92 | return _counterName; | 92 | return _counterName; |
93 | } | 93 | } |
94 | } | 94 | } |
95 | } | 95 | } |
96 | 96 | ||
97 | internal class STPPerformanceCounters | 97 | internal class STPPerformanceCounters |
98 | { | 98 | { |
99 | // Fields | 99 | // Fields |
100 | internal STPPerformanceCounter[] _stpPerformanceCounters; | 100 | internal STPPerformanceCounter[] _stpPerformanceCounters; |
101 | private static readonly STPPerformanceCounters _instance; | 101 | private static readonly STPPerformanceCounters _instance; |
102 | internal const string _stpCategoryHelp = "SmartThreadPool performance counters"; | 102 | internal const string _stpCategoryHelp = "SmartThreadPool performance counters"; |
103 | internal const string _stpCategoryName = "SmartThreadPool"; | 103 | internal const string _stpCategoryName = "SmartThreadPool"; |
104 | 104 | ||
105 | // Methods | 105 | // Methods |
106 | static STPPerformanceCounters() | 106 | static STPPerformanceCounters() |
107 | { | 107 | { |
108 | _instance = new STPPerformanceCounters(); | 108 | _instance = new STPPerformanceCounters(); |
109 | } | 109 | } |
110 | 110 | ||
111 | private STPPerformanceCounters() | 111 | private STPPerformanceCounters() |
112 | { | 112 | { |
113 | STPPerformanceCounter[] stpPerformanceCounters = new STPPerformanceCounter[] | 113 | STPPerformanceCounter[] stpPerformanceCounters = new STPPerformanceCounter[] |
114 | { | 114 | { |
115 | new STPPerformanceCounter("Active threads", "The current number of available in the thread pool.", PerformanceCounterType.NumberOfItems32), | 115 | new STPPerformanceCounter("Active threads", "The current number of available in the thread pool.", PerformanceCounterType.NumberOfItems32), |
116 | new STPPerformanceCounter("In use threads", "The current number of threads that execute a work item.", PerformanceCounterType.NumberOfItems32), | 116 | new STPPerformanceCounter("In use threads", "The current number of threads that execute a work item.", PerformanceCounterType.NumberOfItems32), |
117 | new STPPerformanceCounter("Overhead threads", "The current number of threads that are active, but are not in use.", PerformanceCounterType.NumberOfItems32), | 117 | new STPPerformanceCounter("Overhead threads", "The current number of threads that are active, but are not in use.", PerformanceCounterType.NumberOfItems32), |
118 | new STPPerformanceCounter("% overhead threads", "The current number of threads that are active, but are not in use in percents.", PerformanceCounterType.RawFraction), | 118 | new STPPerformanceCounter("% overhead threads", "The current number of threads that are active, but are not in use in percents.", PerformanceCounterType.RawFraction), |
119 | new STPPerformanceCounter("% overhead threads base", "The current number of threads that are active, but are not in use in percents.", PerformanceCounterType.RawBase), | 119 | new STPPerformanceCounter("% overhead threads base", "The current number of threads that are active, but are not in use in percents.", PerformanceCounterType.RawBase), |
120 | 120 | ||
121 | new STPPerformanceCounter("Work Items", "The number of work items in the Smart Thread Pool. Both queued and processed.", PerformanceCounterType.NumberOfItems32), | 121 | new STPPerformanceCounter("Work Items", "The number of work items in the Smart Thread Pool. Both queued and processed.", PerformanceCounterType.NumberOfItems32), |
122 | new STPPerformanceCounter("Work Items in queue", "The current number of work items in the queue", PerformanceCounterType.NumberOfItems32), | 122 | new STPPerformanceCounter("Work Items in queue", "The current number of work items in the queue", PerformanceCounterType.NumberOfItems32), |
123 | new STPPerformanceCounter("Work Items processed", "The number of work items already processed", PerformanceCounterType.NumberOfItems32), | 123 | new STPPerformanceCounter("Work Items processed", "The number of work items already processed", PerformanceCounterType.NumberOfItems32), |
124 | 124 | ||
125 | new STPPerformanceCounter("Work Items queued/sec", "The number of work items queued per second", PerformanceCounterType.RateOfCountsPerSecond32), | 125 | new STPPerformanceCounter("Work Items queued/sec", "The number of work items queued per second", PerformanceCounterType.RateOfCountsPerSecond32), |
126 | new STPPerformanceCounter("Work Items processed/sec", "The number of work items processed per second", PerformanceCounterType.RateOfCountsPerSecond32), | 126 | new STPPerformanceCounter("Work Items processed/sec", "The number of work items processed per second", PerformanceCounterType.RateOfCountsPerSecond32), |
127 | 127 | ||
128 | new STPPerformanceCounter("Avg. Work Item wait time/sec", "The average time a work item supends in the queue waiting for its turn to execute.", PerformanceCounterType.AverageCount64), | 128 | new STPPerformanceCounter("Avg. Work Item wait time/sec", "The average time a work item supends in the queue waiting for its turn to execute.", PerformanceCounterType.AverageCount64), |
129 | new STPPerformanceCounter("Avg. Work Item wait time base", "The average time a work item supends in the queue waiting for its turn to execute.", PerformanceCounterType.AverageBase), | 129 | new STPPerformanceCounter("Avg. Work Item wait time base", "The average time a work item supends in the queue waiting for its turn to execute.", PerformanceCounterType.AverageBase), |
130 | 130 | ||
131 | new STPPerformanceCounter("Avg. Work Item process time/sec", "The average time it takes to process a work item.", PerformanceCounterType.AverageCount64), | 131 | new STPPerformanceCounter("Avg. Work Item process time/sec", "The average time it takes to process a work item.", PerformanceCounterType.AverageCount64), |
132 | new STPPerformanceCounter("Avg. Work Item process time base", "The average time it takes to process a work item.", PerformanceCounterType.AverageBase), | 132 | new STPPerformanceCounter("Avg. Work Item process time base", "The average time it takes to process a work item.", PerformanceCounterType.AverageBase), |
133 | 133 | ||
134 | new STPPerformanceCounter("Work Items Groups", "The current number of work item groups associated with the Smart Thread Pool.", PerformanceCounterType.NumberOfItems32), | 134 | new STPPerformanceCounter("Work Items Groups", "The current number of work item groups associated with the Smart Thread Pool.", PerformanceCounterType.NumberOfItems32), |
135 | }; | 135 | }; |
136 | 136 | ||
137 | _stpPerformanceCounters = stpPerformanceCounters; | 137 | _stpPerformanceCounters = stpPerformanceCounters; |
138 | SetupCategory(); | 138 | SetupCategory(); |
139 | } | 139 | } |
140 | 140 | ||
141 | private void SetupCategory() | 141 | private void SetupCategory() |
142 | { | 142 | { |
143 | if (!PerformanceCounterCategory.Exists(_stpCategoryName)) | 143 | if (!PerformanceCounterCategory.Exists(_stpCategoryName)) |
144 | { | 144 | { |
145 | CounterCreationDataCollection counters = new CounterCreationDataCollection(); | 145 | CounterCreationDataCollection counters = new CounterCreationDataCollection(); |
146 | 146 | ||
147 | for (int i = 0; i < _stpPerformanceCounters.Length; i++) | 147 | for (int i = 0; i < _stpPerformanceCounters.Length; i++) |
148 | { | 148 | { |
149 | _stpPerformanceCounters[i].AddCounterToCollection(counters); | 149 | _stpPerformanceCounters[i].AddCounterToCollection(counters); |
150 | } | 150 | } |
151 | 151 | ||
152 | PerformanceCounterCategory.Create( | 152 | PerformanceCounterCategory.Create( |
153 | _stpCategoryName, | 153 | _stpCategoryName, |
154 | _stpCategoryHelp, | 154 | _stpCategoryHelp, |
155 | PerformanceCounterCategoryType.MultiInstance, | 155 | PerformanceCounterCategoryType.MultiInstance, |
156 | counters); | 156 | counters); |
157 | 157 | ||
158 | } | 158 | } |
159 | } | 159 | } |
160 | 160 | ||
161 | // Properties | 161 | // Properties |
162 | public static STPPerformanceCounters Instance | 162 | public static STPPerformanceCounters Instance |
163 | { | 163 | { |
164 | get | 164 | get |
165 | { | 165 | { |
166 | return _instance; | 166 | return _instance; |
167 | } | 167 | } |
168 | } | 168 | } |
169 | } | 169 | } |
170 | 170 | ||
171 | internal class STPInstancePerformanceCounter : IDisposable | 171 | internal class STPInstancePerformanceCounter : IDisposable |
172 | { | 172 | { |
173 | // Fields | 173 | // Fields |
174 | private bool _isDisposed; | 174 | private bool _isDisposed; |
175 | private PerformanceCounter _pcs; | 175 | private PerformanceCounter _pcs; |
176 | 176 | ||
177 | // Methods | 177 | // Methods |
178 | protected STPInstancePerformanceCounter() | 178 | protected STPInstancePerformanceCounter() |
179 | { | 179 | { |
180 | _isDisposed = false; | 180 | _isDisposed = false; |
181 | } | 181 | } |
182 | 182 | ||
183 | public STPInstancePerformanceCounter( | 183 | public STPInstancePerformanceCounter( |
184 | string instance, | 184 | string instance, |
185 | STPPerformanceCounterType spcType) : this() | 185 | STPPerformanceCounterType spcType) : this() |
186 | { | 186 | { |
187 | STPPerformanceCounters counters = STPPerformanceCounters.Instance; | 187 | STPPerformanceCounters counters = STPPerformanceCounters.Instance; |
188 | _pcs = new PerformanceCounter( | 188 | _pcs = new PerformanceCounter( |
189 | STPPerformanceCounters._stpCategoryName, | 189 | STPPerformanceCounters._stpCategoryName, |
190 | counters._stpPerformanceCounters[(int) spcType].Name, | 190 | counters._stpPerformanceCounters[(int) spcType].Name, |
191 | instance, | 191 | instance, |
192 | false); | 192 | false); |
193 | _pcs.RawValue = _pcs.RawValue; | 193 | _pcs.RawValue = _pcs.RawValue; |
194 | } | 194 | } |
195 | 195 | ||
196 | 196 | ||
197 | public void Close() | 197 | public void Close() |
198 | { | 198 | { |
199 | if (_pcs != null) | 199 | if (_pcs != null) |
200 | { | 200 | { |
201 | _pcs.RemoveInstance(); | 201 | _pcs.RemoveInstance(); |
202 | _pcs.Close(); | 202 | _pcs.Close(); |
203 | _pcs = null; | 203 | _pcs = null; |
204 | } | 204 | } |
205 | } | 205 | } |
206 | 206 | ||
207 | public void Dispose() | 207 | public void Dispose() |
208 | { | 208 | { |
209 | Dispose(true); | 209 | Dispose(true); |
210 | } | 210 | } |
211 | 211 | ||
212 | public virtual void Dispose(bool disposing) | 212 | public virtual void Dispose(bool disposing) |
213 | { | 213 | { |
@@ -220,90 +220,90 @@ namespace Amib.Threading.Internal | |||
220 | } | 220 | } |
221 | _isDisposed = true; | 221 | _isDisposed = true; |
222 | } | 222 | } |
223 | 223 | ||
224 | public virtual void Increment() | 224 | public virtual void Increment() |
225 | { | 225 | { |
226 | _pcs.Increment(); | 226 | _pcs.Increment(); |
227 | } | 227 | } |
228 | 228 | ||
229 | public virtual void IncrementBy(long val) | 229 | public virtual void IncrementBy(long val) |
230 | { | 230 | { |
231 | _pcs.IncrementBy(val); | 231 | _pcs.IncrementBy(val); |
232 | } | 232 | } |
233 | 233 | ||
234 | public virtual void Set(long val) | 234 | public virtual void Set(long val) |
235 | { | 235 | { |
236 | _pcs.RawValue = val; | 236 | _pcs.RawValue = val; |
237 | } | 237 | } |
238 | } | 238 | } |
239 | 239 | ||
240 | internal class STPInstanceNullPerformanceCounter : STPInstancePerformanceCounter | 240 | internal class STPInstanceNullPerformanceCounter : STPInstancePerformanceCounter |
241 | { | 241 | { |
242 | // Methods | 242 | // Methods |
243 | public override void Increment() {} | 243 | public override void Increment() {} |
244 | public override void IncrementBy(long value) {} | 244 | public override void IncrementBy(long value) {} |
245 | public override void Set(long val) {} | 245 | public override void Set(long val) {} |
246 | } | 246 | } |
247 | 247 | ||
248 | 248 | ||
249 | 249 | ||
250 | internal class STPInstancePerformanceCounters : ISTPInstancePerformanceCounters | 250 | internal class STPInstancePerformanceCounters : ISTPInstancePerformanceCounters |
251 | { | 251 | { |
252 | private bool _isDisposed; | 252 | private bool _isDisposed; |
253 | // Fields | 253 | // Fields |
254 | private STPInstancePerformanceCounter[] _pcs; | 254 | private STPInstancePerformanceCounter[] _pcs; |
255 | private static readonly STPInstancePerformanceCounter _stpInstanceNullPerformanceCounter; | 255 | private static readonly STPInstancePerformanceCounter _stpInstanceNullPerformanceCounter; |
256 | 256 | ||
257 | // Methods | 257 | // Methods |
258 | static STPInstancePerformanceCounters() | 258 | static STPInstancePerformanceCounters() |
259 | { | 259 | { |
260 | _stpInstanceNullPerformanceCounter = new STPInstanceNullPerformanceCounter(); | 260 | _stpInstanceNullPerformanceCounter = new STPInstanceNullPerformanceCounter(); |
261 | } | 261 | } |
262 | 262 | ||
263 | public STPInstancePerformanceCounters(string instance) | 263 | public STPInstancePerformanceCounters(string instance) |
264 | { | 264 | { |
265 | _isDisposed = false; | 265 | _isDisposed = false; |
266 | _pcs = new STPInstancePerformanceCounter[(int)STPPerformanceCounterType.LastCounter]; | 266 | _pcs = new STPInstancePerformanceCounter[(int)STPPerformanceCounterType.LastCounter]; |
267 | 267 | ||
268 | // Call the STPPerformanceCounters.Instance so the static constructor will | 268 | // Call the STPPerformanceCounters.Instance so the static constructor will |
269 | // intialize the STPPerformanceCounters singleton. | 269 | // intialize the STPPerformanceCounters singleton. |
270 | STPPerformanceCounters.Instance.GetHashCode(); | 270 | STPPerformanceCounters.Instance.GetHashCode(); |
271 | 271 | ||
272 | for (int i = 0; i < _pcs.Length; i++) | 272 | for (int i = 0; i < _pcs.Length; i++) |
273 | { | 273 | { |
274 | if (instance != null) | 274 | if (instance != null) |
275 | { | 275 | { |
276 | _pcs[i] = new STPInstancePerformanceCounter( | 276 | _pcs[i] = new STPInstancePerformanceCounter( |
277 | instance, | 277 | instance, |
278 | (STPPerformanceCounterType) i); | 278 | (STPPerformanceCounterType) i); |
279 | } | 279 | } |
280 | else | 280 | else |
281 | { | 281 | { |
282 | _pcs[i] = _stpInstanceNullPerformanceCounter; | 282 | _pcs[i] = _stpInstanceNullPerformanceCounter; |
283 | } | 283 | } |
284 | } | 284 | } |
285 | } | 285 | } |
286 | 286 | ||
287 | 287 | ||
288 | public void Close() | 288 | public void Close() |
289 | { | 289 | { |
290 | if (null != _pcs) | 290 | if (null != _pcs) |
291 | { | 291 | { |
292 | for (int i = 0; i < _pcs.Length; i++) | 292 | for (int i = 0; i < _pcs.Length; i++) |
293 | { | 293 | { |
294 | if (null != _pcs[i]) | 294 | if (null != _pcs[i]) |
295 | { | 295 | { |
296 | _pcs[i].Dispose(); | 296 | _pcs[i].Dispose(); |
297 | } | 297 | } |
298 | } | 298 | } |
299 | _pcs = null; | 299 | _pcs = null; |
300 | } | 300 | } |
301 | } | 301 | } |
302 | 302 | ||
303 | public void Dispose() | 303 | public void Dispose() |
304 | { | 304 | { |
305 | Dispose(true); | 305 | Dispose(true); |
306 | } | 306 | } |
307 | 307 | ||
308 | public virtual void Dispose(bool disposing) | 308 | public virtual void Dispose(bool disposing) |
309 | { | 309 | { |
@@ -316,62 +316,62 @@ namespace Amib.Threading.Internal | |||
316 | } | 316 | } |
317 | _isDisposed = true; | 317 | _isDisposed = true; |
318 | } | 318 | } |
319 | 319 | ||
320 | private STPInstancePerformanceCounter GetCounter(STPPerformanceCounterType spcType) | 320 | private STPInstancePerformanceCounter GetCounter(STPPerformanceCounterType spcType) |
321 | { | 321 | { |
322 | return _pcs[(int) spcType]; | 322 | return _pcs[(int) spcType]; |
323 | } | 323 | } |
324 | 324 | ||
325 | public void SampleThreads(long activeThreads, long inUseThreads) | 325 | public void SampleThreads(long activeThreads, long inUseThreads) |
326 | { | 326 | { |
327 | GetCounter(STPPerformanceCounterType.ActiveThreads).Set(activeThreads); | 327 | GetCounter(STPPerformanceCounterType.ActiveThreads).Set(activeThreads); |
328 | GetCounter(STPPerformanceCounterType.InUseThreads).Set(inUseThreads); | 328 | GetCounter(STPPerformanceCounterType.InUseThreads).Set(inUseThreads); |
329 | GetCounter(STPPerformanceCounterType.OverheadThreads).Set(activeThreads-inUseThreads); | 329 | GetCounter(STPPerformanceCounterType.OverheadThreads).Set(activeThreads-inUseThreads); |
330 | 330 | ||
331 | GetCounter(STPPerformanceCounterType.OverheadThreadsPercentBase).Set(activeThreads-inUseThreads); | 331 | GetCounter(STPPerformanceCounterType.OverheadThreadsPercentBase).Set(activeThreads-inUseThreads); |
332 | GetCounter(STPPerformanceCounterType.OverheadThreadsPercent).Set(inUseThreads); | 332 | GetCounter(STPPerformanceCounterType.OverheadThreadsPercent).Set(inUseThreads); |
333 | } | 333 | } |
334 | 334 | ||
335 | public void SampleWorkItems(long workItemsQueued, long workItemsProcessed) | 335 | public void SampleWorkItems(long workItemsQueued, long workItemsProcessed) |
336 | { | 336 | { |
337 | GetCounter(STPPerformanceCounterType.WorkItems).Set(workItemsQueued+workItemsProcessed); | 337 | GetCounter(STPPerformanceCounterType.WorkItems).Set(workItemsQueued+workItemsProcessed); |
338 | GetCounter(STPPerformanceCounterType.WorkItemsInQueue).Set(workItemsQueued); | 338 | GetCounter(STPPerformanceCounterType.WorkItemsInQueue).Set(workItemsQueued); |
339 | GetCounter(STPPerformanceCounterType.WorkItemsProcessed).Set(workItemsProcessed); | 339 | GetCounter(STPPerformanceCounterType.WorkItemsProcessed).Set(workItemsProcessed); |
340 | 340 | ||
341 | GetCounter(STPPerformanceCounterType.WorkItemsQueuedPerSecond).Set(workItemsQueued); | 341 | GetCounter(STPPerformanceCounterType.WorkItemsQueuedPerSecond).Set(workItemsQueued); |
342 | GetCounter(STPPerformanceCounterType.WorkItemsProcessedPerSecond).Set(workItemsProcessed); | 342 | GetCounter(STPPerformanceCounterType.WorkItemsProcessedPerSecond).Set(workItemsProcessed); |
343 | } | 343 | } |
344 | 344 | ||
345 | public void SampleWorkItemsWaitTime(TimeSpan workItemWaitTime) | 345 | public void SampleWorkItemsWaitTime(TimeSpan workItemWaitTime) |
346 | { | 346 | { |
347 | GetCounter(STPPerformanceCounterType.AvgWorkItemWaitTime).IncrementBy((long)workItemWaitTime.TotalMilliseconds); | 347 | GetCounter(STPPerformanceCounterType.AvgWorkItemWaitTime).IncrementBy((long)workItemWaitTime.TotalMilliseconds); |
348 | GetCounter(STPPerformanceCounterType.AvgWorkItemWaitTimeBase).Increment(); | 348 | GetCounter(STPPerformanceCounterType.AvgWorkItemWaitTimeBase).Increment(); |
349 | } | 349 | } |
350 | 350 | ||
351 | public void SampleWorkItemsProcessTime(TimeSpan workItemProcessTime) | 351 | public void SampleWorkItemsProcessTime(TimeSpan workItemProcessTime) |
352 | { | 352 | { |
353 | GetCounter(STPPerformanceCounterType.AvgWorkItemProcessTime).IncrementBy((long)workItemProcessTime.TotalMilliseconds); | 353 | GetCounter(STPPerformanceCounterType.AvgWorkItemProcessTime).IncrementBy((long)workItemProcessTime.TotalMilliseconds); |
354 | GetCounter(STPPerformanceCounterType.AvgWorkItemProcessTimeBase).Increment(); | 354 | GetCounter(STPPerformanceCounterType.AvgWorkItemProcessTimeBase).Increment(); |
355 | } | 355 | } |
356 | } | 356 | } |
357 | #endif | 357 | #endif |
358 | 358 | ||
359 | internal class NullSTPInstancePerformanceCounters : ISTPInstancePerformanceCounters, ISTPPerformanceCountersReader | 359 | internal class NullSTPInstancePerformanceCounters : ISTPInstancePerformanceCounters, ISTPPerformanceCountersReader |
360 | { | 360 | { |
361 | private static readonly NullSTPInstancePerformanceCounters _instance = new NullSTPInstancePerformanceCounters(); | 361 | private static readonly NullSTPInstancePerformanceCounters _instance = new NullSTPInstancePerformanceCounters(); |
362 | 362 | ||
363 | public static NullSTPInstancePerformanceCounters Instance | 363 | public static NullSTPInstancePerformanceCounters Instance |
364 | { | 364 | { |
365 | get { return _instance; } | 365 | get { return _instance; } |
366 | } | 366 | } |
367 | 367 | ||
368 | public void Close() {} | 368 | public void Close() {} |
369 | public void Dispose() {} | 369 | public void Dispose() {} |
370 | 370 | ||
371 | public void SampleThreads(long activeThreads, long inUseThreads) {} | 371 | public void SampleThreads(long activeThreads, long inUseThreads) {} |
372 | public void SampleWorkItems(long workItemsQueued, long workItemsProcessed) {} | 372 | public void SampleWorkItems(long workItemsQueued, long workItemsProcessed) {} |
373 | public void SampleWorkItemsWaitTime(TimeSpan workItemWaitTime) {} | 373 | public void SampleWorkItemsWaitTime(TimeSpan workItemWaitTime) {} |
374 | public void SampleWorkItemsProcessTime(TimeSpan workItemProcessTime) {} | 374 | public void SampleWorkItemsProcessTime(TimeSpan workItemProcessTime) {} |
375 | public long InUseThreads | 375 | public long InUseThreads |
376 | { | 376 | { |
377 | get { return 0; } | 377 | get { return 0; } |
@@ -391,7 +391,7 @@ namespace Amib.Threading.Internal | |||
391 | { | 391 | { |
392 | get { return 0; } | 392 | get { return 0; } |
393 | } | 393 | } |
394 | } | 394 | } |
395 | 395 | ||
396 | internal class LocalSTPInstancePerformanceCounters : ISTPInstancePerformanceCounters, ISTPPerformanceCountersReader | 396 | internal class LocalSTPInstancePerformanceCounters : ISTPInstancePerformanceCounters, ISTPPerformanceCountersReader |
397 | { | 397 | { |