步驟一：設(shè)置日志開關(guān)

編譯時傳入DAS_DEBUG，即可開啟基礎(chǔ)版SOC SDK日志?；A(chǔ)版SOC SDK代碼中打印日志接口為DAS_LOG(...）定義在das/include/das/platform.h。

步驟二：設(shè)置設(shè)備身份信息

請適配物聯(lián)網(wǎng)終端唯一ID，協(xié)助基礎(chǔ)版SOC SDK識別物聯(lián)網(wǎng)終端，ID可以是MEID、CPU ID、MAC地址等等，形式為字符串即可。

以移遠(yuǎn)ec600s開發(fā)板為例，函數(shù)原型如下：

適配接口在das/src/board/ec600s/das_board.c

size_t das_hal_device_id(char *buf, size_t size);

入?yún)⑿畔⑷缦拢?/p>

步驟三：適配ROM掃描范圍

如果您有text或者ROM code，您希望確保完整性，可以適配此接口，基礎(chǔ)版SOC SDK將定期幫您掃描計(jì)算完整性。

以移遠(yuǎn)ec600s開發(fā)板為例，函數(shù)原型如下：

適配接口在das/src/board/ec600s/das_board.c。

int das_hal_rom_info(das_rom_bank_t banks[DAS_ROM_BANK_NUMBER]);

入?yún)⑿畔⑷缦拢?/p>

返回結(jié)果如下：

可以參考如下案例：

您有兩段代碼段想要掃描，且您認(rèn)為這兩段代碼段正常情況下不該被修改（除非返廠重?zé)鐃ext、code等等，那么您可以可在das_hal_rom_info設(shè)置它。代碼段的位置可根據(jù)您的layout file（如scatter file）所編寫的symbol位置去設(shè)定。

extern uint32_t __flash_text_start__;
extern uint32_t __flash_text_end__;

extern uint32_t __ram_image2_text_start__;
extern uint32_t __ram_image2_text_end__;

int das_hal_rom_info(das_rom_bank_t banks[DAS_ROM_BANK_NUMBER])
{
    banks[0].address = &__flash_text_start__;
    banks[0].size = &__flash_text_end__ - &__flash_text_start__;

    banks[1].address = &__ram_image2_text_start__;
    banks[1].size = &__ram_image2_text_end__ - &__ram_image2_text_start__;

    return 2;
}

步驟四：互斥鎖適配

請?jiān)?code data-tag="code" class="code">das/src/service/service_sys.c和das/src/service/service_lwip_nfi.c文檔中適配互斥鎖，例如POSIX線程pthread或者AliOS-Things互斥鎖aos_mutex。

步驟五：網(wǎng)絡(luò)流量采集適配

根據(jù)不同的網(wǎng)絡(luò)環(huán)境，選擇對應(yīng)的開發(fā)方式：

• 如果您的網(wǎng)路棧是基于LWIP，且可以修改到LWIP協(xié)議棧，請參考基于LWIP的網(wǎng)路流采集篇章做網(wǎng)路監(jiān)控掛載。

• 如果您使用其他網(wǎng)絡(luò)，可以采用自定義網(wǎng)路流采集，根據(jù)您的網(wǎng)路棧做掛載，或者掛載在AT命令負(fù)責(zé)派送網(wǎng)路的出入口。

