VmPortHookFailurePolicyUpdateTask.java 文件源码

@Override
public void executeTransaction(EntityManager em) throws Exception {

    this.vmPort = em.find(VMPort.class, this.vmPort.getId());
    this.dai = em.find(DistributedApplianceInstance.class, this.dai.getId());
    this.securityGroupInterface = em.find(SecurityGroupInterface.class,
            this.securityGroupInterface.getId());

    SdnRedirectionApi controller = this.apiFactoryService.createNetworkRedirectionApi(this.dai);
    try {
        DefaultNetworkPort ingressPort = new DefaultNetworkPort(this.dai.getInspectionOsIngressPortId(),
                this.dai.getInspectionIngressMacAddress());
        DefaultNetworkPort egressPort = new DefaultNetworkPort(this.dai.getInspectionOsEgressPortId(),
                this.dai.getInspectionEgressMacAddress());
        //Element object in DefaultInspectionPort is not used, hence null
        controller.setInspectionHookFailurePolicy(new NetworkElementImpl(this.vmPort), new DefaultInspectionPort(ingressPort, egressPort, null),
                FailurePolicyType.valueOf(this.securityGroupInterface.getFailurePolicyType().name()));
    } finally {
        controller.close();
    }
}