directory-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pro...@apache.org
Subject svn commit: r446658 - /directory/trunks/mina/core/src/main/java/org/apache/mina/transport/vmpipe/support/VmPipeSessionImpl.java
Date Fri, 15 Sep 2006 17:14:29 GMT
Author: proyal
Date: Fri Sep 15 10:14:29 2006
New Revision: 446658

URL: http://svn.apache.org/viewvc?view=rev&rev=446658
Log:
DIRMINA-264 - Put the right Service on the remote end.

Modified:
    directory/trunks/mina/core/src/main/java/org/apache/mina/transport/vmpipe/support/VmPipeSessionImpl.java

Modified: directory/trunks/mina/core/src/main/java/org/apache/mina/transport/vmpipe/support/VmPipeSessionImpl.java
URL: http://svn.apache.org/viewvc/directory/trunks/mina/core/src/main/java/org/apache/mina/transport/vmpipe/support/VmPipeSessionImpl.java?view=diff&rev=446658&r1=446657&r2=446658
==============================================================================
--- directory/trunks/mina/core/src/main/java/org/apache/mina/transport/vmpipe/support/VmPipeSessionImpl.java
(original)
+++ directory/trunks/mina/core/src/main/java/org/apache/mina/transport/vmpipe/support/VmPipeSessionImpl.java
Fri Sep 15 10:14:29 2006
@@ -76,7 +76,7 @@
         this.filterChain = new VmPipeFilterChain( this );
         this.pendingDataQueue = new Queue();
 
-        remoteSession = new VmPipeSessionImpl( service, this, remoteEntry );
+        remoteSession = new VmPipeSessionImpl( this, remoteEntry );
         
         // initialize connector session
         try
@@ -97,9 +97,9 @@
     /**
      * Constructor for server-side session.
      */
-    private VmPipeSessionImpl( IoService service, VmPipeSessionImpl remoteSession, VmPipe
entry ) throws IOException
+    private VmPipeSessionImpl( VmPipeSessionImpl remoteSession, VmPipe entry ) throws IOException
     {
-        this.service = service;
+        this.service = entry.getAcceptor();
         this.serviceConfig = entry.getConfig();
         this.serviceListeners = entry.getListeners();
         this.lock = remoteSession.lock;
@@ -203,7 +203,7 @@
     {
         if( getTrafficMask().isReadable() || getTrafficMask().isWritable())
         {
-            Object[] data = null;
+            Object[] data;
             synchronized( pendingDataQueue )
             {
                 data = pendingDataQueue.toArray();



Mime
View raw message