皮皮网

【官方直接解析源码】【esps源码】【紫色源码】cansend源码

2024-12-23 01:42:18 来源:edis源码级解剖

1.Linux 应用案例开发手册——基于Xilinx Zynq-7010/7020工业开发板
2.linux下socket 网络编程(客户端向服务器端发送文件) 求源代码 大哥大姐帮帮忙 。。谢谢
3.CANOpen系列教程14_协议源码移植(二)

cansend源码

Linux 应用案例开发手册——基于Xilinx Zynq-7010/7020工业开发板

       开发案例说明

       开发案例位于产品资料“4-软件资料\Demo\tl-linux-application\”路径下的 base-demos 和 python-demos 目录。base-demos目录提供Linux常用开发案例,案例bin目录存放可执行文件,案例src目录存放源码。官方直接解析源码python-demos目录提供Python开发案例,脚本文件无需编译,可直接运行。测试板卡是基于Xilinx Zynq-系列XC7Z/XC7Z高性能低功耗处理器设计的异构多核SoC工业级核心板。

       若需重新编译Linux常用开发案例,请将对应案例src目录复制到Ubuntu工作目录下,进入src目录执行命令加载PetaLinux环境变量,并执行make命令进行案例编译。编译完成后,esps源码将在当前目录下生成可执行文件。

       Linux常用开发案例包括tl_led_flash、tl_key_test和tl_can_echo等。

       tl_led_flash案例功能是通过向评估底板用户指示灯LED设备节点反复交替写入1、0数值,实现LED闪烁效果。LED点亮与熄灭时间均为0.5s。程序流程示意图显示LED设备节点为“/sys/class/leds/user-ledX/”目录下的brightness。

       操作说明包括将案例bin目录下的可执行程序tl_led_flash复制到评估板文件系统,并在可执行程序所在目录执行命令运行程序,即可看到评估底板LED1以0.5s的时间间隔进行闪烁。同时,串口终端打印系统全部LED设备信息和程序当前控制的LED设备信息。

       关键代码包括预定义LED数组、紫色源码LED亮灭操作和时间间隔。

       tl_key_test案例功能是通过监听用户按键设备节点状态,检测按键事件。程序流程示意图显示用户按键设备节点为“/dev/input/event0”。操作说明包括将案例bin目录下的可执行程序tl_key_test复制到评估板文件系统,在可执行程序所在目录执行命令运行程序,串口终端将打印提示信息。再按下评估板用户按键KEY1,程序将检测到按键事件,并打印按键状态信息。

       关键代码包括定义按键、监听按键事件和循环监听。

       tl_can_echo案例功能使用canutils工具包的canecho程序实现CAN接口数据接收并重发功能。canutils工具包内含5个独立程序,qurlinfo源码包括canconfig、candump、canecho、cansend、cansequence等。本案例仅使用canecho功能,如需实现其他功能,可自行下载canutils工具包并从中获取对应功能程序源码。操作说明包括使用USB转CAN模块连接评估板CAN接口和PC机USB接口,参照调试工具安装文档安装USB转CAN驱动和ECAN Tools调试软件,双击打开ECAN Tools软件,选择设备类型,然后点击“打开设备”。打开ECAN Tools界面,源码10110101将案例bin目录下的PL端.bin格式可执行文件复制到评估板文件系统"/lib/firmware/"目录下,并执行命令加载PL端可执行文件。进入评估板文件系统使用文件系统自带的canconfig工具设置波特率,并启动CAN接口。将案例bin目录下的可执行程序tl_can_echo复制到评估板文件系统,执行命令查看程序参数信息,绑定CAN接口并接收由ECAN Tools发出的数据,然后将接收到的数据重新发送出去。

       关键代码包括使用socket监听CAN接口和将从CAN接口接收到的数据重新发送出去。

       tcp_udp_demos案例主要实现客户端(client)与服务端(server)的文本数据相互收发功能。案例包含4个程序,包括tl_tcp_server、tl_tcp_client、tl_udp_server和tl_udp_client。操作说明包括将案例bin目录下的4个可执行程序复制到评估板文件系统,在Ubuntu中执行命令使用OpenSSH登陆评估板文件系统,并在可执行程序所在目录执行命令运行TCP和UDP服务端和客户端程序。程序执行后,客户端将会连接服务端或服务端和客户端程序均在评估板上运行时,可进行本地回环测试。关键代码以TCP通信程序为例,包括注意源码中的数据结构和系统调用的使用。

       Python开发案例包括tl_led_flash和tl_key_test两个简单案例。操作说明包括将案例目录下的脚本文件拷贝到评估板文件系统,并在脚本文件所在目录执行命令查看程序参数信息,执行命令运行脚本程序,即可看到评估底板上的LED闪烁或检测按键事件。关键代码包括查找所有LED设备和控制LED亮灭,以及打开按键设备和监听按键事件。

       以上内容为Linux应用案例开发手册——基于Xilinx Zynq-/工业开发板中的详细开发案例和操作说明。更多关于嵌入式开发的内容分享,欢迎关注Tronlong创龙科技~

