- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 82 for perc (0.14 sec)
-
cmd/os_unix.go
func openFileWithFD(name string, flag int, perm os.FileMode) (fd int, err error) { switch flag & writeMode { case writeMode: defer updateOSMetrics(osMetricOpenFileWFd, name)(err) default: defer updateOSMetrics(osMetricOpenFileRFd, name)(err) } var e error fd, e = syscall.Open(name, flag|syscall.O_CLOEXEC, uint32(perm)) if e != nil { return -1, &os.PathError{Op: "open", Path: name, Err: e} }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.3K bytes - Viewed (0) -
internal/event/targetlist.go
statLock sync.RWMutex targetStats map[TargetID]targetStat } type targetStat struct { // The number of concurrent async Send calls per targets currentSendCalls int64 // The number of total events per target totalEvents int64 // The number of failed events per target failedEvents int64 } func (list *TargetList) getStatsByTargetID(id TargetID) (stat targetStat) { list.statLock.RLock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.2K bytes - Viewed (0) -
internal/logger/help.go
Description: "mTLS certificate key for webhook authentication", Optional: true, Type: "string", Sensitive: true, }, config.HelpKV{ Key: BatchSize, Description: "Number of events per HTTP send to webhook target", Optional: true, Type: "number", }, config.HelpKV{ Key: QueueSize, Description: "configure channel queue size for webhook targets", Optional: true,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 07 20:17:46 GMT 2024 - 6.4K bytes - Viewed (0) -
cmd/os-instrumented.go
} // OpenFile captures time taken to call os.OpenFile func OpenFile(name string, flag int, perm os.FileMode) (f *os.File, err error) { switch flag & writeMode { case writeMode: defer updateOSMetrics(osMetricOpenFileW, name)(err) default: defer updateOSMetrics(osMetricOpenFileR, name)(err) } return os.OpenFile(name, flag, perm) } // Access captures time taken to call syscall.Access()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 15 01:09:38 GMT 2024 - 6.3K bytes - Viewed (0) -
cmd/erasure-common.go
) func (er erasureObjects) getOnlineDisks() (newDisks []StorageAPI) { disks := er.getDisks() var wg sync.WaitGroup var mu sync.Mutex r := rand.New(rand.NewSource(time.Now().UnixNano())) for _, i := range r.Perm(len(disks)) { i := i wg.Add(1) go func() { defer wg.Done() if disks[i] == nil { return } di, err := disks[i].DiskInfo(context.Background(), DiskInfoOptions{})
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 4.6K bytes - Viewed (0) -
cmd/metacache-server-pool.go
// Context is canceled, return at once. // request canceled, no entries to return return entries, io.EOF } if !errors.Is(err, context.DeadlineExceeded) { // Report error once per bucket, but continue listing. storageLogOnceIf(ctx, err, "GetMetacacheListing:"+o.Bucket) } o.Transient = true o.Create = false o.ID = mustGetUUID() } else { if c.fileNotFound {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.8K bytes - Viewed (0) -
cmd/format-erasure.go
// Sets field carries the input disk order generated the first // time when fresh disks were supplied, it is a two dimensional // array second dimension represents list of disks used per set. Sets [][]string `json:"sets"` // Distribution algorithm represents the hashing algorithm // to pick the right set index for an object. DistributionAlgo string `json:"distributionAlgo"` } `json:"xl"` }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 23.2K bytes - Viewed (0) -
cmd/storage-datatypes.go
type DiskInfoOptions struct { DiskID string `msg:"id"` Metrics bool `msg:"m"` NoOp bool `msg:"np"` } // DiskInfo is an extended type which returns current // disk usage per path. // The above means that any added/deleted fields are incompatible. // // The above means that any added/deleted fields are incompatible. // //msgp:tuple DiskInfo type DiskInfo struct { Total uint64
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 15.3K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
es.stats.missedExpiryTasks.Add(1) return } select { case <-GlobalContext.Done(): case wrkr <- task: default: es.stats.missedExpiryTasks.Add(1) } } // globalExpiryState is the per-node instance which manages all ILM expiry tasks. var globalExpiryState *expiryState // newExpiryState creates an expiryState with buffered channels allocated for // each ILM expiry task type.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/globals.go
globalNetPerfMinDuration = time.Second * 10 globalNetPerfRX netPerfRX globalSiteNetPerfRX netPerfRX globalObjectPerfBucket = "minio-perf-test-tmp-bucket" globalObjectPerfUserMetadata = "X-Amz-Meta-Minio-Object-Perf" // Clients can set this to bypass S3 API service freeze. Used by object pref tests. // MinIO version unix timestamp globalVersionUnix uint64 // MinIO client
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 16.5K bytes - Viewed (0)