金阊企业建设网站公司兵团建设环保局网站

resample sensor 的一个问题。
背景: 项目要求，发送多个数据到 sensor-hal 上去，发现无论怎样，在 sensor-hal 上都 只有一个数据。
resample sensor 是重新采样，这个怎么理解的，我的理解是： 假设 sensor 采样率有 5/10/15HZ，上层那边发过来的 90ms, 没有这个挡位,则通过这个 resample 会纠正到 100ms(也就是10hz)进行采样
使用 see_workhorse 测试
./see_workhorse -debug=1 -display_events=1 -sensor=pressure -sample_rate=5 -duration=20
看到确实是有两个 payload 上来…

"events" : [{"msg_id" : 1025,"timestamp" : 14729396536,"payload" : {"data" : [1000.000000,990.000000],"status" : "SNS_STD_SENSOR_SAMPLE_STATUS_ACCURACY_HIGH"}}]
},

但是为什么， sensor-hal 上就只有一个数据呢？
后面发现，是被 resample 截取了

截取一段 代码，看下

static bool suid_lookup_cb(sns_sensor *const sensor,char const *data_type, sns_sensor_event *event)
{resampler_state *state =(resampler_state*)sensor->state->state;pb_istream_t stream = pb_istream_from_buffer((void*)event->event, event->event_len);sns_std_attr_event attr_event = sns_std_attr_event_init_default;sns_sensor_util_attrib attrib_list[] ={ {.sensor = sensor, .attr_id = SNS_STD_SENSOR_ATTRID_STREAM_TYPE},{.sensor = sensor, .attr_id = SNS_STD_SENSOR_ATTRID_EVENT_SIZE},{.sensor = NULL, .attr_id   = -1}};attr_event.attributes.funcs.decode = &sns_sensor_util_decode_attr_list;attr_event.attributes.arg = (void*)&attrib_list;if(!pb_decode(&stream, sns_std_attr_event_fields, &attr_event)){SNS_PRINTF(ERROR, sensor, "Error decoding attr event");}else{bool is_streaming = false;uint8_t axis_cnt = 0;int32_t event_size = 0;for(int i=0; i< ARR_SIZE(attrib_list); i++){if(SNS_STD_SENSOR_ATTRID_STREAM_TYPE == attrib_list[i].attr_id){is_streaming = (SNS_STD_SENSOR_STREAM_TYPE_STREAMING == attrib_list[i].attr_value);}if(SNS_STD_SENSOR_ATTRID_EVENT_SIZE == attrib_list[i].attr_id){event_size = attrib_list[i].attr_value;}}/* If expected attribute matched, store it */if (is_streaming){axis_cnt = resampler_get_axis_count(event_size);resampler_store_sensor(sensor, data_type, &state->suid_lookup_data, axis_cnt);}SNS_PRINTF(ERROR, sensor, "xuzhibang event_size:%d, axis_cnt:%d\n",event_size,axis_cnt);}return false;
}//  这个就是从 event size attribute 拿到的值..
/* Calculate the axis count of a sensor from its event size attribute */
static uint8_t resampler_get_axis_count(int32_t event_size)
{uint8_t axis_cnt = AXIS_CNT_DEFAULT;if (event_size > pb_overhead){axis_cnt = (event_size - pb_overhead)/sizeof(float);}return axis_cnt;
}

打印log ，看到 axis_cnt 这个值确实是为1，这个是从 event size attribute 得到的。

resampler_get_axis_count: 这个是决定 发送的个数。 可以看到会除以一个 sizeof(float)
所以我们在：直接发送PRESSURE_EVENT_SIZE 就行了。不需要 什么 sizeof(float)
static void XXX_publish_attributes(sns_sensor * const this)
{
{
float data[PRESSURE_EVENT_SIZE ] = {0}; //
state->encoded_event_len =
pb_get_encoded_size_sensor_stream_event(data, PRESSURE_EVENT_SIZE );
sns_std_attr_value_data value = sns_std_attr_value_data_init_default;
value.has_sint = true;
value.sint = state->encoded_event_len;
sns_publish_attribute(
this, SNS_STD_SENSOR_ATTRID_EVENT_SIZE, &value, 1, false);
}
}

我们修改 相关的 sensor 驱动的 XXX_publish_attributes 的 SNS_STD_SENSOR_ATTRID_EVENT_SIZE 上报的值，我们要上报几个，则 设置 PRESSURE_EVENT_SIZE 这个值为几，就ok 了。

最后说一下:
see_workhorse 与 sensors-hal 的区别是 ： see_workhorse 会关闭 resample