| // Licensed to the Apache Software Foundation (ASF) under one |
| // or more contributor license agreements. See the NOTICE file |
| // distributed with this work for additional information |
| // regarding copyright ownership. The ASF licenses this file |
| // to you 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 com.cloud.api.query.dao; |
| |
| import java.text.DecimalFormat; |
| import java.util.ArrayList; |
| import java.util.HashMap; |
| import java.util.Hashtable; |
| import java.util.List; |
| import java.util.Map; |
| import java.util.Set; |
| import java.util.stream.Collectors; |
| |
| import javax.inject.Inject; |
| |
| import com.cloud.storage.Volume; |
| import org.apache.cloudstack.affinity.AffinityGroupResponse; |
| import org.apache.cloudstack.annotation.AnnotationService; |
| import org.apache.cloudstack.annotation.dao.AnnotationDao; |
| import org.apache.cloudstack.api.ApiConstants; |
| import org.apache.cloudstack.api.ApiConstants.VMDetails; |
| import org.apache.cloudstack.api.ResponseObject.ResponseView; |
| import org.apache.cloudstack.api.response.NicExtraDhcpOptionResponse; |
| import org.apache.cloudstack.api.response.NicResponse; |
| import org.apache.cloudstack.api.response.NicSecondaryIpResponse; |
| import org.apache.cloudstack.api.response.SecurityGroupResponse; |
| import org.apache.cloudstack.api.response.UserVmResponse; |
| import org.apache.cloudstack.context.CallContext; |
| import org.apache.cloudstack.framework.config.dao.ConfigurationDao; |
| import org.apache.cloudstack.query.QueryService; |
| import org.apache.commons.lang3.BooleanUtils; |
| import org.apache.commons.lang3.StringUtils; |
| import org.apache.log4j.Logger; |
| import org.springframework.stereotype.Component; |
| |
| import com.cloud.api.ApiDBUtils; |
| import com.cloud.api.ApiResponseHelper; |
| import com.cloud.api.query.vo.UserVmJoinVO; |
| import com.cloud.gpu.GPU; |
| import com.cloud.host.ControlState; |
| import com.cloud.network.vpc.VpcVO; |
| import com.cloud.network.vpc.dao.VpcDao; |
| import com.cloud.service.ServiceOfferingDetailsVO; |
| import com.cloud.storage.DiskOfferingVO; |
| import com.cloud.storage.GuestOS; |
| import com.cloud.user.Account; |
| import com.cloud.user.AccountManager; |
| import com.cloud.user.User; |
| import com.cloud.user.UserStatisticsVO; |
| import com.cloud.user.dao.UserDao; |
| import com.cloud.user.dao.UserStatisticsDao; |
| import com.cloud.uservm.UserVm; |
| import com.cloud.utils.db.SearchBuilder; |
| import com.cloud.utils.db.SearchCriteria; |
| import com.cloud.utils.db.SearchCriteria.Op; |
| import com.cloud.utils.net.Dhcp; |
| import com.cloud.vm.UserVmDetailVO; |
| import com.cloud.vm.UserVmManager; |
| import com.cloud.vm.VirtualMachine.State; |
| import com.cloud.vm.VmStats; |
| import com.cloud.vm.dao.NicExtraDhcpOptionDao; |
| import com.cloud.vm.dao.NicSecondaryIpVO; |
| import com.cloud.vm.dao.UserVmDetailsDao; |
| |
| @Component |
| public class UserVmJoinDaoImpl extends GenericDaoBaseWithTagInformation<UserVmJoinVO, UserVmResponse> implements UserVmJoinDao { |
| public static final Logger s_logger = Logger.getLogger(UserVmJoinDaoImpl.class); |
| |
| @Inject |
| private ConfigurationDao _configDao; |
| @Inject |
| public AccountManager _accountMgr; |
| @Inject |
| private UserVmDetailsDao _userVmDetailsDao; |
| @Inject |
| private UserDao _userDao; |
| @Inject |
| private NicExtraDhcpOptionDao _nicExtraDhcpOptionDao; |
| @Inject |
| private AnnotationDao annotationDao; |
| @Inject |
| private VpcDao vpcDao; |
| @Inject |
| UserStatisticsDao userStatsDao; |
| |
| private final SearchBuilder<UserVmJoinVO> VmDetailSearch; |
| private final SearchBuilder<UserVmJoinVO> activeVmByIsoSearch; |
| |
| protected UserVmJoinDaoImpl() { |
| |
| VmDetailSearch = createSearchBuilder(); |
| VmDetailSearch.and("idIN", VmDetailSearch.entity().getId(), SearchCriteria.Op.IN); |
| VmDetailSearch.done(); |
| |
| _count = "select count(distinct id) from user_vm_view WHERE "; |
| |
| activeVmByIsoSearch = createSearchBuilder(); |
| activeVmByIsoSearch.and("isoId", activeVmByIsoSearch.entity().getIsoId(), SearchCriteria.Op.EQ); |
| activeVmByIsoSearch.and("stateNotIn", activeVmByIsoSearch.entity().getState(), SearchCriteria.Op.NIN); |
| activeVmByIsoSearch.done(); |
| } |
| |
| @Override |
| public List<UserVmJoinVO> listActiveByIsoId(Long isoId) { |
| SearchCriteria<UserVmJoinVO> sc = activeVmByIsoSearch.create(); |
| sc.setParameters("isoId", isoId); |
| State[] states = new State[2]; |
| states[0] = State.Error; |
| states[1] = State.Expunging; |
| return listBy(sc); |
| } |
| |
| @Override |
| public UserVmResponse newUserVmResponse(ResponseView view, String objectName, UserVmJoinVO userVm, Set<VMDetails> details, Boolean accumulateStats, Boolean showUserData, |
| Account caller) { |
| UserVmResponse userVmResponse = new UserVmResponse(); |
| |
| if (userVm.getHypervisorType() != null) { |
| userVmResponse.setHypervisor(userVm.getHypervisorType().toString()); |
| } |
| userVmResponse.setId(userVm.getUuid()); |
| userVmResponse.setName(userVm.getName()); |
| |
| if (userVm.getDisplayName() != null) { |
| userVmResponse.setDisplayName(userVm.getDisplayName()); |
| } else { |
| userVmResponse.setDisplayName(userVm.getName()); |
| } |
| |
| if (userVm.getAccountType() == Account.Type.PROJECT) { |
| userVmResponse.setProjectId(userVm.getProjectUuid()); |
| userVmResponse.setProjectName(userVm.getProjectName()); |
| } else { |
| userVmResponse.setAccountName(userVm.getAccountName()); |
| } |
| |
| User user = _userDao.getUser(userVm.getUserId()); |
| if (user != null) { |
| userVmResponse.setUserId(user.getUuid()); |
| userVmResponse.setUserName(user.getUsername()); |
| } |
| userVmResponse.setDomainId(userVm.getDomainUuid()); |
| userVmResponse.setDomainName(userVm.getDomainName()); |
| |
| userVmResponse.setCreated(userVm.getCreated()); |
| userVmResponse.setLastUpdated(userVm.getLastUpdated()); |
| userVmResponse.setDisplayVm(userVm.isDisplayVm()); |
| |
| if (userVm.getState() != null) { |
| userVmResponse.setState(userVm.getState().toString()); |
| } |
| userVmResponse.setHaEnable(userVm.isHaEnabled()); |
| if (details.contains(VMDetails.all) || details.contains(VMDetails.group)) { |
| userVmResponse.setGroupId(userVm.getInstanceGroupUuid()); |
| userVmResponse.setGroup(userVm.getInstanceGroupName()); |
| } |
| userVmResponse.setZoneId(userVm.getDataCenterUuid()); |
| userVmResponse.setZoneName(userVm.getDataCenterName()); |
| if (view == ResponseView.Full) { |
| userVmResponse.setInstanceName(userVm.getInstanceName()); |
| userVmResponse.setHostId(userVm.getHostUuid()); |
| userVmResponse.setHostName(userVm.getHostName()); |
| } |
| if (userVm.getHostStatus() != null) { |
| userVmResponse.setHostControlState(ControlState.getControlState(userVm.getHostStatus(), userVm.getHostResourceState()).toString()); |
| } |
| |
| if (details.contains(VMDetails.all) || details.contains(VMDetails.tmpl)) { |
| userVmResponse.setTemplateId(userVm.getTemplateUuid()); |
| userVmResponse.setTemplateName(userVm.getTemplateName()); |
| userVmResponse.setTemplateDisplayText(userVm.getTemplateDisplayText()); |
| userVmResponse.setPasswordEnabled(userVm.isPasswordEnabled()); |
| } |
| if (details.contains(VMDetails.all) || details.contains(VMDetails.iso)) { |
| userVmResponse.setIsoId(userVm.getIsoUuid()); |
| userVmResponse.setIsoName(userVm.getIsoName()); |
| userVmResponse.setIsoDisplayText(userVm.getIsoDisplayText()); |
| } |
| if (details.contains(VMDetails.all) || details.contains(VMDetails.servoff)) { |
| userVmResponse.setServiceOfferingId(userVm.getServiceOfferingUuid()); |
| userVmResponse.setServiceOfferingName(userVm.getServiceOfferingName()); |
| } |
| if (details.contains(VMDetails.all) || details.contains(VMDetails.diskoff)) { |
| DiskOfferingVO diskOfferingVO = ApiDBUtils.findDiskOfferingById(userVm.getDiskOfferingId()); |
| if (diskOfferingVO != null) { |
| userVmResponse.setDiskOfferingId(userVm.getDiskOfferingUuid()); |
| userVmResponse.setDiskOfferingName(userVm.getDiskOfferingName()); |
| } |
| } |
| if (details.contains(VMDetails.all) || details.contains(VMDetails.backoff)) { |
| userVmResponse.setBackupOfferingId(userVm.getBackupOfferingUuid()); |
| userVmResponse.setBackupOfferingName(userVm.getBackupOfferingName()); |
| } |
| if (details.contains(VMDetails.all) || details.contains(VMDetails.servoff) || details.contains(VMDetails.stats)) { |
| userVmResponse.setCpuNumber(userVm.getCpu()); |
| userVmResponse.setCpuSpeed(userVm.getSpeed()); |
| userVmResponse.setMemory(userVm.getRamSize()); |
| ServiceOfferingDetailsVO serviceOfferingDetail = ApiDBUtils.findServiceOfferingDetail(userVm.getServiceOfferingId(), GPU.Keys.vgpuType.toString()); |
| if (serviceOfferingDetail != null) { |
| userVmResponse.setVgpu(serviceOfferingDetail.getValue()); |
| } |
| } |
| userVmResponse.setGuestOsId(userVm.getGuestOsUuid()); |
| if (details.contains(VMDetails.all) || details.contains(VMDetails.volume)) { |
| userVmResponse.setRootDeviceId(userVm.getVolumeDeviceId()); |
| if (userVm.getVolumeType() != null) { |
| userVmResponse.setRootDeviceType(userVm.getVolumeType().toString()); |
| } |
| } |
| userVmResponse.setPassword(userVm.getPassword()); |
| if (userVm.getJobId() != null) { |
| userVmResponse.setJobId(userVm.getJobUuid()); |
| userVmResponse.setJobStatus(userVm.getJobStatus()); |
| } |
| //userVmResponse.setForVirtualNetwork(userVm.getForVirtualNetwork()); |
| |
| userVmResponse.setPublicIpId(userVm.getPublicIpUuid()); |
| userVmResponse.setPublicIp(userVm.getPublicIpAddress()); |
| userVmResponse.setKeyPairNames(userVm.getKeypairNames()); |
| userVmResponse.setOsTypeId(userVm.getGuestOsUuid()); |
| GuestOS guestOS = ApiDBUtils.findGuestOSById(userVm.getGuestOsId()); |
| if (guestOS != null) { |
| userVmResponse.setOsDisplayName(guestOS.getDisplayName()); |
| } |
| |
| if (details.contains(VMDetails.all) || details.contains(VMDetails.stats)) { |
| // stats calculation |
| VmStats vmStats = ApiDBUtils.getVmStatistics(userVm.getId(), accumulateStats); |
| if (vmStats != null) { |
| userVmResponse.setCpuUsed(new DecimalFormat("#.##").format(vmStats.getCPUUtilization()) + "%"); |
| userVmResponse.setNetworkKbsRead((long)vmStats.getNetworkReadKBs()); |
| userVmResponse.setNetworkKbsWrite((long)vmStats.getNetworkWriteKBs()); |
| userVmResponse.setDiskKbsRead((long)vmStats.getDiskReadKBs()); |
| userVmResponse.setDiskKbsWrite((long)vmStats.getDiskWriteKBs()); |
| userVmResponse.setDiskIORead((long)vmStats.getDiskReadIOs()); |
| userVmResponse.setDiskIOWrite((long)vmStats.getDiskWriteIOs()); |
| long totalMemory = (long)vmStats.getMemoryKBs(); |
| long freeMemory = (long)vmStats.getIntFreeMemoryKBs(); |
| long correctedFreeMemory = freeMemory >= totalMemory ? 0 : freeMemory; |
| userVmResponse.setMemoryKBs(totalMemory); |
| userVmResponse.setMemoryIntFreeKBs(correctedFreeMemory); |
| userVmResponse.setMemoryTargetKBs((long)vmStats.getTargetMemoryKBs()); |
| |
| } |
| } |
| |
| if (details.contains(VMDetails.all) || details.contains(VMDetails.secgrp)) { |
| Long securityGroupId = userVm.getSecurityGroupId(); |
| if (securityGroupId != null && securityGroupId.longValue() != 0) { |
| SecurityGroupResponse resp = new SecurityGroupResponse(); |
| resp.setId(userVm.getSecurityGroupUuid()); |
| resp.setName(userVm.getSecurityGroupName()); |
| resp.setDescription(userVm.getSecurityGroupDescription()); |
| resp.setObjectName("securitygroup"); |
| if (userVm.getAccountType() == Account.Type.PROJECT) { |
| resp.setProjectId(userVm.getProjectUuid()); |
| resp.setProjectName(userVm.getProjectName()); |
| } else { |
| resp.setAccountName(userVm.getAccountName()); |
| } |
| userVmResponse.addSecurityGroup(resp); |
| } |
| } |
| |
| if (details.contains(VMDetails.all) || details.contains(VMDetails.nics)) { |
| long nic_id = userVm.getNicId(); |
| if (nic_id > 0) { |
| NicResponse nicResponse = new NicResponse(); |
| nicResponse.setId(userVm.getNicUuid()); |
| nicResponse.setIpaddress(userVm.getIpAddress()); |
| nicResponse.setGateway(userVm.getGateway()); |
| nicResponse.setNetmask(userVm.getNetmask()); |
| nicResponse.setNetworkid(userVm.getNetworkUuid()); |
| nicResponse.setNetworkName(userVm.getNetworkName()); |
| nicResponse.setMacAddress(userVm.getMacAddress()); |
| nicResponse.setIp6Address(userVm.getIp6Address()); |
| nicResponse.setIp6Gateway(userVm.getIp6Gateway()); |
| nicResponse.setIp6Cidr(userVm.getIp6Cidr()); |
| if (userVm.getBroadcastUri() != null) { |
| nicResponse.setBroadcastUri(userVm.getBroadcastUri().toString()); |
| } |
| if (userVm.getIsolationUri() != null) { |
| nicResponse.setIsolationUri(userVm.getIsolationUri().toString()); |
| } |
| if (userVm.getTrafficType() != null) { |
| nicResponse.setTrafficType(userVm.getTrafficType().toString()); |
| } |
| if (userVm.getGuestType() != null) { |
| nicResponse.setType(userVm.getGuestType().toString()); |
| } |
| |
| if (userVm.getVpcUuid() != null) { |
| nicResponse.setVpcId(userVm.getVpcUuid()); |
| VpcVO vpc = vpcDao.findByUuidIncludingRemoved(userVm.getVpcUuid()); |
| nicResponse.setVpcName(vpc.getName()); |
| } |
| nicResponse.setIsDefault(userVm.isDefaultNic()); |
| nicResponse.setDeviceId(String.valueOf(userVm.getNicDeviceId())); |
| List<NicSecondaryIpVO> secondaryIps = ApiDBUtils.findNicSecondaryIps(userVm.getNicId()); |
| if (secondaryIps != null) { |
| List<NicSecondaryIpResponse> ipList = new ArrayList<NicSecondaryIpResponse>(); |
| for (NicSecondaryIpVO ip : secondaryIps) { |
| NicSecondaryIpResponse ipRes = new NicSecondaryIpResponse(); |
| ipRes.setId(ip.getUuid()); |
| ApiResponseHelper.setResponseIpAddress(ip, ipRes); |
| ipList.add(ipRes); |
| } |
| nicResponse.setSecondaryIps(ipList); |
| } |
| nicResponse.setObjectName("nic"); |
| |
| List<NicExtraDhcpOptionResponse> nicExtraDhcpOptionResponses = _nicExtraDhcpOptionDao.listByNicId(nic_id).stream() |
| .map(vo -> new NicExtraDhcpOptionResponse(Dhcp.DhcpOptionCode.valueOfInt(vo.getCode()).getName(), vo.getCode(), vo.getValue())) |
| .collect(Collectors.toList()); |
| nicResponse.setExtraDhcpOptions(nicExtraDhcpOptionResponses); |
| |
| userVmResponse.addNic(nicResponse); |
| } |
| } |
| |
| // update tag information |
| long tag_id = userVm.getTagId(); |
| if (tag_id > 0 && !userVmResponse.containTag(tag_id)) { |
| addTagInformation(userVm, userVmResponse); |
| } |
| |
| userVmResponse.setHasAnnotation(annotationDao.hasAnnotations(userVm.getUuid(), |
| AnnotationService.EntityType.VM.name(), _accountMgr.isRootAdmin(caller.getId()))); |
| |
| if (details.contains(VMDetails.all) || details.contains(VMDetails.affgrp)) { |
| Long affinityGroupId = userVm.getAffinityGroupId(); |
| if (affinityGroupId != null && affinityGroupId.longValue() != 0) { |
| AffinityGroupResponse resp = new AffinityGroupResponse(); |
| resp.setId(userVm.getAffinityGroupUuid()); |
| resp.setName(userVm.getAffinityGroupName()); |
| resp.setDescription(userVm.getAffinityGroupDescription()); |
| resp.setObjectName("affinitygroup"); |
| resp.setAccountName(userVm.getAccountName()); |
| userVmResponse.addAffinityGroup(resp); |
| } |
| } |
| |
| if (BooleanUtils.isTrue(showUserData)) { |
| userVmResponse.setUserData(userVm.getUserData()); |
| } |
| |
| // set resource details map |
| // Allow passing details to end user |
| // Honour the display field and only return if display is set to true |
| List<UserVmDetailVO> vmDetails = _userVmDetailsDao.listDetails(userVm.getId(), true); |
| if (vmDetails != null) { |
| Map<String, String> resourceDetails = new HashMap<String, String>(); |
| for (UserVmDetailVO userVmDetailVO : vmDetails) { |
| if (!userVmDetailVO.getName().startsWith(ApiConstants.PROPERTIES) || |
| (UserVmManager.DisplayVMOVFProperties.value() && userVmDetailVO.getName().startsWith(ApiConstants.PROPERTIES))) { |
| resourceDetails.put(userVmDetailVO.getName(), userVmDetailVO.getValue()); |
| } |
| if ((ApiConstants.BootType.UEFI.toString()).equalsIgnoreCase(userVmDetailVO.getName())) { |
| userVmResponse.setBootType("Uefi"); |
| userVmResponse.setBootMode(userVmDetailVO.getValue().toLowerCase()); |
| |
| } |
| } |
| if (vmDetails.size() == 0) { |
| userVmResponse.setBootType("Bios"); |
| userVmResponse.setBootMode("legacy"); |
| } |
| |
| if (userVm.getPoolType() != null) { |
| userVmResponse.setPoolType(userVm.getPoolType().toString()); |
| } |
| |
| // Remove deny listed settings if user is not admin |
| if (caller.getType() != Account.Type.ADMIN) { |
| String[] userVmSettingsToHide = QueryService.UserVMDeniedDetails.value().split(","); |
| for (String key : userVmSettingsToHide) { |
| resourceDetails.remove(key.trim()); |
| } |
| } |
| userVmResponse.setDetails(resourceDetails); |
| if (caller.getType() != Account.Type.ADMIN) { |
| userVmResponse.setReadOnlyDetails(QueryService.UserVMReadOnlyDetails.value()); |
| } |
| } |
| |
| userVmResponse.setObjectName(objectName); |
| if (userVm.isDynamicallyScalable() == null) { |
| userVmResponse.setDynamicallyScalable(false); |
| } else { |
| userVmResponse.setDynamicallyScalable(userVm.isDynamicallyScalable()); |
| } |
| |
| if (userVm.getAutoScaleVmGroupName() != null) { |
| userVmResponse.setAutoScaleVmGroupName(userVm.getAutoScaleVmGroupName()); |
| } |
| if (userVm.getAutoScaleVmGroupUuid() != null) { |
| userVmResponse.setAutoScaleVmGroupId(userVm.getAutoScaleVmGroupUuid()); |
| } |
| |
| if (userVm.getUserDataId() != null) { |
| userVmResponse.setUserDataId(userVm.getUserDataUUid()); |
| userVmResponse.setUserDataName(userVm.getUserDataName()); |
| userVmResponse.setUserDataDetails(userVm.getUserDataDetails()); |
| userVmResponse.setUserDataPolicy(userVm.getUserDataPolicy()); |
| } |
| |
| addVmRxTxDataToResponse(userVm, userVmResponse); |
| |
| return userVmResponse; |
| } |
| |
| private void addVmRxTxDataToResponse(UserVmJoinVO userVm, UserVmResponse userVmResponse) { |
| Long bytesReceived = 0L; |
| Long bytesSent = 0L; |
| SearchBuilder<UserStatisticsVO> sb = userStatsDao.createSearchBuilder(); |
| sb.and("deviceId", sb.entity().getDeviceId(), Op.EQ); |
| SearchCriteria<UserStatisticsVO> sc = sb.create(); |
| sc.setParameters("deviceId", userVm.getId()); |
| for (UserStatisticsVO stat: userStatsDao.search(sc, null)) { |
| bytesReceived += stat.getNetBytesReceived() + stat.getCurrentBytesReceived(); |
| bytesSent += stat.getNetBytesSent() + stat.getCurrentBytesSent(); |
| } |
| userVmResponse.setBytesReceived(bytesReceived); |
| userVmResponse.setBytesSent(bytesSent); |
| } |
| |
| /** |
| * The resulting Response attempts to be in line with what is returned from |
| * @see com.cloud.api.ApiResponseHelper#createNicResponse(Nic) |
| */ |
| @Override |
| public UserVmResponse setUserVmResponse(ResponseView view, UserVmResponse userVmData, UserVmJoinVO uvo) { |
| Long securityGroupId = uvo.getSecurityGroupId(); |
| if (securityGroupId != null && securityGroupId.longValue() != 0) { |
| SecurityGroupResponse resp = new SecurityGroupResponse(); |
| resp.setId(uvo.getSecurityGroupUuid()); |
| resp.setName(uvo.getSecurityGroupName()); |
| resp.setDescription(uvo.getSecurityGroupDescription()); |
| resp.setObjectName("securitygroup"); |
| if (uvo.getAccountType() == Account.Type.PROJECT) { |
| resp.setProjectId(uvo.getProjectUuid()); |
| resp.setProjectName(uvo.getProjectName()); |
| } else { |
| resp.setAccountName(uvo.getAccountName()); |
| } |
| userVmData.addSecurityGroup(resp); |
| } |
| |
| long nic_id = uvo.getNicId(); |
| if (nic_id > 0) { |
| NicResponse nicResponse = new NicResponse(); |
| // The numbered comments are to keep track of the data returned from here and ApiResponseHelper.createNicResponse() |
| // the data can't be identical but some tidying up/unifying might be possible |
| /*1: nicUuid*/ |
| nicResponse.setId(uvo.getNicUuid()); |
| /*2: networkUuid*/ |
| nicResponse.setNetworkid(uvo.getNetworkUuid()); |
| /*3: vmId makes no sense on a nested nic object so it is omitted here */ |
| |
| if (uvo.getTrafficType() != null) { |
| /*4: trafficType*/ |
| nicResponse.setTrafficType(uvo.getTrafficType().toString()); |
| } |
| if (uvo.getGuestType() != null) { |
| /*5: guestType*/ |
| nicResponse.setType(uvo.getGuestType().toString()); |
| } |
| /*6: ipAddress*/ |
| nicResponse.setIpaddress(uvo.getIpAddress()); |
| /*7: gateway*/ |
| nicResponse.setGateway(uvo.getGateway()); |
| /*8: netmask*/ |
| nicResponse.setNetmask(uvo.getNetmask()); |
| /*9: networkName*/ |
| nicResponse.setNetworkName(uvo.getNetworkName()); |
| /*10: macAddress*/ |
| nicResponse.setMacAddress(uvo.getMacAddress()); |
| /*11: IPv6Address*/ |
| nicResponse.setIp6Address(uvo.getIp6Address()); |
| /*12: IPv6Gateway*/ |
| nicResponse.setIp6Gateway(uvo.getIp6Gateway()); |
| /*13: IPv6Cidr*/ |
| nicResponse.setIp6Cidr(uvo.getIp6Cidr()); |
| /*14: deviceId*/ |
| // where do we find nicResponse.setDeviceId( |
| // this is probably not String.valueOf(uvo.getNicId())); as this is a db-id |
| /*15: broadcastURI*/ |
| if (uvo.getBroadcastUri() != null) { |
| nicResponse.setBroadcastUri(uvo.getBroadcastUri().toString()); |
| } |
| /*16: isolationURI*/ |
| if (uvo.getIsolationUri() != null) { |
| nicResponse.setIsolationUri(uvo.getIsolationUri().toString()); |
| } |
| /*17: default*/ |
| nicResponse.setIsDefault(uvo.isDefaultNic()); |
| nicResponse.setDeviceId(String.valueOf(uvo.getNicDeviceId())); |
| List<NicSecondaryIpVO> secondaryIps = ApiDBUtils.findNicSecondaryIps(uvo.getNicId()); |
| if (secondaryIps != null) { |
| List<NicSecondaryIpResponse> ipList = new ArrayList<NicSecondaryIpResponse>(); |
| for (NicSecondaryIpVO ip : secondaryIps) { |
| NicSecondaryIpResponse ipRes = new NicSecondaryIpResponse(); |
| ipRes.setId(ip.getUuid()); |
| ApiResponseHelper.setResponseIpAddress(ip, ipRes); |
| ipList.add(ipRes); |
| } |
| nicResponse.setSecondaryIps(ipList); |
| } |
| |
| /* 18: extra dhcp options */ |
| nicResponse.setObjectName("nic"); |
| List<NicExtraDhcpOptionResponse> nicExtraDhcpOptionResponses = _nicExtraDhcpOptionDao.listByNicId(nic_id) |
| .stream() |
| .map(vo -> new NicExtraDhcpOptionResponse(Dhcp.DhcpOptionCode.valueOfInt(vo.getCode()).getName(), vo.getCode(), vo.getValue())) |
| .collect(Collectors.toList()); |
| nicResponse.setExtraDhcpOptions(nicExtraDhcpOptionResponses); |
| userVmData.addNic(nicResponse); |
| } |
| |
| long tag_id = uvo.getTagId(); |
| if (tag_id > 0 && !userVmData.containTag(tag_id)) { |
| addTagInformation(uvo, userVmData); |
| } |
| |
| if (userVmData.hasAnnotation() == null) { |
| userVmData.setHasAnnotation(annotationDao.hasAnnotations(uvo.getUuid(), |
| AnnotationService.EntityType.VM.name(), _accountMgr.isRootAdmin(CallContext.current().getCallingAccount().getId()))); |
| } |
| |
| Long affinityGroupId = uvo.getAffinityGroupId(); |
| if (affinityGroupId != null && affinityGroupId.longValue() != 0) { |
| AffinityGroupResponse resp = new AffinityGroupResponse(); |
| resp.setId(uvo.getAffinityGroupUuid()); |
| resp.setName(uvo.getAffinityGroupName()); |
| resp.setDescription(uvo.getAffinityGroupDescription()); |
| resp.setObjectName("affinitygroup"); |
| resp.setAccountName(uvo.getAccountName()); |
| userVmData.addAffinityGroup(resp); |
| } |
| |
| if (StringUtils.isEmpty(userVmData.getDiskOfferingId()) && !Volume.Type.ROOT.equals(uvo.getVolumeType())) { |
| userVmData.setDiskOfferingId(uvo.getDiskOfferingUuid()); |
| userVmData.setDiskOfferingName(uvo.getDiskOfferingName()); |
| } |
| |
| return userVmData; |
| } |
| |
| @Override |
| public List<UserVmJoinVO> searchByIds(Long... vmIds) { |
| // set detail batch query size |
| int DETAILS_BATCH_SIZE = 2000; |
| String batchCfg = _configDao.getValue("detail.batch.query.size"); |
| if (batchCfg != null) { |
| DETAILS_BATCH_SIZE = Integer.parseInt(batchCfg); |
| } |
| // query details by batches |
| List<UserVmJoinVO> uvList = new ArrayList<UserVmJoinVO>(); |
| // query details by batches |
| int curr_index = 0; |
| if (vmIds.length > DETAILS_BATCH_SIZE) { |
| while ((curr_index + DETAILS_BATCH_SIZE) <= vmIds.length) { |
| Long[] ids = new Long[DETAILS_BATCH_SIZE]; |
| for (int k = 0, j = curr_index; j < curr_index + DETAILS_BATCH_SIZE; j++, k++) { |
| ids[k] = vmIds[j]; |
| } |
| SearchCriteria<UserVmJoinVO> sc = VmDetailSearch.create(); |
| sc.setParameters("idIN", ids); |
| List<UserVmJoinVO> vms = searchIncludingRemoved(sc, null, null, false); |
| if (vms != null) { |
| uvList.addAll(vms); |
| } |
| curr_index += DETAILS_BATCH_SIZE; |
| } |
| } |
| if (curr_index < vmIds.length) { |
| int batch_size = (vmIds.length - curr_index); |
| // set the ids value |
| Long[] ids = new Long[batch_size]; |
| for (int k = 0, j = curr_index; j < curr_index + batch_size; j++, k++) { |
| ids[k] = vmIds[j]; |
| } |
| SearchCriteria<UserVmJoinVO> sc = VmDetailSearch.create(); |
| sc.setParameters("idIN", ids); |
| List<UserVmJoinVO> vms = searchIncludingRemoved(sc, null, null, false); |
| if (vms != null) { |
| uvList.addAll(vms); |
| } |
| } |
| return uvList; |
| } |
| |
| @Override |
| public List<UserVmJoinVO> newUserVmView(UserVm... userVms) { |
| |
| Hashtable<Long, UserVm> userVmDataHash = new Hashtable<Long, UserVm>(); |
| for (UserVm vm : userVms) { |
| if (!userVmDataHash.containsKey(vm.getId())) { |
| userVmDataHash.put(vm.getId(), vm); |
| } |
| } |
| |
| Set<Long> vmIdSet = userVmDataHash.keySet(); |
| List<UserVmJoinVO> uvms = searchByIds(vmIdSet.toArray(new Long[vmIdSet.size()])); |
| // populate transit password field from UserVm |
| if (uvms != null) { |
| for (UserVmJoinVO uvm : uvms) { |
| UserVm v = userVmDataHash.get(uvm.getId()); |
| uvm.setPassword(v.getPassword()); |
| } |
| } |
| return uvms; |
| } |
| |
| } |
