remove unsed code

OpenAtomFoundation · Jul 19, 2024 · d5bdcb8 · d5bdcb8
1 parent 0258654
commit d5bdcb8
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 13 deletions.
diff --git a/include/pika_client_conn.h b/include/pika_client_conn.h
@@ -100,7 +100,6 @@ class PikaClientConn : public net::RedisConn {
   void RemoveWatchedKeys();
   void SetTxnFailedFromKeys(const std::vector<std::string>& db_keys);
   void SetTxnFailedIfKeyExists(const std::string target_db_name = "");
-  void SetTxnFailedFromDBs(std::string db_name);
   void ExitTxn();
   bool IsInTxn();
   bool IsTxnInitFailed();

diff --git a/src/pika_client_conn.cc b/src/pika_client_conn.cc
@@ -428,18 +428,6 @@ void PikaClientConn::SetTxnFailedIfKeyExists(std::string target_db_name) {
   }
 }
 
-void PikaClientConn::SetTxnFailedFromDBs(std::string db_name) {
-  auto dispatcher = dynamic_cast<net::DispatchThread*>(server_thread());
-  if (dispatcher != nullptr) {
-    auto involved_conns = dispatcher->GetDBTxns(db_name);
-    for (auto& conn : involved_conns) {
-      if (auto c = std::dynamic_pointer_cast<PikaClientConn>(conn); c != nullptr) {
-        c->SetTxnWatchFailState(true);
-      }
-    }
-  }
-}
-
 void PikaClientConn::ExitTxn() {
   if (IsInTxn()) {
     RemoveWatchedKeys();