- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 155 for fails (0.15 sec)
-
cmd/object-api-listobjects_test.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 11:07:40 GMT 2024 - 73.1K bytes - Viewed (0) -
cmd/format-erasure.go
return formatData, formatFi, nil } return nil, nil, fmt.Errorf(`Disk %s: unknown format version %s`, export, version) } // Migrates version V1 of format.json to version V2 of format.json, // migration fails upon any error. func formatErasureMigrateV1ToV2(data []byte, version string) ([]byte, error) { if version != formatErasureVersionV1 {
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/object-api-utils.go
gotIdx = <-indexCh return gotIdx } } // compressSelfTest performs a self-test to ensure that compression // algorithms completes a roundtrip. If any algorithm // produces an incorrect checksum it fails with a hard error. // // compressSelfTest tries to catch any issue in the compression implementation // early instead of silently corrupting data. func compressSelfTest() { // 4 MB block.
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) -
internal/s3select/sql/value.go
case "t", "true", "1": val = true case "f", "false", "0": val = false default: ok = false } return val, ok } // bytesToString - never fails, but returns empty string if value is not bytes. func (v Value) bytesToString() string { bytes, _ := v.ToBytes() return string(bytes) } // Calculates minimum or maximum of v and a and assigns the result to
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 25 20:31:19 GMT 2022 - 20.2K bytes - Viewed (0) -
internal/event/target/mysql_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package target import ( "database/sql" "testing" ) // TestPostgreSQLRegistration checks if sql driver // is registered and fails otherwise. func TestMySQLRegistration(t *testing.T) { var found bool for _, drv := range sql.Drivers() { if drv == "mysql" { found = true break } } if !found {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue May 02 14:53:13 GMT 2023 - 1.1K bytes - Viewed (0) -
cmd/encryption-v1.go
ctx := logger.SetReqInfo(GlobalContext, reqInfo) logger.CriticalIf(ctx, err) } return int64(size) } // DecryptObjectInfo tries to decrypt the provided object if it is encrypted. // It fails if the object is encrypted and the HTTP headers don't contain // SSE-C headers or the object is not encrypted but SSE-C headers are provided. (AWS behavior) // DecryptObjectInfo returns 'ErrNone' if the object is not encrypted or the
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 36.5K bytes - Viewed (0) -
cmd/common-main.go
if err != nil { logger.Fatal(err, "Unable to initialize a connection to KES as specified by the shell environment") } // Try to generate a data encryption key. Only try to create key if this fails. // This implicitly checks that we can communicate to KES. // We don't treat a policy error as failure condition since MinIO may not have the permission // to create keys - just to generate/decrypt data encryption keys.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 04 00:17:57 GMT 2024 - 35.8K bytes - Viewed (2) -
internal/event/target/postgresql_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package target import ( "database/sql" "testing" ) // TestPostgreSQLRegistration checks if postgres driver // is registered and fails otherwise. func TestPostgreSQLRegistration(t *testing.T) { var found bool for _, drv := range sql.Drivers() { if drv == "postgres" { found = true break } } if !found {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:51:07 GMT 2024 - 1.7K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
if ok { globalNotificationSys.ReloadPoolMeta(ctx) } z.poolMetaMutex.Unlock() } wk.Take() go func(setIdx int) { defer wk.Give() // We will perpetually retry listing if it fails, since we cannot // possibly give up in this matter for { if contextCanceled(ctx) { break } err := set.listObjectsToDecommission(ctx, bi, func(entry metaCacheEntry) {
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) -
cmd/object-handlers.go
writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL) return } if crypto.S3.IsRequested(r.Header) || crypto.S3KMS.IsRequested(r.Header) { // If SSE-S3 or SSE-KMS present -> AWS fails with undefined error writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrBadRequest), r.URL) return } vars := mux.Vars(r) bucket := vars["bucket"] object, err := unescapePath(vars["object"])
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0)