Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 84 for byteCount (1.13 sec)

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

            // However, we'll try to read it safely for compatibility
            if (this.byteCount > bufferIndex - start) {
                try {
                    // Attempt to read nativeFileSystem, but don't fail if there are issues
                    final int fsLen = this.byteCount - (bufferIndex - start);
                    if (fsLen > 0 && fsLen < 256) { // Sanity check on length
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 5.1K bytes
    - Viewed (0)
  2. src/main/java/jcifs/internal/witness/WitnessAsyncNotifyMessage.java

            }
    
            // Read wide string data (UTF-16LE)
            int byteCount = (actualCount - 1) * 2; // Exclude null terminator
            byte[] wideBytes = new byte[byteCount];
            buf.readOctetArray(wideBytes, 0, byteCount);
    
            // Skip null terminator
            buf.dec_ndr_short();
    
            // Skip padding
            int padding = (4 - ((byteCount + 2) % 4)) % 4;
            for (int i = 0; i < padding; i++) {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 24 00:12:28 UTC 2025
    - 16.4K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/MultipartReaderTest.kt

          ),
        )
        val readBuff = Buffer()
        var byteCount = 0L
        while (true) {
          val readByteCount = onlyPart.body.read(readBuff, 1024L)
          if (readByteCount == -1L) break
          byteCount += readByteCount
          assertThat(readBuff.readUtf8()).isEqualTo("a".repeat(readByteCount.toInt()))
        }
        assertThat(byteCount).isEqualTo(1024L * 1024L * 100L)
        assertThat(multipartReader.nextPart()).isNull()
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed May 28 02:11:14 UTC 2025
    - 15.4K bytes
    - Viewed (0)
  4. src/main/java/jcifs/internal/smb2/ServerMessageBlock2.java

        public int encode(final byte[] dst, int dstIndex) {
            final int start = this.headerStart = dstIndex;
            dstIndex += writeHeaderWireFormat(dst, dstIndex);
    
            this.byteCount = writeBytesWireFormat(dst, dstIndex);
            dstIndex += this.byteCount;
            dstIndex += pad8(dstIndex);
    
            this.length = dstIndex - start;
    
            int len = this.length;
    
            if (this.next != null) {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 24K bytes
    - Viewed (0)
  5. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerWriter.kt

      /** Used for tags and subidentifiers. */
      private fun writeVariableLengthLong(v: Long) {
        val sink = sink()
        val bitCount = 64 - java.lang.Long.numberOfLeadingZeros(v)
        val byteCount = (bitCount + 6) / 7
        for (shift in (byteCount - 1) * 7 downTo 0 step 7) {
          val lastBit = if (shift == 0) 0 else 0b1000_0000
          sink.writeByte(((v shr shift) and 0b0111_1111).toInt() or lastBit)
        }
      }
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 5.7K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/UnreadableResponseBody.kt

    ) : ResponseBody(),
      Source {
      override fun contentType() = mediaType
    
      override fun contentLength() = contentLength
    
      override fun source() = buffer()
    
      override fun read(
        sink: Buffer,
        byteCount: Long,
      ): Long =
        throw IllegalStateException(
          """
          |Unreadable ResponseBody! These Response objects have bodies that are stripped:
          | * Response.cacheResponse
          | * Response.networkResponse
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue May 27 15:19:53 UTC 2025
    - 1.7K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Huffman.kt

        return ((bitCount + 7) shr 3).toInt() // Round up to an even byte.
      }
    
      fun decode(
        source: BufferedSource,
        byteCount: Long,
        sink: BufferedSink,
      ) {
        var node = root
        var accumulator = 0
        var accumulatorBitCount = 0
        for (i in 0 until byteCount) {
          val byteIn = source.readByte() and 0xff
          accumulator = accumulator shl 8 or byteIn
          accumulatorBitCount += 8
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 11K bytes
    - Viewed (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/InterceptorTest.kt

          }
        }
    
      private fun uppercase(original: BufferedSink): Sink =
        object : ForwardingSink(original) {
          override fun write(
            source: Buffer,
            byteCount: Long,
          ) {
            original.writeUtf8(source.readUtf8(byteCount).uppercase())
          }
        }
    
      private fun gzip(data: String): Buffer {
        val result = Buffer()
        val sink = GzipSink(result).buffer()
        sink.writeUtf8(data)
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Nov 04 16:11:23 UTC 2025
    - 28.2K bytes
    - Viewed (0)
  9. src/test/java/jcifs/internal/smb1/trans/SmbComTransactionResponseTest.java

            // Fill with basic SMB header structure
            System.arraycopy(new byte[] { (byte) 0xFF, 'S', 'M', 'B' }, 0, buffer, 0, 4);
            buffer[4] = 1; // wordCount
            buffer[7] = 0; // byteCount low
            buffer[8] = 0; // byteCount high
    
            assertDoesNotThrow(() -> response.decode(buffer, 0));
        }
    
        @Test
        @DisplayName("Test writeParameterWordsWireFormat")
        void testWriteParameterWordsWireFormat() {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 13.4K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb1/smb1/SmbComTreeConnectAndXResponse.java

            // win98 observed not returning nativeFileSystem
            /* Problems here with iSeries returning ASCII even though useUnicode = true
             * Fortunately we don't really need nativeFileSystem for anything.
            if( byteCount > bufferIndex - start ) {
                nativeFileSystem = readString( buffer, bufferIndex );
                bufferIndex += stringWireLength( nativeFileSystem, bufferIndex );
            }
            */
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 2.9K bytes
    - Viewed (0)
Back to top