emmanuel | 20 Jan 2006 18:23

CVS update of hedera/src/org/continuent/hedera/adapters (1 file)

    Date: Friday, January 20, 2006  <at>  18:23:36
  Author: emmanuel
    Path: /cvsroot/hedera/hedera/src/org/continuent/hedera/adapters

Modified: MulticastResponse.java (1.1 -> 1.2)

Removed setFailedMembers(List)
Added addFailedMembers(List) that is based on addFailedMember(Member) for lossless and
non-duplicated reporting of failed members
Fixes HEDERA-1

------------------------+
 MulticastResponse.java |   36 +++++++++++++++++++-----------------
 1 files changed, 19 insertions(+), 17 deletions(-)

Index: hedera/src/org/continuent/hedera/adapters/MulticastResponse.java
diff -u hedera/src/org/continuent/hedera/adapters/MulticastResponse.java:1.1 hedera/src/org/continuent/hedera/adapters/MulticastResponse.java:1.2
--- hedera/src/org/continuent/hedera/adapters/MulticastResponse.java:1.1	Fri Aug  5 12:00:03 2005
+++ hedera/src/org/continuent/hedera/adapters/MulticastResponse.java	Fri Jan 20 18:23:36 2006
 <at>  <at>  -23,6 +23,7  <at>  <at> 
 import java.io.Serializable;
 import java.util.ArrayList;
 import java.util.HashMap;
+import java.util.Iterator;
 import java.util.List;
 import java.util.Map;

 <at>  <at>  -80,7 +81,8  <at>  <at> 
       {
         if (failedMembers == null)
(Continue reading)

emmanuel | 20 Jan 2006 18:24

CVS update of hedera/src/org/continuent/hedera/adapters (1 file)

    Date: Friday, January 20, 2006  <at>  18:24:07
  Author: emmanuel
    Path: /cvsroot/hedera/hedera/src/org/continuent/hedera/adapters

Modified: MulticastRequestAdapter.java (1.2 -> 1.3)

Use addFailedMembers(List) instead of setFailedMembers(List)
Fixes HEDERA-1

------------------------------+
 MulticastRequestAdapter.java |    4 ++--
 1 files changed, 2 insertions(+), 2 deletions(-)

Index: hedera/src/org/continuent/hedera/adapters/MulticastRequestAdapter.java
diff -u hedera/src/org/continuent/hedera/adapters/MulticastRequestAdapter.java:1.2 hedera/src/org/continuent/hedera/adapters/MulticastRequestAdapter.java:1.3
--- hedera/src/org/continuent/hedera/adapters/MulticastRequestAdapter.java:1.2	Fri Dec  2
18:37:35 2005
+++ hedera/src/org/continuent/hedera/adapters/MulticastRequestAdapter.java	Fri Jan 20 18:24:07 2006
 <at>  <at>  -205,7 +205,7  <at>  <at> 
         logger.debug("Sending request " + seq + " to " + dests.size()
             + " members.");
       List failed = pullPushAdapter.send(toSend, dests);
-      reply.setFailedMembers(failed);
+      reply.addFailedMembers(failed);
       return reply;
     }
     else
 <at>  <at>  -224,7 +224,7  <at>  <at> 
         logger.debug("Sending message " + key + " to " + dests.size()
             + " members.");
(Continue reading)

mathieu | 20 Jan 2006 20:42

CVS update of hedera (build.properties doc/HISTORY.txt)

    Date: Friday, January 20, 2006  <at>  20:42:22
  Author: mathieu
    Path: /cvsroot/hedera/hedera

Modified: build.properties (1.2 -> 1.3) doc/HISTORY.txt (1.2 -> 1.3)

Prepared files for release 1.2

------------------+
 build.properties |    2 +-
 doc/HISTORY.txt  |    8 +++++++-
 2 files changed, 8 insertions(+), 2 deletions(-)

Index: hedera/build.properties
diff -u hedera/build.properties:1.2 hedera/build.properties:1.3
--- hedera/build.properties:1.2	Thu Dec  8 11:05:43 2005
+++ hedera/build.properties	Fri Jan 20 20:42:22 2006
 <at>  <at>  -1,5 +1,5  <at>  <at> 
 # Hedera version
-version = 1.1
+version = 1.2

 # Java compiler to use
 #build.compiler = jikes
Index: hedera/doc/HISTORY.txt
diff -u hedera/doc/HISTORY.txt:1.2 hedera/doc/HISTORY.txt:1.3
--- hedera/doc/HISTORY.txt:1.2	Thu Dec  8 11:05:43 2005
+++ hedera/doc/HISTORY.txt	Fri Jan 20 20:42:22 2006
 <at>  <at>  -1,11 +1,17  <at>  <at> 
 Hedera History File
