Package io.netty.channel.uring

Class PendingOpMap

java.lang.Object

io.netty.channel.uring.PendingOpMap

final class PendingOpMap
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
private static long	EMPTY
private static long	HASH_MULTIPLIER
private static float	LOAD_FACTOR
private int	mask
private int	maxSize
private java.util.concurrent.atomic.AtomicLong	nextSequence
private byte[]	ops
private int[]	registrationIds
private int	size
private long[]	tokens
private static long	TOMBSTONE
private int	tombstones
private long[]	userDatas

Constructor Summary

Constructors

Constructor	Description
PendingOpMap(int initialCapacity)

Method Summary

Modifier and Type	Method	Description
private static int	calcMaxSize(int capacity)
private static int	expandCapacity(int capacity)
(package private) int	findSlot(long token)
private static int	hashIndex(long key, int mask)
private void	insertAt(int index, long token, int registrationId, byte op, long userData)
private void	insertDuringRehash(long token, int registrationId, byte op, long userData)
(package private) long	nextToken()
(package private) byte	op(int slot)
private int	probeNext(int index)
(package private) void	registerNormal(long token, int registrationId, byte op, long userData)
(package private) int	registrationId(int slot)
private void	rehash(int newCapacity)
(package private) void	release(int slot)
(package private) static long	token(long sequence)	Slow-path and internal tokens are negative so they can be distinguished from packed fast-path userdata by checking bit 63.
(package private) static long	tokenSequence(long token)
(package private) long	userData(int slot)

Methods inherited from class java.lang.Object

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

Field Detail

LOAD_FACTOR

private static final float LOAD_FACTOR

See Also:

Constant Field Values

HASH_MULTIPLIER

private static final long HASH_MULTIPLIER

See Also:

Constant Field Values

EMPTY

private static final long EMPTY

See Also:

Constant Field Values

TOMBSTONE

private static final long TOMBSTONE

See Also:

Constant Field Values

tokens

private long[] tokens

registrationIds

private int[] registrationIds

ops

private byte[] ops

userDatas

private long[] userDatas

mask

private int mask

maxSize

private int maxSize

size

private int size

tombstones

private int tombstones

nextSequence

private final java.util.concurrent.atomic.AtomicLong nextSequence

Constructor Detail

PendingOpMap

PendingOpMap(int initialCapacity)

Method Detail

nextToken

long nextToken()

registerNormal

void registerNormal(long token,
                    int registrationId,
                    byte op,
                    long userData)

findSlot

int findSlot(long token)

registrationId

int registrationId(int slot)

op

byte op(int slot)

userData

long userData(int slot)

release

void release(int slot)

insertAt

private void insertAt(int index,
                      long token,
                      int registrationId,
                      byte op,
                      long userData)

rehash

private void rehash(int newCapacity)

insertDuringRehash

private void insertDuringRehash(long token,
                                int registrationId,
                                byte op,
                                long userData)

token

static long token(long sequence)

Slow-path and internal tokens are negative so they can be distinguished from packed fast-path userdata by checking bit 63.

tokenSequence

static long tokenSequence(long token)

hashIndex

private static int hashIndex(long key,
                             int mask)

probeNext

private int probeNext(int index)

calcMaxSize

private static int calcMaxSize(int capacity)

expandCapacity

private static int expandCapacity(int capacity)