Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 59 for ReadUint (0.04 sec)

  1. internal/grid/grid_types_msgp_test.go

    	}
    	for zb0001 > 0 {
    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		switch msgp.UnsafeString(field) {
    		case "Num":
    			z.Num, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "Num")
    				return
    			}
    		case "String":
    			z.String, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "String")
    				return
    			}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HpackTest.kt

          ),
        )
      }
    
      @Test
      fun readSingleByteInt() {
        assertThat(newReader(byteStream()).readInt(10, 31)).isEqualTo(10)
        assertThat(newReader(byteStream()).readInt(0xe0 or 10, 31)).isEqualTo(10)
      }
    
      @Test
      fun readMultibyteInt() {
        assertThat(newReader(byteStream(154, 10)).readInt(31, 31)).isEqualTo(1337)
      }
    
      @Test
      fun writeSingleByteInt() {
        hpackWriter!!.writeInt(10, 31, 0)
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 38.6K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/io/LittleEndianDataInputStream.java

       * Reads an integer as specified by {@link DataInputStream#readInt()}, except using little-endian
       * byte order.
       *
       * @return the next four bytes of the input stream, interpreted as an {@code int} in little-endian
       *     byte order
       * @throws IOException if an I/O error occurs
       */
      @CanIgnoreReturnValue // to skip some bytes
      @Override
      public int readInt() throws IOException {
        byte b1 = readAndCheckByte();
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Feb 12 03:49:18 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  4. src/test/java/jcifs/pac/PacDataInputStreamTest.java

            assertEquals(1, pdis.available());
            assertEquals(0x05, pdis.readByte());
    
            // Test no alignment needed
            pdis = createInputStream(new byte[] { 0x01, 0x02, 0x03, 0x04 });
            pdis.readInt(); // position is 4
            pdis.align(4);
            assertEquals(0, pdis.available());
    
            // Test alignment with mask 0
            pdis = createInputStream(new byte[] { 0x01, 0x02, 0x03, 0x04 });
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  5. cmd/site-replication-utils_gen.go

    	}
    	for zb0001 > 0 {
    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		switch msgp.UnsafeString(field) {
    		case "v":
    			z.Version, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "Version")
    				return
    			}
    		case "ss":
    			err = z.Status.DecodeMsg(dc)
    			if err != nil {
    				err = msgp.WrapError(err, "Status")
    				return
    			}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 7.1K bytes
    - Viewed (0)
  6. cmd/metacache-set_gen.go

    			if err != nil {
    				err = msgp.WrapError(err, "StopDiskAtLimit")
    				return
    			}
    		case "pool":
    			z.pool, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "pool")
    				return
    			}
    		case "set":
    			z.set, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "set")
    				return
    			}
    		default:
    			err = dc.Skip()
    			if err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 13.8K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Cache.kt

              Platform.get().log("cache corruption", WARN, it)
            }
            requestMethod = source.readUtf8LineStrict()
            val varyHeadersBuilder = Headers.Builder()
            val varyRequestHeaderLineCount = readInt(source)
            for (i in 0 until varyRequestHeaderLineCount) {
              varyHeadersBuilder.addLenient(source.readUtf8LineStrict())
            }
            varyHeaders = varyHeadersBuilder.build()
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Oct 03 17:41:45 UTC 2025
    - 26.8K bytes
    - Viewed (0)
  8. internal/bucket/replication/datatypes_gen.go

    	s = msgp.StringPrefixSize + len(string(z))
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *Type) DecodeMsg(dc *msgp.Reader) (err error) {
    	{
    		var zb0001 int
    		zb0001, err = dc.ReadInt()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = Type(zb0001)
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z Type) EncodeMsg(en *msgp.Writer) (err error) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 3.4K bytes
    - Viewed (0)
  9. src/test/java/org/codelibs/opensearch/extension/analysis/NGramSynonymTokenizer.java

                bytesReader.reset(synonym.output.bytes, synonym.output.offset, synonym.output.length);
                final int code = bytesReader.readVInt();
                final int count = code >>> 1;
                for (int i = 0; i < count; i++) {
                    synonymMap.words.get(bytesReader.readVInt(), scratchBytes);
                    if (scratchChars.chars.length < scratchBytes.length) {
    Registered: Sat Dec 20 13:04:59 UTC 2025
    - Last Modified: Sat Mar 15 06:51:20 UTC 2025
    - 17K bytes
    - Viewed (0)
  10. okhttp-dnsoverhttps/src/main/kotlin/okhttp3/dnsoverhttps/DnsRecordCodec.kt

        for (i in 0 until answerCount) {
          skipName(buf) // name
    
          val type = buf.readShort().toInt() and 0xffff
          buf.readShort() // class
          @Suppress("UNUSED_VARIABLE")
          val ttl = buf.readInt().toLong() and 0xffffffffL // ttl
          val length = buf.readShort().toInt() and 0xffff
    
          if (type == TYPE_A || type == TYPE_AAAA) {
            val bytes = ByteArray(length)
            buf.read(bytes)
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 3.9K bytes
    - Viewed (0)
Back to top