Implement Akka.Remote.Artery transport #4436

Arkatufus · 2020-05-26T16:09:16Z

Aaronontheweb · 2020-06-08T19:08:23Z

Based on our conversation in chat, not doing Aeron ports - correct? @Arkatufus

Arkatufus · 2020-12-15T13:53:17Z

Correct, since there are no such thing as a proper port of Aeron in C#. Unless we want to port that over too. not.

Arkatufus · 2020-12-15T13:54:03Z

An issue raised by @to11mtm, will have to keep an eye on TCS creation to avoid deadlocks.
https://devblogs.microsoft.com/premier-developer/the-danger-of-taskcompletionsourcet-class/

Aaronontheweb · 2021-02-03T19:16:25Z

@Arkatufus adding an issue for this to the current project.

Here's what I really want out of this:

Take all of the items on your checklist, convert them into individual Github issues.
For each Github issue, link to the other "critical dependency" issues that have to be completed first. I.E. if we have to add CompressionTable before can we add CompressionProtocol, we should document that in the CompressionProtocol github issue and link to the CompressionTable implementation issue.
Each issue should also link to a bit of documentation describing how to contribute towards Artery - i.e. which branch to use, porting notes from Scala, etc. We don't want this stuff going into dev just yet.
Arrange all of this into a project on Github, so we can have visibility into the progress of how far along the port is.

Think you can do this next week or this week?

Arkatufus · 2021-03-10T21:06:28Z

Current port status

ArteryTransport.scala

One of the main class of artery, this file touches almost everything in the akka.remote.artery
namespace. Some of the Ported Content have already been ported (marked with a check), while others are
still in the stub method form.

Note that while there is an Association.scala file, the AssociationState class belongs to
this file.

Dependency

Classes

Artery

akka.remote.artery.ArterySettings
akka.remote.artery.Association
akka.remote.artery.AssociationRegistry --> akka/remote/artery/Association.scala
akka.remote.artery.Decoder --> akka/remote/artery/Codecs.scala
akka.remote.artery.Encoder --> akka/remote/artery/Codecs.scala
akka.remote.artery.EnvelopeBuffer --> akka/remote/artery/EnvelopeBufferPool.scala
akka.remote.artery.EnvelopeBufferPool
akka.remote.artery.FlushOnShutdown
akka.remote.artery.MessageDispatcher
akka.remote.artery.Quarantined --> akka/remote/artery/Control.scala
akka.remote.artery.RemotingFlightRecorder (WILL NOT PORT)
akka.remote.artery.RestartCounter
akka.remote.artery.ReusableInboundEnvelope --> akka/remote/artery/InboundEnvelope.scala
akka.remote.artery.ReusableOutboundEnvelope --> akka/remote/artery/OutboundEnvelope.scala
akka.remote.artery.SharedTestState --> akka/remote/artery/TestStage.scala
akka.remote.artery.compress.CompressionProtocol.ActorRefCompressionAdvertisement
akka.remote.artery.compress.CompressionProtocol.ActorRefCompressionAdvertisementAck
akka.remote.artery.compress.CompressionProtocol.ClassManifestCompressionAdvertisement
akka.remote.artery.compress.CompressionProtocol.ClassManifestCompressionAdvertisementAck
akka.remote.artery.compress.CompressionTable
akka.remote.artery.compress.InboundCompressionsImpl
akka.remote.artery.compress.NoInboundCompressions

Other Akka Namespace

akka.stream.Materializer --> akka/stream/Materializer.scala
akka.stream.SharedKillSwitch
akka.stream.SystemMaterializer --> akka/stream/SystemMaterializer.scala

Traits

