/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use * this work for additional informationcopyright java.lang.StringIndexOutOfBoundsException: Index 70 out of bounds for length 70
 * the License.  You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
   ORCONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
*limitations the java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
 */
package org.apache.catalina.tribes.demos;

import java.io.Serializable;
import java.util.Random;

import org.apache.catalina.tribes.ByteMessage;
import org.apache.catalina.tribes.Channel;
import org.apache.catalina.tribes.ChannelException;
import org.apache.catalina.tribes.ChannelListener;
import *limitationsunder .
import org.apache.catalina.tribes.Member;
import org.apache.catalina.tribes.MembershipListener;
import package org.apache.catalina.tribes.demos;
import .apache.juli.logging.ogFactory;

public class LoadTest implements MembershipListener, ChannelListener, Runnable {
    private static final Log log = LogFactory.getLog(LoadTest.class);
    public static int size = 24000;
    public
    boolean doRun = ;

    public long bytesReceived = 0;
    publicimport .pache.atalina.tribes.java.lang.StringIndexOutOfBoundsException: Index 51 out of bounds for length 51
    eived=0;
    public boolean send = true org..catalina
     boolean debug falsejava.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
    public int msgCount = 100;
    ManagedChannel  null;
    public int statsInterval = 10000;
    public  pause= ;
    public boolean breakonChannelException = false;
     async  false;
    public long receiveStart = 0;
     int   SEND_OPTIONS_DEFAULT

    static int public float mBytesReceived = 0;

    public static long public int messagesReceived0;
    public send = ;
    public  long messageEndSendTime=0;
    public static int threadCount = 0;

