SalesAudioTrans_client_g.h 3.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112
  1. #ifndef __SALESAUDIOTRANS_CLIENT_G_H
  2. #define __SALESAUDIOTRANS_CLIENT_G_H
  3. #pragma once
  4. // This code is generated by spgen tool!
  5. #include "SalesAudioTrans_def_g.h"
  6. namespace SalesAudioTrans {
  7. class SalesAudioTransService_ClientBase : public CClientSessionBase {
  8. public:
  9. explicit SalesAudioTransService_ClientBase(CEntityBase *pEntity) : m_pEntityBase(pEntity), m_bSysManaged(false) {}
  10. SalesAudioTransService_ClientBase* operator () (const linkContext &curLink)
  11. {
  12. m_context = curLink;
  13. return this;
  14. }
  15. protected:
  16. virtual ~SalesAudioTransService_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, "SalesAudioTrans", "SalesAudioTransService", 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 StartAudioTrans(SalesAudioTransService_StartAudioTrans_Req &Req, CSmartPointer<IAsynWaitSp> &spAsyncWait, DWORD dwTimeout)
  54. {
  55. CSmartPointer<IClientSessionFunction> pFunc = GetFunction();
  56. CAutoBuffer Buf = SpObject2Buffer(Req);
  57. auto ret = pFunc->AsyncRequest(SalesAudioTransService_Method_StartAudioTrans, SalesAudioTransService_MethodSignature_StartAudioTrans, Buf, spAsyncWait, m_context, dwTimeout);
  58. m_context.clear();
  59. return ret;
  60. }
  61. ErrorCodeEnum StartAudioTrans(SalesAudioTransService_StartAudioTrans_Req &Req, SalesAudioTransService_StartAudioTrans_Ans &Ans, DWORD dwTimeout)
  62. {
  63. CSmartPointer<IAsynWaitSp> spAsyncWait;
  64. ErrorCodeEnum Error = StartAudioTrans(Req, spAsyncWait, dwTimeout);
  65. if (Error == Error_Succeed) {
  66. bool bEnd = false;
  67. Error = SpWaitAnswerObject(spAsyncWait, Ans, bEnd, dwTimeout);
  68. LOG_ASSERT(Error || bEnd);
  69. }
  70. return Error;
  71. }
  72. ErrorCodeEnum StartAudioTrans(SalesAudioTransService_StartAudioTrans_Req &Req, SalesAudioTransService_StartAudioTrans_Ans &Ans, DWORD dwTimeout, DWORD &dwUserError)
  73. {
  74. CSmartPointer<IAsynWaitSp> spAsyncWait;
  75. ErrorCodeEnum Error = StartAudioTrans(Req, spAsyncWait, dwTimeout);
  76. if (Error == Error_Succeed) {
  77. bool bEnd = false;
  78. Error = SpWaitAnswerObject(spAsyncWait, Ans, bEnd, dwUserError, dwTimeout);
  79. LOG_ASSERT(Error || bEnd);
  80. }
  81. return Error;
  82. }
  83. bool SafeDelete()
  84. {
  85. if (!m_bSysManaged) {
  86. delete this;
  87. }
  88. return m_bSysManaged;
  89. }
  90. protected:
  91. bool m_bSysManaged;
  92. CEntityBase *m_pEntityBase;
  93. linkContext m_context;
  94. bool bSessionClosed;
  95. };
  96. ///////////////////////////
  97. } // namespace SalesAudioTrans
  98. #endif // __SALESAUDIOTRANS_CLIENT_G_H