Java Doc for TcpFailureDetector.java in » Sevlet-Container » apache-tomcat-6.0.14 » org » apache » catalina » tribes » group » interceptors » Java Source Code / Java DocumentationJava Source Code and Java Documentation

Java Source Code / Java Documentation

1.	6.0 JDK Core
2.	6.0 JDK Modules
3.	6.0 JDK Modules com.sun
4.	6.0 JDK Modules com.sun.java
5.	6.0 JDK Modules sun
6.	6.0 JDK Platform
7.	Ajax
8.	Apache Harmony Java SE
9.	Aspect oriented
10.	Authentication Authorization
11.	Blogger System
12.	Build
13.	Byte Code
14.	Cache
15.	Chart
16.	Chat
17.	Code Analyzer
18.	Collaboration
19.	Content Management System
20.	Database Client
21.	Database DBMS
22.	Database JDBC Connection Pool
23.	Database ORM
24.	Development
25.	EJB Server geronimo
26.	EJB Server GlassFish
27.	EJB Server JBoss 4.2.1
28.	EJB Server resin 3.1.5
29.	ERP CRM Financial
30.	ESB
31.	Forum
32.	GIS
33.	Graphic Library
34.	Groupware
35.	HTML Parser
36.	IDE
37.	IDE Eclipse
38.	IDE Netbeans
39.	Installer
40.	Internationalization Localization
41.	Inversion of Control
42.	Issue Tracking
43.	J2EE
44.	JBoss
45.	JMS
46.	JMX
47.	Library
48.	Mail Clients
49.	Net
50.	Parser
51.	PDF
52.	Portal
53.	Profiler
54.	Project Management
55.	Report
56.	RSS RDF
57.	Rule Engine
58.	Science
59.	Scripting
60.	Search Engine
61.	Security
62.	Sevlet Container
63.	Source Control
64.	Swing Library
65.	Template Engine
66.	Test Coverage
67.	Testing
68.	UML
69.	Web Crawler
70.	Web Framework
71.	Web Mail
72.	Web Server
73.	Web Services
74.	Web Services apache cxf 2.0.1
75.	Web Services AXIS2
76.	Wiki Engine
77.	Workflow Engines
78.	XML
79.	XML UI

Java

Java Tutorial

Illustrator Tutorials

GIMP Tutorials

C# / C Sharp

C# / CSharp Tutorial

C# / CSharp Open Source

SQL Server / T-SQL Tutorial

Oracle PL / SQL

Oracle PL/SQL Tutorial

Flash / Flex / ActionScript

VBA / Excel / Access / Word

XML

XML Tutorial

Microsoft Office PowerPoint 2007 Tutorial

Microsoft Office Excel 2007 Tutorial

Microsoft Office Word 2007 Tutorial

Java Source Code / Java Documentation » Sevlet Container » apache tomcat 6.0.14 » org.apache.catalina.tribes.group.interceptors

Source Cross Reference

Class Diagram

Java Document (Java Doc)

java.lang .Object

org.apache.catalina.tribes.group .ChannelInterceptorBase

org.apache.catalina.tribes.group.interceptors .TcpFailureDetector

TcpFailureDetector

public class TcpFailureDetector extends ChannelInterceptorBase (Code)

Title: A perfect failure detector

Description: The TcpFailureDetector is a useful interceptor that adds reliability to the membership layer.

If the network is busy, or the system is busy so that the membership receiver thread is not getting enough time to update its table, members can be "timed out" This failure detector will intercept the memberDisappeared message(unless its a true shutdown message) and connect to the member using TCP.

The TcpFailureDetector works in two ways.
1. It intercepts memberDisappeared events 2. It catches send errors

author:
Filip Hanik
version:
1.0

Field Summary
protected static byte[]	TCP_FAIL_DETECT
protected HashMap	addSuspects
protected long	connectTimeout
protected Membership	membership
protected boolean	performConnectTest
protected boolean	performReadTest
protected boolean	performSendTest
protected long	readTestTimeout
protected HashMap	removeSuspects

Method Summary
public void	checkMembers(boolean checkAll)
public Member	getLocalMember(boolean incAlive)
public Member	getMember(Member mbr)
public Member[]	getMembers()
public boolean	hasMembers()
public void	heartbeat()
public void	memberAdded(Member member)
protected boolean	memberAlive(Member mbr)
protected static boolean	memberAlive(Member mbr, byte[] msgData, boolean sendTest, boolean readTest, long readTimeout, long conTimeout, int optionFlag)
public void	memberDisappeared(Member member)
public void	messageReceived(ChannelMessage msg)
protected void	performBasicCheck()
protected void	performForcedCheck()
public void	sendMessage(Member[] destination, ChannelMessage msg, InterceptorPayload payload)
protected synchronized void	setupMembership()

