![]() |
JODA
0.13.1 (59b41972)
JSON On-Demand Analysis
|
#include <DefaultContainerScheduler.h>
Public Types | |
| typedef short | ContainerIdentifier |
Public Member Functions | |
| DefaultContainerScheduler (JsonContainerQueue::queue_t *queue, size_t contSize=0) | |
| ContainerIdentifier | getContainerForDoc (const RJDocument &doc) |
| ContainerIdentifier | getContainerForDoc (std::string &raw) |
| ContainerIdentifier | getContainerForDoc (rapidjson::IStreamWrapper &stream) |
| void | scheduleDocument (ContainerIdentifier id, std::unique_ptr< RJDocument > &&doc, std::unique_ptr< IOrigin > &&origin, size_t size) |
| std::unique_ptr< RJDocument > | getNewDoc (ContainerIdentifier id) |
| void | finalize () |
| virtual | ~DefaultContainerScheduler ()=default |
| void | scheduleDocument (ContainerIdentifier, std::unique_ptr< RJDocument > &&doc, std::unique_ptr< IOrigin > &&origin, size_t size) |
| void | scheduleDocument (ContainerIdentifier, std::unique_ptr< RJDocument > &&doc, std::unique_ptr< IOrigin > &&origin, size_t size) |
| void | finalize () |
| void | finalize () |
A document scheduler scheduling the documents into the same container
| meta | If the Container should be meta finalized or really finalized |
| typedef short joda::docparsing::DefaultContainerScheduler< meta >::ContainerIdentifier |
| joda::docparsing::DefaultContainerScheduler< meta >::DefaultContainerScheduler | ( | JsonContainerQueue::queue_t * | queue, |
| size_t | contSize = 0 |
||
| ) |
Constructs a scheduler for use within the parsers.
| queue | The container queue to use to pass finalized containers through. |
| contSize | The size of newly constructed containers. |
|
virtualdefault |
| void joda::docparsing::DefaultContainerScheduler< true >::finalize | ( | ) |
| void joda::docparsing::DefaultContainerScheduler< false >::finalize | ( | ) |
| void joda::docparsing::DefaultContainerScheduler< meta >::finalize | ( | ) |
Finalizes the Scheduler. Has to be called before deconstructing it.
| joda::docparsing::DefaultContainerScheduler< meta >::ContainerIdentifier joda::docparsing::DefaultContainerScheduler< meta >::getContainerForDoc | ( | const RJDocument & | doc | ) |
Always returns 0, as this scheduler does not require an id
| doc | The document |
| joda::docparsing::DefaultContainerScheduler< meta >::ContainerIdentifier joda::docparsing::DefaultContainerScheduler< meta >::getContainerForDoc | ( | rapidjson::IStreamWrapper & | stream | ) |
Always returns 0, as this scheduler does not require an id
| stream | The stream to check against |
| joda::docparsing::DefaultContainerScheduler< meta >::ContainerIdentifier joda::docparsing::DefaultContainerScheduler< meta >::getContainerForDoc | ( | std::string & | raw | ) |
Always returns 0, as this scheduler does not require an id
| raw | The document in string representation (before parsing) |
| std::unique_ptr< RJDocument > joda::docparsing::DefaultContainerScheduler< meta >::getNewDoc | ( | ContainerIdentifier | id | ) |
Returns a document initialized with the allocator of the container represented by id
| id | The id representing the container |
| void joda::docparsing::DefaultContainerScheduler< meta >::scheduleDocument | ( | ContainerIdentifier | id, |
| std::unique_ptr< RJDocument > && | doc, | ||
| std::unique_ptr< IOrigin > && | origin, | ||
| size_t | size | ||
| ) |
Schedules the document into the container given by id.
| id | The id of the container |
| doc | The document to schedule |
| origin | The origin of the document |
| size | The size of the document (bytes) |
| void joda::docparsing::DefaultContainerScheduler< true >::scheduleDocument | ( | ContainerIdentifier | , |
| std::unique_ptr< RJDocument > && | doc, | ||
| std::unique_ptr< IOrigin > && | origin, | ||
| size_t | size | ||
| ) |
| void joda::docparsing::DefaultContainerScheduler< false >::scheduleDocument | ( | ContainerIdentifier | , |
| std::unique_ptr< RJDocument > && | doc, | ||
| std::unique_ptr< IOrigin > && | origin, | ||
| size_t | size | ||
| ) |