diff options
Diffstat (limited to 'framework/src/onos/apps/mfwd/src/main/java/org/onosproject/mfwd/rest/McastResource.java')
| -rw-r--r-- | framework/src/onos/apps/mfwd/src/main/java/org/onosproject/mfwd/rest/McastResource.java | 149 |
1 files changed, 0 insertions, 149 deletions
diff --git a/framework/src/onos/apps/mfwd/src/main/java/org/onosproject/mfwd/rest/McastResource.java b/framework/src/onos/apps/mfwd/src/main/java/org/onosproject/mfwd/rest/McastResource.java deleted file mode 100644 index 608e0447..00000000 --- a/framework/src/onos/apps/mfwd/src/main/java/org/onosproject/mfwd/rest/McastResource.java +++ /dev/null @@ -1,149 +0,0 @@ -/*
- * Copyright 2015 Open Networking Laboratory
- *
- * Licensed 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.onosproject.mfwd.rest;
-
-import java.io.IOException;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import com.fasterxml.jackson.databind.node.ObjectNode;
-
-import javax.ws.rs.DefaultValue;
-import javax.ws.rs.QueryParam;
-import javax.ws.rs.Consumes;
-import javax.ws.rs.GET;
-import javax.ws.rs.POST;
-import javax.ws.rs.DELETE;
-import javax.ws.rs.Path;
-import javax.ws.rs.Produces;
-import javax.ws.rs.core.MediaType;
-import javax.ws.rs.core.Response;
-
-import org.onosproject.mfwd.impl.McastConnectPoint;
-import org.onosproject.mfwd.impl.McastRouteTable;
-import org.onosproject.mfwd.impl.McastRouteBase;
-import org.onosproject.mfwd.impl.MRibCodec;
-import org.onosproject.rest.AbstractWebResource;
-
-import org.slf4j.Logger;
-import static org.slf4j.LoggerFactory.getLogger;
-
-/**
- * Rest API for Multicast Forwarding.
- */
-@Path("mcast")
-public class McastResource extends AbstractWebResource {
-
- private final Logger log = getLogger(getClass());
- private static final String SOURCE_ADDRESS = "sourceAddress";
- private static final String GROUP_ADDRESS = "groupAddress";
- private static final String INGRESS_POINT = "ingressPoint";
- private static final String EGRESS_POINT = "egressPoint";
- private static final String MCAST_GROUP = "mcastGroup";
-
- /**
- * Retrieve the multicast route table.
- *
- * @return the multicast route table.
- * @throws IOException if an error occurs
- */
- @Path("show")
- @GET
- @Produces(MediaType.APPLICATION_JSON)
- public Response showAll() throws IOException {
- McastRouteTable mrt = McastRouteTable.getInstance();
- ObjectNode pushContent = new MRibCodec().encode(mrt , this);
- return ok(pushContent.toString()).build();
- }
-
- /**
- * Static join a multicast flow.
- *
- * @param sAddr source address to join
- * @param gAddr group address to join
- * @param ports ingress and egress ConnectPoints to join
- * @return the Result of the join
- * @throws IOException if something failed with the join command
- */
- @Path("/join")
- @POST
- @Consumes(MediaType.APPLICATION_JSON)
- @Produces(MediaType.TEXT_PLAIN)
- public Response join(@QueryParam("src") String sAddr,
- @QueryParam("grp") String gAddr,
- @DefaultValue("") @QueryParam("ports") String ports)
- throws IOException {
-
- ObjectMapper mapper = new ObjectMapper();
- log.debug("Source IP Address: " + sAddr);
- log.debug("Destination IP Address: " + gAddr);
- log.debug("Ingress and Egress ports: " + ports);
-
- String output = "Insertion Faild";
- if (sAddr != null && gAddr != null && ports != null) {
-
- String[] portArr = ports.split(",");
- log.debug("Port Array Length: " + portArr.length);
- McastRouteTable mrt = McastRouteTable.getInstance();
- McastRouteBase mr = mrt.addRoute(sAddr, gAddr);
-
- // Port format "of:0000000000000023/4"
- log.debug("checking inside outer if: " + portArr.length);
-
- if (mr != null && portArr != null && portArr.length > 0) {
-
- String inCP = portArr[0];
- log.debug("Ingress port provided: " + inCP);
- mr.addIngressPoint(inCP);
-
- for (int i = 1; i < portArr.length; i++) {
- String egCP = portArr[i];
- log.debug("Egress port provided: " + egCP);
- mr.addEgressPoint(egCP, McastConnectPoint.JoinSource.STATIC);
- }
- mrt.printMcastRouteTable();
- output = "Successfully Inserted";
- }
- } else {
- output = "Please Insert the rest uri correctly";
- }
- return Response.ok(output).build();
- }
-
- /**
- * Delete multicast state.
- *
- * @param src address to be deleted
- * @param grp address to be deleted
- * @return status of delete if successful
- */
- @Path("/delete")
- @DELETE
- @Consumes(MediaType.TEXT_PLAIN)
- @Produces(MediaType.TEXT_PLAIN)
- public Response removeMcastFlow(@QueryParam("src") String src,
- @QueryParam("grp") String grp) {
-
- String resp = "Failed to delete";
- log.info("Source IP Address to delete: " + src);
- log.info("Destination IP Address to delete: " + grp);
- McastRouteTable mrt = McastRouteTable.getInstance();
- if (src != null && grp != null) {
- mrt.removeRoute(src, grp);
- resp = "Deleted flow for src " + src + " and grp " + grp;
- }
-
- return Response.ok(resp).build();
- }
-}
|