|
Packit Service |
db8eaa |
/**
|
|
Packit Service |
db8eaa |
* \file pcm/pcm_shm.c
|
|
Packit Service |
db8eaa |
* \ingroup PCM_Plugins
|
|
Packit Service |
db8eaa |
* \brief PCM Shared Memory Plugin Interface
|
|
Packit Service |
db8eaa |
* \author Abramo Bagnara <abramo@alsa-project.org>
|
|
Packit Service |
db8eaa |
* \date 2000-2001
|
|
Packit Service |
db8eaa |
*/
|
|
Packit Service |
db8eaa |
/*
|
|
Packit Service |
db8eaa |
* PCM - Shared Memory Client
|
|
Packit Service |
db8eaa |
* Copyright (c) 2000 by Abramo Bagnara <abramo@alsa-project.org>
|
|
Packit Service |
db8eaa |
*
|
|
Packit Service |
db8eaa |
*
|
|
Packit Service |
db8eaa |
* This library is free software; you can redistribute it and/or modify
|
|
Packit Service |
db8eaa |
* it under the terms of the GNU Lesser General Public License as
|
|
Packit Service |
db8eaa |
* published by the Free Software Foundation; either version 2.1 of
|
|
Packit Service |
db8eaa |
* the License, or (at your option) any later version.
|
|
Packit Service |
db8eaa |
*
|
|
Packit Service |
db8eaa |
* This program is distributed in the hope that it will be useful,
|
|
Packit Service |
db8eaa |
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
Packit Service |
db8eaa |
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
Packit Service |
db8eaa |
* GNU Lesser General Public License for more details.
|
|
Packit Service |
db8eaa |
*
|
|
Packit Service |
db8eaa |
* You should have received a copy of the GNU Lesser General Public
|
|
Packit Service |
db8eaa |
* License along with this library; if not, write to the Free Software
|
|
Packit Service |
db8eaa |
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
|
|
Packit Service |
db8eaa |
*
|
|
Packit Service |
db8eaa |
*/
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
#include <stdio.h>
|
|
Packit Service |
db8eaa |
#include <stdlib.h>
|
|
Packit Service |
db8eaa |
#include <stddef.h>
|
|
Packit Service |
db8eaa |
#include <limits.h>
|
|
Packit Service |
db8eaa |
#include <unistd.h>
|
|
Packit Service |
db8eaa |
#include <string.h>
|
|
Packit Service |
db8eaa |
#include <fcntl.h>
|
|
Packit Service |
db8eaa |
#include <sys/ioctl.h>
|
|
Packit Service |
db8eaa |
#include <sys/shm.h>
|
|
Packit Service |
db8eaa |
#include <sys/socket.h>
|
|
Packit Service |
db8eaa |
#include <poll.h>
|
|
Packit Service |
db8eaa |
#include <sys/un.h>
|
|
Packit Service |
db8eaa |
#include <sys/mman.h>
|
|
Packit Service |
db8eaa |
#include <netinet/in.h>
|
|
Packit Service |
db8eaa |
#include <arpa/inet.h>
|
|
Packit Service |
db8eaa |
#include <net/if.h>
|
|
Packit Service |
db8eaa |
#include <netdb.h>
|
|
Packit Service |
db8eaa |
#include "aserver.h"
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
#ifndef PIC
|
|
Packit Service |
db8eaa |
/* entry for static linking */
|
|
Packit Service |
db8eaa |
const char *_snd_module_pcm_shm = "";
|
|
Packit Service |
db8eaa |
#endif
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
#ifndef DOC_HIDDEN
|
|
Packit Service |
db8eaa |
typedef struct {
|
|
Packit Service |
db8eaa |
int socket;
|
|
Packit Service |
db8eaa |
volatile snd_pcm_shm_ctrl_t *ctrl;
|
|
Packit Service |
db8eaa |
} snd_pcm_shm_t;
|
|
Packit Service |
db8eaa |
#endif
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static long snd_pcm_shm_action_fd0(snd_pcm_t *pcm, int *fd)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_shm_t *shm = pcm->private_data;
|
|
Packit Service |
db8eaa |
int err;
|
|
Packit Service |
db8eaa |
char buf[1];
|
|
Packit Service |
db8eaa |
volatile snd_pcm_shm_ctrl_t *ctrl = shm->ctrl;
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
err = write(shm->socket, buf, 1);
|
|
Packit Service |
db8eaa |
if (err != 1)
|
|
Packit Service |
db8eaa |
return -EBADFD;
|
|
Packit Service |
db8eaa |
err = snd_receive_fd(shm->socket, buf, 1, fd);
|
|
Packit Service |
db8eaa |
if (err != 1)
|
|
Packit Service |
db8eaa |
return -EBADFD;
|
|
Packit Service |
db8eaa |
if (ctrl->cmd) {
|
|
Packit Service |
db8eaa |
SNDERR("Server has not done the cmd");
|
|
Packit Service |
db8eaa |
return -EBADFD;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
return ctrl->result;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_new_rbptr(snd_pcm_t *pcm, snd_pcm_shm_t *shm,
|
|
Packit Service |
db8eaa |
snd_pcm_rbptr_t *rbptr, volatile snd_pcm_shm_rbptr_t *shm_rbptr)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
if (!shm_rbptr->use_mmap) {
|
|
Packit Service |
db8eaa |
if (&pcm->hw == rbptr)
|
|
Packit Service |
db8eaa |
snd_pcm_set_hw_ptr(pcm, &shm_rbptr->ptr, -1, 0);
|
|
Packit Service |
db8eaa |
else
|
|
Packit Service |
db8eaa |
snd_pcm_set_appl_ptr(pcm, &shm_rbptr->ptr, -1, 0);
|
|
Packit Service |
db8eaa |
} else {
|
|
Packit Service |
db8eaa |
void *ptr;
|
|
Packit Service |
db8eaa |
size_t mmap_size, mmap_offset, offset;
|
|
Packit Service |
db8eaa |
int fd;
|
|
Packit Service |
db8eaa |
long result;
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
shm->ctrl->cmd = &pcm->hw == rbptr ? SND_PCM_IOCTL_HW_PTR_FD : SND_PCM_IOCTL_APPL_PTR_FD;
|
|
Packit Service |
db8eaa |
result = snd_pcm_shm_action_fd0(pcm, &fd;;
|
|
Packit Service |
db8eaa |
if (result < 0)
|
|
Packit Service |
db8eaa |
return result;
|
|
Packit Service |
db8eaa |
mmap_size = page_ptr(shm_rbptr->offset, sizeof(snd_pcm_uframes_t), &offset, &mmap_offset);
|
|
Packit Service |
db8eaa |
ptr = mmap(NULL, mmap_size, PROT_READ|PROT_WRITE, MAP_FILE|MAP_SHARED, fd, mmap_offset);
|
|
Packit Service |
db8eaa |
if (ptr == MAP_FAILED || ptr == NULL) {
|
|
Packit Service |
db8eaa |
SYSERR("shm rbptr mmap failed");
|
|
Packit Service |
db8eaa |
return -errno;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
if (&pcm->hw == rbptr)
|
|
Packit Service |
db8eaa |
snd_pcm_set_hw_ptr(pcm, (snd_pcm_uframes_t *)((char *)ptr + offset), fd, shm_rbptr->offset);
|
|
Packit Service |
db8eaa |
else
|
|
Packit Service |
db8eaa |
snd_pcm_set_appl_ptr(pcm, (snd_pcm_uframes_t *)((char *)ptr + offset), fd, shm_rbptr->offset);
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
return 0;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static long snd_pcm_shm_action(snd_pcm_t *pcm)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_shm_t *shm = pcm->private_data;
|
|
Packit Service |
db8eaa |
int err, result;
|
|
Packit Service |
db8eaa |
char buf[1];
|
|
Packit Service |
db8eaa |
volatile snd_pcm_shm_ctrl_t *ctrl = shm->ctrl;
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
if (ctrl->hw.changed || ctrl->appl.changed)
|
|
Packit Service |
db8eaa |
return -EBADFD;
|
|
Packit Service |
db8eaa |
err = write(shm->socket, buf, 1);
|
|
Packit Service |
db8eaa |
if (err != 1)
|
|
Packit Service |
db8eaa |
return -EBADFD;
|
|
Packit Service |
db8eaa |
err = read(shm->socket, buf, 1);
|
|
Packit Service |
db8eaa |
if (err != 1)
|
|
Packit Service |
db8eaa |
return -EBADFD;
|
|
Packit Service |
db8eaa |
if (ctrl->cmd) {
|
|
Packit Service |
db8eaa |
SNDERR("Server has not done the cmd");
|
|
Packit Service |
db8eaa |
return -EBADFD;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
result = ctrl->result;
|
|
Packit Service |
db8eaa |
if (ctrl->hw.changed) {
|
|
Packit Service |
db8eaa |
err = snd_pcm_shm_new_rbptr(pcm, shm, &pcm->hw, &ctrl->hw);
|
|
Packit Service |
db8eaa |
if (err < 0)
|
|
Packit Service |
db8eaa |
return err;
|
|
Packit Service |
db8eaa |
ctrl->hw.changed = 0;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
if (ctrl->appl.changed) {
|
|
Packit Service |
db8eaa |
err = snd_pcm_shm_new_rbptr(pcm, shm, &pcm->appl, &ctrl->appl);
|
|
Packit Service |
db8eaa |
if (err < 0)
|
|
Packit Service |
db8eaa |
return err;
|
|
Packit Service |
db8eaa |
ctrl->appl.changed = 0;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
return result;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static long snd_pcm_shm_action_fd(snd_pcm_t *pcm, int *fd)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_shm_t *shm = pcm->private_data;
|
|
Packit Service |
db8eaa |
int err;
|
|
Packit Service |
db8eaa |
char buf[1];
|
|
Packit Service |
db8eaa |
volatile snd_pcm_shm_ctrl_t *ctrl = shm->ctrl;
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
if (ctrl->hw.changed || ctrl->appl.changed)
|
|
Packit Service |
db8eaa |
return -EBADFD;
|
|
Packit Service |
db8eaa |
err = write(shm->socket, buf, 1);
|
|
Packit Service |
db8eaa |
if (err != 1)
|
|
Packit Service |
db8eaa |
return -EBADFD;
|
|
Packit Service |
db8eaa |
err = snd_receive_fd(shm->socket, buf, 1, fd);
|
|
Packit Service |
db8eaa |
if (err != 1)
|
|
Packit Service |
db8eaa |
return -EBADFD;
|
|
Packit Service |
db8eaa |
if (ctrl->cmd) {
|
|
Packit Service |
db8eaa |
SNDERR("Server has not done the cmd");
|
|
Packit Service |
db8eaa |
return -EBADFD;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
if (ctrl->hw.changed) {
|
|
Packit Service |
db8eaa |
err = snd_pcm_shm_new_rbptr(pcm, shm, &pcm->hw, &ctrl->hw);
|
|
Packit Service |
db8eaa |
if (err < 0)
|
|
Packit Service |
db8eaa |
return err;
|
|
Packit Service |
db8eaa |
ctrl->hw.changed = 0;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
if (ctrl->appl.changed) {
|
|
Packit Service |
db8eaa |
err = snd_pcm_shm_new_rbptr(pcm, shm, &pcm->appl, &ctrl->appl);
|
|
Packit Service |
db8eaa |
if (err < 0)
|
|
Packit Service |
db8eaa |
return err;
|
|
Packit Service |
db8eaa |
ctrl->appl.changed = 0;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
return ctrl->result;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_nonblock(snd_pcm_t *pcm ATTRIBUTE_UNUSED, int nonblock ATTRIBUTE_UNUSED)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
return 0;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_async(snd_pcm_t *pcm, int sig, pid_t pid)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_shm_t *shm = pcm->private_data;
|
|
Packit Service |
db8eaa |
volatile snd_pcm_shm_ctrl_t *ctrl = shm->ctrl;
|
|
Packit Service |
db8eaa |
ctrl->cmd = SND_PCM_IOCTL_ASYNC;
|
|
Packit Service |
db8eaa |
ctrl->u.async.sig = sig;
|
|
Packit Service |
db8eaa |
ctrl->u.async.pid = pid;
|
|
Packit Service |
db8eaa |
return snd_pcm_shm_action(pcm);
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_info(snd_pcm_t *pcm, snd_pcm_info_t * info)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_shm_t *shm = pcm->private_data;
|
|
Packit Service |
db8eaa |
volatile snd_pcm_shm_ctrl_t *ctrl = shm->ctrl;
|
|
Packit Service |
db8eaa |
int err;
|
|
Packit Service |
db8eaa |
// ctrl->u.info = *info;
|
|
Packit Service |
db8eaa |
ctrl->cmd = SNDRV_PCM_IOCTL_INFO;
|
|
Packit Service |
db8eaa |
err = snd_pcm_shm_action(pcm);
|
|
Packit Service |
db8eaa |
if (err < 0)
|
|
Packit Service |
db8eaa |
return err;
|
|
Packit Service |
db8eaa |
*info = ctrl->u.info;
|
|
Packit Service |
db8eaa |
return err;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_hw_refine_cprepare(snd_pcm_t *pcm ATTRIBUTE_UNUSED, snd_pcm_hw_params_t *params ATTRIBUTE_UNUSED)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
return 0;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_hw_refine_sprepare(snd_pcm_t *pcm ATTRIBUTE_UNUSED, snd_pcm_hw_params_t *sparams)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_access_mask_t saccess_mask = { SND_PCM_ACCBIT_MMAP };
|
|
Packit Service |
db8eaa |
_snd_pcm_hw_params_any(sparams);
|
|
Packit Service |
db8eaa |
_snd_pcm_hw_param_set_mask(sparams, SND_PCM_HW_PARAM_ACCESS,
|
|
Packit Service |
db8eaa |
&saccess_mask);
|
|
Packit Service |
db8eaa |
return 0;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_hw_refine_schange(snd_pcm_t *pcm ATTRIBUTE_UNUSED, snd_pcm_hw_params_t *params,
|
|
Packit Service |
db8eaa |
snd_pcm_hw_params_t *sparams)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
int err;
|
|
Packit Service |
db8eaa |
unsigned int links = ~SND_PCM_HW_PARBIT_ACCESS;
|
|
Packit Service |
db8eaa |
const snd_pcm_access_mask_t *access_mask = snd_pcm_hw_param_get_mask(params, SND_PCM_HW_PARAM_ACCESS);
|
|
Packit Service |
db8eaa |
if (!snd_pcm_access_mask_test(access_mask, SND_PCM_ACCESS_RW_INTERLEAVED) &&
|
|
Packit Service |
db8eaa |
!snd_pcm_access_mask_test(access_mask, SND_PCM_ACCESS_RW_NONINTERLEAVED)) {
|
|
Packit Service |
db8eaa |
err = _snd_pcm_hw_param_set_mask(sparams, SND_PCM_HW_PARAM_ACCESS,
|
|
Packit Service |
db8eaa |
access_mask);
|
|
Packit Service |
db8eaa |
if (err < 0)
|
|
Packit Service |
db8eaa |
return err;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
err = _snd_pcm_hw_params_refine(sparams, links, params);
|
|
Packit Service |
db8eaa |
if (err < 0)
|
|
Packit Service |
db8eaa |
return err;
|
|
Packit Service |
db8eaa |
return 0;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_hw_refine_cchange(snd_pcm_t *pcm ATTRIBUTE_UNUSED, snd_pcm_hw_params_t *params,
|
|
Packit Service |
db8eaa |
snd_pcm_hw_params_t *sparams)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
int err;
|
|
Packit Service |
db8eaa |
unsigned int links = ~SND_PCM_HW_PARBIT_ACCESS;
|
|
Packit Service |
db8eaa |
snd_pcm_access_mask_t access_mask;
|
|
Packit Service |
db8eaa |
snd_mask_copy(&access_mask, snd_pcm_hw_param_get_mask(sparams, SND_PCM_HW_PARAM_ACCESS));
|
|
Packit Service |
db8eaa |
snd_pcm_access_mask_set(&access_mask, SND_PCM_ACCESS_RW_INTERLEAVED);
|
|
Packit Service |
db8eaa |
snd_pcm_access_mask_set(&access_mask, SND_PCM_ACCESS_RW_NONINTERLEAVED);
|
|
Packit Service |
db8eaa |
err = _snd_pcm_hw_param_set_mask(sparams, SND_PCM_HW_PARAM_ACCESS,
|
|
Packit Service |
db8eaa |
&access_mask);
|
|
Packit Service |
db8eaa |
if (err < 0)
|
|
Packit Service |
db8eaa |
return err;
|
|
Packit Service |
db8eaa |
err = _snd_pcm_hw_params_refine(params, links, sparams);
|
|
Packit Service |
db8eaa |
if (err < 0)
|
|
Packit Service |
db8eaa |
return err;
|
|
Packit Service |
db8eaa |
return 0;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_hw_refine_slave(snd_pcm_t *pcm,
|
|
Packit Service |
db8eaa |
snd_pcm_hw_params_t *params)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_shm_t *shm = pcm->private_data;
|
|
Packit Service |
db8eaa |
volatile snd_pcm_shm_ctrl_t *ctrl = shm->ctrl;
|
|
Packit Service |
db8eaa |
int err;
|
|
Packit Service |
db8eaa |
ctrl->u.hw_refine = *params;
|
|
Packit Service |
db8eaa |
ctrl->cmd = SNDRV_PCM_IOCTL_HW_REFINE;
|
|
Packit Service |
db8eaa |
err = snd_pcm_shm_action(pcm);
|
|
Packit Service |
db8eaa |
*params = ctrl->u.hw_refine;
|
|
Packit Service |
db8eaa |
return err;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_hw_refine(snd_pcm_t *pcm, snd_pcm_hw_params_t *params)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
return snd_pcm_hw_refine_slave(pcm, params,
|
|
Packit Service |
db8eaa |
snd_pcm_shm_hw_refine_cprepare,
|
|
Packit Service |
db8eaa |
snd_pcm_shm_hw_refine_cchange,
|
|
Packit Service |
db8eaa |
snd_pcm_shm_hw_refine_sprepare,
|
|
Packit Service |
db8eaa |
snd_pcm_shm_hw_refine_schange,
|
|
Packit Service |
db8eaa |
snd_pcm_shm_hw_refine_slave);
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_hw_params_slave(snd_pcm_t *pcm,
|
|
Packit Service |
db8eaa |
snd_pcm_hw_params_t *params)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_shm_t *shm = pcm->private_data;
|
|
Packit Service |
db8eaa |
volatile snd_pcm_shm_ctrl_t *ctrl = shm->ctrl;
|
|
Packit Service |
db8eaa |
int err;
|
|
Packit Service |
db8eaa |
params->flags |= SND_PCM_HW_PARAMS_EXPORT_BUFFER;
|
|
Packit Service |
db8eaa |
ctrl->cmd = SNDRV_PCM_IOCTL_HW_PARAMS;
|
|
Packit Service |
db8eaa |
ctrl->u.hw_params = *params;
|
|
Packit Service |
db8eaa |
err = snd_pcm_shm_action(pcm);
|
|
Packit Service |
db8eaa |
*params = ctrl->u.hw_params;
|
|
Packit Service |
db8eaa |
return err;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_hw_params(snd_pcm_t *pcm, snd_pcm_hw_params_t * params)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
return snd_pcm_hw_params_slave(pcm, params,
|
|
Packit Service |
db8eaa |
snd_pcm_shm_hw_refine_cchange,
|
|
Packit Service |
db8eaa |
snd_pcm_shm_hw_refine_sprepare,
|
|
Packit Service |
db8eaa |
snd_pcm_shm_hw_refine_schange,
|
|
Packit Service |
db8eaa |
snd_pcm_shm_hw_params_slave);
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_hw_free(snd_pcm_t *pcm)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_shm_t *shm = pcm->private_data;
|
|
Packit Service |
db8eaa |
volatile snd_pcm_shm_ctrl_t *ctrl = shm->ctrl;
|
|
Packit Service |
db8eaa |
ctrl->cmd = SNDRV_PCM_IOCTL_HW_FREE;
|
|
Packit Service |
db8eaa |
return snd_pcm_shm_action(pcm);
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_sw_params(snd_pcm_t *pcm, snd_pcm_sw_params_t * params)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_shm_t *shm = pcm->private_data;
|
|
Packit Service |
db8eaa |
volatile snd_pcm_shm_ctrl_t *ctrl = shm->ctrl;
|
|
Packit Service |
db8eaa |
int err;
|
|
Packit Service |
db8eaa |
ctrl->cmd = SNDRV_PCM_IOCTL_SW_PARAMS;
|
|
Packit Service |
db8eaa |
ctrl->u.sw_params = *params;
|
|
Packit Service |
db8eaa |
err = snd_pcm_shm_action(pcm);
|
|
Packit Service |
db8eaa |
*params = ctrl->u.sw_params;
|
|
Packit Service |
db8eaa |
if (err < 0)
|
|
Packit Service |
db8eaa |
return err;
|
|
Packit Service |
db8eaa |
return err;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_mmap(snd_pcm_t *pcm ATTRIBUTE_UNUSED)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
return 0;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_munmap(snd_pcm_t *pcm)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
unsigned int c;
|
|
Packit Service |
db8eaa |
for (c = 0; c < pcm->channels; ++c) {
|
|
Packit Service |
db8eaa |
snd_pcm_channel_info_t *i = &pcm->mmap_channels[c];
|
|
Packit Service |
db8eaa |
unsigned int c1;
|
|
Packit Service |
db8eaa |
int err;
|
|
Packit Service |
db8eaa |
if (i->type != SND_PCM_AREA_MMAP)
|
|
Packit Service |
db8eaa |
continue;
|
|
Packit Service |
db8eaa |
if (i->u.mmap.fd < 0)
|
|
Packit Service |
db8eaa |
continue;
|
|
Packit Service |
db8eaa |
for (c1 = c + 1; c1 < pcm->channels; ++c1) {
|
|
Packit Service |
db8eaa |
snd_pcm_channel_info_t *i1 = &pcm->mmap_channels[c1];
|
|
Packit Service |
db8eaa |
if (i1->type != SND_PCM_AREA_MMAP)
|
|
Packit Service |
db8eaa |
continue;
|
|
Packit Service |
db8eaa |
if (i1->u.mmap.fd != i->u.mmap.fd)
|
|
Packit Service |
db8eaa |
continue;
|
|
Packit Service |
db8eaa |
i1->u.mmap.fd = -1;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
err = close(i->u.mmap.fd);
|
|
Packit Service |
db8eaa |
if (err < 0) {
|
|
Packit Service |
db8eaa |
SYSERR("close failed");
|
|
Packit Service |
db8eaa |
return -errno;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
return 0;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_channel_info(snd_pcm_t *pcm, snd_pcm_channel_info_t * info)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_shm_t *shm = pcm->private_data;
|
|
Packit Service |
db8eaa |
volatile snd_pcm_shm_ctrl_t *ctrl = shm->ctrl;
|
|
Packit Service |
db8eaa |
int err;
|
|
Packit Service |
db8eaa |
int fd;
|
|
Packit Service |
db8eaa |
ctrl->cmd = SNDRV_PCM_IOCTL_CHANNEL_INFO;
|
|
Packit Service |
db8eaa |
ctrl->u.channel_info = *info;
|
|
Packit Service |
db8eaa |
err = snd_pcm_shm_action_fd(pcm, &fd;;
|
|
Packit Service |
db8eaa |
if (err < 0)
|
|
Packit Service |
db8eaa |
return err;
|
|
Packit Service |
db8eaa |
*info = ctrl->u.channel_info;
|
|
Packit Service |
db8eaa |
info->addr = 0;
|
|
Packit Service |
db8eaa |
switch (info->type) {
|
|
Packit Service |
db8eaa |
case SND_PCM_AREA_MMAP:
|
|
Packit Service |
db8eaa |
info->u.mmap.fd = fd;
|
|
Packit Service |
db8eaa |
break;
|
|
Packit Service |
db8eaa |
case SND_PCM_AREA_SHM:
|
|
Packit Service |
db8eaa |
break;
|
|
Packit Service |
db8eaa |
default:
|
|
Packit Service |
db8eaa |
assert(0);
|
|
Packit Service |
db8eaa |
break;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
return err;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_status(snd_pcm_t *pcm, snd_pcm_status_t * status)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_shm_t *shm = pcm->private_data;
|
|
Packit Service |
db8eaa |
volatile snd_pcm_shm_ctrl_t *ctrl = shm->ctrl;
|
|
Packit Service |
db8eaa |
int err;
|
|
Packit Service |
db8eaa |
ctrl->cmd = SNDRV_PCM_IOCTL_STATUS;
|
|
Packit Service |
db8eaa |
// ctrl->u.status = *status;
|
|
Packit Service |
db8eaa |
err = snd_pcm_shm_action(pcm);
|
|
Packit Service |
db8eaa |
if (err < 0)
|
|
Packit Service |
db8eaa |
return err;
|
|
Packit Service |
db8eaa |
*status = ctrl->u.status;
|
|
Packit Service |
db8eaa |
return err;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static snd_pcm_state_t snd_pcm_shm_state(snd_pcm_t *pcm)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_shm_t *shm = pcm->private_data;
|
|
Packit Service |
db8eaa |
volatile snd_pcm_shm_ctrl_t *ctrl = shm->ctrl;
|
|
Packit Service |
db8eaa |
ctrl->cmd = SND_PCM_IOCTL_STATE;
|
|
Packit Service |
db8eaa |
return snd_pcm_shm_action(pcm);
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_hwsync(snd_pcm_t *pcm)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_shm_t *shm = pcm->private_data;
|
|
Packit Service |
db8eaa |
volatile snd_pcm_shm_ctrl_t *ctrl = shm->ctrl;
|
|
Packit Service |
db8eaa |
ctrl->cmd = SND_PCM_IOCTL_HWSYNC;
|
|
Packit Service |
db8eaa |
return snd_pcm_shm_action(pcm);
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_delay(snd_pcm_t *pcm, snd_pcm_sframes_t *delayp)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_shm_t *shm = pcm->private_data;
|
|
Packit Service |
db8eaa |
volatile snd_pcm_shm_ctrl_t *ctrl = shm->ctrl;
|
|
Packit Service |
db8eaa |
int err;
|
|
Packit Service |
db8eaa |
ctrl->cmd = SNDRV_PCM_IOCTL_DELAY;
|
|
Packit Service |
db8eaa |
err = snd_pcm_shm_action(pcm);
|
|
Packit Service |
db8eaa |
if (err < 0)
|
|
Packit Service |
db8eaa |
return err;
|
|
Packit Service |
db8eaa |
*delayp = ctrl->u.delay.frames;
|
|
Packit Service |
db8eaa |
return err;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static snd_pcm_sframes_t snd_pcm_shm_avail_update(snd_pcm_t *pcm)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_shm_t *shm = pcm->private_data;
|
|
Packit Service |
db8eaa |
volatile snd_pcm_shm_ctrl_t *ctrl = shm->ctrl;
|
|
Packit Service |
db8eaa |
int err;
|
|
Packit Service |
db8eaa |
ctrl->cmd = SND_PCM_IOCTL_AVAIL_UPDATE;
|
|
Packit Service |
db8eaa |
err = snd_pcm_shm_action(pcm);
|
|
Packit Service |
db8eaa |
if (err < 0)
|
|
Packit Service |
db8eaa |
return err;
|
|
Packit Service |
db8eaa |
return err;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_htimestamp(snd_pcm_t *pcm ATTRIBUTE_UNUSED,
|
|
Packit Service |
db8eaa |
snd_pcm_uframes_t *avail ATTRIBUTE_UNUSED,
|
|
Packit Service |
db8eaa |
snd_htimestamp_t *tstamp ATTRIBUTE_UNUSED)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
return -EIO; /* not implemented yet */
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_prepare(snd_pcm_t *pcm)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_shm_t *shm = pcm->private_data;
|
|
Packit Service |
db8eaa |
volatile snd_pcm_shm_ctrl_t *ctrl = shm->ctrl;
|
|
Packit Service |
db8eaa |
ctrl->cmd = SNDRV_PCM_IOCTL_PREPARE;
|
|
Packit Service |
db8eaa |
return snd_pcm_shm_action(pcm);
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_reset(snd_pcm_t *pcm)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_shm_t *shm = pcm->private_data;
|
|
Packit Service |
db8eaa |
volatile snd_pcm_shm_ctrl_t *ctrl = shm->ctrl;
|
|
Packit Service |
db8eaa |
ctrl->cmd = SNDRV_PCM_IOCTL_RESET;
|
|
Packit Service |
db8eaa |
return snd_pcm_shm_action(pcm);
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_start(snd_pcm_t *pcm)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_shm_t *shm = pcm->private_data;
|
|
Packit Service |
db8eaa |
volatile snd_pcm_shm_ctrl_t *ctrl = shm->ctrl;
|
|
Packit Service |
db8eaa |
ctrl->cmd = SNDRV_PCM_IOCTL_START;
|
|
Packit Service |
db8eaa |
return snd_pcm_shm_action(pcm);
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_drop(snd_pcm_t *pcm)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_shm_t *shm = pcm->private_data;
|
|
Packit Service |
db8eaa |
volatile snd_pcm_shm_ctrl_t *ctrl = shm->ctrl;
|
|
Packit Service |
db8eaa |
ctrl->cmd = SNDRV_PCM_IOCTL_DROP;
|
|
Packit Service |
db8eaa |
return snd_pcm_shm_action(pcm);
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_drain(snd_pcm_t *pcm)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_shm_t *shm = pcm->private_data;
|
|
Packit Service |
db8eaa |
volatile snd_pcm_shm_ctrl_t *ctrl = shm->ctrl;
|
|
Packit Service |
db8eaa |
int err;
|
|
Packit Service |
db8eaa |
do {
|
|
Packit Service |
db8eaa |
ctrl->cmd = SNDRV_PCM_IOCTL_DRAIN;
|
|
Packit Service |
db8eaa |
err = snd_pcm_shm_action(pcm);
|
|
Packit Service |
db8eaa |
if (err != -EAGAIN)
|
|
Packit Service |
db8eaa |
break;
|
|
Packit Service |
db8eaa |
usleep(10000);
|
|
Packit Service |
db8eaa |
} while (1);
|
|
Packit Service |
db8eaa |
if (err < 0)
|
|
Packit Service |
db8eaa |
return err;
|
|
Packit Service |
db8eaa |
if (!(pcm->mode & SND_PCM_NONBLOCK))
|
|
Packit Service |
db8eaa |
snd_pcm_wait(pcm, -1);
|
|
Packit Service |
db8eaa |
return err;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_pause(snd_pcm_t *pcm, int enable)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_shm_t *shm = pcm->private_data;
|
|
Packit Service |
db8eaa |
volatile snd_pcm_shm_ctrl_t *ctrl = shm->ctrl;
|
|
Packit Service |
db8eaa |
ctrl->cmd = SNDRV_PCM_IOCTL_PAUSE;
|
|
Packit Service |
db8eaa |
ctrl->u.pause.enable = enable;
|
|
Packit Service |
db8eaa |
return snd_pcm_shm_action(pcm);
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static snd_pcm_sframes_t snd_pcm_shm_rewindable(snd_pcm_t *pcm ATTRIBUTE_UNUSED)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
return 0; /* FIX ME */
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static snd_pcm_sframes_t snd_pcm_shm_rewind(snd_pcm_t *pcm, snd_pcm_uframes_t frames)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_shm_t *shm = pcm->private_data;
|
|
Packit Service |
db8eaa |
volatile snd_pcm_shm_ctrl_t *ctrl = shm->ctrl;
|
|
Packit Service |
db8eaa |
ctrl->cmd = SNDRV_PCM_IOCTL_REWIND;
|
|
Packit Service |
db8eaa |
ctrl->u.rewind.frames = frames;
|
|
Packit Service |
db8eaa |
return snd_pcm_shm_action(pcm);
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static snd_pcm_sframes_t snd_pcm_shm_forwardable(snd_pcm_t *pcm ATTRIBUTE_UNUSED)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
return 0; /* FIX ME */
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static snd_pcm_sframes_t snd_pcm_shm_forward(snd_pcm_t *pcm, snd_pcm_uframes_t frames)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_shm_t *shm = pcm->private_data;
|
|
Packit Service |
db8eaa |
volatile snd_pcm_shm_ctrl_t *ctrl = shm->ctrl;
|
|
Packit Service |
db8eaa |
ctrl->cmd = SND_PCM_IOCTL_FORWARD;
|
|
Packit Service |
db8eaa |
ctrl->u.forward.frames = frames;
|
|
Packit Service |
db8eaa |
return snd_pcm_shm_action(pcm);
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_resume(snd_pcm_t *pcm)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_shm_t *shm = pcm->private_data;
|
|
Packit Service |
db8eaa |
volatile snd_pcm_shm_ctrl_t *ctrl = shm->ctrl;
|
|
Packit Service |
db8eaa |
ctrl->cmd = SNDRV_PCM_IOCTL_RESUME;
|
|
Packit Service |
db8eaa |
return snd_pcm_shm_action(pcm);
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static snd_pcm_sframes_t snd_pcm_shm_mmap_commit(snd_pcm_t *pcm,
|
|
Packit Service |
db8eaa |
snd_pcm_uframes_t offset ATTRIBUTE_UNUSED,
|
|
Packit Service |
db8eaa |
snd_pcm_uframes_t size)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_shm_t *shm = pcm->private_data;
|
|
Packit Service |
db8eaa |
volatile snd_pcm_shm_ctrl_t *ctrl = shm->ctrl;
|
|
Packit Service |
db8eaa |
ctrl->cmd = SND_PCM_IOCTL_MMAP_COMMIT;
|
|
Packit Service |
db8eaa |
ctrl->u.mmap_commit.offset = offset;
|
|
Packit Service |
db8eaa |
ctrl->u.mmap_commit.frames = size;
|
|
Packit Service |
db8eaa |
return snd_pcm_shm_action(pcm);
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_poll_descriptor(snd_pcm_t *pcm)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_shm_t *shm = pcm->private_data;
|
|
Packit Service |
db8eaa |
volatile snd_pcm_shm_ctrl_t *ctrl = shm->ctrl;
|
|
Packit Service |
db8eaa |
int fd, err;
|
|
Packit Service |
db8eaa |
ctrl->cmd = SND_PCM_IOCTL_POLL_DESCRIPTOR;
|
|
Packit Service |
db8eaa |
err = snd_pcm_shm_action_fd(pcm, &fd;;
|
|
Packit Service |
db8eaa |
if (err < 0)
|
|
Packit Service |
db8eaa |
return err;
|
|
Packit Service |
db8eaa |
return fd;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int snd_pcm_shm_close(snd_pcm_t *pcm)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_shm_t *shm = pcm->private_data;
|
|
Packit Service |
db8eaa |
volatile snd_pcm_shm_ctrl_t *ctrl = shm->ctrl;
|
|
Packit Service |
db8eaa |
int result;
|
|
Packit Service |
db8eaa |
ctrl->cmd = SND_PCM_IOCTL_CLOSE;
|
|
Packit Service |
db8eaa |
result = snd_pcm_shm_action(pcm);
|
|
Packit Service |
db8eaa |
shmdt((void *)ctrl);
|
|
Packit Service |
db8eaa |
close(shm->socket);
|
|
Packit Service |
db8eaa |
close(pcm->poll_fd);
|
|
Packit Service |
db8eaa |
free(shm);
|
|
Packit Service |
db8eaa |
return result;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static void snd_pcm_shm_dump(snd_pcm_t *pcm, snd_output_t *out)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_output_printf(out, "Shm PCM\n");
|
|
Packit Service |
db8eaa |
if (pcm->setup) {
|
|
Packit Service |
db8eaa |
snd_output_printf(out, "Its setup is:\n");
|
|
Packit Service |
db8eaa |
snd_pcm_dump_setup(pcm, out);
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static const snd_pcm_ops_t snd_pcm_shm_ops = {
|
|
Packit Service |
db8eaa |
.close = snd_pcm_shm_close,
|
|
Packit Service |
db8eaa |
.info = snd_pcm_shm_info,
|
|
Packit Service |
db8eaa |
.hw_refine = snd_pcm_shm_hw_refine,
|
|
Packit Service |
db8eaa |
.hw_params = snd_pcm_shm_hw_params,
|
|
Packit Service |
db8eaa |
.hw_free = snd_pcm_shm_hw_free,
|
|
Packit Service |
db8eaa |
.sw_params = snd_pcm_shm_sw_params,
|
|
Packit Service |
db8eaa |
.channel_info = snd_pcm_shm_channel_info,
|
|
Packit Service |
db8eaa |
.dump = snd_pcm_shm_dump,
|
|
Packit Service |
db8eaa |
.nonblock = snd_pcm_shm_nonblock,
|
|
Packit Service |
db8eaa |
.async = snd_pcm_shm_async,
|
|
Packit Service |
db8eaa |
.mmap = snd_pcm_shm_mmap,
|
|
Packit Service |
db8eaa |
.munmap = snd_pcm_shm_munmap,
|
|
Packit Service |
db8eaa |
};
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static const snd_pcm_fast_ops_t snd_pcm_shm_fast_ops = {
|
|
Packit Service |
db8eaa |
.status = snd_pcm_shm_status,
|
|
Packit Service |
db8eaa |
.state = snd_pcm_shm_state,
|
|
Packit Service |
db8eaa |
.hwsync = snd_pcm_shm_hwsync,
|
|
Packit Service |
db8eaa |
.delay = snd_pcm_shm_delay,
|
|
Packit Service |
db8eaa |
.prepare = snd_pcm_shm_prepare,
|
|
Packit Service |
db8eaa |
.reset = snd_pcm_shm_reset,
|
|
Packit Service |
db8eaa |
.start = snd_pcm_shm_start,
|
|
Packit Service |
db8eaa |
.drop = snd_pcm_shm_drop,
|
|
Packit Service |
db8eaa |
.drain = snd_pcm_shm_drain,
|
|
Packit Service |
db8eaa |
.pause = snd_pcm_shm_pause,
|
|
Packit Service |
db8eaa |
.rewindable = snd_pcm_shm_rewindable,
|
|
Packit Service |
db8eaa |
.rewind = snd_pcm_shm_rewind,
|
|
Packit Service |
db8eaa |
.forwardable = snd_pcm_shm_forwardable,
|
|
Packit Service |
db8eaa |
.forward = snd_pcm_shm_forward,
|
|
Packit Service |
db8eaa |
.resume = snd_pcm_shm_resume,
|
|
Packit Service |
db8eaa |
.writei = snd_pcm_mmap_writei,
|
|
Packit Service |
db8eaa |
.writen = snd_pcm_mmap_writen,
|
|
Packit Service |
db8eaa |
.readi = snd_pcm_mmap_readi,
|
|
Packit Service |
db8eaa |
.readn = snd_pcm_mmap_readn,
|
|
Packit Service |
db8eaa |
.avail_update = snd_pcm_shm_avail_update,
|
|
Packit Service |
db8eaa |
.mmap_commit = snd_pcm_shm_mmap_commit,
|
|
Packit Service |
db8eaa |
.htimestamp = snd_pcm_shm_htimestamp,
|
|
Packit Service |
db8eaa |
};
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
static int make_local_socket(const char *filename)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
size_t l = strlen(filename);
|
|
Packit Service |
db8eaa |
size_t size = offsetof(struct sockaddr_un, sun_path) + l;
|
|
Packit Service |
db8eaa |
struct sockaddr_un *addr = alloca(size);
|
|
Packit Service |
db8eaa |
int sock;
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
sock = socket(PF_LOCAL, SOCK_STREAM, 0);
|
|
Packit Service |
db8eaa |
if (sock < 0) {
|
|
Packit Service |
db8eaa |
SYSERR("socket failed");
|
|
Packit Service |
db8eaa |
return -errno;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
addr->sun_family = AF_LOCAL;
|
|
Packit Service |
db8eaa |
memcpy(addr->sun_path, filename, l);
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
if (connect(sock, (struct sockaddr *) addr, size) < 0) {
|
|
Packit Service |
db8eaa |
SYSERR("connect failed");
|
|
Packit Service |
db8eaa |
return -errno;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
return sock;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
/**
|
|
Packit Service |
db8eaa |
* \brief Creates a new shared memory PCM
|
|
Packit Service |
db8eaa |
* \param pcmp Returns created PCM handle
|
|
Packit Service |
db8eaa |
* \param name Name of PCM
|
|
Packit Service |
db8eaa |
* \param sockname Unix socket name
|
|
Packit Service |
db8eaa |
* \param sname Server name
|
|
Packit Service |
db8eaa |
* \param stream PCM Stream
|
|
Packit Service |
db8eaa |
* \param mode PCM Mode
|
|
Packit Service |
db8eaa |
* \retval zero on success otherwise a negative error code
|
|
Packit Service |
db8eaa |
* \warning Using of this function might be dangerous in the sense
|
|
Packit Service |
db8eaa |
* of compatibility reasons. The prototype might be freely
|
|
Packit Service |
db8eaa |
* changed in future.
|
|
Packit Service |
db8eaa |
*/
|
|
Packit Service |
db8eaa |
int snd_pcm_shm_open(snd_pcm_t **pcmp, const char *name,
|
|
Packit Service |
db8eaa |
const char *sockname, const char *sname,
|
|
Packit Service |
db8eaa |
snd_pcm_stream_t stream, int mode)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_pcm_t *pcm;
|
|
Packit Service |
db8eaa |
snd_pcm_shm_t *shm = NULL;
|
|
Packit Service |
db8eaa |
snd_client_open_request_t *req;
|
|
Packit Service |
db8eaa |
snd_client_open_answer_t ans;
|
|
Packit Service |
db8eaa |
size_t snamelen, reqlen;
|
|
Packit Service |
db8eaa |
int err;
|
|
Packit Service |
db8eaa |
int result;
|
|
Packit Service |
db8eaa |
snd_pcm_shm_ctrl_t *ctrl = NULL;
|
|
Packit Service |
db8eaa |
int sock = -1;
|
|
Packit Service |
db8eaa |
snamelen = strlen(sname);
|
|
Packit Service |
db8eaa |
if (snamelen > 255)
|
|
Packit Service |
db8eaa |
return -EINVAL;
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
result = make_local_socket(sockname);
|
|
Packit Service |
db8eaa |
if (result < 0) {
|
|
Packit Service |
db8eaa |
SNDERR("server for socket %s is not running", sockname);
|
|
Packit Service |
db8eaa |
goto _err;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
sock = result;
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
reqlen = sizeof(*req) + snamelen;
|
|
Packit Service |
db8eaa |
req = alloca(reqlen);
|
|
Packit Service |
db8eaa |
memcpy(req->name, sname, snamelen);
|
|
Packit Service |
db8eaa |
req->dev_type = SND_DEV_TYPE_PCM;
|
|
Packit Service |
db8eaa |
req->transport_type = SND_TRANSPORT_TYPE_SHM;
|
|
Packit Service |
db8eaa |
req->stream = stream;
|
|
Packit Service |
db8eaa |
req->mode = mode;
|
|
Packit Service |
db8eaa |
req->namelen = snamelen;
|
|
Packit Service |
db8eaa |
err = write(sock, req, reqlen);
|
|
Packit Service |
db8eaa |
if (err < 0) {
|
|
Packit Service |
db8eaa |
SYSERR("write error");
|
|
Packit Service |
db8eaa |
result = -errno;
|
|
Packit Service |
db8eaa |
goto _err;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
if ((size_t) err != reqlen) {
|
|
Packit Service |
db8eaa |
SNDERR("write size error");
|
|
Packit Service |
db8eaa |
result = -EINVAL;
|
|
Packit Service |
db8eaa |
goto _err;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
err = read(sock, &ans, sizeof(ans));
|
|
Packit Service |
db8eaa |
if (err < 0) {
|
|
Packit Service |
db8eaa |
SYSERR("read error");
|
|
Packit Service |
db8eaa |
result = -errno;
|
|
Packit Service |
db8eaa |
goto _err;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
if (err != sizeof(ans)) {
|
|
Packit Service |
db8eaa |
SNDERR("read size error");
|
|
Packit Service |
db8eaa |
result = -EINVAL;
|
|
Packit Service |
db8eaa |
goto _err;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
result = ans.result;
|
|
Packit Service |
db8eaa |
if (result < 0)
|
|
Packit Service |
db8eaa |
goto _err;
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
ctrl = shmat(ans.cookie, 0, 0);
|
|
Packit Service |
db8eaa |
if (!ctrl) {
|
|
Packit Service |
db8eaa |
SYSERR("shmat error");
|
|
Packit Service |
db8eaa |
result = -errno;
|
|
Packit Service |
db8eaa |
goto _err;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
shm = calloc(1, sizeof(snd_pcm_shm_t));
|
|
Packit Service |
db8eaa |
if (!shm) {
|
|
Packit Service |
db8eaa |
result = -ENOMEM;
|
|
Packit Service |
db8eaa |
goto _err;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
shm->socket = sock;
|
|
Packit Service |
db8eaa |
shm->ctrl = ctrl;
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
err = snd_pcm_new(&pcm, SND_PCM_TYPE_SHM, name, stream, mode);
|
|
Packit Service |
db8eaa |
if (err < 0) {
|
|
Packit Service |
db8eaa |
result = err;
|
|
Packit Service |
db8eaa |
goto _err;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
pcm->mmap_rw = 1;
|
|
Packit Service |
db8eaa |
pcm->ops = &snd_pcm_shm_ops;
|
|
Packit Service |
db8eaa |
pcm->fast_ops = &snd_pcm_shm_fast_ops;
|
|
Packit Service |
db8eaa |
pcm->private_data = shm;
|
|
Packit Service |
db8eaa |
err = snd_pcm_shm_poll_descriptor(pcm);
|
|
Packit Service |
db8eaa |
if (err < 0) {
|
|
Packit Service |
db8eaa |
snd_pcm_close(pcm);
|
|
Packit Service |
db8eaa |
return err;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
pcm->poll_fd = err;
|
|
Packit Service |
db8eaa |
pcm->poll_events = stream == SND_PCM_STREAM_PLAYBACK ? POLLOUT : POLLIN;
|
|
Packit Service |
db8eaa |
snd_pcm_set_hw_ptr(pcm, &ctrl->hw.ptr, -1, 0);
|
|
Packit Service |
db8eaa |
snd_pcm_set_appl_ptr(pcm, &ctrl->appl.ptr, -1, 0);
|
|
Packit Service |
db8eaa |
*pcmp = pcm;
|
|
Packit Service |
db8eaa |
return 0;
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
_err:
|
|
Packit Service |
db8eaa |
close(sock);
|
|
Packit Service |
db8eaa |
if (ctrl)
|
|
Packit Service |
db8eaa |
shmdt(ctrl);
|
|
Packit Service |
db8eaa |
free(shm);
|
|
Packit Service |
db8eaa |
return result;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
/*! \page pcm_plugins
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
\section pcm_plugins_shm Plugin: shm
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
This plugin communicates with aserver via shared memory. It is a raw
|
|
Packit Service |
db8eaa |
communication without any conversions, but it can be expected worse
|
|
Packit Service |
db8eaa |
performance.
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
\code
|
|
Packit Service |
db8eaa |
pcm.name {
|
|
Packit Service |
db8eaa |
type shm # Shared memory PCM
|
|
Packit Service |
db8eaa |
server STR # Server name
|
|
Packit Service |
db8eaa |
pcm STR # PCM name
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
\endcode
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
\subsection pcm_plugins_shm_funcref Function reference
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
snd_pcm_shm_open()
|
|
Packit Service |
db8eaa |
_snd_pcm_shm_open()
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
*/
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
/**
|
|
Packit Service |
db8eaa |
* \brief Creates a new shm PCM
|
|
Packit Service |
db8eaa |
* \param pcmp Returns created PCM handle
|
|
Packit Service |
db8eaa |
* \param name Name of PCM
|
|
Packit Service |
db8eaa |
* \param root Root configuration node
|
|
Packit Service |
db8eaa |
* \param conf Configuration node with hw PCM description
|
|
Packit Service |
db8eaa |
* \param stream PCM Stream
|
|
Packit Service |
db8eaa |
* \param mode PCM Mode
|
|
Packit Service |
db8eaa |
* \warning Using of this function might be dangerous in the sense
|
|
Packit Service |
db8eaa |
* of compatibility reasons. The prototype might be freely
|
|
Packit Service |
db8eaa |
* changed in future.
|
|
Packit Service |
db8eaa |
*/
|
|
Packit Service |
db8eaa |
int _snd_pcm_shm_open(snd_pcm_t **pcmp, const char *name,
|
|
Packit Service |
db8eaa |
snd_config_t *root, snd_config_t *conf,
|
|
Packit Service |
db8eaa |
snd_pcm_stream_t stream, int mode)
|
|
Packit Service |
db8eaa |
{
|
|
Packit Service |
db8eaa |
snd_config_iterator_t i, next;
|
|
Packit Service |
db8eaa |
const char *server = NULL;
|
|
Packit Service |
db8eaa |
const char *pcm_name = NULL;
|
|
Packit Service |
db8eaa |
snd_config_t *sconfig;
|
|
Packit Service |
db8eaa |
const char *sockname = NULL;
|
|
Packit Service |
db8eaa |
long port = -1;
|
|
Packit Service |
db8eaa |
int err;
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
snd_config_for_each(i, next, conf) {
|
|
Packit Service |
db8eaa |
snd_config_t *n = snd_config_iterator_entry(i);
|
|
Packit Service |
db8eaa |
const char *id;
|
|
Packit Service |
db8eaa |
if (snd_config_get_id(n, &id) < 0)
|
|
Packit Service |
db8eaa |
continue;
|
|
Packit Service |
db8eaa |
if (snd_pcm_conf_generic_id(id))
|
|
Packit Service |
db8eaa |
continue;
|
|
Packit Service |
db8eaa |
if (strcmp(id, "server") == 0) {
|
|
Packit Service |
db8eaa |
err = snd_config_get_string(n, &server);
|
|
Packit Service |
db8eaa |
if (err < 0) {
|
|
Packit Service |
db8eaa |
SNDERR("Invalid type for %s", id);
|
|
Packit Service |
db8eaa |
return -EINVAL;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
continue;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
if (strcmp(id, "pcm") == 0) {
|
|
Packit Service |
db8eaa |
err = snd_config_get_string(n, &pcm_name);
|
|
Packit Service |
db8eaa |
if (err < 0) {
|
|
Packit Service |
db8eaa |
SNDERR("Invalid type for %s", id);
|
|
Packit Service |
db8eaa |
return -EINVAL;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
continue;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
SNDERR("Unknown field %s", id);
|
|
Packit Service |
db8eaa |
return -EINVAL;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
if (!pcm_name) {
|
|
Packit Service |
db8eaa |
SNDERR("pcm is not defined");
|
|
Packit Service |
db8eaa |
return -EINVAL;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
if (!server) {
|
|
Packit Service |
db8eaa |
SNDERR("server is not defined");
|
|
Packit Service |
db8eaa |
return -EINVAL;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
err = snd_config_search_definition(root, "server", server, &sconfig);
|
|
Packit Service |
db8eaa |
if (err < 0) {
|
|
Packit Service |
db8eaa |
SNDERR("Unknown server %s", server);
|
|
Packit Service |
db8eaa |
return -EINVAL;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
if (snd_config_get_type(sconfig) != SND_CONFIG_TYPE_COMPOUND) {
|
|
Packit Service |
db8eaa |
SNDERR("Invalid type for server %s definition", server);
|
|
Packit Service |
db8eaa |
goto _err;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
snd_config_for_each(i, next, sconfig) {
|
|
Packit Service |
db8eaa |
snd_config_t *n = snd_config_iterator_entry(i);
|
|
Packit Service |
db8eaa |
const char *id;
|
|
Packit Service |
db8eaa |
if (snd_config_get_id(n, &id) < 0)
|
|
Packit Service |
db8eaa |
continue;
|
|
Packit Service |
db8eaa |
if (strcmp(id, "comment") == 0)
|
|
Packit Service |
db8eaa |
continue;
|
|
Packit Service |
db8eaa |
if (strcmp(id, "host") == 0)
|
|
Packit Service |
db8eaa |
continue;
|
|
Packit Service |
db8eaa |
if (strcmp(id, "socket") == 0) {
|
|
Packit Service |
db8eaa |
err = snd_config_get_string(n, &sockname);
|
|
Packit Service |
db8eaa |
if (err < 0) {
|
|
Packit Service |
db8eaa |
SNDERR("Invalid type for %s", id);
|
|
Packit Service |
db8eaa |
goto _err;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
continue;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
if (strcmp(id, "port") == 0) {
|
|
Packit Service |
db8eaa |
err = snd_config_get_integer(n, &port);
|
|
Packit Service |
db8eaa |
if (err < 0) {
|
|
Packit Service |
db8eaa |
SNDERR("Invalid type for %s", id);
|
|
Packit Service |
db8eaa |
goto _err;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
continue;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
SNDERR("Unknown field %s", id);
|
|
Packit Service |
db8eaa |
_err:
|
|
Packit Service |
db8eaa |
err = -EINVAL;
|
|
Packit Service |
db8eaa |
goto __error;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
|
|
Packit Service |
db8eaa |
if (!sockname) {
|
|
Packit Service |
db8eaa |
SNDERR("socket is not defined");
|
|
Packit Service |
db8eaa |
goto _err;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
err = snd_pcm_shm_open(pcmp, name, sockname, pcm_name, stream, mode);
|
|
Packit Service |
db8eaa |
__error:
|
|
Packit Service |
db8eaa |
snd_config_delete(sconfig);
|
|
Packit Service |
db8eaa |
return err;
|
|
Packit Service |
db8eaa |
}
|
|
Packit Service |
db8eaa |
#ifndef DOC_HIDDEN
|
|
Packit Service |
db8eaa |
SND_DLSYM_BUILD_VERSION(_snd_pcm_shm_open, SND_PCM_DLSYM_VERSION);
|
|
Packit Service |
db8eaa |
#endif
|