Changeset 102 for branches/supervisor


Ignore:
Timestamp:
10/14/13 16:38:34 (11 years ago)
Author:
stoda
Message:

All tests working

TODO sometimes exceptiontest fails

Location:
branches/supervisor
Files:
1 added
10 edited

Legend:

Unmodified
Added
Removed

  • branches/supervisor/src/main/java/omq/common/util/OmqConnectionFactory.java

    r83 r102  
    5757                                working = true;
    5858                        } catch (Exception e) {
     59//                              e.printStackTrace();
    5960                                logger.error(e);
    6061                                long milis = 2000;

  • branches/supervisor/src/main/java/omq/common/util/ParameterQueue.java

    r101 r102  
    132132         */
    133133
    134         /**
    135          * Set how many threads will be created to invoke remote methods
    136          */
    137         public static String NUM_THREADS = "omq.num_threads";
    138134
    139135        /**

  • branches/supervisor/src/main/java/omq/server/InvocationThread.java

    r101 r102  
    157157
    158158                }
     159                logger.info("ObjectMQ ('" + obj.getRef() + "') InvocationThread " + Thread.currentThread().getId() + " is killed");
    159160        }
    160161

  • branches/supervisor/src/main/java/omq/server/RemoteThreadPool.java

    r101 r102  
    44import java.util.ArrayList;
    55import java.util.List;
     6import java.util.ListIterator;
    67import java.util.concurrent.atomic.AtomicInteger;
    78
    … …  
    102103                long now = System.currentTimeMillis();
    103104
    104                 int i = 0;
    105                 for (InvocationThread worker : workers) {
    106                         // Ensure there are at least minThreads available
    107                         if (workers.size() == minPoolThreads) {
    108                                 break;
    109                         }
     105                ListIterator<InvocationThread> lIter = workers.listIterator();
     106                while (workers.size() > minPoolThreads && lIter.hasNext()) {
     107                        InvocationThread worker = lIter.next();
    110108                        long lastExec = worker.getLastExecution();
    111109                        System.out.println("last - now = " + (now - lastExec) + " keep alive = " + keepAliveTime);
    … …  
    114112                                try {
    115113                                        worker.kill();
    116                                         workers.remove(i);
     114                                        lIter.remove();
    117115                                } catch (IOException e) {
    118                                         // TODO Auto-generated catch block
    119                                         e.printStackTrace();
     116                                        logger.error(e);
    120117                                }
    121118
    122119                        }
    123                         i++;
    124120                }
    125121        }

  • branches/supervisor/src/test/java/omq/test/lock/SleepTest.java

    r92 r102  
    2020                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
    2121                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    22                 env.setProperty(ParameterQueue.NUM_THREADS, "1");
    2322
    2423                for (int i = 0; i < 4; i++) {

  • branches/supervisor/src/test/java/omq/test/multiThread/ThreadTest.java

    r89 r102  
    7373                env.setProperty(ParameterQueue.RPC_EXCHANGE, "rpc_exchange");
    7474                env.setProperty(ParameterQueue.RETRY_TIME_CONNECTION, "2000");
    75                 env.setProperty(ParameterQueue.NUM_THREADS, "4");
     75                env.setProperty(ParameterQueue.MIN_POOL_THREADS, "4");
     76                env.setProperty(ParameterQueue.MAX_POOL_THREADS, "4");
    7677
    7778                RemoteMulti rm = new RemoteMulti();

  • branches/supervisor/src/test/java/omq/test/multiThread2/MultiThreadTest.java

    r96 r102  
    2121                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
    2222                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    23                 env.setProperty(ParameterQueue.NUM_THREADS, "4");
    24 
     23                env.setProperty(ParameterQueue.MIN_POOL_THREADS, "4");
     24                env.setProperty(ParameterQueue.MAX_POOL_THREADS, "4");
    2525                SleepImpl sleep = new SleepImpl();
    2626

  • branches/supervisor/src/test/java/omq/test/multiThread2/PrintTest.java

    r97 r102  
    2121                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
    2222                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    23                 env.setProperty(ParameterQueue.NUM_THREADS, "2");
     23                env.setProperty(ParameterQueue.MIN_POOL_THREADS, "2");
     24                env.setProperty(ParameterQueue.MAX_POOL_THREADS, "2");
    2425
    2526                PrintImpl print = new PrintImpl(1);

  • branches/supervisor/src/test/java/omq/test/remotePool/RemotePoolTest.java

    r101 r102  
    4747                for (int j = 0; j < 2; j++) {
    4848
    49                         for (int i = 0; i < 4; i++) {
     49                        for (int i = 0; i < 8; i++) {
    5050                                sleep.sleep();
    5151                        }
    5252                        Thread.sleep(3000);
    53                         for (int i = 0; i < 4; i++) {
     53                        for (int i = 0; i < 12; i++) {
    5454                                sleep.sleep();
    5555                        }
    5656                        Thread.sleep(10000);
    5757                }
    58                 Thread.sleep(20000 * 1000);
     58               
    5959        }
    6060}

  • branches/supervisor/src/test/java/omq/test/supervisor/SleepTest.java

    r96 r102  
    2424                env1.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
    2525                env1.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    26                 env1.setProperty(ParameterQueue.NUM_THREADS, "4");
     26                env1.setProperty(ParameterQueue.MIN_POOL_THREADS, "4");
     27                env1.setProperty(ParameterQueue.MAX_POOL_THREADS, "4");
    2728
    2829                Broker broker = new Broker(env1);
    … …  
    3536                env2.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
    3637                env2.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    37                 env2.setProperty(ParameterQueue.NUM_THREADS, "1");
     38                env2.setProperty(ParameterQueue.MIN_POOL_THREADS, "4");
     39                env2.setProperty(ParameterQueue.MAX_POOL_THREADS, "4");
    3840
    3941                Broker broker2 = new Broker(env2);
Note: See TracChangeset for help on using the changeset viewer.