- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 1,629 for closeFn (0.13 sec)
-
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/chan.go
if c == nil { panic(plainError("close of nil channel")) } lock(&c.lock) if c.closed != 0 { unlock(&c.lock) panic(plainError("close of closed channel")) } if raceenabled { callerpc := getcallerpc() racewritepc(c.raceaddr(), callerpc, abi.FuncPCABIInternal(closechan)) racerelease(c.raceaddr()) } c.closed = 1 var glist gList
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:50 UTC 2024 - 25.9K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ContiguousSet.java
* (inclusive) to {@code upper} (inclusive). (These are the same values contained in {@code * Range.closed(lower, upper)}.) * * @throws IllegalArgumentException if {@code lower} is greater than {@code upper} * @since 23.0 */ public static ContiguousSet<Integer> closed(int lower, int upper) { return create(Range.closed(lower, upper), DiscreteDomain.integers()); } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Nov 30 21:54:06 UTC 2023 - 9.9K bytes - Viewed (0) -
src/internal/fuzz/sys_windows.go
sys: sharedMemSys{mapObj: mapObj}, }, nil } // Close unmaps the shared memory and closes the temporary file. If this // sharedMem was created with sharedMemTempFile, Close also removes the file. func (m *sharedMem) Close() error { // Attempt all operations, even if we get an error for an earlier operation. // os.File.Close may fail due to I/O errors, but we still want to delete // the temporary file.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jul 20 18:35:25 UTC 2023 - 4.5K bytes - Viewed (0)