[jboss-jira] [JBoss JIRA] Commented: (JGRP-1368) RPC calls during view updates

[Bela Ban (JIRA)]

    [ https://issues.jboss.org/browse/JGRP-1368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=12630437#comment-12630437 ] 

Bela Ban commented on JGRP-1368:
--------------------------------

I'm going to close this issue; if the problem reoccurs, please reopen this JIRA and attach a sample program which reproduces the problem.

> RPC calls during view updates
> -----------------------------
>
>                 Key: JGRP-1368
>                 URL: https://issues.jboss.org/browse/JGRP-1368
>             Project: JGroups
>          Issue Type: Bug
>    Affects Versions: 3.0
>         Environment: Java version: 1.6.0_22
> JGroups: 3.0.0.CR1
>            Reporter: Andrey Vorobiev
>            Assignee: Bela Ban
>             Fix For: 3.0
>
>
> Environment consists of one server node and several client nodes. When new client node joins group I should call some remote method on it from server node.
> Client node source code:
> import org.jgroups.*;
> import org.jgroups.blocks.RpcDispatcher;
> public class Client extends ReceiverAdapter{
>    public void start() throws Exception{
>        JChannel channel = new JChannel();
>        RpcDispatcher dispatcher = new RpcDispatcher(channel, this, this, this);
>        channel.connect("cluster");
>    }
>    public String doIt(String arg){
>        System.out.println("Client called: " + arg);
>        return arg;
>    }
>    public static void main(String[] args) throws Exception{
>        new Client().start();
>    }
> }
> Server node source code:
> import java.util.*;
> import org.jgroups.*;
> import org.jgroups.blocks.*;
> import org.jgroups.util.*;
> public class Server extends ReceiverAdapter{
>    JChannel channel;
>    RpcDispatcher dispatcher;
>    public void start() throws Exception{
>        channel = new JChannel();
>        dispatcher = new RpcDispatcher(channel, null, this, this);
>        channel.connect("cluster");
>    }
>    public void viewAccepted(View view){
>        try
>        {
>            System.out.println("view accepted: " + view);
>            if (channel.isConnected())
>            {
>                callClients(view);
>            }
>        }
>        catch (Throwable e)
>        {
>            e.printStackTrace();
>        }
>    }
>    public void callClients(View view) throws Exception{
>        MethodCall call = new MethodCall("doIt", new Object[]{ "Hello world" }, new Class[]{String.class});
>        RspList<String> rsp = dispatcher.callRemoteMethods(filter(view.getMembers()), call, new RequestOptions(ResponseMode.GET_ALL, 10000));
>        for (Map.Entry<Address, Rsp<String>> pair : rsp.entrySet())
>        {
>            System.out.println(pair.getKey() + " -- " + pair.getValue().getValue());
>        }
>    }
>    public Collection<Address> filter(Collection<Address> addresses){
>        Collection<Address> result = new ArrayList<Address>();
>        for (Address address : addresses)
>        {
>            if (!address.equals(dispatcher.getChannel().getAddress()))
>            {
>                result.add(address);
>            }
>        }
>        return result;
>    }
>    public String doIt(String arg){
>        System.out.println("Server called: " + arg);
>        return arg;
>    }
>    public static void main(String[] args) throws Exception{
>        new Server().start();
>    }
> }
> If client node is started before server one everything work as expected.
> But when server node is started before client one I observe following
> in stdout from server node:
> Sep 16, 2011 5:15:54 PM org.jgroups.logging.JDKLogImpl info
> INFO: JGroups version: 3.0.0.CR1
> Sep 16, 2011 5:15:54 PM org.jgroups.logging.JDKLogImpl warn
> WARNING: receive buffer of socket java.net.DatagramSocket at 7c6572b was
> set to 20MB, but the OS only allocated 65.51KB. This might lead to
> performance problems. Please set your max receive buffer in the OS
> correctly (e.g. net.core.rmem_max on Linux)
> Sep 16, 2011 5:15:54 PM org.jgroups.logging.JDKLogImpl warn
> WARNING: receive buffer of socket java.net.MulticastSocket at 6e84cc09
> was set to 25MB, but the OS only allocated 65.51KB. This might lead to
> performance problems. Please set your max receive buffer in the OS
> correctly (e.g. net.core.rmem_max on Linux)
> -------------------------------------------------------------------
> GMS: address=andrey-8222, cluster=cluster, physical address=10.0.1.197:65216
> -------------------------------------------------------------------
> view [andrey-8222|0] [andrey-8222]
> connected true
> method called
> []
> view [andrey-8222|1] [andrey-8222, andrey-63112]
> connected true
> Sep 16, 2011 5:16:17 PM org.jgroups.logging.JDKLogImpl warn
> WARNING: andrey-8222: failed to collect all ACKs (expected=1) for view
> [andrey-8222|1] [andrey-8222, andrey-63112] after 2000ms, missing ACKs
> from [andrey-8222]
> method called
> []
> andrey-63112 -- null
> Server called: Hello world
> I'm confused by the following:
> - server nodes tries to receive ACKs from itself (missing ACKs from [andrey-8222])
> - rpc dispatcher calls server node (Server called: Hello world)
> I can work around this issue by doing rpc call in separate thread. By in this case I sometimes receive null as call result from some nodes with following messages in client logs: no physical address for xxx.
> Also I have some general questions about RPC dispatcher:
> - are rpc calls supported during view update?
> - what conditions I should wait for in order to guarantee rpc dispatcher's correct behavior?
>  

--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira