From 576b4a107a3efb1dc96127f38f66bfb4de4bb94b Mon Sep 17 00:00:00 2001 From: Derek Hulley Date: Mon, 5 Jun 2006 14:35:10 +0000 Subject: [PATCH] Added created threads to thread groups to assist with profiling git-svn-id: https://svn.alfresco.com/repos/alfresco-enterprise/alfresco/HEAD/root@3028 c4b6b30b-aa2e-2d43-bbcb-ca4b014f7261 --- .../java/org/alfresco/filesys/ftp/FTPNetworkServer.java | 6 +++++- .../filesys/smb/server/NetBIOSSessionSocketHandler.java | 4 +++- .../filesys/smb/server/TcpipSMBSessionSocketHandler.java | 4 +++- .../server/win32/Win32NetBIOSSessionSocketHandler.java | 8 ++++++-- 4 files changed, 17 insertions(+), 5 deletions(-) diff --git a/source/java/org/alfresco/filesys/ftp/FTPNetworkServer.java b/source/java/org/alfresco/filesys/ftp/FTPNetworkServer.java index ecba21b326..a185206f88 100644 --- a/source/java/org/alfresco/filesys/ftp/FTPNetworkServer.java +++ b/source/java/org/alfresco/filesys/ftp/FTPNetworkServer.java @@ -46,6 +46,10 @@ public class FTPNetworkServer extends NetworkFileServer implements Runnable // Constants // + + // Session Thread group + private static final ThreadGroup THREAD_GROUP_SESSION = new ThreadGroup("FTP_SESSION_GROUP"); + // Server version private static final String ServerVersion = "3.5.0"; @@ -446,7 +450,7 @@ public class FTPNetworkServer extends NetworkFileServer implements Runnable // Start the new session in a seperate thread - Thread srvThread = new Thread(srvSess); + Thread srvThread = new Thread(THREAD_GROUP_SESSION, srvSess); srvThread.setDaemon(true); srvThread.setName("Sess_FTP" + srvSess.getSessionId() + "_" + sessSock.getInetAddress().getHostAddress()); diff --git a/source/java/org/alfresco/filesys/smb/server/NetBIOSSessionSocketHandler.java b/source/java/org/alfresco/filesys/smb/server/NetBIOSSessionSocketHandler.java index 2d3b1c693f..9fa5b20a46 100644 --- a/source/java/org/alfresco/filesys/smb/server/NetBIOSSessionSocketHandler.java +++ b/source/java/org/alfresco/filesys/smb/server/NetBIOSSessionSocketHandler.java @@ -29,6 +29,8 @@ import org.alfresco.filesys.smb.mailslot.TcpipNetBIOSHostAnnouncer; */ public class NetBIOSSessionSocketHandler extends SessionSocketHandler { + // Session Thread group + private static final ThreadGroup THREAD_GROUP_SESSION = new ThreadGroup("NETBIOS_SESSION_GROUP"); /** * Class constructor @@ -96,7 +98,7 @@ public class NetBIOSSessionSocketHandler extends SessionSocketHandler // Start the new session in a seperate thread - Thread srvThread = new Thread(srvSess); + Thread srvThread = new Thread(THREAD_GROUP_SESSION, srvSess); srvThread.setDaemon(true); srvThread.setName("Sess_N" + srvSess.getSessionId() + "_" + sessSock.getInetAddress().getHostAddress()); diff --git a/source/java/org/alfresco/filesys/smb/server/TcpipSMBSessionSocketHandler.java b/source/java/org/alfresco/filesys/smb/server/TcpipSMBSessionSocketHandler.java index bbc6a235d3..a00f863407 100644 --- a/source/java/org/alfresco/filesys/smb/server/TcpipSMBSessionSocketHandler.java +++ b/source/java/org/alfresco/filesys/smb/server/TcpipSMBSessionSocketHandler.java @@ -28,6 +28,8 @@ import org.alfresco.filesys.smb.TcpipSMB; */ public class TcpipSMBSessionSocketHandler extends SessionSocketHandler { + // Session Thread group + private static final ThreadGroup THREAD_GROUP_SESSION = new ThreadGroup("SMB_SESSION_GROUP"); /** * Class constructor @@ -95,7 +97,7 @@ public class TcpipSMBSessionSocketHandler extends SessionSocketHandler // Start the new session in a seperate thread - Thread srvThread = new Thread(srvSess); + Thread srvThread = new Thread(THREAD_GROUP_SESSION, srvSess); srvThread.setDaemon(true); srvThread.setName("Sess_T" + srvSess.getSessionId() + "_" + sessSock.getInetAddress().getHostAddress()); diff --git a/source/java/org/alfresco/filesys/smb/server/win32/Win32NetBIOSSessionSocketHandler.java b/source/java/org/alfresco/filesys/smb/server/win32/Win32NetBIOSSessionSocketHandler.java index 8574cbe223..407b01f6ac 100644 --- a/source/java/org/alfresco/filesys/smb/server/win32/Win32NetBIOSSessionSocketHandler.java +++ b/source/java/org/alfresco/filesys/smb/server/win32/Win32NetBIOSSessionSocketHandler.java @@ -53,6 +53,10 @@ public class Win32NetBIOSSessionSocketHandler extends SessionSocketHandler imple // Constants // + + // Session Thread group + private static final ThreadGroup THREAD_GROUP_SESSION = new ThreadGroup("W32NETBIOS_SESSION_GROUP"); + // Default LANA offline polling interval public static final long LANAPollingInterval = 5000; // 5 seconds @@ -605,7 +609,7 @@ public class Win32NetBIOSSessionSocketHandler extends SessionSocketHandler imple // Start the new session in a seperate thread - Thread srvThread = new Thread(srvSess); + Thread srvThread = new Thread(THREAD_GROUP_SESSION, srvSess); srvThread.setDaemon(true); srvThread.setName("Sess_W" + srvSess.getSessionId() + "_LSN" + lsn); srvThread.start(); @@ -750,7 +754,7 @@ public class Win32NetBIOSSessionSocketHandler extends SessionSocketHandler imple // Start the new session in a seperate thread - Thread srvThread = new Thread(srvSess); + Thread srvThread = new Thread(THREAD_GROUP_SESSION, srvSess); srvThread.setDaemon(true); srvThread.setName("Sess_WS" + srvSess.getSessionId()); srvThread.start();