view system-backend/src/main/java/com/redhat/thermostat/backend/system/JvmStatHostListener.java @ 893:9e6bcfc40ea1

Create VM CPU agent and common bundles This commit extracts VM CPU data collection from SystemBackend into a vm-cpu-agent bundle. It also moves the VmCpuStatDAO from common-core into a vm-cpu-common bundle that registers the DAO once Storage is available. This also removes the DAO from DAOFactory. One side-effect is changing the visibility of VmLatestPojoListGetter to public in order for this DAO implementation (and DAOs in the other commits in this series) to access it. This also temporarily adds the vm-cpu-common bundle as a dependency to client-cli until my later dynamic vm-stat patch. Reviewed-by: omajid Review-thread: http://icedtea.classpath.org/pipermail/thermostat/2013-January/004996.html
author Elliott Baron <ebaron@redhat.com>
date Mon, 07 Jan 2013 15:48:38 -0500
parents 6c00e304b0c3
children 0ba74f790a8a
line wrap: on
line source

/*
 * Copyright 2012 Red Hat, Inc.
 *
 * This file is part of Thermostat.
 *
 * Thermostat is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published
 * by the Free Software Foundation; either version 2, or (at your
 * option) any later version.
 *
 * Thermostat 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 for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with Thermostat; see the file COPYING.  If not see
 * <http://www.gnu.org/licenses/>.
 *
 * Linking this code with other modules is making a combined work
 * based on this code.  Thus, the terms and conditions of the GNU
 * General Public License cover the whole combination.
 *
 * As a special exception, the copyright holders of this code give
 * you permission to link this code with independent modules to
 * produce an executable, regardless of the license terms of these
 * independent modules, and to copy and distribute the resulting
 * executable under terms of your choice, provided that you also
 * meet, for each linked independent module, the terms and conditions
 * of the license of that module.  An independent module is a module
 * which is not derived from or based on this code.  If you modify
 * this code, you may extend this exception to your version of the
 * library, but you are not obligated to do so.  If you do not wish
 * to do so, delete this exception statement from your version.
 */

package com.redhat.thermostat.backend.system;

import java.net.URISyntaxException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.CopyOnWriteArraySet;
import java.util.logging.Level;
import java.util.logging.Logger;

import sun.jvmstat.monitor.MonitorException;
import sun.jvmstat.monitor.MonitoredHost;
import sun.jvmstat.monitor.MonitoredVm;
import sun.jvmstat.monitor.VmIdentifier;
import sun.jvmstat.monitor.event.HostEvent;
import sun.jvmstat.monitor.event.HostListener;
import sun.jvmstat.monitor.event.VmListener;
import sun.jvmstat.monitor.event.VmStatusChangeEvent;

import com.redhat.thermostat.agent.JvmStatusListener;
import com.redhat.thermostat.agent.JvmStatusNotifier;
import com.redhat.thermostat.common.dao.VmClassStatDAO;
import com.redhat.thermostat.common.dao.VmGcStatDAO;
import com.redhat.thermostat.common.dao.VmInfoDAO;
import com.redhat.thermostat.common.dao.VmMemoryStatDAO;
import com.redhat.thermostat.common.utils.LoggingUtils;
import com.redhat.thermostat.storage.model.VmInfo;
import com.redhat.thermostat.utils.ProcDataSource;

public class JvmStatHostListener implements HostListener, JvmStatusNotifier {

    private static final Logger logger = LoggingUtils.getLogger(JvmStatHostListener.class);

    private boolean attachNew;

    private final VmInfoDAO vmInfoDAO;
    private final VmMemoryStatDAO vmMemoryStatDAO;
    private final VmClassStatDAO vmClassStatDAO;
    private final VmGcStatDAO vmGcStatDAO;

    private Map<Integer, MonitoredVm> monitoredVms  = new HashMap<>();
    private Map<MonitoredVm, List<VmListener>> registeredListeners  = new ConcurrentHashMap<>();
    
    private Set<JvmStatusListener> statusListeners = new CopyOnWriteArraySet<JvmStatusListener>();

    JvmStatHostListener(VmInfoDAO vmInfoDAO, VmMemoryStatDAO vmMemoryStatDAO, VmGcStatDAO vmGcStatDAO,
            VmClassStatDAO vmClassStatDAO, boolean attachNew) {
        this.vmInfoDAO = vmInfoDAO;
        this.vmMemoryStatDAO = vmMemoryStatDAO;
        this.vmGcStatDAO = vmGcStatDAO;
        this.vmClassStatDAO = vmClassStatDAO;
        this.attachNew = attachNew;        
    }

    void removeAllListeners() {
        for (MonitoredVm vm : monitoredVms.values()) {
            for (VmListener listener : registeredListeners.get(vm)) {
                try {
                    if (listener != null) vm.removeVmListener(listener);
                
                } catch (MonitorException e) {
                    logger.log(Level.WARNING, "can't remove vm listener", e);
                }
            }
        }
    }
    
