diff options
| -rw-r--r-- | project2/common/rowProcessor.cpp | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/project2/common/rowProcessor.cpp b/project2/common/rowProcessor.cpp index 26ca433..7ffaf7f 100644 --- a/project2/common/rowProcessor.cpp +++ b/project2/common/rowProcessor.cpp @@ -45,16 +45,17 @@ RowProcessor::execute(ExecContext * ec, const RowProcessorCallback & cb) const if (const SourceObject * so = dynamic_cast<const SourceObject *>(this)) { ScopeObject onComplete(boost::bind(&SourceObject::send, so, Complete)); } + const auto rowReadyCallback = boost::bind(&RowProcessor::rowReadyInternal, this, _1, cb, ec); if (IRSE) { try { - source->execute(filter, cb, ec); + source->execute(filter, rowReadyCallback, ec); } catch (const std::exception & e) { Logger()->messagebf(LOG_WARNING, "Source '%s' failed with '%s'", source->name, e.what()); } } else { - source->execute(filter, cb, ec); + source->execute(filter, rowReadyCallback, ec); } } |