Skip to content

Commit

Permalink
CR comment - changed pollInterval to be the last argument for lvmnode…
Browse files Browse the repository at this point in the history
… Start

Signed-off-by: Omri Cohen <[email protected]>
  • Loading branch information
omric-runai committed Sep 7, 2023
1 parent b283985 commit 05695bd
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 2 deletions.
3 changes: 2 additions & 1 deletion pkg/driver/agent.go
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,8 @@ func NewNode(d *CSIDriver) csi.NodeServer {

// start the lvm node resource watcher
go func() {
err := lvmnode.Start(d.config.NodeControllerPollingInterval, &ControllerMutex, stopCh)
err := lvmnode.
Start(&ControllerMutex, stopCh, d.config.NodeControllerPollingInterval)
if err != nil {
klog.Fatalf("Failed to start LVM node controller: %s", err.Error())
}
Expand Down
2 changes: 1 addition & 1 deletion pkg/mgmt/lvmnode/start.go
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ import (
)

// Start starts the lvmnode controller.
func Start(pollInterval int, controllerMtx *sync.RWMutex, stopCh <-chan struct{}) error {
func Start(controllerMtx *sync.RWMutex, stopCh <-chan struct{}, pollInterval int) error {

// Get in cluster config
cfg, err := k8sapi.Config().Get()
Expand Down

0 comments on commit 05695bd

Please sign in to comment.