libusb开发（关于异步IO）

libusb开发（关于异步IO）

上一篇介绍了libusb的同步传输接口，但是很多情况下使用同步传输远远达不到我们的要求，那么这个时候就应该使用异步传输。接下来的内容是我学习libusb时遇到的问题以及异步IO如何使用。

//异步写

void QUniversalSerialBus::AsyncWrite(unsigned char sendBuffer[],size_t len) { int rc = 0; //创建异步传输结构 libusb_transfer* transfer = libusb_alloc_transfer(0); //填充异步传输结构 //transfer 传输结构 //dHand 设备句柄 //sendBuffer 要发送的数据 //len 数据长度 //callbackSend 回调函数，发送完成、失败、或者超时都会调用词回调 //this 用户数据，此处可以放任意数据， //10 超时时间此处写的是10毫秒 libusb_fill_bulk_transfer(transfer,dHand,2,sendBuffer,static_cast<int>(len),&callbackSend,this,10); //提交传输结构 rc = libusb_submit_transfer(transfer); //判断是否传输成功 if(rc < 0) { //释放传输结构 libusb_free_transfer(transfer); } } void callbackSend(struct libusb_transfer *transfer) { if (transfer->status != LIBUSB_TRANSFER_COMPLETED) { //传输失败，可以尝试重新提交传输结构 rc = libusb_submit_transfer(transfer); //判断是否传输成功 if(rc < 0) { //释放传输结构 libusb_free_transfer(transfer); } } //传输完成 printf(“LIBUSB_TRANSFER_COMPLETED”); //释放传输结构 libusb_free_transfer(transfer); transfer = nullptr; }

//异步接收

void QUniversalSerialBus::AsyncRead() { int rc = 0; //循环100次 提交100次传输结构，类似于提交了100个缓存等待接受，这样不会丢包 for(int i = 0;i<100;i++) { //创建异步传输结构 libusb_transfer* transfer = libusb_alloc_transfer(0); //开辟接受内存地址 unsigned char *buf = new unsigned char[64]; //清空内存 memset(buf,0,64); transfer->actual_length = 0; //填充传输结构 //transfer 传输结构 //dHand 设备句柄 //0x82 设备端点，这里是我使用的读数据端点 //buf 数据接受存放缓存 //64 缓存大小 此处我开辟的是64个字节大小的缓存 //callbackRevc 接收回调，接收完成、超时、失败等状态都会调用第回调 //this 用户数据 ，此处可以放任意数据， //0超时时间此处写的是0代表是无限等待超时直到有数据触发。libusb_fill_bulk_transfer(transfer,dHand,0x82,buf,64,&callbackRevc,this,0); //提交传输 rc = libusb_submit_transfer(transfer); if(rc < 0) { //取消传输 libusb_cancel_transfer(transfer); //释放传输结构 libusb_free_transfer(transfer); transfer = nullptr; return; } qTransferList.append(transfer); } } void callbackRevc(struct libusb_transfer *transfer) { QUniversalSerialBus* qObj = nullptr; //数据传输完成 if (transfer->status == LIBUSB_TRANSFER_COMPLETED) { if(transfer->actual_length > 0) { //有数据接受，这里我用的是Qt的语法，将接收到的数据通过对象传出去 QByteArray s(reinterpret_cast<char*>(transfer->buffer),transfer->actual_length); qObj = reinterpret_cast<QUniversalSerialBus*>(transfer->user_data); emit qObj->revice(s); } //再次提交传输用于接受 int rv = libusb_submit_transfer(transfer); if (rv < 0) { printf(“error libusb_submit_transfer : %s\n”, libusb_strerror(libusb_error(rv))); libusb_cancel_transfer(transfer); //异步取消之前提交传输 } }else if (transfer->status == LIBUSB_TRANSFER_CANCELLED) {//取消传输 //释放传输结构 libusb_free_transfer(transfer); }else{ } }

以上就是异步IO的输入输出的用法，但是只有上面的步骤是完不成异步传输的，

异步传输还有一个特别重要的步骤：

//检测句柄事件

libusb_handle_events(context);

开启线程，不停的检查上下文环境变量，只有不停的调用此接口，设备传输才是能，才可以出发输入输出回调函数：

void QEventHandler::run() { while(!stop) { libusb_handle_events(context); } }