[ https://jira.jboss.org/jira/browse/JBAS-6879?page=com.atlassian.jira.plug... ] Brian Stansberry updated JBAS-6879: ----------------------------------- JBoss Forum Reference: http://www.jboss.org/index.html?module=bb&op=viewtopic&t=154345 Affects Version/s: JBossAS-4.2.3.GA JBossAS-4.2.2.GA JBossAS-4.2.1.GA JBossAS-4.2.0.GA JBossAS-4.0.5.GA JBossAS-4.0.4.GA JBossAS-4.0.3 SP1 JBossAS-4.0.3 Final JBossAS-4.0.2 Final JBossAS-4.0.1 SP1 JBossAS-4.0.1 Final JBossAS-4.0.0 Final Moved issue from JBCLUSTER to JBAS. Linked in the forum thread. "Affects Version" is basically all the releases before AS 5; this has been there from the first revision of the code. Clustered deployment in AS 5.1 is radically different and doesn't have this issue. This fix looks to be along the line of what's discussed on the forum thread. I'll check it out and if OK commit it to Branch_4_2. Note however that we do not expect to produce any further releases from Branch_4_2. -- This message is automatically generated by JIRA. - If you think it was sent incorrectly contact one of the administrators: https://jira.jboss.org/jira/secure/Administrators.jspa - For more information on JIRA, see: http://www.atlassian.com/software/jira

[ https://jira.jboss.org/jira/browse/JBAS-6879?page=com.atlassian.jira.plug... ] sachin mishra commented on JBAS-6879: ------------------------------------- Hi Brian, Yes, its similar to the discussion we had on the forum. Here is the complete java code that i wrote to fix this issue for my cluster. I will be using this in the production system soon so if you see anything that looks incorrect please let me know. /* * To change this template, choose Tools | Templates * and open the template in the editor. */ package xxx; import java.io.File; import java.net.URL; import java.util.Date; import java.util.HashMap; import java.util.Iterator; import java.util.Map; import org.apache.log4j.Logger; import org.jboss.ha.framework.interfaces.HAPartition; import org.jboss.ha.framework.server.ClusterFileTransfer; import org.jboss.ha.framework.server.ClusterFileTransfer.ClusterFileTransferException; import org.jboss.ha.framework.server.FarmMemberService; import org.jboss.system.ServiceMBean; public class ClusterMemberService extends FarmMemberService { private Logger logger = Logger.getLogger(getClass()); private ClusterFileTransfer mFileTransfer; private boolean doInit = true; @Override protected void pullNewDeployments(HAPartition partition, HashMap farmed) { if (ServiceMBean.STARTING == getState()) { if (doInit) { init(); doInit = false; } } else { logger.info("using pullNewDeployments on FarmMemberService as we are not in starting state... "); super.pullNewDeployments(partition, farmed); return; } Iterator it = farmed.keySet().iterator(); String parentName = null; File destFile = null; while (it.hasNext()) { String depName = (String) it.next(); Date last = (Date) farmed.get(depName); DeployedURL du = (DeployedURL) parentDUMap.get(depName); int indexofParentName = depName.indexOf('/'); parentName = depName.substring(0, indexofParentName); String child = depName.substring(indexofParentName + 1, depName.length()); File parentFolder = findParent(parentName); if (parentFolder == null) { IllegalStateException stateException = new IllegalStateException("Can't find the farmed folder " + parentName); logger.error(stateException, stateException); throw stateException; } destFile = new File(parentFolder, child); Date localDeployedDate = new Date(destFile.lastModified()); logger.info("parentname=" + parentName + " destfile= " + destFile.getAbsolutePath() + " isexist=" + destFile.exists() + " local mode date=" + localDeployedDate + " remote deploy date=" + last); if (destFile.exists() && !localDeployedDate.before(last)) { logger.info(" no need to pull " + depName + " from remote server as the timestamps are same"); } else { logger.info(" going to pull " + depName + " from remote server....."); pullRemoteFile(new File(depName), parentName); } } } private void init() { try { HAPartition lHAPartition = null; if (mClusterPartition != null) { lHAPartition = mClusterPartition.getHAPartition(); } if (lHAPartition == null) { // Old style config with PartitionName was used -- have to // look up the partition in JMX lHAPartition = (HAPartition) getServer().getAttribute( mClusterPartitionName, "HAPartition"); } mFileTransfer = new ClusterFileTransfer(lHAPartition, buildParentFolderMapping()); logger.info("Created mFileTransfer successfully"); } catch (Exception e) { logger.error("Error Starting ClusterMemberService ", e); } } private void pullRemoteFile(File destFile, String parentName) { try { mFileTransfer.pull(destFile, parentName); synchronized (remotelyDeployed) { remotelyDeployed.add(destFile.getName()); } } catch (ClusterFileTransferException e) { // log the exception and continue with the next deployment log.error(e, e); } } // return mapping of Farming folder names to the File private Map buildParentFolderMapping() { Map map = new HashMap(); URL[] urls = (URL[]) urlList.toArray(new URL[]{}); for (int i = 0; i < urlList.size(); i++) { if (urls[i].getProtocol().equals("file")) { File file = new File(urls[i].getFile()); if (file.isDirectory()) { map.put(file.getName(), file); } } } return map; } } -- This message is automatically generated by JIRA. - If you think it was sent incorrectly contact one of the administrators: https://jira.jboss.org/jira/secure/Administrators.jspa - For more information on JIRA, see: http://www.atlassian.com/software/jira