Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 595 for lena (0.14 sec)

  1. internal/http/listener.go

    	}
    
    	if len(listeners) == 0 {
    		// No listeners initialized, no need to continue
    		return
    	}
    
    	listener = &httpListener{
    		listeners: listeners,
    		acceptCh:  make(chan acceptResult, len(listeners)),
    		opts:      opts,
    	}
    	listener.ctx, listener.ctxCanceler = context.WithCancel(ctx)
    	if opts.Trace != nil {
    		opts.Trace(fmt.Sprint("opening ", len(listener.listeners), " listeners"))
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  2. cmd/metrics-realtime.go

    		} else {
    			// not collecting per-cpu stats, so there will be only one element
    			if len(cm) == 1 {
    				m.Aggregated.CPU.TimesStat = &cm[0]
    			} else {
    				m.Errors = append(m.Errors, fmt.Sprintf("%s: Expected one CPU stat, got %d", byHostName, len(cm)))
    			}
    		}
    		cpuCount, err := c.Counts(true)
    		if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 10 16:28:08 GMT 2024
    - 6.1K bytes
    - Viewed (0)
  3. cmd/tier_gen.go

    			zb0002, err = dc.ReadMapHeader()
    			if err != nil {
    				err = msgp.WrapError(err, "Tiers")
    				return
    			}
    			if z.Tiers == nil {
    				z.Tiers = make(map[string]madmin.TierConfig, zb0002)
    			} else if len(z.Tiers) > 0 {
    				for key := range z.Tiers {
    					delete(z.Tiers, key)
    				}
    			}
    			for zb0002 > 0 {
    				zb0002--
    				var za0001 string
    				var za0002 madmin.TierConfig
    				za0001, err = dc.ReadString()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 20 00:53:08 GMT 2023
    - 4K bytes
    - Viewed (0)
  4. lib/time/mkzip.go

    		}
    		name := filepath.ToSlash(path)
    		w, err := zw.CreateRaw(&zip.FileHeader{
    			Name:               name,
    			Method:             zip.Store,
    			CompressedSize64:   uint64(len(data)),
    			UncompressedSize64: uint64(len(data)),
    			CRC32:              crc32.ChecksumIEEE(data),
    		})
    		if err != nil {
    			log.Fatal(err)
    		}
    		if _, err := w.Write(data); err != nil {
    			log.Fatal(err)
    		}
    		seen[name] = true
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Mon Mar 04 17:32:07 GMT 2024
    - 2.1K bytes
    - Viewed (0)
  5. cmd/local-locker_gen.go

    func (z *lockRequesterInfo) Msgsize() (s int) {
    	s = 1 + 5 + msgp.StringPrefixSize + len(z.Name) + 7 + msgp.BoolSize + 4 + msgp.StringPrefixSize + len(z.UID) + 10 + msgp.TimeSize + 16 + msgp.TimeSize + 7 + msgp.StringPrefixSize + len(z.Source) + 6 + msgp.BoolSize + 6 + msgp.StringPrefixSize + len(z.Owner) + 7 + msgp.IntSize
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 21 17:21:35 GMT 2024
    - 13.8K bytes
    - Viewed (0)
  6. cmd/site-replication.go

    			return info, err
    		}
    		info.Metrics = m
    	}
    
    	// maximum buckets users etc seen across sites
    	info.MaxBuckets = len(bucketStats)
    	info.MaxUsers = len(userInfoStats)
    	info.MaxGroups = len(groupDescStats)
    	info.MaxPolicies = len(policyStats)
    	info.MaxILMExpiryRules = len(ilmExpiryRuleStats)
    	return
    }
    
    // isReplicated returns true if count of replicated matches the number of
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 184.2K bytes
    - Viewed (1)
  7. schema/naming.go

    			}
    		} else {
    			buf.WriteRune(v)
    		}
    
    		lastCase = curCase
    		curCase = nextCase
    	}
    
    	if curCase {
    		if !lastCase && len(value) > 1 {
    			buf.WriteByte('_')
    		}
    		buf.WriteByte(value[len(value)-1] + 32)
    	} else {
    		buf.WriteByte(value[len(value)-1])
    	}
    	ret := buf.String()
    	return ret
    }
    
    func (ns NamingStrategy) toSchemaName(name string) string {
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Mon Oct 30 09:15:49 GMT 2023
    - 5.2K bytes
    - Viewed (0)
  8. cmd/site-replication-utils_gen.go

    func (z *SiteResyncStatus) Msgsize() (s int) {
    	s = 1 + 2 + msgp.IntSize + 3 + z.Status.Msgsize() + 4 + msgp.StringPrefixSize + len(z.DeplID) + 5 + msgp.MapHeaderSize
    	if z.BucketStatuses != nil {
    		for za0001, za0002 := range z.BucketStatuses {
    			_ = za0002
    			s += msgp.StringPrefixSize + len(za0001) + za0002.Msgsize()
    		}
    	}
    	s += 3 + msgp.IntSize + 4 + z.TargetReplicationResyncStatus.Msgsize()
    	return
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Nov 14 15:16:40 GMT 2022
    - 7.2K bytes
    - Viewed (0)
  9. internal/crypto/key.go

    // and a source of randomness. If random is nil the default PRNG of the
    // system (crypto/rand) is used.
    func GenerateKey(extKey []byte, random io.Reader) (key ObjectKey) {
    	if random == nil {
    		random = rand.Reader
    	}
    	if len(extKey) != 32 { // safety check
    		logger.CriticalIf(context.Background(), errors.New("crypto: invalid key length"))
    	}
    	var nonce [32]byte
    	if _, err := io.ReadFull(random, nonce[:]); err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 19 20:28:10 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  10. cmd/batch-expire.go

    		return false
    	}
    
    	if len(ef.Name) > 0 && !wildcard.Match(ef.Name, obj.Name) {
    		return false
    	}
    	if ef.OlderThan > 0 && now.Sub(obj.ModTime) <= ef.OlderThan {
    		return false
    	}
    
    	if ef.CreatedBefore != nil && !obj.ModTime.Before(*ef.CreatedBefore) {
    		return false
    	}
    
    	if len(ef.Tags) > 0 && !obj.DeleteMarker {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 21K bytes
    - Viewed (1)
Back to top