feat: add lock wait time to slow query log

src/tendisplus/commands/command.cpp

@@ -383,6 +383,7 @@ Expected<std::string> Command::runSessionCmd(Session* sess) {
   sess->getCtx()->setArgsBrief(sess->getArgs());
   it->second->incrCallTimes();
   auto now = nsSinceEpoch();
+  sess->resetLockWaitTime();
   auto guard = MakeGuard([it, now, sess, commandName] {
     sess->getCtx()->clearRequestCtx();
     auto end = nsSinceEpoch();

src/tendisplus/server/segment_manager.cpp

@@ -108,13 +108,16 @@ Expected<DbWithLock> SegmentMgrFnvHash64::getDbWithKeyLock(
   }
 
   if (mode != mgl::LockMode::LOCK_NONE) {
+    auto start = nsSinceEpoch();
     auto elk = KeyLock::AquireKeyLock(segId,
                                       chunkId,
                                       key,
                                       mode,
                                       sess,
                                       sess->getServerEntry()->getMGLockMgr(),
                                       lockTimeoutMs);
+    auto duration = nsSinceEpoch() - start;
+    sess->addLockWaitTime(duration);
     if (!elk.ok()) {
       return elk.status();
     }

src/tendisplus/server/server_entry.cpp

@@ -259,6 +259,7 @@ void SlowlogStat::slowlogDataPushEntryIfNeeded(
     slowLog << "# Db: " << sess->getCtx()->getDbId() << "\n";
     slowLog << "# Query_time: " << duration << "\n";
     slowLog << "# Execute_time: " << execTime << "\n";
+    slowLog << "# LockWait_time: " << sess->getLockWaitTime() << "\n";
     slowLog << "# Thread_id: " << getCurThreadId() << "\n";
     slowLog << "# Session_id: " << sess->id() << "\n";
     slowLog << "# Read_Pack_ts: " << sess->getCtx()->getReadPacketTs() << "\n";

src/tendisplus/server/session.cpp

@@ -32,6 +32,7 @@ Session::Session(ServerEntry* svr, Type type)
     _ctx(std::make_unique<SessionCtx>(this)),
     _type(type),
     _timestamp(msSinceEpoch()),
+    _lockWaitTime(0),
     _sessId(_idGen.fetch_add(1, std::memory_order_relaxed)),
     _inLua(false) {
   _aliveCnt.fetch_add(1, std::memory_order_relaxed);

src/tendisplus/server/session.h

@@ -86,12 +86,29 @@ class Session : public std::enable_shared_from_this<Session> {
     return {};
   }
 
+  uint64_t getLockWaitTime() const {
+    return _lockWaitTime;
+  }
+
+  void setLockWaitTime(uint64_t time) {
+    _lockWaitTime = time;
+  }
+
+  void addLockWaitTime(uint64_t time) {
+    _lockWaitTime += time;
+  }
+
+  void resetLockWaitTime() {
+    _lockWaitTime = 0;
+  }
+
  protected:
   std::vector<std::string> _args;
   ServerEntry* _server;
   std::unique_ptr<SessionCtx> _ctx;
   Type _type;
   uint64_t _timestamp;
+  uint64_t _lockWaitTime;
 
  private:
   mutable std::mutex _baseMutex;