- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for dimmer (0.19 sec)
-
internal/kms/kes.go
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Apr 16 15:43:39 GMT 2024 - 14.9K bytes - Viewed (0) -
cmd/erasure-multipart.go
if err != nil { return nil } w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout()) return w.Run(func() error { wait := deleteMultipartCleanupSleeper.Timer(ctx) if time.Since(fi.ModTime) > expiry { pathUUID := mustGetUUID() targetPath := pathJoin(drivePath, minioMetaTmpDeletedBucket, pathUUID)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 43K bytes - Viewed (0) -
cmd/erasure.go
w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout()) return w.Run(func() error { wait := deleteCleanupSleeper.Timer(ctx) removeAll(pathJoin(drivePath, minioMetaTmpDeletedBucket, ddir)) wait() return nil }) }) }(disk) } wg.Wait() }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 16K bytes - Viewed (1) -
cmd/object-api-listobjects_test.go
{Name: "Asia-maps.png"}, {Name: "Asia/India/India-summer-photos-1"}, {Name: "Asia/India/Karnataka/Bangalore/Koramangala/pics"}, {Name: "newPrefix0"}, {Name: "newPrefix1"}, }, }, // ListObjectsResult-2. // (TestCase 24). 2: { IsTruncated: true, Objects: []ObjectInfo{ {Name: "Asia-maps.png"}, {Name: "Asia/India/India-summer-photos-1"},
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 73.1K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
diskBuckets := set.CreateStringSet() for _, bucket := range buckets { diskBuckets.Add(bucket.Name) } sys.RemoveStaleBuckets(diskBuckets) for i := range buckets { wait := sleeper.Timer(ctx) meta, err := loadBucketMetadata(ctx, sys.objAPI, buckets[i].Name) if err != nil { internalLogIf(ctx, err, logger.WarningKind) wait() // wait to proceed to next entry. continue }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 19.8K bytes - Viewed (0) -
internal/http/dial_linux.go
// NewInternodeDialContext setups a custom dialer for internode communication func NewInternodeDialContext(dialTimeout time.Duration, opts TCPOptions) DialContext { return func(ctx context.Context, network, addr string) (net.Conn, error) { dialer := &net.Dialer{ Timeout: dialTimeout, Control: setTCPParametersFn(opts), } return dialer.DialContext(ctx, network, addr) } }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Jun 07 16:53:05 GMT 2023 - 4.4K bytes - Viewed (3) -
internal/http/dial_others.go
// NewInternodeDialContext setups a custom dialer for internode communication var NewInternodeDialContext = NewCustomDialContext // NewCustomDialContext configures a custom dialer for internode communications func NewCustomDialContext(dialTimeout time.Duration, _ TCPOptions) DialContext { return func(ctx context.Context, network, addr string) (net.Conn, error) { dialer := &net.Dialer{ Timeout: dialTimeout, }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed May 03 21:12:25 GMT 2023 - 1.7K bytes - Viewed (0) -
cmd/admin-handlers.go
} } globalProfilerMu.Unlock() timer := time.NewTimer(duration) defer timer.Stop() for { select { case <-ctx.Done(): globalProfilerMu.Lock() defer globalProfilerMu.Unlock() for k, v := range globalProfiler { v.Stop() delete(globalProfiler, k) } return case <-timer.C: if !globalNotificationSys.DownloadProfilingData(ctx, w) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2) -
internal/grid/manager.go
local string // Validate incoming requests. authRequest func(r *http.Request) error } // ManagerOptions are options for creating a new grid manager. type ManagerOptions struct { Dialer ContextDialer // Outgoing dialer. Local string // Local host name. Hosts []string // All hosts, including local in the grid.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0) -
cmd/grid.go
var globalGridStart = make(chan struct{}) func initGlobalGrid(ctx context.Context, eps EndpointServerPools) error { hosts, local := eps.GridHosts() g, err := grid.NewManager(ctx, grid.ManagerOptions{ Dialer: grid.ContextDialer(xhttp.DialContextWithLookupHost(globalDNSCache.LookupHost, xhttp.NewInternodeDialContext(rest.DefaultTimeout, globalTCPOptions))), Local: local, Hosts: hosts,
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Mar 26 15:00:38 GMT 2024 - 2K bytes - Viewed (0)