wbtiger
/
foundationdb
mirror of https://github.com/apple/foundationdb.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Rename sqllite-write thread, add index for read threads. 

Additionally make note these are actually coroutines and not threads.
This commit is contained in:
Ray Jenkins 2022-01-25 13:56:35 -06:00
parent 0d34ec0880
commit fd6597cc7a
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
fdbserver/KeyValueStoreSQLite.actor.cpp
View File

@ -2138,6 +2138,7 @@ KeyValueStoreSQLite::KeyValueStoreSQLite(std::string const& filename,
// the cache sizes for individual threads? // the cache sizes for individual threads?
TaskPriority taskId = g_network->getCurrentTask(); TaskPriority taskId = g_network->getCurrentTask();
g_network->setCurrentTask(TaskPriority::DiskWrite); g_network->setCurrentTask(TaskPriority::DiskWrite);
// Note: the below is actually a coroutine and not a thread.
writeThread->addThread(new Writer(this, writeThread->addThread(new Writer(this,
type == KeyValueStoreType::SSD_BTREE_V2, type == KeyValueStoreType::SSD_BTREE_V2,
checkChecksums, checkChecksums,
@ -2148,7 +2149,7 @@ KeyValueStoreSQLite::KeyValueStoreSQLite(std::string const& filename,
freeListPages, freeListPages,
id, id,
&readCursors), &readCursors),
"fdb-sqlite-wr"); "fdb-sqllite-write");
g_network->setCurrentTask(taskId); g_network->setCurrentTask(taskId);
auto p = new Writer::InitAction(); auto p = new Writer::InitAction();
auto f = p->result.getFuture(); auto f = p->result.getFuture();
@ -2175,10 +2176,13 @@ void KeyValueStoreSQLite::startReadThreads() {
int nReadThreads = readCursors.size(); int nReadThreads = readCursors.size();
TaskPriority taskId = g_network->getCurrentTask(); TaskPriority taskId = g_network->getCurrentTask();
g_network->setCurrentTask(TaskPriority::DiskRead); g_network->setCurrentTask(TaskPriority::DiskRead);
for (int i = 0; i < nReadThreads; i++) for (int i = 0; i < nReadThreads; i++) {
std::string threadName = format("fdb-sqllite-reader-%d", i);
// Note: the below is actually a coroutine and not a thread.
readThreads->addThread( readThreads->addThread(
new Reader(filename, type == KeyValueStoreType::SSD_BTREE_V2, readsComplete, logID, &readCursors[i]), new Reader(filename, type == KeyValueStoreType::SSD_BTREE_V2, readsComplete, logID, &readCursors[i]),
"fdb-sqlite-r"); threadName.c_str());
}
g_network->setCurrentTask(taskId); g_network->setCurrentTask(taskId);
} }