Search Options

Results per page
Sort
Preferred Languages
Advance

Results 541 - 550 of 1,011 for buffers (0.04 sec)

  1. src/main/java/jcifs/internal/smb1/com/SmbComWriteAndXResponse.java

            return 0;
        }
    
        @Override
        protected int readParameterWordsWireFormat(final byte[] buffer, final int bufferIndex) {
            this.count = SMBUtil.readInt2(buffer, bufferIndex) & 0xFFFFL;
            return 8;
        }
    
        @Override
        protected int readBytesWireFormat(final byte[] buffer, final int bufferIndex) {
            return 0;
        }
    
        @Override
        public String toString() {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2.3K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb1/smb1/TransPeekNamedPipeResponse.java

        int readSetupWireFormat(final byte[] buffer, final int bufferIndex, final int len) {
            return 0;
        }
    
        @Override
        int readParametersWireFormat(final byte[] buffer, int bufferIndex, final int len) {
            available = readInt2(buffer, bufferIndex);
            bufferIndex += 2;
            int head = readInt2(buffer, bufferIndex);
            bufferIndex += 2;
            status = readInt2(buffer, bufferIndex);
            return 6;
        }
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 2.3K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/SocksProxy.kt

          val name = "SocksProxy $fromAddress to $toAddress"
          threadName(name) {
            val buffer = Buffer()
            try {
              sink.use {
                source.use {
                  while (true) {
                    val byteCount = source.read(buffer, 8192L)
                    if (byteCount == -1L) break
                    sink.write(buffer, byteCount)
                    sink.emit()
                  }
                }
              }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 7.6K bytes
    - Viewed (0)
  4. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerAdapter.kt

       */
      fun toDer(
        writer: DerWriter,
        value: T,
      )
    
      fun toDer(value: T): ByteString {
        val buffer = Buffer()
        val writer = DerWriter(buffer)
        toDer(writer, value)
        return buffer.readByteString()
      }
    
      /**
       * Returns an adapter that expects this value wrapped by another value. Typically this occurs
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  5. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultUpdateCheckManager.java

            StringBuilder buffer = new StringBuilder(256);
    
            Proxy proxy = repository.getProxy();
            if (proxy != null) {
                if (proxy.getUserName() != null) {
                    int hash = (proxy.getUserName() + proxy.getPassword()).hashCode();
                    buffer.append(hash).append('@');
                }
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Tue Apr 22 22:13:51 UTC 2025
    - 12.1K bytes
    - Viewed (0)
  6. src/main/java/jcifs/netbios/SessionRetargetResponsePacket.java

        }
    
        @Override
        int readTrailerWireFormat(final InputStream in, final byte[] buffer, int bufferIndex) throws IOException {
            if (in.read(buffer, bufferIndex, this.length) != this.length) {
                throw new IOException("unexpected EOF reading netbios retarget session response");
            }
            final int addr = readInt4(buffer, bufferIndex);
            bufferIndex += 4;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 1.7K bytes
    - Viewed (0)
  7. src/test/java/jcifs/util/transport/TransportTest.java

                byte[] buffer = new byte[20];
    
                int bytesRead = Transport.readn(is, buffer, 0, 5);
                assertEquals(5, bytesRead);
                assertArrayEquals("Hello".getBytes(), java.util.Arrays.copyOfRange(buffer, 0, 5));
            }
    
            @Test
            @DisplayName("readn should throw IOException when buffer too short")
            void shouldThrowWhenBufferTooShort() {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 9.5K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/core/xml/DomUtil.java

        /**
         * Appends the string representation of an {@link Element}.
         *
         * @param element
         *            The element. Must not be {@literal null}.
         * @param buf
         *            The string buffer. Must not be {@literal null}.
         */
        public static void appendElement(final Element element, final StringBuilder buf) {
            assertArgumentNotNull("element", element);
            assertArgumentNotNull("buf", buf);
    
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Thu Jul 31 08:16:49 UTC 2025
    - 10.1K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb1/smb1/NetShareEnum.java

            return 0;
        }
    
        @Override
        int readSetupWireFormat(final byte[] buffer, final int bufferIndex, final int len) {
            return 0;
        }
    
        @Override
        int readParametersWireFormat(final byte[] buffer, final int bufferIndex, final int len) {
            return 0;
        }
    
        @Override
        int readDataWireFormat(final byte[] buffer, final int bufferIndex, final int len) {
            return 0;
        }
    
        @Override
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 2.7K bytes
    - Viewed (0)
  10. cmd/bootstrap-peer-server_gen_test.go

    	v := ServerSystemConfig{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	en := msgp.NewWriter(msgp.Nowhere)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.EncodeMsg(en)
    	}
    	en.Flush()
    }
    
    func BenchmarkDecodeServerSystemConfig(b *testing.B) {
    	v := ServerSystemConfig{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Jan 24 21:36:44 UTC 2024
    - 2.4K bytes
    - Viewed (0)
Back to top