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

Questions/problems related to using JGroups <[email protected]> Mon, 29 Oct 2018 09:56:39 +0100
Newsgroups gmane.comp.java.javagroups.general
Message-ID <mailman.44935.1540803409.1409.javagroups-users@lists.sourceforge.net>
The code is trying to read cookie {'b', 'e', 'l', 'a'} (4 bytes) from 
the accepted TCP connection, but it encounters an EOF before being able 
to do so.

This can have a number of causes:
- Some non-JGroups TCP client tries to connect to a JGroups node on the 
port on which the node is listening for other traffic from other nodes.
- The freshly connected client, disconnected
- You're using JGroups nodes with different versions in the same cluster

On 18/10/18 22:08, Questions/problems related to using JGroups wrote:
> 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
> 

-- 
Bela Ban | http://www.jgroups.org



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