Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for Remark (0.2 sec)

  1. 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)
  2. 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)
  3. 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)
  4. docs/LICENSE

         Licensors should also secure all rights necessary before
         applying our licenses so that the public can reuse the
         material as expected. Licensors should clearly mark any
         material not subject to the license. This includes other CC-
         licensed material, or material used under an exception or
         limitation to copyright. More considerations for licensors:
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon May 10 16:50:06 GMT 2021
    - 18.2K bytes
    - Viewed (0)
  5. 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)
  6. cmd/global-heal.go

    		}
    
    		disks, _, healing := er.getOnlineDisksWithHealingAndInfo(true)
    		if len(disks) == healing {
    			// All drives in this erasure set were reformatted for some reasons, abort healing and mark it as successful
    			healingLogIf(ctx, errors.New("all drives are in healing state, aborting.."))
    			return nil
    		}
    
    		disks = disks[:len(disks)-healing] // healing drives are always at the end of the list
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 15K bytes
    - Viewed (1)
  7. cmd/endpoint.go

    }
    
    // UpdateIsLocal - resolves the host and discovers the local host.
    func (endpoints Endpoints) UpdateIsLocal() error {
    	var epsResolved int
    	var foundLocal bool
    	resolvedList := make([]bool, len(endpoints))
    	// Mark the starting time
    	startTime := time.Now()
    	keepAliveTicker := time.NewTicker(500 * time.Millisecond)
    	defer keepAliveTicker.Stop()
    	for {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 34.1K bytes
    - Viewed (0)
  8. 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)
Back to top