import org.openbaton.catalogue.mano.record.VirtualNetworkFunctionRecord; //导入依赖的package包/类
/**
 * Deactivates autoscaling for the passed NSR
 *
 * @param msg : NSR in payload to add for autoscaling
 */
@RequestMapping(
  value = "RELEASE_RESOURCES_FINISH",
  method = RequestMethod.POST,
  consumes = MediaType.APPLICATION_JSON_VALUE,
  produces = MediaType.APPLICATION_JSON_VALUE
)
@ResponseStatus(HttpStatus.CREATED)
public void deactivate(@RequestBody String msg) throws NotFoundException {
  log.trace("msg=" + msg);
  JsonParser jsonParser = new JsonParser();
  JsonObject json = jsonParser.parse(msg).getAsJsonObject();
  Gson mapper = new GsonBuilder().create();
  Action action = mapper.fromJson(json.get("action"), Action.class);
  log.trace("ACTION=" + action);
  NetworkServiceRecord nsr = mapper.fromJson(json.get("payload"), NetworkServiceRecord.class);
  log.trace("NSR=" + nsr);
  for (VirtualNetworkFunctionRecord vnfr : nsr.getVnfr()) {
    elasticityManagement.deactivate(nsr.getProjectId(), nsr.getId(), vnfr);
  }
}
 

import org.openbaton.catalogue.mano.record.VirtualNetworkFunctionRecord; //导入依赖的package包/类
@Override
public VNFRecordDependency getDependencyForAVNFRecordTarget(
    VirtualNetworkFunctionRecord virtualNetworkFunctionRecord) {
  NetworkServiceRecord nsr =
      nsrRepository.findFirstById(virtualNetworkFunctionRecord.getParent_ns_id());
  if (nsr.getStatus().ordinal() != Status.ERROR.ordinal()) {
    Set<VNFRecordDependency> vnfRecordDependencies = nsr.getVnf_dependency();

    for (VNFRecordDependency vnfRecordDependency : vnfRecordDependencies) {
      vnfRecordDependency = vnfrDependencyRepository.findOne(vnfRecordDependency.getId());

      if (vnfRecordDependency.getTarget().equals(virtualNetworkFunctionRecord.getName())) {
        return vnfRecordDependency;
      }
    }
  }
  return null;
}
 

import org.openbaton.catalogue.mano.record.VirtualNetworkFunctionRecord; //导入依赖的package包/类
@Override
public void handleError(VirtualNetworkFunctionRecord virtualNetworkFunctionRecord) {
  log.error("Received Error for VNFR " + virtualNetworkFunctionRecord.getName());
  if (VnfmUtils.getLifecycleEvent(virtualNetworkFunctionRecord.getLifecycle_event(), Event.ERROR)
      != null) {
    StringBuilder output = new StringBuilder("\n--------------------\n--------------------\n");
    try {
      for (String result :
          lcm.executeScriptsForEvent(virtualNetworkFunctionRecord, Event.ERROR)) {
        output.append(JsonUtils.parse(result));
        output.append("\n--------------------\n");
      }
    } catch (Exception e) {
      e.printStackTrace();
      log.error("Exception executing Error handling");
    }
    output.append("\n--------------------\n");
    log.info("Executed script for ERROR. Output was: \n\n" + output);
  }
}
 

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

  log.info("Starting vnfr: " + virtualNetworkFunctionRecord.getName());

  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, Event.START)) {
        output.append(JsonUtils.parse(result));
        output.append("\n--------------------\n");
      }
      output.append("\n--------------------\n");
      log.info("Executed script for START. Output was: \n\n" + output);
    }
  }
  return virtualNetworkFunctionRecord;
}
 

import org.openbaton.catalogue.mano.record.VirtualNetworkFunctionRecord; //导入依赖的package包/类
public Set<String> getNotInitializedVnfrSource(Set<String> ids, NetworkServiceRecord nsr) {

    Set<String> res = new HashSet<>();
    for (String sourceName : ids) {
      log.debug("Looking for VNFR name: " + sourceName);
      boolean found = false;
      for (VirtualNetworkFunctionRecord vnfr : nsr.getVnfr()) {
        if (sourceName.equals(vnfr.getName())) {
          found = true;
          if (vnfr.getStatus().ordinal() < Status.INITIALIZED.ordinal())
            res.add(vnfr.getName() + nsr.getId());
        }
      }
      if (!found) res.add(sourceName + nsr.getId());
    }
    if (!res.isEmpty()) log.debug("There are the following not initialized vnfr sources:" + res);
    return res;
  }
 

