Trying Real Hard to set up remote deployment, nailed it locally using the existing examples but now trying to work between two machines.. finally getting closer and seeing this:
on the "local" system, which is actually an azure box:
let aref =
spawnRemote localSystem "akka.tcp://ryans-house@*ryan's house's ip*:54053/" "hello"
<@ actorOf (fun msg -> printfn "received '%A'" msg) @>
aref <! "sup"seen in the log of the "remote" system, my house:
[ERROR][8/08/2015 1:56:14 AM][Thread 0020][[akka://ryans-house/system/endpointManager/reliableEndpointWriter-akka.tcp%3a%2f%2fryans-cloud%40*the cloud ip*%3a54053-1/endpointWriter]] AssociationError [akka.tcp://ryans-house@*the house ip*:54053] <- akka.tcp://ryans-cloud@*the cloud ip*:54053: Error [Error deserializing object of type 'System.Object'.] [ at Nessos.FsPickler.RootSerialization.readRootObject[T](IPicklerResolver resolver, ReflectionCache reflectionCache, IPickleFormatReader formatter, FSharpOption`1 streamingContext, FSharpOption`1 sifted, Pickler`1 pickler) in c:\Users\eirik\Development\nessos\FsPickler\src\FsPickler\FsPickler\RootSerialization.fs:line 61
at Nessos.FsPickler.FsPicklerSerializer.Deserialize[T](Stream stream, FSharpOption`1 pickler, FSharpOption`1 streamingContext, FSharpOption`1 encoding, FSharpOption`1 leaveOpen) in c:\Users\eirik\Development\nessos\FsPickler\src\FsPickler\FsPickler\Serializer.fs:line 65
at Akka.FSharp.Serialization.deserializeFromBinary[t](BinarySerializer fsp, Byte[] bytes) in C:\Users\rdavis\Source\Repos\akka.net\src\core\Akka.FSharp\FsApi.fs:line 352
at Akka.FSharp.Serialization.ExprSerializer.FromBinary(Byte[] bytes, Type _arg1) in C:\Users\rdavis\Source\Repos\akka.net\src\core\Akka.FSharp\FsApi.fs:line 361
at Akka.Remote.Serialization.DaemonMsgCreateSerializer.Deserialize(ByteString bytes, Type type) in C:\Users\rdavis\Source\Repos\akka.net\src\core\Akka.Remote\Serialization\DaemonMsgCreateSerializer.cs:line 51
at Akka.Remote.Serialization.DaemonMsgCreateSerializer.GetArgs(DaemonMsgCreateData proto) in C:\Users\rdavis\Source\Repos\akka.net\src\core\Akka.Remote\Serialization\DaemonMsgCreateSerializer.cs:line 172
at Akka.Remote.Serialization.DaemonMsgCreateSerializer.FromBinary(Byte[] bytes, Type type) in C:\Users\rdavis\Source\Repos\akka.net\src\core\Akka.Remote\Serialization\DaemonMsgCreateSerializer.cs:line 117
at Akka.Serialization.Serialization.Deserialize(Byte[] bytes, Int32 serializerId, Type type) in C:\Users\rdavis\Source\Repos\akka.net\src\core\Akka\Serialization\Serialization.cs:line 106
at Akka.Remote.MessageSerializer.Deserialize(ActorSystem system, SerializedMessage messageProtocol) in C:\Users\rdavis\Source\Repos\akka.net\src\core\Akka.Remote\MessageSerializer.cs:line 31
at Akka.Remote.DefaultMessageDispatcher.Dispatch(IInternalActorRef recipient, Address recipientAddress, SerializedMessage message, IActorRef senderOption) in C:\Users\rdavis\Source\Repos\akka.net\src\core\Akka.Remote\Endpoint.cs:line 59
at Akka.Remote.EndpointReader.OnReceive(Object message) in C:\Users\rdavis\Source\Repos\akka.net\src\core\Akka.Remote\Endpoint.cs:line 1569
at Akka.Actor.UntypedActor.Receive(Object message) in C:\Users\rdavis\Source\Repos\akka.net\src\core\Akka\Actor\UntypedActor.cs:line 21
at Akka.Actor.ActorBase.AroundReceive(Receive receive, Object message) in C:\Users\rdavis\Source\Repos\akka.net\src\core\Akka\Actor\ActorBase.cs:line 155
at Akka.Actor.ActorCell.ReceiveMessage(Object message) in C:\Users\rdavis\Source\Repos\akka.net\src\core\Akka\Actor\ActorCell.DefaultMessages.cs:line 125
at Akka.Actor.ActorCell.Invoke(Envelope envelope) in C:\Users\rdavis\Source\Repos\akka.net\src\core\Akka\Actor\ActorCell.DefaultMessages.cs:line 55]
Cause: UnknownI think it means the message made it over, but things went bad trying to unpack it. Given that it works using Akka.Remote within the same process, maybe there is something different about the states of the two environments that could cause it? Has anyone seen this before? The hint being Error [Error deserializing object of type 'System.Object'.]
@rdavisau I need more. I've tried this myself and I haven't any of your problems
@Horusiath ok, good to know. I am going to start a clean self-contained test and if it still doesn't work, I'll share it
actually I feel bad about them... this is not how things should look like
don't use Discriminated Unions between F# and C# actors
I'm trying to update Akkling to the latest changes, and I've got a serious mindfuck - our remote serialization/deserialization test is failing, while exactly the same piece of code executed as separate script is passing
hm, no advice.. unless you are using a
let rec loop style actor deployment and messing up the continuation signature like I was this morning :-1:
Google.ProtocolBuffers dependency version missmatch
I hate all of these runtime exceptions
I just fixed my remote deployment situation; I can't say for sure it was due to upgrading one end of the connection to the matching .NET runtime / F# 4.0 because I also simplified the solution a little, but I think it may have been the former
actually I did have an issue at one point with protocol buffers today, I saw repeated
"Binding session to {google protocol buffers dll}" on the receiving end log when a message should have come through, is that what you would expect to see in the case of a version mismatch?
I'm wondering if there is a way to know if a PersistentView is "up to date"?, especially during a clean startup. I know snapshotting can minimize the replay time, however it would be nice to know if the view is going through a long restore.
@rdavisau no, it's usually a runtime error specifying version number of and fully qualified assembly name
@christiansparre when
PersistentView actor is created it won't respond on any custom messages until it fully and successfully recovers.
@christiansparre you can however apply some custom metric i.e. in the receive function to count the number of messages actor received during recovery. You can also check what messages persistent view would receive - since whole API is message based you may simply recreate messages send to journal by persistent view to mock it and verify messages received.
@Horusiath thanks for clearing that up, just thought I experienced receiving something else (in my case a query) before the view was recovered, but guess I was mistaken :) just tried again and it behaves as expected...
@Aaronontheweb I and @barambani have both submitted a PR for #1088. Could you take a look please?
Need some more eyes on this, akkadotnet/akka.net#1222 am I right there or am I misreading something?
How do I specify fully qualified name of a multinode test to run a single test?
```Akka.MultiNodeTestRunner.exe Akka.MultiNodeTests.dll -Dmultinode.enable-filesink=off -Dmultinode.test-spec="Akka.MultiNodeTests.ClusterConsistentHashingGroupSpec.AClusterRouterWithConsistentHashingGroupMustSendToSameDestinationsFromDifferentNodes"
E:\Source\akka.net\src\core\Akka.MultiNodeTestRunner\bin\Debug>Akka.MultiNodeTestRunner.exe Akka.MultiNodeTests.dll -Dmultinode.enable-filesink=off -Dmultinode.test-spec="Akka.MultiNodeTests.ClusterConsistentHashingGroupSpec.AClusterRouterWithConsistentHashingGroupMustSendToSameDestinationsFromDifferentNodes"
This does not work
I'm trying to run the basic akka.io examples using 1.0.4 from nuget and I cannot even call
system.Tcp() without it going infinite loop
namespace Proto1.Client
{
using Akka.Actor;
using Akka.IO;
using System;
class Program
{
static void Main(string[] args)
{
var system = ActorSystem.Create("proto1");
var manager = system.Tcp(); //this causes 100% CPU
Console.ReadLine();
}
}
}
may be I would look at that first
how do I assign github issues to myself?
@schatekar under the labels on the right in issue view you have assignee field, from there you should be able to assign it to yourself. If you can't let me know, I will assign you to it.
@chris-ray have you played with TcpEchoService in the examples section?
just calling system.tcp shoots the cpu to 100%. If I put a Thread.Sleep(5) in first line of Select() method in SelectionHandler.cs, it fixes it, but that's obviously a terrible solution
@chris-ray I tried it from the source code and it works good there
@rogeralsing I'm using dev branch, just cloned about 15 min ago... hmm...
so if you run the 3-line project I posted a bit earlier, your cpu stays low? Mine hits 100
it should pretty much just register the tcp extension and return the manager actor
but the thread sleep brings it back to 0% util
would my environment matter in that three-line program? I'm running VS2015 on a server 2012 instance in AWS (waiting on my new computer to come in the mail)
t2.large
just trying to think of why the same program would work fine for everyone but me
my guess is something with VM config or security
could be... I didn't do any config, just straight out of the box, fired it up and installed VS about 3 hours ago
just ran it outside VS, as a straight exe and it's still pegging
unfortunately I don't have a windows computer to copy the DLL to and test to see if it's in fact the VM until my new one comes on Wednesday. If anyone wants to compile their three-liner and shoot it up to an AWS server 2012 instance to see if it presents for them, it would go a long way towards my sanity :smile:
@chris-ray I also tried you sample using the latest nightly build. Cpu is also rater high around 30% with no debugger attached (50% with debugger). (Core i7). Seems too much...
@evertmulder good news (for my sanity anyway). What's your OS?
Also the sample server app http://getakka.net/docs/IO, runs with high CPU usage on my machine (no clients connected)
could you guys set an issue on that? some exaples and screens/logs with perf monitors would be very helpfull
I only have about 5 min before I'm dark the rest of the weekend. @evertmulder could you do that?
Yep. I can create an issue. Any perf mon counters (apart from cpu) that could help?
I think that code sample to reproduce the problem and CPU stats to compare results should be sufficient.
Maybe machine spec (if it's cloud VM, it's type) also :)
:)
@Horusiath I do not see anything under the labels on the right to assign the issue to myself
do I need to be given some kind of permission on the repo?
ah, yes, one needs to be in the contributor team list.. Ill add
invite sent. that should allow you to assign the task to you
still cannot assign to myself. This is what I see
one question - after my PR is merged, can I just continue to work on the same fork and local clone for some other issue?