cms/conient/DataPanel.java

//---PACKAGE DECLARATION---
package uk.ac.ukc.iscream.conient;

//---IMPORTS---
import uk.ac.ukc.iscream.util.*;
import java.util.HashMap;
import javax.swing.ImageIcon;
import javax.swing.JTabbedPane;
import javax.swing.JPanel;

/**
 * This thread reads data from the DataReader
 * it then asks the appropriate HostDisplayPanel
 * to update its data.
 *
 * @author  $Author: ajm4 $
 * @version $Id: DataPanel.java,v 1.13 2001/02/26 00:25:00 ajm4 Exp $
 */
public class DataPanel extends JPanel implements Runnable {

//---FINAL ATTRIBUTES---

    /**
     * The current CVS revision of this class
     */
    public final String REVISION = "$Revision: 1.13 $";

//---STATIC METHODS---
    
//---CONSTRUCTORS---

//---PUBLIC METHODS---

    /**
     * Starts the DataPanel running
     */
    public void run() {
        // add the tabbed pane to ourselves
        add(_tabbedPane);
        
        // the hosts we are interested in go here
        HashMap hostList = new HashMap();
        
        try {
            while(_running) {
                
                String xml = (String) _dataQueue.get(_myQueue);
                Conient.setQueueStatus(_dataQueue.queueSize(_myQueue), _dataQueue.elementCount());
                if (xml == null) {
                    // shouldn't really happen...but not sure
                    //_status.insert("No XML to update...",0);
                } else {
                    
                    // Get a string without any null characters in it.
                    //  -- maybe String.trim() would be better ?
                    if (xml.indexOf(0) != -1) {
                        xml = xml.substring(0, xml.indexOf(0));
                    }
                    else {
                        xml = xml.substring(0, xml.length());
                    }
                    
                    // Use XMLPacketMaker to make an XMLPacket object.
                    XMLPacketMaker xmlPacketMaker = new XMLPacketMaker(xml);
                    XMLPacket packet = xmlPacketMaker.createXMLPacket();

                    // if we want to debug the packets
                    if(!Configuration.getInstance().getProperty("packetDump").equals("0")) {
                        System.out.println("[DEBUG]\n" + packet.printAll());
                    }
                    
                    String packetType = packet.getParam("packet.attributes.type");
                    if (packetType.equals("heartbeat") || packetType.equals("data")) {
                        String hostName = packet.getParam("packet.attributes.machine_name");
                        if(!hostList.containsKey(hostName)) {
                        
                            HostDisplayPanel host = new HostDisplayPanel(hostName);       
                            _tabbedPane.addTab(hostName, _serverIcon, host, "Monitor " + hostName);
                            hostList.put(hostName, host);
                            Conient.addMessage("New Host added: " + hostName);
                        }
                        if (!((HostDisplayPanel) hostList.get(hostName)).updateHost(packet)) {
                            //throw new Exception(hostName + " sent an invalid data packet stopping data update!");
                            Conient.addMessage("WARNING{data panel}: " + hostName + " sent an invalid data or heartbeat packet");
                        }
                    } else if (packetType.equals("queueStat")) {
                        // check to config to see if we want queueStat packets to be processed or not
                        if(!Configuration.getInstance().getProperty("displayQueueInformation").equals("0")) {
                            if (qFrame == null) {
                                qFrame = new QueueFrame();
                            }
                            qFrame.update(packet);
                        }
                    } else {
                        Conient.addMessage("WARNING{data panel}: and unknown packet type was received - " + packetType);
                    }
                }
            }
        } catch (Exception e) {
            Conient.addMessage("ERROR{data panel}: +" + e);
            e.printStackTrace();
        }
    }

    /**
     * This method allows other classes 
     * to shutdown this data panel.
     */
    public void shutdown() {
        _running = false;
    }

//---PRIVATE METHODS---

//---ACCESSOR/MUTATOR METHODS---

//---ATTRIBUTES---    

    /**
     * The state of this thread.
     */
    boolean _running = true;

