1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.hadoop.chukwa.datacollection.connector;
20
21
22 import java.io.File;
23 import org.apache.hadoop.chukwa.conf.ChukwaConfiguration;
24 import org.apache.hadoop.chukwa.datacollection.agent.ChukwaAgent;
25 import org.apache.hadoop.chukwa.datacollection.connector.http.HttpConnector;
26 import org.apache.hadoop.chukwa.datacollection.controller.ChukwaAgentController;
27 import org.apache.hadoop.chukwa.util.TempFileUtil;
28 import junit.framework.TestCase;
29
30 public class TestFailedCollector extends TestCase {
31
32 public void testFailedCollector() {
33 try {
34 ChukwaAgent agent = new ChukwaAgent();
35 boolean failed = false;
36 HttpConnector connector = new HttpConnector(agent,
37 "http://localhost:1234/chukwa");
38 connector.start();
39
40 ChukwaConfiguration cc = new ChukwaConfiguration();
41 int portno = cc.getInt("chukwaAgent.control.port", 9093);
42 ChukwaAgentController cli = new ChukwaAgentController("localhost", portno);
43
44 File tmpOutput = TempFileUtil.makeBinary(2000);
45
46 cli.addFile("unknown", tmpOutput.getAbsolutePath());
47 System.out.println("have " + agent.adaptorCount() + " running adaptors");
48 cli.removeFile("unknown", tmpOutput.getAbsolutePath());
49
50 tmpOutput.delete();
51 assertFalse(failed);
52 System.out.println("done");
53 agent.shutdown();
54 connector.shutdown();
55 Thread.sleep(2000);
56 } catch (Exception e) {
57 e.printStackTrace();
58 }
59 }
60
61 }