Ensure reg.sock exists while the registrar is running

Signed-off-by: zhuc <[email protected]>
kubernetes-csi · Dec 16, 2019 · 54d0404 · 54d0404
1 parent 0bb1ff3
commit 54d0404
Showing 1 changed file with 11 additions and 3 deletions.
diff --git a/cmd/csi-node-driver-registrar/node_register.go b/cmd/csi-node-driver-registrar/node_register.go
@@ -44,9 +44,17 @@ func nodeRegister(
 			os.Exit(1)
 		}
 	}
-	if err != nil && !os.IsNotExist(err) {
-		klog.Errorf("failed to stat the socket %s with error: %+v", socketPath, err)
-		os.Exit(1)
+
+	if err != nil {
+		if !os.IsNotExist(err) {
+			klog.Errorf("failed to stat the socket %s with error: %+v", socketPath, err)
+			os.Exit(1)
+		} else {
+			if _, err := os.Create(socketPath); err != nil {
+				klog.Errorf("failed to create the socket %s with error: %+v", socketPath, err)
+				os.Exit(1)
+			}
+		}
 	}
 
 	var oldmask int