You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jmeter-dev@jakarta.apache.org by se...@apache.org on 2003/01/27 06:57:44 UTC
cvs commit: jakarta-jmeter/src/core/org/apache/jmeter/reporters ResultCollector.java
seade 2003/01/26 21:57:44
Modified: src/core/org/apache/jmeter/reporters ResultCollector.java
Log:
Formatting changes only.
Revision Changes Path
1.9 +347 -367 jakarta-jmeter/src/core/org/apache/jmeter/reporters/ResultCollector.java
Index: ResultCollector.java
===================================================================
RCS file: /home/cvs/jakarta-jmeter/src/core/org/apache/jmeter/reporters/ResultCollector.java,v
retrieving revision 1.8
retrieving revision 1.9
diff -u -r1.8 -r1.9
--- ResultCollector.java 17 Oct 2002 19:47:17 -0000 1.8
+++ ResultCollector.java 27 Jan 2003 05:57:43 -0000 1.9
@@ -2,7 +2,7 @@
* ====================================================================
* The Apache Software License, Version 1.1
*
- * Copyright (c) 2001 The Apache Software Foundation. All rights
+ * Copyright (c) 2001-2003 The Apache Software Foundation. All rights
* reserved.
*
* Redistribution and use in source and binary forms, with or without
@@ -53,6 +53,7 @@
* <http://www.apache.org/>.
*/
package org.apache.jmeter.reporters;
+
import java.io.BufferedOutputStream;
import java.io.ByteArrayOutputStream;
import java.io.File;
@@ -86,373 +87,352 @@
import org.xml.sax.SAXException;
/**
- * Title: Description: Copyright: Copyright (c) 2001 Company:
+ * Title: Description: Copyright: Copyright (c) 2001 Company:
*
- *@author Michael Stover
- *@created $Date$
- *@version 1.0
+ * @author Michael Stover
+ * @version $Id$
*/
-
-public class ResultCollector extends AbstractListenerElement implements SampleListener, Clearable,
- Serializable,TestListener,Remoteable
+public class ResultCollector
+ extends AbstractListenerElement
+ implements SampleListener, Clearable, Serializable, TestListener, Remoteable
{
- transient private static Logger log = Hierarchy.getDefaultHierarchy().getLoggerFor(
- "jmeter.elements");
- private final static String COLLECTED = "collected";
- public final static String FILENAME = "filename";
- private static boolean functionalMode = false;
- public static final String ERROR_LOGGING = "ResultCollector.error_logging";
-
- /**
- * !ToDo (Field description)
- */
- //protected List results = Collections.synchronizedList(new ArrayList());
- private int current;
- transient private DefaultConfigurationSerializer serializer;
- private boolean inLoading = false;
- transient private PrintWriter out;
- private boolean inTest = false;
- private static Map files = new HashMap();
- private Set hosts = new HashSet();
-
-
- /**
- * !ToDo (Constructor description)
- */
- public ResultCollector()
- {
- current = -1;
- serializer = new DefaultConfigurationSerializer();
- setErrorLogging(false);
- }
-
- private void setFilenameProperty(String f)
- {
- setProperty(FILENAME,f);
- }
-
- public String getFilename()
- {
- return getPropertyAsString(FILENAME);
- }
-
- public boolean isErrorLogging()
- {
- return getPropertyAsBoolean(ERROR_LOGGING);
- }
-
- public void setErrorLogging(boolean errorLogging)
- {
- setProperty(ERROR_LOGGING,new Boolean(errorLogging));
- }
-
- /**
- * Sets the filename attribute of the ResultCollector object
- *
- *@param f The new filename value`
- */
- public void setFilename(String f) throws IOException,IllegalUserActionException
- {
- if(inTest)
- {
- throw new IllegalUserActionException(JMeterUtils.getResString("busy_testing"));
- }
- try
- {
- setFilenameProperty(f);
- loadExistingFile();
- }
- catch(SAXException e)
- {
- log.error("",e);
- throw new IOException("File "+f+" was improperly formatted");
- }
- catch(ConfigurationException e)
- {
- throw new IOException("File "+f+" was improperly formatted");
- }
- }
-
- public void testEnded(String host)
- {
- hosts.remove(host);
- if(hosts.size() == 0)
- {
- finalizeFileOutput();
- inTest = false;
- }
- }
-
- public void testStarted(String host)
- {
- hosts.add(host);
- try {
- initializeFileOutput();
- } catch(Exception e) {
- log.error("",e);
- }
- inTest = true;
- }
-
- public void testEnded()
- {
- testEnded("local");
- }
-
- public void testStarted()
- {
- testStarted("local");
- }
-
- public void loadExistingFile()
- throws SAXException, IOException, ConfigurationException {
- inLoading = true;
- if(new File(getFilename()).exists())
- {
- clear();
- try {
- Configuration savedSamples = getConfiguration(getFilename());
- readSamples(savedSamples);
- } catch(Exception e) {
- log.error("",e);
- }
- }
- inLoading = false;
- }
-
- /**
- * Description of the Method
- */
- private static void writeFileStart(PrintWriter writer)
- {
- writer.println("<?xml version=\"1.0\" encoding=\"UTF-8\"?>");
- writer.println("<testResults>");
- }
-
- /**
- * Description of the Method
- */
- private void writeFileEnd()
- {
- out.print("</testResults>");
- }
-
- private static synchronized PrintWriter getFileWriter(String filename) throws IOException
- {
- if(filename == null || filename.length() == 0)
- {
- return null;
- }
- PrintWriter writer = (PrintWriter)files.get(filename);
- boolean trimmed = true;
- if(writer == null)
- {
- trimmed = trimLastLine(filename);
- writer = new PrintWriter(new OutputStreamWriter(
- new BufferedOutputStream(new FileOutputStream(
- filename,trimmed)),"UTF-8"));
- files.put(filename,writer);
- }
- if(!trimmed)
- {
- writeFileStart(writer);
- }
- return writer;
- }
-
- private static boolean trimLastLine(String filename)
- {
- try
- {
- TextFile text = new TextFile(filename);
- String xml = text.getText();
- xml = xml.substring(0,xml.indexOf("</testResults>"));
- text.setText(xml);
- }
- catch(Exception e)
- {
- return false;
- }
- return true;
- }
-
- public static void enableFunctionalMode(boolean mode)
- {
- functionalMode = mode;
- }
-
- public boolean getFunctionalMode()
- {
- return functionalMode || isErrorLogging();
- }
-
- /**
- * Gets the serializedSampleResult attribute of the ResultCollector object
- *
- *@param result Description of the Parameter
- *@return The serializedSampleResult value
- */
- private String getSerializedSampleResult(SampleResult result) throws SAXException,
- IOException,ConfigurationException
- {
- ByteArrayOutputStream tempOut = new ByteArrayOutputStream();
- serializer.serialize(tempOut, SaveService.getConfiguration(result,getFunctionalMode()));
- String serVer = tempOut.toString();
- return serVer.substring(serVer.indexOf(System.getProperty("line.separator")));
- }
-
- /**
- * Description of the Method
- *
- *@param testResults Description of the Parameter
- */
- private void readSamples(Configuration testResults) throws
- IOException,SAXException,ConfigurationException
- {
- Configuration[] samples = testResults.getChildren();
- for(int i = 0; i < samples.length; i++)
- {
- SampleResult result = SaveService.getSampleResult(samples[i]);
- sendToVisualizer(result);
- recordResult(result);
- }
- }
-
- /**
- * Gets the configuration attribute of the ResultCollector object
- *
- *@param filename Description of the Parameter
- *@return The configuration value
- */
- private Configuration getConfiguration(String filename) throws SAXException,
- IOException,ConfigurationException
- {
- DefaultConfigurationBuilder builder = new DefaultConfigurationBuilder();
- return builder.buildFromFile(filename);
- }
-
- /**
- * !ToDo (Method description)
- */
- public void clear()
- {
- current = -1;
- if(getVisualizer() != null && getVisualizer() instanceof Clearable)
- {
- ((Clearable)getVisualizer()).clear();
- }
- finalizeFileOutput();
- }
-
- /**
- * !ToDo (Method description)
- *
- *@param l !ToDo (Parameter description)
- */
- public void setListener(Object l) { }
-
-
-
- /**
- * !ToDo (Method description)
- *
- *@param e !ToDo (Parameter description)
- */
- public void sampleStarted(SampleEvent e) { }
-
- /**
- * !ToDo (Method description)
- *
- *@param e !ToDo (Parameter description)
- */
- public void sampleStopped(SampleEvent e) { }
-
- /**
- * !ToDo (Method description)
- *
- *@param e !ToDo (Parameter description)
- */
- public void sampleOccurred(SampleEvent e)
- {
- if(!isErrorLogging() || !e.getResult().isSuccessful())
- {
- sendToVisualizer(e.getResult());
- try
- {
- recordResult(e.getResult());
- }
- catch(Exception err)
- {
- log.error("",err); //should throw exception back to caller
- }
- }
- }
-
- protected void sendToVisualizer(SampleResult r) {
- if(getVisualizer() != null)
- {
- getVisualizer().add(r);
- }
- }
-
- /**
- * Description of the Method
- *
- *@param result Description of the Parameter
- */
- private void recordResult(SampleResult result) throws SAXException,IOException,
- ConfigurationException
- {
- if(out != null)
- {
- if(!isResultMarked(result))
- {
- out.print(getSerializedSampleResult(result));
- }
- }
- }
-
- private synchronized boolean isResultMarked(SampleResult res)
- {
- boolean marked = res.isMarked(getFilename());
- if(!marked)
- {
- res.setMarked(getFilename());
- }
- return marked;
- }
-
- private void initializeFileOutput() throws IOException,
- ConfigurationException,SAXException
- {
-
- if(out == null && getFilename() != null)
- {
- if(out == null)
- {
- try
- {
- out = getFileWriter(getFilename());
- }
- catch(FileNotFoundException e)
- {
- out = null;
- }
- }
- }
- }
-
- /**
- * Description of the Method
- */
- private synchronized void finalizeFileOutput()
- {
- if(out != null)
- {
- writeFileEnd();
- out.close();
- files.remove(getFilename());
- out = null;
- }
- }
+ transient private static Logger log =
+ Hierarchy.getDefaultHierarchy().getLoggerFor("jmeter.elements");
+ private final static String COLLECTED = "collected";
+ public final static String FILENAME = "filename";
+ private static boolean functionalMode = false;
+ public static final String ERROR_LOGGING = "ResultCollector.error_logging";
+
+ //protected List results = Collections.synchronizedList(new ArrayList());
+ private int current;
+ transient private DefaultConfigurationSerializer serializer;
+ private boolean inLoading = false;
+ transient private PrintWriter out;
+ private boolean inTest = false;
+ private static Map files = new HashMap();
+ private Set hosts = new HashSet();
+
+ /**
+ * No-arg constructor.
+ */
+ public ResultCollector()
+ {
+ current = -1;
+ serializer = new DefaultConfigurationSerializer();
+ setErrorLogging(false);
+ }
+
+ private void setFilenameProperty(String f)
+ {
+ setProperty(FILENAME, f);
+ }
+
+ public String getFilename()
+ {
+ return getPropertyAsString(FILENAME);
+ }
+
+ public boolean isErrorLogging()
+ {
+ return getPropertyAsBoolean(ERROR_LOGGING);
+ }
+
+ public void setErrorLogging(boolean errorLogging)
+ {
+ setProperty(ERROR_LOGGING, new Boolean(errorLogging));
+ }
+
+ /**
+ * Sets the filename attribute of the ResultCollector object
+ *
+ * @param f The new filename value.
+ */
+ public void setFilename(String f) throws IOException, IllegalUserActionException
+ {
+ if (inTest)
+ {
+ throw new IllegalUserActionException(JMeterUtils.getResString("busy_testing"));
+ }
+ try
+ {
+ setFilenameProperty(f);
+ loadExistingFile();
+ }
+ catch (SAXException e)
+ {
+ log.error("", e);
+ throw new IOException("File " + f + " was improperly formatted");
+ }
+ catch (ConfigurationException e)
+ {
+ throw new IOException("File " + f + " was improperly formatted");
+ }
+ }
+
+ public void testEnded(String host)
+ {
+ hosts.remove(host);
+ if (hosts.size() == 0)
+ {
+ finalizeFileOutput();
+ inTest = false;
+ }
+ }
+
+ public void testStarted(String host)
+ {
+ hosts.add(host);
+ try
+ {
+ initializeFileOutput();
+ }
+ catch (Exception e)
+ {
+ log.error("", e);
+ }
+ inTest = true;
+ }
+
+ public void testEnded()
+ {
+ testEnded("local");
+ }
+
+ public void testStarted()
+ {
+ testStarted("local");
+ }
+
+ public void loadExistingFile() throws SAXException, IOException, ConfigurationException
+ {
+ inLoading = true;
+ if (new File(getFilename()).exists())
+ {
+ clear();
+ try
+ {
+ Configuration savedSamples = getConfiguration(getFilename());
+ readSamples(savedSamples);
+ }
+ catch (Exception e)
+ {
+ log.error("", e);
+ }
+ }
+ inLoading = false;
+ }
+
+ private static void writeFileStart(PrintWriter writer)
+ {
+ writer.println("<?xml version=\"1.0\" encoding=\"UTF-8\"?>");
+ writer.println("<testResults>");
+ }
+
+ private void writeFileEnd()
+ {
+ out.print("</testResults>");
+ }
+
+ private static synchronized PrintWriter getFileWriter(String filename) throws IOException
+ {
+ if (filename == null || filename.length() == 0)
+ {
+ return null;
+ }
+ PrintWriter writer = (PrintWriter) files.get(filename);
+ boolean trimmed = true;
+ if (writer == null)
+ {
+ trimmed = trimLastLine(filename);
+ writer =
+ new PrintWriter(
+ new OutputStreamWriter(
+ new BufferedOutputStream(new FileOutputStream(filename, trimmed)),
+ "UTF-8"));
+ files.put(filename, writer);
+ }
+ if (!trimmed)
+ {
+ writeFileStart(writer);
+ }
+ return writer;
+ }
+
+ private static boolean trimLastLine(String filename)
+ {
+ try
+ {
+ TextFile text = new TextFile(filename);
+ String xml = text.getText();
+ xml = xml.substring(0, xml.indexOf("</testResults>"));
+ text.setText(xml);
+ }
+ catch (Exception e)
+ {
+ return false;
+ }
+ return true;
+ }
+
+ public static void enableFunctionalMode(boolean mode)
+ {
+ functionalMode = mode;
+ }
+
+ public boolean getFunctionalMode()
+ {
+ return functionalMode || isErrorLogging();
+ }
+
+ /**
+ * Gets the serializedSampleResult attribute of the ResultCollector object
+ *
+ * @param result Description of the Parameter
+ * @return The serializedSampleResult value
+ */
+ private String getSerializedSampleResult(SampleResult result)
+ throws SAXException, IOException, ConfigurationException
+ {
+ ByteArrayOutputStream tempOut = new ByteArrayOutputStream();
+ serializer.serialize(tempOut, SaveService.getConfiguration(result, getFunctionalMode()));
+ String serVer = tempOut.toString();
+ return serVer.substring(serVer.indexOf(System.getProperty("line.separator")));
+ }
+
+ /**
+ * Description of the Method
+ *
+ * @param testResults Description of the Parameter
+ */
+ private void readSamples(Configuration testResults)
+ throws IOException, SAXException, ConfigurationException
+ {
+ Configuration[] samples = testResults.getChildren();
+ for (int i = 0; i < samples.length; i++)
+ {
+ SampleResult result = SaveService.getSampleResult(samples[i]);
+ sendToVisualizer(result);
+ recordResult(result);
+ }
+ }
+
+ /**
+ * Gets the configuration attribute of the ResultCollector object
+ *
+ * @param filename Description of the Parameter
+ * @return The configuration value
+ */
+ private Configuration getConfiguration(String filename)
+ throws SAXException, IOException, ConfigurationException
+ {
+ DefaultConfigurationBuilder builder = new DefaultConfigurationBuilder();
+ return builder.buildFromFile(filename);
+ }
+
+ public void clear()
+ {
+ current = -1;
+ if (getVisualizer() != null && getVisualizer() instanceof Clearable)
+ {
+ ((Clearable) getVisualizer()).clear();
+ }
+ finalizeFileOutput();
+ }
+
+ public void setListener(Object l)
+ {
+ }
+
+ public void sampleStarted(SampleEvent e)
+ {
+ }
+
+ public void sampleStopped(SampleEvent e)
+ {
+ }
+
+ public void sampleOccurred(SampleEvent e)
+ {
+ if (!isErrorLogging() || !e.getResult().isSuccessful())
+ {
+ sendToVisualizer(e.getResult());
+ try
+ {
+ recordResult(e.getResult());
+ }
+ catch (Exception err)
+ {
+ log.error("", err); //should throw exception back to caller
+ }
+ }
+ }
+
+ protected void sendToVisualizer(SampleResult r)
+ {
+ if (getVisualizer() != null)
+ {
+ getVisualizer().add(r);
+ }
+ }
+
+ /**
+ * Description of the Method
+ *
+ * @param result Description of the Parameter
+ */
+ private void recordResult(SampleResult result)
+ throws SAXException, IOException, ConfigurationException
+ {
+ if (out != null)
+ {
+ if (!isResultMarked(result))
+ {
+ out.print(getSerializedSampleResult(result));
+ }
+ }
+ }
+
+ private synchronized boolean isResultMarked(SampleResult res)
+ {
+ boolean marked = res.isMarked(getFilename());
+ if (!marked)
+ {
+ res.setMarked(getFilename());
+ }
+ return marked;
+ }
+
+ private void initializeFileOutput() throws IOException, ConfigurationException, SAXException
+ {
+
+ if (out == null && getFilename() != null)
+ {
+ if (out == null)
+ {
+ try
+ {
+ out = getFileWriter(getFilename());
+ }
+ catch (FileNotFoundException e)
+ {
+ out = null;
+ }
+ }
+ }
+ }
+
+ /**
+ * Description of the Method
+ */
+ private synchronized void finalizeFileOutput()
+ {
+ if (out != null)
+ {
+ writeFileEnd();
+ out.close();
+ files.remove(getFilename());
+ out = null;
+ }
+ }
+
}
--
To unsubscribe, e-mail: <ma...@jakarta.apache.org>
For additional commands, e-mail: <ma...@jakarta.apache.org>