// IsUnderPIDPressure returns true if the node is under PID pressure.
764445
func (m *managerImpl) IsUnderPIDPressure() bool {
	m.RLock()
	defer m.RUnlock()
	return hasNodeCondition(m.nodeConditions, v1.NodePIDPressure)
}
1255361
func (ctn *Connection) isIdle() bool {
	return ctn.idleTimeout > 0 && !time.Now().Before(ctn.idleDeadline)
}
575972
func StatusPID(pidFilename string) string {
	PIDFilename(&pidFilename)

	pid, current_status := ReadPIDFile(pidFilename)
	if current_status {
		return fmt.Sprintf("Running. PID: '%d'", pid)
	} else if pid == -1 {
		return fmt.Sprintf("Stopped.")
	} else {
		return fmt.Sprintf("Stopped. But PIDFile '%s' is present with PID '%d'.", pidFilename, pid)
	}
}
207338
func UpdatePIDFile(pidFilename string) bool {
	PIDFilename(&pidFilename)
	if _, err := os.Stat(pidFilename); err == nil {
		err := os.Remove(pidFilename)
		if err != nil {
			return false
		}
	}

	pid := strconv.Itoa(os.Getpid()) + "\n"
	return UpdateFile(pidFilename, pid)
}
877937
func GetPidsData(pid int, cgPath string) (*rspec.LinuxPids, error) {
	return nil, fmt.Errorf("unimplemented yet")
}
1241866
func _pidAlive(pid int) bool {
	proc, err := os.FindProcess(pid)
	if err == nil {
		err = proc.Signal(syscall.Signal(0))
	}

	return err == nil
}
1192310
func (s *TaskDefinition) SetPidMode(v string) *TaskDefinition {
	s.PidMode = &v
	return s
}
164147
func IsCompressedPubKey(pubKey []byte) bool {
	// The public key is only compressed if it is the correct length and
	// the format (first byte) is one of the compressed pubkey values.
	return len(pubKey) == PubKeyBytesLenCompressed &&
		(pubKey[0]&^byte(0x1) == pubkeyCompressed)
}
1267833
func (s StatusCode) IsProtocolDefined() bool {
	switch s {
	case StatusNormalClosure,
		StatusGoingAway,
		StatusProtocolError,
		StatusUnsupportedData,
		StatusInvalidFramePayloadData,
		StatusPolicyViolation,
		StatusMessageTooBig,
		StatusMandatoryExt,
		StatusInternalServerError,
		StatusNoStatusRcvd,
		StatusAbnormalClosure,
		StatusTLSHandshake:
		return true
	}
	return false
}
961375
func (s *holderSyncer) IsClosing() bool {
	if s.Cluster.abortAntiEntropyQ() {
		return true
	}
	select {
	case <-s.Closing:
		return true
	default:
		return false
	}
}
629178
func IsPVMigratable(pv *v1.PersistentVolume) bool {
	for _, curPlugin := range inTreePlugins {
		if curPlugin.CanSupport(pv) {
			return true
		}
	}
	return false
}
254559
func (v *VPCRouter) HasStaticNAT() bool {
	return v.HasSetting() && v.Settings.Router.HasStaticNAT()
}
382647
func isPubkey(pops []parsedOpcode) bool {
	// Valid pubkeys are either 33 or 65 bytes.
	return len(pops) == 2 &&
		(len(pops[0].data) == 33 || len(pops[0].data) == 65) &&
		pops[1].opcode.value == OP_CHECKSIG
}
146728
func isInternal(n *node) bool {
	if n == nil {
		return false
	}
	return n.entry == nil
}
1225242
func (b *BlockServerRemote) IsUnflushed(
	_ context.Context, _ tlf.ID, _ kbfsblock.ID) (
	bool, error) {
	return false, nil
}
515316
func (daemon *Daemon) IsPaused(id string) bool {
	c, _ := daemon.GetContainer(id)
	return c.State.IsPaused()
}
1352169
func (u *volumeUtil) IsBlock(fullPath string) (bool, error) {
	var st unix.Stat_t
	err := unix.Stat(fullPath, &st)
	if err != nil {
		return false, err
	}

	return (st.Mode & unix.S_IFMT) == unix.S_IFBLK, nil
}