summaryrefslogtreecommitdiffstats
path: root/searchlib
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@oath.com>2018-09-07 12:58:45 +0200
committerHenning Baldersheim <balder@oath.com>2018-09-07 12:58:45 +0200
commitd14286806d0f351449d9f8a8056a87b82961901d (patch)
tree605c3d8c0626528d1d3cbd1fe46732cb01321309 /searchlib
parent12c96220ead6e917250c178250e81cf668b5d411 (diff)
Use std::make_shared
Diffstat (limited to 'searchlib')
-rw-r--r--searchlib/src/vespa/searchlib/transactionlog/domain.cpp15
1 files changed, 8 insertions, 7 deletions
diff --git a/searchlib/src/vespa/searchlib/transactionlog/domain.cpp b/searchlib/src/vespa/searchlib/transactionlog/domain.cpp
index 1caff132779..b3b51e1de90 100644
--- a/searchlib/src/vespa/searchlib/transactionlog/domain.cpp
+++ b/searchlib/src/vespa/searchlib/transactionlog/domain.cpp
@@ -60,13 +60,13 @@ Domain::Domain(const string &domainName, const string & baseDir, Executor & comm
}
_sessionExecutor.sync();
if (_parts.empty() || _parts.crbegin()->second->isClosed()) {
- _parts[lastPart].reset(new DomainPart(_name, dir(), lastPart, _defaultCrcType, _fileHeaderContext, false));
+ _parts[lastPart] = std::make_shared<DomainPart>(_name, dir(), lastPart, _defaultCrcType, _fileHeaderContext, false);
vespalib::File::sync(dir());
}
}
void Domain::addPart(int64_t partId, bool isLastPart) {
- DomainPart::SP dp(new DomainPart(_name, dir(), partId, _defaultCrcType, _fileHeaderContext, isLastPart));
+ auto dp = std::make_shared<DomainPart>(_name, dir(), partId, _defaultCrcType, _fileHeaderContext, isLastPart);
if (dp->size() == 0) {
// Only last domain part is allowed to be truncated down to
// empty size.
@@ -199,7 +199,7 @@ Domain::triggerSyncNow()
if (!_pendingSync) {
_pendingSync = true;
DomainPart::SP dp(_parts.rbegin()->second);
- _commitExecutor.execute(Sync::UP(new Sync(_syncMonitor, dp, _pendingSync)));
+ _commitExecutor.execute(std::make_unique<Sync>(_syncMonitor, dp, _pendingSync));
}
}
@@ -290,7 +290,7 @@ void Domain::commit(const Packet & packet)
triggerSyncNow();
waitPendingSync(_syncMonitor, _pendingSync);
dp->close();
- dp.reset(new DomainPart(_name, dir(), entry.serial(), _defaultCrcType, _fileHeaderContext, false));
+ dp = std::make_shared<DomainPart>(_name, dir(), entry.serial(), _defaultCrcType, _fileHeaderContext, false);
{
LockGuard guard(_lock);
_parts[entry.serial()] = dp;
@@ -327,10 +327,11 @@ int Domain::visit(const Domain::SP & domain, SerialNum from, SerialNum to,
assert(this == domain.get());
cleanSessions();
SerialNumRange range(from, to);
- Session * session = new Session(_sessionId++, range, domain, supervisor, conn);
+ auto session = std::make_shared<Session>(_sessionId++, range, domain, supervisor, conn);
+ int id = session->id();
LockGuard guard(_sessionLock);
- _sessions[session->id()] = Session::SP(session);
- return session->id();
+ _sessions[id] = std::move(session);
+ return id;
}
int Domain::startSession(int sessionId)