import org.openbaton.catalogue.mano.record.VirtualNetworkFunctionRecord; //导入依赖的package包/类
private void sendStart(VirtualNetworkFunctionRecord virtualNetworkFunctionRecord)
    throws NotFoundException, BadFormatException, ExecutionException, InterruptedException {
  VnfmSender vnfmSender;
  vnfmSender =
      this.getVnfmSender(
          vnfmRegister.getVnfm(virtualNetworkFunctionRecord.getEndpoint()).getEndpointType());
  log.info(
      "Calling START to: "
          + virtualNetworkFunctionRecord.getName()
          + " because it has 0 dependencies");
  log.trace(
      "VNFR ("
          + virtualNetworkFunctionRecord.getId()
          + ") hibernate version is = "
          + virtualNetworkFunctionRecord.getHbVersion());
  /*vnfmSender.sendCommand(
  new OrVnfmGenericMessage(virtualNetworkFunctionRecord, Action.START),
  vnfmRegister.getVnfm(virtualNetworkFunctionRecord.getEndpoint()));*/
  vnfStateHandler.executeAction(
      vnfmSender.sendCommand(
          new OrVnfmStartStopMessage(virtualNetworkFunctionRecord, null, Action.START),
          vnfmRegister.getVnfm(virtualNetworkFunctionRecord.getEndpoint())));
}
 

import org.openbaton.catalogue.mano.record.VirtualNetworkFunctionRecord; //导入依赖的package包/类
/**
 * Returns the list of VirtualNetworkFunctionDescriptor into a NSD with id
 *
 * @param id of NSD
 * @return Set<VirtualNetworkFunctionDescriptor>: List of VirtualNetworkFunctionDescriptor into
 *     NSD
 */
@ApiOperation(
  value = "Returns the Virtual Network Function Records of a NSR",
  notes = "Returns all the VNFRs that are part of the specified NSR"
)
@RequestMapping(
  value = "{id}/vnfrecords",
  method = RequestMethod.GET,
  produces = MediaType.APPLICATION_JSON_VALUE
)
@ResponseStatus(HttpStatus.OK)
public Set<VirtualNetworkFunctionRecord> getVirtualNetworkFunctionRecords(
    @PathVariable("id") String id, @RequestHeader(value = "project-id") String projectId)
    throws NotFoundException {
  NetworkServiceRecord nsr = networkServiceRecordManagement.query(id, projectId);
  log.trace("*****" + nsr.getVnfr().toString());
  return nsr.getVnfr();
}
 

import org.openbaton.catalogue.mano.record.VirtualNetworkFunctionRecord; //导入依赖的package包/类
@Override
@Async
public Future<NFVMessage> requestLog(VirtualNetworkFunctionRecord vnfr, String hostname)
    throws NotFoundException, BadFormatException, ExecutionException, InterruptedException {
  VnfmManagerEndpoint endpoint = generator.getVnfm(vnfr.getEndpoint());
  if (endpoint == null)
    throw new NotFoundException(
        "VnfManager of type "
            + vnfr.getType()
            + " (endpoint = "
            + vnfr.getEndpoint()
            + ") is not registered");

  OrVnfmLogMessage orVnfmLogMessage = new OrVnfmLogMessage(vnfr.getName(), hostname);
  VnfmSender vnfmSender;
  try {
    vnfmSender = generator.getVnfmSender(endpoint.getEndpointType());
  } catch (BeansException e) {
    throw new NotFoundException(e);
  }
  Future<NFVMessage> answerFuture = vnfmSender.sendCommand(orVnfmLogMessage, endpoint);
  answerFuture.get();
  NFVMessage message = answerFuture.get();
  return new AsyncResult<>(message);
}
 

import org.openbaton.catalogue.mano.record.VirtualNetworkFunctionRecord; //导入依赖的package包/类
public void addVnfr(VirtualNetworkFunctionRecord vnfr) {
  for (VirtualNetworkFunctionRecord vnfrAlreadyPresent : vnfrList) {
    if (vnfrAlreadyPresent.getId().equals(vnfr.getId())) {
      return;
    }
  }
  vnfrList.add(vnfr);
}
 

import org.openbaton.catalogue.mano.record.VirtualNetworkFunctionRecord; //导入依赖的package包/类
@Override
public VirtualNetworkFunctionRecord instantiate(
    VirtualNetworkFunctionRecord virtualNetworkFunctionRecord,
    Object scripts,
    Map<String, Collection<VimInstance>> vimInstances)
    throws Exception {
  return virtualNetworkFunctionRecord;
}
 

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

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

