extract namespace from network annotation when cheking for kubevirt r…

…elated pod instance

Signed-off-by: Ram Lavi <ralavi@redhat.com>

pkg/pool-manager/pod_pool.go

@@ -61,7 +61,10 @@ func (p *PoolManager) AllocatePodMac(pod *corev1.Pod) error {
 	}
 
 	// validate if the pod is related to kubevirt
-	if p.isRelatedToKubevirt(pod) {
+	// since the pod request may not have owned the vm namespace in this early state of vm making,
+	// we need to receive the namespace from the network annotation, and because the namespace is
+	// the same for all the networks, we simply take the namespace from the first network
+	if p.isRelatedToKubevirt(pod, networks[0].Namespace) {
 		// nothing to do here. the mac is already by allocated by the virtual machine webhook
 		log.V(1).Info("This pod have ownerReferences from kubevirt skipping")
 		return nil
@@ -220,7 +223,7 @@ func (p *PoolManager) initPodMap() error {
 		}
 
 		// validate if the pod is related to kubevirt
-		if p.isRelatedToKubevirt(&pod) {
+		if p.isRelatedToKubevirt(&pod, networks[0].Namespace) {
 			// nothing to do here. the mac is already by allocated by the virtual machine webhook
 			log.V(1).Info("This pod have ownerReferences from kubevirt skipping")
 			continue

pkg/pool-manager/virtualmachine_pool.go

@@ -323,14 +323,14 @@ func (p *PoolManager) IsKubevirtEnabled() bool {
 	return p.isKubevirt
 }
 
-func (p *PoolManager) isRelatedToKubevirt(pod *corev1.Pod) bool {
+func (p *PoolManager) isRelatedToKubevirt(pod *corev1.Pod, kubevirtObjectNamespace string) bool {
 	if pod.ObjectMeta.OwnerReferences == nil {
 		return false
 	}
 
 	for _, ref := range pod.OwnerReferences {
 		if ref.Kind == kubevirt.VirtualMachineInstanceGroupVersionKind.Kind {
-			requestUrl := fmt.Sprintf("apis/kubevirt.io/v1alpha3/namespaces/%s/virtualmachines/%s", pod.Namespace, ref.Name)
+			requestUrl := fmt.Sprintf("apis/kubevirt.io/v1alpha3/namespaces/%s/virtualmachines/%s", kubevirtObjectNamespace, ref.Name)
 			log.V(1).Info("test", "requestURI", requestUrl)
 			result := p.kubeClient.ExtensionsV1beta1().RESTClient().Get().RequestURI(requestUrl).Do()