Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 161 - 170 of 211 for Buf (0.01 seconds)

  1. cmd/handler-api.go

    	cgroupV2MemLimitFile = "/sys/fs/cgroup/memory.max"
    )
    
    func cgroupMemLimit() (limit uint64) {
    	buf, err := os.ReadFile(cgroupV2MemLimitFile)
    	if err != nil {
    		buf, err = os.ReadFile(cgroupV1MemLimitFile)
    	}
    	if err != nil {
    		return 0
    	}
    	limit, err = strconv.ParseUint(strings.TrimSpace(string(buf)), 10, 64)
    	if err != nil {
    		// The kernel can return valid but non integer values
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 10.4K bytes
    - Click Count (0)
  2. cmd/data-scanner.go

    	// Load current bloom cycle
    	var cycleInfo currentScannerCycle
    
    	buf, _ := readConfig(ctx, objAPI, dataUsageBloomNamePath)
    	if len(buf) == 8 {
    		cycleInfo.next = binary.LittleEndian.Uint64(buf)
    	} else if len(buf) > 8 {
    		cycleInfo.next = binary.LittleEndian.Uint64(buf[:8])
    		buf = buf[8:]
    		_, err := cycleInfo.UnmarshalMsg(buf)
    		bugLogIf(ctx, err)
    	}
    
    	scannerTimer := time.NewTimer(scannerCycle.Load())
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 45.5K bytes
    - Click Count (0)
  3. 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
    	}
    	defer done(int64(len(buf)), &err)
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Apr 25 05:41:04 GMT 2025
    - 34.5K bytes
    - Click Count (0)
  4. cmd/storage-datatypes_gen.go

    			if dc.IsNil() {
    				err = dc.ReadNil()
    				if err != nil {
    					err = msgp.WrapError(err, "Buf")
    					return
    				}
    				z.Buf = nil
    			} else {
    				z.Buf, err = dc.ReadBytes(z.Buf)
    				if err != nil {
    					err = msgp.WrapError(err, "Buf")
    					return
    				}
    				if z.Buf == nil {
    					z.Buf = make([]byte, 0)
    				}
    			}
    		default:
    			err = dc.Skip()
    			if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 151.7K bytes
    - Click Count (0)
  5. cmd/streaming-signature-v4_test.go

    		}
    	}
    }
    
    // Test parsing s3 chunk extension.
    func TestParseS3ChunkExtension(t *testing.T) {
    	type testCase struct {
    		buf       []byte
    		chunkSize []byte
    		chunkSign []byte
    	}
    
    	tests := []testCase{
    		// Test - 1 valid case.
    		{
    			[]byte("10000;chunk-signature=ad80c730a21e5b8d04586a2213dd63b9a0e99e0e2307b0ade35a65485a288648"),
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  6. src/archive/zip/reader_test.go

    		"../foo",
    		"/foo",
    		"a/b/../../../c",
    		`a\b`,
    	} {
    		var buf bytes.Buffer
    		zw := NewWriter(&buf)
    		_, err := zw.Create(path)
    		if err != nil {
    			t.Errorf("zw.Create(%q) = %v", path, err)
    			continue
    		}
    		zw.Close()
    
    		zr, err := NewReader(bytes.NewReader(buf.Bytes()), int64(buf.Len()))
    		if err != ErrInsecurePath {
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Oct 17 20:10:27 GMT 2025
    - 56.5K bytes
    - Click Count (0)
  7. cmd/xl-storage_test.go

    				if err == io.ErrUnexpectedEOF {
    					if !bytes.Equal(testCase.expectedBuf, buf[:n]) {
    						t.Errorf("Case: %d %#v, expected: \"%s\", got: \"%s\"", i+1, testCase, string(testCase.expectedBuf), string(buf[:n]))
    					}
    					if n > int64(len(buf)) {
    						t.Errorf("Case: %d %#v, expected: %d, got: %d", i+1, testCase, testCase.bufSize, n)
    					}
    				}
    			}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 66K bytes
    - Click Count (0)
  8. cmd/storage-datatypes.go

    type RenameDataInlineHandlerParams struct {
    	RenameDataHandlerParams `msg:"p"`
    }
    
    func newRenameDataInlineHandlerParams() *RenameDataInlineHandlerParams {
    	buf := grid.GetByteBufferCap(32 + 16<<10)
    	return &RenameDataInlineHandlerParams{RenameDataHandlerParams{FI: FileInfo{Data: buf[:0]}}}
    }
    
    // Recycle will reuse the memory allocated for the FileInfo data.
    func (r *RenameDataInlineHandlerParams) Recycle() {
    	if r == nil {
    		return
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 17.4K bytes
    - Click Count (0)
  9. cmd/post-policy_test.go

    		"key":       objectName + "/${filename}",
    		"policy":    encodedPolicy,
    		"signature": signature,
    	}
    
    	maps.Copy(formData, formInputData)
    
    	// Create the multipart form.
    	var buf bytes.Buffer
    	w := multipart.NewWriter(&buf)
    
    	// Set the normal formData
    	for k, v := range formData {
    		w.WriteField(k, v)
    	}
    	// Set the File formData
    	writer, err := w.CreateFormFile("file", "upload.txt")
    	if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 30.6K bytes
    - Click Count (0)
  10. cmd/common-main.go

    	if ctxt.ConsoleAddr == "" {
    		ctxt.ConsoleAddr = ctx.String("console-address")
    	}
    
    	if cxml := ctx.String("crossdomain-xml"); cxml != "" {
    		buf, err := os.ReadFile(cxml)
    		if err != nil {
    			return err
    		}
    		ctxt.CrossDomainXML = string(buf)
    	}
    
    	// Check "no-compat" flag from command line argument.
    	ctxt.StrictS3Compat = !ctx.IsSet("no-compat") && !ctx.GlobalIsSet("no-compat")
    
    	switch {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 32.5K bytes
    - Click Count (3)
Back to Top