- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 236 for proc (0.05 sec)
-
src/os/exec_plan9.go
if e != nil { return nil, &PathError{Op: "fork/exec", Path: name, Err: e} } return newPIDProcess(pid), nil } func (p *Process) writeProcFile(file string, data string) error { f, e := OpenFile("/proc/"+itoa.Itoa(p.Pid)+"/"+file, O_WRONLY, 0) if e != nil { return e } defer f.Close() _, e = f.Write([]byte(data)) return e } func (p *Process) signal(sig Signal) error { switch p.pidStatus() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 22:06:47 UTC 2024 - 3.4K bytes - Viewed (0) -
src/os/pidfd_linux.go
// execution environment in which the above system calls are restricted by // seccomp or a similar technology. func checkPidfd() error { // Get a pidfd of the current process (opening of "/proc/self" won't // work for waitid). fd, err := unix.PidFDOpen(syscall.Getpid(), 0) if err != nil { return NewSyscallError("pidfd_open", err) } defer syscall.Close(int(fd))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 18:08:44 UTC 2024 - 4.2K bytes - Viewed (0) -
src/cmd/trace/goroutinegen.go
} func (g *goroutineGenerator) ProcRange(ctx *traceContext, ev *trace.Event) { // TODO(mknyszek): Extend procRangeGenerator to support rendering proc ranges // that overlap with a goroutine's execution. } func (g *goroutineGenerator) ProcTransition(ctx *traceContext, ev *trace.Event) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 4.6K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager_linux.go
func isProcessRunningInHost(pid int) (bool, error) { // Get init pid namespace. initPidNs, err := os.Readlink("/proc/1/ns/pid") if err != nil { return false, fmt.Errorf("failed to find pid namespace of init process") } klog.V(10).InfoS("Found init PID namespace", "namespace", initPidNs) processPidNs, err := os.Readlink(fmt.Sprintf("/proc/%d/ns/pid", pid)) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 35.1K bytes - Viewed (0) -
src/syscall/syscall_linux_test.go
expected := filter + expect pid := syscall.Getpid() fs, err := os.ReadDir(fmt.Sprintf("/proc/%d/task", pid)) if err != nil { return fmt.Errorf("unable to find %d tasks: %v", pid, err) } expectedProc := fmt.Sprintf("Pid:\t%d", pid) foundAThread := false for _, f := range fs { tf := fmt.Sprintf("/proc/%s/status", f.Name()) d, err := os.ReadFile(tf) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 23K bytes - Viewed (0) -
src/runtime/runtime2.go
pidle puintptr // idle p's npidle atomic.Int32 nmspinning atomic.Int32 // See "Worker thread parking/unparking" comment in proc.go. needspinning atomic.Uint32 // See "Delicate dance" comment in proc.go. Boolean. Must hold sched.lock to set to 1. // Global runnable queue. runq gQueue runqsize int32 // disable controls selective disabling of the scheduler. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 47.9K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container_linux.go
// memory.swap.max does not exist in the cgroup root, so we check /sys/fs/cgroup/<SELF>/memory.swap.max _, unified, err := cgroups.ParseCgroupFileUnified("/proc/self/cgroup") if err != nil { klog.V(5).ErrorS(fmt.Errorf("failed to parse /proc/self/cgroup: %w", err), warn) return } p = filepath.Join("/sys/fs/cgroup", unified, "memory.swap.max") } if _, err := os.Stat(p); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 17.2K bytes - Viewed (0) -
cmd/kubeadm/app/preflight/checks.go
func (poc PortOpenCheck) Name() string { if poc.label != "" { return poc.label } return fmt.Sprintf("Port-%d", poc.port) } // Check validates if the particular port is available. func (poc PortOpenCheck) Check() (warnings, errorList []error) { klog.V(1).Infof("validating availability of port %d", poc.port)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 03 11:20:55 UTC 2024 - 39.5K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
return nil, fmt.Errorf("error initializing the host rules for health checks: %w", err) } podNetns := NewPodNetnsProcFinder(os.DirFS(filepath.Join(pconstants.HostMountsPath, "proc"))) netServer := newNetServer(ztunnelServer, podNsMap, iptablesConfigurator, podNetns, set) // Set some defaults s := &Server{ ctx: ctx, kubeClient: client, isReady: ready,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 21:45:18 UTC 2024 - 7.2K bytes - Viewed (0) -
pkg/volume/nfs/nfs.go
*nfs } func (c *nfsUnmounter) TearDown() error { return c.TearDownAt(c.GetPath()) } func (c *nfsUnmounter) TearDownAt(dir string) error { // Use extensiveMountPointCheck to consult /proc/mounts. We can't use faster // IsLikelyNotMountPoint (lstat()), since there may be root_squash on the // NFS server and kubelet may not be able to do lstat/stat() there.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 9.5K bytes - Viewed (0)