- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for peekKey (0.18 sec)
-
src/main/java/jcifs/util/transport/Transport.java
synchronized ( this.inLock ) { Long peekKey = peekKey(); if ( peekKey == firstKey ) { doRecv(response); response.received(); return response; } doSkip(peekKey); } }
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Nov 01 18:12:21 GMT 2020 - 24.1K bytes - Viewed (0) -
src/main/java/jcifs/smb1/util/transport/Transport.java
Thread thread; TransportException te; protected HashMap response_map = new HashMap( 4 ); protected abstract void makeKey( Request request ) throws IOException; protected abstract Request peekKey() throws IOException; protected abstract void doSend( Request request ) throws IOException; protected abstract void doRecv( Response response ) throws IOException; protected abstract void doSkip() throws IOException;
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 20:39:42 GMT 2019 - 9K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbTransport.java
out.write( sbuf, 0, 4 + n ); out.flush(); /* Note the Transport thread isn't running yet so we can * read from the socket here. */ if (peekKey() == null) /* try to read header */ throw new IOException( "transport closed in negotiate" ); int size = Encdec.dec_uint16be( sbuf, 2 ) & 0xFFFF;
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 31.2K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTransportImpl.java
* read from the socket here. */ try { this.socket.setSoTimeout(this.transportContext.getConfig().getConnTimeout()); if ( peekKey() == null ) /* try to read header */ throw new IOException("transport closed in negotiate"); } finally { this.socket.setSoTimeout(this.transportContext.getConfig().getSoTimeout());
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Wed Jan 18 23:47:00 GMT 2023 - 67K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
throws Exception { closer.eventuallyClose(closeable1, closingExecutor); assertThat(peeker.getDone(input1)).isSameInstanceAs("value1"); try { peeker.getDone(input2Failed); fail("Peeker should fail for failed inputs");
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 75.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
throws Exception { closer.eventuallyClose(closeable1, closingExecutor); assertThat(peeker.getDone(input1)).isSameInstanceAs("value1"); try { peeker.getDone(input2Failed); fail("Peeker should fail for failed inputs");
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 74.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 98.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-ResponseCommon.kt
): String? = headers[name] ?: defaultValue @Throws(IOException::class) fun Response.commonPeekBody(byteCount: Long): ResponseBody { val peeked = body.source().peek() val buffer = Buffer() peeked.request(byteCount) buffer.write(peeked, minOf(byteCount, peeked.buffer.size)) return buffer.asResponseBody(body.contentType(), buffer.size) } fun Response.commonNewBuilder(): Response.Builder = Response.Builder(this)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:24:48 GMT 2024 - 5.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Response.kt
* a modest limit on `byteCount`, such as 1 MiB. */ @Throws(IOException::class) fun peekBody(byteCount: Long): ResponseBody { val peeked = body.source().peek() val buffer = Buffer() peeked.request(byteCount) buffer.write(peeked, minOf(byteCount, peeked.buffer.size)) return buffer.asResponseBody(body.contentType(), buffer.size) } @JvmName("-deprecated_body") @Deprecated(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 15.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/HttpHeaders.kt
while (true) { if (peek == null) { peek = readToken() if (skipCommasAndWhitespace()) break // We peeked a scheme name followed by ','. eqCount = skipAll('='.code.toByte()) } if (eqCount == 0) break // We peeked a scheme name. if (eqCount > 1) return // Unexpected '=' characters. if (skipCommasAndWhitespace()) return // Unexpected ','.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.2K bytes - Viewed (0)