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 | ||
) |