RSVP not blocking sender when message is addressed to a group member

Larry Bunch

unread,

Sep 9, 2020, 5:07:42 PM9/9/20

to jgroups-dev

I'm using RSVP in version 5.0.2 to send messages. When messages are sent to the entire group (e.g. destination Address is null) the RSVP blocks the sender until the receivers' ack is returned as expected. However, when a destination address is set for the message, the sender is not blocked. Is this expected?

Sample Code

import org.jgroups.*;

import org.jgroups.util.MessageBatch;

import java.io.InputStream;

import java.io.OutputStream;

public class RsvpTest

{

public static void main(String[] args)

{

try

{

String group = "test-group";

JChannel channel = new JChannel("udp.xml");

channel.setReceiver(new Receiver()

{

@Override

public void receive(Message msg)

{

System.out.println("Received: " + msg);

}

});

channel.connect(group);

Thread.sleep(3000);

for (int i = 0; i < 10; i++)

{

Message message = new ObjectMessage(null, "entire group blocks");

message.setFlag(Message.Flag.RSVP);

long sendTime = System.currentTimeMillis();

channel.send(message);

System.out.println("Group message time to send was " + (System.currentTimeMillis() - sendTime));

Thread.sleep(1000);

}

for (int i = 0; i < 10; i++)

{

View view = channel.getView();

for (Address address : view.getMembers())

{

if (address.equals(channel.getAddress()))

{

continue;

}

Message message = new ObjectMessage(address, "peer does not block");

message.setFlag(Message.Flag.RSVP);

long sendTime = System.currentTimeMillis();

channel.send(message);

System.out.println("Peer " + address + " message time to send was " + (System.currentTimeMillis() - sendTime));

Thread.sleep(1000);

}

catch (Exception e)

{

e.printStackTrace();

}

Sample UDP+RSVP Configuration

<config xmlns="urn:org:jgroups"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="urn:org:jgroups http://www.jgroups.org/schema/jgroups-5.0.xsd"

version="5.0.2">

<UDP

bundler_capacity="1"

mcast_port="${jgroups.udp.mcast_port:45588}"

thread_pool.min_threads="0"

thread_pool.max_threads="200"

thread_pool.keep_alive_time="30000"

/>

<MERGE3 max_interval="30000"

min_interval="10000"/>

<FD_SOCK/>

<FD_ALL3/>

<VERIFY_SUSPECT timeout="5000" />

<pbcast.NAKACK2 max_rebroadcast_timeout="5000" xmit_interval="2000"/>

<pbcast.STABLE desired_avg_gossip="50000"

max_bytes="4M"/>

<pbcast.GMS view_ack_collection_timeout="4000" print_local_addr="true" join_timeout="5000"/>

<UFC max_credits="10M"

min_threshold="0.4"/>

<MFC max_credits="10M"

min_threshold="0.4"/>

<pbcast.STATE_TRANSFER />

</config>

Sample Output (note that the test network adds 1 second latency to all comms)

Sep 09, 2020 8:43:22 PM org.jgroups.JChannel setAddress

INFO: local_addr: a7f95eea-41b9-7ffa-6771-2dd478997920, name: uas-24-2967

Sep 09, 2020 8:43:22 PM org.jgroups.protocols.UDP setBufferSize

WARNING: JGRP000015: the receive buffer of socket MulticastSocket was set to 5MB, but the OS only allocated 212.99KB

Sep 09, 2020 8:43:22 PM org.jgroups.protocols.UDP setBufferSize

WARNING: JGRP000015: the receive buffer of socket MulticastSocket was set to 5MB, but the OS only allocated 212.99KB

-------------------------------------------------------------------

GMS: address=uas-24-2967, cluster=test-group, physical address=192.168.14.24:35481

-------------------------------------------------------------------