- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 25 for timer (0.02 seconds)
-
cmd/iam.go
} if parentUser == "" { return auth.Credentials{}, time.Time{}, errInvalidArgument } if len(opts.accessKey) > 0 && len(opts.secretKey) == 0 { return auth.Credentials{}, time.Time{}, auth.ErrNoSecretKeyWithAccessKey } if len(opts.secretKey) > 0 && len(opts.accessKey) == 0 { return auth.Credentials{}, time.Time{}, auth.ErrNoAccessKeyWithSecretKey }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Oct 15 17:00:45 GMT 2025 - 76.5K bytes - Click Count (0) -
cmd/erasure-server-pool.go
defer timer.Stop() for { select { case <-ctx.Done(): return case <-timer.C: z.mpCache.Range(func(id string, info MultipartInfo) bool { if time.Since(info.Initiated) >= globalAPIConfig.getStaleUploadsExpiry() { z.mpCache.Delete(id) // No need to notify to peers, each node will delete its own cache. } return true }) // Reset for the next interval
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 89.2K bytes - Click Count (0) -
cmd/xl-storage.go
func (s *xlStorage) readMetadataWithDMTime(ctx context.Context, itemPath string) ([]byte, time.Time, error) { if contextCanceled(ctx) { return nil, time.Time{}, ctx.Err() } if err := checkPathLength(itemPath); err != nil { return nil, time.Time{}, err } f, err := OpenFile(itemPath, readMode, 0o666) if err != nil { return nil, time.Time{}, err } defer f.Close() stat, err := f.Stat() if err != nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 91.7K bytes - Click Count (0) -
tests/query_test.go
} } var times []time.Time if err := DB.Model(User{}).Where("name like ?", "pluck-user%").Pluck("created_at", ×).Error; err != nil { t.Errorf("got error when pluck time: %v", err) } for idx, tv := range times { AssertEqual(t, tv, users[idx].CreatedAt) } var ptrtimes []*time.Time
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Tue Jul 22 06:21:04 GMT 2025 - 51K bytes - Click Count (0) -
cmd/erasure-object.go
readQuorum, _, err := objectQuorumFromMeta(ctx, metaArr, errs, er.defaultParityCount) if err != nil { return FileInfo{}, nil, nil, time.Time{}, "", err } if err := reduceReadQuorumErrs(ctx, errs, objectOpIgnoredErrs, readQuorum); err != nil { return FileInfo{}, nil, nil, time.Time{}, "", err }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Oct 24 04:05:31 GMT 2025 - 80.4K bytes - Click Count (0) -
cmd/peer-rest-server.go
} // Wait until the specified time before executing the signal. if t := vars.Get(peerRESTExecAt); t != "" { execAt, err := time.Parse(time.RFC3339Nano, vars.Get(peerRESTExecAt)) if err != nil { logger.LogIf(GlobalContext, "signalservice", err) execAt = time.Now().Add(restartUpdateDelay) } if d := time.Until(execAt); d > 0 { time.Sleep(d) } } signal := serviceSignal(si)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 53.6K bytes - Click Count (0) -
cmd/batch-handlers.go
jobCancelers: make(map[string]context.CancelFunc), } jpool.ResizeWorkers(workers) randomWait := func() time.Duration { // randomWait depends on the number of nodes to avoid triggering resume and cleanups at the same time. return time.Duration(rand.Float64() * float64(time.Duration(globalEndpoints.NEndpoints())*time.Hour)) } go func() { jpool.resume(randomWait) jpool.cleanupReports(randomWait) }()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 63.5K bytes - Click Count (1) -
cmd/iam-store.go
if isGroup { if store.getUsersSysType() == MinIOUsersSysType { g, ok := c.iamGroupsMap[name] if !ok { if err := store.loadGroup(context.Background(), name, c.iamGroupsMap); err != nil { return nil, time.Time{}, err } g, ok = c.iamGroupsMap[name] if !ok { return nil, time.Time{}, errNoSuchGroup } }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 87.1K bytes - Click Count (0) -
src/bufio/bufio_test.go
if err == nil { t.Error("error expected") } else if err != io.ErrNoProgress { t.Error("unexpected error:", err) } case <-time.After(time.Second): t.Error("test timed out (endless loop in ReadByte?)") } } // A StringReader delivers its data one string segment at a time via Read. type StringReader struct { data []string step int } func (r *StringReader) Read(p []byte) (n int, err error) {Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Fri Feb 07 01:08:54 GMT 2025 - 51.6K bytes - Click Count (0) -
cmd/admin-handlers-users.go
} writeSuccessResponseJSON(w, b) } } func addExpirationToCondValues(exp *time.Time, condValues map[string][]string) error { if exp == nil || exp.IsZero() || exp.Equal(timeSentinel) { return nil } dur := time.Until(*exp) if dur <= 0 { return errors.New("unsupported expiration time") } condValues["DurationSeconds"] = []string{strconv.FormatInt(int64(dur.Seconds()), 10)} return nil
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 90.6K bytes - Click Count (0)