1. 基于LWIP的網(wǎng)路流采集

   如果您的網(wǎng)路棧是基于LWIP，且您可以修改到LWIP協(xié)議棧，您可采用此網(wǎng)路流采集方式。常見RTOS如FreeRTOS和AliOS-Things上，都是采用LWIP協(xié)議棧?；A(chǔ)版SOC SDK提供das_attest API對網(wǎng)絡(luò)行為進(jìn)行監(jiān)控。主要原理是在系統(tǒng)的LWIP協(xié)議棧中，插入das_attest審計(jì)代碼，從而記錄網(wǎng)絡(luò)流的進(jìn)程。

   1. TCP網(wǎng)絡(luò)流量進(jìn)入

      在tcp_in.c文件開頭引入相關(guān)頭文件。

      #include "lwip/ip.h"
      #include <das.h>

      在tcp_in.c文件的tcp_input函數(shù)中插入das_attest監(jiān)控代碼。

      void
      tcp_input(struct pbuf *p, struct netif *inp)
      {
        ....
            
        /* Convert fields in TCP header to host byte order. */
        tcphdr->src = ntohs(tcphdr->src);
        tcphdr->dest = ntohs(tcphdr->dest);
        seqno = tcphdr->seqno = ntohl(tcphdr->seqno);
        ackno = tcphdr->ackno = ntohl(tcphdr->ackno);
        tcphdr->wnd = ntohs(tcphdr->wnd);
      
        // 插入如下代碼 {
        das_attest("NFI_INPUT", 
          ip_current_src_addr()->addr, 
          ip_current_dest_addr()->addr, 
          tcphdr->src,
          tcphdr->dest,
          p->tot_len, 
          ip_current_header_proto()
        );
        // }
         
        flags = TCPH_FLAGS(tcphdr);
        tcplen = p->tot_len + ((flags & (TCP_FIN | TCP_SYN)) ? 1 : 0);
      
        /* Demultiplex an incoming segment. First, we check if it is destined
           for an active connection. */
        prev = NULL;
      
        ...
      }

   2. UDP協(xié)議流量進(jìn)入

      在udp.c文件開頭引入相關(guān)頭文件。

      #include "lwip/ip.h"
      #include <das.h>

      在udp.c文件的udp_input函數(shù)中插入das_attest監(jiān)控代碼。

      void
      udp_input(struct pbuf *p, struct netif *inp)
      {
        ...
      
        LWIP_DEBUGF(UDP_DEBUG, ("udp_input: received datagram of length %"U16_F"\n", p->tot_len));
      
        /* convert src and dest ports to host byte order */
        src = ntohs(udphdr->src);
        dest = ntohs(udphdr->dest);
      
        udp_debug_print(udphdr);
          
        // 插入如下代碼 {
        das_attest("NFI_INPUT", 
          ip_current_src_addr()->addr, 
          ip_current_dest_addr()->addr, 
          src,
          dest,
          p->tot_len, 
          ip_current_header_proto()
        );
        // }
        
        /* print the UDP source and destination */
        LWIP_DEBUGF(UDP_DEBUG,
                    ("udp (%"U16_F".%"U16_F".%"U16_F".%"U16_F", %"U16_F") <-- "
                     "(%"U16_F".%"U16_F".%"U16_F".%"U16_F", %"U16_F")\n",
                     ip4_addr1_16(&iphdr->dest), ip4_addr2_16(&iphdr->dest),
                     ip4_addr3_16(&iphdr->dest), ip4_addr4_16(&iphdr->dest), ntohs(udphdr->dest),
                     ip4_addr1_16(&iphdr->src), ip4_addr2_16(&iphdr->src),
                     ip4_addr3_16(&iphdr->src), ip4_addr4_16(&iphdr->src), ntohs(udphdr->src)));
      
        ...
      }

   3. 網(wǎng)絡(luò)流量出方向

      在ip.c文件開頭引入相關(guān)頭文件。

      #include <das.h>

      在ip.c文件的ip_output_if_opt函數(shù)中插入das_attest監(jiān)控代碼。

      err_t ip_output_if_opt(struct pbuf *p, ip_addr_t *src, ip_addr_t *dest,
             u8_t ttl, u8_t tos, u8_t proto, struct netif *netif, void *ip_options,
             u16_t optlen)
      {
        ...
      
        LWIP_DEBUGF(IP_DEBUG, ("netif->output()"));
      
        // 插入如下代碼 {
        {
          u16_t sport = 0, dport = 0;
          u16_t len = 0;
          u16_t iphdr_hlen = IPH_HL(iphdr);
      
          iphdr_hlen *= 4;
      
          if (proto == IP_PROTO_UDP || IPH_PROTO(iphdr) == IP_PROTO_UDP) {
            struct udp_hdr *udphdr = (struct udp_hdr *)((u8_t *)iphdr + iphdr_hlen);
            if (udphdr) {
              sport = lwip_ntohs(udphdr->src);
              dport = lwip_ntohs(udphdr->dest);
              len = (p->tot_len > iphdr_hlen) ? (p->tot_len - iphdr_hlen) : p->tot_len;
            }
          }
          else if (proto == IP_PROTO_TCP || IPH_PROTO(iphdr) == IP_PROTO_TCP) {
            struct tcp_hdr *tcphdr = (struct tcp_hdr *)((u8_t *)iphdr + iphdr_hlen);
            if (tcphdr) {
              sport = lwip_ntohs(tcphdr->src);
              dport = lwip_ntohs(tcphdr->dest);
              len = (p->tot_len > iphdr_hlen) ? (p->tot_len - iphdr_hlen) : p->tot_len;
            }
          }
      
          if (dport) {
            das_attest("NFI_OUTPUT", 
                src->addr,
                dest->addr, 
                sport,
                dport, 
                len,
                proto
                );
          }
        }
        // }
          
        return netif->output(netif, p, dest);
      }

