comparison examples/basic_libpd/render.cpp @ 353:bec5d43e4e7a prerelease

Digital channels are fully managed by Pd

  *  Created on: Oct 24, 2014
  *      Author: parallels
  */
 
 #include <Bela.h>
-#include <DigitalToMessage.h>
+#include <DigitalChannelManager.h>
 #include <cmath>
 #include <Utilities.h>
 #include <I2c_Codec.h>
 #include <PRU.h>
 #include <stdio.h>

         usleep(1000);
     }
 }
 
 #define PARSE_MIDI
-AuxiliaryTask libpdReadFilesTask;
-Midi midi;
+static AuxiliaryTask libpdReadFilesTask;
+static Midi midi;
+static DigitalChannelManager dcm;
 //UdpServer udpServer;
 
-static uint32_t clearDataOut;
-static uint32_t setDataOut;
-static uint16_t digitalModeClear;
-static uint16_t digitalModeSet;
-static uint16_t digitalRates;
 
 
 void sendDigitalMessage(bool state, unsigned int delay, void* receiverName){
 	libpd_float((char*)receiverName, (float)state);
 //	rt_printf("%s: %d\n", (char*)receiverName, state);

 void Bela_messageHook(const char *source, const char *symbol, int argc, t_atom *argv){
 	if(strcmp(source, "bela_setDigital") == 0){
 		// symbol is the direction, argv[0] is the channel, argv[1] (optional)
 		// is signal(\"sig\" or \"~\") or message(\"mess\", default) rate
 		bool error = false;
-		bool signal = false; // defaults to message rate
+		bool isMessageRate = true; // defaults to message rate
 		bool direction;
 		if(strcmp(symbol, "in") == 0){
 			direction = INPUT;
 		} else if(strcmp(symbol, "out") == 0){
 			direction = OUTPUT;

 		if(argc >= 2){
 			t_atom* a = &argv[1];
 			if(libpd_is_symbol(a)){
 				char *s = libpd_get_symbol(a);
 				if(strcmp(s, "~") == 0  || strncmp(s, "sig", 3) == 0){
-					signal = true;
-				}
-			}
-		}
-		digitalRates = changeBit(digitalRates, channel, signal);
-		if(direction == 1){
-			digitalModeClear = setBit(digitalModeClear, channel);
-			digitalModeSet = clearBit(digitalModeSet, channel);
-		} else {
-			digitalModeSet = setBit(digitalModeSet, channel);
-			digitalModeClear = clearBit(digitalModeClear, channel);
-		}
-//		rt_printf("Channel: %d, input?: %d, ~?: %d\n", channel, direction==INPUT, signal);
-//		rt_printf("modeSet 0x%x modeClear 0x%x\n", digitalModeSet, digitalModeClear);
+					isMessageRate = false;
+				}
+			}
+		}
+		dcm.setPinMode(channel, direction, isMessageRate);
 	}
 }
 
 void Bela_floatHook(const char *source, float value){
 //	rt_printf("received: %s %f\n", source, value);

 				receiver += (source[prefixLength+1] - 48);
 //				rt_printf("received on digital %d value %.0f\n", receiver, value);
 				unsigned int channel = receiver - 11; // go back to the actual Bela digital channel number
 				if(channel >= 0 && channel < 16){ //16 is the hardcoded value for the number of digital channels
 					//TODO: here we should check if this channel has been registered as message-rate output
-					if(value == 0){
-						clearDataOut = setBit(clearDataOut, channel);
-						setDataOut = clearBit(setDataOut, channel);
-					} else {
-						setDataOut = setBit(setDataOut, channel);
-						clearDataOut = clearBit(clearDataOut, channel);
-					}
+					dcm.setOutput(channel, value);
 //					rt_printf("clear 0x%x set 0x%x\n", clearDataOut, setDataOut);
 				}
 			}
 		}
 	}

 	{"bela_digitalIn16"},{"bela_digitalIn17"},{"bela_digitalIn18"},{"bela_digitalIn19"},{"bela_digitalIn20"},
 	{"bela_digitalIn21"},{"bela_digitalIn22"},{"bela_digitalIn23"},{"bela_digitalIn24"},{"bela_digitalIn25"},
 	{"bela_digitalIn26"}
 };
 
