- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 68 for er (0.02 sec)
-
cmd/erasure.go
func (er erasureObjects) defaultWQuorum() int { dataCount := er.setDriveCount - er.defaultParityCount if dataCount == er.defaultParityCount { return dataCount + 1 } return dataCount } // defaultRQuorum read quorum based on setDriveCount and defaultParityCount func (er erasureObjects) defaultRQuorum() int { return er.setDriveCount - er.defaultParityCount }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 22:23:33 UTC 2024 - 16.1K bytes - Viewed (0) -
cmd/erasure-multipart.go
return oi, toObjectErr(err, bucket) } return oi, toObjectErr(err, bucket, object, uploadID) } uploadIDPath := er.getUploadIDDir(bucket, object, uploadID) onlineDisks := er.getDisks() writeQuorum := fi.WriteQuorum(er.defaultWQuorum()) readQuorum := fi.ReadQuorum(er.defaultRQuorum()) // Read Part info for all parts partPath := pathJoin(uploadIDPath, fi.DataDir) + SlashSeparator
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 29 22:40:36 UTC 2024 - 44.7K bytes - Viewed (0) -
cmd/erasure-healing.go
} opts.Tags = map[string]string{ "healObject": auditObjectOp{ Name: opts.Object, Pool: er.poolIndex + 1, Set: er.setIndex + 1, }.String(), } auditLogInternal(ctx, opts) } // Heals an object by re-writing corrupt/missing erasure blocks.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Oct 02 17:50:41 UTC 2024 - 34.4K bytes - Viewed (0) -
cmd/erasure-common.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "math/rand" "sync" "time" ) func (er erasureObjects) getOnlineDisks() (newDisks []StorageAPI) { disks := er.getDisks() var wg sync.WaitGroup var mu sync.Mutex r := rand.New(rand.NewSource(time.Now().UnixNano())) for _, i := range r.Perm(len(disks)) { i := i wg.Add(1) go func() {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Aug 12 08:38:15 UTC 2024 - 2.3K bytes - Viewed (0) -
cmd/erasure-healing_test.go
z := objLayer.(*erasureServerPools) for _, set := range z.serverPools { er := set.sets[0] erasureDisks := er.getDisks() fileInfos, errs := readAllFileInfo(ctx, erasureDisks, "", bucket, object, "", false, true) nfi, err := getLatestFileInfo(ctx, fileInfos, er.defaultParityCount, errs) if errors.Is(err, errFileNotFound) { continue } if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 49K bytes - Viewed (0) -
cmd/erasure-object.go
} func (er erasureObjects) getObjectFileInfo(ctx context.Context, bucket, object string, opts ObjectOptions, readData bool) (FileInfo, []FileInfo, []StorageAPI, error) { rawArr := make([]RawFileInfo, er.setDriveCount) metaArr := make([]FileInfo, er.setDriveCount) errs := make([]error, er.setDriveCount) for i := range errs { errs[i] = errDiskOngoingReq }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 78.8K bytes - Viewed (0) -
docs/nl/docs/environment-variables.md
Hello Wade Wilson from Python // De omgevingsvariabelen bestaan daarna niet meer $ python main.py Hello World from Python ``` </div> /// tip Je kunt er meer over lezen op <a href="https://12factor.net/config" class="external-link" target="_blank">The Twelve-Factor App: Config</a>. /// ## Types en Validatie
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Fri Sep 20 11:13:32 UTC 2024 - 8.6K bytes - Viewed (0) -
cmd/global-heal.go
continue } } if serverDebugLog { console.Debugf(color.Green("healDrive:")+" healing bucket %s content on %s erasure set\n", bucket, humanize.Ordinal(er.setIndex+1)) } disks, _, healing := er.getOnlineDisksWithHealingAndInfo(true) if len(disks) == healing { // All drives in this erasure set were reformatted for some reasons, abort healing and mark it as successful
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 16.3K bytes - Viewed (0) -
internal/etag/reader.go
// Reader compares the etag with the computed // MD5 sum once the r returns io.EOF. func NewReader(ctx context.Context, r io.Reader, etag ETag, forceMD5 []byte) *Reader { if er, ok := r.(*Reader); ok { if er.readN == 0 && Equal(etag, er.checksum) { return er } } if len(forceMD5) != 0 { return &Reader{ src: r, md5: NewUUIDHash(forceMD5), checksum: etag, } } return &Reader{
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 4.8K bytes - Viewed (0) -
docs/de/docs/deployment/server-workers.md
Sie können sehen, dass: * Der Gunicorn **Prozessmanager** beginnt, mit der PID `19499` (in Ihrem Fall ist es eine andere Nummer). * Dann beginnt er zu lauschen: `Listening at: http://0.0.0.0:80`. * Dann erkennt er, dass er die Workerklasse `uvicorn.workers.UvicornWorker` verwenden muss. * Und dann werden **4 Worker** gestartet, jeder mit seiner eigenen PID: `19511`, `19513`, `19514` und `19515`.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Tue Aug 06 04:48:30 UTC 2024 - 10.1K bytes - Viewed (0)