CVS update: JGroups/src/org/jgroups/blocks TCPConnectionMap.java

  User: belaban 
  Date: 10/09/27 07:29:45

  Modified:    src/org/jgroups/blocks TCPConnectionMap.java
  Log:
  renamed sending to running
  
  Revision  Changes    Path
  1.39      +4 -6      JGroups/src/org/jgroups/blocks/TCPConnectionMap.java
  
  Index: TCPConnectionMap.java
  ===================================================================
  RCS file: /cvsroot/javagroups/JGroups/src/org/jgroups/blocks/TCPConnectionMap.java,v
  retrieving revision 1.38
  retrieving revision 1.39
  diff -u -r1.38 -r1.39
  --- TCPConnectionMap.java	13 Aug 2010 10:18:53 -0000	1.38
  +++ TCPConnectionMap.java	27 Sep 2010 07:29:45 -0000	1.39
  @@ -13,8 +13,6 @@
   import java.io.*;
   import java.net.*;
   import java.util.Collection;
  -import java.util.HashMap;
  -import java.util.Iterator;
   import java.util.Map;
   import java.util.concurrent.BlockingQueue;
   import java.util.concurrent.LinkedBlockingQueue;
  @@ -642,7 +640,7 @@
   
               final BlockingQueue<byte[]> send_queue;
               final Thread runner;
  -            private final AtomicBoolean sending = new AtomicBoolean(false);
  +            private final AtomicBoolean running= new AtomicBoolean(false);
   
               public Sender(ThreadFactory tf,int send_queue_size) {
                   this.runner=tf.newThread(this, "Connection.Sender [" + getSockAddress() + "]");
  @@ -655,19 +653,19 @@
               }
   
               public void start() {
  -                if(sending.compareAndSet(false, true)) {
  +                if(running.compareAndSet(false, true)) {
                       runner.start();
                   }
               }
   
               public void stop() {
  -                if(sending.compareAndSet(true, false)) {
  +                if(running.compareAndSet(true, false)) {
                       runner.interrupt();
                   }
               }
               
               public boolean isRunning() {
  -                return sending.get();
  +                return running.get();
               }
               
               public boolean canRun() {
  
  
  

------------------------------------------------------------------------------
Start uncovering the many advantages of virtual appliances
and start using them to simplify application deployment and
accelerate your shift to cloud computing.
http://p.sf.net/sfu/novell-sfdev2dev