Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 355 for mbuf (0.02 sec)

  1. src/archive/tar/reader.go

    	buf, err := readSpecialFile(r)
    	if err != nil {
    		return nil, err
    	}
    	sbuf := string(buf)
    
    	// For GNU PAX sparse format 0.0 support.
    	// This function transforms the sparse format 0.0 headers into format 0.1
    	// headers since 0.0 headers were not PAX compliant.
    	var sparseMap []string
    
    	paxHdrs := make(map[string]string)
    	for len(sbuf) > 0 {
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Mar 08 01:59:14 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/io/CharStreamsTest.java

        assertEquals(-1, empty.read());
      }
    
      public void testExhaust_readable() throws IOException {
        CharBuffer buf = CharBuffer.wrap(ASCII);
        assertEquals(ASCII.length(), CharStreams.exhaust(buf));
        assertEquals(0, buf.remaining());
        assertEquals(0, CharStreams.exhaust(buf));
    
        CharBuffer empty = CharBuffer.wrap("");
        assertEquals(0, CharStreams.exhaust(empty));
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 11.3K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/io/CharStreamsTest.java

        assertEquals(-1, empty.read());
      }
    
      public void testExhaust_readable() throws IOException {
        CharBuffer buf = CharBuffer.wrap(ASCII);
        assertEquals(ASCII.length(), CharStreams.exhaust(buf));
        assertEquals(0, buf.remaining());
        assertEquals(0, CharStreams.exhaust(buf));
    
        CharBuffer empty = CharBuffer.wrap("");
        assertEquals(0, CharStreams.exhaust(empty));
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 11.3K bytes
    - Viewed (0)
  4. cmd/xl-storage-format-v2.go

    	if err != nil {
    		return 0, 0, 0, buf, err
    	}
    	if hdrVer > xlHeaderVersion {
    		return 0, 0, 0, buf, fmt.Errorf("decodeXLHeaders: Unknown xl header version %d", hdrVer)
    	}
    	if metaVer > xlMetaVersion {
    		return 0, 0, 0, buf, fmt.Errorf("decodeXLHeaders: Unknown xl meta version %d", metaVer)
    	}
    	versions, buf, err = msgp.ReadIntBytes(buf)
    	if err != nil {
    		return 0, 0, 0, buf, err
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 65.6K bytes
    - Viewed (1)
  5. 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...
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jun 13 11:33:47 UTC 2025
    - 91.7K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb/SmbTransportImpl.java

            int size = Encdec.dec_uint16be(this.sbuf, 2) & 0xFFFF | (this.sbuf[1] & 0xFF) << 16;
            if (size < Smb2Constants.SMB2_HEADER_LENGTH + 1) {
                throw new IOException("Invalid payload size: " + size);
            }
    
            if (this.sbuf[0] != (byte) 0x00 || this.sbuf[4] != (byte) 0xFE || this.sbuf[5] != (byte) 'S' || this.sbuf[6] != (byte) 'M'
                    || this.sbuf[7] != (byte) 'B') {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 69.8K bytes
    - Viewed (0)
  7. cmd/data-usage-cache_gen_test.go

    	v := allTierStats{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    
    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodeallTierStats Msgsize() is inaccurate")
    	}
    
    	vn := allTierStats{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    }
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 19K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/api/json/SearchApiManager.java

                buf.append(',');
                buf.append("\"page_number\":");
                buf.append(currentPageNumber);
                buf.append(',');
                buf.append("\"record_count\":");
                buf.append(allRecordCount);
                buf.append(',');
                buf.append("\"record_count_relation\":");
                buf.append(escapeJson(allRecordCountRelation));
                buf.append(',');
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 54.6K bytes
    - Viewed (1)
  9. cmd/batch-replicate_gen_test.go

    	v := BatchJobReplicateCredentials{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    
    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodeBatchJobReplicateCredentials Msgsize() is inaccurate")
    	}
    
    	vn := BatchJobReplicateCredentials{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 29 18:27:23 UTC 2023
    - 14.2K bytes
    - Viewed (0)
  10. src/main/java/jcifs/dcerpc/DcerpcMessage.java

        }
    
        void encode_header(final NdrBuffer buf) {
            buf.enc_ndr_small(5); /* RPC version */
            buf.enc_ndr_small(0); /* minor version */
            buf.enc_ndr_small(this.ptype);
            buf.enc_ndr_small(this.flags);
            buf.enc_ndr_long(0x00000010); /* Little-endian / ASCII / IEEE */
            buf.enc_ndr_short(this.length);
            buf.enc_ndr_short(0); /* length of auth_value */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 6.3K bytes
    - Viewed (0)
Back to top