Ignore:
Timestamp:
Feb 1, 2019, 9:57:09 PM (5 years ago)
Author:
coas-nagasima
Message:

TINETとSocket APIなどを更新

Location:
asp3_tinet_ecnl_arm/trunk/app1_usb_watt_meter
Files:
2 added
9 edited

Legend:

Unmodified
Added
Removed

  • asp3_tinet_ecnl_arm/trunk/app1_usb_watt_meter/.cproject

    r352 r364  
    2222                        <storageModule moduleId="com.renesas.cdt.managedbuild.core.toolchainInfo">
    2323                                <option id="toolchain.id" value="gcc-arm-embedded"/>
    24                                 <option id="toolchain.version" value="5.4.1.20160919"/>
     24                                <option id="toolchain.version" value="6.3.1.20170620"/>
    2525                        </storageModule>
    2626                        <storageModule moduleId="cdtBuildSystem" version="4.0.0">
    … …  
    5959                                                        <option id="com.renesas.cdt.managedbuild.gcc.rz.option.warnStack.2041552637" name="Warn if stack size exceeds the limit (-Wstack-usage) (H')" superClass="com.renesas.cdt.managedbuild.gcc.rz.option.warnStack" useByScannerDiscovery="false" value="100" valueType="string"/>
    6060                                                        <targetPlatform archList="all" binaryParser="org.eclipse.cdt.core.ELF" id="ilg.gnuarmeclipse.managedbuild.cross.targetPlatform.1106389026" isAbstract="false" osList="all" superClass="ilg.gnuarmeclipse.managedbuild.cross.targetPlatform"/>
    61                                                         <builder buildPath="${workspace_loc:/app1_usb_watt_meter}/Debug" id="com.renesas.cdt.managedbuild.gcc.rz.builder.1499740602" keepEnvironmentInBuildfile="false" managedBuildOn="false" name="GCC for Renesas Builder" parallelBuildOn="false" superClass="com.renesas.cdt.managedbuild.gcc.rz.builder"/>
     61                                                        <builder buildPath="${workspace_loc:/app1_usb_watt_meter}/Debug" id="com.renesas.cdt.managedbuild.gcc.rz.builder.1499740602" keepEnvironmentInBuildfile="false" managedBuildOn="false" name="GCC for Renesas Builder" parallelBuildOn="true" parallelizationNumber="optimal" superClass="com.renesas.cdt.managedbuild.gcc.rz.builder"/>
    6262                                                        <tool id="com.renesas.cdt.managedbuild.gcc.rz.tool.assembler.473685659" name="Cross ARM GNU Assembler" superClass="com.renesas.cdt.managedbuild.gcc.rz.tool.assembler">
    6363                                                                <option id="ilg.gnuarmeclipse.managedbuild.cross.option.assembler.usepreprocessor.600330630" name="Use preprocessor" superClass="ilg.gnuarmeclipse.managedbuild.cross.option.assembler.usepreprocessor" useByScannerDiscovery="false" value="true" valueType="boolean"/>
    … …  
    127127                        <storageModule moduleId="com.renesas.cdt.managedbuild.core.toolchainInfo">
    128128                                <option id="toolchain.id" value="gcc-arm-embedded"/>
    129                                 <option id="toolchain.version" value="5.4.1.20160919"/>
     129                                <option id="toolchain.version" value="6.3.1.20170620"/>
    130130                        </storageModule>
    131131                        <storageModule moduleId="cdtBuildSystem" version="4.0.0">
    … …  
    164164                                                        <option id="com.renesas.cdt.managedbuild.gcc.rz.option.warnStack.504056262" name="Warn if stack size exceeds the limit (-Wstack-usage) (H')" superClass="com.renesas.cdt.managedbuild.gcc.rz.option.warnStack" useByScannerDiscovery="false" value="100" valueType="string"/>
    165165                                                        <targetPlatform archList="all" binaryParser="org.eclipse.cdt.core.ELF" id="ilg.gnuarmeclipse.managedbuild.cross.targetPlatform.211973441" isAbstract="false" osList="all" superClass="ilg.gnuarmeclipse.managedbuild.cross.targetPlatform"/>
    166                                                         <builder buildPath="${workspace_loc:/app1_usb_watt_meter}/DebugEther" id="com.renesas.cdt.managedbuild.gcc.rz.builder.559752886" keepEnvironmentInBuildfile="false" managedBuildOn="false" name="GCC for Renesas Builder" parallelBuildOn="false" superClass="com.renesas.cdt.managedbuild.gcc.rz.builder"/>
     166                                                        <builder buildPath="${workspace_loc:/app1_usb_watt_meter}/DebugEther" id="com.renesas.cdt.managedbuild.gcc.rz.builder.559752886" keepEnvironmentInBuildfile="false" managedBuildOn="false" name="GCC for Renesas Builder" parallelBuildOn="true" parallelizationNumber="optimal" superClass="com.renesas.cdt.managedbuild.gcc.rz.builder"/>
    167167                                                        <tool id="com.renesas.cdt.managedbuild.gcc.rz.tool.assembler.541834310" name="Cross ARM GNU Assembler" superClass="com.renesas.cdt.managedbuild.gcc.rz.tool.assembler">
    168168                                                                <option id="ilg.gnuarmeclipse.managedbuild.cross.option.assembler.usepreprocessor.1603061550" name="Use preprocessor" superClass="ilg.gnuarmeclipse.managedbuild.cross.option.assembler.usepreprocessor" useByScannerDiscovery="false" value="true" valueType="boolean"/>
    … …  
    232232                        <storageModule moduleId="com.renesas.cdt.managedbuild.core.toolchainInfo">
    233233                                <option id="toolchain.id" value="gcc-arm-embedded"/>
    234                                 <option id="toolchain.version" value="5.4.1.20160919"/>
     234                                <option id="toolchain.version" value="6.3.1.20170620"/>
    235235                        </storageModule>
    236236                        <storageModule moduleId="cdtBuildSystem" version="4.0.0">
    … …  
    269269                                                        <option id="com.renesas.cdt.managedbuild.gcc.rz.option.warnStack.1222794445" name="Warn if stack size exceeds the limit (-Wstack-usage) (H')" superClass="com.renesas.cdt.managedbuild.gcc.rz.option.warnStack" useByScannerDiscovery="false" value="100" valueType="string"/>
    270270                                                        <targetPlatform archList="all" binaryParser="org.eclipse.cdt.core.ELF" id="ilg.gnuarmeclipse.managedbuild.cross.targetPlatform.1527919964" isAbstract="false" osList="all" superClass="ilg.gnuarmeclipse.managedbuild.cross.targetPlatform"/>
    271                                                         <builder buildPath="${workspace_loc:/app1_usb_watt_meter}/DebugEnbt" id="com.renesas.cdt.managedbuild.gcc.rz.builder.896433184" keepEnvironmentInBuildfile="false" managedBuildOn="false" name="GCC for Renesas Builder" parallelBuildOn="false" superClass="com.renesas.cdt.managedbuild.gcc.rz.builder"/>
     271                                                        <builder buildPath="${workspace_loc:/app1_usb_watt_meter}/DebugEnbt" id="com.renesas.cdt.managedbuild.gcc.rz.builder.896433184" keepEnvironmentInBuildfile="false" managedBuildOn="false" name="GCC for Renesas Builder" parallelBuildOn="true" parallelizationNumber="optimal" superClass="com.renesas.cdt.managedbuild.gcc.rz.builder"/>
    272272                                                        <tool id="com.renesas.cdt.managedbuild.gcc.rz.tool.assembler.893283254" name="Cross ARM GNU Assembler" superClass="com.renesas.cdt.managedbuild.gcc.rz.tool.assembler">
    273273                                                                <option id="ilg.gnuarmeclipse.managedbuild.cross.option.assembler.usepreprocessor.1741240748" name="Use preprocessor" superClass="ilg.gnuarmeclipse.managedbuild.cross.option.assembler.usepreprocessor" useByScannerDiscovery="false" value="true" valueType="boolean"/>
    … …  
    341341                </configuration>
    342342        </storageModule>
     343        <storageModule moduleId="org.eclipse.cdt.make.core.buildtargets"/>
    343344</cproject>

  • asp3_tinet_ecnl_arm/trunk/app1_usb_watt_meter/Debug/Makefile

    r352 r364  
    182182        CDEFS := -DTOPPERS_OMIT_TECS $(CDEFS)
    183183endif
    184 CDEFS := $(CDEFS) -DDHCP4_CLI_CFG -DUSE_PING -DUSE_RESOLVER -DUSE_NETAPP_SUBR -DECHONET_USE_MALLOC -DHAVE_CONFIG_H -DWOLFSSL_USER_SETTINGS -DRamDisk=_binary_______ntshell_src_rom_fs_bin_start
     184CDEFS := $(CDEFS) -DDHCP4_CLI_CFG -DUSE_PING -DUSE_RESOLVER -DUSE_NETAPP_SUBR -DNOUSE_MPF_NET_BUF -DECHONET_USE_MALLOC -DHAVE_CONFIG_H -DWOLFSSL_USER_SETTINGS -DRamDisk=_binary_______ntshell_src_rom_fs_bin_start
    185185INCLUDES := -I. -I$(SRCDIR)/include -I$(SRCDIR) \
    186186        -I$(SRCDIR)/../btstack/include \
    … …  
    196196        -I$(SRCDIR)/../curl-7.57.0 \
    197197        $(INCLUDES)
    198 LDFLAGS := $(LDFLAGS) -Wl,-Map=$(OBJNAME).map,--cref -L.
     198LDFLAGS := $(LDFLAGS) -L.
    199199LIBS := $(LIBS) $(CXXLIBS)
    200200CFLAGS = $(COPTS) $(CDEFS) $(INCLUDES)
    … …  
    207207APPL_COBJS := $(APPL_COBJS) netcmd.o fdtable.o io_stub.o socket_stub.o ffarch.o diskio.o ff.o sdfs.o ccsbcs.o ntshell.o text_editor.o text_history.o usrcmd.o vtrecv.o vtsend.o ntlibc.o ntstdio.o ntopt.o syscall.o tlsf.o
    208208APPLDIRS := $(APPLDIRS) ../../ntshell/lcd
    209 APPL_COBJS := $(APPL_COBJS) draw_font.o misaki_font.o
     209APPL_COBJS := $(APPL_COBJS) draw_font.o shnm12_font.o
     210APPL_CFLAGS := $(APPL_CFLAGS) -DSHNM12_FONT
    210211
    211212#
    … …  
    220221APPL_ASMOBJS :=
    221222ifdef USE_CXX
    222         APPL_CXXOBJS := main.o ntshell_main.o echonet_main.o client.o
     223        APPL_CXXOBJS := main.o ntshell_main.o echonet_main.o client.o jsonsl.o
    223224        APPL_COBJS := $(APPL_COBJS)
    224225else
    225         APPL_COBJS := $(APPL_COBJS) main.o ntshell_main.o echonet_main.o client.o
     226        APPL_COBJS := $(APPL_COBJS) main.o ntshell_main.o echonet_main.o client.o jsonsl.o
    226227endif
    227228APPL_COBJS := $(APPL_COBJS) log_output.o vasyslog.o t_perror.o strerror.o
    … …  
    232233endif
    233234
    234 
    235 #
    236 #  ネットワークサービスの定義
    237 #
    238 NO_USE_TINET_LIBRARY = true
    239 
    240 #  ネットワークインタフェースの選択、何れか一つ選択する。
    241 NET_IF = ether
    242 
    243 #  イーサネット・ディバイスドライバの選択
    244 NET_DEV = if_btusb
    245 
    246 #  ネットワーク層の選択
    247 #SUPPORT_INET6 = true
    248 SUPPORT_INET4 = true
    249 
    250 #  API に組込む機能の選択
    251 #API_CFG_IP4MAPPED_ADDR = true
    252 
    253 #  トランスポート層の選択
    254 SUPPORT_TCP = true
    255 SUPPORT_UDP = true
    256 
    257 # IGMPを有効に設定
    258 SUPPORT_IGMP = true
    259 
    260 #
    261 #  ネットワークサービスの Makefile のインクルード
    262 #
    263 include $(SRCDIR)/$(TINETDIR)/Makefile.tinet
     235ifdef TINETDIR
     236        #
     237        #  ネットワークサービスの定義
     238        #
     239        NO_USE_TINET_LIBRARY = true
     240
     241        #  ネットワークインタフェースの選択、何れか一つ選択する。
     242        NET_IF = ether
     243
     244        #  イーサネット・ディバイスドライバの選択
     245        NET_DEV = if_btusb
     246
     247        #  ネットワーク層の選択
     248        #SUPPORT_INET6 = true
     249        SUPPORT_INET4 = true
     250
     251        #  API に組込む機能の選択
     252        #API_CFG_IP4MAPPED_ADDR = true
     253
     254        #  トランスポート層の選択
     255        SUPPORT_TCP = true
     256        SUPPORT_UDP = true
     257
     258        # IGMPを有効に設定
     259        SUPPORT_IGMP = true
     260
     261        #
     262        #  ネットワークサービスの Makefile のインクルード
     263        #
     264        include $(SRCDIR)/$(TINETDIR)/Makefile.tinet
     265endif
    264266
    265267#
    … …  
    294296#  コンフィギュレータに関する定義
    295297#
    296 CFG_TRB := -T $(TINET_ROOT)/tinet.trb:tcpip -T ../../ntshell/echonet/echonet.trb:echonet -T $(TARGETDIR)/target_kernel.trb:kernel
    297 CFG_TABS := --api-table $(TINET_ROOT)/tcpip_api.def:tcpip \
     298ifndef TINETDIR
     299  CFG_TRB := -T $(TARGETDIR)/target_kernel.trb
     300  CFG_TABS := --api-table $(SRCDIR)/kernel/kernel_api.def \
     301                        --symval-table $(SRCDIR)/kernel/kernel_sym.def $(CFG_TABS)
     302else
     303  CFG_TRB := -T $(TINET_ROOT)/tinet.trb:tcpip -T ../../ntshell/echonet/echonet.trb:echonet -T $(TARGETDIR)/target_kernel.trb:kernel
     304  CFG_TABS := --api-table $(TINET_ROOT)/tcpip_api.def:tcpip \
    298305                        --api-table ../../ntshell/echonet/echonet_api.def:echonet \
    299306                        --api-table $(SRCDIR)/kernel/kernel_api.def:kernel \
    … …  
    301308                        --symval-table ../../ntshell/echonet/echonet_sym.def \
    302309                        --symval-table $(SRCDIR)/kernel/kernel_sym.def $(CFG_TABS)
     310endif
    303311CFG_ASMOBJS := $(CFG_ASMOBJS)
    304312CFG_COBJS := kernel_cfg.o echonet_cfg.o $(CFG_COBJS)
    … …  
    446454
    447455#
     456#  並列makeのための依存関係の定義
     457#
     458$(APPL_OBJS) $(filter-out $(CFG_DMY), $(SYSSVC_OBJS)): | kernel_cfg.timestamp
     459$(APPL_ASMOBJS) $(filter-out $(CFG_DMY), $(SYSSVC_ASMOBJS)) $(KERNEL_ASMOBJS) $(CFG_ASMOBJS): \
     460                                                                                                                | offset.timestamp
     461
     462#
    448463#  特別な依存関係の定義
    449464#
    … …  
    454469#
    455470$(OBJFILE): $(ALL_OBJS) $(LIBS_DEP)
    456         $(LINK) $(CFLAGS) $(LDFLAGS) $(OBJ_LDFLAGS) -o $(OBJFILE) \
     471        $(LINK) $(CFLAGS) $(LDFLAGS) $(OBJ_LDFLAGS) -o $(OBJFILE) -Wl,-Map=$(OBJNAME).map,--cref \
    457472                        $(START_OBJS) $(APPL_OBJS) $(SYSSVC_OBJS) $(CFG_OBJS) \
    458473                        -Wl,--start-group $(ALL_LIBS) -Wl,--end-group $(END_OBJS)

  • asp3_tinet_ecnl_arm/trunk/app1_usb_watt_meter/DebugEnbt/Makefile

    r352 r364  
    182182        CDEFS := -DTOPPERS_OMIT_TECS $(CDEFS)
    183183endif
    184 CDEFS := $(CDEFS) -DIF_ETHER_MULTI_NIC -DDHCP4_CLI_CFG -DUSE_PING -DUSE_RESOLVER -DUSE_NETAPP_SUBR -DECHONET_USE_MALLOC -DHAVE_CONFIG_H -DWOLFSSL_USER_SETTINGS -DRamDisk=_binary_______ntshell_src_rom_fs_bin_start
     184CDEFS := $(CDEFS) -DIF_ETHER_MULTI_NIC -DDHCP4_CLI_CFG -DUSE_PING -DUSE_RESOLVER -DUSE_NETAPP_SUBR -DNOUSE_MPF_NET_BUF -DECHONET_USE_MALLOC -DHAVE_CONFIG_H -DWOLFSSL_USER_SETTINGS -DRamDisk=_binary_______ntshell_src_rom_fs_bin_start
    185185INCLUDES := -I. -I$(SRCDIR)/include -I$(SRCDIR) \
    186186        -I$(SRCDIR)/../btstack/include \
    … …  
    196196        -I$(SRCDIR)/../curl-7.57.0 \
    197197        $(INCLUDES)
    198 LDFLAGS := $(LDFLAGS) -Wl,-Map=$(OBJNAME).map,--cref -L.
     198LDFLAGS := $(LDFLAGS) -L.
    199199LIBS := $(LIBS) $(CXXLIBS)
    200200CFLAGS = $(COPTS) $(CDEFS) $(INCLUDES)
    … …  
    207207APPL_COBJS := $(APPL_COBJS) netcmd.o fdtable.o io_stub.o socket_stub.o ffarch.o diskio.o ff.o sdfs.o ccsbcs.o ntshell.o text_editor.o text_history.o usrcmd.o vtrecv.o vtsend.o ntlibc.o ntstdio.o ntopt.o syscall.o tlsf.o
    208208APPLDIRS := $(APPLDIRS) ../../ntshell/lcd
    209 APPL_COBJS := $(APPL_COBJS) draw_font.o misaki_font.o
     209APPL_COBJS := $(APPL_COBJS) draw_font.o shnm12_font.o
     210APPL_CFLAGS := $(APPL_CFLAGS) -DSHNM12_FONT
    210211
    211212#
    … …  
    220221APPL_ASMOBJS :=
    221222ifdef USE_CXX
    222         APPL_CXXOBJS := main.o ntshell_main.o echonet_main.o client.o
     223        APPL_CXXOBJS := main.o ntshell_main.o echonet_main.o client.o jsonsl.o
    223224        APPL_COBJS := $(APPL_COBJS)
    224225else
    225         APPL_COBJS := $(APPL_COBJS) main.o ntshell_main.o echonet_main.o client.o
     226        APPL_COBJS := $(APPL_COBJS) main.o ntshell_main.o echonet_main.o client.o jsonsl.o
    226227endif
    227228APPL_COBJS := $(APPL_COBJS) log_output.o vasyslog.o t_perror.o strerror.o
    … …  
    232233endif
    233234
    234 
    235 #
    236 #  ネットワークサービスの定義
    237 #
    238 NO_USE_TINET_LIBRARY = true
    239 
    240 #  ネットワークインタフェースの選択、何れか一つ選択する。
    241 NET_IF = ether
    242 
    243 #  イーサネット・ディバイスドライバの選択
    244 NET_DEV = if_enbt
    245 
    246 #  ネットワーク層の選択
    247 #SUPPORT_INET6 = true
    248 SUPPORT_INET4 = true
    249 
    250 #  API に組込む機能の選択
    251 #API_CFG_IP4MAPPED_ADDR = true
    252 
    253 #  トランスポート層の選択
    254 SUPPORT_TCP = true
    255 SUPPORT_UDP = true
    256 
    257 # IGMPを有効に設定
    258 SUPPORT_IGMP = true
    259 
    260 #
    261 #  ネットワークサービスの Makefile のインクルード
    262 #
    263 include $(SRCDIR)/$(TINETDIR)/Makefile.tinet
     235ifdef TINETDIR
     236        #
     237        #  ネットワークサービスの定義
     238        #
     239        NO_USE_TINET_LIBRARY = true
     240
     241        #  ネットワークインタフェースの選択、何れか一つ選択する。
     242        NET_IF = ether
     243
     244        #  イーサネット・ディバイスドライバの選択
     245        NET_DEV = if_enbt
     246
     247        #  ネットワーク層の選択
     248        #SUPPORT_INET6 = true
     249        SUPPORT_INET4 = true
     250
     251        #  API に組込む機能の選択
     252        #API_CFG_IP4MAPPED_ADDR = true
     253
     254        #  トランスポート層の選択
     255        SUPPORT_TCP = true
     256        SUPPORT_UDP = true
     257
     258        # IGMPを有効に設定
     259        SUPPORT_IGMP = true
     260
     261        #
     262        #  ネットワークサービスの Makefile のインクルード
     263        #
     264        include $(SRCDIR)/$(TINETDIR)/Makefile.tinet
     265endif
    264266
    265267#
    … …  
    294296#  コンフィギュレータに関する定義
    295297#
    296 CFG_TRB := -T $(TINET_ROOT)/tinet.trb:tcpip -T ../../ntshell/echonet/echonet.trb:echonet -T $(TARGETDIR)/target_kernel.trb:kernel
    297 CFG_TABS := --api-table $(TINET_ROOT)/tcpip_api.def:tcpip \
     298ifndef TINETDIR
     299  CFG_TRB := -T $(TARGETDIR)/target_kernel.trb
     300  CFG_TABS := --api-table $(SRCDIR)/kernel/kernel_api.def \
     301                        --symval-table $(SRCDIR)/kernel/kernel_sym.def $(CFG_TABS)
     302else
     303  CFG_TRB := -T $(TINET_ROOT)/tinet.trb:tcpip -T ../../ntshell/echonet/echonet.trb:echonet -T $(TARGETDIR)/target_kernel.trb:kernel
     304  CFG_TABS := --api-table $(TINET_ROOT)/tcpip_api.def:tcpip \
    298305                        --api-table ../../ntshell/echonet/echonet_api.def:echonet \
    299306                        --api-table $(SRCDIR)/kernel/kernel_api.def:kernel \
    … …  
    301308                        --symval-table ../../ntshell/echonet/echonet_sym.def \
    302309                        --symval-table $(SRCDIR)/kernel/kernel_sym.def $(CFG_TABS)
     310endif
    303311CFG_ASMOBJS := $(CFG_ASMOBJS)
    304312CFG_COBJS := kernel_cfg.o echonet_cfg.o $(CFG_COBJS)
    … …  
    446454
    447455#
     456#  並列makeのための依存関係の定義
     457#
     458$(APPL_OBJS) $(filter-out $(CFG_DMY), $(SYSSVC_OBJS)): | kernel_cfg.timestamp
     459$(APPL_ASMOBJS) $(filter-out $(CFG_DMY), $(SYSSVC_ASMOBJS)) $(KERNEL_ASMOBJS) $(CFG_ASMOBJS): \
     460                                                                                                                | offset.timestamp
     461
     462#
    448463#  特別な依存関係の定義
    449464#
    … …  
    454469#
    455470$(OBJFILE): $(ALL_OBJS) $(LIBS_DEP)
    456         $(LINK) $(CFLAGS) $(LDFLAGS) $(OBJ_LDFLAGS) -o $(OBJFILE) \
     471        $(LINK) $(CFLAGS) $(LDFLAGS) $(OBJ_LDFLAGS) -o $(OBJFILE) -Wl,-Map=$(OBJNAME).map,--cref \
    457472                        $(START_OBJS) $(APPL_OBJS) $(SYSSVC_OBJS) $(CFG_OBJS) \
    458473                        -Wl,--start-group $(ALL_LIBS) -Wl,--end-group $(END_OBJS)

  • asp3_tinet_ecnl_arm/trunk/app1_usb_watt_meter/DebugEther/Makefile

    r352 r364  
    182182        CDEFS := -DTOPPERS_OMIT_TECS $(CDEFS)
    183183endif
    184 CDEFS := $(CDEFS) -DDHCP4_CLI_CFG -DUSE_PING -DUSE_RESOLVER -DUSE_NETAPP_SUBR -DECHONET_USE_MALLOC -DHAVE_CONFIG_H -DWOLFSSL_USER_SETTINGS -DRamDisk=_binary_______ntshell_src_rom_fs_bin_start
     184CDEFS := $(CDEFS) -DDHCP4_CLI_CFG -DUSE_PING -DUSE_RESOLVER -DUSE_NETAPP_SUBR -DNOUSE_MPF_NET_BUF -DECHONET_USE_MALLOC -DHAVE_CONFIG_H -DWOLFSSL_USER_SETTINGS -DRamDisk=_binary_______ntshell_src_rom_fs_bin_start
    185185INCLUDES := -I. -I$(SRCDIR)/include -I$(SRCDIR) \
    186186        -I$(SRCDIR)/../btstack/include \
    … …  
    196196        -I$(SRCDIR)/../curl-7.57.0 \
    197197        $(INCLUDES)
    198 LDFLAGS := $(LDFLAGS) -Wl,-Map=$(OBJNAME).map,--cref -L.
     198LDFLAGS := $(LDFLAGS) -L.
    199199LIBS := $(LIBS) $(CXXLIBS)
    200200CFLAGS = $(COPTS) $(CDEFS) $(INCLUDES)
    … …  
    207207APPL_COBJS := $(APPL_COBJS) netcmd.o fdtable.o io_stub.o socket_stub.o ffarch.o diskio.o ff.o sdfs.o ccsbcs.o ntshell.o text_editor.o text_history.o usrcmd.o vtrecv.o vtsend.o ntlibc.o ntstdio.o ntopt.o syscall.o tlsf.o
    208208APPLDIRS := $(APPLDIRS) ../../ntshell/lcd
    209 APPL_COBJS := $(APPL_COBJS) draw_font.o misaki_font.o
     209APPL_COBJS := $(APPL_COBJS) draw_font.o shnm12_font.o
     210APPL_CFLAGS := $(APPL_CFLAGS) -DSHNM12_FONT
    210211
    211212#
    … …  
    220221APPL_ASMOBJS :=
    221222ifdef USE_CXX
    222         APPL_CXXOBJS := main.o ntshell_main.o echonet_main.o client.o
     223        APPL_CXXOBJS := main.o ntshell_main.o echonet_main.o client.o jsonsl.o
    223224        APPL_COBJS := $(APPL_COBJS)
    224225else
    225         APPL_COBJS := $(APPL_COBJS) main.o ntshell_main.o echonet_main.o client.o
     226        APPL_COBJS := $(APPL_COBJS) main.o ntshell_main.o echonet_main.o client.o jsonsl.o
    226227endif
    227228APPL_COBJS := $(APPL_COBJS) log_output.o vasyslog.o t_perror.o strerror.o
    … …  
    232233endif
    233234
    234 
    235 #
    236 #  ネットワークサービスの定義
    237 #
    238 NO_USE_TINET_LIBRARY = true
    239 
    240 #  ネットワークインタフェースの選択、何れか一つ選択する。
    241 NET_IF = ether
    242 
    243 #  イーサネット・ディバイスドライバの選択
     235ifdef TINETDIR
     236        #
     237        #  ネットワークサービスの定義
     238        #
     239        NO_USE_TINET_LIBRARY = true
     240
     241        #  ネットワークインタフェースの選択、何れか一つ選択する。
     242        NET_IF = ether
     243
     244        #  イーサネット・ディバイスドライバの選択
    244245        NET_DEV = if_mbed
    245246
    246 #  ネットワーク層の選択
    247 #SUPPORT_INET6 = true
    248 SUPPORT_INET4 = true
    249 
    250 #  API に組込む機能の選択
    251 #API_CFG_IP4MAPPED_ADDR = true
    252 
    253 #  トランスポート層の選択
    254 SUPPORT_TCP = true
    255 SUPPORT_UDP = true
    256 
    257 # IGMPを有効に設定
    258 SUPPORT_IGMP = true
    259 
    260 #
    261 #  ネットワークサービスの Makefile のインクルード
    262 #
    263 include $(SRCDIR)/$(TINETDIR)/Makefile.tinet
     247        #  ネットワーク層の選択
     248        #SUPPORT_INET6 = true
     249        SUPPORT_INET4 = true
     250
     251        #  API に組込む機能の選択
     252        #API_CFG_IP4MAPPED_ADDR = true
     253
     254        #  トランスポート層の選択
     255        SUPPORT_TCP = true
     256        SUPPORT_UDP = true
     257
     258        # IGMPを有効に設定
     259        SUPPORT_IGMP = true
     260
     261        #
     262        #  ネットワークサービスの Makefile のインクルード
     263        #
     264        include $(SRCDIR)/$(TINETDIR)/Makefile.tinet
     265endif
    264266
    265267#
    … …  
    294296#  コンフィギュレータに関する定義
    295297#
    296 CFG_TRB := -T $(TINET_ROOT)/tinet.trb:tcpip -T ../../ntshell/echonet/echonet.trb:echonet -T $(TARGETDIR)/target_kernel.trb:kernel
    297 CFG_TABS := --api-table $(TINET_ROOT)/tcpip_api.def:tcpip \
     298ifndef TINETDIR
     299  CFG_TRB := -T $(TARGETDIR)/target_kernel.trb
     300  CFG_TABS := --api-table $(SRCDIR)/kernel/kernel_api.def \
     301                        --symval-table $(SRCDIR)/kernel/kernel_sym.def $(CFG_TABS)
     302else
     303  CFG_TRB := -T $(TINET_ROOT)/tinet.trb:tcpip -T ../../ntshell/echonet/echonet.trb:echonet -T $(TARGETDIR)/target_kernel.trb:kernel
     304  CFG_TABS := --api-table $(TINET_ROOT)/tcpip_api.def:tcpip \
    298305                        --api-table ../../ntshell/echonet/echonet_api.def:echonet \
    299306                        --api-table $(SRCDIR)/kernel/kernel_api.def:kernel \
    … …  
    301308                        --symval-table ../../ntshell/echonet/echonet_sym.def \
    302309                        --symval-table $(SRCDIR)/kernel/kernel_sym.def $(CFG_TABS)
     310endif
    303311CFG_ASMOBJS := $(CFG_ASMOBJS)
    304312CFG_COBJS := kernel_cfg.o echonet_cfg.o $(CFG_COBJS)
    … …  
    446454
    447455#
     456#  並列makeのための依存関係の定義
     457#
     458$(APPL_OBJS) $(filter-out $(CFG_DMY), $(SYSSVC_OBJS)): | kernel_cfg.timestamp
     459$(APPL_ASMOBJS) $(filter-out $(CFG_DMY), $(SYSSVC_ASMOBJS)) $(KERNEL_ASMOBJS) $(CFG_ASMOBJS): \
     460                                                                                                                | offset.timestamp
     461
     462#
    448463#  特別な依存関係の定義
    449464#
    … …  
    454469#
    455470$(OBJFILE): $(ALL_OBJS) $(LIBS_DEP)
    456         $(LINK) $(CFLAGS) $(LDFLAGS) $(OBJ_LDFLAGS) -o $(OBJFILE) \
     471        $(LINK) $(CFLAGS) $(LDFLAGS) $(OBJ_LDFLAGS) -o $(OBJFILE) -Wl,-Map=$(OBJNAME).map,--cref \
    457472                        $(START_OBJS) $(APPL_OBJS) $(SYSSVC_OBJS) $(CFG_OBJS) \
    458473                        -Wl,--start-group $(ALL_LIBS) -Wl,--end-group $(END_OBJS)

  • asp3_tinet_ecnl_arm/trunk/app1_usb_watt_meter/src/client.c

    r352 r364  
    11/*
    22 *  TOPPERS ECHONET Lite Communication Middleware
    3  * 
     3 *
    44 *  Copyright (C) 2016 Cores Co., Ltd. Japan
    5  * 
     5 *
    66 *  上記著作権者は，以下の(1)～(4)の条件を満たす場合に限り，本ソフトウェ
    77 *  ア（本ソフトウェアを改変したものを含む．以下同じ）を使用・複製・改
    … …  
    2626 *      由に基づく請求からも，上記著作権者およびTOPPERSプロジェクトを
    2727 *      免責すること．
    28  * 
     28 *
    2929 *  本ソフトウェアは，無保証で提供されているものである．上記著作権者お
    3030 *  よびTOPPERSプロジェクトは，本ソフトウェアに関して，特定の使用目的
    … …  
    3232 *  アの利用により直接的または間接的に生じたいかなる損害に関しても，そ
    3333 *  の責任を負わない．
    34  * 
     34 *
    3535 *  @(#) $Id$
    3636 */
    … …  
    4848#include "ff.h"
    4949#include "util/ntstdio.h"
     50#include "client.h"
     51#include "jsonsl.h"
    5052
    5153#define SKIP_PEER_VERIFICATION
    5254//#define SKIP_HOSTNAME_VERIFICATION
     55
     56const char SCOPE_DRIVE_FILE[] = "https://www.googleapis.com/auth/drive.file";
     57const char GRANT_TYPE_DEVICE[] = "http://oauth.net/grant_type/device/1.0";
     58
    5359char response[80];
    54 extern ntstdio_t ntstdio;
     60char errbuf[CURL_ERROR_SIZE];
     61
     62google_drive_t google_drive;
     63
     64void curl_setopt_common(CURL *curl);
     65int google_drive_error_callback(jsonsl_t jsn, jsonsl_error_t err,
     66        struct jsonsl_state_st *state, char *errat);
     67void google_drive_state_callback(jsonsl_t jsn, jsonsl_action_t action,
     68        struct jsonsl_state_st *state, const char *buf);
    5569
    5670void client_init(void)
    5771{
     72        google_drive_t *gd = &google_drive;
     73        jsonsl_t jsn;
     74
     75        memset(gd, 0, sizeof(google_drive_t));
     76        memcpy(gd->fname, "1:/log/20160101000000.log", sizeof(gd->fname));
     77
     78        jsn = gd->jsn = jsonsl_new(3);
     79        jsn->data = gd;
     80        jsn->error_callback = google_drive_error_callback;
     81        jsn->action_callback = google_drive_state_callback;
     82        jsonsl_enable_all_callbacks(jsn);
     83
    5884        //uITRON4_minit(ITRON_POOL_SIZE);
    5985
    … …  
    6187}
    6288
    63 size_t write_data(void *buffer, size_t size, size_t nmemb, void *userp)
    64 {
    65         int rest = size * nmemb;
     89size_t write_callback(void *buffer, size_t size, size_t nmemb, void *arg)
     90{
     91        google_drive_t *gd = (google_drive_t *)arg;
     92        jsonsl_t jsn = gd->jsn;
     93        size_t len = size * nmemb, pos;
     94        jsonsl_char_t data;
     95
     96        for (pos = 0; pos < len; pos++) {
     97                data = *((jsonsl_char_t *)&((uint8_t *)buffer)[pos]);
     98
     99                if ((gd->jsn_buf_pos >= 0) && (gd->jsn_buf_pos < sizeof(gd->jsn_buf)))
     100                        gd->jsn_buf[gd->jsn_buf_pos++] = data;
     101                jsonsl_feed(jsn, &data, 1);
     102        }
     103
     104        return len;
     105}
     106
     107void get_device_id_state_start(google_drive_t *gd, struct jsonsl_state_st *state, const char *buf)
     108{
     109        switch (gd->state) {
     110        case psRoot:
     111                if (state->level != 2) {
     112                        break;
     113                }
     114                else if (strcmp(buf, "device_code") == 0) {
     115                        gd->state = psDeviceCode;
     116                }
     117                else if (strcmp(buf, "user_code") == 0) {
     118                        gd->state = psUserCode;
     119                }
     120                else if (strcmp(buf, "expires_in") == 0) {
     121                        gd->state = psExpiresIn;
     122                }
     123                else if (strcmp(buf, "interval") == 0) {
     124                        gd->state = psInterval;
     125                }
     126                else if (strcmp(buf, "verification_url") == 0) {
     127                        gd->state = psVerificationUrl;
     128                }
     129                else if (strcmp(buf, "error") == 0) {
     130                        gd->state = psError;
     131                }
     132                else if (strcmp(buf, "error_description") == 0) {
     133                        gd->state = psErrorDescription;
     134                }
     135                break;
     136        case psDeviceCode:
     137                if (state->type == JSONSL_T_STRING) {
     138                        strlcpy(gd->credential.device_code, buf, sizeof(gd->credential.device_code));
     139                        gd->state = psRoot;
     140                }
     141                break;
     142        case psUserCode:
     143                if (state->type == JSONSL_T_STRING) {
     144                        strlcpy(gd->credential.user_code, buf, sizeof(gd->credential.user_code));
     145                        gd->state = psRoot;
     146                }
     147                break;
     148        case psExpiresIn:
     149                if (state->type == JSONSL_T_SPECIAL) {
     150                        gd->credential.expires_in = atoi(buf);
     151                        gd->state = psRoot;
     152                }
     153                break;
     154        case psInterval:
     155                if (state->type == JSONSL_T_SPECIAL) {
     156                        gd->credential.interval = atoi(buf);
     157                        gd->state = psRoot;
     158                }
     159                break;
     160        case psVerificationUrl:
     161                if (state->type == JSONSL_T_STRING) {
     162                        strlcpy(gd->credential.verification_url, buf, sizeof(gd->credential.verification_url));
     163                        gd->state = psRoot;
     164                }
     165                break;
     166        case psError:
     167                if (state->type == JSONSL_T_STRING) {
     168                        strlcpy(gd->error.error, buf, sizeof(gd->error.error));
     169                        gd->state = psRoot;
     170                }
     171                break;
     172        case psErrorDescription:
     173                if (state->type == JSONSL_T_STRING) {
     174                        strlcpy(gd->error.error_description, buf, sizeof(gd->error.error_description));
     175                        gd->state = psRoot;
     176                }
     177                break;
     178        }
     179}
     180
     181void get_device_id_state_end(google_drive_t *gd, struct jsonsl_state_st *state, const char *buf)
     182{
     183}
     184
     185int get_device_id(google_drive_t *gd, const char *scope)
     186{
     187        client_info_t *client_info = &gd->client_info;
     188        credential_t *credential = &gd->credential;
     189        CURLcode ret;
     190        CURL *curl;
     191        struct curl_slist *slist1;
     192        size_t len;
     193        char *postdata;
     194        jsonsl_t jsn = gd->jsn;
     195
     196        gd->jsn_buf_pos = -1;
     197
     198        jsonsl_reset(jsn);
     199        gd->start = get_device_id_state_start;
     200        gd->end = get_device_id_state_end;
     201
     202        slist1 = NULL;
     203        slist1 = curl_slist_append(slist1, "Content-Type: application/x-www-form-urlencoded");
     204
     205        curl = curl_easy_init();
     206
     207        char *client_id = curl_easy_escape(curl, client_info->client_id, strnlen(client_info->client_id, sizeof(client_info->client_id)));
     208        char *esc_scope = curl_easy_escape(curl, scope, strlen(scope));
     209
     210        len = sizeof("client_id=") + strlen(client_id) + sizeof("scope=") + strlen(esc_scope);
     211        postdata = malloc(len);
     212        snprintf(postdata, len, "client_id=%s&scope=%s", client_id, esc_scope);
     213
     214        curl_free(client_id);
     215        curl_free(esc_scope);
     216
     217        curl_easy_setopt(curl, CURLOPT_URL, "https://accounts.google.com/o/oauth2/device/code");
     218        curl_easy_setopt(curl, CURLOPT_POSTFIELDS, postdata);
     219        curl_easy_setopt(curl, CURLOPT_POSTFIELDSIZE_LARGE, (curl_off_t)strnlen(postdata, len));
     220        curl_easy_setopt(curl, CURLOPT_HTTPHEADER, slist1);
     221        curl_setopt_common(curl);
     222
     223        curl_easy_setopt(curl, CURLOPT_WRITEDATA, gd);
     224        curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, write_callback);
     225
     226        ret = curl_easy_perform(curl);
     227
     228        free(postdata);
     229
     230        curl_easy_cleanup(curl);
     231        curl = NULL;
     232        curl_slist_free_all(slist1);
     233        slist1 = NULL;
     234
     235        return (int)ret;
     236}
     237
     238void get_access_token_state_start(google_drive_t *gd, struct jsonsl_state_st *state, const char *buf)
     239{
     240        switch (gd->state) {
     241        case psRoot:
     242                if (state->level != 2) {
     243                        break;
     244                }
     245                else if (strcmp(buf, "access_token") == 0) {
     246                        gd->state = psAccessToken;
     247                }
     248                else if (strcmp(buf, "expires_in") == 0) {
     249                        gd->state = psExpiresIn;
     250                }
     251                else if (strcmp(buf, "refresh_token") == 0) {
     252                        gd->state = psRefreshToken;
     253                }
     254                else if (strcmp(buf, "scope") == 0) {
     255                        gd->state = psScope;
     256                }
     257                else if (strcmp(buf, "token_type") == 0) {
     258                        gd->state = psTokenType;
     259                }
     260                else if (strcmp(buf, "error") == 0) {
     261                        gd->state = psError;
     262                }
     263                else if (strcmp(buf, "error_description") == 0) {
     264                        gd->state = psErrorDescription;
     265                }
     266                break;
     267        case psAccessToken:
     268                if (state->type == JSONSL_T_STRING) {
     269                        strlcpy(gd->credential.access_token, buf, sizeof(gd->credential.access_token));
     270                        gd->state = psRoot;
     271                }
     272                break;
     273        case psExpiresIn:
     274                if (state->type == JSONSL_T_SPECIAL) {
     275                        gd->credential.expires_in = atoi(buf);
     276                        gd->state = psRoot;
     277                }
     278                break;
     279        case psRefreshToken:
     280                if (state->type == JSONSL_T_STRING) {
     281                        strlcpy(gd->credential.refresh_token, buf, sizeof(gd->credential.refresh_token));
     282                        gd->state = psRoot;
     283                }
     284                break;
     285        case psScope:
     286                if (state->type == JSONSL_T_STRING) {
     287                        strlcpy(gd->credential.scope, buf, sizeof(gd->credential.scope));
     288                        gd->state = psRoot;
     289                }
     290                break;
     291        case psTokenType:
     292                if (state->type == JSONSL_T_STRING) {
     293                        strlcpy(gd->credential.token_type, buf, sizeof(gd->credential.token_type));
     294                        gd->state = psRoot;
     295                }
     296                break;
     297        case psError:
     298                if (state->type == JSONSL_T_STRING) {
     299                        strlcpy(gd->error.error, buf, sizeof(gd->error.error));
     300                        gd->state = psRoot;
     301                }
     302                break;
     303        case psErrorDescription:
     304                if (state->type == JSONSL_T_STRING) {
     305                        strlcpy(gd->error.error_description, buf, sizeof(gd->error.error_description));
     306                        gd->state = psRoot;
     307                }
     308                break;
     309        }
     310}
     311
     312void get_access_token_state_end(google_drive_t *gd, struct jsonsl_state_st *state, const char *buf)
     313{
     314}
     315
     316int get_access_token(google_drive_t *gd)
     317{
     318        client_info_t *client_info = &gd->client_info;
     319        credential_t *credential = &gd->credential;
     320        CURLcode ret;
     321        CURL *curl;
     322        struct curl_slist *slist1;
     323        size_t len;
     324        char *postdata;
     325        jsonsl_t jsn = gd->jsn;
     326
     327        gd->jsn_buf_pos = -1;
     328
     329        jsonsl_reset(jsn);
     330        gd->start = get_access_token_state_start;
     331        gd->end = get_access_token_state_end;
     332
     333        slist1 = NULL;
     334        slist1 = curl_slist_append(slist1, "Content-Type: application/x-www-form-urlencoded");
     335
     336        curl = curl_easy_init();
     337
     338        char *client_id = curl_easy_escape(curl, client_info->client_id, strnlen(client_info->client_id, sizeof(client_info->client_id)));
     339        char *client_secret = curl_easy_escape(curl, client_info->client_secret, strnlen(client_info->client_secret, sizeof(client_info->client_secret)));
     340        char *grant_type = curl_easy_escape(curl, GRANT_TYPE_DEVICE, strnlen(GRANT_TYPE_DEVICE, sizeof(GRANT_TYPE_DEVICE)));
     341
     342        len = sizeof("client_id=") + strlen(client_id) + sizeof("client_secret=") + strlen(client_secret)
     343                + sizeof("code=") + strlen(credential->device_code) + sizeof("grant_type=") + strlen(grant_type);
     344        postdata = malloc(len);
     345        snprintf(postdata, len, "client_id=%s&client_secret=%s&code=%s&grant_type=%s",
     346                client_id, client_secret, credential->device_code, grant_type);
     347
     348        curl_free(client_id);
     349        curl_free(client_secret);
     350        curl_free(grant_type);
     351
     352        curl_easy_setopt(curl, CURLOPT_URL, "https://www.googleapis.com/oauth2/v4/token");
     353        curl_easy_setopt(curl, CURLOPT_POSTFIELDS, postdata);
     354        curl_easy_setopt(curl, CURLOPT_POSTFIELDSIZE_LARGE, (curl_off_t)strnlen(postdata, len));
     355        curl_easy_setopt(curl, CURLOPT_HTTPHEADER, slist1);
     356        curl_setopt_common(curl);
     357
     358        curl_easy_setopt(curl, CURLOPT_WRITEDATA, gd);
     359        curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, write_callback);
     360
     361        ret = curl_easy_perform(curl);
     362
     363        free(postdata);
     364
     365        curl_easy_cleanup(curl);
     366        curl = NULL;
     367        curl_slist_free_all(slist1);
     368        slist1 = NULL;
     369
     370        return (int)ret;
     371}
     372
     373void update_access_token_state_start(google_drive_t *gd, struct jsonsl_state_st *state, const char *buf)
     374{
     375        switch (gd->state) {
     376        case psRoot:
     377                if (state->level != 2) {
     378                        break;
     379                }
     380                else if (strcmp(buf, "access_token") == 0) {
     381                        gd->state = psAccessToken;
     382                }
     383                else if (strcmp(buf, "expires_in") == 0) {
     384                        gd->state = psExpiresIn;
     385                }
     386                else if (strcmp(buf, "scope") == 0) {
     387                        gd->state = psScope;
     388                }
     389                else if (strcmp(buf, "token_type") == 0) {
     390                        gd->state = psTokenType;
     391                }
     392                else if (strcmp(buf, "error") == 0) {
     393                        gd->state = psError;
     394                }
     395                else if (strcmp(buf, "error_description") == 0) {
     396                        gd->state = psErrorDescription;
     397                }
     398                break;
     399        case psAccessToken:
     400                if (state->type == JSONSL_T_STRING) {
     401                        strlcpy(gd->credential.access_token, buf, sizeof(gd->credential.access_token));
     402                        gd->state = psRoot;
     403                }
     404                break;
     405        case psExpiresIn:
     406                if (state->type == JSONSL_T_SPECIAL) {
     407                        gd->credential.expires_in = atoi(buf);
     408                        gd->state = psRoot;
     409                }
     410                break;
     411        case psScope:
     412                if (state->type == JSONSL_T_STRING) {
     413                        strlcpy(gd->credential.scope, buf, sizeof(gd->credential.scope));
     414                        gd->state = psRoot;
     415                }
     416                break;
     417        case psTokenType:
     418                if (state->type == JSONSL_T_STRING) {
     419                        strlcpy(gd->credential.token_type, buf, sizeof(gd->credential.token_type));
     420                        gd->state = psRoot;
     421                }
     422                break;
     423        case psError:
     424                if (state->type == JSONSL_T_STRING) {
     425                        strlcpy(gd->error.error, buf, sizeof(gd->error.error));
     426                        gd->state = psRoot;
     427                }
     428                break;
     429        case psErrorDescription:
     430                if (state->type == JSONSL_T_STRING) {
     431                        strlcpy(gd->error.error_description, buf, sizeof(gd->error.error_description));
     432                        gd->state = psRoot;
     433                }
     434                break;
     435        }
     436}
     437
     438void update_access_token_state_end(google_drive_t *gd, struct jsonsl_state_st *state, const char *buf)
     439{
     440}
     441
     442int update_access_token(google_drive_t *gd)
     443{
     444        client_info_t *client_info = &gd->client_info;
     445        credential_t *credential = &gd->credential;
     446        CURLcode ret;
     447        CURL *curl;
     448        struct curl_slist *slist1;
     449        size_t len;
     450        char *postdata;
     451        jsonsl_t jsn = gd->jsn;
     452
     453        gd->jsn_buf_pos = -1;
     454
     455        jsonsl_reset(jsn);
     456        gd->start = update_access_token_state_start;
     457        gd->end = update_access_token_state_end;
     458
     459        slist1 = NULL;
     460        slist1 = curl_slist_append(slist1, "Content-Type: application/x-www-form-urlencoded");
     461
     462        curl = curl_easy_init();
     463
     464        char *client_id = curl_easy_escape(curl, client_info->client_id, strnlen(client_info->client_id, sizeof(client_info->client_id)));
     465        char *client_secret = curl_easy_escape(curl, client_info->client_secret, strnlen(client_info->client_secret, sizeof(client_info->client_secret)));
     466
     467        len = sizeof("client_id=") + strlen(client_id) + sizeof("client_secret=") + strlen(client_secret)
     468                + sizeof("refresh_token=") + strlen(credential->refresh_token);
     469        postdata = malloc(len);
     470        snprintf(postdata, len, "client_id=%s&client_secret=%s&code=%s&grant_type=refresh_token",
     471                client_id, client_secret, credential->refresh_token);
     472
     473        curl_free(client_id);
     474        curl_free(client_secret);
     475
     476        curl_easy_setopt(curl, CURLOPT_URL, "https://www.googleapis.com/oauth2/v4/token");
     477        curl_easy_setopt(curl, CURLOPT_POSTFIELDS, postdata);
     478        curl_easy_setopt(curl, CURLOPT_POSTFIELDSIZE_LARGE, (curl_off_t)strnlen(postdata, len));
     479        curl_easy_setopt(curl, CURLOPT_HTTPHEADER, slist1);
     480        curl_easy_setopt(curl, CURLOPT_CUSTOMREQUEST, "POST");
     481        curl_setopt_common(curl);
     482
     483        curl_easy_setopt(curl, CURLOPT_WRITEDATA, gd);
     484        curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, write_callback);
     485
     486        ret = curl_easy_perform(curl);
     487
     488        free(postdata);
     489
     490        curl_easy_cleanup(curl);
     491        curl = NULL;
     492        curl_slist_free_all(slist1);
     493        slist1 = NULL;
     494
     495        return (int)ret;
     496}
     497
     498void revoke_device_state_start(google_drive_t *gd, struct jsonsl_state_st *state, const char *buf)
     499{
     500}
     501
     502void revoke_device_state_end(google_drive_t *gd, struct jsonsl_state_st *state, const char *buf)
     503{
     504}
     505
     506int revoke_device(google_drive_t *gd)
     507{
     508        client_info_t *client_info = &gd->client_info;
     509        credential_t *credential = &gd->credential;
     510        CURLcode ret;
     511        CURL *curl;
     512        size_t len;
     513        struct curl_slist *slist1;
     514        char *postdata;
     515        jsonsl_t jsn = gd->jsn;
     516
     517        gd->jsn_buf_pos = -1;
     518
     519        jsonsl_reset(jsn);
     520        gd->start = revoke_device_state_start;
     521        gd->end = revoke_device_state_end;
     522
     523        slist1 = NULL;
     524        slist1 = curl_slist_append(slist1, "Content-Type: application/x-www-form-urlencoded");
     525
     526        curl = curl_easy_init();
     527
     528        len = sizeof("token=") + strlen(credential->access_token);
     529        postdata = malloc(len);
     530        snprintf(postdata, len, "token=%s", credential->access_token);
     531
     532        curl_easy_setopt(curl, CURLOPT_URL, "https://accounts.google.com/o/oauth2/revoke");
     533        curl_easy_setopt(curl, CURLOPT_POSTFIELDS, postdata);
     534        curl_easy_setopt(curl, CURLOPT_POSTFIELDSIZE_LARGE, (curl_off_t)strnlen(postdata, len));
     535        curl_easy_setopt(curl, CURLOPT_HTTPHEADER, slist1);
     536        curl_setopt_common(curl);
     537
     538        curl_easy_setopt(curl, CURLOPT_WRITEDATA, gd);
     539        curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, write_callback);
     540
     541        ret = curl_easy_perform(curl);
     542
     543        free(postdata);
     544
     545        curl_easy_cleanup(curl);
     546        curl = NULL;
     547        curl_slist_free_all(slist1);
     548        slist1 = NULL;
     549
     550        return (int)ret;
     551}
     552
     553void upload_file_state_start(google_drive_t *gd, struct jsonsl_state_st *state, const char *buf)
     554{
     555        switch (gd->state) {
     556        case psRoot:
     557                if (state->level != 2) {
     558                        break;
     559                }
     560                else if (strcmp(buf, "kind") == 0) {
     561                        gd->state = psKind;
     562                }
     563                else if (strcmp(buf, "id") == 0) {
     564                        gd->state = psId;
     565                }
     566                else if (strcmp(buf, "name") == 0) {
     567                        gd->state = psName;
     568                }
     569                else if (strcmp(buf, "mimeType") == 0) {
     570                        gd->state = psMimeType;
     571                }
     572                else if (strcmp(buf, "error") == 0) {
     573                        gd->state = psError;
     574                }
     575                else if (strcmp(buf, "error_description") == 0) {
     576                        gd->state = psErrorDescription;
     577                }
     578                break;
     579        case psKind:
     580                if (state->type == JSONSL_T_STRING) {
     581                        strlcpy(gd->file.kind, buf, sizeof(gd->file.kind));
     582                        gd->state = psRoot;
     583                }
     584                break;
     585        case psId:
     586                if (state->type == JSONSL_T_STRING) {
     587                        strlcpy(gd->file.id, buf, sizeof(gd->file.id));
     588                        gd->state = psRoot;
     589                }
     590                break;
     591        case psName:
     592                if (state->type == JSONSL_T_STRING) {
     593                        strlcpy(gd->file.name, buf, sizeof(gd->file.name));
     594                        gd->state = psRoot;
     595                }
     596                break;
     597        case psMimeType:
     598                if (state->type == JSONSL_T_STRING) {
     599                        strlcpy(gd->file.mimeType, buf, sizeof(gd->file.mimeType));
     600                        gd->state = psRoot;
     601                }
     602                break;
     603        case psError:
     604                if (state->type == JSONSL_T_STRING) {
     605                        strlcpy(gd->error.error, buf, sizeof(gd->error.error));
     606                        gd->state = psRoot;
     607                }
     608                break;
     609        case psErrorDescription:
     610                if (state->type == JSONSL_T_STRING) {
     611                        strlcpy(gd->error.error_description, buf, sizeof(gd->error.error_description));
     612                        gd->state = psRoot;
     613                }
     614                break;
     615        }
     616}
     617
     618void upload_file_state_end(google_drive_t *gd, struct jsonsl_state_st *state, const char *buf)
     619{
     620}
     621
     622size_t read_callback(char *buffer, size_t size, size_t nitems, void *arg)
     623{
     624        FIL *file = (FIL *)arg;
     625        UINT ret = 0;
     626        FRESULT res;
     627
     628        res = f_read(file, buffer, size * nitems, &ret);
     629        if (res != FR_OK)
     630                return 0;
     631
     632        int rest = ret;
    66633        int len;
    67634
    … …  
    76643                response[len] = '\0';
    77644
    78                 ntstdio_printf(&ntstdio, response);
    79 
    80                 dly_tsk(100 * 1000);
     645                printf(response);
     646
     647                dly_tsk(100);
    81648
    82649                rest -= len;
    … …  
    84651        }
    85652
    86         return size * nmemb;
    87 }
    88 
    89 size_t read_data(char *buffer, size_t size, size_t nitems, void *instream)
    90 {
    91         FIL *file = (FIL *)instream;
    92         UINT ret = 0;
    93         FRESULT res;
    94 
    95         res = f_read(file, buffer, size * nitems, &ret);
    96         if (res != FR_OK)
    97                 return 0;
    98 
    99         int rest = ret;
    100         int len;
    101 
    102         while (rest > 0) {
    103                 len = rest;
    104                 if (len > (sizeof(response) - 1)) {
    105                         len = sizeof(response) - 1;
    106                 }
    107 
    108                 memcpy(response, buffer, len);
    109 
    110                 response[len] = '\0';
    111 
    112                 ntstdio_printf(&ntstdio, response);
    113 
    114                 dly_tsk(100);
    115 
    116                 rest -= len;
    117                 buffer = (char *)buffer + len;
    118         }
    119 
    120653        return ret;
    121654}
    122655
    123 char errbuf[CURL_ERROR_SIZE];
     656int seek_callback(void *arg, curl_off_t offset, int origin)
     657{
     658        FIL *file = (FIL *)arg;
     659        BYTE mode;
     660        FRESULT ret;
     661
     662        switch (origin) {
     663        case SEEK_SET:
     664                mode = F_SEEK_SET;
     665                break;
     666        case SEEK_CUR:
     667                mode = F_SEEK_CUR;
     668                break;
     669        case SEEK_END:
     670                mode = F_SEEK_END;
     671                break;
     672        default:
     673                return CURL_SEEKFUNC_FAIL;
     674        }
     675
     676        ret = f_seek(file, offset, mode);
     677        if (ret != F_OK)
     678                return CURL_SEEKFUNC_FAIL;
     679
     680        return CURL_SEEKFUNC_OK;
     681}
     682
     683int upload_file(google_drive_t *gd, const char *filename, const char *localfilepath)
     684{
     685        CURLcode ret;
     686        CURL *curl;
     687        curl_mime *mime;
     688        curl_mimepart *part;
     689        struct curl_slist *slist1;
     690        size_t len;
     691        char *postdata, *authorization;
     692        static const char buf[] = "Expect:";
     693        jsonsl_t jsn = gd->jsn;
     694        FIL file;
     695        FRESULT fret;
     696
     697        gd->jsn_buf_pos = -1;
     698
     699        jsonsl_reset(jsn);
     700        gd->start = upload_file_state_start;
     701        gd->end = upload_file_state_end;
     702
     703        fret = f_open(&file, localfilepath, FA_READ);
     704        if (fret != FR_OK) {
     705                printf("log file open error %d\n", fret);
     706                return -1;
     707        }
     708
     709        len = sizeof("{\"name\":\"\"}") + strlen(filename);
     710        postdata = malloc(len);
     711        snprintf(postdata, len, "{\"name\":\"%s\"}", filename);
     712
     713        curl = curl_easy_init();
     714
     715        mime = curl_mime_init(curl);
     716        part = curl_mime_addpart(mime);
     717        curl_mime_name(part, "metadata");
     718        curl_mime_type(part, "application/json;charset=utf-8");
     719        curl_mime_data(part, postdata, CURL_ZERO_TERMINATED);
     720        free(postdata);
     721
     722        part = curl_mime_addpart(mime);
     723        curl_mime_name(part, "file");
     724        curl_mime_type(part, "application/json");
     725        curl_mime_data_cb(part, file.fsize, read_callback, seek_callback, NULL, &file);
     726
     727        len = sizeof("Authorization: Bearer ") + strnlen(gd->credential.access_token, sizeof(gd->credential.access_token));
     728        authorization = malloc(len);
     729        snprintf(authorization, len, "Authorization: Bearer %s", gd->credential.access_token);
     730        slist1 = NULL;
     731        slist1 = curl_slist_append(slist1, authorization);
     732        free(authorization);
     733
     734        slist1 = curl_slist_append(slist1, buf);
     735
     736        curl_easy_setopt(curl, CURLOPT_URL, "https://www.googleapis.com/upload/drive/v3/files?uploadType=multipart");
     737        curl_easy_setopt(curl, CURLOPT_FOLLOWLOCATION, 1L);
     738        curl_easy_setopt(curl, CURLOPT_MIMEPOST, mime);
     739        curl_easy_setopt(curl, CURLOPT_HTTPHEADER, slist1);
     740        curl_easy_setopt(curl, CURLOPT_CUSTOMREQUEST, "POST");
     741        curl_setopt_common(curl);
     742
     743        curl_easy_setopt(curl, CURLOPT_WRITEDATA, gd);
     744        curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, write_callback);
     745
     746        ret = curl_easy_perform(curl);
     747
     748        curl_easy_cleanup(curl);
     749        curl = NULL;
     750        curl_mime_free(mime);
     751        mime = NULL;
     752        curl_slist_free_all(slist1);
     753        slist1 = NULL;
     754
     755        f_close(&file);
     756
     757        return (int)ret;
     758}
     759
     760int google_drive_error_callback(jsonsl_t jsn, jsonsl_error_t err,
     761        struct jsonsl_state_st *state, char *errat)
     762{
     763        return 0;
     764}
     765
     766void google_drive_state_callback(jsonsl_t jsn, jsonsl_action_t action,
     767        struct jsonsl_state_st *state, const char *buf)
     768{
     769        google_drive_t *gd = (google_drive_t *)jsn->data;
     770
     771        switch (action) {
     772        case JSONSL_ACTION_PUSH:
     773                switch (state->type) {
     774                case JSONSL_T_SPECIAL:
     775                        gd->jsn_buf[0] = *buf;
     776                        gd->jsn_buf_pos = 1;
     777                        break;
     778                case JSONSL_T_STRING:
     779                case JSONSL_T_HKEY:
     780                        gd->jsn_buf_pos = 0;
     781                        break;
     782                default:
     783                        gd->jsn_buf_pos = -1;
     784                }
     785                break;
     786        case JSONSL_ACTION_POP:
     787                switch (state->type) {
     788                case JSONSL_T_SPECIAL:
     789                case JSONSL_T_STRING:
     790                case JSONSL_T_HKEY:
     791                        gd->jsn_buf_pos--;
     792                        if (gd->jsn_buf_pos < sizeof(gd->jsn_buf)) {
     793                                gd->jsn_buf[gd->jsn_buf_pos] = '\0';
     794                        }
     795                        gd->start(gd, state, gd->jsn_buf);
     796                        break;
     797                default:
     798                        gd->jsn_buf[0] = '\0';
     799                        break;
     800                }
     801                gd->jsn_buf_pos = -1;
     802                break;
     803        default:
     804                gd->jsn_buf_pos = -1;
     805                break;
     806        }
     807}
    124808
    125809static void get_logfname(char *fname)
    … …  
    185869        ret = f_open(&file, fname, FA_CREATE_ALWAYS | FA_WRITE);
    186870        if (ret != FR_OK) {
    187                 ntstdio_printf(&ntstdio, "not open a upload file %d\n", ret);
     871                printf("not open a upload file %d\n", ret);
    188872                return ret;
    189873        }
    … …  
    232916        f_putc('}', &file);
    233917
    234 file_close:
    235918        f_close(&file);
    236919
    … …  
    238921}
    239922
    240 void client_task(intptr_t exinf)
    241 {
    242         CURL *curl;
     923void curl_setopt_common(CURL *curl)
     924{
    243925        CURLcode res;
    244         int error = 0;
    245         //const char *data = "{\"value\":\"data post\"}";
    246         struct curl_slist *list = NULL;
    247         FIL file;
    248         FRESULT ret;
    249         char fname[] = {"1:/log/20160101000000.log"};
    250 
    251         get_logfname(fname);
    252 
    253         ret = write_log(fname);
    254         if (ret != FR_OK) {
    255                 ntstdio_printf(&ntstdio, "log file write error %d\n", ret);
    256                 return;
    257         }
    258 
    259         ret = f_open(&file, fname, FA_READ);
    260         if (ret != FR_OK) {
    261                 ntstdio_printf(&ntstdio, "log file open error %d\n", ret);
    262                 return;
    263         }
    264 
    265         ntstdio_printf(&ntstdio, "cURL start\n");
    266 
    267         curl = curl_easy_init();
    268         if (curl == NULL) {
    269                 ntstdio_printf(&ntstdio, "curl_easy_init() failed\n");
    270                 goto file_close;
    271         }
    272926
    273927        /* ask libcurl to show us the verbose output */
    274         curl_easy_setopt(curl, CURLOPT_VERBOSE, true);
    275 
    276         res = curl_easy_setopt(curl, CURLOPT_URL, "https://www.example.com/");
     928        res = curl_easy_setopt(curl, CURLOPT_VERBOSE, true);
    277929        if (res != CURLE_OK)
    278                 ntstdio_printf(&ntstdio, "CURLOPT_URL failed: %s\n",
     930                printf("CURLOPT_VERBOSE failed: %s\n",
    279931                        curl_easy_strerror(res));
    280932
    … …  
    283935
    284936        /* provide a buffer to store errors in */
    285         curl_easy_setopt(curl, CURLOPT_ERRORBUFFER, errbuf);
     937        res = curl_easy_setopt(curl, CURLOPT_ERRORBUFFER, errbuf);
     938        if (res != CURLE_OK)
     939                printf("CURLOPT_ERRORBUFFER failed: %s\n",
     940                        curl_easy_strerror(res));
    286941
    287942#ifdef SKIP_PEER_VERIFICATION
    … …  
    298953        res = curl_easy_setopt(curl, CURLOPT_SSL_VERIFYPEER, 0L);
    299954        if (res != CURLE_OK)
    300                 ntstdio_printf(&ntstdio, "CURLOPT_SSL_VERIFYPEER failed: %s\n",
     955                printf("CURLOPT_SSL_VERIFYPEER failed: %s\n",
    301956                        curl_easy_strerror(res));
    302957#else
    303958        res = curl_easy_setopt(curl, CURLOPT_CAINFO, "0:/certs/ca-cert.pem");
    304959        if (res != CURLE_OK)
    305                 ntstdio_printf(&ntstdio, "CURLOPT_CAINFO failed: %s\n",
     960                printf("CURLOPT_CAINFO failed: %s\n",
    306961                        curl_easy_strerror(res));
    307962
    308963        res = curl_easy_setopt(curl, CURLOPT_SSLCERT, "0:/certs/client-cert.pem");
    309964        if (res != CURLE_OK)
    310                 ntstdio_printf(&ntstdio, "CURLOPT_SSLCERT failed: %s\n",
     965                printf("CURLOPT_SSLCERT failed: %s\n",
    311966                        curl_easy_strerror(res));
    312967
    313968        res = curl_easy_setopt(curl, CURLOPT_SSLKEY, "0:/certs/client-key.pem");
    314969        if (res != CURLE_OK)
    315                 ntstdio_printf(&ntstdio, "CURLOPT_SSLKEY failed: %s\n",
     970                printf("CURLOPT_SSLKEY failed: %s\n",
    316971                        curl_easy_strerror(res));
    317972#endif
    … …  
    326981        res = curl_easy_setopt(curl, CURLOPT_SSL_VERIFYHOST, 0L);
    327982        if (res != CURLE_OK)
    328                 ntstdio_printf(&ntstdio, "CURLOPT_SSL_VERIFYHOST failed: %s\n",
     983                printf("CURLOPT_SSL_VERIFYHOST failed: %s\n",
    329984                        curl_easy_strerror(res));
    330985#endif
    … …  
    332987        /*res = curl_easy_setopt(curl, CURLOPT_PROXY, "https://proxy.example.com:8080");
    333988        if (res != CURLE_OK)
    334                 ntstdio_printf(&ntstdio, "CURLOPT_PROXY failed: %s\n",
     989                printf("CURLOPT_PROXY failed: %s\n",
    335990                        curl_easy_strerror(res));*/
    336991
    337         curl_easy_setopt(curl, CURLOPT_POST, 1);
    338 
    339         /* size of the POST data */
    340         //curl_easy_setopt(curl, CURLOPT_POSTFIELDSIZE, strlen(data));
    341         curl_easy_setopt(curl, CURLOPT_POSTFIELDSIZE, file.fsize);
    342 
    343         /* pass in a pointer to the data - libcurl will not copy */
    344         //curl_easy_setopt(curl, CURLOPT_POSTFIELDS, data);
    345 
    346         list = curl_slist_append(list, "Content-Type: application/json");
    347 
    348         curl_easy_setopt(curl, CURLOPT_HTTPHEADER, list);
    349 
    350         curl_easy_setopt(curl, CURLOPT_WRITEDATA, (void *)&error);
    351 
    352         curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, write_data);
    353 
    354         /* now specify which file to upload */
    355         curl_easy_setopt(curl, CURLOPT_READDATA, &file);
    356 
    357         /* we want to use our own read function */
    358         curl_easy_setopt(curl, CURLOPT_READFUNCTION, read_data);
    359 
    360         ntstdio_printf(&ntstdio, "cURL perform the request\n");
    361         tslp_tsk(100 * 1000);
    362 
    363         /* Perform the request, res will get the return code */
    364         res = curl_easy_perform(curl);
    365         /* Check for errors */
    366         if (res != CURLE_OK) {
    367                 ntstdio_printf(&ntstdio, "curl_easy_perform() failed: %s\n",
     992        res = curl_easy_setopt(curl, CURLOPT_NOPROGRESS, 1L);
     993        if (res != CURLE_OK)
     994                printf("CURLOPT_NOPROGRESS failed: %s\n",
    368995                        curl_easy_strerror(res));
    369                 ntstdio_printf(&ntstdio, errbuf);
    370         }
    371 
    372         /* always cleanup */
    373         curl_easy_cleanup(curl);
    374 
    375         ntstdio_printf(&ntstdio, "cURL end\n");
    376 
    377 file_close:
    378         f_close(&file);
    379 }
    380 
    381 void client_fin(void)
    382 {
     996
     997        res = curl_easy_setopt(curl, CURLOPT_MAXREDIRS, 50L);
     998        if (res != CURLE_OK)
     999                printf("CURLOPT_MAXREDIRS failed: %s\n",
     1000                        curl_easy_strerror(res));
     1001
     1002        res = curl_easy_setopt(curl, CURLOPT_TCP_KEEPALIVE, 1L);
     1003        if (res != CURLE_OK)
     1004                printf("CURLOPT_TCP_KEEPALIVE failed: %s\n",
     1005                        curl_easy_strerror(res));
     1006}
     1007
     1008void client_set_client_id(const char *client_id)
     1009{
     1010        google_drive_t *gd = &google_drive;
     1011
     1012        strlcpy(gd->client_info.client_id, client_id, sizeof(gd->client_info.client_id));
     1013}
     1014
     1015void client_set_client_secret(const char *client_secret)
     1016{
     1017        google_drive_t *gd = &google_drive;
     1018
     1019        strlcpy(gd->client_info.client_secret, client_secret, sizeof(gd->client_info.client_secret));
     1020}
     1021
     1022int client_get_device_id(int argc, char **argv)
     1023{
     1024        google_drive_t *gd = &google_drive;
     1025        int ret;
     1026
     1027        ret = get_device_id(gd, SCOPE_DRIVE_FILE);
     1028        if (ret == 0) {
     1029                printf("Device was registered. Enter the code at the following URL\n");
     1030                printf("url:  %s\n", gd->credential.verification_url);
     1031                printf("code: %s\n", gd->credential.user_code);
     1032        }
     1033        else {
     1034                printf("Device register failed! %d\n", ret);
     1035        }
     1036
     1037        return ret;
     1038}
     1039
     1040int client_get_access_token(int argc, char **argv)
     1041{
     1042        google_drive_t *gd = &google_drive;
     1043        int ret;
     1044
     1045        ret = get_access_token(gd);
     1046        if (ret == 0) {
     1047                printf("Access token was give\n");
     1048                printf("Refresh token: %s\n", gd->credential.refresh_token);
     1049                printf("Access token: %s\n", gd->credential.access_token);
     1050        }
     1051        else {
     1052                printf("Access token gain failed. %d\n", ret);
     1053        }
     1054
     1055        return ret;
     1056}
     1057
     1058int client_update_access_token(int argc, char **argv)
     1059{
     1060        google_drive_t *gd = &google_drive;
     1061        int ret;
     1062
     1063        ret = update_access_token(gd);
     1064        if (ret == 0) {
     1065                printf("Access token was update\n");
     1066                printf("Access token: %s\n", gd->credential.access_token);
     1067        }
     1068        else {
     1069                printf("Access token update failed. %d\n", ret);
     1070        }
     1071
     1072        return ret;
     1073}
     1074
     1075int client_revoke(int argc, char **argv)
     1076{
     1077        google_drive_t *gd = &google_drive;
     1078        int ret;
     1079
     1080        ret = revoke_device(gd);
     1081        if (ret == 0) {
     1082                printf("Device was revoked.\n");
     1083        }
     1084        else {
     1085                printf("Device revoke failed. %d\n", ret);
     1086        }
     1087
     1088        return ret;
     1089}
     1090
     1091int client_upload_file(int argc, char **argv)
     1092{
     1093        google_drive_t *gd = &google_drive;
     1094        int ret;
     1095        FRESULT fret;
     1096        char fname[] = { "1:/log/20160101000000.log" };
     1097
     1098        get_logfname(fname);
     1099
     1100        fret = write_log(fname);
     1101        if (fret != FR_OK) {
     1102                printf("log file write error %d\n", fret);
     1103                return (int)fret;
     1104        }
     1105
     1106        ret = upload_file(gd, &fname[7], fname);
     1107        if (ret == 0) {
     1108                printf("%s was uploaded.\n", &fname[7]);
     1109        }
     1110        else {
     1111                printf("%s upload failed. %d\n", &fname[7], ret);
     1112        }
     1113
     1114        return ret;
     1115}
     1116
     1117void client_final(void)
     1118{
     1119        google_drive_t *gd = &google_drive;
     1120        jsonsl_t jsn = gd->jsn;
     1121
    3831122        curl_global_cleanup();
    384 }
     1123        jsonsl_destroy(jsn);
     1124}

  • asp3_tinet_ecnl_arm/trunk/app1_usb_watt_meter/src/client.h

    r352 r364  
    3939#define _CLIENT_H_
    4040
    41 #include <kernel.h>
    42 #include "target_kernel_impl.h"
     41typedef struct client_info_t {
     42        char client_id[80];
     43        char client_secret[32];
     44} client_info_t;
    4345
    44 #define CLIENT_PRIORITY         4               /* クライアントタスクの優先度 */
     46typedef struct credential_t {
     47        char device_code[100];
     48        char user_code[12];
     49        int expires_in;
     50        int interval;
     51        char verification_url[32];
     52        char access_token[132];
     53        char refresh_token[64];
     54        char scope[64];
     55        char token_type[16];
     56} credential_t;
    4557
    46 #define CLIENT_STACK_SIZE       6144    /* スタック領域のサイズ */
     58typedef struct error_response_t {
     59        char error[64];
     60        char error_description[64];
     61} error_response_t;
    4762
    48 extern void client_init(void);
    49 extern void client_task(intptr_t exinf);
    50 extern void client_fin(void);
     63typedef struct drive_file_t {
     64        char kind[32];
     65        char id[36];
     66        char name[256];
     67        char mimeType[40];
     68} drive_file_t;
     69
     70typedef enum google_drive_parse_state_t {
     71        psRoot,
     72        psDeviceCode,
     73        psUserCode,
     74        psExpiresIn,
     75        psInterval,
     76        psVerificationUrl,
     77        psAccessToken,
     78        psRefreshToken,
     79        psScope,
     80        psTokenType,
     81        psKind,
     82        psId,
     83        psName,
     84        psMimeType,
     85        psError,
     86        psErrorDescription,
     87} google_drive_parse_state_t;
     88
     89struct jsonsl_st;
     90typedef struct jsonsl_st *jsonsl_t;
     91
     92typedef void (*parser_callback_t)(struct google_drive_t *gd, struct jsonsl_state_st *state, const char *buf);
     93
     94typedef struct google_drive_t {
     95        client_info_t client_info;
     96        credential_t credential;
     97        drive_file_t file;
     98        error_response_t error;
     99        jsonsl_t jsn;
     100        google_drive_parse_state_t state;
     101        char fname[sizeof("1:/log/20160101000000.log")];
     102        char jsn_buf[256];
     103        int jsn_buf_pos;
     104        parser_callback_t start;
     105        parser_callback_t end;
     106} google_drive_t;
     107
     108extern google_drive_t google_drive;
     109
     110void client_init(void);
     111void client_final(void);
     112
     113void client_set_client_id(const char *client_id);
     114void client_set_client_secret(const char *client_secret);
     115int client_get_device_id(int argc, char **argv);
     116int client_get_access_token(int argc, char **argv);
     117int client_update_access_token(int argc, char **argv);
     118int client_revoke(int argc, char **argv);
     119int client_upload_file(int argc, char **argv);
    51120
    52121#endif /* _CLIENT_H_ */

  • asp3_tinet_ecnl_arm/trunk/app1_usb_watt_meter/src/echonet_main.c

    r352 r364  
    11/*
    22 *  TOPPERS ECHONET Lite Communication Middleware
    3  * 
     3 *
    44 *  Copyright (C) 2016-2018 Cores Co., Ltd. Japan
    5  * 
     5 *
    66 *  上記著作権者は，以下の(1)～(4)の条件を満たす場合に限り，本ソフトウェ
    77 *  ア（本ソフトウェアを改変したものを含む．以下同じ）を使用・複製・改
    … …  
    2626 *      由に基づく請求からも，上記著作権者およびTOPPERSプロジェクトを
    2727 *      免責すること．
    28  * 
     28 *
    2929 *  本ソフトウェアは，無保証で提供されているものである．上記著作権者お
    3030 *  よびTOPPERSプロジェクトは，本ソフトウェアに関して，特定の使用目的
    … …  
    3232 *  アの利用により直接的または間接的に生じたいかなる損害に関しても，そ
    3333 *  の責任を負わない．
    34  * 
     34 *
    3535 *  @(#) $Id$
    3636 */
    3737
    38 /* 
     38/*
    3939 *  サンプルプログラム(1)の本体
    4040 */
    … …  
    164164{
    165165        /* サイズが１以外は受け付けない */
    166         if(size != 1)
     166        if (size != 1)
    167167                return 0;
    168168
    169169        *anno = *((uint8_t*)item->exinf) != *((uint8_t*)src);
    170170
    171         switch(*(uint8_t *)src){
     171        switch (*(uint8_t *)src) {
    172172        /* ONの場合 */
    173173        case 0x30:
    … …  
    196196{
    197197        /* サイズが１以外は受け付けない */
    198         if(size != 1)
     198        if (size != 1)
    199199                return 0;
    200200
    201201        *anno = *((uint8_t *)item->exinf) != *((uint8_t *)src);
    202202
    203         switch(*(uint8_t *)src){
     203        switch (*(uint8_t *)src) {
    204204        /* 異常発生ありの場合 */
    205205        case 0x41:
    … …  
    271271int date_prop_set(const EPRPINIB *item, const void *src, int size, bool_t *anno)
    272272{
    273         uint8_t *p_src;
     273        const uint8_t *p_src;
    274274        time_t temp;
    275275        struct tm _tm;
    … …  
    283283        /* 年月日設定 */
    284284        p_src = (uint8_t *)src;
    285         _tm.tm_year = (*(p_src++) * 100) + *p_src++;
     285        _tm.tm_year = (*p_src++ * 100) + *p_src++;
    286286        _tm.tm_mon = (*p_src++) - 1;
    287287        _tm.tm_mday = *p_src++;
    … …  
    325325
    326326        /* サイズが4以外は受け付けない */
    327         if(size != 4)
     327        if (size != 4)
    328328                return 0;
    329329
    … …  
    345345
    346346        len = 48 - meter->current_pos;
    347         if(len > 0)
     347        if (len > 0)
    348348                memcpy(dst, &meter->integral_electric_energy_measurement_log[meter->current_pos], sizeof(uint32_t) * len);
    349349        dst = &((uint8_t *)dst)[len];
    … …  
    404404
    405405        ret2 = get_tim(&now);
    406         if (ret2 != E_OK){
     406        if (ret2 != E_OK) {
    407407                syslog(LOG_ERROR, "get_tim");
    408408                return;
    409409        }
    410410
    411         for(;;){
     411        for (;;) {
    412412                prev = now;
    413413
    … …  
    417417                /* 応答電文待ち */
    418418                ret = ecn_trcv_esv(&esv, timer);
    419                 if ((ret != E_OK) && (ret != E_BRK) && (ret != E_TMOUT)){
     419                if ((ret != E_OK) && (ret != E_BRK) && (ret != E_TMOUT)) {
    420420                        syslog(LOG_ERROR, "ecn_trcv_esv");
    421421                        break;
    … …  
    423423
    424424                ret2 = get_tim(&now);
    425                 if (ret2 != E_OK){
     425                if (ret2 != E_OK) {
    426426                        syslog(LOG_ERROR, "get_tim");
    427427                        break;
    … …  
    438438                        /* 領域解放 */
    439439                        ret = ecn_rel_esv(esv);
    440                         if (ret != E_OK){
     440                        if (ret != E_OK) {
    441441                                syslog(LOG_ERROR, "ecn_rel_esv");
    442442                                break;
    … …  
    447447                        /* 応答電文待ちの割り込みデータ取得 */
    448448                        ret = ecn_get_brk_dat(esv, brkdat, sizeof(brkdat), &len);
    449                         if (ret != E_OK){
     449                        if (ret != E_OK) {
    450450                                syslog(LOG_ERROR, "ecn_get_brk_dat");
    451451                                break;
    … …  
    457457                        /* 領域解放 */
    458458                        ret = ecn_rel_esv(esv);
    459                         if (ret != E_OK){
     459                        if (ret != E_OK) {
    460460                                syslog(LOG_ERROR, "ecn_rel_esv");
    461461                                break;
    … …  
    468468}
    469469
    470 bool_t started = false;
    471 
    472470void echonet_change_netif_link(uint8_t link_up, uint8_t up)
    473471{
    … …  
    477475                return;
    478476
    479         if (up && !started) {
    480                 started = true;
    481 
    482                 /* ECHONETミドルウェアを起動 */
    483                 ret = ecn_sta_svc();
    484                 if (ret != E_OK)
    485                         return;
    486 
    487                 /* ECHONETミドルウェアを起動するのを待つ */
    488                 dly_tsk(100);
     477        if (up) {
     478                /* インスタンスリスト通知の送信 */
     479                ret = ecn_ntf_inl();
     480                if (ret != E_OK) {
     481                        syslog(LOG_ERROR, "ecn_ntf_inl");
     482                }
    489483        }
    490484
    … …  
    500494}
    501495
    502 enum main_state_t{
     496enum main_state_t {
     497        main_state_start,
    503498        main_state_idle,
    504499};
    505500
    506501int main_timer = TMO_FEVR;
    507 enum main_state_t main_state = main_state_idle;
     502enum main_state_t main_state = main_state_start;
    508503int main_lcd_state = 0;
    509504int main_lcd_timer = TMO_FEVR;
    … …  
    557552        analogin_init(&joystick, P1_12);
    558553
    559         /* 10ms後にボタン状態を確認 */
    560         main_timer = 10 * 1000;
    561 
    562         /* ボタン状態読み込み */
     554        /* ECHONETミドルウェアを起動するのを待つ */
     555        main_state = main_state_start;
     556        main_timer = 1000 * 1000;
     557
    563558        btn = main_read_button(&joystick);
    564559        main_btn1_state = btn == BUTTON_LEFT;
    … …  
    568563        spi_init(&lcd.hspi, P10_14, P10_15, P10_12, NC);
    569564        spi_format(&lcd.hspi, 8, 0, 0);
    570         spi_frequency(&lcd.hspi, 1000000);
     565        spi_frequency(&lcd.hspi, 4000000);
    571566
    572567        gpio_init_out(&lcd.cs_pin, P10_13);
    … …  
    590585        main_adv_timer = 1000 * 1000;
    591586
     587        /* メインタスクを起動 */
    592588        ER ret = act_tsk(MAIN_TASK);
    593589        if (ret != E_OK) {
    … …  
    603599        int result = main_timer;
    604600
    605         if((result == TMO_FEVR)
    606                 || ((main_lcd_timer != TMO_FEVR) && (main_lcd_timer < result))){
     601        if ((result == TMO_FEVR)
     602                || ((main_lcd_timer != TMO_FEVR) && (main_lcd_timer < result))) {
    607603                result = main_lcd_timer;
    608604        }
    … …  
    621617static void main_progress(int interval)
    622618{
    623         if(main_timer != TMO_FEVR){
     619        if (main_timer != TMO_FEVR) {
    624620                main_timer -= interval;
    625                 if(main_timer < 0){
     621                if (main_timer < 0) {
    626622                        main_timer = 0;
    627623                }
    628624        }
    629625
    630         if(main_lcd_timer != TMO_FEVR){
     626        if (main_lcd_timer != TMO_FEVR) {
    631627                main_lcd_timer -= interval;
    632                 if(main_lcd_timer < 0){
     628                if (main_lcd_timer < 0) {
    633629                        main_lcd_timer = 0;
    634630                }
    … …  
    655651
    656652        ret = ecn_itr_ini(&enm, esv);
    657         if(ret != E_OK){
     653        if (ret != E_OK) {
    658654                syslog(LOG_ERROR, "ecn_itr_ini");
    659655                return;
    660656        }
    661657
    662         for(;;) {
    663                 while((ret = ecn_itr_nxt(&enm, &epc, &pdc, p_edt)) == E_OK) {
     658        for (;;) {
     659                while ((ret = ecn_itr_nxt(&enm, &epc, &pdc, p_edt)) == E_OK) {
    664660                        switch (epc) {
    665661                        case 0x80:
    … …  
    669665                        }
    670666                }
    671                 if(ret != E_BOVR){
     667                if (ret != E_BOVR) {
    672668                        syslog(LOG_ERROR, "ecn_itr_nxt");
    673669                        break;
    674670                }
    675                 if(enm.is_eof)
     671                if (enm.is_eof)
    676672                        break;
    677673        }
    … …  
    684680{
    685681        char mac_text[30] = "mac: ";
    686         char ipaddr_text[30] = "ipaddr: ";
    687         T_IN4_ADDR *ip4_addr;
     682        char ipaddr_text[30] = "ipadr: ";
     683        const T_IN4_ADDR *ip4_addr;
    688684        int pos;
    689685
    690         switch(main_state){
     686        switch (main_state) {
    691687        case main_state_idle:
    692688                if (len == 0)
    … …  
    704700                        pos = str_macaddr(&mac_text[4], sizeof(mac_text) - 4, mac_addr, 0);
    705701                        mac_text[pos + 4] = '\0';
    706                         lcd_drawString(&lcd, mac_text, X_LINE_TO_PIX(&lcd, 0) + 10, Y_ROW_TO_PIX(&lcd, 14) + 10, ST7735_BLACK, ST7735_WHITE);
     702                        lcd_drawString(&lcd, mac_text, X_LINE_TO_PIX(&lcd, 0), Y_ROW_TO_PIX(&lcd, 11), ST7735_BLACK, ST7735_WHITE);
    707703
    708704                        ip4_addr = in4_get_ifaddr(0);
    709                         pos = str_ipv4addr(&ipaddr_text[7], sizeof(ipaddr_text) - 7, ip4_addr, 0);
    710                         ipaddr_text[pos + 7] = '\0';
    711                         lcd_drawString(&lcd, ipaddr_text, X_LINE_TO_PIX(&lcd, 0) + 10, Y_ROW_TO_PIX(&lcd, 15) + 10, ST7735_BLACK, ST7735_WHITE);
     705                        pos = str_ipv4addr(&ipaddr_text[6], sizeof(ipaddr_text) - 6, ip4_addr, 0);
     706                        ipaddr_text[pos + 6] = '\0';
     707                        lcd_drawString(&lcd, ipaddr_text, X_LINE_TO_PIX(&lcd, 0), Y_ROW_TO_PIX(&lcd, 12), ST7735_BLACK, ST7735_WHITE);
    712708                }
    713709                break;
    … …  
    724720static void main_timeout()
    725721{
    726         if(main_timer == 0){
     722        if (main_timer == 0) {
    727723                main_ontimer();
    728724        }
    729725
    730         if(main_lcd_timer == 0){
     726        if (main_lcd_timer == 0) {
    731727                main_lcd_ontimer();
    732728        }
    … …  
    746742        int port_no, btn;
    747743
    748         switch(main_lcd_state) {
     744        switch (main_lcd_state) {
    749745        case 0:
    750746        case 1:
    … …  
    757753                text[16] = '0' + main_7seg[port_no][2];
    758754                text[17] = '0' + main_7seg[port_no][3];
    759                 lcd_drawString(&lcd, &text[14], X_LINE_HALF_TO_PIX(&lcd, 11) + 10, Y_ROW_TO_PIX(&lcd, main_lcd_state + 4) + 10, ST7735_BLACK, ST7735_WHITE);
     755                lcd_drawString(&lcd, &text[14], X_LINE_HALF_TO_PIX(&lcd, 11), Y_ROW_TO_PIX(&lcd, main_lcd_state + 2), ST7735_BLACK, ST7735_WHITE);
    760756                main_lcd_state++;
    761757                break;
    762758        case 6:
    763759                btn = main_read_button(&joystick);
    764                 lcd_drawString(&lcd, btn_texts[btn], X_LINE_TO_PIX(&lcd, 0) + 10, Y_ROW_TO_PIX(&lcd, 10) + 10, ST7735_BLACK, ST7735_WHITE);
     760                lcd_drawString(&lcd, btn_texts[btn], X_LINE_TO_PIX(&lcd, 0), Y_ROW_TO_PIX(&lcd, 9), ST7735_BLACK, ST7735_WHITE);
    765761                main_lcd_state++;
    766762                break;
    … …  
    769765                break;
    770766        case 10:
    771                 lcd_drawString(&lcd, "USB電力計", X_LINE_TO_PIX(&lcd, 10) + 10, Y_ROW_TO_PIX(&lcd, 0) + 10, ST7735_BLACK, ST7735_WHITE);
     767                lcd_drawString(&lcd, "USB電力計", X_LINE_TO_PIX(&lcd, 6), Y_ROW_TO_PIX(&lcd, 0), ST7735_BLACK, ST7735_WHITE);
    772768                for (port_no = 0; port_no < 6; port_no++) {
    773769                        text[3] = '1' + port_no;
    774                         lcd_drawString(&lcd, text, X_LINE_TO_PIX(&lcd, 0) + 10, Y_ROW_TO_PIX(&lcd, port_no + 4) + 10, ST7735_BLACK, ST7735_WHITE);
     770                        lcd_drawString(&lcd, text, X_LINE_TO_PIX(&lcd, 0), Y_ROW_TO_PIX(&lcd, port_no + 2), ST7735_BLACK, ST7735_WHITE);
    775771                }
    776772                main_lcd_state = 0;
    … …  
    802798static void main_ontimer()
    803799{
     800        ER ret;
    804801        uint8_t btn;
    805802        uint16_t ad_value;
    806803
    807         switch(main_state){
     804        switch (main_state) {
     805        case main_state_start:
     806                /* ECHONETミドルウェアを起動 */
     807                ret = ecn_sta_svc();
     808                if (ret != E_OK) {
     809                        syslog(LOG_ERROR, "ecn_sta_svc");
     810                }
     811
     812                /* 10ms後にボタン状態を確認 */
     813                main_state = main_state_idle;
     814                main_timer = 10 * 1000;
     815                break;
    808816        case main_state_idle:
    809817                /* 10ms後にボタン状態を確認 */
    … …  
    845853
    846854                /* ボタン１の処理 */
    847                 if((btn == BUTTON_LEFT) && !main_btn1_state){
     855                if ((btn == BUTTON_LEFT) && !main_btn1_state) {
    848856                        main_btn1_count++;
    849                         if(main_btn1_count > 10){
     857                        if (main_btn1_count > 10) {
    850858                                main_btn1_count = 0;
    851859                                main_btn1_state = true;
    … …  
    854862                        }
    855863                }
    856                 else if((btn != BUTTON_LEFT) && main_btn1_state){
     864                else if ((btn != BUTTON_LEFT) && main_btn1_state) {
    857865                        main_btn1_count++;
    858                         if(main_btn1_count > 10){
     866                        if (main_btn1_count > 10) {
    859867                                main_btn1_count = 0;
    860868                                main_btn1_state = false;
    … …  
    865873
    866874                /* ボタン２の処理 */
    867                 if((btn == BUTTON_RIGHT) && !main_btn2_state){
     875                if ((btn == BUTTON_RIGHT) && !main_btn2_state) {
    868876                        main_btn2_count++;
    869                         if(main_btn2_count > 10){
     877                        if (main_btn2_count > 10) {
    870878                                main_btn2_count = 0;
    871879                                main_btn2_state = true;
    … …  
    874882                        }
    875883                }
    876                 else if((btn != BUTTON_RIGHT) && main_btn2_state){
     884                else if ((btn != BUTTON_RIGHT) && main_btn2_state) {
    877885                        main_btn2_count++;
    878                         if(main_btn2_count > 10){
     886                        if (main_btn2_count > 10) {
    879887                                main_btn2_count = 0;
    880888                                main_btn2_state = false;
    … …  
    897905static uint8_t main_read_button(analogin_t *obj)
    898906{
    899     float a = analogin_read(obj);
    900 
    901     a *= 5.0;
    902 
    903     //printf("Button read analog = %f\r\n",a);
    904     if (a < 0.2)
    905         return BUTTON_DOWN;
    906     if (a < 1.0)
    907         return BUTTON_RIGHT;
    908     if (a < 1.7)
    909         return BUTTON_SELECT;
    910     if (a < 2.6)
    911         return BUTTON_UP;
    912     if (a < 4.6)
    913         return BUTTON_LEFT;
    914     else
    915         return BUTTON_NONE;
     907        float a = analogin_read(obj);
     908
     909        a *= 5.0;
     910
     911        //printf("Button read analog = %f\r\n",a);
     912        if (a < 0.2)
     913                return BUTTON_DOWN;
     914        if (a < 1.0)
     915                return BUTTON_RIGHT;
     916        if (a < 1.7)
     917                return BUTTON_SELECT;
     918        if (a < 2.6)
     919                return BUTTON_UP;
     920        if (a < 4.6)
     921                return BUTTON_LEFT;
     922        else
     923                return BUTTON_NONE;
    916924}
    917925
    … …  
    924932{
    925933        /* 押されて戻った時に処理する */
    926         if(push)
     934        if (push)
    927935                return;
    928936
    929937        /* 表示ポート番号 */
    930         if(!main_rev){
     938        if (!main_rev) {
    931939                main_port_no--;
    932                 if(main_port_no < 1){
     940                if (main_port_no < 1) {
    933941                        main_port_no = 1;
    934942                        main_rev = true;
    … …  
    936944                }
    937945        }
    938         else{
     946        else {
    939947                main_port_no++;
    940                 if(main_port_no > main_ad_count){
     948                if (main_port_no > main_ad_count) {
    941949                        main_port_no = main_ad_count;
    942950                        main_rev = false;
    … …  
    952960{
    953961        /* 押されて戻った時に処理する */
    954         if(push)
     962        if (push)
    955963                return;
    956964
    … …  
    961969
    962970        /* 表示ポート番号 */
    963         if(!main_rev){
     971        if (!main_rev) {
    964972                main_port_no++;
    965                 if(main_port_no > main_ad_count){
     973                if (main_port_no > main_ad_count) {
    966974                        main_port_no = main_ad_count;
    967975                        main_rev = false;
    … …  
    969977                }
    970978        }
    971         else{
     979        else {
    972980                main_port_no--;
    973                 if(main_port_no < 1){
     981                if (main_port_no < 1) {
    974982                        main_port_no = 1;
    975983                        main_rev = true;
    … …  
    988996
    989997        main_port_no++;
    990         if(main_port_no > main_ad_count)
     998        if (main_port_no > main_ad_count)
    991999                main_port_no = 1;
    9921000

  • asp3_tinet_ecnl_arm/trunk/app1_usb_watt_meter/src/main.c

    r359 r364  
    4545#include <sil.h>
    4646#include <setjmp.h>
     47#include <stdlib.h>
    4748#include <string.h>
    4849#include "syssvc/serial.h"
    … …  
    8081
    8182ID ws_api_mailboxid = MAIN_DATAQUEUE;
     83#ifndef NOUSE_MPF_NET_BUF
    8284ID ws_mempoolid = MPF_NET_BUF_256;
     85#endif
    8386
    8487#if defined(IF_ETHER_BTUSB) || defined(IF_ETHER_ENBT)
    … …  
    114117static void main_timeout();
    115118
     119extern int ntshell_exit;
     120
    116121int uart_read(char *buf, int cnt, void *extobj)
    117122{
    118         return serial_rea_dat(SIO_PORTID, (char *)buf, cnt);
     123        struct main_t *obj = (struct main_t *)extobj;
     124        int result;
     125        ER ret;
     126        int timer;
     127
     128        obj->prev = obj->now;
     129
     130        /* タイマー取得 */
     131        timer = main_get_timer();
     132
     133        /* 待ち */
     134        ret = serial_trea_dat(SIO_PORTID, buf, cnt, timer);
     135        if ((ret < 0) && (ret != E_OK) && (ret != E_TMOUT)) {
     136                syslog(LOG_NOTICE, "tslp_tsk ret: %s %d", itron_strerror(ret), timer);
     137                ntshell_exit = 1;
     138                return -1;
     139        }
     140        result = (int)ret;
     141
     142        ret = get_tim(&obj->now);
     143        if (ret != E_OK) {
     144                syslog(LOG_NOTICE, "get_tim ret: %s", itron_strerror(ret));
     145                ntshell_exit = 1;
     146                return -1;
     147        }
     148
     149                        /* 時間経過 */
     150        int elapse = obj->now - obj->prev;
     151        main_progress(elapse);
     152
     153        /* タイムアウト処理 */
     154        main_timeout();
     155
     156        return result;
    119157}
    120158
    … …  
    122160{
    123161        return serial_wri_dat(SIO_PORTID, buf, cnt);
    124 }
    125 
    126 unsigned char ntstdio_xi(struct ntstdio_t *handle)
    127 {
    128         char buf[1];
    129         if(serial_rea_dat(SIO_PORTID, buf, 1) != 1)
    130                 return -EIO;
    131         return buf[0];
    132 }
    133 
    134 void ntstdio_xo(struct ntstdio_t *handle, unsigned char c)
    135 {
    136         char buf[1];
    137         buf[0] = c;
    138         serial_wri_dat(SIO_PORTID, buf, 1);
    139162}
    140163
    … …  
    156179        main_initialize();
    157180
    158         ntshell_init(&ntshell, uart_read, uart_write, cmd_execute, NULL);
     181        ntshell_init(&ntshell, uart_read, uart_write, cmd_execute, &main_obj);
    159182        ntshell_set_prompt(&ntshell, "NTShell>");
    160183        ntshell_execute(&ntshell);
    … …  
    176199        ER ret;
    177200
     201#ifdef TOPPERS_OMIT_TECS
     202        serial_opn_por(SIO_PORTID);
     203#endif
     204        serial_ctl_por(SIO_PORTID, IOCTL_FCSND | IOCTL_FCRCV);
     205
    178206        //wolfSSL_Debugging_ON();
    179207
    180         ntshell_task_init();
     208        ntshell_task_init(uart_read, uart_write, &main_obj);
    181209
    182210        main_obj.timer = TMO_FEVR;
    … …  
    313341}
    314342
     343int cmd_creid(int argc, char **argv)
     344{
     345        if (argc != 2) {
     346                printf("creid {client_id}\n");
     347                return 0;
     348        }
     349
     350        client_set_client_id(argv[1]);
     351
     352        return 0;
     353}
     354
     355int cmd_secret(int argc, char **argv)
     356{
     357        if (argc != 2) {
     358                printf("secret {client_secret}\n");
     359                return 0;
     360        }
     361
     362        client_set_client_secret(argv[1]);
     363
     364        return 0;
     365}
     366
    315367int cmd_logupload(int argc, char **argv)
    316368{
    317         client_task(0);
    318         return 0;
     369        return client_upload_file(argc, argv);
    319370}
    320371
    … …  
    335386        {"dnsc", "DNS client", usrcmd_dnsc },
    336387        {"ntpc", "NTP client", usrcmd_ntpc },
     388        {"creid", "Regster device", cmd_creid},
     389        {"secret", "Regster device", cmd_secret},
     390        {"gdi", "get_device_id", client_get_device_id},
     391        {"gat", "get_access_token", client_get_access_token},
     392        {"uat", "update_access_token", client_update_access_token},
     393        {"rd", "revoke device", client_revoke},
     394        {"uf", "upload_file", client_upload_file},
    337395        {"logupload", "Upload log to server", cmd_logupload},
    338396        {"info", "This is a description text string for info command.", usrcmd_info},

  • asp3_tinet_ecnl_arm/trunk/app1_usb_watt_meter/src/main.cfg

    r352 r364  
    5454INCLUDE("tinet/tinet_asp.cfg");
    5555INCLUDE("tinet_main.cfg");
    56 INCLUDE("netinet/ip_igmp.cfg");
    5756
    5857/* DHCP クライアント */
Note: See TracChangeset for help on using the changeset viewer.