- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 68 for manny (0.22 sec)
-
internal/grid/grid_test.go
register := func(manager *Manager) { errFatal(manager.RegisterStreamingHandler(handlerTest, StreamHandler{ Handle: func(ctx context.Context, payload []byte, request <-chan []byte, resp chan<- []byte) *RemoteErr { // Send many responses. // Test that this doesn't block. for i := byte(0); i < 100; i++ { select { case resp <- []byte{i}: // ok case <-ctx.Done(): return NewRemoteErr(ctx.Err()) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
schema/relationship_test.go
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Mon Apr 15 03:20:20 GMT 2024 - 25.5K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
disks, _ := set.getOnlineDisksWithHealing(false) if len(disks) == 0 { return fmt.Errorf("no online drives found for set with endpoints %s", set.getEndpoints()) } // However many we ask, versions must exist on ~50% listingQuorum := (set.setDriveCount + 1) / 2 // How to resolve partial results. resolver := metadataResolutionParams{
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/storage-datatypes.go
MaxSize int64 // Return error if size is exceed. MetadataOnly bool // Read as XL meta and truncate data. AbortOn404 bool // Stop reading after first file not found. MaxResults int // Stop after this many successful results. <= 0 means all. } // ReadMultipleResp contains a single response from a ReadMultipleReq. type ReadMultipleResp struct { Bucket string // Bucket as given by request.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 15.3K bytes - Viewed (0) -
cmd/storage-errors.go
// errFileNotFound - cannot find requested file version. var errFileVersionNotFound = StorageErr("file version not found") // errTooManyOpenFiles - too many open files. var errTooManyOpenFiles = StorageErr("too many open files, please increase 'ulimit -n'") // errFileNameTooLong - given file name is too long than supported length. var errFileNameTooLong = StorageErr("file name too long")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.4K bytes - Viewed (0) -
cmd/data-usage_test.go
}, } createUsageTestFiles(t, base, bucket, files) err = os.RemoveAll(filepath.Join(base, bucket, "dir1/dira/dirasub/dcfile")) if err != nil { t.Fatal(err) } // Changed dir must be picked up in this many cycles. for i := 0; i < dataUsageUpdateDirCycles; i++ { got, err = scanDataFolder(context.Background(), nil, base, got, getSize, 0, weSleep) got.Info.NextCycle++ if err != nil { t.Fatal(err) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Mar 27 15:10:40 GMT 2024 - 14.1K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
disks, _ := set.getOnlineDisksWithHealing(false) if len(disks) == 0 { return fmt.Errorf("no online drives found for set with endpoints %s", set.getEndpoints()) } // However many we ask, versions must exist on ~50% listingQuorum := (set.setDriveCount + 1) / 2 // How to resolve partial results. resolver := metadataResolutionParams{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
cmd/object-api-errors.go
} // StorageFull storage ran out of space. type StorageFull struct{} func (e StorageFull) Error() string { return "Storage reached its minimum free drive threshold." } // SlowDown too many file descriptors open or backend busy . type SlowDown struct{} func (e SlowDown) Error() string { return "Please reduce your request rate" } // RQErrType reason for read quorum error. type RQErrType int
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 21.3K bytes - Viewed (0) -
src/archive/tar/writer.go
if _, tw.err = tw.w.Write(zeroBlock[:tw.pad]); tw.err != nil { return tw.err } tw.pad = 0 return nil } // WriteHeader writes hdr and prepares to accept the file's contents. // The Header.Size determines how many bytes can be written for the next file. // If the current file is not fully written, then this returns an error. // This implicitly flushes any padding necessary before writing the header.
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 19.6K bytes - Viewed (0) -
cmd/erasure-server-pool.go
serverPools.FilterMaxUsed(100 - (100 * diskReserveFraction)) total := serverPools.TotalAvailable() if total == 0 { return -1 } // choose when we reach this many choose := rand.Uint64() % total atTotal := uint64(0) for _, pool := range serverPools { atTotal += pool.Available if atTotal > choose && pool.Available > 0 { return pool.Index } }
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)