- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 737 for chosen (0.11 sec)
-
mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt
* and [ShutdownOutputAtEnd] that close a socket after a response, and where there are * follow-up requests. The client is unblocked and free to continue as soon as it has received the * entire response body. If and when the client makes a subsequent request using a pooled socket the * server may not have had time to close the socket. The socket will be closed at an indeterminate
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 4.6K bytes - Viewed (0) -
src/main/java/jcifs/context/AbstractCIFSContext.java
return false; } /** * {@inheritDoc} * * * @see jcifs.CIFSContext#close() */ @Override public boolean close () throws CIFSException { if ( !this.closed ) { Runtime.getRuntime().removeShutdownHook(this); } return false; } /** * {@inheritDoc} *
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Tue Jul 07 10:50:16 UTC 2020 - 3.7K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/com/SmbComWriteAndX.java
this.off = off; this.dataLength = len; this.digest = null; /* * otherwise recycled commands * like writeandx will choke if session * closes in between */ } /** * @param writeMode * the writeMode to set */
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 5.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
this.withLock { cancel = !source.finished && source.closed && (sink.finished || sink.closed) open = isOpen } if (cancel) { // RST this stream to prevent additional data from being sent. This is safe because the input // stream is closed (we won't use any further bytes) and the output stream is either finished // or closed (so RSTing both streams doesn't cause harm).
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 23.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt
while (true) { if (closed) throw IOException("closed") if (frameLength > 0L) { source.readFully(messageFrameBuffer, frameLength) if (!isClient) { messageFrameBuffer.readAndWriteUnsafe(maskCursor!!) maskCursor.seek(messageFrameBuffer.size - frameLength) toggleMask(maskCursor, maskKey!!) maskCursor.close() } }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 9.8K bytes - Viewed (0) -
guava/src/com/google/common/collect/RangeSet.java
* Range#isConnected(Range) disconnected} ranges of type {@code C}. * * <p>Implementations that choose to support the {@link #add(Range)} operation are required to * ignore empty ranges and coalesce connected ranges. For example: * * <pre>{@code * RangeSet<Integer> rangeSet = TreeRangeSet.create(); * rangeSet.add(Range.closed(1, 10)); // {[1, 10]} * rangeSet.add(Range.closedOpen(11, 15)); // disconnected range; {[1, 10], [11, 15)}
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 10.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache2/RelayTest.kt
val relay = edit(file, upstream, metadata, 1024) val source1 = relay.newSource() val source2 = relay.newSource() source1!!.close() source1.close() // Unnecessary. Shouldn't decrement the reference count. assertThat(relay.isClosed).isFalse() source2!!.close() assertThat(relay.isClosed).isTrue() assertFile(Relay.PREFIX_DIRTY, -1L, -1, null, null) } @Test fun racingReaders() {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 8.1K bytes - Viewed (0) -
docs/fr/docs/help-fastapi.md
* Lire d'autres idées, articles, et sur les outils que j'ai créés. * Suivez-moi pour lire quand je publie quelque chose de nouveau. ## Tweeter sur **FastAPI**
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Mon Jul 29 23:35:07 UTC 2024 - 5.7K bytes - Viewed (0) -
internal/event/target/postgresql.go
} // Delete the event from store. return target.store.Del(key) } // Close - closes underneath connections to PostgreSQL database. func (target *PostgreSQLTarget) Close() error { close(target.quitCh) if target.updateStmt != nil { // FIXME: log returned error. ignore time being. _ = target.updateStmt.Close() } if target.deleteStmt != nil { // FIXME: log returned error. ignore time being.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 13.3K bytes - Viewed (0) -
cmd/bitrot_test.go
} _, err = writer.Write([]byte("aaaaaaaaaa")) if err != nil { t.Fatal(err) } _, err = writer.Write([]byte("aaaaa")) if err != nil { t.Fatal(err) } if bw, ok := writer.(io.Closer); ok { bw.Close() } reader := newBitrotReader(disk, nil, volume, filePath, 35, bitrotAlgo, bitrotWriterSum(writer), 10) b := make([]byte, 10) if _, err = reader.ReadAt(b, 0); err != nil { t.Fatal(err) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jan 30 20:43:25 UTC 2024 - 2.1K bytes - Viewed (0)