public class UFC extends FlowControl
FlowControl.Credit
Modifier and Type | Field and Description |
---|---|
protected Map<Address,FlowControl.Credit> |
sent
Map: keys are members, values are credits left.
|
CREDIT_REQUEST_HDR, frag_size_received, ignore_synchronous_response, ignore_thread, max_block_time, max_block_times, max_credits, min_credits, min_threshold, num_credit_requests_received, num_credit_requests_sent, num_credit_responses_received, num_credit_responses_sent, received, REPLENISH_HDR, running
Constructor and Description |
---|
UFC() |
Modifier and Type | Method and Description |
---|---|
Map<String,Object> |
dumpStats() |
int |
getNumberOfBlockings() |
long |
getTotalTimeBlocked() |
protected void |
handleCredit(Address sender,
long increase) |
protected Object |
handleDownMessage(Event evt,
Message msg,
Address dest,
int length) |
protected boolean |
handleMulticastMessage()
Whether the protocol handles message with dest == null || dest.isMulticastAddress()
|
protected void |
handleViewChange(List<Address> mbrs) |
String |
printCredits() |
String |
printSenderCredits() |
void |
stop()
This method is called on a
Channel.disconnect() . |
void |
unblock()
Allows to unblock all blocked senders from an external program, e.g.
|
adjustCredit, down, getAverageTimeBlocked, getMaxBlockTime, getMaxBlockTime, getMaxBlockTimes, getMaxCredits, getMinCredits, getMinThreshold, getNumberOfCreditRequestsReceived, getNumberOfCreditRequestsSent, getNumberOfCreditResponsesReceived, getNumberOfCreditResponsesSent, handleConfigEvent, handleCreditRequest, init, printMap, printReceiverCredits, resetStats, sendCredit, sendCreditRequest, setMaxBlockTime, setMaxBlockTimes, setMaxCredits, setMinCredits, setMinThreshold, start, up
destroy, enableStats, getConfigurableObjects, getDownProtocol, getId, getLevel, getName, getProtocolStack, getSocketFactory, getThreadFactory, getTransport, getUpProtocol, getValue, isErgonomics, printStats, providedDownServices, providedUpServices, requiredDownServices, requiredUpServices, resetStatistics, setDownProtocol, setErgonomics, setId, setLevel, setProtocolStack, setSocketFactory, setUpProtocol, setValue, setValues, statsEnabled
protected final Map<Address,FlowControl.Credit> sent
public String printSenderCredits()
printSenderCredits
in class FlowControl
public String printCredits()
printCredits
in class FlowControl
public Map<String,Object> dumpStats()
dumpStats
in class FlowControl
protected boolean handleMulticastMessage()
FlowControl
handleMulticastMessage
in class FlowControl
public void unblock()
FlowControl
unblock
in class FlowControl
public int getNumberOfBlockings()
getNumberOfBlockings
in class FlowControl
public long getTotalTimeBlocked()
getTotalTimeBlocked
in class FlowControl
public void stop()
Protocol
Channel.disconnect()
. Stops work (e.g. by closing multicast socket).
Will be called from top to bottom. This means that at the time of the method invocation the
neighbor protocol below is still working. This method will replace the
STOP, STOP_OK, CLEANUP and CLEANUP_OK events. The ProtocolStack guarantees that
when this method is called all messages in the down queue will have been flushedstop
in class FlowControl
protected Object handleDownMessage(Event evt, Message msg, Address dest, int length)
handleDownMessage
in class FlowControl
protected void handleViewChange(List<Address> mbrs)
handleViewChange
in class FlowControl
protected void handleCredit(Address sender, long increase)
handleCredit
in class FlowControl
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.