Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
  • 04:50
    nagytech commented #4083
  • Dec 10 21:04
    Aaronontheweb closed #3438
  • Dec 10 21:04
    Aaronontheweb edited #3438
  • Dec 10 21:04
    Aaronontheweb edited #3438
  • Dec 10 21:04
    Aaronontheweb edited #3438
  • Dec 10 21:04
    Aaronontheweb edited #3438
  • Dec 10 21:04
    Aaronontheweb edited #3438
  • Dec 10 21:04
    Aaronontheweb edited #3438
  • Dec 10 21:04
    Aaronontheweb closed #3455
  • Dec 10 21:04
    Aaronontheweb commented #3455
  • Dec 10 21:03
    Aaronontheweb closed #3471
  • Dec 10 21:03
    Aaronontheweb commented #3471
  • Dec 10 21:02
    Aaronontheweb closed #3533
  • Dec 10 21:02
    Aaronontheweb commented #3533
  • Dec 10 21:01
    Aaronontheweb closed #3587
  • Dec 10 21:01
    Aaronontheweb commented #3587
  • Dec 10 20:49
    Aaronontheweb commented #4086
  • Dec 10 20:47
    Aaronontheweb commented #4071
  • Dec 10 18:03
    Aaronontheweb closed #3760
  • Dec 10 12:04
    valdisz commented #4071
Natan Vivo
@nvivo
there are reasons to use async that have nothing to do with concurrency
Bartosz Sypytkowski
@Horusiath
have you looked at bottom readme in https://github.com/OrleansContrib/DesignPatterns ?
Natan Vivo
@nvivo
@Horusiath me?
Bartosz Sypytkowski
@Horusiath
this is a general question I just cannot belive in those numbers
Natan Vivo
@nvivo
you think it's too much or too little?
I'm not impressed by anything =)
Bartosz Sypytkowski
@Horusiath
my comp has 8 cores, and I can spin Akka.NET up to 20-68mln msgs/sec, while Orleans is talking about 10k on 8 core VM
Roger Johansson
@rogeralsing
Optimizing for locality in akka.net, we would do 30 mil messages per sec inside that machine...
Bartosz Sypytkowski
@Horusiath
I'm guessing that's a metrics methodology issue
Natan Vivo
@nvivo
that's what I thought
I'm not sure what "requests" mean there and what they are doing
Also, I'm very skeptical about VMs.... sometimes we forget how faster a bare machine can be
Roger Johansson
@rogeralsing
Also orleans serialize all messages, because no immutable messages
Aaron Stannard
@Aaronontheweb
man those numbers
ewwwwwwwwwww
serializing every message will do that
their benchmark is probably comparing different stuff though
I would love to do an Akka.Cluster / Akka.Remote benchmark at some point
had an idea for a load-testing tool for Akka.Remote but haven't had any time to work on it
Aaron Stannard
@Aaronontheweb
btw, not sure who's interesting in using the Clustering module yet
but I have a patch coming in soon - hopefully this weekend, that enables full support for Pool routers
even have the multi-node tests to prove it :p
@rogeralsing for the ConsistentHashing stuff that we talked about - I'm just going to go full-bore and import virtual nodes while I'm atit
no reason for us not to have the latest stuff there
Aaron Stannard
@Aaronontheweb
plus, although it's not a perfect solution for #673, I think it offers a better solution that what we have now
Aaron Stannard
@Aaronontheweb
for anyone who wants to read the original Akka source - this is a life saver: http://jim-mcbeath.blogspot.com/2008/12/scala-operator-cheat-sheet.html
Roger Johansson
@rogeralsing
:+1
Roger Johansson
@rogeralsing
This is where the remoting fails for mono:
            try
            {
                var addressPromise = new TaskCompletionSource<IList<ProtocolTransportAddressPair>>();
                _endpointManager.Tell(new EndpointManager.Listen(addressPromise));

                addressPromise.Task.Wait(Provider.RemoteSettings.StartupTimeout);
                var akkaProtocolTransports = addressPromise.Task.Result;
Task.Result hangs forever
Roger Johansson
@rogeralsing
I get a Listen message in the endpoint manager.. then there are coming in some Prune messages into the endpointmanager too, which it doesnt handle?
cc @Aaronontheweb
ah, it does that in accepting phase , but it is not in that phase
Roger Johansson
@rogeralsing
hmmm Listens never completes, so the remoting is stuck in startup
         _listens = Task.WhenAll(tasks).ContinueWith(transportResults => transportResults.Result.ToList(), TaskContinuationOptions.ExecuteSynchronously | TaskContinuationOptions.AttachedToParent);
Aaron Stannard
@Aaronontheweb
@rogeralsing try doing this on that line - I see a bug in the TaskContinuationOptions
 _listens = Task.WhenAll(tasks).ContinueWith(transportResults => transportResults.Result.ToList(), TaskContinuationOptions.ExecuteSynchronously & TaskContinuationOptions.AttachedToParent);
meant to use bitwise AND
not bitwise OR
Mono's TPL implementation might check for those flags differently
coffeeyesplease
@coffeeyesplease
Hi there all. I’m about to use Akka.Net on a ASP.NET MVC application. The intention is here is to have communicate with another process remotely. My question is, do remote connections timeout?
thanks in advance
Aaron Stannard
@Aaronontheweb
Akka.Remote connections are perpetual unless one side of the connection fails to deliver heartbeats to the other
I don't recall what the default heartbeat settings are, I think 1 per second or 500ms
and if more than 3-4 heartbeats get missed then the connection is considered unhealthy and gets restarted
Akka.Remote connections are lazy too - outbound only turn on the first time you try to send a message to a remote address
but it listens for incoming connections immediately
Aaron Stannard
@Aaronontheweb
@coffeeyesplease was my answer helpful at all? If not let me know - happy to help out with Remoting since we don't have a lot of literature on it at the moment.
coffeeyesplease
@coffeeyesplease
@Aaronontheweb brilliant! Yes very helpful indeed.
I’m already following your advice in starting it all on Global.asax with a static reference