From c80bc292b555c6666930790c399f6fac6226c468 Mon Sep 17 00:00:00 2001
From: Vadim Dashevskiy <watcherhd@gmail.com>
Date: Sat, 21 Jul 2012 10:11:53 +0000
Subject: Skype and IMO2sProxy added, not adapted yet

git-svn-id: http://svn.miranda-ng.org/main/trunk@1091 1316c22d-e87f-b044-9b9b-93d7a3e3ba9c
---
 protocols/Skype/msgq.c | 90 ++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 90 insertions(+)
 create mode 100644 protocols/Skype/msgq.c

(limited to 'protocols/Skype/msgq.c')

diff --git a/protocols/Skype/msgq.c b/protocols/Skype/msgq.c
new file mode 100644
index 0000000000..48790e1c29
--- /dev/null
+++ b/protocols/Skype/msgq.c
@@ -0,0 +1,90 @@
+/*
+ * Implements a simple message queue for send and receive queue.
+ * We could use memlist.c, but it's not efficient 
+ * enough for this purpose (would always memmove on removing first
+ * element), therefore it's implemented as tail queue.
+ */
+
+#include "skype.h"
+#include "msgq.h"
+#include "debug.h"
+
+
+void MsgQ_Init(TYP_MSGQ *q)
+{
+	TAILQ_INIT(&q->l);
+	InitializeCriticalSection (&q->cs);
+}
+
+void MsgQ_Exit(TYP_MSGQ *q)
+{
+	struct MsgQueue *ptr;
+
+	EnterCriticalSection(&q->cs);
+	while (ptr=q->l.tqh_first)
+		free(MsgQ_RemoveMsg(q, ptr));
+	LeaveCriticalSection(&q->cs);
+	DeleteCriticalSection (&q->cs);
+}
+
+BOOL MsgQ_Add(TYP_MSGQ *q, char *msg)
+{
+	struct MsgQueue *ptr;
+
+	if (!(ptr=(struct MsgQueue*)malloc(sizeof(struct MsgQueue))))
+		return FALSE;
+	ptr->message = _strdup(msg); // Don't forget to free!
+	ptr->tAdded = SkypeTime(NULL);
+	SkypeTime(&ptr->tReceived);
+	EnterCriticalSection(&q->cs);
+	TAILQ_INSERT_TAIL(&q->l, ptr, l);
+	//LOG (("MsgQ_Add (%s) @%lu/%ld", msg, ptr->tReceived, ptr->tAdded));
+	LeaveCriticalSection(&q->cs);
+	return TRUE;
+}
+
+char *MsgQ_RemoveMsg(TYP_MSGQ *q, struct MsgQueue *ptr)
+{
+	char *msg;
+
+	if (!ptr) return NULL;
+	TAILQ_REMOVE(&q->l, ptr, l);
+	msg=ptr->message;
+	free(ptr);
+	return msg;
+}
+
+char *MsgQ_Get(TYP_MSGQ *q)
+{
+	char *msg;
+
+	EnterCriticalSection(&q->cs);
+	msg=MsgQ_RemoveMsg(q, q->l.tqh_first);
+	LeaveCriticalSection(&q->cs);
+	return msg;
+}
+
+int MsgQ_CollectGarbage(TYP_MSGQ *q, time_t age)
+{
+	struct MsgQueue *ptr;
+	int i=0;
+
+	EnterCriticalSection(&q->cs);
+	ptr=q->l.tqh_first;
+	while (ptr)
+	{
+		if (ptr->tAdded && SkypeTime(NULL)-ptr->tAdded>age)
+		{
+			struct MsgQueue *ptr_;
+			LOG(("GarbageCollector throwing out message: %s", ptr->message));
+			ptr_=ptr;
+			ptr=ptr->l.tqe_next;
+			free(MsgQ_RemoveMsg(q, ptr_));
+			i++;
+			continue;
+		}
+		ptr=ptr->l.tqe_next;
+	}
+	LeaveCriticalSection(&q->cs);
+	return i;
+}
-- 
cgit v1.2.3