Skip to content

Commit da061e7

Browse files
committed
Tagged non-supported bundlers as experimental
1 parent 47f7e20 commit da061e7

File tree

5 files changed

+10
-0
lines changed

5 files changed

+10
-0
lines changed

src/org/jgroups/protocols/PerDestinationBundler.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
package org.jgroups.protocols;
22

33
import org.jgroups.*;
4+
import org.jgroups.annotations.Experimental;
45
import org.jgroups.annotations.ManagedAttribute;
56
import org.jgroups.annotations.Property;
67
import org.jgroups.conf.AttributeType;
@@ -34,6 +35,7 @@
3435
* @author Bela Ban
3536
* @since 5.2.7
3637
*/
38+
@Experimental
3739
public class PerDestinationBundler implements Bundler {
3840

3941
/**

src/org/jgroups/protocols/RingBufferBundler.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@
55
import org.jgroups.Global;
66
import org.jgroups.Message;
77
import org.jgroups.PhysicalAddress;
8+
import org.jgroups.annotations.Experimental;
89
import org.jgroups.annotations.Property;
910
import org.jgroups.util.*;
1011

@@ -23,6 +24,7 @@
2324
* RingBuffer uses a wait strategy (to for example spinning) before blocking. Also, the hashmap of the superclass is not
2425
* used, but the array of the RingBuffer is used directly to bundle and send messages, minimizing memory allocation.
2526
*/
27+
@Experimental
2628
public class RingBufferBundler extends BaseBundler {
2729
protected RingBuffer<Message> rb;
2830
protected Runner bundler_thread;

src/org/jgroups/protocols/RingBufferBundlerLockless.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@
44
import org.jgroups.Address;
55
import org.jgroups.Global;
66
import org.jgroups.Message;
7+
import org.jgroups.annotations.Experimental;
78
import org.jgroups.util.Runner;
89
import org.jgroups.util.Util;
910

@@ -21,6 +22,7 @@
2122
* @author Bela Ban
2223
* @since 4.0
2324
*/
25+
@Experimental
2426
public class RingBufferBundlerLockless extends BaseBundler {
2527
protected Message[] buf;
2628
protected int read_index;

src/org/jgroups/protocols/RingBufferBundlerLockless2.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@
44
import org.jgroups.EmptyMessage;
55
import org.jgroups.Global;
66
import org.jgroups.Message;
7+
import org.jgroups.annotations.Experimental;
78
import org.jgroups.util.*;
89

910
import java.util.Objects;
@@ -19,6 +20,7 @@
1920
* @author Bela Ban
2021
* @since 4.0
2122
*/
23+
@Experimental
2224
public class RingBufferBundlerLockless2 extends BaseBundler {
2325
protected Message[] buf;
2426
protected final AtomicInteger read_index; // shared by reader and writers (reader only writes it)

src/org/jgroups/protocols/SenderSendsBundler.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,15 @@
11
package org.jgroups.protocols;
22

33
import org.jgroups.Message;
4+
import org.jgroups.annotations.Experimental;
45

56
import java.util.concurrent.atomic.AtomicInteger;
67

78
/**
89
* @author Bela Ban
910
* @since 4.0
1011
*/
12+
@Experimental
1113
public class SenderSendsBundler extends BaseBundler {
1214
protected final AtomicInteger num_senders=new AtomicInteger(0); // current senders adding msgs to the bundler
1315

0 commit comments

Comments
 (0)