Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 106 for realCall (0.13 sec)

  1. cmd/s3-zip-handlers.go

    		rs := &HTTPRangeSpec{IsSuffixLength: true, Start: int64(-size)}
    		gr, err := objectAPI.GetObjectNInfo(ctx, bucket, object, rs, nil, opts)
    		if err != nil {
    			return nil, ObjectInfo{}, err
    		}
    		b, err := io.ReadAll(gr)
    		gr.Close()
    		if err != nil {
    			return nil, ObjectInfo{}, err
    		}
    		if size > len(b) {
    			size = len(b)
    		}
    
    		// Calculate the object real size if encrypted
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  2. cmd/bucket-policy-handlers_test.go

    			t.Fatalf("Case %d: Expected the response status to be `%d`, but instead found `%d`", i+1, testCase.expectedRespStatus, recV4.Code)
    		}
    		// read the response body.
    		bucketPolicyReadBuf, err := io.ReadAll(recV4.Body)
    		if err != nil {
    			t.Fatalf("Test %d: %s: Failed parsing response body: <ERROR> %v", i+1, instanceType, err)
    		}
    
    		if recV4.Code != testCase.expectedRespStatus {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 32.9K bytes
    - Viewed (0)
  3. cmd/admin-handlers-site-replication.go

    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    }
    
    func parseJSONBody(ctx context.Context, body io.Reader, v interface{}, encryptionKey string) error {
    	data, err := io.ReadAll(body)
    	if err != nil {
    		return SRError{
    			Cause: err,
    			Code:  ErrSiteReplicationInvalidRequest,
    		}
    	}
    	if encryptionKey != "" {
    		data, err = madmin.DecryptData(encryptionKey, bytes.NewReader(data))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  4. src/archive/tar/reader.go

    		n += nn
    	}
    	if len(b) == n && err == io.EOF {
    		err = nil
    	}
    	return n, err
    }
    
    // readSpecialFile is like io.ReadAll except it returns
    // ErrFieldTooLong if more than maxSpecialFileSize is read.
    func readSpecialFile(r io.Reader) ([]byte, error) {
    	buf, err := io.ReadAll(io.LimitReader(r, maxSpecialFileSize+1))
    	if len(buf) > maxSpecialFileSize {
    		return nil, ErrFieldTooLong
    	}
    	return buf, err
    }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Mar 08 01:59:14 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  5. src/archive/zip/reader_test.go

    		return
    	}
    	start, err := f.DataOffset()
    	if err != nil {
    		t.Errorf("%v: DataOffset error=%v", f.Name, err)
    		return
    	}
    	got, err := io.ReadAll(rw)
    	if err != nil {
    		t.Errorf("%v: OpenRaw ReadAll error=%v", f.Name, err)
    		return
    	}
    	end := uint64(start) + f.CompressedSize64
    	want := raw[start:end]
    	if !bytes.Equal(got, want) {
    		t.Logf("got %q", got)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Jul 25 00:25:45 UTC 2024
    - 55.6K bytes
    - Viewed (0)
  6. cmd/background-newdisks-heal-ops.go

    	if disk == nil {
    		return nil, errors.New("loadHealingTracker: nil drive given")
    	}
    	diskID, err := disk.GetDiskID()
    	if err != nil {
    		return nil, err
    	}
    	b, err := disk.ReadAll(ctx, minioMetaBucket,
    		pathJoin(bucketMetaPrefix, healingTrackerFilename))
    	if err != nil {
    		return nil, err
    	}
    	var h healingTracker
    	_, err = h.UnmarshalMsg(b)
    	if err != nil {
    		return nil, err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  7. docs/debugging/xl-meta/main.go

    		var baseName string
    		// versionID ->
    		combineFiles := make(map[string][]string)
    		decode := func(r io.Reader, file string) ([]byte, error) {
    			file = strings.ReplaceAll(file, ":", "_")
    			b, err := io.ReadAll(r)
    			if err != nil {
    				return nil, err
    			}
    			b, _, minor, err := checkXL2V1(b)
    			if err != nil {
    				return nil, err
    			}
    			filemap[file] = make(map[string]string)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 05 11:57:44 UTC 2024
    - 40.3K bytes
    - Viewed (0)
  8. api/go1.19.txt

    pkg go/doc, func Synopsis //deprecated #51082
    pkg go/doc, func ToHTML //deprecated #51082
    pkg go/doc, func ToText //deprecated #51082
    pkg io/ioutil, func NopCloser //deprecated #42026
    pkg io/ioutil, func ReadAll //deprecated #42026
    pkg io/ioutil, func ReadDir //deprecated #42026
    pkg io/ioutil, func ReadFile //deprecated #42026
    pkg io/ioutil, func TempDir //deprecated #42026
    pkg io/ioutil, func TempFile //deprecated #42026
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Dec 02 16:29:41 UTC 2022
    - 17.9K bytes
    - Viewed (0)
  9. cmd/metacache-stream_test.go

    	r := loadMetacacheSample(t)
    	defer r.Close()
    	var readErr error
    	objs := make(chan metaCacheEntry, 1)
    	var wg sync.WaitGroup
    	wg.Add(1)
    	go func() {
    		readErr = r.readAll(context.Background(), objs)
    		wg.Done()
    	}()
    	want := loadMetacacheSampleNames
    	i := 0
    	for entry := range objs {
    		if entry.name != want[i] {
    			t.Errorf("entry %d, want %q, got %q", i, want[i], entry.name)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 15K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt

        val zippedSize = zipped.size.toInt()
        writeMedium(frame, zippedSize)
        frame.writeByte(Http2.TYPE_DATA)
        frame.writeByte(FLAG_COMPRESSED)
        frame.writeInt(expectedStreamId and 0x7fffffff)
        zipped.readAll(frame)
        assertFailsWith<IOException> {
          reader.nextFrame(requireSettings = false, BaseTestHandler())
        }.also { expected ->
          assertThat(expected.message)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 28.1K bytes
    - Viewed (0)
Back to top