poc, kubevirt: Support post copy live migration

Signed-off-by: Enrique Llorente <ellorent@redhat.com>
ovn-org · Mar 3, 2023 · e584c39 · e584c39
1 parent a0c4f4e
commit e584c39
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/go-controller/pkg/kubevirt/kubevirt.go b/go-controller/pkg/kubevirt/kubevirt.go
@@ -16,6 +16,7 @@ const (
 	NodeNameLabel                                = "kubevirt.io/nodeName"
 	IPPoolNameAnnotation                         = "kubevirt.io/ipPoolName"
 	AllowPodBridgeNetworkLiveMigrationAnnotation = "kubevirt.io/allow-pod-bridge-network-live-migration"
+	MigrationTargetStartTimestamp                = "kubevirt.io/migration-target-start-timestamp"
 )
 
 type IPConfig struct {

diff --git a/go-controller/pkg/ovn/kubevirt.go b/go-controller/pkg/ovn/kubevirt.go
@@ -125,8 +125,9 @@ func (oc *DefaultNetworkController) enroutePodAddressesToNode(pod *kapi.Pod) err
 
 func (oc *DefaultNetworkController) enrouteVirtualMachine(pod *kapi.Pod) error {
 	targetNode := pod.Labels[kubevirt.NodeNameLabel]
-	// There is no live migration or live migration has finished
-	if targetNode == "" || targetNode == pod.Spec.NodeName {
+	targetStartTimestamp := pod.Labels[kubevirt.MigrationTargetStartTimestamp]
+	// No live migration or target node was reached || qemu is already ready
+	if targetNode == pod.Spec.NodeName || targetStartTimestamp != "" {
 		if err := oc.enroutePodAddressesToNode(pod); err != nil {
 			return fmt.Errorf("failed enroutePodAddressesToNode for  %s/%s: %w", pod.Namespace, pod.Name, err)
 		}