var quotaCmd … var quotaCmdInitialized … var quotaCmdLock … type linuxFilesystemType … const bitsPerWord … var linuxSupportedFilesystems … type VolumeProvider … var quotaCmds … var quotaParseRegexp … var lsattrCmd … var lsattrParseRegexp … // GetQuotaApplier -- does this backing device support quotas that // can be applied to directories? func (*VolumeProvider) GetQuotaApplier(mountpoint string, backingDev string) LinuxVolumeQuotaApplier { … } type linuxVolumeQuotaApplier … func getXFSQuotaCmd() (string, error) { … } func doRunXFSQuotaCommand(mountpoint string, mountsFile, command string) (string, error) { … } // Extract the mountpoint we care about into a temporary mounts file so that xfs_quota does // not attempt to scan every mount on the filesystem, which could hang if e. g. // a stuck NFS mount is present. // See https://bugzilla.redhat.com/show_bug.cgi?id=237120 for an example // of the problem that could be caused if this were to happen. func runXFSQuotaCommand(mountpoint string, command string) (string, error) { … } // SupportsQuotas determines whether the filesystem supports quotas. func SupportsQuotas(mountpoint string, qType QuotaType) (bool, error) { … } func isFilesystemOfType(mountpoint string, backingDev string, typeMagic int64) bool { … } // GetQuotaOnDir retrieves the quota ID (if any) associated with the specified directory // If we can't make system calls, all we can say is that we don't know whether // it has a quota, and higher levels have to make the call. func (v linuxVolumeQuotaApplier) GetQuotaOnDir(path string) (QuotaID, error) { … } // SetQuotaOnDir applies a quota to the specified directory under the specified mountpoint. func (v linuxVolumeQuotaApplier) SetQuotaOnDir(path string, id QuotaID, bytes int64) error { … } func getQuantity(mountpoint string, id QuotaID, xfsQuotaArg string, multiplier int64, allowEmptyOutput bool) (int64, error) { … } // GetConsumption returns the consumption in bytes if available via quotas func (v linuxVolumeQuotaApplier) GetConsumption(_ string, id QuotaID) (int64, error) { … } // GetInodes returns the inodes in use if available via quotas func (v linuxVolumeQuotaApplier) GetInodes(_ string, id QuotaID) (int64, error) { … } // QuotaIDIsInUse checks whether the specified quota ID is in use on the specified // filesystem func (v linuxVolumeQuotaApplier) QuotaIDIsInUse(id QuotaID) (bool, error) { … }
Codebase Browser
kubernetes