- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 33 for timer (0.06 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) -
android/guava/src/com/google/common/util/concurrent/Futures.java
* * <p>The delegate future is interrupted and cancelled if it times out. * * @param delegate The future to delegate to. * @param time when to time out the future * @param unit the time unit of the time parameter * @param scheduledExecutor The executor service to enforce the timeout. * @since 19.0 */ @J2ktIncompatible
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 64.3K 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) -
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/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) -
guava/src/com/google/common/collect/Iterators.java
* is polled. This amortizes the sorting cost over the iteration and requires less memory than * sorting all elements at once. * * <p>Retrieving a single element takes approximately O(log(M)) time, where M is the number of * iterators. (Retrieving all elements takes approximately O(N*log(M)) time, where N is the total * number of elements.) */
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Sep 16 12:42:11 GMT 2025 - 51.4K bytes - Click Count (0) -
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) -
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)