diff options
Diffstat (limited to 'puredata')
| -rw-r--r-- | puredata/pdp_comm.c | 17 | ||||
| -rw-r--r-- | puredata/pdp_queue.c | 10 |
2 files changed, 21 insertions, 6 deletions
diff --git a/puredata/pdp_comm.c b/puredata/pdp_comm.c index 4c67659..2674e36 100644 --- a/puredata/pdp_comm.c +++ b/puredata/pdp_comm.c @@ -116,12 +116,16 @@ void pdp_packet_pass_if_valid(t_outlet *outlet, int *packet_ptr) { + + t_pdp *header = pdp_packet_header(*packet_ptr); if (header){ + /* send register phase */ outlet_pdp_register(outlet, *packet_ptr); + /* unregister */ pdp_packet_mark_unused(*packet_ptr); *packet_ptr = -1; @@ -129,7 +133,9 @@ pdp_packet_pass_if_valid(t_outlet *outlet, int *packet_ptr) /* send process phase */ outlet_pdp_process(outlet); + } + } void @@ -317,7 +323,7 @@ void pd_atom_to_pdp_atom(t_atom *pdatom, t_pdp_atom *pdpatom) } } - +#if PDP_SYMBOL_HACK /* some "accelerated" pd symbols */ t_symbol s_pdp = {"pdp", 0, 0}; @@ -329,6 +335,8 @@ t_symbol s_inspect = {"inspect", 0, 0}; t_symbol s_accumulate = {"accumulate", 0, 0}; t_symbol s_chanmask = {"chanmask", 0, 0}; + + // internal pd method t_symbol *dogensym(char *s, t_symbol *oldsym); static void _addsym(t_symbol *s) @@ -345,6 +353,7 @@ static void _addsym(t_symbol *s) } } + void pdp_pdsym_setup(void) { @@ -360,6 +369,12 @@ pdp_pdsym_setup(void) } +#else + +void pdp_pdsym_setup(void){ +} + +#endif #ifdef __cplusplus diff --git a/puredata/pdp_queue.c b/puredata/pdp_queue.c index b66289a..f5a9d65 100644 --- a/puredata/pdp_queue.c +++ b/puredata/pdp_queue.c @@ -79,10 +79,10 @@ void pdp_procqueue_wait(t_pdp_procqueue *q) D post("pdp_procqueue_wait(%x): pdp_procqueue_thread has finished processing", q); } -void pdp_procqueue_finish(t_pdp_procqueue *q, int index) +void pdp_procqueue_finish(t_pdp_procqueue *q, int indx) { - if (-1 == index) { + if (-1 == indx) { //post("pdp_pq_remove: index == -1"); return; } @@ -90,8 +90,8 @@ void pdp_procqueue_finish(t_pdp_procqueue *q, int index) pdp_procqueue_wait(q); /* invalidate callback at index */ - q->q[index & q->mask].x_callback = 0; - q->q[index & q->mask].x_queue_id = 0; + q->q[indx & q->mask].x_callback = 0; + q->q[indx & q->mask].x_queue_id = 0; } @@ -364,7 +364,7 @@ t_pdp_procqueue *pdp_queue_get_queue(void){return &pdp_queue;} #if 1 /* default pdp queue shortcut methods */ void pdp_queue_wait() {pdp_procqueue_wait(&pdp_queue);} -void pdp_queue_finish(int index) { pdp_procqueue_finish(&pdp_queue, index);} +void pdp_queue_finish(int indx) { pdp_procqueue_finish(&pdp_queue, indx);} void pdp_queue_add(void *owner, void *process, void *callback, int *queue_id) { pdp_procqueue_add(&pdp_queue, owner, process, callback, queue_id); } |