Recreate dbus connection (#512)

*Issue #, if available:*
#309,
#515,
#516

*Description of changes:* 

Recreate dbus connection after receiving a "connection closed" error.

By submitting this pull request, I confirm that you can use, modify,
copy, and redistribute this contribution, under the terms of your
choice.

---------

Signed-off-by: Vlad Volodkin <vlaad@amazon.com>
Co-authored-by: Vlad Volodkin <vlaad@amazon.com>

Author: vladem

charts/aws-mountpoint-s3-csi-driver/templates/node.yaml

@@ -155,7 +155,8 @@ spec:
               mountPropagation: HostToContainer
               {{- end }}
             - name: systemd-bus
-              mountPath: /run/systemd/private
+              mountPath: /run/systemd
+              mountPropagation: HostToContainer
             - name: host-dev
               mountPath: /host/dev
           ports:
@@ -236,8 +237,8 @@ spec:
             type: DirectoryOrCreate
         - name: systemd-bus
           hostPath:
-            path: /run/systemd/private
-            type: Socket
+            path: /run/systemd
+            type: Directory
         - name: kubelet-dir
           hostPath:
             path: {{ .Values.node.kubeletPath }}

deploy/kubernetes/base/node-daemonset.yaml

@@ -113,7 +113,8 @@ spec:
               # without needing to mount "/proc/mounts" from host.
               mountPropagation: HostToContainer
             - name: systemd-bus
-              mountPath: /run/systemd/private
+              mountPath: /run/systemd
+              mountPropagation: HostToContainer
             - name: host-dev
               mountPath: /host/dev
           ports:
@@ -201,8 +202,8 @@ spec:
             type: DirectoryOrCreate
         - name: systemd-bus
           hostPath:
-            path: /run/systemd/private
-            type: Socket
+            path: /run/systemd
+            type: Directory
         - name: kubelet-dir
           hostPath:
             path: /var/lib/kubelet

pkg/driver/node/mounter/systemd_mounter.go

@@ -28,7 +28,7 @@ type SystemdMounter struct {
 }
 
 func NewSystemdMounter(credProvider *credentialprovider.Provider, mpMounter *mpmounter.Mounter, mpVersion string, kubernetesVersion string) (*SystemdMounter, error) {
-	runner, err := system.StartOsSystemdSupervisor()
+	runner, err := system.StartSystemdRunner(system.OsSystemdSupervisorFactory{})
 	if err != nil {
 		return nil, fmt.Errorf("failed to start systemd supervisor: %w", err)
 	}