/**************************************************************************** * audio/audio.c * * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. The * ASF licenses this file to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance with the * License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the * License for the specific language governing permissions and limitations * under the License. * ****************************************************************************/ /**************************************************************************** * Included Files ****************************************************************************/ #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #ifdef CONFIG_AUDIO /**************************************************************************** * Pre-processor Definitions ****************************************************************************/ /* Debug ********************************************************************/ /* Non-standard debug that may be enabled just for testing Audio */ #ifndef AUDIO_MAX_DEVICE_PATH # define AUDIO_MAX_DEVICE_PATH 32 #endif #ifndef CONFIG_AUDIO_BUFFER_DEQUEUE_PRIO # define CONFIG_AUDIO_BUFFER_DEQUEUE_PRIO 1 #endif /**************************************************************************** * Private Type Definitions ****************************************************************************/ /* This structure describes the state of the upper half driver */ struct audio_upperhalf_s { uint8_t crefs; /* The number of times the device has been opened */ volatile bool started; /* True: playback is active */ mutex_t lock; /* Supports mutual exclusion */ FAR struct audio_lowerhalf_s *dev; /* lower-half state */ struct file *usermq; /* User mode app's message queue */ }; /**************************************************************************** * Private Function Prototypes ****************************************************************************/ static int audio_open(FAR struct file *filep); static int audio_close(FAR struct file *filep); static ssize_t audio_read(FAR struct file *filep, FAR char *buffer, size_t buflen); static ssize_t audio_write(FAR struct file *filep, FAR const char *buffer, size_t buflen); static int audio_ioctl(FAR struct file *filep, int cmd, unsigned long arg); #ifdef CONFIG_AUDIO_MULTI_SESSION static int audio_start(FAR struct audio_upperhalf_s *upper, FAR void *session); static void audio_callback(FAR void *priv, uint16_t reason, FAR struct ap_buffer_s *apb, uint16_t status, FAR void *session); #else static int audio_start(FAR struct audio_upperhalf_s *upper); static void audio_callback(FAR void *priv, uint16_t reason, FAR struct ap_buffer_s *apb, uint16_t status); #endif /* CONFIG_AUDIO_MULTI_SESSION */ /**************************************************************************** * Private Data ****************************************************************************/ static const struct file_operations g_audioops = { audio_open, /* open */ audio_close, /* close */ audio_read, /* read */ audio_write, /* write */ NULL, /* seek */ audio_ioctl, /* ioctl */ }; /**************************************************************************** * Private Functions ****************************************************************************/ /**************************************************************************** * Name: audio_open * * Description: * This function is called whenever the Audio device is opened. * ****************************************************************************/ static int audio_open(FAR struct file *filep) { FAR struct inode *inode = filep->f_inode; FAR struct audio_upperhalf_s *upper = inode->i_private; uint8_t tmp; int ret; audinfo("crefs: %d\n", upper->crefs); /* Get exclusive access to the device structures */ ret = nxmutex_lock(&upper->lock); if (ret < 0) { goto errout; } /* Increment the count of references to the device. If this the first * time that the driver has been opened for this device, then initialize * the device. */ tmp = upper->crefs + 1; if (tmp == 0) { /* More than 255 opens; uint8_t overflows to zero */ ret = -EMFILE; goto errout_with_lock; } /* Save the new open count on success */ upper->crefs = tmp; ret = OK; errout_with_lock: nxmutex_unlock(&upper->lock); errout: return ret; } /**************************************************************************** * Name: audio_close * * Description: * This function is called when the Audio device is closed. * ****************************************************************************/ static int audio_close(FAR struct file *filep) { FAR struct inode *inode = filep->f_inode; FAR struct audio_upperhalf_s *upper = inode->i_private; int ret; audinfo("crefs: %d\n", upper->crefs); /* Get exclusive access to the device structures */ ret = nxmutex_lock(&upper->lock); if (ret < 0) { goto errout; } /* Decrement the references to the driver. If the reference count will * decrement to 0, then uninitialize the driver. */ if (upper->crefs > 1) { upper->crefs--; } else { FAR struct audio_lowerhalf_s *lower = upper->dev; /* There are no more references to the port */ upper->crefs = 0; /* Disable the Audio device */ DEBUGASSERT(lower->ops->shutdown != NULL); audinfo("calling shutdown\n"); lower->ops->shutdown(lower); upper->usermq = NULL; } ret = OK; nxmutex_unlock(&upper->lock); errout: return ret; } /**************************************************************************** * Name: audio_read * * Description: * A dummy read method. This is provided only to satsify the VFS layer. * ****************************************************************************/ static ssize_t audio_read(FAR struct file *filep, FAR char *buffer, size_t buflen) { FAR struct inode *inode = filep->f_inode; FAR struct audio_upperhalf_s *upper = inode->i_private; FAR struct audio_lowerhalf_s *lower = upper->dev; /* TODO: Should we check permissions here? */ /* Audio read operations get passed directly to the lower-level */ if (lower->ops->read != NULL) { return lower->ops->read(lower, buffer, buflen); } return 0; } /**************************************************************************** * Name: audio_write * * Description: * A dummy write method. This is provided only to satsify the VFS layer. * ****************************************************************************/ static ssize_t audio_write(FAR struct file *filep, FAR const char *buffer, size_t buflen) { FAR struct inode *inode = filep->f_inode; FAR struct audio_upperhalf_s *upper = inode->i_private; FAR struct audio_lowerhalf_s *lower = upper->dev; /* TODO: Should we check permissions here? */ /* Audio write operations get passed directly to the lower-level */ if (lower->ops->write != NULL) { return lower->ops->write(lower, buffer, buflen); } return 0; } /**************************************************************************** * Name: audio_start * * Description: * Handle the AUDIOIOC_START ioctl command * ****************************************************************************/ #ifdef CONFIG_AUDIO_MULTI_SESSION static int audio_start(FAR struct audio_upperhalf_s *upper, FAR void *session) #else static int audio_start(FAR struct audio_upperhalf_s *upper) #endif { FAR struct audio_lowerhalf_s *lower = upper->dev; int ret = OK; DEBUGASSERT(upper != NULL && lower->ops->start != NULL); /* Verify that the Audio is not already running */ if (!upper->started) { /* Invoke the bottom half method to start the audio stream */ #ifdef CONFIG_AUDIO_MULTI_SESSION ret = lower->ops->start(lower, session); #else ret = lower->ops->start(lower); #endif /* A return value of zero means that the audio stream was started * successfully. */ if (ret == OK) { /* Indicate that the audio stream has started */ upper->started = true; } } return ret; } /**************************************************************************** * Name: audio_ioctl * * Description: * The standard ioctl method. This is where ALL of the Audio work is done. * ****************************************************************************/ static int audio_ioctl(FAR struct file *filep, int cmd, unsigned long arg) { FAR struct inode *inode = filep->f_inode; FAR struct audio_upperhalf_s *upper = inode->i_private; FAR struct audio_lowerhalf_s *lower = upper->dev; FAR struct audio_buf_desc_s *bufdesc; #ifdef CONFIG_AUDIO_MULTI_SESSION FAR void *session; #endif int ret; audinfo("cmd: %d arg: %ld\n", cmd, arg); /* Get exclusive access to the device structures */ ret = nxmutex_lock(&upper->lock); if (ret < 0) { return ret; } /* Handle built-in ioctl commands */ switch (cmd) { /* AUDIOIOC_GETCAPS - Get the audio device capabilities. * * ioctl argument: A pointer to the audio_caps_s structure. */ case AUDIOIOC_GETCAPS: { FAR struct audio_caps_s *caps = (FAR struct audio_caps_s *)((uintptr_t)arg); DEBUGASSERT(lower->ops->getcaps != NULL); audinfo("AUDIOIOC_GETCAPS: Device=%d\n", caps->ac_type); /* Call the lower-half driver capabilities handler */ ret = lower->ops->getcaps(lower, caps->ac_type, caps); } break; case AUDIOIOC_CONFIGURE: { FAR const struct audio_caps_desc_s *caps = (FAR const struct audio_caps_desc_s *)((uintptr_t)arg); DEBUGASSERT(lower->ops->configure != NULL); audinfo("AUDIOIOC_INITIALIZE: Device=%d\n", caps->caps.ac_type); /* Call the lower-half driver configure handler */ #ifdef CONFIG_AUDIO_MULTI_SESSION ret = lower->ops->configure(lower, caps->session, &caps->caps); #else ret = lower->ops->configure(lower, &caps->caps); #endif } break; case AUDIOIOC_SHUTDOWN: { DEBUGASSERT(lower->ops->shutdown != NULL); audinfo("AUDIOIOC_SHUTDOWN\n"); /* Call the lower-half driver initialize handler */ ret = lower->ops->shutdown(lower); } break; /* AUDIOIOC_START - Start the audio stream. * The AUDIOIOC_SETCHARACTERISTICS * command must have previously been sent. * * ioctl argument: Audio session */ case AUDIOIOC_START: { audinfo("AUDIOIOC_START\n"); DEBUGASSERT(lower->ops->start != NULL); /* Start the audio stream */ #ifdef CONFIG_AUDIO_MULTI_SESSION session = (FAR void *) arg; ret = audio_start(upper, session); #else ret = audio_start(upper); #endif } break; /* AUDIOIOC_STOP - Stop the audio stream. * * ioctl argument: Audio session */ #ifndef CONFIG_AUDIO_EXCLUDE_STOP case AUDIOIOC_STOP: { audinfo("AUDIOIOC_STOP\n"); DEBUGASSERT(lower->ops->stop != NULL); if (upper->started) { #ifdef CONFIG_AUDIO_MULTI_SESSION session = (FAR void *) arg; ret = lower->ops->stop(lower, session); #else ret = lower->ops->stop(lower); #endif upper->started = false; } } break; #endif /* CONFIG_AUDIO_EXCLUDE_STOP */ /* AUDIOIOC_PAUSE - Pause the audio stream. * * ioctl argument: Audio session */ #ifndef CONFIG_AUDIO_EXCLUDE_PAUSE_RESUME case AUDIOIOC_PAUSE: { audinfo("AUDIOIOC_PAUSE\n"); DEBUGASSERT(lower->ops->pause != NULL); if (upper->started) { #ifdef CONFIG_AUDIO_MULTI_SESSION session = (FAR void *) arg; ret = lower->ops->pause(lower, session); #else ret = lower->ops->pause(lower); #endif } } break; /* AUDIOIOC_RESUME - Resume the audio stream. * * ioctl argument: Audio session */ case AUDIOIOC_RESUME: { audinfo("AUDIOIOC_RESUME\n"); DEBUGASSERT(lower->ops->resume != NULL); if (upper->started) { #ifdef CONFIG_AUDIO_MULTI_SESSION session = (FAR void *) arg; ret = lower->ops->resume(lower, session); #else ret = lower->ops->resume(lower); #endif } } break; #endif /* CONFIG_AUDIO_EXCLUDE_PAUSE_RESUME */ /* AUDIOIOC_ALLOCBUFFER - Allocate an audio buffer * * ioctl argument: pointer to an audio_buf_desc_s structure */ case AUDIOIOC_ALLOCBUFFER: { audinfo("AUDIOIOC_ALLOCBUFFER\n"); bufdesc = (FAR struct audio_buf_desc_s *) arg; if (lower->ops->allocbuffer) { ret = lower->ops->allocbuffer(lower, bufdesc); } else { /* Perform a simple kumm_malloc operation assuming 1 session */ ret = apb_alloc(bufdesc); } } break; /* AUDIOIOC_FREEBUFFER - Free an audio buffer * * ioctl argument: pointer to an audio_buf_desc_s structure */ case AUDIOIOC_FREEBUFFER: { audinfo("AUDIOIOC_FREEBUFFER\n"); bufdesc = (FAR struct audio_buf_desc_s *) arg; if (lower->ops->freebuffer) { ret = lower->ops->freebuffer(lower, bufdesc); } else { /* Perform a simple apb_free operation */ DEBUGASSERT(bufdesc->u.buffer != NULL); apb_free(bufdesc->u.buffer); ret = sizeof(struct audio_buf_desc_s); } } break; /* AUDIOIOC_ENQUEUEBUFFER - Enqueue an audio buffer * * ioctl argument: pointer to an audio_buf_desc_s structure */ case AUDIOIOC_ENQUEUEBUFFER: { audinfo("AUDIOIOC_ENQUEUEBUFFER\n"); DEBUGASSERT(lower->ops->enqueuebuffer != NULL); bufdesc = (FAR struct audio_buf_desc_s *) arg; ret = lower->ops->enqueuebuffer(lower, bufdesc->u.buffer); } break; /* AUDIOIOC_REGISTERMQ - Register a client Message Queue * * TODO: This needs to have multi session support. */ case AUDIOIOC_REGISTERMQ: { audinfo("AUDIOIOC_REGISTERMQ\n"); ret = fs_getfilep((mqd_t)arg, &upper->usermq); } break; /* AUDIOIOC_UNREGISTERMQ - Register a client Message Queue * * TODO: This needs to have multi session support. */ case AUDIOIOC_UNREGISTERMQ: { audinfo("AUDIOIOC_UNREGISTERMQ\n"); upper->usermq = NULL; ret = OK; } break; /* AUDIOIOC_RESERVE - Reserve a session with the driver * * ioctl argument - pointer to receive the session context */ case AUDIOIOC_RESERVE: { audinfo("AUDIOIOC_RESERVE\n"); DEBUGASSERT(lower->ops->reserve != NULL); /* Call lower-half to perform the reservation */ #ifdef CONFIG_AUDIO_MULTI_SESSION ret = lower->ops->reserve(lower, (FAR void **) arg); #else ret = lower->ops->reserve(lower); #endif } break; /* AUDIOIOC_RESERVE - Reserve a session with the driver * * ioctl argument - pointer to receive the session context */ case AUDIOIOC_RELEASE: { audinfo("AUDIOIOC_RELEASE\n"); DEBUGASSERT(lower->ops->release != NULL); /* Call lower-half to perform the release */ #ifdef CONFIG_AUDIO_MULTI_SESSION ret = lower->ops->release(lower, (FAR void *) arg); #else ret = lower->ops->release(lower); #endif } break; /* Any unrecognized IOCTL commands might be * platform-specific ioctl commands */ default: { audinfo("Forwarding unrecognized cmd: %d arg: %ld\n", cmd, arg); DEBUGASSERT(lower->ops->ioctl != NULL); ret = lower->ops->ioctl(lower, cmd, arg); } break; } nxmutex_unlock(&upper->lock); return ret; } /**************************************************************************** * Name: audio_dequeuebuffer * * Description: * Dequeues a previously enqueued Audio Pipeline Buffer. * * 1. The upper half driver calls the enqueuebuffer method, providing the * lower half driver with the ab_buffer to process. * 2. The lower half driver's enqueuebuffer will either processes the * buffer directly, or more likely add it to a queue for processing * by a background thread or worker task. * 3. When the lower half driver has completed processing of the enqueued * ab_buffer, it will call this routine to indicate processing of the * buffer is complete. * 4. When this routine is called, it will check if any threads are waiting * to enqueue additional buffers and "wake them up" for further * processing. * * Input Parameters: * handle - This is the handle that was provided to the lower-half * start() method. * apb - A pointer to the previsously enqueued ap_buffer_s * status - Status of the dequeue operation * * Returned Value: * None * * Assumptions: * This function may be called from an interrupt handler. * ****************************************************************************/ #ifdef CONFIG_AUDIO_MULTI_SESSION static inline void audio_dequeuebuffer(FAR struct audio_upperhalf_s *upper, FAR struct ap_buffer_s *apb, uint16_t status, FAR void *session) #else static inline void audio_dequeuebuffer(FAR struct audio_upperhalf_s *upper, FAR struct ap_buffer_s *apb, uint16_t status) #endif { struct audio_msg_s msg; audinfo("Entry\n"); /* Send a dequeue message to the user if a message queue is registered */ if (upper->usermq != NULL) { msg.msg_id = AUDIO_MSG_DEQUEUE; msg.u.ptr = apb; #ifdef CONFIG_AUDIO_MULTI_SESSION msg.session = session; #endif apb->flags |= AUDIO_APB_DEQUEUED; file_mq_send(upper->usermq, (FAR const char *)&msg, sizeof(msg), CONFIG_AUDIO_BUFFER_DEQUEUE_PRIO); } } /**************************************************************************** * Name: audio_complete * * Description: * Send an AUDIO_MSG_COMPLETE message to the client to indicate that the * active playback has completed. The lower-half driver initiates this * call via its callback pointer to our upper-half driver. * ****************************************************************************/ #ifdef CONFIG_AUDIO_MULTI_SESSION static inline void audio_complete(FAR struct audio_upperhalf_s *upper, FAR struct ap_buffer_s *apb, uint16_t status, FAR void *session) #else static inline void audio_complete(FAR struct audio_upperhalf_s *upper, FAR struct ap_buffer_s *apb, uint16_t status) #endif { struct audio_msg_s msg; audinfo("Entry\n"); /* Send a dequeue message to the user if a message queue is registered */ upper->started = false; if (upper->usermq != NULL) { msg.msg_id = AUDIO_MSG_COMPLETE; msg.u.ptr = NULL; #ifdef CONFIG_AUDIO_MULTI_SESSION msg.session = session; #endif file_mq_send(upper->usermq, (FAR const char *)&msg, sizeof(msg), CONFIG_AUDIO_BUFFER_DEQUEUE_PRIO); } } /**************************************************************************** * Name: audio_message * * Description: * Send an custom message to the client to indicate that the * active message has delivered. The lower-half driver initiates this * call via its callback pointer to our upper-half driver. * ****************************************************************************/ #ifdef CONFIG_AUDIO_MULTI_SESSION static inline void audio_message(FAR struct audio_upperhalf_s *upper, FAR struct ap_buffer_s *apb, uint16_t status, FAR void *session) #else static inline void audio_message(FAR struct audio_upperhalf_s *upper, FAR struct ap_buffer_s *apb, uint16_t status) #endif { struct audio_msg_s *msg = (FAR struct audio_msg_s *)apb; /* Send a message to the user if a message queue is registered */ if (upper->usermq != NULL) { #ifdef CONFIG_AUDIO_MULTI_SESSION msg->session = session; #endif file_mq_send(upper->usermq, (FAR const char *)msg, sizeof(*msg), CONFIG_AUDIO_BUFFER_DEQUEUE_PRIO); } } /**************************************************************************** * Name: audio_callback * * Description: * Provides a callback interface for lower-half drivers to call to the * upper-half for buffer dequeueing, error reporting, etc. * * Input Parameters: * priv - Private context data owned by the upper-half * reason - The reason code for the callback * apb - A pointer to the previsously enqueued ap_buffer_s * status - Status information associated with the callback * * Returned Value: * None * * Assumptions: * This function may be called from an interrupt handler. * ****************************************************************************/ #ifdef CONFIG_AUDIO_MULTI_SESSION static void audio_callback(FAR void *handle, uint16_t reason, FAR struct ap_buffer_s *apb, uint16_t status, FAR void *session) #else static void audio_callback(FAR void *handle, uint16_t reason, FAR struct ap_buffer_s *apb, uint16_t status) #endif { FAR struct audio_upperhalf_s *upper = (FAR struct audio_upperhalf_s *)handle; audinfo("Entry\n"); /* Perform operation based on reason code */ switch (reason) { case AUDIO_CALLBACK_DEQUEUE: { /* Call the dequeue routine */ #ifdef CONFIG_AUDIO_MULTI_SESSION audio_dequeuebuffer(upper, apb, status, session); #else audio_dequeuebuffer(upper, apb, status); #endif break; } /* Lower-half I/O error occurred */ case AUDIO_CALLBACK_IOERR: { } break; /* Lower-half driver has completed a playback */ case AUDIO_CALLBACK_COMPLETE: { /* Send a complete message to the user if a message queue * is registered */ #ifdef CONFIG_AUDIO_MULTI_SESSION audio_complete(upper, apb, status, session); #else audio_complete(upper, apb, status); #endif } break; case AUDIO_CALLBACK_MESSAGE: { #ifdef CONFIG_AUDIO_MULTI_SESSION audio_message(upper, apb, status, session); #else audio_message(upper, apb, status); #endif } break; default: { auderr("ERROR: Unknown callback reason code %d\n", reason); break; } } } /**************************************************************************** * Public Functions ****************************************************************************/ /**************************************************************************** * Name: audio_register * * Description: * This function binds an instance of a "lower half" audio driver with the * "upper half" Audio device and registers that device so that can be used * by application code. * * When this function is called, the "lower half" driver should be in the * reset state (as if the shutdown() method had already been called). * * Input Parameters: * path - The full path to the driver to be registers in the NuttX pseudo- * filesystem. The recommended convention is to name Audio drivers * based on the function they provide, such as "/dev/pcm0", "/dev/mp31", * etc. * dev - A pointer to an instance of lower half audio driver. * This instance is bound to the Audio driver and must persists as long * as the driver persists. * * Returned Value: * Zero on success; a negated errno value on failure. * ****************************************************************************/ int audio_register(FAR const char *name, FAR struct audio_lowerhalf_s *dev) { FAR struct audio_upperhalf_s *upper; char path[AUDIO_MAX_DEVICE_PATH]; static bool dev_audio_created = false; #ifndef CONFIG_AUDIO_CUSTOM_DEV_PATH FAR const char *devname = "/dev/audio"; #elif !defined(CONFIG_AUDIO_DEV_ROOT) FAR const char *devname = CONFIG_AUDIO_DEV_PATH; FAR const char *ptr; FAR char *pathptr; #endif /* Allocate the upper-half data structure */ upper = kmm_zalloc(sizeof(struct audio_upperhalf_s)); if (!upper) { auderr("ERROR: Allocation failed\n"); return -ENOMEM; } /* Initialize the Audio device structure * (it was already zeroed by kmm_zalloc()) */ nxmutex_init(&upper->lock); upper->dev = dev; #ifdef CONFIG_AUDIO_CUSTOM_DEV_PATH #ifdef CONFIG_AUDIO_DEV_ROOT /* This is the simple case ... No need to make a directory */ strlcpy(path, "/dev/", sizeof(path)); strlcat(path, name, sizeof(path)); #else /* Ensure the path begins with "/dev" as we don't support placing device * anywhere but in the /dev directory */ DEBUGASSERT(strncmp(devname, "/dev", 4) == 0); /* Create a /dev/audio directory. */ if (!dev_audio_created) { /* Get path name after "/dev" */ ptr = &devname[4]; if (*ptr == '/') { ptr++; } strlcpy(path, "/dev/", sizeof(path)); pathptr = &path[5]; /* Do mkdir for each segment of the path */ while (*ptr != '\0') { /* Build next path segment into path variable */ while (*ptr != '/' && *ptr != '\0') { *pathptr++ = *ptr++; } *pathptr = '\0'; /* Make this level of directory */ mkdir(path, 0644); /* Check for another level */ *pathptr++ = '/'; if (*ptr == '/') { ptr++; } } /* Indicate we have created the audio dev path */ dev_audio_created = true; } /* Now build the path for registration */ strlcpy(path, devname, sizeof(path)); if (devname[sizeof(devname)-1] != '/') { strlcat(path, "/", sizeof(path)); } strlcat(path, name, sizeof(path)); #endif /* CONFIG_AUDIO_DEV_PATH=="/dev" */ #else /* CONFIG_AUDIO_CUSTOM_DEV_PATH */ /* Create a /dev/audio directory. */ if (!dev_audio_created) { /* We don't check for error here because even if it fails, then * the register_driver call below will return an error condition * for us. */ mkdir(devname, 0644); dev_audio_created = true; } /* Register the Audio device */ strlcpy(path, devname, sizeof(path)); strlcat(path, "/", sizeof(path)); strlcat(path, name, sizeof(path)); #endif /* Give the lower-half a context to the upper half */ dev->upper = audio_callback; dev->priv = upper; audinfo("Registering %s\n", path); return register_driver(path, &g_audioops, 0666, upper); } #endif /* CONFIG_AUDIO */