diff --git a/cpp/dbpool.cc b/cpp/dbpool.cc index 844f69a..a7b2000 100644 --- a/cpp/dbpool.cc +++ b/cpp/dbpool.cc @@ -75,29 +75,6 @@ namespace f8 work_thread_ = new std::thread(&DBThread::WorkThreadProc, this); } -#if 0 - void AddAsyncQuery(int sockhandle, int query_type, long long context_id, const std::string& sql) - { - AsyncQueryNode *p = new AsyncQueryNode(); - p->query_type = query_type; - p->socket_handle = sockhandle; - p->context_id = context_id; - p->sql = sql; - - std::unique_lock lk(*loop_mutex_); - msg_mutex_->lock(); - if (bot_node_) { - bot_node_->nextnode = p; - bot_node_ = p; - } else { - top_node_ = p; - bot_node_ = p; - } - msg_mutex_->unlock(); - loop_cond_->notify_all(); - } -#endif - void AddAsyncQuery(AsyncQueryNode* p) { std::unique_lock lk(*loop_mutex_);