#2303

Build # #2303

Build Type

push

Committed by

Commit Message

Merge pull request #771 from apache/SCB-2727

SCB-2727 Using integrity to verify the js and css files

Run Details

4056 of 4957 relevant lines covered (81.82%)

1.29 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

98.8

/alpha/alpha-core/src/main/java/org/apache/servicecomb/pack/alpha/core/metrics/MetricsBean.java

/*
 * 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.
 */

package org.apache.servicecomb.pack.alpha.core.metrics;

import com.google.common.util.concurrent.AtomicDouble;
import java.util.concurrent.atomic.AtomicLong;

public class MetricsBean {

  private AtomicLong eventReceived = new AtomicLong();
  private AtomicLong eventAccepted = new AtomicLong();
  private AtomicLong eventRejected = new AtomicLong();
  private AtomicDouble eventAvgTime = new AtomicDouble();//milliseconds moving average
  private AtomicLong actorReceived = new AtomicLong();
  private AtomicLong actorAccepted = new AtomicLong();
  private AtomicLong actorRejected = new AtomicLong();
  private AtomicDouble actorAvgTime = new AtomicDouble();//milliseconds moving average
  private AtomicLong sagaBeginCounter = new AtomicLong();
  private AtomicLong sagaEndCounter = new AtomicLong();
  private AtomicDouble sagaAvgTime = new AtomicDouble();//milliseconds moving average
  private AtomicLong committed = new AtomicLong();
  private AtomicLong compensated = new AtomicLong();
  private AtomicLong suspended = new AtomicLong();
  private AtomicLong repositoryReceived = new AtomicLong();
  private AtomicLong repositoryAccepted = new AtomicLong();
  private AtomicLong repositoryRejected = new AtomicLong();
  private AtomicDouble repositoryAvgTime = new AtomicDouble();//milliseconds moving average

  public void doEventReceived() {
    eventReceived.incrementAndGet();
  }

  public void doEventAccepted() {
    eventAccepted.incrementAndGet();
  }

  public void doEventRejected() {
    eventRejected.incrementAndGet();
  }

  public void doEventAvgTime(long time) {
    if (eventAvgTime.get() == 0) {
      eventAvgTime.set(time);
    } else {
      eventAvgTime.set((eventAvgTime.get() + time) / 2);
    }
  }

  public void doActorReceived() {
    actorReceived.incrementAndGet();
  }

  public void doActorAccepted() {
    actorAccepted.incrementAndGet();
  }

  public void doActorRejected() {
    actorRejected.incrementAndGet();
  }

  public void doActorAvgTime(long time) {
    if (actorAvgTime.get() == 0) {
      actorAvgTime.set(time);
    } else {
      actorAvgTime.set((actorAvgTime.get() + time) / 2);
    }
  }

  public void doSagaBeginCounter() {
    sagaBeginCounter.incrementAndGet();
  }

  public void doSagaEndCounter() {
    sagaEndCounter.incrementAndGet();
  }

  public void doSagaAvgTime(long time) {
    if (sagaAvgTime.get() == 0) {
      sagaAvgTime.set(time);
    } else {
      sagaAvgTime.set((sagaAvgTime.get() + time) / 2);
    }
  }

  public void doCommitted() {
    committed.incrementAndGet();
  }

  public void doCompensated() {
    compensated.incrementAndGet();
  }

  public void doSuspended() {
    suspended.incrementAndGet();
  }

  public void doRepositoryReceived() {
    repositoryReceived.incrementAndGet();
  }

  public void doRepositoryAccepted() {
    repositoryAccepted.incrementAndGet();
  }

  public void doRepositoryAccepted(int size) {
    repositoryAccepted.getAndAdd(size);
  }

  public void doRepositoryRejected() {
    repositoryRejected.incrementAndGet();
  }

  public void doRepositoryAvgTime(long time) {
    if (repositoryAvgTime.get() == 0) {
      repositoryAvgTime.set(time);
    } else {
      repositoryAvgTime.set((repositoryAvgTime.get() + time) / 2);
    }
  }

  public long getEventReceived() {
    return eventReceived.get();
  }

  public long getEventAccepted() {
    return eventAccepted.get();
  }

  public long getEventRejected() {
    return eventRejected.get();
  }

