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