linux/firewire/JackFFADOMidiOutputPort.cpp

   1 /*
   2 Copyright (C) 2010 Devin Anderson
   3
   4 This program is free software; you can redistribute it and/or modify
   5 it under the terms of the GNU Lesser General Public License as published by
   6 the Free Software Foundation; either version 2.1 of the License, or
   7 (at your option) any later version.
   8
   9 This program is distributed in the hope that it will be useful,
  10 but WITHOUT ANY WARRANTY; without even the implied warranty of
  11 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  12 GNU Lesser General Public License for more details.
  13
  14 You should have received a copy of the GNU Lesser General Public License
  15 along with this program; if not, write to the Free Software
  16 Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
  17
  18 */
  19
  20 #include <memory>
  21
  22 #include "JackFFADOMidiOutputPort.h"
  23 #include "JackMidiUtil.h"
  24 #include "JackError.h"
  25
  26 using Jack::JackFFADOMidiOutputPort;
  27
  28 JackFFADOMidiOutputPort::JackFFADOMidiOutputPort(size_t non_rt_size,
  29                                                  size_t max_non_rt_messages,
  30                                                  size_t max_rt_messages)
  31 {
  32     event = 0;
  33     read_queue = new JackMidiBufferReadQueue();
  34     std::unique_ptr<JackMidiBufferReadQueue> read_queue_ptr(read_queue);
  35     send_queue = new JackFFADOMidiSendQueue();
  36     std::unique_ptr<JackFFADOMidiSendQueue> send_queue_ptr(send_queue);
  37     raw_queue = new JackMidiRawOutputWriteQueue(send_queue, non_rt_size,
  38                                                 max_non_rt_messages,
  39                                                 max_rt_messages);
  40     send_queue_ptr.release();
  41     read_queue_ptr.release();
  42 }
  43
  44 JackFFADOMidiOutputPort::~JackFFADOMidiOutputPort()
  45 {
  46     delete raw_queue;
  47     delete read_queue;
  48     delete send_queue;
  49 }
  50
  51 void
  52 JackFFADOMidiOutputPort::Process(JackMidiBuffer *port_buffer,
  53                                  uint32_t *output_buffer,
  54                                  jack_nframes_t frames)
  55 {
  56     read_queue->ResetMidiBuffer(port_buffer);
  57     send_queue->ResetOutputBuffer(output_buffer, frames);
  58     jack_nframes_t boundary_frame = GetLastFrame() + frames;
  59     if (! event) {
  60         event = read_queue->DequeueEvent();
  61     }
  62     for (; event; event = read_queue->DequeueEvent()) {
  63         switch (raw_queue->EnqueueEvent(event)) {
  64         case JackMidiWriteQueue::BUFFER_FULL:
  65
  66             // Processing events early might free up some space in the raw
  67             // output queue.
  68
  69             raw_queue->Process(boundary_frame);
  70             switch (raw_queue->EnqueueEvent(event)) {
  71             case JackMidiWriteQueue::BUFFER_TOO_SMALL:
  72                 // This shouldn't really happen.  It indicates a bug if it
  73                 // does.
  74                 jack_error("JackFFADOMidiOutputPort::Process - **BUG** "
  75                            "JackMidiRawOutputWriteQueue::EnqueueEvent "
  76                            "returned `BUFFER_FULL`, and then returned "
  77                            "`BUFFER_TOO_SMALL` after a `Process()` call.");
  78                 // Fallthrough on purpose
  79             case JackMidiWriteQueue::OK:
  80                 continue;
  81             default:
  82                 return;
  83             }
  84         case JackMidiWriteQueue::BUFFER_TOO_SMALL:
  85             jack_error("JackFFADOMidiOutputPort::Process - The write queue "
  86                        "couldn't enqueue a %d-byte event. Dropping event.",
  87                        event->size);
  88             // Fallthrough on purpose
  89         case JackMidiWriteQueue::OK:
  90             continue;
  91         default:
  92             // This is here to stop compilers from warning us about not
  93             // handling enumeration values.
  94             ;
  95         }
  96         break;
  97     }
  98     raw_queue->Process(boundary_frame);
  99 }