0

我正在尝试让 DataLogger 和 Logbook 在movesense 设备上工作。我正在尝试做的是与这个问题中提出的类似/延续。当我在设备连接时配置我的服务时，我想等待 DataLogger 启动（返回状态代码 200），然后再继续执行我的其余代码。

作为 onSubscribe() 函数的一部分，我执行以下代码来配置 DataLogger：

WB_RES::DataLoggerConfig logConfig;
WB_RES::DataEntry entry;
WB_RES::DataLoggerStateValues::Type logState = WB_RES::DataLoggerStateValues::Type::DATALOGGER_LOGGING;

entry.path = <pathToService>;
<del>logConfig.dataEntries.dataEntry= {entry}; </del>
logConfig.dataEntries.dataEntry = whiteboard::MakeArray<WB_RES::DataEntry>(&entry, 1);

result = asyncPut(WB_RES::LOCAL::MEM_DATALOGGER_CONFIG(), AsyncRequestOptions::Empty, logConfig);

我在这个命令之后得到的状态码是 202 Accepted。我从上一个问题中了解到，我需要检查这个函数在 onPutResult() 函数中是否返回返回码 200。

这是我做的

switch(resourceId.localResourceId)
{
case WB_RES::LOCAL::MEM_DATALOGGER_CONFIG::LID:
{
  if(resultCode == whiteboard::HTTP_CODE_OK)
  {
    asyncPut(WB_RES::LOCAL::MEM_DATALOGGER_STATE(), AsyncRequestOptions::Empty,WB_RES::DataLoggerStateValues::Type::DATALOGGER_LOGGING);
  }
}
break;

再次在 onPutResult() 中，我使用这段代码检查数据记录器是否设置为正确状态

case WB_RES::LOCAL::MEM_DATALOGGER_STATE::LID:
{
  if(resultCode == whiteboard::HTTP_CODE_OK)
  {
    // Boolean variable that indicate that the dataLogger is running.
    DataLoggerRunning = true; 
  }
  else
  {
    DEBUGLOG("onPutResult::MEM_DATALOGGER_STATE::
               SomethingIsNotRight");
  }
}
break;

现在我想在启动我的服务之前检测变量 DataLoggerRunning 是否为真。这是我有点迷茫的地方，我尝试在一个while循环中等待，并在movesense-device-lib中寻找一个睡眠函数（没有运气），希望在等待数据记录器时不会崩溃代码开始。while 循环导致了一个无限循环，我假设如果我能找到一个 sleep 函数也会阻塞。

这是错误的方法还是我在正确的轨道上，如果有帮助，我们将不胜感激。

编辑：更新了添加数据记录器路径的代码。如果使用旧代码，我们将得到 404 not found 路径。

4

1 回答 1

0

您的代码的设置部分是正确的。asyncPut 中的结果 202 表示请求被分派到另一个线程，并且您在 onPutResult 中正确看到了 PUT 操作的实际结果。

由于 Movesense 是一种异步架构，因此您不能在循环中等待变量（或者有一种方法，但它是非常不可取的，因为它可能会在其他地方引起问题），尤其是在简单的 while 循环中。除非您在其他地方需要它，否则您实际上并不需要DataLoggerRunning标志。当您收到 onPutResult() 回调时， DataLogger正在运行，但可能还没有任何日志（如果没有数据）。DataLogger的工作方式是订阅给定的路径并存储它收到的通知中的数据。

基本上你有几个选择：

  1. 只需在 opPutResult 中调用您的启动代码，因为数据记录器现在正在运行。您提出的任何请求都必须是快速的（比如说 < 200 毫秒）或异步的。
  2. 触发“延迟过程调用”（whiteboard::DpcFunctor类）。这会导致执行断开连接，Movesense 调度程序将稍后执行您的功能。
  3. 如果您需要稍等，请调用startTimer()并在onTimer() 回调中调用其余代码
于 2018-07-04T07:00:04.360 回答