first commit

Author: root

CCountingSem.cpp

@@ -0,0 +1,22 @@
+
+
+#include "CCountingSem.h"
+
+
+
+
+
+CCountingSem::CCountingSem()
+{
+
+}
+
+
+
+CCountingSem::~CCountingSem()
+{
+
+
+}
+
+

CCountingSem.h

@@ -0,0 +1,48 @@
+
+
+#ifndef _CCountingSem_h_
+#define _CCountingSem_h_
+
+/********************************************************************************************
+*
+*File name: CCountingSem.h
+*Author: Wu Yinghao
+*Version: 0.0.1
+*Date: 2013.5.20
+*E-Mail: [email protected]
+*Description: this file is base class of CountingSem
+*
+********************************************************************************************/
+
+class CCountingSem
+{
+	public:
+		typedef enum {
+       	 kTimeout,
+        	 kForever
+    		}Mode;                     
+
+
+		CCountingSem();
+		~CCountingSem();
+
+		 //get the sem and sem -1
+		 virtual bool Get(Mode mode = kForever, unsigned long timeoutMS = 0) = 0;
+
+		 //post the sem and sem +1
+    	 virtual bool Post(void) = 0;
+
+};
+
+
+
+
+
+
+
+
+
+#endif
+
+
+

CLinuxCountingSem.cpp

@@ -0,0 +1,48 @@
+
+#include "CLinuxCountingSem.h"
+#include <stdio.h>
+#include <stdlib.h>
+
+
+
+CLinuxCountingSem::CLinuxCountingSem(unsigned int init_sem_count):
+CCountingSem()
+{
+	int result;
+    	result = sem_init(&sem, 0, init_sem_count);
+		
+	    if (result != 0) {
+	        printf("CLinuxCountingSem:  error\n");
+	       
+	    }
+
+
+}
+
+
+CLinuxCountingSem::~CLinuxCountingSem()
+{
+
+
+}
+
+
+bool CLinuxCountingSem::Get(Mode mode , unsigned long )
+{
+    
+	 if(sem_wait(&sem)==0)
+	 	return true;
+	 else
+	 	return false;
+
+
+}
+
+
+bool CLinuxCountingSem::Post()
+{
+	sem_post(&sem);
+    	return true;
+
+}
+

CLinuxCountingSem.h

@@ -0,0 +1,60 @@
+
+
+
+#ifndef _CLinuxCountingSem_h_
+#define _CLinuxCountingSem_h_
+
+/********************************************************************************************
+*
+*File name: CLinuxCountingSem.h
+*Author: Wu Yinghao
+*Version: 0.0.1
+*Date: 2013.5.20
+*E-Mail: [email protected]
+*Description: this file is linux sem class which inheritance from CCountingSem
+*
+********************************************************************************************/
+
+#include "CCountingSem.h"
+
+
+#include <sys/time.h>
+#include <sys/types.h>
+#include <pthread.h>
+#include <semaphore.h>
+#include <time.h>
+#include <unistd.h>
+#include <errno.h>
+
+
+class CLinuxCountingSem:public CCountingSem
+{
+	public:
+		CLinuxCountingSem(unsigned int init_sem_count);
+		~CLinuxCountingSem();
+
+
+		 virtual bool                Get(Mode mode = kForever, unsigned long timeoutMS = 0) ;
+
+    		 virtual bool                Post(void) ;
+
+
+
+
+	private:
+
+		sem_t		sem;
+
+
+};
+
+
+
+
+
+
+
+#endif
+
+
+

CLinuxMsgQueue.cpp

