|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--com.sun.multicast.reliable.transport.tram.TRAMTransportProfile
A TransportProfile for TRAM (Tree-based Reliable Multicast Protocol).
This class adds several transport-specific public methods that control transport-specific parameters. Several of the most interesting are getMinDataRate, setMinDataRate, getMaxDataRate, and setMaxDataRate. These allow the application to specify minimum and maximum data rates for the session. The minimum rate is purely advisory for now. It may be used later to prune receivers that can't keep up. The maximum data rate is used to throttle outgoing data. This avoids overrunning network elements.
TransportProfile
, Serialized FormField Summary | |
protected static int |
LATE_JOIN_WITH_FULL_RECOVERY
Constant to specify the Late Join preference. |
static int |
LATE_JOIN_WITH_LIMITED_RECOVERY
Constant to specify the Late Join preference. |
static int |
LATE_JOIN_WITH_NO_RECOVERY
Constant to specify the Late Join preference. |
static int |
LOG_CONGESTION
Constant to specify 'Logging of Congestion' related messages. |
static int |
LOG_CONTROL_MESG
Constant to specify 'Logging of TRAM Control' messages. |
static int |
LOG_DATA_CACHE
Constant to specify 'Logging of Data Cache related' messages. |
static int |
LOG_DATA_MESG
Constant to specify 'Logging of TRAM Data' messages. |
static int |
LOG_DIAGNOSTICS
Constant to specify 'Log DIAGNOSTICS' messages. |
static int |
LOG_INFO
Constant to specify 'Log INFO' messages. |
static int |
LOG_NONE
Constant to specify 'Log nothing' option. |
static int |
LOG_PERFORMANCE_MONITOR
Level for visual performance monitor. |
static int |
LOG_SECURITY
Constant to specify 'Logging of Security related' messages. |
static int |
LOG_SESSION_STATUS
Constant to specify 'Logging of Multicast session related' messages. |
static int |
LOG_TEST
Constant to specify 'Logging of Test related' messages. |
static int |
LOG_VERBOSE
Constant to specify 'Log Everything' option. |
static int |
MAX_CONG_WINDOW_MULTIPLE
|
static int |
MIN_CONG_WINDOW_MULTIPLE
constant to limit congestionWindow as a multiple of ackWindow. |
static int |
TREE_FORM_HA
Constant to specify the algorithm to use to build the TRAM repair tree. |
static int |
TREE_FORM_HA_STATIC_R
|
static int |
TREE_FORM_HA_STATIC_RW
|
static int |
TREE_FORM_HAMTHA
Constant to specify the algorithm to use to build the TRAM repair tree. |
static int |
TREE_FORM_HAMTHA_STATIC_R
|
static int |
TREE_FORM_HAMTHA_STATIC_RW
|
static int |
TREE_FORM_MTHA
Constant to specify the algorithm to use to build the TRAM repair tree. |
static int |
TREE_FORM_MTHA_STATIC_R
|
static int |
TREE_FORM_MTHA_STATIC_RW
|
static int |
TREE_FORM_STATIC_R
Constants to specify the algorithm to use to build the TRAM repair tree. |
static int |
TREE_FORM_STATIC_RW
|
Fields inherited from interface com.sun.multicast.reliable.transport.TransportProfile |
RECEIVER, REPAIR_NODE, SEND_RECEIVE, SENDER |
Constructor Summary | |
TRAMTransportProfile(java.net.InetAddress ia,
int port)
Creates an TRAMTransportProfile using the Multicast Address and port specified. |
|
TRAMTransportProfile(java.lang.String filename)
Creates an TRAMTransportProfile using the details specified in a configuration file. |
Method Summary | |
java.lang.Object |
clone()
Returns a copy of this transport profile. |
RMPacketSocket |
createRMPacketSocket(int sendReceive)
Creates an RMPacketSocket using this TransportProfile. |
RMPacketSocket |
createRMPacketSocket(int sendReceive,
java.net.InetAddress interfaceAddress)
Creates an RMPacketSocket using this TransportProfile. |
RMPacketSocket |
createRMPacketSocket(int sendReceive,
java.net.InetAddress interfaceAddress,
TRAMSimulator simulator)
Creates an RMPacketSocket using this TransportProfile and a TRAMSimulator object. |
RMPacketSocket |
createRMPacketSocket(int sendReceive,
TRAMSimulator simulator)
Creates an RMPacketSocket using this TransportProfile and a TRAMSimulator object. |
RMStreamSocket |
createRMStreamSocket(int sendReceive)
Creates an RMStreamSocket using this TransportProfile. |
RMStreamSocket |
createRMStreamSocket(int sendReceive,
java.net.InetAddress interfaceAddress)
Creates an RMStreamSocket using this TransportProfile. |
boolean |
decentralizedPruning()
|
void |
disableAuthentication()
Disables the use of Authentication by the transport. |
void |
enableAuthentication()
Enables the use of authentication by the transport. |
short |
getAckWindow()
Gets the Acknowledgement window size. |
java.net.InetAddress |
getAddress()
Returns the multicast address specified in the TransportProfile. |
java.lang.String |
getAuthenticationSpecFileName()
Gets the name of the authenticationSpec filename that is to be used for initialization. |
java.lang.String |
getAuthenticationSpecPassword()
Gets the password for the authenticationSpec |
long |
getBeaconRate()
Gets the rate at which the Beacon messages are sent. |
byte |
getBeaconTTLIncrements()
Gets the TTL steps by which the multicast scope of the beacon message is incremented. |
int |
getCacheSize()
Gets the maximum cache size in packets |
int |
getCongestionWindow()
Gets the current congestion window size. |
java.net.InetAddress |
getDataSourceAddress()
Gets the source address of the multicast data stream. |
long |
getHaInterval()
Gets the interval between successive Head Advertisements. |
byte |
getHaTTLIncrements()
Gets the TTL steps by which the multicast scope of the Head Advertisement message is to be incremented. |
byte |
getHaTTLLimit()
Gets the TTL limit of the Head Advertisement message. |
long |
getHelloRate()
Gets the rate at which the Hello messages are sent. |
int |
getLateJoinPreference()
Gets the current Late join preference. |
int |
getLogMask()
|
int |
getMaxBuf()
This method returns the maximum buffer size used in reception of data packets. |
int |
getMaxCongestionWindowMultiple()
|
int |
getMaxConsecutiveCongestionCount()
|
long |
getMaxDataRate()
Gets the maximum rate data transfer. |
long |
getMaxHABWWhileDataTransfer()
Gets the configured limit on the bandwidth usage by HA message during the multicast data transfer. |
long |
getMaxHABWWhileTreeForming()
Gets the configured limit on the bandwidth usage by HA message during the tree formation phase(before the multicast data starts). |
byte |
getMaxHelloMisses()
Gets the count of Hello messages that are to be missed continuously by a member to declare the head inactive and re-affiliate with another head. |
short |
getMaxMembers()
Gets the limit of the number of members that a group head can accommodate. |
int |
getMaxNonHeads()
Gets the configured limit of the number of non Head members(i.e., members with MROLE set to MEMBER_ONLY) that can be accepted as members while performing the role of a head. |
int |
getMaxPruneTime()
Gets the maximum time to wait before pruning a slow member |
long |
getMinDataRate()
Gets the minimum rate of data transfer. |
int |
getMissingPacketThreshold()
|
byte |
getMrole()
Gets the specified Member Role(mrole) value in the Transport profile. |
long |
getMsRate()
Gets the rate at which the Member Solicitation(MS) messages are sent. |
byte |
getMsTTLIncrements()
Gets the TTL steps by which the multicast scope of the Member Solicitation(MS) message is to be incremented. |
short |
getNackReportWindow()
Gets the size of the negative Acknowledgement window. |
java.lang.String |
getName()
Returns the name of this transport. |
int |
getPort()
Returns the multicast port number specified in the TransportProfile. |
long |
getPruneHelloRate()
Gets the rate at which the Hello messages are sent after it has been detected that a member has not sent an ACK. |
double |
getPruningWindow()
|
double |
getRateIncreaseFactor()
|
int |
getReceiveBufferSize()
This function returns the value that was asked to be set using setReceiveBufferSize. |
long |
getReceiverMaxDataRate()
|
boolean |
getSAhead()
Method to test if REPAIR_NODE mode is turned on. |
int |
getSessionId()
Gets the session ID associated with this transport profile. |
int |
getTimeForAvgRateCalc()
|
byte |
getTmode()
Gets the specified Transport Mode(tmode) value in the transport profile. |
double |
getTransferDataSize()
Gets the transfer data size that is currently in use. |
long |
getTransferDuration()
Gets allowed duration of data transfer. |
int |
getTreeFormationPreference(boolean mask)
Gets the configured tree formation preference. |
byte |
getTTL()
Returns the time-to-live for this TransportProfile. |
int |
getUnicastPort()
Gets the unicast communication port in use. |
boolean |
isLanTreeFormationEnabled()
Method to test whether or not lan tree formation is allowed. |
boolean |
isLoggingEnabled()
Method to test the logging status. |
boolean |
isLoggingEnabled(int testLogMask)
|
boolean |
isMultiSender()
Determines if multiple senders are supported with this TransportProfile. |
boolean |
isOrdered()
Test method to check if Packet Ordering option is enabled in the Transport profile. |
boolean |
isSmoothTransmission()
Gets the flag indicating whether or not bursting transmission is allowed. |
boolean |
isUsingAuthentication()
Returns the value of the authentication flag. |
boolean |
isValid()
Tests whether this TransportProfile is valid. |
static void |
main(java.lang.String[] args)
|
boolean |
reaffiliateAfterBeingDisowned()
Gets the flag indicating whether or not to reaffiliate after being disowned. |
void |
setAckWindow(short ackWindow)
Sets the size of the acknowledgement window to the required value. |
void |
setAddress(java.net.InetAddress address)
Sets the multicast address for this TransportProfile. |
void |
setAuthenticationSpecFileName(java.lang.String specFileName)
Sets the name of the authenticationSpec filename to use for Authentication Module initialization. |
void |
setAuthenticationSpecPassword(java.lang.String password)
Sets the password for the authenticationSpec |
void |
setBeaconRate(long beaconRate)
Sets the required rate at which the beacon messages are to be sent. |
void |
setBeaconTTLIncrements(byte beaconTTLIncrements)
Sets the TTL steps by which the multicast scope of the beacon message is incremented. |
void |
setCacheSize(int cacheSize)
Sets the maximum size of the cache in packets. |
void |
setCongestionWindow(int congestionWindow)
Set the value of the congestion window. |
void |
setDataSourceAddress(java.net.InetAddress dataSourceAddress)
Sets the source address of the multicast data session.. |
void |
setDecentralizedPruning(boolean decentralizedPruning)
|
void |
setHaInterval(long haInterval)
Sets the interval between two successive HA messages with the specified value. |
void |
setHaTTLIncrements(byte haTTLIncrements)
Sets the TTL steps by which the multicast scope of the HA message is to be incremented. |
void |
setHaTTLLimit(byte haTTLLimit)
Sets the TTL limit of the Head Advertisement message. |
void |
setHelloRate(long helloRate)
Sets the required Hello Rate value. |
void |
setLanTreeFormation(boolean b)
Method to turn on or turn off lan tree formation. |
void |
setLateJoinPreference(int lateJoinPreference)
Sets the Late join preference for the session. |
void |
setLogMask(int logMask)
Method to turn on or turn off the logging mechanism. |
void |
setMaxBuf(int size)
This method sets the maximum buffer size used in reception of data packets. |
void |
setMaxCongestionWindowMultiple(int congestionWindowMultiple)
Set the maximum congestion window multiple. |
void |
setMaxConsecutiveCongestionCount(int maxConsecutiveCongestionCount)
|
void |
setMaxDataRate(long maxDataRate)
Sets the maximum rate at which the multicast data messages can be sent. |
void |
setMaxHABWWhileDataTransfer(long maxHABWWhileDataTransfer)
Sets the maximum Bandwidth that can be used by HA messages while the multicast data transfer is in progress. |
void |
setMaxHABWWhileTreeForming(long maxHABWWhileTreeForming)
Sets the maximum Bandwidth that can be used by HA messages before the multicast data transfer starts. |
void |
setMaxHelloMisses(byte maxHelloMisses)
Sets the count of Hello messages that are to be missed, continuously, by a member to disown a head. |
void |
setMaxMembers(short maxMembers)
Sets the maximum limit of members that a repair head can accommodate. |
void |
setMaxNonHeads(int maxNonHeads)
sets the configured limit of the number of non Heads(i.e., MEMBER_ONLY) that can be accepted as members while performing the role of a head. |
void |
setMaxPruneTime(int time)
Sets the maximum time (in seconds) to wait before pruning a slow member Default is 5 seconds. |
void |
setMinDataRate(long minDataRate)
Sets the minimum rate of data transmission to the specified value. |
void |
setMissingPacketThreshold(int missingPacketThreshold)
|
void |
setMrole(byte mrole)
Set the required Member Role(mrole) value in the transport profile. |
void |
setMsRate(long msRate)
Sets the required Member Solicitation(MS) rate value. |
void |
setMsTTLIncrements(byte msTTLIncrements)
Sets the TTL steps by which the multicast scope of the Member Solicitation(MS) message is to be incremented. |
void |
setMultiSender(boolean multisender)
Sets the value of the multisender flag. |
void |
setNackReportWindow(short nackReportWindow)
Sets the Negative Acknowledgement window size to the preferred value. |
void |
setOrdered(boolean ordered)
Sets the Packet Ordering preference in the transport profile. |
void |
setPort(int port)
Sets the multicast port number for this TransportProfile. |
void |
setPruneHelloRate(long pruneHelloRate)
Sets the rate at which the Hello messages are sent after it has been detected that a member has not sent an ACK. |
void |
setPruningWindow(double pruningWindow)
|
void |
setRateIncreaseFactor(double rateIncreaseFactor)
|
void |
setreaffiliateAfterBeingDisowned(boolean rad)
Sets the flag indicating whether or not to reaffiliate after being disowned. |
void |
setReceiveBufferSize(int rbs)
Sets the receive buffer size. |
void |
setReceiverMaxDataRate(long receiverMaxDataRate)
|
void |
setSessionId(int sessionId)
Sets the session ID associated with this transport profile. |
void |
setSmoothTransmission(boolean smoothTransmission)
Sets the flag to indicate that the sender should try to smooth out the transmission of packets as much as possible over time rather than sending out bursts of packets. |
void |
setTimeForAvgRateCalc(int timeForAverageRateCalc)
|
void |
setTmode(byte tmode)
Set the required Transport Mode(tmode) value in the Transport Profile. |
void |
setTransferDataSize(double transferDataSize)
Sets the size of the data that is to be transferred. |
void |
setTransferDuration(long transferDuration)
Sets the allowed duration of Data transfer(in minutes). |
void |
setTreeFormationPreference(int treeFormationPreference)
Sets the tree formation preference for the session. |
void |
setTTL(byte ttl)
Sets the value for the Time-to-live. |
void |
setUnicastPort(int unicastPort)
Sets the unicast port that is to be used for exchange of control messages. |
Methods inherited from class java.lang.Object |
equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
public static final int MIN_CONG_WINDOW_MULTIPLE
public static final int MAX_CONG_WINDOW_MULTIPLE
public static final int LATE_JOIN_WITH_LIMITED_RECOVERY
protected static final int LATE_JOIN_WITH_FULL_RECOVERY
public static final int LATE_JOIN_WITH_NO_RECOVERY
public static final int TREE_FORM_HA
public static final int TREE_FORM_MTHA
public static final int TREE_FORM_HAMTHA
public static final int TREE_FORM_STATIC_R
public static final int TREE_FORM_STATIC_RW
public static final int TREE_FORM_HA_STATIC_R
public static final int TREE_FORM_MTHA_STATIC_R
public static final int TREE_FORM_HAMTHA_STATIC_R
public static final int TREE_FORM_HA_STATIC_RW
public static final int TREE_FORM_MTHA_STATIC_RW
public static final int TREE_FORM_HAMTHA_STATIC_RW
public static final int LOG_VERBOSE
public static final int LOG_NONE
public static final int LOG_DIAGNOSTICS
public static final int LOG_INFO
public static final int LOG_CONGESTION
public static final int LOG_CONTROL_MESG
public static final int LOG_DATA_MESG
public static final int LOG_SESSION_STATUS
public static final int LOG_SECURITY
public static final int LOG_DATA_CACHE
public static final int LOG_TEST
public static final int LOG_PERFORMANCE_MONITOR
Constructor Detail |
public TRAMTransportProfile(java.lang.String filename) throws java.io.IOException
filename
- the name of an TRAM configuration filejava.io.IOException
- if an I/O exception occurspublic TRAMTransportProfile(java.net.InetAddress ia, int port) throws java.io.IOException, InvalidMulticastAddressException
ia
- a multicast InetAddressport
- the multicast port numberjava.io.IOException
- if an I/O exception occursInvalidMulticastAddressException
- if the multicast address
supplied is not a multicast addressMethod Detail |
public static void main(java.lang.String[] args)
public RMStreamSocket createRMStreamSocket(int sendReceive) throws UnsupportedException, InvalidTransportProfileException, java.io.IOException
createRMStreamSocket
in interface TransportProfile
sendReceive
- indicates whether this socket is being used
to send or receive data. The code automatically fills in the
tmode and mrole fields based on this parameter.UnsupportedException
- if the transport does not
support a stream interface.InvalidTransportProfileException
- if the TransportProfile
is not validjava.io.IOException
- if an I/O exception occurs.public RMStreamSocket createRMStreamSocket(int sendReceive, java.net.InetAddress interfaceAddress) throws UnsupportedException, InvalidTransportProfileException, java.io.IOException
sendReceive
- indicates whether this socket is being used
to send or receive data. The code automatically fills in the
tmode and mrole fields based on this parameter.interfaceAddress
- indicates the IP address of the interface
to use for the multicast socket.UnsupportedException
- if the transport does not
support a stream interface.InvalidTransportProfileException
- if the TransportProfile
is not validjava.io.IOException
- if an I/O exception occurs.public RMPacketSocket createRMPacketSocket(int sendReceive) throws UnsupportedException, InvalidTransportProfileException, java.io.IOException
createRMPacketSocket
in interface TransportProfile
sendReceive
- indicates whether this socket is being used
to send or receive data. The code automatically fills in the
tmode and mrole fields based on this parameter.UnsupportedException
- if the transport does not
support a packet interface.InvalidTransportProfileException
- if the TransportProfile
is not validjava.io.IOException
- if an I/O exception occurs.public RMPacketSocket createRMPacketSocket(int sendReceive, java.net.InetAddress interfaceAddress) throws UnsupportedException, InvalidTransportProfileException, java.io.IOException
sendReceive
- indicates whether this socket is being used
to send or receive data. The code automatically fills in the
tmode and mrole fields based on this parameter.interfaceAddress
- indicates the IP address of the interface
to use for the multicast socket.UnsupportedException
- if the transport does not
support a packet interface.InvalidTransportProfileException
- if the TransportProfile
is not validjava.io.IOException
- if an I/O exception occurs.public RMPacketSocket createRMPacketSocket(int sendReceive, TRAMSimulator simulator) throws UnsupportedException, InvalidTransportProfileException, java.io.IOException
sendReceive
- indicates whether this socket is being used
to send or receive data. The code automatically fills in the
tmode and mrole fields based on this parameter.simulator
- specifies the simulator object being usedUnsupportedException
- if the transport does not
support a packet interface.InvalidTransportProfileException
- if the TransportProfile
is not validjava.io.IOException
- if an I/O exception occurs.public RMPacketSocket createRMPacketSocket(int sendReceive, java.net.InetAddress interfaceAddress, TRAMSimulator simulator) throws UnsupportedException, InvalidTransportProfileException, java.io.IOException
sendReceive
- indicates whether this socket is being used
to send or receive data. The code automatically fills in the
tmode and mrole fields based on this parameter.interfaceAddress
- indicates the IP address of the interface
to use for the multicast socket.simulator
- specifies the simulator object being usedUnsupportedException
- if the transport does not
support a packet interface.InvalidTransportProfileException
- if the TransportProfile
is not validjava.io.IOException
- if an I/O exception occurs.public java.lang.Object clone()
clone
in interface TransportProfile
clone
in class java.lang.Object
public boolean isValid()
isValid
in interface TransportProfile
true
if the TransportProfile is valid;
false
otherwisepublic java.lang.String getName()
getName
in interface TransportProfile
public boolean getSAhead()
true
if REPAIR_NODE flag is set(turned on).
false
if REPAIR_NODE flag is turned off.public java.net.InetAddress getAddress()
getAddress
in interface TransportProfile
public void setAddress(java.net.InetAddress address) throws InvalidMulticastAddressException
setAddress
in interface TransportProfile
address
- the new multicast address.InvalidMulticastAddressException
- if an
the address specified is not a multicast address.public int getPort()
getPort
in interface TransportProfile
public void setPort(int port)
setPort
in interface TransportProfile
port
- the new multicast port number.public byte getTTL()
getTTL
in interface TransportProfile
public void setTTL(byte ttl)
setTTL
in interface TransportProfile
ttl
- the value of the time-to-live parameter.public boolean isMultiSender()
isMultiSender
in interface TransportProfile
public void setMultiSender(boolean multisender) throws UnsupportedException
setMultiSender
in interface TransportProfile
multisender
- true if the application wishes to support
multiple senders; false otherwiseUnsupportedException
- if the transport does not
support multiple senders.public boolean isOrdered()
isOrdered
in interface TransportProfile
public boolean isUsingAuthentication()
isUsingAuthentication
in interface TransportProfile
public void setOrdered(boolean ordered)
setOrdered
in interface TransportProfile
ordered
- true to enable; false to disable ordering.public byte getMrole()
MROLE
public void setMrole(byte mrole) throws java.lang.IllegalArgumentException
mrole
- the mrole value that is to be set. Default is MEMBER_ONLY.java.lang.IllegalArgumentException
- if the mrole value is
invalid.MROLE
public byte getTmode()
TMODE
public void setTmode(byte tmode) throws java.lang.IllegalArgumentException
tmode
- the tmode value that is to be set. Default is RECEIVE_ONLY.java.lang.IllegalArgumentException
- if the tmode value is invalid.TMODE
public short getMaxMembers()
public void setMaxMembers(short maxMembers)
maxMembers
- The maximum count of members that a group head can
accommodate. Default is 32.public long getHelloRate()
public void setHelloRate(long helloRate)
helloRate
- The preferred helloRate value(in milliseconds) that is
to be set. Default is 1000 ms.public long getPruneHelloRate()
public void setPruneHelloRate(long pruneHelloRate)
pruneHelloRate
- The preferred pruneHelloRate value
(in milliseconds) that is to be set. Default is 1000 ms.public long getMsRate()
public void setMsRate(long msRate)
msRate
- The required MS Rate(in Milliseconds) that is to be
set. Default is 500 ms.public long getBeaconRate()
public void setBeaconRate(long beaconRate)
beaconRate
- The beacon Rate value(in milliseconds) that
is to be set. Default is 1000 ms.public short getAckWindow()
public void setAckWindow(short ackWindow)
ackWindow
- The acknowledge window size(in terms of packets)
that is to be set. The default value is 32 packets. At high data rates,
it makes sense to increase this value.public void setCongestionWindow(int congestionWindow)
congestionWindow
- the number of packets in the congestion window.
The default is 32 packets.public int getCongestionWindow()
public short getNackReportWindow()
public void setNackReportWindow(short nackReportWindow)
nackReportWindow
- The required negative Acknowledgement window
size that is to be set. Default is 5.public byte getMaxHelloMisses()
public void setMaxHelloMisses(byte maxHelloMisses)
maxHelloMisses
- The required count of hello messages to be
missed continuously to declare a head inactive. Default value is 4.public byte getBeaconTTLIncrements()
public void setBeaconTTLIncrements(byte beaconTTLIncrements)
beaconTTLIncrements
- The required TTL steps by which multicast
scope of the Beacon message is to be increased. Default is 2.public int getUnicastPort()
public void setUnicastPort(int unicastPort)
unicastPort
- The unicast port value that is to be set.public double getTransferDataSize()
public void setTransferDataSize(double transferDataSize)
transferDataSize
- The required size of the data that is to be
transferred(in bytes). Default is 0.public long getTransferDuration()
Note: This is currently not supported.
public void setTransferDuration(long transferDuration)
Note: This is currently not supported.
transferDuration
- The required duration of data transfer in
minutes. Default is 0.public long getMinDataRate()
public void setMinDataRate(long minDataRate)
minDataRate
- the minimum rate of transmission in bytes/second.
default is 0.public long getMaxDataRate()
public void setMaxDataRate(long maxDataRate)
maxDataRate
- the maximum rate of transmission in bytes/second.
Default is 64000.public java.net.InetAddress getDataSourceAddress()
public void setDataSourceAddress(java.net.InetAddress dataSourceAddress)
dataSourceAddress
- the source address of the multicast data
stream.public void setLogMask(int logMask)
logMask
- - the level of logging required to be turned on.public boolean isLoggingEnabled()
true
if logging is enabled/turned on.
false
if logging is disabled/turned off.public boolean isLoggingEnabled(int testLogMask)
public int getLogMask()
public void setLanTreeFormation(boolean b)
b
- true
to enable/turn on.
false
to disable/turn off.public boolean isLanTreeFormationEnabled()
true
if lan tree formation is enabled/turned on.
false
if lan tree formation is disabled/turned off.public int getMaxNonHeads()
public void setMaxNonHeads(int maxNonHeads)
maxNonHeads
- the new limit of maximum non eager
that is to be set.public byte getHaTTLIncrements()
public void setHaTTLIncrements(byte haTTLIncrements)
haTTLIncrements
- The preferred TTL steps by which multicast
scope of the HA message is to be increased. Default is 2.public byte getHaTTLLimit()
public void setHaTTLLimit(byte haTTLLimit)
haTTLLimit
- The TTL limit of the Head Advertisement message.public byte getMsTTLIncrements()
public void setMsTTLIncrements(byte msTTLIncrements)
msTTLIncrements
- The preferred TTL steps by which multicast
scope of the HA message is to be increased. Default is 2.public long getMaxHABWWhileDataTransfer()
public void setMaxHABWWhileDataTransfer(long maxHABWWhileDataTransfer)
maxHABWWhileDataTransfer
- the maximum bandwidth for HA
HA messages during data transfer. Default is 0 bytes/sec.public long getMaxHABWWhileTreeForming()
public void setMaxHABWWhileTreeForming(long maxHABWWhileTreeForming)
maxHABWWhileTreeForming
- the maximum bandwidth for HA
HA messages before data transfer. Default is Max Data
rate value.public long getHaInterval()
public void setHaInterval(long haInterval)
haInterval
- The preferred HAInterval value(in milliseconds) that
is to be set. Default is 1000 ms.public int getLateJoinPreference()
public void setLateJoinPreference(int lateJoinPreference)
lateJoinPreference
- The preferred late join preference that
is to be set. Default is LATE_JOIN_WITH_LIMITED_RECOVERY.public int getTreeFormationPreference(boolean mask)
public void setTreeFormationPreference(int treeFormationPreference)
treeFormationPreference
- The preferred late join preference that
is to be set. Default is LATE_JOIN_WITH_LIMITED_RECOVERY.public int getMaxBuf()
public void setMaxBuf(int size)
size
- the new maximum buffer size.public void enableAuthentication()
enableAuthentication
in interface TransportProfile
public void disableAuthentication()
disableAuthentication
in interface TransportProfile
public java.lang.String getAuthenticationSpecFileName()
getAuthenticationSpecFileName
in interface TransportProfile
public void setAuthenticationSpecFileName(java.lang.String specFileName)
setAuthenticationSpecFileName
in interface TransportProfile
specFileName
- the name of the authentication Spec file name.public java.lang.String getAuthenticationSpecPassword()
getAuthenticationSpecPassword
in interface TransportProfile
public void setAuthenticationSpecPassword(java.lang.String password)
setAuthenticationSpecPassword
in interface TransportProfile
password
- the password for the authenticationSpec.public int getSessionId()
public void setSessionId(int sessionId)
the
- session ID associated with this transport profile.public void setSmoothTransmission(boolean smoothTransmission)
public boolean isSmoothTransmission()
public void setCacheSize(int cacheSize)
public int getCacheSize()
public void setMaxPruneTime(int time)
public int getMaxPruneTime()
public void setreaffiliateAfterBeingDisowned(boolean rad)
public boolean reaffiliateAfterBeingDisowned()
public void setDecentralizedPruning(boolean decentralizedPruning)
public boolean decentralizedPruning()
public void setPruningWindow(double pruningWindow)
public double getPruningWindow()
public void setReceiverMaxDataRate(long receiverMaxDataRate)
public long getReceiverMaxDataRate()
public void setMaxConsecutiveCongestionCount(int maxConsecutiveCongestionCount)
public int getMaxConsecutiveCongestionCount()
public void setReceiveBufferSize(int rbs)
public int getReceiveBufferSize()
public void setRateIncreaseFactor(double rateIncreaseFactor)
public double getRateIncreaseFactor()
public void setTimeForAvgRateCalc(int timeForAverageRateCalc)
public int getTimeForAvgRateCalc()
public void setMissingPacketThreshold(int missingPacketThreshold)
public int getMissingPacketThreshold()
public void setMaxCongestionWindowMultiple(int congestionWindowMultiple)
public int getMaxCongestionWindowMultiple()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
JavaTM Reliable MulticastTM Service version 1.1
Copyright (c) 2001, Sun Microsystems Laboratories, All rights reserved.