- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 546 for buffer (0.2 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
* to buffer chunks; typically by using a buffered sink with this sink. */ private inner class ChunkedSink : Sink { private val timeout = ForwardingTimeout(sink.timeout()) private var closed: Boolean = false override fun timeout(): Timeout = timeout override fun write( source: Buffer, byteCount: Long, ) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 16.2K bytes - Viewed (0) -
okhttp-tls/src/test/java/okhttp3/tls/internal/der/DerTest.kt
derWriter.writeUtf8("a".repeat(201)) } assertThat(buffer.readByteString(3)).isEqualTo("1e81c9".decodeHex()) assertThat(buffer.readUtf8()).isEqualTo("a".repeat(201)) } @Test fun `decode primitive bit string`() { val buffer = Buffer() .write("0307040A3B5F291CD0".decodeHex()) val derReader = DerReader(buffer) derReader.read("test") { header ->
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 31.7K bytes - Viewed (0) -
docs/bigdata/README.md
fs.s3a.fast.upload.buffer=disk # Use disk as the buffer for uploads fs.s3a.fast.upload=true # Turn on fast upload mode fs.s3a.max.total.tasks=2048 # Maximum number of parallel tasks fs.s3a.multipart.size=512M # Size of each multipart chunk fs.s3a.multipart.threshold=512M # Size before using multipart uploads fs.s3a.socket.recv.buffer=65536 # Read socket buffer hint fs.s3a.socket.send.buffer=65536 # Write socket buffer hint
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Sep 29 04:28:45 GMT 2022 - 14.7K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/RecordedRequestTest.kt
import assertk.assertions.isEqualTo import java.net.InetAddress import java.net.Socket import okhttp3.Headers import okhttp3.Headers.Companion.headersOf import okhttp3.internal.EMPTY_HEADERS import okio.Buffer import org.junit.jupiter.api.Test import org.junit.jupiter.api.Timeout @Timeout(30) class RecordedRequestTest { private val headers: Headers = EMPTY_HEADERS @Test fun testIPv4() { val socket =
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.1K bytes - Viewed (0) -
cmd/batch-handlers_gen_test.go
v := BatchJobRequest{} 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 BenchmarkDecodeBatchJobRequest(b *testing.B) { v := BatchJobRequest{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len()))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 29 18:27:23 GMT 2023 - 4.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt
@Throws(IOException::class) override fun configureSocket(socket: Socket): Socket { socket.sendBufferSize = SOCKET_BUFFER_SIZE socket.receiveBufferSize = SOCKET_BUFFER_SIZE return socket } }, ) .sslSocketFactory( handshakeCertificates.sslSocketFactory(),
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 9.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/ThreadInterruptTest.kt
serverSocket.setReceiveBufferSize(SOCKET_BUFFER_SIZE) return serverSocket } } client = clientTestRule.newClientBuilder() .socketFactory( object : DelegatingSocketFactory(getDefault()) { @Throws(IOException::class) override fun configureSocket(socket: Socket): Socket { socket.setSendBufferSize(SOCKET_BUFFER_SIZE)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RequestBodyTest.kt
assertOnFileDescriptor(content = "Hello") { fd -> val requestBody = fd.toRequestBody() val buffer = Buffer() requestBody.writeTo(buffer) assertThat(buffer.readUtf8()).isEqualTo("Hello") assertThrows(IOException::class.java) { requestBody.writeTo(Buffer()) } } } @Test fun testFileDescriptorAfterClose() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.6K bytes - Viewed (1) -
maven-builder-support/src/main/java/org/apache/maven/building/DefaultProblem.java
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Mon Feb 26 17:04:44 GMT 2024 - 4.3K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/tree/Smb2TreeConnectResponse.java
@Override protected int readBytesWireFormat ( byte[] buffer, int bufferIndex ) throws SMBProtocolDecodingException { int start = bufferIndex; int structureSize = SMBUtil.readInt2(buffer, bufferIndex); if ( structureSize != 16 ) { throw new SMBProtocolDecodingException("Structure size is not 16"); } this.shareType = buffer[ bufferIndex + 2 ]; bufferIndex += 4;
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Mon May 23 14:35:20 GMT 2022 - 6.1K bytes - Viewed (0)