iter = lead;
advance(lead, 1);
}
- MWR_LOGI("data_count : %zu", mAudioData.size());
+ MWR_LOGE("data_count : %zu", mAudioData.size());
lock.unlock();
while (!(mStopStreamingThread.load())) {
}
if (MAS_SPEECH_STREAMING_EVENT_FINISH == speech_data.event) {
- MWR_LOGI("[INFO] Finish to get and send speech data");
+ MWR_LOGE("[INFO] Finish to get and send speech data");
finish_event_sent = true;
break;
}
lock.unlock();
for (const auto& observer : observers) {
if (observer) {
- MWR_LOGI("No FINISH event sent yet, adding to finalize streaming session");
+ MWR_LOGE("No FINISH event sent yet, adding to finalize streaming session");
if (!observer->on_streaming_audio_data(
MAS_SPEECH_STREAMING_EVENT_FINISH, final_buffer, sizeof(final_buffer))) {
LOGE("[Recorder WARNING] One of the observer returned false");
}
}
mStreamingThreadActive.store(false);
- MWR_LOGI("[EXIT]");
+ MWR_LOGE("[EXIT]");
}
void CAudioManager::add_audio_data(mas_speech_data& data, long long time)
static auto last = std::chrono::steady_clock::now();
auto now = std::chrono::steady_clock::now();
if (now - last > interval) {
- MWR_LOGI("Feeding audio data : num(%d), now(%" PRId64 "), %d %zu",
+ MWR_LOGE("Feeding audio data : num(%d), now(%" PRId64 "), %d %zu",
num, now.time_since_epoch().count(),
mStreamingThreadActive.load(), mAudioData.size());
last = now;