This repository has been archived by the owner on Jan 1, 2019. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 175
/
ParallelClientUdpBasicTest.java
128 lines (98 loc) · 3.92 KB
/
ParallelClientUdpBasicTest.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
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
package io.parallec.core.main.udp;
import io.parallec.core.ParallecResponseHandler;
import io.parallec.core.ParallelClient;
import io.parallec.core.ResponseOnSingleTask;
import io.parallec.core.TestBase;
import io.parallec.core.exception.ParallelTaskInvalidException;
import io.parallec.core.main.udp.sampleserver.UdpServerThread;
import java.util.HashMap;
import java.util.Map;
import org.apache.http.util.Asserts;
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.Test;
public class ParallelClientUdpBasicTest extends TestBase {
private static ParallelClient pc;
private static UdpServerThread serverThread;
@BeforeClass
public static void setUp() throws Exception {
pc = new ParallelClient();
boolean similateSlowResponse = false;
serverThread = new UdpServerThread(similateSlowResponse);
serverThread.start();
try {
Thread.sleep(500L);
} catch (Exception e) {
;
}
}
@AfterClass
public static void shutdown() throws Exception {
pc.releaseExternalResources();
serverThread.setShutdown(true);
try {
Thread.sleep(500L);
} catch (Exception e) {
;
}
}
/**
* http://www.jeffpei.com/job_b.html http://www.restsuperman.com/job_c.html
*/
@Test(timeout = 50000)
public void UdpTest() {
Map<String, Object> responseContext = new HashMap<String, Object>();
pc.prepareUdp("hadoopmonudp").setConcurrency(300)
.setTargetHostsFromString("localhost")
.setUdpPort(10091)
.setResponseContext(responseContext)
.execute(new ParallecResponseHandler() {
@Override
public void onCompleted(ResponseOnSingleTask res,
Map<String, Object> responseContext) {
logger.info("Responose:" + res.getResponseContent() + " host: "
+ res.getHost() + " errmsg: "
+ res.getErrorMessage());
responseContext.put("resp",
res.getResponseContent());
}
});
String resp = (String) responseContext.get("resp");
Asserts.check(resp.contains("AT_UDP_SERVER"),
"fail.UdpTest with whole PC flow");
}
@Test(timeout = 50000)
public void UdpExpectedRefusedConnectionTest() {
Map<String, Object> responseContext = new HashMap<String, Object>();
pc.prepareUdp("hadoopmon").setConcurrency(300)
.setTargetHostsFromString("localhost")
.setUdpPort(10099)
.setResponseContext(responseContext)
.execute(new ParallecResponseHandler() {
@Override
public void onCompleted(ResponseOnSingleTask res,
Map<String, Object> responseContext) {
logger.info("Responose:" + res.getResponseContent() + " host: "
+ res.getHost() + " errmsg: "
+ res.getErrorMessage());
responseContext.put("resp",
res.getStatusCode());
}
});
String resp = (String) responseContext.get("resp");
Asserts.check(resp.contains("FAILURE"),
"fail.TcpTest with expected wrong port");
}
@Test
public void UdpTestFunctionsExceptions() {
try{
pc.prepareUdp("hadoopmonudp").setConcurrency(300)
.setTargetHostsFromString("localhost")
.setHttpPollable(true)
.validation()
;
}catch(ParallelTaskInvalidException e){
logger.info("EXPECTED error" + e.getLocalizedMessage());
}
}
}