/* | |
* 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(); | |
} | |
} |