Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for buf (0.14 sec)

  1. cmd/xl-storage.go

    	stat, err := f.Stat()
    	if err != nil {
    		buf, err = io.ReadAll(f)
    		return buf, dmTime, osErrToFileErr(err)
    	}
    	if stat.IsDir() {
    		return nil, dmTime, errFileNotFound
    	}
    
    	// Read into appropriate buffer.
    	sz := stat.Size()
    	if sz <= metaDataReadDefault {
    		buf = metaDataPoolGet()
    		buf = buf[:sz]
    	} else {
    		buf = make([]byte, sz)
    	}
    
    	// Read file...
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  2. cmd/storage-rest-server.go

    	}
    	buf := make([]byte, length)
    	defer metaDataPoolPut(buf) // Reuse if we can.
    	_, err = s.getStorage().ReadFile(r.Context(), volume, filePath, int64(offset), buf, verifier)
    	if err != nil {
    		s.writeErrorResponse(w, err)
    		return
    	}
    	w.Header().Set(xhttp.ContentLength, strconv.Itoa(len(buf)))
    	w.Write(buf)
    }
    
    // ReadFileStreamHandler - read section of a file.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 44.8K bytes
    - Viewed (0)
  3. cmd/storage-rest-client.go

    }
    
    // AppendFile - append to a file.
    func (client *storageRESTClient) AppendFile(ctx context.Context, volume string, path string, buf []byte) error {
    	values := make(url.Values)
    	values.Set(storageRESTVolume, volume)
    	values.Set(storageRESTFilePath, path)
    	reader := bytes.NewReader(buf)
    	respBody, err := client.call(ctx, storageRESTMethodAppendFile, values, reader, -1)
    	defer xhttp.DrainBody(respBody)
    	return err
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  4. cmd/xl-storage-disk-id-check.go

    		return p.storage.ReadFile(ctx, volume, path, offset, buf, verifier)
    	})
    }
    
    // Legacy API - does not have any deadlines
    func (p *xlStorageDiskIDCheck) AppendFile(ctx context.Context, volume string, path string, buf []byte) (err error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricAppendFile, volume, path)
    	if err != nil {
    		return err
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  5. cmd/erasure-object.go

    	// Read `xl.meta` in parallel across disks.
    	for index := range rawFileInfos {
    		rf := rawFileInfos[index]
    		if rf.Buf == nil {
    			continue
    		}
    		if !readData {
    			// Save the buffer so we can reuse it.
    			v2bufs[index] = rf.Buf
    		}
    
    		var xl xlMetaV2
    		if err := xl.LoadOrConvert(rf.Buf); err != nil {
    			errs[index] = err
    			continue
    		}
    		metadataArray[index] = &xl
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 76.9K bytes
    - Viewed (2)
  6. cmd/erasure-multipart.go

    	for i, file := range req.Files {
    		file := file
    		partN := i + start
    		i := i
    
    		g.Go(func() error {
    			buf, err := disk.ReadAll(ctx, minioMetaMultipartBucket, pathJoin(partPath, file))
    			if err != nil {
    				return err
    			}
    
    			var pfi FileInfo
    			_, err = pfi.UnmarshalMsg(buf)
    			if err != nil {
    				return err
    			}
    
    			if len(pfi.Parts) != 1 {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
  7. cmd/object-handlers_test.go

    	}
    
    	var buf bytes.Buffer
    	r, err := obj.GetObjectNInfo(context.Background(), bucketName, testObject, nil, nil, ObjectOptions{})
    	if err != nil {
    		t.Fatalf("Test: %s reading completed file failed: <ERROR> %v", instanceType, err)
    	}
    	if _, err = io.Copy(&buf, r); err != nil {
    		r.Close()
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 160K bytes
    - Viewed (0)
Back to top