- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 55 for sysfs (0.06 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/chain_test.go
} } func TestAdmitAndValidate(t *testing.T) { sysns := metav1.NamespaceSystem otherns := "default" tests := []struct { name string ns string operation Operation options runtime.Object chain chainAdmissionHandler accept bool calls map[string]bool }{ { name: "all accept", ns: sysns, operation: Create, options: &metav1.CreateOptions{},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 20 15:11:00 UTC 2019 - 5.4K bytes - Viewed (0) -
src/internal/poll/sendfile_linux.go
}() if err := dstFD.writeLock(); err != nil { return 0, err, false } defer dstFD.writeUnlock() if err := dstFD.pd.prepareWrite(dstFD.isFile); err != nil { return 0, err, false } dst := dstFD.Sysfd for remain > 0 { n := maxSendfileSize if int64(n) > remain { n = int(remain) } n, err = syscall.Sendfile(dst, src, nil, n) if n > 0 { written += int64(n) remain -= int64(n) continue
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 18:12:56 UTC 2024 - 1.4K bytes - Viewed (0) -
src/internal/poll/fd_windows_test.go
Err error } var ( logMu sync.Mutex loggedFDs map[syscall.Handle]*loggedFD ) func logFD(net string, fd *poll.FD, err error) { logMu.Lock() defer logMu.Unlock() loggedFDs[fd.Sysfd] = &loggedFD{ Net: net, FD: fd, Err: err, } } func init() { loggedFDs = make(map[syscall.Handle]*loggedFD) *poll.LogInitFD = logFD poll.InitWSA() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Feb 14 08:33:36 UTC 2024 - 4.3K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.6.md
#### vSphere * Reverts to looking up the current VM in vSphere using the machine's UUID, either obtained via sysfs or via the `vm-uuid` parameter in the cloud configuration file. ([#40892](https://github.com/kubernetes/kubernetes/pull/40892), [@robdaemon](https://github.com/robdaemon))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 24 02:28:26 UTC 2020 - 304K bytes - Viewed (0) -
src/internal/poll/sockopt_windows.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Aug 30 19:09:46 UTC 2023 - 586 bytes - Viewed (0) -
src/net/tcpconn_keepalive_test.go
testPreHookSetKeepAlive = func(*netFD) {} }) var ( errHook error oldCfg KeepAliveConfig ) testPreHookSetKeepAlive = func(nfd *netFD) { oldCfg, errHook = getCurrentKeepAliveSettings(fdType(nfd.pfd.Sysfd)) } handler := func(ls *localServer, ln Listener) { for { c, err := ln.Accept() if err != nil { return } c.Close() } } ln := newLocalListener(t, "tcp", &ListenConfig{
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 03:10:07 UTC 2024 - 4.2K bytes - Viewed (0) -
src/internal/poll/sendfile_bsd.go
}() if err := dstFD.writeLock(); err != nil { return 0, err, false } defer dstFD.writeUnlock() if err := dstFD.pd.prepareWrite(dstFD.isFile); err != nil { return 0, err, false } dst := dstFD.Sysfd for remain > 0 { n := maxSendfileSize if int64(n) > remain { n = int(remain) } pos1 := pos n, err = syscall.Sendfile(dst, src, &pos1, n) if n > 0 { pos += int64(n) written += int64(n)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 18:12:56 UTC 2024 - 1.5K bytes - Viewed (0) -
src/internal/poll/sock_cloexec_solaris.go
return -1, nil, "accept4", err } return ns, sa, "", nil } // See ../syscall/exec_unix.go for description of ForkLock. // It is probably okay to hold the lock across syscall.Accept // because we have put fd.sysfd into non-blocking mode. // However, a call to the File method will put it back into // blocking mode. We can't take that risk, so no use of ForkLock here. ns, sa, err := AcceptFunc(s) if err == nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Apr 14 18:17:25 UTC 2024 - 1.5K bytes - Viewed (0) -
src/os/readfrom_linux_test.go
} func (h *copyFileRangeHook) install() { h.original = *PollCopyFileRangeP *PollCopyFileRangeP = func(dst, src *poll.FD, remain int64) (int64, bool, error) { h.called = true h.dstfd = dst.Sysfd h.srcfd = src.Sysfd h.remain = remain h.written, h.handled, h.err = h.original(dst, src, remain) return h.written, h.handled, h.err } } func (h *copyFileRangeHook) uninstall() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 21:49:26 UTC 2024 - 20.3K bytes - Viewed (0) -
src/internal/poll/sys_cloexec.go
func accept(s int) (int, syscall.Sockaddr, string, error) { // See ../syscall/exec_unix.go for description of ForkLock. // It is probably okay to hold the lock across syscall.Accept // because we have put fd.sysfd into non-blocking mode. // However, a call to the File method will put it back into // blocking mode. We can't take that risk, so no use of ForkLock here. ns, sa, err := AcceptFunc(s) if err == nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 07 23:34:17 UTC 2023 - 1.1K bytes - Viewed (0)