- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 29 for Howard (0.18 sec)
-
cmd/metacache-walk.go
var scanDir func(path string) error scanDir = func(current string) error { // Skip forward, if requested... sb := bytebufferpool.Get() defer func() { sb.Reset() bytebufferpool.Put(sb) }() forward := "" if len(opts.ForwardTo) > 0 && strings.HasPrefix(opts.ForwardTo, current) { forward = strings.TrimPrefix(opts.ForwardTo, current) // Trim further directories and trailing slash.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.4K bytes - Viewed (0) -
cmd/xl-storage-format-v2_test.go
expireRestored bool expectedDataDir string }{ { // object versions with inlined data don't count towards shared data directory versionID: mustGetUUID(), dataDir: d0, data: data, shares: 0, }, { // object versions with inlined data don't count towards shared data directory versionID: mustGetUUID(), dataDir: d1, data: data2, shares: 0, },
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Mar 08 17:50:48 GMT 2024 - 36.4K bytes - Viewed (0) -
cmd/metacache-set.go
// The last entry can be used as a marker to resume the listing. func (r *metacacheReader) filter(o listPathOptions) (entries metaCacheEntriesSorted, err error) { // Forward to prefix, if any err = r.forwardTo(o.Prefix) if err != nil { return entries, err } if o.Marker != "" { err = r.forwardTo(o.Marker) if err != nil { return entries, err } }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 19:52:52 GMT 2024 - 30.4K bytes - Viewed (0) -
cmd/generic-handlers.go
if err != nil { h.ServeHTTP(w, r) return } remote, self := globalSiteReplicationSys.getPeerForUpload(deplID) if self { h.ServeHTTP(w, r) return } // forward request to peer handling this upload if globalBucketTargetSys.isOffline(remote.EndpointURL) { defer logger.AuditLog(r.Context(), w, r, mustGetClaimsFromToken(r))
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 11 01:08:52 GMT 2024 - 20.7K bytes - Viewed (0) -
cmd/erasure-multipart.go
// uploads for a particular object in a bucket. // // Implements minimal S3 compatible ListMultipartUploads API. We do // not support prefix based listing, this is a deliberate attempt // towards simplification of multipart APIs. // The resulting ListMultipartsInfo structure is unmarshalled directly as XML.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 43K bytes - Viewed (0) -
cmd/dynamic-timeouts.go
} else if failPct < dynamicTimeoutDecreaseThresholdPct { // We are hitting the timeout relatively few times, // so decrease the timeout towards 25 % of maximum time spent. max = max * 125 / 100 timeout := atomic.LoadInt64(&dt.timeout) if max < time.Duration(timeout) { // Move 50% toward the max. timeout = (int64(max) + timeout) / 2 } if timeout < dt.minimum { timeout = dt.minimum }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Aug 19 23:21:05 GMT 2022 - 4.5K bytes - Viewed (0) -
internal/event/target/kafka_scram_client_contrib.go
return nil } // Step takes a string provided from a server (or just an empty string for the // very first conversation step) and attempts to move the authentication // conversation forward. It returns a string to be sent to the server or an // error if the server message is invalid. Calling Step after a conversation // completes is also an error.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Nov 09 04:04:01 GMT 2023 - 3.2K bytes - Viewed (0) -
cmd/metacache-stream.go
} if r.current.name != "" { return false } _, err := r.peek() if err != nil { r.err = err return r.err == io.EOF } return false } // forwardTo will forward to the first entry that is >= s. // Will return io.EOF if end of stream is reached without finding any. func (r *metacacheReader) forwardTo(s string) error { r.checkInit() if r.err != nil { return r.err }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 19.5K bytes - Viewed (0) -
cmd/object-lambda-handlers.go
tokenErr.Description = "The request token included in the request is invalid" writeErrorResponse(ctx, w, tokenErr, r.URL) return } // Set all the relevant lambda forward headers if found. fwdHeadersToS3(resp.Header, w) if apiErr := fwdStatusToAPIError(resp); apiErr != nil { writeErrorResponse(ctx, w, *apiErr, r.URL) return } if resp.StatusCode != http.StatusOK {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Sep 15 04:58:17 GMT 2023 - 10.2K bytes - Viewed (1) -
cmd/server-main.go
if configRetriableErrors(err) { return fmt.Errorf("Unable to initialize config system: %w", err) } // Any other config errors we simply print a message and proceed forward. configLogIf(ctx, fmt.Errorf("Unable to initialize config, some features may be missing: %w", err)) } return nil } func setGlobalInternodeInterface(interfaceName string) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 33K bytes - Viewed (1)