import com.thoughtworks.xstream.io.xml.Xpp3Driver; //导入依赖的package包/类
/**
 * Setup the data to deserialize.
 *
 * @param params the parameters of the benchmark
 * @since 1.4.9
 */
@Setup(Level.Trial)
public void setUp(final BenchmarkParams params) {
    xstream = new XStream(new Xpp3Driver());
    xstream.addPermission(NoTypePermission.NONE);
    xstream.addPermission(ArrayTypePermission.ARRAYS);
    xstream.addPermission(PrimitiveTypePermission.PRIMITIVES);
    xstream.allowTypes(Model.class, String.class, BigInteger.class, UUID.class);
    final String benchmark = params.getBenchmark();
    switch (benchmark.substring(ConverterTypeBenchmark.class.getName().length() + 1)) {
    case "reflection":
        xstream.registerConverter(new ReflectionConverter(xstream.getMapper(), xstream.getReflectionProvider(),
            Model.class));
        break;
    case "javaBean":
        xstream.registerConverter(new JavaBeanConverter(xstream.getMapper(), Model.class));
        break;
    case "custom":
        xstream.registerConverter(new ModelConverter());
        break;
    default:
        throw new IllegalStateException("Unsupported benchmark type: " + benchmark);
    }
    xml = xstream.toXML(array);
    // System.out.println(xstream.toXML(array[0]));
}
 

import com.thoughtworks.xstream.io.xml.Xpp3Driver; //导入依赖的package包/类
public DriverEndToEndTestSuite() {
    super(DriverEndToEndTestSuite.class.getName());
    addDriverTest(new BEAStaxDriver());
    addDriverTest(new BinaryStreamDriver());
    addDriverTest(new Dom4JDriver());
    addDriverTest(new DomDriver());
    addDriverTest(new JDomDriver());
    addDriverTest(new JDom2Driver());
    addDriverTest(new KXml2DomDriver());
    addDriverTest(new KXml2Driver());
    addDriverTest(new StaxDriver());
    addDriverTest(new StandardStaxDriver());
    addDriverTest(new WstxDriver());
    addDriverTest(new XomDriver());
    addDriverTest(new Xpp3DomDriver());
    addDriverTest(new Xpp3Driver());
    addDriverTest(new XppDomDriver());
    addDriverTest(new XppDriver());
    addDriverTest(new JettisonMappedXmlDriver());
}
 

import com.thoughtworks.xstream.io.xml.Xpp3Driver; //导入依赖的package包/类
public static ArrayList<NSAdvice> ParseAdvice(String req) {
    try
    {
        //use xstream because i'm not gonna write an entire parser for the massive amount of tags reisadvies provides.

        XStream stream = new XStream(new Xpp3Driver());
        stream.alias("ReisMogelijkheden", NSAdvice[].class);
        stream.alias("ReisMogelijkheid", NSAdvice.class);
        stream.alias("ReisDeel", NSReisdeel.class);
        stream.alias("ReisStop", NSReisStop.class);
        stream.alias("Melding", NSMelding.class);
        stream.alias("Naam", String.class);
        stream.alias("Tijd", Date.class);
        stream.alias("Spoor", Integer.class);
        stream.registerConverter(new NSDateConverter());
        return new ArrayList<NSAdvice>(Arrays.asList((NSAdvice[])stream.fromXML(req)));
    }
    catch(Exception z) {
        NSTask.LastExceptionMessage = z.getMessage();
        NSAPI.Error(z);
    }

    return null;
}
 

import com.thoughtworks.xstream.io.xml.Xpp3Driver; //导入依赖的package包/类
/**
 * Setup the data to deserialize.
 *
 * @param params the parameters of the benchmark
 * @since 1.4.9
 */
