| 215 | } |
| 216 | |
| 217 | int RequestCache::Clear() { |
| 218 | { |
| 219 | std::unique_lock<std::mutex> lock(queue_mutex_); |
| 220 | std::queue<std::pair<uint64_t, std::shared_ptr<Response>>> empty; |
| 221 | swap(empty, task_queue_); |
| 222 | } |
| 223 | int count = 0; |
| 224 | { |
| 225 | std::lock_guard<std::recursive_mutex> lk(cache_mtx_); |
| 226 | count = lru_.size(); |
| 227 | lru_.clear(); |
| 228 | map_.clear(); |
| 229 | } |
| 230 | LOG(INFO) << "Clear " << count << " key!"; |
| 231 | return 0; |
| 232 | } |
| 233 | |
| 234 | } // namespace predictor |
| 235 | } // namespace paddle_serving |
no test coverage detected