Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 1,125 for buffers (0.04 sec)

  1. cmd/metacache-entries.go

    	}
    	return res
    }
    
    // metaCacheEntriesSorted contains metacache entries that are sorted.
    type metaCacheEntriesSorted struct {
    	o metaCacheEntries
    	// list id is not serialized
    	listID string
    	// Reuse buffers
    	reuse bool
    	// Contain the last skipped object after an ILM expiry evaluation
    	lastSkippedEntry string
    }
    
    // shallowClone will create a shallow clone of the array objects,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 24.1K bytes
    - Viewed (0)
  2. cmd/object-handlers_test.go

    	}{
    		{byteData: generateBytesData(6 * humanize.KiByte)},
    	}
    	h := md5.New()
    	h.Write(bytesData[0].byteData)
    	bytesData[0].md5sum = hex.EncodeToString(h.Sum(nil))
    
    	buffers := []*bytes.Buffer{
    		new(bytes.Buffer),
    		new(bytes.Buffer),
    	}
    	bucketInfo, err := obj.GetBucketInfo(context.Background(), bucketName, BucketOptions{})
    	if err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 163.1K bytes
    - Viewed (0)
  3. cmd/erasure-multipart.go

    		} else {
    			buffer = globalBytePoolCap.Load().Get()
    			defer globalBytePoolCap.Load().Put(buffer)
    		}
    	case size < fi.Erasure.BlockSize:
    		// No need to allocate fully fi.Erasure.BlockSize buffer if the incoming data is smaller.
    		buffer = make([]byte, size, 2*size+int64(fi.Erasure.ParityBlocks+fi.Erasure.DataBlocks-1))
    	}
    
    	if len(buffer) > int(fi.Erasure.BlockSize) {
    		buffer = buffer[:fi.Erasure.BlockSize]
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 47.1K bytes
    - Viewed (0)
  4. cmd/server-main.go

    		EnvVar: "MINIO_READ_HEADER_TIMEOUT",
    		Hidden: true,
    	},
    	cli.DurationFlag{
    		Name:   "conn-user-timeout",
    		Usage:  "custom TCP_USER_TIMEOUT for socket buffers",
    		Hidden: true,
    		Value:  10 * time.Minute,
    		EnvVar: "MINIO_CONN_USER_TIMEOUT",
    	},
    	cli.StringFlag{
    		Name:   "interface",
    		Usage:  "bind to right VRF device for MinIO services",
    		Hidden: true,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:18:36 UTC 2025
    - 35.9K bytes
    - Viewed (4)
  5. cmd/object-api-utils.go

    	// DNS separator (period), used for bucket name validation.
    	dnsDelimiter = "."
    	// On compressed files bigger than this;
    	compReadAheadSize = 100 << 20
    	// Read this many buffers ahead.
    	compReadAheadBuffers = 5
    	// Size of each buffer.
    	compReadAheadBufSize = 1 << 20
    	// Pad Encrypted+Compressed files to a multiple of this.
    	compPadEncrypted = 256
    	// Disable compressed file indices below this size
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Jun 25 15:08:54 UTC 2025
    - 37.3K bytes
    - Viewed (0)
  6. CHANGELOG/CHANGELOG-1.2.md

    kube-apiserver (instead of --etcd-config):
         * --etcd-certfile, --etcd-keyfile (if using client cert auth)
         * --etcd-cafile (if not using system roots)
      * As part of preparation in 1.2 for adding support for protocol buffers (and the
    direct YAML support in the API available today), the Content-Type and Accept
    headers are now properly handled as per the HTTP spec.  As a consequence, if
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Fri Dec 04 06:36:19 UTC 2020
    - 41.4K bytes
    - Viewed (0)
  7. cmd/erasure-object.go

    		buffer = make([]byte, size, 2*size+int64(fi.Erasure.ParityBlocks+fi.Erasure.DataBlocks-1))
    	}
    
    	if len(buffer) > int(fi.Erasure.BlockSize) {
    		buffer = buffer[:fi.Erasure.BlockSize]
    	}
    
    	writers := make([]io.Writer, len(onlineDisks))
    	inlineBuffers := make([]*bytes.Buffer, len(onlineDisks))
    	for i, disk := range onlineDisks {
    		if disk == nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb1/dcerpc/rpc.java

                    final int _bufferl = length / 2;
                    final int _buffers = maximum_length / 2;
                    _dst.enc_ndr_long(_buffers);
                    _dst.enc_ndr_long(0);
                    _dst.enc_ndr_long(_bufferl);
                    final int _bufferi = _dst.index;
                    _dst.advance(2 * _bufferl);
    
                    _dst = _dst.derive(_bufferi);
                    for (int _i = 0; _i < _bufferl; _i++) {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 11.2K bytes
    - Viewed (0)
  9. src/test/java/jcifs/internal/fscc/FileInternalInfoTest.java

            fileInternalInfo.decode(buffer2, 0, buffer2.length);
            assertEquals(indexNumber2, fileInternalInfo.getIndexNumber());
    
            // Third decode - should overwrite again
            byte[] buffer3 = new byte[8];
            long indexNumber3 = 0x3333333333333333L;
            SMBUtil.writeInt8(indexNumber3, buffer3, 0);
            fileInternalInfo.decode(buffer3, 0, buffer3.length);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 13.1K bytes
    - Viewed (0)
  10. src/test/java/jcifs/internal/fscc/FsctlPipeWaitRequestTest.java

            // Encode multiple times
            byte[] buffer1 = new byte[100];
            byte[] buffer2 = new byte[100];
            byte[] buffer3 = new byte[100];
    
            int encoded1 = request.encode(buffer1, 0);
            int encoded2 = request.encode(buffer2, 0);
            int encoded3 = request.encode(buffer3, 0);
    
            // All should produce same result
            assertEquals(encoded1, encoded2);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 13.1K bytes
    - Viewed (0)
Back to top