Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 501 for bufs (0.01 sec)

  1. src/main/java/jcifs/smb/BufferCacheImpl.java

            synchronized (this.cache) {
                byte[] buf;
    
                if (this.freeBuffers > 0) {
                    for (int i = 0; i < this.cache.length; i++) {
                        if (this.cache[i] != null) {
                            buf = (byte[]) this.cache[i];
                            this.cache[i] = null;
                            this.freeBuffers--;
                            return buf;
                        }
                    }
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 3.2K bytes
    - Viewed (0)
  2. src/main/java/jcifs/internal/witness/WitnessRegisterMessage.java

                buf.enc_ndr_long(charCount + 1); // MaximumCount (including null terminator)
                buf.enc_ndr_long(0); // Offset
                buf.enc_ndr_long(charCount + 1); // ActualCount (including null terminator)
    
                // String data in UTF-16LE
                buf.writeOctetArray(wideBytes, 0, wideBytes.length);
                buf.enc_ndr_short(0); // Wide null terminator
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 23 09:06:40 UTC 2025
    - 8.6K bytes
    - Viewed (0)
  3. docs/debugging/inspect/export.go

    	hdrVer, buf, e := msgp.ReadUintBytes(buf)
    	if e != nil {
    		return 0, buf, e
    	}
    	metaVer, buf, e := msgp.ReadUintBytes(buf)
    	if e != nil {
    		return 0, buf, e
    	}
    	if hdrVer > xlHeaderVersion {
    		return 0, buf, fmt.Errorf("decodeXLHeaders: Unknown xl header version %d", metaVer)
    	}
    	if metaVer > xlMetaVersion {
    		return 0, buf, fmt.Errorf("decodeXLHeaders: Unknown xl meta version %d", metaVer)
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 9.2K bytes
    - Viewed (1)
  4. src/main/java/jcifs/internal/witness/WitnessAsyncNotifyMessage.java

            int maxCount = buf.dec_ndr_long();
            int offset = buf.dec_ndr_long();
            int actualCount = buf.dec_ndr_long();
    
            if (actualCount <= 0) {
                return "";
            }
    
            // Read wide string data (UTF-16LE)
            int byteCount = (actualCount - 1) * 2; // Exclude null terminator
            byte[] wideBytes = new byte[byteCount];
            buf.readOctetArray(wideBytes, 0, byteCount);
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 24 00:12:28 UTC 2025
    - 16.4K bytes
    - Viewed (0)
  5. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/CommandExtractor.java

                final StringBuilder buf = new StringBuilder(100);
                if (strings.length > 1) {
                    for (int i = 0; i < strings.length - 1; i++) {
                        if (buf.length() != 0) {
                            buf.append('.');
                        }
                        buf.append(strings[i]);
                    }
                    filePrefix = buf.toString();
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Nov 23 12:19:14 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/hash/HashingInputStreamTest.java

        assertEquals(4, numOfByteRead);
    
        assertEquals(expectedHash, in.hash());
      }
    
      public void testHash_hashesCorrectlyReadOutOfBound() throws Exception {
        HashCode expectedHash = Hashing.md5().hashBytes(testBytes);
        HashingInputStream in = new HashingInputStream(Hashing.md5(), buffer);
    
        byte[] buf = new byte[100];
        int numOfByteRead = in.read(buf, 0, buf.length);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 5K bytes
    - Viewed (0)
  7. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/smb1/SmbAuthentication.java

         */
        public String getPathPrefix() {
            final StringBuilder buf = new StringBuilder(100);
            buf.append("smb1://");
            if (server != null) {
                buf.append(server);
                if (port > 0) {
                    buf.append(':');
                    buf.append(port);
                }
                buf.append('/');
            }
            return buf.toString();
        }
    
        /**
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Sep 18 09:30:45 UTC 2025
    - 3.9K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb/MIEName.java

            if (buf.length < i + NAME_LEN_SIZE) {
                throw new IllegalArgumentException();
            }
            len = 0xff000000 & buf[i++] << 24;
            len |= 0x00ff0000 & buf[i++] << 16;
            len |= 0x0000ff00 & buf[i++] << 8;
            len |= 0x000000ff & buf[i++];
    
            // NAME
            if (buf.length < i + len) {
                throw new IllegalArgumentException();
            }
            this.name = new String(buf, i, len);
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 3.5K bytes
    - Viewed (0)
  9. src/main/java/jcifs/dcerpc/DcerpcPipeHandle.java

            }
    
            int off = this.handle.recv(buf, 0, buf.length);
            if (buf[0] != 5 || buf[1] != 0) {
                throw new IOException("Unexpected DCERPC PDU header");
            }
    
            final int length = Encdec.dec_uint16le(buf, 8);
            if (length > getMaxRecv()) {
                throw new IOException("Unexpected fragment length: " + length);
            }
    
            while (off < length) {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 5.6K bytes
    - Viewed (0)
  10. cmd/background-newdisks-heal-ops_gen_test.go

    	v := healingTracker{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    
    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodehealingTracker Msgsize() is inaccurate")
    	}
    
    	vn := healingTracker{}
    	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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 2.3K bytes
    - Viewed (0)
Back to top