1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
|
/*
Copyright ©2006 Ricardo Pescuma Domenecci
Modified ©2008-2010 DeathAxe, Yasnovidyashii, Merlin, K. Romanov, Kreol
This program is free software; you can redistribute it and/or
modify it under the terms of the GNU General Public License
as published by the Free Software Foundation; either version 2
of the License, or (at your option) any later version.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software
Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*/
#ifndef __CONTACTASYNCQUEUE_H__
#define __CONTACTASYNCQUEUE_H__
/**
*
*
**/
struct CQueueItem
{
DWORD check_time;
MCONTACT hContact;
PVOID param;
};
/////////////////////////////////////////////////////////////////////////////////////////
class CContactQueue
{
public:
enum EQueueStatus
{
RUNNING = 0,
STOPPING = 1,
STOPPED = 2
};
CContactQueue(int initialSize = 10);
~CContactQueue();
__forceinline int Size() const {
return _queue.getCount();
}
CQueueItem* Get(int idx) const {
return _queue[idx];
}
void RemoveAll();
// This function removes all queue items for the hContact.
void RemoveAll(MCONTACT hContact);
// This function removes all queue items for the hContact considering the correct parameter.
void RemoveAllConsiderParam(MCONTACT hContact, void *param);
/**
* This method adds the desired new item.
*
* @param waitTime - the time to wait until the callback is desired to run
* @param hContact - the contact to perform the action for
* @param param - a caller defined parameter passed to the callback function
*
* @retval TRUE - The item is added to the queue successfully.
* @retval FALSE - The item is not added to the queue.
**/
BOOL Add(int waitTime, MCONTACT hContact, void *param = nullptr);
/**
* This method adds the desired new item only, if the queue does not yet contain
* an item for the contact.
*
* @param waitTime - the time to wait until the callback is desired to run
* @param hContact - the contact to perform the action for
* @param param - a caller defined parameter passed to the callback function
*
* @retval TRUE - The item is added to the queue successfully.
* @retval FALSE - The item is not added to the queue.
**/
BOOL AddIfDontHave(int waitTime, MCONTACT hContact, void *param = nullptr);
/**
* This method removes all existing queue items for the contact and adds a new queue item
* for the given contact. This method might be used to move an existing entry,
* whose check_time has changed.
*
* @param waitTime - the time to wait until the callback is desired to run
* @param hContact - the contact to perform the action for
* @param param - a caller defined parameter passed to the callback function
*
* @return nothing
**/
BOOL AddUnique(int waitTime, MCONTACT hContact, void *param = nullptr);
/**
* This method removes all existing queue items for the contact with the same parameter as @e param
* and adds a new queue item for the given contact. This method might be used to move an existing
* entry, whose check_time has changed.
*
* @param waitTime - the time to wait until the callback is desired to run
* @param hContact - the contact to perform the action for
* @param param - a caller defined parameter passed to the callback function
*
* @return nothing
**/
BOOL AddUniqueConsiderParam (int waitTime, MCONTACT hContact, void *param = nullptr);
// This method resumes the worker thread and immitiatly goes on with the next entry.
void ContinueWithNext();
protected:
virtual void OnEmpty() {};
virtual void Callback(MCONTACT hContact, PVOID param) = 0;
/**
* This is the real thread callback function. As long as _status
* is set to RUNNING it looks for items in the queue to perform
* the _pfnCallback function on them. If the queue is empty or the
* next upcoming item is located in the future, the thread is suspended
* in the meanwhile.
*
* @param none
*
* @return nothing
**/
void Thread();
// This is a static method to redirect the thread's callback function
// to the desired class object.
static void __cdecl ThreadProc(CContactQueue* obj)
{
obj->Thread();
}
// This method suspends the worker thread for the given ammount of time.
void Suspend(int time) const;
private:
LIST<CQueueItem> _queue;
mir_cs _cs;
HANDLE _hEvent;
EQueueStatus _status;
/**
* This member function really adds an item into the time sorted queue list.
*
* @param waitTime - the time to wait until the callback is desired to run
* @param hContact - the contact to perform the action for
* @param param - a caller defined parameter passed to the callback function
*
* @retval TRUE - The item is added to the queue successfully.
* @retval FALSE - The item is not added to the queue.
**/
BOOL InternalAdd(int waitTime, MCONTACT hContact, void *param);
void Remove(int idx);
};
#endif // __CONTACTASYNCQUEUE_H__
|
