import com.sun.xml.internal.messaging.saaj.util.FastInfosetReflection; //导入依赖的package包/类
/**
 * return the Transfer Data of type DataFlavor from InputStream
 * @param df The DataFlavor.
 * @param ins The InputStream corresponding to the data.
 * @return The constructed Object.
 */
public Object getTransferData(DataFlavor flavor, DataSource dataSource)
    throws IOException
{
    if (flavor.getMimeType().startsWith("application/fastinfoset")) {
        try {
            if (flavor.getRepresentationClass().getName().equals(STR_SRC)) {
                return FastInfosetReflection.FastInfosetSource_new(
                    dataSource.getInputStream());
            }
        }
        catch (Exception e) {
            throw new IOException(e.getMessage());
        }
    }
    return null;
}
 

import com.sun.xml.internal.messaging.saaj.util.FastInfosetReflection; //导入依赖的package包/类
/**
 * construct an object from a byte stream
 * (similar semantically to previous method, we are deciding
 *  which one to support)
 */
public void writeTo(Object obj, String mimeType, OutputStream os)
    throws IOException
{
    if (!mimeType.equals("application/fastinfoset")) {
        throw new IOException("Invalid content type \"" + mimeType
            + "\" for FastInfosetDCH");
    }

    try {
        InputStream is = FastInfosetReflection.FastInfosetSource_getInputStream(
            (Source) obj);

        int n; byte[] buffer = new byte[4096];
        while ((n = is.read(buffer)) != -1) {
            os.write(buffer, 0, n);
        }
    }
    catch (Exception ex) {
        throw new IOException(
            "Error copying FI source to output stream " + ex.getMessage());
    }
}
 

import com.sun.xml.internal.messaging.saaj.util.FastInfosetReflection; //导入依赖的package包/类
/**
 * Serialize to FI if boolean parameter set.
 */
public void output(OutputStream out, boolean isFastInfoset)
    throws IOException
{
    if (!isFastInfoset) {
        output(out);
    }
    else {
        try {
            // Run transform and generate FI output from content
            Source source = getContent();
            Transformer transformer = EfficientStreamingTransformer.newTransformer();
                transformer.transform(getContent(),
                    FastInfosetReflection.FastInfosetResult_new(out));
        }
        catch (Exception ex) {
            throw new IOException(ex.getMessage());
        }
    }
}
 

import com.sun.xml.internal.messaging.saaj.util.FastInfosetReflection; //导入依赖的package包/类
/**
 * Return the Transfer Data of type DataFlavor from InputStream
 * @param flavor The DataFlavor.
 * @param dataSource DataSource.
 * @return The constructed Object.
 * @exception IOException in case of an I/O error
 */
@Override
public Object getTransferData(DataFlavor flavor, DataSource dataSource)
    throws IOException
{
    if (flavor.getMimeType().startsWith("application/fastinfoset")) {
        try {
            if (flavor.getRepresentationClass().getName().equals(STR_SRC)) {
                return FastInfosetReflection.FastInfosetSource_new(
                    dataSource.getInputStream());
            }
        }
        catch (Exception e) {
            throw new IOException(e.getMessage());
        }
    }
    return null;
}
 

import com.sun.xml.internal.messaging.saaj.util.FastInfosetReflection; //导入依赖的package包/类
/**
 * Construct an object from a byte stream
 * (similar semantically to previous method, we are deciding
 *  which one to support)
 */
@Override
public void writeTo(Object obj, String mimeType, OutputStream os)
    throws IOException
{
    if (!mimeType.equals("application/fastinfoset")) {
        throw new IOException("Invalid content type \"" + mimeType
            + "\" for FastInfosetDCH");
    }

    try {
        InputStream is = FastInfosetReflection.FastInfosetSource_getInputStream(
            (Source) obj);

        int n; byte[] buffer = new byte[4096];
        while ((n = is.read(buffer)) != -1) {
            os.write(buffer, 0, n);
        }
    }
    catch (Exception ex) {
        throw new IOException(
            "Error copying FI source to output stream " + ex.getMessage());
    }
}
 

import com.sun.xml.internal.messaging.saaj.util.FastInfosetReflection; //导入依赖的package包/类
/**
 * Serialize to FI if boolean parameter set.
 */
@Override
public void output(OutputStream out, boolean isFastInfoset)
    throws IOException
{
    if (!isFastInfoset) {
        output(out);
    }
    else {
        try {
            // Run transform and generate FI output from content
            Transformer transformer = EfficientStreamingTransformer.newTransformer();
                transformer.transform(getContent(),
                    FastInfosetReflection.FastInfosetResult_new(out));
        }
        catch (Exception ex) {
            throw new IOException(ex.getMessage());
        }
    }
}
 

import com.sun.xml.internal.messaging.saaj.util.FastInfosetReflection; //导入依赖的package包/类
/**
 * Serialize to FI if boolean parameter set.
 */
