import java.util.List;

import java.util.Vector;

import org.eclipse.hyades.internal.execution.local.control.AgentPeerListener;

import org.eclipse.hyades.internal.execution.local.control.Node;

import org.eclipse.hyades.trace.ui.ProfileUIManager;

import org.eclipse.hyades.trace.ui.internal.util.AttachConfigurationDetail;

import org.eclipse.jface.preference.IPreferenceStore;

import org.eclipse.tptp.platform.common.internal.CommonPlugin;

import org.eclipse.tptp.platform.common.ui.trace.internal.CommonUITraceConstants;

    /*

     * (non-Javadoc)

     * @see org.eclipse.hyades.trace.ui.internal.piclient.PIProcessListener#peerWaiting(org.eclipse.hyades.internal.execution.local.control.Agent, org.eclipse.hyades.internal.execution.local.control.Agent)

     */

    public synchronized void peerWaiting(Agent agent, Agent peer) {

        /*

         * Check if we're already attached to this agent. If so,

         * don't try to attach again.

         */

        if (!peer.isAttached() && trcProcessProxy != null && trcProcessProxy.getNode() != null) {

	        /*

	         * Find the TRCAgentProxy associated with the agent, in

	         * order to match the settings on the new TRCAgentProxy.

	         */

	        TRCAgentProxy trcAgent = null;

	        Iterator iter = trcProcessProxy.getAgentProxies().iterator();

	        while (iter.hasNext()) {

	            TRCAgentProxy agentProxy = (TRCAgentProxy)iter.next();

	            Object obj = LoadersUtils.locateAgentInstance(agentProxy);

	            if (obj == agent) {

	                trcAgent = agentProxy;

	                break;

	            }

	        }

	        /*

	         * Set the default project, monitor, and profile file.

	         */

			IPreferenceStore store = UIPlugin.getDefault().getPreferenceStore();

			String projectName = store.getString(CommonUITraceConstants.TRACE_PROJECT_NAME);

			String monitorName = store.getString(CommonUITraceConstants.TRACE_MONITOR_NAME);

			// bug 95689: if agent is currently profile to file, the peer agent will also be profile to file.

			String profileFile = (agent!=null? agent.getProfileFile():null);

			String peerProfileFile = null;

			if (profileFile!=null) {

				StringBuffer suffix = new StringBuffer().append("_").

					append(trcAgent.getProcessProxy().getNode().getName()).append("_").

					append(trcAgent.getProcessProxy().getPid()).append("_").

					append(trcAgent.getRuntimeId()).append(".trcxml"); //$NON-NLS-1$

				int ext = profileFile.lastIndexOf(".trcxml"); //$NON-NLS-1$

				if (ext>0) {

					peerProfileFile = new StringBuffer(profileFile.substring(0,ext)).append(suffix).toString();

				}

				else {

					peerProfileFile =  new StringBuffer(profileFile).append(suffix).toString();

				}

			}

	        /*

	         * If the peer agent can be found, match the values on the

	         * newly discovered agent.

	         */

	        if (trcAgent != null) {

	            TRCProcessProxy trcProcess = trcAgent.getProcessProxy();

	            if (trcProcess != null) {

	                TRCNode trcNode = trcProcess.getNode();

	                if (trcNode != null) {

	                    TRCMonitor trcMonitor = trcNode.getMonitor();

	                    if (trcMonitor != null) {

//	                        IResource folder = HyadesUtil.getSelectionFolder(trcMonitor);

	                    	URI projectPath = trcMonitor.eResource().getURI();

	                        String fullProjectPath =  projectPath.trimSegments(1).path();

	                        fullProjectPath = fullProjectPath.substring(fullProjectPath.indexOf('/', 1));

	                        fullProjectPath = fullProjectPath.replaceAll("%20", " ");

	                        if (fullProjectPath != null) {

	                            monitorName = trcMonitor.getName();

	                            projectName = fullProjectPath;

	                        }

	                    }

	                }

	            }

	        }

	        try {

	            Node node = peer.getProcess().getNode();

	            final String hostname = node.getName();

	            String port = String.valueOf(node.getConnection().getPort());

	            Vector agents = new Vector();

	            agents.add(peer);

	            /*

	             * Add Analysis Type

	             */

        		LauncherUtility.associateAnalysisType(peer, InstrumentConstants.ARM_ANALYSIS_TYPE);

	            /*

	             * Copy the agent options to the newly discovered

	             * agent.

	             */

	            Vector options = new Vector();

	            AgentConfiguration conf = agent.getConfiguration();

	            for (int i=0;i<conf.size();++i) {

	                options.add(conf.getEntryAt(i));

	            }

	            /*

	             * Force the connection to be established before attaching.

	             * This will avoid the delay in re-establishing when start

	             * monitoring, which freezes the UI.

	             */

	            PDCoreUtil.profileConnect(hostname, port);

	            /*

	             * Attach to the newly discovered agent.

	             */

	            AttachConfigurationDetail attachConfigurationDetail = new AttachConfigurationDetail();

	            attachConfigurationDetail.setHostName(hostname);

	            attachConfigurationDetail.setAgents(agents);

	            attachConfigurationDetail.setOptions(options);

	            attachConfigurationDetail.setProject(projectName);

	            attachConfigurationDetail.setMonitor(monitorName);

	            attachConfigurationDetail.setPortNumber(port);

	            attachConfigurationDetail.setProfileFile(peerProfileFile);

	            attachConfigurationDetail.setSwitchPerspective(false);

	            List trcAgents = PDCoreUtil.attach(attachConfigurationDetail);

	            if (trcAgents != null)

	            {

		            for (int i = 0, agentsCount = trcAgents.size(); i < agentsCount; i++)

					{

		            	TRCAgentProxy currentAgentProxy = (TRCAgentProxy)trcAgents.get(i);

		            	Object currentAgent = LoadersUtils.locateAgentInstance(currentAgentProxy);

		            	if (currentAgent instanceof Agent)

		            	{

		            		/* Set Collection mode */		            		

		            		setCollectionMode((Agent)currentAgent, currentAgentProxy);

		            		/* attach */

		            		PDCoreUtil.doAttach((Agent)currentAgent, currentAgentProxy);

		            	}

					}

		            if (trcAgents.size() == 1) {

		                final Object obj = trcAgents.get(0);

		                if (obj instanceof TRCAgentProxy) {

		                    Display.getDefault().syncExec(new Runnable() {

		                        public void run() {

		    			            ProfileUIManager.getInstance().startMonitoring((TRCAgentProxy)obj);

		                        }

		                    });

		                }

		            }	            	

	            }

	        }

	        catch (Exception e) {

	        	CommonPlugin.logError(e);

	        }

        }

    }