|
@@ -126,6 +126,7 @@ void* log_producer_read_persistent_thread(void* param)
|
|
|
//缓存uuid和n_logs、modular
|
|
|
for (i = 0; i < builder->grp->n_logs; i++) {
|
|
|
strcpy(uuid[i], builder->grp->logs[i].uuid);
|
|
|
+ RvcLogSdkManager::getInstance().SendTestLog(builder->grp->logs[i].buffer);
|
|
|
}
|
|
|
n_logs = builder->grp->n_logs;
|
|
|
if (n_logs > 0) {
|
|
@@ -421,8 +422,7 @@ void* log_producer_flush_thread(void* param)
|
|
|
int insert_result = 0;
|
|
|
log_group_builder* builder = (log_group_builder*)data;
|
|
|
memset(frame.data, 0, sizeof(serialize_buf));
|
|
|
- serialize_to_buf(&builder->grp->logs[0], (serialize_buf*)frame.data);
|
|
|
- RvcLogSdkManager::getInstance().SendTestLog(builder->grp->logs[builder->grp->n_logs - 1].buffer);
|
|
|
+ serialize_to_buf(&builder->grp->logs[0], (serialize_buf*)frame.data);// it would not cause dirty logs
|
|
|
frame.size = sizeof(serialize_buf);
|
|
|
CS_ENTER(persistent_manager->lock);
|
|
|
insert_result = ClibsharequeueInsert(producer_manager->share_queue, &frame, 0);
|