(Continue reading)

mathieu | 20 Jan 2006 20:44

CVS update of hedera (build.properties)

    Date: Friday, January 20, 2006  <at>  20:44:55
  Author: mathieu
    Path: /cvsroot/hedera/hedera

Modified: build.properties (1.3 -> 1.4)

Increased release number for next release

------------------+
 build.properties |    2 +-
 1 files changed, 1 insertion(+), 1 deletion(-)

Index: hedera/build.properties
diff -u hedera/build.properties:1.3 hedera/build.properties:1.4
--- hedera/build.properties:1.3	Fri Jan 20 20:42:22 2006
+++ hedera/build.properties	Fri Jan 20 20:44:55 2006
 <at>  <at>  -1,5 +1,5  <at>  <at> 
 # Hedera version
-version = 1.2
+version = 1.3

 # Java compiler to use
 #build.compiler = jikes
mathieu | 21 Jan 2006 17:28

CVS update of hedera/src/org/continuent/hedera/adapters (1 file)

    Date: Saturday, January 21, 2006  <at>  17:28:53
  Author: mathieu
    Path: /cvsroot/hedera/hedera/src/org/continuent/hedera/adapters

Modified: MulticastRequestAdapter.java (1.3 -> 1.4)

Make sure that all objects are initialized when the new instance is registered with the PullPushAdapter
(as we start receiving messages). Should prevent NPE (HEDERA-2).

------------------------------+
 MulticastRequestAdapter.java |   36 ++++++++++++++++++++----------------
 1 files changed, 20 insertions(+), 16 deletions(-)

