Package org.jgroups.protocols
Class BasicTCP
- java.lang.Object
-
- org.jgroups.stack.Protocol
-
- org.jgroups.protocols.TP
-
- org.jgroups.protocols.BasicTCP
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.jgroups.protocols.TP
TP.ProbeHandler, TP.ProtocolAdapter
-
-
Field Summary
Fields Modifier and Type Field Description protected long
conn_expire_time
protected int
end_port
protected java.net.InetAddress
external_addr
protected long
reaper_interval
protected int
start_port
-
Fields inherited from class org.jgroups.protocols.TP
bind_addr, channel_name, discard_incompatible_packets, global_thread_factory, local_addr, members, persistent_ports, persistent_ports_file, pm, pm_expiry_time, thread_naming_pattern, timer, timer_thread_factory, view
-
-
Constructor Summary
Constructors Constructor Description BasicTCP()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description long
getConnExpireTime()
int
getEndPort()
java.lang.String
getInfo()
long
getReaperInterval()
int
getStartPort()
protected java.lang.Object
handleDownEvent(Event evt)
void
init()
Called after instance has been created (null constructor) and before protocol is started.void
postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
void
postUnmarshallingList(Message msg, Address dest, boolean multicast)
abstract java.lang.String
printConnections()
void
receive(Address sender, byte[] data, int offset, int length)
ConnectionTable.Receiver interfaceabstract void
retainAll(java.util.Collection<Address> members)
abstract void
send(Address dest, byte[] data, int offset, int length)
void
sendToAllMembers(byte[] data, int offset, int length)
Send to all members in the group.void
sendToSingleMember(Address dest, byte[] data, int offset, int length)
Send to all members in the group.void
setConnExpireTime(long conn_expire_time)
void
setEndPort(int end_port)
boolean
setProperties(java.util.Properties props)
Setup the Protocol instance according to the configuration stringvoid
setReaperInterval(long reaper_interval)
void
setStartPort(int start_port)
-
Methods inherited from class org.jgroups.protocols.TP
createThreadPool, destroy, down, dumpStats, getBindAddress, getBindPort, getBindToAllInterfaces, getChannelName, getDefaultThreadPool, getDefaultThreadPoolThreadFactory, getIncomingKeepAliveTime, getIncomingMaxPoolSize, getIncomingMaxQueueSize, getIncomingMessages, getIncomingMinPoolSize, getIncomingPoolSize, getIncomingQueueSize, getLocalAddress, getMaxBundleSize, getMaxBundleTimeout, getNumBytesReceived, getNumBytesSent, getNumMessagesReceived, getNumMessagesSent, getOOBKeepAliveTime, getOOBMaxPoolSize, getOOBMaxQueueSize, getOOBMessages, getOOBMinPoolSize, getOOBPoolSize, getOOBQueueSize, getOOBThreadPool, getOOBThreadPoolThreadFactory, getReceiveInterfaces, getSendInterfaces, getSingletonName, getThreadFactory, getThreadNamingPattern, getTimer, getTimerThreadFactory, getUpProtocols, handleConfigEvent, handleConnect, handleDisconnect, isDefaulThreadPoolEnabled, isDiscardIncompatiblePackets, isEnable_unicast_bundling, isEnableBundling, isLoopback, isOOBThreadPoolEnabled, isReceiveOnAllInterfaces, isSendOnAllInterfaces, isUseIncomingPacketHandler, passToAllUpProtocols, receive, registerProbeHandler, resetStats, sendUpLocalAddressEvent, setBindAddress, setBindPort, setBindToAllInterfaces, setDefaultThreadPool, setDefaultThreadPoolThreadFactory, setDiscardIncompatiblePackets, setEnable_unicast_bundling, setEnableBundling, setIncomingKeepAliveTime, setIncomingMaxPoolSize, setIncomingMinPoolSize, setLoopback, setMaxBundleSize, setMaxBundleTimeout, setOOBKeepAliveTime, setOOBMaxPoolSize, setOOBMinPoolSize, setOOBThreadPool, setOOBThreadPoolThreadFactory, setThreadFactory, setThreadNames, setTimerThreadFactory, start, stop, toString, unregisterProbeHandler, unsetThreadNames, up
-
Methods inherited from class org.jgroups.stack.Protocol
downThreadEnabled, enableStats, getDownProtocol, getName, getProperties, getProtocolStack, getTransport, getUpProtocol, printStats, providedDownServices, providedUpServices, requiredDownServices, requiredUpServices, setDownProtocol, setPropertiesInternal, setProtocolStack, setUpProtocol, statsEnabled, upThreadEnabled
-
-
-
-
Method Detail
-
getStartPort
public int getStartPort()
-
setStartPort
public void setStartPort(int start_port)
-
getEndPort
public int getEndPort()
-
setEndPort
public void setEndPort(int end_port)
-
getReaperInterval
public long getReaperInterval()
-
setReaperInterval
public void setReaperInterval(long reaper_interval)
-
getConnExpireTime
public long getConnExpireTime()
-
setConnExpireTime
public void setConnExpireTime(long conn_expire_time)
-
setProperties
public boolean setProperties(java.util.Properties props)
Description copied from class:TP
Setup the Protocol instance according to the configuration string- Overrides:
setProperties
in classTP
- Returns:
- true if no other properties are left. false if the properties still have data in them, ie , properties are left over and not handled by the protocol stack
-
init
public void init() throws java.lang.Exception
Description copied from class:Protocol
Called after instance has been created (null constructor) and before protocol is started. Properties are already set. Other protocols are not yet connected and events cannot yet be sent.
-
sendToAllMembers
public void sendToAllMembers(byte[] data, int offset, int length) throws java.lang.Exception
Description copied from class:TP
Send to all members in the group. UDP would use an IP multicast message, whereas TCP would send N messages, one for each member- Specified by:
sendToAllMembers
in classTP
- Parameters:
data
- The data to be sent. This is not a copy, so don't modify it- Throws:
java.lang.Exception
-
sendToSingleMember
public void sendToSingleMember(Address dest, byte[] data, int offset, int length) throws java.lang.Exception
Description copied from class:TP
Send to all members in the group. UDP would use an IP multicast message, whereas TCP would send N messages, one for each member- Specified by:
sendToSingleMember
in classTP
- Parameters:
dest
- Must be a non-null unicast addressdata
- The data to be sent. This is not a copy, so don't modify it- Throws:
java.lang.Exception
-
postUnmarshalling
public void postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
- Specified by:
postUnmarshalling
in classTP
-
postUnmarshallingList
public void postUnmarshallingList(Message msg, Address dest, boolean multicast)
- Specified by:
postUnmarshallingList
in classTP
-
printConnections
public abstract java.lang.String printConnections()
-
send
public abstract void send(Address dest, byte[] data, int offset, int length) throws java.lang.Exception
- Throws:
java.lang.Exception
-
retainAll
public abstract void retainAll(java.util.Collection<Address> members)
-
receive
public void receive(Address sender, byte[] data, int offset, int length)
ConnectionTable.Receiver interface
-
handleDownEvent
protected java.lang.Object handleDownEvent(Event evt)
- Overrides:
handleDownEvent
in classTP
-
-