网站系统开发,创新的做网站,大数据营销的典型案例,破解软件网站最近一直在处理hid 数据需求#xff0c;简而言之就是两台设备直接可以通过usb 线互相传递数据。
项目架构 为什么Device 端要采用HID#xff08;人机接口设备#xff09;的方式发送和接收数据呢#xff1f;
主要是速度快#xff0c;举个例子#xff0c;就是鼠标移动简而言之就是两台设备直接可以通过usb 线互相传递数据。
项目架构 为什么Device 端要采用HID人机接口设备的方式发送和接收数据呢
主要是速度快举个例子就是鼠标移动屏幕可以及时响应用的也是这种协议。
因为Host端底层我们控制不了不能保证都支持Hid 协议所以Host 端采用跨平台方案libusb 协议。
Liusb 网上介绍的很多啦可以运行在各个平台windows ,android.linux,是一种理想中的跨平台数据传输方案。 项目主要功能
1sensor数据传输
2TP 数据传输按键传输同理 项目主要技术点
1TP数据监听
2sensor数据监听
3hid 数据传输丢失问题
4HID 节点生成监听
5开机启动native 服务处理数据
6selinux 权限问题 技术实现
代码结构 TP数据监听
驱动所有的滑动 和 按键 上报都是通过节点的方式不同平台节点有所差异需要和驱动沟通。我试验的平台节点是
#define INPUT_KEY_NODE /dev/input/event1
#define INPUT_TP_NODE /dev/input/event3
所以监听这两个就行了我们这里采用的是poll 的方式有数据的时候会回调没有的话会阻塞
主要代码
void HidReceiver::listenThread()
{struct pollfd fds[IN_FILES];fds[0].events POLLIN;fds[1].events POLLIN;fds[2].events POLLIN;int result;char buff[512];
// sleep(1);LOGD(hid open);hid_fd open(DEVICE_NODE, O_RDWR | O_NONBLOCK);int key_fd open(INPUT_KEY_NODE, O_RDWR | O_NONBLOCK);int tp_fd open(INPUT_TP_NODE, O_RDWR | O_NONBLOCK);LOGD(nod %d,%d,%d,hid_fd,key_fd,tp_fd);fds[0].fd hid_fd;fds[1].fd key_fd;fds[2].fd tp_fd;unsigned char data[sizeof(input_event)];input_event dev_data;while(1){result poll(fds, IN_FILES, -1);if (result 0) {LOGD(Poll timeout);} else if(result 0){if ((fds[0].revents POLLIN)){ int size read(fds[0].fd, buff, sizeof(buff));if(size 0){process_event(buff);}}if ((fds[1].revents POLLIN)){ int size read (fds[1].fd, (unsigned char*)data, sizeof(input_event));LOGD(size:%d, size);memcpy(dev_data, data, sizeof(input_event));LOGD(Keyevent size:%d, dev_data.type);// sensordata.sensorType 0x104;// sensordata.ievent dev_data;// process_event(sensordata);}if ((fds[2].revents POLLIN)){ int size read (fds[2].fd, (unsigned char*)data, sizeof(input_event));memcpy(dev_data, data, sizeof(input_event));#if 0LOGD(abs size:%d, dev_data.type);if (dev_data.type EV_ABS){if (dev_data.code ABS_MT_POSITION_X){x dev_data.value;if (x 0) x 0;LOGD(rel X:%d, dev_data.value);}else if(dev_data.code ABS_MT_POSITION_Y){LOGD(\nx%d,y%d,dev_data.code%d\n, x, y,dev_data.code);y dev_data.value;if (y 0) y 0;sensordata.sensorType 0x104;sensordata.abs_x x;sensordata.abs_y y;process_event(sensordata);x 0;y 0;}}#endifif (dev_data.type EV_KEY){LOGD(EV_KEY %d,dev_data.code);switch(dev_data.code){case KEY_KP5://双击case KEY_DASHBOARD://单机case KEY_F17://左滑case KEY_ISO://右滑case KEY_F16://上滑case KEY_CONFIG://下滑sensordata.sensorType 0x104;sensordata.type dev_data.type;sensordata.code dev_data.code;sensordata.value dev_data.value;sensordata.priority 3;process_event(sensordata);break; }}}} }
}
代码中DEVICE_NODE 用于监听hid 数据的这个后面说。
sensor数据监听
void SensorTransfer::listenThread()
{int64_t stamp;LOGD(listenThread);while (m_bListening){ASensorEvent event;while (ASensorEventQueue_getEvents(m_pEvtQue, event, 1) 0){stamp event.timestamp;switch (event.type){// case ASENSOR_TYPE_GYROSCOPE:// printf(GYROSCOPE:(%llu, %f,%f,%f)\n, (unsigned long long)stamp, event.data[0], event.data[1], event.data[2]);// break;case ASENSOR_TYPE_ACCELEROMETER:// printf(ACCELEROMETER: (%llu, %f,%f,%f)\n, (unsigned long long)stamp, event.data[0], event.data[1], event.data[2]);sensordata.stamp stamp;sensordata.sensorType 0x100;sensordata.xvalue event.data[0];sensordata.yvalue event.data[1];sensordata.zvalue event.data[2];saveSensorData(sensordata);sensordata.priority 1;break;case ASENSOR_TYPE_GRAVITY:// printf(GRAVITY: (%llu, %f,%f,%f)\n, (unsigned long long)stamp, event.data[0], event.data[1], event.data[2]);sensordata.stamp stamp;sensordata.sensorType 0x101;sensordata.xvalue event.data[0];sensordata.yvalue event.data[1];sensordata.zvalue event.data[2];sensordata.priority 1;saveSensorData(sensordata);break;case ASENSOR_TYPE_PROXIMITY:sensordata.stamp stamp;sensordata.sensorType 0x102;sensordata.lightvalue event.data[0];sensordata.priority 1;saveSensorData(sensordata);break;default:break;}}usleep(1000);}
}
这个参考的一个博主的方案主要是通过循环读取native sensor 数据。
监听HID节点删除添加
void HidReceiver::nodWatch(){int length, i 0;int fd;int wd;char buffer[BUF_LEN];fd inotify_init();if (fd 0) {LOGD(inotify_init);}wd inotify_add_watch(fd, DEV_NODE, IN_CREATE );if (wd 0) {LOGD(inotify_add_watch);}LOGD(Monitoring directory: %s, DEV_NODE);bool monitor true;while (monitor) {LOGD(start monitor);length read(fd, buffer, BUF_LEN); if (length 0) {LOGD(read);} i 0;LOGD(read %d,length);while (i length) {struct inotify_event *event (struct inotify_event *) buffer[i];LOGD(inotify_event %d,event-len);if (event-len) {LOGD(ievent-mask %d,event-mask);if (event-mask IN_CREATE) {LOGD(Created: %s, event-name);if(strcmp(event-name,hidg0) 0){LOGD(Created: hidg0);monitor false;startListen();inotify_rm_watch(fd, wd);return;}} else if (event-mask IN_DELETE) {LOGD(Deleted: %s, event-name);} else if (event-mask IN_MODIFY) {LOGD(Modified: %s, event-name);} else if (event-mask IN_MOVED_FROM) {LOGD(Moved from: %s, event-name);} else if (event-mask IN_MOVED_TO) {LOGD(Moved to: %s, event-name);}}i EVENT_SIZE event-len;}}
} Hid 数据传输和数据丢失问题
hid 数据怎么传其实很简单写节点就可以了但是数据量太大的时候会出现写节点失败同时按键或者TP 等数据也会丢失sensor 数据丢失感知倒不是很大但是按键和触摸这些传输失败Host端就无法响应体验会很差。 目前采用的方案是
Bufferqueue 延时 解决HID 数据丢失的问题(生产者消费者模式)
priority_queue 解决用户主动操作的数据优先级问题主要是TP 和 按键保证优先响应
主要代码
消费者
// 消费者线程读取队列中的数据并发送
void SensorTransfer::consumer() {while (true) {std::unique_lockstd::mutex lock(queueMutex);dataCondition.wait(lock, [this] { return !bufferQueue.empty(); });// if (!bufferQueue.empty())// break; // 程序结束if(!bufferQueue.empty()){sensor_data data bufferQueue.top();// 发送数据到 HID 设备int written write(hid_fd,data,sizeof(struct sensor_data));if(written 0){bufferQueue.pop();}else{//LOGD(rewrite data result fail);std::this_thread::sleep_for(std::chrono::milliseconds(1)); // 控制发送速率}if(data.sensorType 259){LOGD(consumer sn);std::this_thread::sleep_for(std::chrono::milliseconds(5)); }if(data.sensorType 260){LOGD(consumer KEY);std::this_thread::sleep_for(std::chrono::milliseconds(5)); }}else{LOGD(consumer 等待);}}
}
生产者
int SensorTransfer::saveSensorData(sensor_data data) {//std::lock_guardstd::mutex lock(queueMutex);if (bufferQueue.size() MAX_QUEUE) { // 限制队列最大长度bufferQueue.push(data);sensor_data topdata bufferQueue.top();if(topdata.sensorType ! 259topdata.sensorType ! 260){dataCondition.notify_one(); // 通知消费者线程}}else{LOGD(buffer is full);}return 0;
} selinux 添加
这个是老一套了之前也写过文章可以参考这里直接贴上主要权限
新增hidtransfer.te
type hidtransfer, domain,mlstrustedsubject;
typeattribute hidtransfer coredomain;
type hidtransfer_exec, system_file_type, exec_type, file_type;
binder_use(hidtransfer)
init_daemon_domain(hidtransfer)allow hidtransfer system_server:unix_stream_socket {read write};
allow hidtransfer tty_device:chr_file {write read getattr};
allow hidtransfer hid_device:chr_file { read getattr open ioctl write};
allow hidtransfer device:dir read;
allow hidtransfer system_server:binder call;
allow hidtransfer tty_device:chr_file ioctl;
allow hidtransfer serialno_prop:file { map getattr open read};
allow hidtransfer permission_service:service_manager find;
allow hidtransfer sensorservice_service:service_manager find;
allow hidtransfer input_device:chr_file { read write open };
allow hidtransfer input_device:dir { search };
allow hidtransfer device:dir watch;
allow hidtransfer system_server:fd use;file_contexts
/system/bin/hidtransfer u:object_r:hidtransfer_exec:s0
/dev/hidg0 u:object_r:hid_device:s0
device.te
type hid_device,dev_type; 参考
1.Android Native Sensor(C)实例_sensor hal 陀螺仪读取数据实现代码-CSDN博客
