diff --git a/changelogs/unreleased/ac-fix-rss.yml b/changelogs/unreleased/ac-fix-rss.yml new file mode 100644 index 0000000000000000000000000000000000000000..c874e4cd238e89aeb79e0e42b121ff452e74b059 --- /dev/null +++ b/changelogs/unreleased/ac-fix-rss.yml @@ -0,0 +1,5 @@ +--- +title: Fix RSS monitoring +merge_request: 1257 +author: +type: fixed diff --git a/internal/supervisor/monitor.go b/internal/supervisor/monitor.go index 4544e259a1ecdc4f968eb7900a3e9e6d5824d1bb..1be00963862f705fdc06e6b6dfe3410537feaa7f 100644 --- a/internal/supervisor/monitor.go +++ b/internal/supervisor/monitor.go @@ -3,11 +3,11 @@ package supervisor import ( "os/exec" "strconv" + "strings" "time" "github.com/prometheus/client_golang/prometheus" log "github.com/sirupsen/logrus" - "gitlab.com/gitlab-org/gitaly/internal/helper/text" ) var ( @@ -82,7 +82,7 @@ func getRss(pid int) int { return 0 } - rss, err := strconv.Atoi(text.ChompBytes(psRss)) + rss, err := strconv.Atoi(strings.TrimSpace(string(psRss))) if err != nil { return 0 } diff --git a/internal/supervisor/monitor_test.go b/internal/supervisor/monitor_test.go new file mode 100644 index 0000000000000000000000000000000000000000..8b78aaf8a785f303573fe8958574a74eb8f96be7 --- /dev/null +++ b/internal/supervisor/monitor_test.go @@ -0,0 +1,13 @@ +package supervisor + +import ( + "os" + "testing" + + "github.com/stretchr/testify/require" +) + +func TestGetRss(t *testing.T) { + rss := getRss(os.Getpid()) + require.True(t, rss > 0, "Expected a positive RSS") +}