import org.openbaton.catalogue.mano.record.VNFCInstance; //导入依赖的package包/类
/**
 * Make a VNFCInstance switch into standby mode.
 *
 * @param idNsr the ID of the NetworkServiceRecord containing the VNFCInstance
 * @param idVnfr the ID of the VirtualNetworkFunctionRecord containing the VNFCInstance
 * @param idVdu the ID of the VirtualDeploymentUnit containing the VNFCInstance
 * @param idVnfc the ID on the VNFCInstance that shall switch into standby mode
 * @param failedVnfcInstance
 * @throws SDKException
 */
@Help(help = "Switch to standby")
public void switchToStandby(
    final String idNsr,
    final String idVnfr,
    final String idVdu,
    final String idVnfc,
    final VNFCInstance failedVnfcInstance)
    throws SDKException {
  String url =
      idNsr
          + "/vnfrecords/"
          + idVnfr
          + "/vdunits/"
          + idVdu
          + "/vnfcinstances/"
          + idVnfc
          + "/switchtostandby";
  requestPost(url, failedVnfcInstance);
}
 

import org.openbaton.catalogue.mano.record.VNFCInstance; //导入依赖的package包/类
private void updateScript(
    Script script,
    VirtualNetworkFunctionRecord virtualNetworkFunctionRecord,
    VNFCInstance vnfcInstance)
    throws Exception {
  JsonObject jsonMessage =
      JsonUtils.getJsonObjectForScript(
          "SCRIPTS_UPDATE",
          Base64.encodeBase64String(script.getPayload()),
          script.getName(),
          properties.getProperty("script-path", "/opt/openbaton/scripts"));
  ems.executeActionOnEMS(
      vnfcInstance.getHostname(),
      jsonMessage.toString(),
      virtualNetworkFunctionRecord,
      vnfcInstance);
}
 

import org.openbaton.catalogue.mano.record.VNFCInstance; //导入依赖的package包/类
/**
 * Execute the switch to standby action on a VNFR. This action starts the standby VNFC and sets
 * the failed VNFC in failed state. Eventually configures the dependent VNFRs.
 *
 * @param failedVnfcInstance failed VNFC instance as JSON
 * @param id NSR Id
 * @param idVnf VNFR Id
 * @param idVdu VDU Id
 * @param idVNFC VNFC Id of the standby VNFC
 * @param projectId Project Id
 * @throws NotFoundException
 * @throws BadFormatException
 * @throws WrongStatusException
 * @throws ExecutionException
 * @throws InterruptedException
 */
@ApiOperation(
  value = "Execute the switch to standby action on a VNFR",
  notes =
      "This action starts the standby VNFC and sets the failed VNFC in failed state. Eventually configures the dependent VNFRs"
)
@RequestMapping(
  value = "{id}/vnfrecords/{idVnf}/vdunits/{idVdu}/vnfcinstances/{idVNFC}/switchtostandby",
  method = RequestMethod.POST,
  consumes = MediaType.APPLICATION_JSON_VALUE
)
@ResponseStatus(HttpStatus.CREATED)
public void switchToRendundantVNFCInstance(
    @RequestBody @Valid VNFCInstance failedVnfcInstance,
    @PathVariable("id") String id,
    @PathVariable("idVnf") String idVnf,
    @PathVariable("idVdu") String idVdu,
    @PathVariable("idVNFC") String idVNFC,
    @RequestHeader(value = "project-id") String projectId)
    throws NotFoundException, BadFormatException, WrongStatusException, ExecutionException,
        InterruptedException {
  log.debug("switch to a standby component");
  networkServiceRecordManagement.switchToRedundantVNFCInstance(
      id, idVnf, idVdu, idVNFC, "standby", failedVnfcInstance, projectId);
}
 

import org.openbaton.catalogue.mano.record.VNFCInstance; //导入依赖的package包/类
@Override
protected NFVMessage doWork() throws Exception {
  log.info("Release resources for VNFR: " + virtualNetworkFunctionRecord.getName());

  for (VirtualDeploymentUnit virtualDeploymentUnit : virtualNetworkFunctionRecord.getVdu()) {
    log.debug(
        "Removing VDU: "
            + virtualDeploymentUnit.getHostname()
            + " from VNFR "
            + virtualNetworkFunctionRecord.getId());
    for (VNFCInstance vnfcInstance : virtualDeploymentUnit.getVnfc_instance()) {
      log.debug(
          "Removing VNFC instance: "
              + vnfcInstance
              + " from VNFR "
              + virtualNetworkFunctionRecord.getId());
      this.resourceManagement.release(virtualDeploymentUnit, vnfcInstance);
    }
  }
  setHistoryLifecycleEvent(new Date());
  saveVirtualNetworkFunctionRecord();
  return null;
}
 

