- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 907 for buffer (0.18 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http/HttpHeaders.kt
} return commaFound } private fun Buffer.startsWith(prefix: Byte): Boolean = !exhausted() && this[0] == prefix /** * Reads a double-quoted string, unescaping quoted pairs like `\"` to the 2nd character in each * sequence. Returns the unescaped string, or null if the buffer isn't prefixed with a * double-quoted string. */ @Throws(EOFException::class) private fun Buffer.readQuotedString(): String? {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
) synchronized(this@Relay) { // Append new upstream bytes into the buffer. Trim it to its max size. buffer.write(upstreamBuffer, upstreamBytesRead) if (buffer.size > bufferMaxSize) { buffer.skip(buffer.size - bufferMaxSize) } // Now that the file and buffer have bytes, adjust upstreamPos. ******@****.***amPos += upstreamBytesRead }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SecurityDescriptor.java
} public SecurityDescriptor(byte[] buffer, int bufferIndex, int len) throws IOException { this.decode(buffer, bufferIndex, len); } public int decode(byte[] buffer, int bufferIndex, int len) throws IOException { int start = bufferIndex; bufferIndex++; // revision bufferIndex++; type = ServerMessageBlock.readInt2(buffer, bufferIndex); bufferIndex += 2;
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 3.3K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance_gen_test.go
v := rebalanceInfo{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len())) en := msgp.NewWriter(msgp.Nowhere) b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.EncodeMsg(en) } en.Flush() } func BenchmarkDecoderebalanceInfo(b *testing.B) { v := rebalanceInfo{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len()))
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Oct 25 19:36:57 GMT 2022 - 11K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/Trans2QueryFSInformationResponse.java
case SMB_QUERY_FS_SIZE_INFO: return readSmbQueryFSSizeInfoWireFormat( buffer, bufferIndex ); case SMB_FS_FULL_SIZE_INFORMATION: return readFsFullSizeInformationWireFormat( buffer, bufferIndex ); default: return 0; } } int readSmbInfoAllocationWireFormat( byte[] buffer, int bufferIndex ) {
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 5.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
assertThat(stream.takeHeaders()).isEqualTo(headersOf("a", "android")) val source = stream.getSource() val buffer = Buffer() buffer.writeAll(source) assertThat(source.read(buffer, 1)).isEqualTo(-1) assertThat(buffer.size).isEqualTo(150) val synStream = peer.takeFrame() assertThat(synStream.type).isEqualTo(Http2.TYPE_HEADERS) for (i in 0..2) {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/trans2/Trans2GetDfsReferralResponse.java
} @Override protected int readSetupWireFormat ( byte[] buffer, int bufferIndex, int len ) { return 0; } @Override protected int readParametersWireFormat ( byte[] buffer, int bufferIndex, int len ) { return 0; } @Override protected int readDataWireFormat ( byte[] buffer, int bufferIndex, int len ) { int start = bufferIndex;
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 3K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/ServerMessageBlock2.java
protected int readHeaderWireFormat ( byte[] buffer, int bufferIndex ) { // these are common between SYNC/ASYNC SMBUtil.readInt4(buffer, bufferIndex); bufferIndex += 4; SMBUtil.readInt2(buffer, bufferIndex); this.creditCharge = SMBUtil.readInt2(buffer, bufferIndex + 2); bufferIndex += 4; this.status = SMBUtil.readInt4(buffer, bufferIndex); bufferIndex += 4;
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Sun Sep 30 10:47:31 GMT 2018 - 19.9K bytes - Viewed (0) -
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> {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 28.1K bytes - Viewed (0) -
src/main/java/jcifs/internal/fscc/FileStandardInfo.java
*/ @Override public int decode ( byte[] buffer, int bufferIndex, int len ) throws SMBProtocolDecodingException { int start = bufferIndex; this.allocationSize = SMBUtil.readInt8(buffer, bufferIndex); bufferIndex += 8; this.endOfFile = SMBUtil.readInt8(buffer, bufferIndex); bufferIndex += 8; this.numberOfLinks = SMBUtil.readInt4(buffer, bufferIndex); bufferIndex += 4;
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 3.3K bytes - Viewed (0)