Keep track of dynamic proxies too and broadcast messages to them (merge from main #5826) (#6445)

Author: alexvru

ydb/library/actors/core/actorsystem.cpp

@@ -123,6 +123,7 @@ namespace NActors {
                     if (!target) {
                         target = actorId;
                         ServiceMap->RegisterLocalService(recipient, target);
+                        DynamicProxies.push_back(target);
                     }
                 }
                 if (target != actorId) {
@@ -230,10 +231,21 @@ namespace NActors {
 
     ui32 TActorSystem::BroadcastToProxies(const std::function<IEventHandle*(const TActorId&)>& eventFabric) {
         // TODO: get rid of this method
+        ui32 res = 0;
         for (ui32 i = 0; i < InterconnectCount; ++i) {
             Send(eventFabric(Interconnect[i]));
+            ++res;
         }
-        return InterconnectCount;
+
+        auto guard = Guard(ProxyCreationLock);
+        for (size_t i = 0; i < DynamicProxies.size(); ++i) {
+            const TActorId actorId = DynamicProxies[i];
+            auto unguard = Unguard(guard);
+            Send(eventFabric(actorId));
+            ++res;
+        }
+
+        return res;
     }
 
     TActorId TActorSystem::LookupLocalService(const TActorId& x) const {

ydb/library/actors/core/actorsystem.h

@@ -161,6 +161,7 @@ namespace NActors {
         TIntrusivePtr<NLog::TSettings> LoggerSettings0;
         TProxyWrapperFactory ProxyWrapperFactory;
         TMutex ProxyCreationLock;
+        mutable std::vector<TActorId> DynamicProxies;
 
         bool StartExecuted;
         bool StopExecuted;