- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 28 for fn (0.68 sec)
-
cmd/os_unix.go
return consumed, nil, typ, err } return consumed, nameBuf[:nameLen], typ, nil } // readDirFn applies the fn() function on each entries at dirPath, doesn't recurse into // the directory itself, if the dirPath doesn't exist this function doesn't return // an error. func readDirFn(dirPath string, fn func(name string, typ os.FileMode) error) error { fd, err := openFileWithFD(dirPath, readMode, 0o666) if err != nil {
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) -
cmd/erasure-server-pool-decom.go
return errInvalidArgument } z.poolMetaMutex.Lock() defer z.poolMetaMutex.Unlock() fn := z.decommissionCancelers[idx] if fn == nil { // canceling a decommission before it started return an error. return errDecommissionNotStarted } defer fn() // cancel any active thread. if z.poolMeta.DecommissionCancel(idx) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
internal/grid/benchmark_test.go
tests := []struct { name string fn func(b *testing.B, n int) }{ {name: "request", fn: benchmarkGridStreamReqOnly}, {name: "responses", fn: benchmarkGridStreamRespOnly}, } for _, test := range tests { b.Run(test.name, func(b *testing.B) { for n := 2; n <= 32; n *= 2 { b.Run("servers="+strconv.Itoa(n), func(b *testing.B) { test.fn(b, n) }) } }) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 12.2K bytes - Viewed (0) -
cmd/object-api-utils.go
if err != nil { return nil, 0, 0, err } fn = func(inputReader io.Reader, _ http.Header, cFns ...func()) (r *GetObjectReader, err error) { r = &GetObjectReader{ ObjInfo: oi, Reader: inputReader, cleanUpFns: cFns, } return r, nil } } return fn, off, length, nil } // Close - calls the cleanup actions in reverse order
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 11 11:55:34 GMT 2024 - 35.6K bytes - Viewed (1) -
cmd/testdata/undeleteable-object.tgz
§EcBSizeÒ §EcIndex ¦EcDistœ ¨CSumAlgo ¨PartNums‘ ©PartETagsÀ©PartSizes‘Ñ !ªPartASizes‘Ñ !¤SizeÑ !¥MTimeÓ É ŸBÏÀ§MetaSys ¼x-minio-internal-inline-dataÄ true§MetaUsr‚¤etagÙ 83a7a4f493d028750df8¬content-type°application/json¡v Î:f ú ¤nullÄÑ—sSGN4ÇÑç>J fN v ªïìŸCÆx Â|è±é´ {"lastUpdate":"2024-04-25T20:31:49.258248Z","objectsCount":0,"versionsCount":0,"deleteMarkersCount":0,"objectsTotalSize":0,"objectsReplicationIn":null,"bucketsCount":1,"bucket multisitea/data/disterasure/xl6/.minio.sys/buckets/buck...
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 00:31:12 GMT 2024 - 8.7M bytes - Viewed (0) -
docs/debugging/inspect/export.go
func decodeVersions(buf []byte, versions int, fn func(idx int, hdr, meta []byte) error) (e error) { var tHdr, tMeta []byte // Zero copy bytes for i := 0; i < versions; i++ { tHdr, buf, e = msgp.ReadBytesZC(buf) if e != nil { return e } tMeta, buf, e = msgp.ReadBytesZC(buf) if e != nil { return e } if e = fn(i, tHdr, tMeta); e != nil { return e } } return nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 08 15:58:02 GMT 2022 - 9.1K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
tgtClient, err := globalTierConfigMgr.getDriver(ctx, oi.TransitionedObject.Tier) if err != nil { return nil, fmt.Errorf("transition storage class not configured: %w", err) } fn, off, length, err := NewGetObjectReader(rs, oi, opts) if err != nil { return nil, ErrorRespToObjectError(err, bucket, object) } gopts := WarmBackendGetOpts{} // get correct offsets for object
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/bucket-replication.go
tgt, oi, proxy := proxyHeadToRepTarget(ctx, bucket, object, rs, opts, proxyTargets) if !proxy.Proxy { return nil, proxy, nil } fn, _, _, err := NewGetObjectReader(nil, oi, opts) if err != nil { return nil, proxy, err } gopts := minio.GetObjectOptions{ VersionID: opts.VersionID,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
internal/s3select/progress.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Oct 18 15:44:36 GMT 2021 - 4.2K bytes - Viewed (0) -
cmd/utils.go
switch madmin.ProfilerType(profilerType) { case madmin.ProfilerCPU: dirPath, err := os.MkdirTemp("", "profile") if err != nil { return nil, err } fn := filepath.Join(dirPath, "cpu.out") f, err := Create(fn) if err != nil { return nil, err } err = pprof.StartCPUProfile(f) if err != nil { return nil, err } prof.stopFn = func() ([]byte, error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 31.4K bytes - Viewed (0)