    /**
     * Assigns the queue that this panel
     * will use to obtain data
     *
     * @param queue the queue
     */
    public void setQueue(Queue queue) {
        _dataQueue = queue;
        _myQueue = _dataQueue.getQueue();
    }

    /**
     * Removes all the tabs on display
     * Used to tidy up when a new data
     * channel is opened.
     */
    public void cleanUpTabs() {
        _tabbedPane.removeAll();
    }

    /**
     * The tabbed pane is where HostDisplayPanel's
     * are placed
     */
    JTabbedPane _tabbedPane = new JTabbedPane();
    
    /**
     * The queue new data will be read from
     */
    Queue _dataQueue;
    
    /**
     * Our queue number
     */
    int _myQueue;
    
    /**
     * An icon to represent a host
     */
    ImageIcon _serverIcon = new ImageIcon("./uk/ac/ukc/iscream/conient/server.gif");
    
    /**
     * A frame to display Queue information
     * may not always be used - loaded according to config
     */
    QueueFrame qFrame = null; 
    
}
Revision:	1.14
Committed:	Tue Feb 27 03:09:59 2001 UTC (23 years, 3 months ago) by ajm
Branch:	MAIN
Changes since 1.13:	+4 -4 lines
Log Message:	Now has fully support for configuration modification, saving and loading. Note there are still bugs, namely the server config is NOT treated seperately from local config, as well as concurrency issues of loading in a config as its changing. Also not present is support for checking all REQUIRED configuration options are present, so that will need to be done.
#	User	Rev	Content
1	ajm	1.5	//---PACKAGE DECLARATION---
2			package uk.ac.ukc.iscream.conient;
3
4			//---IMPORTS---
5	ajm	1.1	import uk.ac.ukc.iscream.util.*;
6	ajm	1.5	import java.util.HashMap;
7			import javax.swing.ImageIcon;
8			import javax.swing.JTabbedPane;
9			import javax.swing.JPanel;
10
11			/**
12			* This thread reads data from the DataReader
13			* it then asks the appropriate HostDisplayPanel
14			* to update its data.
15			*
16	ajm	1.6	* @author $Author: ajm4 $
17	ajm	1.14	* @version $Id: DataPanel.java,v 1.13 2001/02/26 00:25:00 ajm4 Exp $
18	ajm	1.5	*/
19			public class DataPanel extends JPanel implements Runnable {
20	ajm	1.1
21	ajm	1.5	//---FINAL ATTRIBUTES---
22	ajm	1.2
23	ajm	1.5	/**
24			* The current CVS revision of this class
25			*/
26	ajm	1.14	public final String REVISION = "$Revision: 1.13 $";
27	ajm	1.5
28			//---STATIC METHODS---
29
30			//---CONSTRUCTORS---
31
32			//---PUBLIC METHODS---
33
34			/**
35			* Starts the DataPanel running
36			*/
37	ajm	1.1	public void run() {
38	ajm	1.5	// add the tabbed pane to ourselves
39	ajm	1.2	add(_tabbedPane);
40	ajm	1.5
41			// the hosts we are interested in go here
42	ajm	1.1	HashMap hostList = new HashMap();
43	ajm	1.5
44	ajm	1.1	try {
45	ajm	1.5	while(_running) {
46	ajm	1.1
47			String xml = (String) _dataQueue.get(_myQueue);
48	ajm	1.6	Conient.setQueueStatus(_dataQueue.queueSize(_myQueue), _dataQueue.elementCount());
49	ajm	1.1	if (xml == null) {
50			// shouldn't really happen...but not sure
51			//_status.insert("No XML to update...",0);
52			} else {
53
54			// Get a string without any null characters in it.
55			// -- maybe String.trim() would be better ?
56			if (xml.indexOf(0) != -1) {
57			xml = xml.substring(0, xml.indexOf(0));
58			}
59			else {
60			xml = xml.substring(0, xml.length());
61			}
62
63			// Use XMLPacketMaker to make an XMLPacket object.
64			XMLPacketMaker xmlPacketMaker = new XMLPacketMaker(xml);
65			XMLPacket packet = xmlPacketMaker.createXMLPacket();
66	ajm	1.13
67			// if we want to debug the packets
68	ajm	1.14	if(!Configuration.getInstance().getProperty("packetDump").equals("0")) {
69	ajm	1.13	System.out.println("[DEBUG]\n" + packet.printAll());
70			}
71
72	ajm	1.11	String packetType = packet.getParam("packet.attributes.type");
73			if (packetType.equals("heartbeat") \|\| packetType.equals("data")) {
74			String hostName = packet.getParam("packet.attributes.machine_name");
75			if(!hostList.containsKey(hostName)) {
76	ajm	1.1
77	ajm	1.11	HostDisplayPanel host = new HostDisplayPanel(hostName);
78			_tabbedPane.addTab(hostName, _serverIcon, host, "Monitor " + hostName);
79			hostList.put(hostName, host);
80			Conient.addMessage("New Host added: " + hostName);
81			}
82			if (!((HostDisplayPanel) hostList.get(hostName)).updateHost(packet)) {
83			//throw new Exception(hostName + " sent an invalid data packet stopping data update!");
84			Conient.addMessage("WARNING{data panel}: " + hostName + " sent an invalid data or heartbeat packet");
85			}
86	ajm	1.12	} else if (packetType.equals("queueStat")) {
87			// check to config to see if we want queueStat packets to be processed or not
88	ajm	1.14	if(!Configuration.getInstance().getProperty("displayQueueInformation").equals("0")) {
89	ajm	1.12	if (qFrame == null) {
90			qFrame = new QueueFrame();
91			}
92			qFrame.update(packet);
93			}
94	ajm	1.11	} else {
95			Conient.addMessage("WARNING{data panel}: and unknown packet type was received - " + packetType);
96	ajm	1.5	}
97	ajm	1.1	}
98			}
99			} catch (Exception e) {
100	ajm	1.8	Conient.addMessage("ERROR{data panel}: +" + e);
101	ajm	1.10	e.printStackTrace();
102	ajm	1.1	}
103			}
104
105	ajm	1.5	/**
106			* This method allows other classes
107			* to shutdown this data panel.
108			*/
109			public void shutdown() {
110			_running = false;
111			}
112
113			//---PRIVATE METHODS---
114
115			//---ACCESSOR/MUTATOR METHODS---
116
117			//---ATTRIBUTES---
118
119			/**
120			* The state of this thread.
121			*/
122			boolean _running = true;
123
124			/**
125			* Assigns the queue that this panel
126			* will use to obtain data
127			*
128			* @param queue the queue
129			*/
130	ajm	1.1	public void setQueue(Queue queue) {
131			_dataQueue = queue;
132			_myQueue = _dataQueue.getQueue();
133	tdb	1.4	}
134
135	ajm	1.5	/**
136			* Removes all the tabs on display
137			* Used to tidy up when a new data
138			* channel is opened.
139			*/
140	tdb	1.4	public void cleanUpTabs() {
141			_tabbedPane.removeAll();
142	ajm	1.1	}
143
144	ajm	1.5	/**
145			* The tabbed pane is where HostDisplayPanel's
146			* are placed
147			*/
148	ajm	1.1	JTabbedPane _tabbedPane = new JTabbedPane();
149	ajm	1.5
150			/**
151			* The queue new data will be read from
152			*/
153	ajm	1.1	Queue _dataQueue;
154	ajm	1.5
155			/**
156			* Our queue number
157			*/
158	ajm	1.1	int _myQueue;
159	ajm	1.5
160			/**
161			* An icon to represent a host
162			*/
163	ajm	1.7	ImageIcon _serverIcon = new ImageIcon("./uk/ac/ukc/iscream/conient/server.gif");
164	ajm	1.12
165			/**
166			* A frame to display Queue information
167			* may not always be used - loaded according to config
168			*/
169			QueueFrame qFrame = null;
170
171	ajm	1.7	}