import org.openbaton.catalogue.mano.record.VirtualNetworkFunctionRecord; //导入依赖的package包/类
@Override
public VirtualNetworkFunctionRecord scale(
    Action scaleInOrOut,
    VirtualNetworkFunctionRecord virtualNetworkFunctionRecord,
    VNFComponent component,
    Object scripts,
    VNFRecordDependency dependency)
    throws Exception {
  return virtualNetworkFunctionRecord;
}
 

import org.openbaton.catalogue.mano.record.VirtualNetworkFunctionRecord; //导入依赖的package包/类
public void scaleOutTo(String projectId, VirtualNetworkFunctionRecord vnfr, int value)
    throws SDKException, NotFoundException, VimException {
  int vnfci_counter = 0;
  for (VirtualDeploymentUnit vdu : vnfr.getVdu()) {
    vnfci_counter += vdu.getVnfc_instance().size();
  }
  for (int i = vnfci_counter + 1; i <= value; i++) {
    scaleOut(projectId, vnfr, 1);
  }
}
 

import org.openbaton.catalogue.mano.record.VirtualNetworkFunctionRecord; //导入依赖的package包/类
public void scaleInTo(String projectId, VirtualNetworkFunctionRecord vnfr, int value)
    throws SDKException, NotFoundException, VimException {
  int vnfci_counter = 0;
  for (VirtualDeploymentUnit vdu : vnfr.getVdu()) {
    vnfci_counter += vdu.getVnfc_instance().size();
  }
  for (int i = vnfci_counter; i > value; i--) {
    scaleIn(projectId, vnfr, 1);
  }
}
 

import org.openbaton.catalogue.mano.record.VirtualNetworkFunctionRecord; //导入依赖的package包/类
public void activate(NetworkServiceRecord nsr)
    throws NotFoundException, VimException, SDKException {
  log.debug("Activating Elasticity for NSR with id: " + nsr.getId());
  for (VirtualNetworkFunctionRecord vnfr : nsr.getVnfr()) {
    for (AutoScalePolicy autoScalePolicy : vnfr.getAuto_scale_policy())
      detectionManagment.start(nsr.getProjectId(), nsr.getId(), vnfr.getId(), autoScalePolicy);
  }
  log.info("Activated Elasticity for NSR with id: " + nsr.getId());
}
 

import org.openbaton.catalogue.mano.record.VirtualNetworkFunctionRecord; //导入依赖的package包/类
/**
 * Updates a VirtualNetworkFunctionRecord.
 *
 * @param idNsr the ID of the NetworkServiceRecord containing the VirtualNetworkFunctionRecord
 * @param idVnfr the ID of the VirtualNetworkFunctionRecord to update
 * @param virtualNetworkFunctionRecord the updated version of the VirtualNetworkFunctionRecord
 * @return the updated VirtualNetworkFunctionRecord
 * @throws SDKException
 */
@Help(help = "update VirtualNetworkFunctionRecord")
public String updateVNFR(
    final String idNsr,
    final String idVnfr,
    final VirtualNetworkFunctionRecord virtualNetworkFunctionRecord)
    throws SDKException {
  String url = idNsr + "/vnfrecords" + "/" + idVnfr;
  return requestPut(url, virtualNetworkFunctionRecord).toString();
}
 

import org.openbaton.catalogue.mano.record.VirtualNetworkFunctionRecord; //导入依赖的package包/类
protected VirtualNetworkFunctionRecord getNextToCallStart(
    VirtualNetworkFunctionRecord virtualNetworkFunctionRecord) {

  Map<String, Integer> vnfrNames =
      vnfmManager.getVnfrNames().get(virtualNetworkFunctionRecord.getParent_ns_id());

  if (vnfrNames != null) {

    log.debug("List of VNFRs to start: " + vnfrNames);

    if (!vnfrNames.isEmpty()) {
      for (Entry<String, Integer> entry : vnfrNames.entrySet()) {
        vnfrNames.remove(entry.getKey());
        for (VirtualNetworkFunctionRecord vnfr :
            networkServiceRecordRepository
                .findFirstById(virtualNetworkFunctionRecord.getParent_ns_id())
                .getVnfr()) {
          if (vnfr.getName().equals(entry.getKey())) {
            return vnfr;
          }
        }

        return null;
      }
    }
  }
  return null;
}
 

import org.openbaton.catalogue.mano.record.VirtualNetworkFunctionRecord; //导入依赖的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.VirtualNetworkFunctionRecord; //导入依赖的package包/类
Future<VNFCInstance> allocate(
VirtualDeploymentUnit vdu,
VirtualNetworkFunctionRecord virtualNetworkFunctionRecord,
VNFComponent componentToAdd,
BaseVimInstance vimInstance,
String userdata)
throws InterruptedException, ExecutionException, PluginException, VimException,
    VimDriverException;