| 23 | const int QueueConditionCount = 1; |
| 24 | |
| 25 | QueueOperation::QueueOperation(QueueType type, HWND hNotify, int notifyCode, void * notifyData) : |
| 26 | m_type(type), |
| 27 | m_client(NULL), |
| 28 | m_hNotify(hNotify), |
| 29 | m_notifyCode(notifyCode), |
| 30 | m_notifyData(notifyData), |
| 31 | m_doConnect(true), |
| 32 | m_doDisconnect(false), |
| 33 | m_result(-1), //error by default |
| 34 | m_data(NULL), |
| 35 | m_progress(0.0f), |
| 36 | m_notifSent(0), |
| 37 | m_running(false), |
| 38 | m_ackMonitor(QueueConditionCount), |
| 39 | m_terminating(false) |
| 40 | { |
| 41 | m_winThread = GetWindowThreadProcessId(m_hNotify, NULL); |
| 42 | } |
| 43 | |
| 44 | QueueOperation::~QueueOperation() { |
| 45 | Terminate(); |
nothing calls this directly
no outgoing calls
no test coverage detected