Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 161 - 170 of 1,132 for timeN (0.03 seconds)

  1. internal/ioutil/ioutil_test.go

    	"errors"
    	"io"
    	"os"
    	"strings"
    	"testing"
    	"time"
    )
    
    type sleepWriter struct {
    	timeout time.Duration
    }
    
    func (w *sleepWriter) Write(p []byte) (n int, err error) {
    	time.Sleep(w.timeout)
    	return len(p), nil
    }
    
    func (w *sleepWriter) Close() error {
    	return nil
    }
    
    func TestDeadlineWorker(t *testing.T) {
    	work := NewDeadlineWorker(500 * time.Millisecond)
    
    	err := work.Run(func() error {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 5.6K bytes
    - Click Count (0)
  2. cmd/object-api-datatypes.go

    	Name string
    
    	// Date and time when the bucket was created.
    	Created time.Time
    	Deleted time.Time
    
    	// Bucket features enabled
    	Versioning, ObjectLocking bool
    }
    
    // ObjectInfo - represents object metadata.
    type ObjectInfo struct {
    	// Name of the bucket.
    	Bucket string
    
    	// Name of the object.
    	Name string
    
    	// Date and time when the object was last modified.
    	ModTime time.Time
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 21.2K bytes
    - Click Count (0)
  3. cmd/metrics-v3-cluster-iam.go

    	pluginAuthnServiceLastSuccSecondsMD      = NewCounterMD(pluginAuthnServiceLastSuccSeconds, "When plugin authentication is configured, returns time (in seconds) since the last successful request to the service")
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu May 02 08:20:42 GMT 2024
    - 4.5K bytes
    - Click Count (0)
  4. utils/tests/utils.go

    		isEqual := func() {
    			if curTime, ok := got.(time.Time); ok {
    				format := "2006-01-02T15:04:05Z07:00"
    
    				if curTime.Round(time.Second).UTC().Format(format) != expect.(time.Time).Round(time.Second).UTC().Format(format) && curTime.Truncate(time.Second).UTC().Format(format) != expect.(time.Time).Truncate(time.Second).UTC().Format(format) {
    					t.Errorf("%v: expect: %v, got %v after time round", utils.FileWithLineNum(), expect.(time.Time), curTime)
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Fri Mar 10 09:21:56 GMT 2023
    - 3.9K bytes
    - Click Count (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/ConnectionPoolTest.kt

        val c1 = factory.newConnection(pool, routeA1, 50L)
    
        // Running at time 50, the pool returns that nothing can be evicted until time 150.
        assertThat(pool.closeConnections(50L)).isEqualTo(100L)
        assertThat(pool.connectionCount()).isEqualTo(1)
        assertThat(c1.socket().isClosed).isFalse()
    
        // Running at time 60, the pool returns that nothing can be evicted until time 150.
        assertThat(pool.closeConnections(60L)).isEqualTo(90L)
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Oct 07 21:55:03 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  6. internal/dsync/utils.go

    package dsync
    
    import (
    	"math/rand"
    	"time"
    )
    
    func backoffWait(minSleep, unit, maxSleep time.Duration) func(*rand.Rand, uint) time.Duration {
    	if unit > time.Hour {
    		// Protect against integer overflow
    		panic("unit cannot exceed one hour")
    	}
    	return func(r *rand.Rand, attempt uint) time.Duration {
    		sleep := minSleep
    		sleep += unit * time.Duration(attempt)
    		if sleep > maxSleep {
    			sleep = maxSleep
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Nov 11 14:51:43 GMT 2024
    - 1.2K bytes
    - Click Count (0)
  7. internal/config/batch/batch.go

    type Config struct {
    	ReplicationWorkersWait time.Duration `json:"replicationWorkersWait"`
    	KeyRotationWorkersWait time.Duration `json:"keyRotationWorkersWait"`
    	ExpirationWorkersWait  time.Duration `json:"expirationWorkersWait"`
    }
    
    // ExpirationWait returns the duration for which a batch expiration worker
    // would wait before working on next object.
    func (opts Config) ExpirationWait() time.Duration {
    	configMu.RLock()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 4.7K bytes
    - Click Count (0)
  8. okcurl/src/main/kotlin/okhttp3/curl/logging/OneLineLogFormat.kt

    package okhttp3.curl.logging
    
    import java.io.PrintWriter
    import java.io.StringWriter
    import java.time.Instant
    import java.time.ZoneOffset
    import java.time.format.DateTimeFormatterBuilder
    import java.time.temporal.ChronoField.HOUR_OF_DAY
    import java.time.temporal.ChronoField.MINUTE_OF_HOUR
    import java.time.temporal.ChronoField.NANO_OF_SECOND
    import java.time.temporal.ChronoField.SECOND_OF_MINUTE
    import java.util.logging.Formatter
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Apr 05 03:30:42 GMT 2024
    - 2.1K bytes
    - Click Count (1)
  9. cmd/local-locker_test.go

    					}
    
    					// Expire 50%
    					expired := time.Now().Add(-time.Hour * 2)
    					for _, v := range l.lockMap {
    						for i := range v {
    							if rng.Intn(2) == 0 {
    								v[i].TimeLastRefresh = expired.UnixNano()
    							}
    						}
    					}
    					start = time.Now()
    					l.expireOldLocks(time.Hour)
    					t.Logf("Expire 50%% took: %v. Left: %d/%d", time.Since(start).Round(time.Millisecond), len(l.lockUID), len(l.lockMap))
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  10. cmd/listen-notification-handlers.go

    		if pingInterval < 1 {
    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrInvalidQueryParams), r.URL)
    			return
    		}
    		t := time.NewTicker(time.Duration(pingInterval) * time.Second)
    		defer t.Stop()
    		emptyEventTicker = t.C
    	} else {
    		// Deprecated Apr 2023
    		t := time.NewTicker(500 * time.Millisecond)
    		defer t.Stop()
    		keepAliveTicker = t.C
    	}
    
    	enc := json.NewEncoder(w)
    	for {
    		select {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 6K bytes
    - Click Count (0)
Back to Top