- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 402 for isopen (0.22 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
/** * Returns true if this stream is open. A stream is open until either: * * * A `SYN_RESET` frame abnormally terminates the stream. * * Both input and output streams have transmitted all data and headers. * * Note that the input stream may continue to yield data even after a stream reports itself as * not open. This is because input data is buffered. */ val isOpen: Boolean get() {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
src/main/java/jcifs/smb/SmbFileOutputStream.java
} /** * @return whether the stream is open */ public boolean isOpen () { return this.handle != null && this.handle.isValid(); } protected synchronized SmbFileHandleImpl ensureOpen () throws CIFSException { if ( !isOpen() ) { // one extra acquire to keep this open till the stream is released
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Sat Nov 13 15:14:04 GMT 2021 - 11.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
} else { writePing(false, INTERVAL_PING, 0) return@schedule pingIntervalNanos } } } } /** * Returns the number of [open streams][Http2Stream.isOpen] on this connection. */ fun openStreamCount(): Int = this.withLock { streams.size } fun getStream(id: Int): Http2Stream? = this.withLock { streams[id] }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTreeImpl.java
private volatile int tid = -1; private volatile String service = "?????"; private volatile boolean inDfs, inDomainDfs; private volatile long treeNum; // used by SmbFile.isOpen private final AtomicLong usageCount = new AtomicLong(0); private final AtomicBoolean sessionAcquired = new AtomicBoolean(true); private final boolean traceResource;
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Thu Jan 05 13:06:39 GMT 2023 - 29.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
} sink1.writeUtf8("def") sink1.close() assertFailsWith<ConnectionShutdownException> { connection.newStream(headerEntries("c", "cola"), true) } assertThat(stream1.isOpen).isTrue() assertThat(stream2.isOpen).isFalse() assertThat(connection.openStreamCount()).isEqualTo(1) // Verify the peer received what was expected. val synStream1 = peer.takeFrame()
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/smb1/smb1/SmbFile.java
} return f; } void open( int flags, int access, int attrs, int options ) throws SmbException { if( isOpen() ) { return; } fid = open0( flags, access, attrs, options ); opened = true; tree_num = tree.tree_num; } boolean isOpen() { boolean ans = opened && isConnected() && tree_num == tree.tree_num;
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Mon Mar 13 12:00:57 GMT 2023 - 107.9K bytes - Viewed (2) -
okhttp-android/src/main/baseline-prof.txt
HSPLokhttp3/internal/http2/Http2Stream;->getSink()Lokio/Sink; HSPLokhttp3/internal/http2/Http2Stream;->isLocallyInitiated()Z HSPLokhttp3/internal/http2/Http2Stream;->isOpen()Z HSPLokhttp3/internal/http2/Http2Stream;->receiveHeaders(Lokhttp3/Headers;Z)V HSPLokhttp3/internal/http2/Http2Stream;->waitForIo$okhttp()V HSPLokhttp3/internal/http2/Http2Writer;-><clinit>()V
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Mar 21 11:22:00 GMT 2022 - 127.9K bytes - Viewed (0) -
internal/ioutil/read_file.go
"io" "io/fs" "os" "github.com/minio/minio/internal/disk" ) var ( // OpenFileDirectIO allows overriding default function. OpenFileDirectIO = disk.OpenFileDirectIO // OsOpen allows overriding default function. OsOpen = os.Open // OsOpenFile allows overriding default function. OsOpenFile = os.OpenFile ) // ReadFileWithFileInfo reads the named file and returns the contents.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Dec 09 18:17:51 GMT 2023 - 2.3K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceRecorder.kt
private val events = LinkedBlockingDeque<Any>() private var cancel = false fun enqueueCancel() { cancel = true } override fun onOpen( eventSource: EventSource, response: Response, ) { get().log("[ES] onOpen", Platform.INFO, null) events.add(Open(eventSource, response)) drainCancelQueue(eventSource) } override fun onEvent( eventSource: EventSource, id: String?,
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.1K bytes - Viewed (0) -
src/cmd/cgo/internal/swig/testdata/stdio/main.go
"os" ) func F() int { return int(C.F()) } func main() { if x := int(C.F()); x != 1 { fatal("x = %d, want 1", x) } // Open this file itself and verify that the first few characters are // as expected. f := Fopen("main.go", "r") if f.Swigcptr() == 0 { fatal("fopen failed") } if Fgetc(f) != '/' || Fgetc(f) != '/' || Fgetc(f) != ' ' || Fgetc(f) != 'C' { fatal("read unexpected characters") }
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Fri May 12 12:00:07 GMT 2023 - 975 bytes - Viewed (0)