|
a/src/rcldb/rcldb.cpp |
|
b/src/rcldb/rcldb.cpp |
|
... |
|
... |
| 129 |
|
129 |
|
| 130 |
Db::Native::Native(Db *db)
|
130 |
Db::Native::Native(Db *db)
|
| 131 |
: m_rcldb(db), m_isopen(false), m_iswritable(false),
|
131 |
: m_rcldb(db), m_isopen(false), m_iswritable(false),
|
| 132 |
m_noversionwrite(false)
|
132 |
m_noversionwrite(false)
|
| 133 |
#ifdef IDX_THREADS
|
133 |
#ifdef IDX_THREADS
|
| 134 |
, m_wqueue("DbUpd",
|
|
|
| 135 |
m_rcldb->m_config->getThrConf(RclConfig::ThrDbWrite).first),
|
134 |
, m_wqueue("DbUpd", m_rcldb->m_config->getThrConf(RclConfig::ThrDbWrite).first),
|
| 136 |
m_totalworkns(0LL)
|
135 |
m_totalworkns(0LL)
|
| 137 |
#endif // IDX_THREADS
|
136 |
#endif // IDX_THREADS
|
| 138 |
{
|
137 |
{
|
| 139 |
LOGDEB1(("Native::Native: me %p\n", this));
|
138 |
LOGDEB1(("Native::Native: me %p\n", this));
|
| 140 |
}
|
139 |
}
|
|
... |
|
... |
| 475 |
}
|
474 |
}
|
| 476 |
|
475 |
|
| 477 |
// Note: xapian has no close call, we delete and recreate the db
|
476 |
// Note: xapian has no close call, we delete and recreate the db
|
| 478 |
bool Db::close()
|
477 |
bool Db::close()
|
| 479 |
{
|
478 |
{
|
| 480 |
LOGDEB2(("Db::close()\n"));
|
479 |
LOGDEB1(("Db::close()\n"));
|
| 481 |
return i_close(false);
|
480 |
return i_close(false);
|
| 482 |
}
|
481 |
}
|
| 483 |
bool Db::i_close(bool final)
|
482 |
bool Db::i_close(bool final)
|
| 484 |
{
|
483 |
{
|
| 485 |
if (m_ndb == 0)
|
484 |
if (m_ndb == 0)
|