顯示具有 SockTcpHandler 標籤的文章。 顯示所有文章
顯示具有 SockTcpHandler 標籤的文章。 顯示所有文章

2012年12月31日 星期一

SockTcpHandler 增加 setCheckAckSize(), 由開發人員自訂是否需要檢查ack message size

因應某一伺服端程控,  ack message 屬於不定長度, 現有SockTcpHandler無法判定, 導致視為異常作業, 自動終止連線, 再重新連線

目前SockTcpHandler::setAckSize (), 意即指定元件須確認 ack message size相同時, 才會將ack messsage以call back方式引入, 反之, 視為異常作業, 自行斷線重新連線

試以增加一函式, SockTcpHandler::setCheckAckSize (), 由同仁自訂是否需要由元件檢查ack message size, 預設為true (檢查)
反之(不檢查), 元件則直接將接收的 ack message以call back方式引入


提供使用範例程式碼如下::

void NGOSndCtrl::run()
{
    int rcv_len = 0;
    myTcpClnt.openClient(server, _TCPPORT);
    myTcpClnt.setHeaderSize(sizeof(TCP_HEAD));
    myTcpClnt.setAckSize(sizeof(TCP_ACK), sizeof(TCP_HEAD)+1);
    myTcpClnt.setNeedAck(1);
    myTcpClnt.setCheckAckSize (ChkACKSize_NO);  // 設定為不檢查
    myTcpClnt.setTimeout(1000); // -1 is no time out
    /*an option, custom to ckeck reply ack message */
    myTcpClnt.setOnReadAck(CB(onReadAck));
    myTcpClnt.runClient();

    .....(以下省略)
}

當要接收不同的ack message時, 應如何善用SockTcpHandler::setAckSize()

同位提出一個需求討論:
假若不同的L2 client side (L2A, L2B), 需回覆不同格式的ack format時(ACK_A, ACK_B), 如何因應??
struct ackA {
  TCP_HEAD head;
  char blank1;
  char acept; /**< accept or not */
  char trans_id[4];
  char err_code[4];
  char blank2[2];
  char err_msg[31];
} ACK_A;

struct ackB {
  TCP_HEAD head;
  char blank1;
  char acept; /**< accept or not */
  char trans_id[4];
  char err_code[4];
} ACK_B;

建議做法::
可以於SockTcpHandler::setAckSize (ack_size, accept_position)進行調整
    ack_size: 客戶端連線所回覆的ack message資料長度
    accept_position: 客戶端連線對於前一筆送出資料的驗證結果的字元位置


針對L2A : myTcpSvr.setAckSize(sizeof(ACK_A), sizeof(TCP_HEAD)+2);
針對L2B : myTcpSvr.setAckSize(sizeof(ACK_B), sizeof(TCP_HEAD)+2);


提供一般Control Class::run ()的範例程式碼::

void NGORcvCtrl::run()
{
    /* specify the header size of message */
    myTcpSvr.setHeaderSize(sizeof(TCP_HEAD));
    /* specify the ack size and function position */
    myTcpSvr.setAckSize(sizeof(TCP_ACK), sizeof(TCP_HEAD)+1);
    /* set need to reply ack */
    myTcpSvr.setNeedAck(1);
    /* assign a funcion, when tcp server on receive complete message will call back */
    myTcpSvr.setOnReceive(CB(onReceive));
    /* assign a funcion, when tcp server on reply custom ack will call back it */
    myTcpSvr.setOnReply(CB_RP(onReply));
    /* run the tcp server */
    myTcpSvr.runSingleSvr ();
}