diff options
Diffstat (limited to 'src/mongo/db/operation_context_noop.h')
-rw-r--r-- | src/mongo/db/operation_context_noop.h | 144 |
1 files changed, 69 insertions, 75 deletions
diff --git a/src/mongo/db/operation_context_noop.h b/src/mongo/db/operation_context_noop.h index 5466806b276..172ba5f5d5d 100644 --- a/src/mongo/db/operation_context_noop.h +++ b/src/mongo/db/operation_context_noop.h @@ -36,84 +36,78 @@ namespace mongo { - class OperationContextNoop : public OperationContext { - public: - - OperationContextNoop() : OperationContextNoop(new RecoveryUnitNoop()) {} - - OperationContextNoop(RecoveryUnit* ru) : OperationContextNoop(nullptr, 0, ru) {} - - OperationContextNoop(Client* client, unsigned int opId) - : OperationContextNoop(client, opId, new RecoveryUnitNoop()) { - } - - OperationContextNoop(Client* client, unsigned int opId, RecoveryUnit* ru) - : OperationContextNoop(client, opId, new LockerNoop(), ru) { - } - - OperationContextNoop(Client* client, unsigned int opId, Locker* locker) - : OperationContextNoop(client, opId, locker, new RecoveryUnitNoop()) { - } - - OperationContextNoop(Client* client, unsigned int opId, Locker* locker, RecoveryUnit* ru) - : OperationContext(client, opId, locker), - _recoveryUnit(ru) { - - _locker.reset(lockState()); - } - - virtual ~OperationContextNoop() = default; - - virtual RecoveryUnit* recoveryUnit() const override { - return _recoveryUnit.get(); - } - - virtual RecoveryUnit* releaseRecoveryUnit() override { - return _recoveryUnit.release(); - } - - virtual RecoveryUnitState setRecoveryUnit(RecoveryUnit* unit, - RecoveryUnitState state) override { - RecoveryUnitState oldState = _ruState; - _recoveryUnit.reset(unit); - _ruState = state; - return oldState; - } - - virtual ProgressMeter* setMessage_inlock(const char * msg, - const std::string &name, - unsigned long long progressMeterTotal, - int secondsBetween) override { - return &_pm; - } - - virtual void checkForInterrupt() override { } - virtual Status checkForInterruptNoAssert() override { - return Status::OK(); - } - - virtual bool isPrimaryFor( StringData ns ) override { - return true; - } - - virtual std::string getNS() const override { - return std::string(); - }; +class OperationContextNoop : public OperationContext { +public: + OperationContextNoop() : OperationContextNoop(new RecoveryUnitNoop()) {} + + OperationContextNoop(RecoveryUnit* ru) : OperationContextNoop(nullptr, 0, ru) {} + + OperationContextNoop(Client* client, unsigned int opId) + : OperationContextNoop(client, opId, new RecoveryUnitNoop()) {} + + OperationContextNoop(Client* client, unsigned int opId, RecoveryUnit* ru) + : OperationContextNoop(client, opId, new LockerNoop(), ru) {} + + OperationContextNoop(Client* client, unsigned int opId, Locker* locker) + : OperationContextNoop(client, opId, locker, new RecoveryUnitNoop()) {} + + OperationContextNoop(Client* client, unsigned int opId, Locker* locker, RecoveryUnit* ru) + : OperationContext(client, opId, locker), _recoveryUnit(ru) { + _locker.reset(lockState()); + } + + virtual ~OperationContextNoop() = default; + + virtual RecoveryUnit* recoveryUnit() const override { + return _recoveryUnit.get(); + } + + virtual RecoveryUnit* releaseRecoveryUnit() override { + return _recoveryUnit.release(); + } + + virtual RecoveryUnitState setRecoveryUnit(RecoveryUnit* unit, + RecoveryUnitState state) override { + RecoveryUnitState oldState = _ruState; + _recoveryUnit.reset(unit); + _ruState = state; + return oldState; + } + + virtual ProgressMeter* setMessage_inlock(const char* msg, + const std::string& name, + unsigned long long progressMeterTotal, + int secondsBetween) override { + return &_pm; + } + + virtual void checkForInterrupt() override {} + virtual Status checkForInterruptNoAssert() override { + return Status::OK(); + } + + virtual bool isPrimaryFor(StringData ns) override { + return true; + } + + virtual std::string getNS() const override { + return std::string(); + }; - void setReplicatedWrites(bool writesAreReplicated = true) override {} + void setReplicatedWrites(bool writesAreReplicated = true) override {} - bool writesAreReplicated() const override { - return false; - } + bool writesAreReplicated() const override { + return false; + } - virtual uint64_t getRemainingMaxTimeMicros() const override { - return 0; - } + virtual uint64_t getRemainingMaxTimeMicros() const override { + return 0; + } - private: - std::unique_ptr<RecoveryUnit> _recoveryUnit; - std::unique_ptr<Locker> _locker; - ProgressMeter _pm; - }; +private: + std::unique_ptr<RecoveryUnit> _recoveryUnit; + std::unique_ptr<Locker> _locker; + ProgressMeter _pm; +}; } // namespace mongo |