Google
 

Open Sound System
The Hitchhiker's Guide to OSS 4.1 Internals

Do you have problems with sound/audio application development? Don't panic! Click here for help!

vmix_core/vmix_input.c

Virtual mixing audio driver recording routines

Description




This file is part of Open Sound System.

Copyright (C) 4Front Technologies 1996-2008.

This this source file is released under GPL v2 license (no other versions). See the COPYING file included in the main directory of this source distribution for the license terms and conditions.


#define SWAP_SUPPORT
#include <oss_config.h>
#include "vmix.h"

#if 0
/* Debugging macros */
extern unsigned char tmp_status;
# define UP_STATUS(v) OUTB(NULL, (tmp_status=tmp_status|(v)), 0x378)
# define DOWN_STATUS(v) OUTB(NULL, (tmp_status=tmp_status&~(v)), 0x378)
#else
# define UP_STATUS(v)
# define DOWN_STATUS(v)
#endif

#undef SINE_DEBUG

#ifndef CONFIG_OSS_VMIX_FLOAT
#undef SINE_DEBUG
#endif

#ifdef SINE_DEBUG
#define SINE_SIZE	48
static const float sine_table[SINE_SIZE] = {
  0.000000, 0.130526, 0.258819, 0.382683,
  0.500000, 0.608761, 0.707107, 0.793353,
  0.866025, 0.923880, 0.965926, 0.991445,
  1.000000, 0.991445, 0.965926, 0.923880,
  0.866025, 0.793353, 0.707107, 0.608761,
  0.500000, 0.382683, 0.258819, 0.130526,
  0.000000, -0.130526, -0.258819, -0.382683,
  -0.500000, -0.608761, -0.707107, -0.793353,
  -0.866025, -0.923880, -0.965926, -0.991445,
  -1.000000, -0.991445, -0.965926, -0.923880,
  -0.866025, -0.793353, -0.707107, -0.608761,
  -0.500000, -0.382683, -0.258819, -0.130526
};
static int sine_phase[2] = { 0 };
#endif


Recording import functions (from the physical devices)

#undef  INT_IMPORT
#define INT_IMPORT(x) (x * 256)

static void
import16ne (vmix_engine_t * eng, void *inbuf, vmix_sample_t * chbufs[],
	    int channels, int samples)
{
  short *op;
#define SAMPLE_TYPE	short
#define SAMPLE_RANGE	32768.0
#undef VMIX_BYTESWAP
#define VMIX_BYTESWAP(x) x

#include "vmix_import.inc"
}

static void
import16oe (vmix_engine_t * eng, void *inbuf, vmix_sample_t * chbufs[],
	    int channels, int samples)
{
  short *op;
#undef  SAMPLE_TYPE
#undef  SAMPLE_RANGE
#define SAMPLE_TYPE	short
#define SAMPLE_RANGE	32768.0
#undef VMIX_BYTESWAP
#define VMIX_BYTESWAP(x) bswap16(x)

#include "vmix_import.inc"
}

#undef  INT_IMPORT
#define INT_IMPORT(x) (x / 256)

static void
import32ne (vmix_engine_t * eng, void *inbuf, vmix_sample_t * chbufs[],
	    int channels, int samples)
{
  int *op;
#undef  SAMPLE_TYPE
#undef  SAMPLE_RANGE
#define SAMPLE_TYPE	int
#define SAMPLE_RANGE	2147483648.0
#undef VMIX_BYTESWAP
#define VMIX_BYTESWAP(x) x

#include "vmix_import.inc"
}

static void
import32oe (vmix_engine_t * eng, void *inbuf, vmix_sample_t * chbufs[],
	    int channels, int samples)
{
  int *op;
#define SAMPLE_TYPE	int
#define SAMPLE_RANGE	2147483648.0
#undef VMIX_BYTESWAP
#define VMIX_BYTESWAP(x) bswap32(x)

#include "vmix_import.inc"
}


recording export functions to virtual devices

#undef  BUFFER_TYPE
#define BUFFER_TYPE short *

#undef  INT_EXPORT
#define INT_EXPORT(x) (x / 256)

