Uploaded image for project: 'JGroups'
  1. JGroups
  2. JGRP-737 Shared transport protocols use stack field from first channel created
  3. JGRP-748

Change in start() and connect() introduced new bug in the shared transport

    XMLWordPrintable

Details

    • Sub-task
    • Resolution: Done
    • Major
    • None
    • None
    • None

    Description

      [Vladimir]
      This change caused SharedTransportTest#testReferenceCounting to start failing. As soon as one channel sharing transport layer calls disconnect we shut down threads receiving packets.

      Can you access JIRA and cvs. Both are not working for me!

      Vladimir

      Bela Ban wrote:
      > User: belaban Date: 08/04/23 02:21:53
      >
      > Modified: src/org/jgroups/protocols Tag: Branch_JGroups_2_6 UDP.java
      > Log:
      > moved thread starting to handleConnect() from start() (http://jira.jboss.com/jira/browse/JGRP-738)
      > Revision Changes Path
      > No revision
      > No revision
      > 1.156.2.3 +8 -4 JGroups/src/org/jgroups/protocols/UDP.java
      > Index: UDP.java
      > ===================================================================
      > RCS file: /cvsroot/javagroups/JGroups/src/org/jgroups/protocols/UDP.java,v
      > retrieving revision 1.156.2.2
      > retrieving revision 1.156.2.3
      > diff -u -r1.156.2.2 -r1.156.2.3
      > — UDP.java 3 Apr 2008 08:04:19 -0000 1.156.2.2
      > +++ UDP.java 23 Apr 2008 09:21:53 -0000 1.156.2.3
      > @@ -37,7 +37,7 @@
      > * input buffer overflow, consider setting this property to true.
      > * </ul>
      > * @author Bela Ban
      > - * @version $Id: UDP.java,v 1.156.2.2 2008/04/03 08:04:19 belaban Exp $
      > + * @version $Id: UDP.java,v 1.156.2.3 2008/04/23 09:21:53 belaban Exp $
      > */
      > public class UDP extends TP implements Runnable

      { > @@ -366,7 +366,7 @@ > throw new Exception(tmp, ex); > }

      > super.start();
      > - startThreads();
      > + // startThreads();
      > }
      > @@ -377,9 +377,13 @@
      > super.stop();
      > }
      > + protected void handleConnect() throws Exception

      { > + startThreads(); > + }

      > -
      > -
      > + protected void handleDisconnect()

      { > + stopThreads(); > + }

      Attachments

        Activity

          People

            rhn-engineering-bban Bela Ban
            rhn-engineering-bban Bela Ban
            Votes:
            0 Vote for this issue
            Watchers:
            0 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: