Lines Matching defs:er
71 struct echo_reference *er;
77 er = (struct echo_reference *)((char *)buffer_provider -
80 if (er->wr_src_buf == NULL || er->wr_frames_in == 0) {
86 buffer->frame_count = (buffer->frame_count > er->wr_frames_in) ?
87 er->wr_frames_in : buffer->frame_count;
88 // this is er->rd_channel_count here as we resample after stereo to mono conversion if any
89 buffer->i16 = (int16_t *)er->wr_src_buf + (er->wr_curr_frame_size - er->wr_frames_in) *
90 er->rd_channel_count;
98 struct echo_reference *er;
104 er = (struct echo_reference *)((char *)buffer_provider -
107 er->wr_frames_in -= buffer->frame_count;
110 static void echo_reference_reset_l(struct echo_reference *er)
113 free(er->buffer);
114 er->buffer = NULL;
115 er->buf_size = 0;
116 er->frames_in = 0;
117 free(er->wr_buf);
118 er->wr_buf = NULL;
119 er->wr_buf_size = 0;
120 er->wr_render_time.tv_sec = 0;
121 er->wr_render_time.tv_nsec = 0;
122 er->delta_count = 0;
123 er->prev_delta_sign = 0;
134 struct echo_reference *er = (struct echo_reference *)echo_reference;
137 if (er == NULL) {
141 pthread_mutex_lock(&er->lock);
145 er->state &= ~ECHOREF_WRITING;
146 echo_reference_reset_l(er);
151 ALOGV("echo_reference_write() playbackTimestamp:[%d].[%d], er->playback_delay:[%d]",
153 (int)buffer->time_stamp.tv_nsec, er->playback_delay);
159 (er->wr_render_time.tv_sec == 0) && (er->wr_render_time.tv_nsec == 0)) {
163 if ((er->state & ECHOREF_WRITING) == 0) {
165 if (er->resampler != NULL) {
166 er->resampler->reset(er->resampler);
168 er->state |= ECHOREF_WRITING;
171 if ((er->state & ECHOREF_READING) == 0) {
175 er->wr_render_time.tv_sec = buffer->time_stamp.tv_sec;
176 er->wr_render_time.tv_nsec = buffer->time_stamp.tv_nsec;
178 er->playback_delay = buffer->delay_ns;
181 er->wr_curr_frame_size = buffer->frame_count;
186 if (er->rd_channel_count != er->wr_channel_count ||
187 er->rd_sampling_rate != er->wr_sampling_rate) {
192 if (er->rd_sampling_rate != er->wr_sampling_rate) {
193 inFrames = (buffer->frame_count * er->rd_sampling_rate) / er->wr_sampling_rate +
202 if (er->wr_buf_size < wrBufSize) {
204 er->wr_buf_size, wrBufSize);
205 er->wr_buf_size = wrBufSize;
206 er->wr_buf = realloc(er->wr_buf, er->wr_buf_size * er->rd_frame_size);
209 if (er->rd_channel_count != er->wr_channel_count) {
212 int16_t *dst16 = (int16_t *)er->wr_buf;
219 if (er->wr_sampling_rate != er->rd_sampling_rate) {
220 if (er->resampler == NULL) {
223 er->wr_sampling_rate, er->rd_sampling_rate);
224 er->provider.get_next_buffer = echo_reference_get_next_buffer;
225 er->provider.release_buffer = echo_reference_release_buffer;
226 rc = create_resampler(er->wr_sampling_rate,
227 er->rd_sampling_rate,
228 er->rd_channel_count,
230 &er->provider,
231 &er->resampler);
233 er->resampler = NULL;
239 // er->wr_src_buf and er->wr_frames_in are used by getNexBuffer() called by the
241 if (er->rd_channel_count != er->wr_channel_count) {
242 er->wr_src_buf = er->wr_buf;
244 er->wr_src_buf = buffer->raw;
246 er->wr_frames_in = buffer->frame_count;
250 er->wr_sampling_rate, er->rd_sampling_rate);
251 er->resampler->resample_from_provider(er->resampler,
252 (int16_t *)er->wr_buf, &inFrames);
253 ALOGV_IF(er->wr_frames_in != 0,
254 "echo_reference_write() er->wr_frames_in not 0 (%d) after resampler",
255 er->wr_frames_in);
257 srcBuf = er->wr_buf;
263 if (er->frames_in + inFrames > er->buf_size) {
265 er->buf_size, er->frames_in + inFrames);
266 er->buf_size = er->frames_in + inFrames;
267 er->buffer = realloc(er->buffer, er->buf_size * er->rd_frame_size);
269 memcpy((char *)er->buffer + er->frames_in * er->rd_frame_size,
271 inFrames * er->rd_frame_size);
272 er->frames_in += inFrames;
275 " er->wr_render_time:[%d].[%d], er->playback_delay:[%d]",
276 inFrames, er->frames_in, er->buf_size,
277 (int)er->wr_render_time.tv_sec, (int)er->wr_render_time.tv_nsec, er->playback_delay);
279 pthread_cond_signal(&er->cond);
281 pthread_mutex_unlock(&er->lock);
296 struct echo_reference *er = (struct echo_reference *)echo_reference;
298 if (er == NULL) {
302 pthread_mutex_lock(&er->lock);
306 er->state &= ~ECHOREF_READING;
311 "er->frames_in:[%d],buffer->frame_count:[%d]",
312 buffer->delay_ns, er->frames_in, buffer->frame_count);
314 if ((er->state & ECHOREF_READING) == 0) {
316 echo_reference_reset_l(er);
317 er->state |= ECHOREF_READING;
320 if ((er->state & ECHOREF_WRITING) == 0) {
321 memset(buffer->raw, 0, er->rd_frame_size * buffer->frame_count);
329 if (er->frames_in < buffer->frame_count) {
330 uint32_t timeoutMs = (uint32_t)((1000 * buffer->frame_count) / er->rd_sampling_rate / 2);
335 pthread_cond_timedwait_relative_np(&er->cond, &er->lock, &ts);
337 ALOGV_IF((er->frames_in < buffer->frame_count),
339 " er->frames_in: %d, buffer->frame_count = %d",
340 timeoutMs, er->frames_in, buffer->frame_count);
346 if ((er->wr_render_time.tv_sec == 0 && er->wr_render_time.tv_nsec == 0) ||
352 if (buffer->time_stamp.tv_nsec < er->wr_render_time.tv_nsec) {
353 tmp.tv_sec = buffer->time_stamp.tv_sec - er->wr_render_time.tv_sec - 1;
354 tmp.tv_nsec = 1000000000 + buffer->time_stamp.tv_nsec - er->wr_render_time.tv_nsec;
356 tmp.tv_sec = buffer->time_stamp.tv_sec - er->wr_render_time.tv_sec;
357 tmp.tv_nsec = buffer->time_stamp.tv_nsec - er->wr_render_time.tv_nsec;
361 int64_t expectedDelayNs = er->playback_delay + buffer->delay_ns - timeDiff;
363 if (er->resampler != NULL) {
365 int32_t rsmp_delay = er->resampler->delay_ns(er->resampler);
370 "er->playback_delay[%d] + delayCapture[%d] - timeDiff[%lld]",
371 expectedDelayNs, er->playback_delay, buffer->delay_ns, timeDiff);
374 int64_t delayNs = ((int64_t)er->frames_in * 1000000000) / er->rd_sampling_rate;
385 if (delay_sign == er->prev_delta_sign) {
386 er->delta_count++;
388 er->delta_count = 1;
390 er->prev_delta_sign = delay_sign;
392 if (er->delta_count > MIN_DELTA_NUM) {
393 size_t previousFrameIn = er->frames_in;
394 er->frames_in = (size_t)((expectedDelayNs * er->rd_sampling_rate)/1000000000);
395 int offset = er->frames_in - previousFrameIn;
398 "er->frames_in: %d, previousFrameIn = %d",
399 delay_sign ? "positive" : "negative", er->frames_in, previousFrameIn);
403 if (er->frames_in > er->buf_size) {
404 er->buf_size = er->frames_in;
405 er->buffer = realloc(er->buffer, er->buf_size * er->rd_frame_size);
407 er->buf_size);
411 memset((char *)er->buffer + previousFrameIn * er->rd_frame_size,
412 0, offset * er->rd_frame_size);
419 memcpy(er->buffer, (char *)er->buffer + (offset * er->rd_frame_size),
420 er->frames_in * er->rd_frame_size);
422 er->frames_in);
427 er->delta_count = 0;
428 er->prev_delta_sign = 0;
434 "er->playback_delay[%d] + delayCapture[%d] - timeDiff[%lld]",
435 expectedDelayNs, er->playback_delay, buffer->delay_ns, timeDiff);
439 if (er->frames_in < buffer->frame_count) {
440 if (buffer->frame_count > er->buf_size) {
441 er->buf_size = buffer->frame_count;
442 er->buffer = realloc(er->buffer, er->buf_size * er->rd_frame_size);
443 ALOGV("echo_reference_read(): increasing buffer size to %d", er->buf_size);
446 memset((char *)er->buffer + er->frames_in * er->rd_frame_size,
447 0, (buffer->frame_count - er->frames_in) * er->rd_frame_size);
448 er->frames_in = buffer->frame_count;
452 (char *)er->buffer,
453 buffer->frame_count * er->rd_frame_size);
455 er->frames_in -= buffer->frame_count;
456 memcpy(er->buffer,
457 (char *)er->buffer + buffer->frame_count * er->rd_frame_size,
458 er->frames_in * er->rd_frame_size);
464 buffer->frame_count, er->frames_in);
466 pthread_cond_signal(&er->cond);
469 pthread_mutex_unlock(&er->lock);
482 struct echo_reference *er;
504 er = (struct echo_reference *)calloc(1, sizeof(struct echo_reference));
506 er->itfe.read = echo_reference_read;
507 er->itfe.write = echo_reference_write;
509 er->state = ECHOREF_IDLE;
510 er->rd_format = rdFormat;
511 er->rd_channel_count = rdChannelCount;
512 er->rd_sampling_rate = rdSamplingRate;
513 er->wr_format = wrFormat;
514 er->wr_channel_count = wrChannelCount;
515 er->wr_sampling_rate = wrSamplingRate;
516 er->rd_frame_size = audio_bytes_per_sample(rdFormat) * rdChannelCount;
517 er->wr_frame_size = audio_bytes_per_sample(wrFormat) * wrChannelCount;
518 *echo_reference = &er->itfe;
523 struct echo_reference *er = (struct echo_reference *)echo_reference;
525 if (er == NULL) {
530 echo_reference_reset_l(er);
531 if (er->resampler != NULL) {
532 release_resampler(er->resampler);
534 free(er);
