source: asp3_tinet_ecnl_rx/trunk/app1_usb_watt_meter/src/main.c@ 364

Last change on this file since 364 was 364, checked in by coas-nagasima, 5 years ago

TINETとSocket APIなどを更新
  • Property svn:eol-style set to native
  • Property svn:mime-type set to text/x-csrc;charset=UTF-8
File size: 9.6 KB
Line 
1/*
2 * TOPPERS ECHONET Lite Communication Middleware
3 *
4 * Copyright (C) 2014-2017 Cores Co., Ltd. Japan
5 *
6 * 上記著作権者は，以下の(1)～(4)の条件を満たす場合に限り，本ソフトウェ
7 * ア（本ソフトウェアを改変したものを含む．以下同じ）を使用・複製・改
8 * 変・再配布（以下，利用と呼ぶ）することを無償で許諾する．
9 * (1) 本ソフトウェアをソースコードの形で利用する場合には，上記の著作
10 * 権表示，この利用条件および下記の無保証規定が，そのままの形でソー
11 * スコード中に含まれていること．
12 * (2) 本ソフトウェアを，ライブラリ形式など，他のソフトウェア開発に使
13 * 用できる形で再配布する場合には，再配布に伴うドキュメント（利用
14 * 者マニュアルなど）に，上記の著作権表示，この利用条件および下記
15 * の無保証規定を掲載すること．
16 * (3) 本ソフトウェアを，機器に組み込むなど，他のソフトウェア開発に使
17 * 用できない形で再配布する場合には，次のいずれかの条件を満たすこ
18 * と．
19 * (a) 再配布に伴うドキュメント（利用者マニュアルなど）に，上記の著
20 * 作権表示，この利用条件および下記の無保証規定を掲載すること．
21 * (b) 再配布の形態を，別に定める方法によって，TOPPERSプロジェクトに
22 * 報告すること．
23 * (4) 本ソフトウェアの利用により直接的または間接的に生じるいかなる損
24 * 害からも，上記著作権者およびTOPPERSプロジェクトを免責すること．
25 * また，本ソフトウェアのユーザまたはエンドユーザからのいかなる理
26 * 由に基づく請求からも，上記著作権者およびTOPPERSプロジェクトを
27 * 免責すること．
28 *
29 * 本ソフトウェアは，無保証で提供されているものである．上記著作権者お
30 * よびTOPPERSプロジェクトは，本ソフトウェアに関して，特定の使用目的
31 * に対する適合性も含めて，いかなる保証も行わない．また，本ソフトウェ
32 * アの利用により直接的または間接的に生じたいかなる損害に関しても，そ
33 * の責任を負わない．
34 *
35 * @(#) $Id$
36 */
37
38/*
39 * サンプルプログラム(1)の本体
40 */
41
42#include "shellif.h"
43#include <kernel.h>
44#include <t_stdlib.h>
45#include <sil.h>
46#include <setjmp.h>
47#include <stdlib.h>
48#include <string.h>
49#include "syssvc/serial.h"
50#include "syssvc/syslog.h"
51#include "target_syssvc.h"
52#include "kernel_cfg.h"
53#include "main.h"
54#include <tinet_config.h>
55#include <netinet/in.h>
56#include <netinet/in_itron.h>
57#include <tinet_nic_defs.h>
58#include <tinet_cfg.h>
59#include <netinet/in_var.h>
60#include <net/ethernet.h>
61#include <net/if6_var.h>
62#include <net/net.h>
63#include <net/if_var.h>
64#include <netinet/udp_var.h>
65#include "netapp/dhcp4_cli.h"
66#include "ffarch.h"
67#include "ff.h"
68#include "core/ntshell.h"
69#include "core/ntlibc.h"
70#include "util/ntstdio.h"
71#include "usrcmd.h"
72#include "util/ntopt.h"
73#include "socket_stub.h"
74#include "mbed_api.h"
75#include "usb_hbth.h"
76#include "ntshell_main.h"
77#include <btstack/utils.h>
78#include "client.h"
79#include "ntp_cli.h"
80#include "netcmd.h"
81
82ID ws_api_mailboxid = MAIN_DATAQUEUE;
83#ifndef NOUSE_MPF_NET_BUF
84ID ws_mempoolid = MPF_NET_BUF_256;
85#endif
86#ifdef IF_ETHER_BTUSB
87extern int bt_bnep_mode;
88/* PANU向けリモートアドレス */
89bd_addr_t remote_addr = {0x00,0x1B,0xDC,0x09,0x27,0x26};
90bool_t dhcp_enable = false;
91#else
92bool_t dhcp_enable = true;
93#endif
94
95uint8_t mac_addr[6] = {0x12, 0x34, 0x56, 0x78, 0x9A, 0x01};
96PRI main_task_priority = MAIN_PRIORITY + 1;
97
98static void netif_link_callback(T_IFNET *ether);
99extern int execute_command(int wait);
100
101enum main_state_t {
102 main_state_start,
103 main_state_idle,
104};
105
106struct main_t {
107 int timer;
108 enum main_state_t state;
109 SYSTIM prev, now;
110};
111struct main_t main_obj;
112
113static void main_initialize();
114static int main_get_timer();
115static void main_progress(int interval);
116static void main_timeout();
117
118extern int ntshell_exit;
119
120int uart_read(char *buf, int cnt, void *extobj)
121{
122 struct main_t *obj = (struct main_t *)extobj;
123 int result;
124 ER ret;
125 int timer;
126
127 obj->prev = obj->now;
128
129 /* タイマー取得 */
130 timer = main_get_timer();
131
132 /* 待ち */
133 ret = serial_trea_dat(SIO_PORTID, buf, cnt, timer);
134 if ((ret < 0) && (ret != E_OK) && (ret != E_TMOUT)) {
135 syslog(LOG_NOTICE, "tslp_tsk ret: %s %d", itron_strerror(ret), timer);
136 ntshell_exit = 1;
137 return -1;
138 }
139 result = (int)ret;
140
141 ret = get_tim(&obj->now);
142 if (ret != E_OK) {
143 syslog(LOG_NOTICE, "get_tim ret: %s", itron_strerror(ret));
144 ntshell_exit = 1;
145 return -1;
146 }
147
148 /* 時間経過 */
149 int elapse = obj->now - obj->prev;
150 main_progress(elapse);
151
152 /* タイムアウト処理 */
153 main_timeout();
154
155 return result;
156}
157
158int uart_write(const char *buf, int cnt, void *extobj)
159{
160 return serial_wri_dat(SIO_PORTID, buf, cnt);
161}
162
163ntshell_t ntshell;
164
165/*
166 * メインタスク
167 */
168void main_task(intptr_t exinf)
169{
170#ifdef IF_ETHER_BTUSB
171 // PANU mode
172 bt_bnep_mode = 0;
173#endif
174
175 main_initialize();
176
177 ntshell_init(&ntshell, uart_read, uart_write, cmd_execute, &main_obj);
178 ntshell_set_prompt(&ntshell, "NTShell>");
179 ntshell_execute(&ntshell);
180}
181
182int wolfSSL_Debugging_ON(void);
183
184/*
185 * 初期化
186 */
187static void main_initialize()
188{
189 FILINFO fno;
190#if _USE_LFN
191 char lfn[_MAX_LFN + 1];
192 fno.lfname = lfn;
193 fno.lfsize = _MAX_LFN + 1;
194#endif
195 ER ret;
196
197#ifdef TOPPERS_OMIT_TECS
198 serial_opn_por(SIO_PORTID);
199#endif
200 serial_ctl_por(SIO_PORTID, IOCTL_FCSND | IOCTL_FCRCV);
201
202 //wolfSSL_Debugging_ON();
203
204 ntshell_task_init(uart_read, uart_write, &main_obj);
205
206 main_obj.timer = TMO_FEVR;
207 main_obj.state = main_state_start;
208
209 gpio_t led_blue, led_green, led_red, sw;
210 gpio_init_out(&led_blue, LED_BLUE);
211 gpio_init_out(&led_green, LED_GREEN);
212 gpio_init_out(&led_red, LED_RED);
213 gpio_init_in(&sw, USER_BUTTON0);
214
215 bool_t exec = gpio_read(&sw) == 1;
216
217 gpio_write(&led_blue, 1);
218 gpio_write(&led_green, exec ? 1 : 0);
219 gpio_write(&led_red, 0);
220
221 if (!dhcp_enable) {
222 dhcp4c_rel_info();
223
224 in4_add_ifaddr(IPV4_ADDR_STAIC_LOCAL, IPV4_ADDR_STAIC_LOCAL_MASK);
225 uint8_t data[32], c;
226 int i, j;
227
228 for (i = 0, j = 0; i < sizeof(mac_addr); i++) {
229 c = mac_addr[i] >> 4;
230 data[j++] = (c < 10) ? ('0' + c) : ('A' - 10 + c);
231 c = mac_addr[i] & 0xF;
232 data[j++] = (c < 10) ? ('0' + c) : ('A' - 10 + c);
233 data[j++] = ':';
234 }
235 data[--j] = '\0';
236
237 syslog(LOG_NOTICE, "mac_addr %s %s", data, dhcp_enable ? "dhcp" : "static");
238 }
239
240 /* libcurlとWolfSSLの初期化 */
241 client_init();
242
243 ether_set_link_callback(netif_link_callback);
244
245 /* 初期化 */
246 ffarch_init();
247
248 gpio_write(&led_green, 0);
249
250#ifdef IF_ETHER_BTUSB
251 usbhost_init(USBHOST_TASK);
252#endif
253
254 ret = get_tim(&main_obj.now);
255 if (ret != E_OK) {
256 syslog(LOG_ERROR, "get_tim");
257 ext_tsk();
258 return;
259 }
260}
261
262/*
263 * タイマー取得
264 */
265static int main_get_timer()
266{
267 int timer = main_obj.timer;
268
269 return timer;
270}
271
272/*
273 * 時間経過
274 */
275static void main_progress(int interval)
276{
277 if (main_obj.timer != TMO_FEVR) {
278 main_obj.timer -= interval;
279 if (main_obj.timer < 0) {
280 main_obj.timer = 0;
281 }
282 }
283}
284
285/*
286 * タイムアウト処理
287 */
288static void main_timeout()
289{
290 //if (main_obj.timer == 0) {
291 //}
292}
293
294/* MACアドレスの設定時に呼ばれる */
295void mbed_mac_address(char *mac)
296{
297 memcpy(mac, mac_addr, 6);
298}
299
300void echonet_change_netif_link(uint8_t link_up, uint8_t up);
301
302static void netif_link_callback(T_IFNET *ether)
303{
304 uint8_t link_up = (ether->flags & IF_FLAG_LINK_UP) != 0;
305 uint8_t up = (ether->flags & IF_FLAG_UP) != 0;
306
307 if (dhcp_enable) {
308 if (!link_up)
309 dhcp4c_rel_info();
310 else if (!up)
311 dhcp4c_renew_info();
312 }
313 else {
314 up = link_up;
315 }
316
317 if (link_up && up)
318 ntp_cli_execute();
319
320 ntshell_change_netif_link(link_up, up);
321
322 echonet_change_netif_link(link_up, up);
323}
324
325int custom_rand_generate_seed(uint8_t* output, int32_t sz)
326{
327 SYSTIM now;
328 int32_t i;
329
330 get_tim(&now);
331 srand(now);
332
333 for (i = 0; i < sz; i++)
334 output[i] = rand();
335
336 return 0;
337}
338
339int cmd_creid(int argc, char **argv)
340{
341 if (argc != 2) {
342 printf("creid {client_id}\n");
343 return 0;
344 }
345
346 client_set_client_id(argv[1]);
347
348 return 0;
349}
350
351int cmd_secret(int argc, char **argv)
352{
353 if (argc != 2) {
354 printf("secret {client_secret}\n");
355 return 0;
356 }
357
358 client_set_client_secret(argv[1]);
359
360 return 0;
361}
362
363int cmd_logupload(int argc, char **argv)
364{
365 return client_upload_file(argc, argv);
366}
367
368extern int curl_main(int argc, char **argv);
369
370static const cmd_table_t cmdlist[] = {
371 {"cd", "change directory", usrcmd_cd },
372 {"ls", "list files", usrcmd_ls },
373 {"cp", "copy file", usrcmd_cp },
374 {"rm", "remove file", usrcmd_rm },
375 {"mv", "move file", usrcmd_mv },
376 {"mkdir", "Make directory", usrcmd_mkdir},
377 {"hexdump", "Hex dump", usrcmd_hexdump},
378 {"date", "print date and time", usrcmd_date},
379 {"curl", "Command lines or scripts to transfer data", curl_main},
380 {"ping", "ping", usrcmd_ping},
381 {"dhcpc", "DHCP Client rel/renew/info", usrcmd_dhcp4c},
382 {"dnsc", "DNS client", usrcmd_dnsc },
383 {"ntpc", "NTP client", usrcmd_ntpc },
384 {"creid", "Regster device", cmd_creid},
385 {"secret", "Regster device", cmd_secret},
386 {"gdi", "get_device_id", client_get_device_id},
387 {"gat", "get_access_token", client_get_access_token},
388 {"uat", "update_access_token", client_update_access_token},
389 {"rd", "revoke device", client_revoke},
390 {"uf", "upload_file", client_upload_file},
391 {"logupload", "Upload log to server", cmd_logupload},
392 {"info", "This is a description text string for info command.", usrcmd_info},
393 {"exit", "Exit Natural Tiny Shell", usrcmd_exit},
394};
395cmd_table_info_t cmd_table_info = { cmdlist, sizeof(cmdlist) / sizeof(cmdlist[0]) };
Note: See TracBrowser for help on using the repository browser.