akka.remote.artery.ControlMessage --> akka/remote/artery/Control.scala
akka.remote.artery.Decoder.InboundCompressionAccess --> akka/remote/artery/Codecs.scala
akka.remote.artery.Encoder.OutboundCompressionAccess --> akka/remote/artery/Codecs.scala
akka.remote.artery.InboundControlJunction.ControlMessageObserver --> akka/remote/artery/Control.scala
akka.remote.artery.InboundControlJunction.ControlMessageSubject --> akka/remote/artery/Control.scala
akka.remote.artery.InboundEnvelope
akka.remote.artery.OutboundContext --> akka/remote/artery/ArteryTransport.scala
akka.remote.artery.OutboundEnvelope
akka.remote.artery.compress.InboundCompressions

External Dependency

an update to Akka.Actor.IScheduler to have a ScheduleRepeatedly method that takes (TimeSpan initialDelay, TimeSpan interval, Action runable) as arguments

Ported Content

Association.scala

Dependency

Classes

akka.actor.ActorSelectionMessage
akka.dispatch.sysmsg.Unwatch
akka.dispatch.sysmsg.DeathWatchNotification
akka.event.MarkerLoggingAdapter --> akka/event/Logging.scala
akka.remote.DaemonMsgCreate
akka.remote.RemoteLogMarker
akka.remote.artery.compress.CompressionTable
akka.remote.artery.ArteryTransport
akka.remote.artery.AssociationState --> akka/remote/artery/ArteryTransport.scala
akka.remote.artery.FlushBeforeDeathWatchNotification
akka.remote.artery.ObjectPool
akka.remote.artery.RestartCounter
akka.remote.artery.SystemMessageDelivery.ClearSystemMessageDelivery
akka.stream.Materializer --> akka/stream/Materializer.scala
akka.stream.SharedKillSwitch
akka.util.WildcardIndex

Traits

akka.remote.artery.ControlMessage --> akka/remote/artery/Control.scala
akka.remote.artery.Decoder.InboundCompressionAccess --> akka/remote/artery/Codecs.scala
akka.remote.artery.Encoder.OutboundCompressionAccess --> akka/remote/artery/Codecs.scala
akka.remote.artery.InboundControlJunction.ControlMessageSubject --> akka/remote/artery/Control.scala
akka.remote.artery.OutboundContext --> akka/remote/artery/ArteryTransport.scala
akka.remote.artery.OutboundEnvelope
akka.remote.artery.OutboundControlJunction.OutboundControlIngress--> akka/remote/artery/Control.scala
akka.remote.artery.SendQueue.ProducerApi

External Dependency

java.util.concurrent.CountDownLatch.java
- Ported to C# (Akka.Remote.Artery.Utils.Concurrent.CountDownLatch)
- Async code need code review
java.util.concurrent.LinkedBlockingQueue.java
- Ported to C# (Akka.Remote.Artery.Utils.Concurrent.LinkedBlockingQueue)
- Much rather have a better battle tested code instead.
- I'm not confident with my multi-thread concurrent codes.
org.agrona.concurrent.ManyToOneConcurrentArrayQueue.java
- Replaced with ConcurrentQueue wrapped inside a java-like API facade (Akka.Remote.Artery.Utils.Concurrent.ConcurrentQueueWrapper)
- Might need to find a similar alternative or port the required functionality.

Ported Content

Codecs.scala

Dependency

Classes

akka.remote.MessageSerializer
akka.remote.artery.ArterySettings
akka.remote.artery.EnvelopeBuffer --> akka/remote/artery/EnvelopeBufferPool.scala
akka.remote.artery.EnvelopeBufferPool
akka.remote.artery.ObjectPool
akka.remote.artery.RemoteInstruments (Not ported)
akka.remote.artery.ReusableInboundEnvelope --> akka/remote/artery/InboundEnvelope.scala
akka.remote.artery.compress.CompressionTable
akka.remote.serialization.AbstractActorRefResolveCache
akka.serialization.SerializationExtension
akka.serialization.Serializers
akka.serialization.Serialization

Traits

akka.remote.artery.InboundContext
akka.remote.artery.InboundEnvelope
akka.remote.artery.OutboundEnvelope
akka.remote.artery.compress.InboundCompressions

Ported Content

EnvelopeBufferPool.scala

Dependency

Classes

