- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 205 for Dup (0.17 sec)
-
src/cmd/go/scriptconds_test.go
// number of net tests that can run concurrently so that the overall number // of network connections won't exceed the limit. _, dup := scriptNetEnabled.LoadOrStore(t, true) if !dup { // Acquire a net token for this test until the test completes. netTestSem <- struct{}{} t.Cleanup(func() { <-netTestSem scriptNetEnabled.Delete(t) }) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Feb 21 22:16:54 UTC 2024 - 7.4K bytes - Viewed (0) -
src/net/fd_unix.go
netfd.setAddr(netfd.addrFunc()(lsa), netfd.addrFunc()(rsa)) return netfd, nil } // Defined in os package. func newUnixFile(fd int, name string) *os.File func (fd *netFD) dup() (f *os.File, err error) { ns, call, err := fd.pfd.Dup() if err != nil { if call != "" { err = os.NewSyscallError(call, err) } return nil, err } return newUnixFile(ns, fd.name()), nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 24 20:19:46 UTC 2023 - 5.4K bytes - Viewed (0) -
src/syscall/exec_libc2.go
} // Implemented in runtime package. func runtime_BeforeFork() func runtime_AfterFork() func runtime_AfterForkInChild() // Fork, dup fd onto 0..len(fd), and exec(argv0, argvv, envv) in child. // If a dup or exec fails, write the errno error to pipe. // (Pipe is close-on-exec so if exec succeeds, it will be closed.) // In the child, this function must not acquire any locks, because
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 29 18:51:35 UTC 2023 - 8.2K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/main/java/org/gradle/model/internal/manage/schema/extract/ManagedProxyClassGenerator.java
import static org.objectweb.asm.Opcodes.ASTORE; import static org.objectweb.asm.Opcodes.ATHROW; import static org.objectweb.asm.Opcodes.CHECKCAST; import static org.objectweb.asm.Opcodes.DCONST_0; import static org.objectweb.asm.Opcodes.DUP; import static org.objectweb.asm.Opcodes.FCONST_0; import static org.objectweb.asm.Opcodes.GETFIELD; import static org.objectweb.asm.Opcodes.GETSTATIC; import static org.objectweb.asm.Opcodes.GOTO;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 55.3K bytes - Viewed (0) -
src/syscall/exec_libc.go
// syscall defines this global on our behalf to avoid a build dependency on other platforms func init() { execveLibc = execve } // Fork, dup fd onto 0..len(fd), and exec(argv0, argvv, envv) in child. // If a dup or exec fails, write the errno error to pipe. // (Pipe is close-on-exec so if exec succeeds, it will be closed.) // In the child, this function must not acquire any locks, because
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 29 18:51:35 UTC 2023 - 8.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/api/meta/multirestmapper.go
// ignore "no match" errors, but any other error percolates back up if IsNoMatchError(err) { continue } if err != nil { return nil, err } // walk the existing values to de-dup for _, curr := range gvrs { found := false for _, existing := range allGVRs { if curr == existing { found = true break } } if !found { allGVRs = append(allGVRs, curr)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 05 23:44:02 UTC 2021 - 5.8K bytes - Viewed (0) -
src/cmd/go/internal/lockedfile/internal/filelock/filelock_fcntl.go
// unlock calls that refer to the same inode through different descriptors. fi, err := f.Stat() if err != nil { return err } ino := fi.Sys().(*syscall.Stat_t).Ino mu.Lock() if i, dup := inodes[f]; dup && i != ino { mu.Unlock() return &fs.PathError{ Op: lt.String(), Path: f.Name(), Err: errors.New("inode for file changed since last Lock or RLock"), } } inodes[f] = ino
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 17 02:24:35 UTC 2023 - 5.5K bytes - Viewed (0) -
src/go/constant/value_test.go
kind Kind arg, want any } func dup(k Kind, x any) makeTestCase { return makeTestCase{k, x, x} } func TestMake(t *testing.T) { for _, test := range []makeTestCase{ {Bool, false, false}, {String, "hello", "hello"}, {Int, int64(1), int64(1)}, {Int, big.NewInt(10), int64(10)}, {Int, new(big.Int).Lsh(big.NewInt(1), 62), int64(1 << 62)}, dup(Int, new(big.Int).Lsh(big.NewInt(1), 63)),
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Dec 13 18:45:54 UTC 2021 - 15.6K bytes - Viewed (0) -
src/net/tcpsock_plan9.go
ln.fd.ctl.Close() return err } if err := ln.fd.ctl.Close(); err != nil { return err } return nil } func (ln *TCPListener) file() (*os.File, error) { f, err := ln.dup() if err != nil { return nil, err } return f, nil } func (sl *sysListener) listenTCP(ctx context.Context, laddr *TCPAddr) (*TCPListener, error) { fd, err := listenPlan9(ctx, sl.network, laddr)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 2.3K bytes - Viewed (0) -
src/cmd/go/internal/mvs/graph.go
} // Truncate reqs to its capacity to avoid aliasing bugs if it is later // returned from RequiredBy and appended to. reqs = slices.Clip(reqs) if _, dup := g.required[m]; dup { panic(fmt.Sprintf("requirements of %v have already been set", m)) } g.required[m] = reqs for _, dep := range reqs { // Mark dep reachable, regardless of whether it is selected.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 01 02:52:19 UTC 2023 - 6.3K bytes - Viewed (0)