akka.remote.artery.compress

Class InboundCompressionsImpl

java.lang.Object

akka.remote.artery.compress.InboundCompressionsImpl

All Implemented Interfaces:

InboundCompressions

public final class InboundCompressionsImpl
extends java.lang.Object
implements InboundCompressions

INTERNAL API

One per incoming Aeron stream, actual compression tables are kept per-originUid and created on demand.

Constructor Summary

Constructors

Constructor and Description
InboundCompressionsImpl(ActorSystem system, InboundContext inboundContext, ArterySettings.Compression settings, EventSink eventSink)

Method Summary

Modifier and Type	Method and Description
void	close(long originUid) Remove compression and cancel advertisement scheduling for a specific origin
void	confirmActorRefCompressionAdvertisement(long originUid, byte tableVersion)
void	confirmClassManifestCompressionAdvertisement(long originUid, byte tableVersion)
OptionVal<ActorRef>	decompressActorRef(long originUid, byte tableVersion, int idx)
OptionVal<java.lang.String>	decompressClassManifest(long originUid, byte tableVersion, int idx)
void	hitActorRef(long originUid, Address address, ActorRef ref, int n)
void	hitClassManifest(long originUid, Address address, java.lang.String manifest, int n)
void	runNextActorRefAdvertisement() Send compression table advertisement over control stream.
void	runNextClassManifestAdvertisement() Send compression table advertisement over control stream.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

InboundCompressionsImpl

public InboundCompressionsImpl(ActorSystem system,
                               InboundContext inboundContext,
                               ArterySettings.Compression settings,
                               EventSink eventSink)

Method Detail

decompressActorRef

public OptionVal<ActorRef> decompressActorRef(long originUid,
                                              byte tableVersion,
                                              int idx)

Specified by:

decompressActorRef in interface InboundCompressions

hitActorRef

public void hitActorRef(long originUid,
                        Address address,
                        ActorRef ref,
                        int n)

Specified by:

hitActorRef in interface InboundCompressions

confirmActorRefCompressionAdvertisement

public void confirmActorRefCompressionAdvertisement(long originUid,
                                                    byte tableVersion)

Specified by:

confirmActorRefCompressionAdvertisement in interface InboundCompressions

runNextActorRefAdvertisement

public void runNextActorRefAdvertisement()

Send compression table advertisement over control stream. Should be called from Decoder.

Specified by:

runNextActorRefAdvertisement in interface InboundCompressions

decompressClassManifest

public OptionVal<java.lang.String> decompressClassManifest(long originUid,
                                                           byte tableVersion,
                                                           int idx)

Specified by:

decompressClassManifest in interface InboundCompressions

hitClassManifest

public void hitClassManifest(long originUid,
                             Address address,
                             java.lang.String manifest,
                             int n)

Specified by:

hitClassManifest in interface InboundCompressions

confirmClassManifestCompressionAdvertisement

public void confirmClassManifestCompressionAdvertisement(long originUid,
                                                         byte tableVersion)

Specified by:

confirmClassManifestCompressionAdvertisement in interface InboundCompressions

runNextClassManifestAdvertisement

public void runNextClassManifestAdvertisement()

Send compression table advertisement over control stream. Should be called from Decoder.

Specified by:

runNextClassManifestAdvertisement in interface InboundCompressions

close

public void close(long originUid)

Description copied from interface: InboundCompressions

Remove compression and cancel advertisement scheduling for a specific origin

Specified by:

close in interface InboundCompressions

Parameters:

originUid - (undocumented)