linux下socket 网络编程(客户端向服务器端发送文件) 求源代码 大哥大姐帮帮忙 。。谢谢

       server:

       #include <stdio.h>

       #include <errno.h>

       #include <unistd.h>

       #include <signal.h>

       #include <stdlib.h>

       #include <sys/types.h>

       #include <sys/socket.h>

       #include <arpa/inet.h>

       #include <netinet/in.h>

       #include <syslog.h>

       #include <sys/time.h>

       #include <string.h>

       #include <fcntl.h>

       #include <sys/wait.h>

       #define MAXDATASIZE

       #define SERVPORT

       #define BACKLOG

       int SendFileToServ(const char *path, const char *FileName, const char *ip)

       {

       #define PORT

        int sockfd;

        int recvbytes;

        char buf[MAXDATASIZE];

        char send_str[MAXDATASIZE];

        char filepath[] = { 0};

        struct sockaddr_in serv_addr;

        FILE *fp;

        sprintf(filepath, "%s%s", path, FileName);

        if((sockfd=socket(AF_INET,SOCK_STREAM,0))==-1)

        {

        perror("socket");

        return 1;

        }

        bzero(&serv_addr,sizeof(struct sockaddr_in));

        serv_addr.sin_family=AF_INET;

        serv_addr.sin_port=htons(PORT);

        inet_aton(ip, &serv_addr.sin_addr);

        int IErrCount = 0;

       again:

        if(connect(sockfd,(struct sockaddr *)&serv_addr,sizeof(struct sockaddr))==-1)

        {

        if (5 == IErrCount)

        return 1;

        IErrCount++;

        perror("connect");

        sleep(2);

        goto again;

        }

        //if ((fp = fopen(FileName, "rb")) == NULL)

        if ((fp = fopen(filepath, "rb")) == NULL)

        {

        perror("fopen ");

        return 1;

        }

        recvbytes = write(sockfd, FileName, strlen(FileName));

        recvbytes = read(sockfd, buf, MAXDATASIZE);

        if (!memcmp(buf, "sendmsg", 7))

        {

        while(fgets(send_str, MAXDATASIZE, fp))

        {

        recvbytes = write(sockfd, send_str, strlen(send_str));

        recvbytes = read(sockfd, buf, MAXDATASIZE);

        if (recvbytes <= 0)

        {

        fclose(fp);

        close(sockfd);

        return 1;

        }

        if (memcmp(buf, "goon", 4))

        {

        fclose(fp);

        close(sockfd);

        return 1;

        }

        }

        recvbytes = write(sockfd, "end", 3);

        }

        else

        {

        fclose(fp);

        close(sockfd);

        return 1;

        }

        memset(buf, 0, MAXDATASIZE);

        if (read(sockfd, buf, MAXDATASIZE) <= 0)

        {

        close(sockfd);

        return 2;

        }

        char *Eptr = "nginx reload error";

        //printf("bf[%s]\n", buf);

        int ret;

        ret = strncmp(buf, Eptr, strlen(Eptr));

        //printf("%d\n", ret);

        if (!ret)

        {

        close(sockfd);

        return 2;

        }

        close(sockfd);

        return 0;

       }

       int mysyslog(const char * msg)

       {

        FILE *fp;

        if ((fp = fopen("/tmp/tmp.log", "a+")) == NULL)

        {

        return 0;

        }

        fprintf(fp, "[%s]\n", msg);

        fclose(fp);

        return 0;

       }

       static void quit_handler(int signal)

       {

        kill(0, SIGUSR2);

        syslog( LOG_NOTICE, "apuserv quit...");

        // do something exit thing ,such as close socket ,close mysql,free list

        // .....

        //i end

        exit(0);

       }

       static int re_conf = 0;

       static void reconf_handler(int signal)

       {

        re_conf=1;

        syslog(LOG_NOTICE,"apuserv reload configure file .");

        // 请在循环体中判断,如果re_conf == 1,请再次加载配置文件。

       }

       static int isrunning(void)

       {

        int fd;

        int ret;

        struct flock lock;

        lock.l_type = F_WRLCK;

        lock.l_whence = 0;

        lock.l_start = 0;

        lock.l_len = 0;

        const char *lckfile = "/tmp/apuserv.lock";

        fd = open(lckfile,O_WRONLY|O_CREAT);

        if (fd < 0) {

        syslog(LOG_ERR,"can not create lock file: %s\n",lckfile);

        return 1;

        }

        if ((ret = fcntl(fd,F_SETLK,&lock)) < 0) {

        ret = fcntl(fd,F_GETLK,&lock);

        if (lock.l_type != F_UNLCK) {

        close(fd);

        return lock.l_pid;

        }

        else {

        fcntl(fd,F_SETLK,&lock);

        }

        }

        return 0;

       }

       int MyHandleBuff(const char *buf, char *str, char *FileName, char *pth)

       {

        sscanf(buf, "%s %s %s", pth, FileName, str);

        printf("path=%s\nfilename=%s\nip=%s\n", pth, FileName, str);

        return 0;

       }

       int main(int argc, char **argv)

       {

        int sockfd,client_fd;

        socklen_t sin_size;

        struct sockaddr_in my_addr,remote_addr;

        char buff[MAXDATASIZE];

        int recvbytes;

       #if 1

        int pid ;

        char ch ;

        int ret;

        int debug = 0;

        signal(SIGUSR1, SIG_IGN);

        signal(SIGUSR2, SIG_IGN);

        signal(SIGHUP, SIG_IGN);

        signal(SIGTERM, quit_handler);

        syslog(LOG_NOTICE,"apuserver start....");

        while ((ch = getopt(argc, argv, "dhV")) != -1) {

        switch (ch) {

        case 'd':

        debug = 1;

        break;

        case 'V':

        printf("Version:%s\n","1.0.0");

        return 0;

        case 'h':

        printf(" -d use daemon mode\n");

        printf(" -V show version\n");

        return 0;

        default:

        printf(" -d use daemon mode\n");

        printf(" -V show version\n");

        }

        }

        if (debug && daemon(0,0 ) ) {

        return -1;

        }

        if (isrunning()) {

        fprintf(stderr, "apuserv is already running\n");

        syslog(LOG_INFO,"apuserv is already running\n");

        exit(0);

        }

        while (1) {

        pid = fork();

        if (pid < 0)

        return -1;

        if (pid == 0)

        break;

        while ((ret = waitpid(pid, NULL, 0)) != pid) {

        syslog(LOG_NOTICE, "waitpid want %d, but got %d", pid, ret);

        if (ret < 0)

        syslog(LOG_NOTICE, "waitpid errno:%d", errno);

        }

        kill(0, SIGUSR2);

        sleep(1);

        syslog(LOG_NOTICE,"restart apuserver");

        }

        signal(SIGHUP, reconf_handler);

        signal(SIGPIPE, SIG_IGN);

        signal(SIGUSR1,SIG_IGN);

        signal(SIGUSR2, SIG_DFL);

        signal(SIGTERM, SIG_DFL);

       #endif

        if((sockfd=socket(AF_INET,SOCK_STREAM,0))==-1)

        {

        perror("socket");

        exit(1);

        }

        bzero(&my_addr,sizeof(struct sockaddr_in));

        my_addr.sin_family=AF_INET;

        my_addr.sin_port=htons(SERVPORT);

        my_addr.sin_addr.s_addr = htonl(INADDR_ANY);

        if(bind(sockfd,(struct sockaddr *)&my_addr,sizeof(struct sockaddr))==-1)

        {

        perror("bind");

        exit(1);

        }

        if(listen(sockfd,BACKLOG)==-1)

        {

        perror("listen");

        exit(1);

        }

        int nret;

        while(1)

        {

        sin_size = sizeof(struct sockaddr_in);

        if((client_fd = accept(sockfd, (struct sockaddr *)&remote_addr, &sin_size))==-1)

        {

        perror("falied accept");

        continue;

        }

        memset(buff, 0, MAXDATASIZE);

        recvbytes = read(client_fd, buff, MAXDATASIZE);

        char str[] = { 0};

        char FileName[] = { 0};

        char path[] = { 0};

        MyHandleBuff(buff, str, FileName, path);

        if (recvbytes > 0)

        {

        nret = SendFileToServ(path, FileName, str);

        printf("nret[%d]\n", nret);

        if (1 == nret)

        write(client_fd, "send file error", );

        else if(2 == nret)

        write(client_fd, "reload nginx error", );

        else

        write(client_fd, "succ", 4);

        }

        close(client_fd);

        }

       }

       _________________________________________________

       client:

       #include <stdio.h>

       #include <errno.h>

       #include <unistd.h>

       #include <signal.h>

       #include <stdlib.h>

       #include <sys/types.h>

       #include <sys/socket.h>

       #include <arpa/inet.h>

       #include <netinet/in.h>

       #include <syslog.h>

       #include <sys/time.h>

       #include <string.h>

       #include <fcntl.h>

       #include <sys/wait.h>

       #define MAXDATASIZE

       #define SERVPORT

       #define BACKLOG

       int mysyslog(const char * msg)

       {

        FILE *fp;

        if ((fp = fopen("/tmp/tmp.log", "a+")) == NULL)

        {

        return 0;

        }

        fprintf(fp, "[%s]\n", msg);

        fclose(fp);

        return 0;

       }

       static void quit_handler(int signal)

       {

        kill(0, SIGUSR2);

        syslog( LOG_NOTICE, "apuserv quit...");

        // do something exit thing ,such as close socket ,close mysql,free list

        // .....

        //i end

        exit(0);

       }

       static int re_conf = 0;

       static void reconf_handler(int signal)

       {

        re_conf=1;

        syslog(LOG_NOTICE,"apuserv reload configure file .");

        // ·1nf == 1£′μ?

        static int isrunning(void)

       {

        int fd;

        int ret;

        struct flock lock;

        lock.l_type = F_WRLCK;

        lock.l_whence = 0;

        lock.l_start = 0;

        lock.l_len = 0;

        const char *lckfile = "/tmp/dstserver.lock";

        fd = open(lckfile,O_WRONLY|O_CREAT);

        if (fd < 0) {

        syslog(LOG_ERR,"can not create lock file: %s\n",lckfile);

        return 1;

        }

        if ((ret = fcntl(fd,F_SETLK,&lock)) < 0) {

        ret = fcntl(fd,F_GETLK,&lock);

        if (lock.l_type != F_UNLCK) {

        close(fd);

        return lock.l_pid;

        }

        else {

        fcntl(fd,F_SETLK,&lock);

        }

        }

        return 0;

       }

       int main(int argc, char **argv)

       {

        int sockfd,client_fd;

        socklen_t sin_size;

        struct sockaddr_in my_addr,remote_addr;

        char buff[MAXDATASIZE];

        int recvbytes;

       #if 1

        int pid ;

        char ch ;

        int ret;

        int debug = 0;

        signal(SIGUSR1, SIG_IGN);

        signal(SIGUSR2, SIG_IGN);

        signal(SIGHUP, SIG_IGN);

        signal(SIGTERM, quit_handler);

        syslog(LOG_NOTICE,"dstserver start....");

        while ((ch = getopt(argc, argv, "dhV")) != -1) {

        switch (ch) {

        case 'd':

        debug = 1;

        break;

        case 'V':

        printf("Version:%s\n","1.0.0");

        return 0;

        case 'h':

        printf(" -d use daemon mode\n");

        printf(" -V show version\n");

        return 0;

        default:

        printf(" -d use daemon mode\n");

        printf(" -V show version\n");

        }

        }

        if (debug && daemon(0,0 ) ) {

        return -1;

        }

        if (isrunning()) {

        fprintf(stderr, "dstserver is already running\n");

        syslog(LOG_INFO,"dstserver is already running\n");

        exit(0);

        }

        while (1) {

        pid = fork();

        if (pid < 0)

        return -1;

        if (pid == 0)

        break;

        while ((ret = waitpid(pid, NULL, 0)) != pid) {

        syslog(LOG_NOTICE, "waitpid want %d, but got %d", pid, ret);

        if (ret < 0)

        syslog(LOG_NOTICE, "waitpid errno:%d", errno);

        }

        kill(0, SIGUSR2);

        sleep(1);

        syslog(LOG_NOTICE,"restart apuserver");

        }

        signal(SIGHUP, reconf_handler);

        signal(SIGPIPE, SIG_IGN);

        signal(SIGUSR1,SIG_IGN);

        signal(SIGUSR2, SIG_DFL);

        signal(SIGTERM, SIG_DFL);

       #endif

        if((sockfd=socket(AF_INET,SOCK_STREAM,0))==-1)

        {

        perror("socket");

        exit(1);

        }

        bzero(&my_addr,sizeof(struct sockaddr_in));

        my_addr.sin_family=AF_INET;

        my_addr.sin_port=htons(SERVPORT);

        my_addr.sin_addr.s_addr = htonl(INADDR_ANY);

        if(bind(sockfd,(struct sockaddr *)&my_addr,sizeof(struct sockaddr))==-1)

        {

        perror("bind");

        exit(1);

        }

        if(listen(sockfd,BACKLOG)==-1)

        {

        perror("listen");

        exit(1);

        }

        char filepath[MAXDATASIZE]= { 0};

        FILE *fp;

        while(1)

        {

        sin_size = sizeof(struct sockaddr_in);

        if((client_fd = accept(sockfd, (struct sockaddr *)&remote_addr, &sin_size))==-1)

        {

        perror("falied accept");

        continue;

        }

        memset(buff, 0, MAXDATASIZE);

        recvbytes = read(client_fd, buff, MAXDATASIZE);

        sprintf(filepath, "/etc/nginx/url_rule/%s", buff);

        if ((fp = fopen(filepath, "wb")) == NULL)

        {

        perror("fopen");

        close(client_fd);

        continue;

        }

        write(client_fd, "sendmsg", 7);

        while(read(client_fd, buff, MAXDATASIZE))

        {

        if (!memcmp(buff, "end", 3))

        {

        fclose(fp);

        break;

        }

        else

        {

        fprintf(fp, "%s", buff);

        write(client_fd, "goon", 4);

        }

        }

        //system("nginx -s reload");

        char *Sptr = "nginx reload succ";

        char *Eptr = "nginx reload error";

        int ret;

        ret = system("nginx -s reload");

        printf("ret[%d]\n", ret);

        if (ret != 0)

        {

        write(client_fd, Eptr, strlen(Eptr));

        }

        else

        {

        write(client_fd, Sptr, strlen(Sptr));

        }

        close(client_fd);

        }

       }

       以前写的:内容忘记了。不是很复杂你可以自己看!

CANOpen系列教程_协议源码移植(二)

       本文主要阐述了在嵌入式系统开发中,将CANOpen协议源码移植到工程中并实现的具体步骤。作者首先强调了系列教程的背景,基于CanFestival架构、STMF1芯片、FreeRTOS操作系统、以及Keil MDK-ARM开发环境。接下来,文章深入讲解了移植过程中需要关注的几个关键点。

       在添加源码和路径部分,作者指出需要在现有工程中加入与CANOpen相关的组和文件,并添加CANOpen源码的inc头文件路径,确保编译时能正确找到所需文件。这部分是基础准备工作,确保开发环境能正确识别和使用新添加的代码。

       在添加代码及分析部分,文章聚焦于实际代码实现的关键点。作者提到需要修改的canfestival.h文件,以防止递归包含问题,同时解释了需要实现的底层驱动函数,如canSend,这是CANOpen源代码调用最频繁的函数。作者还详细介绍了初始化相关接口的实现方法,以及定时器调度接口的调用和实现。特别地,文中提到发送接口函数canSend的重要性,并建议尽量保持其接口原样,因为这一函数在多个源文件中被广泛调用。最后,文章还讨论了发送和接收缓存的实现、中断接收机制以及配置节点等关键功能。

       工程下载及运行效果部分展示了作者提供的示例工程,该工程展示了主站和从站的心跳功能,通过CAN分析仪抓取数据进行验证。通过这一部分,读者可以直观地了解移植后的CANOpen协议在实际应用中的表现。

       文章最后对文档的使用和版权所有进行了说明,并推荐了作者的博客、GitHub以及微信公众号,鼓励读者关注以获取更多相关资源和内容。