NULL == interface->get_utterance_data_count)
return;
- MWR_LOGD("data_count : %d", interface->get_utterance_data_count());
+ MWR_LOGE("data_count : %s, %d",
+ mSelectedEngine->engine_name.c_str(),
+ interface->get_utterance_data_count());
#ifdef BUF_SAVE_MODE
if (g_pFile) {
}
int burst_count = 0;
+ int sleep_count = 0;
+
while (!(mStopStreamingThread.load())) {
int ret = -1;
int cnt = 0;
if (0 != ret) {
/* empty queue */
- MWR_LOGD("[DEBUG] No feedback data. Waiting mode : %d %d", ret, cnt);
+ MWR_LOGI("[DEBUG] No feedback data. Waiting mode : %d %d", ret, cnt);
+ sleep_count = 0;
/* waiting */
while (!(mStopStreamingThread.load())) {
burst_count = 0;
+ if (++sleep_count >= 100) {
+ MWR_LOGI("Still waiting : %d %p %p", sleep_count,
+ interface->get_utterance_data,
+ interface->get_utterance_data_count);
+ sleep_count = 0;
+ }
this_thread::sleep_for(chrono::milliseconds(10));
if (index < interface->get_utterance_data_count()) {
- MWR_LOGD("[INFO] Resume thread, %d", cnt);
+ MWR_LOGI("[INFO] Resume thread, %d", cnt);
break;
}
mStreamingHistory.last_count_fetched.store(get_current_milliseconds_after_epoch());