Package org.jgroups.protocols
Class BasicTCP
java.lang.Object
org.jgroups.stack.Protocol
org.jgroups.protocols.TP
org.jgroups.protocols.BasicTCP
Shared base class for tcpip protocols
- Author:
- Scott Marlow
-
Nested Class Summary
Nested classes/interfaces inherited from class org.jgroups.protocols.TP
TP.ProbeHandler, TP.ProtocolAdapter
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected long
protected int
protected InetAddress
protected long
protected int
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 -
Method Summary
Modifier and TypeMethodDescriptionlong
int
getInfo()
long
int
protected 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 String
void
ConnectionTable.Receiver interfaceabstract void
retainAll
(Collection<Address> members) abstract void
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
(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
-
Field Details
-
external_addr
-
start_port
protected int start_port -
end_port
protected int end_port -
reaper_interval
protected long reaper_interval -
conn_expire_time
protected long conn_expire_time
-
-
Constructor Details
-
BasicTCP
public BasicTCP()
-
-
Method Details
-
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
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
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
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 itoffset
-length
-- Throws:
Exception
-
sendToSingleMember
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 itoffset
-length
-- Throws:
Exception
-
getInfo
-
postUnmarshalling
- Specified by:
postUnmarshalling
in classTP
-
postUnmarshallingList
- Specified by:
postUnmarshallingList
in classTP
-
printConnections
-
send
- Throws:
Exception
-
retainAll
-
receive
ConnectionTable.Receiver interface -
handleDownEvent
- Overrides:
handleDownEvent
in classTP
-