fix: wakeup pipe create failed

fix: typo in definitions and command_impl mircrosecond -> microsecond

README.md

@@ -233,5 +233,5 @@ Here is the example:
 # 5 Support
 
 You can get support from Livox with the following methods:
-* Send email to dev@livoxtech.com with a clear description of your problem and your setup
+* Send email to cs@livoxtech.com with a clear description of your problem and your setup
 * Github Issues

README_CN.md

@@ -234,5 +234,5 @@ char broadcast_code_list[kMaxLidarCount][kBroadcastCodeSize] = {
 # 5 支持
 
 你可以通过以下方式获取 Livox 的技术支持 :
-* 发送邮件到 dev@livoxtech.com 描述清楚问题和使用场景
+* 发送邮件到 cs@livoxtech.com 描述清楚问题和使用场景
 * Github Issues

sdk_core/include/config.h

@@ -41,7 +41,7 @@
     #define HAVE_KQUEUE 1
 #else
     #include <sys/poll.h>
-    #define HAVE POLL 1
+    #define HAVE_POLL 1
 #endif
 
 #endif  // CONFIG_H_

sdk_core/include/livox_def.h

@@ -643,7 +643,7 @@ typedef struct {
   uint8_t month;
   uint8_t day;
   uint8_t hour;
-  uint32_t mircrosecond;
+  uint32_t microsecond;
 } LidarSetUtcSyncTimeRequest;
 
 /**

sdk_core/src/base/multiple_io/multiple_io_kqueue.cpp

@@ -83,22 +83,27 @@ bool MultipleIOKqueue::PollSetAdd(PollFd poll_fd) {
 
 bool MultipleIOKqueue::PollSetRemove(PollFd poll_fd) {
   int fd = poll_fd.fd;
+  bool result = true;
   if (descriptors_.find(fd) != descriptors_.end()) {
-    if (descriptors_[fd].event & READBLE_EVENT) {
-      EV_SET(&kevent_, fd, EVFILT_READ, EV_DELETE, 0, 0, NULL);
-      if (kevent(kqueue_fd_, &kevent_, 1, nullptr, 0, nullptr) == -1) {
-        return false;
+    do {
+      if (descriptors_[fd].event & READBLE_EVENT) {
+        EV_SET(&kevent_, fd, EVFILT_READ, EV_DELETE, 0, 0, NULL);
+        if (kevent(kqueue_fd_, &kevent_, 1, nullptr, 0, nullptr) == -1) {
+          result = false;
+          break;
+        }
       }
-    }
-    if (descriptors_[fd].event & WRITABLE_EVENT) {
-      EV_SET(&kevent_, fd, EVFILT_WRITE, EV_DELETE, 0, 0, NULL);
-      if (kevent(kqueue_fd_, &kevent_, 1, nullptr, 0, nullptr) == -1) {
-        return false;
+      if (descriptors_[fd].event & WRITABLE_EVENT) {
+        EV_SET(&kevent_, fd, EVFILT_WRITE, EV_DELETE, 0, 0, NULL);
+        if (kevent(kqueue_fd_, &kevent_, 1, nullptr, 0, nullptr) == -1) {
+          result = false;
+          break;
+        }
       }
-    }
+    } while(0);
     descriptors_.erase(fd);
   }
-  return true;
+  return result;
 }
 
 void MultipleIOKqueue::Poll(int time_out) {

sdk_core/src/base/multiple_io/multiple_io_poll.cpp

@@ -93,10 +93,10 @@ void MultipleIOPoll:: Poll(int time_out) {
     for (int i = 0; i < pollset_num_; i++) {
       FdEvent fd_event = NONE_EVENT;
       if (pollset_[i].revents & POLLIN) {
-        fd_event = | READBLE_EVENT;
+        fd_event |= READBLE_EVENT;
       }
       if (pollset_[i].revents & POLLOUT) {
-        fd_event = | WRITABLE_EVENT;
+        fd_event |= WRITABLE_EVENT;
       }
       int fd = pollset_[i].fd;
       if (descriptors_.find(fd) != descriptors_.end()) {

sdk_core/src/base/thread_base.h

@@ -26,7 +26,6 @@
 #define LIVOX_THREAD_BASE_H_
 #include <atomic>
 #include <thread>
-#include <memory>
 #include "noncopyable.h"
 
 namespace livox {

sdk_core/src/base/wake_up/unix/wake_up_pipe.cpp

@@ -67,30 +67,43 @@ bool WakeUpPipe::PipeDestroy() {
 }
 
 bool WakeUpPipe::PipeCreate() {
+  bool status = false;
   //in filedes[0]
   //out filedes[1]
-  int filedes[2];
+  int filedes[2]= {};
   if (pipe(filedes) == -1) {
     return false;
   }
+  do {
+    int flags = 0;
+    if ((flags = fcntl(filedes[0], F_GETFD)) == -1) {
+      break;
+    }
 
-  int flags = 0;
-  if ((flags = fcntl(filedes[0], F_GETFL|O_NONBLOCK)) == -1) {
-    return false;
-  }
+    flags |= FD_CLOEXEC;
+    if (fcntl(filedes[0], F_SETFD, flags) == -1) {
+      break;
+    }
 
-  flags |= FD_CLOEXEC;
-  if (fcntl(filedes[0], F_SETFL, flags) == -1) {
-    return false;
-  }
+    flags = 0;
+    if ((flags = fcntl(filedes[1], F_GETFD)) == -1) {
+      break;
+    }
 
-  flags = 0;
-  if ((flags = fcntl(filedes[1], F_GETFD)) == -1) {
-    return false;
-  }
+    flags |= FD_CLOEXEC;
+    if (fcntl(filedes[1], F_SETFD, flags) == -1) {
+      break;
+    }
+    status = true;
+  } while(0);
 
-  flags |= FD_CLOEXEC;
-  if (fcntl(filedes[1], F_SETFD, flags) == -1) {
+  if (!status) {
+    if (filedes[0] > 0) {
+      close(filedes[0]);
+    }
+    if (filedes[1] > 0) {
+      close(filedes[1]);
+    }
     return false;
   }
   pipe_out_ = filedes[0];

sdk_core/src/command_handler/command_impl.cpp

@@ -209,7 +209,7 @@ bool ParseRmcTime(const char* rmc, uint16_t rmc_len, LidarSetUtcSyncTimeRequest*
   }
 
   utc_time_req->hour = hour;
-  utc_time_req->mircrosecond = (minute * 60 * 1000 + second * 1000) * 1000;
+  utc_time_req->microsecond = (minute * 60 * 1000 + second * 1000) * 1000;
   return true;
 }
 

sdk_core/src/device_manager.cpp

@@ -160,6 +160,18 @@ void DeviceManager::HubLidarInfomationCallback(livox_status status, uint8_t, Hub
     if (connected_cb_) {
       connected_cb_(&(devices_[kHubDefaultHandle].info), kEventHubConnectionChange);
     }
+  } else if (status == kStatusTimeout) {
+    LOG_WARN("Query lidars information Timeout.");
+    if (IsDeviceConnected(kHubDefaultHandle)) {
+      LOG_INFO("Retry to query lidars information.");
+      command_handler().SendCommand(kHubDefaultHandle,
+                                    kCommandSetHub,
+                                    kCommandIDHubQueryLidarInformation,
+                                    NULL,
+                                    0,
+                                    MakeCommandCallback<DeviceManager, HubQueryLidarInformationResponse>(
+                                        this, &DeviceManager::HubLidarInfomationCallback));
+    }
   } else {
     LOG_ERROR("Failed to query lidars information connected to hub.");
   }
@@ -178,6 +190,18 @@ void DeviceManager::QueryDeviceInformationCallback(livox_status status, uint8_t
     if (connected_cb_) {
       connected_cb_(&devices_[handle].info, kEventConnect);
     }
+  } else if (status == kStatusTimeout) {
+    LOG_WARN("Query lidar information Timeout.");
+    if (IsDeviceConnected(handle)) {
+      LOG_INFO("Retry to query lidar information.");
+      command_handler().SendCommand(handle,
+                                    kCommandSetGeneral,
+                                    kCommandIDGeneralDeviceInfo,
+                                    NULL,
+                                    0,
+                                    MakeCommandCallback<DeviceManager, DeviceInformationResponse>(
+                                        this, &DeviceManager::QueryDeviceInformationCallback));
+    }
   } else {
     LOG_ERROR("Failed to query lidar information.");
   }