Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 93 for others (0.15 sec)

  1. cmd/metacache-entries.go

    			return e, other.isDir() == e.isDir()
    		}
    		return other, other.isDir() == e.isDir()
    	}
    	eVers, eErr := e.xlmeta()
    	oVers, oErr := other.xlmeta()
    	if eErr != nil || oErr != nil {
    		return nil, false
    	}
    
    	// check both fileInfo's have same number of versions, if not skip
    	// the `other` entry.
    	if len(eVers.versions) != len(oVers.versions) {
    		eTime := eVers.latestModtime()
    		oTime := oVers.latestModtime()
    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. internal/grid/manager.go

    		return fmt.Errorf("handler %v, subroute:%v: %w", id.String(), s, ErrHandlerAlreadyExists)
    	}
    	m.handlers.subSingle[subID] = h
    	// Copy so clients can also pick it up for other subpaths.
    	m.handlers.subSingle[makeZeroSubHandlerID(id)] = h
    	return nil
    }
    
    /*
    // RegisterStateless will register a stateless handler that serves
    // []byte -> stream of ([]byte, error) requests.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.5K bytes
    - Viewed (0)
  3. cmd/storage-datatypes.go

    	Fresh bool `msg:"fr"` // indicates this is a first time call to write FileInfo.
    
    	// Position of this version or object in a multi-object delete call,
    	// no other caller must set this value other than multi-object delete call.
    	// usage in other calls in undefined please avoid.
    	Idx int `msg:"i"`
    
    	// Combined checksum when object was uploaded.
    	Checksum []byte `msg:"cs,allownil"`
    
    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)
  4. cmd/erasure-server-pool-decom.go

    				// to decommission, just skip it, this also includes
    				// any other versions that have already expired.
    				remainingVersions := len(fivs.Versions) - expired
    				if version.Deleted && remainingVersions == 1 {
    					decommissioned++
    					stopFn(errors.New("DELETE marked object with no other non-current versions will be skipped"))
    					continue
    				}
    
    				versionID := version.VersionID
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 15:18:21 GMT 2024
    - 41.5K bytes
    - Viewed (1)
  5. cmd/api-response.go

    			continue
    		}
    	}
    
    	for _, k := range toRemove {
    		delete(m, k)
    		delete(m, strings.ToLower(k))
    	}
    
    	return m
    }
    
    // generates an ListBucketVersions response for the said bucket with other enumerated options.
    func generateListVersionsResponse(bucket, prefix, marker, versionIDMarker, delimiter, encodingType string, maxKeys int, resp ListObjectVersionsInfo, metadata metaCheckFn) ListVersionsResponse {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 33.3K bytes
    - Viewed (2)
  6. internal/grid/grid_test.go

    	defer cancel()
    	st, err := remoteConn.NewStream(ctx, handlerTest, []byte(testPayload))
    	errFatal(err)
    
    	// Wait for the server to send the first response.
    	<-serverSent
    
    	// Now do 100 other requests to ensure that the server doesn't block.
    	for i := 0; i < 100; i++ {
    		_, err := remoteConn.Request(ctx, handlerTest2, []byte(testPayload))
    		errFatal(err)
    	}
    	// Drain responses
    	got := 0
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 30 15:03:35 GMT 2024
    - 30.1K bytes
    - Viewed (0)
  7. cmd/metacache-server-pool.go

    // otherwise nil or an unexpected error is returned.
    // The listPathOptions given will be checked and modified internally.
    // Required important fields are Bucket, Prefix, Separator.
    // Other important fields are Limit, Marker.
    // List ID always derived from the Marker.
    func (z *erasureServerPools) listPath(ctx context.Context, o *listPathOptions) (entries metaCacheEntriesSorted, err error) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.8K bytes
    - Viewed (0)
  8. cmd/tier.go

    	for k := range config.drivercache {
    		delete(config.drivercache, k)
    	}
    	// Remove existing tier configs
    	for k := range config.Tiers {
    		delete(config.Tiers, k)
    	}
    	// Copy over the new tier configs
    	for tier, cfg := range newConfig.Tiers {
    		config.Tiers[tier] = cfg
    	}
    	config.lastRefreshedAt = UTCNow()
    	return nil
    }
    
    // Save saves tier configuration onto objAPI
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  9. internal/rest/client.go

    		return nil, &NetworkError{Err: c.LastError()}
    	}
    
    	// client is still connected, attempt the request.
    
    	// Shallow copy. We don't modify the *UserInfo, if set.
    	// All other fields are copied.
    	u := *c.url
    	u.Path = path.Join(u.Path, method)
    	u.RawQuery = values.Encode()
    
    	req, err := c.newRequest(ctx, u, body)
    	if err != nil {
    		return nil, &NetworkError{Err: err}
    	}
    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)
  10. cmd/handler-utils.go

    	err := xmlDecoder(r.Body, &locationConstraint, r.ContentLength)
    	if err != nil && r.ContentLength != 0 {
    		internalLogOnceIf(GlobalContext, err, "location-constraint-xml-parsing")
    		// Treat all other failures as XML parsing errors.
    		return "", ErrMalformedXML
    	} // else for both err as nil or io.EOF
    	location = locationConstraint.Location
    	if location == "" {
    		location = globalSite.Region
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.5K bytes
    - Viewed (3)
Back to top