import org.openbaton.catalogue.mano.record.VNFCInstance; //导入依赖的package包/类
/**
 * Returns the VNFCInstance with the passed ID from a specific VDU. If null is passed for the
 * VNFCInstance ID, the first VNFCInstance in the VDU is returned.
 *
 * @param virtualDeploymentUnit the VDU holding the VNFCinstance
 * @param idVNFCI the id of the VNFCInstance
 * @return the VNFCinstance
 * @throws NotFoundException if not found
 */
private VNFCInstance getVNFCInstance(VirtualDeploymentUnit virtualDeploymentUnit, String idVNFCI)
    throws NotFoundException {

  for (VNFCInstance vnfcInstance : virtualDeploymentUnit.getVnfc_instance()) {
    if (idVNFCI == null || idVNFCI.equals(vnfcInstance.getId())) {
      return vnfcInstance;
    }
  }

  if (idVNFCI != null) {
    throw new NotFoundException(
        "VNFCInstance with ID "
            + idVNFCI
            + " was not found in VDU with ID "
            + virtualDeploymentUnit.getId());
  } else {
    throw new NotFoundException(
        "No VNFCInstance found in VDU with ID " + virtualDeploymentUnit.getId());
  }
}
 

import org.openbaton.catalogue.mano.record.VNFCInstance; //导入依赖的package包/类
@Override
public VnfmOrLogMessage getLog(String nsrId, String vnfrName, String hostname)
    throws NotFoundException, InterruptedException, BadFormatException, ExecutionException {
  for (VirtualNetworkFunctionRecord virtualNetworkFunctionRecord :
      networkServiceRecordRepository.findFirstById(nsrId).getVnfr()) {
    if (virtualNetworkFunctionRecord.getName().equals(vnfrName)) {
      for (VirtualDeploymentUnit virtualDeploymentUnit : virtualNetworkFunctionRecord.getVdu()) {
        for (VNFCInstance vnfcInstance : virtualDeploymentUnit.getVnfc_instance()) {
          if (hostname.equals(vnfcInstance.getHostname())) {

            log.debug("Requesting log from VNFM");
            Future<NFVMessage> futureMessage =
                vnfmManager.requestLog(virtualNetworkFunctionRecord, hostname);
            VnfmOrLogMessage vnfmOrLogMessage = (VnfmOrLogMessage) futureMessage.get();
            return vnfmOrLogMessage;
          }
        }
      }
    }
  }

  throw new NotFoundException("Error something was not found");
}
 

import org.openbaton.catalogue.mano.record.VNFCInstance; //导入依赖的package包/类
@Test
public void nsrManagementDeleteTest()
    throws VimException, InterruptedException, ExecutionException, NamingException,
        NotFoundException, WrongStatusException, PluginException, BadFormatException {
  NetworkServiceRecord nsd_exp = createNetworkServiceRecord();
  when(resourceManagement.release(any(VirtualDeploymentUnit.class), any(VNFCInstance.class)))
      .thenReturn(new AsyncResult<Void>(null));
  when(nsrRepository.findFirstByIdAndProjectId(nsd_exp.getId(), projectId)).thenReturn(nsd_exp);
  Configuration system = new Configuration();
  system.setConfigurationParameters(new HashSet<>());
  ConfigurationParameter configurationParameter = new ConfigurationParameter();
  configurationParameter.setConfKey("delete-on-all-status");
  configurationParameter.setValue("true");
  when(configurationManagement.queryByName("system")).thenReturn(system);
  nsrManagement.delete(nsd_exp.getId(), projectId);
}
 

import org.openbaton.catalogue.mano.record.VNFCInstance; //导入依赖的package包/类
private VNFCInstance getVnfcInstance(
    VirtualNetworkFunctionRecord virtualNetworkFunctionRecord, VNFComponent component) {
  VNFCInstance vnfcInstance_new = null;
  boolean found = false;
  for (VirtualDeploymentUnit virtualDeploymentUnit : virtualNetworkFunctionRecord.getVdu()) {
    for (VNFCInstance vnfcInstance : virtualDeploymentUnit.getVnfc_instance()) {
      if (vnfcInstance.getVnfComponent().getId().equals(component.getId())) {
        vnfcInstance_new = vnfcInstance;
        fillProvidesVNFC(virtualNetworkFunctionRecord, vnfcInstance);
        found = true;
        log.debug("VNFComponentInstance FOUND : " + vnfcInstance_new.getVnfComponent());
        break;
      }
    }
    if (found) {
      break;
    }
  }
  return vnfcInstance_new;
}
 

