fluid_alsa.c
上传用户:tjmskj2
上传日期:2020-08-17
资源大小:577k
文件大小:28k
源码类别:

midi

开发平台:

C/C++

  1. /* FluidSynth - A Software Synthesizer
  2.  *
  3.  * Copyright (C) 2003  Peter Hanappe and others.
  4.  *
  5.  * This library is free software; you can redistribute it and/or
  6.  * modify it under the terms of the GNU Library General Public License
  7.  * as published by the Free Software Foundation; either version 2 of
  8.  * the License, or (at your option) any later version.
  9.  *
  10.  * This library is distributed in the hope that it will be useful, but
  11.  * WITHOUT ANY WARRANTY; without even the implied warranty of
  12.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  13.  * Library General Public License for more details.
  14.  *
  15.  * You should have received a copy of the GNU Library General Public
  16.  * License along with this library; if not, write to the Free
  17.  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA
  18.  * 02111-1307, USA
  19.  */
  20. /* fluid_alsa.c
  21.  *
  22.  * Driver for the Advanced Linux Sound Architecture
  23.  *
  24.  */
  25. #include "fluid_synth.h"
  26. #include "fluid_midi.h"
  27. #include "fluid_adriver.h"
  28. #include "fluid_mdriver.h"
  29. #include "fluid_settings.h"
  30. #if ALSA_SUPPORT
  31. #define ALSA_PCM_NEW_HW_PARAMS_API
  32. #include <alsa/asoundlib.h>
  33. #include <fcntl.h>
  34. #include <unistd.h>
  35. #include <errno.h>
  36. #include <sys/poll.h>
  37. #include "config.h"
  38. #include "fluid_lash.h"
  39. #define FLUID_ALSA_DEFAULT_MIDI_DEVICE  "default"
  40. #define FLUID_ALSA_DEFAULT_SEQ_DEVICE   "default"
  41. #define BUFFER_LENGTH 512
  42. /** fluid_alsa_audio_driver_t
  43.  *
  44.  * This structure should not be accessed directly. Use audio port
  45.  * functions instead.
  46.  */
  47. typedef struct {
  48.   fluid_audio_driver_t driver;
  49.   snd_pcm_t* pcm;
  50.   fluid_audio_func_t callback;
  51.   void* data;
  52.   int buffer_size;
  53.   fluid_thread_t *thread;
  54.   int cont;
  55. } fluid_alsa_audio_driver_t;
  56. fluid_audio_driver_t* new_fluid_alsa_audio_driver(fluid_settings_t* settings,
  57.   fluid_synth_t* synth);
  58. fluid_audio_driver_t* new_fluid_alsa_audio_driver2(fluid_settings_t* settings,
  59.    fluid_audio_func_t func, void* data);
  60. int delete_fluid_alsa_audio_driver(fluid_audio_driver_t* p);
  61. void fluid_alsa_audio_driver_settings(fluid_settings_t* settings);
  62. static void fluid_alsa_audio_run_float(void* d);
  63. static void fluid_alsa_audio_run_s16(void* d);
  64. struct fluid_alsa_formats_t {
  65.   char* name;
  66.   snd_pcm_format_t format;
  67.   snd_pcm_access_t access;
  68.   fluid_thread_func_t run;
  69. };
  70. struct fluid_alsa_formats_t fluid_alsa_formats[] = {
  71.   { "s16, rw, interleaved",
  72.     SND_PCM_FORMAT_S16,
  73.     SND_PCM_ACCESS_RW_INTERLEAVED,
  74.     fluid_alsa_audio_run_s16 },
  75.   { "float, rw, non interleaved",
  76.     SND_PCM_FORMAT_FLOAT,
  77.     SND_PCM_ACCESS_RW_NONINTERLEAVED,
  78.     fluid_alsa_audio_run_float },
  79.   { NULL, 0, 0, NULL }
  80. };
  81. /*
  82.  * fluid_alsa_rawmidi_driver_t
  83.  *
  84.  */
  85. typedef struct {
  86.   fluid_midi_driver_t driver;
  87.   snd_rawmidi_t *rawmidi_in;
  88.   struct pollfd *pfd;
  89.   int npfd;
  90.   fluid_thread_t *thread;
  91.   int status;
  92.   unsigned char buffer[BUFFER_LENGTH];
  93.   fluid_midi_parser_t* parser;
  94. } fluid_alsa_rawmidi_driver_t;
  95. fluid_midi_driver_t* new_fluid_alsa_rawmidi_driver(fluid_settings_t* settings,
  96.    handle_midi_event_func_t handler,
  97.    void* event_handler_data);
  98. int delete_fluid_alsa_rawmidi_driver(fluid_midi_driver_t* p);
  99. static void fluid_alsa_midi_run(void* d);
  100. /*
  101.  * fluid_alsa_seq_driver_t
  102.  *
  103.  */
  104. typedef struct {
  105.   fluid_midi_driver_t driver;
  106.   snd_seq_t *seq_handle;
  107.   struct pollfd *pfd;
  108.   int npfd;
  109.   fluid_thread_t *thread;
  110.   int status;
  111.   int port_count;
  112. } fluid_alsa_seq_driver_t;
  113. fluid_midi_driver_t* new_fluid_alsa_seq_driver(fluid_settings_t* settings,
  114.      handle_midi_event_func_t handler,
  115.      void* data);
  116. int delete_fluid_alsa_seq_driver(fluid_midi_driver_t* p);
  117. static void fluid_alsa_seq_run(void* d);
  118. /**************************************************************
  119.  *
  120.  *        Alsa audio driver
  121.  *
  122.  */
  123. void fluid_alsa_audio_driver_settings(fluid_settings_t* settings)
  124. {
  125.   fluid_settings_register_str(settings, "audio.alsa.device", "default", 0, NULL, NULL);
  126. }
  127. fluid_audio_driver_t*
  128. new_fluid_alsa_audio_driver(fluid_settings_t* settings,
  129.     fluid_synth_t* synth)
  130. {
  131.   return new_fluid_alsa_audio_driver2(settings, NULL, synth);
  132. }
  133. fluid_audio_driver_t*
  134. new_fluid_alsa_audio_driver2(fluid_settings_t* settings,
  135.      fluid_audio_func_t func, void* data)
  136. {
  137.   fluid_alsa_audio_driver_t* dev;
  138.   double sample_rate;
  139.   int periods, period_size;
  140.   char* device = NULL;
  141.   int realtime_prio = 0;
  142.   int i, err, dir = 0;
  143.   snd_pcm_hw_params_t* hwparams;
  144.   snd_pcm_sw_params_t* swparams = NULL;
  145.   snd_pcm_uframes_t uframes;
  146.   unsigned int tmp;
  147.   dev = FLUID_NEW(fluid_alsa_audio_driver_t);
  148.   if (dev == NULL) {
  149.     FLUID_LOG(FLUID_ERR, "Out of memory");
  150.     return NULL;
  151.   }
  152.   FLUID_MEMSET(dev, 0, sizeof(fluid_alsa_audio_driver_t));
  153.   fluid_settings_getint(settings, "audio.periods", &periods);
  154.   fluid_settings_getint(settings, "audio.period-size", &period_size);
  155.   fluid_settings_getnum(settings, "synth.sample-rate", &sample_rate);
  156.   fluid_settings_dupstr(settings, "audio.alsa.device", &device);   /* ++ dup device name */
  157.   fluid_settings_getint (settings, "audio.realtime-prio", &realtime_prio);
  158.   dev->data = data;
  159.   dev->callback = func;
  160.   dev->cont = 1;
  161.   dev->buffer_size = period_size;
  162.   /* Open the PCM device */
  163.   if ((err = snd_pcm_open(&dev->pcm, device ? device : "default",
  164.                           SND_PCM_STREAM_PLAYBACK, SND_PCM_NONBLOCK)) != 0) {
  165.     if (err == -EBUSY) {
  166.       FLUID_LOG(FLUID_ERR, "The "%s" audio device is used by another application",
  167.                 device ? device : "default");
  168.       goto error_recovery;
  169.     } else {
  170.       FLUID_LOG(FLUID_ERR, "Failed to open the "%s" audio device",
  171.                 device ? device : "default");
  172.       goto error_recovery;
  173.     }
  174.   }
  175.   snd_pcm_hw_params_alloca(&hwparams);
  176.   snd_pcm_sw_params_alloca(&swparams);
  177.   /* Set hardware parameters. We continue trying access methods and
  178.      sample formats until we have one that works. For example, if
  179.      memory mapped access fails we try regular IO methods. (not
  180.      finished, yet). */
  181.   for (i = 0; fluid_alsa_formats[i].name != NULL; i++) {
  182.     snd_pcm_hw_params_any(dev->pcm, hwparams);
  183.     if (snd_pcm_hw_params_set_access(dev->pcm, hwparams, fluid_alsa_formats[i].access) < 0) {
  184.       continue;
  185.     }
  186.     if (snd_pcm_hw_params_set_format(dev->pcm, hwparams, fluid_alsa_formats[i].format) < 0) {
  187.       continue;
  188.     }
  189.     if ((err = snd_pcm_hw_params_set_channels(dev->pcm, hwparams, 2)) < 0) {
  190.       FLUID_LOG(FLUID_ERR, "Failed to set the channels: %s",
  191. snd_strerror (err));
  192.       goto error_recovery;
  193.     }
  194.     tmp = (unsigned int) sample_rate;
  195.     if ((err = snd_pcm_hw_params_set_rate_near(dev->pcm, hwparams, &tmp, NULL)) < 0) {
  196.       FLUID_LOG(FLUID_ERR, "Failed to set the sample rate: %s",
  197. snd_strerror (err));
  198.       goto error_recovery;
  199.     }
  200.     if (tmp != sample_rate) {
  201.       /* There's currently no way to change the sampling rate of the
  202.  synthesizer after it's been created. */
  203.       FLUID_LOG(FLUID_WARN, "Requested sample rate of %d, got %d instead, "
  204. "synthesizer likely out of tune!", (unsigned int) sample_rate, tmp);
  205.     }
  206.     uframes = period_size;
  207.     if (snd_pcm_hw_params_set_period_size_near(dev->pcm, hwparams, &uframes, &dir) < 0) {
  208.       FLUID_LOG(FLUID_ERR, "Failed to set the period size");
  209.       goto error_recovery;
  210.     }
  211.     if (uframes != (unsigned long) period_size) {
  212.       FLUID_LOG(FLUID_WARN, "Requested a period size of %d, got %d instead",
  213. period_size, (int) uframes);
  214.       dev->buffer_size = (int) uframes;
  215.       period_size = uframes; /* period size is used below, so set it to the real value */
  216.     }
  217.     tmp = periods;
  218.     if (snd_pcm_hw_params_set_periods_near(dev->pcm, hwparams, &tmp, &dir) < 0) {
  219.       FLUID_LOG(FLUID_ERR, "Failed to set the number of periods");
  220.       goto error_recovery;
  221.     }
  222.     if (tmp != (unsigned int) periods) {
  223.       FLUID_LOG(FLUID_WARN, "Requested %d periods, got %d instead",
  224. periods, (int) tmp);
  225.     }
  226.     if (snd_pcm_hw_params(dev->pcm, hwparams) < 0) {
  227.       FLUID_LOG(FLUID_WARN, "Audio device hardware configuration failed");
  228.       continue;
  229.     }
  230.     break;
  231.   }
  232.   if (fluid_alsa_formats[i].name == NULL) {
  233.     FLUID_LOG(FLUID_ERR, "Failed to find a workable audio format");
  234.     goto error_recovery;
  235.   }
  236.   /* Set the software params */
  237.   snd_pcm_sw_params_current(dev->pcm, swparams);
  238.   if (snd_pcm_sw_params_set_start_threshold(dev->pcm, swparams, period_size) != 0) {
  239.     FLUID_LOG(FLUID_ERR, "Failed to set start threshold.");
  240.   }
  241.   if (snd_pcm_sw_params_set_avail_min(dev->pcm, swparams, period_size) != 0) {
  242.     FLUID_LOG(FLUID_ERR, "Software setup for minimum available frames failed.");
  243.   }
  244.   if (snd_pcm_sw_params(dev->pcm, swparams) != 0) {
  245.     FLUID_LOG(FLUID_ERR, "Software setup failed.");
  246.   }
  247.   if (snd_pcm_nonblock(dev->pcm, 0) != 0) {
  248.     FLUID_LOG(FLUID_ERR, "Failed to set the audio device to blocking mode");
  249.     goto error_recovery;
  250.   }
  251.   /* Create the audio thread */
  252.   dev->thread = new_fluid_thread (fluid_alsa_formats[i].run, dev, realtime_prio, FALSE);
  253.   if (!dev->thread)
  254.     goto error_recovery;
  255.   if (device) FLUID_FREE (device);      /* -- free device name */
  256.   return (fluid_audio_driver_t*) dev;
  257.  error_recovery:
  258.   if (device) FLUID_FREE (device);      /* -- free device name */
  259.   delete_fluid_alsa_audio_driver((fluid_audio_driver_t*) dev);
  260.   return NULL;
  261. }
  262. int delete_fluid_alsa_audio_driver(fluid_audio_driver_t* p)
  263. {
  264.   fluid_alsa_audio_driver_t* dev = (fluid_alsa_audio_driver_t*) p;
  265.   if (dev == NULL) {
  266.     return FLUID_OK;
  267.   }
  268.   dev->cont = 0;
  269.   if (dev->thread)
  270.     fluid_thread_join (dev->thread);
  271.   if (dev->pcm)
  272.     snd_pcm_close (dev->pcm);
  273.   FLUID_FREE(dev);
  274.   return FLUID_OK;
  275. }
  276. /* handle error after an ALSA write call */
  277. static int fluid_alsa_handle_write_error (snd_pcm_t *pcm, int errval)
  278. {
  279.   switch (errval)
  280.   {
  281.   case -EAGAIN:
  282.     snd_pcm_wait(pcm, 1);
  283.     break;
  284.   case -EPIPE:
  285.   case -EBADFD:
  286.     if (snd_pcm_prepare(pcm) != 0) {
  287.       FLUID_LOG(FLUID_ERR, "Failed to prepare the audio device");
  288.       return FLUID_FAILED;
  289.     }
  290.     break;
  291.   case -ESTRPIPE:
  292.     if ((snd_pcm_resume(pcm) != 0) && (snd_pcm_prepare(pcm) != 0)) {
  293.       FLUID_LOG(FLUID_ERR, "Failed to resume the audio device");
  294.       return FLUID_FAILED;
  295.     }
  296.     break;
  297.   default:
  298.     FLUID_LOG(FLUID_ERR, "The audio device error: %s", snd_strerror(errval));
  299.     return FLUID_FAILED;
  300.   }
  301.   return FLUID_OK;
  302. }
  303. static void fluid_alsa_audio_run_float (void *d)
  304. {
  305.   fluid_alsa_audio_driver_t* dev = (fluid_alsa_audio_driver_t*) d;
  306.   fluid_synth_t *synth = (fluid_synth_t *)(dev->data);
  307.   float* left;
  308.   float* right;
  309.   float* handle[2];
  310.   int n, buffer_size, offset;
  311.   buffer_size = dev->buffer_size;
  312.   left = FLUID_ARRAY(float, buffer_size);
  313.   right = FLUID_ARRAY(float, buffer_size);
  314.   if ((left == NULL) || (right == NULL)) {
  315.     FLUID_LOG(FLUID_ERR, "Out of memory.");
  316.     return;
  317.   }
  318.   if (snd_pcm_prepare(dev->pcm) != 0) {
  319.     FLUID_LOG(FLUID_ERR, "Failed to prepare the audio device");
  320.     goto error_recovery;
  321.   }
  322.   /* use separate loops depending on if callback supplied or not (overkill?) */
  323.   if (dev->callback)
  324.   {
  325.     while (dev->cont) {
  326.       handle[0] = left;
  327.       handle[1] = right;
  328.       (*dev->callback)(synth, buffer_size, 0, NULL, 2, handle);
  329.       offset = 0;
  330.       while (offset < buffer_size) {
  331. handle[0] = left + offset;
  332. handle[1] = right + offset;
  333. n = snd_pcm_writen(dev->pcm, (void *)handle, buffer_size - offset);
  334. if (n < 0) /* error occurred? */
  335. {
  336.   if (fluid_alsa_handle_write_error (dev->pcm, n) != FLUID_OK)
  337.     goto error_recovery;
  338. } else offset += n; /* no error occurred */
  339.       } /* while (offset < buffer_size) */
  340.     } /* while (dev->cont) */
  341.   }
  342.   else /* no user audio callback (faster) */
  343.   {
  344.     while (dev->cont) {
  345.       fluid_synth_write_float(dev->data, buffer_size, left, 0, 1, right, 0, 1);
  346.       offset = 0;
  347.       while (offset < buffer_size) {
  348. handle[0] = left + offset;
  349. handle[1] = right + offset;
  350. n = snd_pcm_writen(dev->pcm, (void *)handle, buffer_size - offset);
  351. if (n < 0) /* error occurred? */
  352. {
  353.   if (fluid_alsa_handle_write_error (dev->pcm, n) != FLUID_OK)
  354.     goto error_recovery;
  355. } else offset += n; /* no error occurred */
  356.       } /* while (offset < buffer_size) */
  357.     } /* while (dev->cont) */
  358.   }
  359.  error_recovery:
  360.   FLUID_FREE(left);
  361.   FLUID_FREE(right);
  362. }
  363. static void fluid_alsa_audio_run_s16 (void *d)
  364. {
  365.   fluid_alsa_audio_driver_t* dev = (fluid_alsa_audio_driver_t*) d;
  366.   float* left;
  367.   float* right;
  368.   short* buf;
  369.   float* handle[2];
  370.   int n, buffer_size, offset;
  371.   buffer_size = dev->buffer_size;
  372.   left = FLUID_ARRAY(float, buffer_size);
  373.   right = FLUID_ARRAY(float, buffer_size);
  374.   buf = FLUID_ARRAY(short, 2 * buffer_size);
  375.   if ((left == NULL) || (right == NULL) || (buf == NULL)) {
  376.     FLUID_LOG(FLUID_ERR, "Out of memory.");
  377.     return;
  378.   }
  379.   handle[0] = left;
  380.   handle[1] = right;
  381.   if (snd_pcm_prepare(dev->pcm) != 0) {
  382.     FLUID_LOG(FLUID_ERR, "Failed to prepare the audio device");
  383.     goto error_recovery;
  384.   }
  385.   /* use separate loops depending on if callback supplied or not */
  386.   if (dev->callback)
  387.   {
  388.     int dither_index = 0;
  389.     while (dev->cont)
  390.     {
  391.       (*dev->callback)(dev->data, buffer_size, 0, NULL, 2, handle);
  392.       /* convert floating point data to 16 bit (with dithering) */
  393.       fluid_synth_dither_s16 (&dither_index, buffer_size, left, right,
  394.       buf, 0, 2, buf, 1, 2);
  395.       offset = 0;
  396.       while (offset < buffer_size)
  397.       {
  398. n = snd_pcm_writei (dev->pcm, (void*) (buf + 2 * offset),
  399.     buffer_size - offset);
  400. if (n < 0) /* error occurred? */
  401. {
  402.   if (fluid_alsa_handle_write_error (dev->pcm, n) != FLUID_OK)
  403.     goto error_recovery;
  404. }
  405. else offset += n; /* no error occurred */
  406.       } /* while (offset < buffer_size) */
  407.     } /* while (dev->cont) */
  408.   }
  409.   else /* no user audio callback, dev->data is the synth instance */
  410.   {
  411.     fluid_synth_t* synth = (fluid_synth_t *)(dev->data);
  412.     while (dev->cont)
  413.     {
  414.       fluid_synth_write_s16 (synth, buffer_size, buf, 0, 2, buf, 1, 2);
  415.       offset = 0;
  416.       while (offset < buffer_size)
  417.       {
  418. n = snd_pcm_writei (dev->pcm, (void*) (buf + 2 * offset),
  419.     buffer_size - offset);
  420. if (n < 0) /* error occurred? */
  421. {
  422.   if (fluid_alsa_handle_write_error (dev->pcm, n) != FLUID_OK)
  423.     goto error_recovery;
  424. }
  425. else offset += n; /* no error occurred */
  426.       } /* while (offset < buffer_size) */
  427.     } /* while (dev->cont) */
  428.   }
  429.  error_recovery:
  430.   FLUID_FREE(left);
  431.   FLUID_FREE(right);
  432.   FLUID_FREE(buf);
  433. }
  434. /**************************************************************
  435.  *
  436.  *        Alsa MIDI driver
  437.  *
  438.  */
  439. void fluid_alsa_rawmidi_driver_settings(fluid_settings_t* settings)
  440. {
  441.   fluid_settings_register_str(settings, "midi.alsa.device", "default", 0, NULL, NULL);
  442. }
  443. /*
  444.  * new_fluid_alsa_rawmidi_driver
  445.  */
  446. fluid_midi_driver_t*
  447. new_fluid_alsa_rawmidi_driver(fluid_settings_t* settings,
  448.      handle_midi_event_func_t handler,
  449.      void* data)
  450. {
  451.   int i, err;
  452.   fluid_alsa_rawmidi_driver_t* dev;
  453.   int realtime_prio = 0;
  454.   int count;
  455.   struct pollfd *pfd = NULL;
  456.   char* device = NULL;
  457.   /* not much use doing anything */
  458.   if (handler == NULL) {
  459.     FLUID_LOG(FLUID_ERR, "Invalid argument");
  460.     return NULL;
  461.   }
  462.   /* allocate the device */
  463.   dev = FLUID_NEW(fluid_alsa_rawmidi_driver_t);
  464.   if (dev == NULL) {
  465.     FLUID_LOG(FLUID_ERR, "Out of memory");
  466.     return NULL;
  467.   }
  468.   FLUID_MEMSET(dev, 0, sizeof(fluid_alsa_rawmidi_driver_t));
  469.   dev->driver.handler = handler;
  470.   dev->driver.data = data;
  471.   /* allocate one event to store the input data */
  472.   dev->parser = new_fluid_midi_parser();
  473.   if (dev->parser == NULL) {
  474.     FLUID_LOG(FLUID_ERR, "Out of memory");
  475.     goto error_recovery;
  476.   }
  477.   fluid_settings_getint (settings, "midi.realtime-prio", &realtime_prio);
  478.   /* get the device name. if none is specified, use the default device. */
  479.   fluid_settings_dupstr(settings, "midi.alsa.device", &device);         /* ++ alloc device name */
  480.   /* open the hardware device. only use midi in. */
  481.   if ((err = snd_rawmidi_open(&dev->rawmidi_in, NULL, device ? device : "default",
  482.                               SND_RAWMIDI_NONBLOCK)) < 0) {
  483.     FLUID_LOG(FLUID_ERR, "Error opening ALSA raw MIDI port");
  484.     goto error_recovery;
  485.   }
  486.   snd_rawmidi_nonblock(dev->rawmidi_in, 1);
  487.   /* get # of MIDI file descriptors */
  488.   count = snd_rawmidi_poll_descriptors_count(dev->rawmidi_in);
  489.   if (count > 0) { /* make sure there are some */
  490.     pfd = FLUID_MALLOC(sizeof (struct pollfd) * count);
  491.     dev->pfd = FLUID_MALLOC(sizeof (struct pollfd) * count);
  492.     /* grab file descriptor POLL info structures */
  493.     count = snd_rawmidi_poll_descriptors(dev->rawmidi_in, pfd, count);
  494.   }
  495.   /* copy the input FDs */
  496.   for (i = 0; i < count; i++) { /* loop over file descriptors */
  497.     if (pfd[i].events & POLLIN) { /* use only the input FDs */
  498.       dev->pfd[dev->npfd].fd = pfd[i].fd;
  499.       dev->pfd[dev->npfd].events = POLLIN;
  500.       dev->pfd[dev->npfd].revents = 0;
  501.       dev->npfd++;
  502.     }
  503.   }
  504.   FLUID_FREE(pfd);
  505.   dev->status = FLUID_MIDI_READY;
  506.   /* create the MIDI thread */
  507.   dev->thread = new_fluid_thread (fluid_alsa_midi_run, dev, realtime_prio, FALSE);
  508.   if (!dev->thread)
  509.     goto error_recovery;
  510.   if (device) FLUID_FREE (device);      /* -- free device name */
  511.   return (fluid_midi_driver_t*) dev;
  512.  error_recovery:
  513.   if (device) FLUID_FREE (device);      /* -- free device name */
  514.   delete_fluid_alsa_rawmidi_driver((fluid_midi_driver_t*) dev);
  515.   return NULL;
  516. }
  517. /*
  518.  * delete_fluid_alsa_rawmidi_driver
  519.  */
  520. int
  521. delete_fluid_alsa_rawmidi_driver(fluid_midi_driver_t* p)
  522. {
  523.   fluid_alsa_rawmidi_driver_t* dev;
  524.   dev = (fluid_alsa_rawmidi_driver_t*) p;
  525.   if (dev == NULL) {
  526.     return FLUID_OK;
  527.   }
  528.   /* cancel the thread and wait for it before cleaning up */
  529.   dev->status = FLUID_MIDI_DONE;
  530.   if (dev->thread)
  531.     fluid_thread_join (dev->thread);
  532.   if (dev->rawmidi_in) {
  533.     snd_rawmidi_close(dev->rawmidi_in);
  534.   }
  535.   if (dev->parser != NULL) {
  536.     delete_fluid_midi_parser(dev->parser);
  537.   }
  538.   FLUID_FREE(dev);
  539.   return FLUID_OK;
  540. }
  541. /*
  542.  * fluid_alsa_midi_run
  543.  */
  544. void
  545. fluid_alsa_midi_run(void* d)
  546. {
  547.   fluid_midi_event_t* evt;
  548.   fluid_alsa_rawmidi_driver_t* dev = (fluid_alsa_rawmidi_driver_t*) d;
  549.   int n, i;
  550.   /* go into a loop until someone tells us to stop */
  551.   dev->status = FLUID_MIDI_LISTENING;
  552.   while (dev->status == FLUID_MIDI_LISTENING) {
  553.     /* is there something to read? */
  554.     n = poll(dev->pfd, dev->npfd, 100); /* use a 100 milliseconds timeout */
  555.     if (n < 0) {
  556.       perror("poll");
  557.     } else if (n > 0) {
  558.       /* read new data */
  559.       n = snd_rawmidi_read(dev->rawmidi_in, dev->buffer, BUFFER_LENGTH);
  560.       if ((n < 0) && (n != -EAGAIN)) {
  561. FLUID_LOG(FLUID_ERR, "Failed to read the midi input");
  562. dev->status = FLUID_MIDI_DONE;
  563.       }
  564.       /* let the parser convert the data into events */
  565.       for (i = 0; i < n; i++) {
  566. evt = fluid_midi_parser_parse(dev->parser, dev->buffer[i]);
  567. if (evt != NULL) {
  568.   (*dev->driver.handler)(dev->driver.data, evt);
  569. }
  570.       }
  571.     }
  572.   }
  573. }
  574. /**************************************************************
  575.  *
  576.  *        Alsa sequencer
  577.  *
  578.  */
  579. void fluid_alsa_seq_driver_settings(fluid_settings_t* settings)
  580. {
  581.   fluid_settings_register_str(settings, "midi.alsa_seq.device", "default", 0, NULL, NULL);
  582.   fluid_settings_register_str(settings, "midi.alsa_seq.id", "pid", 0, NULL, NULL);
  583. }
  584. static char* fluid_alsa_seq_full_id(char* id, char* buf, int len)
  585. {
  586.   if (id != NULL) {
  587.     if (FLUID_STRCMP(id, "pid") == 0) {
  588.       snprintf(buf, len, "FLUID Synth (%d)", getpid());
  589.     } else {
  590.       snprintf(buf, len, "FLUID Synth (%s)", id);
  591.     }
  592.   } else {
  593.     snprintf(buf, len, "FLUID Synth");
  594.   }
  595.   return buf;
  596. }
  597. static char* fluid_alsa_seq_full_name(char* id, int port, char* buf, int len)
  598. {
  599.   if (id != NULL) {
  600.     if (FLUID_STRCMP(id, "pid") == 0) {
  601.       snprintf(buf, len, "Synth input port (%d:%d)", getpid(), port);
  602.     } else {
  603.       snprintf(buf, len, "Synth input port (%s:%d)", id, port);
  604.     }
  605.   } else {
  606.     snprintf(buf, len, "Synth input port");
  607.   }
  608.   return buf;
  609. }
  610. /*
  611.  * new_fluid_alsa_seq_driver
  612.  */
  613. fluid_midi_driver_t*
  614. new_fluid_alsa_seq_driver(fluid_settings_t* settings,
  615.  handle_midi_event_func_t handler, void* data)
  616. {
  617.   int i, err;
  618.   fluid_alsa_seq_driver_t* dev;
  619.   int realtime_prio = 0;
  620.   int count;
  621.   struct pollfd *pfd = NULL;
  622.   char *device = NULL;
  623.   char *id = NULL;
  624.   char *portname = NULL;
  625.   char full_id[64];
  626.   char full_name[64];
  627.   snd_seq_port_info_t *port_info = NULL;
  628.   int midi_channels;
  629.   /* not much use doing anything */
  630.   if (handler == NULL) {
  631.     FLUID_LOG(FLUID_ERR, "Invalid argument");
  632.     return NULL;
  633.   }
  634.   /* allocate the device */
  635.   dev = FLUID_NEW(fluid_alsa_seq_driver_t);
  636.   if (dev == NULL) {
  637.     FLUID_LOG(FLUID_ERR, "Out of memory");
  638.     return NULL;
  639.   }
  640.   FLUID_MEMSET(dev, 0, sizeof(fluid_alsa_seq_driver_t));
  641.   dev->driver.data = data;
  642.   dev->driver.handler = handler;
  643.   fluid_settings_getint (settings, "midi.realtime-prio", &realtime_prio);
  644.   /* get the device name. if none is specified, use the default device. */
  645.   if (fluid_settings_dupstr(settings, "midi.alsa_seq.device", &device) == 0)    /* ++ alloc device name */
  646.     goto error_recovery;
  647.   if (fluid_settings_dupstr(settings, "midi.alsa_seq.id", &id) == 0)    /* ++ alloc id string */
  648.     goto error_recovery;
  649.   if (id == NULL) {
  650.     id = FLUID_MALLOC (32);
  651.     if (!id)
  652.     {
  653.       FLUID_LOG(FLUID_ERR, "Out of memory");
  654.       goto error_recovery;
  655.     }
  656.     sprintf(id, "%d", getpid());
  657.   }
  658.   /* get the midi portname */
  659.   fluid_settings_dupstr(settings, "midi.portname", &portname);
  660.   if (portname && FLUID_STRLEN (portname) == 0)
  661.   {
  662.     FLUID_FREE (portname);      /* -- free port name */
  663.     portname = NULL;
  664.   }
  665.   /* open the sequencer INPUT only */
  666.   err = snd_seq_open(&dev->seq_handle, device ? device : "default", SND_SEQ_OPEN_INPUT, 0);
  667.   if (err < 0) {
  668.     FLUID_LOG(FLUID_ERR, "Error opening ALSA sequencer");
  669.     goto error_recovery;
  670.   }
  671.   snd_seq_nonblock (dev->seq_handle, 1);
  672.   /* get # of MIDI file descriptors */
  673.   count = snd_seq_poll_descriptors_count(dev->seq_handle, POLLIN);
  674.   if (count > 0) { /* make sure there are some */
  675.     pfd = FLUID_MALLOC(sizeof (struct pollfd) * count);
  676.     dev->pfd = FLUID_MALLOC(sizeof (struct pollfd) * count);
  677.     /* grab file descriptor POLL info structures */
  678.     count = snd_seq_poll_descriptors(dev->seq_handle, pfd, count, POLLIN);
  679.   }
  680.   /* copy the input FDs */
  681.   for (i = 0; i < count; i++) { /* loop over file descriptors */
  682.     if (pfd[i].events & POLLIN) { /* use only the input FDs */
  683.       dev->pfd[dev->npfd].fd = pfd[i].fd;
  684.       dev->pfd[dev->npfd].events = POLLIN;
  685.       dev->pfd[dev->npfd].revents = 0;
  686.       dev->npfd++;
  687.     }
  688.   }
  689.   FLUID_FREE(pfd);
  690.   /* set the client name */
  691.   if (!portname) {
  692.     snd_seq_set_client_name(dev->seq_handle, fluid_alsa_seq_full_id(id, full_id, 64));
  693.   }
  694.   else {
  695.     snd_seq_set_client_name(dev->seq_handle, portname);
  696.   }
  697.   /* create the ports */
  698.   snd_seq_port_info_alloca(&port_info);
  699.   FLUID_MEMSET(port_info, 0, snd_seq_port_info_sizeof());
  700.   fluid_settings_getint(settings, "synth.midi-channels", &midi_channels);
  701.   dev->port_count = midi_channels / 16;
  702.   snd_seq_port_info_set_capability(port_info,
  703.    SND_SEQ_PORT_CAP_WRITE |
  704.    SND_SEQ_PORT_CAP_SUBS_WRITE);
  705.   snd_seq_port_info_set_type(port_info,
  706.      SND_SEQ_PORT_TYPE_MIDI_GENERIC | SND_SEQ_PORT_TYPE_APPLICATION);
  707.   snd_seq_port_info_set_midi_channels(port_info, 16);
  708.   snd_seq_port_info_set_port_specified(port_info, 1);
  709.   for (i = 0; i < dev->port_count; i++) {
  710.     if (!portname) {
  711.       snd_seq_port_info_set_name(port_info, fluid_alsa_seq_full_name(id, i, full_name, 64));
  712.     }
  713.     else {
  714.       snd_seq_port_info_set_name(port_info, portname);
  715.     }
  716.     snd_seq_port_info_set_port(port_info, i);
  717.     err = snd_seq_create_port(dev->seq_handle, port_info);
  718.     if (err  < 0) {
  719.       FLUID_LOG(FLUID_ERR, "Error creating ALSA sequencer port");
  720.       goto error_recovery;
  721.     }
  722.   }
  723.   /* tell the lash server our client id */
  724. #ifdef LASH_ENABLED
  725.   {
  726.     int enable_lash = 0;
  727.     fluid_settings_getint (settings, "lash.enable", &enable_lash);
  728.     if (enable_lash)
  729.       fluid_lash_alsa_client_id (fluid_lash_client, snd_seq_client_id (dev->seq_handle));
  730.   }
  731. #endif /* LASH_ENABLED */
  732.   dev->status = FLUID_MIDI_READY;
  733.   /* create the MIDI thread */
  734.   dev->thread = new_fluid_thread (fluid_alsa_seq_run, dev, realtime_prio, FALSE);
  735.   if (portname) FLUID_FREE (portname);
  736.   if (id) FLUID_FREE (id);
  737.   if (device) FLUID_FREE (device);
  738.   return (fluid_midi_driver_t*) dev;
  739.  error_recovery:
  740.   if (portname) FLUID_FREE (portname);
  741.   if (id) FLUID_FREE (id);
  742.   if (device) FLUID_FREE (device);
  743.   delete_fluid_alsa_seq_driver((fluid_midi_driver_t*) dev);
  744.   return NULL;
  745. }
  746. /*
  747.  * delete_fluid_alsa_seq_driver
  748.  */
  749. int
  750. delete_fluid_alsa_seq_driver(fluid_midi_driver_t* p)
  751. {
  752.   fluid_alsa_seq_driver_t* dev;
  753.   dev = (fluid_alsa_seq_driver_t*) p;
  754.   if (dev == NULL) {
  755.     return FLUID_OK;
  756.   }
  757.   /* cancel the thread and wait for it before cleaning up */
  758.   dev->status = FLUID_MIDI_DONE;
  759.   if (dev->thread)
  760.     fluid_thread_join (dev->thread);
  761.   if (dev->seq_handle) {
  762.     snd_seq_close(dev->seq_handle);
  763.   }
  764.   if (dev->pfd) FLUID_FREE (dev->pfd);
  765.   FLUID_FREE(dev);
  766.   return FLUID_OK;
  767. }
  768. /*
  769.  * fluid_alsa_seq_run
  770.  */
  771. void
  772. fluid_alsa_seq_run(void* d)
  773. {
  774.   int n, ev;
  775.   snd_seq_event_t *seq_ev;
  776.   fluid_midi_event_t evt;
  777.   fluid_alsa_seq_driver_t* dev = (fluid_alsa_seq_driver_t*) d;
  778.   /* go into a loop until someone tells us to stop */
  779.   dev->status = FLUID_MIDI_LISTENING;
  780.   while (dev->status == FLUID_MIDI_LISTENING) {
  781.     /* is there something to read? */
  782.     n = poll(dev->pfd, dev->npfd, 100); /* use a 100 milliseconds timeout */
  783.     if (n < 0) {
  784.       perror("poll");
  785.     } else if (n > 0) {      /* check for pending events */
  786.       do
  787. {
  788.     ev = snd_seq_event_input(dev->seq_handle, &seq_ev); /* read the events */
  789.             if (ev == -EAGAIN) break;
  790.     /* Negative value indicates an error, ignore interrupted system call
  791.      * (-EPERM) and input event buffer overrun (-ENOSPC) */
  792.     if (ev < 0)
  793.     { /* FIXME - report buffer overrun? */
  794. if (ev != -EPERM && ev != -ENOSPC)
  795. {
  796.   FLUID_LOG(FLUID_ERR, "Error while reading ALSA sequencer (code=%d)", ev);
  797.   dev->status = FLUID_MIDI_DONE;
  798. }
  799. break;
  800.     }
  801.     switch (seq_ev->type)
  802.     {
  803.     case SND_SEQ_EVENT_NOTEON:
  804.       evt.type = NOTE_ON;
  805.       evt.channel = seq_ev->dest.port * 16 + seq_ev->data.note.channel;
  806.       evt.param1 = seq_ev->data.note.note;
  807.       evt.param2 = seq_ev->data.note.velocity;
  808.       break;
  809.     case SND_SEQ_EVENT_NOTEOFF:
  810.       evt.type = NOTE_OFF;
  811.       evt.channel = seq_ev->dest.port * 16 + seq_ev->data.note.channel;
  812.       evt.param1 = seq_ev->data.note.note;
  813.       evt.param2 = seq_ev->data.note.velocity;
  814.       break;
  815.     case SND_SEQ_EVENT_KEYPRESS:
  816.       evt.type = KEY_PRESSURE;
  817.       evt.channel = seq_ev->dest.port * 16 + seq_ev->data.note.channel;
  818.       evt.param1 = seq_ev->data.note.note;
  819.       evt.param2 = seq_ev->data.note.velocity;
  820.       break;
  821.     case SND_SEQ_EVENT_CONTROLLER:
  822.       evt.type = CONTROL_CHANGE;
  823.       evt.channel = seq_ev->dest.port * 16 + seq_ev->data.control.channel;
  824.       evt.param1 = seq_ev->data.control.param;
  825.       evt.param2 = seq_ev->data.control.value;
  826.       break;
  827.     case SND_SEQ_EVENT_PITCHBEND:
  828.       evt.type = PITCH_BEND;
  829.       evt.channel = seq_ev->dest.port * 16 + seq_ev->data.control.channel;
  830.       /* ALSA pitch bend is -8192 - 8191, we adjust it here */
  831.       evt.param1 = seq_ev->data.control.value + 8192;
  832.       break;
  833.     case SND_SEQ_EVENT_PGMCHANGE:
  834.       evt.type = PROGRAM_CHANGE;
  835.       evt.channel = seq_ev->dest.port * 16 + seq_ev->data.control.channel;
  836.       evt.param1 = seq_ev->data.control.value;
  837.       break;
  838.     case SND_SEQ_EVENT_CHANPRESS:
  839.       evt.type = CHANNEL_PRESSURE;
  840.       evt.channel = seq_ev->dest.port * 16 + seq_ev->data.control.channel;
  841.       evt.param1 = seq_ev->data.control.value;
  842.       break;
  843.     case SND_SEQ_EVENT_SYSEX:
  844.       if (seq_ev->data.ext.len < 2) continue;
  845.       fluid_midi_event_set_sysex (&evt, (char *)(seq_ev->data.ext.ptr) + 1,
  846.   seq_ev->data.ext.len - 2, FALSE);
  847.       break;
  848.     default:
  849.       continue; /* unhandled event, next loop iteration */
  850.     }
  851.     /* send the events to the next link in the chain */
  852.     (*dev->driver.handler)(dev->driver.data, &evt);
  853. }
  854. while (ev > 0);
  855.     } /* if poll() > 0 */
  856.   } /* while (dev->status == FLUID_MIDI_LISTENING) */
  857. }
  858. #endif /* #if ALSA_SUPPORT */