- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 38 for ReadInt (0.16 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
} val padding = if (flags and FLAG_PADDED != 0) source.readByte() and 0xff else 0 val promisedStreamId = source.readInt() and 0x7fffffff val headerBlockLength = lengthWithoutPadding(length - 4, flags, padding) // - 4 for readInt(). val headerBlock = readHeaderBlock(headerBlockLength, padding, flags, streamId) handler.pushPromise(streamId, promisedStreamId, headerBlock) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 19.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/ByteStreamsTest.java
assertThrows(IllegalStateException.class, () -> in.readInt()); } public void testNewDataInput_normal() { ByteArrayDataInput in = ByteStreams.newDataInput(bytes); assertEquals(0x12345678, in.readInt()); assertEquals(0x76543210, in.readInt()); assertThrows(IllegalStateException.class, () -> in.readInt()); } public void testNewDataInput_readFully() {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 21.9K bytes - Viewed (0) -
src/main/java/jcifs/pac/PacLogonInfo.java
SID groupId = pacStream.readId(); // Groups information int groupCount = pacStream.readInt(); int groupPointer = pacStream.readInt(); // User flags about PAC Logon Info content this.userFlags = pacStream.readInt(); boolean hasExtraSids = ( this.userFlags & PacConstants.LOGON_EXTRA_SIDS ) == PacConstants.LOGON_EXTRA_SIDS;
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 11.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/ByteStreamsTest.java
assertThrows(IllegalStateException.class, () -> in.readInt()); } public void testNewDataInput_normal() { ByteArrayDataInput in = ByteStreams.newDataInput(bytes); assertEquals(0x12345678, in.readInt()); assertEquals(0x76543210, in.readInt()); assertThrows(IllegalStateException.class, () -> in.readInt()); } public void testNewDataInput_readFully() {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 21.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Hpack.kt
// 1NNNNNNN val index = readInt(b, PREFIX_7_BITS) readIndexedHeader(index - 1) } b == 0x40 -> { // 01000000 readLiteralHeaderWithIncrementalIndexingNewName() } b and 0x40 == 0x40 -> { // 01NNNNNN val index = readInt(b, PREFIX_6_BITS)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 22.5K bytes - Viewed (1) -
okhttp/src/test/java/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)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 38.2K bytes - Viewed (0) -
src/main/java/org/codelibs/core/collection/ArrayMap.java
@Override public void readExternal(final ObjectInput in) throws IOException, ClassNotFoundException { final int num = in.readInt(); mapTable = new Entry[num]; listTable = new Entry[num]; threshold = (int) (num * LOAD_FACTOR); final int size = in.readInt(); for (int i = 0; i < size; i++) { final K key = (K) in.readObject(); final V value = (V) in.readObject();
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 20.6K bytes - Viewed (1) -
cmd/local-locker_gen.go
} switch msgp.UnsafeString(field) { case "Total": z.Total, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "Total") return } case "Writes": z.Writes, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "Writes") return } case "Reads": z.Reads, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "Reads") return
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 13.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/publicsuffix/PublicSuffixDatabaseTest.kt
FileSystem.RESOURCES.source(PublicSuffixDatabase.PUBLIC_SUFFIX_RESOURCE).use { resource -> GzipSource(resource).buffer().use { source -> var length = source.readInt() source.skip(length.toLong()) length = source.readInt() buffer.write(source, length.toLong()) } } while (!buffer.exhausted()) { val exception = buffer.readUtf8LineStrict()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.3K bytes - Viewed (0) -
okhttp/src/main/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()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 26.8K bytes - Viewed (0)