1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.hadoop.chukwa.rest.resource;
19
20 import java.io.File;
21 import java.io.IOException;
22 import java.net.InetAddress;
23 import java.net.URI;
24 import java.net.URISyntaxException;
25 import java.net.UnknownHostException;
26
27 import org.apache.hadoop.chukwa.hicc.HiccWebServer;
28 import org.apache.hadoop.chukwa.util.ExceptionUtil;
29 import org.apache.hadoop.conf.Configuration;
30 import org.apache.hadoop.fs.FileSystem;
31 import org.apache.hadoop.hdfs.MiniDFSCluster;
32 import org.mortbay.jetty.Server;
33 import org.mortbay.jetty.nio.SelectChannelConnector;
34 import org.mortbay.jetty.servlet.Context;
35 import org.mortbay.jetty.servlet.ServletHolder;
36
37 import com.sun.jersey.api.client.Client;
38 import com.sun.jersey.api.client.WebResource;
39 import com.sun.jersey.spi.container.servlet.ServletContainer;
40
41 import junit.framework.TestCase;
42
43 public class SetupTestEnv extends TestCase {
44 public WebResource resource;
45 public URI baseURL;
46 public Client client;
47 public static int restPort = 4080;
48 public static Configuration conf = null;
49 public static HiccWebServer hicc = null;
50 public static String user = "admin";
51 public static String authorization = "Basic YWRtaW46YWRtaW4=";
52 public static MiniDFSCluster dfs;
53
54 public SetupTestEnv() {
55 try {
56 Configuration conf=new Configuration();
57 conf.setBoolean("dfs.permissions",true);
58 dfs=new MiniDFSCluster(conf,1,true,null);
59 } catch(Exception e) {
60 fail("Fail to start MiniDFSCluster");
61 }
62 if(hicc==null) {
63 hicc = HiccWebServer.getInstance();
64 conf = HiccWebServer.getConfig();
65 }
66 }
67
68 public void setUp() {
69 hicc.start();
70 }
71
72 public void tearDown() {
73 dfs.shutdown();
74 }
75 }