/* * Copyright (c) 2004, Oracle and/or its affiliates. All rights reserved. * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. * * This code is free software; you can redistribute it and/or modify it * under the terms of the GNU General Public License version 2 only, as * published by the Free Software Foundation.  Oracle designates this * particular file as subject to the "Classpath" exception as provided * by Oracle in the LICENSE file that accompanied this code. * * This code is distributed in the hope that it will be useful, but WITHOUT * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License * version 2 for more details (a copy is included in the LICENSE file that * accompanied this code). * * You should have received a copy of the GNU General Public License version * 2 along with this work; if not, write to the Free Software Foundation, * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA. * * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA * or visit www.oracle.com if you need additional information or have any * questions. */ package sun.tools.jstatd; import java.util.*;import java.nio.*;import java.io.*;import java.net.*;import java.rmi.*;import java.rmi.server.*;import sun.jvmstat.monitor.*;import sun.jvmstat.monitor.event.*;import sun.jvmstat.monitor.remote.*; /** * Concrete implementation of the RemoteHost interface for the HotSpot * PerfData <em>rmi:</em> protocol. * <p> * This class provides remote access to the instrumentation exported * by HotSpot Java Virtual Machines through the PerfData shared memory * interface. * * @author Brian Doherty * @since 1.5 */public class RemoteHostImpl implements RemoteHost, HostListener {     private MonitoredHost monitoredHost;    private Set<Integer> activeVms;     public RemoteHostImpl() throws MonitorException {        try {            monitoredHost = MonitoredHost.getMonitoredHost("localhost");        } catch (URISyntaxException e) { }         activeVms = monitoredHost.activeVms();        monitoredHost.addHostListener(this);    }     public RemoteVm attachVm(int lvmid, String mode)                    throws RemoteException, MonitorException {        Integer v = new Integer(lvmid);        RemoteVm stub = null;        StringBuffer sb = new StringBuffer();         sb.append("local://").append(lvmid).append("@localhost");        if (mode != null) {            sb.append("?mode=" + mode);        }         String vmidStr = sb.toString();         try {            VmIdentifier vmid = new VmIdentifier(vmidStr);            MonitoredVm mvm = monitoredHost.getMonitoredVm(vmid);            RemoteVmImpl rvm = new RemoteVmImpl((BufferedMonitoredVm)mvm);            stub = (RemoteVm) UnicastRemoteObject.exportObject(rvm, 0);        }        catch (URISyntaxException e) {            throw new RuntimeException("Malformed VmIdentifier URI: "                                       + vmidStr, e);        }        return stub;    }     public void detachVm(RemoteVm rvm) throws RemoteException {        rvm.detach();    }     public int[] activeVms() throws MonitorException {        Object[] vms = null;        int[] vmids = null;         vms = monitoredHost.activeVms().toArray();        vmids = new int[vms.length];         for (int i = 0; i < vmids.length; i++) {            vmids[i] = ((Integer)vms[i]).intValue();        }        return vmids;    }     public void vmStatusChanged(VmStatusChangeEvent ev) {        synchronized(this.activeVms) {            activeVms.retainAll(ev.getActive());        }    }     public void disconnected(HostEvent ev) {        // we only monitor the local host, so this event shouldn't occur.    }}