| 103 | return sp_it != sp_map_of_db.end(); |
| 104 | } |
| 105 | std::shared_ptr<hybridse::vm::CompileInfo> GetRequestInfo(const std::string& db, const std::string& sp_name, |
| 106 | hybridse::base::Status& status) override { // NOLINT |
| 107 | std::lock_guard<SpinMutex> spin_lock(spin_mutex_); |
| 108 | auto db_it = db_sp_map_.find(db); |
| 109 | if (db_it == db_sp_map_.end()) { |
| 110 | status = hybridse::base::Status(hybridse::common::kProcedureNotFound, |
| 111 | "store procedure[" + sp_name + "] not found in db[" + db + "]"); |
| 112 | return std::shared_ptr<hybridse::vm::CompileInfo>(); |
| 113 | } |
| 114 | auto sp_it = db_it->second.find(sp_name); |
| 115 | if (sp_it == db_it->second.end()) { |
| 116 | status = hybridse::base::Status(hybridse::common::kProcedureNotFound, |
| 117 | "store procedure[" + sp_name + "] not found in db[" + db + "]"); |
| 118 | return std::shared_ptr<hybridse::vm::CompileInfo>(); |
| 119 | } |
| 120 | |
| 121 | if (!sp_it->second.request_info) { |
| 122 | status = hybridse::base::Status(hybridse::common::kProcedureNotFound, |
| 123 | "store procedure[" + sp_name + "] not found in db[" + db + "]"); |
| 124 | return std::shared_ptr<hybridse::vm::CompileInfo>(); |
| 125 | } |
| 126 | return sp_it->second.request_info; |
| 127 | } |
| 128 | std::shared_ptr<hybridse::vm::CompileInfo> GetBatchRequestInfo(const std::string& db, const std::string& sp_name, |
| 129 | hybridse::base::Status& status) override { // NOLINT |
| 130 | std::lock_guard<SpinMutex> spin_lock(spin_mutex_); |