Changeset 364 for asp3_tinet_ecnl_rx/trunk/app7_buzzer/src/echonet_main.c

Timestamp:

Feb 1, 2019, 9:57:09 PM (5 years ago)

Author:

coas-nagasima

Message:

TINETとSocket APIなどを更新

File:

• asp3_tinet_ecnl_rx/trunk/app7_buzzer/src/echonet_main.c (modified) (39 diffs)

asp3_tinet_ecnl_rx/trunk/app7_buzzer/src/echonet_main.c

@@ -1 +1 @@
 /*
  *  TOPPERS ECHONET Lite Communication Middleware
- * 
+ *
  *  Copyright (C) 2014-2018 Cores Co., Ltd. Japan
- * 
+ *
  *  上記著作権者は，以下の(1)～(4)の条件を満たす場合に限り，本ソフトウェ
  *  ア（本ソフトウェアを改変したものを含む．以下同じ）を使用・複製・改
@@ -26 +26 @@
  *      由に基づく請求からも，上記著作権者およびTOPPERSプロジェクトを
  *      免責すること．
- * 
+ *
  *  本ソフトウェアは，無保証で提供されているものである．上記著作権者お
  *  よびTOPPERSプロジェクトは，本ソフトウェアに関して，特定の使用目的
@@ -32 +32 @@
  *  アの利用により直接的または間接的に生じたいかなる損害に関しても，そ
  *  の責任を負わない．
- * 
+ *
  *  @(#) $Id$
  */
 
-/* 
+/*
  *  サンプルプログラム(1)の本体
  */
@@ -106 +106 @@
 {
         /* サイズが１以外は受け付けない */
-        if(size != 1)
+        if (size != 1)
                 return 0;
 
         *anno = *((uint8_t*)item->exinf) != *((uint8_t*)src);
 
-        switch(*(uint8_t *)src){
+        switch (*(uint8_t *)src) {
         /* ONの場合 */
         case 0x30:
@@ -138 +138 @@
 {
         /* サイズが１以外は受け付けない */
-        if(size != 1)
+        if (size != 1)
                 return 0;
 
         *anno = *((uint8_t *)item->exinf) != *((uint8_t *)src);
 
-        switch(*(uint8_t *)src){
+        switch (*(uint8_t *)src) {
         /* 異常発生ありの場合 */
         case 0x41:
@@ -166 +166 @@
 
         /* サイズが1以外は受け付けない */
-        if(size != 1)
-                return 0;
-
-        switch(*(uint8_t *)src){
+        if (size != 1)
+                return 0;
+
+        switch (*(uint8_t *)src) {
         /* 音発生有の場合 */
         case 0x41:
@@ -199 +199 @@
 
         /* サイズが１以外は受け付けない */
-        if(size != 1)
+        if (size != 1)
                 return 0;
 
@@ -208 +208 @@
         data[1] = (*((uint8_t *)src) == 0x41) ? 0x01 : 0x00;
         ret = ecn_brk_wai(data, sizeof(data));
-        if(ret != E_OK){
+        if (ret != E_OK) {
                 syslog(LOG_ERROR, "ecn_brk_wai");
         }
@@ -224 +224 @@
 
         /* サイズが１以外は受け付けない */
-        if(size != 1)
+        if (size != 1)
                 return 0;
 
@@ -233 +233 @@
         data[1] = (*((uint8_t *)src) == 0x41) ? 0x01 : 0x00;
         ret = ecn_brk_wai(data, sizeof(data));
-        if(ret != E_OK){
+        if (ret != E_OK) {
                 syslog(LOG_ERROR, "ecn_brk_wai");
         }
@@ -263 +263 @@
 
         ret2 = get_tim(&now);
-        if (ret2 != E_OK){
+        if (ret2 != E_OK) {
                 syslog(LOG_ERROR, "get_tim");
                 return;
         }
 
-        for(;;){
+        for (;;) {
                 prev = now;
 
@@ -276 +276 @@
                 /* 応答電文待ち */
                 ret = ecn_trcv_esv(&esv, timer);
-                if ((ret != E_OK) && (ret != E_BRK) && (ret != E_TMOUT)){
+                if ((ret != E_OK) && (ret != E_BRK) && (ret != E_TMOUT)) {
                         syslog(LOG_ERROR, "ecn_trcv_esv");
                         break;
@@ -282 +282 @@
 
                 ret2 = get_tim(&now);
-                if (ret2 != E_OK){
+                if (ret2 != E_OK) {
                         syslog(LOG_ERROR, "get_tim");
                         break;
@@ -297 +297 @@
                         /* 領域解放 */
                         ret = ecn_rel_esv(esv);
-                        if (ret != E_OK){
+                        if (ret != E_OK) {
                                 syslog(LOG_ERROR, "ecn_rel_esv");
                                 break;
@@ -306 +306 @@
                         /* 応答電文待ちの割り込みデータ取得 */
                         ret = ecn_get_brk_dat(esv, brkdat, sizeof(brkdat), &len);
-                        if (ret != E_OK){
+                        if (ret != E_OK) {
                                 syslog(LOG_ERROR, "ecn_get_brk_dat");
                                 break;
@@ -316 +316 @@
                         /* 領域解放 */
                         ret = ecn_rel_esv(esv);
-                        if (ret != E_OK){
+                        if (ret != E_OK) {
                                 syslog(LOG_ERROR, "ecn_rel_esv");
                                 break;
@@ -327 +327 @@
 }
 
-bool_t started = false;
-
 void echonet_change_netif_link(uint8_t link_up, uint8_t up)
 {
@@ -336 +334 @@
                 return;
 
-        if (up && !started) {
-                started = true;
-
-                /* ECHONETミドルウェアを起動 */
-                ret = ecn_sta_svc();
-                if (ret != E_OK)
-                        return;
-
-                /* ECHONETミドルウェアを起動するのを待つ */
-                dly_tsk(100);
+        if (up) {
+                /* インスタンスリスト通知の送信 */
+                ret = ecn_ntf_inl();
+                if (ret != E_OK) {
+                        syslog(LOG_ERROR, "ecn_ntf_inl");
+                }
         }
 
@@ -351 +345 @@
         uint8_t data[2];
         data[0] = 0x01;
-        data[1] = up ? 0x01 : 0x02;
         ret = ecn_brk_wai(data, sizeof(data));
         if (ret != E_OK) {
@@ -359 +352 @@
 }
 
-enum main_state_t{
+enum main_state_t {
+        main_state_start,
         main_state_idle,
         main_state_search,
@@ -366 +360 @@
 
 int main_timer = TMO_FEVR;
-enum main_state_t main_state = main_state_idle;
+enum main_state_t main_state = main_state_start;
 
 int main_nop_timer = TMO_FEVR;
@@ -378 +372 @@
         sil_wrb_mem((uint8_t *)0x0008C02A, 0x00);
 
-        /* １秒後にブザーを検索 */
-        main_state = main_state_search;
+        /* ECHONETミドルウェアを起動するのを待つ */
+        main_state = main_state_start;
         main_timer = 1000 * 1000;
 
+        /* メインタスクを起動 */
         ER ret = act_tsk(MAIN_TASK);
         if (ret != E_OK) {
@@ -395 +390 @@
         int result = main_timer;
 
-        if((result == TMO_FEVR)
-                || ((main_nop_timer != TMO_FEVR) && (main_nop_timer < result))){
+        if ((result == TMO_FEVR)
+                || ((main_nop_timer != TMO_FEVR) && (main_nop_timer < result))) {
                 result = main_nop_timer;
         }
@@ -408 +403 @@
 static void main_progress(int interval)
 {
-        if(main_timer != TMO_FEVR){
+        if (main_timer != TMO_FEVR) {
                 main_timer -= interval;
-                if(main_timer < 0){
+                if (main_timer < 0) {
                         main_timer = 0;
                 }
         }
 
-        if(main_nop_timer != TMO_FEVR){
+        if (main_nop_timer != TMO_FEVR) {
                 main_nop_timer -= interval;
-                if(main_nop_timer < 0){
+                if (main_nop_timer < 0) {
                         main_nop_timer = 0;
                 }
@@ -436 +431 @@
 
         eobjid = ecn_get_eobj(esv);
-        if(eobjid == EOBJ_NULL){
+        if (eobjid == EOBJ_NULL) {
                 syslog(LOG_ERROR, "ecn_get_eobj");
                 return;
@@ -442 +437 @@
 
         ret = ecn_itr_ini(&enm, esv);
-        if(ret != E_OK){
+        if (ret != E_OK) {
                 syslog(LOG_ERROR, "ecn_itr_ini");
                 return;
         }
 
-        for(;;) {
-                while((ret = ecn_itr_nxt(&enm, &epc, &pdc, p_edt)) == E_OK) {
+        for (;;) {
+                while ((ret = ecn_itr_nxt(&enm, &epc, &pdc, p_edt)) == E_OK) {
                         switch (epc) {
                         case 0xD6:
-                                switch(main_state){
+                                switch (main_state) {
                                 case main_state_search:
                                         if (eobjid == POT_NODE_EOBJ) {
@@ -463 +458 @@
                         }
                 }
-                if(ret != E_BOVR){
+                if (ret != E_BOVR) {
                         syslog(LOG_ERROR, "ecn_itr_nxt");
                         break;
                 }
-                if(enm.is_eof)
+                if (enm.is_eof)
                         break;
         }
@@ -478 +473 @@
         uint8_t p_edt[1];
 
-        switch(main_state){
+        switch (main_state) {
         case main_state_idle:
                 p_edt[0] = 0x41; /* 音発生有 */
@@ -484 +479 @@
                 /* プロパティ設定電文作成 */
                 ret = ecn_esv_seti(&esv, BUZZER_EOBJ, 0xB1, 1, p_edt);
-                if(ret != E_OK){
+                if (ret != E_OK) {
                         syslog(LOG_ERROR, "ecn_esv_seti");
                         break;
@@ -491 +486 @@
                 /* 電文送信 */
                 ecn_snd_esv(esv);
-                if(ret != E_OK){
+                if (ret != E_OK) {
                         syslog(LOG_ERROR, "ecn_snd_esv");
                         break;
@@ -511 +506 @@
         uint8_t p_edt[1];
 
-        switch(main_state){
+        switch (main_state) {
         case main_state_buzzer_on:
                 p_edt[0] = 0x42; /* 音発生無 */
@@ -517 +512 @@
                 /* プロパティ設定電文作成 */
                 ret = ecn_esv_seti(&esv, BUZZER_EOBJ, 0xB1, 1, p_edt);
-                if(ret != E_OK){
+                if (ret != E_OK) {
                         syslog(LOG_ERROR, "ecn_esv_seti");
                         break;
@@ -524 +519 @@
                 /* 電文送信 */
                 ecn_snd_esv(esv);
-                if(ret != E_OK){
+                if (ret != E_OK) {
                         syslog(LOG_ERROR, "ecn_snd_esv");
                         break;
@@ -545 +540 @@
         }
 
-        if(len < 2)
-                return;
-
-        switch(brkdat[0]){
+        if (len < 2)
+                return;
+
+        switch (brkdat[0]) {
         case 0x01:
-                if(brkdat[1] != 0)
+                if (brkdat[1] != 0)
                         main_buzzer_on();
                 else
@@ -556 +551 @@
                 break;
         case 0x02:
-                if(brkdat[1] == 0)
+                if (brkdat[1] == 0)
                         main_nop_timer = 5000 * 1000; /* ５秒後にブザーON */
                 break;
@@ -570 +565 @@
 static void main_timeout()
 {
-        if(main_timer == 0){
+        if (main_timer == 0) {
                 main_ontimer();
         }
 
-        if(main_nop_timer == 0){
+        if (main_nop_timer == 0) {
                 main_nop_timeout();
         }
@@ -583 +578 @@
 static void main_ontimer()
 {
-        switch (main_state)
-        {
+        ER ret;
+
+        switch (main_state) {
+        case main_state_start:
+                /* ECHONETミドルウェアを起動 */
+                ret = ecn_sta_svc();
+                if (ret != E_OK) {
+                        syslog(LOG_ERROR, "ecn_sta_svc");
+                }
+
+                /* １秒後にブザーを検索 */
+                main_state = main_state_search;
+                main_timer = 1000 * 1000;
+                break;
         case main_state_search:
                 /* 電気ポット再検索 */
@@ -608 +615 @@
         /* 電気ポット検索 */
         ret = ecn_esv_inf_req(&esv, EOBJ_NULL, 0xD6);
-        if(ret != E_OK){
+        if (ret != E_OK) {
                 syslog(LOG_ERROR, "ecn_esv_inf_req");
                 return;
@@ -615 +622 @@
         /* 電文送信 */
         ret = ecn_snd_esv(esv);
-        if(ret != E_OK){
+        if (ret != E_OK) {
                 syslog(LOG_ERROR, "ecn_snd_esv");
         }