audin_sndio.c

 
#include <freerdp/config.h>
 
#include <sndio.h>
 
#include <winpr/cmdline.h>
 
#include <freerdp/freerdp.h>
#include <freerdp/channels/rdpsnd.h>
 
#include "audin_main.h"
 
typedef struct
{
  IAudinDevice device;
 
  HANDLE thread;
  HANDLE stopEvent;
 
  AUDIO_FORMAT format;
  UINT32 FramesPerPacket;
 
  AudinReceive receive;
  void* user_data;
 
  rdpContext* rdpcontext;
} AudinSndioDevice;
 
static BOOL audin_sndio_format_supported(IAudinDevice* device, const AUDIO_FORMAT* format)
{
  if (device == nullptr || format == nullptr)
    return FALSE;
 
  return (format->wFormatTag == WAVE_FORMAT_PCM);
}
 
static UINT audin_sndio_set_format(IAudinDevice* device, const AUDIO_FORMAT* format,
                                   UINT32 FramesPerPacket)
{
  AudinSndioDevice* sndio = (AudinSndioDevice*)device;
 
  if (device == nullptr || format == nullptr)
    return ERROR_INVALID_PARAMETER;
 
  if (format->wFormatTag != WAVE_FORMAT_PCM)
    return ERROR_INTERNAL_ERROR;
 
  sndio->format = *format;
  sndio->FramesPerPacket = FramesPerPacket;
 
  return CHANNEL_RC_OK;
}
 
static DWORD WINAPI audin_sndio_thread_func(LPVOID arg)
{
  struct sio_hdl* hdl = nullptr;
  struct sio_par par = WINPR_C_ARRAY_INIT;
  BYTE* buffer = nullptr;
  AudinSndioDevice* sndio = (AudinSndioDevice*)arg;
  UINT error = CHANNEL_RC_OK;
 
  if (arg == nullptr)
  {
    error = ERROR_INVALID_PARAMETER;
    goto err_out;
  }
 
  hdl = sio_open(SIO_DEVANY, SIO_REC, 0);
  if (hdl == nullptr)
  {
    WLog_ERR(TAG, "could not open audio device");
    error = ERROR_INTERNAL_ERROR;
    goto err_out;
  }
 
  sio_initpar(&par);
  par.bits = sndio->format.wBitsPerSample;
  par.rchan = sndio->format.nChannels;
  par.rate = sndio->format.nSamplesPerSec;
  if (!sio_setpar(hdl, &par))
  {
    WLog_ERR(TAG, "could not set audio parameters");
    error = ERROR_INTERNAL_ERROR;
    goto err_out;
  }
  if (!sio_getpar(hdl, &par))
  {
    WLog_ERR(TAG, "could not get audio parameters");
    error = ERROR_INTERNAL_ERROR;
    goto err_out;
  }
 
  if (!sio_start(hdl))
  {
    WLog_ERR(TAG, "could not start audio device");
    error = ERROR_INTERNAL_ERROR;
    goto err_out;
  }
 
  const size_t nbytes = (1ull * sndio->FramesPerPacket * sndio->format.nChannels *
                         (sndio->format.wBitsPerSample / 8));
  if (nbytes > INT32_MAX)
    goto err_out;
 
  buffer = (BYTE*)calloc((nbytes + sizeof(void*)), sizeof(BYTE));
 
  if (buffer == nullptr)
  {
    error = ERROR_NOT_ENOUGH_MEMORY;
    goto err_out;
  }
 
  while (1)
  {
    const DWORD status = WaitForSingleObject(sndio->stopEvent, 0);
 
    if (status == WAIT_FAILED)
    {
      error = GetLastError();
      WLog_ERR(TAG, "WaitForSingleObject failed with error %" PRIu32 "", error);
      goto err_out;
    }
 
    if (status == WAIT_OBJECT_0)
      break;
 
    const size_t n = sio_read(hdl, buffer, nbytes);
 
    if (n == 0)
    {
      WLog_ERR(TAG, "could not read");
      continue;
    }
 
    if (n < nbytes)
      continue;
 
    if ((error = sndio->receive(&sndio->format, buffer, nbytes, sndio->user_data)))
    {
      WLog_ERR(TAG, "sndio->receive failed with error %" PRIu32 "", error);
      break;
    }
  }
 
err_out:
  if (error && sndio && sndio->rdpcontext)
    setChannelError(sndio->rdpcontext, error, "audin_sndio_thread_func reported an error");
 
  if (hdl != nullptr)
  {
    WLog_INFO(TAG, "sio_close");
    sio_stop(hdl);
    sio_close(hdl);
  }
 
  free(buffer);
  return 0;
}
 
