grpc_unix.go

@@ -36,19 +36,16 @@ func (s *GRPCServer) Close() {
 	s.server.Stop()
 }
 
-// Verifies the RPC UNIX path is still listening if it exists.
 func RPCCleanPath(rpcPath string) {
 	// Check if the RPC socket already exists.
 	_, err := os.Stat(rpcPath)
 	if err == nil {
 		// If the socket exists, see if its listening.
-		l, err := net.Dial("unix", rpcPath)
+		_, err = net.Dial("unix", rpcPath)
 
 		// If its not listening, remove it to allow us to start.
 		if err != nil {
 			os.Remove(rpcPath)
-		} else {
-			l.Close()
 		}
 	}
 }

grpc_windows.go

@@ -38,25 +38,25 @@ func (s *GRPCServer) Close() {
 	s.server.Stop()
 }
 
-// Dialer for named pipes to allow connecting GRPC via named pipes.
 func pipeDialer(ctx context.Context, addr string) (net.Conn, error) {
+	// The addr argument passed by gRPC will be the string we pass to grpc.DialContext (e.g., namedPipePath).
+	// winio.DialPipe handles connecting to the named pipe and returns a net.Conn.
+	// You may need to use winio.DialPipeContext for a cancellable context, but DialPipe
+	// is simpler for a basic example and relies on the deadline set by the gRPC call.
 	return winio.DialPipe(addr, nil)
 }
 
-// Verifies the RPC UNIX path is still listening if it exists.
 func RPCCleanPath(rpcPath string) {
 	if !strings.HasPrefix(rpcPath, `\\.\`) {
 		// Check if the RPC socket already exists.
 		_, err := os.Stat(rpcPath)
 		if err == nil {
 			// If the socket exists, see if its listening.
-			l, err := net.Dial("unix", rpcPath)
+			_, err = net.Dial("unix", rpcPath)
 
 			// If its not listening, remove it to allow us to start.
 			if err != nil {
 				os.Remove(rpcPath)
-			} else {
-				l.Close()
 			}
 		}
 	}
@@ -102,7 +102,6 @@ func NewGRPCClient() (c pb.VxlanClient, conn *grpc.ClientConn, err error) {
 
 	// Start an gRPC client connection to the unix socket.
 	if strings.HasPrefix(config.RPCPath, `\\.\`) {
-		// Attempt to connect using named pipes.
 		dialOption := grpc.WithContextDialer(pipeDialer)
 
 		conn, err = grpc.DialContext(

main.go

@@ -6,7 +6,7 @@ const (
 	serviceDisplayName = "Virtual VXLAN"
 	serviceVendor      = "com.mrgeckosmedia"
 	serviceDescription = "Virtual VXLAN using TUN interfaces"
-	serviceVersion     = "0.2.5"
+	serviceVersion     = "0.2.4"
 	defaultConfigFile  = "config.yaml"
 )