| 146 | } |
| 147 | |
| 148 | int FTPQueue::CancelQueueOp(QueueOperation * op) { |
| 149 | m_monitor->Enter(); |
| 150 | if (m_performing) { |
| 151 | if (op == m_queue.front()) { |
| 152 | m_monitor->Exit(); |
| 153 | return -1; //Cannot cancel running operation, only abort |
| 154 | } |
| 155 | } |
| 156 | |
| 157 | size_t size = m_queue.size(); |
| 158 | QueueOperation * queueop = NULL; |
| 159 | for(size_t i = 0; i < size; i++) { |
| 160 | queueop = m_queue.front(); |
| 161 | //m_queue.pop_front(); |
| 162 | if (queueop == op) { |
| 163 | m_queue.erase(m_queue.begin()+i); |
| 164 | queueop->SendNotification(QueueOperation::QueueEventRemove); |
| 165 | delete queueop; |
| 166 | break; |
| 167 | } |
| 168 | // else { |
| 169 | // m_queue.push_back(queueop); |
| 170 | //} |
| 171 | } |
| 172 | m_monitor->Exit(); |
| 173 | |
| 174 | return 0; |
| 175 | } |
| 176 | |
| 177 | int FTPQueue::QueueLoop() { |
| 178 | QueueOperation * op = NULL; |
no test coverage detected