Top Fields Constructors Methods

io.rsocket.core

pack-priv final Class RequesterLeaseTracker

Class Inheritance

extends Object
implements Availability

java.lang.Object
io.rsocket.core.RequesterLeaseTracker

All Implemented Interfaces

io.rsocket.Availability

Imports

io.netty.buffer.ByteBuf, io.rsocket.Availability, io.rsocket.frame.LeaseFrameCodec, io.rsocket.lease.Lease, .MissingLeaseException, java.time.Duration, java.util.ArrayDeque, .Queue

Field Summary

Modifier and Type	Field and Description
pack-priv int	availableRequests
pack-priv final Queue<LeasePermitHandler>	awaitingPermitHandlersQueue
pack-priv Lease	currentLease
pack-priv boolean	isDisposed
pack-priv final int	maximumAllowedAwaitingPermitHandlersNumber
pack-priv Throwable	t
pack-priv final String	tag

Constructor Summary

Access	Constructor and Description
pack-priv	RequesterLeaseTracker(String tag, int maximumAllowedAwaitingPermitHandlersNumber)

Method Summary

Modifier and Type	Method and Description
public synchronized double	availability() Implements io.rsocket.Availability.availability.
public synchronized void	dispose(Throwable t)
pack-priv void	handleLeaseFrame(ByteBuf leaseFrame)
pack-priv static boolean	isExpired(Lease currentLease)
pack-priv synchronized void	issue(LeasePermitHandler leasePermitHandler)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

availableRequests	back to summary
pack-priv int availableRequests

awaitingPermitHandlersQueue	back to summary
pack-priv final Queue<LeasePermitHandler> awaitingPermitHandlersQueue

currentLease	back to summary
pack-priv Lease currentLease

isDisposed	back to summary
pack-priv boolean isDisposed

maximumAllowedAwaitingPermitHandlersNumber	back to summary
pack-priv final int maximumAllowedAwaitingPermitHandlersNumber

t	back to summary
pack-priv Throwable t

tag	back to summary
pack-priv final String tag

Constructor Detail

RequesterLeaseTracker	back to summary
pack-priv RequesterLeaseTracker(String tag, int maximumAllowedAwaitingPermitHandlersNumber)

Method Detail

availability

back to summary

public synchronized double availability()

Implements io.rsocket.Availability.availability.

Returns:double

Doc from io.rsocket.Availability.availability.

a positive numbers representing the availability of the entity. Higher is better, 0.0 means not available

Annotations

@Override

dispose	back to summary
public synchronized void dispose(Throwable t)

handleLeaseFrame	back to summary
pack-priv void handleLeaseFrame(ByteBuf leaseFrame)

isExpired	back to summary
pack-priv static boolean isExpired(Lease currentLease)

issue	back to summary
pack-priv synchronized void issue(LeasePermitHandler leasePermitHandler)