1 files changed, 101 insertions, 0 deletions
diff --git a/src/JackInput.h b/src/JackInput.h
new file mode 100644
index 0000000..d5832c7
--- /dev/null
+++ b/src/JackInput.h
@@ -0,0 +1,101 @@
+/* ------------------------------------------------------------------
+ * Copyright (C) 2011 Martin Storsjo
+ * Copyright (C) 2013,2014 Matthias P. Braendli
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
+ * express or implied.
+ * See the License for the specific language governing permissions
+ * and limitations under the License.
+ * -------------------------------------------------------------------
+ */
+
+#ifndef __JACK_INPUT_H
+#define __JACK_INPUT_H
+#include "config.h"
+#include <cstdio>
+#include <string>
+
+#if HAVE_JACK
+
+extern "C" {
+#include <jack/jack.h>
+}
+
+#include "SampleQueue.h"
+
+// 16 bits per sample is fine for now
+#define BYTES_PER_SAMPLE 2
+
+class JackInput
+{
+    public:
+        JackInput(const std::string& jack_name,
+                unsigned int channels,
+                unsigned int samplerate,
+                SampleQueue<uint8_t>& queue) :
+            m_client(NULL),
+            m_jack_name(jack_name),
+            m_channels(channels),
+            m_rate(samplerate),
+            m_queue(queue) { }
+
+        ~JackInput() {
+            if (m_client) {
+                jack_client_close(m_client);
+            }
+        }
+
+        /* Prepare the audio input */
+        int prepare();
+
+    private:
+        JackInput(const JackInput& other);
+
+        jack_client_t* m_client;
+
+        std::vector<jack_port_t*> m_input_ports;
+
+        std::string m_jack_name;
+        unsigned int m_channels;
+        unsigned int m_rate;
+
+        // Callback for real-time JACK process
+        void jack_process(jack_nframes_t nframes);
+
+        // Callback when JACK shuts down
+        void jack_shutdown()
+        {
+            m_fault = true;
+        }
+
+        bool m_fault;
+        bool m_running;
+
+        SampleQueue<uint8_t>& m_queue;
+
+        // Static functions for JACK callbacks
+        static int process_cb(jack_nframes_t nframes, void* arg)
+        {
+            ((JackInput*)arg)->jack_process(nframes);
+            return 0;
+        }
+
+        static void shutdown_cb(void* arg)
+        {
+            ((JackInput*)arg)->jack_shutdown();
+        }
+
+};
+
+#endif // HAVE_JACK
+
+#endif
+