11 #ifndef __INPUTPARSER_H__ 12 #define __INPUTPARSER_H__ 14 #include <shogun/lib/config.h> 20 #include <condition_variable> 25 #define PARSER_DEFAULT_BUFFSIZE 100 292 static void* parse_loop_entry_point(
void* params);
398 if (is_labelled ==
true)
435 SG_SDEBUG(
"entering CInputParser::start_parser()\n")
438 SG_SERROR(
"Parser thread is already running! Multiple parse threads not supported.\n")
445 parse_thread = std::thread(&parse_loop_entry_point,
this);
447 SG_SDEBUG(
"leaving CInputParser::start_parser()\n")
461 SG_SDEBUG(
"entering CInputParser::is_running()\n")
473 SG_SDEBUG(
"leaving CInputParser::is_running(), returning %d\n", ret)
653 SG_SDEBUG(
"entering CInputParser::end_parser\n")
657 SG_SDEBUG(
"leaving CInputParser::end_parser\n")
670 #endif // __INPUTPARSER_H__
A Streaming File access class.
all of classes and functions are contained in the shogun namespace
constexpr size_t CPU_CACHE_LINE_SIZE