Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 725 for bufLen (0.09 sec)

  1. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/metadata/AbstractArtifactMetadata.java

        }
    
        public String extendedToString() {
            StringBuilder buffer = new StringBuilder(256);
    
            buffer.append(LS).append("Artifact Metadata").append(LS).append("--------------------------");
            buffer.append(LS).append("GroupId: ").append(getGroupId());
            buffer.append(LS).append("ArtifactId: ").append(getArtifactId());
            buffer.append(LS).append("Metadata Type: ").append(getClass().getName());
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/cache2/FileOperatorTest.kt

        val buffer = Buffer()
        operator.read(6, buffer, 21)
        operator.read(36, buffer, 1)
        operator.read(5, buffer, 5)
        operator.read(28, buffer, 8)
        operator.read(17, buffer, 10)
        operator.read(36, buffer, 2)
        operator.read(2, buffer, 4)
        operator.write(0, buffer, buffer.size)
        operator.read(0, buffer, 12)
        operator.read(47, buffer, 3)
        operator.read(45, buffer, 2)
        operator.read(47, buffer, 3)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt

            for (b in data.toByteArray()) {
              assertThat(b).isEqualTo(2.toByte())
            }
          }
        }
      }
    
      private fun gzip(data: ByteArray): Buffer {
        val buffer = Buffer()
        GzipSink(buffer).buffer().write(data).close()
        return buffer
      }
    
      /** Create a sufficiently large header set to overflow INITIAL_MAX_FRAME_SIZE bytes.  */
      private fun largeHeaders(): List<Header> {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  4. src/main/java/jcifs/internal/smb1/AndXServerMessageBlock.java

         */
    
        @Override
        public int decode ( byte[] buffer, int bufferIndex ) throws SMBProtocolDecodingException {
            int start = this.headerStart = bufferIndex;
    
            bufferIndex += readHeaderWireFormat(buffer, bufferIndex);
            bufferIndex += readAndXWireFormat(buffer, bufferIndex);
    
            int len = bufferIndex - start;
            this.length = len;
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Mon Nov 28 10:56:27 UTC 2022
    - 14.3K bytes
    - Viewed (0)
  5. src/main/java/jcifs/internal/smb1/com/SmbComNegotiateResponse.java

            this.server.smaxMpxCount = SMBUtil.readInt2(buffer, bufferIndex);
            bufferIndex += 2;
            this.server.maxNumberVcs = SMBUtil.readInt2(buffer, bufferIndex);
            bufferIndex += 2;
            this.server.maxBufferSize = SMBUtil.readInt4(buffer, bufferIndex);
            bufferIndex += 4;
            this.server.maxRawSize = SMBUtil.readInt4(buffer, bufferIndex);
            bufferIndex += 4;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Tue Jul 07 10:52:42 UTC 2020
    - 15.4K bytes
    - Viewed (0)
  6. 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)
  7. src/main/java/jcifs/internal/smb2/ioctl/SrvPipePeekResponse.java

         */
        @Override
        public int decode ( byte[] buffer, int bufferIndex, int len ) throws SMBProtocolDecodingException {
            int start = bufferIndex;
            this.namedPipeState = SMBUtil.readInt4(buffer, bufferIndex);
            bufferIndex += 4;
            this.readDataAvailable = SMBUtil.readInt4(buffer, bufferIndex);
            bufferIndex += 4;
            this.numberOfMessages = SMBUtil.readInt4(buffer, bufferIndex);
            bufferIndex += 4;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Aug 05 09:45:59 UTC 2018
    - 2.7K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. 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)
Back to top