blob: 4dd1a988c7a83f7a57174448477ad280bb7a605a (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
|
// **********************************************************************
//
// Copyright (c) 2003-2013 ZeroC, Inc. All rights reserved.
//
// This copy of Ice is licensed to you under the terms described in the
// ICE_LICENSE file included in this distribution.
//
// **********************************************************************
package IceMX;
import IceInternal.MetricsMap;
public class Observer<T extends Metrics> extends IceUtilInternal.StopWatch implements Ice.Instrumentation.Observer
{
public interface MetricsUpdate<T>
{
void update(T m);
};
public void
attach()
{
if(!isStarted())
{
start();
}
}
public void
detach()
{
long lifetime = _previousDelay + stop();
for(MetricsMap<T>.Entry e : _objects)
{
e.detach(lifetime);
}
}
public void
failed(String exceptionName)
{
for(MetricsMap<T>.Entry e : _objects)
{
e.failed(exceptionName);
}
}
public void
forEach(MetricsUpdate<T> u)
{
for(MetricsMap<T>.Entry e : _objects)
{
e.execute(u);
}
}
public void
init(MetricsHelper<T> helper, java.util.List<MetricsMap<T>.Entry> objects, Observer<T> previous)
{
_objects = objects;
if(previous == null)
{
return;
}
_previousDelay = previous._previousDelay + previous.delay();
//
// Detach entries from previous observer which are no longer
// attached to this new observer.
//
for(MetricsMap<T>.Entry p : previous._objects)
{
if(!_objects.contains(p))
{
p.detach(_previousDelay);
}
}
}
public <S extends Metrics, ObserverImpl extends Observer<S>> ObserverImpl
getObserver(String mapName, MetricsHelper<S> helper, Class<S> mcl, Class<ObserverImpl> ocl)
{
java.util.List<MetricsMap<S>.Entry> metricsObjects = null;
for(MetricsMap<T>.Entry entry : _objects)
{
MetricsMap<S>.Entry e = entry.getMatching(mapName, helper, mcl);
if(e != null)
{
if(metricsObjects == null)
{
metricsObjects = new java.util.ArrayList<MetricsMap<S>.Entry>(_objects.size());
}
metricsObjects.add(e);
}
}
if(metricsObjects == null)
{
return null;
}
try
{
ObserverImpl obsv = ocl.newInstance();
obsv.init(helper, metricsObjects, null);
return obsv;
}
catch(Exception ex)
{
assert(false);
return null;
}
}
public MetricsMap<T>.Entry
getEntry(MetricsMap map)
{
for(MetricsMap<T>.Entry e : _objects)
{
if(e.getMap() == map)
{
return e;
}
}
return null;
}
private java.util.List<MetricsMap<T>.Entry> _objects;
private long _previousDelay = 0;
};
|