  public double getEventAvgTime() {
    return (double) Math.round(eventAvgTime.get() * 100) / 100;
  }

  public long getActorReceived() {
    return actorReceived.get();
  }

  public long getActorAccepted() {
    return actorAccepted.get();
  }

  public long getActorRejected() {
    return actorRejected.get();
  }

  public double getActorAvgTime() {
    return (double) Math.round(actorAvgTime.get() * 100) / 100;
  }

  public long getSagaBeginCounter() {
    return sagaBeginCounter.get();
  }

  public long getSagaEndCounter() {
    return sagaEndCounter.get();
  }

  public double getSagaAvgTime() {
    return (double) Math.round(sagaAvgTime.get() * 100) / 100;
  }

  public long getRepositoryReceived() {
    return repositoryReceived.get();
  }

  public long getRepositoryAccepted() {
    return repositoryAccepted.get();
  }

  public long getRepositoryRejected() {
    return repositoryRejected.get();
  }

  public double getRepositoryAvgTime() {
    return (double) Math.round(repositoryAvgTime.get() * 100) / 100;
  }

  public long getCommitted() {
    return committed.get();
  }

  public long getCompensated() {
    return compensated.get();
  }

  public long getSuspended() {
    return suspended.get();
  }

}

1	/*
2	* Licensed to the Apache Software Foundation (ASF) under one or more
3	* contributor license agreements. See the NOTICE file distributed with
4	* this work for additional information regarding copyright ownership.
5	* The ASF licenses this file to You under the Apache License, Version 2.0
6	* (the "License"); you may not use this file except in compliance with
7	* the License. You may obtain a copy of the License at
8	*
9	* http://www.apache.org/licenses/LICENSE-2.0
10	*
11	* Unless required by applicable law or agreed to in writing, software
12	* distributed under the License is distributed on an "AS IS" BASIS,
13	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14	* See the License for the specific language governing permissions and
15	* limitations under the License.
16	*/
17
18	package org.apache.servicecomb.pack.alpha.core.metrics;
19
20	import com.google.common.util.concurrent.AtomicDouble;
21	import java.util.concurrent.atomic.AtomicLong;
22
23	public class MetricsBean {	2✔
24
25	private AtomicLong eventReceived = new AtomicLong();	2✔
26	private AtomicLong eventAccepted = new AtomicLong();	2✔
27	private AtomicLong eventRejected = new AtomicLong();	2✔
28	private AtomicDouble eventAvgTime = new AtomicDouble();//milliseconds moving average	2✔
29	private AtomicLong actorReceived = new AtomicLong();	2✔
30	private AtomicLong actorAccepted = new AtomicLong();	2✔
31	private AtomicLong actorRejected = new AtomicLong();	2✔
32	private AtomicDouble actorAvgTime = new AtomicDouble();//milliseconds moving average	2✔
33	private AtomicLong sagaBeginCounter = new AtomicLong();	2✔
34	private AtomicLong sagaEndCounter = new AtomicLong();	2✔
35	private AtomicDouble sagaAvgTime = new AtomicDouble();//milliseconds moving average	2✔
36	private AtomicLong committed = new AtomicLong();	2✔
37	private AtomicLong compensated = new AtomicLong();	2✔
38	private AtomicLong suspended = new AtomicLong();	2✔
39	private AtomicLong repositoryReceived = new AtomicLong();	2✔
40	private AtomicLong repositoryAccepted = new AtomicLong();	2✔
41	private AtomicLong repositoryRejected = new AtomicLong();	2✔
42	private AtomicDouble repositoryAvgTime = new AtomicDouble();//milliseconds moving average	2✔
43
44	public void doEventReceived() {
45	eventReceived.incrementAndGet();	2✔
46	}	2✔
47
48	public void doEventAccepted() {
49	eventAccepted.incrementAndGet();	2✔
50	}	2✔
51
52	public void doEventRejected() {
53	eventRejected.incrementAndGet();	2✔
54	}	2✔
55
56	public void doEventAvgTime(long time) {
57	if (eventAvgTime.get() == 0) {	1✔
58	eventAvgTime.set(time);	1✔
59	} else {
60	eventAvgTime.set((eventAvgTime.get() + time) / 2);	×
61	}
62	}	1✔
63
64	public void doActorReceived() {
65	actorReceived.incrementAndGet();	2✔
66	}	2✔
67
68	public void doActorAccepted() {
69	actorAccepted.incrementAndGet();	2✔
70	}	2✔
71
72	public void doActorRejected() {
73	actorRejected.incrementAndGet();	2✔
74	}	2✔
75
76	public void doActorAvgTime(long time) {
77	if (actorAvgTime.get() == 0) {	1✔
78	actorAvgTime.set(time);	1✔
79	} else {
80	actorAvgTime.set((actorAvgTime.get() + time) / 2);	1✔
81	}
82	}	1✔
83
84	public void doSagaBeginCounter() {
85	sagaBeginCounter.incrementAndGet();	1✔
86	}	1✔
87
88	public void doSagaEndCounter() {
89	sagaEndCounter.incrementAndGet();	1✔
90	}	1✔
91
92	public void doSagaAvgTime(long time) {
93	if (sagaAvgTime.get() == 0) {	1✔
94	sagaAvgTime.set(time);	1✔
95	} else {
96	sagaAvgTime.set((sagaAvgTime.get() + time) / 2);	1✔
97	}
98	}	1✔
99
100	public void doCommitted() {
101	committed.incrementAndGet();	1✔
102	}	1✔
103
104	public void doCompensated() {
105	compensated.incrementAndGet();	1✔
106	}	1✔
107
108	public void doSuspended() {
109	suspended.incrementAndGet();	1✔
110	}	1✔
111
112	public void doRepositoryReceived() {
113	repositoryReceived.incrementAndGet();	2✔
114	}	2✔
115
116	public void doRepositoryAccepted() {
117	repositoryAccepted.incrementAndGet();	2✔
118	}	2✔
119
120	public void doRepositoryAccepted(int size) {
121	repositoryAccepted.getAndAdd(size);	1✔
122	}	1✔
123
124	public void doRepositoryRejected() {
125	repositoryRejected.incrementAndGet();	2✔
126	}	2✔
127
128	public void doRepositoryAvgTime(long time) {
129	if (repositoryAvgTime.get() == 0) {	1✔
130	repositoryAvgTime.set(time);	1✔
131	} else {
132	repositoryAvgTime.set((repositoryAvgTime.get() + time) / 2);	1✔
133	}
134	}	1✔
135
136	public long getEventReceived() {
137	return eventReceived.get();	2✔
138	}
139
140	public long getEventAccepted() {
141	return eventAccepted.get();	2✔
142	}
143
144	public long getEventRejected() {
145	return eventRejected.get();	2✔
146	}
147
148	public double getEventAvgTime() {
149	return (double) Math.round(eventAvgTime.get() * 100) / 100;	1✔
150	}
151
152	public long getActorReceived() {
153	return actorReceived.get();	2✔
154	}
155
156	public long getActorAccepted() {
157	return actorAccepted.get();	2✔
158	}
159
160	public long getActorRejected() {
161	return actorRejected.get();	2✔
162	}
163
164	public double getActorAvgTime() {
165	return (double) Math.round(actorAvgTime.get() * 100) / 100;	1✔
166	}
167
168	public long getSagaBeginCounter() {
169	return sagaBeginCounter.get();	1✔
170	}
171
172	public long getSagaEndCounter() {
173	return sagaEndCounter.get();	1✔
174	}
175
176	public double getSagaAvgTime() {
177	return (double) Math.round(sagaAvgTime.get() * 100) / 100;	1✔
178	}
179
180	public long getRepositoryReceived() {
181	return repositoryReceived.get();	2✔
182	}
183
184	public long getRepositoryAccepted() {
185	return repositoryAccepted.get();	2✔
186	}
187
188	public long getRepositoryRejected() {
189	return repositoryRejected.get();	2✔
190	}
191
192	public double getRepositoryAvgTime() {
193	return (double) Math.round(repositoryAvgTime.get() * 100) / 100;	1✔
194	}
195
196	public long getCommitted() {
197	return committed.get();	1✔
198	}
199
200	public long getCompensated() {
201	return compensated.get();	1✔
202	}
203
204	public long getSuspended() {
205	return suspended.get();	1✔
206	}
207
208	}

apache / servicecomb-pack / #2303

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous