Ignore:
Timestamp:
Jan 14, 2016, 1:17:21 PM (8 years ago)
Author:
coas-nagasima
Message:

・デジタルPinとアナログPinのWAMPトピックを追加し、PubSubできるように機能追加。

デジタルPINのトピックは、

「com.sonycsl.kadecot.arduino.topic.pinXX」(XXは0から13)

アナログPINのトピックは、

「com.sonycsl.kadecot.arduino.topic.pinXX.thrYYY」(XXは14から19、YYYは閾値十進)

・デバッグ用の使用していない文字列が、ROM領域に残ってしまうのを修正
・WebSocket接続時のHTTPヘッダーを1行ずつNAK応答を待って送信しているのを、一括で送るよう変更

File:
1 edited

Legend:

Unmodified
Added
Removed
  • uKadecot/trunk/ecnl_ssp/echonet.c

    r108 r152  
    235235        a_ret = _ecn_fbs_add_data_ex(*(ECN_FBS_ID *)&ppk_esv, &ppk_esv->hdr.edata.opc, 1);
    236236        if (a_ret) {
    237                 ECN_DBG_PUT "ecn_trn_set_get(): _ecn_fbs_add_data_ex() result = %d:%s", a_ret, itron_strerror(a_ret) ECN_DBG_END;
     237                ECN_DBG_PUT("ecn_trn_set_get(): _ecn_fbs_add_data_ex() result = %d:%s", a_ret, itron_strerror(a_ret));
    238238                return a_ret;
    239239        }
     
    264264        a_wr_opc = _ecn_fbs_peek(*(ECN_FBS_ID *)&ppk_esv, fa_trn_pos);
    265265        if (a_wr_opc < 0) {
    266                 ECN_DBG_PUT "ecn_end_set_get(): _ecn_fbs_peek() result = %d:%s", a_wr_opc, itron_strerror(a_wr_opc) ECN_DBG_END;
     266                ECN_DBG_PUT("ecn_end_set_get(): _ecn_fbs_peek() result = %d:%s", a_wr_opc, itron_strerror(a_wr_opc));
    267267                return a_wr_opc;
    268268        }
     
    274274        a_ret = _ecn_fbs_poke(*(ECN_FBS_ID *)&ppk_esv, fa_trn_pos, a_rd_opc);
    275275        if (a_ret) {
    276                 ECN_DBG_PUT "ecn_end_set_get(): _ecn_fbs_poke() result = %d:%s", a_ret, itron_strerror(a_ret) ECN_DBG_END;
     276                ECN_DBG_PUT("ecn_end_set_get(): _ecn_fbs_poke() result = %d:%s", a_ret, itron_strerror(a_ret));
    277277                return a_ret;
    278278        }
     
    328328        a_ret = _ecn_fbs_add_data_ex(a_fbs_id, &a_ecn_prp, sizeof(a_ecn_prp));
    329329        if (a_ret) {
    330                 ECN_DBG_PUT "ecn_add_edt(): _ecn_fbs_add_data_ex(*, ecn_prp{epc:0x%02X}, %u) result = %d:%s",
     330                ECN_DBG_PUT("ecn_add_edt(): _ecn_fbs_add_data_ex(*, ecn_prp{epc:0x%02X}, %u) result = %d:%s",
    331331                        a_ecn_prp.epc, sizeof(a_ecn_prp),
    332                         a_ret, itron_strerror(a_ret) ECN_DBG_END;
     332                        a_ret, itron_strerror(a_ret));
    333333                goto lb_except;
    334334        }
     
    337337                a_ret = _ecn_fbs_add_data_ex(a_fbs_id, p_edt, fa_pdc);
    338338                if (a_ret) {
    339                         ECN_DBG_PUT "ecn_add_edt(): _ecn_fbs_add_data_ex(*, ecn_prp{epc:0x%02X} edt, %u) result = %d:%s",
     339                        ECN_DBG_PUT("ecn_add_edt(): _ecn_fbs_add_data_ex(*, ecn_prp{epc:0x%02X} edt, %u) result = %d:%s",
    340340                                a_ecn_prp.epc, fa_pdc,
    341                                 a_ret, itron_strerror(a_ret) ECN_DBG_END;
     341                                a_ret, itron_strerror(a_ret));
    342342                        goto lb_except;
    343343                }
     
    523523
    524524#ifdef ECN_ENA_ITR_NXT_CARP
    525         ECN_CAP_PUT "ecn_itr_nxt() rd.cur=b%dp%d", pk_itr->cur.blk, pk_itr->cur.pos ECN_CAP_PUT;
     525        ECN_CAP_PUT("ecn_itr_nxt() rd.cur=b%dp%d", pk_itr->cur.blk, pk_itr->cur.pos ECN_CAP_PUT(;
    526526#endif
    527527        if (pk_itr->count <= pk_itr->got_ct && 0 < pk_itr->next_blk_ct) {
     
    550550                goto lb_except;
    551551        if (a_rd_len < sizeof(a_ecn_prp)) {
    552                 ECN_DBG_PUT "ecn_itr_nxt() ecn_prp read fault."
    553                         " rd.cur=%d", pk_itr->cur ECN_DBG_END;
     552                ECN_DBG_PUT("ecn_itr_nxt() ecn_prp read fault."
     553                        " rd.cur=%d", pk_itr->cur);
    554554                pk_itr->is_eof = 1;                     /* 終端に達した時、非0 */
    555555                a_ret = E_BOVR; /* データ終了 */
     
    566566                        goto lb_except;
    567567                if (a_rd_len < (ECN_FBS_SSIZE_T)a_ecn_prp.pdc) {
    568                         ECN_DBG_PUT "ecn_itr_nxt() edt read fault."
    569                                 " rd.cur=%d,epc=0x%02X,pdc=%u", pk_itr->cur, a_ecn_prp.epc , a_ecn_prp.pdc ECN_DBG_END;
     568                        ECN_DBG_PUT("ecn_itr_nxt() edt read fault."
     569                                " rd.cur=%d,epc=0x%02X,pdc=%u", pk_itr->cur, a_ecn_prp.epc , a_ecn_prp.pdc);
    570570                        pk_itr->is_eof = 1;                     /* 終端に達した時、非0 */
    571571                        a_ret = E_BOVR; /* データ終了 */
     
    576576
    577577#ifdef ECN_ENA_ITR_NXT_CARP
    578         ECN_CAP_PUT "ecn_itr_nxt() read: ct=%d/%d", pk_itr->got_ct, pk_itr->count ECN_CAP_PUT;
     578        ECN_CAP_PUT("ecn_itr_nxt() read: ct=%d/%d", pk_itr->got_ct, pk_itr->count ECN_CAP_PUT(;
    579579#endif
    580580
     
    605605        a_ret = _ecn_tsk_snd_mbx(a_fbs_id, true);
    606606        if (a_ret) {
    607                 ECN_DBG_PUT "_ecn_tsk_snd_mbx() result = %d:%s",
    608                         a_ret, itron_strerror(a_ret) ECN_DBG_END;
     607                ECN_DBG_PUT("_ecn_tsk_snd_mbx() result = %d:%s",
     608                        a_ret, itron_strerror(a_ret));
    609609                goto lb_except;
    610610        }
     
    637637        a_fbs.ptr = (T_ECN_FST_BLK *)pk_esv;
    638638        if (a_fbs.ptr->hdr.type != ECN_MSG_USER_BREAK) {
    639                 ECN_DBG_PUT "ecn_get_brk_dat: fbs-type:%d != ECN_MSG_USER_BREAK",
    640                         a_fbs.ptr->hdr.type ECN_DBG_END;
     639                ECN_DBG_PUT("ecn_get_brk_dat: fbs-type:%d != ECN_MSG_USER_BREAK",
     640                        a_fbs.ptr->hdr.type);
    641641                return E_PAR;
    642642        }
     
    645645        a_ret = _ecn_fbs_set_rpos(a_fbs, 0);
    646646        if (a_ret) {
    647                 ECN_DBG_PUT "_ecn_fbs_set_rpos(*, 0) result = %d:%s",
    648                         a_ret, itron_strerror(a_ret) ECN_DBG_END;
     647                ECN_DBG_PUT("_ecn_fbs_set_rpos(*, 0) result = %d:%s",
     648                        a_ret, itron_strerror(a_ret));
    649649                return a_ret;
    650650        }
     
    655655                a_ret = _ecn_fbs_get_data(a_fbs, p_buf, fa_bufsz, &a_len);
    656656                if (a_ret || !a_len) {
    657                         ECN_DBG_PUT "_ecn_fbs_get_data(*, p_buf, fa_bufsz) result = %d:%s",
    658                                 a_ret, itron_strerror(a_ret) ECN_DBG_END;
     657                        ECN_DBG_PUT("_ecn_fbs_get_data(*, p_buf, fa_bufsz) result = %d:%s",
     658                                a_ret, itron_strerror(a_ret));
    659659                        return E_PAR;
    660660                }
Note: See TracChangeset for help on using the changeset viewer.