Field Detail

TCP_FAIL_DETECT
protected static byte[] TCP_FAIL_DETECT(Code)

addSuspects
protected HashMap addSuspects(Code)

connectTimeout
protected long connectTimeout(Code)

membership
protected Membership membership(Code)

performConnectTest
protected boolean performConnectTest(Code)

performReadTest
protected boolean performReadTest(Code)

performSendTest
protected boolean performSendTest(Code)

readTestTimeout
protected long readTestTimeout(Code)

removeSuspects
protected HashMap removeSuspects(Code)

Method Detail

checkMembers
public void checkMembers(boolean checkAll)(Code)

getLocalMember
public Member getLocalMember(boolean incAlive)(Code)

getMember
public Member getMember(Member mbr)(Code)

getMembers
public Member[] getMembers()(Code)

hasMembers
public boolean hasMembers()(Code)

heartbeat
public void heartbeat()(Code)

memberAdded
public void memberAdded(Member member)(Code)

memberAlive
protected boolean memberAlive(Member mbr)(Code)

memberAlive
protected static boolean memberAlive(Member mbr, byte[] msgData, boolean sendTest, boolean readTest, long readTimeout, long conTimeout, int optionFlag)(Code)

memberDisappeared
public void memberDisappeared(Member member)(Code)

messageReceived
public void messageReceived(ChannelMessage msg)(Code)

performBasicCheck
protected void performBasicCheck()(Code)

performForcedCheck
protected void performForcedCheck()(Code)

sendMessage
public void sendMessage(Member[] destination, ChannelMessage msg, InterceptorPayload payload) throws ChannelException(Code)

setupMembership
protected synchronized void setupMembership()(Code)

Fields inherited from org.apache.catalina.tribes.group.ChannelInterceptorBase

protected static org.apache.juli.logging.Log log(Code)(Java Doc)
protected int optionFlag(Code)(Java Doc)

Methods inherited from org.apache.catalina.tribes.group.ChannelInterceptorBase

public boolean accept(ChannelMessage msg)(Code)(Java Doc)
public void fireInterceptorEvent(InterceptorEvent event)(Code)(Java Doc)
public Member getLocalMember(boolean incAlive)(Code)(Java Doc)
public Member getMember(Member mbr)(Code)(Java Doc)
public Member[] getMembers()(Code)(Java Doc)
final public ChannelInterceptor getNext()(Code)(Java Doc)
public int getOptionFlag()(Code)(Java Doc)
final public ChannelInterceptor getPrevious()(Code)(Java Doc)
public boolean hasMembers()(Code)(Java Doc)
public void heartbeat()(Code)(Java Doc)
public void memberAdded(Member member)(Code)(Java Doc)
public void memberDisappeared(Member member)(Code)(Java Doc)
public void messageReceived(ChannelMessage msg)(Code)(Java Doc)
public boolean okToProcess(int messageFlags)(Code)(Java Doc)
public void sendMessage(Member[] destination, ChannelMessage msg, InterceptorPayload payload) throws ChannelException(Code)(Java Doc)
final public void setNext(ChannelInterceptor next)(Code)(Java Doc)
public void setOptionFlag(int optionFlag)(Code)(Java Doc)
final public void setPrevious(ChannelInterceptor previous)(Code)(Java Doc)
public void start(int svc) throws ChannelException(Code)(Java Doc)
public void stop(int svc) throws ChannelException(Code)(Java Doc)

Methods inherited from java.lang.Object

native protected Object clone() throws CloneNotSupportedException(Code)(Java Doc)
public boolean equals(Object obj)(Code)(Java Doc)
protected void finalize() throws Throwable(Code)(Java Doc)
final native public Class getClass()(Code)(Java Doc)
native public int hashCode()(Code)(Java Doc)
final native public void notify()(Code)(Java Doc)
final native public void notifyAll()(Code)(Java Doc)
public String toString()(Code)(Java Doc)
final native public void wait(long timeout) throws InterruptedException(Code)(Java Doc)
final public void wait(long timeout, int nanos) throws InterruptedException(Code)(Java Doc)
final public void wait() throws InterruptedException(Code)(Java Doc)

www.java2java.com | Contact Us

All other trademarks are property of their respective owners.