kelvin/warewulf
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

fixups

Browse Source
This commit is contained in:
Carter Dodd
2022-06-05 17:37:23 -05:00
parent 30ba916703
commit 3242d2998e
2 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
internal/pkg/util/util.go
View File

@@ -31,7 +31,7 @@ var processLimitedNum int32 = 0
// Counter over total history of started processes
var processLimitedCounter uint32 = 0
func ProcessLimitedEnter() (index int32) {
func ProcessLimitedEnter() (index uint32) {
atomic.AddInt32(&processLimitedNum, 1)
index = atomic.AddUint32(&processLimitedCounter, 1)
// NOTE: blocks when channel is full (i.e. processLimitedMax)
@@ -45,8 +45,8 @@ func ProcessLimitedExit() {
atomic.AddInt32(&processLimitedNum, -1)
}
func ProcessLimitedStatus() (running int, queued int) {
running = len(processLimitedChan)
func ProcessLimitedStatus() (running int32, queued int32) {
running = int32(len(processLimitedChan))
queued = processLimitedNum - running
return
}

1
internal/pkg/warewulfd/provision.go
View File

@@ -10,7 +10,6 @@ import (
"github.com/hpcng/warewulf/internal/pkg/buildconfig"
"github.com/hpcng/warewulf/internal/pkg/container"
"github.com/hpcng/warewulf/internal/pkg/kernel"
nodepkg "github.com/hpcng/warewulf/internal/pkg/node"
"github.com/hpcng/warewulf/internal/pkg/util"
"github.com/hpcng/warewulf/internal/pkg/warewulfconf"
"github.com/hpcng/warewulf/internal/pkg/wwlog"