- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 57 for Ferris (0.19 sec)
-
cmd/erasure-server-pool.go
derrs[i] = checkDelObjArgs(ctx, bucket, objects[i].ObjectName) objSets.Add(objects[i].ObjectName) } // Acquire a bulk write lock across 'objects' multiDeleteLock := z.NewNSLock(bucket, objSets.ToSlice()...) lkctx, err := multiDeleteLock.GetLock(ctx, globalOperationTimeout) if err != nil { for i := range derrs { derrs[i] = err } return dobjects, derrs } ctx = lkctx.Context()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
cmd/erasure-object.go
if err != nil { for i := range errs { if errs[i] == nil { errs[i] = err } } return metaFileInfos, errs } if !lfi.IsValid() { for i := range errs { if errs[i] == nil { errs[i] = errFileCorrupt } } return metaFileInfos, errs } versionID := lfi.VersionID if versionID == "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
internal/logger/targets.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 22:56:14 GMT 2024 - 6.1K bytes - Viewed (0) -
internal/rest/rpc-stats.go
import ( "net/http" "net/http/httptrace" "sync/atomic" "time" ) var globalStats = struct { errs uint64 tcpDialErrs uint64 tcpDialCount uint64 tcpDialTotalDur uint64 }{} // RPCStats holds information about the DHCP/TCP metrics and errors type RPCStats struct { Errs uint64 DialAvgDuration uint64 DialErrs uint64 }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Sep 29 16:27:58 GMT 2022 - 2.3K bytes - Viewed (0) -
cmd/naughty-disk_test.go
func (d *naughtyDisk) DeleteVersions(ctx context.Context, volume string, versions []FileInfoVersions, opts DeleteOptions) []error { if err := d.calcError(); err != nil { errs := make([]error, len(versions)) for i := range errs { errs[i] = err } return errs } return d.disk.DeleteVersions(ctx, volume, versions, opts) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 9.3K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
cmd/erasure-common.go
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) -
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
if err == nil { _, _ = fmt.Fprintf(c.OutOrStdout(), "%v.%v:\n%v\n", podName, podNamespace, resp) } else { errs = multierror.Append(fmt.Errorf("%v.%v: %v", podName, podNamespace, err)) } } if err := multierror.Flatten(errs.ErrorOrNil()); err != nil { return err } return nil }, ValidArgsFunction: completion.ValidPodsNameArgs(ctx), }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed May 01 13:11:40 GMT 2024 - 22.2K bytes - Viewed (0) -
internal/s3select/select.go
} // Test these compressor errors errs := []error{ gzip.ErrHeader, gzip.ErrChecksum, s2.ErrCorrupt, s2.ErrUnsupported, s2.ErrCRC, zstd.ErrBlockTooSmall, zstd.ErrMagicMismatch, zstd.ErrWindowSizeExceeded, zstd.ErrUnknownDictionary, zstd.ErrWindowSizeTooSmall, lz4.ErrInvalid, lz4.ErrBlockDependency, } for _, e := range errs { if errors.Is(err, e) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (0) -
cmd/erasure-object_test.go
parts7SC := storageclass.Config{ Standard: storageclass.StorageClass{ Parity: 5, }, } tests := []struct { parts []FileInfo errs []error expectedReadQuorum int expectedWriteQuorum int storageClassCfg storageclass.Config expectedError error }{ {parts1, errs1, 12, 12, parts1SC, nil},
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 36.8K bytes - Viewed (0)