import org.codehaus.enunciate.jaxrs.StatusCodes;
import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
import org.codehaus.enunciate.jaxrs.StatusCodes;
import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
import org.opendaylight.neutron.spi.INeutronLoadBalancerPoolCRUD;
import org.opendaylight.neutron.spi.NeutronLoadBalancerPool;
import org.opendaylight.neutron.spi.NeutronLoadBalancerPoolMember;
import org.opendaylight.neutron.spi.INeutronLoadBalancerPoolCRUD;
import org.opendaylight.neutron.spi.NeutronLoadBalancerPool;
import org.opendaylight.neutron.spi.NeutronLoadBalancerPoolMember;
- try (ReadOnlyTransaction tx = dataBroker.newReadOnlyTransaction()) {
- if (!loadBalancerPoolInterface.exists(loadBalancerPoolUUID, tx)) {
- throw new ResourceNotFoundException(uuidNoExist());
+ try {
+ try (ReadOnlyTransaction tx = dataBroker.newReadOnlyTransaction()) {
+ if (!loadBalancerPoolInterface.exists(loadBalancerPoolUUID, tx)) {
+ throw new ResourceNotFoundException(uuidNoExist());
+ }
- }
- List<NeutronLoadBalancerPoolMember> members = loadBalancerPoolInterface.get(loadBalancerPoolUUID)
- .getLoadBalancerPoolMembers();
- List<NeutronLoadBalancerPoolMember> ans = new ArrayList<>();
- for (NeutronLoadBalancerPoolMember nsg : members) {
- if ((queryLoadBalancerPoolMemberID == null || queryLoadBalancerPoolMemberID.equals(nsg.getID()))
- && loadBalancerPoolUUID.equals(nsg.getPoolID())
- && (queryLoadBalancerPoolMemberTenantID == null
- || queryLoadBalancerPoolMemberTenantID.equals(nsg.getTenantID()))
- && (queryLoadBalancerPoolMemberAddress == null
- || queryLoadBalancerPoolMemberAddress.equals(nsg.getPoolMemberAddress()))
- && (queryLoadBalancerPoolMemberAdminStateUp == null
- || queryLoadBalancerPoolMemberAdminStateUp.equals(nsg.getPoolMemberAdminStateIsUp()))
- && (queryLoadBalancerPoolMemberWeight == null
- || queryLoadBalancerPoolMemberWeight.equals(nsg.getPoolMemberWeight()))
- && (queryLoadBalancerPoolMemberSubnetID == null
- || queryLoadBalancerPoolMemberSubnetID.equals(nsg.getPoolMemberSubnetID()))) {
- if (fields.size() > 0) {
- ans.add(nsg.extractFields(fields));
- } else {
- ans.add(nsg);
+ List<NeutronLoadBalancerPoolMember> members = loadBalancerPoolInterface.get(loadBalancerPoolUUID)
+ .getLoadBalancerPoolMembers();
+ List<NeutronLoadBalancerPoolMember> ans = new ArrayList<>();
+ for (NeutronLoadBalancerPoolMember nsg : members) {
+ if ((queryLoadBalancerPoolMemberID == null || queryLoadBalancerPoolMemberID.equals(nsg.getID()))
+ && loadBalancerPoolUUID.equals(nsg.getPoolID())
+ && (queryLoadBalancerPoolMemberTenantID == null
+ || queryLoadBalancerPoolMemberTenantID.equals(nsg.getTenantID()))
+ && (queryLoadBalancerPoolMemberAddress == null
+ || queryLoadBalancerPoolMemberAddress.equals(nsg.getPoolMemberAddress()))
+ && (queryLoadBalancerPoolMemberAdminStateUp == null
+ || queryLoadBalancerPoolMemberAdminStateUp.equals(nsg.getPoolMemberAdminStateIsUp()))
+ && (queryLoadBalancerPoolMemberWeight == null
+ || queryLoadBalancerPoolMemberWeight.equals(nsg.getPoolMemberWeight()))
+ && (queryLoadBalancerPoolMemberSubnetID == null
+ || queryLoadBalancerPoolMemberSubnetID.equals(nsg.getPoolMemberSubnetID()))) {
+ if (fields.size() > 0) {
+ ans.add(nsg.extractFields(fields));
+ } else {
+ ans.add(nsg);
+ }
- INeutronLoadBalancerPoolCRUD loadBalancerPoolInterface = getNeutronCRUD();
- try (ReadOnlyTransaction tx = dataBroker.newReadOnlyTransaction()) {
- if (!loadBalancerPoolInterface.exists(loadBalancerPoolUUID, tx)) {
- throw new ResourceNotFoundException(uuidNoExist());
- }
- }
- List<NeutronLoadBalancerPoolMember> members = loadBalancerPoolInterface.get(loadBalancerPoolUUID)
- .getLoadBalancerPoolMembers();
- for (NeutronLoadBalancerPoolMember ans : members) {
- if (!ans.getID().equals(loadBalancerPoolMemberUUID)) {
- continue;
+ try {
+ INeutronLoadBalancerPoolCRUD loadBalancerPoolInterface = getNeutronCRUD();
+ try (ReadOnlyTransaction tx = dataBroker.newReadOnlyTransaction()) {
+ if (!loadBalancerPoolInterface.exists(loadBalancerPoolUUID, tx)) {
+ throw new ResourceNotFoundException(uuidNoExist());
+ }
- if (fields.size() > 0) {
- return Response.status(HttpURLConnection.HTTP_OK)
- .entity(new NeutronLoadBalancerPoolMemberRequest(ans.extractFields(fields))).build();
- } else {
- return Response.status(HttpURLConnection.HTTP_OK).entity(new NeutronLoadBalancerPoolMemberRequest(ans))
- .build();
+ if (fields.size() > 0) {
+ return Response.status(HttpURLConnection.HTTP_OK)
+ .entity(new NeutronLoadBalancerPoolMemberRequest(ans.extractFields(fields))).build();
+ } else {
+ return Response.status(HttpURLConnection.HTTP_OK)
+ .entity(new NeutronLoadBalancerPoolMemberRequest(ans)).build();
+ }
@ResponseCode(code = HttpURLConnection.HTTP_UNAVAILABLE, condition = "No providers available") })
public Response createLoadBalancerPoolMember(@PathParam("loadBalancerPoolUUID") String loadBalancerPoolUUID,
final NeutronLoadBalancerPoolMemberRequest input) {
@ResponseCode(code = HttpURLConnection.HTTP_UNAVAILABLE, condition = "No providers available") })
public Response createLoadBalancerPoolMember(@PathParam("loadBalancerPoolUUID") String loadBalancerPoolUUID,
final NeutronLoadBalancerPoolMemberRequest input) {
- INeutronLoadBalancerPoolCRUD loadBalancerPoolInterface = getNeutronCRUD();
-
- if (input.isSingleton()) {
- NeutronLoadBalancerPoolMember singleton = input.getSingleton();
- singleton.setPoolID(loadBalancerPoolUUID);
- /**
- * Add the member from the neutron load balancer pool as well
- */
+ if (input.isSingleton()) {
+ NeutronLoadBalancerPoolMember singleton = input.getSingleton();
+ singleton.setPoolID(loadBalancerPoolUUID);
+ /**
+ * Add the member from the neutron load balancer pool as well
+ */
- loadBalancerPoolInterface.addNeutronLoadBalancerPoolMember(loadBalancerPoolUUID, singleton);
- } else {
- /*
- * now, each element of the bulk request can be added to the cache
- */
- for (NeutronLoadBalancerPoolMember test : input.getBulk()) {
- loadBalancerPoolInterface.addNeutronLoadBalancerPoolMember(loadBalancerPoolUUID, test);
+ loadBalancerPoolInterface.addNeutronLoadBalancerPoolMember(loadBalancerPoolUUID, singleton);
+ } else {
+ /*
+ * now, each element of the bulk request can be added to the cache
+ */
+ for (NeutronLoadBalancerPoolMember test : input.getBulk()) {
+ loadBalancerPoolInterface.addNeutronLoadBalancerPoolMember(loadBalancerPoolUUID, test);
+ }
public Response updateLoadBalancerPoolMember(@PathParam("loadBalancerPoolUUID") String loadBalancerPoolUUID,
@PathParam("loadBalancerPoolMemberUUID") String loadBalancerPoolMemberUUID,
final NeutronLoadBalancerPoolMemberRequest input) {
public Response updateLoadBalancerPoolMember(@PathParam("loadBalancerPoolUUID") String loadBalancerPoolUUID,
@PathParam("loadBalancerPoolMemberUUID") String loadBalancerPoolMemberUUID,
final NeutronLoadBalancerPoolMemberRequest input) {
- INeutronLoadBalancerPoolCRUD loadBalancerPoolInterface = getNeutronCRUD();
- NeutronLoadBalancerPool singletonPool = loadBalancerPoolInterface.get(loadBalancerPoolUUID);
- NeutronLoadBalancerPoolMember singleton = input.getSingleton();
- singleton.setPoolID(loadBalancerPoolUUID);
+ try {
+ INeutronLoadBalancerPoolCRUD loadBalancerPoolInterface = getNeutronCRUD();
+ NeutronLoadBalancerPool singletonPool = loadBalancerPoolInterface.get(loadBalancerPoolUUID);
+ NeutronLoadBalancerPoolMember singleton = input.getSingleton();
+ singleton.setPoolID(loadBalancerPoolUUID);
- if (singletonPool == null) {
- throw new ResourceNotFoundException("Pool doesn't Exist");
+ if (singletonPool == null) {
+ throw new ResourceNotFoundException("Pool doesn't Exist");
+ }
+ loadBalancerPoolInterface.updateNeutronLoadBalancerPoolMember(loadBalancerPoolUUID,
+ loadBalancerPoolMemberUUID, singleton);
+ return Response.status(HttpURLConnection.HTTP_OK).entity(input).build();
+ } catch (OperationFailedException e) {
+ throw new DatastoreOperationFailedWebApplicationException(e);
@ResponseCode(code = HttpURLConnection.HTTP_UNAVAILABLE, condition = "No providers available") })
public Response deleteLoadBalancerPoolMember(@PathParam("loadBalancerPoolUUID") String loadBalancerPoolUUID,
@PathParam("loadBalancerPoolMemberUUID") String loadBalancerPoolMemberUUID) {
@ResponseCode(code = HttpURLConnection.HTTP_UNAVAILABLE, condition = "No providers available") })
public Response deleteLoadBalancerPoolMember(@PathParam("loadBalancerPoolUUID") String loadBalancerPoolUUID,
@PathParam("loadBalancerPoolMemberUUID") String loadBalancerPoolMemberUUID) {
- INeutronLoadBalancerPoolCRUD loadBalancerPoolInterface = getNeutronCRUD();
-
- //Verify that the LB pool member exists
- NeutronLoadBalancerPoolMember singleton = null;
- List<NeutronLoadBalancerPoolMember> members = loadBalancerPoolInterface.get(loadBalancerPoolUUID)
- .getLoadBalancerPoolMembers();
- for (NeutronLoadBalancerPoolMember member : members) {
- if (member.getID().equals(loadBalancerPoolMemberUUID)) {
- singleton = member;
- break;
+ try {
+ INeutronLoadBalancerPoolCRUD loadBalancerPoolInterface = getNeutronCRUD();
+ // Verify that the LB pool member exists
+ NeutronLoadBalancerPoolMember singleton = null;
+ List<NeutronLoadBalancerPoolMember> members = loadBalancerPoolInterface.get(loadBalancerPoolUUID)
+ .getLoadBalancerPoolMembers();
+ for (NeutronLoadBalancerPoolMember member : members) {
+ if (member.getID().equals(loadBalancerPoolMemberUUID)) {
+ singleton = member;
+ break;
+ }
+ }
+ if (singleton == null) {
+ throw new BadRequestException("LoadBalancerPoolMember UUID does not exist.");
- /**
- * Remove the member from the neutron load balancer pool
- */
- loadBalancerPoolInterface.removeNeutronLoadBalancerPoolMember(loadBalancerPoolUUID, loadBalancerPoolMemberUUID);
+ /**
+ * Remove the member from the neutron load balancer pool
+ */
+ loadBalancerPoolInterface.removeNeutronLoadBalancerPoolMember(loadBalancerPoolUUID,
+ loadBalancerPoolMemberUUID);