摘要：
rsync.pid）｛/*Thisischildprocess*/execvp；fprintf；exit（-1）；｝如果｛fpprintf；return-1；｝uloop_process_add；｝Intmain（）｛…..uloop_init（）；//初始化fun（）；uloop_run（）；｝以上是使用库之前的一个简单伪代码演示。ULoop仅适用于单个线程中的任务。多线程会导致错误。
摘自：https://blog.csdn.net/liangdsing/article/details/53201410
uloop.c是libubox的一个小模块，简化了编程
1. socket 使用#include "" struct uloop_fd ufd; //创建uloop_fd全局变量 static void fd_handler(struct uloop_fd *u, unsigned int ev) { if(recvfrom(u->fd, ...)) == -1) { } else { //do your work } } int main() { // int socket = socket(....); ufd.fd = socket; uloop_init(); //使用库初始化 ufd.cb = fd_handler; uloop_fd_add(&ufd, ULOOP_READ)); uloop_run(); }
#include "" struct uloop_timeout timeout; //创建uloop_timeout全局变量 int frequency = 5; //每隔5秒超时一次 static void timeout_cb(struct uloop_timeout *t) { //do your work uloop_timeout_set(t, frequency * 1000);//设置下次的超时时间 } int main() { uloop_init(); //使用库初始化 timeout.cb = timeout_cb; uloop_timeout_set(t, frequency * 1000);//设置下次的超时时间 uloop_run(); }
其作用是在子进程中调用rsync命令进行文件同步，子进程退出后调用rsync_complete回调函数
#include "" static struct uloop_process rsync; //创建rsync全局变量 static void rsync_complete(struct uloop_process *proc, int ret) { //do something where child exit; printf("rsync work is complete "); } function fun() { char *argv[]={"rsync", "-az", "rsync://XYZ@192.168.26.99/www","/root/www/","--password-file=/root/rsync.secrets", NULL}; rsync.cb = rsync_complete; rsync.pid = fork(); if (!rsync.pid) { /* This is child process*/ execvp(argv[0], argv); fprintf(stderr, "fork failed "); exit(-1); } if (rsync.pid <=0) { fprintf(stderr, "fork failed2 "); return -1; } uloop_process_add(&rsync); } int main() { ..... uloop_init(); //使用库前进行初始化 fun(); uloop_run(); }
以上是简单的伪代码演示。uloop只适合于单线程中的任务，多线程会有bug。