akka.remote.artery.ArteryTransport
akka.remote.artery.LruBoundedCache
akka.remote.artery.RemoteInstruments (WILL NOT PORT)
akka.serialization.Serialization
akka.remote.artery.compress.CompressionTable

Traits

akka.remote.artery.OutboundEnvelope
akka.remote.artery.compress.InboundCompressions

External Dependency

java.nio.ByteBuffer (ported to C#)
org.agrona.concurrent.ManyToManyConcurrentArrayQueue.java, used ConcurrentQueue to replace.

Ported Content

class akka.remote.artery.OutOfBuffersException
class akka.remote.artery.EnvelopeBufferPool
class akka.remote.artery.ByteFlag
class akka.remote.artery.HeaderBuilder
class akka.remote.artery.SerializationFormatCache
class akka.remote.artery.HeaderBuilderImpl
class akka.remote.artery.EnvelopeBuffer

FixedSizePartitionHub.scala

Dependency

Class

akka.stream.scaladsl.PartitionHub

Traits

akka.stream.scaladsl.PartitionHub.Internal.PartitionQueue

External Dependency

org.agrona.concurrent.OneToOneConcurrentArrayQueue.java, might need to find a similar alternative or port the required functionality. See if we can use ConcurrentQueue backed class to replace this.

Ported Content

class akka.remote.artery.FixedSizePartitionHub
class akka.remote.artery.FixedSizePartitionQueue

FlushBeforeDeathWatchNotification.scala

Dependency

Classes

akka.remote.artery.Association
akka.remote.artery.FlushAck --> akka/remote/artery/Control.scala

Ported Content

class akka.stream.artery.FlushBeforeDeathWatchNotification

FlushOnShutdown.scala

class akka.remote.artery.FlushOnShutdown

Handshake.scala

Dependency

Classes

akka.remote.artery.ObjectPool
akka.remote.artery.OutboundEnvelope
akka.remote.artery.Reply --> akka/remote/artery/Control.scala
akka.remote.artery.ReusableOutboundEnvelope --> akka/remote/artery/OutboundEnvelope.scala

Traits

akka.remote.artery.ControlMessage
akka.remote.artery.OutboundContext --> akka/remote/artery/ArteryTransport.scala

Ported Content

ImmutableLongMap.scala

This is basically a Dictionary<long, T>, but specialized for long keys with less than 1000 entries. Do we need this kind of optimization?

InboundEnvelope.scala

Dependency

Classes

akka.remote.artery.ByteFlag --> akka/remote/artery/EnvelopeBufferPool.scala
akka.remote.artery.EnvelopeBuffer --> akka/remote/artery/EnvelopeBufferPool.scala

Traits

akka.remote.artery.OutboundContext --> akka/remote/artery/ArteryTransport.scala

Ported Content

trait akka.remote.artery.InboundEnvelope
class akka.remote.artery.ReusableInboundEnvelope

InboundQuarantineCheck.scala

Dependency

Classes

akka.actor.ActorSelectionMessage --> akka/actor/ActorSelection.scala
akka.remote.HeartbeatMessage --> akka/remote/Remoting.scala
akka.remote.artery.Association
akka.remote.artery.AssociationState --> akka/remote/artery/ArteryTransport.scala
akka.remote.artery.InboundEnvelope
akka.remote.artery.Quarantined --> akka/remote/artery/Control.scala

Traits

akka.remote.artery.InboundContext --> akka/remote/artery/ArteryTransport.scala

Ported Content

class akka.remote.artery.InboundQuarantineCheck

LruBoundedCache.scala

Already ported, its in Akka.Remote.Serialization.LruBoundedCache.cs

MessageDispatcher.scala

Dependency

Classes

akka.actor.ActorSelectionMessage --> akka/actor/ActorSelection.scala
akka.remote.artery.InboundEnvelope

Traits

akka.actor.PossiblyHarmful --> Already ported, its in Akka.Actor.INoSerializationVerificationNeeded.cs

Ported Content

class akka.remote.artery.MessageDispatcher

ObjectPool.scala

Dependency

External Dependency

org.agrona.concurrent.ManyToManyConcurrentArrayQueue.java, Replaced with ConcurrentQueue.

Ported Content

class akka.remote.artery.ObjectPool

OutboundEnvelope.scala

Dependency:

Classes

class akka.remote.artery.ObjectPool

Ported Content

trait akka.remote.artery.OutboundEnvelope
class akka.remote.artery.ReusableOutboundEnvelope

QuarantinedEvent.scala

Ported Content

akka.remote.artery.QuarantinedEvent
akka.remote.artery.GracefulShutdownQuarantinedEvent
akka.remote.artery.ThisActorSystemQuarantinedEvent

RemoteInstrument.scala

Not ported to Akka.Net

RemotingFlightRecorder.scala

Not ported to Akka.Net

RestartCounter.scala

Dependency

Classes

scala.concurrent.duration.Deadline (already ported as Akka.Remote.Deadline)

Ported Content

class akka.remote.artery.RestartCounter

SendQueue.scala

Ported Content

class akka.remote.artery.SendQueue
- trait akka.remote.artery.SendQueue.ProducerApi
- trait akka.remote.artery.SendQueue.QueueValue
- trait akka.remote.artery.SendQueue.WakeupSignal

SystemMessageDelivery.scala

Dependency

Classes

akka.remote.artery.ArterySettings
akka.remote.artery.AssociationState --> akka/remote/artery/ArteryTransport.scala

Traits

akka.remote.artery.ArteryMessage --> akka/remote/artery/Control.scala
akka.remote.artery.InboundContext --> akka/remote/artery/ArteryTransport.scala
akka.remote.artery.InboundEnvelope
akka.remote.artery.InboundControlJunction.ControlMessageObserver --> akka/remote/artery/Control.scala
akka.remote.artery.InboundControlJunction.ControlMessageSubject --> akka/remote/artery/Control.scala
akka.remote.artery.OutboundContext --> akka/remote/artery/ArteryTransport.scala
akka.remote.artery.OutboundEnvelope
akka.remote.artery.Reply --> akka/remote/artery/Control.scala

External Requirements

class java.util.ArrayDeque

Ported Content

class akka.remote.artery.SystemMessageDelivery
- class akka.remote.artery.SystemMessageDelivery.SystemMessageAcker
- class akka.remote.artery.SystemMessageDelivery.SystemMessageEnvelope
- class akka.remote.artery.SystemMessageDelivery.Ack
- class akka.remote.artery.SystemMessageDelivery.Nack
- class akka.remote.artery.SystemMessageDelivery.ClearSystemMessageDelivery
- class akka.remote.artery.SystemMessageDelivery.GaveUpSystemMessageException
- trait akka.remote.artery.SystemMessageDelivery.AckedDeliveryMessage

TestStage.scala

Dependency

Traits

akka.remote.artery.OutboundContext --> akka/remote/artery/ArteryTransport.scala
akka.remote.artery.OutboundEnvelope
akka.remote.artery.OutboundContext --> akka/remote/artery/ArteryTransport.scala
akka.remote.artery.OutboundEnvelope

Ported Content

static class akka.remote.artery.TestManagementCommands
- case class akka.remote.artery.TestManagementCommands.FailInboundStreamOnce
class akka.remote.artery.SharedTestState
case class akka.remote.artery.TestState
class akka.remote.artery.OutboundTestStage
class akka.remote.artery.InboundTestStage

compress/CompressionProtocol.scala

Ported Content

compress/CountMinSketch.java

Ported Content

class akka.remote.artery.compress.CountMinSketch
- static class akka.remote.artery.compress.CountMinSketch.Murmur3

compress/CompressionTable.scala

Dependency

Classes

akka.remote.artery.compress.DecompressionTable

External Dependency

org.agrona.collections.Object2IntHashMap.java, replaced with ImmutableDictionary

Ported Content

class akka.remote.artery.compress.CompressionTable

compress/DecompressionTable.scala

Dependency

Classes

class akka.remote.artery.compress.CompressionTable

Ported Content

class akka.remote.artery.compress.DecompressionTable

compress/InboundCompressions.scala

Dependency

Classes

akka.remote.artery.ArterySettings
akka.remote.artery.Association
akka.remote.artery.AssociationState --> akka/remote/artery/ArteryTransport.scala
akka.remote.artery.compress.CompressionProtocol.ActorRefCompressionAdvertisement
akka.remote.artery.compress.CompressionProtocol.ClassManifestCompressionAdvertisement
akka.remote.artery.compress.CompressionTable
akka.remote.artery.compress.DecompressionTable
akka.remote.artery.compress.TopHeavyHitters

Traits

akka.remote.artery.InboundContext --> akka/remote/artery/ArteryTransport.scala
akka.remote.artery.OutboundContext --> akka/remote/artery/ArteryTransport.scala
akka.remote.artery.RemotingFlightRecorder (WILL NOT PORT)

External Dependency

org.agrona.collections.Long2ObjectHashMap.java, replaced with Dictionary

Ported Content

trait akka.remote.artery.compress.InboundCompressions
class akka.remote.artery.compress.InboundCompressionsImpl
class akka.remote.artery.compress.InboundActorRefCompressions
class akka.remote.artery.compress.InboundManifestCompressions
class akka.remote.artery.compress.InboundCompression
- class akka.remote.artery.compress.InboundCompression.Tables
class akka.remote.artery.compress.UnknownCompressedIdException
class akka.remote.artery.compress.NoInboundCompressions

compress/TopHeavyHitters.scala

Ported Content

class akka.remote.artery.compress.TopHeavyHitters
- case class akka.remote.artery.compress.TopHeavyHitters.HashCodeVal

tcp/ArteryTcpTransport.scala

Dependency:

Classes

akka.remote.artery.ArterySettings
akka.remote.artery.ArteryTransport
akka.remote.artery.Association
akka.remote.artery.AssociationState --> akka/remote/artery/ArteryTransport.scala
akka.remote.artery.DuplicateHandshakeReq --> akka/remote/artery/Control.scala
akka.remote.artery.EnvelopeBuffer --> akka/remote/artery/EnvelopeBufferPool.scala
akka.remote.artery.EnvelopeBufferPool
akka.remote.artery.tcp.SSLEngineProvider
akka.remote.artery.tcp.SSLEngineProviderSetup --> akka/remote/artery/tcp/SSLEngineProvider.scala
akka.remote.artery.tcp.TcpFraming
akka.stream.KillSwitches
akka.stream.SharedKillSwitch
akka.stream.scaladsl.Tcp
akka.stream.scaladsl.Tcp.IncomingConnection
akka.stream.scaladsl.Tcp.ServerBinding

Traits

akka.remote.artery.Decoder.InboundCompressionAccess
akka.remote.artery.InboundEnvelope
akka.remote.artery.OutboundContext --> akka/remote/artery/ArteryTransport.scala

External Dependency

java.nio.ByteBuffer (ported to C#)
java.net.ssl.SSLEngine
java.net.InetSocketAddress

Ported Content

class akka.remote.artery.tcp.ArteryTcpTransport

tcp/ConfigSSLEngineProvider.scala

Dependency:

Classes

akka.remote.artery.tcp.SecureRandomFactory
akka.remote.artery.tcp.SSLEngineProvider
akka.stream.TLSRole

External Dependency

javax.net.ssl.SSLContext
javax.net.ssl.SSLEngine
java.security.KeyStore
javax.net.ssl.KeyManager
javax.net.ssl.KeyManagerFactory
javax.net.ssl.TrustManager
javax.net.ssl.TrustManagerFactory
java.security.SecureRandom

Ported Content

class akka.remote.artery.tcp.ConfigSSLEngineProvider

tcp/SecureRandomFactory.scala

Dependency

External Dependency

java.security.SecureRandom

Ported Content

class akka.remote.artery.tcp.SecureRandomFactory

tcp/SSLEngineProvider.scala

Dependency:

External Dependency

javax.net.ssl.SSLEngine
javax.net.ssl.SSLSession

Ported Content

trait akka.remote.artery.tcp.SSLEngineProvider
class akka.remote.artery.tcp.SslTransportException
class akka.remote.artery.tcp.SSLEngineProviderSetup

tcp/TcpFraming.scala

Dependency:

Classes

akka.remote.artery.EnvelopeBuffer
akka.stream.impl.io.ByteStringParser

Ported Content

class akka.remote.artery.tcp.TcpFraming
case class akka.remote.artery.tcp.TcpFraming.ReadStreamId
case class akka.remote.artery.tcp.TcpFraming.ReadFrame

tcp/ssl/PemManagersProvider.scala

Dependency:

Classes

akka.pki.pem.DERPrivateKeyLoader
akka.pki.pem.PEMDecoder

External Dependency

java.security.PrivateKey
java.security.KeyStore
java.security.cert.Certificate
java.security.cert.CertificateFactory
java.security.cert.X509Certificate
javax.net.ssl.KeyManager
javax.net.ssl.KeyManagerFactory
javax.net.ssl.TrustManager
javax.net.ssl.TrustManagerFactory

Ported Content

static class akka.remote.artery.tcp.ssl.PemManagersProvider

tcp/ssl/RotatingKeySSLEngineProvider.scala

Dependency

Classes

akka.remote.artery.tcp.SSLEngineProvider
akka.remote.artery.tcp.SecureRandomFactory
akka.remote.artery.tcp.ssl.PemManagersProvider
akka.remote.artery.tcp.ssl.PeerSubjectVerifier --> akka/remote/artery/tcp/ssl/SessionVerifier.scala
akka.remote.artery.tcp.ssl.SSLEngineConfig
akka.stream.TLSRole --> akka-stream/src/main/scala/akka.stream/SslTslOptions.scala
akka.stream.Client --> akka-stream/src/main/scala/akka.stream/SslTslOptions.scala

External Dependency

javax.net.ssl.KeyManager
javax.net.ssl.SSLContext
javax.net.ssl.SSLEngine
javax.net.ssl.SSLSession
javax.net.ssl.TrustManager
java.security.PrivateKey
java.security.SecureRandom
java.security.cert.Certificate
java.security.cert.X509Certificate

Ported Content

class akka.remote.artery.tcp.ssl.RotatingKeySSLEngineProvider
case class akka.remote.artery.tcp.ssl.RotatingKeySSLEngineProvider.CachedContext
case class akka.remote.artery.tcp.ssl.RotatingKeySSLEngineProvider.ConfiguredContext

tcp/ssl/SessionVerifier.scala

Dependency

Classes

akka.remote.artery.tcp.ssl.X509Readers

External Dependency

javax.net.ssl.SSLSession
java.security.cert.X509Certificate

Ported Content

trait akka.remote.artery.tcp.ssl.SessionVerifier
class akka.remote.artery.tcp.ssl.NoopSessionVerifier
class akka.remote.artery.tcp.ssl.PeerSubjectVerifier

tcp/ssl/SSLEngineConfig.scala

Ported Content

class akka.remote.artery.tcp.ssl.SSLEngineConfig

tcp/ssl/X509Readers.scala

Dependency

External Dependency

java.security.cert.X509Certificate

Ported Content

static class class akka.remote.artery.tcp.ssl.X509Readers

Additional files that needed porting outside of artery

akka-stream/src/main/scala/akka.stream/SslTslOptions.scala
akka-stream/src/main/scala/akka.stream/impl/io/ByteStringParser.scala

Arkatufus · 2021-03-10T21:06:57Z

I'll be splitting these into separate issues

Kiddinglife · 2021-05-23T07:38:44Z

areon donet already ported by people it is open sourced. https://github.com/AdaptiveConsulting/Aeron.NET

Arkatufus mentioned this issue May 26, 2020

Update attributes #4437

Merged

Aaronontheweb added this to the 1.5.0 milestone May 26, 2020

Aaronontheweb added akka-io akka-remote akka-streams labels May 26, 2020

This was referenced May 27, 2020

ARTERY: Port Akka.Remote.Artery.ArterySettings #4443

Closed

ARTERY: Port Akka.Remote.Artery.ArteryTransport #4448

Closed

Arkatufus mentioned this issue Jun 8, 2020

Update Akka.NET source code to support Akka.Remote.Artery port. #4460

Merged

Aaronontheweb added the artery Akka.Remote Artery Protocol label Jun 8, 2020

Arkatufus mentioned this issue Jun 8, 2020

Port Akka.Remote.Artery settings classes #4462

Merged

Aaronontheweb mentioned this issue Jul 16, 2020

Is there a way to seperate network resource for different actors in akka remote? #4522

Closed

Aaronontheweb added this to Needs triage in Akka.NET Sprint 2/8 - 2/22 via automation Feb 3, 2021

Aaronontheweb moved this from Needs triage to Low priority in Akka.NET Sprint 2/8 - 2/22 Feb 3, 2021

Aaronontheweb mentioned this issue Aug 29, 2021

[PERF] Cluster Sharding perf issue #5203

Open

Aaronontheweb modified the milestones: 1.5.0, 1.5.1 Mar 2, 2023

Aaronontheweb modified the milestones: 1.5.1, 1.5.2 Mar 15, 2023

Aaronontheweb modified the milestones: 1.5.2, 1.5.3 Apr 6, 2023

Aaronontheweb modified the milestones: 1.5.3, 1.5.4 Apr 20, 2023

Aaronontheweb added this to the 1.5.5 milestone Apr 25, 2023

Aaronontheweb modified the milestones: 1.5.5, 1.5.6, 1.5.7, 1.6.0 May 4, 2023

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Implement Akka.Remote.Artery transport #4436

Implement Akka.Remote.Artery transport #4436

Arkatufus commented May 26, 2020 •

edited

Aaronontheweb commented Jun 8, 2020

Arkatufus commented Dec 15, 2020

Arkatufus commented Dec 15, 2020

Aaronontheweb commented Feb 3, 2021

Arkatufus commented Mar 10, 2021

Arkatufus commented Mar 10, 2021

Kiddinglife commented May 23, 2021 •

edited

Implement Akka.Remote.Artery transport #4436

Implement Akka.Remote.Artery transport #4436

Comments

Arkatufus commented May 26, 2020 • edited

Aaronontheweb commented Jun 8, 2020

Arkatufus commented Dec 15, 2020

Arkatufus commented Dec 15, 2020

Aaronontheweb commented Feb 3, 2021

Arkatufus commented Mar 10, 2021

Current port status

ArteryTransport.scala

Dependency

Classes

Artery

Other Akka Namespace

Traits

External Dependency

Ported Content

Association.scala

Dependency

Classes

Traits

External Dependency

Ported Content

Codecs.scala

Dependency

Classes

Traits

Ported Content

EnvelopeBufferPool.scala

Dependency

Classes

Traits

External Dependency

Ported Content

FixedSizePartitionHub.scala

Dependency

Class

Traits

External Dependency

Ported Content

FlushBeforeDeathWatchNotification.scala

Dependency

Classes

Ported Content

FlushOnShutdown.scala

Handshake.scala

Dependency

Classes

Traits

Ported Content

ImmutableLongMap.scala

InboundEnvelope.scala

Dependency

Classes

Traits

Ported Content

InboundQuarantineCheck.scala

Dependency

Classes

Traits

Ported Content

LruBoundedCache.scala

MessageDispatcher.scala

Dependency

Classes

Traits

Ported Content

ObjectPool.scala

Dependency

External Dependency

Ported Content

OutboundEnvelope.scala

Dependency:

Classes

Ported Content

QuarantinedEvent.scala

Ported Content

RemoteInstrument.scala

RemotingFlightRecorder.scala

Arkatufus commented May 26, 2020 •

edited