import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
+import java.net.HttpURLConnection;
+import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLConnection;
import java.nio.charset.Charset;
+import java.util.Arrays;
+
import org.apache.commons.codec.binary.Base64;
+import org.codehaus.jettison.json.JSONArray;
+import org.codehaus.jettison.json.JSONException;
import org.codehaus.jettison.json.JSONObject;
import org.codehaus.jettison.json.JSONTokener;
+import org.opendaylight.controller.hosttracker.IfIptoHost;
+import org.opendaylight.controller.sal.core.ConstructionException;
+import org.opendaylight.controller.sal.core.Node;
+import org.opendaylight.controller.sal.core.NodeConnector;
+import org.opendaylight.controller.sal.core.UpdateType;
+import org.opendaylight.controller.switchmanager.IInventoryListener;
import org.opendaylight.controller.usermanager.IUserManager;
@RunWith(PaxExam.class)
@Inject
private BundleContext bc;
private IUserManager users = null;
+ private IInventoryListener invtoryListener = null;
private String stateToString(int state) {
switch (state) {
// If UserManager is null, cannot login to run tests.
assertNotNull(this.users);
+ r = bc.getServiceReference(IfIptoHost.class.getName());
+ if (r != null) {
+ this.invtoryListener = (IInventoryListener)bc.getService(r);
+ }
+
+ // If inventoryListener is null, cannot run hosttracker tests.
+ assertNotNull(this.invtoryListener);
+
}
- @Test
- public void testStatistics() {
+ // static variable to pass response code from getJsonResult()
+ private static Integer httpResponseCode = null;
- System.out.println("Starting Statistics JAXB client.");
+ private String getJsonResult(String restUrl) {
+ return getJsonResult(restUrl, "GET");
+ }
+
+ private String getJsonResult(String restUrl, String method) {
+ // initialize response code to indicate error
+ httpResponseCode = 400;
- String baseURL = "http://127.0.0.1:8080/controller/nb/v2/statistics/default/flowstats";
try {
- URL url = new URL(baseURL);
+ URL url = new URL(restUrl);
this.users.getAuthorizationList();
this.users.authenticate("admin", "admin");
String authString = "admin:admin";
byte[] authEncBytes = Base64.encodeBase64(authString.getBytes());
String authStringEnc = new String(authEncBytes);
- URLConnection connection = url.openConnection();
+
+ HttpURLConnection connection = (HttpURLConnection) url
+ .openConnection();
+ connection.setRequestMethod(method);
connection.setRequestProperty("Authorization", "Basic "
+ authStringEnc);
-
connection.setRequestProperty("Content-Type", "application/json");
connection.setRequestProperty("Accept", "application/json");
connection.connect();
connection.getContentType();
+
+ // Response code for success should be 2xx
+ httpResponseCode = connection.getResponseCode();
+
InputStream is = connection.getInputStream();
- // InputStream is = connection.getInputStream();
BufferedReader rd = new BufferedReader(new InputStreamReader(is,
Charset.forName("UTF-8")));
StringBuilder sb = new StringBuilder();
sb.append((char) cp);
}
is.close();
- JSONTokener jt = new JSONTokener(sb.toString());
+ connection.disconnect();
+ return sb.toString();
+ } catch (Exception e) {
+ return null;
+ }
+
+ }
+
+ @Test
+ public void testStatistics() {
+ String actionTypes[] = { "drop", "loopback", "flood", "floodAll",
+ "controller", "swPath", "hwPath", "output", "setDlSrc",
+ "setDlDst", "setDlType", "setVlanId", "setVlanPcp",
+ "setVlanCfi", "popVlan", "pushVlan", "setNwSrc", "setNwDst",
+ "setNwTos", "setTpSrc", "setTpDst" };
+ System.out.println("Starting Statistics JAXB client.");
+
+ String baseURL = "http://127.0.0.1:8080/controller/nb/v2/statistics/default/";
+ try {
+ String result = getJsonResult(baseURL + "flowstats");
+ JSONTokener jt = new JSONTokener(result);
JSONObject json = new JSONObject(jt);
- JSONObject flowStatistics = json.getJSONObject("flowStatistics");
+ JSONObject flowStatistics =
+ getJsonInstance (json, "flowStatistics", 0xCAFE);
JSONObject node = flowStatistics.getJSONObject("node");
// test that node was returned properly
Assert.assertTrue(node.getInt("@id") == 0xCAFE);
Assert.assertTrue(node.getString("@type").equals("STUB"));
// test that flow statistics results are correct
- JSONObject flowStat = flowStatistics.getJSONObject("flowStat");
+ JSONArray flowStats = flowStatistics.getJSONArray("flowStat");
+ for (int i = 0; i < flowStats.length(); i++) {
+
+ JSONObject flowStat = flowStats.getJSONObject(i);
+ testFlowStat(flowStat, actionTypes[i]);
+
+ }
+
+ // for /controller/nb/v2/statistics/default/portstats
+ result = getJsonResult(baseURL + "portstats");
+ jt = new JSONTokener(result);
+ json = new JSONObject(jt);
+ JSONObject portStatistics =
+ getJsonInstance (json, "portStatistics", 0xCAFE);
+ JSONObject node2 = portStatistics.getJSONObject("node");
+ // test that node was returned properly
+ Assert.assertTrue(node2.getInt("@id") == 0xCAFE);
+ Assert.assertTrue(node2.getString("@type").equals("STUB"));
+
+ // test that port statistic results are correct
+ JSONObject portStat = portStatistics.getJSONObject("portStat");
+ Assert.assertTrue(portStat.getInt("receivePackets") == 250);
+ Assert.assertTrue(portStat.getInt("transmitPackets") == 500);
+ Assert.assertTrue(portStat.getInt("receiveBytes") == 1000);
+ Assert.assertTrue(portStat.getInt("transmitBytes") == 5000);
+ Assert.assertTrue(portStat.getInt("receiveDrops") == 2);
+ Assert.assertTrue(portStat.getInt("transmitDrops") == 50);
+ Assert.assertTrue(portStat.getInt("receiveErrors") == 3);
+ Assert.assertTrue(portStat.getInt("transmitErrors") == 10);
+ Assert.assertTrue(portStat.getInt("receiveFrameError") == 5);
+ Assert.assertTrue(portStat.getInt("receiveOverRunError") == 6);
+ Assert.assertTrue(portStat.getInt("receiveCrcError") == 1);
+ Assert.assertTrue(portStat.getInt("collisionCount") == 4);
+
+ // test for getting one specific node's stats
+ result = getJsonResult(baseURL + "flowstats/STUB/51966");
+ jt = new JSONTokener(result);
+ json = new JSONObject(jt);
+ node = json.getJSONObject("node");
+ // test that node was returned properly
+ Assert.assertTrue(node.getInt("@id") == 0xCAFE);
+ Assert.assertTrue(node.getString("@type").equals("STUB"));
+
+ // test that flow statistics results are correct
+ flowStats = json.getJSONArray("flowStat");
+ for (int i = 0; i < flowStats.length(); i++) {
+ JSONObject flowStat = flowStats.getJSONObject(i);
+ testFlowStat(flowStat, actionTypes[i]);
+ }
+
+ result = getJsonResult(baseURL + "portstats/STUB/51966");
+ jt = new JSONTokener(result);
+ json = new JSONObject(jt);
+ node2 = json.getJSONObject("node");
+ // test that node was returned properly
+ Assert.assertTrue(node2.getInt("@id") == 0xCAFE);
+ Assert.assertTrue(node2.getString("@type").equals("STUB"));
+
+ // test that port statistic results are correct
+ portStat = json.getJSONObject("portStat");
+ Assert.assertTrue(portStat.getInt("receivePackets") == 250);
+ Assert.assertTrue(portStat.getInt("transmitPackets") == 500);
+ Assert.assertTrue(portStat.getInt("receiveBytes") == 1000);
+ Assert.assertTrue(portStat.getInt("transmitBytes") == 5000);
+ Assert.assertTrue(portStat.getInt("receiveDrops") == 2);
+ Assert.assertTrue(portStat.getInt("transmitDrops") == 50);
+ Assert.assertTrue(portStat.getInt("receiveErrors") == 3);
+ Assert.assertTrue(portStat.getInt("transmitErrors") == 10);
+ Assert.assertTrue(portStat.getInt("receiveFrameError") == 5);
+ Assert.assertTrue(portStat.getInt("receiveOverRunError") == 6);
+ Assert.assertTrue(portStat.getInt("receiveCrcError") == 1);
+ Assert.assertTrue(portStat.getInt("collisionCount") == 4);
+
+ } catch (Exception e) {
+ // Got an unexpected exception
+ Assert.assertTrue(false);
+
+ }
+ }
+
+ private void testFlowStat(JSONObject flowStat, String actionType) {
+ try {
Assert.assertTrue(flowStat.getInt("tableId") == 1);
Assert.assertTrue(flowStat.getInt("durationSeconds") == 40);
Assert.assertTrue(flowStat.getInt("durationNanoseconds") == 400);
Assert.assertTrue(match.getString("type").equals("NW_DST"));
Assert.assertTrue(match.getString("value").equals("1.1.1.1"));
- Assert.assertTrue(flow.getJSONObject("actions").getString("@type")
- .equals("drop"));
+ JSONObject act = flow.getJSONObject("actions");
+ Assert.assertTrue(act.getString("@type").equals(actionType));
+
+ if (act.getString("@type").equals("output")) {
+ JSONObject port = act.getJSONObject("port");
+ JSONObject port_node = port.getJSONObject("node");
+ Assert.assertTrue(port.getInt("@id") == 51966);
+ Assert.assertTrue(port.getString("@type").equals("STUB"));
+ Assert.assertTrue(port_node.getInt("@id") == 51966);
+ Assert.assertTrue(port_node.getString("@type").equals("STUB"));
+ }
+
+ if (act.getString("@type").equals("setDlSrc")) {
+ byte srcMatch[] = { (byte) 5, (byte) 4, (byte) 3, (byte) 2,
+ (byte) 1 };
+ String src = act.getString("address");
+ byte srcBytes[] = new byte[5];
+ srcBytes[0] = Byte.parseByte(src.substring(0, 2));
+ srcBytes[1] = Byte.parseByte(src.substring(2, 4));
+ srcBytes[2] = Byte.parseByte(src.substring(4, 6));
+ srcBytes[3] = Byte.parseByte(src.substring(6, 8));
+ srcBytes[4] = Byte.parseByte(src.substring(8, 10));
+ Assert.assertTrue(Arrays.equals(srcBytes, srcMatch));
+ }
+ if (act.getString("@type").equals("setDlDst")) {
+ byte dstMatch[] = { (byte) 1, (byte) 2, (byte) 3, (byte) 4,
+ (byte) 5 };
+ String dst = act.getString("address");
+ byte dstBytes[] = new byte[5];
+ dstBytes[0] = Byte.parseByte(dst.substring(0, 2));
+ dstBytes[1] = Byte.parseByte(dst.substring(2, 4));
+ dstBytes[2] = Byte.parseByte(dst.substring(4, 6));
+ dstBytes[3] = Byte.parseByte(dst.substring(6, 8));
+ dstBytes[4] = Byte.parseByte(dst.substring(8, 10));
+ Assert.assertTrue(Arrays.equals(dstBytes, dstMatch));
+ }
+ if (act.getString("@type").equals("setDlType"))
+ Assert.assertTrue(act.getInt("dlType") == 10);
+ if (act.getString("@type").equals("setVlanId"))
+ Assert.assertTrue(act.getInt("vlanId") == 2);
+ if (act.getString("@type").equals("setVlanPcp"))
+ Assert.assertTrue(act.getInt("pcp") == 3);
+ if (act.getString("@type").equals("setVlanCfi"))
+ Assert.assertTrue(act.getInt("cfi") == 1);
+
+ if (act.getString("@type").equals("setNwSrc"))
+ Assert.assertTrue(act.getString("address").equals("2.2.2.2"));
+ if (act.getString("@type").equals("setNwDst"))
+ Assert.assertTrue(act.getString("address").equals("1.1.1.1"));
+
+ if (act.getString("@type").equals("pushVlan")) {
+ int head = act.getInt("VlanHeader");
+ // parsing vlan header
+ int id = head & 0xfff;
+ int cfi = (head >> 12) & 0x1;
+ int pcp = (head >> 13) & 0x7;
+ int tag = (head >> 16) & 0xffff;
+ Assert.assertTrue(id == 1234);
+ Assert.assertTrue(cfi == 1);
+ Assert.assertTrue(pcp == 1);
+ Assert.assertTrue(tag == 0x8100);
+ }
+ if (act.getString("@type").equals("setNwTos"))
+ Assert.assertTrue(act.getInt("tos") == 16);
+ if (act.getString("@type").equals("setTpSrc"))
+ Assert.assertTrue(act.getInt("port") == 4201);
+ if (act.getString("@type").equals("setTpDst"))
+ Assert.assertTrue(act.getInt("port") == 8080);
+ } catch (Exception e) {
+ Assert.assertTrue(false);
+ }
+ }
+
+ // method to extract a JSONObject with specified node ID from a JSONObject
+ // that may contain an array of JSONObjects
+ // This is specifically written for statistics manager northbound REST interface
+ // array_name should be either "flowStatistics" or "portStatistics"
+ private JSONObject getJsonInstance (JSONObject json, String array_name, Integer nodeId) throws JSONException
+ {
+ JSONObject result = null;
+ if (json.get(array_name) instanceof JSONArray){
+ JSONArray json_array = json.getJSONArray(array_name);
+ for (int i = 0; i < json_array.length(); i++) {
+ result = json_array.getJSONObject(i);
+ Integer nid = result.getJSONObject("node").getInt("@id");
+ if ( nid.equals(nodeId) ) break;
+ }
+ }
+ else {
+ result = json.getJSONObject(array_name);
+ Integer nid = result.getJSONObject("node").getInt("@id");
+ if ( ! nid.equals(nodeId) ) result = null;
+ }
+ return result;
+ }
+
+
+ // a class to construct query parameter for HTTP request
+ private class QueryParameter {
+ StringBuilder queryString = null;
+
+ // constructor
+ QueryParameter (String key, String value) {
+ queryString = new StringBuilder();
+ queryString.append("?").append(key).append("=").append(value);
+ }
+
+ // method to add more query parameter
+ QueryParameter add (String key, String value){
+ this.queryString.append("&").append(key).append("=").append(value);
+ return this;
+ }
+
+ // method to get the query parameter string
+ String getString (){
+ return this.queryString.toString();
+ }
+
+ }
+
+
+ @Test
+ public void testHostTracker() {
+
+ System.out.println("Starting HostTracker JAXB client.");
+
+ // setup 2 host models for @POST method
+ // 1st host
+ String networkAddress_1 = "192.168.0.8";
+ String dataLayerAddress_1 = "11:22:33:44:55:66";
+ String nodeType_1 = "STUB";
+ Integer nodeId_1 = 3366;
+ String nodeConnectorType_1 = "STUB";
+ Integer nodeConnectorId_1 = 12;
+ String vlan_1 = "4";
+
+
+ // 2nd host
+ String networkAddress_2 = "10.1.1.1";
+ String dataLayerAddress_2 = "1A:2B:3C:4D:5E:6F";
+ String nodeType_2 = "STUB";
+ Integer nodeId_2 = 4477;
+ String nodeConnectorType_2 = "STUB";
+ Integer nodeConnectorId_2 = 34;
+ String vlan_2 = "0";
+
+ String baseURL = "http://127.0.0.1:8080/controller/nb/v2/host/default";
+
+ // test POST method: addHost()
+ try {
+ String queryParameter =
+ new QueryParameter("dataLayerAddress", dataLayerAddress_1)
+ .add("nodeType", nodeType_1)
+ .add("nodeId", nodeId_1.toString())
+ .add("nodeConnectorType", nodeConnectorType_1)
+ .add("nodeConnectorId", nodeConnectorId_1.toString())
+ .add("vlan", vlan_1)
+ .getString();
+
+ String result = getJsonResult(baseURL +"/" + networkAddress_1 + queryParameter, "POST");
+ Assert.assertTrue (httpResponseCode.intValue() == (Integer) 201);
+
+ // vlan is not passed through query parameter but should be defaulted to "0"
+ queryParameter =
+ new QueryParameter("dataLayerAddress", dataLayerAddress_2)
+ .add("nodeType", nodeType_2)
+ .add("nodeId", nodeId_2.toString())
+ .add("nodeConnectorType", nodeConnectorType_2)
+ .add("nodeConnectorId", nodeConnectorId_2.toString())
+ .getString();
+
+ result = getJsonResult(baseURL +"/" + networkAddress_2 + queryParameter, "POST");
+ Assert.assertTrue (httpResponseCode.intValue() == (Integer) 201);
+ } catch (Exception e) {
+ // Got an unexpected exception
+ Assert.assertTrue(false);
+ }
+
+ // define variables for decoding returned strings
+ String networkAddress;
+ JSONObject host_jo, dl_jo, nc_jo, node_jo;
+
+ // the two hosts should be in inactive host DB
+ // test GET method: getInactiveHosts()
+ try {
+ String result = getJsonResult(baseURL +"/inactive", "GET");
+ Assert.assertTrue (httpResponseCode.intValue() == (Integer) 200);
+
+ JSONTokener jt = new JSONTokener(result);
+ JSONObject json = new JSONObject(jt);
+ // there should be at least two hosts in the DB
+ Assert.assertTrue (json.get("host") instanceof JSONArray);
+ JSONArray ja = json.getJSONArray("host");
+ Integer count = ja.length();
+ Assert.assertTrue (count == 2);
+
+ for ( int i = 0; i < count; i++) {
+ host_jo = ja.getJSONObject(i);
+ dl_jo = host_jo.getJSONObject("dataLayerAddress");
+ nc_jo = host_jo.getJSONObject("nodeConnector");
+ node_jo = nc_jo.getJSONObject("node");
+
+ networkAddress = host_jo.getString("networkAddress");
+ if (networkAddress.equalsIgnoreCase(networkAddress_1)) {
+ Assert.assertTrue (dl_jo.getString("macAddress").equalsIgnoreCase(dataLayerAddress_1));
+ Assert.assertTrue (nc_jo.getString("@type").equalsIgnoreCase(nodeConnectorType_1));
+ Assert.assertTrue (Integer.parseInt(nc_jo.getString("@id")) == nodeConnectorId_1);
+ Assert.assertTrue (node_jo.getString("@type").equalsIgnoreCase(nodeType_1));
+ Assert.assertTrue (Integer.parseInt(node_jo.getString("@id")) == nodeId_1);
+ Assert.assertTrue (host_jo.getString("vlan").equalsIgnoreCase(vlan_1));
+ }
+ else if (networkAddress.equalsIgnoreCase(networkAddress_2)) {
+ Assert.assertTrue (dl_jo.getString("macAddress").equalsIgnoreCase(dataLayerAddress_2));
+ Assert.assertTrue (nc_jo.getString("@type").equalsIgnoreCase(nodeConnectorType_2));
+ Assert.assertTrue (Integer.parseInt(nc_jo.getString("@id")) == nodeConnectorId_2);
+ Assert.assertTrue (node_jo.getString("@type").equalsIgnoreCase(nodeType_2));
+ Assert.assertTrue (Integer.parseInt(node_jo.getString("@id")) == nodeId_2);
+ Assert.assertTrue (host_jo.getString("vlan").equalsIgnoreCase(vlan_2));
+ }
+ else {
+ Assert.assertTrue(false);
+ }
+ }
+ } catch (Exception e) {
+ // Got an unexpected exception
+ Assert.assertTrue(false);
+ }
+
+ // test GET method: getActiveHosts() - no host expected
+ try {
+ String result = getJsonResult(baseURL, "GET");
+ Assert.assertTrue (httpResponseCode.intValue() == (Integer) 200);
+
+ JSONTokener jt = new JSONTokener(result);
+ JSONObject json = new JSONObject(jt);
+ Assert.assertFalse(hostInJson(json, networkAddress_1));
+ Assert.assertFalse(hostInJson(json, networkAddress_2));
+ } catch (Exception e) {
+ // Got an unexpected exception
+ Assert.assertTrue(false);
+ }
+
+ // put the 1st host into active host DB
+ Node nd;
+ NodeConnector ndc;
+ try {
+ nd = new Node(nodeType_1, nodeId_1);
+ ndc = new NodeConnector(nodeConnectorType_1, nodeConnectorId_1, nd);
+ this.invtoryListener.notifyNodeConnector(ndc,
+ UpdateType.ADDED, null);
+ }catch(ConstructionException e){
+ ndc = null;
+ nd = null;
+ }
+
+ // verify the host shows up in active host DB
+ try {
+ String result = getJsonResult(baseURL, "GET");
+ Assert.assertTrue (httpResponseCode.intValue() == (Integer) 200);
+
+ JSONTokener jt = new JSONTokener(result);
+ JSONObject json = new JSONObject(jt);
+
+ Assert.assertTrue(hostInJson(json, networkAddress_1));
} catch (Exception e) {
// Got an unexpected exception
Assert.assertTrue(false);
+ }
+
+
+ // test GET method for getHostDetails()
+ try {
+ String result = getJsonResult(baseURL+"/"+networkAddress_1, "GET");
+ Assert.assertTrue (httpResponseCode.intValue() == (Integer) 200);
+
+ JSONTokener jt = new JSONTokener(result);
+ JSONObject json = new JSONObject(jt);
+ Assert.assertFalse(json.length() == 0);
+
+ dl_jo = json.getJSONObject("dataLayerAddress");
+ nc_jo = json.getJSONObject("nodeConnector");
+ node_jo = nc_jo.getJSONObject("node");
+
+ Assert.assertTrue (json.getString("networkAddress").equalsIgnoreCase(networkAddress_1));
+ Assert.assertTrue (dl_jo.getString("macAddress").equalsIgnoreCase(dataLayerAddress_1));
+ Assert.assertTrue (nc_jo.getString("@type").equalsIgnoreCase(nodeConnectorType_1));
+ Assert.assertTrue (Integer.parseInt(nc_jo.getString("@id")) == nodeConnectorId_1);
+ Assert.assertTrue (node_jo.getString("@type").equalsIgnoreCase(nodeType_1));
+ Assert.assertTrue (Integer.parseInt(node_jo.getString("@id")) == nodeId_1);
+ Assert.assertTrue (json.getString("vlan").equalsIgnoreCase(vlan_1));
+ } catch (Exception e) {
+ // Got an unexpected exception
+ Assert.assertTrue(false);
+ }
+
+ // test DELETE method for deleteFlow()
+ try {
+ String result = getJsonResult(baseURL+"/"+networkAddress_1, "DELETE");
+ Assert.assertTrue (httpResponseCode.intValue() == (Integer) 200);
+
+ } catch (Exception e) {
+ // Got an unexpected exception
+ Assert.assertTrue(false);
+ }
+
+ // verify host_1 removed from active host DB
+ // test GET method: getActiveHosts() - no host expected
+ try {
+ String result = getJsonResult(baseURL, "GET");
+ Assert.assertTrue (httpResponseCode.intValue() == (Integer) 200);
+
+ JSONTokener jt = new JSONTokener(result);
+ JSONObject json = new JSONObject(jt);
+
+ Assert.assertFalse(hostInJson(json, networkAddress_1));
+ } catch (Exception e) {
+ // Got an unexpected exception
+ Assert.assertTrue(false);
+ }
+ }
+
+ private Boolean hostInJson (JSONObject json, String hostIp) throws JSONException {
+ // input JSONObject may be empty
+ if ( json.length() == 0 ) {
+ return false;
+ }
+ if (json.get("host") instanceof JSONArray){
+ JSONArray ja = json.getJSONArray("host");
+ for (int i = 0; i < ja.length(); i++) {
+ String na = ja.getJSONObject(i).getString("networkAddress");
+ if (na.equalsIgnoreCase(hostIp))
+ return true;
+ }
+ return false;
+ }
+ else {
+ String na = json.getJSONObject("host").getString("networkAddress");
+ return (na.equalsIgnoreCase(hostIp)) ? true : false;
}
}
+
// Configure the OSGi container
@Configuration
public Option[] config() {
Code Review / controller.git / blobdiff