@Setup(Level.Trial)
public void setUp(final BenchmarkParams params) {
    final String benchmark = params.getBenchmark();
    final SingleValueConverter converter;
    switch (benchmark.substring(StringConverterBenchmark.class.getName().length() + 1)) {
    case "nonCaching":
        converter = new NonCachingStringConverter();
        break;
    case "intern":
        converter = new InternStringConverter();
        break;
    case "unlimitedSynchronizedWeakCache":
        converter = new SynchronizedWeakCacheStringConverter(Integer.MAX_VALUE);
        break;
    case "limitedSynchronizedWeakCache":
        converter = new SynchronizedWeakCacheStringConverter(UUID.randomUUID().toString().length());
        break;
    case "unlimitedConcurrentMap":
        converter = new SynchronizedWeakCacheStringConverter(Integer.MAX_VALUE);
        break;
    case "limitedConcurrentMap":
        converter = new SynchronizedWeakCacheStringConverter(UUID.randomUUID().toString().length());
        break;
    default:
        throw new IllegalStateException("Unsupported benchmark type: " + benchmark);
    }
    xstream = new XStream(new Xpp3Driver());
    xstream.addPermission(NoTypePermission.NONE);
    xstream.addPermission(ArrayTypePermission.ARRAYS);
    xstream.allowTypes(String.class);
    xstream.registerConverter(converter);
}
 

import com.thoughtworks.xstream.io.xml.Xpp3Driver; //导入依赖的package包/类
protected HierarchicalStreamReader createReader(String xml) throws Exception {
    // Transmogrify XML input into binary format.
    HierarchicalStreamReader xmlReader = 
            new Xpp3Driver().createReader(new StringReader(xml));

    ByteArrayOutputStream buffer = new ByteArrayOutputStream();
    HierarchicalStreamWriter binaryWriter = new BinaryStreamWriter(buffer);
    copier.copy(xmlReader, binaryWriter);

    return new BinaryStreamReader(new ByteArrayInputStream(buffer.toByteArray()));
}
 

import com.thoughtworks.xstream.io.xml.Xpp3Driver; //导入依赖的package包/类
protected HierarchicalStreamReader createReader(String xml) throws Exception {
    HierarchicalStreamReader sourceReader = 
            new Xpp3Driver().createReader(new StringReader(xml));

    StringWriter buffer = new StringWriter();
    HierarchicalStreamWriter destinationWriter = new CompactWriter(buffer);

    copier.copy(sourceReader, destinationWriter);

    return new XppReader(new StringReader(buffer.toString()), XppFactory.createDefaultParser());
}
 

import com.thoughtworks.xstream.io.xml.Xpp3Driver; //导入依赖的package包/类
/**
 * @return Returns given Result as XML string, and shows time based on showTime
 */
public static String resultToXML( Result result ) {
	//Use custom coder to disable underscore escaping so run_type is properly printed
	final XStream stream = new XStream( new Xpp3Driver( new XmlFriendlyNameCoder( "_-", "_" ) ) );
	if ( !result.getShowTime() ) {
		stream.omitField( Result.class, "ms" );
	}
	stream.processAnnotations( Result.class );
	return "<?xml version=\"1.0\" encoding=\"utf-8\"?>\n" + stream.toXML( result );
}
 

import com.thoughtworks.xstream.io.xml.Xpp3Driver; //导入依赖的package包/类
/**
 * @return Returns given Results as XML string, and shows time based on showTime
 */
public static String resultsToXML( Results results ) {
	//Use custom coder to disable underscore escaping so run_type is properly printed
	final XStream stream = new XStream(new Xpp3Driver( new XmlFriendlyNameCoder( "_-", "_" ) ) );
	if ( !results.getShowTime() ) {
		stream.omitField( Run.class, "ms" );
		stream.omitField( Result.class, "ms" );
	}
	stream.processAnnotations( Results.class );
	return "<?xml version=\"1.0\" encoding=\"utf-8\"?>\n" + stream.toXML( results );
}
 

import com.thoughtworks.xstream.io.xml.Xpp3Driver; //导入依赖的package包/类
/**
 * @return the given XML string as an object of the given class. note that this method disables
 * underscore as an escape character if the class is Results so the attribute "run_type" is printed correctly.
 */
public static Object xmlToClass( String xml, Class convertClass ) {
	final XStream stream;
	if ( convertClass.equals( Results.class )) {
		//Use custom coder to disable underscore escaping so run_type is properly printed
		stream = new XStream( new Xpp3Driver( new XmlFriendlyNameCoder( "_-", "_" ) ) );
	} else {
		stream = new XStream();
	}
	stream.processAnnotations( convertClass );
	return stream.fromXML( xml );
}
 

import com.thoughtworks.xstream.io.xml.Xpp3Driver; //导入依赖的package包/类
public XStreamXpp3() {
    super(new Xpp3Driver(), "XML with Xpp3 parser");
}