开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 游戏 > 模拟服务器 > 查看源码
KSynDataSet.cpp
资源名称：SwordOnline.rar　[点击查看]
上传用户：dzyhzl
上传日期：2019-04-29
资源大小：56270k
文件大小：13k
源码类别：

模拟服务器

开发平台：

C/C++

KSynDataSet.cpp：源码内容
  1. // KSynDataSet.cpp: implementation of the KSynDataSet class.
  2. //
  3. //////////////////////////////////////////////////////////////////////
  5. #include "KSynDataSet.h"
  6. #include "KSynDataSets.h"
  7. #include "iostream.h"
  9. //////////////////////////////////////////////////////////////////////
  10. // Construction/Destruction
  11. //////////////////////////////////////////////////////////////////////
  12. //#define printf ;
  13. extern FILE * stream;
  14. extern FILE * stream1;
  17. extern CORBA::ORB_var g_Orb;
  19. CORBA::Object_ptr  GetObjectReference(char * szObjName, char * szObjType, CORBA::ORB_ptr orb);
  20. CORBA::Boolean BindObjectToName(CORBA::ORB_ptr orb, CORBA::Object_ptr objref, char * ObjName, char * ObjType);
  21. KSynDataSet::KSynDataSet()
  22. {
  23. m_nTopIndex = 0;
  24. for(long i = 0; i < MAX_UNITNUM; i++)
  25. {
  27. m_Sets[i] = NULL;
  29. }
  31. }
  33. KSynDataSet::~KSynDataSet()
  34. {
  36. }
  39. //
  40. CORBA::Long KSynDataSet::Lock(CORBA::Long id, const char* ObjName)
  41. {
  42. long lockid = 0;
  44. HANDLE hevent;
  45. char e_name[20];
  47. itoa(id, e_name,10);
  48. //同时只能有一个线程申请Lock服务。
  49. hevent = OpenEvent(EVENT_ALL_ACCESS, FALSE, e_name);
  50. if (!hevent)
  51. hevent = CreateEvent(NULL,TRUE,TRUE,e_name);
  53. if (!hevent)
  54. hevent = OpenEvent(EVENT_ALL_ACCESS, FALSE, e_name);
  56. WaitForSingleObject(hevent,INFINITE);
  58. if ((lockid = m_LockSets[id].Lock()) < 0)
  59. {
  60. LockInfoNode * pNode = new LockInfoNode;
  61. pNode->id = id;
  62. pNode->index =  -1 * lockid;
  63. pNode->pServer = NULL;
  65. long ServerId = g_FileName2Id((char *)ObjName);
  67. TServerNode *pServerData = NULL; 
  70. if(!m_ServerList.IsEmpty())
  71. {
  72. //在服务对象列表中查找是否有一致id的服务器对象
  73. for( pServerData = (TServerNode*) m_ServerList.GetHead(); pServerData != NULL; )
  74. {
  75. if (pServerData->ServerId == ServerId)
  76. {
  78. pNode->pServer = pServerData->pServer;
  79. break;
  81. }
  82. pServerData = (TServerNode *) pServerData->GetNext();
  83. }
  84. if (!pNode->pServer)
  85. {
  86. }
  87. }
  88. else 
  89. {
  91. }
  93. //未找到的话
  94. if (!pNode->pServer)//Server  is Not Exist ,Then Build a New Server Connection
  95. {
  96. char cString[100];
  97. strcpy(cString,ObjName); 
  98. char * sName = cString;
  99. char * sType = strstr(cString, ".");
  100. sType ++;
  101. cString[sType - sName - 1] = '';
  103. CORBA::Object_ptr obj_ptr = GetObjectReference(sName,sType,g_Orb);
  104. // printf("Servername is %s,%s and %sn",ObjName,sName,sType);
  106. if (obj_ptr)
  107. {
  108. TServerNode * pNewServer = new TServerNode;
  109. pNewServer->pServer = ReqServer::_narrow(obj_ptr);
  110. pNewServer->ServerId = ServerId;
  111. pNode->pServer = pNewServer->pServer;
  112. m_ServerList.AddTail((KNode*) pNewServer);
  114. }
  115. else
  116. {
  118. SetEvent(hevent);
  119. return -100000;
  120. }
  122. }
  124. m_ReqLockList.AddTail((KNode*)pNode);
  127. }
  129. SetEvent(hevent);
  130. return lockid;
  131. }
  134. CORBA::Long KSynDataSet::UnLock(CORBA::Long id, CORBA::Long index)  
  135. {
  137. HANDLE hevent;
  138. char e_name[20];
  139. e_name[0]='U';
  141. itoa(id, e_name+1,10);
  144. //同时只能有一个线程申请UnLock服务
  145. hevent = OpenEvent(EVENT_ALL_ACCESS, FALSE, e_name);
  146. if (!hevent)
  147. hevent = CreateEvent(NULL,TRUE,TRUE,e_name);
  148. WaitForSingleObject(hevent,INFINITE);
  151. LockInfoNode *pNode;
  154. fflush(stream);
  155. fflush(stream1);
  158. if (m_LockSets[id].UnLock(index) == TRUE)//如果本次解锁成功
  159. {
  162. if(!m_ReqLockList.IsEmpty())
  163. {
  164. ///在数据锁定请求列表中找到下一个请求相关的对象，并调用通知其。
  167. if (m_LockSets[id].GetCurId() > 0)
  168. {
  169. for( pNode = (LockInfoNode*) m_ReqLockList.GetHead(); pNode != NULL; )
  170. {
  171. if (pNode->id == id && pNode->index == m_LockSets[id].GetCurId()) 
  172. {
  174. pNode->pServer->SendResult(id, m_LockSets[id].GetCurId(),0);
  176. pNode->Remove();
  177. SetEvent(hevent);
  178. return 1;
  179. }
  181. pNode = (LockInfoNode *) pNode->GetNext();
  182. }
  186. }
  189. }
  190. else
  191. {
  193. }
  196. SetEvent(hevent);
  197. return 1;
  199. }
  200. else 
  201. {
  203. SetEvent(hevent);
  204. return -1;
  205. }
  206. SetEvent(hevent);
  209. }
  215. CORBA::Any* KSynDataSet::GetData(CORBA::Long id) 
  216. {
  217. CORBA::Any* result = new CORBA::Any;
  218. *result = m_Sets[id]->GetData();
  219. return result;
  221. }
  223. CORBA::Any* KSynDataSet::GetDataWithLock(CORBA::Long id, CORBA::Long& Result, const char* ObjName) 
  224. {
  227. if ((Result = Lock(id,ObjName)) > 0)
  228. {
  229. return GetData(id);
  230. }
  231. else
  232. {
  233. return NULL;
  234. }
  236. }
  238. CORBA::Long KSynDataSet::SetData(CORBA::Long id, const CORBA::Any& data) 
  239. {
  240. m_Sets[id]->SetData(data);
  241. return 1;
  242. }
  244. CORBA::Long KSynDataSet::SetDataWithLock(CORBA::Long id, const CORBA::Any& data, CORBA::Long& Result, const char* ObjName) 
  245. {
  248. if ( (Result = Lock(id,ObjName)) > 0)
  249. {
  251. SetData(id,data);
  252. return Result;
  253. }
  254. else
  255. return Result;
  258. }
  260. CORBA::Long KSynDataSet::SetDataWithOnce(CORBA::Long id, const CORBA::Any& data, CORBA::Long& Result, const char* ObjName) 
  261. {
  263. long nLockId;
  264. if ((nLockId = Lock(id,ObjName)) > 0)
  265. {
  266. SetData(id,data);
  267. UnLock(id, nLockId);
  268. Result = nLockId;
  269. return Result;
  270. }
  272. else 
  273. {
  274. if (nLockId < 0){};
  275. Result = nLockId;
  276. return nLockId;
  277. }
  279. }
  281. CORBA::Any* KSynDataSet::GetDataWithOnce(CORBA::Long id, CORBA::Long& Result, const char* ObjName) 
  282. {
  283. CORBA::Any *result;
  285. if ((Result = Lock(id,ObjName)) > 0)
  286. {
  287. result = GetData(id);
  288. UnLock(id,Result);
  289. return result;
  290. }
  291. else
  292. return NULL;
  294. }
  300. CORBA::Object_ptr  GetObjectReference(char * szObjName, char * szObjType, CORBA::ORB_ptr orb)
  301. {
  302. CosNaming::NamingContext_var rootContext;
  304. try {
  305. // Obtain a reference to the root context of the Name service:
  306. CORBA::Object_var obj;
  307. obj = orb->resolve_initial_references("NameService");
  309. // Narrow the reference returned.
  310. rootContext = CosNaming::NamingContext::_narrow(obj);
  311. if( CORBA::is_nil(rootContext) ) {
  312. cerr << "Failed to narrow the root naming context." << endl;
  313. return CORBA::Object::_nil();
  314. }
  315. }
  316. catch(CORBA::ORB::InvalidName& ex) {
  317. // This should not happen!
  318. cerr << "Service required is invalid [does not exist]." << endl;
  319. return CORBA::Object::_nil();
  320. }
  323. // Create a name object, containing the name test/context:
  324. CosNaming::Name name;
  325. name.length(2);
  327. name[0].id   = (const char*) "test";       // string copied
  328. name[0].kind = (const char*) "my_context"; // string copied
  329. name[1].id   = (const char*) szObjName;//"CorbaPartical";
  330. name[1].kind = (const char*) szObjType;//"Object";
  331. // Note on kind: The kind field is used to indicate the type
  332. // of the object. This is to avoid conventions such as that used
  333. // by files (name.type -- e.g. test.ps = postscript etc.)
  336. try {
  337. // Resolve the name to an object reference.
  338. return rootContext->resolve(name);
  339. }
  340. catch(CosNaming::NamingContext::NotFound& ex) {
  341. // This exception is thrown if any of the components of the
  342. // path [contexts or the object] aren't found:
  343. cerr << "Context not found." << endl;
  344. }
  345. catch(CORBA::COMM_FAILURE& ex) {
  346. cerr << "Caught system exception COMM_FAILURE -- unable to contact the "
  347. << "naming service." << endl;
  348. }
  349. catch(CORBA::SystemException&) {
  350. cerr << "Caught a CORBA::SystemException while using the naming service."
  351. << endl;
  352. }
  353. }
  357. CORBA::Boolean BindObjectToName(CORBA::ORB_ptr orb, CORBA::Object_ptr objref, char * ObjName, char * ObjType)
  358. {
  359. CosNaming::NamingContext_var rootContext;
  361. try {
  362. // Obtain a reference to the root context of the Name service:
  363. CORBA::Object_var obj;
  364. obj = orb->resolve_initial_references("NameService");
  366. // Narrow the reference returned.
  367. rootContext = CosNaming::NamingContext::_narrow(obj);
  368. if( CORBA::is_nil(rootContext) ) {
  369. cerr << "Failed to narrow the root naming context." << endl;
  370. return 0;
  371. }
  372. }
  373. catch(CORBA::ORB::InvalidName& ex) {
  374. // This should not happen!
  375. cerr << "Service required is invalid [does not exist]." << endl;
  376. return 0;
  377. }
  380. try {
  381. // Bind a context called "test" to the root context:
  384. CosNaming::Name contextName;
  385. contextName.length(1);
  386. contextName[0].id   = (const char*) "test";       // string copied
  387. contextName[0].kind = (const char*) "my_context"; // string copied
  389. // Note on kind: The kind field is used to indicate the type
  390. // of the object. This is to avoid conventions such as that used
  391. // by files (name.type -- e.g. test.ps = postscript etc.)
  393. CosNaming::NamingContext_var testContext;
  394. try {
  395. // Bind the context to root.
  396. testContext = rootContext->bind_new_context(contextName);
  397. }
  398. catch(CosNaming::NamingContext::AlreadyBound& ex) {
  399. // If the context already exists, this exception will be raised.
  400. // In this case, just resolve the name and assign testContext
  401. // to the object returned:
  402. CORBA::Object_var obj;
  403. obj = rootContext->resolve(contextName);
  404. testContext = CosNaming::NamingContext::_narrow(obj);
  405. if( CORBA::is_nil(testContext) ) {
  406. cerr << "Failed to narrow d context." << endl;
  407. return 0;
  408. }
  409. }
  412. // Bind objref with name Echo to the testContext:
  413. CosNaming::Name objectName;
  414. objectName.length(1);
  415. objectName[0].id   = (const char*) ObjName; //"CorbaPartical";   // string copied
  416. objectName[0].kind = (const char*) ObjType;//"Object"; // string copied
  418. try {
  419. testContext->bind(objectName, objref);
  420. }
  421. catch(CosNaming::NamingContext::AlreadyBound& ex) {
  422. testContext->rebind(objectName, objref);
  423. }
  424. // Note: Using rebind() will overwrite any Object previously bound
  425. //       to /test/Echo with obj.
  426. //       Alternatively, bind() can be used, which will raise a
  427. //       CosNaming::NamingContext::AlreadyBound exception if the name
  428. //       supplied is already bound to an object.
  430. // Amendment: When using OrbixNames, it is necessary to first try bind
  431. // and then rebind, as rebind on it's own will throw a NotFoundexception if
  432. // the Name has not already been bound. [This is incorrect behaviour -
  433. // it should just bind].
  434. }
  435. catch(CORBA::COMM_FAILURE& ex) {
  436. cerr << "Caught system exception COMM_FAILURE -- unable to contact the "
  437. << "naming service." << endl;
  438. return 0;
  439. }
  440. catch(CORBA::SystemException&) {
  441. cerr << "Caught a CORBA::SystemException while using the naming service."
  442. << endl;
  443. return 0;
  444. }
  446. return 1;
  447. }
  450. CORBA::Any* KSynDataSet::GetDataMember(CORBA::Long id,CORBA::Long MemberId)
  451. {
  452. CORBA::Any* result = new CORBA::Any;
  454. *result = m_Sets[id]->GetDataMember(MemberId);
  456. return result;
  458. }
  460. CORBA::Long KSynDataSet::SetDataMember(CORBA::Long id, CORBA::Long MemberId, const CORBA::Any& data) 
  461. {
  462. m_Sets[id]->SetDataMember(MemberId, data);
  464. return 1;
  466. }
  468. CORBA::Any* KSynDataSet::GetDataMemberWithLock(CORBA::Long id, CORBA::Long MemberId, CORBA::Long& Result, const char* ObjName) 
  469. {
  470. if ((Result = Lock(id,ObjName)) > 0)
  471. {
  472. return GetDataMember(id,MemberId);
  473. }
  474. else
  475. {
  476. return NULL;
  477. }
  479. }
  481. CORBA::Long KSynDataSet::SetDataMemberWithLock(CORBA::Long id, CORBA::Long MemberId, const CORBA::Any& data, CORBA::Long& Result, const char* ObjName) 
  482. {
  483. if ( (Result = Lock(id,ObjName)) > 0)
  484. {
  486. SetDataMember(id,MemberId,data);
  487. return Result;
  488. }
  489. else
  490. return Result;
  491. }
  493. CORBA::Any* KSynDataSet::GetDataMemberWithOnce(CORBA::Long id, CORBA::Long MemberId, CORBA::Long& Result, const char* ObjName) 
  494. {
  495. CORBA::Any *result;
  497. if ((Result = Lock(id,ObjName)) > 0)
  498. {
  499. result = GetDataMember(id, MemberId);
  500. UnLock(id,Result);
  501. return result;
  502. }
  503. else
  504. return NULL;
  507. }
  510. CORBA::Long KSynDataSet::SetDataMemberWithOnce(CORBA::Long id, CORBA::Long MemberId, const CORBA::Any& data, CORBA::Long& Result, const char* ObjName) 
  511. {
  513. long nLockId;
  514. if ((nLockId = Lock(id,ObjName)) > 0)
  515. {
  516. SetDataMember(id, MemberId, data);
  517. UnLock(id, nLockId);
  518. Result = nLockId;
  519. return Result;
  520. }
  522. else 
  523. {
  524. if (nLockId < 0){};
  526. Result = nLockId;
  527. return nLockId;
  528. }
  531. }
  533. BOOL KSynDataSet::AddData(KSynData * pData, long id)
  534. {
  536. if(m_Sets[id])
  537. {
  538. if (m_Sets[id]->m_bExist == FALSE)
  539. {
  540. m_Sets[id] = pData;
  541. m_Sets[id]->m_bExist = TRUE;
  542. return TRUE;
  543. }
  544. else 
  545. return FALSE;
  546. }
  547. else 
  548. {
  549. m_Sets[id] = pData;
  550. m_Sets[id]->m_bExist = TRUE;
  551. if (id > m_nTopIndex) m_nTopIndex = id;
  552. return TRUE;
  555. }
  557. }
  560. DataSeq * KSynDataSet::SaveData()
  561. {
  563. long Len = 0;
  565. for(long j = 0; j< m_nTopIndex ;j++)
  566. {
  567. if(m_Sets[j]->m_bExist)
  568. Len ++;
  569. }
  570. DataSeq*  pdataSeq = new DataSeq;
  571. pdataSeq->length(Len);
  573. for(long i= 0;i<Len;i++)
  574. {
  575. if (m_Sets[i]->m_bExist)
  576. {
  577. CORBA::Any * pAny;
  578. pAny = GetData(i);
  580. (*pdataSeq)[i] = *pAny;
  581. }
  582. }
  584. return pdataSeq;
  585. }