monitorasteriskgraph.java

无线网络管理

// NAME
//      $RCSfile: MonitorAsteriskGraph.java,v $
// DESCRIPTION
//      [given below in javadoc format]
// DELTA
//      $Revision: 1.2 $
// CREATED
//      $Date: 2006/06/19 10:52:16 $
// COPYRIGHT
//      Westhawk Ltd
// TO DO
//

/*
 * Copyright (C) 1998 - 2006 by Westhawk Ltd
 *
 * Permission to use, copy, modify, and distribute this software
 * for any purpose and without fee is hereby granted, provided
 * that the above copyright notices appear in all copies and that
 * both the copyright notice and this permission notice appear in
 * supporting documentation.
 * This software is provided "as is" without express or implied
 * warranty.
 * author <a href="mailto:[e-mail]">Tim Panton</a>
 */

package uk.co.westhawk.examplev2c;

import uk.co.westhawk.snmp.stack.*;
import uk.co.westhawk.snmp.pdu.*;

import java.util.*;
import java.io.*;

import java.awt.*;
import java.awt.geom.*;
import java.awt.event.*;
import javax.swing.*;
import javax.swing.border.*;

import prefuse.*;
import prefuse.data.*;
import prefuse.data.util.*;
import prefuse.visual.*;
import prefuse.render.*;
import prefuse.activity.*;
import prefuse.action.*;
import prefuse.action.layout.*;
import prefuse.action.layout.graph.*;
import prefuse.action.assignment.*;
import prefuse.util.*;
import prefuse.util.collections.*;
import prefuse.data.expression.*;
import prefuse.visual.expression.*;
import prefuse.controls.*;

/**
 * <p>
 * This class is written to test the Asterisk host functionality.
 * </p>
 *
 * <p>
 * It walks the tree by creating a new AsteriskChanTablePdu out off the
 * previous one, and it collects the values of all the channels.
 * </p>
 *
 * <p>
 * The information will be printed to System.out .
 * </p>
 *
 * <p>
 * The host, port, community name and sockettype can be configured in the
 * properties file.
 * The name of the properties file can be passed as first argument to
 * this application. If there is no such argument, it will look for
 * <code>MonitorAsteriskGraph.properties</code>. If this file does not exist, the
 * application will use default parameters.
 * </p>
 *
 * @author <a href="mailto:[e-mail]">Birgit Arkesteijn</a>
 * @version $Revision: 1.2 $ $Date: 2006/06/19 10:52:16 $
 */
