diff --git a/src/index/fsindexer.cpp b/src/index/fsindexer.cpp index f2345697..156d3e27 100644 --- a/src/index/fsindexer.cpp +++ b/src/index/fsindexer.cpp @@ -44,6 +44,7 @@ #include "wipedir.h" #include "fileudi.h" #include "cancelcheck.h" +#include "rclinit.h" // When using extended attributes, we have to use the ctime. // This is quite an expensive price to pay... @@ -361,6 +362,7 @@ void FsIndexer::makesig(const struct stat *stp, string& out) #ifdef IDX_THREADS void *FsIndexerDbUpdWorker(void * fsp) { + recoll_threadinit(); FsIndexer *fip = (FsIndexer*)fsp; WorkQueue *tqp = &fip->m_dwqueue; DebugLog::getdbl()->setloglevel(fip->m_loglevel); @@ -384,6 +386,7 @@ void *FsIndexerDbUpdWorker(void * fsp) void *FsIndexerInternfileWorker(void * fsp) { + recoll_threadinit(); FsIndexer *fip = (FsIndexer*)fsp; WorkQueue *tqp = &fip->m_iwqueue; DebugLog::getdbl()->setloglevel(fip->m_loglevel); diff --git a/src/rcldb/rcldb.cpp b/src/rcldb/rcldb.cpp index 0f8dc4ec..b4207cfa 100644 --- a/src/rcldb/rcldb.cpp +++ b/src/rcldb/rcldb.cpp @@ -56,6 +56,7 @@ using namespace std; #include "ptmutex.h" #include "termproc.h" #include "expansiondbs.h" +#include "rclinit.h" // Recoll index format version is stored in user metadata. When this change, // we can't open the db and will have to reindex. @@ -793,6 +794,7 @@ static const string cstr_nc("\n\r\x0c"); #ifdef IDX_THREADS void *DbUpdWorker(void* vdbp) { + recoll_threadinit(); Db *dbp = (Db *)vdbp; WorkQueue *tqp = &(dbp->m_ndb->m_wqueue); DebugLog::getdbl()->setloglevel(dbp->m_ndb->m_loglevel); @@ -1170,7 +1172,8 @@ bool Db::Native::addOrUpdateWrite(const string& udi, const string& uniterm, void Db::waitUpdIdle() { m_ndb->m_wqueue.waitIdle(); - LOGDEB(("Db::waitUpdIdle: total work %ll mS\n", m_ndb->m_totalworkus/1000)); + LOGDEB(("Db::waitUpdIdle: total work %lld mS\n", + m_ndb->m_totalworkus/1000)); } #endif