aboutsummaryrefslogtreecommitdiffstats
path: root/library/go/maxprocs/helpers.go
diff options
context:
space:
mode:
authorqrort <qrort@yandex-team.com>2022-11-30 23:47:12 +0300
committerqrort <qrort@yandex-team.com>2022-11-30 23:47:12 +0300
commit22f8ae0e3f5d68b92aecccdf96c1d841a0334311 (patch)
treebffa27765faf54126ad44bcafa89fadecb7a73d7 /library/go/maxprocs/helpers.go
parent332b99e2173f0425444abb759eebcb2fafaa9209 (diff)
downloadydb-22f8ae0e3f5d68b92aecccdf96c1d841a0334311.tar.gz
validate canons without yatest_common
Diffstat (limited to 'library/go/maxprocs/helpers.go')
-rw-r--r--library/go/maxprocs/helpers.go46
1 files changed, 46 insertions, 0 deletions
diff --git a/library/go/maxprocs/helpers.go b/library/go/maxprocs/helpers.go
new file mode 100644
index 0000000000..70263e6eb3
--- /dev/null
+++ b/library/go/maxprocs/helpers.go
@@ -0,0 +1,46 @@
+package maxprocs
+
+import (
+ "bytes"
+ "io/ioutil"
+ "math"
+ "os"
+ "strconv"
+)
+
+func getEnv(envName string) (string, bool) {
+ val, ok := os.LookupEnv(envName)
+ return val, ok && val != ""
+}
+
+func applyIntStringLimit(val string) int {
+ maxProc, err := strconv.Atoi(val)
+ if err == nil {
+ return Adjust(maxProc)
+ }
+
+ return Adjust(SafeProc)
+}
+
+func applyFloatStringLimit(val string) int {
+ maxProc, err := strconv.ParseFloat(val, 64)
+ if err != nil {
+ return Adjust(SafeProc)
+ }
+
+ return applyFloatLimit(maxProc)
+}
+
+func applyFloatLimit(val float64) int {
+ maxProc := int(math.Floor(val))
+ return Adjust(maxProc)
+}
+
+func readFileInt(filename string) (int, error) {
+ raw, err := ioutil.ReadFile(filename)
+ if err != nil {
+ return 0, err
+ }
+
+ return strconv.Atoi(string(bytes.TrimSpace(raw)))
+}