Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 471 for RANGE (0.13 sec)

  1. cmd/erasure-object.go

    			if disk == nil {
    				for i := range objects {
    					delObjErrs[index][i] = errDiskNotFound
    				}
    				return
    			}
    			errs := disk.DeleteVersions(ctx, bucket, dedupVersions, DeleteOptions{})
    			for i, err := range errs {
    				if err == nil {
    					continue
    				}
    				for _, v := range dedupVersions[i].Versions {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  2. cmd/bucket-policy.go

    			tagMap := tag.ToMap()
    			keys := make([]string, 0, len(tagMap))
    			for k, v := range tagMap {
    				args[pathJoin("ExistingObjectTag", k)] = []string{v}
    				args[pathJoin("RequestObjectTag", k)] = []string{v}
    				keys = append(keys, k)
    			}
    			args["RequestObjectTagKeys"] = keys
    		}
    	}
    
    	for _, objLock := range []string{
    		xhttp.AmzObjectLockMode,
    		xhttp.AmzObjectLockLegalHold,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 8K bytes
    - Viewed (0)
  3. cmd/net.go

    	ifs, err := net.Interfaces()
    	logger.FatalIf(err, "Unable to get IP addresses of this host")
    
    	for _, interf := range ifs {
    		addrs, err := interf.Addrs()
    		if err != nil {
    			continue
    		}
    		if runtime.GOOS == "windows" && interf.Flags&net.FlagUp == 0 {
    			continue
    		}
    
    		for _, addr := range addrs {
    			var ip net.IP
    			switch v := addr.(type) {
    			case *net.IPNet:
    				ip = v.IP
    			case *net.IPAddr:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 26 15:00:38 GMT 2024
    - 9.3K bytes
    - Viewed (0)
  4. cmd/notification.go

    	ng := WithNPeers(len(sys.peerClients))
    	for idx, client := range sys.peerClients {
    		if client == nil {
    			continue
    		}
    		client := client
    		ng.Go(ctx, func() error {
    			return client.LoadBucketMetadata(bucketName)
    		}, idx, *client.host)
    	}
    	for _, nErr := range ng.Wait() {
    		reqInfo := (&logger.ReqInfo{}).AppendTags("peerAddress", nErr.Host.String())
    		if nErr.Err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
  5. internal/event/targetlist.go

    	list.RLock()
    	defer list.RUnlock()
    
    	targets := []Target{}
    	for _, tgt := range list.targets {
    		targets = append(targets, tgt)
    	}
    
    	return targets
    }
    
    // List - returns available target IDs.
    func (list *TargetList) List() []TargetID {
    	list.RLock()
    	defer list.RUnlock()
    
    	keys := []TargetID{}
    	for k := range list.targets {
    		keys = append(keys, k)
    	}
    
    	return keys
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.2K bytes
    - Viewed (0)
  6. guava/src/com/google/common/collect/ImmutableRangeMap.java

          return null;
        } else {
          Range<K> range = ranges.get(index);
          return range.contains(key) ? Maps.immutableEntry(range, values.get(index)) : null;
        }
      }
    
      @Override
      public Range<K> span() {
        if (ranges.isEmpty()) {
          throw new NoSuchElementException();
        }
        Range<K> firstRange = ranges.get(0);
        Range<K> lastRange = ranges.get(ranges.size() - 1);
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 14.7K bytes
    - Viewed (0)
  7. cmd/xl-storage-format-v2_gen.go

    	for za0004 := range z.PartNumbers {
    		o = msgp.AppendInt(o, z.PartNumbers[za0004])
    	}
    	// string "PartETags"
    	o = append(o, 0xa9, 0x50, 0x61, 0x72, 0x74, 0x45, 0x54, 0x61, 0x67, 0x73)
    	if z.PartETags == nil { // allownil: if nil
    		o = msgp.AppendNil(o)
    	} else {
    		o = msgp.AppendArrayHeader(o, uint32(len(z.PartETags)))
    		for za0005 := range z.PartETags {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 53.8K bytes
    - Viewed (0)
  8. internal/grid/types.go

    		return msgp.NilSize
    	}
    	s := msgp.MapHeaderSize
    	for za0001, za0002 := range *m {
    		s += msgp.StringPrefixSize + len(za0001) + msgp.StringPrefixSize + len(za0002)
    	}
    	return s
    }
    
    // NewMSS returns a new MSS.
    func NewMSS() *MSS {
    	m := MSS(mssPool.Get().(map[string]string))
    	for k := range m {
    		delete(m, k)
    	}
    	return &m
    }
    
    // NewMSSWith returns a new MSS with the given map.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 01 23:42:09 GMT 2024
    - 15.4K bytes
    - Viewed (0)
  9. cmd/bucket-targets.go

    			for _, ep := range sys.hc {
    				eps = append(eps, madmin.ServerProperties{Endpoint: ep.Endpoint, Scheme: ep.Scheme})
    			}
    			sys.hMutex.RUnlock()
    
    			if len(eps) > 0 {
    				cctx, cancel := context.WithTimeout(ctx, 30*time.Second)
    				m := make(map[string]epHealth, len(eps))
    				start := time.Now()
    
    				for result := range sys.hcClient.Alive(cctx, madmin.AliveOpts{}, eps...) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  10. istioctl/pkg/precheck/precheck.go

    	if err != nil {
    		return err
    	}
    	for _, se := range ses.Items {
    		if se.Spec.Resolution != networking.ServiceEntry_NONE {
    			continue
    		}
    		changed := false
    		for _, p := range se.Spec.Ports {
    			if p.TargetPort != 0 && p.Number != p.TargetPort {
    				changed = true
    			}
    		}
    		if changed {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 02:57:30 GMT 2024
    - 19.3K bytes
    - Viewed (0)
Back to top