jeremias 2004/09/07 13:57:47
Added: test/java/org/apache/fop/threading FOProcessorImpl.java
FOPTestbed.java sample.cfg.xml FOProcessor.java
Main.java
Log:
Initial import of multi-threading testbed.
Revision Changes Path
1.1 xml-fop/test/java/org/apache/fop/threading/FOProcessorImpl.java
Index: FOProcessorImpl.java
===================================================================
/*
* Copyright 2004 The Apache Software Foundation.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
/* $Id: FOProcessorImpl.java,v 1.1 2004/09/07 20:57:47 jeremias Exp $ */
package org.apache.fop.threading;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.URL;
import javax.xml.transform.*;
import javax.xml.transform.stream.StreamSource;
import javax.xml.transform.stream.StreamResult;
import javax.xml.transform.sax.SAXResult;
import org.xml.sax.InputSource;
import org.apache.avalon.framework.logger.AbstractLogEnabled;
import org.apache.avalon.framework.configuration.*;
import org.apache.fop.apps.Fop;
import org.apache.fop.apps.FOPException;
import org.apache.fop.fo.Constants;
import org.apache.avalon.framework.activity.Initializable;
public class FOProcessorImpl extends AbstractLogEnabled
implements FOProcessor, Configurable, Initializable {
private String baseDir;
private String fontBaseDir;
private String userconfig;
private boolean strokeSVGText;
public void configure(Configuration configuration) throws ConfigurationException
{
this.baseDir = configuration.getChild("basedir").getValue(null);
this.fontBaseDir = configuration.getChild("fontbasedir").getValue(null);
this.userconfig = configuration.getChild("userconfig").getValue(null);
this.strokeSVGText =
configuration.getChild("strokesvgtext").getValueAsBoolean(true);
}
public void initialize() throws Exception {
/*
org.apache.fop.messaging.MessageHandler.setScreenLogger(getLogger());
if (userconfig != null) {
getLogger().info("Using user config: "+userconfig);
InputStream in =
org.apache.fop.tools.URLBuilder.buildURL(userconfig).openStream();
try {
new org.apache.fop.apps.Options(in);
} finally {
in.close();
}
}
if (this.baseDir != null) {
getLogger().info("Setting base dir: "+baseDir);
org.apache.fop.configuration.Configuration.put("baseDir", this.baseDir);
}
if (this.fontBaseDir != null) {
getLogger().info("Setting font base dir: "+fontBaseDir);
org.apache.fop.configuration.Configuration.put("fontBaseDir",
this.fontBaseDir);
}
String value = (this.strokeSVGText?"true":"false");
org.apache.fop.configuration.Configuration.put("strokeSVGText", value);
*/
}
public void process(InputStream in, Templates templates, OutputStream out)
throws org.apache.fop.apps.FOPException, java.io.IOException {
Fop fop = new Fop(Constants.RENDER_PDF);
fop.setOutputStream(out);
try {
Transformer transformer;
if (templates == null) {
TransformerFactory factory = TransformerFactory.newInstance();
transformer = factory.newTransformer();
} else {
transformer = templates.newTransformer();
}
Source src = new StreamSource(in);
Result res = new SAXResult(fop.getDefaultHandler());
transformer.transform(src, res);
} catch (TransformerException e) {
throw new FOPException(e);
}
}
}
1.1 xml-fop/test/java/org/apache/fop/threading/FOPTestbed.java
Index: FOPTestbed.java
===================================================================
/*
* Copyright 2004 The Apache Software Foundation.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
/* $Id: FOPTestbed.java,v 1.1 2004/09/07 20:57:47 jeremias Exp $ */
package org.apache.fop.threading;
import java.util.List;
import java.util.Iterator;
import java.io.File;
import java.io.InputStream;
import java.io.OutputStream;
import java.text.DecimalFormat;
import javax.xml.transform.Source;
import javax.xml.transform.Templates;
import javax.xml.transform.TransformerConfigurationException;
import javax.xml.transform.TransformerFactory;
import javax.xml.transform.stream.StreamSource;
import org.apache.avalon.framework.CascadingRuntimeException;
import org.apache.avalon.framework.activity.Executable;
import org.apache.avalon.framework.activity.Initializable;
import org.apache.avalon.framework.configuration.Configurable;
import org.apache.avalon.framework.configuration.Configuration;
import org.apache.avalon.framework.configuration.ConfigurationException;
import org.apache.avalon.framework.container.ContainerUtil;
import org.apache.avalon.framework.logger.AbstractLogEnabled;
import org.apache.commons.io.IOUtils;
public class FOPTestbed extends AbstractLogEnabled
implements Configurable, Initializable {
private int repeat;
private List tasks = new java.util.ArrayList();
private int threads;
private File outputDir;
private Configuration fopCfg;
private int counter = 0;
public void configure(Configuration configuration) throws ConfigurationException
{
this.threads = configuration.getChild("threads").getValueAsInteger(10);
this.outputDir = new File(configuration.getChild("output-dir").getValue());
Configuration tasks = configuration.getChild("tasks");
this.repeat = tasks.getAttributeAsInteger("repeat", 1);
Configuration[] entries = tasks.getChildren("task");
for (int i=0; i<entries.length; i++) {
this.tasks.add(new TaskDef(entries[i]));
}
this.fopCfg = configuration.getChild("foprocessor");
}
public void initialize() throws Exception {
}
public void doStressTest() {
getLogger().info("Starting stress test...");
long start = System.currentTimeMillis();
this.counter = 0;
//Initialize threads
List threadList = new java.util.LinkedList();
for (int ti = 0; ti < this.threads; ti++) {
Thread thread = new Thread(new TaskRunner());
threadList.add(thread);
}
//Start threads
Iterator i = threadList.iterator();
while (i.hasNext()) {
((Thread)i.next()).start();
}
//Wait for threads to end
while (threadList.size() > 0) {
Thread t = (Thread)threadList.get(0);
if (!t.isAlive()) {
threadList.remove(0);
continue;
}
try {
Thread.sleep(100);
} catch (InterruptedException ie) {
}
}
getLogger().info("Stress test duration: " + (System.currentTimeMillis() -
start) + "ms");
}
private class TaskRunner implements Runnable {
public void run() {
try {
for (int r = 0; r < repeat; r++) {
Iterator i = tasks.iterator();
while (i.hasNext()) {
TaskDef def = (TaskDef)i.next();
final Task task = new Task(def, counter++);
task.execute();
}
}
} catch (Exception e) {
getLogger().error("Thread ended with an exception", e);
}
}
}
public FOProcessor createFOProcessor() {
try {
Class clazz = Class.forName(this.fopCfg.getAttribute("class",
"org.apache.fop.threading.FOProcessorImpl"));
FOProcessor fop = (FOProcessor)clazz.newInstance();
ContainerUtil.enableLogging(fop, getLogger());
ContainerUtil.configure(fop, this.fopCfg);
ContainerUtil.initialize(fop);
return fop;
} catch (Exception e) {
throw new CascadingRuntimeException("Error creating FO Processor", e);
}
}
private class TaskDef {
private String fo;
private String xml;
private String xslt;
private Templates templates;
public TaskDef(String fo) {
this.fo = fo;
}
public TaskDef(Configuration cfg) throws ConfigurationException {
this.fo = cfg.getAttribute("fo", null);
if (this.fo == null) {
this.xml = cfg.getAttribute("xml");
this.xslt = cfg.getAttribute("xslt");
TransformerFactory factory = TransformerFactory.newInstance();
Source xsltSource = new StreamSource(new File(xslt));
try {
this.templates = factory.newTemplates(xsltSource);
} catch (TransformerConfigurationException tce) {
throw new ConfigurationException("Invalid XSLT", tce);
}
}
}
public String getFO() {
return this.fo;
}
public String getXML() {
return this.xml;
}
public Templates getTemplates() {
return this.templates;
}
public String toString() {
StringBuffer sb = new StringBuffer();
if (this.fo != null) {
sb.append("fo=");
sb.append(this.fo);
} else {
sb.append("xml=");
sb.append(this.xml);
sb.append(" xslt=");
sb.append(this.xslt);
}
return sb.toString();
}
}
private class Task implements Executable {
private TaskDef def;
private int num;
public Task(TaskDef def, int num) {
this.def = def;
this.num = num;
}
public void execute() throws Exception {
getLogger().info("Processing: "+def);
FOProcessor fop = (FOProcessor)createFOProcessor();
DecimalFormat df = new DecimalFormat("00000");
File outfile = new File(outputDir, df.format(num) + ".pdf");
OutputStream out = new java.io.FileOutputStream(outfile);
try {
InputStream in;
Templates templates;
if (def.getFO() != null) {
in = new java.io.FileInputStream(new File(def.getFO()));
templates = null;
} else {
in = new java.io.FileInputStream(new File(def.getXML()));
templates = def.getTemplates();
}
try {
fop.process(in, templates, out);
} finally {
IOUtils.closeQuietly(in);
}
} finally {
IOUtils.closeQuietly(out);
}
}
}
}
1.1 xml-fop/test/java/org/apache/fop/threading/sample.cfg.xml
Index: sample.cfg.xml
===================================================================
<?xml version="1.0" encoding="UTF-8"?>
<config>
<threads>2</threads>
<output-dir>C:/Dev/FOP/temp/out</output-dir>
<foprocessor>
<!--basedir>C:/Dev/FOP/temp</basedir>
<fontbasedir>C:/Dev/FOP/temp/fonts</fontbasedir>
<userconfig>C:/Dev/FOP/temp/userconfig.xml</userconfig>
<strokesvgtext>true</strokesvgtext-->
</foprocessor>
<tasks repeat="2">
<task fo="C:/Dev/FOP/temp/helloworld.fo"/>
<task xml="C:/Dev/FOP/temp/page-x-of-y.xml"
xslt="C:/Dev/FOP/temp/page-x-of-y.xsl"/>
</tasks>
</config>
1.1 xml-fop/test/java/org/apache/fop/threading/FOProcessor.java
Index: FOProcessor.java
===================================================================
/*
* Copyright 2004 The Apache Software Foundation.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
/* $Id: FOProcessor.java,v 1.1 2004/09/07 20:57:47 jeremias Exp $ */
package org.apache.fop.threading;
import java.io.InputStream;
import java.io.OutputStream;
import javax.xml.transform.Templates;
public interface FOProcessor {
String ROLE = FOProcessor.class.getName();
void process(InputStream in, Templates templates, OutputStream out)
throws org.apache.fop.apps.FOPException, java.io.IOException;
}
1.1 xml-fop/test/java/org/apache/fop/threading/Main.java
Index: Main.java
===================================================================
/*
* Copyright 2004 The Apache Software Foundation.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
/* $Id: Main.java,v 1.1 2004/09/07 20:57:47 jeremias Exp $ */
package org.apache.fop.threading;
import java.io.File;
import org.apache.avalon.framework.ExceptionUtil;
import org.apache.avalon.framework.configuration.Configuration;
import org.apache.avalon.framework.configuration.DefaultConfigurationBuilder;
import org.apache.avalon.framework.container.ContainerUtil;
import org.apache.avalon.framework.logger.ConsoleLogger;
public class Main {
public static void main(String[] args) {
try {
//Read configuration
File cfgFile = new File(args[0]);
DefaultConfigurationBuilder builder = new DefaultConfigurationBuilder();
Configuration cfg = builder.buildFromFile(cfgFile);
//Setup testbed
FOPTestbed testbed = new FOPTestbed();
ContainerUtil.enableLogging(testbed, new
ConsoleLogger(ConsoleLogger.LEVEL_INFO));
ContainerUtil.configure(testbed, cfg);
ContainerUtil.initialize(testbed);
//Start tests
testbed.doStressTest();
System.exit(0);
} catch (Exception e) {
System.err.println(ExceptionUtil.printStackTrace(e));
System.exit(-1);
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
