Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 968 for plen (0.09 sec)

  1. internal/bpool/bpool_test.go

    	}
    
    	b = bp.Get()
    	if len(b) != width {
    		t.Fatalf("bytepool length invalid: got %v want %v", len(b), width)
    	}
    	if cap(b) != capWidth {
    		t.Fatalf("bytepool length invalid: got %v want %v", cap(b), capWidth)
    	}
    
    	bp.Put(b)
    
    	// Check the size of the pool.
    	if uint64(len(bp.c)) != size {
    		t.Fatalf("bytepool size invalid: got %v want %v", len(bp.c), size)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  2. cmd/data-scanner.go

    		}
    
    		// If we have many subfolders, compact ourself.
    		shouldCompact := f.newCache.Info.Name != folder.name &&
    			len(existingFolders)+len(newFolders) >= dataScannerCompactAtFolders ||
    			len(existingFolders)+len(newFolders) >= dataScannerForceCompactAtFolders
    
    		if totalFolders := len(existingFolders) + len(newFolders); totalFolders > int(scannerExcessFolders.Load()) {
    			prefixName := strings.TrimSuffix(folder.name, "/") + "/"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  3. 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"))
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  4. src/main/java/jcifs/dcerpc/UnicodeString.java

         */
        public UnicodeString ( String str, boolean zterm ) {
            this.zterm = zterm;
    
            int len = str.length();
            int zt = zterm ? 1 : 0;
    
            this.length = this.maximum_length = (short) ( ( len + zt ) * 2 );
            this.buffer = new short[len + zt];
    
            int i;
            for ( i = 0; i < len; i++ ) {
                this.buffer[ i ] = (short) str.charAt(i);
            }
            if ( zterm ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 2.5K bytes
    - Viewed (0)
  5. cmd/bucket-replication-utils.go

    	}
    	if len(s) == 0 {
    		return
    	}
    	for _, p := range strings.Split(s, ",") {
    		if p == "" {
    			continue
    		}
    		slc := strings.Split(p, "=")
    		if len(slc) != 2 {
    			return r, errInvalidReplicateDecisionFormat
    		}
    		tgtStr := strings.TrimSuffix(strings.TrimPrefix(slc[1], `"`), `"`)
    		tgt := strings.Split(tgtStr, ";")
    		if len(tgt) != 4 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  6. cmd/metacache-walk.go

    				return ctx.Err()
    			}
    			meta := metaCacheEntry{name: pathJoinBuf(sb, current, entry)}
    
    			// If directory entry on stack before this, pop it now.
    			for len(dirStack) > 0 && dirStack[len(dirStack)-1] < meta.name {
    				pop := dirStack[len(dirStack)-1]
    				select {
    				case <-ctx.Done():
    					return ctx.Err()
    				case out <- metaCacheEntry{name: pop}:
    				}
    				if opts.Recursive {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  7. cmd/object-api-utils.go

    	if isMinioMetaBucketName(bucket) {
    		return true
    	}
    	if len(bucket) < 3 || len(bucket) > 63 {
    		return false
    	}
    
    	// Split on dot and check each piece conforms to rules.
    	allNumbers := true
    	pieces := strings.Split(bucket, dnsDelimiter)
    	for _, piece := range pieces {
    		if len(piece) == 0 || piece[0] == '-' ||
    			piece[len(piece)-1] == '-' {
    			// Current piece has 0-length or starts or
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  8. cmd/endpoint.go

    	return nil
    }
    
    func isEmptyLayout(poolsLayout ...poolDisksLayout) bool {
    	return len(poolsLayout) == 0 || len(poolsLayout[0].layout) == 0 || len(poolsLayout[0].layout[0]) == 0 || len(poolsLayout[0].layout[0][0]) == 0
    }
    
    func isSingleDriveLayout(poolsLayout ...poolDisksLayout) bool {
    	return len(poolsLayout) == 1 && len(poolsLayout[0].layout) == 1 && len(poolsLayout[0].layout[0]) == 1
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 34.2K bytes
    - Viewed (0)
  9. cmd/erasure-sets.go

    	setCount := len(format.Erasure.Sets)
    	setDriveCount := len(format.Erasure.Sets[0])
    
    	endpointStrings := make([]string, len(endpoints.Endpoints))
    	for i, endpoint := range endpoints.Endpoints {
    		endpointStrings[i] = endpoint.String()
    	}
    
    	// Initialize the erasure sets instance.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  10. internal/amztime/iso8601_time.go

    func ISO8601Format(t time.Time) string {
    	value := t.Format(iso8601TimeFormat)
    	if len(value) < len(iso8601TimeFormat) {
    		value = t.Format(iso8601TimeFormat[:len(iso8601TimeFormat)-1])
    		// Pad necessary zeroes to full-fill the iso8601TimeFormat
    		return value + strings.Repeat("0", (len(iso8601TimeFormat)-1)-len(value)) + "Z"
    	}
    	return value
    }
    
    // ISO8601Parse parses ISO8601 date string
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jan 16 23:38:33 UTC 2023
    - 1.9K bytes
    - Viewed (0)
Back to top