Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for mari (0.14 sec)

  1. cmd/metacache-entries.go

    				if xl == nil {
    					// Discard current "best"
    					if err := selectFrom(bestIdx); err != nil {
    						return err
    					}
    					bestIdx = idx
    					best = other
    					xl = xl2
    				} else {
    					// Mark read, unless we added it as new "best".
    					if err := selectFrom(idx); err != nil {
    						return err
    					}
    				}
    				versions = append(versions, xl2.versions)
    			}
    
    			if xl != nil && len(versions) > 0 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  2. src/archive/zip/reader.go

    }
    
    func (r *Reader) initFileList() {
    	r.fileListOnce.Do(func() {
    		// files and knownDirs map from a file/directory name
    		// to an index into the r.fileList entry that we are
    		// building. They are used to mark duplicate entries.
    		files := make(map[string]int)
    		knownDirs := make(map[string]int)
    
    		// dirs[name] is true if name is known to be a directory,
    		// because it appears as a prefix in a path.
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Oct 13 18:36:46 GMT 2023
    - 27.7K bytes
    - Viewed (0)
  3. cni/pkg/iptables/iptables.go

    	// From here on, we should be only inserting rules into our custom chains.
    
    	// CLI: -A ISTIO_PRERT -m mark --mark 0x539/0xfff -j CONNMARK --set-xmark 0x111/0xfff
    	//
    	// DESC: If we have a packet mark, set a connmark.
    	iptablesBuilder.AppendRule(iptableslog.UndefinedCommand, ChainInpodPrerouting, iptablesconstants.MANGLE, "-m", "mark",
    		"--mark", inpodMark,
    		"-j", "CONNMARK",
    		"--set-xmark", inpodTproxyMark)
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue May 07 19:54:50 GMT 2024
    - 19.7K bytes
    - Viewed (0)
  4. internal/rest/client.go

    func NewClient(uu *url.URL, tr http.RoundTripper, newAuthToken func(aud string) string) *Client {
    	connected := int32(online)
    	urlStr := uu.String()
    	u, err := url.Parse(urlStr)
    	if err != nil {
    		// Mark offline, with no reconnection attempts.
    		connected = int32(offline)
    		err = &url.Error{URL: urlStr, Err: err}
    	}
    	// The host's colon:port should be normalized. See Issue 14836.
    	u.Host = removeEmptyPort(u.Host)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 14.4K bytes
    - Viewed (0)
  5. cmd/storage-datatypes.go

    	// All the parts per object.
    	Parts []ObjectPartInfo `msg:"parts"`
    
    	// Erasure info for all objects.
    	Erasure ErasureInfo `msg:"ei"`
    
    	MarkDeleted      bool             `msg:"md"` // mark this version as deleted
    	ReplicationState ReplicationState `msg:"rs"` // Internal replication state to be passed back in ObjectInfo
    
    	Data []byte `msg:"d,allownil"` // optionally carries object data
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 15.3K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool-rebalance.go

    	r := z.rebalMeta
    	poolStats := r.PoolStats[poolIdx]
    	if poolStats.Info.Status == rebalCompleted {
    		return true
    	}
    
    	pfi := float64(poolStats.InitFreeSpace+poolStats.Bytes) / float64(poolStats.InitCapacity)
    	// Mark pool rebalance as done if within 5% from PercentFreeGoal.
    	if diff := math.Abs(pfi - r.PercentFreeGoal); diff <= 0.05 {
    		r.PoolStats[poolIdx].Info.Status = rebalCompleted
    		r.PoolStats[poolIdx].Info.EndTime = time.Now()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  7. src/bytes/bytes.go

    				b = append(b, replacement...)
    			}
    			continue
    		}
    		invalid = false
    		b = append(b, s[i:i+wid]...)
    		i += wid
    	}
    	return b
    }
    
    // isSeparator reports whether the rune could mark a word boundary.
    // TODO: update when package unicode captures more of the properties.
    func isSeparator(r rune) bool {
    	// ASCII alphanumerics and underscore are not separators
    	if r <= 0x7F {
    		switch {
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Mon Feb 19 19:51:15 GMT 2024
    - 33.8K bytes
    - Viewed (0)
  8. src/cmd/api/main_test.go

    							for _, id := range spec.Names {
    								mark(id)
    							}
    						case *ast.TypeSpec:
    							mark(spec.Name)
    						}
    					}
    				}
    				return true // look at specs
    			case *ast.FuncDecl:
    				if isDeprecated(n.Doc) {
    					mark(n.Name)
    				}
    				return false
    			case *ast.TypeSpec:
    				if isDeprecated(n.Doc) {
    					mark(n.Name)
    				}
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Tue Apr 09 20:48:51 GMT 2024
    - 31.4K bytes
    - Viewed (0)
  9. cmd/erasure-healing-common.go

    				int64(len(meta.Data)),
    				meta.Erasure.ShardFileSize(meta.Size),
    				checksumInfo.Algorithm,
    				checksumInfo.Hash, meta.Erasure.ShardSize())
    			if dataErrs[i] == nil {
    				// All parts verified, mark it as all data available.
    				availableDisks[i] = onlineDisk
    			} else {
    				// upon errors just make that disk's fileinfo invalid
    				partsMetadata[i] = FileInfo{}
    			}
    			continue
    		}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 10.8K bytes
    - Viewed (0)
  10. internal/dsync/drwmutex.go

    	// c) timed out
    	//
    	i, locksFailed := 0, 0
    	done := false
    
    	for ; i < len(restClnts); i++ { // Loop until we acquired all locks
    		select {
    		case grant := <-ch:
    			if grant.isLocked() {
    				// Mark that this node has acquired the lock
    				(*locks)[grant.index] = grant.lockUID
    			} else {
    				locksFailed++
    				if locksFailed > tolerance {
    					// We know that we are not going to get the lock anymore,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 19.7K bytes
    - Viewed (0)
Back to top