prefetch_pipe.h

   1 /*
   2 Calf Box, an open source musical instrument.
   3 Copyright (C) 2010-2013 Krzysztof Foltman
   4
   5 This program is free software: you can redistribute it and/or modify
   6 it under the terms of the GNU General Public License as published by
   7 the Free Software Foundation, either version 3 of the License, or
   8 (at your option) any later version.
   9
  10 This program is distributed in the hope that it will be useful,
  11 but WITHOUT ANY WARRANTY; without even the implied warranty of
  12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  13 GNU General Public License for more details.
  14
  15 You should have received a copy of the GNU General Public License
  16 along with this program.  If not, see <http://www.gnu.org/licenses/>.
  17 */
  18
  19 #ifndef CBOX_PREFETCH_PIPE_H
  20 #define CBOX_PREFETCH_PIPE_H
  21
  22 #include <assert.h>
  23 #include <glib.h>
  24 #include <pthread.h>
  25 #include <sndfile.h>
  26 #include <stdint.h>
  27 #include <tarfile.h>
  28
  29 struct cbox_waveform;
  30
  31 enum cbox_prefetch_pipe_state
  32 {
  33     pps_free,
  34     pps_opening,
  35     pps_active,
  36     pps_finished,
  37     pps_error,
  38     pps_closing,
  39     pps_closed,
  40 };
  41
  42 struct cbox_prefetch_pipe
  43 {
  44     enum cbox_prefetch_pipe_state state;
  45     int next_free_pipe;
  46     struct cbox_waveform *waveform;
  47     struct cbox_tarfile_sndstream sndstream;
  48     int16_t *data;
  49     uint32_t buffer_size;
  50     SF_INFO info;
  51     SNDFILE *sndfile;
  52     uint32_t file_pos_frame;
  53     uint32_t file_loop_start;
  54     uint32_t file_loop_end;
  55     uint32_t buffer_loop_end;
  56     uint32_t play_count, loop_count;
  57     size_t write_ptr;
  58     size_t produced;
  59     size_t consumed;
  60     gboolean finished;
  61     gboolean returned;
  62 };
  63
  64 extern void cbox_prefetch_pipe_init(struct cbox_prefetch_pipe *pipe, uint32_t buffer_size);
  65 extern void cbox_prefetch_pipe_consumed(struct cbox_prefetch_pipe *pipe, uint32_t frames);
  66 extern void cbox_prefetch_pipe_close(struct cbox_prefetch_pipe *pipe);
  67
  68 static inline uint32_t cbox_prefetch_pipe_get_remaining(struct cbox_prefetch_pipe *pipe)
  69 {
  70     assert(pipe->consumed <= pipe->produced);
  71     return pipe->produced - pipe->consumed;
  72 }
  73
  74 struct cbox_prefetch_stack
  75 {
  76     struct cbox_prefetch_pipe *pipes;
  77     int pipe_count;
  78     pthread_t thr_prefetch;
  79     int last_free_pipe;
  80     gboolean finished;
  81 };
  82
  83 extern struct cbox_prefetch_stack *cbox_prefetch_stack_new(int npipes, uint32_t buffer_size);
  84 extern struct cbox_prefetch_pipe *cbox_prefetch_stack_pop(struct cbox_prefetch_stack *stack, struct cbox_waveform *waveform, uint32_t file_loop_start, uint32_t file_loop_end, uint32_t loop_count);
  85 extern void cbox_prefetch_stack_push(struct cbox_prefetch_stack *stack, struct cbox_prefetch_pipe *pipe);
  86 extern int cbox_prefetch_stack_get_active_pipe_count(struct cbox_prefetch_stack *stack);
  87 extern void cbox_prefetch_stack_destroy(struct cbox_prefetch_stack *stack);
  88
  89 #endif