/
ClientTcpSslLoadTest.java
83 lines (66 loc) · 2.56 KB
/
ClientTcpSslLoadTest.java
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
/*
* 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.ignite.loadtests.client;
import org.apache.ignite.client.*;
import org.apache.ignite.internal.util.typedef.internal.*;
/**
* Makes a long run to ensure stability and absence of memory leaks.
*/
public class ClientTcpSslLoadTest extends GridClientTcpSslMultiThreadedSelfTest {
/** Test duration. */
private static final long TEST_RUN_TIME = 8 * 60 * 60 * 1000;
/** Statistics output interval. */
private static final long STATISTICS_PRINT_INTERVAL = 5 * 60 * 1000;
/** Time to let connections closed by idle. */
private static final long RELAX_INTERVAL = 60 * 1000;
/**
* @throws Exception If failed.
*/
public void testLongRun() throws Exception {
long start = System.currentTimeMillis();
long lastPrint = start;
do {
clearCaches();
testMultithreadedTaskRun();
testMultithreadedCachePut();
long now = System.currentTimeMillis();
if (now - lastPrint > STATISTICS_PRINT_INTERVAL) {
info(">>>>>>> Running test for " + ((now - start) / 1000) + " seconds.");
lastPrint = now;
}
// Let idle check work.
U.sleep(RELAX_INTERVAL);
}
while (System.currentTimeMillis() - start < TEST_RUN_TIME);
}
/** {@inheritDoc} */
@Override protected int topologyRefreshFrequency() {
return 5000;
}
/** {@inheritDoc} */
@Override protected int maxConnectionIdleTime() {
return topologyRefreshFrequency() / 5;
}
/**
* Clears caches on all nodes.
*/
@SuppressWarnings("ConstantConditions")
private void clearCaches() {
for (int i = 0; i < NODES_CNT; i++)
grid(i).cache(PARTITIONED_CACHE_NAME).clearAll();
}
}