2. 自定義網(wǎng)路流采集

   如果您的網(wǎng)路棧不是基于LWIP，或者您無法修改LWIP協(xié)議棧，您可采用自定義網(wǎng)路流采集方式。您需要提供您每筆網(wǎng)路流的源IP、源端口、目標(biāo)IP、目標(biāo)端口、協(xié)議。您可根據(jù)您的網(wǎng)路棧做掛載，或者掛載在AT命令負(fù)責(zé)派送網(wǎng)路的出入口等等也行。

   1. 掛載TCP網(wǎng)絡(luò)流量進(jìn)方向

      #include "das.h"
      #include "inet.h"
      
      // ...
      
      struct in_addr remote_addr;
      struct in_addr local_addr;
      inet_aton(remote_ip, &remote_addr);
      inet_aton(local_ip, &local_addr);
      
      das_attest("NFI_INPUT", 
          remote_addr.s_addr, // 外部 IP 位置，需要是 inet_aton 轉(zhuǎn)換后格式，uint32_t。
          local_addr.s_addr,  // 本機(jī) IP 位置，需要是 inet_aton 轉(zhuǎn)換后格式，uint32_t。
          remote_port,        // 外部端口，uint32_t。
          local_port,         // 本機(jī)端口，uint32_t。
          packet_len,         // 包長度，uint32_t。
          6                   // 填寫 6，代表 TCP，uint32_t。
      );
      
      // ...

   2. 掛載TCP網(wǎng)絡(luò)流量出方向

      #include "das.h"
      #include "inet.h"
      
      // ...
      
      struct in_addr remote_addr;
      struct in_addr local_addr;
      inet_aton(remote_ip, &remote_addr);
      inet_aton(local_ip, &local_addr);
      
      das_attest("NFI_OUTPUT", 
          local_addr.s_addr,  // 反過來，本機(jī) IP 位置，需要是 inet_aton 轉(zhuǎn)換后格式，uint32_t。
          remote_addr.s_addr, // 反過來，外部 IP 位置，需要是 inet_aton 轉(zhuǎn)換后格式，uint32_t。
          local_port,         // 反過來，本機(jī)端口，uint32_t。
          remote_port,        // 反過來，外部端口，uint32_t。
          packet_len,         // 包長度，uint32_t。
          6                   // 填寫 6，代表 TCP，uint32_t。
      );
      
      // ...

   3. 掛載UDP網(wǎng)絡(luò)流量進(jìn)方向

      #include "das.h"
      #include "inet.h"
      
      // ...
      
      struct in_addr remote_addr;
      struct in_addr local_addr;
      inet_aton(remote_ip, &remote_addr);
      inet_aton(local_ip, &local_addr);
      
      das_attest("NFI_INPUT", 
          remote_addr.s_addr, // 外部 IP 位置，需要是 inet_aton 轉(zhuǎn)換后格式，uint32_t。
          local_addr.s_addr,  // 本機(jī) IP 位置，需要是 inet_aton 轉(zhuǎn)換后格式，uint32_t。
          remote_port,        // 外部端口，uint32_t。
          local_port,         // 本機(jī)端口，uint32_t。
          packet_len,         // 包長度，uint32_t。
          17                  // 填寫 17，代表 UDP，uint32_t。
      );
      
      // ...

   4. 掛載UDP網(wǎng)絡(luò)流量出方向

      #include "das.h"
      #include "inet.h"
      
      // ...
      
      struct in_addr remote_addr;
      struct in_addr local_addr;
      inet_aton(remote_ip, &remote_addr);
      inet_aton(local_ip, &local_addr);
      
      das_attest("NFI_OUTPUT", 
          local_addr.s_addr,  // 反過來，本機(jī) IP 位置，需要是 inet_aton 轉(zhuǎn)換后格式，uint32_t。
          remote_addr.s_addr, // 反過來，外部 IP 位置，需要是 inet_aton 轉(zhuǎn)換后格式，uint32_t。
          local_port,         // 反過來，本機(jī)端口，uint32_t。
          remote_port,        // 反過來，外部端口，uint32_t。
          packet_len,         // 包長度，uint32_t。
          17                  // 填寫 17，代表 UDP，uint32_t。
      );
      
      // ...

