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

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

模拟服务器

开发平台：

C/C++

KDataManage.cpp：源码内容
  1. #include "KDataManage.h"
  2. #include "iostream.h"
  4. KDataManage::KDataManage()
  5. {
  8. }
  10. KDataManage::~KDataManage()
  11. {
  12. }
  15. long KDataManage::Lock(CORBA::Long MapId, CORBA::Long StyleId, long id)
  16. {
  19. try{
  21. long lockid = 0;
  22. if ((lockid = m_pCorbaDataSets->Lock(MapId,StyleId,id,m_ServerObjName)) > 0 )
  23. {
  24. return lockid;
  25. }
  26. else 
  27. {
  28. char e_name[100];
  29. sprintf(e_name,"%d_%d",id,lockid);
  30. HANDLE hevent;
  31. hevent = CreateEvent(NULL,TRUE,FALSE,e_name);
  32. WaitForSingleObject(hevent,INFINITE);
  33. CloseHandle(hevent);
  34. return lockid;
  35. }
  37. }
  39. catch(CORBA::COMM_FAILURE& ex) {
  40. cerr << "Caught system exception COMM_FAILURE -- unable to contact the "
  41. << "object." <<id<< endl;
  43. }
  44. catch(CORBA::SystemException&) {
  45. cerr << "Caught CORBA::SystemException1." << endl;
  46. }
  47. catch(CORBA::Exception&) {
  48. cerr << "Caught CORBA::Exception." << endl;
  49. }
  50. catch(omniORB::fatalException& fe) {
  51. cerr << "Caught omniORB::fatalException:" << endl;
  52. cerr << "  file: " << fe.file() << endl;
  53. cerr << "  line: " << fe.line() << endl;
  54. cerr << "  mesg: " << fe.errmsg() << endl;
  55. }
  56. catch(...) {
  57. cerr << "Caught unknown exception." << endl;
  58. }
  60. return -9999;
  61. }
  63. long KDataManage::UnLock(CORBA::Long MapId, CORBA::Long StyleId, long id, long index)
  64. {
  65. return m_pCorbaDataSets->UnLock(MapId,StyleId,id,index);
  66. }
  68. CORBA::Any* KDataManage::GetData(CORBA::Long MapId, CORBA::Long StyleId, long id)
  69. {
  70. return m_pCorbaDataSets->GetData(MapId,StyleId,id);
  72. }
  74. long KDataManage::SetData(CORBA::Long MapId, CORBA::Long StyleId, long id, const CORBA::Any& data) 
  75. {
  76. return m_pCorbaDataSets->SetData(MapId,StyleId,id,data);
  78. }
  79. //获得数据，并锁住数据
  80. CORBA::Any* KDataManage::GetDataWithLock(CORBA::Long MapId, CORBA::Long StyleId, long id) 
  81. {
  83. long lockid = 0;
  84. CORBA::Long Result;
  85. CORBA::Any * pAnyResult;
  86. try
  87. {
  89. pAnyResult  = m_pCorbaDataSets->GetDataWithLock(MapId,StyleId,id,Result,m_ServerObjName);
  90. if ( Result == 1)
  91. {
  92. return pAnyResult;
  93. }
  94. else
  95. {
  96. char e_name[100];
  97. sprintf(e_name,"%d_%d",id,-1*Result);
  99. HANDLE hevent;
  100. hevent = CreateEvent(NULL,TRUE,FALSE,e_name);
  101. WaitForSingleObject(hevent,INFINITE);
  102. CloseHandle(hevent);
  103. return m_pCorbaDataSets->GetData(MapId,StyleId,id);
  109. }   
  112. }
  114. catch(CORBA::COMM_FAILURE& ex) {
  115. cerr << "Caught system exception COMM_FAILURE -- unable to contact the "
  116. << "object." << endl;
  117. }
  118. catch(CORBA::SystemException&) {
  119. cerr << "Caught CORBA::SystemException2." << endl;
  120. }
  121. catch(CORBA::Exception&) {
  122. cerr << "Caught CORBA::Exception." << endl;
  123. }
  124. catch(omniORB::fatalException& fe) {
  125. cerr << "Caught omniORB::fatalException:" << endl;
  126. cerr << "  file: " << fe.file() << endl;
  127. cerr << "  line: " << fe.line() << endl;
  128. cerr << "  mesg: " << fe.errmsg() << endl;
  129. }
  130. catch(...) {
  131. cerr << "Caught unknown exception." << endl;
  132. }
  133. return NULL;
  134. }
  136. CORBA::Long KDataManage::SetDataWithLock(CORBA::Long MapId, CORBA::Long StyleId,CORBA::Long id, const CORBA::Any& data) 
  137. {
  140. long lockid = 0;
  141. CORBA::Long Result;
  143. try
  144. {
  146. m_pCorbaDataSets->SetDataWithLock(MapId,StyleId,id,data ,Result,m_ServerObjName);
  148. if ( Result == 1)
  149. {
  150. return 1;
  151. }
  152. else
  153. {
  154. char e_name[100];
  155. sprintf(e_name,"%d_%d",id,-1 * Result);
  156. printf("Add Lock %sn",e_name);
  158. HANDLE hevent;
  159. hevent = CreateEvent(NULL,TRUE,FALSE,e_name);
  160. WaitForSingleObject(hevent,INFINITE);
  162. CloseHandle(hevent);
  163. m_pCorbaDataSets->SetData(MapId,StyleId,id,data);
  164. return Result;
  169. }   
  172. }
  174. catch(CORBA::COMM_FAILURE& ex) {
  175. cerr << "Caught system exception COMM_FAILURE -- unable to contact the "
  176. << "object." << endl;
  177. }
  178. catch(CORBA::SystemException&) {
  179. cerr << "Caught CORBA::SystemException3." << endl;
  180. }
  181. catch(CORBA::Exception&) {
  182. cerr << "Caught CORBA::Exception." << endl;
  183. }
  184. catch(omniORB::fatalException& fe) {
  185. cerr << "Caught omniORB::fatalException:" << endl;
  186. cerr << "  file: " << fe.file() << endl;
  187. cerr << "  line: " << fe.line() << endl;
  188. cerr << "  mesg: " << fe.errmsg() << endl;
  189. }
  190. catch(...) {
  191. cerr << "Caught unknown exception." << endl;
  192. }
  197. }
  198. CORBA::Any* KDataManage::GetDataWithOnce(CORBA::Long MapId, CORBA::Long StyleId,CORBA::Long id)
  199. {
  200. long lockid = 0;
  201. CORBA::Long Result;
  202. CORBA::Any * pAnyResult;
  203. try
  204. {
  206. pAnyResult  = m_pCorbaDataSets->GetDataWithOnce(MapId,StyleId,id,Result,m_ServerObjName);
  207. if ( Result == 1)
  208. {
  209. return pAnyResult;
  210. }
  211. else
  212. {
  213. char e_name[100];
  214. sprintf(e_name,"%d_%d",id,-1*Result);
  216. HANDLE hevent;
  217. hevent = CreateEvent(NULL,TRUE,FALSE,e_name);
  218. WaitForSingleObject(hevent,INFINITE);
  220. CloseHandle(hevent);
  221. return m_pCorbaDataSets->GetData(MapId,StyleId,id);
  225. }   
  228. }
  230. catch(CORBA::COMM_FAILURE& ex) {
  231. cerr << "Caught system exception COMM_FAILURE -- unable to contact the "
  232. << "object." << endl;
  233. }
  234. catch(CORBA::SystemException&) {
  235. cerr << "Caught CORBA::SystemException4." << endl;
  236. }
  237. catch(CORBA::Exception&) {
  238. cerr << "Caught CORBA::Exception." << endl;
  239. }
  240. catch(omniORB::fatalException& fe) {
  241. cerr << "Caught omniORB::fatalException:" << endl;
  242. cerr << "  file: " << fe.file() << endl;
  243. cerr << "  line: " << fe.line() << endl;
  244. cerr << "  mesg: " << fe.errmsg() << endl;
  245. }
  246. catch(...) {
  247. cerr << "Caught unknown exception." << endl;
  248. }
  249. return NULL;
  250. }
  252. CORBA::Long KDataManage::SetDataWithOnce(CORBA::Long MapId, CORBA::Long StyleId,CORBA::Long id, const CORBA::Any& data) 
  253. {
  255. long lockid = 0;
  256. CORBA::Long Result = 999 ;
  258. try
  259. {
  261. long tt = m_pCorbaDataSets->SetDataWithOnce(MapId,StyleId,id,data ,Result,m_ServerObjName);
  263. if ( Result == 1)
  264. {
  265. return 1;
  266. }
  267. else
  268. {
  269. char e_name[100];
  270. sprintf(e_name,"%d_%d",id,-1*Result);
  271. printf("tt is %dn",tt);
  272. printf("Add Lock %sn",e_name);
  274. HANDLE hevent;
  275. hevent = CreateEvent(NULL,TRUE,FALSE,e_name);
  276. WaitForSingleObject(hevent,INFINITE);
  278. CloseHandle(hevent);
  279. m_pCorbaDataSets->SetData(MapId,StyleId,id,data);
  280. printf("UnLock %dn",-1*Result);
  281. UnLock(MapId, StyleId, id,-1*Result);
  282. return 1;
  286. }   
  289. }
  291. catch(CORBA::COMM_FAILURE& ex) {
  292. cerr << "Caught system exception COMM_FAILURE -- unable to contact the "
  293. << "object." << endl;
  294. }
  295. catch(CORBA::SystemException&) {
  296. cerr << "Caught CORBA::SystemException5." <<id<<Result<< endl;
  297. }
  298. catch(CORBA::Exception&) {
  299. cerr << "Caught CORBA::Exception." << endl;
  300. }
  301. catch(omniORB::fatalException& fe) {
  302. cerr << "Caught omniORB::fatalException:" << endl;
  303. cerr << "  file: " << fe.file() << endl;
  304. cerr << "  line: " << fe.line() << endl;
  305. cerr << "  mesg: " << fe.errmsg() << endl;
  306. }
  307. catch(...) {
  308. cerr << "Caught unknown exception." << endl;
  309. }
  310. }