tsmf_oss.c

 
#include <freerdp/config.h>
 
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
 
#include <winpr/crt.h>
 
#include <err.h>
#include <errno.h>
#include <fcntl.h>
#include <libgen.h>
#include <limits.h>
#if defined(__OpenBSD__)
#include <soundcard.h>
#else
#include <sys/soundcard.h>
#endif
#include <sys/ioctl.h>
 
#include <freerdp/types.h>
#include <freerdp/codec/dsp.h>
 
#include "tsmf_audio.h"
 
typedef struct
{
  ITSMFAudioDevice iface;
 
  char dev_name[PATH_MAX];
  int pcm_handle;
 
  UINT32 sample_rate;
  UINT32 channels;
  UINT32 bits_per_sample;
 
  UINT32 data_size_last;
} TSMFOssAudioDevice;
 
#define OSS_LOG_ERR(_text, _error)                                        \
  do                                                                    \
  {                                                                     \
    if ((_error) != 0)                                                \
    {                                                                 \
      char ebuffer[256] = { 0 };                                    \
      WLog_ERR(TAG, "%s: %i - %s", (_text), (_error),               \
               winpr_strerror((_error), ebuffer, sizeof(ebuffer))); \
    }                                                                 \
  } while (0)
 
static BOOL tsmf_oss_open(ITSMFAudioDevice* audio, const char* device)
{
  int tmp = 0;
  TSMFOssAudioDevice* oss = (TSMFOssAudioDevice*)audio;
 
  if (oss == NULL || oss->pcm_handle != -1)
    return FALSE;
 
  if (device == NULL) /* Default device. */
  {
    strncpy(oss->dev_name, "/dev/dsp", sizeof(oss->dev_name));
  }
  else
  {
    strncpy(oss->dev_name, device, sizeof(oss->dev_name) - 1);
  }
 
  if ((oss->pcm_handle = open(oss->dev_name, O_WRONLY)) < 0)
  {
    OSS_LOG_ERR("sound dev open failed", errno);
    oss->pcm_handle = -1;
    return FALSE;
  }
 
  const int rc = ioctl(oss->pcm_handle, SNDCTL_DSP_GETFMTS, &tmp);
  if (rc == -1)
  {
    OSS_LOG_ERR("SNDCTL_DSP_GETFMTS failed", errno);
    close(oss->pcm_handle);
    oss->pcm_handle = -1;
    return FALSE;
  }
 
  if ((AFMT_S16_LE & tmp) == 0)
  {
    OSS_LOG_ERR("SNDCTL_DSP_GETFMTS - AFMT_S16_LE", EOPNOTSUPP);
    close(oss->pcm_handle);
    oss->pcm_handle = -1;
    return FALSE;
  }
 
  WLog_INFO(TAG, "open: %s", oss->dev_name);
  return TRUE;
}
 
static BOOL tsmf_oss_set_format(ITSMFAudioDevice* audio, UINT32 sample_rate, UINT32 channels,
                                UINT32 bits_per_sample)
{
  int tmp = 0;
  TSMFOssAudioDevice* oss = (TSMFOssAudioDevice*)audio;
 
  if (oss == NULL || oss->pcm_handle == -1)
    return FALSE;
 
  oss->sample_rate = sample_rate;
  oss->channels = channels;
  oss->bits_per_sample = bits_per_sample;
  tmp = AFMT_S16_LE;
 
  if (ioctl(oss->pcm_handle, SNDCTL_DSP_SETFMT, &tmp) == -1)
    OSS_LOG_ERR("SNDCTL_DSP_SETFMT failed", errno);
 
  tmp = WINPR_ASSERTING_INT_CAST(int, channels);
 
  if (ioctl(oss->pcm_handle, SNDCTL_DSP_CHANNELS, &tmp) == -1)
    OSS_LOG_ERR("SNDCTL_DSP_CHANNELS failed", errno);
 
  tmp = WINPR_ASSERTING_INT_CAST(int, sample_rate);
 
  if (ioctl(oss->pcm_handle, SNDCTL_DSP_SPEED, &tmp) == -1)
    OSS_LOG_ERR("SNDCTL_DSP_SPEED failed", errno);
 
  tmp = WINPR_ASSERTING_INT_CAST(int, ((bits_per_sample / 8) * channels * sample_rate));
 
  if (ioctl(oss->pcm_handle, SNDCTL_DSP_SETFRAGMENT, &tmp) == -1)
    OSS_LOG_ERR("SNDCTL_DSP_SETFRAGMENT failed", errno);
 
  DEBUG_TSMF("sample_rate %" PRIu32 " channels %" PRIu32 " bits_per_sample %" PRIu32 "",
             sample_rate, channels, bits_per_sample);
  return TRUE;
}
 
static BOOL tsmf_oss_play(ITSMFAudioDevice* audio, const BYTE* data, UINT32 data_size)
{
  UINT32 offset = 0;
  TSMFOssAudioDevice* oss = (TSMFOssAudioDevice*)audio;
  DEBUG_TSMF("tsmf_oss_play: data_size %" PRIu32 "", data_size);
 
  if (oss == NULL || oss->pcm_handle == -1)
    return FALSE;
 
  if (data == NULL || data_size == 0)
    return TRUE;
 
  offset = 0;
  oss->data_size_last = data_size;
 
  while (offset < data_size)
  {
    const ssize_t status = write(oss->pcm_handle, &data[offset], (data_size - offset));
 
    if (status < 0)
    {
      OSS_LOG_ERR("write fail", errno);
      return FALSE;
    }
 
    offset += status;
  }
 
  return TRUE;
}
 
static UINT64 tsmf_oss_get_latency(ITSMFAudioDevice* audio)
{
  UINT64 latency = 0;
  TSMFOssAudioDevice* oss = (TSMFOssAudioDevice*)audio;
 
  if (oss == NULL)
    return 0;
 
  // latency = ((oss->data_size_last / (oss->bits_per_sample / 8)) * oss->sample_rate);
  // WLog_INFO(TAG, "latency: %zu", latency);
  return latency;
}
 
static BOOL tsmf_oss_flush(ITSMFAudioDevice* audio)
{
  return TRUE;
}
 
static void tsmf_oss_free(ITSMFAudioDevice* audio)
{
  TSMFOssAudioDevice* oss = (TSMFOssAudioDevice*)audio;
 
  if (oss == NULL)
    return;
 
  if (oss->pcm_handle != -1)
  {
    WLog_INFO(TAG, "close: %s", oss->dev_name);
    close(oss->pcm_handle);
  }
 
  free(oss);
}
 
FREERDP_ENTRY_POINT(UINT VCAPITYPE oss_freerdp_tsmf_client_audio_subsystem_entry(void* ptr))
{
  ITSMFAudioDevice** sptr = (ITSMFAudioDevice**)ptr;
  WINPR_ASSERT(sptr);
  *sptr = NULL;
 
  TSMFOssAudioDevice* oss = calloc(1, sizeof(TSMFOssAudioDevice));
  if (!oss)
    return ERROR_OUTOFMEMORY;
 
  oss->iface.Open = tsmf_oss_open;
  oss->iface.SetFormat = tsmf_oss_set_format;
  oss->iface.Play = tsmf_oss_play;
  oss->iface.GetLatency = tsmf_oss_get_latency;
  oss->iface.Flush = tsmf_oss_flush;
  oss->iface.Free = tsmf_oss_free;
  oss->pcm_handle = -1;
  *sptr = &oss->iface;
  return CHANNEL_RC_OK;
}