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
|
package org.onap.aai.sparky.dal.aai;
import org.junit.Assert;
import org.junit.Test;
import org.onap.aai.sparky.dal.NetworkTransaction;
import org.onap.aai.sparky.dal.rest.HttpMethod;
import org.onap.aai.sparky.dal.rest.OperationResult;
public class ActiveInventoryProcessingExceptionStatisticsTest {
@Test
public void testUpdateCounters() {
ActiveInventoryProcessingExceptionStatistics aipes =
new ActiveInventoryProcessingExceptionStatistics();
aipes.incrementCounter("NativeSocketConnectException", 1);
aipes.incrementCounter("NativeSocketConnectionReset", 1);
aipes.incrementCounter("NativeSocketConnectionRefused", 1);
aipes.incrementCounter("JerseyClientTimoutException", 1);
aipes.incrementCounter("UnknownException", 1);
OperationResult result = new OperationResult();
result.setResultCode(310);
result.setResult("java.net.SocketTimeoutException: connect timed out");
result.setNumRequestRetries(1);
NetworkTransaction ntwTxn1 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
aipes.updateCounters(ntwTxn1);
result.setResult("result-1");
NetworkTransaction ntwTxn2 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
aipes.updateCounters(ntwTxn2);
result.setResult("java.net.ConnectException: Connection timed out: connect");
NetworkTransaction ntwTxn3 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
aipes.updateCounters(ntwTxn3);
result.setResult("java.net.ConnectException: Connection refused: connect");
NetworkTransaction ntwTxn4 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
aipes.updateCounters(ntwTxn4);
result.setResult("java.net.SocketException: Connection reset");
NetworkTransaction ntwTxn5 = new NetworkTransaction(HttpMethod.GET, "entity-1", result);
aipes.updateCounters(ntwTxn5);
}
@Test
public void testGetStatisticsReport() {
ActiveInventoryProcessingExceptionStatistics aipes =
new ActiveInventoryProcessingExceptionStatistics();
aipes.incrementCounter("NativeSocketConnectException", 1);
aipes.incrementCounter("NativeSocketConnectionReset", 1);
aipes.incrementCounter("NativeSocketConnectionRefused", 1);
aipes.incrementCounter("JerseyClientTimoutException", 1);
aipes.incrementCounter("UnknownException", 1);
String statReport = aipes.getStatisticsReport();
Assert.assertNotNull(statReport);
}
}
|
