public final class InboundCompressionsImpl extends java.lang.Object implements InboundCompressions
One per incoming Aeron stream, actual compression tables are kept per-originUid and created on demand.
Constructor and Description |
---|
InboundCompressionsImpl(ActorSystem system,
InboundContext inboundContext,
ArterySettings.Compression settings,
EventSink eventSink) |
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.
|
public InboundCompressionsImpl(ActorSystem system, InboundContext inboundContext, ArterySettings.Compression settings, EventSink eventSink)
public OptionVal<ActorRef> decompressActorRef(long originUid, byte tableVersion, int idx)
decompressActorRef
in interface InboundCompressions
public void hitActorRef(long originUid, Address address, ActorRef ref, int n)
hitActorRef
in interface InboundCompressions
public void confirmActorRefCompressionAdvertisement(long originUid, byte tableVersion)
confirmActorRefCompressionAdvertisement
in interface InboundCompressions
public void runNextActorRefAdvertisement()
runNextActorRefAdvertisement
in interface InboundCompressions
public OptionVal<java.lang.String> decompressClassManifest(long originUid, byte tableVersion, int idx)
decompressClassManifest
in interface InboundCompressions
public void hitClassManifest(long originUid, Address address, java.lang.String manifest, int n)
hitClassManifest
in interface InboundCompressions
public void confirmClassManifestCompressionAdvertisement(long originUid, byte tableVersion)
confirmClassManifestCompressionAdvertisement
in interface InboundCompressions
public void runNextClassManifestAdvertisement()
runNextClassManifestAdvertisement
in interface InboundCompressions
public void close(long originUid)
InboundCompressions
close
in interface InboundCompressions
originUid
- (undocumented)