New counter for activations (CurrentActivationTimeUsByActivity) #4938
Conversation
kruall
changed the title
|
⚪
|
|
⚪
|
| @@ -165,6 +175,12 @@ namespace NActors { | |||
| AggregateOne(ActorsAliveByActivity, other.ActorsAliveByActivity); | |||
| AggregateOne(ScheduledEventsByActivity, other.ScheduledEventsByActivity); | |||
| AggregateOne(StuckActorsByActivity, other.StuckActorsByActivity); | |||
| if (other.CurrentActivationTime.TimeUs) { | |||
There was a problem hiding this comment.
@kruall в этом if thread sanitizer находит проблему - чтение данных, модифицируемых на другом потоке.
В следующем if происходит что-то совсем странное (хотя это проходит для tsan незамеченным) - идет обращение к контейнеру, который изменяется на другом потоке. Мне кажется понятно к чему это приводит.
There was a problem hiding this comment.
Обсудили голосом.
- гонка по данным происходит когда специально выделенный поток проходится по всем TExecutorThreadStats и аггрегирует их, причем делает это за два прохода.
- с AggregatedCurrentActivationTime проблемы не происходит, потому что их может менять только поток, который собирает статистику
т.е. если в первом случае данные в other меняются в других потоках во момент сбора статистики, то с AggregatedCurrentActivationTime такого не происходит, их просто не трогают на тех потоках.
Changelog entry
...
Changelog category
Additional information
...