comparison examples/basic_libpd/render.cpp @ 338:1802f99cd77f prerelease

Initial support for thread-safe libpd (stil missing updated libpd binary), untested

 #include <Utilities.h>
 #include <I2c_Codec.h>
 #include <PRU.h>
 #include <stdio.h>
 #include "z_libpd.h"
+#include "z_queued.h"
 #include <UdpServer.h>
 #include <Midi.h>
 
 
 // setup() is called once before the audio rendering starts.

 	if(context->audioFrames < gLibPdBlockSize){
 		fprintf(stderr, "Error: minimum block size must be %d\n", gLibPdBlockSize);
 		return false;
 	}
 	// init pd
-	libpd_set_printhook(Bela_printHook); // set this before calling libpd_init
-	libpd_set_noteonhook(pdnoteon);
-	libpd_init();
+	libpd_set_queued_printhook(Bela_printHook); // set this before calling libpd_init
+	libpd_set_queued_noteonhook(pdnoteon);
+	libpd_queued_init();
 	//TODO: analyse the ASCII of the patch file and find the in/outs to use
 	libpd_init_audio(gChannelsInUse, gChannelsInUse, context->audioSampleRate);
 
 	libpd_start_message(1); // one entry in list
 	libpd_add_float(1.0f);

 		}
 	}
 	// rt_printf("inW %d\n", inW);
 	if(inW == 0){ //if the buffer is full, process it
 		static int numberOfPdBlocksToProcess = gBufLength/gLibPdBlockSize;
+		// TODO: see if we can rewrite libpd_process_float so that it takes a buffer
+		// of interleaved channels of arbitrary length channels rather than a series of
+		// stacked buffers of size gLibPdBlockSize as it currently does.
 		libpd_process_float(numberOfPdBlocksToProcess, gInBuf, gOutBuf);
 		outR = 0; // reset the read pointer. NOTE: hopefully this is needed only the first time
 	}
 
 	for(unsigned int n = 0; n < context->audioFrames; n++){ //pd buffers are interleaved

 // cleanup() is called once at the end, after the audio has stopped.
 // Release any resources that were allocated in setup().
 
 void cleanup(BelaContext *context, void *userData)
 {
+	libpd_queued_release();
 	free(gInBuf);
 	free(gOutBuf);
 }