void
vmix_rec_export_16ne (vmix_portc_t * portc, int nsamples)
{
  short *outp;
#undef VMIX_BYTESWAP
#define VMIX_BYTESWAP(x) x
#ifdef CONFIG_OSS_VMIX_FLOAT
  double range = 32767.0;
#endif
#include "rec_export.inc"
}

void
vmix_rec_export_16oe (vmix_portc_t * portc, int nsamples)
{
  short *outp;
#undef VMIX_BYTESWAP
#define VMIX_BYTESWAP(x) bswap16(x)
#ifdef CONFIG_OSS_VMIX_FLOAT
  double range = 32767.0;
#endif
#include "rec_export.inc"
}

#undef BUFFER_TYPE
#define BUFFER_TYPE int *
#undef  INT_EXPORT
#define INT_EXPORT(x) (x * 256)

void
vmix_rec_export_32ne (vmix_portc_t * portc, int nsamples)
{
  int *outp;
#undef VMIX_BYTESWAP
#define VMIX_BYTESWAP(x) x
#ifdef CONFIG_OSS_VMIX_FLOAT
  double range = 2147483647.0;
#endif
#include "rec_export.inc"
}

void
vmix_rec_export_32oe (vmix_portc_t * portc, int nsamples)
{
  int *outp;
#undef VMIX_BYTESWAP
#define VMIX_BYTESWAP(x) bswap32(x)
#ifdef CONFIG_OSS_VMIX_FLOAT
  double range = 2147483647.0;
#endif
#include "rec_export.inc"
}

#ifdef CONFIG_OSS_VMIX_FLOAT
void
vmix_rec_export_float (vmix_portc_t * portc, int nsamples)
{
  float *outp;
#undef BUFFER_TYPE
#define BUFFER_TYPE float *
#undef VMIX_BYTESWAP
#define VMIX_BYTESWAP(x) x
  double range = 1.0;
#include "rec_export.inc"
}
#endif

static void
vmix_record_callback (int dev, int parm)
{
  int i, n;
  int do_input = 0;

  adev_t *adev = audio_engines[dev];
  dmap_t *dmap = adev->dmap_in;
  oss_native_word flags;

  vmix_mixer_t *mixer = adev->vmix_mixer;
  vmix_engine_t *eng = &mixer->record_engine;

#ifdef CONFIG_OSS_VMIX_FLOAT
  fp_env_t fp_buf;
  short *fp_env = fp_buf;
  fp_flags_t fp_flags;
#endif

  if (mixer == NULL) /* Houston, we have a problem. */
     return;


Check if any input applications are active. Skip input processing if it's not needed (to save CPU cycles).


  for (i = 0; i < mixer->num_clientdevs; i++)
    if (mixer->client_portc[i]->trigger_bits & PCM_ENABLE_INPUT)
      do_input = 1;

  if (!do_input) /* Skip all input processing */
     {
	  n = 0;
	  while (n++ < dmap->nfrags
		 && (int) (dmap->byte_counter - dmap->user_counter) >=
		 dmap->fragment_size)
	    {
		  dmap->user_counter += dmap->fragment_size;
	    }
	  return;
     }

  UP_STATUS (0x02);
  MUTEX_ENTER_IRQDISABLE (mixer->mutex, flags);
#ifdef CONFIG_OSS_VMIX_FLOAT
  {

Align the FP save buffer to 16 byte boundary

    oss_native_word p;
    p = (oss_native_word) fp_buf;

    p = ((p + 15ULL) / 16) * 16;
    fp_env = (short *) p;
  }

  FP_SAVE (fp_env, fp_flags);
#endif

  n = 0;
  while (n++ < dmap->nfrags
	 && (int) (dmap->byte_counter - dmap->user_counter) >=
	 dmap->fragment_size)
    {
      int i, p;
      unsigned char *inbuf;

      if (!do_input)
	{

Just skip the recorded data becaus nobody needs it.

	  dmap->user_counter += dmap->fragment_size;
	  continue;
	}

      for (i = 0; i < eng->channels; i++)
	{
	  memset (eng->chbufs[i], 0, CHBUF_SAMPLES * sizeof (vmix_sample_t));
	}

      p = (int) (dmap->user_counter % dmap->bytes_in_use);
      inbuf = dmap->dmabuf + p;

      eng->converter (eng, inbuf, eng->chbufs, eng->channels,
		      eng->samples_per_frag);

      for (i = 0; i < mixer->num_clientdevs; i++)
	{
	  vmix_portc_t *portc = mixer->client_portc[i];

	  if (portc->trigger_bits & PCM_ENABLE_INPUT)
	    {
	      if (portc->rec_mixing_func == NULL)
		continue;
	      if (portc->rec_choffs + portc->channels >
		  mixer->record_engine.channels)
		portc->rec_choffs = 0;
	      portc->rec_mixing_func (portc,
				      mixer->record_engine.samples_per_frag);
	    }
	}

      dmap->user_counter += dmap->fragment_size;
    }

#ifdef CONFIG_OSS_VMIX_FLOAT
  FP_RESTORE (fp_env, fp_flags);
#endif
  MUTEX_EXIT_IRQRESTORE (mixer->mutex, flags);


Call oss_audio_inputintr outside FP mode because it may cause a task switch (under Solaris). Task switch may turn on CR0.TS under x86 which in turn will cause #nm exception.

  for (i = 0; i < mixer->num_clientdevs; i++)
    if (mixer->client_portc[i]->trigger_bits & PCM_ENABLE_INPUT)
      {
	vmix_portc_t *portc = mixer->client_portc[i];
	oss_audio_inputintr (portc->audio_dev, 0);
      }
  DOWN_STATUS (0x02);
}

