diff options
Diffstat (limited to 'protocols/IcqOscarJ/src/icq_infoupdate.cpp')
| -rw-r--r-- | protocols/IcqOscarJ/src/icq_infoupdate.cpp | 196 |
1 files changed, 75 insertions, 121 deletions
diff --git a/protocols/IcqOscarJ/src/icq_infoupdate.cpp b/protocols/IcqOscarJ/src/icq_infoupdate.cpp index fcba9444f1..501adb6cc3 100644 --- a/protocols/IcqOscarJ/src/icq_infoupdate.cpp +++ b/protocols/IcqOscarJ/src/icq_infoupdate.cpp @@ -40,7 +40,7 @@ void CIcqProto::icq_InitInfoUpdate(void) infoUpdateMutex = new icq_critical_section();
// Init list
- for (int i = 0; i<LISTSIZE; i++) {
+ for (int i = 0; i < LISTSIZE; i++) {
m_infoUpdateList[i].dwUin = 0;
m_infoUpdateList[i].hContact = NULL;
m_infoUpdateList[i].queued = 0;
@@ -57,80 +57,64 @@ void CIcqProto::icq_InitInfoUpdate(void) // Returns FALSE if the list was full
BOOL CIcqProto::icq_QueueUser(MCONTACT hContact)
{
- if ( !infoUpdateMutex )
+ if (!infoUpdateMutex)
return FALSE;
- if (nInfoUserCount < LISTSIZE)
- {
- int i, nChecked = 0, nFirstFree = -1;
- BOOL bFound = FALSE;
+ if (nInfoUserCount >= LISTSIZE)
+ return FALSE;
- infoUpdateMutex->Enter();
+ int i, nChecked = 0, nFirstFree = -1;
+ BOOL bFound = FALSE;
- // Check if in list
- for (i = 0; (i<LISTSIZE && nChecked < nInfoUserCount); i++)
- {
- if (m_infoUpdateList[i].hContact)
- {
- nChecked++;
- if (m_infoUpdateList[i].hContact == hContact)
- {
- bFound = TRUE;
- break;
- }
- }
- else if (nFirstFree == -1)
- {
- nFirstFree = i;
+ infoUpdateMutex->Enter();
+
+ // Check if in list
+ for (i = 0; (i < LISTSIZE && nChecked < nInfoUserCount); i++) {
+ if (m_infoUpdateList[i].hContact) {
+ nChecked++;
+ if (m_infoUpdateList[i].hContact == hContact) {
+ bFound = TRUE;
+ break;
}
}
- if (nFirstFree == -1)
+ else if (nFirstFree == -1)
nFirstFree = i;
-
- // Add to list
- if (!bFound)
- {
- DWORD dwUin = getContactUin(hContact);
-
- if (dwUin)
- {
- m_infoUpdateList[nFirstFree].dwUin = dwUin;
- m_infoUpdateList[nFirstFree].hContact = hContact;
- m_infoUpdateList[nFirstFree].queued = time(NULL);
- nInfoUserCount++;
+ }
+ if (nFirstFree == -1)
+ nFirstFree = i;
+
+ // Add to list
+ if (!bFound) {
+ DWORD dwUin = getContactUin(hContact);
+ if (dwUin) {
+ m_infoUpdateList[nFirstFree].dwUin = dwUin;
+ m_infoUpdateList[nFirstFree].hContact = hContact;
+ m_infoUpdateList[nFirstFree].queued = time(NULL);
+ nInfoUserCount++;
#ifdef _DEBUG
- debugLogA("Queued user %u, place %u, count %u", dwUin, nFirstFree, nInfoUserCount);
+ debugLogA("Queued user %u, place %u, count %u", dwUin, nFirstFree, nInfoUserCount);
#endif
- // Notify worker thread
- if (hInfoQueueEvent && bInfoUpdateEnabled)
- SetEvent(hInfoQueueEvent);
- }
+ // Notify worker thread
+ if (hInfoQueueEvent && bInfoUpdateEnabled)
+ SetEvent(hInfoQueueEvent);
}
-
- infoUpdateMutex->Leave();
-
- return TRUE;
}
- return FALSE;
+ infoUpdateMutex->Leave();
+ return TRUE;
}
-
void CIcqProto::icq_DequeueUser(DWORD dwUin)
{
- if (nInfoUserCount > 0)
- {
+ if (nInfoUserCount > 0) {
int nChecked = 0;
// Check if in list
infoUpdateMutex->Enter();
- for (int i = 0; (i < LISTSIZE && nChecked < nInfoUserCount); i++)
- {
- if (m_infoUpdateList[i].dwUin)
- {
+ for (int i = 0; (i < LISTSIZE && nChecked < nInfoUserCount); i++) {
+ if (m_infoUpdateList[i].dwUin) {
nChecked++;
// Remove from list
- if (m_infoUpdateList[i].dwUin == dwUin)
- {
+ if (m_infoUpdateList[i].dwUin == dwUin) {
#ifdef _DEBUG
debugLogA("Dequeued user %u", m_infoUpdateList[i].dwUin);
#endif
@@ -146,7 +130,6 @@ void CIcqProto::icq_DequeueUser(DWORD dwUin) }
}
-
void CIcqProto::icq_RescanInfoUpdate()
{
bInfoPendingUsers = 0;
@@ -155,24 +138,16 @@ void CIcqProto::icq_RescanInfoUpdate() bInfoUpdateEnabled = 0; // freeze thread
// Queue all outdated users
- MCONTACT hContact = db_find_first(m_szModuleName);
- while (hContact != NULL)
- {
- if (IsMetaInfoChanged(hContact))
- { // Queue user
- if (!icq_QueueUser(hContact))
- { // The queue is full, pause queuing contacts
+ for (MCONTACT hContact = db_find_first(m_szModuleName); hContact; hContact = db_find_next(hContact, m_szModuleName))
+ if (IsMetaInfoChanged(hContact)) // Queue user
+ if (!icq_QueueUser(hContact)) { // The queue is full, pause queuing contacts
bInfoPendingUsers = 1;
- break;
+ break;
}
- }
- hContact = db_find_next(hContact, m_szModuleName);
- }
bInfoUpdateEnabled = TRUE;
}
-
void CIcqProto::icq_EnableUserLookup(BOOL bEnable)
{
bInfoUpdateEnabled = bEnable;
@@ -182,7 +157,6 @@ void CIcqProto::icq_EnableUserLookup(BOOL bEnable) SetEvent(hInfoQueueEvent);
}
-
void __cdecl CIcqProto::InfoUpdateThread( void* )
{
int i;
@@ -192,20 +166,17 @@ void __cdecl CIcqProto::InfoUpdateThread( void* ) bInfoUpdateRunning = TRUE;
- while (bInfoUpdateRunning)
- {
+ while (bInfoUpdateRunning) {
if (!nInfoUserCount && bInfoPendingUsers) // whole queue processed, check if more users needs updating
icq_RescanInfoUpdate();
- if (!nInfoUserCount || !bInfoUpdateEnabled || !icqOnline())
- {
+ if (!nInfoUserCount || !bInfoUpdateEnabled || !icqOnline()) {
dwWait = WAIT_TIMEOUT;
- while (bInfoUpdateRunning && dwWait == WAIT_TIMEOUT)
- { // wait for new work or until we should end
+ while (bInfoUpdateRunning && dwWait == WAIT_TIMEOUT) // wait for new work or until we should end
dwWait = ICQWaitForSingleObject(hInfoQueueEvent, 10000);
- }
}
- if (!bInfoUpdateRunning) break;
+ if (!bInfoUpdateRunning)
+ break;
switch (dwWait) {
case WAIT_IO_COMPLETION:
@@ -215,50 +186,44 @@ void __cdecl CIcqProto::InfoUpdateThread( void* ) case WAIT_OBJECT_0:
case WAIT_TIMEOUT:
// Time to check for new users
- if (!bInfoUpdateEnabled) continue; // we can't send requests now
+ if (!bInfoUpdateEnabled)
+ continue; // we can't send requests now
- if (nInfoUserCount && icqOnline())
- {
+ if (nInfoUserCount && icqOnline()) {
time_t now = time(NULL);
BOOL bNotReady = FALSE, bTimeOuted = FALSE;
// Check the list, take only users that were there for at least 5sec
// wait if any user is there shorter than 5sec and not a single user is there longer than 20sec
infoUpdateMutex->Enter();
- for (i = 0; i<LISTSIZE; i++)
- {
- if (m_infoUpdateList[i].hContact)
- {
- if (m_infoUpdateList[i].queued + 20 < now)
- {
+ for (i = 0; i < LISTSIZE; i++) {
+ if (m_infoUpdateList[i].hContact) {
+ if (m_infoUpdateList[i].queued + 20 < now) {
bTimeOuted = TRUE;
break;
}
- else if (m_infoUpdateList[i].queued + 5 >= now)
+ if (m_infoUpdateList[i].queued + 5 >= now)
bNotReady = TRUE;
}
}
infoUpdateMutex->Leave();
- if (!bTimeOuted && bNotReady)
- {
+ if (!bTimeOuted && bNotReady) {
SleepEx(1000, TRUE);
- if (!bInfoUpdateRunning)
- { // need to end as fast as possible
+ if (!bInfoUpdateRunning) { // need to end as fast as possible
debugLogA("%s thread ended.", "Info-Update");
goto LBL_Exit;
}
continue;
}
- if (FindCookie(dwInfoActiveRequest, NULL, NULL))
- { // only send another request, when the previous is completed
+ // only send another request, when the previous is completed
+ if (FindCookie(dwInfoActiveRequest, NULL, NULL)) {
#ifdef _DEBUG
debugLogA("Info-Update: Request 0x%x still in progress.", dwInfoActiveRequest);
#endif
SleepEx(1000, TRUE);
- if (!bInfoUpdateRunning)
- { // need to end as fast as possible
+ if (!bInfoUpdateRunning) { // need to end as fast as possible
debugLogA("%s thread ended.", "Info-Update");
goto LBL_Exit;
}
@@ -270,14 +235,13 @@ void __cdecl CIcqProto::InfoUpdateThread( void* ) #endif
// Either some user is waiting long enough, or all users are ready (waited at least the minimum time)
m_ratesMutex->Enter();
- if (!m_rates)
- { // we cannot send info request - icq is offline
+ if (!m_rates) { // we cannot send info request - icq is offline
m_ratesMutex->Leave();
break;
}
+
WORD wGroup = m_rates->getGroupFromSNAC(ICQ_EXTENSIONS_FAMILY, ICQ_META_CLI_REQUEST);
- while (m_rates->getNextRateLevel(wGroup) < m_rates->getLimitLevel(wGroup, RML_IDLE_30))
- { // we are over rate, need to wait before sending
+ while (m_rates->getNextRateLevel(wGroup) < m_rates->getLimitLevel(wGroup, RML_IDLE_30)) { // we are over rate, need to wait before sending
int nDelay = m_rates->getDelayToLimitLevel(wGroup, RML_IDLE_50);
m_ratesMutex->Leave();
@@ -285,8 +249,7 @@ void __cdecl CIcqProto::InfoUpdateThread( void* ) debugLogA("Rates: InfoUpdate delayed %dms", nDelay);
#endif
SleepEx(nDelay, TRUE); // do not keep things locked during sleep
- if (!bInfoUpdateRunning)
- { // need to end as fast as possible
+ if (!bInfoUpdateRunning) { // need to end as fast as possible
debugLogA("%s thread ended.", "Info-Update");
goto LBL_Exit;
}
@@ -294,8 +257,7 @@ void __cdecl CIcqProto::InfoUpdateThread( void* ) if (!m_rates) // we lost connection when we slept, go away
break;
}
- if (!m_rates)
- { // we cannot send info request - icq is offline
+ if (!m_rates) { // we cannot send info request - icq is offline
m_ratesMutex->Leave();
break;
}
@@ -307,21 +269,16 @@ void __cdecl CIcqProto::InfoUpdateThread( void* ) int nRequestSize = 0;
infoUpdateMutex->Enter();
- for (i = 0; i<LISTSIZE; i++)
- {
- if (m_infoUpdateList[i].hContact)
- {
+ for (i = 0; i < LISTSIZE; i++) {
+ if (m_infoUpdateList[i].hContact) {
// check TS again, maybe it has been updated while we slept
- if (IsMetaInfoChanged(m_infoUpdateList[i].hContact))
- {
- if (m_infoUpdateList[i].queued + 5 < now)
- {
+ if (IsMetaInfoChanged(m_infoUpdateList[i].hContact)) {
+ if (m_infoUpdateList[i].queued + 5 < now) {
BYTE *pItem = NULL;
int nItemSize = 0;
- DBVARIANT dbv = {DBVT_DELETED};
+ DBVARIANT dbv = { DBVT_DELETED };
- if (!getSetting(m_infoUpdateList[i].hContact, DBSETTING_METAINFO_TOKEN, &dbv))
- { // retrieve user details using privacy token
+ if (!getSetting(m_infoUpdateList[i].hContact, DBSETTING_METAINFO_TOKEN, &dbv)) { // retrieve user details using privacy token
ppackTLV(&pItem, &nItemSize, 0x96, dbv.cpbVal, dbv.pbVal);
db_free(&dbv);
}
@@ -336,8 +293,7 @@ void __cdecl CIcqProto::InfoUpdateThread( void* ) hContactList[nListIndex++] = &m_infoUpdateList[i];
}
}
- else
- {
+ else {
#ifdef _DEBUG
debugLogA("Dequeued absolete user %u", m_infoUpdateList[i].dwUin);
#endif
@@ -353,21 +309,19 @@ void __cdecl CIcqProto::InfoUpdateThread( void* ) #ifdef _DEBUG
debugLogA("Request info for %u user(s).", nListIndex);
#endif
- if (!nListIndex)
- { // no users to request info for
+ if (!nListIndex) { // no users to request info for
infoUpdateMutex->Leave();
break;
}
- if (!(dwInfoActiveRequest = sendUserInfoMultiRequest(pRequestData, nRequestSize, nListIndex)))
- { // sending data packet failed
+
+ if (!(dwInfoActiveRequest = sendUserInfoMultiRequest(pRequestData, nRequestSize, nListIndex))) { // sending data packet failed
SAFE_FREE((void**)&pRequestData);
infoUpdateMutex->Leave();
break;
}
SAFE_FREE((void**)&pRequestData);
- for (i = 0; i<nListIndex; i++)
- { // Dequeue users and go back to sleep
+ for (i = 0; i < nListIndex; i++) { // Dequeue users and go back to sleep
hContactList[i]->dwUin = 0;
hContactList[i]->hContact = NULL;
hContactList[i]->queued = 0;
|