apps/plugins/pdbox/pdbox.c

   1 /***************************************************************************
   2  *             __________               __   ___.
   3  *   Open      \______   \ ____   ____ |  | _\_ |__   _______  ___
   4  *   Source     |       _//  _ \_/ ___\|  |/ /| __ \ /  _ \  \/  /
   5  *   Jukebox    |    |   (  <_> )  \___|    < | \_\ (  <_> > <  <
   6  *   Firmware   |____|_  /\____/ \___  >__|_ \|___  /\____/__/\_ \
   7  *                     \/            \/     \/    \/            \/
   8  * $Id$
   9  *
  10  * Copyright (C) 2009, 2010 Wincent Balin
  11  *
  12  * This program is free software; you can redistribute it and/or
  13  * modify it under the terms of the GNU General Public License
  14  * as published by the Free Software Foundation; either version 2
  15  * of the License, or (at your option) any later version.
  16  *
  17  * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY
  18  * KIND, either express or implied.
  19  *
  20  ****************************************************************************/
  21
  22 #include "plugin.h"
  23 #include "pdbox.h"
  24
  25 #include "PDa/src/m_pd.h"
  26 #include "PDa/src/s_stuff.h"
  27
  28 /* Welcome to the PDBox plugin */
  29 PLUGIN_HEADER
  30 PLUGIN_IRAM_DECLARE
  31
  32 /* Name of the file to open. */
  33 char* filename;
  34
  35 /* Running time. */
  36 uint64_t runningtime IBSS_ATTR = 0;
  37
  38 /* Variables for Pure Data. */
  39 int sys_verbose;
  40 int sys_noloadbang;
  41 t_symbol *sys_libdir;
  42 t_namelist *sys_openlist;
  43 int sys_soundindevlist[MAXAUDIOINDEV];
  44 int sys_chinlist[MAXAUDIOINDEV];
  45 int sys_soundoutdevlist[MAXAUDIOOUTDEV];
  46 int sys_choutlist[MAXAUDIOOUTDEV];
  47 t_binbuf* inbinbuf;
  48
  49 /* References for scheduler variables and functions. */
  50 extern t_time sys_time;
  51 extern t_time sys_time_per_dsp_tick;
  52 extern void sched_tick(t_time next_sys_time);
  53
  54 /* LATER consider making this variable.  It's now the LCM of all sample
  55 rates we expect to see: 32000, 44100, 48000, 88200, 96000. */
  56 #define TIMEUNITPERSEC (32.*441000.)
  57
  58
  59 /* Quit flag. */
  60 bool quit IBSS_ATTR = false;
  61
  62 /* Stack sizes for threads. */
  63 #define CORESTACKSIZE (1 * 1024 * 1024)
  64 #define GUISTACKSIZE (512 * 1024)
  65
  66 /* Thread stacks. */
  67 void* core_stack IBSS_ATTR;
  68 void* gui_stack IBSS_ATTR;
  69
  70 /* Thread IDs. */
  71 unsigned int core_thread_id IBSS_ATTR;
  72 unsigned int gui_thread_id IBSS_ATTR;
  73
  74
  75 /* GUI thread */
  76 void gui_thread(void)
  77 {
  78     struct pd_widget widget[128];
  79     unsigned int widgets = 0;
  80     struct datagram dg;
  81     bool update;
  82
  83     /* Initialize GUI. */
  84     pd_gui_init();
  85
  86     /* Load PD patch. */
  87     widgets = pd_gui_load_patch(widget,
  88                                 sizeof(widget) / sizeof(struct pd_widget));
  89
  90     /* Draw initial state of UI. */
  91     pd_gui_draw(widget, widgets);
  92
  93     /* GUI loop */
  94     while(!quit)
  95     {
  96         /* Reset update flag. */
  97         update = false;
  98
  99         /* Apply timer to widgets. */
 100         update |=
 101         pd_gui_apply_timeouts(widget, widgets);
 102
 103         /* Process buttons. */
 104         update |=
 105         pd_gui_parse_buttons(widgets);
 106
 107         /* Receive and parse datagrams. */
 108         while(RECEIVE_FROM_CORE(&dg))
 109         {
 110             update = true;
 111             pd_gui_parse_message(&dg, widget, widgets);
 112         }
 113
 114         /* If there is something to update in GUI, do so. */
 115         if(update)
 116             pd_gui_draw(widget, widgets);
 117
 118         rb->sleep(1);
 119     }
 120
 121     rb->thread_exit();
 122 }
 123
 124 /* Core thread */
 125 void core_thread(void)
 126 {
 127     /* Add the directory the called .pd file resides in to lib directories. */
 128     sys_findlibdir(filename);
 129
 130     /* Open the PD design file. */
 131     sys_openlist = namelist_append(sys_openlist, filename);
 132
 133     /* Fake a GUI start. */
 134     sys_startgui(NULL);
 135
 136     /* Core scheduler loop */
 137     while(!quit)
 138     {
 139         /* Receive datagrams. */
 140         struct datagram dg;
 141
 142         while(RECEIVE_TO_CORE(&dg))
 143             rockbox_receive_callback(&dg);
 144
 145         /* Use sys_send_dacs() function as timer. */
 146         while(sys_send_dacs() != SENDDACS_NO)
 147             sched_tick(sys_time + sys_time_per_dsp_tick);
 148
 149         rb->sleep(1);
 150     }
 151
 152     rb->thread_exit();
 153 }
 154
 155
 156
 157 /* Plug-in entry point */
 158 enum plugin_status plugin_start(const void* parameter)
 159 {
 160     PLUGIN_IRAM_INIT(rb)
 161
 162     /* Memory pool variables. */
 163     size_t mem_size;
 164     void* mem_pool;
 165
 166     /* Get the file name; check whether parameter contains no file name. */
 167     filename = (char*) parameter;
 168     if(strlen(filename) == 0)
 169     {
 170         rb->splash(HZ, "Play a .pd file!");
 171         return PLUGIN_ERROR;
 172     }
 173
 174     /* Initialize memory pool. */
 175     mem_pool = rb->plugin_get_audio_buffer(&mem_size);
 176     if(mem_size < MIN_MEM_SIZE)
 177     {
 178         rb->splash(HZ, "Not enough memory!");
 179         return PLUGIN_ERROR;
 180     }
 181
 182     init_memory_pool(mem_size, mem_pool);
 183
 184     /* Initialize net. */
 185     net_init();
 186
 187     /* Initialize Pure Data, as does sys_main in s_main.c */
 188     pd_init();
 189
 190     /* Set audio API. */
 191     sys_set_audio_api(API_ROCKBOX);
 192
 193     /* Initialize audio subsystem. */
 194     sys_open_audio(0, /* No sound input yet */
 195                    sys_soundindevlist,
 196                    0, /* No sound input yet */
 197                    sys_chinlist,
 198                    1, /* One sound output device */
 199                    sys_soundoutdevlist,
 200                    -1, /* Use the default amount (2) of channels */
 201                    sys_choutlist,
 202                    PD_SAMPLERATE, /* Sample rate */
 203                    DEFAULTADVANCE, /* Scheduler advance */
 204                    1 /* Enable */);
 205
 206     /* Initialize scheduler time variables. */
 207     sys_time = 0;
 208     sys_time_per_dsp_tick = (TIMEUNITPERSEC) *
 209                             ((double) sys_schedblocksize) / sys_dacsr;
 210
 211
 212     /* Create stacks for threads. */
 213     core_stack = getbytes(CORESTACKSIZE);
 214     gui_stack = getbytes(GUISTACKSIZE);
 215     if(core_stack == NULL || gui_stack == NULL)
 216     {
 217         rb->splash(HZ, "Not enough memory!");
 218         return PLUGIN_ERROR;
 219     }
 220
 221 #ifdef HAVE_SCHEDULER_BOOSTCTRL
 222     /* Boost CPU. */
 223     rb->trigger_cpu_boost();
 224 #endif
 225
 226     /* Start threads. */
 227     core_thread_id =
 228         rb->create_thread(&core_thread,
 229                           core_stack,
 230                           CORESTACKSIZE,
 231                           0, /* FIXME Which flags? */
 232                           "PD core"
 233                           IF_PRIO(, PRIORITY_REALTIME)
 234                           IF_COP(, COP));
 235
 236     gui_thread_id =
 237         rb->create_thread(&gui_thread,
 238                           gui_stack,
 239                           GUISTACKSIZE,
 240                           0, /* FIXME Which flags? */
 241                           "PD GUI"
 242                           IF_PRIO(, PRIORITY_USER_INTERFACE)
 243                           IF_COP(, CPU));
 244
 245     /* If having an error creating threads, bail out. */
 246     if(core_thread_id == 0 || gui_thread_id == 0)
 247         return PLUGIN_ERROR;
 248
 249     /* Main loop. */
 250     while(!quit)
 251     {
 252         /* Add time slice in milliseconds. */
 253         runningtime += (1000 / HZ);
 254
 255         /* Sleep to the next time slice. */
 256         rb->sleep(1);
 257     }
 258
 259     /* Wait for threads to complete. */
 260     rb->thread_wait(gui_thread_id);
 261     rb->thread_wait(core_thread_id);
 262
 263 #ifdef HAVE_SCHEDULER_BOOSTCTRL
 264     /* Unboost CPU. */
 265     rb->cancel_cpu_boost();
 266 #endif
 267
 268     /* Close audio subsystem. */
 269     sys_close_audio();
 270
 271     /* Destroy net. */
 272     net_destroy();
 273
 274     /* Clear memory pool. */
 275     destroy_memory_pool(mem_pool);
 276
 277     return PLUGIN_OK;
 278 }
 279