Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for replace (0.19 sec)

  1. cni/pkg/ipset/nldeps_linux.go

    	if ipsetErr, ok := err.(nl.IPSetError); ok && ipsetErr == nl.IPSET_ERR_EXIST {
    		return nil
    	}
    
    	return err
    }
    
    func (m *realDeps) destroySet(name string) error {
    	err := netlink.IpsetDestroy(name)
    	return err
    }
    
    func (m *realDeps) addIP(name string, ip netip.Addr, ipProto uint8, comment string, replace bool) error {
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  2. cni/pkg/ipset/ipset.go

    }
    
    func (m *IPSet) AddIP(ip netip.Addr, ipProto uint8, comment string, replace bool) error {
    	ipToInsert := ip.Unmap()
    
    	// We have already Unmap'd, so we can do a simple IsV6 y/n check now
    	if ipToInsert.Is6() {
    		return m.Deps.addIP(m.V6Name, ipToInsert, ipProto, comment, replace)
    	}
    	return m.Deps.addIP(m.V4Name, ipToInsert, ipProto, comment, replace)
    }
    
    func (m *IPSet) DeleteIP(ip netip.Addr, ipProto uint8) error {
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  3. cni/pkg/ipset/nldeps_mock.go

    	args := m.Called(name)
    	return args.Error(0)
    }
    
    func (m *MockedIpsetDeps) addIP(name string, ip netip.Addr, ipProto uint8, comment string, replace bool) error {
    	args := m.Called(name, ip, ipProto, comment, replace)
    	return args.Error(0)
    }
    
    func (m *MockedIpsetDeps) deleteIP(name string, ip netip.Addr, ipProto uint8) error {
    	args := m.Called(name, ip, ipProto)
    	return args.Error(0)
    }
    
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/collect/MoreCollectors.java

        }
    
        void add(Object o) {
          checkNotNull(o);
          if (element == null) {
            this.element = o;
          } else if (extras.isEmpty()) {
            // Replace immutable empty list with mutable list.
            extras = new ArrayList<>(MAX_EXTRAS);
            extras.add(o);
          } else if (extras.size() < MAX_EXTRAS) {
            extras.add(o);
          } else {
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed May 01 18:44:57 GMT 2024
    - 5.7K bytes
    - Viewed (0)
  5. cni/pkg/ipset/nldeps_unspecified.go

    }
    
    func (m *realDeps) destroySet(name string) error {
    	return errors.New("not implemented on this platform")
    }
    
    func (m *realDeps) addIP(name string, ip netip.Addr, ipProto uint8, comment string, replace bool) error {
    	return errors.New("not implemented on this platform")
    }
    
    func (m *realDeps) deleteIP(name string, ip netip.Addr, ipProto uint8) error {
    	return errors.New("not implemented on this platform")
    }
    
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/net.go

    	// For each pod IP
    	for _, pip := range podIPs {
    		// Add to host ipset
    		log.Debugf("adding pod %s probe to ipset %s with ip %s", pod.Name, hostsideProbeSet.Prefix, pip)
    		// Add IP/port combo to set. Note that we set Replace to true - a pod ip/port combo already being
    		// in the set is perfectly fine, and something we can always safely overwrite, so we will.
    		if err := hostsideProbeSet.AddIP(pip, ipProto, podUID, true); err != nil {
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 12.2K bytes
    - Viewed (1)
  7. cni/pkg/cmd/root.go

    	rootCmd.Flags().Bool(name, value, usage)
    	registerEnvironment(name, value, usage)
    }
    
    func registerEnvironment[T env.Parseable](name string, defaultValue T, usage string) {
    	envName := strings.Replace(strings.ToUpper(name), "-", "_", -1)
    	// Note: we do not rely on istio env package to retrieve configuration. We relies on viper.
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 12.5K bytes
    - Viewed (0)
  8. RELEASE.md

          * Replace `tf.keras.mixed_precision.experimental.set_policy` with `tf.keras.mixed_precision.set_global_policy`. The experimental symbol `set_policy` was renamed to `set_global_policy` in the non-experimental API.
    Plain Text
    - Registered: Tue Apr 30 12:39:09 GMT 2024
    - Last Modified: Mon Apr 29 19:17:57 GMT 2024
    - 727.7K bytes
    - Viewed (8)
  9. cmd/xl-storage.go

    		// upload to copy back its data from the remote tier. This
    		// doesn't replace the existing version, so we don't need to add
    		// a free-version.
    		xlMeta.AddFreeVersion(fi)
    	}
    
    	// indicates if RenameData() is called by healing.
    	healing := fi.Healing()
    
    	// Replace the data of null version or any other existing version-id
    	_, ver, err := xlMeta.findVersionStr(reqVID)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  10. cmd/storage-rest-server.go

    		}
    	case errors.Is(err, errFaultyDisk):
    		if !exit {
    			storageLogOnceIf(GlobalContext, fmt.Errorf("Drive is faulty at %s, please replace the drive - drive will be offline", endpoint), "log-fatal-errs")
    		} else {
    			logger.Fatal(err, "Unable to initialize backend")
    		}
    	case errors.Is(err, errDiskFull):
    		if !exit {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 44.8K bytes
    - Viewed (0)
Back to top