- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 127 for newOff (0.22 sec)
-
cmd/xl-storage-free-version_test.go
t.Fatalf("Expected zero free version but got %d", len(freeVersions)) } report() // Adding a free version to a version with no tiered content. newfi := fi newfi.SetTierFreeVersionID("00000000-0000-0000-0000-0000000000f3") fatalErr(xl.AddFreeVersion(newfi)) // this shouldn't add a free-version report() // Check number of free-versions freeVersions, err = xl.listFreeVersions(newtierfi.Volume, newtierfi.Name)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Mar 02 05:11:03 UTC 2024 - 7.8K bytes - Viewed (0) -
src/net/ipsock_plan9.go
} laddr, err = readPlan9Addr(net, netdir+"/"+proto+"/"+name+"/local") if err != nil { f.Close() return nil, err } return newFD(proto, name, nil, f, nil, laddr, nil) } func (fd *netFD) netFD() (*netFD, error) { return newFD(fd.net, fd.n, fd.listen, fd.ctl, fd.data, fd.laddr, fd.raddr) } func (fd *netFD) acceptPlan9() (nfd *netFD, err error) { defer func() { fixErr(err) }()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Aug 29 20:38:53 UTC 2023 - 7.5K bytes - Viewed (0) -
pkg/controller/garbagecollector/graph_builder.go
isUnblocked := c.newRef.BlockOwnerDeletion == nil || (c.newRef.BlockOwnerDeletion != nil && !*c.newRef.BlockOwnerDeletion) if wasBlocked && isUnblocked { node, found := gb.uidToNode.Read(c.newRef.UID) if !found { logger.V(5).Info("cannot find uid in uidToNode", "uid", c.newRef.UID) continue } gb.attemptToDelete.Add(node) } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.9K bytes - Viewed (0) -
src/encoding/json/stream.go
dec.buf = dec.buf[:n] dec.scanp = 0 } // Grow buffer if not large enough. const minRead = 512 if cap(dec.buf)-len(dec.buf) < minRead { newBuf := make([]byte, len(dec.buf), 2*cap(dec.buf)+minRead) copy(newBuf, dec.buf) dec.buf = newBuf } // Read. Delay error for next iteration (after scan). n, err := dec.r.Read(dec.buf[len(dec.buf):cap(dec.buf)]) dec.buf = dec.buf[0 : len(dec.buf)+n]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 08 19:04:28 UTC 2023 - 12.9K bytes - Viewed (0) -
pkg/test/loadbalancersim/loadbalancer/leastrequest.go
func newWeightedLeastRequest(conn *weightedConnections, activeRequestBias float64) network.Connection { lb := &weightedLeastRequest{ weightedConnections: conn, activeRequestBias: activeRequestBias, edf: NewEDF(), } // Add all endpoints to the EDF scheduler. for _, c := range conn.conns { lb.edf.Add(lb.calcEDFWeight(0, c), c) } return lb }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Nov 14 20:23:34 UTC 2022 - 3.4K bytes - Viewed (0) -
src/net/fd_unix.go
const ( readSyscallName = "read" readFromSyscallName = "recvfrom" readMsgSyscallName = "recvmsg" writeSyscallName = "write" writeToSyscallName = "sendto" writeMsgSyscallName = "sendmsg" ) func newFD(sysfd, family, sotype int, net string) (*netFD, error) { ret := &netFD{ pfd: poll.FD{ Sysfd: sysfd, IsStream: sotype == syscall.SOCK_STREAM,
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/crypto/cipher/cipher_test.go
cfbd.XORKeyStream(ct, pt[:0]) assertEqual("CFB decrypt", ct, pt) ctr := cipher.NewCTR(b, iv) ctr.XORKeyStream(ct, pt[:0]) assertEqual("CTR", ct, pt) ofb := cipher.NewOFB(b, iv) ofb.XORKeyStream(ct, pt[:0]) assertEqual("OFB", ct, pt) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 13 21:42:23 UTC 2016 - 2.2K bytes - Viewed (0) -
src/syscall/net_js.go
} func Bind(fd int, sa Sockaddr) error { return ENOSYS } func StopIO(fd int) error { return ENOSYS } func Listen(fd int, backlog int) error { return ENOSYS } func Accept(fd int) (newfd int, sa Sockaddr, err error) { return 0, nil, ENOSYS } func Connect(fd int, sa Sockaddr) error { return ENOSYS } func Recvfrom(fd int, p []byte, flags int) (n int, from Sockaddr, err error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 25 00:12:41 UTC 2023 - 1.4K bytes - Viewed (0) -
cmd/kubeadm/app/phases/upgrade/staticpods_test.go
t.Fatalf("couldn't read temp file: %v", err) } newcfg, err := getConfig(constants.CurrentKubernetesVersion.String(), tempCertsDir, tmpEtcdDataDir) if err != nil { t.Fatalf("couldn't create config: %v", err) } // create the kubeadm etcd certs caCert, caKey, err := certsphase.KubeadmCertEtcdCA().CreateAsCA(newcfg) if err != nil { t.Fatalf("couldn't create new CA certificate: %v", err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 32K bytes - Viewed (0) -
src/net/fd_windows.go
func canUseConnectEx(net string) bool { switch net { case "tcp", "tcp4", "tcp6": return true } // ConnectEx windows API does not support connectionless sockets. return false } func newFD(sysfd syscall.Handle, family, sotype int, net string) (*netFD, error) { ret := &netFD{ pfd: poll.FD{ Sysfd: sysfd, IsStream: sotype == syscall.SOCK_STREAM,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 07 16:46:10 UTC 2024 - 6.2K bytes - Viewed (0)