@@ -0,0 +1,88 @@
+
+
+#include "CLinuxMsgQueue.h"
+#include "COperatingSystemFactory.h"
+
+
+CLinuxMsgQueue::CLinuxMsgQueue(const char *pName):
+CMsgQueue(pName)
+{
+
+	p_mutex=COperatingSystemFactory::newMutex("Msg Mutex");
+	p_sem=COperatingSystemFactory::newCountingSem(0);
+
+
+}
+
+
+
+CLinuxMsgQueue::~CLinuxMsgQueue()
+{
+
+}
+
+
+
+
+
+bool CLinuxMsgQueue::recvMsg(unsigned int &m_msg_code,void *&p_msg)
+{
+
+ 	bool result;
+    	Elements queue_element;
+
+	p_sem->Get();
+
+	p_mutex->Lock();
+   
+	if (m_queue.empty()) {
+	    
+
+	    	return false;
+	    
+	}
+
+
+	queue_element = m_queue.front();
+	m_queue.pop_front();
+
+
+	m_msg_code = queue_element.msg_code;
+	p_msg = queue_element.p_message;
+
+	p_mutex->UnLock();
+
+    return true;
+
+
+}
+
+
+
+
+bool CLinuxMsgQueue::sendMsg(unsigned int m_msg_code,void *p_msg)
+{
+	bool result;
+    	Elements queue_element;
+
+	
+
+	queue_element.msg_code=m_msg_code;
+	queue_element.p_message=p_msg;
+
+	p_mutex->Lock();
+
+	m_queue.push_back(queue_element);
+
+
+	p_mutex->UnLock();
+
+	p_sem->Post();
+
+
+    return true;
+
+
+}
+
+

CLinuxMsgQueue.h

@@ -0,0 +1,42 @@
+
+
+#ifndef _CLinuxMsg_h_
+#define _CLinuxMsg_h_
+#include <deque>
+#include "CMsgQueue.h"
+#include "CMutex.h"
+#include "CCountingSem.h"
+
+
+class CLinuxMsgQueue : public CMsgQueue
+{
+	public:
+		CLinuxMsgQueue(const char *pName=NULL);
+		~CLinuxMsgQueue();
+
+		virtual bool recvMsg(unsigned int &m_msg_code,void *&p_msg);
+		virtual bool sendMsg(unsigned int m_msg_code,void *p_msg);
+
+	private:
+
+		 std::deque<Elements>            m_queue;
+
+		 
+		CMutex	*p_mutex;
+		CCountingSem *p_sem;
+
+};
+
+
+
+
+
+
+
+
+
+
+#endif
+
+
+

CLinuxMutex.cpp

@@ -0,0 +1,85 @@
+
+
+
+
+#include "CLinuxMutex.h"
+
+
+
+
+
+CLinuxMutex::CLinuxMutex(const char *pName):
+CMutex(pName)
+{
+
+	m_thread = (pthread_t) 0;
+
+    	pthread_mutexattr_init(&m_mtex_attr);
+    	if (pthread_mutexattr_settype(&m_mtex_attr, PTHREAD_MUTEX_ERRORCHECK_NP))
+        	printf("CLinuxMutex::CnlLinuxMutex() : Failed to set mutex attibutes\n");
+               
+
+   	 pthread_mutex_init(&m_mutex, &m_mtex_attr);
+
+
+
+}
+
+
+CLinuxMutex::~CLinuxMutex()
+{
+
+}
+
+bool CLinuxMutex::Lock()
+{
+
+	bool locked     = false;
+    	int result;
+    
+        
+        result = pthread_mutex_lock(&m_mutex);
+    
+
+    switch (result) {
+      case 0:
+        m_thread = pthread_self();
+
+        locked = true;
+        break;
+      case EDEADLK:
+        locked = true;
+        break;
+      default:
+        break;
+    }
+
+    return locked;
+
+}
+
+bool CLinuxMutex::UnLock()
+{
+	int result;
+    	bool unlocked   = true;
+
+	    if (m_thread!= pthread_self()) {
+	        unlocked = false;
+	        printf("CnlLinuxMutex::Unlock() :  Error - Mutex not locked or not owned by the thread! \n");
+
+	    } else {
+	         result = pthread_mutex_unlock(&m_mutex);
+		  if(result<0)
+		  	unlocked=false;
+	    }
+    	return unlocked;
+
+}
+
+
+
+
+
+
+
+