Update grpc_server.go

pkg/actor/grpc_server.go

@@ -46,7 +46,7 @@ func (s *ControlServer[V]) AnnounceExpiry(ctx context.Context, req *messages.Exp
 
 // ControlPlane: Ping
 func (s *ControlServer[V]) Ping(ctx context.Context, _ *messages.Empty) (*messages.PingReply, error) {
-
+	log.Printf("got ping")
 	return &messages.PingReply{
 		Host:     s.pool.Hostname(),
 		UnixTime: time.Now().Unix(),
@@ -89,14 +89,15 @@ func NewControlServer[V any](addr string, pool GrainPool[V]) (*grpc.Server, erro
 		pool: pool,
 	}
 
-	log.Printf("gRPC server listening on %s", addr)
-
-	if err := grpcServer.Serve(lis); err != nil {
-		log.Fatalf("failed to serve gRPC: %v", err)
-	}
-
 	messages.RegisterControlPlaneServer(grpcServer, server)
 	reflection.Register(grpcServer)
 
+	log.Printf("gRPC server listening on %s", addr)
+	go func() {
+		if err := grpcServer.Serve(lis); err != nil {
+			log.Fatalf("failed to serve gRPC: %v", err)
+		}
+	}()
+
 	return grpcServer, nil
 }