Search Options

Results per page
Sort
Preferred Languages
Advance

Results 431 - 440 of 939 for Buffers (0.04 sec)

  1. src/main/java/jcifs/internal/smb2/lease/Smb2LeaseKey.java

         */
        public byte[] getKey() {
            return Arrays.copyOf(key, LEASE_KEY_SIZE);
        }
    
        /**
         * Write the lease key to a buffer
         *
         * @param dst destination buffer
         * @param dstIndex starting index in destination buffer
         */
        public void encode(byte[] dst, int dstIndex) {
            System.arraycopy(key, 0, dst, dstIndex, LEASE_KEY_SIZE);
        }
    
        /**
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 21 00:16:17 UTC 2025
    - 3.3K bytes
    - Viewed (0)
  2. src/main/java/jcifs/internal/smb1/trans/TransPeekNamedPipe.java

            return 0;
        }
    
        @Override
        protected int readParametersWireFormat(final byte[] buffer, final int bufferIndex, final int len) {
            return 0;
        }
    
        @Override
        protected int readDataWireFormat(final byte[] buffer, final int bufferIndex, final int len) {
            return 0;
        }
    
        @Override
        public String toString() {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 3K bytes
    - Viewed (0)
  3. cmd/storage-datatypes_gen_test.go

    	v := BaseOptions{}
    	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 BenchmarkDecodeBaseOptions(b *testing.B) {
    	v := BaseOptions{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 73.9K bytes
    - Viewed (0)
  4. docs/bigdata/README.md

    fs.s3a.fast.upload.buffer=disk # Use disk as the buffer for uploads
    fs.s3a.fast.upload=true # Turn on fast upload mode
    fs.s3a.max.total.tasks=2048 # Maximum number of parallel tasks
    fs.s3a.multipart.size=512M # Size of each multipart chunk
    fs.s3a.multipart.threshold=512M # Size before using multipart uploads
    fs.s3a.socket.recv.buffer=65536 # Read socket buffer hint
    fs.s3a.socket.send.buffer=65536 # Write socket buffer hint
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  5. 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 Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  6. 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 Dec 26 11:42:13 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 7.6K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/core/io/FileUtil.java

                }
    
                final ByteBuffer buffer = ByteBuffer.allocate((int) fileSize);
                ChannelUtil.read(channel, buffer);
                return buffer.array();
            } finally {
                CloseableUtil.close(is);
            }
        }
    
        /**
         * Reads text from a file using the default encoding.
    Registered: Sat Dec 20 08:55:33 UTC 2025
    - Last Modified: Sat Nov 22 11:21:59 UTC 2025
    - 13.1K bytes
    - Viewed (0)
  8. fess-crawler/src/test/java/org/codelibs/fess/crawler/util/ResponseDataUtilTest.java

            assertTrue(tempFile.exists());
    
            // Read and verify content
            try (FileInputStream fis = new FileInputStream(tempFile)) {
                byte[] buffer = new byte[1024];
                int bytesRead = fis.read(buffer);
                String content = new String(buffer, 0, bytesRead);
                assertEquals("Test response body", content);
            } finally {
                // Clean up
                tempFile.delete();
            }
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sat Nov 22 13:28:22 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  9. impl/maven-core/src/main/java/org/apache/maven/internal/impl/DefaultProjectBuilder.java

                                StringBuilder buffer = new StringBuilder(256);
    
                                if (!getSource().isEmpty()) {
                                    buffer.append(getSource());
                                }
    
                                if (getLineNumber() > 0) {
                                    if (!buffer.isEmpty()) {
                                        buffer.append(", ");
                                    }
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Sat Sep 13 09:44:11 UTC 2025
    - 8.8K bytes
    - Viewed (0)
  10. src/test/java/jcifs/dcerpc/msrpc/samrTest.java

                verify(mockNdrBuffer).enc_ndr_short((short) 6);
                verify(mockNdrBuffer).enc_ndr_referent(entry.name.buffer, 1);
            }
    
            @Test
            @DisplayName("Should encode entry with null buffer")
            void testEncodeNullBuffer() throws NdrException {
                // Given: SAM entry with null buffer
                samr.SamrSamEntry entry = new samr.SamrSamEntry();
                entry.idx = 1;
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 33.7K bytes
    - Viewed (0)
Back to top