IncrementalSAXSource_Filter implements IncrementalSAXSource, using a standard SAX2 event source as its input and parcelling out those events gradually in reponse to deliverMoreNodes() requests. Output from the filter will be passed along to a SAX handler registered as our listener, but those callbacks will pass through a counting stage which periodically yields control back to the controller coroutine.
%REVIEW%: This filter is not currenly intended to be reusable for parsing additional streams/documents. We may want to consider making it resettable at some point in the future. But it's a small object, so that'd be mostly a convenience issue; the cost of allocating each time is trivial compared to the cost of processing any nontrival stream.
For a brief usage example, see the unit-test main() method.
This is a simplification of the old CoroutineSAXParser, focusing specifically on filtering. The resulting controller protocol is _far_ simpler and less error-prone; the only controller operation is deliverMoreNodes(), and the only requirement is that deliverMoreNodes(false) be called if you want to discard the rest of the stream and the previous deliverMoreNodes() didn't return false. This class is final and package private for security reasons. Please see CR 6537912 for further details.
| Modifier and Type | Class and Description |
|---|---|
| pack-priv class | IncrementalSAXSource_Filter.
Used to quickly terminate parse when running under a startParse() thread. |
| Modifier and Type | Field and Description |
|---|---|
| private ContentHandler | |
| private DTDHandler | |
| private ErrorHandler | |
| private LexicalHandler | |
| pack-priv boolean | |
| private int | |
| private int | |
| private CoroutineManager | |
| private boolean | |
| private int | |
| private int | |
| private XMLReader | |
| private InputSource |
| Access | Constructor and Description |
|---|---|
| public | |
| public | IncrementalSAXSource_Filter(CoroutineManager co, int controllerCoroutineID)
Create a IncrementalSAXSource_Filter which is not yet bound to a specific SAX event source. |
| Modifier and Type | Method and Description |
|---|---|
| public void | characters(char[] ch, int start, int length)
Implements org. Receive notification of character data. |
| private void | |
| private void | |
| public void | comment(char[] ch, int start, int length)
Implements org. Report an XML comment anywhere in the document. |
| protected void | count_and_yield(boolean
Should always be true unless this is being called
at the end of endDocument() handling. moreExpected)In the SAX delegation code, I've inlined the count-down in the hope of encouraging compilers to deliver better performance. |
| public static IncrementalSAXSource | |
| public Object | Returns: Boolean.TRUE if there may be more events available by invoking deliverMoreNodes() again. Boolean.FALSE if parsing has run to completion (or been terminated by deliverMoreNodes(false). Or an exception object if something malfunctioned. %REVIEW% We _could_ actually throw the exception, but that would require runinng deliverMoreNodes() in a try/catch... and for many applications, exception will be simply be treated as "not TRUE" in any case.If true, tells the incremental filter to generate
another chunk of output. If false, tells the filter that we're
satisfied and it can terminate parsing of this document. parsemore)Implements com. deliverMoreNodes() is a simple API which tells the coroutine parser that we need more nodes. |
| public void | |
| public void | endDocument()
Implements org. Receive notification of the end of a document. |
| public void | |
| public void | endElement(String namespaceURI, String localName, String qName)
Implements org. Receive notification of the end of an element. |
| public void | endEntity(String name)
Implements org. Report the end of an entity. |
| public void | endPrefixMapping(String prefix)
Implements org. End the scope of a prefix-URI mapping. |
| public void | error(SAXParseException exception)
Implements org. Receive notification of a recoverable error. |
| public void | fatalError(SAXParseException exception)
Implements org. Receive notification of a non-recoverable, fatal error. |
| public int | |
| public CoroutineManager | |
| public int | |
| public void | ignorableWhitespace(char[] ch, int start, int length)
Implements org. Receive notification of ignorable whitespace in element content. |
| public void | |
| public void | notationDecl(String a, String b, String c)
Implements org. Receive notification of a notation declaration event. |
| public void | processingInstruction(String target, String data)
Implements org. Receive notification of a processing instruction. |
| public void | |
| public void | setContentHandler(ContentHandler handler)
Implements com. Register a SAX-style content handler for us to output to |
| public void | setDocumentLocator(Locator locator)
Implements org. Receive an object for locating the origin of SAX document events. |
| public void | setDTDHandler(DTDHandler handler)
Implements com. Register a SAX-style DTD handler for us to output to |
| public void | |
| public void | setLexicalHandler(LexicalHandler handler)
Implements com. Register a SAX-style lexical handler for us to output to |
| public void | |
| public void | |
| public void | skippedEntity(String name)
Implements org. Receive notification of a skipped entity. |
| public void | startCDATA()
Implements org. Report the start of a CDATA section. |
| public void | startDocument()
Implements org. Receive notification of the beginning of a document. |
| public void | startDTD(String name, String publicId, String systemId)
Implements org. Report the start of DTD declarations, if any. |
| public void | startElement(String namespaceURI, String localName, String qName, Attributes atts)
Implements org. Receive notification of the beginning of an element. |
| public void | startEntity(String name)
Implements org. Report the beginning of some internal and external XML entities. |
| public void | startParse(InputSource source)
Implements com. Launch a thread that will run an XMLReader's parse() operation within a thread, feeding events to this IncrementalSAXSource_Filter. |
| public void | startPrefixMapping(String prefix, String uri)
Implements org. Begin the scope of a prefix-URI Namespace mapping. |
| public void | unparsedEntityDecl(String a, String b, String c, String d)
Implements org. Receive notification of an unparsed entity declaration event. |
| public void | warning(SAXParseException exception)
Implements org. Receive notification of a warning. |
| clientContentHandler | back to summary |
|---|---|
| private ContentHandler clientContentHandler | |
| clientDTDHandler | back to summary |
|---|---|
| private DTDHandler clientDTDHandler | |
| clientErrorHandler | back to summary |
|---|---|
| private ErrorHandler clientErrorHandler | |
| clientLexicalHandler | back to summary |
|---|---|
| private LexicalHandler clientLexicalHandler | |
| DEBUG | back to summary |
|---|---|
| pack-priv boolean DEBUG | |
| eventcounter | back to summary |
|---|---|
| private int eventcounter | |
| fControllerCoroutineID | back to summary |
|---|---|
| private int fControllerCoroutineID | |
| fCoroutineManager | back to summary |
|---|---|
| private CoroutineManager fCoroutineManager | |
| fNoMoreEvents | back to summary |
|---|---|
| private boolean fNoMoreEvents | |
| frequency | back to summary |
|---|---|
| private int frequency | |
| fSourceCoroutineID | back to summary |
|---|---|
| private int fSourceCoroutineID | |
| fXMLReader | back to summary |
|---|---|
| private XMLReader fXMLReader | |
| fXMLReaderInputSource | back to summary |
|---|---|
| private InputSource fXMLReaderInputSource | |
| IncrementalSAXSource_Filter | back to summary |
|---|---|
| public IncrementalSAXSource_Filter() | |
| IncrementalSAXSource_Filter | back to summary |
|---|---|
| public IncrementalSAXSource_Filter(CoroutineManager co, int controllerCoroutineID) Create a IncrementalSAXSource_Filter which is not yet bound to a specific SAX event source. | |
| characters | back to summary |
|---|---|
| public void characters(char[] ch, int start, int length) throws SAXException Implements org. Doc from org. Receive notification of character data. The Parser will call this method to report each chunk of character data. SAX parsers may return all contiguous character data in a single chunk, or they may split it into several chunks; however, all of the characters in any single event must come from the same external entity so that the Locator provides useful information. The application must not attempt to read from the array outside of the specified range. Individual characters may consist of more than one Java
Your code should not assume that algorithms using
Note that some parsers will report whitespace in element
content using the
| |
| co_entry_pause | back to summary |
|---|---|
| private void co_entry_pause() throws SAXException co_entry_pause is called in startDocument() before anything else happens. It causes the filter to wait for a "go ahead" request from the controller before delivering any events. Note that the very first thing the controller tells us may be "I don't need events after all"! | |
| co_yield | back to summary |
|---|---|
| private void co_yield(boolean moreRemains) throws SAXException Co_Yield handles coroutine interactions while a parse is in progress. When moreRemains==true, we are pausing after delivering events, to ask if more are needed. We will resume the controller thread with co_resume(Boolean.TRUE, ...) When control is passed back it may indicate Boolean.TRUE indication to continue delivering events Boolean.FALSE indication to discontinue events and shut down. When moreRemains==false, we shut down immediately without asking the controller's permission. Normally this means end of document has been reached. Shutting down a IncrementalSAXSource_Filter requires terminating the incoming SAX event stream. If we are in control of that stream (if it came from an XMLReader passed to our startReader() method), we can do so very quickly by throwing a reserved exception to it. If the stream is coming from another source, we can't do that because its caller may not be prepared for this "normal abnormal exit", and instead we put ourselves in a "spin" mode where events are discarded. | |
| comment | back to summary |
|---|---|
| public void comment(char[] ch, int start, int length) throws SAXException Implements org. Doc from org. Report an XML comment anywhere in the document. This callback will be used for comments inside or outside the document element, including comments in the external DTD subset (if read). Comments in the DTD must be properly nested inside start/endDTD and start/endEntity events (if used).
| |
| count_and_yield | back to summary |
|---|---|
| protected void count_and_yield(boolean moreExpected) throws SAXException In the SAX delegation code, I've inlined the count-down in the hope of encouraging compilers to deliver better performance. However, if we subclass (eg to directly connect the output to a DTM builder), that would require calling super in order to run that logic... which seems inelegant. Hence this routine for the convenience of subclasses: every [frequency] invocations, issue a co_yield.
| |
| createIncrementalSAXSource | back to summary |
|---|---|
| public static IncrementalSAXSource createIncrementalSAXSource(CoroutineManager co, int controllerCoroutineID) | |
| deliverMoreNodes | back to summary |
|---|---|
| public Object deliverMoreNodes(boolean parsemore) Implements com. deliverMoreNodes() is a simple API which tells the coroutine parser that we need more nodes. This is intended to be called from one of our partner routines, and serves to encapsulate the details of how incremental parsing has been achieved.
| |
| endCDATA | back to summary |
|---|---|
| public void endCDATA() throws SAXException Implements org. Doc from org. Report the end of a CDATA section.
| |
| endDocument | back to summary |
|---|---|
| public void endDocument() throws SAXException Implements org. Doc from org. Receive notification of the end of a document. This method is invoked by the parser to signal it has reached the end of the document after successfully completing the parsing process. After the event, the parser will return the control to the application.
| |
| endDTD | back to summary |
|---|---|
| public void endDTD() throws SAXException Implements org. Doc from org. Report the end of DTD declarations. This method is intended to report the end of the DOCTYPE declaration; if the document has no DOCTYPE declaration, this method will not be invoked.
| |
| endElement | back to summary |
|---|---|
| public void endElement(String namespaceURI, String localName, String qName) throws SAXException Implements org. Doc from org. Receive notification of the end of an element. The SAX parser will invoke this method at the end of every
element in the XML document; there will be a corresponding
For information on the names, see startElement.
| |
| endEntity | back to summary |
|---|---|
| public void endEntity(String name) throws SAXException Implements org. Doc from org. Report the end of an entity.
| |
| endPrefixMapping | back to summary |
|---|---|
| public void endPrefixMapping(String prefix) throws SAXException Implements org. Doc from org. End the scope of a prefix-URI mapping. See
| |
| error | back to summary |
|---|---|
| public void error(SAXParseException exception) throws SAXException Implements org. Doc from org. Receive notification of a recoverable error. This corresponds to the definition of "error" in section 1.2 of the W3C XML 1.0 Recommendation. For example, a validating parser would use this callback to report the violation of a validity constraint. The default behaviour is to take no action. The SAX parser must continue to provide normal parsing events after invoking this method: it should still be possible for the application to process the document through to the end. If the application cannot do so, then the parser should report a fatal error even if the XML recommendation does not require it to do so. Filters may use this method to report other, non-XML errors as well.
| |
| fatalError | back to summary |
|---|---|
| public void fatalError(SAXParseException exception) throws SAXException Implements org. Doc from org. Receive notification of a non-recoverable, fatal error. As defined in section 1.2 of the W3C XML 1.0 Recommendation, fatal errors are those that would make it impossible for a parser to continue normal processing. These include violation of a well-formedness constraint, invalid encoding, and forbidden structural errors as described in the W3C XML 1.0 Recommendation.
| |
| getControllerCoroutineID | back to summary |
|---|---|
| public int getControllerCoroutineID() | |
| getCoroutineManager | back to summary |
|---|---|
public CoroutineManager getCoroutineManager()
| |
| getSourceCoroutineID | back to summary |
|---|---|
| public int getSourceCoroutineID() | |
| ignorableWhitespace | back to summary |
|---|---|
| public void ignorableWhitespace(char[] ch, int start, int length) throws SAXException Implements org. Doc from org. Receive notification of ignorable whitespace in element content. Validating Parsers must use this method to report each chunk of whitespace in element content (see the W3C XML 1.0 recommendation, section 2.10): non-validating parsers may also use this method if they are capable of parsing and using content models. SAX parsers may return all contiguous whitespace in a single chunk, or they may split it into several chunks; however, all of the characters in any single event must come from the same external entity, so that the Locator provides useful information. The application must not attempt to read from the array outside of the specified range.
| |
| init | back to summary |
|---|---|
| public void init(CoroutineManager co, int controllerCoroutineID, int sourceCoroutineID) | |
| notationDecl | back to summary |
|---|---|
| public void notationDecl(String a, String b, String c) throws SAXException Implements org. Doc from org. Receive notification of a notation declaration event. It is up to the application to record the notation for later reference, if necessary; notations may appear as attribute values and in unparsed entity declarations, and are sometime used with processing instruction target names. At least one of publicId and systemId must be non-null. If a system identifier is present, and it is a URL, the SAX parser must resolve it fully before passing it to the application through this event. There is no guarantee that the notation declaration will be reported before any unparsed entities that use it.
| |
| processingInstruction | back to summary |
|---|---|
| public void processingInstruction(String target, String data) throws SAXException Implements org. Doc from org. Receive notification of a processing instruction. The Parser will invoke this method once for each processing instruction found: note that processing instructions may occur before or after the main document element. A SAX parser must never report an XML declaration (XML 1.0, section 2.8) or a text declaration (XML 1.0, section 4.3.1) using this method. Like
| |
| run | back to summary |
|---|---|
| public void run() Implements java. Doc from java. Runs this operation. | |
| setContentHandler | back to summary |
|---|---|
| public void setContentHandler(ContentHandler handler) Implements com. Doc from com. Register a SAX-style content handler for us to output to | |
| setDocumentLocator | back to summary |
|---|---|
| public void setDocumentLocator(Locator locator) Implements org. Doc from org. Receive an object for locating the origin of SAX document events. SAX parsers are strongly encouraged (though not absolutely required) to supply a locator: if it does so, it must supply the locator to the application by invoking this method before invoking any of the other methods in the ContentHandler interface. The locator allows the application to determine the end position of any document-related event, even if the parser is not reporting an error. Typically, the application will use this information for reporting its own errors (such as character content that does not match an application's business rules). The information returned by the locator is probably not sufficient for use with a search engine. Note that the locator will return correct information only
during the invocation SAX event callbacks after
| |
| setDTDHandler | back to summary |
|---|---|
| public void setDTDHandler(DTDHandler handler) Implements com. Doc from com. Register a SAX-style DTD handler for us to output to | |
| setErrHandler | back to summary |
|---|---|
| public void setErrHandler(ErrorHandler handler) | |
| setLexicalHandler | back to summary |
|---|---|
| public void setLexicalHandler(LexicalHandler handler) Implements com. Doc from com. Register a SAX-style lexical handler for us to output to | |
| setReturnFrequency | back to summary |
|---|---|
| public void setReturnFrequency(int events) | |
| setXMLReader | back to summary |
|---|---|
| public void setXMLReader(XMLReader eventsource) Bind our input streams to an XMLReader. Just a convenience routine; obviously you can explicitly register this as a listener with the same effect. | |
| skippedEntity | back to summary |
|---|---|
| public void skippedEntity(String name) throws SAXException Implements org. Doc from org. Receive notification of a skipped entity. This is not called for entity references within markup constructs such as element start tags or markup declarations. (The XML recommendation requires reporting skipped external entities. SAX also reports internal entity expansion/non-expansion, except within markup constructs.) The Parser will invoke this method each time the entity is
skipped. Non-validating processors may skip entities if they
have not seen the declarations (because, for example, the
entity was declared in an external DTD subset). All processors
may skip external entities, depending on the values of the
| |
| startCDATA | back to summary |
|---|---|
| public void startCDATA() throws SAXException Implements org. Doc from org. Report the start of a CDATA section. The contents of the CDATA section will be reported through
the regular
| |
| startDocument | back to summary |
|---|---|
| public void startDocument() throws SAXException Implements org. Doc from org. Receive notification of the beginning of a document. The SAX parser will invoke this method only once, before any
other event callbacks (except for
| |
| startDTD | back to summary |
|---|---|
| public void startDTD(String name, String publicId, String systemId) throws SAXException Implements org. Doc from org. Report the start of DTD declarations, if any. This method is intended to report the beginning of the DOCTYPE declaration; if the document has no DOCTYPE declaration, this method will not be invoked. All declarations reported through
Note that the start/endDTD events will appear within
the start/endDocument events from ContentHandler and
before the first
| |
| startElement | back to summary |
|---|---|
| public void startElement(String namespaceURI, String localName, String qName, Attributes atts) throws SAXException Implements org. Doc from org. Receive notification of the beginning of an element. The Parser will invoke this method at the beginning of every
element in the XML document; there will be a corresponding
This event allows up to three name components for each element:
Any or all of these may be provided, depending on the values of the http://xml.org/sax/features/namespaces and the http://xml.org/sax/features/namespace-prefixes properties:
Note that the attribute list provided will contain only
attributes with explicit values (specified or defaulted):
#IMPLIED attributes will be omitted. The attribute list
will contain attributes used for Namespace declarations
(xmlns* attributes) only if the
Like
| |
| startEntity | back to summary |
|---|---|
| public void startEntity(String name) throws SAXException Implements org. Doc from org. Report the beginning of some internal and external XML entities. The reporting of parameter entities (including
the external DTD subset) is optional, and SAX2 drivers that
report LexicalHandler events may not implement it; you can use the
General entities are reported with their regular names, parameter entities have '%' prepended to their names, and the external DTD subset has the pseudo-entity name "[dtd]". When a SAX2 driver is providing these events, all other
events must be properly nested within start/end entity
events. There is no additional requirement that events from
Note that skipped entities will be reported through the
Because of the streaming event model that SAX uses, some entity boundaries cannot be reported under any circumstances:
These will be silently expanded, with no indication of where the original entity boundaries were. Note also that the boundaries of character references (which are not really entities anyway) are not reported. All start/endEntity events must be properly nested.
| |
| startParse | back to summary |
|---|---|
| public void startParse(InputSource source) throws SAXException Implements com. Launch a thread that will run an XMLReader's parse() operation within a thread, feeding events to this IncrementalSAXSource_Filter. Mostly a convenience routine, but has the advantage that -- since we invoked parse() -- we can halt parsing quickly via a StopException rather than waiting for the SAX stream to end by itself.
| |
| startPrefixMapping | back to summary |
|---|---|
| public void startPrefixMapping(String prefix, String uri) throws SAXException Implements org. Doc from org. Begin the scope of a prefix-URI Namespace mapping. The information from this event is not necessary for
normal Namespace processing: the SAX XML reader will
automatically replace prefixes for element and attribute
names when the There are cases, however, when applications need to use prefixes in character data or in attribute values, where they cannot safely be expanded automatically; the start/endPrefixMapping event supplies the information to the application to expand prefixes in those contexts itself, if necessary. Note that start/endPrefixMapping events are not
guaranteed to be properly nested relative to each other:
all startPrefixMapping events will occur immediately before the
corresponding There should never be start/endPrefixMapping events for the "xml" prefix, since it is predeclared and immutable.
| |
| unparsedEntityDecl | back to summary |
|---|---|
| public void unparsedEntityDecl(String a, String b, String c, String d) throws SAXException Implements org. Doc from org. Receive notification of an unparsed entity declaration event. Note that the notation name corresponds to a notation
reported by the If the system identifier is a URL, the parser must resolve it fully before passing it to the application.
| |
| warning | back to summary |
|---|---|
| public void warning(SAXParseException exception) throws SAXException Implements org. Doc from org. Receive notification of a warning. SAX parsers will use this method to report conditions that are not errors or fatal errors as defined by the XML recommendation. The default behaviour is to take no action. The SAX parser must continue to provide normal parsing events after invoking this method: it should still be possible for the application to process the document through to the end. Filters may use this method to report other, non-XML warnings as well.
| |
| Modifier and Type | Field and Description |
|---|---|
| pack-priv static final long |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| serialVersionUID | back to summary |
|---|---|
| pack-priv static final long serialVersionUID | |
| StopException | back to summary |
|---|---|
| pack-priv StopException() | |