ymodem 发送代码实现，测试支持securecrt8.1的多文件传输

发布于 2018-11-16 10:25:43 浏览：5725 订阅该版

* 本帖最后由 白霖 于 2018-11-30 09:46 编辑 *

原代码仅支持ymodem文件下载，效果还比较不错，位置在/rt-thread/components/utilities/ymodem目录下

现需要使用到ymodem文件上传功能，因此顺便实现了上传功能，

代码风格继承原有风格，本来打算分成多个文件，不过考虑到原来c文件的命名，还是算了，都放到ymodem.c中得了

希望能给rtt出些绵薄之力。

-------------------------------------分割线2018-11-16 12:06--------------------------------------
补充说明以下使用方法

传递参数类似rym
/**
 * @brief transmit multi file
 * @param dev         serial port to be used
 * @param oflag       serial port open flag
 * @param fname_list  file's name to be sent
 * @param file_num    file count to be sent
 * @return if succeed return RT_EOK
 * @attention the file name in fname_list must be absolute file path
 *            if not, the transmistion will be failed
 */
rt_err_t tym_recv_on_device( struct tym_ctx *ctx, rt_device_t dev, rt_uint16_t oflag,
        int handshake_timeout, const char** fname_list, int file_num);

注意区分的是：fname_list 的类型是一个字符串数组，file_num指明待传文件数量

同时，需要提前实现dfs接口。
传输的文件名也必须是绝对地址。

示例函数

```int sym_test(void)
{
    const char* filenamelist[2]={"/menu.json","coregen.log"};

struct tym_ctx *ctx = rt_malloc(sizeof(struct tym_ctx));
    rt_device_t dev = rt_device_find("uart3");
    rt_err_t err = tym_recv_on_device(ctx, dev, RT_DEVICE_OFLAG_RDWR | RT_DEVICE_FLAG_INT_RX, 1000, filenamelist, 2);

rt_free(ctx);

return err;
}
FINSH_FUNCTION_EXPORT(sym_test, sym function demo);```------------------------------------------分割线------2018-11-30 09:42------------------------------------------
发现一个使用问题，情景是，当传输的文件大小超过10个数据包时，传输出错，
经过监听端口发现，原本应该为0A的包序号，被flag为STREAM的串口端口强制转换成了0D 0A

进一步查看代码发现，这个转换是在serial驱动模块里实现的。

下载附件 [ymodem.c](https://oss-club.rt-thread.org/uploads/201811/16/102504bm46e8icgat4c8co.attach)

下载附件 [ymodem.h](https://oss-club.rt-thread.org/uploads/201811/16/102505ufretmunegfll9uf.attach)

10 个回答

armink 2018-11-30

这家伙很懒，什么也没写！

>发现一个使用问题，情景是，当传输的文件大小超过10个数据包时，传输出错，
>经过监听端口发现，原本应该为0 ...

---

估计你的用法有问题吧，本来 on_device 时就是有做这个处理的，如下图：[attach]6895[/attach]

我们的一般用法如下：

```
#include <rthw.h>
#include <rtthread.h>
#include <shell.h>
#include <finsh.h>
#include <ulog.h>
#include <easyflash.h>
#include <ymodem.h>
#include <board.h>

static size_t update_file_total_size, update_file_cur_size;
static uint32_t crc32_checksum = 0;
static enum rym_code ymodem_on_begin(struct rym_ctx *ctx, rt_uint8_t *buf, rt_size_t len) {
    char *file_name, *file_size;

/* calculate and store file size */
    file_name = (char *) &buf[0];
    file_size = (char *) &buf[rt_strlen(file_name) + 1];
    update_file_total_size = atol(file_size);
    /* 4 bytes align */
    update_file_total_size = (update_file_total_size + 3) / 4 * 4;
    update_file_cur_size = 0;
    crc32_checksum = 0;

/* erase backup section */
    if (ef_erase_bak_app(update_file_total_size)) {
        /* if erase fail then end session */
        return RYM_CODE_CAN;
    }

return RYM_CODE_ACK;
}

static enum rym_code ymodem_on_data(struct rym_ctx *ctx, rt_uint8_t *buf, rt_size_t len) {
    if (update_file_cur_size + len <= update_file_total_size) {
        crc32_checksum = ef_calc_crc32(crc32_checksum, buf, len);
    } else {
        crc32_checksum = ef_calc_crc32(crc32_checksum, buf, update_file_total_size - update_file_cur_size);
    }
    /* write data of application to backup section  */
    if (ef_write_data_to_bak(buf, len, &update_file_cur_size, update_file_total_size)) {
        /* if write fail then end session */
        return RYM_CODE_CAN;
    }
    return RYM_CODE_ACK;
}

void update(uint8_t argc, char **argv) {
    char new_char[2], c_file_size[11] = { 0 }, c_crc32_checksum[11] = { 0 };
    struct rym_ctx rctx;

ulog_global_filter_lvl_set(LOG_FILTER_LVL_SILENT);
    rt_kprintf("Waring: This operator will not recovery. If you want, press 'Y'.\n");
    new_char[0] = getchar();
    rt_kprintf("%c", new_char[0]);
    new_char[1] = getchar();
    rt_kprintf("%c", new_char[1]);
    if ((new_char[0] != 'y') && (new_char[0] != 'Y')) {
        goto __exit;
    }
    rt_kprintf("Please select the application firmware file and use Ymodem to send.\n");

if (!rym_recv_on_device(&rctx, rt_console_get_device(), RT_DEVICE_OFLAG_RDWR | RT_DEVICE_FLAG_INT_RX,
            ymodem_on_begin, ymodem_on_data, NULL, RT_TICK_PER_SECOND)) {
        /* wait some time for terminal response finish */
        rt_thread_delay(RT_TICK_PER_SECOND);
        /* save the downloaded firmware crc32 checksum ENV */
        ef_set_env("iap_need_crc32_check", "1");
        rt_snprintf(c_crc32_checksum, sizeof(c_crc32_checksum), "%ld", crc32_checksum);
        ef_set_env("iap_crc32_checksum", c_crc32_checksum);
        /* set need copy application from backup section flag is 1, backup application length */
        ef_set_env("iap_need_copy_app", "1");
        rt_sprintf(c_file_size, "%ld", update_file_total_size);
        ef_set_env("iap_copy_app_size", c_file_size);
        ef_save_env();
        rt_kprintf("Download firmware to flash OK.\n");
        rt_kprintf("System now will restart...\n");
        NVIC_SystemReset();
    } else {
        /* wait some time for terminal response finish */
        rt_thread_delay(RT_TICK_PER_SECOND);
        rt_kprintf("Update firmware fail.\n");
    }

__exit:
    ulog_global_filter_lvl_set(LOG_FILTER_LVL_ALL);
}
MSH_CMD_EXPORT(update, Update user application firmware);
```