diff options
| author | mataes2007 <mataes2007@e753b5eb-9565-29b2-b5c5-2cc6f99dfbcb> | 2011-05-04 19:12:23 +0000 |
|---|---|---|
| committer | mataes2007 <mataes2007@e753b5eb-9565-29b2-b5c5-2cc6f99dfbcb> | 2011-05-04 19:12:23 +0000 |
| commit | 036428b1f75d480617d5df454dc28a5adb941d26 (patch) | |
| tree | b6022e3c20886baee4948ce652e7a4fd2a087fdc /MRA/MraSendQueue.cpp | |
| parent | 7c7b7aad1fab29f8b9c56298c7f2815752ad47e1 (diff) | |
added MRA
git-svn-id: http://miranda-plugins.googlecode.com/svn/trunk@67 e753b5eb-9565-29b2-b5c5-2cc6f99dfbcb
Diffstat (limited to 'MRA/MraSendQueue.cpp')
| -rw-r--r-- | MRA/MraSendQueue.cpp | 225 |
1 files changed, 225 insertions, 0 deletions
diff --git a/MRA/MraSendQueue.cpp b/MRA/MraSendQueue.cpp new file mode 100644 index 0000000..de68943 --- /dev/null +++ b/MRA/MraSendQueue.cpp @@ -0,0 +1,225 @@ +#include "Mra.h"
+#include "MraSendQueue.h"
+
+
+
+
+typedef struct
+{
+ LIST_MT lmtListMT;
+ DWORD dwSendTimeOutInterval;
+} MRA_SEND_QUEUE;
+
+
+typedef struct
+{
+ // internal
+ LIST_MT_ITEM lmtListMTItem;
+ FILETIME ftSendTime;
+ // external
+ DWORD dwCMDNum;
+ DWORD dwFlags;
+ HANDLE hContact;
+ DWORD dwAckType;
+ LPBYTE lpbData;
+ SIZE_T dwDataSize;
+} MRA_SEND_QUEUE_ITEM;
+
+
+
+#define FILETIME_SECOND ((DWORDLONG)10000000)
+
+
+
+
+DWORD MraSendQueueInitialize(DWORD dwSendTimeOutInterval,HANDLE *phSendQueueHandle)
+{
+ DWORD dwRetErrorCode;
+
+ if (phSendQueueHandle)
+ {
+ MRA_SEND_QUEUE *pmrasqSendQueue;
+
+ pmrasqSendQueue=(MRA_SEND_QUEUE*)MEMALLOC(sizeof(MRA_SEND_QUEUE));
+ if (pmrasqSendQueue)
+ {
+ dwRetErrorCode=ListMTInitialize(&pmrasqSendQueue->lmtListMT,0);
+ if (dwRetErrorCode==NO_ERROR)
+ {
+ pmrasqSendQueue->dwSendTimeOutInterval=dwSendTimeOutInterval;
+ (*phSendQueueHandle)=(HANDLE)pmrasqSendQueue;
+ }
+ }else{
+ dwRetErrorCode=GetLastError();
+ }
+ }else{
+ dwRetErrorCode=ERROR_INVALID_HANDLE;
+ }
+return(dwRetErrorCode);
+}
+
+
+void MraSendQueueDestroy(HANDLE hSendQueueHandle)
+{
+ if (hSendQueueHandle)
+ {
+ MRA_SEND_QUEUE *pmrasqSendQueue=(MRA_SEND_QUEUE*)hSendQueueHandle;
+ MRA_SEND_QUEUE_ITEM *pmrasqiSendQueueItem;
+
+ ListMTLock(&pmrasqSendQueue->lmtListMT);
+ while(ListMTItemGetFirst(&pmrasqSendQueue->lmtListMT,NULL,(LPVOID*)&pmrasqiSendQueueItem)==NO_ERROR)
+ {
+ ListMTItemDelete(&pmrasqSendQueue->lmtListMT,&pmrasqiSendQueueItem->lmtListMTItem);
+ //MEMFREE(pmrasqiSendQueueItem->lpbData);
+ MEMFREE(pmrasqiSendQueueItem);
+ }
+ ListMTUnLock(&pmrasqSendQueue->lmtListMT);
+
+ ListMTDestroy(&pmrasqSendQueue->lmtListMT);
+ MEMFREE(pmrasqSendQueue);
+ }
+}
+
+
+DWORD MraSendQueueAdd(HANDLE hSendQueueHandle,DWORD dwCMDNum,DWORD dwFlags,HANDLE hContact,DWORD dwAckType,LPBYTE lpbData,SIZE_T dwDataSize)
+{
+ DWORD dwRetErrorCode;
+
+ if (hSendQueueHandle && dwCMDNum)
+ {
+ MRA_SEND_QUEUE *pmrasqSendQueue=(MRA_SEND_QUEUE*)hSendQueueHandle;
+ MRA_SEND_QUEUE_ITEM *pmrasqiSendQueueItem;
+
+ pmrasqiSendQueueItem=(MRA_SEND_QUEUE_ITEM*)MEMALLOC(sizeof(MRA_SEND_QUEUE_ITEM));
+ if (pmrasqiSendQueueItem)
+ {
+ //pmrasqiSendQueueItem->lmtListMTItem;
+ GetSystemTimeAsFileTime(&pmrasqiSendQueueItem->ftSendTime);
+ pmrasqiSendQueueItem->dwCMDNum=dwCMDNum;
+ pmrasqiSendQueueItem->dwFlags=dwFlags;
+ pmrasqiSendQueueItem->hContact=hContact;
+ pmrasqiSendQueueItem->dwAckType=dwAckType;
+ pmrasqiSendQueueItem->lpbData=lpbData;
+ pmrasqiSendQueueItem->dwDataSize=dwDataSize;
+
+ ListMTLock(&pmrasqSendQueue->lmtListMT);
+ ListMTItemAdd(&pmrasqSendQueue->lmtListMT,&pmrasqiSendQueueItem->lmtListMTItem,pmrasqiSendQueueItem);
+ ListMTUnLock(&pmrasqSendQueue->lmtListMT);
+ dwRetErrorCode=NO_ERROR;
+ }else{
+ dwRetErrorCode=GetLastError();
+ }
+ }else{
+ dwRetErrorCode=ERROR_INVALID_HANDLE;
+ }
+return(dwRetErrorCode);
+}
+
+
+DWORD MraSendQueueFree(HANDLE hSendQueueHandle,DWORD dwCMDNum)
+{
+ DWORD dwRetErrorCode;
+
+ if (hSendQueueHandle)
+ {
+ MRA_SEND_QUEUE *pmrasqSendQueue=(MRA_SEND_QUEUE*)hSendQueueHandle;
+ MRA_SEND_QUEUE_ITEM *pmrasqiSendQueueItem;
+ LIST_MT_ITERATOR lmtiIterator;
+
+ dwRetErrorCode=ERROR_NOT_FOUND;
+ ListMTLock(&pmrasqSendQueue->lmtListMT);
+ ListMTIteratorMoveFirst(&pmrasqSendQueue->lmtListMT,&lmtiIterator);
+ do
+ {// цикл
+ if (ListMTIteratorGet(&lmtiIterator,NULL,(LPVOID*)&pmrasqiSendQueueItem)==NO_ERROR)
+ if (pmrasqiSendQueueItem->dwCMDNum==dwCMDNum)
+ {
+ ListMTItemDelete(&pmrasqSendQueue->lmtListMT,&pmrasqiSendQueueItem->lmtListMTItem);
+ //MEMFREE(pmrasqiSendQueueItem->lpbData);
+ MEMFREE(pmrasqiSendQueueItem);
+ dwRetErrorCode=NO_ERROR;
+ break;
+ }
+ }while(ListMTIteratorMoveNext(&lmtiIterator));
+ ListMTUnLock(&pmrasqSendQueue->lmtListMT);
+ }else{
+ dwRetErrorCode=ERROR_INVALID_HANDLE;
+ }
+return(dwRetErrorCode);
+}
+
+
+DWORD MraSendQueueFind(HANDLE hSendQueueHandle,DWORD dwCMDNum,DWORD *pdwFlags,HANDLE *phContact,DWORD *pdwAckType,LPBYTE *plpbData,SIZE_T *pdwDataSize)
+{
+ DWORD dwRetErrorCode;
+
+ if (hSendQueueHandle)
+ {
+ MRA_SEND_QUEUE *pmrasqSendQueue=(MRA_SEND_QUEUE*)hSendQueueHandle;
+ MRA_SEND_QUEUE_ITEM *pmrasqiSendQueueItem;
+ LIST_MT_ITERATOR lmtiIterator;
+
+ dwRetErrorCode=ERROR_NOT_FOUND;
+ ListMTLock(&pmrasqSendQueue->lmtListMT);
+ ListMTIteratorMoveFirst(&pmrasqSendQueue->lmtListMT,&lmtiIterator);
+ do
+ {// цикл
+ if (ListMTIteratorGet(&lmtiIterator,NULL,(LPVOID*)&pmrasqiSendQueueItem)==NO_ERROR)
+ if (pmrasqiSendQueueItem->dwCMDNum==dwCMDNum)
+ {
+ if (pdwFlags) (*pdwFlags)=pmrasqiSendQueueItem->dwFlags;
+ if (phContact) (*phContact)=pmrasqiSendQueueItem->hContact;
+ if (pdwAckType) (*pdwAckType)=pmrasqiSendQueueItem->dwAckType;
+ if (plpbData) (*plpbData)=pmrasqiSendQueueItem->lpbData;
+ if (pdwDataSize) (*pdwDataSize)=pmrasqiSendQueueItem->dwDataSize;
+ dwRetErrorCode=NO_ERROR;
+ break;
+ }
+ }while(ListMTIteratorMoveNext(&lmtiIterator));
+ ListMTUnLock(&pmrasqSendQueue->lmtListMT);
+ }else{
+ dwRetErrorCode=ERROR_INVALID_HANDLE;
+ }
+return(dwRetErrorCode);
+}
+
+
+DWORD MraSendQueueFindOlderThan(HANDLE hSendQueueHandle,DWORD dwTime,DWORD *pdwCMDNum,DWORD *pdwFlags,HANDLE *phContact,DWORD *pdwAckType,LPBYTE *plpbData,SIZE_T *pdwDataSize)
+{
+ DWORD dwRetErrorCode;
+
+ if (hSendQueueHandle)
+ {
+ FILETIME ftExpireTime;
+ MRA_SEND_QUEUE *pmrasqSendQueue=(MRA_SEND_QUEUE*)hSendQueueHandle;
+ MRA_SEND_QUEUE_ITEM *pmrasqiSendQueueItem;
+ LIST_MT_ITERATOR lmtiIterator;
+
+ GetSystemTimeAsFileTime(&ftExpireTime);
+ (*((DWORDLONG*)&ftExpireTime))-=((DWORDLONG)dwTime*FILETIME_SECOND);
+ dwRetErrorCode=ERROR_NOT_FOUND;
+ ListMTLock(&pmrasqSendQueue->lmtListMT);
+ ListMTIteratorMoveFirst(&pmrasqSendQueue->lmtListMT,&lmtiIterator);
+ do
+ {// цикл
+ if (ListMTIteratorGet(&lmtiIterator,NULL,(LPVOID*)&pmrasqiSendQueueItem)==NO_ERROR)
+ if ((*((DWORDLONG*)&ftExpireTime))>(*((DWORDLONG*)&pmrasqiSendQueueItem->ftSendTime)))
+ {
+ if (pdwCMDNum) (*pdwCMDNum)=pmrasqiSendQueueItem->dwCMDNum;
+ if (pdwFlags) (*pdwFlags)=pmrasqiSendQueueItem->dwFlags;
+ if (phContact) (*phContact)=pmrasqiSendQueueItem->hContact;
+ if (pdwAckType) (*pdwAckType)=pmrasqiSendQueueItem->dwAckType;
+ if (plpbData) (*plpbData)=pmrasqiSendQueueItem->lpbData;
+ if (pdwDataSize) (*pdwDataSize)=pmrasqiSendQueueItem->dwDataSize;
+ dwRetErrorCode=NO_ERROR;
+ break;
+ }
+ }while(ListMTIteratorMoveNext(&lmtiIterator));
+ ListMTUnLock(&pmrasqSendQueue->lmtListMT);
+ }else{
+ dwRetErrorCode=ERROR_INVALID_HANDLE;
+ }
+return(dwRetErrorCode);
+}
+
+
|