[jboss-cvs] JBossRemoting/src/tests/org/jboss/test/remoting/performance/raw/socket ...

[Ron Sigal]

  User: rsigal  
  Date: 06/09/03 01:11:44

  Modified:    src/tests/org/jboss/test/remoting/performance/raw/socket 
                        SocketServer.java
  Log:
  JBREM-589:  Changed callbackServerPort from an int to a ThreadLocal.
  
  Revision  Changes    Path
  1.8       +5 -3      JBossRemoting/src/tests/org/jboss/test/remoting/performance/raw/socket/SocketServer.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: SocketServer.java
  ===================================================================
  RCS file: /cvsroot/jboss/JBossRemoting/src/tests/org/jboss/test/remoting/performance/raw/socket/SocketServer.java,v
  retrieving revision 1.7
  retrieving revision 1.8
  diff -u -b -r1.7 -r1.8
  --- SocketServer.java	24 Aug 2006 21:03:14 -0000	1.7
  +++ SocketServer.java	3 Sep 2006 05:11:44 -0000	1.8
  @@ -54,7 +54,7 @@
   
      private int serverReadThreads;
   
  -   private int callbackServerPort = -1;
  +   private ThreadLocal callbackServerPort = new ThreadLocal();
   
      private boolean continueToRun = true; // flag to keep the server listening
   
  @@ -175,7 +175,8 @@
            }
            else
            {
  -            SocketHandler callbackHandler = new SocketHandler(serverBindAddress, sessionId, callbackServerPort);
  +            int port = ((Integer)callbackServerPort.get()).intValue();
  +            SocketHandler callbackHandler = new SocketHandler(serverBindAddress, sessionId, port);
               tracker = new CallTracker(sessionId, callbackHandler);
               callTrackers.put(sessionId, tracker);
               tracker.createTotalCount(totalCount);
  @@ -202,7 +203,8 @@
         }
         else if("callbackserver".equals(method))
         {
  -         callbackServerPort = ((Integer) param).intValue();
  +//         callbackServerPort = ((Integer) param).intValue();
  +         callbackServerPort.set(param);
            return null;
         }
         else