client/javacli/XMLStreamReaderThread.java

/* 
 * i-scream central monitoring system
 * Copyright (C) 2000-2002 i-scream
 * 
 * This program 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
 * of the License, or (at your option) any later version.
 * 
 * This program 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 this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
 */

//---PACKAGE DECLARATION---

//---IMPORTS---
import java.io.*;
import java.net.*;
import java.util.ArrayList;

import org.xml.sax.*;
import javax.xml.parsers.SAXParserFactory;
import javax.xml.parsers.ParserConfigurationException;
import javax.xml.parsers.SAXParser;

/**
 * XMLStreamReaderThread.
 *
 * @author  $Author: pjm2 $
 * @version $Id: XMLStreamReaderThread.java,v 1.1 2001/01/14 21:58:11 pjm2 Exp $
 */
public class XMLStreamReaderThread extends Thread {

//---FINAL ATTRIBUTES---

    /**
     * The current CVS revision of this class
     */
    public final String REVISION = "$Revision: 1.1 $";
    
//---STATIC METHODS---

//---CONSTRUCTORS---

    // Constructor
    public XMLStreamReaderThread (String serverName, int serverPort, TerminalScreen screen) {
        _serverName = serverName;
        _serverPort = serverPort;
        _screen = screen;
    }

//---PUBLIC METHODS---

    public void run() {

        final int maxPacketSize = 8196;
        final int startByte = 0;
        final int endByte = 1;

        BufferedReader br = null;
        try {
            Socket conn = new Socket(_serverName, _serverPort);
            InputStreamReader isr = new InputStreamReader(conn.getInputStream());
            br = new BufferedReader(isr);
            
        }
        catch(Exception e) {
            _screen.clear();
            System.out.println("Cannot connect to "+_serverName+":"+_serverPort);
            System.exit(1);
        }

        DataLayout layout = new DataLayout(_screen, JavaCLIParameters.showData);

        // Use the default (non-validating) parser
        SAXParserFactory factory = SAXParserFactory.newInstance();
        while (1 == 1) {
            try {
                String xml = br.readLine();

                // Parse the input
                XMLPacket packet = new XMLPacket();
                SAXParser saxParser = factory.newSAXParser();
                saxParser.parse(new InputSource(new StringReader(xml)), new XMLStreamParser(packet));


                // For out information
                //_screen.gotoxy(4, 5);
                //_screen.print(packet.printAll(), TerminalScreen.RED);
                
                layout.updateScreen(packet);

            }
            catch (IOException e) {
                System.out.println("Connection to server broken.");
                break;
            }
            catch (Exception e) {
                System.out.println("Error caught in the Thread: "+e);
                break;
            }
        }

        _screen.clear();

    }


//---PRIVATE METHODS---

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

//---ATTRIBUTES---

    private String _serverName;
    private int _serverPort;
    private TerminalScreen _screen;

//---STATIC ATTRIBUTES---

}
Revision:	1.2
Committed:	Sat May 18 18:15:56 2002 UTC (22 years, 6 months ago) by tdb
Branch:	MAIN
Changes since 1.1:	+22 -3 lines
Log Message:	i-scream is now licensed under the GPL. I've added the GPL headers to every source file, and put a full copy of the license in the appropriate places. I think I've covered everything. This is going to be a mad commit ;)
#	User	Rev	Content
1	tdb	1.2	/*
2			* i-scream central monitoring system
3			* Copyright (C) 2000-2002 i-scream
4			*
5			* This program is free software; you can redistribute it and/or
6			* modify it under the terms of the GNU General Public License
7			* as published by the Free Software Foundation; either version 2
8			* of the License, or (at your option) any later version.
9			*
10			* This program is distributed in the hope that it will be useful,
11			* but WITHOUT ANY WARRANTY; without even the implied warranty of
12			* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13			* GNU General Public License for more details.
14			*
15			* You should have received a copy of the GNU General Public License
16			* along with this program; if not, write to the Free Software
17			* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
18			*/
19
20	pjm2	1.1	//---PACKAGE DECLARATION---
21
22			//---IMPORTS---
23			import java.io.*;
24			import java.net.*;
25			import java.util.ArrayList;
26
27			import org.xml.sax.*;
28			import javax.xml.parsers.SAXParserFactory;
29			import javax.xml.parsers.ParserConfigurationException;
30			import javax.xml.parsers.SAXParser;
31
32			/**
33			* XMLStreamReaderThread.
34			*
35	tdb	1.2	* @author $Author: pjm2 $
36			* @version $Id: XMLStreamReaderThread.java,v 1.1 2001/01/14 21:58:11 pjm2 Exp $
37	pjm2	1.1	*/
38			public class XMLStreamReaderThread extends Thread {
39
40			//---FINAL ATTRIBUTES---
41
42			/**
43			* The current CVS revision of this class
44			*/
45	tdb	1.2	public final String REVISION = "$Revision: 1.1 $";
46	pjm2	1.1
47			//---STATIC METHODS---
48
49			//---CONSTRUCTORS---
50
51			// Constructor
52			public XMLStreamReaderThread (String serverName, int serverPort, TerminalScreen screen) {
53			_serverName = serverName;
54			_serverPort = serverPort;
55			_screen = screen;
56			}
57
58			//---PUBLIC METHODS---
59
60			public void run() {
61
62			final int maxPacketSize = 8196;
63			final int startByte = 0;
64			final int endByte = 1;
65
66			BufferedReader br = null;
67			try {
68			Socket conn = new Socket(_serverName, _serverPort);
69			InputStreamReader isr = new InputStreamReader(conn.getInputStream());
70			br = new BufferedReader(isr);
71
72			}
73			catch(Exception e) {
74			_screen.clear();
75			System.out.println("Cannot connect to "+_serverName+":"+_serverPort);
76			System.exit(1);
77			}
78
79			DataLayout layout = new DataLayout(_screen, JavaCLIParameters.showData);
80
81			// Use the default (non-validating) parser
82			SAXParserFactory factory = SAXParserFactory.newInstance();
83			while (1 == 1) {
84			try {
85			String xml = br.readLine();
86
87			// Parse the input
88			XMLPacket packet = new XMLPacket();
89			SAXParser saxParser = factory.newSAXParser();
90			saxParser.parse(new InputSource(new StringReader(xml)), new XMLStreamParser(packet));
91
92
93			// For out information
94			//_screen.gotoxy(4, 5);
95			//_screen.print(packet.printAll(), TerminalScreen.RED);
96
97			layout.updateScreen(packet);
98
99			}
100			catch (IOException e) {
101			System.out.println("Connection to server broken.");
102			break;
103			}
104			catch (Exception e) {
105			System.out.println("Error caught in the Thread: "+e);
106			break;
107			}
108			}
109
110			_screen.clear();
111
112			}
113
114
115			//---PRIVATE METHODS---
116
117			//---ACCESSOR/MUTATOR METHODS---
118
119			//---ATTRIBUTES---
120
121			private String _serverName;
122			private int _serverPort;
123			private TerminalScreen _screen;
124
125			//---STATIC ATTRIBUTES---
126
127			}