Method QueueLoop

src/FTPQueue.cpp:177–222

}

int FTPQueue::QueueLoop() {
	QueueOperation * op = NULL;

	while(!m_stopping) {

		m_monitor->Enter();
			while (m_queue.empty() && !m_stopping)
				m_monitor->Wait(ConditionQueueOps);

			if (m_stopping) {
				m_monitor->Exit();
				break;
			}

			op = m_queue.front();
			m_activeOp = op;
			m_performing = true;
		m_monitor->Exit();

		op->SendNotification(QueueOperation::QueueEventStart);
		op->SetRunning(true);
		Sleep(500);
		op->Perform();
		op->SetRunning(false);
		op->SendNotification(QueueOperation::QueueEventEnd);

		if (m_stopping)
			break;

		op->SendNotification(QueueOperation::QueueEventRemove);

		m_monitor->Enter();
			m_activeOp = NULL;
			m_performing = false;
			m_queue.pop_front();
			delete op;
		m_monitor->Exit();
	}

	m_monitor->Enter();
		m_performing = false;
		m_monitor->Signal(ConditionQueueStop);
	m_monitor->Exit();

	return 0;
}

int FTPQueue::OnDataReceived(long received, long total) {
	m_monitor->Enter();