- Sort Score
- Result 10 results
- Languages All
Results 461 - 470 of 859 for err (0.02 sec)
-
cmd/config-migrate.go
} if osIsNotExist(err) || osIsPermission(err) || len(data) == 0 { data, err = readConfig(GlobalContext, objAPI, configFile) if err != nil { // when config.json is not found, then we freshly initialize. if errors.Is(err, errConfigNotFound) { return newServerCfg() } return nil, err } data, err = decryptData(data, configFile) if err != nil { return nil, err }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.4K bytes - Viewed (0) -
cmd/metacache-entries.go
xl, err := best.xlmeta() if err == nil { versions = append(versions, xl.versions) } for _, idx := range toMerge { other := top[idx] if other == nil { continue } xl2, err := other.xlmeta() if err != nil { if err := selectFrom(idx); err != nil { return err } continue } if xl == nil {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Aug 08 15:29:58 UTC 2024 - 24.1K bytes - Viewed (0) -
internal/hash/reader.go
err := ChecksumMismatch{ Want: r.contentHash.Encoded, Got: base64.StdEncoding.EncodeToString(sum), } return n, err } } } if err != nil && err != io.EOF { if v, ok := err.(etag.VerifyError); ok { return n, BadDigest{ ExpectedMD5: v.Expected.String(), CalculatedMD5: v.Computed.String(), } } } return n, err }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Sep 19 12:59:07 UTC 2024 - 10.9K bytes - Viewed (0) -
cmd/bucket-versioning.go
vc, err := sys.Get(bucket) if err != nil { logger.CriticalIf(GlobalContext, err) } return vc.PrefixEnabled(prefix) } // Suspended suspended versioning? func (sys *BucketVersioningSys) Suspended(bucket string) bool { vc, err := sys.Get(bucket) if err != nil { logger.CriticalIf(GlobalContext, err) } return vc.Suspended() }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Oct 25 00:44:15 UTC 2022 - 2.6K bytes - Viewed (0) -
internal/s3select/progress.go
switch compType { case noneType: r = scannedReader case gzipType: gzr, err := gzip.NewReader(scannedReader) if err != nil { if errors.Is(err, gzip.ErrHeader) || errors.Is(err, gzip.ErrChecksum) { return nil, errInvalidCompression(err, compType) } return nil, errTruncatedInput(err) } r = gzr pr.closer = gzr case bzip2Type:
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Sep 22 00:33:43 UTC 2024 - 4.3K bytes - Viewed (0) -
cmd/config-encrypted_test.go
cred2 := auth.Credentials{ AccessKey: "minio", SecretKey: "minio1234", } data := []byte(`config data`) edata1, err := madmin.EncryptData(cred1.String(), data) if err != nil { t.Fatal(err) } edata2, err := madmin.EncryptData(cred2.String(), data) if err != nil { t.Fatal(err) } tests := []struct { edata []byte cred auth.Credentials success bool }{ {edata1, cred1, true},
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Jun 20 00:53:08 UTC 2023 - 1.9K bytes - Viewed (0) -
internal/grid/debug.go
continue } if err := manager.Connection(remote).WaitForConnect(ctx); err != nil { panic(err) } } } } func getHosts(n int) (hosts []string, listeners []net.Listener, err error) { for i := 0; i < n; i++ { l, err := net.Listen("tcp", "127.0.0.1:0") if err != nil { if l, err = net.Listen("tcp6", "[::1]:0"); err != nil {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 4.4K bytes - Viewed (0) -
cmd/mrf.go
mw := msgp.NewWriter(w) n, err := mw.Write(data[:]) if err != nil { w.CloseWithError(err) return } if n != len(data) { w.CloseWithError(io.ErrShortWrite) return } for item := range m.opCh { err = item.EncodeMsg(mw) if err != nil { break } } mw.Flush() w.CloseWithError(err) }() return r }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Aug 13 22:26:05 UTC 2024 - 6.5K bytes - Viewed (0) -
cmd/bucket-policy.go
policy, _, err := globalBucketMetadataSys.GetPolicyConfig(bucket) return policy, err } // IsAllowed - checks given policy args is allowed to continue the Rest API. func (sys *PolicySys) IsAllowed(args policy.BucketPolicyArgs) bool { p, err := sys.Get(args.BucketName) if err == nil { return p.IsAllowed(args) } // Log unhandled errors. if _, ok := err.(BucketPolicyNotFound); !ok {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 8K bytes - Viewed (0) -
internal/s3select/csv/errors.go
statusCode int cause error } func (err *s3Error) Cause() error { return err.cause } func (err *s3Error) ErrorCode() string { return err.code } func (err *s3Error) ErrorMessage() string { return err.message } func (err *s3Error) HTTPStatusCode() int { return err.statusCode } func (err *s3Error) Error() string { return err.message }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Jun 01 21:59:40 UTC 2021 - 1.6K bytes - Viewed (0)