- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 3,889 for close1 (0.08 sec)
-
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/continuous/CancellationContinuousIntegrationTest.groovy
then: cancelsAndExits() } def "should cancel build when System.in is closed"() { given: succeeds("build") when: gradle.stdinPipe.close() then: cancelsAndExits() } def "should cancel build when System.in contains some other characters, then closes"() { when: succeeds("build") stdinPipe << 'abc' then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 2.5K bytes - Viewed (0) -
src/database/sql/sql_test.go
} dc := db.freeConn[0] if dc.closed { t.Errorf("conn shouldn't be closed") } if n := len(dc.openStmt); n != 1 { t.Errorf("driverConn num openStmt = %d; want 1", n) } err = db.Close() if err != nil { t.Errorf("db Close = %v", err) } if !dc.closed { t.Errorf("after db.Close, driverConn should be closed") } if n := len(dc.openStmt); n != 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 111.6K bytes - Viewed (0) -
src/database/sql/driver/driver.go
// used by multiple goroutines concurrently. type Stmt interface { // Close closes the statement. // // As of Go 1.1, a Stmt will not be closed if it's in use // by any queries. // // Drivers must ensure all network calls made by Close // do not block indefinitely (e.g. apply a timeout). Close() error // NumInput returns the number of placeholder parameters. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Oct 23 09:04:12 UTC 2023 - 20.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/connection.go
const createStreamResponseTimeout = 30 * time.Second // Close first sends a reset for all of the connection's streams, and then // closes the underlying spdystream.Connection. func (c *connection) Close() error { c.streamLock.Lock() for _, s := range c.streams { // calling Reset instead of Close ensures that all streams are fully torn down s.Reset() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 01 15:04:07 UTC 2021 - 6.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
) { check(!closed) { "closed" } checkOffsetAndCount(source.size, 0, byteCount) sink.write(source, byteCount) } override fun flush() { if (closed) return // Don't throw; this stream might have been closed on the caller's behalf. sink.flush() } override fun close() { if (closed) return closed = true detachTimeout(timeout)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 16.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/httpstream.go
CreateStream(headers http.Header) (Stream, error) // Close resets all streams and closes the connection. Close() error // CloseChan returns a channel that is closed when the underlying connection is closed. CloseChan() <-chan bool // SetIdleTimeout sets the amount of time the connection may remain idle before // it is automatically closed. SetIdleTimeout(timeout time.Duration)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:33:38 UTC 2023 - 6.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ResponseBody.kt
* must close this body by calling any of the following methods: * * * `Response.close()` * * `Response.body().close()` * * `Response.body().source().close()` * * `Response.body().charStream().close()` * * `Response.body().byteStream().close()` * * `Response.body().bytes()` * * `Response.body().string()` * * There is no benefit to invoking multiple `close()` methods for the same response body. *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
// we find them, regardless of what the address policies need. // // 2. EVICTABLE: Connections not required by any address policy. This matches connections that // don't participate in any policy, plus connections whose policies won't be violated if the // connection is closed. We only close these if the idle connection limit is exceeded. //
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/hbone/util.go
} if ew != nil { return } } if err != nil { // read is already closed - we need to close out _ = closeWriter(dst) return } } } // CloseWriter is one of possible interfaces implemented by Out to send a FIN, without closing // the input. Some writers only do this when Close is called. type CloseWriter interface { CloseWrite() error } func closeWriter(dst io.Writer) error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 3.4K bytes - Viewed (0) -
src/database/sql/sql.go
si driver.Stmt closed bool closeErr error // return value of previous Close call } // Close ensures driver.Stmt is only closed once and always returns the same // result. func (ds *driverStmt) Close() error { ds.Lock() defer ds.Unlock() if ds.closed { return ds.closeErr } ds.closed = true ds.closeErr = ds.si.Close() return ds.closeErr }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:53 UTC 2024 - 103.6K bytes - Viewed (0)