#ifndef __INTERACTIONCONTEXT_CLIENT_G_H #define __INTERACTIONCONTEXT_CLIENT_G_H #pragma once // This code is generated by spgen tool! #include "InteractionContext_def_g.h" namespace InteractionContext { class SyncService_ClientBase : public CClientSessionBase { public: explicit SyncService_ClientBase(CEntityBase *pEntity) : m_pEntityBase(pEntity), m_bSysManaged(false) {} SyncService_ClientBase* operator () (const linkContext &curLink) { m_context = curLink; return this; } protected: virtual ~SyncService_ClientBase() { /// override by user } public: void OnConnectSucceed() { bSessionClosed = false; } void OnClose(ErrorCodeEnum) { bSessionClosed = true; } bool QuerySessionClosed() { return bSessionClosed; } ErrorCodeEnum Connect(CSmartPointer &spAsyncWait) { CSmartPointer pFunc = m_pEntityBase->GetFunction(); ErrorCodeEnum Error = pFunc->ConnectRemoteEntity(this, "InteractionContext", "SyncService", spAsyncWait); if (Error == Error_Succeed) { m_bSysManaged = true; bSessionClosed = false; } return Error; } ErrorCodeEnum Connect() { CSmartPointer spAsyncWait; ErrorCodeEnum Error = Connect(spAsyncWait); if (Error == Error_Succeed) { Error = spAsyncWait->WaitAnswer(); } return Error; } ErrorCodeEnum SetMachineData(SyncService_SetMachineData_Info &Info) { CSmartPointer pFunc = GetFunction(); if (m_context.checkEmpty()) { m_context.AutoGenerate(); DbgToBeidou(m_context, m_pEntityBase != NULL ? m_pEntityBase->GetEntityName() : "")(); m_context = m_context.upgradeLink(); } CAutoBuffer Buf = SpObject2Buffer(Info); auto ret = pFunc->OnewayCall(SyncService_Method_SetMachineData, SyncService_MethodSignature_SetMachineData, Buf, m_context); m_context.clear(); return ret; } ErrorCodeEnum GetMachineData(SyncService_GetMachineData_Req &Req, CSmartPointer &spAsyncWait, DWORD dwTimeout) { CSmartPointer pFunc = GetFunction(); CAutoBuffer Buf = SpObject2Buffer(Req); if (m_context.checkEmpty()) { m_context.AutoGenerate(); DbgToBeidou(m_context, m_pEntityBase != NULL ? m_pEntityBase->GetEntityName() : "")(); m_context = m_context.upgradeLink(); } auto ret = pFunc->AsyncRequest(SyncService_Method_GetMachineData, SyncService_MethodSignature_GetMachineData, Buf, spAsyncWait, m_context, dwTimeout); m_context.clear(); return ret; } ErrorCodeEnum GetMachineData(SyncService_GetMachineData_Req &Req, SyncService_GetMachineData_Ans &Ans, DWORD dwTimeout) { CSmartPointer spAsyncWait; ErrorCodeEnum Error = GetMachineData(Req, spAsyncWait, dwTimeout); if (Error == Error_Succeed) { bool bEnd = false; Error = SpWaitAnswerObject(spAsyncWait, Ans, bEnd, dwTimeout); LOG_ASSERT(Error || bEnd); } return Error; } ErrorCodeEnum GetMachineData(SyncService_GetMachineData_Req &Req, SyncService_GetMachineData_Ans &Ans, DWORD dwTimeout, DWORD &dwUserError, CSimpleString &str) { CSmartPointer spAsyncWait; ErrorCodeEnum Error = GetMachineData(Req, spAsyncWait, dwTimeout); if (Error == Error_Succeed) { bool bEnd = false; Error = SpWaitAnswerObject(spAsyncWait, Ans, bEnd, dwUserError, str, dwTimeout); LOG_ASSERT(Error || bEnd); } return Error; } ErrorCodeEnum GetMachineData(SyncService_GetMachineData_Req &Req, SyncService_GetMachineData_Ans &Ans, DWORD dwTimeout, DWORD &dwUserError) { CSmartPointer spAsyncWait; ErrorCodeEnum Error = GetMachineData(Req, spAsyncWait, dwTimeout); if (Error == Error_Succeed) { bool bEnd = false; CSimpleString str; Error = SpWaitAnswerObject(spAsyncWait, Ans, bEnd, dwUserError, str, dwTimeout); LOG_ASSERT(Error || bEnd); } return Error; } ErrorCodeEnum SetSessionData(SyncService_SetSessionData_Info &Info) { CSmartPointer pFunc = GetFunction(); if (m_context.checkEmpty()) { m_context.AutoGenerate(); DbgToBeidou(m_context, m_pEntityBase != NULL ? m_pEntityBase->GetEntityName() : "")(); m_context = m_context.upgradeLink(); } CAutoBuffer Buf = SpObject2Buffer(Info); auto ret = pFunc->OnewayCall(SyncService_Method_SetSessionData, SyncService_MethodSignature_SetSessionData, Buf, m_context); m_context.clear(); return ret; } ErrorCodeEnum GetSessionData(SyncService_GetSessionData_Req &Req, CSmartPointer &spAsyncWait, DWORD dwTimeout) { CSmartPointer pFunc = GetFunction(); CAutoBuffer Buf = SpObject2Buffer(Req); if (m_context.checkEmpty()) { m_context.AutoGenerate(); DbgToBeidou(m_context, m_pEntityBase != NULL ? m_pEntityBase->GetEntityName() : "")(); m_context = m_context.upgradeLink(); } auto ret = pFunc->AsyncRequest(SyncService_Method_GetSessionData, SyncService_MethodSignature_GetSessionData, Buf, spAsyncWait, m_context, dwTimeout); m_context.clear(); return ret; } ErrorCodeEnum GetSessionData(SyncService_GetSessionData_Req &Req, SyncService_GetSessionData_Ans &Ans, DWORD dwTimeout) { CSmartPointer spAsyncWait; ErrorCodeEnum Error = GetSessionData(Req, spAsyncWait, dwTimeout); if (Error == Error_Succeed) { bool bEnd = false; Error = SpWaitAnswerObject(spAsyncWait, Ans, bEnd, dwTimeout); LOG_ASSERT(Error || bEnd); } return Error; } ErrorCodeEnum GetSessionData(SyncService_GetSessionData_Req &Req, SyncService_GetSessionData_Ans &Ans, DWORD dwTimeout, DWORD &dwUserError, CSimpleString &str) { CSmartPointer spAsyncWait; ErrorCodeEnum Error = GetSessionData(Req, spAsyncWait, dwTimeout); if (Error == Error_Succeed) { bool bEnd = false; Error = SpWaitAnswerObject(spAsyncWait, Ans, bEnd, dwUserError, str, dwTimeout); LOG_ASSERT(Error || bEnd); } return Error; } ErrorCodeEnum GetSessionData(SyncService_GetSessionData_Req &Req, SyncService_GetSessionData_Ans &Ans, DWORD dwTimeout, DWORD &dwUserError) { CSmartPointer spAsyncWait; ErrorCodeEnum Error = GetSessionData(Req, spAsyncWait, dwTimeout); if (Error == Error_Succeed) { bool bEnd = false; CSimpleString str; Error = SpWaitAnswerObject(spAsyncWait, Ans, bEnd, dwUserError, str, dwTimeout); LOG_ASSERT(Error || bEnd); } return Error; } bool SafeDelete() { if (!m_bSysManaged) { delete this; } return m_bSysManaged; } protected: bool m_bSysManaged; CEntityBase *m_pEntityBase; linkContext m_context; bool bSessionClosed; }; /////////////////////////// } // namespace InteractionContext #endif // __INTERACTIONCONTEXT_CLIENT_G_H