[jgroups-users] WARNING: JGRP000006: failed accepting connection from peer

Questions/problems related to using JGroups <[email protected]> Thu, 18 Oct 2018 16:08:26 -0400
Newsgroups gmane.comp.java.javagroups.general
Message-ID <mailman.37102.1539894780.1409.javagroups-users@lists.sourceforge.net>
Hi,

A customer using our jgroups-based-app has reported this happening every
~10 seconds for at least a couple days (as far back as my info goes), and
then Java ran out of memory, which may or may not be related:

10/18/18 12:57:31 PM org.jgroups.blocks.cs.TcpServer$Acceptor run WARNING:
JGRP000006: failed accepting connection from peer
java.io.EOFException
at java.io.DataInputStream.readFully(DataInputStream.java:197)
at
org.jgroups.blocks.cs.TcpConnection.readPeerAddress(TcpConnection.java:235)
at org.jgroups.blocks.cs.TcpConnection.<init>(TcpConnection.java:51)
at org.jgroups.blocks.cs.TcpServer$Acceptor.handleAccept(TcpServer.java:126)
at org.jgroups.blocks.cs.TcpServer$Acceptor.run(TcpServer.java:111)
at java.lang.Thread.run(Thread.java:745)

Do you have any idea what could be causing this? I don't know yet if the
other 2 nodes in the cluster saw issues in their logs or not, and am
getting the logs. This is a production system for them, so we can't try
things to experiment, but I can try them locally if it helps.

We're using jgroups 4.0.8.Final with a programmatic stack like this:

        List<Protocol> stack = new ArrayList<>();
        stack.add(new TCP()
            .setValue("bind_addr", InetAddress.getByName(<bind address set
by user>))
            .setValue("bind_port", bindingPort)
            .setValue("thread_pool_min_threads", 1)
            .setValue("thread_pool_keep_alive_time", 5000)
            .setValue("send_buf_size", 640000)
            .setValue("sock_conn_timeout", 300)
            .setValue("recv_buf_size", 5000000));
        stack.add(new TCPPING()
            .setValue("initial_hosts", <host list set by user>)
            .setValue("send_cache_on_join", true)
            .setValue("port_range", 0));
        stack.add(new MERGE3()
            .setValue("min_interval", 10000)
            .setValue("max_interval", 30000));
        stack.add(new FD_ALL()
            .setValue("timeout", <40 sec in this case>);
        stack.add(new VERIFY_SUSPECT()
            .setValue("timeout", 1500));
        stack.add(new BARRIER());
        stack.add(new NAKACK2()
            .setValue("use_mcast_xmit", false));
        stack.add(new UNICAST3());
        stack.add(new STABLE()
            .setValue("desired_avg_gossip", 50000)
            .setValue("max_bytes", 4000000));
        stack.add(<custom auth protocol>);
        stack.add(new GMS()
            .setValue("join_timeout", 3000));
        stack.add(new MFC()
            .setValue("max_credits", 2000000)
            .setValue("min_credits", 800000));
        stack.add(new FRAG2());
        stack.add(new STATE_TRANSFER());
        return new JChannel(stack);

Thanks,
Bobby

_______________________________________________
javagroups-users mailing list
[email protected]
https://lists.sourceforge.net/lists/listinfo/javagroups-users