name = theName;
}
+ @Override
public String getName() {
return name;
}
public class DuplicateMappingParamFilter implements Filter {
+ @Override
public void init(FilterConfig filterConfig) throws ServletException {
// NO-OP
}
+ @Override
public void doFilter(ServletRequest req, ServletResponse res,
FilterChain chain) throws ServletException, IOException {
chain.doFilter(req, res);
}
+ @Override
public void destroy() {
// destroy
}
private FilterConfig _filterConfig;
+ @Override
public void init(FilterConfig filterConfig) throws ServletException {
_filterConfig = filterConfig;
}
+ @Override
public void doFilter(ServletRequest req, ServletResponse res,
FilterChain chain) throws ServletException, IOException {
PrintWriter out = res.getWriter();
chain.doFilter(req, res);
}
+ @Override
public void destroy() {
// destroy
}
public class TestTomcatSSL extends TomcatBaseTest {
static TrustManager[] trustAllCerts = new TrustManager[] {
new X509TrustManager() {
+ @Override
public X509Certificate[] getAcceptedIssuers() {
return null;
}
+ @Override
public void checkClientTrusted(X509Certificate[] certs,
String authType) {
// NOOP - Trust everything
}
+ @Override
public void checkServerTrusted(X509Certificate[] certs,
String authType) {
// NOOP - Trust everything
* TODO Implement this org.apache.catalina.tribes.tipis.RpcCallback
* method
*/
+ @Override
public void leftOver(Serializable msg, Member sender) {
System.out.println("Received a left over message from ["+sender.getName()+"] with data ["+msg+"]");
}
* TODO Implement this org.apache.catalina.tribes.tipis.RpcCallback
* method
*/
+ @Override
public Serializable replyRequest(Serializable msg, Member sender) {
System.out.println("Received a reply request message from ["+sender.getName()+"] with data ["+msg+"]");
return "Reply("+name+"):"+msg;
}
+ @Override
public void run() {
long counter = 0;
while (counter<count) {
final String lext = ext;
if (dir.isDirectory()) {
names = dir.list(new FilenameFilter() {
+ @Override
public boolean accept(File d, String name) {
if (name.endsWith(lext)) {
return true;
}
+ @Override
public void run() {
long counter = 0;
* TODO Implement this org.apache.catalina.tribes.MembershipListener
* method
*/
+ @Override
public void memberAdded(Member member) {
log.info("Member added:"+member);
synchronized (mutex) {
* TODO Implement this org.apache.catalina.tribes.MembershipListener
* method
*/
+ @Override
public void memberDisappeared(Member member) {
log.info("Member disappeared:"+member);
}
+ @Override
public boolean accept(Serializable msg, Member mbr){
return (msg instanceof LoadMessage) || (msg instanceof ByteMessage);
}
+ @Override
public void messageReceived(Serializable msg, Member mbr){
if ( receiveStart == 0 ) receiveStart = System.currentTimeMillis();
if ( debug ) {
* will always return false since we rely on the
* lazy map to do all the messaging for us
*/
+ @Override
public boolean accept(Serializable msg, Member source) {
//simple refresh the table model
table.dataModel.getValueAt(-1,-1);
* @param msg - the message received
* @param source - the sending member
*/
+ @Override
public void messageReceived(Serializable msg, Member source) {
// NOOP
}
/**
* Invoked when a member is added to the group
*/
+ @Override
public void memberAdded(Member member) {
// NOOP
}
/**
* Invoked when a member leaves the group
*/
+ @Override
public void memberDisappeared(Member member) {
//just refresh the table model
table.dataModel.getValueAt(-1,-1);
"isProxy",
"isBackup"};
+ @Override
public int getColumnCount() { return columnNames.length; }
+ @Override
public int getRowCount() {return map.sizeFull() +1; }
public StringBuilder getMemberNames(Member[] members){
return buf;
}
+ @Override
public Object getValueAt(int row, int col) {
if ( row==-1 ) {
update();
return button;
}
+ @Override
public void actionPerformed(ActionEvent e) {
System.out.println(e.getActionCommand());
if ( "add".equals(e.getActionCommand()) ) {
return props;
}
+ @Override
public void memberAdded(Member member) {
try {
System.out.println("Received member added:"+member);
}
}
+ @Override
public void memberDisappeared(Member member) {
try {
System.out.println("Received member disappeared:"+member);
public static class Listener implements ChannelListener {
long count = 0;
+ @Override
public boolean accept(Serializable s, Member m) {
return (s instanceof Data);
}
+ @Override
public void messageReceived(Serializable s, Member m) {
Data d = (Data)s;
if ( !Data.verify(d) ) {
public Listener() {
Arrays.fill(nrs, 0);
}
+ @Override
public boolean accept(Serializable s, Member m) {
return (s instanceof Data);
}
+ @Override
public void messageReceived(Serializable s, Member m) {
try {
Data d = (Data)s;
public static class Listener implements ChannelListener {
long noErrCnt = 0;
long errCnt = 0;
+ @Override
public boolean accept(Serializable s, Member m) {
return (s instanceof Data);
}
+ @Override
public void messageReceived(Serializable s, Member m) {
Data d = (Data)s;
if ( !Data.verify(d) ) {
public Listener() {
Arrays.fill(nrs, 0);
}
+ @Override
public boolean accept(Serializable s, Member m) {
return (s instanceof Data);
}
+ @Override
public void messageReceived(Serializable s, Member m) {
try {
Data d = (Data)s;
final AtomicInteger value = new AtomicInteger(0);
final Queue<Exception> exceptionQueue = new ConcurrentLinkedQueue<Exception>();
Runnable run = new Runnable() {
+ @Override
public void run() {
for (int i = 0; i < 100; i++) {
try {
int cnt = 0;
int total = 0;
boolean fail = false;
+ @Override
public synchronized void messageReceived(Serializable msg, Member sender) {
total++;
Integer i = (Integer)msg;
}
+ @Override
public boolean accept(Serializable msg, Member sender) {
return (msg instanceof Integer);
}
this.name = name;
}
+ @Override
public void messageReceived(Serializable msg, Member sender) {
System.out.println("["+name+"] Received message:"+msg+" from " + sender.getName());
}
+ @Override
public boolean accept(Serializable msg, Member sender) {
return true;
}
}
public ArrayList<Member> members = new ArrayList<Member>();
+ @Override
public void memberAdded(Member member) {
if (!members.contains(member)) {
members.add(member);
}
}
+ @Override
public void memberDisappeared(Member member) {
if (members.contains(member)) {
members.remove(member);
}
public ArrayList<Member> members = new ArrayList<Member>();
+ @Override
public void memberAdded(Member member) {
if (!members.contains(member)) {
members.add(member);
}
}
+ @Override
public void memberDisappeared(Member member) {
if (members.contains(member)) {
members.remove(member);
this.name = name;
}
public ArrayList<Member> members = new ArrayList<Member>();
+ @Override
public void memberAdded(Member member) {
if ( !members.contains(member) ) {
members.add(member);
}
}
+ @Override
public void memberDisappeared(Member member) {
if ( members.contains(member) ) {
members.remove(member);
boolean first = true;
+ @Override
public void messageReceived(ChannelMessage msg) {
if (first) {
first = false;
}
}
+ @Override
public boolean accept(ChannelMessage msg) {
synchronized (this) {accept++;}
return true;
private volatile long currentMillis = 0;
private volatile Date currentDate = null;
+ @Override
public void run() {
getCurrentDate();
}
private ThreadLocal<Date> currentDateLocal = new ThreadLocal<Date>();
+ @Override
public void run() {
getCurrentDate();
}
private ThreadLocal<Date> currentDateLocal = new ThreadLocal<Date>();
+ @Override
public void run() {
getCurrentDate();
}
}
};
+ @Override
public void run() {
getCurrentDate();
}
private SimpleDateFormat timeFormatter = new SimpleDateFormat(
"hh:mm:ss");
+ @Override
public void run() {
printDate();
}
}
};
+ @Override
public void run() {
printDate();
}
}
};
+ @Override
public void run() {
printDate();
}
}
};
+ @Override
public void run() {
printDate();
}
this.test = test;
}
+ @Override
public void run() {
for (int i = 0; i < count; i++) {
test.run();
projects / tomcat7.0 / commitdiff