static UINT audin_sndio_open(IAudinDevice* device, AudinReceive receive, void* user_data)
{
  AudinSndioDevice* sndio = (AudinSndioDevice*)device;
  sndio->receive = receive;
  sndio->user_data = user_data;
 
  if (!(sndio->stopEvent = CreateEvent(nullptr, TRUE, FALSE, nullptr)))
  {
    WLog_ERR(TAG, "CreateEvent failed");
    return ERROR_INTERNAL_ERROR;
  }
 
  if (!(sndio->thread = CreateThread(nullptr, 0, audin_sndio_thread_func, sndio, 0, nullptr)))
  {
    WLog_ERR(TAG, "CreateThread failed");
    (void)CloseHandle(sndio->stopEvent);
    sndio->stopEvent = nullptr;
    return ERROR_INTERNAL_ERROR;
  }
 
  return CHANNEL_RC_OK;
}
 
static UINT audin_sndio_close(IAudinDevice* device)
{
  AudinSndioDevice* sndio = (AudinSndioDevice*)device;
 
  if (device == nullptr)
    return ERROR_INVALID_PARAMETER;
 
  if (sndio->stopEvent != nullptr)
  {
    (void)SetEvent(sndio->stopEvent);
 
    if (WaitForSingleObject(sndio->thread, INFINITE) == WAIT_FAILED)
    {
      const UINT error = GetLastError();
      WLog_ERR(TAG, "WaitForSingleObject failed with error %" PRIu32 "", error);
      return error;
    }
 
    (void)CloseHandle(sndio->stopEvent);
    sndio->stopEvent = nullptr;
    (void)CloseHandle(sndio->thread);
    sndio->thread = nullptr;
  }
 
  sndio->receive = nullptr;
  sndio->user_data = nullptr;
 
  return CHANNEL_RC_OK;
}
 
static UINT audin_sndio_free(IAudinDevice* device)
{
  AudinSndioDevice* sndio = (AudinSndioDevice*)device;
 
  if (device == nullptr)
    return ERROR_INVALID_PARAMETER;
 
  const UINT error = audin_sndio_close(device);
  if (error != CHANNEL_RC_OK)
  {
    WLog_ERR(TAG, "audin_sndio_close failed with error code %" PRIu32, error);
  }
 
  free(sndio);
 
  return CHANNEL_RC_OK;
}
 
static UINT audin_sndio_parse_addin_args(AudinSndioDevice* sndio, const ADDIN_ARGV* args)
{
  WINPR_ASSERT(sndio);
 
  COMMAND_LINE_ARGUMENT_A audin_sndio_args[] = { { nullptr, 0, nullptr, nullptr, nullptr, -1,
                                                 nullptr, nullptr } };
  const DWORD flags =
      COMMAND_LINE_SIGIL_NONE | COMMAND_LINE_SEPARATOR_COLON | COMMAND_LINE_IGN_UNKNOWN_KEYWORD;
  const int status = CommandLineParseArgumentsA(args->argc, args->argv, audin_sndio_args, flags,
                                                sndio, nullptr, nullptr);
 
  if (status < 0)
    return ERROR_INVALID_PARAMETER;
 
  const COMMAND_LINE_ARGUMENT_A* arg = audin_sndio_args;
 
  do
  {
    if (!(arg->Flags & COMMAND_LINE_VALUE_PRESENT))
      continue;
 
    CommandLineSwitchStart(arg) CommandLineSwitchEnd(arg)
  } while ((arg = CommandLineFindNextArgumentA(arg)) != nullptr);
 
  return CHANNEL_RC_OK;
}
 
FREERDP_ENTRY_POINT(UINT VCAPITYPE sndio_freerdp_audin_client_subsystem_entry(
    PFREERDP_AUDIN_DEVICE_ENTRY_POINTS pEntryPoints))
{
  UINT ret = CHANNEL_RC_OK;
  AudinSndioDevice* sndio = (AudinSndioDevice*)calloc(1, sizeof(AudinSndioDevice));
 
  if (sndio == nullptr)
    return CHANNEL_RC_NO_MEMORY;
 
  sndio->device.Open = audin_sndio_open;
  sndio->device.FormatSupported = audin_sndio_format_supported;
  sndio->device.SetFormat = audin_sndio_set_format;
  sndio->device.Close = audin_sndio_close;
  sndio->device.Free = audin_sndio_free;
  sndio->rdpcontext = pEntryPoints->rdpcontext;
  const ADDIN_ARGV* args = pEntryPoints->args;
 
  if (args->argc > 1)
  {
    ret = audin_sndio_parse_addin_args(sndio, args);
 
    if (ret != CHANNEL_RC_OK)
    {
      WLog_ERR(TAG, "error parsing arguments");
      goto error;
    }
  }
 
  if ((ret = pEntryPoints->pRegisterAudinDevice(pEntryPoints->plugin, (IAudinDevice*)sndio)))
  {
    WLog_ERR(TAG, "RegisterAudinDevice failed with error %" PRIu32 "", ret);
    goto error;
  }
 
  return ret;
error:
  audin_sndio_free(&sndio->device);
  return ret;
}