Lines Matching defs:er
73 struct echo_reference *er;
79 er = (struct echo_reference *)((char *)buffer_provider -
82 if (er->wr_src_buf == NULL || er->wr_frames_in == 0) {
88 buffer->frame_count = (buffer->frame_count > er->wr_frames_in) ?
89 er->wr_frames_in : buffer->frame_count;
90 // this is er->rd_channel_count here as we resample after stereo to mono conversion if any
91 buffer->i16 = (int16_t *)er->wr_src_buf + (er->wr_curr_frame_size - er->wr_frames_in) *
92 er->rd_channel_count;
100 struct echo_reference *er;
106 er = (struct echo_reference *)((char *)buffer_provider -
109 er->wr_frames_in -= buffer->frame_count;
112 static void echo_reference_reset_l(struct echo_reference *er)
115 free(er->buffer);
116 er->buffer = NULL;
117 er->buf_size = 0;
118 er->frames_in = 0;
119 free(er->wr_buf);
120 er->wr_buf = NULL;
121 er->wr_buf_size = 0;
122 er->wr_render_time.tv_sec = 0;
123 er->wr_render_time.tv_nsec = 0;
124 er->delta_count = 0;
125 er->prev_delta_sign = 0;
136 struct echo_reference *er = (struct echo_reference *)echo_reference;
139 if (er == NULL) {
143 pthread_mutex_lock(&er->lock);
147 er->state &= ~ECHOREF_WRITING;
148 echo_reference_reset_l(er);
153 ALOGV("echo_reference_write() playbackTimestamp:[%d].[%d], er->playback_delay:[%" PRId32 "]",
155 (int)buffer->time_stamp.tv_nsec, er->playback_delay);
161 (er->wr_render_time.tv_sec == 0) && (er->wr_render_time.tv_nsec == 0)) {
165 if ((er->state & ECHOREF_WRITING) == 0) {
167 if (er->resampler != NULL) {
168 er->resampler->reset(er->resampler);
170 er->state |= ECHOREF_WRITING;
173 if ((er->state & ECHOREF_READING) == 0) {
177 er->wr_render_time.tv_sec = buffer->time_stamp.tv_sec;
178 er->wr_render_time.tv_nsec = buffer->time_stamp.tv_nsec;
180 er->playback_delay = buffer->delay_ns;
183 er->wr_curr_frame_size = buffer->frame_count;
188 if (er->rd_channel_count != er->wr_channel_count ||
189 er->rd_sampling_rate != er->wr_sampling_rate) {
194 if (er->rd_sampling_rate != er->wr_sampling_rate) {
195 inFrames = (buffer->frame_count * er->rd_sampling_rate) / er->wr_sampling_rate +
204 if (er->wr_buf_size < wrBufSize) {
206 er->wr_buf_size, wrBufSize);
207 er->wr_buf_size = wrBufSize;
208 er->wr_buf = realloc(er->wr_buf, er->wr_buf_size * er->rd_frame_size);
211 if (er->rd_channel_count != er->wr_channel_count) {
214 int16_t *dst16 = (int16_t *)er->wr_buf;
221 if (er->wr_sampling_rate != er->rd_sampling_rate) {
222 if (er->resampler == NULL) {
225 er->wr_sampling_rate, er->rd_sampling_rate);
226 er->provider.get_next_buffer = echo_reference_get_next_buffer;
227 er->provider.release_buffer = echo_reference_release_buffer;
228 rc = create_resampler(er->wr_sampling_rate,
229 er->rd_sampling_rate,
230 er->rd_channel_count,
232 &er->provider,
233 &er->resampler);
235 er->resampler = NULL;
241 // er->wr_src_buf and er->wr_frames_in are used by getNexBuffer() called by the
243 if (er->rd_channel_count != er->wr_channel_count) {
244 er->wr_src_buf = er->wr_buf;
246 er->wr_src_buf = buffer->raw;
248 er->wr_frames_in = buffer->frame_count;
252 er->wr_sampling_rate, er->rd_sampling_rate);
253 er->resampler->resample_from_provider(er->resampler,
254 (int16_t *)er->wr_buf, &inFrames);
255 ALOGV_IF(er->wr_frames_in != 0,
256 "echo_reference_write() er->wr_frames_in not 0 (%d) after resampler",
257 er->wr_frames_in);
259 srcBuf = er->wr_buf;
265 if (er->frames_in + inFrames > er->buf_size) {
267 er->buf_size, er->frames_in + inFrames);
268 er->buf_size = er->frames_in + inFrames;
269 er->buffer = realloc(er->buffer, er->buf_size * er->rd_frame_size);
271 memcpy((char *)er->buffer + er->frames_in * er->rd_frame_size,
273 inFrames * er->rd_frame_size);
274 er->frames_in += inFrames;
277 " er->wr_render_time:[%d].[%d], er->playback_delay:[%" PRId32 "]",
278 inFrames, er->frames_in, er->buf_size,
279 (int)er->wr_render_time.tv_sec, (int)er->wr_render_time.tv_nsec, er->playback_delay);
281 pthread_cond_signal(&er->cond);
283 pthread_mutex_unlock(&er->lock);
298 struct echo_reference *er = (struct echo_reference *)echo_reference;
300 if (er == NULL) {
304 pthread_mutex_lock(&er->lock);
308 er->state &= ~ECHOREF_READING;
313 "er->frames_in:[%zu],buffer->frame_count:[%zu]",
314 buffer->delay_ns, er->frames_in, buffer->frame_count);
316 if ((er->state & ECHOREF_READING) == 0) {
318 echo_reference_reset_l(er);
319 er->state |= ECHOREF_READING;
322 if ((er->state & ECHOREF_WRITING) == 0) {
323 memset(buffer->raw, 0, er->rd_frame_size * buffer->frame_count);
331 if (er->frames_in < buffer->frame_count) {
332 uint32_t timeoutMs = (uint32_t)((1000 * buffer->frame_count) / er->rd_sampling_rate / 2);
347 pthread_cond_timedwait_relative_np(&er->cond, &er->lock, &ts);
349 pthread_cond_timedwait(&er->cond, &er->lock, &ts);
352 ALOGV_IF((er->frames_in < buffer->frame_count),
354 " er->frames_in: %d, buffer->frame_count = %d",
355 timeoutMs, er->frames_in, buffer->frame_count);
361 if ((er->wr_render_time.tv_sec == 0 && er->wr_render_time.tv_nsec == 0) ||
367 if (buffer->time_stamp.tv_nsec < er->wr_render_time.tv_nsec) {
368 tmp.tv_sec = buffer->time_stamp.tv_sec - er->wr_render_time.tv_sec - 1;
369 tmp.tv_nsec = 1000000000 + buffer->time_stamp.tv_nsec - er->wr_render_time.tv_nsec;
371 tmp.tv_sec = buffer->time_stamp.tv_sec - er->wr_render_time.tv_sec;
372 tmp.tv_nsec = buffer->time_stamp.tv_nsec - er->wr_render_time.tv_nsec;
376 int64_t expectedDelayNs = er->playback_delay + buffer->delay_ns - timeDiff;
378 if (er->resampler != NULL) {
380 int32_t rsmp_delay = er->resampler->delay_ns(er->resampler);
385 "er->playback_delay[%" PRId32 "] + delayCapture[%" PRId32
387 expectedDelayNs, er->playback_delay, buffer->delay_ns, timeDiff);
390 int64_t delayNs = ((int64_t)er->frames_in * 1000000000) / er->rd_sampling_rate;
401 if (delay_sign == er->prev_delta_sign) {
402 er->delta_count++;
404 er->delta_count = 1;
406 er->prev_delta_sign = delay_sign;
408 if (er->delta_count > MIN_DELTA_NUM) {
409 er->frames_in;
410 er->frames_in = (size_t)((expectedDelayNs * er->rd_sampling_rate)/1000000000);
411 int offset = er->frames_in - previousFrameIn;
414 "er->frames_in: %zu, previousFrameIn = %zu",
415 delay_sign ? "positive" : "negative", er->frames_in, previousFrameIn);
419 if (er->frames_in > er->buf_size) {
420 er->buf_size = er->frames_in;
421 er->buffer = realloc(er->buffer, er->buf_size * er->rd_frame_size);
423 er->buf_size);
427 memset((char *)er->buffer + previousFrameIn * er->rd_frame_size,
428 0, offset * er->rd_frame_size);
435 memcpy(er->buffer, (char *)er->buffer + (offset * er->rd_frame_size),
436 er->frames_in * er->rd_frame_size);
438 er->frames_in);
443 er->delta_count = 0;
444 er->prev_delta_sign = 0;
450 "] = er->playback_delay[%" PRId32 "] + delayCapture[%" PRId32
452 expectedDelayNs, er->playback_delay, buffer->delay_ns, timeDiff);
456 if (er->frames_in < buffer->frame_count) {
457 if (buffer->frame_count > er->buf_size) {
458 er->buf_size = buffer->frame_count;
459 er->buffer = realloc(er->buffer, er->buf_size * er->rd_frame_size);
460 ALOGV("echo_reference_read(): increasing buffer size to %zu", er->buf_size);
463 memset((char *)er->buffer + er->frames_in * er->rd_frame_size,
464 0, (buffer->frame_count - er->frames_in) * er->rd_frame_size);
465 er->frames_in = buffer->frame_count;
469 (char *)er->buffer,
470 buffer->frame_count * er->rd_frame_size);
472 er->frames_in -= buffer->frame_count;
473 memcpy(er->buffer,
474 (char *)er->buffer + buffer->frame_count * er->rd_frame_size,
475 er->frames_in * er->rd_frame_size);
481 buffer->frame_count, er->frames_in);
483 pthread_cond_signal(&er->cond);
486 pthread_mutex_unlock(&er->lock);
499 struct echo_reference *er;
521 er = (struct echo_reference *)calloc(1, sizeof(struct echo_reference));
523 er->itfe.read = echo_reference_read;
524 er->itfe.write = echo_reference_write;
526 er->state = ECHOREF_IDLE;
527 er->rd_format = rdFormat;
528 er->rd_channel_count = rdChannelCount;
529 er->rd_sampling_rate = rdSamplingRate;
530 er->wr_format = wrFormat;
531 er->wr_channel_count = wrChannelCount;
532 er->wr_sampling_rate = wrSamplingRate;
533 er->rd_frame_size = audio_bytes_per_sample(rdFormat) * rdChannelCount;
534 er->wr_frame_size = audio_bytes_per_sample(wrFormat) * wrChannelCount;
535 *echo_reference = &er->itfe;
540 struct echo_reference *er = (struct echo_reference *)echo_reference;
542 if (er == NULL) {
547 echo_reference_reset_l(er);
548 if (er->resampler != NULL) {
549 release_resampler(er->resampler);
551 free(er);
