public class NonBlockingCreditMap extends CreditMap
Modifier and Type | Field and Description |
---|---|
protected SizeBoundedQueue<Message> |
msg_queue |
protected static Consumer<Message> |
NO_OP_SEND_FUNCTION |
protected LongAdder |
num_queued |
protected boolean |
queuing |
protected Consumer<Message> |
send_function |
accumulated_credits, avg_block_time, credits, credits_available, lock, max_credits, min_credits, num_blockings
Constructor and Description |
---|
NonBlockingCreditMap(long max_credits,
int max_size,
Lock lock) |
NonBlockingCreditMap(long max_credits,
int max_size,
Lock lock,
Consumer<Message> send_function) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
addToQueue(Message msg,
int length) |
boolean |
decrement(Message msg,
int credits,
long timeout)
Decrements credits bytes from all.
|
int |
getEnqueuedMessages() |
int |
getQueuedMessages() |
int |
getQueuedMessageSize() |
boolean |
isQueuing() |
void |
replenish(Address sender,
long new_credits) |
void |
reset() |
String |
toString() |
clear, computeLowestCredit, computeLowestCreditWithAccumulated, decrement, decrementAndAdd, flushAccumulatedCredits, get, getAccumulatedCredits, getAverageBlockTime, getMembersWithCreditsLessThan, getMembersWithInsufficientCredits, getMinCredits, getNumBlockings, keys, putIfAbsent, remove, replenishAll
protected final SizeBoundedQueue<Message> msg_queue
protected boolean queuing
protected final LongAdder num_queued
public NonBlockingCreditMap(long max_credits, int max_size, Lock lock)
public boolean isQueuing()
public int getQueuedMessages()
public int getQueuedMessageSize()
public int getEnqueuedMessages()
public boolean decrement(Message msg, int credits, long timeout)
CreditMap
public void replenish(Address sender, long new_credits)
protected boolean addToQueue(Message msg, int length)
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.