Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 829 for timme (0.04 sec)

  1. internal/lsync/lrwmutex.go

    			return false
    		default:
    			if lm.lock(id, source, isWriteLock) {
    				return true
    			}
    			time.Sleep(time.Duration(r.Float64() * float64(lockRetryInterval)))
    		}
    	}
    }
    
    // Unlock unlocks the write lock.
    //
    // It is a run-time error if lm is not locked on entry to Unlock.
    func (lm *LRWMutex) Unlock() {
    	isWriteLock := true
    	success := lm.unlock(isWriteLock)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 4.8K bytes
    - Viewed (0)
  2. internal/bucket/bandwidth/monitor.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package bandwidth
    
    //go:generate msgp -file=$GOFILE -unexported
    
    import (
    	"context"
    	"sync"
    	"time"
    
    	"golang.org/x/time/rate"
    )
    
    //msgp:ignore bucketThrottle Monitor
    
    type bucketThrottle struct {
    	*rate.Limiter
    	NodeBandwidthPerSec int64
    }
    
    // Monitor holds the state of the global bucket monitor
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 6K bytes
    - Viewed (0)
  3. cmd/update-notifier.go

    	// difference between newer and current release.
    	t := time.Time{}
    	newerThan := humanize.RelTime(t, t.Add(older), "before the latest release", "")
    
    	if globalServerCtxt.JSON {
    		return fmt.Sprintf("You are running an older version of MinIO released %s, update: %s", newerThan, downloadURL)
    	}
    
    	// Return the nicely colored and formatted update message.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Mar 09 03:07:08 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  4. src/archive/tar/strconv.go

    func parsePAXTime(s string) (time.Time, error) {
    	const maxNanoSecondDigits = 9
    
    	// Split string into seconds and sub-seconds parts.
    	ss, sn, _ := strings.Cut(s, ".")
    
    	// Parse the seconds.
    	secs, err := strconv.ParseInt(ss, 10, 64)
    	if err != nil {
    		return time.Time{}, ErrHeader
    	}
    	if len(sn) == 0 {
    		return time.Unix(secs, 0), nil // No sub-second values
    	}
    
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Tue Aug 01 14:28:42 UTC 2023
    - 9K bytes
    - Viewed (0)
  5. tests/test_tutorial/test_extra_data_types/test_tutorial001_an_py310.py

                                "type": "string",
                                "format": "date-time",
                            },
                            "end_datetime": {
                                "title": "End Datetime",
                                "type": "string",
                                "format": "date-time",
                            },
                            "repeat_at": IsDict(
                                {
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Fri Apr 19 00:11:40 UTC 2024
    - 7K bytes
    - Viewed (0)
  6. tests/default_value_test.go

    import (
    	"testing"
    	"time"
    
    	"gorm.io/gorm"
    )
    
    func TestDefaultValue(t *testing.T) {
    	type Harumph struct {
    		gorm.Model
    		Email   string    `gorm:"not null;index:,unique"`
    		Name    string    `gorm:"notNull;default:foo"`
    		Name2   string    `gorm:"size:233;not null;default:'foo'"`
    		Name3   string    `gorm:"size:233;notNull;default:''"`
    		Age     int       `gorm:"default:18"`
    		Created time.Time `gorm:"default:2000-01-02"`
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Mon Apr 08 03:29:55 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  7. internal/rest/rpc-stats.go

    	var dialStart, dialEnd int64
    	start := time.Now()
    	trace := &httptrace.ClientTrace{
    		GotFirstResponseByte: func() {
    			atomic.AddUint64(&globalStats.tcpTimeForFirstByteTotalDur, uint64(time.Since(start)))
    		},
    		ConnectStart: func(network, addr string) {
    			atomic.StoreInt64(&dialStart, time.Now().UnixNano())
    		},
    		ConnectDone: func(network, addr string, err error) {
    			if err == nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 13 18:21:34 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  8. cmd/mrf.go

    					continue
    				}
    				if wildcard.Match("tmp-old/*", u.Object) {
    					continue
    				}
    			}
    
    			now := time.Now()
    			if now.Sub(u.Queued) < time.Second {
    				// let recently failed networks to reconnect
    				// making MRF wait for 1s before retrying,
    				// i.e 4 reconnect attempts.
    				time.Sleep(time.Second)
    			}
    
    			// wait on timer per heal
    			wait := healSleeper.Timer(context.Background())
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  9. internal/event/target/kafka.go

    		config.Producer.CompressionLevel = args.Producer.CompressionLevel
    	}
    
    	config.Net.ReadTimeout = (5 * time.Second)
    	config.Net.DialTimeout = (5 * time.Second)
    	config.Net.WriteTimeout = (5 * time.Second)
    	config.Metadata.Retry.Max = 1
    	config.Metadata.Retry.Backoff = (1 * time.Second)
    	config.Metadata.RefreshFrequency = (15 * time.Minute)
    
    	target.config = config
    
    	brokers := []string{}
    	for _, broker := range args.Brokers {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  10. cmd/handler-api.go

    	requestsPool           chan struct{}
    	clusterDeadline        time.Duration
    	listQuorum             string
    	corsAllowOrigins       []string
    	replicationPriority    string
    	replicationMaxWorkers  int
    	replicationMaxLWorkers int
    	transitionWorkers      int
    
    	staleUploadsExpiry          time.Duration
    	staleUploadsCleanupInterval time.Duration
    	deleteCleanupInterval       time.Duration
    	enableODirect               bool
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 26 17:07:10 UTC 2024
    - 10.4K bytes
    - Viewed (0)
Back to top