|
|
@@ -32,6 +32,7 @@ public:
|
|
|
}
|
|
|
void OnClose(ErrorCodeEnum)
|
|
|
{
|
|
|
+ Dbg("session closed.");
|
|
|
bSessionClosed = true;
|
|
|
}
|
|
|
bool QuerySessionClosed()
|
|
|
@@ -58,119 +59,6 @@ public:
|
|
|
return Error;
|
|
|
}
|
|
|
|
|
|
- ErrorCodeEnum Set(GpioService_Set_Info &Info)
|
|
|
- {
|
|
|
- CSmartPointer<IClientSessionFunction> 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(GpioService_Method_Set, GpioService_MethodSignature_Set, Buf, m_context);
|
|
|
- m_context.clear();
|
|
|
- return ret;
|
|
|
- }
|
|
|
-
|
|
|
- ErrorCodeEnum GetStatus(GpioService_GetStatus_Req &Req, CSmartPointer<IAsynWaitSp> &spAsyncWait, DWORD dwTimeout)
|
|
|
- {
|
|
|
- CSmartPointer<IClientSessionFunction> 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(GpioService_Method_GetStatus, GpioService_MethodSignature_GetStatus, Buf, spAsyncWait, m_context, dwTimeout);
|
|
|
- m_context.clear();
|
|
|
- return ret;
|
|
|
- }
|
|
|
- ErrorCodeEnum GetStatus(GpioService_GetStatus_Req &Req, GpioService_GetStatus_Ans &Ans, DWORD dwTimeout)
|
|
|
- {
|
|
|
- CSmartPointer<IAsynWaitSp> spAsyncWait;
|
|
|
- ErrorCodeEnum Error = GetStatus(Req, spAsyncWait, dwTimeout);
|
|
|
- if (Error == Error_Succeed) {
|
|
|
- bool bEnd = false;
|
|
|
- Error = SpWaitAnswerObject(spAsyncWait, Ans, bEnd, dwTimeout);
|
|
|
- LOG_ASSERT(Error || bEnd);
|
|
|
- }
|
|
|
- return Error;
|
|
|
- }
|
|
|
- ErrorCodeEnum GetStatus(GpioService_GetStatus_Req &Req, GpioService_GetStatus_Ans &Ans, DWORD dwTimeout, DWORD &dwUserError, CSimpleString &str)
|
|
|
- {
|
|
|
- CSmartPointer<IAsynWaitSp> spAsyncWait;
|
|
|
- ErrorCodeEnum Error = GetStatus(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 GetStatus(GpioService_GetStatus_Req &Req, GpioService_GetStatus_Ans &Ans, DWORD dwTimeout, DWORD &dwUserError)
|
|
|
- {
|
|
|
- CSmartPointer<IAsynWaitSp> spAsyncWait;
|
|
|
- ErrorCodeEnum Error = GetStatus(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 QueryCurrSet(GpioService_QueryCurrSet_Req &Req, CSmartPointer<IAsynWaitSp> &spAsyncWait, DWORD dwTimeout)
|
|
|
- {
|
|
|
- CSmartPointer<IClientSessionFunction> 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(GpioService_Method_QueryCurrSet, GpioService_MethodSignature_QueryCurrSet, Buf, spAsyncWait, m_context, dwTimeout);
|
|
|
- m_context.clear();
|
|
|
- return ret;
|
|
|
- }
|
|
|
- ErrorCodeEnum QueryCurrSet(GpioService_QueryCurrSet_Req &Req, GpioService_QueryCurrSet_Ans &Ans, DWORD dwTimeout)
|
|
|
- {
|
|
|
- CSmartPointer<IAsynWaitSp> spAsyncWait;
|
|
|
- ErrorCodeEnum Error = QueryCurrSet(Req, spAsyncWait, dwTimeout);
|
|
|
- if (Error == Error_Succeed) {
|
|
|
- bool bEnd = false;
|
|
|
- Error = SpWaitAnswerObject(spAsyncWait, Ans, bEnd, dwTimeout);
|
|
|
- LOG_ASSERT(Error || bEnd);
|
|
|
- }
|
|
|
- return Error;
|
|
|
- }
|
|
|
- ErrorCodeEnum QueryCurrSet(GpioService_QueryCurrSet_Req &Req, GpioService_QueryCurrSet_Ans &Ans, DWORD dwTimeout, DWORD &dwUserError, CSimpleString &str)
|
|
|
- {
|
|
|
- CSmartPointer<IAsynWaitSp> spAsyncWait;
|
|
|
- ErrorCodeEnum Error = QueryCurrSet(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 QueryCurrSet(GpioService_QueryCurrSet_Req &Req, GpioService_QueryCurrSet_Ans &Ans, DWORD dwTimeout, DWORD &dwUserError)
|
|
|
- {
|
|
|
- CSmartPointer<IAsynWaitSp> spAsyncWait;
|
|
|
- ErrorCodeEnum Error = QueryCurrSet(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 GetDevInfo(GpioService_GetDevInfo_Req &Req, CSmartPointer<IAsynWaitSp> &spAsyncWait, DWORD dwTimeout)
|
|
|
{
|
|
|
CSmartPointer<IClientSessionFunction> pFunc = GetFunction();
|