1 files changed, 82 insertions, 0 deletions
diff --git a/input/shmem.c b/input/shmem.c
new file mode 100644
index 0000000..c7bf040
--- /dev/null
+++ b/input/shmem.c
@@ -0,0 +1,82 @@
+#include "input/shmem.h"
+#include "input/common.h"
+
+#include <sys/mman.h>
+#include <sys/stat.h>
+#include <sys/types.h>
+
+typedef unsigned int u32_t;
+typedef short s16_t;
+
+// #define BUFSIZE 1024
+#define BUFSIZE 2048
+
+int rc;
+
+#define VIS_BUF_SIZE 16384
+#define VB_OFFSET 8192 + 4096
+
+typedef struct {
+    pthread_rwlock_t rwlock;
+    u32_t buf_size;
+    u32_t buf_index;
+    bool running;
+    u32_t rate;
+    time_t updated;
+    s16_t buffer[VIS_BUF_SIZE];
+} vis_t;
+
+// input: SHMEM
+void *input_shmem(void *data) {
+    struct audio_data *audio = (struct audio_data *)data;
+    vis_t *mmap_area;
+    int fd; /* file descriptor to mmaped area */
+    int mmap_count = sizeof(vis_t);
+
+    printf("input_shmem: source: %s", audio->source);
+
+    fd = shm_open(audio->source, O_RDWR, 0666);
+
+    if (fd < 0) {
+        printf("Could not open source '%s': %s\n", audio->source, strerror(errno));
+        exit(EXIT_FAILURE);
+    } else {
+        mmap_area = mmap(NULL, sizeof(vis_t), PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0);
+        if ((intptr_t)mmap_area == -1) {
+            printf("mmap failed - check if squeezelite is running with visualization enabled\n");
+            exit(EXIT_FAILURE);
+        }
+    }
+    // printf("bufs: %u / run: %u / rate: %u\n",mmap_area->buf_size, mmap_area->running,
+    // mmap_area->rate);
+    audio->rate = mmap_area->rate;
+
+    while (!audio->terminate) {
+        write_to_fftw_input_buffers(mmap_area->buffer, BUFSIZE, audio);
+        /*
+                        for (i = VB_OFFSET; i < BUFSIZE+VB_OFFSET; i += 2) {
+                                if (audio->channels == 1) {
+                                        audio->audio_out_l[n] = (mmap_area->buffer[i] +
+           mmap_area->buffer[i + 1]) / 2; } else if (audio->channels == 2) { audio->audio_out_l[n] =
+           mmap_area->buffer[i]; audio->audio_out_r[n] = mmap_area->buffer[i + 1];
+                                }
+                                n++;
+                                if (n == audio->FFTbufferSize - 1) n = 0;
+                        }
+        */
+    }
+
+    // cleanup
+    if (fd > 0) {
+        if (close(fd) != 0) {
+            printf("Could not close file descriptor %d: %s", fd, strerror(errno));
+        }
+    } else {
+        printf("Wrong file descriptor %d", fd);
+    }
+
+    if (munmap(mmap_area, mmap_count) != 0) {
+        printf("Could not munmap() area %p+%d. %s", mmap_area, mmap_count, strerror(errno));
+    }
+    return 0;
+}