- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 1,754 for closeFn (0.2 sec)
-
pkg/keepalive/options.go
// After having pinged for keepalive check, the server waits for a duration of Timeout and if no activity is seen even after that // the connection is closed. Timeout time.Duration // MaxServerConnectionAge is a duration for the maximum amount of time a // connection may exist before it will be closed by the server sending a GoAway. // A random jitter is added to spread out connection storms.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 3.9K bytes - Viewed (0) -
README.md
**For more information, please visit the [official project homepage](https://gradle.org)** ## Getting Started
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sun Mar 24 20:49:08 UTC 2024 - 3.9K bytes - Viewed (0) -
src/net/rpc/jsonrpc/all_test.go
} type pipeAddr int func (pipeAddr) Network() string { return "pipe" } func (pipeAddr) String() string { return "pipe" } func (p *pipe) Close() error { err := p.PipeReader.Close() err1 := p.PipeWriter.Close() if err == nil { err = err1 } return err } func (p *pipe) LocalAddr() net.Addr { return pipeAddr(0) } func (p *pipe) RemoteAddr() net.Addr {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Sep 07 01:09:53 UTC 2022 - 7.8K bytes - Viewed (0) -
src/cmd/internal/objabi/pkgspecial.go
NoRaceFunc bool // AllowAsmABI indicates that assembly in this package is allowed to use ABI // selectors in symbol names. Generally this is needed for packages that // interact closely with the runtime package or have performance-critical // assembly. AllowAsmABI bool } var runtimePkgs = []string{ "runtime", "internal/runtime/atomic", "internal/runtime/exithook",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 02:32:19 UTC 2024 - 3.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/poll.go
// poller returns a WaitFunc that will send to the channel every interval until // timeout has elapsed and then closes the channel. // // Over very short intervals you may receive no ticks before the channel is // closed. A timeout of 0 is interpreted as an infinity, and in such a case // it would be the caller's responsibility to close the done channel. // Failure to do so would result in a leaked goroutine. //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 26 06:13:35 UTC 2023 - 14K 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) -
.github/workflows/stale-issues.yml
It will be closed if no further activity occurs. Thank you. close-issue-message: > This issue was closed because it has been inactive for 7 days since being marked as stale. Please reopen if you'd like to work on this further. days-before-pr-stale: 14 days-before-pr-close: 14
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Nov 23 20:04:38 UTC 2023 - 4.1K bytes - Viewed (0) -
src/cmd/go/internal/lockedfile/internal/filelock/filelock_test.go
defer remove() rLock(t, f) f2 := mustOpen(t, f.Name()) defer f2.Close() doUnlockTF := false switch runtime.GOOS { case "aix", "solaris": // When using POSIX locks (as on Solaris), we can't safely read-lock the // same inode through two different descriptors at the same time: when the // first descriptor is closed, the second descriptor would still be open but
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 06 22:37:50 UTC 2023 - 4K bytes - Viewed (0) -
src/net/internal/socktest/sys_unix.go
if so.Err == nil { syscall.Close(s) } return -1, err } sw.smu.Lock() defer sw.smu.Unlock() if so.Err != nil { sw.stats.getLocked(so.Cookie).OpenFailed++ return -1, so.Err } nso := sw.addLocked(s, family, sotype, proto) sw.stats.getLocked(nso.Cookie).Opened++ return s, nil } // Close wraps syscall.Close. func (sw *Switch) Close(s int) (err error) { so := sw.sockso(s)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 4K bytes - Viewed (0) -
src/runtime/testdata/testprogcgo/eintr.go
return } log.Fatal(err) } wg.Add(2) go func() { defer wg.Done() defer ln.Close() c, err := ln.Accept() if err != nil { log.Fatal(err) } defer c.Close() cf, err := c.(*net.TCPConn).File() if err != nil { log.Fatal(err) } defer cf.Close() if err := syscall.SetNonblock(int(cf.Fd()), false); err != nil { log.Fatal(err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 05 17:54:15 UTC 2022 - 5.2K bytes - Viewed (0)