Skip to content

Commit

Permalink
csi: use different ports for controller and node plugins
Browse files Browse the repository at this point in the history
Usubg host network produces port collisions.

So we use different ports for controller plugin deployments and
node plugin deamonsets  to avoid collisions.

Signed-off-by: Michael Adam <[email protected]>
  • Loading branch information
obnoxxx committed Feb 6, 2025
1 parent da919bd commit 6be915c
Show file tree
Hide file tree
Showing 2 changed files with 11 additions and 7 deletions.
8 changes: 4 additions & 4 deletions internal/controller/driver_controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -772,15 +772,15 @@ func (r *driverReconcile) reconcileControllerPluginDeployment() error {
utils.PodContainerArg,
utils.PodUidContainerArg,
utils.CsiAddonsAddressContainerArg,
utils.ControllerPortContainerArg,
utils.ControllerPluginPortContainerArg,
utils.NamespaceContainerArg,
utils.If(logRotationEnabled, utils.LogToStdErrContainerArg, ""),
utils.If(logRotationEnabled, utils.AlsoLogToStdErrContainerArg, ""),
utils.If(logRotationEnabled, utils.LogFileContainerArg("csi-addons"), ""),
),
),
Ports: []corev1.ContainerPort{
utils.CsiAddonsContainerPort,
utils.ControllerPluginCsiAddonsContainerPort,
},
Env: []corev1.EnvVar{
utils.NodeIdEnvVar,
Expand Down Expand Up @@ -1122,7 +1122,7 @@ func (r *driverReconcile) reconcileNodePluginDeamonSet() error {
utils.CsiAddonsNodeIdContainerArg,
utils.LogVerbosityContainerArg(logVerbosity),
utils.CsiAddonsAddressContainerArg,
utils.ControllerPortContainerArg,
utils.NodePluginPortContainerArg,
utils.PodContainerArg,
utils.NamespaceContainerArg,
utils.PodUidContainerArg,
Expand All @@ -1133,7 +1133,7 @@ func (r *driverReconcile) reconcileNodePluginDeamonSet() error {
},
),
Ports: []corev1.ContainerPort{
utils.CsiAddonsContainerPort,
utils.NodePluginCsiAddonsContainerPort,

Check failure on line 1136 in internal/controller/driver_controller.go

View workflow job for this annotation

GitHub Actions / govulncheck

undefined: utils.NodePluginCsiAddonsContainerPort
},
Env: []corev1.EnvVar{
utils.NodeIdEnvVar,
Expand Down
10 changes: 7 additions & 3 deletions internal/utils/csi.go
Original file line number Diff line number Diff line change
Expand Up @@ -337,10 +337,13 @@ var DriverNamespaceEnvVar = corev1.EnvVar{
},
}

// CSI Addons container port definition
var CsiAddonsContainerPort = corev1.ContainerPort{
// CSI Addons container port definitions
var ControllerPluginCsiAddonsContainerPort = corev1.ContainerPort{
ContainerPort: int32(9070),
}
var NodePluginCsiAddonsContainerPort2 = corev1.ContainerPort{
ContainerPort: int32(9071),
}

// Ceph CSI common container arguments
var CsiAddressContainerArg = fmt.Sprintf("--csi-address=%s", csiEndpoint)
Expand All @@ -359,7 +362,8 @@ var HandleVolumeInuseErrorContainerArg = "--handle-volume-inuse-error=false"
var PodUidContainerArg = fmt.Sprintf("--pod-uid=$(%s)", PodUidEnvVar.Name)
var PodContainerArg = fmt.Sprintf("--pod=$(%s)", PodNameEnvVar.Name)
var NamespaceContainerArg = fmt.Sprintf("--namespace=$(%s)", PodNamespaceEnvVar.Name)
var ControllerPortContainerArg = fmt.Sprintf("--controller-port=%d", CsiAddonsContainerPort.ContainerPort)
var ControllerPluginPortContainerArg = fmt.Sprintf("--controller-port=%d", ControllerPluginCsiAddonsContainerPort.ContainerPort)
var NodePluginPortContainerArg = fmt.Sprintf("--controller-port=%d", NodePluginCsiAddonsContainerPort.ContainerPort)

Check failure on line 366 in internal/utils/csi.go

View workflow job for this annotation

GitHub Actions / build

undefined: NodePluginCsiAddonsContainerPort

Check failure on line 366 in internal/utils/csi.go

View workflow job for this annotation

GitHub Actions / unittests

undefined: NodePluginCsiAddonsContainerPort

Check failure on line 366 in internal/utils/csi.go

View workflow job for this annotation

GitHub Actions / golangci-lint

undefined: NodePluginCsiAddonsContainerPort (typecheck)

Check failure on line 366 in internal/utils/csi.go

View workflow job for this annotation

GitHub Actions / golangci-lint

undefined: NodePluginCsiAddonsContainerPort) (typecheck)

Check failure on line 366 in internal/utils/csi.go

View workflow job for this annotation

GitHub Actions / golangci-lint

undefined: NodePluginCsiAddonsContainerPort) (typecheck)

Check failure on line 366 in internal/utils/csi.go

View workflow job for this annotation

GitHub Actions / govulncheck

undefined: NodePluginCsiAddonsContainerPort
var DriverNamespaceContainerArg = fmt.Sprintf("--drivernamespace=$(%s)", DriverNamespaceEnvVar.Name)
var MetricsPathContainerArg = "--metricspath=/metrics"
var PoolTimeContainerArg = "--polltime=60s"
Expand Down

0 comments on commit 6be915c

Please sign in to comment.