- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 59 for ReadUint (0.07 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)