Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 68 for er (0.02 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top