add srl connectivity test

Makefile

@@ -62,6 +62,7 @@ KWOK_VERSION = v0.3.0
 KWOK_IMAGE = registry.k8s.io/kwok/kwok:$(KWOK_VERSION)
 
 VPC_NAT_GW_IMG = $(REGISTRY)/vpc-nat-gateway:$(VERSION)
+KUBEOVN_BASE_IMG= $(REGISTRY)/kube-ovn-base:$(VERSION)
 
 E2E_NETWORK = bridge
 ifneq ($(VLAN_ID),)

pkg/controller/endpoint.go

@@ -194,16 +194,18 @@ func (c *Controller) handleUpdateEndpoint(key string) error {
 
 			// for performance reason delete lb with no backends
 			if len(backends) != 0 {
+				klog.V(3).Infof("update vip %s with backends %s to LB %s", vip, backends, lb)
 				if err = c.ovnClient.LoadBalancerAddVip(lb, vip, backends...); err != nil {
 					klog.Errorf("failed to add vip %s with backends %s to LB %s: %v", vip, backends, lb, err)
 					return err
 				}
 			} else {
+				klog.V(3).Infof("delete vip %s from LB %s", vip, lb)
 				if err := c.ovnClient.LoadBalancerDeleteVip(lb, vip); err != nil {
 					klog.Errorf("failed to delete vip %s from LB %s: %v", vip, lb, err)
 					return err
 				}
-
+				klog.V(3).Infof("delete vip %s from old LB %s", vip, lb)
 				if err := c.ovnClient.LoadBalancerDeleteVip(oldLb, vip); err != nil {
 					klog.Errorf("failed to delete vip %s from LB %s: %v", vip, lb, err)
 					return err

pkg/controller/service.go

@@ -56,7 +56,6 @@ func (c *Controller) enqueueAddService(obj interface{}) {
 
 func (c *Controller) enqueueDeleteService(obj interface{}) {
 	svc := obj.(*v1.Service)
-	//klog.V(3).Infof("enqueue delete service %s/%s", svc.Namespace, svc.Name)
 	klog.Infof("enqueue delete service %s/%s", svc.Namespace, svc.Name)
 
 	vip, ok := svc.Annotations[util.SwitchLBRuleVipsAnnotation]

pkg/ipam/ipam.go

@@ -61,7 +61,7 @@ func (ipam *IPAM) GetRandomAddress(podName, nicName string, mac *string, subnetN
 func (ipam *IPAM) GetStaticAddress(podName, nicName, ip string, mac *string, subnetName string, checkConflict bool) (string, string, string, error) {
 	ipam.mutex.RLock()
 	defer ipam.mutex.RUnlock()
-
+	klog.Infof("allocating static ip %s from subnet %s", ip, subnetName)
 	if subnet, ok := ipam.Subnets[subnetName]; !ok {
 		return "", "", "", ErrNoAvailable
 	} else {

test/e2e/framework/image.go

@@ -1,8 +1,10 @@
 package framework
 
 const (
-	PauseImage   = "kubeovn/pause:3.2"
-	BusyBoxImage = "busybox:stable"
-	AgnhostImage = "kubeovn/agnhost:2.43"
-	NginxImage   = "nginx:latest"
+	PauseImage    = "kubeovn/pause:3.2"
+	BusyBoxImage  = "busybox:stable"
+	AgnhostImage  = "kubeovn/agnhost:2.43"
+	NginxImage    = "nginx:latest"
+	HttpdImage    = "httpd:latest"
+	NetShootImage = "nicolaka/netshoot:latest"
 )