libsent/src/adin/adin_pulseaudio.c

説明を見る。

/*
 * Copyright (c) 2010-2011 Julius project team, Nagoya Institute of Technology
 * All rights reserved
 */

#include <sent/stddefs.h>
#include <sent/adin.h>

#ifdef HAS_PULSEAUDIO
#include <pulse/simple.h>
#include <pulse/error.h>

#define BUFSIZE 512
static pa_simple *s = NULL;
static int srate;
static char name_buf[] = "PulseAudio default device";
#endif

boolean
adin_pulseaudio_standby(int sfreq, void *dummy)
{
#ifndef HAS_PULSEAUDIO
  jlog("Error: PulseAudio not compiled in\n");
  return FALSE;
#else
  srate = sfreq;
  return TRUE;
#endif
}
 
boolean
adin_pulseaudio_begin(char *arg)
{
#ifndef HAS_PULSEAUDIO
  jlog("Error: PulseAudio not compiled in\n");
  return FALSE;
#else
  pa_sample_spec ss;
  int error;

  ss.format = PA_SAMPLE_S16LE;
  ss.rate = srate;
  ss.channels = 1;
  
  if (!(s = pa_simple_new(NULL, "Julius", PA_STREAM_RECORD, NULL, "record", &ss, NULL, NULL, &error))) {
    jlog("Error: adin_pulseaudio: pa_simple_new() failed: %s\n", pa_strerror(error));
    return FALSE;
  }
  return TRUE;
#endif
}

boolean
adin_pulseaudio_end()
{
#ifndef HAS_PULSEAUDIO
  jlog("Error: PulseAudio not compiled in\n");
  return FALSE;
#else
  if (s != NULL) {
    pa_simple_free(s);
    s = NULL;
  }
  return TRUE;
#endif
}

int
adin_pulseaudio_read(SP16 *buf, int sampnum)
{
#ifndef HAS_PULSEAUDIO
  return -2;
#else

  int error;
  int cnt, bufsize;

  bufsize = sampnum * sizeof(SP16);
  if (bufsize > BUFSIZE) bufsize = BUFSIZE;

  if (pa_simple_read(s, buf, bufsize, &error) < 0) {
    jlog("Error: adin_pulseaudio: pa_simple_read() failed: %s\n", pa_strerror(error));
    return (-2);
  }

  cnt = bufsize / sizeof(SP16);

  return(cnt);

#endif
}

char *
adin_pulseaudio_input_name()
{
#ifndef HAS_PULSEAUDIO
  return NULL;
#else
  return(name_buf);
#endif
}