Initializer_client_g.h 7.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207
  1. #ifndef __INITIALIZER_CLIENT_G_H
  2. #define __INITIALIZER_CLIENT_G_H
  3. #pragma once
  4. // This code is generated by spgen tool!
  5. #include "Initializer_def_g.h"
  6. namespace Initializer {
  7. class InitializerService_ClientBase : public CClientSessionBase {
  8. public:
  9. explicit InitializerService_ClientBase(CEntityBase *pEntity) : m_pEntityBase(pEntity), m_bSysManaged(false) {}
  10. InitializerService_ClientBase* operator () (const linkContext &curLink)
  11. {
  12. m_context = curLink;
  13. return this;
  14. }
  15. protected:
  16. virtual ~InitializerService_ClientBase()
  17. {
  18. /// override by user
  19. }
  20. public:
  21. void OnConnectSucceed()
  22. {
  23. bSessionClosed = false;
  24. }
  25. void OnClose(ErrorCodeEnum)
  26. {
  27. Dbg("session closed.");
  28. bSessionClosed = true;
  29. }
  30. bool QuerySessionClosed()
  31. {
  32. return bSessionClosed;
  33. }
  34. ErrorCodeEnum Connect(CSmartPointer<IAsynWaitSp> &spAsyncWait)
  35. {
  36. CSmartPointer<IEntityFunction> pFunc = m_pEntityBase->GetFunction();
  37. ErrorCodeEnum Error = pFunc->ConnectRemoteEntity(this, "Initializer", "InitializerService", spAsyncWait);
  38. if (Error == Error_Succeed) {
  39. m_bSysManaged = true;
  40. bSessionClosed = false;
  41. }
  42. return Error;
  43. }
  44. ErrorCodeEnum Connect()
  45. {
  46. CSmartPointer<IAsynWaitSp> spAsyncWait;
  47. ErrorCodeEnum Error = Connect(spAsyncWait);
  48. if (Error == Error_Succeed) {
  49. Error = spAsyncWait->WaitAnswer();
  50. }
  51. return Error;
  52. }
  53. ErrorCodeEnum Initialize(InitializerService_Initialize_Info &Info)
  54. {
  55. CSmartPointer<IClientSessionFunction> pFunc = GetFunction();
  56. CAutoBuffer Buf = SpObject2Buffer(Info);
  57. auto ret = pFunc->OnewayCall(InitializerService_Method_Initialize, InitializerService_MethodSignature_Initialize, Buf, m_context);
  58. m_context.clear();
  59. return ret;
  60. }
  61. ErrorCodeEnum InitializeNew(InitializerService_InitializeNew_Req &Req, CSmartPointer<IAsynWaitSp> &spAsyncWait, DWORD dwTimeout)
  62. {
  63. CSmartPointer<IClientSessionFunction> pFunc = GetFunction();
  64. CAutoBuffer Buf = SpObject2Buffer(Req);
  65. auto ret = pFunc->AsyncRequest(InitializerService_Method_InitializeNew, InitializerService_MethodSignature_InitializeNew, Buf, spAsyncWait, m_context, dwTimeout);
  66. m_context.clear();
  67. return ret;
  68. }
  69. ErrorCodeEnum InitializeNew(InitializerService_InitializeNew_Req &Req, InitializerService_InitializeNew_Ans &Ans, DWORD dwTimeout)
  70. {
  71. CSmartPointer<IAsynWaitSp> spAsyncWait;
  72. ErrorCodeEnum Error = InitializeNew(Req, spAsyncWait, dwTimeout);
  73. if (Error == Error_Succeed) {
  74. bool bEnd = false;
  75. Error = SpWaitAnswerObject(spAsyncWait, Ans, bEnd, dwTimeout);
  76. LOG_ASSERT(Error || bEnd);
  77. }
  78. return Error;
  79. }
  80. ErrorCodeEnum InitializeNew(InitializerService_InitializeNew_Req &Req, InitializerService_InitializeNew_Ans &Ans, DWORD dwTimeout, DWORD &dwUserError)
  81. {
  82. CSmartPointer<IAsynWaitSp> spAsyncWait;
  83. ErrorCodeEnum Error = InitializeNew(Req, spAsyncWait, dwTimeout);
  84. if (Error == Error_Succeed) {
  85. bool bEnd = false;
  86. Error = SpWaitAnswerObject(spAsyncWait, Ans, bEnd, dwUserError, dwTimeout);
  87. LOG_ASSERT(Error || bEnd);
  88. }
  89. return Error;
  90. }
  91. ErrorCodeEnum GetAuthServerInfo(InitializerService_GetAuthServerInfo_Req &Req, CSmartPointer<IAsynWaitSp> &spAsyncWait, DWORD dwTimeout)
  92. {
  93. CSmartPointer<IClientSessionFunction> pFunc = GetFunction();
  94. CAutoBuffer Buf = SpObject2Buffer(Req);
  95. auto ret = pFunc->AsyncRequest(InitializerService_Method_GetAuthServerInfo, InitializerService_MethodSignature_GetAuthServerInfo, Buf, spAsyncWait, m_context, dwTimeout);
  96. m_context.clear();
  97. return ret;
  98. }
  99. ErrorCodeEnum GetAuthServerInfo(InitializerService_GetAuthServerInfo_Req &Req, InitializerService_GetAuthServerInfo_Ans &Ans, DWORD dwTimeout)
  100. {
  101. CSmartPointer<IAsynWaitSp> spAsyncWait;
  102. ErrorCodeEnum Error = GetAuthServerInfo(Req, spAsyncWait, dwTimeout);
  103. if (Error == Error_Succeed) {
  104. bool bEnd = false;
  105. Error = SpWaitAnswerObject(spAsyncWait, Ans, bEnd, dwTimeout);
  106. LOG_ASSERT(Error || bEnd);
  107. }
  108. return Error;
  109. }
  110. ErrorCodeEnum GetAuthServerInfo(InitializerService_GetAuthServerInfo_Req& Req, InitializerService_GetAuthServerInfo_Ans& Ans, DWORD dwTimeout, DWORD& dwUserError, CSimpleString &str)
  111. {
  112. CSmartPointer<IAsynWaitSp> spAsyncWait;
  113. ErrorCodeEnum Error = GetAuthServerInfo(Req, spAsyncWait, dwTimeout);
  114. if (Error == Error_Succeed) {
  115. bool bEnd = false;
  116. Error = SpWaitAnswerObject(spAsyncWait, Ans, bEnd, dwUserError, str, dwTimeout);
  117. LOG_ASSERT(Error || bEnd);
  118. }
  119. return Error;
  120. }
  121. ErrorCodeEnum GetAuthServerInfo(InitializerService_GetAuthServerInfo_Req &Req, InitializerService_GetAuthServerInfo_Ans &Ans, DWORD dwTimeout, DWORD &dwUserError)
  122. {
  123. CSmartPointer<IAsynWaitSp> spAsyncWait;
  124. ErrorCodeEnum Error = GetAuthServerInfo(Req, spAsyncWait, dwTimeout);
  125. if (Error == Error_Succeed) {
  126. bool bEnd = false;
  127. CSimpleString str;
  128. Error = SpWaitAnswerObject(spAsyncWait, Ans, bEnd, dwUserError,str, dwTimeout);
  129. LOG_ASSERT(Error || bEnd);
  130. }
  131. return Error;
  132. }
  133. ErrorCodeEnum InitializeForBlueTooth(InitializerService_InitializeForBlueTooth_Req &Req, CSmartPointer<IAsynWaitSp> &spAsyncWait, DWORD dwTimeout)
  134. {
  135. CSmartPointer<IClientSessionFunction> pFunc = GetFunction();
  136. CAutoBuffer Buf = SpObject2Buffer(Req);
  137. auto ret = pFunc->AsyncRequest(InitializerService_Method_InitializeForBlueTooth, InitializerService_MethodSignature_InitializeForBlueTooth, Buf, spAsyncWait, m_context, dwTimeout);
  138. m_context.clear();
  139. return ret;
  140. }
  141. ErrorCodeEnum InitializeForBlueTooth(InitializerService_InitializeForBlueTooth_Req &Req, InitializerService_InitializeForBlueTooth_Ans &Ans, DWORD dwTimeout)
  142. {
  143. CSmartPointer<IAsynWaitSp> spAsyncWait;
  144. ErrorCodeEnum Error = InitializeForBlueTooth(Req, spAsyncWait, dwTimeout);
  145. if (Error == Error_Succeed) {
  146. bool bEnd = false;
  147. Error = SpWaitAnswerObject(spAsyncWait, Ans, bEnd, dwTimeout);
  148. LOG_ASSERT(Error || bEnd);
  149. }
  150. return Error;
  151. }
  152. ErrorCodeEnum InitializeForBlueTooth(InitializerService_InitializeForBlueTooth_Req& Req, InitializerService_InitializeForBlueTooth_Ans& Ans, DWORD dwTimeout, DWORD& dwUserError, CSimpleString &str)
  153. {
  154. CSmartPointer<IAsynWaitSp> spAsyncWait;
  155. ErrorCodeEnum Error = InitializeForBlueTooth(Req, spAsyncWait, dwTimeout);
  156. if (Error == Error_Succeed) {
  157. bool bEnd = false;
  158. Error = SpWaitAnswerObject(spAsyncWait, Ans, bEnd, dwUserError, str, dwTimeout);
  159. LOG_ASSERT(Error || bEnd);
  160. }
  161. return Error;
  162. }
  163. ErrorCodeEnum InitializeForBlueTooth(InitializerService_InitializeForBlueTooth_Req &Req, InitializerService_InitializeForBlueTooth_Ans &Ans, DWORD dwTimeout, DWORD &dwUserError)
  164. {
  165. CSmartPointer<IAsynWaitSp> spAsyncWait;
  166. ErrorCodeEnum Error = InitializeForBlueTooth(Req, spAsyncWait, dwTimeout);
  167. if (Error == Error_Succeed) {
  168. bool bEnd = false;
  169. CSimpleString str;
  170. Error = SpWaitAnswerObject(spAsyncWait, Ans, bEnd, dwUserError, str, dwTimeout);
  171. LOG_ASSERT(Error || bEnd);
  172. }
  173. return Error;
  174. }
  175. bool SafeDelete()
  176. {
  177. if (!m_bSysManaged) {
  178. delete this;
  179. }
  180. return m_bSysManaged;
  181. }
  182. protected:
  183. bool m_bSysManaged;
  184. CEntityBase *m_pEntityBase;
  185. linkContext m_context;
  186. bool bSessionClosed;
  187. };
  188. ///////////////////////////
  189. } // namespace Initializer
  190. #endif // __INITIALIZER_CLIENT_G_H