TP.ProbeHandler, TP.ProtocolAdapter
Modifier and Type | Field and Description |
---|---|
protected long |
conn_expire_time |
protected int |
end_port |
protected java.net.InetAddress |
external_addr |
protected long |
reaper_interval |
protected int |
start_port |
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 and Description |
---|
BasicTCP() |
Modifier and Type | Method and 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 interface
|
abstract 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 string
|
void |
setReaperInterval(long reaper_interval) |
void |
setStartPort(int start_port) |
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
downThreadEnabled, enableStats, getDownProtocol, getName, getProperties, getProtocolStack, getTransport, getUpProtocol, printStats, providedDownServices, providedUpServices, requiredDownServices, requiredUpServices, setDownProtocol, setPropertiesInternal, setProtocolStack, setUpProtocol, statsEnabled, upThreadEnabled
protected java.net.InetAddress external_addr
protected int start_port
protected int end_port
protected long reaper_interval
protected long conn_expire_time
public int getStartPort()
public void setStartPort(int start_port)
public int getEndPort()
public void setEndPort(int end_port)
public long getReaperInterval()
public void setReaperInterval(long reaper_interval)
public long getConnExpireTime()
public void setConnExpireTime(long conn_expire_time)
public boolean setProperties(java.util.Properties props)
TP
setProperties
in class TP
public void init() throws java.lang.Exception
Protocol
public void sendToAllMembers(byte[] data, int offset, int length) throws java.lang.Exception
TP
sendToAllMembers
in class TP
data
- The data to be sent. This is not a copy, so don't modify itjava.lang.Exception
public void sendToSingleMember(Address dest, byte[] data, int offset, int length) throws java.lang.Exception
TP
sendToSingleMember
in class TP
dest
- Must be a non-null unicast addressdata
- The data to be sent. This is not a copy, so don't modify itjava.lang.Exception
public void postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)
postUnmarshalling
in class TP
public void postUnmarshallingList(Message msg, Address dest, boolean multicast)
postUnmarshallingList
in class TP
public abstract java.lang.String printConnections()
public abstract void send(Address dest, byte[] data, int offset, int length) throws java.lang.Exception
java.lang.Exception
public abstract void retainAll(java.util.Collection<Address> members)
public void receive(Address sender, byte[] data, int offset, int length)
protected java.lang.Object handleDownEvent(Event evt)
handleDownEvent
in class TP
Copyright ? 1998-2008 Bela Ban. All Rights Reserved.