Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 291 - 300 of 986 for Buffer (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. src/main/java/jcifs/internal/smb2/create/Smb2CloseResponse.java

            this.creationTime = SMBUtil.readTime(buffer, bufferIndex);
            bufferIndex += 8;
            this.lastAccessTime = SMBUtil.readTime(buffer, bufferIndex);
            bufferIndex += 8;
            this.lastWriteTime = SMBUtil.readTime(buffer, bufferIndex);
            bufferIndex += 8;
            this.changeTime = SMBUtil.readTime(buffer, bufferIndex);
            bufferIndex += 8;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 6.1K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/util/InputStreamThread.java

        }
    
        /**
         * Runs the thread to continuously read lines from the input stream.
         * Each line is processed by the output callback (if provided) and added to the buffer.
         * The buffer is maintained as a circular buffer with the specified size.
         */
        @Override
        public void run() {
            boolean running = true;
            while (running) {
                try {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  3. src/main/java/jcifs/internal/smb1/trans2/Trans2QueryFSInformation.java

        @Override
        protected int readSetupWireFormat(final byte[] buffer, final int bufferIndex, final int len) {
            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;
        }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 3.9K bytes
    - Click Count (0)
  4. src/main/java/jcifs/internal/smb2/nego/EncryptionNegotiateContext.java

        @Override
        public int decode(final byte[] buffer, int bufferIndex, final int len) throws SMBProtocolDecodingException {
            final int start = bufferIndex;
            final int nciphers = SMBUtil.readInt2(buffer, bufferIndex);
            bufferIndex += 2;
    
            this.ciphers = new int[nciphers];
            for (int i = 0; i < nciphers; i++) {
                this.ciphers[i] = SMBUtil.readInt2(buffer, bufferIndex);
                bufferIndex += 2;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 3.8K bytes
    - Click Count (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

       * to buffer chunks; typically by using a buffered sink with this sink.
       */
      private inner class ChunkedSink : Sink {
        private val timeout = ForwardingTimeout(socket.sink.timeout())
        private var closed: Boolean = false
    
        override fun timeout(): Timeout = timeout
    
        override fun write(
          source: Buffer,
          byteCount: Long,
        ) {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 17.6K bytes
    - Click Count (7)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/MessageDeflater.kt

      private val deflaterSink = DeflaterSink(deflatedBytes, deflater)
    
      /** Deflates [buffer] in place as described in RFC 7692 section 7.2.1. */
      @Throws(IOException::class)
      fun deflate(buffer: Buffer) {
        require(deflatedBytes.size == 0L)
    
        if (noContextTakeover) {
          deflater.reset()
        }
    
        deflaterSink.write(buffer, buffer.size)
        deflaterSink.flush()
    
        if (deflatedBytes.endsWith(EMPTY_DEFLATE_BLOCK)) {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 2.1K bytes
    - Click Count (0)
  7. src/test/java/jcifs/smb1/smb1/AndXServerMessageBlockTest.java

                return bytesWritten;
            }
    
            @Override
            int readParameterWordsWireFormat(byte[] buffer, int bufferIndex) {
                paramWordsRead = 10;
                return paramWordsRead;
            }
    
            @Override
            int readBytesWireFormat(byte[] buffer, int bufferIndex) {
                bytesRead = 20;
                return bytesRead;
            }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 12.5K bytes
    - Click Count (0)
  8. src/test/java/jcifs/smb1/util/HMACT64Test.java

            // Test engineDigest with buffer too small
            HMACT64 hmac = new HMACT64(TEST_KEY);
            hmac.engineUpdate(TEST_DATA, 0, TEST_DATA.length);
    
            byte[] buffer = new byte[10];
            // Should throw exception when buffer is too small
            assertThrows(IllegalStateException.class, () -> hmac.engineDigest(buffer, 0, 10));
        }
    
        @Test
        void testClone() {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 10.1K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/io/ByteStreams.java

        int initialBufferSize = min(BUFFER_SIZE, max(128, Integer.highestOneBit(totalLen) * 2));
        // Starting with an 8k buffer, double the size of each successive buffer. Smaller buffers
        // quadruple in size until they reach 8k, to minimize the number of small reads for longer
        // streams. Buffers are retained in a deque so that there's no copying between buffers while
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 21:06:42 GMT 2026
    - 31.1K bytes
    - Click Count (0)
  10. okhttp/src/androidMain/baseline-prof.txt

    HSPLokio/Buffer;->readShort()S
    HSPLokio/Buffer;->readString(JLjava/nio/charset/Charset;)Ljava/lang/String;
    HSPLokio/Buffer;->readString(Ljava/nio/charset/Charset;)Ljava/lang/String;
    HSPLokio/Buffer;->skip(J)V
    HSPLokio/Buffer;->writableSegment$okio(I)Lokio/Segment;
    HSPLokio/Buffer;->write(Lokio/Buffer;J)V
    HSPLokio/Buffer;->write(Lokio/ByteString;)Lokio/Buffer;
    HSPLokio/Buffer;->write([B)Lokio/Buffer;
    HSPLokio/Buffer;->write([BII)Lokio/Buffer;
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Mon Dec 30 23:28:56 GMT 2024
    - 127.9K bytes
    - Click Count (1)
Back to Top