Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 968 for Buffer (0.34 sec)

  1. guava/src/com/google/common/hash/Murmur3_32HashFunction.java

        @CanIgnoreReturnValue
        @Override
        public Hasher putBytes(ByteBuffer buffer) {
          ByteOrder bo = buffer.order();
          buffer.order(ByteOrder.LITTLE_ENDIAN);
          while (buffer.remaining() >= 4) {
            putInt(buffer.getInt());
          }
          while (buffer.hasRemaining()) {
            putByte(buffer.get());
          }
          buffer.order(bo);
          return this;
        }
    
        @CanIgnoreReturnValue
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Aug 02 13:50:22 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  2. src/main/java/jcifs/internal/smb1/com/SmbComLockingAndX.java

        protected int readParameterWordsWireFormat ( byte[] buffer, int bufferIndex ) {
            int start = bufferIndex;
    
            this.fid = SMBUtil.readInt2(buffer, bufferIndex);
            bufferIndex += 2;
    
            this.typeOfLock = buffer[ bufferIndex ];
    
            if ( ( this.typeOfLock & 0x10 ) == 0x10 ) {
                this.largeFile = true;
            }
    
            this.newOpLockLevel = buffer[ bufferIndex + 1 ];
            bufferIndex += 2;
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 4.9K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/MultipartReaderTest.kt

            boundary = "simple boundary",
            source = Buffer().writeUtf8(multipart),
          )
    
        assertThat(parts.nextPart()).isNotNull()
        assertThat(parts.nextPart()).isNull()
        assertThat(parts.nextPart()).isNull()
      }
    
      @Test fun `empty source`() {
        val parts =
          MultipartReader(
            boundary = "simple boundary",
            source = Buffer(),
          )
    
        assertFailsWith<EOFException> {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  4. src/archive/zip/writer_test.go

    		testReadFile(t, r.File[i], &wt)
    	}
    }
    
    func TestWriterFlush(t *testing.T) {
    	var buf bytes.Buffer
    	w := NewWriter(struct{ io.Writer }{&buf})
    	_, err := w.Create("foo")
    	if err != nil {
    		t.Fatal(err)
    	}
    	if buf.Len() > 0 {
    		t.Fatalf("Unexpected %d bytes already in buffer", buf.Len())
    	}
    	if err := w.Flush(); err != nil {
    		t.Fatal(err)
    	}
    	if buf.Len() == 0 {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Sep 23 14:32:33 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/internal/ws/MessageDeflaterInflaterTest.kt

        val buffer = Buffer()
        buffer.write(byteString)
        deflate(buffer)
        return buffer.readByteString()
      }
    
      private fun MessageInflater.inflate(byteString: ByteString): ByteString {
        val buffer = Buffer()
        buffer.write(byteString)
        inflate(buffer)
        return buffer.readByteString()
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 06 05:31:00 UTC 2024
    - 5K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/ResponseJvmTest.kt

       * most [BufferedSource] instances, but not of [Buffer].
       */
      private fun responseBody(content: String): ResponseBody {
        val data = Buffer().writeUtf8(content)
        val source: Source =
          object : Source {
            var closed = false
    
            override fun close() {
              closed = true
            }
    
            override fun read(
              sink: Buffer,
              byteCount: Long,
            ): Long {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/io/ReaderInputStream.java

      private static int availableCapacity(Buffer buffer) {
        return buffer.capacity() - buffer.limit();
      }
    
      /**
       * Flips the buffer output buffer so we can start reading bytes from it. If we are starting to
       * drain because there was overflow, and there aren't actually any characters to drain, then the
       * overflow must be due to a small output buffer.
       */
      private void startDraining(boolean overflow) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  8. guava/src/com/google/common/io/ReaderInputStream.java

      private static int availableCapacity(Buffer buffer) {
        return buffer.capacity() - buffer.limit();
      }
    
      /**
       * Flips the buffer output buffer so we can start reading bytes from it. If we are starting to
       * drain because there was overflow, and there aren't actually any characters to drain, then the
       * overflow must be due to a small output buffer.
       */
      private void startDraining(boolean overflow) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  9. src/main/java/jcifs/dcerpc/msrpc/lsarpc.java

                _dst.enc_ndr_referent(this.name.buffer, 1);
                _dst.enc_ndr_short(this.dns_domain.length);
                _dst.enc_ndr_short(this.dns_domain.maximum_length);
                _dst.enc_ndr_referent(this.dns_domain.buffer, 1);
                _dst.enc_ndr_short(this.dns_forest.length);
                _dst.enc_ndr_short(this.dns_forest.maximum_length);
                _dst.enc_ndr_referent(this.dns_forest.buffer, 1);
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:40:13 UTC 2019
    - 35.6K bytes
    - Viewed (0)
  10. src/main/java/jcifs/netbios/SessionServicePacket.java

            writeInt2(this.length, dst, dstIndex);
            return HEADER_LENGTH;
        }
    
    
        int readHeaderWireFormat ( InputStream in, byte[] buffer, int bufferIndex ) {
            this.type = buffer[ bufferIndex++ ] & 0xFF;
            this.length = ( ( buffer[ bufferIndex ] & 0x01 ) << 16 ) + readInt2(buffer, bufferIndex + 1);
            return HEADER_LENGTH;
        }
    
    
        abstract int writeTrailerWireFormat ( byte[] dst, int dstIndex );
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 4.6K bytes
    - Viewed (0)
Back to top