From: Julio G. <ju...@us...> - 2004-11-24 18:37:37
|
Update of /cvsroot/smartfrog/core/smartfrog/src/org/smartfrog/sfcore/prim In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv16403/src/org/smartfrog/sfcore/prim Modified Files: LivenessSender.java PrimImpl.java Log Message: Naming threads Index: PrimImpl.java =================================================================== RCS file: /cvsroot/smartfrog/core/smartfrog/src/org/smartfrog/sfcore/prim/PrimImpl.java,v retrieving revision 1.48 retrieving revision 1.49 diff -C2 -d -r1.48 -r1.49 *** PrimImpl.java 12 Nov 2004 23:04:13 -0000 1.48 --- PrimImpl.java 24 Nov 2004 18:37:25 -0000 1.49 *************** *** 657,661 **** try { sfLivenessSender = new LivenessSender(this, ! sfLivenessDelay * 1000); sfLivenessSender.start(); } catch (Throwable t) { --- 657,661 ---- try { sfLivenessSender = new LivenessSender(this, ! sfLivenessDelay * 1000, this.sfCompleteNameSafe().toString() ); sfLivenessSender.start(); } catch (Throwable t) { Index: LivenessSender.java =================================================================== RCS file: /cvsroot/smartfrog/core/smartfrog/src/org/smartfrog/sfcore/prim/LivenessSender.java,v retrieving revision 1.2 retrieving revision 1.3 diff -C2 -d -r1.2 -r1.3 *** LivenessSender.java 24 Nov 2004 18:19:13 -0000 1.2 --- LivenessSender.java 24 Nov 2004 18:37:25 -0000 1.3 *************** *** 35,38 **** --- 35,40 ---- protected Liveness target; + protected String name = "LivenessSender"; + /** * Constructor. *************** *** 41,45 **** * @param delay wait between heartbeats (in millis) */ ! public LivenessSender(Liveness target, long delay) { super(delay); this.target = target; --- 43,47 ---- * @param delay wait between heartbeats (in millis) */ ! public LivenessSender(Liveness target, long delay, String name) { super(delay); this.target = target; *************** *** 66,71 **** * @return Thread */ ! protected Thread createThread(Runnable run) { ! Thread t = new Thread(livenessGroup, run,"LivenessSender"); t.setDaemon(true); --- 68,75 ---- * @return Thread */ ! protected Thread createThread(Runnable run, String nameTh) { ! if (nameTh !=null) ! this.name = nameTh+"."+name; ! Thread t = new Thread(livenessGroup, run,name); t.setDaemon(true); |