void
finalize_record_engine (vmix_mixer_t * mixer, int fmt, adev_t * adev,
			dmap_p dmap)
{
  int i;

  switch (fmt)
    {
    case AFMT_S16_NE:
      mixer->record_engine.bits = 16;
      mixer->record_engine.converter = import16ne;
      break;

    case AFMT_S16_OE:
      mixer->record_engine.bits = 16;
      mixer->record_engine.converter = import16oe;
      break;

    case AFMT_S32_NE:
      mixer->record_engine.bits = 32;
      mixer->record_engine.converter = import32ne;
      break;

    case AFMT_S32_OE:
      mixer->record_engine.bits = 32;
      mixer->record_engine.converter = import32oe;
      break;

    default:
      cmn_err (CE_CONT, "Unrecognized recording sample format %x\n", fmt);
      return;
    }

  mixer->record_engine.fragsize = dmap->fragment_size;

  mixer->record_engine.samples_per_frag =
    mixer->record_engine.fragsize / mixer->record_engine.channels /
    (mixer->record_engine.bits / 8);

  if (mixer->record_engine.samples_per_frag > CHBUF_SAMPLES)
    {
      cmn_err (CE_WARN, "Too many samples per fragment (%d,%d)\n",
	       mixer->record_engine.samples_per_frag, CHBUF_SAMPLES);
      return;
    }

  for (i = 0; i < mixer->record_engine.channels; i++)
    if (mixer->record_engine.chbufs[i] == NULL)	/* Not allocated yet */
      {
	mixer->record_engine.chbufs[i] =
	  PMALLOC (mixer->master_osdev,
		   CHBUF_SAMPLES * sizeof (vmix_sample_t));
	if (mixer->record_engine.chbufs[i] == NULL)
	  {
	    cmn_err (CE_WARN, "Out of memory\n");
	    return;
	  }
      }

  dmap->audio_callback = vmix_record_callback;	/* Enable conversions */
  dmap->callback_parm = mixer->instance_num;
  dmap->dma_mode = PCM_ENABLE_INPUT;

  if (mixer->num_clientdevs > 1)
  {
    adev->redirect_out = mixer->client_portc[0]->audio_dev;
    adev->vmix_mixer = mixer;
  }
  vmix_record_callback (mixer->inputdev, mixer->instance_num);
}

