- Sort Score
- Result 10 results
- Languages All
Results 471 - 480 of 859 for err (0.01 sec)
-
internal/s3select/csv/reader_contrib_test.go
} z, err := zip.NewReader(bytes.NewReader(f), int64(len(f))) if err != nil { t.Fatal(err) } for _, f := range z.File { if f.Name == file { rc, err := f.Open() if err != nil { t.Fatal(err) } defer rc.Close() b, err := io.ReadAll(rc) if err != nil { t.Fatal(err) } return b } } t.Fatal(file, "not found in testdata/testdata.zip") return nil
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 38.5K bytes - Viewed (0) -
cmd/object-api-deleteobject_test.go
if err != nil { t.Log(oi) t.Fatalf("%s : %s", instanceType, err.Error()) } } oi, err := obj.DeleteObject(context.Background(), testCase.bucketName, testCase.pathToDelete, ObjectOptions{}) if err != nil && !isErrObjectNotFound(err) { t.Log(oi) t.Errorf("Test %d: %s: Expected to pass, but failed with: <ERROR> %s", i+1, instanceType, err) continue }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Aug 29 01:40:52 UTC 2024 - 4.1K bytes - Viewed (0) -
internal/config/batch/batch.go
if err != nil { return cfg, err } if rduration < 0 { return cfg, config.ErrInvalidBatchReplicationWorkersWait(nil) } kduration, err := time.ParseDuration(env.Get(EnvKeyRotationWorkersWait, kvs.GetWithDefault(KeyRotationWorkersWait, DefaultKVS))) if err != nil { return cfg, err } if kduration < 0 { return cfg, config.ErrInvalidBatchKeyRotationWorkersWait(nil) }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.7K bytes - Viewed (0) -
cmd/erasure.go
return er.setDriveCount - er.defaultParityCount } func diskErrToDriveState(err error) (state string) { switch { case errors.Is(err, errDiskNotFound) || errors.Is(err, context.DeadlineExceeded): state = madmin.DriveStateOffline case errors.Is(err, errCorruptedFormat) || errors.Is(err, errCorruptedBackend): state = madmin.DriveStateCorrupt case errors.Is(err, errUnformattedDisk): state = madmin.DriveStateUnformatted
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Oct 04 22:23:33 UTC 2024 - 16.1K bytes - Viewed (0) -
internal/bucket/replication/sourceselectioncriteria.go
func (s SourceSelectionCriteria) MarshalXML(e *xml.Encoder, start xml.StartElement) error { if err := e.EncodeToken(start); err != nil { return err } if s.IsValid() { if err := e.EncodeElement(s.ReplicaModifications, xml.StartElement{Name: xml.Name{Local: "ReplicaModifications"}}); err != nil { return err } } return e.EncodeToken(xml.EndElement{Name: start.Name})
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Jun 01 21:59:40 UTC 2021 - 2.5K bytes - Viewed (0) -
cmd/erasure-encode_test.go
for i, test := range erasureEncodeTests { setup, err := newErasureTestSetup(t, test.dataBlocks, test.onDisks-test.dataBlocks, test.blocksize) if err != nil { t.Fatalf("Test %d: failed to create test setup: %v", i, err) } disks := setup.disks erasure, err := NewErasure(context.Background(), test.dataBlocks, test.onDisks-test.dataBlocks, test.blocksize) if err != nil {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Jan 30 20:43:25 UTC 2024 - 11.9K bytes - Viewed (0) -
internal/s3select/csv/recordtransform.go
oneByte []byte useOneByte bool } func (rr *recordTransform) Read(p []byte) (n int, err error) { if rr.useOneByte { p[0] = rr.oneByte[0] rr.useOneByte = false n, err = rr.reader.Read(p[1:]) n++ } else { n, err = rr.reader.Read(p) } if err != nil { return n, err } // Do nothing if record-delimiter is already newline. if string(rr.recordDelimiter) == "\n" {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Jun 01 21:59:40 UTC 2021 - 2.1K bytes - Viewed (0) -
internal/grid/handlers.go
} if h.callReuseReq { defer h.recycleReq(req) } res, err := c.Request(ctx, h.id, payload) PutByteBuffer(payload) if err != nil { return resp, err } defer PutByteBuffer(res) r := h.NewResponse() _, err = r.UnmarshalMsg(res) if err != nil { h.PutResponse(r) return resp, err } return r, err } // RemoteClient contains information about the caller.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 27.7K bytes - Viewed (0) -
tests/connection_test.go
return } err := DB.Connection(func(tx *gorm.DB) error { if err := tx.Exec(setSQL, expectedName).Error; err != nil { return err } if err := tx.Raw(getSQL).Scan(&actualName).Error; err != nil { return err } return nil }) if err != nil { t.Errorf(fmt.Sprintf("WithSingleConnection should work, but got err %v", err)) } if actualName != expectedName {
Registered: Sun Oct 27 09:35:08 UTC 2024 - Last Modified: Fri Jan 28 14:16:42 UTC 2022 - 963 bytes - Viewed (0) -
internal/config/etcd/etcd.go
cfg := Config{} if err := config.CheckValidKeys(config.EtcdSubSys, kvs, DefaultKVS); err != nil { return cfg, err } endpoints := env.Get(EnvEtcdEndpoints, kvs.Get(Endpoints)) if endpoints == "" { return cfg, nil } etcdEndpoints, etcdSecure, err := parseEndpoints(endpoints) if err != nil { return cfg, err } cfg.Enabled = true
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Jun 28 23:17:22 UTC 2024 - 5.2K bytes - Viewed (0)