import org.openbaton.catalogue.mano.record.VNFCInstance; //导入依赖的package包/类
@Override
public VirtualNetworkFunctionRecord heal(
    VirtualNetworkFunctionRecord virtualNetworkFunctionRecord,
    VNFCInstance component,
    String cause)
    throws Exception {
  return virtualNetworkFunctionRecord;
}
 

import org.openbaton.catalogue.mano.record.VNFCInstance; //导入依赖的package包/类
@Override
public VirtualNetworkFunctionRecord resume(
    VirtualNetworkFunctionRecord virtualNetworkFunctionRecord,
    VNFCInstance vnfcInstance,
    VNFRecordDependency dependency)
    throws Exception {
  return virtualNetworkFunctionRecord;
}
 

import org.openbaton.catalogue.mano.record.VNFCInstance; //导入依赖的package包/类
@Override
public VirtualNetworkFunctionRecord updateSoftware(
    Script script, VirtualNetworkFunctionRecord virtualNetworkFunctionRecord) throws Exception {
  for (VirtualDeploymentUnit vdu : virtualNetworkFunctionRecord.getVdu()) {
    for (VNFCInstance vnfcInstance : vdu.getVnfc_instance()) {
      updateScript(script, virtualNetworkFunctionRecord, vnfcInstance);
    }
  }
  return virtualNetworkFunctionRecord;
}
 

import org.openbaton.catalogue.mano.record.VNFCInstance; //导入依赖的package包/类
@Override
public VirtualNetworkFunctionRecord terminate(
    VirtualNetworkFunctionRecord virtualNetworkFunctionRecord) throws Exception {
  log.debug("Termination of VNF: " + virtualNetworkFunctionRecord.getName());
  if (VnfmUtils.getLifecycleEvent(
          virtualNetworkFunctionRecord.getLifecycle_event(), Event.TERMINATE)
      != null) {
    StringBuilder output = new StringBuilder("\n--------------------\n--------------------\n");
    for (String result :
        lcm.executeScriptsForEvent(virtualNetworkFunctionRecord, Event.TERMINATE)) {
      output.append(JsonUtils.parse(result));
      output.append("\n--------------------\n");
    }
    output.append("\n--------------------\n");
    log.info("Executed script for TERMINATE. Output was: \n\n" + output);
  }

  for (VirtualDeploymentUnit vdu : virtualNetworkFunctionRecord.getVdu()) {
    for (VNFCInstance vnfci : vdu.getVnfc_instance()) {
      try {
        ems.removeRegistrationUnit(vnfci.getHostname());
      } catch (BadFormatException e) {
        e.printStackTrace();
      }
    }
  }

  return virtualNetworkFunctionRecord;
}
 

import org.openbaton.catalogue.mano.record.VNFCInstance; //导入依赖的package包/类
@Override
public VirtualNetworkFunctionRecord startVNFCInstance(
    VirtualNetworkFunctionRecord virtualNetworkFunctionRecord, VNFCInstance vnfcInstance)
    throws Exception {

  log.info("Starting vnfc instance: " + vnfcInstance.getHostname());

  if (VnfmUtils.getLifecycleEvent(virtualNetworkFunctionRecord.getLifecycle_event(), Event.START)
      != null) {
    if (VnfmUtils.getLifecycleEvent(
                virtualNetworkFunctionRecord.getLifecycle_event(), Event.START)
            .getLifecycle_events()
        != null) {
      StringBuilder output = new StringBuilder("\n--------------------\n--------------------\n");
      for (String result :
          lcm.executeScriptsForEvent(virtualNetworkFunctionRecord, vnfcInstance, Event.START)) {
        output.append(JsonUtils.parse(result));
        output.append("\n--------------------\n");
      }
      output.append("\n--------------------\n");
      log.info(
          "Executed script for START on VNFC Instance "
              + vnfcInstance.getHostname()
              + ". Output was: \n\n"
              + output);
    }
  }

  return virtualNetworkFunctionRecord;
}
 