public void output(OutputStream out, boolean isFastInfoset)
    throws IOException
{
    if (!isFastInfoset) {
        output(out);
    }
    else {
        try {
            // Run transform and generate FI output from content
            Transformer transformer = EfficientStreamingTransformer.newTransformer();
                transformer.transform(getContent(),
                    FastInfosetReflection.FastInfosetResult_new(out));
        }
        catch (Exception ex) {
            throw new IOException(ex.getMessage());
        }
    }
}
 

import com.sun.xml.internal.messaging.saaj.util.FastInfosetReflection; //导入依赖的package包/类
/**
 * return the DataFlavors for this <code>DataContentHandler</code>
 * @return The DataFlavors.
 */
public DataFlavor[] getTransferDataFlavors() { // throws Exception;
    DataFlavor flavors[] = new DataFlavor[1];
    flavors[0] = new ActivationDataFlavor(
            FastInfosetReflection.getFastInfosetSource_class(),
            "application/fastinfoset", "Fast Infoset");
    return flavors;
}
 

import com.sun.xml.internal.messaging.saaj.util.FastInfosetReflection; //导入依赖的package包/类
public Object getContent(DataSource dataSource) throws IOException {
    try {
        return FastInfosetReflection.FastInfosetSource_new(
            dataSource.getInputStream());
    }
    catch (Exception e) {
        throw new IOException(e.getMessage());
    }
}
 

import com.sun.xml.internal.messaging.saaj.util.FastInfosetReflection; //导入依赖的package包/类
@Override
public Source getContent() throws SOAPException {
    if (source != null) {
        InputStream bis = null;
        if (source instanceof JAXMStreamSource) {
            StreamSource streamSource = (StreamSource)source;
            bis = streamSource.getInputStream();
        } else if (FastInfosetReflection.isFastInfosetSource(source)) {
            // FastInfosetSource inherits from SAXSource
            SAXSource saxSource = (SAXSource)source;
            bis = saxSource.getInputSource().getByteStream();
        }

        if (bis != null) {
            try {
                bis.reset();
            } catch (IOException e) {
                /* This exception will never be thrown.
                 *
                 * The setContent method will modify the source
                 * if StreamSource to JAXMStreamSource, that uses
                 * a ByteInputStream, and for a FastInfosetSource will
                 * replace the InputStream with a ByteInputStream.
                 */
            }
        }
        return source;
    }

    return ((Envelope) getEnvelope()).getContent();
}
 

import com.sun.xml.internal.messaging.saaj.util.FastInfosetReflection; //导入依赖的package包/类
/**
 * Return the DataFlavors for this <code>DataContentHandler</code>
 * @return The DataFlavors.
 */
@Override
public DataFlavor[] getTransferDataFlavors() { // throws Exception;
    DataFlavor flavors[] = new DataFlavor[1];
    flavors[0] = new ActivationDataFlavor(
            FastInfosetReflection.getFastInfosetSource_class(),
            "application/fastinfoset", "Fast Infoset");
    return flavors;
}
 

import com.sun.xml.internal.messaging.saaj.util.FastInfosetReflection; //导入依赖的package包/类
@Override
public Object getContent(DataSource dataSource) throws IOException {
    try {
        return FastInfosetReflection.FastInfosetSource_new(
            dataSource.getInputStream());
    }
    catch (Exception e) {
        throw new IOException(e.getMessage());
    }
}
 

import com.sun.xml.internal.messaging.saaj.util.FastInfosetReflection; //导入依赖的package包/类
public InputStream getContentAsStream() throws IOException {
    if (source != null) {
        InputStream is = null;

        // Allow message to be transcode if so requested
        if (source instanceof StreamSource && !isFastInfoset()) {
            is = ((StreamSource) source).getInputStream();
        }
        else if (FastInfosetReflection.isFastInfosetSource(source) &&
            isFastInfoset())
        {
            try {
                // InputStream is = source.getInputStream()
                is = FastInfosetReflection.FastInfosetSource_getInputStream(source);
            }
            catch (Exception e) {
                throw new IOException(e.toString());
            }
        }

        if (is != null) {
            if (lazyContentLength) {
                return is;
            }
            if (!(is instanceof ByteInputStream)) {
                log.severe("SAAJ0546.soap.stream.incorrect.type");
                throw new IOException("Internal error: stream not of the right type");
            }
            return (ByteInputStream) is;
        }
        // need to do something here for reader...
        // for now we'll see if we can fallback...
    }

    ByteOutputStream b = new ByteOutputStream();

    Envelope env = null;

    try {
        env = (Envelope) getEnvelope();
        env.output(b, isFastInfoset());
    }
    catch (SOAPException soapException) {
        log.severe("SAAJ0547.soap.cannot.externalize");
        throw new SOAPIOException(
        "SOAP exception while trying to externalize: ",
        soapException);
    }

    return b.newInputStream();
}