| | |
|---|
| | | |
|---|
| | | auto onRecvDataMessage = [&](void* pFrom, IMessage* pMessage) -> void { |
|---|
| | | HEADER* pHeader = pMessage->getHeader(); |
|---|
| | | int nStream = (pHeader->stream & 0x7F); |
|---|
| | | |
|---|
| | | TRACE("收到消息 S%dF%d================\n", pHeader->stream & 0x7F, pHeader->function); |
|---|
| | | TRACE("Body:%s\n", pMessage->toString()); |
|---|
| | | LOGI("onRecvDataMessage(%s).", pMessage->toString()); |
|---|
| | | |
|---|
| | | if (nStream == 5 && pHeader->function == 1) { |
|---|
| | | // S1F1 |
|---|
| | | replyAck(5, 2, pMessage->getHeader()->systemBytes, 0, _T("ACK0")); |
|---|
| | | } |
|---|
| | | }; |
|---|
| | | |
|---|
| | | ActiveListener listener; |
|---|
| | |
|---|
| | | |
|---|
| | | return 0; |
|---|
| | | } |
|---|
| | | |
|---|
| | | int CHsmsActive::replyAck0(IMessage* pMessage) |
|---|
| | | { |
|---|
| | | return 0; |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 通用的reply ack函数 |
|---|
| | | void CHsmsActive::replyAck(int s, int f, unsigned int systemBytes, BYTE ack, const char* pszAckName) |
|---|
| | | { |
|---|
| | | IMessage* pMessage = NULL; |
|---|
| | | HSMS_Create1Message(pMessage, m_nSessionId, s, f, systemBytes); |
|---|
| | | ASSERT(pMessage); |
|---|
| | | ISECS2Item* pItem = pMessage->getBody(); |
|---|
| | | pItem->setBinary((const char*)&ack, 1, pszAckName); |
|---|
| | | m_pActive->sendMessage(pMessage); |
|---|
| | | LOGI("<HSMS>[SECS Msg SEND]S%dF%d (SysByte=%u)", s, f, systemBytes); |
|---|
| | | HSMS_Destroy1Message(pMessage); |
|---|
| | | } |
|---|
| | | |
|---|