-static DigitalToMessage** dtm;
 static unsigned int analogChannelsInUse;
 static unsigned int gLibpdBlockSize;
 static unsigned int gChannelsInUse = 26;
 
 bool setup(BelaContext *context, void *userData)
 {
+	dcm.setCallback(sendDigitalMessage);
 	analogChannelsInUse = min(context->analogChannels, gChannelsInUse - context->audioChannels - context->digitalChannels);
-	dtm = new DigitalToMessage* [context->digitalChannels];
 	if(context->digitalChannels > 0){
 		for(unsigned int ch = 0; ch < context->digitalChannels; ++ch){
-			dtm[ch] = new DigitalToMessage;
-			dtm[ch]->setCallback(sendDigitalMessage, receiverNames[ch]);
-			if((ch%2) == 0 )
-				pinMode(context, 0, ch, INPUT);
-			else
-				pinMode(context, 0, ch, OUTPUT);
+			dcm.setCallbackArgument(ch, receiverNames[ch]);
 		}
 	}
 	midi.readFrom(0);
 	midi.writeTo(0);
 #ifdef PARSE_MIDI

 	libpd_add_float(1.0f);
 	libpd_finish_message("pd", "dsp");
 
 	gBufLength = max(gLibpdBlockSize, context->audioFrames);
 
-	char file[] = "_main.pd";
-	char folder[] = "./";
-	// open patch       [; pd open file folder(
-	libpd_openfile(file, folder);
 
 	// bind your receivers here
 	libpd_bind("bela_digitalOut11");
 	libpd_bind("bela_digitalOut12");
 	libpd_bind("bela_digitalOut13");

 	libpd_bind("bela_digitalOut24");
 	libpd_bind("bela_digitalOut25");
 	libpd_bind("bela_digitalOut26");
 	libpd_bind("bela_setDigital");
 
+	char file[] = "_main.pd";
+	char folder[] = "./";
+	// open patch       [; pd open file folder(
+	libpd_openfile(file, folder);
 	libpdReadFilesTask = Bela_createAuxiliaryTask(libpdReadFilesLoop, 60, "libpdReadFiles");
 	Bela_scheduleAuxiliaryTask(libpdReadFilesTask);
 
 
 	return true;

 				}
 			}
 		}
 
 		//then digital
-		 //TODO: in multiple places below we assume that the number of digitals is same as number of audio
+		// note: in multiple places below we assume that the number of digitals is same as number of audio
 		// digital in at message-rate
-		for(unsigned int n = 0; n < context->digitalChannels; ++n){
-			// note that we consider only the first sample of the block
-			// considering all of them is notably more expensive
-			// TODO: only process the channels marked as such
-			dtm[n]->process(n + 16, &context->digital[audioFrameBase], 1);
-		}
+		dcm.processInput(&context->digital[audioFrameBase], gLibpdBlockSize);
+
 		// digital in at signal-rate
 		for (j = 0, p0 = gInBuf; j < gLibpdBlockSize; j++, p0++) {
+			unsigned int digitalFrame = audioFrameBase + j;
 			for (k = 0, p1 = p0 + gLibpdBlockSize * (context->audioChannels + 8);
 					k < 16; ++k, p1 += gLibpdBlockSize) {
-				// note that we only write the last sample of the block
-				// writing all of them is notably more expensive.
-
-				// TODO: only process the channels marked as such
-				unsigned int digitalFrame = audioFrameBase + j;
-				*p1 = digitalRead(context, digitalFrame, k);
+				if(dcm.isSignalRate(k) && dcm.isInput(k)){ // only process input channels that are handled at signal rate
+					*p1 = digitalRead(context, digitalFrame, k);
+				}
 			}
 		}
 
 		libpd_process_sys(); // process the block
 
 		//digital out
-		// digital out at  signal-rate
+		// digital out at signal-rate
 		for (j = 0, p0 = gOutBuf; j < gLibpdBlockSize; ++j, ++p0) {
 			unsigned int digitalFrame = (audioFrameBase + j);
 			for (k = 0, p1 = p0  + gLibpdBlockSize * (context->audioChannels + 8);
 					k < context->digitalChannels; k++, p1 += gLibpdBlockSize) {
-				// TODO: only process the channels marked as such
-				digitalWriteOnce(context, digitalFrame, k, *p1 > 0.5);
+				if(dcm.isSignalRate(k) && dcm.isOutput(k)){ // only process output channels that are handled at signal rate
+					digitalWriteOnce(context, digitalFrame, k, *p1 > 0.5);
+				}
 			}
 		}
 
 		// digital out at message-rate
-		if(clearDataOut || setDataOut || digitalModeSet || digitalModeClear){
-			uint32_t orWord = ((setDataOut << 16) | digitalModeSet);
-			uint32_t andTildeWord = ((clearDataOut << 16) | digitalModeClear);
-			uint32_t outWord;
-			for (unsigned int frame = audioFrameBase; frame < audioFrameBase + gLibpdBlockSize; ++frame) {
-				outWord = context->digital[frame];
-				outWord = outWord | orWord;
-				outWord = outWord &~ andTildeWord;
-				context->digital[frame] = outWord;
-			}
-		}
+		dcm.processOutput(&context->digital[audioFrameBase], gLibpdBlockSize);
 
 		//audio
 		for (j = 0, p0 = gOutBuf; j < gLibpdBlockSize; j++, p0++) {
 			for (k = 0, p1 = p0; k < context->audioChannels; k++, p1 += gLibpdBlockSize) {
 				audioWrite(context, audioFrameBase + j, k, *p1);

 // 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)
 {
-	delete[] dtm;
-}
+}