Re: [javagroups-users] JavaGroups Communicator Not able to start

SourceForge Headquarters 225 Broadway Suite 1600 San Diego, CA 92101 +1 (858) 454-5900

Richard, I looked into the JavaGroupsCommunicator source code. 
The appliation hangs when it tries to create a jgroups
NotificationBus/Channel to join the Group. 
The following debug statement is in the log "JavaGroupsCommunicator()
using busName:", but it fails to print the 
".. finished starting new JavaGroups Communicator" debug statement after
starting the NotificationBus/Channel.
This issue happens rarely.  

As this part is related to jgroups, can you please advise. I will post
in Swarmcache forum also
but looks like it is not active anymore.

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

package net.sf.swarmcache;

import java.io.Serializable;
import java.util.Properties;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.jgroups.Address;
import org.jgroups.Channel;
import org.jgroups.blocks.NotificationBus;

/**
 * Created by IntelliJ IDEA.
 * User: jwat
 * Date: Jul 25, 2003
 * Time: 11:47:57 AM
 * To change this template use Options | File Templates.
 */
public class JavaGroupsCommunicator extends Communicator implements
NotificationBus.Consumer {

    Log log = LogFactory.getLog(this.getClass());

    public static final String BUS_NAME = "CacheBus";
    public static final String CHANNEL_PROPERTIES =
"multi.cache.properties";

    private NotificationBus bus;
    private String properties;

//----------------------------------------------------------------------
---
    // Constructors

//----------------------------------------------------------------------
---

    public JavaGroupsCommunicator(String channelProperties, Properties
properties) {
		log.info("Starting a JavaGroups Communicator..." +
channelProperties);

    	String busName = properties.getProperty("cache.scope.name");
    	if ((busName == null) || "".equals(busName)) {
    		busName = BUS_NAME;
    	}
   		log.info("JavaGroupsCommunicator() using busName: " +
busName);
        setGroupName(busName);
		this.properties = channelProperties;
		try {
			if (properties == null) {
				bus = new
NotificationBus(getGroupName());
			} else {
				bus = new
NotificationBus(getGroupName(), this.properties);
			}
			bus.start();
			bus.getChannel().setOpt(Channel.LOCAL, new
Boolean(false));
			bus.getChannel().setOpt(Channel.AUTO_RECONNECT,
new Boolean(true));
			bus.setConsumer(this);
			log.info("... finished starting new JavaGroups
Communicator.");
		} catch (Exception e) {
			log.error("There was a problem initiating the
cache notification bus: ");
			e.printStackTrace();
		}
    }

-----Original Message-----
From: Richard Achmatowicz [mailto:rac...@re...] 
Sent: Monday, March 31, 2008 4:38 PM
To: Angappan, Siva; jav...@li...
Subject: Re: [javagroups-users] JavaGroups Communicator Not able to
start

For your information, the JavaGroupsCommunicator is a Swarmcache class,
not a JGroups class:

**net.sf.swarmcache.JavaGroupsCommunicator**

You would be better off discussing your problem with Swarmcache first.

Richard

Angappan, Siva wrote:
>
> We are using Swarmcache as the cache layer for Hibernate. We are 
> facing issues occasionally with Java Groups communicator when we do 
> application server restarts. We have a total of 6 Jrun server 
> instances running for our application. We restart the servers one at a

> time, with an interval of 30 mins. When the application server 
> restarts, we noticed the Java Groups Communicator is not able to start

> sometimes and it utilizes all the system resources and the application

> server hangs. If we do a server restart after a time interval, it 
> works but not always. I do not have experience with Jgroups.  In the 
> forums, they have suggested to kill the co-ordinator. Do we have any 
> other solutions to resolve this issue. Please help.
>
> Java Version 1.4.2_16
> Jgroups Version 2.2
> Hibernate 2.X
>
> ----------------------------------------------------------------------
> ------------------------------------------------
>
>
> INFO  [jrpp-9] [] swarmcache.JavaGroupsCommunicator:34 - Starting a 
> JavaGroups
> Communicator...UDP(mcast_addr=231.15.21.159;mcast_port=45566;ip_ttl=32
> ;mcast_send_buf_size=150000;mcast_recv_buf_size=80000):PING(timeout=20
> 00;num_initial_members=3):MERGE2(min_interval=5000;max_interval=10000)
> :FD(timeout=6000;max_tries=5;shun=true):VERIFY_SUSPECT(timeout=1500):p
> bcast.NAKACK(gc_lag=50;retransmit_timeout=300,600,1200,2400,4800):UNIC
> AST(timeout=5000):pbcast.STABLE(desired_avg_gossip=20000):FRAG(frag_si
> ze=8096;down_thread=false;up_thread=false):pbcast.GMS(join_timeout=500
> 0;join_retry_timeout=2000;shun=false;print_local_addr=true)
>
> INFO  [jrpp-9] [] swarmcache.JavaGroupsCommunicator:40 -
> JavaGroupsCommunicator() using busName: SCBUSN
>
> -------------------------------------------------------
> GMS: address is server133:56781
> -------------------------------------------------------
> 03/29 19:57:12 metrics (busy/total) web: 0/5
> jrpp:listenTh:40,idleTh:0,delayTh:0,busyTh:2,totalTh:42 sch: 1/21
> Sessions: 2 Memory(Tot/Free)=1966080/1559324
>
> 03/29 19:58:12 metrics (busy/total) web: 0/5
> jrpp:listenTh:40,idleTh:0,delayTh:0,busyTh:8,totalTh:48 sch: 1/21
> Sessions: 4 Memory(Tot/Free)=1966080/1551116
>
> 03/29 19:59:12 metrics (busy/total) web: 0/5
> jrpp:listenTh:40,idleTh:0,delayTh:0,busyTh:11,totalTh:51 sch: 1/21
> Sessions: 7 Memory(Tot/Free)=1966080/1547020
>
> 03/29 20:00:12 metrics (busy/total) web: 0/5
> jrpp:listenTh:40,idleTh:0,delayTh:0,busyTh:16,totalTh:56 sch: 1/21
> Sessions: 10 Memory(Tot/Free)=1966080/1541644
>
> 03/29 20:01:08 user jrun.servlet.RedirectServlet: init
> 03/29 20:01:08 user FileServlet: init
> 03/29 20:01:12 metrics (busy/total) web: 0/5
> jrpp:listenTh:40,idleTh:0,delayTh:0,busyTh:25,totalTh:65 sch: 1/21
> Sessions: 13 Memory(Tot/Free)=1966080/1535244
>
> 03/29 20:02:12 metrics (busy/total) web: 0/5
> jrpp:listenTh:40,idleTh:1,delayTh:0,busyTh:40,totalTh:81 sch: 1/21
> Sessions: 16 Memory(Tot/Free)=1966080/1527308
>
> 03/29 20:15:12 metrics (busy/total) web: 0/5
> jrpp:listenTh:40,idleTh:1,delayTh:0,busyTh:230,totalTh:271 sch: 1/22
> Sessions: 55 Memory(Tot/Free)=1966080/1404940
>
> 03/29 20:16:12 metrics (busy/total) web: 0/5 
> jrpp:listenTh:40,idleTh:2,delayTh:0,busyTh:238,totalTh:280 sch: 1/22
> Sessions: 58 Memory(Tot/Free)=1966080/1395468
>
> 03/29 20:17:12 metrics (busy/total) web: 0/5
> jrpp:listenTh:40,idleTh:3,delayTh:0,busyTh:246,totalTh:289 sch: 1/22
> Sessions: 56 Memory(Tot/Free)=1966080/1386252
>
> 03/29 20:18:12 metrics (busy/total) web: 0/5
> jrpp:listenTh:40,idleTh:2,delayTh:4,busyTh:256,totalTh:302 sch: 1/22
> Sessions: 54 Memory(Tot/Free)=1966080/1376012
>
> 03/29 20:19:12 metrics (busy/total) web: 0/5
> jrpp:listenTh:40,idleTh:2,delayTh:6,busyTh:256,totalTh:304 sch: 1/22
> Sessions: 51 Memory(Tot/Free)=1966080/1367564
>
> java.lang.RuntimeException: Request timed out waiting for an available

> thread to run. You may want to consider increasing the number of 
> active threads in the thread pool.
>
>         at
jrunx.scheduler.ThreadPool$Throttle.enter(ThreadPool.java:116)
>         at
> jrunx.scheduler.ThreadPool$ThreadThrottle.invokeRunnable(ThreadPool.ja
> va:425)
>
>         at
> jrunx.scheduler.ThreadPool$UpstreamMetrics.invokeRunnable(ThreadPool.j
> ava:266)
>
>         at jrunx.scheduler.WorkerThread.run(WorkerThread.java:66)
> java.lang.RuntimeException: Request timed out waiting for an available

> thread to run. You may want to consider increasing the number of 
> active threads in the thread pool.
>
>         at
jrunx.scheduler.ThreadPool$Throttle.enter(ThreadPool.java:116)
>         at
> jrunx.scheduler.ThreadPool$ThreadThrottle.invokeRunnable(ThreadPool.ja
> va:425)
>
>         at
> jrunx.scheduler.ThreadPool$UpstreamMetrics.invokeRunnable(ThreadPool.j
> ava:266)
>
>         at jrunx.scheduler.WorkerThread.run(WorkerThread.java:66)
>
> With Kind Regards
> Siva Angappan
> R&R Production Support
> Phone: +1 609 734 5425
> _SA...@et..._ <mailto:SAn...@et...>
>
>
> --------------------------------------------------
> This e-mail and any files transmitted with it may contain privileged
or confidential information.
> It is solely for use by the individual for whom it is intended, even
if addressed incorrectly.
> If you received this e-mail in error, please notify the sender; do not

> disclose, copy, distribute, or take any action in reliance on the 
> contents of this information; and delete it from your system. Any
other use of this e-mail is prohibited.
>
> Thank you for your compliance.
> --------------------------------------------------
>   
> ----------------------------------------------------------------------
> --
>
> ----------------------------------------------------------------------
> --- Check out the new SourceForge.net Marketplace.
> It's the best place to buy or sell services for just about anything 
> Open Source.
> http://ad.doubleclick.net/clk;164216239;13503038;w?http://sf.net/marke
> tplace
> ----------------------------------------------------------------------
> --
>
> _______________________________________________
> javagroups-users mailing list
> jav...@li...
> https://lists.sourceforge.net/lists/listinfo/javagroups-users
>   

--------------------------------------------------
This e-mail and any files transmitted with it may contain privileged or confidential information.
It is solely for use by the individual for whom it is intended, even if addressed incorrectly.
If you received this e-mail in error, please notify the sender; do not disclose, copy, distribute,
or take any action in reliance on the contents of this information; and delete it from
your system. Any other use of this e-mail is prohibited.

Thank you for your compliance.
--------------------------------------------------