- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 70 for bawler (0.25 sec)
-
cmd/generic-handlers.go
// such as ".." and "." func hasBadPathComponent(path string) bool { if len(path) > 4096 { // path cannot be greater than Linux PATH_MAX // this is to avoid a busy loop, that can happen // if the caller sends path of following style // a/a/a/a/a/a/a/a... return true } path = filepath.ToSlash(strings.TrimSpace(path)) // For windows '\' must be converted to '/'
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:08:52 GMT 2024 - 20.7K bytes - Viewed (0) -
cmd/metacache-set.go
if serverDebugLog { console.Debugln(data...) } } // gatherResults will collect all results on the input channel and filter results according // to the options or to the current bucket ILM expiry rules. // Caller should close the channel when done. // The returned function will return the results once there is enough or input is closed, // or the context is canceled.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:59:08 GMT 2024 - 30.4K bytes - Viewed (0) -
internal/ioutil/ioutil.go
timeout: timeout, } return dw } // Run runs the given function, passing it a stopper channel. If the deadline passes before // the function finishes executing, Run returns context.DeadlineExceeded to the caller. // channel so that the work function can attempt to exit gracefully. // Multiple calls to Run will run independently of each other. func (d *DeadlineWorker) Run(work func() error) error { c := make(chan ioret[struct{}], 1)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 11:26:59 GMT 2024 - 10.3K bytes - Viewed (0) -
cmd/global-heal.go
// in the beginning of erasure set healing if _, err := objAPI.HealBucket(ctx, bucket, madmin.HealOpts{ ScanMode: scanMode, }); err != nil { // Set this such that when we return this function // we let the caller retry this disk again for the // buckets that failed healing. retErr = err healingLogIf(ctx, err) continue } var ( vc *versioning.Versioning lc *lifecycle.Lifecycle
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 15K bytes - Viewed (1) -
cmd/os_windows.go
typ = fi.Mode() case data.FileAttributes&syscall.FILE_ATTRIBUTE_DIRECTORY != 0: typ = os.ModeDir } if err = filter(name, typ); err == errDoneForNow { // filtering requested to return by caller. return nil } } return nil } // Return N entries at the directory dirPath. func readDirWithOpts(dirPath string, opts readDirOpts) (entries []string, err error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Oct 18 18:08:15 GMT 2023 - 5.1K bytes - Viewed (0) -
cmd/server-startup-msg.go
h = host } ip := net.ParseIP(h) return ip.To16() != nil && ip.To4() == nil } // strip api endpoints list with standard ports such as // port "80" and "443" before displaying on the startup // banner. Returns a new list of API endpoints. func stripStandardPorts(apiEndpoints []string, host string) (newAPIEndpoints []string) { if len(apiEndpoints) == 1 { return apiEndpoints }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Mar 09 03:07:08 GMT 2024 - 6.8K bytes - Viewed (0) -
internal/crypto/sse-s3.go
} // There are two possibilities: // - We use a KMS -> There must be non-empty key ID and a KMS data key. // - We use a K/V -> There must be no key ID and no KMS data key. // Otherwise, the caller has passed an invalid argument combination. if keyID == "" && len(kmsKey) != 0 { logger.CriticalIf(context.Background(), errors.New("The key ID must not be empty if a KMS data key is present")) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 8.5K bytes - Viewed (0) -
internal/config/identity/plugin/config.go
func (h *metrics) setConnFailure(reqStartTime time.Time) { h.Lock() defer h.Unlock() h.LastCheckFailure = reqStartTime } func (h *metrics) updateLastFullMinute(currReqMinute time.Time) { // Assumes the caller has h.Lock()'ed h.lastFullMinute = h.currentMinute h.currentMinute = serviceRTTMinuteStats{ statsTime: currReqMinute, } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13.3K bytes - Viewed (3) -
internal/logger/target/http/http.go
// format of a log entry to the configured http endpoint. // An internal buffer of logs is maintained but when the // buffer is full, new logs are just ignored and an error // is returned to the caller. type Target struct { totalMessages int64 failedMessages int64 status int32 // Worker control workers int64 maxWorkers int64 // workerStartMu sync.Mutex lastStarted time.Time
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 14.9K bytes - Viewed (0) -
cmd/iam-object-store.go
iamOS.Lock() defer iamOS.Unlock() iamOS.iamCache.iamSTSAccountsMap = stsAccountsFromStore iamOS.iamCache.iamSTSPolicyMap = stsAccPoliciesFromStore return nil } // Assumes cache is locked by caller. func (iamOS *IAMObjectStore) loadAllFromObjStore(ctx context.Context, cache *iamCache) error { if iamOS.objAPI == nil { return errServerNotInitialized } bootstrapTraceMsg("loading all IAM items")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 05 21:26:41 GMT 2024 - 19.9K bytes - Viewed (0)