Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for deleteDevices (0.34 sec)

  1. pkg/volume/iscsi/iscsi_util.go

    		return fmt.Errorf("no data written to file: %s", filename)
    	}
    	klog.V(4).Infof("Deleted block device: %s", deviceName)
    	return nil
    }
    
    // deleteDevices tries to remove all the block devices and multipath map devices
    // associated with a given iscsi device
    func deleteDevices(c iscsiDiskUnmounter) error {
    	lunNumber, err := strconv.Atoi(c.iscsiDisk.Lun)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 22 12:53:01 UTC 2022
    - 34.1K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/serviceentry/store.go

    	}
    	return model.SortServicesByCreationTime(out)
    }
    
    func (s *serviceStore) getServices(key types.NamespacedName) []*model.Service {
    	return s.servicesBySE[key]
    }
    
    func (s *serviceStore) deleteServices(key types.NamespacedName) {
    	delete(s.servicesBySE, key)
    }
    
    func (s *serviceStore) updateServices(key types.NamespacedName, services []*model.Service) {
    	s.servicesBySE[key] = services
    	s.allocateNeeded = true
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/serviceentry/store_test.go

    	if !reflect.DeepEqual(got, expectedServices) {
    		t.Errorf("got unexpected services %v", got)
    	}
    	if !store.allocateNeeded {
    		t.Errorf("expected allocate needed")
    	}
    	store.allocateNeeded = false
    	store.deleteServices(httpDNSRR.NamespacedName())
    	got = store.getAllServices()
    	if len(got) != 0 {
    		t.Errorf("got unexpected services %v", got)
    	}
    	if store.allocateNeeded {
    		t.Errorf("expected no allocate needed")
    	}
    }
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  4. pkg/proxy/winkernel/proxier_test.go

    		t.Errorf("Global refCount: %v does not match endpoint refCount: %v", *proxier.endPointsRefCount[endpointGuid1], *epInfo.refCount)
    	}
    
    	proxier.setInitialized(false)
    	deleteServices(proxier,
    		makeTestService(svcPortName2.Namespace, svcPortName2.Name, func(svc *v1.Service) {
    			svc.Spec.Type = "NodePort"
    			svc.Spec.ClusterIP = svcIP2
    			svc.Spec.Ports = []v1.ServicePort{{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 28 14:30:51 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  5. pilot/pkg/serviceregistry/serviceentry/controller_test.go

    	// Now delete few services and validate that IPs are retained for original services.
    	deleteServices := []*model.Service{}
    	for i, svc := range inServices {
    		if _, exists := originalServices[svc.Hostname.String()]; !exists {
    			if i%2 == 0 {
    				continue
    			}
    		}
    		deleteServices = append(deleteServices, svc)
    	}
    	inServices = deleteServices
    	allocateAndValidate()
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 92.9K bytes
    - Viewed (0)
  6. pilot/pkg/serviceregistry/serviceentry/controller.go

    			updatedSvcs = append(updatedSvcs, unchangedSvcs...)
    			unchangedSvcs = nil
    		}
    		s.services.updateServices(key, cs)
    	case model.EventDelete:
    		deletedSvcs = cs
    		s.services.deleteServices(key)
    	case model.EventAdd:
    		addedSvcs = cs
    		s.services.updateServices(key, cs)
    	default:
    		// this should not happen
    		unchangedSvcs = cs
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 36.8K bytes
    - Viewed (0)
Back to top