| 312 | } |
| 313 | |
| 314 | bool queue_manager::cache_add(queue_file* fp) |
| 315 | { |
| 316 | bool ret; |
| 317 | |
| 318 | std::map<acl::string, queue_file*>::iterator it; |
| 319 | m_queueLocker.lock(); |
| 320 | it = m_queueList.find(fp->key()); |
| 321 | if (it == m_queueList.end()) { |
| 322 | m_queueList[fp->key()] = fp; |
| 323 | ret = true; |
| 324 | } else { |
| 325 | ret = false; |
| 326 | } |
| 327 | m_queueLocker.unlock(); |
| 328 | return ret; |
| 329 | } |
| 330 | |
| 331 | bool queue_manager::cache_del(const char* key) |
| 332 | { |