Method SendNotification

src/QueueOperation.cpp:82–127

}

int QueueOperation::SendNotification(QueueEvent event) {
	UINT msg = 0;
	if (event != QueueEventProgress && (m_notifSent & event) != 0)
		return 0;		//do not send duplicate notifications, except for progress

	m_notifSent |= event;

	switch(event) {
		case QueueEventStart:
			msg = NotifyMessageStart;
			break;
		case QueueEventEnd:
			msg = NotifyMessageEnd;
			break;
		case QueueEventAdd:
			msg = NotifyMessageAdd;
			break;
		case QueueEventRemove:
			msg = NotifyMessageRemove;
			break;
		case QueueEventProgress:
			msg = NotifyMessageProgress;
			break;
		default:
			return -1;
			break;
	}

	DWORD curThread = GetCurrentThreadId();
	if (m_winThread == curThread) {
		::SendMessage(m_hNotify, msg, m_notifyCode, (LPARAM)this);
		return 0;
	}

	m_ackMonitor.Enter();
		if (m_terminating) {
			m_ackMonitor.Exit();
			return 0;
		}

		::PostMessage(m_hNotify, msg, m_notifyCode, (LPARAM)this);
		m_ackMonitor.Wait(QueueConditionAcked);
	m_ackMonitor.Exit();

	return 0;
}

int QueueOperation::AckNotification() {
	m_ackMonitor.Enter();