first commit

2026-08-05 06:23:09 +00:00 · 2014-08-20 16:15:02 +08:00
commit f61e330e38
1633 changed files with 119931 additions and 0 deletions
@@ -0,0 +1,204 @@
+/***************************************************************
+* 
+*
+*  作者：   王少培
+*  文件名：   NetHookManager.cpp
+*  创建时间： 2014-3-20
+*
+***************************************************************/
+#include <assert.h>
+#include <stdio.h>
+#include <stdlib.h>
+
+#include "NetFactory.h"
+#include "GameShare_NetSystem.h"
+#include "NetHttpClient.h"
+#include "NetPacket.h"
+#include "ScopeLock.h"
+#include "NetListProcess.h"
+static CNetFactory* spNetFactory = NULL;
+//////////////////////////////////////////////////////////////////////////
+void CHttpInfo::clr()
+{
+
+}
+CHttpInfo::~CHttpInfo()
+{
+	if (mpPacket)
+	{
+		delete mpPacket;
+		mpPacket = NULL;
+	}
+}
+//////////////////////////////////////////////////////////////////////////
+ CHttpInfo* CNetFactory::createHttpInfo(INetEvent* pEvent)
+ {
+	 return new CHttpInfo(pEvent);
+ }
+
+bool CNetFactory::addToPool(CHttpInfo *pInfo) {
+	ScopeLock lock(mLock);
+	NetInfoList::iterator it = mNetInfoList.begin();
+	for (;it!=mNetInfoList.end();++it)
+	{
+		if (*it == pInfo)
+			return false;
+	}
+	mNetInfoList.push_back(pInfo);
+    pthread_cond_signal(&s_SleepCondition);
+	 return true;
+}
+int CNetFactory::getNetInfoListAmount()
+{
+	ScopeLock lock(mLock);
+	return mNetInfoList.size();
+}
+void CNetFactory::releaseFromPool(CHttpInfo *pInfo,bool bDel) {
+	ScopeLock lock(mLock);
+	NetInfoList::iterator it = mNetInfoList.begin();
+	for (;it!=mNetInfoList.end();)
+	{
+		CHttpInfo* pTemp = *it;
+		if (pTemp == pInfo)
+		{
+			if (bDel)
+			{
+				delete pTemp;
+				pTemp = NULL;
+			}
+			mNetInfoList.erase(it++);
+			//break;
+		}else
+		{
+			++it;
+		}
+	}
+	return ;
+}
+void CNetFactory::processNetEvent()
+{
+	do 
+	{
+        if(mbQuit)
+            break;
+		if (!mNetInfoList.empty())
+		{
+			CHttpInfo* pTemp = NULL;
+			{
+				ScopeLock lock(mLock);
+				pTemp = mNetInfoList.front();
+				mNetInfoList.pop_front();
+				if(pTemp == NULL)
+					return;
+			}
+            
+			std::string strResult;
+			if(pTemp->getPacket())
+				strResult = GameShare_NetSystem::ShareNetSystem()->NetSystem_HTTPRequest(pTemp->getUrl().c_str(),pTemp->getPacket()->getContent().c_str());
+			else
+				strResult = GameShare_NetSystem::ShareNetSystem()->NetSystem_HTTPRequest(pTemp->getUrl().c_str());
+			pTemp->setReceData(strResult.c_str());
+			CNetListProcess::sharedInstance().addToPool(pTemp);
+		}
+		else
+        {
+            CCLOG("pthread_cond_wait");
+            pthread_cond_wait(&s_SleepCondition, &s_SleepMutex);
+        }
+//#ifdef _WIN32
+//			Sleep(50);
+//#else
+//			usleep(50);
+//#endif
+	} while (true);
+    
+    pthread_mutex_destroy(&s_SleepMutex);
+    pthread_cond_destroy(&s_SleepCondition);
+}
+void CNetFactory::processNetEventEx()
+{
+    do
+	{
+		if (!mNetInfoList.empty())
+		{
+			CHttpInfo* pTemp = NULL;
+			{
+				ScopeLock lock(mLock);
+				pTemp = mNetInfoList.front();
+				mNetInfoList.pop_front();
+				if(pTemp == NULL)
+					return;
+			}
+            
+			std::string strResult;
+			if(pTemp->getPacket())
+            {
+                CCHttpRequest* request = new CCHttpRequest();
+                request->setUrl(pTemp->getUrl().c_str());
+                request->setRequestType(CCHttpRequest::kHttpPost);
+                request->setResponseCallback(this, httpresponse_selector(CNetFactory::httpRequestComplete));
+                request->setTag("REQUSET GAME DATA");
+                CCHttpClient::getInstance()->send(request);
+                request->release();
+            }
+////				strResult = GameShare_NetSystem::ShareNetSystem()->NetSystem_HTTPRequest(pTemp->getUrl().c_str(),pTemp->getPacket()->getContent().c_str());
+//			else
+//				strResult = GameShare_NetSystem::ShareNetSystem()->NetSystem_HTTPRequest(pTemp->getUrl().c_str());
+//			pTemp->setReceData(strResult.c_str());
+//			CNetListProcess::sharedInstance().addToPool(pTemp);
+		}
+	} while (true);
+}
+void CNetFactory::httpRequestComplete(CCHttpClient *sender, CCHttpResponse *response)
+{
+	if (!response)
+	{
+		CCLOG("CCHttpResponse is null");
+		return;
+	}
+    
+	// You can get original request type from: response->request->reqType
+	if (0 != strlen(response->getHttpRequest()->getTag()))
+	{
+		CCLog("%s completed", response->getHttpRequest()->getTag());
+	}
+    
+	int statusCode = response->getResponseCode();
+	char statusString[64] = {};
+	sprintf(statusString, "HTTP Status Code: %d, tag = %s", statusCode, response->getHttpRequest()->getTag());
+	CCLog("response code: %d", statusCode);
+    
+	if (!response->isSucceed())
+	{
+		CCLog("response failed");
+		CCLog("error buffer: %s", response->getErrorBuffer());
+		return;
+	}
+        // dump data
+        std::vector<char> *buffer = response->getResponseData();
+        std::string path = CCFileUtils::sharedFileUtils()->getWritablePath();
+        std::string buf(buffer->begin(),buffer->end());
+
+}
+void CNetFactory::run()
+{
+	processNetEvent();
+
+}
+void CNetFactory::start()
+{
+    pthread_mutex_init(&s_SleepMutex, NULL);
+    pthread_cond_init(&s_SleepCondition, NULL);
+    CRunable::start();
+}
+CNetFactory *CNetFactory::sharedInstance() {
+	if (spNetFactory == NULL)
+	{
+		spNetFactory  = new CNetFactory;
+		spNetFactory->start();
+	}
+  return spNetFactory;
+}
+
+CNetFactory::CNetFactory():mbQuit(false) {
+}