SD卡热插拔检查(netlink方式).pdfVIP

SD 卡热插拔检查（netlink 方式） void *CDiskManage::HotPlugSdCheckThreadFunc(void *arg){ struct sockaddr_nl client; int hotplug_sock = -1; int buffersize = 1024; int ret; tIPC_HOTPLUG_INFO info; CDiskManage *pThisDiskManage = (CDiskManage *)arg; hotplug_sock = socket(AF_NETLINK, SOCK_RAW, NETLINK_KOBJECT_UEVENT); if (hotplug_sock == -1) { LOG_DEBUG_MSG_ERROR(, create sd hotplug socket error !\n); return NU ; } memset(amp;client, 0, sizeof(client)); client.nl_family = AF_NETLINK ; client.nl_pid = getpid() ; client.nl_groups = 1 ; //receive broadcast message setsockopt(hotplug_sock, SOL_SOCKET, SO_RCVBUF, amp;buffersize, sizeof(buffersize)); ret = bind(hotplug_sock, (struct sockaddr *)amp;client, sizeof(client)); if (ret lt; 0) { LOG_DEBUG_MSG_ERROR(, bind hotplug socket error !\n); close(hotplug_sock); return NU ; } while (1) { char buf[UEVENT_BUFFER_SIZE] = { 0 }; struct timeval tv; fd_set fds; int rcvlen, ret; FD_ZERO(amp;fds); FD_SET(hotplug_sock, amp;fds); tv.tv_sec = 0; tv.tv_usec = 100 * 1000; ret = select(hotplug_sock + 1, amp;fds, NULL, NULL, amp;tv); if(ret lt; 0) continue; if(!(ret gt; 0 amp;amp; FD_ISSET(hotplug_sock, amp;fds))) continue; //receive data char *end = NULL, *start = NULL; rcvlen = recv(hotplug_sock, amp;buf, (UEVENT_BUFFER_SIZE - 1), 0); if (rcvlen gt; 0) { buf[rcvlen] = \0; //LOG_DEBUG_MSG_ERROR(, IPC HotPlug Thread, Original Recv message=%s\n, buf); end = buf + rcvlen; start = buf ; while(start lt; end) { if (*start == \0) *start = #; start++; } //LOG_DEBUG_MSG_ERROR(, IPC HotPlug Thread, Recv message=%s\n, buf); pThisDiskManage-gt;DiskManage_AnayseHotplugEvent Content(buf, strlen(buf), amp;info); if (info.plug_event_type != OTHER_PLUG_EVENT) pThisDiskManage-gt;DiskManage_DealIpcSdHotPlug(a mp;info); } usleep(100000); } close( hotplug_sock ); pthread_exit(NULL);}void CDiskManage::DiskManage_AnayseHotplugEventContent (char *buf, int len, t