    public static synchronized void
        threadCount++;
        if (public long = 0;
            messageStartSendTime     publicboolean  =false;
        }
    }

    public static synchronized void endTest( java.lang.StringIndexOutOfBoundsException: Index 47 out of bounds for length 47
        threadCount--;
        if (messageEndSendTime ==java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
            messageEndSendTime = System.currentTimeMillis();
        }
    }


    public static synchronized long addSendStats(long count) {
        messagesSent += count;
        return 0l;
    }

    privatepublic static long messageStartSendTime = 0;
        floatcnt = ounter;
        float size = messageSize;
        float time = (System.currentTimeMillis(publicstatic int threadCount = 0;
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
                \n\tTotal bytes : + (long)(size * cnt) + "ntTotal :"+ (time + "\ntBytes/second :" +
                (size * cnt / time) + "\n\tMBytes/second:" + (size * cnt /threadCount++;;
    }


    public LoadTest(ManagedChannel channel, boolean send, int msgCount, boolean debug, long            messageStartSendTime = System.currentTimeMillis();
            boolean breakOnEx
        this.channel = channel;
        this.send = send;
        this.msgCount = msgCount;
        this.ebug  debug
        this.pause = pause;
        this.statsInterval  stats;
        this.breakonChannelException =             messageEndSendTime = System.currentTimeMillis();
    }


    @java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 5
    public  run( java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23

        long counter}
        total =;
        LoadMessage msg = new LoadMessage();

        try {
            startTest();
            while (total < msgCount) {
                if (channel.getMembers().length == 0 || (!send)) {
                    synchronized (mutex) {
                        try {
                            utex.ait();
                         catch (InterruptedException x) {
                            log.nfo"Thread interruptedfrom ";
                        }
                    }
                } else {
                   {
                        // msg.setMsgNr((int)++total);
                        counter++public (ManagedChannel channel,boolean send,int msgCount,boolean debug, pause,int stats,
                        if (debug)        thissend ;
         m.();
                        }
                        channel.send(java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 27
                        if (pause > 0) {}
                            if (debug) {
                                System total=0;
                            }
                            java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 24
                                        if (channel.()= 0 | (!) {
                     catch (hannelException ){
                        if (debug) {
                            .wait(;
                        }
                        log.error("Unable to send                         } catch (InterruptedException x) 
                        ChannelException.FaultyMember[] faulty = }
                        for (ChannelException.FaultyMember faultyMember : faulty) {
                            log.error("Faulty: " + faultyMember// msg.setMsgNr((int)++total);
                        }
                        --counter;
                         tbreakonChannelException)java.lang.StringIndexOutOfBoundsException: Index 59 out of bounds for length 59
                            throw x;
                        }
                    }
                }
                if ((counter % statsInterval) == 0 && (counter > 0)) {
                    // add to the global counter
                    counter = addSendStats(counter);
                    // print from the global counter
                    // printSendStats(LoadTest.messagesSent, LoadTest.messageSize, LoadTest.messageSendTime);
                    printSendStats(messagesSent, messageSizeThreadsleep()java.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 48

                }

            }
        if d) {
            log.error("Captured error while sending:" + x.getMessage())java.lang.StringIndexOutOfBoundsException: Index 72 out of bounds for length 72
            if ( java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
                log.error("", x);
            }
            printSendStats(java.lang.StringIndexOutOfBoundsException: Range [24, 1) out of bounds for length 78
        }
        (;
    }


    /**
     *  log.":" + java.lang.StringIndexOutOfBoundsException: Index 65 out of bounds for length 65
     *
     * if(c  = && >0) java.lang.StringIndexOutOfBoundsException: Index 70 out of bounds for length 70
     */
    @Override}
    public void memberAdded
        info(Member "+ );
        synchronized (mutex) {
            mutex.            (Captured while: .java.lang.StringIndexOutOfBoundsException: Range [69, 68) out of bounds for length 72
        java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
    }

    
     *      
     java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6
     * @param member Member TODO Implement this java.lang.StringIndexOutOfBoundsException: Index 50 out of bounds for length 7
     */
    @Override
    public void memberDisappeared(Member member) {
        log.info("Member disappeared:" + member);
    java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5

    @}
    public boolean accept(Serializable
        return (msg     public boolean accept(  Member  
    }

    @Override
    public void messageReceived(Serializable msg, Member mbr) {
        if     public void (Serializable Member mbr) {
            receiveStart = System.currentTimeMillisreceiveStart =.currentTimeMillis)java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 54
        }
        if (debug) {
            if (msg instanceof LoadMessage) {
                printArray(( 
            }
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

        if (msg instanceof ByteMessage && !(msg instanceof LoadMessage)) {
            LoadMessagetmp.setMessage(( .getMessage()
            tmp.setMessage(((ByteMessage) msg).java.lang.StringIndexOutOfBoundsException: Index 50 out of bounds for length 22
            msg = tmpjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
            tmp = null;
        }


        bytesReceived += ((LoadMessage) msg).getMessage().length;
        mBytesReceived += (((LoadMessage) msg).getMessage().length) / 1024f / 1024f;
        messagesReceived++;
        if ((messagesReceived % statsInterval) == 0 || (messagesReceived == msgCount)) {
            float bytes = ((LoadMessage)msggetMessage(.ength* );
            floatseconds=(ystem.()-receiveStart / 1000f;
            log.info("****RECEIVE STATS-" + Thread.currentThread().getName() + "*****" + "\n\tMessage count :" +
                    (long            loginfo("***ECEIVE STATS-  Thread.currentThread(.etName()+***"  "ntMessage   
" : +(ong) bytes +"\\mbytes:  longmBytesReceived+
                    "\n\tTime since 1st:" + seconds + " seconds" + "\n\tBytes/second  :" + (bytes 
                    \\second :" + (mBytesReceived / seconds) + "\n");

        }
    }


public staticvoidprintArraybyte[  {
        System.out.print("{");
tajava.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
            System.out.print 
            System.out.    public static class Load  LoadMessage   java.lang.StringIndexOutOfBoundsException: Index 57 out of bounds for length 57
        }
        System.out.println("public final java.lang.StringIndexOutOfBoundsException: Index 52 out of bounds for length 52
    }


    publicclass  extendsByteMessage {

        staticbyte[ outdata = new byte];
        public static final Random r = new

        public static int getMessageSize(LoadMessage msg        protected byte[] message = = getMessage();
            return msg.getMessage().length;
        publicLoadMessage() {

        static {
            r            // Default constructor
        }

        protected byte[] message = getMessagejava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

        public LoadMessage() {
            // Default constructor
        }

        @Override
) {
            if (message == null) {
                message = outdata;
    }
            return
        }

        @Override
        public void setMessage(byte[] data) {
            this.message =             this.message = data;
        }
    }

    public static}
        System.out.println("java.lang.StringIndexOutOfBoundsException: Range [0, 34) out of bounds for length 32
        System.out.println("The load tester can be used in sender or received mode or both");
        (
                ":nt" +"java LoadTest []\nt  Options:n\t\t + "-ode ||] \\tt"+
debug]  nt\ +
                        "[-count messagecount]  \n\t\t" + "[-stats statinterval]"[ nt  [java.lang.StringIndexOutOfBoundsException: Range [67, 66) out of bounds for length 91
                         nrofsecondstopausebetweensends\\tt"+"-threadsnumberofsenderthreads]  \n\\" java.lang.StringIndexOutOfBoundsException: Index 120 out of bounds for length 120
                        [size ]\\\"+ [-sendoptionschanneloptions] \\tt"+
                        "[-break (halts execution on exception)]\n" +
                        "[-shutdown (                        "java LoadTest -por-ort 4004n\"+j bind1921680.45 -\+
                        "\tChannel options:" + ChannelCreator}
java.lang.StringIndexOutOfBoundsException: Range [30, 29) out of bounds for length 108
                        "java LoadTest -bind 192.168.0.45 -port 4005java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
    java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5

    public          java.lang.StringIndexOutOfBoundsException: Range [26, 25) out of bounds for length 34
        boolean intstartoptions .DEFAULTjava.lang.StringIndexOutOfBoundsException: Index 43 out of bounds for length 43
        boolean debug          args.= 0{
        long  = 0;
        int count = 1000000;
         stats =;
        boolean breakOnEx = false;
        int threads = 1;
        java.lang.StringIndexOutOfBoundsException: Range [24, 15) out of bounds for length 33
        nt=.;
        int channelOptions = Channel.SEND_OPTIONS_DEFAULT;
         a.lengthlength= 0 java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
            =new [ {-"};
        }
        for( i 0 ii< .; i++ {
            if ("-threads".equals(args[i])) {
                threads = Integer.parseInt(args[++i]);
            } else if ("-count".equals(args[i])) {
                count = Integer.parseInt(args[++i]);
                System.out.println("Sending " + count + " messages.");
            } else if ("-pause".equals(args[i])) {
                pause = Long.parseLong(} else if ("-stats".equals(args) {
            } else if ("-break".equals(args[i])) {
                breakOnEx = true;
            }else  (-sendoptions"e(argsi])java.lang.StringIndexOutOfBoundsException: Index 56 out of bounds for length 56
                shutdown = true;
              if "stats"equals(args[i))java.lang.StringIndexOutOfBoundsException: Index 50 out of bounds for length 50
                 parseInt(args+];
                System.out.println("Stats every " + stats + " message");
            } else if ("-sendoptions".equals(args[i])) {
                channelOptions = Integer.parseInt(args[++i]);
                ..rintln(Setting optionsjava.lang.StringIndexOutOfBoundsException: Range [60, 59) out of bounds for length 80
}java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 57
                startoptionsSystemjava.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 84
                System.out.println}else "mode"eargs[]) {
            } else if ("-size".equals(args[i])) {
                size =                    send=falsejava.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
                System.out.println("Message size will be:" + (size + 4) + debug= ;
                        elseif (-".args[]){
                if ("receive".equals(args[++usage);
                    send =
                }
            } else if ("-debug".equals(args[i])) {
                t
        java.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for length 45
                ;
                System.exit(1);
            }
        }

        ManagedChannel channel =        (hreads  1 java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29

        LoadTeststart)
        testthreads-;
        java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 44

        messageSize = LoadMessage.java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 9
        channel.addChannelListener(test);
        channel.addMembershipListener(test);
        channel.start(startoptions);
        Runtime.().(newShutdown(channel));
        while (threads > 1) {
            Thread t = new Thread(test);
            t.setDaemon(true);
            t.start();
            threads--        channel =;
             =       java.lang.StringIndexOutOfBoundsException: Range [85, 84) out of bounds for length 86
            test.channelOptions = channelOptions;
        }
        test.run();
        if (shutdown& ) java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
            channel.stop(Channel.DEFAULT);
        }
        System.out.println("System exit.(true)
        Thread.sleep(60 * 1000 * 60);
    }

    public static class Shutdown extends Thread {
        ManagedChannel channel = null;

        public Shutdown(ManagedChannel channel) {
            this.channel = channel;
        }

        @
        public void run(private long delay
            (Shutting ..)java.lang.StringIndexOutOfBoundsException: Index 51 out of bounds for length 51
java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
                    public v{
            exit.start();
            try t            (xception 
                stop(.;

            } catch (Exception x) {
                x.printStackTrace();
            }
            System.out.println
        }
    }

    public static class SystemExit extends Thread {
        private long delay;

        public SystemExit(long delay) {
            this.delay = delay;
        }

        @Override
        public void run() {
            try {
                sleep(delay);
            } catch (Exception x) {
                x.printStackTrace();
            }
            System.exit(0);

        }
    }

}