void
vmix_setup_record_engine (vmix_mixer_t * mixer, adev_t * adev, dmap_t * dmap)
{
  int fmt;
  int old_min;
  int frags = 0x7fff0007;	/* fragment size of 128 bytes */


Sample format (and endianess) setup


  // First make sure a sane format is selected before starting to probe
  fmt = adev->d->adrv_set_format (mixer->inputdev, AFMT_S16_LE);
  fmt = adev->d->adrv_set_format (mixer->inputdev, AFMT_S16_NE);

  // Find out the "best" sample format supported by the device

  if (adev->iformat_mask & AFMT_S16_OE)
    fmt = AFMT_S16_OE;
  if (adev->iformat_mask & AFMT_S16_NE)
    fmt = AFMT_S16_NE;
  if (mixer->multich_enable)
    {
      if (adev->iformat_mask & AFMT_S32_OE)
	fmt = AFMT_S32_OE;
      if (adev->iformat_mask & AFMT_S32_NE)
	fmt = AFMT_S32_NE;
    }

  fmt = adev->d->adrv_set_format (mixer->inputdev, fmt);
  mixer->record_engine.fmt = fmt;


Number of channels

  mixer->record_engine.channels = mixer->max_channels;

  if (mixer->record_engine.channels > MAX_REC_CHANNELS)
     mixer->record_engine.channels = MAX_REC_CHANNELS;

  if (!mixer->multich_enable)
    mixer->record_engine.channels = 2;

  /* Force the device to stereo before trying with (possibly) imultiple channels */
  adev->d->adrv_set_channels (mixer->inputdev, 2);

  mixer->record_engine.channels = 
    adev->d->adrv_set_channels (mixer->inputdev,
				mixer->record_engine.channels);

  if (mixer->record_engine.channels > MAX_REC_CHANNELS)
    {
      cmn_err (CE_WARN,
	       "Number of channels (%d) is larger than maximum (%d)\n",
	       mixer->record_engine.channels, MAX_REC_CHANNELS);
      return;
    }


Try to set the same rate than for playback.

  mixer->record_engine.rate =
    oss_audio_set_rate (mixer->inputdev, mixer->play_engine.rate);

  if (mixer->record_engine.rate <= 22050)
    frags = 0x7fff0004;		/* Use smaller fragments */

  audio_engines[mixer->inputdev]->hw_parms.channels =
    mixer->record_engine.channels;
  audio_engines[mixer->inputdev]->hw_parms.rate = mixer->record_engine.rate;
  audio_engines[mixer->inputdev]->dmap_in->data_rate =
    mixer->record_engine.rate * mixer->record_engine.channels *
    mixer->record_engine.bits / 8;
  audio_engines[mixer->inputdev]->dmap_in->frame_size =
    mixer->record_engine.channels * mixer->record_engine.bits / 8;

  old_min = adev->min_fragments;

#if 0
  if ((adev->max_fragments == 0 || adev->max_fragments >= 4)
      && adev->min_block == 0)
    adev->min_fragments = 4;
#endif

  oss_audio_ioctl (mixer->inputdev, NULL, SNDCTL_DSP_SETFRAGMENT,
		   (ioctl_arg) & frags);
  oss_audio_ioctl (mixer->inputdev, NULL, SNDCTL_DSP_GETBLKSIZE,
		   (ioctl_arg) & mixer->record_engine.fragsize);

  dmap->bytes_in_use = dmap->fragment_size * dmap->nfrags;

  oss_audio_ioctl (mixer->inputdev, NULL, SNDCTL_DSP_GETBLKSIZE,
		   (ioctl_arg) & mixer->record_engine.fragsize);
  mixer->record_engine.fragsize = dmap->fragment_size;
  adev->min_fragments = old_min;

  if (mixer->record_engine.channels > 2)
    {
      DDB (cmn_err
	   (CE_CONT, "Enabling multi channel rec mode, %d hw channels\n",
	    mixer->record_engine.channels));
    }
  else if (mixer->record_engine.channels != 2)
    {
      cmn_err (CE_WARN,
	       "Master device doesn't support suitable channel configuration\n");

      return;
    }

  finalize_record_engine (mixer, fmt, adev, dmap);
}

Copyright (C) 4Front Technologies, 2007. All rights reserved.

Back to index OSS web site


Copyright (C) 4Front Technologies, 2007. All rights reserved.
Back to index OSS web site