import org.openbaton.catalogue.mano.record.VNFCInstance; //导入依赖的package包/类
@Override
public VirtualNetworkFunctionRecord stopVNFCInstance(
    VirtualNetworkFunctionRecord virtualNetworkFunctionRecord, VNFCInstance vnfcInstance)
    throws Exception {

  log.info("Stopping vnfc instance: " + vnfcInstance.getHostname());

  if (VnfmUtils.getLifecycleEvent(virtualNetworkFunctionRecord.getLifecycle_event(), Event.STOP)
      != null) {
    if (VnfmUtils.getLifecycleEvent(virtualNetworkFunctionRecord.getLifecycle_event(), Event.STOP)
            .getLifecycle_events()
        != null) {
      StringBuilder output = new StringBuilder("\n--------------------\n--------------------\n");
      for (String result :
          lcm.executeScriptsForEvent(virtualNetworkFunctionRecord, vnfcInstance, Event.STOP)) {
        output.append(JsonUtils.parse(result));
        output.append("\n--------------------\n");
      }
      output.append("\n--------------------\n");
      log.info(
          "Executed script for STOP on VNFC Instance "
              + vnfcInstance.getHostname()
              + ". Output was: \n\n"
              + output);
    }
  }

  return virtualNetworkFunctionRecord;
}
 

import org.openbaton.catalogue.mano.record.VNFCInstance; //导入依赖的package包/类
@Override
public VirtualNetworkFunctionRecord resume(
    VirtualNetworkFunctionRecord virtualNetworkFunctionRecord,
    VNFCInstance vnfcInstance,
    VNFRecordDependency dependency) {
  return virtualNetworkFunctionRecord;
}
 

import org.openbaton.catalogue.mano.record.VNFCInstance; //导入依赖的package包/类
public synchronized void saveLogToFile(
    VirtualNetworkFunctionRecord virtualNetworkFunctionRecord,
    String script,
    VNFCInstance vnfcInstance1,
    String output)
    throws IOException {
  saveLogToFile(virtualNetworkFunctionRecord, script, vnfcInstance1, output, false);
}
 

import org.openbaton.catalogue.mano.record.VNFCInstance; //导入依赖的package包/类
@Override
public VirtualNetworkFunctionRecord stopVNFCInstance(
    VirtualNetworkFunctionRecord virtualNetworkFunctionRecord, VNFCInstance vnfcInstance)
    throws Exception {
  log.info(
      "Stop VNFCInstance " + vnfcInstance.getHostname() + " with id " + vnfcInstance.getId());
  return virtualNetworkFunctionRecord;
}
 

import org.openbaton.catalogue.mano.record.VNFCInstance; //导入依赖的package包/类
public OrVnfmStartStopMessage(
    VirtualNetworkFunctionRecord virtualNetworkFunctionRecord,
    VNFCInstance vnfcInstance,
    Action action) {
  this.virtualNetworkFunctionRecord = virtualNetworkFunctionRecord;
  this.vnfcInstance = vnfcInstance;
  this.action = action;
}
 

import org.openbaton.catalogue.mano.record.VNFCInstance; //导入依赖的package包/类
/**
 * Fill the Map vnfrVnfc.
 *
 * @param nsr
 */
private void fillVnfrVnfc(NetworkServiceRecord nsr) {
  for (VirtualNetworkFunctionRecord vnfr : nsr.getVnfr()) {
    List<VNFCRepresentation> representationList = new LinkedList<>();
    Configuration conf = vnfr.getConfigurations();
    Map<String, String> confMap = new HashMap<>();
    for (ConfigurationParameter confPar : conf.getConfigurationParameters()) {
      confMap.put(confPar.getConfKey(), confPar.getValue());
    }
    for (VirtualDeploymentUnit vdu : vnfr.getVdu()) {
      for (VNFCInstance vnfcInstance : vdu.getVnfc_instance()) {
        VNFCRepresentation vnfcRepresentation = new VNFCRepresentation();
        vnfcRepresentation.setVnfrName(vnfr.getName());
        vnfcRepresentation.setHostname(vnfcInstance.getHostname());
        vnfcRepresentation.setConfiguration(confMap);
        for (Ip ip : vnfcInstance.getIps()) {
          vnfcRepresentation.addNetIp(ip.getNetName(), ip.getIp());
        }
        for (Ip fIp : vnfcInstance.getFloatingIps()) {
          vnfcRepresentation.addNetFip(fIp.getNetName(), fIp.getIp());
        }
        representationList.add(vnfcRepresentation);
      }
    }
    if (!vnfrVnfc.containsKey(vnfr.getType())) {
      vnfrVnfc.put(vnfr.getType(), representationList);
    } else {
      List<VNFCRepresentation> l = vnfrVnfc.get(vnfr.getType());
      l.addAll(representationList);
    }
  }
}
 

import org.openbaton.catalogue.mano.record.VNFCInstance; //导入依赖的package包/类
public VnfmOrStartStopMessage(
    VirtualNetworkFunctionRecord virtualNetworkFunctionRecord,
    VNFCInstance vnfcInstance,
    Action action) {
  this.virtualNetworkFunctionRecord = virtualNetworkFunctionRecord;
  this.vnfcInstance = vnfcInstance;
  this.action = action;
}