Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 304 for dead (0.17 sec)

  1. internal/s3select/json/reader_test.go

    			f, err := os.Open(filepath.Join("testdata", file.Name()))
    			if err != nil {
    				t.Fatal(err)
    			}
    			r := NewReader(f, &ReaderArgs{})
    			var record sql.Record
    			for {
    				record, err = r.Read(record)
    				if err != nil {
    					break
    				}
    			}
    			r.Close()
    			if err != io.EOF {
    				t.Fatalf("Reading failed with %s, %s", err, file.Name())
    			}
    		})
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 2.5K bytes
    - Viewed (0)
  2. cmd/encryption-v1_test.go

    			t.Fatalf("Impossible read specified: %d %d %d", skipLen, readLen, oSize)
    		}
    
    		var cumulativeSum, cumulativeEncSum int64
    		toRead := readLen
    		readStart := false
    		for i, v := range s {
    			partOffset := int64(0)
    			partDarePkgOffset := int64(0)
    			if !readStart && cumulativeSum+v > skipLen {
    				// Read starts at the current part
    				readStart = true
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Sep 24 04:17:08 GMT 2022
    - 19.9K bytes
    - Viewed (0)
  3. cmd/xl-storage-disk-id-check.go

    type diskHealthWrapper struct {
    	tracker *healthDiskCtxValue
    	r       io.Reader
    	w       io.Writer
    }
    
    func (d *diskHealthWrapper) Read(p []byte) (int, error) {
    	if d.r == nil {
    		return 0, fmt.Errorf("diskHealthWrapper: Read with no reader")
    	}
    	n, err := d.r.Read(p)
    	if err == nil || err == io.EOF && n > 0 {
    		d.tracker.logSuccess()
    	}
    	return n, err
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  4. internal/s3select/select.go

    	}
    	return rsc.offset, nil
    }
    
    // Read call to implement io.Reader
    func (rsc *ObjectReadSeekCloser) Read(p []byte) (n int, err error) {
    	if rsc.reader == nil {
    		rsc.reader, err = rsc.segmentReader(rsc.offset)
    		if err != nil {
    			return 0, err
    		}
    	}
    	return rsc.reader.Read(p)
    }
    
    // Close call to implement io.Closer. Calling Read/Seek after Close reopens the
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Nov 06 22:26:08 GMT 2023
    - 21K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool.go

    	derrs := make([]error, len(poolIndices))
    	dobjects := make([]ObjectInfo, len(poolIndices))
    
    	// Delete concurrently in all server pools that reported no error or read quorum error
    	// where the read quorum issue is from metadata inconsistency.
    	var wg sync.WaitGroup
    	for idx, pe := range poolIndices {
    		if v, ok := pe.Err.(InsufficientReadQuorum); ok && v.Type != RQInconsistentMeta {
    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)
  6. cmd/erasure-common.go

    	}
    
    	ignoredErrs := []error{
    		errFileNotFound,
    		errVolumeNotFound,
    		errFileVersionNotFound,
    		io.ErrUnexpectedEOF, // some times we would read without locks, ignore these errors
    		io.EOF,              // some times we would read without locks, ignore these errors
    		context.DeadlineExceeded,
    		context.Canceled,
    	}
    	ignoredErrs = append(ignoredErrs, objectOpIgnoredErrs...)
    
    	errs := g.Wait()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  7. cmd/server_test.go

    	c.Assert(response.StatusCode, http.StatusNoContent)
    }
    
    // TestNonExistentBucket - Asserts response for HEAD on non-existent bucket.
    func (s *TestSuiteCommon) TestNonExistentBucket(c *check) {
    	// generate a random bucket name.
    	bucketName := getRandomBucketName()
    	// create request to HEAD on the bucket.
    	// HEAD on an bucket helps validate the existence of the bucket.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 108K bytes
    - Viewed (0)
  8. cmd/erasure-object.go

    		ctx = lkctx.Context()
    
    		// Release lock when the metadata is verified, and reader
    		// is ready to be read.
    		//
    		// This is possible to be lock free because
    		// - xl.meta for inlined objects has already read the data
    		//   into memory, any mutation on xl.meta subsequently is
    		//   inconsequential to the overall read operation.
    		// - xl.meta metadata is still verified for quorum under lock()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  9. internal/hash/checksum.go

    	h.Write(data)
    	raw := h.Sum(nil)
    	c := Checksum{Type: t, Encoded: base64.StdEncoding.EncodeToString(raw), Raw: raw}
    	if !c.Valid() {
    		return nil
    	}
    	return &c
    }
    
    // ReadCheckSums will read checksums from b and return them.
    func ReadCheckSums(b []byte, part int) map[string]string {
    	res := make(map[string]string, 1)
    	for len(b) > 0 {
    		t, n := binary.Uvarint(b)
    		if n < 0 {
    			break
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 11.9K bytes
    - Viewed (0)
  10. docs/config/README.md

    ### Certificate Directory
    
    TLS certificates by default are expected to be stored under ``${HOME}/.minio/certs`` directory. You need to place certificates here to enable `HTTPS` based access. Read more about [How to secure access to MinIO server with TLS](https://min.io/docs/minio/linux/operations/network-encryption.html).
    
    Following is a sample directory structure for MinIO server with TLS certificates.
    
    ```sh
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 11 21:48:54 GMT 2023
    - 17.7K bytes
    - Viewed (0)
Back to top