Udp.Received give incorrect ByteString when client send several packets at once #3210
Description
Akka version: 1.3.2
Platform: .net core 2.0
When client sending several packets at once (within a loop) like this:
a
bb
ccc
ddd
eeee
fffff
gggggg
hhhhhhh
iiiiiiii
jjjjjjjjj
Server will receive incorrect bytes like this:
i
jj
iii
jjjj
...
The length of the bytes remain correct but the content is replaced by other bytes.
Here code sample to reproduce result above:
Server:
using Akka.Actor;
using Akka.Configuration;
using Akka.Event;
using Akka.IO;
using System;
using System.Net;
class Program
{
static void Main(string[] args)
{
var config = @"akka
{
stdout-loglevel = INFO
loglevel = DEBUG
log-config-on-start = off
io
{
udp
{
trace-logging = on
}
}
actor
{
serializers
{
hyperion = ""Akka.Serialization.HyperionSerializer, Akka.Serialization.Hyperion""
}
serialization-bindings
{
""System.Object"" = hyperion
}
}
}";
using (var system = ActorSystem.Create("test", ConfigurationFactory.ParseString(config)))
{
system.ActorOf(Props.Create(() => new UdpServer(new IPEndPoint(IPAddress.Any, 32500))));
Console.Read();
}
}
public class UdpServer : ReceiveActor
{
private readonly ILoggingAdapter _log = Context.GetLogger();
private readonly IPEndPoint _serverAddr;
private IActorRef _server;
public UdpServer(IPEndPoint serverAddr)
{
_serverAddr = serverAddr;
Receive<Udp.Bound>(b => _server = Sender);
Receive<Udp.Received>(rec => _log.Debug($"{rec.Sender} {rec.Data.ToString()}"));
}
protected override void PreStart()
{
Context.System.Udp().Tell(new Udp.Bind(Self, _serverAddr));
}
}
}Client:
using Akka.Actor;
using Akka.Configuration;
using Akka.Event;
using Akka.IO;
using System;
using System.Net;
using System.Text;
class Program
{
static void Main(string[] args)
{
var config = @"akka
{
stdout-loglevel = INFO
loglevel = DEBUG
log-config-on-start = off
io
{
udp
{
trace-logging = on
}
}
actor
{
serializers
{
hyperion = ""Akka.Serialization.HyperionSerializer, Akka.Serialization.Hyperion""
}
serialization-bindings
{
""System.Object"" = hyperion
}
}
}";
using (var system = ActorSystem.Create("test", ConfigurationFactory.ParseString(config)))
{
var serverAddr = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 32500);
var worker = system.ActorOf(Props.Create(() => new Worker(serverAddr)));
while (true)
{
Console.ReadLine();
worker.Tell(Send.Instance);
}
}
}
class Worker : ReceiveActor
{
private readonly IPEndPoint _serverAddr;
private IActorRef _simpleSender;
public Worker(IPEndPoint serverAddr)
{
Receive<Udp.SimpleSenderReady>(r =>
{
_simpleSender = Sender;
Self.Tell(Send.Instance);
});
Receive<Send>(s =>
{
var start = 'a';
for (int i = 0; i < 10; i++)
{
var str = new string((char)(start + i), i + 1);
var data = Encoding.Default.GetBytes(str);
Context.GetLogger().Debug(str);
_simpleSender.Tell(Udp.Send.Create(ByteString.CopyFrom(data), _serverAddr));
}
});
_serverAddr = serverAddr;
}
protected override void PreStart()
{
Context.System.Udp().Tell(Udp.SimpleSender.Instance);
}
}
class Send
{
private Send() { }
public static readonly Send Instance = new Send();
}
}