    @Override
    public void disconnected(HostEvent event) {
        logger.warning("Disconnected from host");
    }

    @SuppressWarnings("unchecked") // Unchecked casts to (Set<Integer>).
    @Override
    public void vmStatusChanged(VmStatusChangeEvent event) {
        MonitoredHost host = event.getMonitoredHost();

        for (Integer newVm : (Set<Integer>) event.getStarted()) {
            try {
                logger.fine("New vm: " + newVm);
                sendNewVM(newVm, host);
            } catch (MonitorException e) {
                logger.log(Level.WARNING, "error getting info for new vm" + newVm, e);
            } catch (URISyntaxException e) {
                logger.log(Level.WARNING, "error getting info for new vm" + newVm, e);
            }
        }

        for (Integer stoppedVm : (Set<Integer>) event.getTerminated()) {
            try {
                logger.fine("stopped vm: " + stoppedVm);
                sendStoppedVM(stoppedVm, host);
            } catch (URISyntaxException e) {
                logger.log(Level.WARNING, "error getting info for stopped vm" + stoppedVm, e);
            } catch (MonitorException e) {
                logger.log(Level.WARNING, "error getting info for stopped vm" + stoppedVm, e);
            }
        }
    }

    private void sendNewVM(Integer vmId, MonitoredHost host)
            throws MonitorException, URISyntaxException {
        MonitoredVm vm = host.getMonitoredVm(host.getHostIdentifier().resolve(
                new VmIdentifier(vmId.toString())));
        if (vm != null) {
            VmInfo info = null;
            try {
                long startTime = System.currentTimeMillis();
                long stopTime = Long.MIN_VALUE;
                JvmStatDataExtractor extractor = new JvmStatDataExtractor(vm);
                Map<String, String> properties = new HashMap<String, String>();
                ProcDataSource dataSource = new ProcDataSource();
                Map<String, String> environment = new ProcessEnvironmentBuilder(dataSource).build(vmId);
                // TODO actually figure out the loaded libraries.
                String[] loadedNativeLibraries = new String[0];
                info = new VmInfo(vmId, startTime, stopTime,
                        extractor.getJavaVersion(), extractor.getJavaHome(),
                        extractor.getMainClass(), extractor.getCommandLine(),
                        extractor.getVmName(), extractor.getVmInfo(), extractor.getVmVersion(), extractor.getVmArguments(),
                        properties, environment, loadedNativeLibraries);
                vmInfoDAO.putVmInfo(info);
                logger.finer("Sent VM_STARTED messsage");
            } catch (MonitorException me) {
                logger.log(Level.WARNING, "error getting vm info for " + vmId, me);
            }

            if (attachNew) {
                List<VmListener> listeners = registeredListeners.get(vm);
                if (listeners == null) {
                    listeners = new CopyOnWriteArrayList<>();
                }
                
                VmListener listener =  new JvmStatVmListener(vmMemoryStatDAO, vmGcStatDAO, vmId);
                vm.addVmListener(listener);
                listeners.add(listener);
                
                listener = new JvmStatVmClassListener(vmClassStatDAO, vmId);
                vm.addVmListener(listener);
                listeners.add(listener);
                
                registeredListeners.put(vm, listeners);
                
            } else {
                logger.log(Level.FINE, "skipping new vm " + vmId);
            }
            for (JvmStatusListener statusListener : statusListeners) {
                statusListener.jvmStarted(vmId);
            }

            monitoredVms.put(vmId, vm);
        }
    }

    private void sendStoppedVM(Integer vmId, MonitoredHost host) throws URISyntaxException, MonitorException {
        
        VmIdentifier resolvedVmID = host.getHostIdentifier().resolve(new VmIdentifier(vmId.toString()));
        if (resolvedVmID != null) {
            long stopTime = System.currentTimeMillis();
            for (JvmStatusListener statusListener : statusListeners) {
                statusListener.jvmStopped(vmId);
            }
            vmInfoDAO.putVmStoppedTime(vmId, stopTime);

            MonitoredVm vm = monitoredVms.remove(vmId);
            List<VmListener> listeners = registeredListeners.remove(vm);
            for (VmListener listener : listeners) {
                try {
                    if (listener != null) vm.removeVmListener(listener);
                } catch (MonitorException e) {
                    logger.log(Level.WARNING, "can't remove vm listener", e);
                }
            }
            vm.detach();
        }
    }

    @Override
    public void addJvmStatusListener(JvmStatusListener listener) {
        statusListeners.add(listener);
    }

    @Override
    public void removeJvmStatusListener(JvmStatusListener listener) {
        statusListeners.remove(listener);
    }
}