| 72 | } |
| 73 | |
| 74 | queue_file* queue_manager::create_file(const char* extName) |
| 75 | { |
| 76 | queue_file* fp = NEW queue_file; |
| 77 | |
| 78 | if (!fp->create(m_home.c_str(), m_queueName.c_str(), |
| 79 | extName, sub_width_)) { |
| 80 | |
| 81 | delete fp; |
| 82 | return NULL; |
| 83 | } |
| 84 | |
| 85 | if (!cache_add(fp)) { |
| 86 | logger_fatal("%s already exist in table", fp->key()); |
| 87 | } |
| 88 | return fp; |
| 89 | } |
| 90 | |
| 91 | queue_file* queue_manager::open_file(const char* filePath, bool no_cache /* = true */) |
| 92 | { |
no test coverage detected