Index: hedera/src/org/continuent/hedera/adapters/MulticastRequestAdapter.java
diff -u hedera/src/org/continuent/hedera/adapters/MulticastRequestAdapter.java:1.3 hedera/src/org/continuent/hedera/adapters/MulticastRequestAdapter.java:1.4
--- hedera/src/org/continuent/hedera/adapters/MulticastRequestAdapter.java:1.3	Fri Jan 20
18:24:07 2006
+++ hedera/src/org/continuent/hedera/adapters/MulticastRequestAdapter.java	Sat Jan 21 17:28:53 2006
 <at>  <at>  -45,27 +45,28  <at>  <at> 
 public class MulticastRequestAdapter implements MessageListener
 {
   /** Do not wait for any response when multicasting a message (asynchronous) */
-  public static final int WAIT_NONE = 0;
+  public static final int              WAIT_NONE         = 0;
   /** Wait for the first reponse before returning of a multicast send */
-  public static final int WAIT_FIRST = 1;
+  public static final int              WAIT_FIRST        = 1;
   /** Wait for a majority of responses before returning of a multicast send */
-  public static final int WAIT_MAJORITY = 2;
+  public static final int              WAIT_MAJORITY     = 2;
(Continue reading)

mathieu | 21 Jan 2006 18:53

CVS update of hedera/doc (HISTORY.txt)

    Date: Saturday, January 21, 2006  <at>  18:53:47
  Author: mathieu
    Path: /cvsroot/hedera/hedera/doc

Modified: HISTORY.txt (1.3 -> 1.4)

Prepared 1.3 release

-------------+
 HISTORY.txt |    7 +++++++
 1 files changed, 7 insertions(+)

Index: hedera/doc/HISTORY.txt
diff -u hedera/doc/HISTORY.txt:1.3 hedera/doc/HISTORY.txt:1.4
--- hedera/doc/HISTORY.txt:1.3	Fri Jan 20 20:42:22 2006
+++ hedera/doc/HISTORY.txt	Sat Jan 21 18:53:47 2006
 <at>  <at>  -5,6 +5,13  <at>  <at> 
 CVS Tag:
 Description:

+Hedera version 1.3
+  Release date: 21 Janvier 2006
+  CVS Tag: hedera-1_3
+  Description:
+  	+ Fixed HEDERA-2: java.lang.NullPointerException at
+  	org.continuent.hedera.adapters.MulticastRequestAdapterThread.run(MulticastRequestAdapterThread.java:122)
+
 Hedera version 1.2
   Release date: 20 Janvier 2006
   CVS Tag: hedera-1_2
(Continue reading)

mathieu | 21 Jan 2006 18:56

CVS update of hedera (build.properties)

    Date: Saturday, January 21, 2006  <at>  18:56:38
  Author: mathieu
    Path: /cvsroot/hedera/hedera

Modified: build.properties (1.4 -> 1.5)

Increased release number

------------------+
 build.properties |    2 +-
 1 files changed, 1 insertion(+), 1 deletion(-)

Index: hedera/build.properties
diff -u hedera/build.properties:1.4 hedera/build.properties:1.5
--- hedera/build.properties:1.4	Fri Jan 20 20:44:55 2006
+++ hedera/build.properties	Sat Jan 21 18:56:38 2006
 <at>  <at>  -1,5 +1,5  <at>  <at> 
 # Hedera version
-version = 1.3
+version = 1.4

 # Java compiler to use
 #build.compiler = jikes
stephane | 23 Jan 2006 22:20

CVS update of hedera/src/org/continuent/hedera/adapters (1 file)

    Date: Monday, January 23, 2006  <at>  22:20:52
  Author: stephane
    Path: /cvsroot/hedera/hedera/src/org/continuent/hedera/adapters

Modified: MulticastResponse.java (1.2 -> 1.3)

Fixed HEDERA-3 :
First failed member was not added to the list

------------------------+
 MulticastResponse.java |    2 +-
 1 files changed, 1 insertion(+), 1 deletion(-)

Index: hedera/src/org/continuent/hedera/adapters/MulticastResponse.java
diff -u hedera/src/org/continuent/hedera/adapters/MulticastResponse.java:1.2 hedera/src/org/continuent/hedera/adapters/MulticastResponse.java:1.3
--- hedera/src/org/continuent/hedera/adapters/MulticastResponse.java:1.2	Fri Jan 20 18:23:36 2006
+++ hedera/src/org/continuent/hedera/adapters/MulticastResponse.java	Mon Jan 23 22:20:52 2006
 <at>  <at>  -81,7 +81,7  <at>  <at> 
       {
         if (failedMembers == null)
           failedMembers = new ArrayList();
-        else if (!failedMembers.contains(m))
+        if (!failedMembers.contains(m))
           failedMembers.add(m);
         if (shouldNotify())
           results.notify();
damian | 27 Jan 2006 14:40

CVS update of hedera/src/org/continuent/hedera/adapters (1 file)

    Date: Friday, January 27, 2006  <at>  14:40:07
  Author: damian
    Path: /cvsroot/hedera/hedera/src/org/continuent/hedera/adapters

Modified: PullPushAdapter.java (1.1 -> 1.2)

Fixed HEDERA-2. Now the PushPullAdapter constructor does not start the reader thread. This thread should
be started externally with the start() method.

----------------------+
 PullPushAdapter.java |    1 -
 1 files changed, 1 deletion(-)

Index: hedera/src/org/continuent/hedera/adapters/PullPushAdapter.java
diff -u hedera/src/org/continuent/hedera/adapters/PullPushAdapter.java:1.1 hedera/src/org/continuent/hedera/adapters/PullPushAdapter.java:1.2
--- hedera/src/org/continuent/hedera/adapters/PullPushAdapter.java:1.1	Fri Aug  5 12:00:03 2005
+++ hedera/src/org/continuent/hedera/adapters/PullPushAdapter.java	Fri Jan 27 14:40:07 2006
 <at>  <at>  -64,7 +64,6  <at>  <at> 
   {
     this.channel = channel;
     this.listener = listener;
-    start();
   }

   /**
damian | 27 Jan 2006 14:41

CVS update of hedera/src/org/continuent/hedera/adapters (1 file)

    Date: Friday, January 27, 2006  <at>  14:41:14
  Author: damian
    Path: /cvsroot/hedera/hedera/src/org/continuent/hedera/adapters

Modified: MulticastRequestAdapter.java (1.4 -> 1.5)

Fixed HEDERA-2. New start() method that starts the reader thread of the underlying  PushPullAdapter.

------------------------------+
 MulticastRequestAdapter.java |   10 ++++++++++
 1 files changed, 10 insertions(+)

Index: hedera/src/org/continuent/hedera/adapters/MulticastRequestAdapter.java
diff -u hedera/src/org/continuent/hedera/adapters/MulticastRequestAdapter.java:1.4 hedera/src/org/continuent/hedera/adapters/MulticastRequestAdapter.java:1.5
--- hedera/src/org/continuent/hedera/adapters/MulticastRequestAdapter.java:1.4	Sat Jan 21
17:28:53 2006
+++ hedera/src/org/continuent/hedera/adapters/MulticastRequestAdapter.java	Fri Jan 27 14:41:14 2006
 <at>  <at>  -100,6 +100,16  <at>  <at> 
   }

   /**
+   * Start this MulticastRequestAdapter. This starts the reader thread of the
+   * underlying PullPushAdapter, meaning that we can receive messages from the
+   * channel.
+   */
+  public void start()
+  {
+    pullPushAdapter.start();
+  }
+
(Continue reading)


Gmane