步驟一：初始化核心服務(wù)

請參考如下函數(shù)原型：

void* das_init(const char *product_name, const char *device_name);

入?yún)⑿畔⑷缦拢?/p>

步驟二：設(shè)置固件版本號

請參考如下函數(shù)原型：

int das_set_firmware_version(char *ver);

入?yún)⑿畔⑷缦拢?/p>

步驟三：設(shè)置上下行消息主題

服務(wù)器端和客戶端根據(jù)消息的topic類型來確認(rèn)是否是自己需要處理的數(shù)據(jù)。

請參考如下函數(shù)原型：

• 設(shè)置上行消息主題

  const char* das_pub_topic(void *session, const char *topic);

• 設(shè)置下行消息主題

  const char* das_sub_topic(void *session, const char *topic);

  入?yún)⑿畔⑷缦拢?/p>

  參數(shù)	描述
  session	由das_init函數(shù)返回的服務(wù)實(shí)例。
  topic	自定義的上下行消息topic字符串；如果想使用內(nèi)置的缺省topic，則此值為NULL。

  返回結(jié)果如下：

  請求結(jié)果	描述
  成功	返回默認(rèn)或自定義的topic字符串。 說明 如果topic參數(shù)為NULL，返回內(nèi)置的缺省topic字符串，原型如下：/sys/$(product_name)/$(device_name)/security/up(down)stream。 自定義topic字符串長度不能超過64字節(jié)，否則設(shè)置會失敗。
  失敗	返回NULL。有可能是參數(shù)錯誤或者topic字符串超過64字節(jié)。

步驟四：配置網(wǎng)絡(luò)連接

基礎(chǔ)版SOC SDK采集的數(shù)據(jù)需要通過業(yè)務(wù)已有的網(wǎng)絡(luò)通道進(jìn)行上報(bào)。

請參考如下函數(shù)原型：

void das_connection(void *session,
                    publish_handle_t publish_handle,
                    void *channel);

入?yún)⑿畔⑷缦拢?/p>

步驟五：消息發(fā)送回調(diào)

用來發(fā)送數(shù)據(jù)的回調(diào)函數(shù)。如果基礎(chǔ)版SOC SDK有數(shù)據(jù)需要上報(bào)，那么該回調(diào)由安全服務(wù)內(nèi)部觸發(fā)。請將此回調(diào)通過das_connection注冊。

請參考如下函數(shù)原型：

typedef int (*publish_handle_t)(const char *topic,
                                const uint8_t *message, size_t msg_size,
                                void *channel);

入?yún)⑿畔⑷缦拢?/p>

步驟六：更新網(wǎng)絡(luò)連接狀態(tài)

當(dāng)業(yè)務(wù)的網(wǎng)絡(luò)狀態(tài)發(fā)生變化時，需要通知基礎(chǔ)版SOC SDK。

請參考如下函數(shù)原型：

• 業(yè)務(wù)網(wǎng)絡(luò)已連接

  void das_on_connected(void *session);

• 業(yè)務(wù)網(wǎng)絡(luò)已斷開

  void das_on_connected(void *session);

  入?yún)⑿畔⑷缦拢?/p>

  參數(shù)	描述
  session	由das_init函數(shù)返回的實(shí)例。

  本函數(shù)無返回值。

步驟七：處理下行數(shù)據(jù)

當(dāng)業(yè)務(wù)收到服務(wù)器下發(fā)的指令或數(shù)據(jù)的時候，可以通過topic來區(qū)分是否是SOC的。如果是，則需要通知基礎(chǔ)版SOC SDK來處理。

請參考如下函數(shù)原型：

void das_on_message(void *session, const uint8_t *message, size_t msg_size);

入?yún)⑿畔⑷缦拢?/p>

步驟八：步進(jìn)驅(qū)動取證服務(wù)

基礎(chǔ)版SOC SDK不會主動執(zhí)行取證操作，而是需要業(yè)務(wù)定時來驅(qū)動執(zhí)行。

請參考如下函數(shù)原型：

das_result_t das_stepping(void *session, uint64_t now);

入?yún)⑿畔⑷缦拢?/p>

步驟九：終止核心服務(wù)

請參考如下函數(shù)原型：

void das_final(void *session);

入?yún)⑿畔⑷缦拢?/p>