public class MFC extends FlowControl
FlowControl.Credit
Modifier and Type | Field and Description |
---|---|
protected CreditMap |
credits
Maintains credits per member
|
protected long |
last_credit_request
Last time a credit request was sent.
|
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 |
---|
MFC() |
Modifier and Type | Method and Description |
---|---|
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) |
void |
init()
Called after instance has been created (null constructor) and before protocol is started.
|
protected boolean |
needToSendCreditRequest() |
String |
printCredits() |
String |
printSenderCredits() |
void |
stop()
This method is called on a
Channel.disconnect() . |
void |
unblock()
Allows to unblock a blocked sender from an external program, e.g.
|
adjustCredit, down, dumpStats, getAverageTimeBlocked, getMaxBlockTime, getMaxBlockTime, getMaxBlockTimes, getMaxCredits, getMinCredits, getMinThreshold, getNumberOfCreditRequestsReceived, getNumberOfCreditRequestsSent, getNumberOfCreditResponsesReceived, getNumberOfCreditResponsesSent, handleConfigEvent, handleCreditRequest, 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 CreditMap credits
protected long last_credit_request
public void unblock()
unblock
in class FlowControl
public String printCredits()
printCredits
in class FlowControl
public String printSenderCredits()
printSenderCredits
in class FlowControl
public int getNumberOfBlockings()
getNumberOfBlockings
in class FlowControl
public long getTotalTimeBlocked()
getTotalTimeBlocked
in class FlowControl
protected boolean handleMulticastMessage()
FlowControl
handleMulticastMessage
in class FlowControl
public void init() throws Exception
Protocol
init
in class FlowControl
Exception
- Thrown if protocol cannot be initialized successfully. This will cause the
ProtocolStack to fail, so the channel constructor will throw an exceptionpublic 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 boolean needToSendCreditRequest()
protected void handleCredit(Address sender, long increase)
handleCredit
in class FlowControl
protected void handleViewChange(List<Address> mbrs)
handleViewChange
in class FlowControl
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.