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

fix tabs in worker.actor.cpp

This commit is contained in:
Clement Pang 2018-10-08 17:28:58 -07:00
parent eb72427923
commit 403b4c5d94
1 changed files with 20 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
fdbserver/worker.actor.cpp
View File

@ -357,28 +357,28 @@ ACTOR Future<Void> storageServerRollbackRebooter( Future<Void> prevStorageServer
// for memory servers, we won't reload from disk if REUSE_MEMORY_STORE_ON_ROLLBACK is active.
if (SERVER_KNOBS -> REUSE_MEMORY_STORE_ON_ROLLBACK && storeType == KeyValueStoreType::MEMORY) {
store->reset();
StorageServerInterface ssi;
ssi.uniqueID = id;
ssi.locality = locality;
ssi.initEndpoints();
store->reset();
StorageServerInterface ssi;
ssi.uniqueID = id;
ssi.locality = locality;
ssi.initEndpoints();
prevStorageServer = storageServer( store, ssi, db, folder, Promise<Void>() );
prevStorageServer = storageServer( store, ssi, db, folder, Promise<Void>() );
prevStorageServer = handleIOErrors(prevStorageServer, store, id, store->onClosed(), true);
} else {
//if (BUGGIFY) Void _ = wait(delay(1.0)); // This does the same thing as zombie()
// We need a new interface, since the new storageServer will do replaceInterface(). And we need to destroy
// the old one so the failure detector will know it is gone.
StorageServerInterface ssi;
ssi.uniqueID = id;
ssi.locality = locality;
ssi.initEndpoints();
auto *kv = openKVStore(storeType, filename, ssi.uniqueID, memoryLimit);
Future<Void> kvClosed = kv->onClosed();
filesClosed->add(kvClosed);
prevStorageServer = storageServer(kv, ssi, db, folder, Promise<Void>());
prevStorageServer = handleIOErrors(prevStorageServer, kv, id, kvClosed);
}
} else {
//if (BUGGIFY) Void _ = wait(delay(1.0)); // This does the same thing as zombie()
// We need a new interface, since the new storageServer will do replaceInterface(). And we need to destroy
// the old one so the failure detector will know it is gone.
StorageServerInterface ssi;
ssi.uniqueID = id;
ssi.locality = locality;
ssi.initEndpoints();
auto *kv = openKVStore(storeType, filename, ssi.uniqueID, memoryLimit);
Future<Void> kvClosed = kv->onClosed();
filesClosed->add(kvClosed);
prevStorageServer = storageServer(kv, ssi, db, folder, Promise<Void>());
prevStorageServer = handleIOErrors(prevStorageServer, kv, id, kvClosed);
}
}
}