public class MonitorAsteriskGraph extends JPanel
      implements Observer, Runnable, WindowListener 
{
    private static final String     version_id =
        "@(#)$Id: MonitorAsteriskGraph.java,v 1.2 2006/06/19 10:52:16 birgit Exp $ Copyright Westhawk Ltd";

    /**
     * Use 2 (sec) as interval
     */
    public final static long SLEEPTIME = 2000;
    private boolean _mayLoopStart;

    private AsteriskChanTypeTablePdu _atPdu;
    private AsteriskChanTablePdu _aPdu;
    private String _host;
    private int _port;
    private SnmpContextv2c _context;
    private Util _util;

    // Maps channelTypeName to Node index
    private HashMap _channelTypeMap = new HashMap();
    private HashMap _oldActiveChannelMap;

    // Maps activeChannelIndex with pdu
    private HashMap _activeChannelMap;

    // Maps activeChannelName to Node index
    private HashMap _activeChannelNameMap;

    public final static String CTYPE = "channelType";
    public final static String ACHAN = "activeChannel";
    public final static String ISACT = "isActiveChannel";

    public final static String GNAME = "graph";
    public final static String EDGES = "graph.edges";
    public final static String NODES = "graph.nodes";

    public final static String LAYOUT = "layout";
    public final static String COLOUR = "colour";
    public final static String FONT = "font";
    public final static String REPAINT = "repaint";

    private Visualization _viz;
    private Graph _graph;
    private Display _display;
    private Predicate _activeChannelPred;

/**
 * Constructor.
 *
 * @param propertiesFilename The name of the properties file. Can be
 * null.
 */
public MonitorAsteriskGraph(String propertiesFilename)
{
    _util = new Util(propertiesFilename, this.getClass().getName());

    createGraph();

    this.setLayout(new BorderLayout());
    this.add(_display, BorderLayout.CENTER);
}


private void createGraph()
{
    _viz = new Visualization();
    _viz.setInteractive(EDGES, null, false);

    _display = new Display(_viz);
    _display.setForeground(Color.GRAY);
    _display.setBackground(Color.WHITE);

    _graph = new Graph(true);
    VisualGraph vg = _viz.addGraph(GNAME, _graph);

    Table nodesTable = _graph.getNodeTable();
    nodesTable.addColumn(CTYPE, String.class);
    nodesTable.addColumn(ACHAN, String.class);
    nodesTable.addColumn(ISACT, boolean.class);

    // in order for the 'ar' renderer to work, with the
    // _activeChannelPred expression I have to create the ISACT column
    // on edgeTable as well.
    Table edgeTable = _graph.getEdgeTable();
    edgeTable.addColumn(ISACT, boolean.class);

    // set up the renderers
    // use CTYPE label for the ChannelType Nodes 
    LabelRenderer rt = new LabelRenderer(CTYPE);
    rt.setHorizontalPadding(10);
    rt.setVerticalPadding(10);

    // use ACHAN label for the Active Channel Nodes 
    LabelRenderer ar = new LabelRenderer(ACHAN);
    ar.setHorizontalPadding(5);
    ar.setVerticalPadding(5);
    ar.setRoundedCorner(8, 8); // round the corners
    _activeChannelPred = new ColumnExpression(ISACT);

    // create a new default renderer factory
    // return our name label renderer as the default for all non-EdgeItems
    // includes straight line edges for EdgeItems by default
    DefaultRendererFactory drf = new DefaultRendererFactory();
    drf.setDefaultRenderer(rt);
    drf.add(_activeChannelPred, ar);
    _viz.setRendererFactory(drf);


    HoverPredicate hoverPred = new HoverPredicate();
    // throws java.lang.IllegalStateException, shame!
    // I only want the active channel nodes to hover. Sigh.
    // hoverPred.addParameter(_activeChannelPred); 

    // first set up all the colour actions
    ColorAction nStroke = new ColorAction(NODES, VisualItem.STROKECOLOR);
    nStroke.setDefaultColor(ColorLib.color(Color.BLACK));

    ColorAction nFill = new ColorAction(NODES, VisualItem.FILLCOLOR);
    nFill.setDefaultColor(ColorLib.color(Color.PINK));
    nFill.add(hoverPred, ColorLib.color(Color.LIGHT_GRAY));
    nFill.add(_activeChannelPred, ColorLib.color(Color.CYAN));

    ColorAction nText = new ColorAction(NODES, VisualItem.TEXTCOLOR);
    nText.setDefaultColor(ColorLib.color(Color.BLACK));
    nText.add(hoverPred, ColorLib.color(Color.RED));

    ColorAction eStroke = new ColorAction(EDGES, VisualItem.STROKECOLOR);
    eStroke.setDefaultColor(ColorLib.color(Color.BLACK));

    ColorAction eFill = new ColorAction(EDGES, VisualItem.FILLCOLOR);
    eFill.setDefaultColor(ColorLib.color(Color.BLACK));

    // bundle the colour actions
    ActionList colours = new ActionList();
    colours.add(nStroke);
    colours.add(nFill);
    colours.add(nText);
    colours.add(eStroke);
    colours.add(eFill);
    _viz.putAction(COLOUR, colours);


    // create a separate repaint action
    ActionList repaint = new ActionList();
    repaint.add(colours);
    repaint.add(new RepaintAction());
    _viz.putAction(REPAINT, repaint);


    // create a font action
    FontAction fonts = new FontAction(NODES, FontLib.getFont("Tahoma", Font.BOLD, 12));
    ActionList font = new ActionList();
    font.add(fonts);
    _viz.putAction(FONT, font);


    // create an action list with layout
    ActionList layout = new ActionList(Activity.DEFAULT_STEP_TIME);
    layout.add(new ForceDirectedLayout(GNAME));
    layout.add(new CircleLayout(GNAME));
    _viz.putAction(LAYOUT, layout);

    // add some controls:
    // - repaint when hovering
    _display.addControlListener(new HoverActionControl(REPAINT));

    // when hovering over an activeChannel Node, show the details
    _display.addControlListener(new ControlAdapter() 
    {
        public void itemEntered(VisualItem item, MouseEvent e) 
        {
            if (item.canGetString(ACHAN))
            {
                // title.setText(item.getString(ACHAN));
                String txt = item.getString(ACHAN);
                if (txt != null)
                {
                    showActiveChannelInfo(txt);
                }
            }
        }
        public void itemExited(VisualItem item, MouseEvent e) 
        {
            // title.setText(null);
        }
    });
}


public void init ()
{
    // AsnObject.setDebug(15);
    AsnObject.setDebug(6);
    _host = _util.getHost();
    String bindAddr = _util.getBindAddress();
    _port = _util.getPort(SnmpContextBasisFace.DEFAULT_PORT);
    String socketType = _util.getSocketType();
    String community = _util.getCommunity();

    try
    {
        _context = new SnmpContextv2c(_host, _port, bindAddr, socketType);
        _context.setCommunity(community);
        System.out.println("context: " + _context.toString());
    }
    catch (IOException exc)
    {
        System.out.println("IOException: " + exc.getMessage());
        System.exit(0);
    }
}

/** 
 * Sends a request, asking for the channels types. The types shouldn't
 * change during the lifetime of the agent.
 */
public void getChannelTypes(SnmpContextBasisFace con, AsteriskChanTypeTablePdu prev)
{
    _atPdu = new AsteriskChanTypeTablePdu(con);
    _atPdu.addObserver(this);
    _atPdu.addOids(prev);
    try
    {
        _atPdu.send();
    }
    catch(java.io.IOException exc)
    {
        System.out.println("getChannelTypes(): IOException " + exc.getMessage());
    }
    catch(uk.co.westhawk.snmp.stack.PduException exc)
    {
        System.out.println("getChannelTypes(): PduException " + exc.getMessage());
    }
}


/** 
 * Sends a request, asking for the active channels. The active channels
 * change by nature.
 */
public void getActiveChannels(SnmpContextBasisFace con, AsteriskChanTablePdu prev)
{
    _aPdu = new AsteriskChanTablePdu(con);
    _aPdu.addObserver(this);
    _aPdu.addOids(prev);
    try
    {
        _aPdu.send();
    }
    catch(java.io.IOException exc)
    {
        System.out.println("getActiveChannels(): IOException " + exc.getMessage());
    }
    catch(uk.co.westhawk.snmp.stack.PduException exc)
    {
        System.out.println("getActiveChannels(): PduException " + exc.getMessage());
    }
}


public void start()
{
    // Get the channel types once and then keep looping to get the
    // active channels
    if (_context != null)
    {
        getChannelTypes(_context, null);
    }
}

protected void startThread()
{
    _mayLoopStart = true;
    Thread me = new Thread(this);
    me.setPriority(Thread.MIN_PRIORITY);
    me.start();
}

public void run()
{
    // Get the channel types once and then keep looping to get the
    // active channels
    while (_context != null)
    {
        if (_mayLoopStart == true)
        {
            // System.out.println("\nrun: starting from the top .. ");