#define DEFAULT_PERIOD_SIZE 1024
#define DEFAULT_PERIOD_COUNT 2
-//void proxy_init(alsa_device_proxy * proxy)
-//{
-// proxy->profile = NULL;
-//
-// proxy->alsa_config.format = DEFAULT_SAMPLE_FORMAT;
-// proxy->alsa_config.rate = DEFAULT_SAMPLE_RATE;
-// proxy->alsa_config.channels = DEFAULT_CHANNEL_COUNT;
-//
-// proxy->alsa_config.period_size = DEFAULT_PERIOD_SIZE;
-// proxy->alsa_config.period_count = DEFAULT_PERIOD_COUNT;
-//
-// proxy->pcm = NULL;
-//}
-
void proxy_prepare(alsa_device_proxy * proxy, alsa_device_profile* profile,
struct pcm_config * config)
{
int proxy_open(alsa_device_proxy * proxy)
{
alsa_device_profile* profile = proxy->profile;
-
ALOGV("proxy_open(card:%d device:%d %s)", profile->card, profile->device,
profile->direction == PCM_OUT ? "PCM_OUT" : "PCM_IN");
void proxy_close(alsa_device_proxy * proxy)
{
- pcm_close(proxy->pcm);
- proxy->pcm = NULL;
+ ALOGV("proxy_close() [pcm:%p]", proxy->pcm);
+
+ if (proxy->pcm != NULL) {
+ pcm_close(proxy->pcm);
+ proxy->pcm = NULL;
+ }
}
/*
const struct stream_out* out = (const struct stream_out*)stream;
size_t buffer_size =
proxy_get_period_size(&out->proxy) * audio_stream_out_frame_size(&(out->stream));
- ALOGV("out_get_buffer_size() = %zu", buffer_size);
return buffer_size;
}
*/
alsa_device_proxy * proxy = &((struct stream_out*)stream)->proxy;
audio_format_t format = audio_format_from_pcm_format(proxy_get_format(proxy));
- ALOGV("out_get_format() = %d", format);
return format;
}
if (param_val >= 0)
device = atoi(value);
- if (card >= 0 && device >= 0) {
+ if (card >= 0 && device >= 0 && !profile_is_cached_for(out->profile, card, device)) {
/* cannot read pcm device info if playback is active */
if (!out->standby)
ret_value = -ENOSYS;
}
}
}
+
pthread_mutex_unlock(&out->lock);
pthread_mutex_unlock(&out->dev->lock);
str_parms_destroy(parms);
}
pthread_mutex_unlock(&out->dev->lock);
-
alsa_device_proxy* proxy = &out->proxy;
const void * write_buff = buffer;
int num_write_buff_bytes = bytes;
// build this to hand to the alsa_device_proxy
struct pcm_config proxy_config;
+ memset(&proxy_config, 0, sizeof(proxy_config));
int ret = 0;
pthread_mutex_lock(&in->dev->lock);
pthread_mutex_lock(&in->lock);
- /* Card/Device */
+ /* Device Connection Message ("card=1,device=0") */
param_val = str_parms_get_str(parms, "card", value, sizeof(value));
if (param_val >= 0)
card = atoi(value);
if (param_val >= 0)
device = atoi(value);
- if (card >= 0 && device >= 0) {
+ if (card >= 0 && device >= 0 && !profile_is_cached_for(in->profile, card, device)) {
/* cannot read pcm device info if playback is active */
if (!in->standby)
ret_value = -ENOSYS;
in->profile->device = saved_device;
}
}
- }
+ }
pthread_mutex_unlock(&in->lock);
pthread_mutex_unlock(&in->dev->lock);
in->profile = &in->dev->in_profile;
struct pcm_config proxy_config;
+ memset(&proxy_config, 0, sizeof(proxy_config));
/* Rate */
if (config->sample_rate == 0) {
*/
static int adev_set_parameters(struct audio_hw_device *dev, const char *kvpairs)
{
+ ALOGV("audio_hw:usb adev_set_parameters(%s)", kvpairs);
+
+ struct audio_device * adev = (struct audio_device *)dev;
+
+ char value[32];
+ int param_val;
+
+ struct str_parms * parms = str_parms_create_str(kvpairs);
+
+ /* Check for the "disconnect" message */
+ param_val = str_parms_get_str(parms, "disconnect", value, sizeof(value));
+ if (param_val >= 0) {
+ audio_devices_t device = (audio_devices_t)atoi(value);
+
+ param_val = str_parms_get_str(parms, "card", value, sizeof(value));
+ int alsa_card = param_val >= 0 ? atoi(value) : -1;
+
+ param_val = str_parms_get_str(parms, "device", value, sizeof(value));
+ int alsa_device = param_val >= 0 ? atoi(value) : -1;
+
+ if (alsa_card >= 0 && alsa_device >= 0) {
+ /* "decache" the profile */
+ pthread_mutex_lock(&adev->lock);
+ if (device == AUDIO_DEVICE_OUT_USB_DEVICE &&
+ profile_is_cached_for(&adev->out_profile, alsa_card, alsa_device)) {
+ profile_decache(&adev->out_profile);
+ }
+ if (device == AUDIO_DEVICE_IN_USB_DEVICE &&
+ profile_is_cached_for(&adev->in_profile, alsa_card, alsa_device)) {
+ profile_decache(&adev->in_profile);
+ }
+ pthread_mutex_unlock(&adev->lock);
+ }
+ }
+
return 0;
}