- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,693 for close1 (0.1 sec)
-
src/internal/poll/fd_unix.go
} // Close closes the FD. The underlying file descriptor is closed by the // destroy method when there are no remaining references. func (fd *FD) Close() error { if !fd.fdmu.increfAndClose() { return errClosing(fd.isFile) } // Unblock any I/O. Once it all unblocks and returns, // so that it cannot be referring to fd.sysfd anymore, // the final decref will close fd.sysfd. This should happen
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 04:09:44 UTC 2024 - 17.9K bytes - Viewed (0) -
pkg/xds/server.go
} } } func Receive(ctx ConnectionContext) { con := ctx.XdsConnection() defer func() { close(con.errorChan) close(con.reqChan) // Close the initialized channel, if its not already closed, to prevent blocking the stream. select { case <-con.initialized: default: close(con.initialized) } }() firstRequest := true for { req, err := con.stream.Recv()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0) -
platforms/core-execution/build-cache-local/src/main/java/org/gradle/caching/local/internal/DirectoryBuildCache.java
tempFileStore.withTempFile(key, file -> { try { Closer closer = Closer.create(); try { result.accept(closer.register(new FileOutputStream(file))); } catch (Exception e) { throw closer.rethrow(e); } finally { closer.close(); } } catch (IOException ex) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:53 UTC 2024 - 7K bytes - Viewed (0) -
src/test/java/org/codelibs/core/io/CloseableUtilTest.java
CloseableUtil.close(out); } private static class NotifyOutputStream extends OutputStream { private String notify_; @Override public void write(final int arg0) throws IOException { } @Override public void close() throws IOException { super.close(); notify_ = "closed"; }
Registered: Wed Jun 12 12:50:12 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 2.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
} } /** * Closes this connection. This cancels all open streams and unanswered pings. It closes the * underlying input and output streams and shuts down internal task queues. */ override fun close() { close(ErrorCode.NO_ERROR, ErrorCode.CANCEL, null) } internal fun close( connectionCode: ErrorCode, streamCode: ErrorCode,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0) -
pilot/pkg/server/instance_test.go
} }) } } type reclosableChannel struct { c chan struct{} closed bool } func newReclosableChannel() *reclosableChannel { return &reclosableChannel{ c: make(chan struct{}), } } func (c *reclosableChannel) Close() { if !c.closed { c.closed = true close(c.c) } } type fakeComponent struct { started *atomic.Bool completed *atomic.Bool
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 23:02:39 UTC 2024 - 4.1K bytes - Viewed (0) -
cmd/bitrot-streaming.go
} func (b *streamingBitrotReader) Close() error { if b.rc == nil { return nil } if closer, ok := b.rc.(io.Closer); ok { // drain the body for connection reuse at network layer. xhttp.DrainBody(struct { io.Reader io.Closer }{ Reader: b.rc, Closer: closeWrapper(func() error { return nil }), }) return closer.Close() } return nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 6.1K bytes - Viewed (0) -
internal/event/target/postgresql.go
} // Delete the event from store. return target.store.Del(key.Name) } // 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 Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 13.3K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/service/DefaultServiceRegistryTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:53:25 UTC 2024 - 59.8K bytes - Viewed (0) -
src/net/dial_test.go
addr := ln.Addr().String() conn1, err := Dial(network, addr) if err != nil { ln.Close() t.Fatal(err) } defer conn1.Close() // Now close the listener so the next Dial fails // keeping conn1 alive so the port is not made // available. ln.Close() maxElapsed := time.Second // The host can be heavy-loaded and take // longer than configured. Retry until
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 30.3K bytes - Viewed (0)