akkadotnet/akka.net

Port of Akka actors for .NET

Aaron Stannard

@Aaronontheweb

but we should investigate

Christian Duhard

@cduhard

could it have anything to do with monitoring?

Aaron Stannard

@Aaronontheweb

using Akka.Monitoring?

Christian Duhard

@cduhard

yes

Aaron Stannard

@Aaronontheweb

hmmm.... could be - calling it from the child actor/

Christian Duhard

@cduhard

yes

Aaron Stannard

@Aaronontheweb

only way I could see that happening would be if the actor was receiving a message while it was still being created... which Akka.Monitoring implementation are you using?

Christian Duhard

@cduhard

statsd

nothing gets to Receive until after i see a zillion of those messages

Aaron Stannard

@Aaronontheweb

could you do a test for me and try commenting the monitoring method calls out

see if those come in?

because I have literally never seen this message in two years of using Akka.NET

Christian Duhard

@cduhard

yeah i'm about to do that

yeah, they still show up

Aaron Stannard

@Aaronontheweb

post a gist with the full source for this

can't give you any meaningful help with just what's in gitter

Christian Duhard

@cduhard

i understand

Aaron Stannard

@Aaronontheweb

basically it's a race condition of some sort - someone's trying to resolve a reference to a child actor that doesn't exist yet

the interesting question is how that's even possible - these should all be self-contained

my gut tells me that the way you've exposed these actors inside your application contains shared mutable state

but without seeing that

I'm just guessing

if these are just child actors to some other actor then 100% of that state is private and self-contained

Christian Duhard

@cduhard

the actors that use this router are PersistenActors

the router is shared amongst persistent actors created by a parent coordinator

none of this was happening until i converted the routed actors from ReceiveActor to ActorBase

return Akka.Actor.Props.Create(() => new Account(id, OtherRouter, ContactVerifier));

like that

thats how the router gets used, it only receives messages from siblings

Aaron Stannard

@Aaronontheweb

so the child actors inherit directly from ActorBase?

why that instead of ReceiveActor?

Christian Duhard

@cduhard

yes

I'll try changing it back and see if that's the cause here. it's weird that the other router doesn't do this

Christian Duhard

@cduhard

same problem

ok, it seems to be happing everytime UpdateState gets called in the persistent actor

Christian Duhard

@cduhard

if i log there these messages are interleaved

its definitely related to the journal replay. why/how no clue...

Christian Duhard

@cduhard

there is nothing related to those routers happing in UpdateState

Roger Johansson

@rogeralsing

@Horusiath can you create a gist with the failing serialization cases?

Bartosz Sypytkowski

@Horusiath

rogeralsing/Wire#13

Roger Johansson

@rogeralsing

:+1:

Bartosz Sypytkowski

@Horusiath

@rogeralsing how do you emit code for type serializers?

Roger Johansson

@rogeralsing

using Linq.Expressions

stupid question maybe but the immutabledictionary, is that from F#? or from one of the immutable collection libs?

Bartosz Sypytkowski

@Horusiath

each immutable data type has static method CreateRange<T>(IEnumerable<T>) or CreateRange<TKey, TValue>(IEnumerable<KeyValuePair<TKey, TValue>>)

no, it's the one from MS

in F# (and any language not being C#) it's called a Map

Roger Johansson

@rogeralsing

ok, yes I see the problem here, I have a half-assed impl for serializing ienumerables. I need to finish that

Kamil Wojciechowski

@aph5nt

yo, I need some help

Where communities thrive

People

Repo info

Activity