diff options
author | Henning Baldersheim <balder@oath.com> | 2018-09-07 12:58:45 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@oath.com> | 2018-09-07 12:58:45 +0200 |
commit | d14286806d0f351449d9f8a8056a87b82961901d (patch) | |
tree | 605c3d8c0626528d1d3cbd1fe46732cb01321309 /searchlib | |
parent | 12c96220ead6e917250c178250e81cf668b5d411 (diff) |
Use std::make_shared
Diffstat (limited to 'searchlib')
-rw-r--r-- | searchlib/src/vespa/searchlib/transactionlog/domain.cpp | 15 |
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) |