From c3f5ea53917dea9c80751ee5809c7455589888be Mon Sep 17 00:00:00 2001 From: Hans-Christoph Steiner Date: Thu, 15 Dec 2005 07:41:49 +0000 Subject: oops, mixed a few svn path=/trunk/externals/pdp/; revision=4218 --- abstractions/pdp_affine.pd | 15 - abstractions/pdp_agc.pd | 28 -- abstractions/pdp_blur.pd | 27 -- abstractions/pdp_blur_hor.pd | 27 -- abstractions/pdp_blur_ver.pd | 27 -- abstractions/pdp_cheby3o.pd | 22 -- abstractions/pdp_contrast.pd | 41 -- abstractions/pdp_conv_alledge.pd | 28 -- abstractions/pdp_conv_emboss.pd | 37 -- abstractions/pdp_conv_smooth.pd | 14 - doc/misc/devdoc.html | 167 -------- doc/misc/layers.txt | 222 ----------- doc/misc/overview.html | 102 ----- doc/misc/todo.jme | 4 - opengl/doc/examples/arm.pd | 40 -- opengl/doc/examples/example01.pd | 257 ------------- opengl/doc/examples/example02.pd | 46 --- opengl/doc/examples/example03.pd | 65 ---- opengl/doc/examples/example04.pd | 25 -- opengl/doc/examples/example05.pd | 41 -- opengl/doc/examples/example06.pd | 85 ----- opengl/doc/examples/example07.pd | 25 -- opengl/doc/examples/example08.pd | 94 ----- opengl/doc/examples/example09.pd | 90 ----- opengl/doc/examples/example10.pd | 39 -- opengl/doc/examples/example11.pd | 77 ---- opengl/doc/examples/example12.pd | 90 ----- opengl/doc/examples/example13.pd | 81 ---- opengl/doc/examples/example14.pd | 66 ---- opengl/doc/examples/example15.pd | 126 ------ opengl/doc/examples/example16.pd | 107 ------ opengl/doc/objects/3dp_for.pd | 91 ----- puredata/CONTENTS | 10 - puredata/Makefile | 12 - puredata/pdp_base.c | 415 -------------------- puredata/pdp_comm.c | 367 ------------------ puredata/pdp_compat.c | 57 --- puredata/pdp_control.c | 186 --------- puredata/pdp_dpd_base.c | 270 ------------- puredata/pdp_forthproc.c_bak | 807 --------------------------------------- puredata/pdp_imagebase.c | 79 ---- puredata/pdp_queue.c | 386 ------------------- puredata/pdp_ut.c | 262 ------------- system/net/Makefile | 11 - system/net/pdp_net.c | 685 --------------------------------- 45 files changed, 5753 deletions(-) delete mode 100644 abstractions/pdp_affine.pd delete mode 100644 abstractions/pdp_agc.pd delete mode 100644 abstractions/pdp_blur.pd delete mode 100644 abstractions/pdp_blur_hor.pd delete mode 100644 abstractions/pdp_blur_ver.pd delete mode 100644 abstractions/pdp_cheby3o.pd delete mode 100644 abstractions/pdp_contrast.pd delete mode 100644 abstractions/pdp_conv_alledge.pd delete mode 100644 abstractions/pdp_conv_emboss.pd delete mode 100644 abstractions/pdp_conv_smooth.pd delete mode 100644 doc/misc/devdoc.html delete mode 100644 doc/misc/layers.txt delete mode 100644 doc/misc/overview.html delete mode 100644 doc/misc/todo.jme delete mode 100644 opengl/doc/examples/arm.pd delete mode 100644 opengl/doc/examples/example01.pd delete mode 100644 opengl/doc/examples/example02.pd delete mode 100644 opengl/doc/examples/example03.pd delete mode 100644 opengl/doc/examples/example04.pd delete mode 100644 opengl/doc/examples/example05.pd delete mode 100644 opengl/doc/examples/example06.pd delete mode 100644 opengl/doc/examples/example07.pd delete mode 100644 opengl/doc/examples/example08.pd delete mode 100644 opengl/doc/examples/example09.pd delete mode 100644 opengl/doc/examples/example10.pd delete mode 100644 opengl/doc/examples/example11.pd delete mode 100644 opengl/doc/examples/example12.pd delete mode 100644 opengl/doc/examples/example13.pd delete mode 100644 opengl/doc/examples/example14.pd delete mode 100644 opengl/doc/examples/example15.pd delete mode 100644 opengl/doc/examples/example16.pd delete mode 100644 opengl/doc/objects/3dp_for.pd delete mode 100644 puredata/CONTENTS delete mode 100644 puredata/Makefile delete mode 100644 puredata/pdp_base.c delete mode 100644 puredata/pdp_comm.c delete mode 100644 puredata/pdp_compat.c delete mode 100644 puredata/pdp_control.c delete mode 100644 puredata/pdp_dpd_base.c delete mode 100644 puredata/pdp_forthproc.c_bak delete mode 100644 puredata/pdp_imagebase.c delete mode 100644 puredata/pdp_queue.c delete mode 100644 puredata/pdp_ut.c delete mode 100644 system/net/Makefile delete mode 100644 system/net/pdp_net.c diff --git a/abstractions/pdp_affine.pd b/abstractions/pdp_affine.pd deleted file mode 100644 index 831d8ae..0000000 --- a/abstractions/pdp_affine.pd +++ /dev/null @@ -1,15 +0,0 @@ -#N canvas 600 556 450 300 10; -#X obj 47 39 inlet; -#X obj 111 39 inlet; -#X obj 170 38 inlet; -#X obj 98 151 pdp_cheby; -#X obj 63 205 outlet; -#X text 26 7 for patch compatibility with older versions of pdp; -#X msg 119 98 coef 1 \$1; -#X msg 197 97 coef 0 \$1; -#X connect 0 0 3 0; -#X connect 1 0 6 0; -#X connect 2 0 7 0; -#X connect 3 0 4 0; -#X connect 6 0 3 0; -#X connect 7 0 3 0; diff --git a/abstractions/pdp_agc.pd b/abstractions/pdp_agc.pd deleted file mode 100644 index bd67c58..0000000 --- a/abstractions/pdp_agc.pd +++ /dev/null @@ -1,28 +0,0 @@ -#N canvas 572 396 450 300 10; -#X obj 174 115 pdp_cog; -#X obj 174 222 /; -#X obj 174 147 t b f; -#X obj 116 89 pdp_t p p; -#X obj 116 252 pdp_gain; -#X text 22 13 an automatic gain control using the pdp_cog object; -#X obj 23 40 inlet; -#X obj 238 146 inlet; -#X obj 174 183 f \$1; -#X obj 116 279 outlet; -#X text 158 36 creation argument or right inlet; -#X text 157 51 is desired average intensity; -#X obj 23 62 route chanmask; -#X msg 23 102 chanmask \$1; -#X connect 0 0 2 0; -#X connect 1 0 4 1; -#X connect 2 0 8 0; -#X connect 2 1 1 1; -#X connect 3 0 4 0; -#X connect 3 1 0 0; -#X connect 4 0 9 0; -#X connect 6 0 12 0; -#X connect 7 0 8 1; -#X connect 8 0 1 0; -#X connect 12 0 13 0; -#X connect 12 1 3 0; -#X connect 13 0 4 0; diff --git a/abstractions/pdp_blur.pd b/abstractions/pdp_blur.pd deleted file mode 100644 index 46425dd..0000000 --- a/abstractions/pdp_blur.pd +++ /dev/null @@ -1,27 +0,0 @@ -#N canvas 344 526 521 227 10; -#X obj 26 33 inlet; -#X obj 26 174 outlet; -#X obj 26 134 pdp_bq; -#X obj 70 66 pdp_ut_addscaleclip -1 -0.5 0.05 0.48; -#X obj 70 33 inlet; -#X msg 181 34 2; -#X msg 70 98 lpf \$1 0.25; -#X msg 136 34 0; -#X obj 136 10 loadbang; -#X msg 163 98 hor 1; -#X msg 209 98 ver 1; -#X text 100 138 this uses pdp_bq as a 2 pass lowpass filter to produce -a blur effect in all directions; -#X connect 0 0 2 0; -#X connect 2 0 1 0; -#X connect 3 0 6 0; -#X connect 4 0 3 0; -#X connect 5 0 2 1; -#X connect 6 0 2 0; -#X connect 7 0 3 0; -#X connect 8 0 7 0; -#X connect 8 0 5 0; -#X connect 8 0 9 0; -#X connect 8 0 10 0; -#X connect 9 0 2 0; -#X connect 10 0 2 0; diff --git a/abstractions/pdp_blur_hor.pd b/abstractions/pdp_blur_hor.pd deleted file mode 100644 index 00c4f89..0000000 --- a/abstractions/pdp_blur_hor.pd +++ /dev/null @@ -1,27 +0,0 @@ -#N canvas 344 526 521 227 10; -#X obj 26 33 inlet; -#X obj 26 174 outlet; -#X obj 26 134 pdp_bq; -#X obj 70 66 pdp_ut_addscaleclip -1 -0.5 0.05 0.48; -#X obj 70 33 inlet; -#X msg 181 34 2; -#X msg 70 98 lpf \$1 0.25; -#X msg 136 34 0; -#X obj 136 10 loadbang; -#X msg 163 98 hor 1; -#X msg 209 98 ver 0; -#X text 100 138 this uses pdp_bq as a 2 pass lowpass filter to produce -a horzontal blur effect; -#X connect 0 0 2 0; -#X connect 2 0 1 0; -#X connect 3 0 6 0; -#X connect 4 0 3 0; -#X connect 5 0 2 1; -#X connect 6 0 2 0; -#X connect 7 0 3 0; -#X connect 8 0 7 0; -#X connect 8 0 5 0; -#X connect 8 0 9 0; -#X connect 8 0 10 0; -#X connect 9 0 2 0; -#X connect 10 0 2 0; diff --git a/abstractions/pdp_blur_ver.pd b/abstractions/pdp_blur_ver.pd deleted file mode 100644 index 915931f..0000000 --- a/abstractions/pdp_blur_ver.pd +++ /dev/null @@ -1,27 +0,0 @@ -#N canvas 368 520 521 227 10; -#X obj 26 33 inlet; -#X obj 26 174 outlet; -#X obj 26 134 pdp_bq; -#X obj 70 66 pdp_ut_addscaleclip -1 -0.5 0.05 0.48; -#X obj 70 33 inlet; -#X msg 181 34 2; -#X msg 70 98 lpf \$1 0.25; -#X msg 136 34 0; -#X obj 136 10 loadbang; -#X text 100 138 this uses pdp_bq as a 2 pass lowpass filter to produce -a vertical blur effect; -#X msg 209 98 ver 1; -#X msg 163 98 hor 0; -#X connect 0 0 2 0; -#X connect 2 0 1 0; -#X connect 3 0 6 0; -#X connect 4 0 3 0; -#X connect 5 0 2 1; -#X connect 6 0 2 0; -#X connect 7 0 3 0; -#X connect 8 0 7 0; -#X connect 8 0 5 0; -#X connect 8 0 11 0; -#X connect 8 0 10 0; -#X connect 10 0 2 0; -#X connect 11 0 2 0; diff --git a/abstractions/pdp_cheby3o.pd b/abstractions/pdp_cheby3o.pd deleted file mode 100644 index db9c83f..0000000 --- a/abstractions/pdp_cheby3o.pd +++ /dev/null @@ -1,22 +0,0 @@ -#N canvas 29 385 450 300 10; -#X obj 42 87 inlet; -#X obj 194 189 outlet; -#X obj 194 159 pdp_cheby 3; -#X msg 115 87 coef 0 \$1; -#X msg 194 86 coef 1 \$1; -#X msg 278 85 coef 2 \$1; -#X msg 358 84 coef 3 \$1; -#X obj 115 62 inlet; -#X obj 194 62 inlet; -#X obj 278 61 inlet; -#X obj 358 60 inlet; -#X connect 0 0 2 0; -#X connect 2 0 1 0; -#X connect 3 0 2 0; -#X connect 4 0 2 0; -#X connect 5 0 2 0; -#X connect 6 0 2 0; -#X connect 7 0 3 0; -#X connect 8 0 4 0; -#X connect 9 0 5 0; -#X connect 10 0 6 0; diff --git a/abstractions/pdp_contrast.pd b/abstractions/pdp_contrast.pd deleted file mode 100644 index 83e8cce..0000000 --- a/abstractions/pdp_contrast.pd +++ /dev/null @@ -1,41 +0,0 @@ -#N canvas 700 349 450 324 10; -#X obj 42 159 pdp_sthresh; -#X obj 42 261 pdp_gain; -#X msg 100 211 -1; -#X obj 100 235 /; -#X obj 170 195 - 1; -#X obj 170 167 * 2; -#X text 10 -1 contrast enhancement (works on YCrCb and greyscale); -#X obj 170 100 moses 0.49; -#X msg 235 123 0.49; -#X obj 262 83 / 2; -#X msg 87 101 chanmask 1; -#X obj 170 46 loadbang; -#X obj 170 75 f \$1; -#X obj 42 47 inlet; -#X obj 262 45 inlet; -#X obj 42 285 outlet; -#X text 11 13 i.e. to process the output of pdp_agc; -#X obj 170 141 f; -#X obj 42 185 pdp_t p b; -#X connect 0 0 18 0; -#X connect 1 0 15 0; -#X connect 2 0 3 0; -#X connect 3 0 1 1; -#X connect 4 0 3 1; -#X connect 5 0 4 0; -#X connect 7 0 17 0; -#X connect 7 1 8 0; -#X connect 8 0 17 0; -#X connect 9 0 7 0; -#X connect 10 0 1 0; -#X connect 10 0 0 0; -#X connect 11 0 10 0; -#X connect 11 0 12 0; -#X connect 12 0 7 0; -#X connect 13 0 0 0; -#X connect 14 0 9 0; -#X connect 17 0 0 1; -#X connect 17 0 5 0; -#X connect 18 0 1 0; -#X connect 18 1 2 0; diff --git a/abstractions/pdp_conv_alledge.pd b/abstractions/pdp_conv_alledge.pd deleted file mode 100644 index 0433c16..0000000 --- a/abstractions/pdp_conv_alledge.pd +++ /dev/null @@ -1,28 +0,0 @@ -#N canvas 245 202 522 199 10; -#X obj 29 17 inlet; -#X obj 29 156 outlet; -#X obj 29 97 pdp_conv; -#X msg 95 36 hmask 0.33 0.33 0.33; -#X msg 95 59 vmask -0.33 -0.33 -0.33; -#X obj 29 126 pdp_add; -#X obj 95 13 loadbang; -#X obj 292 34 int; -#X obj 292 56 * 2; -#X obj 292 79 - 1; -#X obj 292 12 inlet; -#X text 101 115 pdp_alledge is an all edge sensitive convolution filter -using pdp_add and pdp_conv to compose a non separable edge detection -convolution mask (pdp_conv can only compute separable convolution masks). -the right inlet sets number of times the filter is run (2n-1); -#X connect 0 0 2 0; -#X connect 0 0 5 1; -#X connect 2 0 5 0; -#X connect 3 0 2 0; -#X connect 3 0 4 0; -#X connect 4 0 2 0; -#X connect 5 0 1 0; -#X connect 6 0 3 0; -#X connect 7 0 8 0; -#X connect 8 0 9 0; -#X connect 9 0 2 1; -#X connect 10 0 7 0; diff --git a/abstractions/pdp_conv_emboss.pd b/abstractions/pdp_conv_emboss.pd deleted file mode 100644 index 5346bde..0000000 --- a/abstractions/pdp_conv_emboss.pd +++ /dev/null @@ -1,37 +0,0 @@ -#N canvas 172 505 641 290 10; -#X obj 30 55 inlet; -#X obj 29 206 outlet; -#X obj 29 93 pdp_conv; -#X obj 29 126 pdp_add; -#X obj 108 9 loadbang; -#X obj 218 86 pdp_conv; -#X obj 29 176 pdp_affine 1; -#X msg 108 151 0.5; -#X msg 108 37 hmask 1 0 0; -#X msg 218 35 hmask 0 0 1; -#X obj 145 151 inlet; -#X text 142 178 this uses pdp_conv \, pdp_add and pdp_affine to produce -an emboss effect using the convolution mask (-1 0 0 \; 0 0 0 \; 0 0 -1) the right inlet sets the chroma offset.; -#X msg 218 60 vmask 0 0 1; -#X msg 108 60 vmask -1 0 0; -#X msg 108 128 chanmask 1; -#X connect 0 0 2 0; -#X connect 0 0 5 0; -#X connect 2 0 3 0; -#X connect 3 0 6 0; -#X connect 4 0 8 0; -#X connect 4 0 9 0; -#X connect 5 0 3 1; -#X connect 6 0 1 0; -#X connect 7 0 6 2; -#X connect 8 0 2 0; -#X connect 8 0 13 0; -#X connect 9 0 5 0; -#X connect 9 0 12 0; -#X connect 10 0 6 2; -#X connect 12 0 5 0; -#X connect 13 0 2 0; -#X connect 13 0 14 0; -#X connect 14 0 6 0; -#X connect 14 0 7 0; diff --git a/abstractions/pdp_conv_smooth.pd b/abstractions/pdp_conv_smooth.pd deleted file mode 100644 index e37320e..0000000 --- a/abstractions/pdp_conv_smooth.pd +++ /dev/null @@ -1,14 +0,0 @@ -#N canvas 490 446 522 199 10; -#X obj 29 17 inlet; -#X obj 29 156 outlet; -#X obj 29 97 pdp_conv; -#X obj 95 13 loadbang; -#X obj 292 12 inlet; -#X msg 95 36 mask 0.33 0.33 0.33; -#X text 107 108 pdp_conv_smooth is an averaging convolution filter. -second inlet sets number of passes.; -#X connect 0 0 2 0; -#X connect 2 0 1 0; -#X connect 3 0 5 0; -#X connect 4 0 2 1; -#X connect 5 0 2 0; diff --git a/doc/misc/devdoc.html b/doc/misc/devdoc.html deleted file mode 100644 index 5ce1f83..0000000 --- a/doc/misc/devdoc.html +++ /dev/null @@ -1,167 +0,0 @@ - - - - PDP Developer Documentation - - - -

PDP Developer Documentation

- -

Introduction

- -

There is not yet much developer information, partly because pdp is not that big and since the goals are - not completely clear yet, a lot will probably change on the inside in the future. I believe it is - not too hard to figure out how it works, once you get started somewhere. This document is a minimalistic - attempt to provide that starting point. For full prototypes see the header files. I suggest you have a look at the pdp_base base class, and some simple - modules: pdp_add, pdp_noise and pdp_gain for examples. - -

PDP architecture

-

Architecture is a big word, but pdp is organized as modules. A packet pool module (a reuse pool memory manager), - a packet class, a processing queue module, a high level type conversion module, an image packet class, and some - low level modules for image type conversion, image resampling and all sorts of other image processing. Besides that - there are 2 extension libraries: pdp_scaf, a cellular automata extension and pdp_opengl, a 3d rendering extension. - These are separate because of portability issues. The different pdp_* externs in the main pdp library use the - core modules' functionality to minimize code duplication. I'm relatively happy with how it fits together, - but some things need to change for future plans. Most objects are written in the object oriented c style of pd. - To prevent namespace conflicts, (almost) all routines start with the pdp_ prefix. The second name is the name of the - object or module they belong to. The first argument is always a pointer to an object or an integer (for packets). - - -

PD ties

-

PDP is written as an extension for PD. One of the goals of pdp is to evolve to a separate library that can - be reused in other software. The architecture will be split into two parts. A pd-independent part (the packet classes, - the packet pool, the type conversion system and the forth system) and a part with pd specific stuff (the process queue and interfaces to the - pd system like the base classes and the pd communication protocol). In order to do this the packet class will probably - evolve to a proper object model, supporting run time attribute binding (inspired by the python object model). - -

There are some things that put a stamp on the current pdp design. Most importantly pd's processor object model and - communication protocol. (i.e. the fact that pd only supports unidirectional messaging creates the awkward concept - of a "passing packet" to eliminate excessive data copying.) - -

In pd, the pdp messaging protocol is implemented as pd messages. The protocol is however 3 phase. - With a read only register phase, a read/write register phase and a process phase. This functionality - is part of the base class or the forth processor object. The dpd protocol is entirely different, - and is used in the opengl library. It is - not based on parallel dataflow but serial context passing. - -

Packets

-

PDP introduces a new atom: the data packet. This can contain all kinds of data. Images (16bit/8bit), cellular - automata (1bit), matrices (real/complex float/double), opengl textures and 3d rendering contexts. Packets - are stored in a pool to ensure fast reuse, and to enable sharing. The paradigm is centered around a - combination of an object oriented approach and a dataflow approach. -

The methods operating on packets - (pdp_packet_*) are mainly for administrative purposes: memory management (construction, registering, copying) - and getting or setting info. -

All processing is done in the pd modules. Processors can be defined using - the forth scripting language, but this is still experimental. The forth system can be accessed - from the guile library. -

There is a central mechanism for packet type conversion. This is to facilitate the combination of different - media types. Whenever a packet class is constructed (i.e. in an extension library), a number of conversion - routines should be defined to convert the added type to one or some of the main pdp types. - - - - - - -

PDP API Overview

- - The pdp public api contains only a single class: the packet. (The internal api has more classes, that can be used - too if necessary, but i won't document them.) A packet is a class in pdp. The table below lists the supported methods. - The first argument of a call is a packet id. - - -
pdp_packet_* -
new construct a raw packet (depreciated) -
new_* construct packet of specific type/subtype/... -
mark_unused release -
mark_passing conditional release (release on first copy ro/rw) -
copy_ro readonly (shared) copy -
copy_rw private copy -
clone_rw private copy (copies only meta data, not the content) -
header get the raw header (t_pdp *) -
data get the raw data (void *) -
pass_if_valid send a packet to pd outlet, if it is valid, and mark unused -
replace_if_valid delete packet and replace with new one, if new is valid -
copy_ro_or_drop copy readonly, or don't copy if dest slot is full + send drop notify -
copy_rw_or_drop same, but private copy -
get_description retrieve type info -
convert_ro same as copy_ro, but with an automatic conversion matching a type template -
convert_rw same as convert_ro, but producing a private copy -
- - -

The pool object methods. All the packets are stored in a central packet pool. - - -
pdp_pool_* -
collect_garbage manually free all unused resources in packet pool -
- -

The process queue object methods. PDP supports a separate processing thread. - - -
pdp_queue_* -
add add a process method + callback -
finish wait until a specific task is done -
wait wait until processing queue is done -
- -

The control methods. General pdp control messages. - - -
pdp_control_* -
notify_drop notify that a packet has been dropped -
- -

The type mediator methods. - -
pdp_type_* -
description_match check if two type templates match -
register_conversion register a type conversion program - - -
- - -

NOTE: it is advised to derive your module from the pdp base class defined in pdp_base.h - instead of communicating directly with the pdp core - - - -

pdp_base class

- If you want to write a pdp extern, you can derive it from the pdp_base class, instead of t_object. - This class abstracts a lot of the hassle of writing ordinary (inplace) packet processors. The base - allows you to register process callbacks. There are 3 kinds of callbacks: preproc, process and postproc. - The preproc method is called inside the pd thread. This can be used to setup some things that can only - be done inside the pd thread. The process method should do most of the work, and is called from the - pdp processing thread if it is enabled, after the preproc method is finished. You can't use most - of pd's calls in this method. The postproc method is called - from the pd thread after the process method is finished, and can be used to send data to pd outlets. Simple - packet processors only need the process method (packet input/output is handled by the pdp_base class). - -

pdp_imageproc_* modules

- Most of the image processing code is organized as planar 16 bit signed processors. - This is crude and oversimplified, but it helps to keep the code size small and fast - at the same time (platform dependent assembly code is reduced to a bare minimum). These - routines can be used to build higher level image processing objects that are more (cache) - efficient than an abstraction using separate pdp modules. If you plan to write your own image - processing routines, you can use the pdp_imageproc_dispatch_ routine to support all 16bit image - types at once (greyscale, subsampled YCrCb, multichannel planar). This requires you write the - image processing routine as a planar (greyscale) processor using the pdp_imageproc_ - interface. (see pdp_imageproc.h) - -

pdp_llconv call

- Low level image conversion routines. (operating on raw data buffers). You probably won't need this, - since the high level type conversion (pdp_packet_convert_ro/rw) covers most of its functionality. - - - -
-
Tom Schouten
- - -Last modified: Fri Sep 19 04:52:12 CEST 2003 - - - diff --git a/doc/misc/layers.txt b/doc/misc/layers.txt deleted file mode 100644 index a02e481..0000000 --- a/doc/misc/layers.txt +++ /dev/null @@ -1,222 +0,0 @@ -pdp 0.13 design layers + components ------------------------------------ - -from version 0.13 onwards, pdp is no longer just a pd plugin but a -standalone unix library (libpdp). this documents is an attempt to -describe the design layers. - -A. PD INTERFACE ---------------- - -on the top level, libpdp is interfaced to pd using a glue layer which -consists of - -1. pdp/dpd protocols for pd -2. process queue -3. base classes for pdp/dpd -4. some small utility pd objects -5. pd specific interfaces to part of pdp core -6. pdp_console -7. pd object interface to packet forth (pdp object) - - -1. is the same as previous versions to ensure backwards compatibility in -pd with previous pdp modules and extensions that are written as pd -externs or external libs. this includes parts of pdp that are not yet -migrated to libpdp (some of them are very pd specific and will not be -moved to libpdp), and pidip. if you intend to write new modules, it is -encouraged to use the new forth based api, so your code can be part of -libpdp to use it in other image processing applications. - -2. is considered a pd part. it implements multithreading of pdp inside -pd. multithreading is considered a host interface part, since it usually -requires special code. - -3. the base classes (pd objects) for pdp image processing remain part of -the pd<->pdp layer. the reason is the same as 1. a lot of the original -pd style pdp is written as subclasses of the pdp_base, pdp_image_base, -dpd_base and pdp_3dp_base classes. if you need to write pd specific -code, it is still encouraged to use these apis, since they eliminate a -lot of red tape involving the pdp protocol. a disadvantage is that this -api is badly documented, and the basic api (1.) is a lot simpler to -learn and documented. 3dp is supposed to merge to the new forth api, -along with the image/video processing code. - -4. is small enough to be ignored here - -5. includes interfaces to thread system and type conversion system + -some pd specific stuff using 1. or 3. - -6. the console interface to the pdp core, basicly a console for a -forth like language called packet forth which is pdp's main scripting -language. it's inteded for develloping and testing pdp but it can be -used to write controllers for pd/pdp/... too. this is based on 1. - -7. is the main link between the new libpdp and pd. it is used to -instantiate pdp processors in pd which are written in the packet forth. -i.e. to create a mixer, you instantiate a [pdp mix] object, which would -be the same as the previous [pdp_mix] object. each [pdp] object creates -a forth environment, which is initialized by calling a forth init -method. [pdp mix] would call the forth word init_mix to create the local -environment for the mix object. wrappers will be included for backward -compatibility when the image processing code is moved to libpdp. - - -B. PDP SYSTEM CODE ------------------- - -1. basic building blocks: symbol, list, memory manager -2. packet implementation (packet class and reuse queue) -3. packet type conversion system -4. os interface (X11, net, png, ...) -5. packet forth -6. additional libraries - - -1. pdp makes intensive use of symbols and lists (trees, stacks, queues). -pdp's namespace is built on the symbol implementation. a lot of other -code uses the list - -2. the pdp packet model is very simple. basicly nothing more than -constructors (new, copy, clone), destructors (mark_unused (for reuse -later), delete). there is no real object model for processors. this is a -conscious decision. processor objects are implemented as packet forth -processes with object state stored in process data space. this is enough -to interface the functionality present in packet forth code to any -arbitrary object oriented language or system. - -3. each packet type can register conversion methods to other types. the -type conversion system does the casting. this is not completely finished -yet (no automatic multistage casting yet) but most of it is in place and -usable. no types without casts. - -4. os specific modules for input/output. not much fun here.. - -5. All of pdp is glued together with a scripting language called packet -forth. This is a "high level" forth dialect that can operate on floats, -ints, symbols, lists, trees and packets. It is a "fool proof" forth, -which is polymorphic and relatively robust to user errors (read: it -should not crash or cause memory leaks when experimenting). It is -intended to serve as a packet level glue language, so it is not very -efficient for scalar code. This is usually not a problem, since packet -operations (esp. image processing) are much more expensive than a this -thin layer of glue connecting them. - -All packet operations can be accessed in the forth. If you've ever -worked with HP's RPN calculators, you can use packet forth. The basic -idea is to write objects in packet forth that can be used in pd or in -other image processing applications. For more information on packet -forth, see the code (pdp_forth.h, pdp_forth.c and words.def) - -6. opengl lib, based on dpd (3.) which will be moved to packet forth -words and the cellular automata lib, which will be moved to -vector/slice forth later. - - -C. LOW LEVEL CODE ------------------ - -All the packet processing code is (will be) exported as packet forth -words. This section is about how the code exported by those words is -structured. - -C.1 IMAGE PROESSING: VECTOR FORTH - -Eventually, image operations need to be implemented, and in order -to do this efficiently, both codewize (good modularity) as execution speed -wize, i've opted for another forth. DSP and forth seem to mix well, once -you get the risc pipeline issues out of the way. And, as a less rational -explanation, forth has this magic kind of feel, something like art.. -well, whatever :) - -As opposed to the packet forth, this is a "real" lowlevel forth -optimized for performance. Its reason of being is the solution of 3 -problems: image processing code factoring, quasi optimal processor -pipeline & instruction usage, and locality of reference for maximum -cache performance. Expect crashes when you start experimenting with -this. It's really nothing more than a fancy macro assembler. It has no -safety belts. Chuck Moore doctrine.. - -The distinction between the two forths is at first sight not a good -example of minimizing glue layers. I.e. both systems (packet script -forth and low level slice forth) are forths in essence, requiring -(partial) design duplication. Both implementations are however -significantly different which justified this design duplication. - -Apart from the implementation differences, the purpose of both languages -is not the same. This requires the designs of both languages to be -different in some respect. So, with the rule of "do everything right -once" in mind, this small remark tries to justify the fact that forth != -forth. - -The only place where apparent design correspondence (the language model) -is actually used is in the interface between the packet forth and the -slice forth. - -The base forth is an ordinary minimal 32bit (or machine word -lenght) subroutine threaded forth, with a native code kernel for -i386/mmx, a portable c code kernel and room for more native code kernels -(i.e i386/sse/sse2/3dnow, altivec, dsp, ...) Besides support for native -machine words bit ints and pointers, no floats, since they clash with -mmx, are not needed for the fixed point image type, and can be -implemented using other vector instructions when needed), support for -slices and a separate "vector stack". - -Vectors are the native machine vectors, i.e. 64bit for mmx/3dnow, -128bit for sse/sse2, or anything else. The architecture is supposed to -be open. (I've been thinking to add a block forth, operating on 256bit -blocks to eliminate pipeline issues). Blocks are just blocks of vectors -which are used as a basic loop unrolling data size grain for solving -pipeline operations in slice processing words. - -Slices are just arrays of blocks. In the mmx forth kernel, they can -represent 4 scanlines or a 4 colour component scanline, depending on how -they are fed from packet data. Slices can be anything, but right now, -they're just scanlines. The forth kernel has a very simple and efficient -(branchless) reference count based memory allocator for slices. This -slice allocator is also stack based which ensures locality of reference: -a new allocated slice is the last deallocated slice. - -The reason for this obsession with slices is that a lot of video -effects can be chained on the slice level (scanline or bunch of -scanlines), which improves speed through more locality of reference. In -concreto intermediates are not flushed to slower memory. The same -principles can be used to do audio dsp, but that's for later. - -The mmx forth kernel is further factored down following another -virtual machine paradigm. After doing some profiling, i came to the -conclusion that the only, single paradigm way of writing efficient -vector code on today's machines is multiple accumulators to avoid -pipeline stalls. The nice thing about image processing is that it -parallellizes easily. Hence the slice/block thing. This leads to the -1-operand virtual machine concept for the mmx slice operations. The -basic data size is one 4x4 pixel block (16bit pixels), which is -implemented as asm macros in mmx-sliceops-macro.s and used in -mmx-sliceops-code.s to build slice operations. The slice operations are -built out of macro instructions for this 256bit or 512bit, 2 or 1 -register virtual machine which has practically no pipeline delays -between its instructions. - -Since the base of sliceforth is just another forth, it could be that -(part of) 3dp will be implemented in this lowlevel forth too, if -performance dictates it. It's probably simpler to do it in the lowlevel -forth than the packet forth anyway, in the form of cwords. - -C.2: MATRIX PROCESSING: LIBGSL - -All matrix processing packet forth words are (will be) basicly wrappers -around gsl library calls. Very straightforward. - -C.3: OPENGL STUFF - -The same goes for opengl. The difference here is that it uses the dpd -protocol in pdp, which is more like the Gem way of doing things. The -reason for this is that, although i've tried hard to avoid it, opengl -seems to dictate a drawing context based, instead of an object based way -of working. So processing is context (accumulator) based. Packet forth -will probably get some object oriented, or context oriented feel when -this is implemented. - - - - diff --git a/doc/misc/overview.html b/doc/misc/overview.html deleted file mode 100644 index 6eb0e70..0000000 --- a/doc/misc/overview.html +++ /dev/null @@ -1,102 +0,0 @@ - -Pure Data Packet - - -

Pure Data Packet

- - -

Introduction

- -

Pure Data Packet (PDP) is an extension library for the computer music -program Pure Data (PD), by Miller Puckette and -others. Its goal is to provide a way to use arbitrary data types (data -packets) as messages that can be passed around inside PD, along side the -standard PD numbers and symbol types. In short it puts any data object on -the same level as a float or a symbol. - -

PDP runs on Linux and OSX. The OSX version depends on Fink, which is not in the "point & -click" stage yet, so setting it up will require some efford. There is no -windows version. The reason for this is simple: i don't use windows myself. -Porting would require writing code for input/output and getting the -libraries PDP depends on to work. If anyone is willing to do this, just let -me know. PDP can run without X Window, using SDL. - -

Currently, PDP's focus is on images and video, but there is no reason it -should stay like that. There is limited support for matrix processing -included in the main library (like Jitter or Gridflow). There is an -extension library for 1D and 2D binary cellular automata, opengl rendering -(like Gem). Some plans include audio buffers (like Vasp), ascii packets, -text buffers, ... Finally there's a library that enables you to connect a -scheme interpreter (guile) to PD/PDP. For more image processing objects, -have a look at Yves Degoyon's PiDiP library. - -

Getting Started

- -If you're used to working with PD, the the documentation and example -patches should be enough to get you started. Have a look at the README file -in the distribution to find out how to compile and setup. The file -doc/reference.txt contains a list of objects. If you have installed PDP -properly, you can just press the right mouse button on an object and select -help to get a help patch. If this doesn't work, look in the directory -doc/objects for a collection of help patches. The directory doc/examples -contains some more demos. The directory doc/objects contains two -abstractions that are used to setup the input and output in the help -patches. You might want to cut and connect some wires to use the -input/output setup that works for you. - -

Packets and Types

- -

PDP is centered around the concept of packets and operations on -packets. There are several types of packets. The default type for most -objects is image/YCrCb/320x240. This is a single video -frame, encoded in the internal 16bit YUV format, measuring 320 by 240 -pixels. Another image type is the grayscale image -image/grey/320x240. Important notes: All image processing objects that -combine two or more packets need to be fed with the same packet types, i.e. -encoding (YCrCb/grey) and dimensions need to be the same. Image dimensions need to be a -multiple of 8x8. - -

The -bitmap/*/* type is another image representation type -supporting several encodings. I.e. bitmap/rgb/*, -bitmap/rgba/*, bitmap/yv12/*, ... - -This type cannot be processed directly by most of the image processing -objects, but it can be used to store in delay lines, or to send over the -network. It's main use is to support all kinds of input/output devices, and -opengl textures, without introducing too many conversions, but it can serve -as a space and bandwidth saver too (especially -bitmap/yv12/*). - -

One of the interesting -features in PD is the possibility of connecting everything with everything. -If you want to generalize this to all kinds of media objects, the complexity -of managing the different types starts to grow quite fast. Therefore PDP has -a type conversion system that can take care of most of the conversions -using the [pdp_convert] object. You can manually convert -packets to a certain type by specifying a type template as a creation -argument. I.e. [pdp_convert image/grey/*] will convert -any packet to a greyscale image. Most of the conversion will become -automatic later on. - -

An example: You can use the basic PDP library together with the -cellular automata library and the opengl rendering library to use a cellular -automaton as an input to a video processing chain. You can convert the -processed image to a texture that can be applied to a 3d object, which then -can be drawn to the screen, captured as a texture, converted back to an -image, which can then be converted to a sound, processed and converted back -to an image, etc... You get the point. The possibilities are endless. - - - -

-
Tom Schouten
- - -Last modified: Thu Sep 25 20:51:44 CEST 2003 - - - diff --git a/doc/misc/todo.jme b/doc/misc/todo.jme deleted file mode 100644 index 2ce317d..0000000 --- a/doc/misc/todo.jme +++ /dev/null @@ -1,4 +0,0 @@ -todo list of jme@off.net ------------------------- -- a packet to trigger packet generator instead of bang - o the created packet has the same format as the incoming packet diff --git a/opengl/doc/examples/arm.pd b/opengl/doc/examples/arm.pd deleted file mode 100644 index 36a8f48..0000000 --- a/opengl/doc/examples/arm.pd +++ /dev/null @@ -1,40 +0,0 @@ -#N canvas 475 534 572 380 10; -#X obj 43 10 inlet; -#X obj 43 227 outlet; -#X obj 43 141 3dp_push; -#X obj 208 200 3dp_view transx 0.5; -#X obj 43 113 3dp_view rotz; -#X obj 260 11 inlet; -#X obj 208 174 3dp_view scalex \$1; -#X obj 43 186 3dp_view transx \$1; -#X obj 260 275 r texture; -#X obj 43 83 3dp_view roty; -#X obj 129 61 r roty; -#X obj 329 91 r scale; -#X obj 43 37 3dp_draw cube 1; -#X obj 143 11 r cubesize; -#X obj 208 334 3dp_draw torus 0.25 0.5 6; -#X obj 208 256 spigot; -#X obj 245 232 r drawtorus; -#X obj 276 307 r torusr1; -#X obj 353 307 r torusr2; -#X text 375 27 draw one arm segment; -#X connect 0 0 12 0; -#X connect 2 0 7 0; -#X connect 2 1 6 0; -#X connect 3 0 15 0; -#X connect 4 0 2 0; -#X connect 5 0 4 1; -#X connect 6 0 3 0; -#X connect 7 0 1 0; -#X connect 8 0 14 1; -#X connect 9 0 4 0; -#X connect 10 0 9 1; -#X connect 11 0 6 1; -#X connect 11 0 7 1; -#X connect 12 0 9 0; -#X connect 13 0 12 2; -#X connect 15 0 14 0; -#X connect 16 0 15 1; -#X connect 17 0 14 2; -#X connect 18 0 14 3; diff --git a/opengl/doc/examples/example01.pd b/opengl/doc/examples/example01.pd deleted file mode 100644 index 969ee17..0000000 --- a/opengl/doc/examples/example01.pd +++ /dev/null @@ -1,257 +0,0 @@ -#N canvas 426 142 799 779 10; -#X floatatom 126 37 5 0 0 0 - - -; -#X obj 56 20 bng 15 250 50 0 empty empty empty 0 -6 0 8 -262144 -1 --1; -#X msg 83 19 stop; -#X floatatom 360 431 5 0 0 0 - - -; -#X obj 59 103 3dp_push; -#X floatatom 672 189 5 0 0 0 - - -; -#X obj 546 244 3dp_view transx 3; -#X obj 546 270 3dp_light; -#X obj 612 97 f; -#X floatatom 641 98 5 0 0 0 - - -; -#X floatatom 669 370 5 0 0 0 - - -; -#X obj 182 491 arm 3; -#X obj 182 514 arm 3; -#X obj 182 537 arm 3; -#X obj 182 467 arm 3; -#X floatatom 360 455 5 0 0 0 - - -; -#X floatatom 359 478 5 0 0 0 - - -; -#X floatatom 358 501 5 0 0 0 - - -; -#X floatatom 358 524 5 0 0 0 - - -; -#X obj 182 584 arm 3; -#X obj 182 607 arm 3; -#X obj 182 630 arm 3; -#X obj 182 560 arm 3; -#X floatatom 358 548 5 0 0 0 - - -; -#X floatatom 358 571 5 0 0 0 - - -; -#X floatatom 358 594 5 0 0 0 - - -; -#X obj 59 224 3dp_view roty; -#X obj 284 449 * 1; -#X obj 284 589 * -1; -#X obj 182 653 arm 3; -#X floatatom 358 617 5 0 0 0 - - -; -#X obj 284 635 * -1.5; -#X obj 663 686 s roty; -#X floatatom 615 611 5 0 0 0 - - -; -#X floatatom 671 585 5 0 0 0 - - -; -#X obj 673 616 s scale; -#X floatatom 359 388 5 0 0 0 - - -; -#X obj 284 473 * -1.01; -#X obj 284 496 * 0.99; -#X obj 284 519 * -1.01; -#X obj 284 542 * 2.1; -#X obj 284 566 * -1.7; -#X obj 182 425 3dp_draw cube 1.4; -#X obj 182 809 3dp_draw cube 1.4; -#X msg 597 536 4; -#X obj 59 151 3dp_view transz -3; -#X obj 546 216 3dp_view roty 54; -#X obj 669 392 s cubesize; -#X msg 360 345 3.15; -#X msg 126 17 20; -#X obj 284 612 * 0.11; -#X floatatom 672 220 5 0 0 0 - - -; -#X msg 612 72 0; -#X obj 342 311 * 1; -#X obj 59 201 3dp_view rotx; -#X floatatom 164 187 5 0 0 0 - - -; -#X floatatom 358 641 5 0 0 0 - - -; -#X obj 182 700 arm 3; -#X obj 182 724 arm 3; -#X obj 182 748 arm 3; -#X obj 182 677 arm 3; -#X floatatom 359 664 5 0 0 0 - - -; -#X floatatom 359 688 5 0 0 0 - - -; -#X floatatom 360 712 5 0 0 0 - - -; -#X obj 284 706 * -1; -#X obj 182 771 arm 3; -#X floatatom 360 735 5 0 0 0 - - -; -#X obj 283 753 * -1.5; -#X obj 284 659 * 2.1; -#X obj 284 682 * -1.7; -#X obj 283 730 * 0.11; -#X obj 9 334 3dp_push; -#X obj 182 399 3dp_view transz; -#X floatatom 282 369 5 0 0 0 - - -; -#X obj 131 371 3dp_view transz; -#X obj 231 338 * -1; -#X msg 282 341 2; -#X obj 564 401 s drawtorus; -#X obj 564 374 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 1 -1; -#X obj 674 496 s torusr1; -#X floatatom 672 473 5 0 0 0 - - -; -#X floatatom 667 419 5 0 0 0 - - -; -#X obj 669 442 s torusr2; -#X msg 564 349 1; -#X obj 597 645 *; -#X obj 59 126 3dp_push; -#X obj 9 364 3dp_push; -#X obj 9 437 3dp_view rotx; -#X floatatom 96 416 5 0 0 0 - - -; -#X obj 9 471 3dp_draw sphere 30 40; -#X obj 9 593 3dp_snap; -#X obj 473 487 / 1000; -#X floatatom 473 461 5 0 0 0 - - -; -#X obj 430 8 loadbang; -#X obj 430 31 bng 15 250 50 0 empty empty empty 0 -6 0 8 -262144 -1 --1; -#X obj 59 77 3dp_windowcontext; -#X obj 59 274 3dp_push; -#X obj 110 303 pdp_t p b; -#X obj 9 307 pdp_t p b; -#X msg 349 252 400; -#X msg 311 252 -400; -#X obj 342 287 +; -#X msg 473 434 3; -#X text 544 189 light source; -#X obj 59 248 3dp_view scale 0.4; -#X obj 640 157 s counter; -#X obj 245 169 r counter; -#X text 694 98 speed; -#X obj 59 54 metro 20; -#X obj 238 207 * 0.05; -#X obj 9 570 spigot; -#X obj 76 546 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 1 1 -; -#X obj 612 122 + 1; -#X text 28 521 texture feedback; -#X text 486 751 "no-bots in no-sphere"; -#X text 459 768 a double dance of 13 segments; -#X text 549 734 ---; -#X text 549 787 ---; -#X obj 59 176 3dp_mouserotate; -#X connect 0 0 108 1; -#X connect 1 0 108 0; -#X connect 2 0 108 0; -#X connect 3 0 27 1; -#X connect 4 0 85 0; -#X connect 4 1 46 0; -#X connect 5 0 46 1; -#X connect 6 0 7 0; -#X connect 8 0 112 0; -#X connect 9 0 112 1; -#X connect 10 0 47 0; -#X connect 11 0 12 0; -#X connect 12 0 13 0; -#X connect 13 0 22 0; -#X connect 14 0 11 0; -#X connect 15 0 37 1; -#X connect 16 0 38 1; -#X connect 17 0 39 1; -#X connect 18 0 40 1; -#X connect 19 0 20 0; -#X connect 20 0 21 0; -#X connect 21 0 29 0; -#X connect 22 0 19 0; -#X connect 23 0 41 1; -#X connect 24 0 28 1; -#X connect 25 0 50 1; -#X connect 26 0 104 0; -#X connect 27 0 37 0; -#X connect 27 0 14 1; -#X connect 28 0 50 0; -#X connect 28 0 20 1; -#X connect 29 0 60 0; -#X connect 30 0 31 1; -#X connect 31 0 29 1; -#X connect 31 0 68 0; -#X connect 33 0 84 1; -#X connect 34 0 35 0; -#X connect 36 0 42 2; -#X connect 36 0 43 2; -#X connect 37 0 38 0; -#X connect 37 0 11 1; -#X connect 38 0 39 0; -#X connect 38 0 12 1; -#X connect 39 0 40 0; -#X connect 39 0 13 1; -#X connect 40 0 41 0; -#X connect 40 0 22 1; -#X connect 41 0 28 0; -#X connect 41 0 19 1; -#X connect 42 0 14 0; -#X connect 44 0 34 0; -#X connect 45 0 118 0; -#X connect 46 0 6 0; -#X connect 48 0 36 0; -#X connect 48 0 102 0; -#X connect 48 0 76 0; -#X connect 48 0 83 0; -#X connect 49 0 0 0; -#X connect 50 0 31 0; -#X connect 50 0 21 1; -#X connect 51 0 6 1; -#X connect 52 0 8 0; -#X connect 53 0 27 0; -#X connect 54 0 26 0; -#X connect 55 0 54 1; -#X connect 56 0 68 1; -#X connect 57 0 58 0; -#X connect 58 0 59 0; -#X connect 59 0 65 0; -#X connect 60 0 57 0; -#X connect 61 0 69 1; -#X connect 62 0 64 1; -#X connect 63 0 70 1; -#X connect 64 0 70 0; -#X connect 64 0 58 1; -#X connect 65 0 43 0; -#X connect 66 0 67 1; -#X connect 67 0 65 1; -#X connect 68 0 69 0; -#X connect 68 0 60 1; -#X connect 69 0 64 0; -#X connect 69 0 57 1; -#X connect 70 0 67 0; -#X connect 70 0 59 1; -#X connect 71 0 86 0; -#X connect 71 1 74 0; -#X connect 72 0 42 0; -#X connect 73 0 72 1; -#X connect 73 0 75 0; -#X connect 74 0 42 0; -#X connect 75 0 74 1; -#X connect 76 0 73 0; -#X connect 78 0 77 0; -#X connect 80 0 79 0; -#X connect 81 0 82 0; -#X connect 83 0 78 0; -#X connect 84 0 32 0; -#X connect 85 0 45 0; -#X connect 86 0 87 0; -#X connect 87 0 89 0; -#X connect 88 0 87 1; -#X connect 89 0 110 0; -#X connect 90 1 89 1; -#X connect 91 0 33 0; -#X connect 92 0 91 0; -#X connect 93 0 94 0; -#X connect 94 0 1 0; -#X connect 94 0 48 0; -#X connect 95 0 4 0; -#X connect 95 1 118 1; -#X connect 96 0 98 0; -#X connect 96 1 97 0; -#X connect 97 0 72 0; -#X connect 97 1 100 0; -#X connect 98 0 71 0; -#X connect 98 1 99 0; -#X connect 99 0 101 0; -#X connect 100 0 101 0; -#X connect 101 0 53 0; -#X connect 102 0 92 0; -#X connect 102 0 44 0; -#X connect 104 0 96 0; -#X connect 106 0 109 0; -#X connect 108 0 95 0; -#X connect 108 0 8 0; -#X connect 109 0 26 1; -#X connect 110 0 90 0; -#X connect 111 0 110 1; -#X connect 112 0 8 1; -#X connect 112 0 84 0; -#X connect 112 0 101 1; -#X connect 112 0 105 0; -#X connect 118 0 54 0; diff --git a/opengl/doc/examples/example02.pd b/opengl/doc/examples/example02.pd deleted file mode 100644 index d5023d9..0000000 --- a/opengl/doc/examples/example02.pd +++ /dev/null @@ -1,46 +0,0 @@ -#N canvas 696 306 480 535 10; -#X obj 102 73 3dp_windowcontext; -#X obj 102 36 metro 20; -#X obj 102 122 3dp_push; -#X obj 102 11 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 1 1 -; -#X obj 56 40 bng 15 250 50 0 empty empty empty 0 -6 0 8 -262144 -1 --1; -#X msg 253 32 cursor \$1; -#X obj 253 12 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 0 1 -; -#X obj 102 209 3dp_mouserotate; -#X obj 153 322 3dp_draw cube 1; -#X obj 265 139 3dp_view transxyz -4 3 4; -#X obj 102 270 3dp_push; -#X obj 102 348 3dp_push; -#X obj 102 425 3dp_push; -#X obj 153 296 3dp_view transx 2; -#X obj 153 374 3dp_view transy 2; -#X obj 153 451 3dp_view transz 2; -#X obj 153 400 3dp_draw cube 1; -#X obj 153 477 3dp_draw cube 1; -#X obj 102 506 3dp_draw dodeca 1; -#X text 25 231 use the mouse to rotate the model (but not the light -source since it is rendered before the rotation is applied.); -#X obj 265 161 3dp_light; -#X connect 0 0 2 0; -#X connect 0 1 7 1; -#X connect 1 0 0 0; -#X connect 2 0 7 0; -#X connect 2 1 9 0; -#X connect 3 0 1 0; -#X connect 4 0 0 0; -#X connect 5 0 0 0; -#X connect 6 0 5 0; -#X connect 7 0 10 0; -#X connect 9 0 20 0; -#X connect 10 0 11 0; -#X connect 10 1 13 0; -#X connect 11 0 12 0; -#X connect 11 1 14 0; -#X connect 12 0 18 0; -#X connect 12 1 15 0; -#X connect 13 0 8 0; -#X connect 14 0 16 0; -#X connect 15 0 17 0; diff --git a/opengl/doc/examples/example03.pd b/opengl/doc/examples/example03.pd deleted file mode 100644 index 48d714b..0000000 --- a/opengl/doc/examples/example03.pd +++ /dev/null @@ -1,65 +0,0 @@ -#N canvas 382 102 480 535 10; -#X obj 102 73 3dp_windowcontext; -#X obj 102 36 metro 20; -#X obj 102 139 3dp_push; -#X obj 261 185 3dp_light; -#X obj 102 11 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 1 1 -; -#X obj 56 40 bng 15 250 50 0 empty empty empty 0 -6 0 8 -262144 -1 --1; -#X msg 253 32 cursor \$1; -#X obj 253 12 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 1 1 -; -#X obj 102 209 3dp_mouserotate; -#X obj 261 163 3dp_view transxyz -4 3 4; -#X obj 102 427 arm 3; -#X obj 371 230 loadbang; -#X obj 102 333 pdp_t p p p p; -#X obj 102 304 pdp_t p p p p; -#X floatatom 199 386 5 0 0; -#X obj 318 378 s roty; -#X floatatom 318 327 5 0 0; -#X obj 371 378 s drawtorus; -#X obj 371 355 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 1 -1; -#X obj 102 256 pdp_t p b; -#X obj 212 273 f 0; -#X obj 302 352 *; -#X obj 183 409 *; -#X obj 212 307 + 0.1; -#X obj 102 105 3dp_view transz -5; -#X text 41 471 it is possible to send the rendercontext to the same -rendering/transforming chain multiple times. (in other words: 3dp objects -do not support fanout \, but they do support fanin.); -#X connect 0 0 24 0; -#X connect 0 1 8 1; -#X connect 1 0 0 0; -#X connect 2 0 8 0; -#X connect 2 1 9 0; -#X connect 4 0 1 0; -#X connect 5 0 0 0; -#X connect 6 0 0 0; -#X connect 7 0 6 0; -#X connect 8 0 19 0; -#X connect 9 0 3 0; -#X connect 11 0 18 0; -#X connect 12 0 10 0; -#X connect 12 1 10 0; -#X connect 12 2 10 0; -#X connect 12 3 10 0; -#X connect 13 0 12 0; -#X connect 13 1 12 0; -#X connect 13 2 12 0; -#X connect 13 3 12 0; -#X connect 14 0 22 1; -#X connect 16 0 21 1; -#X connect 18 0 17 0; -#X connect 19 0 13 0; -#X connect 19 1 20 0; -#X connect 20 0 23 0; -#X connect 21 0 15 0; -#X connect 22 0 10 1; -#X connect 23 0 20 1; -#X connect 23 0 22 0; -#X connect 23 0 21 0; -#X connect 24 0 2 0; diff --git a/opengl/doc/examples/example04.pd b/opengl/doc/examples/example04.pd deleted file mode 100644 index 5d22270..0000000 --- a/opengl/doc/examples/example04.pd +++ /dev/null @@ -1,25 +0,0 @@ -#N canvas 288 311 566 284 10; -#X obj 54 156 3dp_windowcontext; -#X obj 54 43 metro 40; -#X obj 54 19 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 0 1 -; -#X obj 54 76 t b b; -#X obj 134 120 pdp_convert texture/*/*; -#X obj 54 183 3dp_mouserotate; -#X floatatom 180 202 5 0 0 0 - - -; -#X msg 134 68 open /dev/video1; -#X obj 54 227 3dp_draw sphere 5; -#X text 132 18 convert pdp image packets to textures and map them on -a sphere; -#X obj 134 93 pdp_v4l; -#X connect 0 0 5 0; -#X connect 0 1 5 1; -#X connect 1 0 3 0; -#X connect 2 0 1 0; -#X connect 3 0 0 0; -#X connect 3 1 10 0; -#X connect 4 0 8 1; -#X connect 5 0 8 0; -#X connect 6 0 8 2; -#X connect 7 0 10 0; -#X connect 10 0 4 0; diff --git a/opengl/doc/examples/example05.pd b/opengl/doc/examples/example05.pd deleted file mode 100644 index 7996355..0000000 --- a/opengl/doc/examples/example05.pd +++ /dev/null @@ -1,41 +0,0 @@ -#N canvas 352 162 732 325 10; -#X obj 54 43 metro 40; -#X obj 54 19 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 1 1 -; -#X obj 314 120 pdp_convert texture/*/*; -#X floatatom 343 212 5 0 0; -#X obj 286 247 3dp_draw sphere 5; -#X obj 314 95 pdp_plasma; -#X obj 408 48 loadbang; -#X msg 408 70 dim 512 256; -#X obj 314 65 bng 15 250 50 0 empty empty empty 0 -6 0 8 -262144 -1 --1; -#X obj 181 144 3dp_windowcontext; -#X obj 181 203 3dp_view roty; -#X floatatom 267 176 5 0 0; -#X obj 31 144 3dp_windowcontext; -#X obj 31 203 3dp_view roty; -#X floatatom 117 176 5 0 0; -#X obj 286 278 3dp_draw cube 2; -#X obj 336 164 pdp_del 3; -#X text 414 164 <- textures can be stored in a delay line; -#X text 133 9 convert pdp image packets to textures and map them on -a sphere and cube. create 2 independent viewing windows.; -#X connect 0 0 9 0; -#X connect 0 0 12 0; -#X connect 1 0 0 0; -#X connect 2 0 4 1; -#X connect 2 0 16 0; -#X connect 3 0 4 2; -#X connect 4 0 15 0; -#X connect 5 0 2 0; -#X connect 6 0 7 0; -#X connect 7 0 5 0; -#X connect 8 0 5 0; -#X connect 9 0 10 0; -#X connect 10 0 4 0; -#X connect 11 0 10 1; -#X connect 12 0 13 0; -#X connect 13 0 4 0; -#X connect 14 0 13 1; -#X connect 16 0 15 1; diff --git a/opengl/doc/examples/example06.pd b/opengl/doc/examples/example06.pd deleted file mode 100644 index 8d8595a..0000000 --- a/opengl/doc/examples/example06.pd +++ /dev/null @@ -1,85 +0,0 @@ -#N canvas 516 361 634 497 10; -#X obj 23 119 metro 40; -#X obj 23 89 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 1 1 -; -#X obj 360 397 pdp_convert texture/*/*; -#X obj 23 387 3dp_mouserotate; -#X obj 155 255 3dp_light 0; -#X obj 23 193 3dp_push; -#X floatatom 269 198 5 0 0; -#X obj 23 161 3dp_windowcontext; -#X obj 360 299 pdp_convert image/grey/*; -#X obj 360 184 bng 15 250 50 0 empty empty empty 0 -6 0 8 -262144 -1 --1; -#X msg 478 163 random; -#X msg 479 186 rule gameoflife; -#X msg 478 114 rule fire; -#X obj 360 270 pdp_ca; -#X obj 360 371 pdp_motion_phase; -#X floatatom 479 343 5 0 0; -#X obj 478 88 loadbang; -#X msg 479 322 0.33; -#X obj 328 473 3dp_draw sphere 2.6; -#X floatatom 463 434 5 0 0; -#X obj 155 227 3dp_view transz 5; -#X floatatom 480 237 5 0 0; -#X msg 517 322 1; -#X obj 360 347 pdp_gain; -#X floatatom 411 323 5 0 0; -#X msg 478 139 dim 256 128; -#X obj 179 393 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 0 -1; -#X obj 328 419 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 1 -1; -#X obj 23 416 3dp_toggle depth_test 0; -#X obj 179 445 3dp_toggle blend_add 1; -#X msg 480 213 1; -#X obj 23 316 3dp_mode texture; -#X floatatom 281 310 5 0 0; -#X obj 156 339 3dp_view scale 1; -#X floatatom 280 340 5 0 0; -#X obj 156 366 3dp_view rotz; -#X text 141 197 move light source; -#X text 143 294 transform texture coords; -#X text 31 12 blending with depth test disabled using 3dp_toggle object. -together with a cellular automata texture (you need pdp_scaf for this) -and texture coordinate transformation.; -#X connect 0 0 7 0; -#X connect 0 0 9 0; -#X connect 1 0 0 0; -#X connect 2 0 18 1; -#X connect 3 0 28 0; -#X connect 5 0 31 0; -#X connect 5 1 20 0; -#X connect 6 0 20 1; -#X connect 7 0 5 0; -#X connect 7 1 3 1; -#X connect 8 0 23 0; -#X connect 9 0 13 0; -#X connect 10 0 13 0; -#X connect 11 0 13 0; -#X connect 12 0 13 0; -#X connect 12 0 25 0; -#X connect 13 0 8 0; -#X connect 14 0 2 0; -#X connect 15 0 14 1; -#X connect 16 0 12 0; -#X connect 17 0 15 0; -#X connect 19 0 18 2; -#X connect 20 0 4 0; -#X connect 21 0 13 2; -#X connect 22 0 15 0; -#X connect 23 0 14 0; -#X connect 24 0 23 1; -#X connect 25 0 13 0; -#X connect 25 0 10 0; -#X connect 26 0 28 1; -#X connect 27 0 29 1; -#X connect 28 1 29 0; -#X connect 29 1 18 0; -#X connect 30 0 21 0; -#X connect 31 0 3 0; -#X connect 31 1 33 0; -#X connect 32 0 33 1; -#X connect 33 0 35 0; -#X connect 34 0 35 1; diff --git a/opengl/doc/examples/example07.pd b/opengl/doc/examples/example07.pd deleted file mode 100644 index cd3618c..0000000 --- a/opengl/doc/examples/example07.pd +++ /dev/null @@ -1,25 +0,0 @@ -#N canvas 400 454 637 428 10; -#X obj 18 131 3dp_windowcontext; -#X obj 18 159 3dp_push; -#X obj 201 70 metro 40; -#X obj 201 42 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 1 1 -; -#X obj 201 99 pdp_v4l; -#X obj 201 131 pdp_convert texture/*/*; -#X floatatom 258 265 5 0 0; -#X obj 18 218 3dp_view scalex 1.33333; -#X obj 18 187 3dp_mouserotate; -#X text 15 10 using a square scaled by an aspect ratio to construct -an an alternative pdp_glx; -#X obj 144 290 3dp_draw square 8; -#X connect 0 0 1 0; -#X connect 0 1 8 1; -#X connect 1 0 8 0; -#X connect 2 0 0 0; -#X connect 2 0 4 0; -#X connect 3 0 2 0; -#X connect 4 0 5 0; -#X connect 5 0 10 1; -#X connect 6 0 10 2; -#X connect 7 0 10 0; -#X connect 8 0 7 0; diff --git a/opengl/doc/examples/example08.pd b/opengl/doc/examples/example08.pd deleted file mode 100644 index a5f7e9d..0000000 --- a/opengl/doc/examples/example08.pd +++ /dev/null @@ -1,94 +0,0 @@ -#N canvas 96 78 756 667 10; -#X obj 18 131 3dp_windowcontext; -#X obj 18 159 3dp_push; -#X obj 327 80 metro 40; -#X obj 327 52 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 1 1 -; -#X obj 327 224 pdp_v4l; -#X obj 431 463 pdp_convert texture/*/*; -#X floatatom 488 554 5 0 0; -#X obj 18 215 3dp_view scalex 1.33333; -#X obj 18 189 3dp_mouserotate; -#X floatatom 83 308 5 0 0; -#X msg 83 287 10; -#X obj 69 428 3dp_view rotx; -#X obj 69 475 3dp_view roty; -#X obj 69 523 3dp_view rotz; -#X obj 155 398 random 360; -#X obj 155 453 random 360; -#X obj 155 500 random 360; -#X obj 155 371 bng 15 250 50 0 empty empty empty 0 -6 0 8 -262144 -1 --1; -#X obj 18 366 3dp_push; -#X text 132 305 nb of squares; -#X floatatom 220 369 5 0 0; -#X obj 431 309 pdp_plasma; -#X obj 431 256 loadbang; -#X obj 327 192 bng 15 250 50 0 empty empty empty 0 -6 0 8 -262144 -1 --1; -#X obj 397 279 bng 15 250 50 0 empty empty empty 0 -6 0 8 -262144 -1 --1; -#X msg 417 55 200; -#X floatatom 510 364 5 0 0; -#X msg 378 55 40; -#X obj 327 126 spigot; -#X obj 385 106 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 1 -1; -#X obj 431 395 pdp_gain 0.3; -#X obj 18 333 3dp_for 10; -#X text 21 12 another example of accumulated blending combined with -a 3dp_for object to render multiple randomly rotated squares.; -#X msg 386 186 open /dev/video1; -#X obj 18 246 3dp_blend; -#X text 411 106 switch between video textures and stills; -#X msg 386 160 open /dev/video0; -#X text 87 246 <-- click for more info; -#X msg 431 281 dim 64 64 \, bang; -#X obj 548 228 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 0 -1; -#X obj 548 256 metro 2000; -#X obj 374 583 3dp_draw square 8; -#X connect 0 0 1 0; -#X connect 0 1 8 1; -#X connect 1 0 8 0; -#X connect 2 0 0 0; -#X connect 2 0 28 0; -#X connect 3 0 2 0; -#X connect 4 0 30 0; -#X connect 5 0 41 1; -#X connect 6 0 41 2; -#X connect 7 0 34 0; -#X connect 8 0 7 0; -#X connect 9 0 31 1; -#X connect 10 0 9 0; -#X connect 11 0 12 0; -#X connect 12 0 13 0; -#X connect 13 0 41 0; -#X connect 14 0 11 1; -#X connect 15 0 12 1; -#X connect 16 0 13 1; -#X connect 17 0 14 0; -#X connect 17 0 15 0; -#X connect 17 0 16 0; -#X connect 18 1 11 0; -#X connect 20 0 14 1; -#X connect 20 0 15 1; -#X connect 20 0 16 1; -#X connect 21 0 30 0; -#X connect 22 0 38 0; -#X connect 23 0 4 0; -#X connect 24 0 21 0; -#X connect 25 0 2 1; -#X connect 26 0 30 1; -#X connect 27 0 2 1; -#X connect 28 0 23 0; -#X connect 29 0 28 1; -#X connect 30 0 5 0; -#X connect 31 0 18 0; -#X connect 31 1 17 0; -#X connect 33 0 4 0; -#X connect 34 0 31 0; -#X connect 36 0 4 0; -#X connect 38 0 21 0; -#X connect 39 0 40 0; -#X connect 40 0 21 0; diff --git a/opengl/doc/examples/example09.pd b/opengl/doc/examples/example09.pd deleted file mode 100644 index 3333d3a..0000000 --- a/opengl/doc/examples/example09.pd +++ /dev/null @@ -1,90 +0,0 @@ -#N canvas 96 78 756 667 10; -#X obj 18 111 3dp_windowcontext; -#X obj 18 139 3dp_push; -#X obj 18 169 3dp_mouserotate; -#X floatatom 141 370 5 0 0; -#X msg 141 349 10; -#X obj 127 490 3dp_view rotx; -#X obj 127 537 3dp_view roty; -#X obj 127 585 3dp_view rotz; -#X obj 213 460 random 360; -#X obj 213 515 random 360; -#X obj 213 562 random 360; -#X obj 213 433 bng 15 250 50 0 empty empty empty 0 -6 0 8 -262144 -1 --1; -#X obj 76 428 3dp_push; -#X floatatom 278 431 5 0 0; -#X obj 76 395 3dp_for 10; -#X obj 18 226 3dp_blend; -#X text 87 226 <-- click for more info; -#X obj 18 365 3dp_color; -#X floatatom 32 311 5 0 0; -#X floatatom 78 311 5 0 0; -#X floatatom 123 311 5 0 0; -#X floatatom 167 311 5 0 0; -#X obj 415 193 3dp_view transz 5; -#X obj 415 217 3dp_light; -#X obj 18 78 metro 40; -#X obj 18 50 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 1 1 -; -#X floatatom 529 166 5 0 0; -#X obj 32 252 vsl 15 50 0 1 0 1 empty empty empty 0 -8 0 8 -262144 --1 -1 2200 1; -#X obj 78 251 vsl 15 50 0 1 0 1 empty empty empty 0 -8 0 8 -262144 --1 -1 2100 1; -#X obj 123 251 vsl 15 50 0 1 0 1 empty empty empty 0 -8 0 8 -262144 --1 -1 3800 1; -#X obj 169 250 vsl 15 50 0 1 0 1 empty empty empty 0 -8 0 8 -262144 --1 -1 1100 1; -#X text 209 275 in this blending mode \, alpha is interpreted as a -color gain; -#X floatatom 515 137 5 0 0; -#X floatatom 144 178 5 0 0; -#X obj 127 633 3dp_draw tetra 4; -#X text 14 13 similar to as example08.; -#X obj 415 168 3dp_view roty 5; -#X obj 18 199 3dp_view scale 4; -#X msg 278 406 18; -#X msg 515 112 75; -#X connect 0 0 1 0; -#X connect 0 1 2 1; -#X connect 1 0 2 0; -#X connect 1 1 36 0; -#X connect 2 0 37 0; -#X connect 3 0 14 1; -#X connect 4 0 3 0; -#X connect 5 0 6 0; -#X connect 6 0 7 0; -#X connect 7 0 34 0; -#X connect 8 0 5 1; -#X connect 9 0 6 1; -#X connect 10 0 7 1; -#X connect 11 0 8 0; -#X connect 11 0 9 0; -#X connect 11 0 10 0; -#X connect 12 1 5 0; -#X connect 13 0 8 1; -#X connect 13 0 9 1; -#X connect 13 0 10 1; -#X connect 14 0 12 0; -#X connect 14 1 11 0; -#X connect 15 0 17 0; -#X connect 17 1 14 0; -#X connect 18 0 17 1; -#X connect 19 0 17 2; -#X connect 20 0 17 3; -#X connect 21 0 17 4; -#X connect 22 0 23 0; -#X connect 24 0 0 0; -#X connect 25 0 24 0; -#X connect 26 0 22 1; -#X connect 27 0 18 0; -#X connect 28 0 19 0; -#X connect 29 0 20 0; -#X connect 30 0 21 0; -#X connect 32 0 36 1; -#X connect 33 0 37 1; -#X connect 36 0 22 0; -#X connect 37 0 15 0; -#X connect 38 0 13 0; -#X connect 39 0 32 0; diff --git a/opengl/doc/examples/example10.pd b/opengl/doc/examples/example10.pd deleted file mode 100644 index 2216fb3..0000000 --- a/opengl/doc/examples/example10.pd +++ /dev/null @@ -1,39 +0,0 @@ -#N canvas 592 340 647 499 10; -#X obj 231 344 pdp_xv; -#X obj 54 72 metro 40; -#X obj 54 47 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 1 1 -; -#X obj 54 140 3dp_push; -#X obj 248 158 3dp_view transz 5; -#X floatatom 362 126 5 0 0; -#X obj 248 182 3dp_light 0; -#X obj 54 169 3dp_mouserotate; -#X obj 54 111 3dp_windowcontext; -#X obj 231 311 pdp_blur; -#X obj 285 291 hsl 128 15 0 1 0 1 empty empty empty -2 -6 0 8 -262144 --1 -1 8100 1; -#X text 104 7 connect 3dp and basic pdp image processing with 3dp_snap -; -#X text 105 26 3dp_snap defaults to texture packets \, but you can -specify the desired type as a creation argument; -#X obj 107 377 pdp_convert texture/*/*; -#X obj 54 412 3dp_draw cube 10; -#X text 247 233 <- specify packet type and capture area; -#X obj 54 200 3dp_draw cube 2; -#X obj 54 234 3dp_snap image/*/* 320 240; -#X connect 1 0 8 0; -#X connect 2 0 1 0; -#X connect 3 0 7 0; -#X connect 3 1 4 0; -#X connect 4 0 6 0; -#X connect 5 0 4 1; -#X connect 7 0 16 0; -#X connect 8 0 3 0; -#X connect 8 1 7 1; -#X connect 9 0 13 0; -#X connect 9 0 0 0; -#X connect 10 0 9 1; -#X connect 13 0 14 1; -#X connect 16 0 17 0; -#X connect 17 0 14 0; -#X connect 17 1 9 0; diff --git a/opengl/doc/examples/example11.pd b/opengl/doc/examples/example11.pd deleted file mode 100644 index c902408..0000000 --- a/opengl/doc/examples/example11.pd +++ /dev/null @@ -1,77 +0,0 @@ -#N canvas 542 122 669 675 10; -#X obj 23 70 metro 40; -#X obj 23 40 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 1 1 -; -#X obj 23 517 3dp_mouserotate; -#X obj 171 520 3dp_light 0; -#X obj 23 444 3dp_push; -#X obj 171 492 3dp_view transz 5; -#X obj 23 112 3dp_windowcontext; -#X obj 205 311 3dp_snap; -#X obj 205 213 3dp_draw clear; -#X obj 23 406 3dp_draw clear; -#X obj 60 347 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 1 1 -; -#X obj 23 157 3dp_subcontext 64 64; -#X obj 23 380 spigot; -#X text 384 210 <- clear it; -#X text 380 309 <- snap to texture; -#X obj 205 261 3dp_view rota 1 1 0; -#X floatatom 333 236 5 0 0; -#X text 69 10 multipass rendering to texture using a subcontext (subwindow) -; -#X text 381 285 <- draw a wireframe sphere; -#X text 383 235 <- rotate around (1 \, 1 \, 0); -#X text 135 406 <- clear the window; -#X obj 205 286 3dp_draw wsphere 3 10 10; -#X obj 323 429 3dp_draw clear; -#X obj 323 405 3dp_view reset; -#X obj 323 507 3dp_draw wdodeca; -#X obj 323 532 3dp_snap; -#X obj 22 613 3dp_draw cube 10; -#X obj 360 348 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 1 -1; -#X obj 323 381 spigot; -#X text 381 346 <- enable/disable second pass; -#X text 87 345 <- enable/disable third pass; -#X text 443 404 <- reset context; -#X text 442 427 <- clear context; -#X text 442 507 <- draw wire dodecahedron; -#X text 441 532 <- snap to texture; -#X obj 323 483 3dp_view rota 1 1 0; -#X floatatom 451 458 5 0 0; -#X text 501 457 <- rotate around (1 \, 1 \, 0); -#X obj 23 562 3dp_draw cube 2; -#X text 204 142 NOTE: the part you use as a subcontext must be visible -for the texture snap to work.; -#X text 203 91 use the lower left 64x64 part of the window as a subcontext -(right outlet) the left outlet is a new full window context reset to -default.; -#X connect 0 0 6 0; -#X connect 1 0 0 0; -#X connect 2 0 38 0; -#X connect 4 0 2 0; -#X connect 4 1 5 0; -#X connect 5 0 3 0; -#X connect 6 0 11 0; -#X connect 6 1 2 1; -#X connect 7 0 28 0; -#X connect 7 1 38 1; -#X connect 8 0 15 0; -#X connect 9 0 4 0; -#X connect 10 0 12 1; -#X connect 11 0 12 0; -#X connect 11 1 8 0; -#X connect 12 0 9 0; -#X connect 15 0 21 0; -#X connect 16 0 15 4; -#X connect 21 0 7 0; -#X connect 22 0 35 0; -#X connect 23 0 22 0; -#X connect 24 0 25 0; -#X connect 25 1 26 1; -#X connect 27 0 28 1; -#X connect 28 0 23 0; -#X connect 35 0 24 0; -#X connect 36 0 35 4; -#X connect 38 0 26 0; diff --git a/opengl/doc/examples/example12.pd b/opengl/doc/examples/example12.pd deleted file mode 100644 index 14f8afd..0000000 --- a/opengl/doc/examples/example12.pd +++ /dev/null @@ -1,90 +0,0 @@ -#N canvas 529 191 669 751 10; -#X obj 55 68 metro 40; -#X obj 55 38 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 1 1 -; -#X obj 55 515 3dp_mouserotate; -#X obj 184 514 3dp_light 0; -#X obj 55 442 3dp_push; -#X obj 184 486 3dp_view transz 5; -#X obj 55 110 3dp_windowcontext; -#X obj 343 481 3dp_snap; -#X obj 55 404 3dp_draw clear; -#X obj 436 272 3dp_light 0; -#X obj 436 244 3dp_view transxyz 5 5 0; -#X obj 285 226 3dp_push; -#X obj 343 449 3dp_draw sphere 7 10 10; -#X text 69 10 another multipass rendering example; -#X obj 55 576 3dp_draw cube 7; -#X obj 55 155 3dp_subcontext 256 256; -#X obj 285 260 3dp_mouserotate; -#X obj 343 413 3dp_draw icosa 1; -#X obj 285 342 3dp_color; -#X obj 343 387 3dp_view scale 1; -#X floatatom 450 358 5 0 0; -#N canvas 0 0 291 420 coord_to_color 0; -#X obj 97 85 route drag; -#X obj 97 147 *; -#X obj 134 146 *; -#X obj 97 174 +; -#X obj 97 281 sqrt; -#X obj 97 225 - 1; -#X obj 97 249 * -1; -#X obj 97 114 unpack 0 0; -#X obj 98 45 inlet; -#X obj 53 337 outlet; -#X obj 181 332 outlet; -#X obj 116 336 outlet; -#X connect 0 0 7 0; -#X connect 1 0 3 0; -#X connect 2 0 3 1; -#X connect 3 0 5 0; -#X connect 4 0 11 0; -#X connect 5 0 6 0; -#X connect 6 0 4 0; -#X connect 7 0 1 1; -#X connect 7 0 1 0; -#X connect 7 0 9 0; -#X connect 7 1 2 1; -#X connect 7 1 2 0; -#X connect 7 1 10 0; -#X connect 8 0 0 0; -#X restore 304 305 pd coord_to_color; -#X obj 453 337 hsl 128 15 1 3 0 1 empty empty empty -2 -6 0 8 -262144 --1 -1 7900 1; -#X obj 285 196 3dp_draw clear; -#X obj 92 622 bng 15 250 50 0 empty empty empty 0 -6 0 8 -262144 -1 --1; -#X obj 55 662 3dp_screenshot /tmp/screenshot.png; -#X msg 227 71 dim 1023 768; -#X connect 0 0 6 0; -#X connect 1 0 0 0; -#X connect 2 0 14 0; -#X connect 4 0 2 0; -#X connect 4 1 5 0; -#X connect 5 0 3 0; -#X connect 6 0 15 0; -#X connect 6 1 2 1; -#X connect 6 1 21 0; -#X connect 6 1 16 1; -#X connect 7 1 12 1; -#X connect 7 1 14 1; -#X connect 8 0 4 0; -#X connect 10 0 9 0; -#X connect 11 0 16 0; -#X connect 11 1 10 0; -#X connect 12 0 7 0; -#X connect 14 0 25 0; -#X connect 15 0 8 0; -#X connect 15 1 23 0; -#X connect 16 0 18 0; -#X connect 17 0 12 0; -#X connect 18 1 19 0; -#X connect 19 0 17 0; -#X connect 20 0 19 1; -#X connect 21 0 18 1; -#X connect 21 1 18 2; -#X connect 21 2 18 3; -#X connect 22 0 20 0; -#X connect 23 0 11 0; -#X connect 24 0 25 0; -#X connect 26 0 6 0; diff --git a/opengl/doc/examples/example13.pd b/opengl/doc/examples/example13.pd deleted file mode 100644 index a8c5f75..0000000 --- a/opengl/doc/examples/example13.pd +++ /dev/null @@ -1,81 +0,0 @@ -#N canvas 478 168 669 751 10; -#X obj 55 68 metro 40; -#X obj 55 38 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 1 1 -; -#X obj 55 110 3dp_windowcontext; -#X obj 262 479 3dp_snap; -#X obj 355 270 3dp_light 0; -#X obj 355 242 3dp_view transxyz 5 5 0; -#X obj 204 224 3dp_push; -#X obj 262 447 3dp_draw sphere 7 10 10; -#X obj 204 258 3dp_mouserotate; -#X obj 262 411 3dp_draw icosa 1; -#X obj 204 340 3dp_color; -#X obj 262 385 3dp_view scale 1; -#X floatatom 369 356 5 0 0; -#N canvas 0 0 291 420 coord_to_color 0; -#X obj 97 85 route drag; -#X obj 97 147 *; -#X obj 134 146 *; -#X obj 97 174 +; -#X obj 97 281 sqrt; -#X obj 97 225 - 1; -#X obj 97 249 * -1; -#X obj 97 114 unpack 0 0; -#X obj 98 45 inlet; -#X obj 53 337 outlet; -#X obj 181 332 outlet; -#X obj 116 336 outlet; -#X connect 0 0 7 0; -#X connect 1 0 3 0; -#X connect 2 0 3 1; -#X connect 3 0 5 0; -#X connect 4 0 11 0; -#X connect 5 0 6 0; -#X connect 6 0 4 0; -#X connect 7 0 1 1; -#X connect 7 0 1 0; -#X connect 7 0 9 0; -#X connect 7 1 2 1; -#X connect 7 1 2 0; -#X connect 7 1 10 0; -#X connect 8 0 0 0; -#X restore 223 303 pd coord_to_color; -#X obj 372 335 hsl 128 15 1 3 0 1 empty empty empty -2 -6 0 8 -262144 --1 -1 7900 1; -#X obj 204 194 3dp_draw clear; -#X text 209 658 <- stretch the texture to cover the entire window (click -for info); -#X text 119 13 fixed resolution processing (independent of the display -window size) using multipass rendering; -#X floatatom 210 631 5 0 0; -#X obj 55 658 3dp_display_texture; -#X text 338 480 <- snap the result to a texture; -#X text 228 154 <- create a subcontext to do some drawing; -#X text 402 76 see also; -#X obj 405 97 3dp_fixedsizewindowcontext 64 64; -#X obj 55 155 3dp_subcontext 320 240; -#X connect 0 0 2 0; -#X connect 1 0 0 0; -#X connect 2 0 24 0; -#X connect 2 1 13 0; -#X connect 2 1 8 1; -#X connect 3 1 7 1; -#X connect 3 1 19 1; -#X connect 5 0 4 0; -#X connect 6 0 8 0; -#X connect 6 1 5 0; -#X connect 7 0 3 0; -#X connect 8 0 10 0; -#X connect 9 0 7 0; -#X connect 10 1 11 0; -#X connect 11 0 9 0; -#X connect 12 0 11 1; -#X connect 13 0 10 1; -#X connect 13 1 10 2; -#X connect 13 2 10 3; -#X connect 14 0 12 0; -#X connect 15 0 6 0; -#X connect 18 0 19 2; -#X connect 24 0 19 0; -#X connect 24 1 15 0; diff --git a/opengl/doc/examples/example14.pd b/opengl/doc/examples/example14.pd deleted file mode 100644 index fa0cabb..0000000 --- a/opengl/doc/examples/example14.pd +++ /dev/null @@ -1,66 +0,0 @@ -#N canvas 586 145 669 674 10; -#X obj 67 71 3dp_windowcontext; -#X obj 67 46 metro 40; -#X obj 67 23 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 0 1 -; -#X obj 67 155 3dp_blend; -#X obj 176 423 3dp_view transxyz; -#X msg 226 296 reset; -#X obj 197 374 *; -#X obj 304 375 *; -#X floatatom 320 347 5 0 0; -#X obj 274 154 vsl 15 30 0 1 0 1 empty empty empty 0 -8 0 8 -262144 --1 -1 700 1; -#X obj 316 154 vsl 15 30 0 1 0 1 empty empty empty 0 -8 0 8 -262144 --1 -1 1100 1; -#X obj 295 154 vsl 15 30 0 1 0 1 empty empty empty 0 -8 0 8 -262144 --1 -1 1200 1; -#X obj 337 154 vsl 15 30 0 1 0 1 empty empty empty 0 -8 0 8 -262144 --1 -1 400 1; -#X obj 125 253 3dp_push; -#X obj 67 95 3dp_mouserotate; -#X obj 67 124 3dp_view scale 1; -#X floatatom 206 99 5 0 0; -#X obj 209 79 hsl 128 15 0.2 5 1 1 empty empty empty -2 -6 0 8 -262144 --1 -1 7000 1; -#X obj 323 326 hsl 128 15 0.1 2 1 1 empty empty empty -2 -6 0 8 -262144 --1 -1 2100 1; -#X obj 67 187 3dp_color; -#X obj 226 223 route press3; -#X text 329 223 <- right click mouse to reset; -#X text 211 253 <- remove 3dp_push object to accumulate the translations -; -#X obj 197 326 randomwalk2D 100; -#X obj 125 224 3dp_for 100; -#X text 287 130 R G B I; -#X obj 176 460 3dp_draw cube 1; -#X text 227 13 using 3dp_for and the randomwalk2D abstraction to create -random walking blended cubes.; -#X connect 0 0 14 0; -#X connect 0 1 14 1; -#X connect 0 1 20 0; -#X connect 1 0 0 0; -#X connect 2 0 1 0; -#X connect 3 0 19 0; -#X connect 4 0 26 0; -#X connect 5 0 23 0; -#X connect 6 0 4 1; -#X connect 7 0 4 2; -#X connect 8 0 7 1; -#X connect 8 0 6 1; -#X connect 9 0 19 1; -#X connect 10 0 19 3; -#X connect 11 0 19 2; -#X connect 12 0 19 4; -#X connect 13 1 4 0; -#X connect 14 0 15 0; -#X connect 15 0 3 0; -#X connect 16 0 15 1; -#X connect 17 0 16 0; -#X connect 18 0 8 0; -#X connect 19 1 24 0; -#X connect 20 0 5 0; -#X connect 23 0 6 0; -#X connect 23 1 7 0; -#X connect 24 0 13 0; -#X connect 24 1 23 0; diff --git a/opengl/doc/examples/example15.pd b/opengl/doc/examples/example15.pd deleted file mode 100644 index 281c91a..0000000 --- a/opengl/doc/examples/example15.pd +++ /dev/null @@ -1,126 +0,0 @@ -#N canvas 269 234 933 697 10; -#X obj 67 46 metro 40; -#X obj 67 23 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 1 1 -; -#X obj 67 224 3dp_blend; -#X obj 176 673 3dp_view transxyz; -#X msg 260 342 reset; -#X obj 197 497 *; -#X obj 304 498 *; -#X obj 272 218 vsl 15 30 0 1 0 1 empty empty empty 0 -8 0 8 -262144 --1 -1 1000 1; -#X obj 314 218 vsl 15 30 0 1 0 1 empty empty empty 0 -8 0 8 -262144 --1 -1 0 1; -#X obj 293 218 vsl 15 30 0 1 0 1 empty empty empty 0 -8 0 8 -262144 --1 -1 100 1; -#X obj 335 218 vsl 15 30 0 1 0 1 empty empty empty 0 -8 0 8 -262144 --1 -1 200 1; -#X obj 125 304 3dp_push; -#X obj 67 119 3dp_mouserotate; -#X obj 67 176 3dp_view scale 1; -#X floatatom 241 145 5 0 0 0 - - -; -#X obj 244 125 hsl 128 15 0.2 5 1 1 empty empty empty -2 -6 0 8 -262144 --1 -1 3800 1; -#X obj 523 456 hsl 128 15 0.01 2 1 1 empty empty empty -2 -6 0 8 -262144 --1 -1 7900 1; -#X obj 67 251 3dp_color; -#X obj 402 231 route press3; -#X text 211 304 <- remove 3dp_push object to accumulate the translations -; -#X obj 197 392 randomwalk2D 100; -#X obj 125 275 3dp_for 100; -#X text 285 185 R G B I; -#X obj 197 533 smoothupdate 100; -#X obj 304 567 smoothupdate 100; -#X obj 524 490 hsl 128 15 0.01 1 1 1 empty empty empty -2 -6 0 8 -262144 --1 -1 1300 1; -#X obj 67 93 3dp_push; -#X obj 476 111 3dp_view transz 5; -#X obj 476 171 3dp_light; -#X obj 219 351 s i; -#X obj 250 511 r i; -#X obj 357 543 r i; -#X obj 419 716 smoothupdate 100; -#X obj 472 692 r i; -#X obj 197 325 t f f b; -#X obj 419 639 random 100; -#X obj 419 662 - 50; -#X obj 529 675 hsl 128 15 0.01 1 1 1 empty empty empty -2 -6 0 8 -262144 --1 -1 600 1; -#X obj 419 688 / 10; -#X msg 418 424 reset; -#X obj 148 201 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 0 -1; -#X obj 67 200 pdp_route; -#X obj 176 765 3dp_draw torus 1 2 5 5; -#X obj 176 709 pdp_route; -#X obj 265 711 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 0 -1; -#X obj 194 741 3dp_draw cube 2; -#X text 315 344 <- reset random walk; -#X text 532 554 <- reset smoothed points to origin; -#X text 227 13 like example14 but with coordinate smoothing and lighting -; -#X text 505 246 <- route mouse buttons; -#X obj 481 265 route press2; -#X text 666 453 <- walk radius; -#X text 667 488 <- walk smoothing; -#X obj 67 70 3dp_fixedsizewindowcontext 320 240; -#X floatatom 199 250 5 0 0 0 - - -; -#X connect 0 0 53 0; -#X connect 1 0 0 0; -#X connect 2 0 17 0; -#X connect 3 0 43 0; -#X connect 4 0 20 0; -#X connect 5 0 23 0; -#X connect 6 0 24 0; -#X connect 7 0 17 1; -#X connect 8 0 17 3; -#X connect 9 0 17 2; -#X connect 10 0 17 4; -#X connect 11 1 3 0; -#X connect 12 0 13 0; -#X connect 13 0 41 0; -#X connect 14 0 13 1; -#X connect 15 0 14 0; -#X connect 16 0 6 1; -#X connect 16 0 5 1; -#X connect 17 1 21 0; -#X connect 18 0 4 0; -#X connect 18 1 50 0; -#X connect 20 0 5 0; -#X connect 20 1 6 0; -#X connect 21 0 11 0; -#X connect 21 1 34 0; -#X connect 23 0 3 1; -#X connect 24 0 3 2; -#X connect 25 0 23 2; -#X connect 25 0 24 2; -#X connect 26 0 12 0; -#X connect 26 1 27 0; -#X connect 27 0 28 0; -#X connect 30 0 23 1; -#X connect 31 0 24 1; -#X connect 32 0 3 3; -#X connect 33 0 32 1; -#X connect 34 0 20 0; -#X connect 34 1 29 0; -#X connect 34 2 35 0; -#X connect 35 0 36 0; -#X connect 36 0 38 0; -#X connect 37 0 32 2; -#X connect 38 0 32 0; -#X connect 39 0 23 0; -#X connect 39 0 24 0; -#X connect 39 0 32 0; -#X connect 40 0 41 1; -#X connect 41 0 2 0; -#X connect 41 1 17 0; -#X connect 43 0 42 0; -#X connect 43 1 45 0; -#X connect 44 0 43 1; -#X connect 50 0 39 0; -#X connect 53 0 26 0; -#X connect 53 1 12 1; -#X connect 53 1 18 0; -#X connect 54 0 21 1; diff --git a/opengl/doc/examples/example16.pd b/opengl/doc/examples/example16.pd deleted file mode 100644 index e9495aa..0000000 --- a/opengl/doc/examples/example16.pd +++ /dev/null @@ -1,107 +0,0 @@ -#N canvas 196 0 772 525 10; -#X obj 57 25 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 1 1 -; -#X obj 57 153 3dp_blend; -#X floatatom 101 237 5 0 0 0 - - -; -#X floatatom 149 237 5 0 0 0 - - -; -#X floatatom 199 236 5 0 0 0 - - -; -#X floatatom 247 236 5 0 0 0 - - -; -#X obj 167 364 3dp_push; -#X obj 218 434 3dp_view transxyz; -#X msg 276 354 normal; -#X obj 422 255 f; -#X floatatom 484 264 5 0 0 0 - - -; -#X msg 422 220 0; -#X obj 57 177 pdp_t p b; -#X obj 392 185 t b b; -#X msg 591 238 0.2; -#X msg 484 239 0; -#X obj 57 72 3dp_windowcontext; -#X obj 392 112 route press3; -#X obj 57 49 metro 40; -#X obj 167 328 3dp_for 100; -#X obj 227 125 3dp_view transz 5; -#X obj 227 159 3dp_light; -#X obj 57 96 3dp_push; -#X obj 422 289 + 0.2; -#X obj 497 112 loadbang; -#X msg 519 238 0.01; -#N canvas 0 0 577 190 coordinates 0; -#X obj 51 100 *; -#X obj 51 72 elbat 100; -#X obj 165 99 *; -#X obj 165 71 elbat 100; -#X obj 276 97 *; -#X obj 276 69 elbat 100; -#X obj 51 19 inlet; -#X obj 125 18 inlet; -#X text 354 69 <- table read abstraction; -#X obj 51 130 outlet; -#X obj 165 127 outlet; -#X obj 276 125 outlet; -#X connect 0 0 9 0; -#X connect 1 0 0 0; -#X connect 2 0 10 0; -#X connect 3 0 2 0; -#X connect 4 0 11 0; -#X connect 5 0 4 0; -#X connect 6 0 1 0; -#X connect 6 0 3 0; -#X connect 6 0 5 0; -#X connect 7 0 0 1; -#X connect 7 0 2 1; -#X connect 7 0 4 1; -#X restore 239 403 pd coordinates; -#X msg 392 136 bang; -#X text 459 219 <- reset scaling to 0 (infinite density); -#X text 469 290 <- increment scaling for each new frame; -#X text 340 354 <- compute a new normal distributed set of points; -#X text 506 371 (velocity vectors); -#X text 545 264 <- diffusion speed; -#X msg 559 238 0.1; -#X text 182 12 explosion using 100 spheres with normal distributed -velocity vectors; -#X floatatom 367 441 5 0 0 0 - - -; -#X obj 57 125 3dp_mouserotate; -#X obj 57 278 3dp_color 0.1 0.1 0.1 0.27; -#X obj 218 478 3dp_draw sphere 1 8 8; -#X connect 0 0 18 0; -#X connect 1 0 12 0; -#X connect 2 0 37 1; -#X connect 3 0 37 2; -#X connect 4 0 37 3; -#X connect 5 0 37 4; -#X connect 6 1 7 0; -#X connect 7 0 38 0; -#X connect 8 0 26 0; -#X connect 9 0 23 0; -#X connect 10 0 23 1; -#X connect 11 0 9 0; -#X connect 12 0 37 0; -#X connect 12 1 9 0; -#X connect 13 0 8 0; -#X connect 13 1 11 0; -#X connect 14 0 10 0; -#X connect 15 0 10 0; -#X connect 16 0 22 0; -#X connect 16 1 17 0; -#X connect 16 1 36 1; -#X connect 17 0 27 0; -#X connect 18 0 16 0; -#X connect 19 0 6 0; -#X connect 19 1 26 0; -#X connect 20 0 21 0; -#X connect 22 0 36 0; -#X connect 22 1 20 0; -#X connect 23 0 9 1; -#X connect 23 0 26 1; -#X connect 24 0 13 0; -#X connect 25 0 10 0; -#X connect 26 0 7 1; -#X connect 26 1 7 2; -#X connect 26 2 7 3; -#X connect 27 0 13 0; -#X connect 33 0 10 0; -#X connect 35 0 38 2; -#X connect 36 0 1 0; -#X connect 37 1 19 0; diff --git a/opengl/doc/objects/3dp_for.pd b/opengl/doc/objects/3dp_for.pd deleted file mode 100644 index ccaf22d..0000000 --- a/opengl/doc/objects/3dp_for.pd +++ /dev/null @@ -1,91 +0,0 @@ -#N canvas 545 167 607 718 10; -#X obj 22 40 3dp_windowcontext; -#X obj 22 15 metro 40; -#X obj 22 -5 tgl 15 0 empty empty empty 0 -6 0 8 -262144 -1 -1 1 1 -; -#X obj 22 67 3dp_push; -#X obj 180 126 3dp_light; -#X floatatom 301 85 5 0 0 0 - - -; -#X obj 22 97 3dp_mouserotate; -#X floatatom 151 228 5 0 0 0 - - -; -#X obj 180 104 3dp_view transz 10; -#X floatatom 81 165 5 0 0 0 - - -; -#X obj 23 191 3dp_for 3; -#X obj 23 251 3dp_view transx 1.5; -#X floatatom 130 280 5 0 0 0 - - -; -#X obj 23 302 3dp_view roty 45; -#X obj 23 389 3dp_draw sphere 1; -#X obj 81 365 + 1; -#X obj 81 343 *; -#X floatatom 129 327 5 0 0 0 - - -; -#X text 135 159 3dp_for sends a rendering context trough a chain multiple -times. the second outlet is the current number \, starting from zero -\, and can be used to change the parameters parameters of the chain. -(i.e. by reading from a table); -#X text 222 252 all the geometry operations are accumulative \,; -#X text 222 266 if you don't want that \, insert a 3dp_push object: -; -#X obj 314 313 3dp_for 3; -#X obj 314 336 3dp_push; -#X obj 365 400 3dp_draw cube 0.5; -#X obj 23 140 3dp_push; -#X obj 365 374 3dp_view transy; -#X obj 465 343 * 1; -#X floatatom 481 319 5 0 0 0 - - -; -#X obj 86 569 pdp_t p p p; -#X obj 86 606 3dp_view transy 1; -#X obj 86 630 3dp_draw cube 0.5; -#X obj 177 465 3dp_for 3; -#X text 72 492 so \, in short \,; -#X text 313 492 is equivalent to; -#X obj 177 491 3dp_view transy 1; -#X obj 177 515 3dp_draw cube 0.5; -#X obj 354 539 3dp_view transy 1; -#X obj 354 563 3dp_draw cube 0.5; -#X obj 354 589 3dp_view transy 1; -#X obj 354 613 3dp_draw cube 0.5; -#X obj 354 638 3dp_view transy 1; -#X obj 354 662 3dp_draw cube 0.5; -#X text 256 596 and; -#X obj 180 84 3dp_view roty; -#X floatatom 266 66 5 0 0 0 - - -; -#X connect 0 0 3 0; -#X connect 0 1 6 1; -#X connect 1 0 0 0; -#X connect 2 0 1 0; -#X connect 3 0 6 0; -#X connect 3 1 43 0; -#X connect 5 0 8 1; -#X connect 6 0 24 0; -#X connect 7 0 11 1; -#X connect 8 0 4 0; -#X connect 9 0 10 1; -#X connect 10 0 11 0; -#X connect 10 1 16 0; -#X connect 11 0 13 0; -#X connect 12 0 13 1; -#X connect 13 0 14 0; -#X connect 15 0 14 2; -#X connect 16 0 15 0; -#X connect 17 0 16 1; -#X connect 21 0 22 0; -#X connect 21 1 26 0; -#X connect 22 1 25 0; -#X connect 24 0 10 0; -#X connect 24 1 21 0; -#X connect 25 0 23 0; -#X connect 26 0 25 1; -#X connect 27 0 26 1; -#X connect 28 0 29 0; -#X connect 28 1 29 0; -#X connect 28 2 29 0; -#X connect 29 0 30 0; -#X connect 31 0 34 0; -#X connect 34 0 35 0; -#X connect 36 0 37 0; -#X connect 37 0 38 0; -#X connect 38 0 39 0; -#X connect 39 0 40 0; -#X connect 40 0 41 0; -#X connect 43 0 8 0; -#X connect 44 0 43 1; diff --git a/puredata/CONTENTS b/puredata/CONTENTS deleted file mode 100644 index 19eeaaa..0000000 --- a/puredata/CONTENTS +++ /dev/null @@ -1,10 +0,0 @@ -base pdp base pd object -image_base image processing base pd object -dpd_base bucket base pd object -comm pdp communication protocol in pd -compat legacy pdp stuff -control control pdp from within pd -fp object interface to the forth system -forthconsole console interface to the forth system -queue processing queue and synchro stuff -ut some utility pd objects diff --git a/puredata/Makefile b/puredata/Makefile deleted file mode 100644 index 11c78ec..0000000 --- a/puredata/Makefile +++ /dev/null @@ -1,12 +0,0 @@ - -OBJECTS = pdp_base.o pdp_imagebase.o pdp_dpd_base.o pdp_ut.o pdp_queue.o pdp_comm.o \ - pdp_control.o pdp_compat.o $(PDP_PDMOD) - - -include ../Makefile.config - -all: $(OBJECTS) - -clean: - rm -f *~ - rm -f *.o diff --git a/puredata/pdp_base.c b/puredata/pdp_base.c deleted file mode 100644 index 194134e..0000000 --- a/puredata/pdp_base.c +++ /dev/null @@ -1,415 +0,0 @@ -/* - * Pure Data Packet base class implementation. - * Copyright (c) by Tom Schouten - * - * This program is free software; you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation; either version 2 of the License, or - * (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program; if not, write to the Free Software - * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. - * - */ - - -/* - - This file contains the pdp base class object. - This is really nothing more than an attempt to stay away from c++ - as far as possible, while having some kind of base class functionality - for pdp (tucking away the communication & thread protocol). - -*/ - -#include "pdp_base.h" -#include - - -static void pdp_base_debug(t_pdp_base *b, t_floatarg f) -{ - int i; - post("debug"); - post("inlets: %d", b->b_inlets); - post("\tpacket\tnext_packet"); - for (i=0; ib_inlets; i++) - post("\t%d\t%d", b->b_packet[i], b->b_packet_next[i]); - //post("outlets: %d", b->b_inlets); -} - -static void pdp_base_thread(t_pdp_base *b, t_floatarg f) -{ - int i = (int)f; - if ((i == 0) || (i == 1)) b->b_thread_enabled = i; -} - -static void pdp_base_process(t_pdp_base *b) -{ - - if (b->b_process_method) - (*b->b_process_method)(b); -} - -/* this method is called after the thread has finished processing */ -static void pdp_base_postprocess(t_pdp_base *b) -{ - /* call the derived class postproc callback if there is any */ - if (b->b_postproc_method) - (*b->b_postproc_method)(b); - - /* unregister (mark unused) packet and propagate if packet is valid */ - if (b->b_outlet[0]) - pdp_pass_if_valid(b->b_outlet[0], &b->b_packet[0]); -} - - -/* move the passive packets in place */ -void pdp_base_movepassive(void *x) -{ - t_pdp_base *b = (t_pdp_base *)x; - int i; - - /* if a cold packet was received in the meantime - swap it in, else keep the old one */ - for (i=1; ib_inlets; i++){ - pdp_replace_if_valid(&b->b_packet[i], &b->b_packet_next[i]); - } - - -} - -/* the standard bang method */ -void pdp_base_bang(void *x) -{ - t_pdp_base *b = (t_pdp_base *)x; - int i; - - /* if pdp thread is still processing, do nothing */ - if (-1 != b->b_queue_id) return; - - /* move packets in place */ - pdp_base_movepassive(x); - - - /* if there is a preproc method defined, call it inside - the pd thread. (mainly for allocations) */ - if (b->b_preproc_method) - (*b->b_preproc_method)(b); - - /* check if we need to use pdp queue */ - if (b->b_thread_enabled){ - - /* add the process method and callback to the process queue */ - pdp_procqueue_add(b->b_q, b, pdp_base_process, pdp_base_postprocess, &b->b_queue_id); - } - else{ - /* call both methods directly */ - pdp_base_process(b); - pdp_base_postprocess(b); - } -} - -/* hot packet input handler */ -void pdp_base_input_hot(t_pdp_base *b, t_symbol *s, t_floatarg f) -{ - - int p = (int)f; - - /* dont register if active inlet is disabled */ - if (!b->b_active_inlet_enabled) return; - - /* register the packet (readonly or read/write) - or drop it if we have an active packet - if type template is not null, packet will be converted */ - - - if (b->b_active_inlet_readonly){ - if (s == S_REGISTER_RO){ - if (b->b_type_template[0]){ - pdp_packet_convert_ro_or_drop(&b->b_packet[0], p, b->b_type_template[0]); - } - else{ - pdp_packet_copy_ro_or_drop(&b->b_packet[0], p); - } - } - } - else{ - if (s == S_REGISTER_RW) { - if (b->b_type_template[0]){ - pdp_packet_convert_rw_or_drop(&b->b_packet[0], p, b->b_type_template[0]); - } - else{ - pdp_packet_copy_rw_or_drop(&b->b_packet[0], p); - } - } - } - - /* start processing if there is an active packet to process - and the processing method is not active */ - - if ((s == S_PROCESS) && (-1 != b->b_packet[0]) && (-1 == b->b_queue_id)){ - pdp_base_bang(b); - } - //if ((pdp_sym_prc() == s) && (-1 != b->b_packet[0]) && (!b->b_dropped)) pdp_base_bang(b); - -} - -/* cold packet input handlers */ -void pdp_base_input_cold(t_pdp_base *b, t_symbol *s, int ac, t_atom *av) -{ - - int p; - int i; - char msg[] = "pdp1"; - char *c; - - int inlet; - - //post("pdp_base_input_cold: got packet"); - - /* do cheap tests first */ - if (ac != 2) return; - if (av[0].a_type != A_SYMBOL) return; - if (av[0].a_w.w_symbol != S_REGISTER_RO) return; - if (av[1].a_type != A_FLOAT) return; - p = (int)av[1].a_w.w_float; - - - /* check if it's a pdp message - and determine inlet */ - for (i=1; ib_packet_next[inlet], p); -} - - -void pdp_base_set_process_method(void *x, t_pdp_method m) -{ - t_pdp_base *b = (t_pdp_base *)x; - b->b_process_method = m; -} - -void pdp_base_set_preproc_method(void *x, t_pdp_method m) -{ - t_pdp_base *b = (t_pdp_base *)x; - b->b_preproc_method = m; -} - - -void pdp_base_set_postproc_method(void *x, t_pdp_method m) -{ - t_pdp_base *b = (t_pdp_base *)x; - b->b_postproc_method = m; -} - - -void pdp_base_queue_wait(void *x) -{ - t_pdp_base *b = (t_pdp_base *)x; - pdp_procqueue_wait(b->b_q); -} - -void pdp_base_set_queue(void *x, t_pdp_procqueue *q) -{ - t_pdp_base *b = (t_pdp_base *)x; - pdp_base_queue_wait(x); - b->b_q = q; -} - -t_pdp_procqueue *pdp_base_get_queue(void *x) -{ - t_pdp_base *b = (t_pdp_base *)x; - return b->b_q; -} - -void pdp_base_setup(t_class *c) -{ - - /* add pdp base class methods */ - class_addmethod(c, (t_method)pdp_base_thread, gensym("thread"), A_FLOAT, A_NULL); - class_addmethod(c, (t_method)pdp_base_debug, gensym("debug"), A_NULL); - - /* hot packet handler */ - class_addmethod(c, (t_method)pdp_base_input_hot, gensym("pdp"), A_SYMBOL, A_DEFFLOAT, A_NULL); - - /* cold packet handler */ - class_addanything(c, (t_method)pdp_base_input_cold); -} - -/* pdp base instance constructor */ -void pdp_base_init(void *x) -{ - int i; - t_pdp_base *b = (t_pdp_base *)x; - - b->b_channel_mask = -1; - - for(i=0; ib_packet[i] = -1; - b->b_packet_next[i] = -1; - b->b_type_template[i] = 0; - } - - b->b_queue_id = -1; - //b->b_dropped = 0; - b->b_process_method = 0; - b->b_preproc_method = 0; - b->b_inlets = 1; - b->b_outlets = 0; - b->b_active_inlet_enabled = 1; - b->b_active_inlet_readonly = 0; - b->b_thread_enabled = 1; - - // default queue is pdp queue - b->b_q = pdp_queue_get_queue(); - -} - -/* base instance destructor */ -void pdp_base_free(void *x) -{ - int i; - t_pdp_base *b = (t_pdp_base *)x; - /* remove process method from queue before deleting data */ - pdp_procqueue_finish(b->b_q, b->b_queue_id); - - /* delete stuff */ - for(i=0; ib_packet[i]); - pdp_packet_mark_unused(b->b_packet_next[i]); - } - -} - -void pdp_base_readonly_active_inlet(void *x) -{ - t_pdp_base *b = (t_pdp_base *)x; - b->b_active_inlet_readonly = 1; -} - -void pdp_base_disable_active_inlet(void *x) -{ - t_pdp_base *b = (t_pdp_base *)x; - b->b_active_inlet_enabled = 0; -} - - -/* add an inlet */ -void pdp_base_add_pdp_inlet(void *x) -{ - t_pdp_base *b = (t_pdp_base *)x; - char s[] = "pdp0"; - s[3] += b->b_inlets; - - if (b->b_inlets < MAX_NB_PDP_BASE_INLETS){ - inlet_new(&b->x_obj, &b->x_obj.ob_pd, gensym("pdp"), gensym(s)); - b->b_inlets++; - } - else { - post("pdp_base_add_pdp_inlet: only %d pdp inlets allowed. ignoring.", MAX_NB_PDP_BASE_INLETS); - } -} - - -/* add an outlet: only one allowed */ -t_outlet *pdp_base_add_pdp_outlet(void *x) -{ - t_pdp_base *b = (t_pdp_base *)x; - t_outlet *outlet = outlet_new(&b->x_obj, &s_anything); - - - if (b->b_outlets < MAX_NB_PDP_BASE_OUTLETS){ - b->b_outlet[b->b_outlets] = outlet; - b->b_outlets++; - } - - return outlet; - -} - -void pdp_base_set_packet(void *x, int inlet, int packet) -{ - t_pdp_base *b = (t_pdp_base *)x; - - if (inlet < b->b_inlets){ - //post("%d %d", b->b_packet[inlet], b->b_packet_next[inlet]); - pdp_packet_mark_unused(b->b_packet[inlet]); - b->b_packet[inlet] = packet; - } -} - - -int pdp_base_get_packet(void *x, int inlet) -{ - t_pdp_base *b = (t_pdp_base *)x; - - if (inlet < b->b_inlets){ - //post("%d %d", b->b_packet[inlet], b->b_packet_next[inlet]); - return (b->b_packet[inlet]); - } - - return -1; -} - -int pdp_base_move_packet(void *x, int inlet) -{ - t_pdp_base *b = (t_pdp_base *)x; - int p; - - if (inlet < b->b_inlets){ - p = b->b_packet[inlet]; - b->b_packet[inlet] = -1; - return (p); - } - - return -1; -} - - - -t_object *pdp_base_get_object(void *x) -{ - return (t_object *)x; -} - -void pdp_base_add_gen_inlet(void *x, t_symbol *from, t_symbol *to) -{ - t_object *o = (t_object *)x; - inlet_new(o, &o->ob_pd, from, to); -} - -void pdp_base_disable_thread(void *x) -{ - - t_pdp_base *b = (t_pdp_base *)x; - b->b_thread_enabled = 0; -} - -void pdp_base_set_type_template(void *x, int inlet, t_pdp_symbol *type_template) -{ - t_pdp_base *b = (t_pdp_base *)x; - if (inlet < b->b_inlets){ - b->b_type_template[inlet] = type_template; - } -} diff --git a/puredata/pdp_comm.c b/puredata/pdp_comm.c deleted file mode 100644 index 4c67659..0000000 --- a/puredata/pdp_comm.c +++ /dev/null @@ -1,367 +0,0 @@ -/* - * Pure Data Packet system implementation. - * Copyright (c) by Tom Schouten - * - * This program is free software; you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation; either version 2 of the License, or - * (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program; if not, write to the Free Software - * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. - * - */ - -/* this file contains misc communication (packet) methods for pd */ - - -#include -#include "pdp_pd.h" -#include "pdp_internals.h" -#include "pdp_packet.h" -#include "pdp_comm.h" -#include "pdp_type.h" -#include "pdp_control.h" -#include "pdp_mem.h" -#include "pdp_queue.h" // for notify drop: fix this (should be from pdp_control.h) -#include "pdp_debug.h" - -/* all symbols are C style */ -#ifdef __cplusplus -extern "C" -{ -#endif - - -/* interface to pd system: - pdp/dpd communication protocol in pd - pd <-> pdp atom and list conversion */ - - /* NOTE: when using the outlet_pdp methods, the packet - is no longer read/write, but can be readonly */ - - - /* NOTE: since 0.13 the passing packet is no more. - in order to limit copying. processors should always register ro, - and replace with writable when packet needs to be written in the process method */ - - -/* send a packet to an outlet */ -void outlet_pdp_register(t_outlet *out, int packetid) -{ - t_atom atom[2]; - - SETFLOAT(atom+1, (float)packetid); - - /* during the following phase, - objects can register a ro copy */ - - SETSYMBOL(atom+0, S_REGISTER_RO); - outlet_anything(out, S_PDP, 2, atom); - - /* DEPRECIATED: objects can register a rw copy - but this will always copy the packet. it is better - to perform a pdp_packet_replace_with_writable operation during the process step */ - - SETSYMBOL(atom+0, S_REGISTER_RW); - outlet_anything(out, S_PDP, 2, atom); - -} -/* send a packet to an outlet */ -void outlet_pdp_process(t_outlet *out) -{ - t_atom atom[2]; - - /* set a dummy invalid packet. - this is for uniform pdp messages in pd, for ease of routing. */ - SETFLOAT(atom+1, (float)-1); - - /* during the process phase, objects can perform pdp_packet_replace_with_writable - and process the packet data */ - SETSYMBOL(atom+0, S_PROCESS); - outlet_anything(out, S_PDP, 2, atom); - -} - -/* for compat */ -void outlet_pdp(t_outlet *out, int packetid) -{ - outlet_pdp_register(out, packetid); - outlet_pdp_process(out); -} - -/* send an accumulation packet to an outlet */ -void outlet_dpd(t_outlet *out, int packetid) -{ - t_atom atom[2]; - - SETFLOAT(atom+1, (float)packetid); - - SETSYMBOL(atom+0, S_INSPECT); - outlet_anything(out, S_DPD, 2, atom); - - SETSYMBOL(atom+0, S_ACCUMULATE); - outlet_anything(out, S_DPD, 2, atom); - -} - -/* unregister a packet and send it to an outlet */ -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; - - /* send process phase */ - outlet_pdp_process(outlet); - - } -} - -void -pdp_packet_replace_if_valid(int *dpacket, int *spacket) -{ - if (-1 != *spacket){ - pdp_packet_mark_unused(*dpacket); - *dpacket = *spacket; - *spacket = -1; - } - -} - - -int -pdp_packet_copy_ro_or_drop(int *dpacket, int spacket) -{ - int drop = 0; - if (*dpacket == -1) *dpacket = pdp_packet_copy_ro(spacket); - else { - /* send a notification there is a dropped packet */ - pdp_control_notify_drop(spacket); - drop = 1; - } - return drop; -} - - -int -pdp_packet_copy_rw_or_drop(int *dpacket, int spacket) -{ - int drop = 0; - if (*dpacket == -1) *dpacket = pdp_packet_copy_rw(spacket); - else { - /* send a notification there is a dropped packet */ - pdp_control_notify_drop(spacket); - drop = 1; - } - return drop; -} - -int -pdp_packet_convert_ro_or_drop(int *dpacket, int spacket, t_pdp_symbol *template) -{ - int drop = 0; - - if (!template) return pdp_packet_copy_ro_or_drop(dpacket, spacket); - - if (*dpacket == -1) *dpacket = pdp_packet_convert_ro(spacket, template); - else { - /* send a notification there is a dropped packet */ - pdp_control_notify_drop(spacket); - drop = 1; - } - return drop; -} - - -int -pdp_packet_convert_rw_or_drop(int *dpacket, int spacket, t_pdp_symbol *template) -{ - int drop = 0; - - if (!template) return pdp_packet_copy_rw_or_drop(dpacket, spacket); - - if (*dpacket == -1) *dpacket = pdp_packet_convert_rw(spacket, template); - else { - /* send a notification there is a dropped packet */ - pdp_control_notify_drop(spacket); - drop = 1; - } - return drop; -} - - -/* send a pdp list to a pd outlet. packets are not copied but passed! */ -void outlet_pdp_atom(t_outlet *out, t_pdp_atom *a) -{ - int packet = -1; - if (!a) return; - switch(a->t){ - case a_float: - outlet_float(out, a->w.w_float); - return; - case a_int: - outlet_float(out, (float)a->w.w_int); - return; - case a_symbol: - outlet_symbol(out, gensym(a->w.w_symbol->s_name)); - return; - case a_list: - outlet_pdp_list(out, a->w.w_list); - return; - case a_packet: - pdp_packet_pass_if_valid(out, &a->w.w_packet); - return; - default: - return; - } -} - -void outlet_pdp_list(t_outlet *out, struct _pdp_list *l) -{ - int elements; - t_atom *atomlist; - t_pdp_atom *pdp_a; - t_atom *pd_a; - t_symbol *pd_selector; - - if (!l) return; - switch(l->elements){ - case 0: /* bang */ - outlet_bang(out); - return; - case 1: /* atom */ - outlet_pdp_atom(out, l->first); - return; - default: /* proper list*/ - elements = l->elements; - - /* allocate list */ - atomlist = pdp_alloc(sizeof (t_atom) * l->elements); - pd_a = atomlist; - pdp_a = l->first; - - /* setup selector */ - if (pdp_a->t != a_symbol){ - pd_selector = gensym("list"); - } - else { - pd_selector = gensym(pdp_a->w.w_symbol->s_name); - elements--; - pdp_a = pdp_a->next; - } - - /* setup atoms */ - while (pdp_a){ - switch(pdp_a->t){ - case a_float: - SETFLOAT(pd_a, pdp_a->w.w_float); - break; - case a_int: - SETFLOAT(pd_a, (float)pdp_a->w.w_int); - break; - case a_symbol: - SETSYMBOL(pd_a, gensym(pdp_a->w.w_symbol->s_name)); - break; - default: - SETSYMBOL(pd_a, gensym("invalid")); - break; - } - - pdp_a = pdp_a->next; - pd_a++; - } - - /* send out */ - outlet_anything(out, pd_selector, elements, atomlist); - - - - /* clean up */ - pdp_dealloc(atomlist); - - } - - -} - - -void pd_atom_to_pdp_atom(t_atom *pdatom, t_pdp_atom *pdpatom) -{ - switch (pdatom->a_type){ - case A_FLOAT: - pdpatom->t = a_float; - pdpatom->w.w_float = pdatom->a_w.w_float; - break; - case A_SYMBOL: - pdpatom->t = a_symbol; - pdpatom->w.w_symbol = pdp_gensym(pdatom->a_w.w_symbol->s_name); - break; - default: - pdpatom->t = a_undef; - break; - } -} - - - -/* some "accelerated" pd symbols */ -t_symbol s_pdp = {"pdp", 0, 0}; -t_symbol s_register_ro = {"register_ro", 0, 0}; -t_symbol s_register_rw = {"register_rw", 0, 0}; -t_symbol s_process = {"process", 0, 0}; -t_symbol s_dpd = {"dpd", 0, 0}; -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) -{ - - /* don't kill me for this one.. - if the symbol is already defined and used, .. well, that's a problem - but right now it seems a reasonable hack */ - - t_symbol *sret = dogensym(s->s_name, s); - if (s != sret){ - post("PDP INIT ERROR: pd symbol clash adding symbol %s: new=%08x old=%08x", s->s_name, s, sret); - post("try loading pdp before other libraries"); - } -} - -void -pdp_pdsym_setup(void) -{ - - _addsym(&s_pdp); - _addsym(&s_register_ro); - _addsym(&s_register_rw); - _addsym(&s_process); - _addsym(&s_dpd); - _addsym(&s_inspect); - _addsym(&s_accumulate); - _addsym(&s_chanmask); - -} - - - -#ifdef __cplusplus -} -#endif diff --git a/puredata/pdp_compat.c b/puredata/pdp_compat.c deleted file mode 100644 index e7bc0c2..0000000 --- a/puredata/pdp_compat.c +++ /dev/null @@ -1,57 +0,0 @@ -/* - * Pure Data Packet system implementation. Compatibility routines. - * Copyright (c) by Tom Schouten - * - * This program is free software; you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation; either version 2 of the License, or - * (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program; if not, write to the Free Software - * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. - * - */ - -/* this file contains misc communication methods */ - -#include - -#include "pdp_pd.h" -#include "pdp_comm.h" -#include "pdp_internals.h" - -/* all symbols are C style */ -#ifdef __cplusplus -extern "C" -{ -#endif - - - -void -pdp_pass_if_valid(t_outlet *outlet, int *packet) -{ - pdp_packet_pass_if_valid(outlet, packet); -} - -void -pdp_replace_if_valid(int *dpacket, int *spacket) -{ - pdp_packet_replace_if_valid(dpacket, spacket); - -} - - - - - - -#ifdef __cplusplus -} -#endif diff --git a/puredata/pdp_control.c b/puredata/pdp_control.c deleted file mode 100644 index 0b49fd9..0000000 --- a/puredata/pdp_control.c +++ /dev/null @@ -1,186 +0,0 @@ -/* - * Pure Data Packet system implementation: control object - * Copyright (c) by Tom Schouten - * - * This program is free software; you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation; either version 2 of the License, or - * (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program; if not, write to the Free Software - * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. - * - */ - - -/* this is an actual pd class that is used for communication with the - pdp framework */ - -#include "pdp_internals.h" -#include "pdp_control.h" -#include "pdp_packet.h" -#include - -/* all symbols are C style */ -#ifdef __cplusplus -extern "C" -{ -#endif - - - -static long dropped_packets; - -static t_class* pdp_control_class; - - -/* pdp control instance data */ - -struct _pdp_control; -typedef struct _pdp_control -{ - t_object x_obj; - t_outlet *x_outlet0; - struct _pdp_control *x_next; - -} t_pdp_control; - - - -static t_pdp_control *pdp_control_list; - -static void pdp_control_info(t_pdp_control *x) -{ -} - -static void pdp_control_collectgarbage(t_pdp_control *x) -{ - int nb_packets_freed = pdp_pool_collect_garbage(); - post("pdp_control: freed %d packets", nb_packets_freed); - -} - -static void pdp_control_set_mem_limit(t_pdp_control *x, t_floatarg f) -{ - int limit = (int)f; - if (limit < 0) limit = 0; - pdp_pool_set_max_mem_usage(limit); - if (limit) post("pdp_control: set memory limit to %d bytes", limit); - else post("pdp_control: disabled memory limit"); - -} - -static void pdp_control_thread(t_pdp_control *x, t_floatarg f) -{ - int t = (int)f; - - if (t){ - post("pdp_control: pdp is now using its own processing thread"); - pdp_queue_use_thread(1); - } - else { - post("pdp_control: pdp is now using the main pd thread"); - pdp_queue_use_thread(0); - } -} - - -static void pdp_control_send_drop_message(t_pdp_control *x) -{ - t_atom atom[1]; - t_symbol *s = gensym("pdp_drop"); - - SETFLOAT(atom+0, (float)dropped_packets); - outlet_anything(x->x_outlet0, s, 1, atom); -} - - -static void pdp_control_free(t_pdp_control *x) -{ - /* remove from linked list */ - t_pdp_control *curr = pdp_control_list; - if (pdp_control_list == x) pdp_control_list = x->x_next; - else while (curr){ - if (curr->x_next == x) { - curr->x_next = x->x_next; - break; - } - else { - curr = curr->x_next; - } - - } -} - - -static void *pdp_control_new(void) -{ - t_pdp_control *x = (t_pdp_control *)pd_new(pdp_control_class); - x->x_outlet0 = outlet_new(&x->x_obj, &s_anything); - - /* add to list */ - x->x_next = pdp_control_list; - pdp_control_list = x; - return x; -} - -/************************* class methods ***************************************/ - - -void pdp_control_addmethod(t_method m, t_symbol *s) -{ - class_addmethod(pdp_control_class, m, s, A_GIMME, A_NULL); -} - -void pdp_control_setup(void) -{ - - pdp_control_list = 0; - dropped_packets = 0; - - /* setup pd class data */ - pdp_control_class = class_new(gensym("pdp_control"), (t_newmethod)pdp_control_new, - (t_method)pdp_control_free, sizeof(t_pdp_control), 0, A_NULL); - - - class_addmethod(pdp_control_class, (t_method)pdp_control_info, gensym("info"), A_NULL); - class_addmethod(pdp_control_class, (t_method)pdp_control_thread, gensym("thread"), A_DEFFLOAT, A_NULL); - class_addmethod(pdp_control_class, (t_method)pdp_control_collectgarbage, gensym("collectgarbage"), A_NULL); - class_addmethod(pdp_control_class, (t_method)pdp_control_set_mem_limit, gensym("memlimit"), A_FLOAT, A_NULL); -} - - - -void pdp_control_notify_broadcast(t_pdp_control_method_notify *notify) -{ - t_pdp_control *curr = pdp_control_list; - while (curr){ - (*notify)(curr); - curr = curr->x_next; - } -} - - - -/************************* notify class methods *************************/ - -void pdp_control_notify_drop(int packet) -{ - dropped_packets++; - - /* send drop notify to controller class instances */ - pdp_control_notify_broadcast(pdp_control_send_drop_message); - //post("dropped packet"); -} - - - -#ifdef __cplusplus -} -#endif diff --git a/puredata/pdp_dpd_base.c b/puredata/pdp_dpd_base.c deleted file mode 100644 index 371b99e..0000000 --- a/puredata/pdp_dpd_base.c +++ /dev/null @@ -1,270 +0,0 @@ -/* - * Pure Data Packet module. DPD base class implementation. - * Copyright (c) by Tom Schouten - * - * This program is free software; you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation; either version 2 of the License, or - * (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program; if not, write to the Free Software - * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. - * - */ - - -#include "pdp_dpd_base.h" -#include "pdp_internals.h" - - -#define THIS(b) t_pdp_dpd_base *b = (t_pdp_dpd_base *)x - - -#ifdef __cplusplus -extern "C" -{ -#endif - - - -/* PRIVATE METHODS */ - - - - -/* dpd packet context input handler */ -static void _pdp_dpd_base_context_input(t_pdp_dpd_base *b, t_symbol *s, t_floatarg f) -{ - - int p = (int)f; - int i; - - //post ("pdp_dpd_base_context_input: got %s %d", s->s_name, p); - - /* sources/sinks have active inlet disabled */ - if (b->b_dpd_active_inlet_disabled) return; - - /* handle inspect message */ - if (s == S_INSPECT){ - - /* store packet for inspector */ - b->b_context_packet = p; - - /* add inspector to pdp queue - this is special: it doesn't use a command object */ - pdp_dpd_base_queue_command(b, b, b->b_inspector_method, b->b_inspector_callback, 0); - } - - /* handle accumulate message */ - if (s == S_ACCUMULATE){ - - /* store context for accumulator methods */ - b->b_context_packet = p; - - /* call bang */ - pdp_dpd_base_bang(b); - - - } - -} - -/* default command object (returns self) */ -void *_pdp_dpd_base_get_command_object(void *x){return x;} - -/* PUBLIC METHODS */ - - -void pdp_dpd_base_queue_command(void *x, void *c, t_pdp_method process, - t_pdp_method callback, int *id) -{ - THIS(b); - t_pdp_procqueue *q = pdp_base_get_queue(x); - pdp_procqueue_add(q, c, process, callback, id); - -} - -/* bang method (propagate context to outlet) : it is not registered as a pd message by default ! */ -void pdp_dpd_base_bang(void *x) -{ - THIS(b); - int i, id; - void *cobj; - - /* move passive pdp packets in place */ - pdp_base_movepassive(x); - - /* get command object (or use self) */ - cobj = b->b_command_factory_method ? (b->b_command_factory_method)(b) : b; - //post(" command object is %x. object is %x", cobj, b); - - - /* queue acc method & propagate for all outlets */ - for (i=b->b_nb_context_outlets; i--;){ - - - /* propagate the context packet to the outlet */ - if (b->b_outlet_enable[i]){ - pdp_dpd_base_queue_command(x, cobj, b->b_accum_method[i], b->b_accum_callback[i], 0); - outlet_dpd(b->b_context_outlet[i], b->b_context_packet); - } - else{ - //post("outlet %d disabled", i); - } - } - - /* queue cleanup method */ - if (b->b_cleanup_method) - //pdp_procqueue_add(b->b_q, b, b->b_cleanup_method, 0, &b->b_cleanup_queue_id); - pdp_dpd_base_queue_command(x, cobj, b->b_cleanup_method, b->b_cleanup_callback, 0); - - /* send communication complete notify */ - if (b->b_complete_notify) - (b->b_complete_notify)(x); - -} - -/* get/set context packet */ -int pdp_dpd_base_get_context_packet(void *x){ - THIS(b); - return b->b_context_packet; -} -int pdp_dpd_base_move_context_packet(void *x){ - THIS(b); - int p = b->b_context_packet; - b->b_context_packet = -1; - return p; -} - -void pdp_dpd_base_set_context_packet(void *x, int p){ - THIS(b); - pdp_packet_mark_unused(b->b_context_packet); - b->b_context_packet = p; -} - -/* add a cleanup callback (called after all propagation is finished) for sources/sinks */ -void pdp_dpd_base_add_cleanup(void *x, t_pdp_method cleanup_method, t_pdp_method cleanup_callback) -{ - THIS(b); - b->b_cleanup_method = cleanup_method; - b->b_cleanup_callback = cleanup_callback; - //b->b_cleanup_queue_id = -1; -} - -/* add a inspector callback */ -void pdp_dpd_base_add_inspector(void *x, t_pdp_method inspector_method) -{ - THIS(b); - b->b_inspector_method = inspector_method; - //b->b_inspector_queue_id = -1; -} - -/* add a context outlet */ -t_outlet *pdp_dpd_base_add_outlet(void *x, t_pdp_method accum_method, t_pdp_method accum_callback) -{ - THIS(b); - int i = b->b_nb_context_outlets; - if (i < PDP_DPD_MAX_CONTEXT_OUTLETS){ - b->b_context_outlet[i] = outlet_new((t_object *)b, &s_anything); - b->b_outlet_enable[i] = 1; - b->b_accum_method[i] = accum_method; - b->b_accum_callback[i] = accum_callback; - //b->b_accum_queue_id[i] = -1; - b->b_nb_context_outlets++; - return b->b_context_outlet[i]; - } - else{ - post("pdp_dpd_base_add_outlet: no more free outlet slots"); - return 0; - } - -} - - -/* destructor */ -void pdp_dpd_base_free(void *x) -{ - THIS(b); - - /* free base */ - pdp_base_free(b); -} - - -void pdp_dpd_base_disable_active_inlet(void *x) -{ - THIS(b); - b->b_dpd_active_inlet_disabled = 1; -} - - - -void pdp_dpd_base_enable_outlet(void *x, int outlet, int toggle) -{ - THIS(b); - if (outlet >=0 && outlet < PDP_DPD_MAX_CONTEXT_OUTLETS){ - b->b_outlet_enable[outlet] = toggle; - } - -} - - -void pdp_dpd_base_register_complete_notify(void *x, t_pdp_method method) -{ - THIS(b); - b->b_complete_notify = method; -} - -void pdp_dpd_base_register_command_factory_method(void *x, t_pdp_newmethod command_factory_method) -{ - THIS(b); - b->b_command_factory_method = command_factory_method; -} - - -/* init method */ -void pdp_dpd_base_init(void *x) -{ - THIS(b); - - /* super init */ - pdp_base_init(b); - - /* disable pdp messages on active inlet (dpd messages are used as sync) */ - pdp_base_disable_active_inlet(b); - - /* init data */ - b->b_nb_context_outlets = 0; - b->b_context_packet = -1; - b->b_cleanup_method = 0; - //b->b_cleanup_queue_id = -1; - b->b_inspector_method = 0; - //b->b_inspector_queue_id = -1; - b->b_dpd_active_inlet_disabled = 0; - - // default notify == none - b->b_complete_notify = 0; - - // default command object getter - b->b_command_factory_method = 0; - -} - - -void pdp_dpd_base_setup(t_class *class) -{ - - pdp_base_setup(class); - class_addmethod(class, (t_method)_pdp_dpd_base_context_input, gensym("dpd"), A_SYMBOL, A_FLOAT, A_NULL); - -} - -#ifdef __cplusplus -} -#endif diff --git a/puredata/pdp_forthproc.c_bak b/puredata/pdp_forthproc.c_bak deleted file mode 100644 index e6517d5..0000000 --- a/puredata/pdp_forthproc.c_bak +++ /dev/null @@ -1,807 +0,0 @@ -/* - * Pure Data Packet module. - * Copyright (c) by Tom Schouten - * - * This program is free software; you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation; either version 2 of the License, or - * (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program; if not, write to the Free Software - * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. - * - */ - -/* TODO: ADD THREAD SUPPORT */ - -/* - -this is the pd interface to forth processes / processors. -in time, it should become the only interface between the processing -functionality in pdp, and pd objects representing this functionality - -example object definitions: - -a forth process is a virtual machine operating on a private -rotation stack, as found in hp rpn calcs (this is the machine state vector) -the tick operation leaves the stack size and relative position of -the elements invariant - -this is a very crude and simple framework. it is an experiment to -see how far this forth thing can be pushed to solve the problem -of dataflow processing in a simple way, by cutting out the fat. -yes, chuck moore's ideas are viral.. - -a forth process has a setup code that will construct an initial stack template - -an object definition is a list of -- list of symbolic input to stack location mappings (first = active) -- list of symbolic output to stack location mappings -- stack template init code (bootblock) -- process code - -the stack is the machine memory - -the mapping between pdp's forth processors and pd object -is handled by pdmaps. these can probably be reused to build other -object oriented interfaces to the forth processors - -*/ - - -/* pdp forthprocs support thread processing. - - there is only one stack, which - serves as the machine state and input/output storage. - - when processing in thread, the input/output event - queue is used, when processing directly pd events - are inserted into the stack directly and the queues - are bypassed - -*/ - - -#include -#include "pdp_pd.h" -#include "pdp_comm.h" -#include "pdp_packet.h" -#include "pdp_mem.h" -#include "pdp_forth.h" -#include "pdp_pdmap.h" -#include "pdp_queue.h" -#include "pdp_debug.h" - - - -/* this object instantiates a forth processor */ - -typedef struct forthproc_struct -{ - t_object x_obj; - t_pdp_list *x_processor; // the processor definition - t_pdp_list *x_pdmap; // the pd port mappings - t_pdp_list *x_program; // the forth program - - - t_pdp_list *x_stack; // the state stack - t_pdp_list *x_stack_template; // a "fake" stack serving as a type template - - t_pdp_list *x_input_events; // current input event list - - t_pdp_list *x_queue_input; // queue of input event lists, event = (atom index, word) - t_pdp_list *x_queue_output; // queue of output event lists, event = (outlet ptr, word) - - t_pdp_procqueue *x_q; // process queue - - - pthread_mutex_t x_mut; // queue mutex - - int x_nb_outlets; // number of pd outlets - t_outlet **x_outlet; - - int x_thread; // use thread processing or not - - t_symbol *x_protocol; // protocol used (pdp or dpd) - - /* pdp image legacy */ - int x_chanmask; - - /* dpd */ - int x_dpd_packet; - t_outlet *x_dpd_outlet; - -} t_forthproc; - - -static inline void lock(t_forthproc *x){pthread_mutex_lock(&x->x_mut);} -static inline void unlock(t_forthproc *x){pthread_mutex_unlock(&x->x_mut);} - - -/* send an atom to an outlet */ -static void send_pdp_atom_to_outlet(t_outlet *out, t_pdp_atom *a) -{ - outlet_pdp_atom(out, a); -} - -/* output stack contents to outlet or output event list */ -static void output_from_stack(t_forthproc *x) -{ - t_pdp_list *outsym = pdp_forth_pdmap_outlist(x->x_pdmap); - - /* create an event list if we're in thread mode */ - t_pdp_list *eventlist = x->x_thread ? pdp_list_new(0) : 0; - - static void _do_outlet(int index, t_pdp_atom *pname, t_pdp_list *eventlist){ - t_outlet *out = x->x_outlet[index]; - t_pdp_atom *a = pdp_forth_processor_stackatom_from_outputname( - x->x_processor, x->x_stack, pname->w.w_symbol); - - PDP_ASSERT(a); - - /* bang in reverse order by using head recursion */ - if (pname->next) _do_outlet(index+1, pname->next, eventlist); - - /* send the atom to the outlet if no event list */ - if (!eventlist){ - send_pdp_atom_to_outlet(out, a); - } - /* or add it to the event list */ - else { - t_pdp_list *ev = pdp_list_new(2); - pdp_list_set_0(ev, a_pointer, - (t_pdp_word)(void*)out); // store outlet ptr - pdp_list_set_1(ev, a->t, a->w); // store atom - pdp_list_add_back(eventlist, a_list, - (t_pdp_word)ev); // store event in list - - /* if it was a packet, clear the stacks reference */ - if (a->t == a_packet) a->w.w_packet = -1; - } - - } - - _do_outlet(0, outsym->first, eventlist); - - /* add eventlist to output event queue */ - if (eventlist){ - - lock(x); - pdp_list_add_back(x->x_queue_output, a_list, - (t_pdp_word)eventlist); - unlock(x); - } -} - -/* legacy hack: setup channel mask for image processing */ -static void setup_chanmask(t_forthproc *x) -{ - if (x->x_chanmask != -1){ - t_pdp_symbol *pname = pdp_forth_pdmap_get_pname(x->x_pdmap, pdp_gensym("pdp")); - t_pdp_atom *a = pdp_forth_processor_stackatom_from_inputname(x->x_processor, x->x_stack, pname); - int *packet; - if (a && a->t == a_packet){ - packet = &a->w.w_packet; - pdp_packet_replace_with_writable(packet); // make sure it's a private copy - pdp_packet_image_set_chanmask(*packet, x->x_chanmask); - //post("chanmask set to %d", x->x_chanmask); - } - } -} - -static void exec_program(t_forthproc *x) -{ - int error; - setup_chanmask(x); - if (e_ok != (error = pdp_forth_execute_def(x->x_stack, x->x_program))){ - post("error %d (%s) executing forth processor", - error, pdp_forth_word_error(error)); - post("PROGRAM:"); - pdp_list_print(x->x_program); - post("STACK:"); - pdp_list_print(x->x_stack); - post(""); - - /* delete stack and create a new one */ - pdp_tree_strip_packets(x->x_stack); - pdp_tree_free(x->x_stack); - x->x_stack = pdp_forth_processor_setup_stack(x->x_processor); - - - } - - -} - - -static void thread_exec(t_forthproc *x) -{ - t_pdp_list *event_list; - t_pdp_atom *a; - - /* get input event list from input event queue */ - PDP_ASSERT(x->x_queue_input->elements); - lock(x); - event_list = pdp_list_pop(x->x_queue_input).w_list; - unlock(x); - - /* add input events to state stack */ - for (a=event_list->first; a; a=a->next){ - int index = a->w.w_list->first->w.w_int; - t_pdp_atom *src = a->w.w_list->first->next; - - t_pdp_atom *dest = x->x_stack->first; - while (index--) dest = dest->next; - - PDP_ASSERT(dest->t == src->t); - - switch(src->t){ - - /* copy pure atoms */ - case a_float: - case a_int: - case a_symbol: - dest->w = src->w; - break; - - /* move reference atoms */ - case a_packet: - pdp_packet_mark_unused(dest->w.w_packet); - dest->w = src->w; - src->w.w_packet = -1; - break; - - /* ignored */ - case a_pointer: - case a_list: - default: - break; - } - } - - - - /* free event list */ - pdp_tree_free(event_list); - - /* run the process */ - exec_program(x); - - /* send output events to output event queue */ - output_from_stack(x); - -} - -static void thread_output(t_forthproc *x) -{ - t_pdp_list *event_list; - t_pdp_atom *a; - - /* get output event list from output event queue */ - PDP_ASSERT(x->x_queue_output->elements); - lock(x); - event_list = pdp_list_pop(x->x_queue_output).w_list; - unlock(x); - - /* send */ - for (a=event_list->first; a; a=a->next){ - t_outlet *outlet = a->w.w_list->first->w.w_pointer; - t_pdp_atom *outatom = a->w.w_list->first->next; - PDP_ASSERT(outlet); - PDP_ASSERT(outatom); - send_pdp_atom_to_outlet(outlet, outatom); - } - - /* free event list */ - pdp_tree_strip_packets(event_list); - pdp_tree_free(event_list); - -} - -/* handle dpd packet passing */ -static void dpd_output(t_forthproc *x) -{ - //post("checking dpd"); - //post("protocol: %s, outlet: %08x, packet: %d", x->x_protocol->s_name, x->x_dpd_outlet, x->x_dpd_packet); - if ((x->x_protocol != S_DPD) - || (!x->x_dpd_outlet) - || (x->x_dpd_packet == -1)) return; - - /* send the dpd packet to the special (first) outlet */ - //post("sending dpd"); - outlet_dpd(x->x_dpd_outlet, x->x_dpd_packet); - x->x_dpd_packet = -1; - -} - - -/* this method is called after - an active event is received */ - -static void run(t_forthproc *x) -{ - - /* NO THREAD: - no brainer: execute and output in one go */ - - if (!x->x_thread){ - - /* run the word */ - exec_program(x); - - /* output stuff */ - output_from_stack(x); - dpd_output(x); - } - - /* THREAD: - start queueing operations - - this is a bit harder since we need to make a copy of the machine state (stack) - before we send off a command to process it in the queue - - this case is handled separately, because processing without thread is obviously - more efficient regarding memory usage and locality of reference. - - */ - - else { - - t_pdp_list *newstack; - - /* compared to the previous approach, no 'automatic' dropping is applied - for forth processors. the input and output queues are of indefinite length. - - dropping is the responsability of the sender or a special object - that uses the processing queue to synchronize (see 3dp_windowcontext) - - this allows for pipelining. - - a drawback is that feedback is a problem with this approach, - but it already was with the previous one. - - the only exception to the dropping rule is when the procqueue is full - - */ - - - /* make sure process queue is not full */ - if (pdp_procqueue_full(x->x_q)){ - - post("forthproc: WARNING: procqueue is full. dropping input events."); - - /* clear the input event list */ - pdp_tree_strip_packets(x->x_input_events); - pdp_tree_free(x->x_input_events); - x->x_input_events = pdp_list_new(0); - - /* exit */ - return; - } - - /* add collected input events to input event queue, and create - a new empty input event list */ - lock(x); - pdp_list_add_back(x->x_queue_input, a_list, (t_pdp_word)x->x_input_events); - x->x_input_events = pdp_list_new(0); - unlock(x); - - /* queue the process method & callback */ - pdp_procqueue_add(x->x_q, x, thread_exec, thread_output, 0); - - /* how to handle dpd packets? - they both have direct and indirect output - let's try this: the dpd input is always passed on directly. - the other outputs are just like pdp outputs */ - - dpd_output(x); - - } -} - - -static int handle_special_message(t_forthproc *x, t_symbol *s, int argc, t_atom *argv) -{ - /* handle the chanmask message. this is a legacy thingy */ - if (s == S_CHANMASK){ - if ((argc == 1) && (argv->a_type == A_FLOAT)){ - x->x_chanmask = (int)argv->a_w.w_float; - return 1; - } - } - - return 0; -} - - -/* pd message handler: - receives a pd message and stores an event in the input queue - or directly on the stack */ - -static void handle_pd_message(t_forthproc *x, t_symbol *s, int argc, t_atom *argv) -{ - int active = 0; - int index; - int i; - t_pdp_atom ta; - t_pdp_symbol *message_id; - t_pdp_symbol *pname; - - - /* get the param name from the received symbol */ - message_id = pdp_gensym(s->s_name); - pname = pdp_forth_pdmap_get_pname(x->x_pdmap, message_id); - - /* if the parameter name is null, it should be interpreted - as a active */ - if (pname == PDP_SYM_NULL){ - run(x); - return; - } - - - /* get the stack atom index */ - index = pdp_forth_processor_map_inputname_to_stackindex(x->x_processor, pname); - t_pdp_atom *stack_atom; - - if (index < 0){ - /* message is not in the pdmap: check any special messages */ - if (!handle_special_message(x, s, argc, argv)) - post("got invalid msg %s", s->s_name); - return; - } - - /* get stack atom - if thread processing is on, get an atom from the template stack - because the real stack is in an indeterminate state */ - i=index; - stack_atom = x->x_thread ? x->x_stack_template->first : x->x_stack->first; - while (i--) stack_atom = stack_atom->next; - - - /* store the type */ - ta.t = stack_atom->t; - - /* check if it is an active inlet - only floats, symbols, bangs, pdp and dpd messages can be active, - the others will be translated to different selectors */ - - if ((&s_float == s) - ||(&s_bang == s) - ||(&s_symbol == s) - ||(S_PDP == s) - ||(S_DPD == s)) active = 1; - - /* interprete the anything message according to expected type (ta.t) - and put the result in the input event queue w */ - - switch(ta.t){ - - case a_float: - if ((argc != 1) || argv[0].a_type != A_FLOAT) post("bad float msg"); - else ta.w.w_float = argv[0].a_w.w_float; - break; - - case a_int: - if ((argc != 1) || argv[0].a_type != A_FLOAT) post("bad float msg"); - else ta.w.w_int = (int)argv[0].a_w.w_float; - break; - - case a_symbol: - if ((argc != 1) || argv[0].a_type != A_SYMBOL) post("bad symbol msg"); - else ta.w.w_symbol = pdp_gensym(argv[0].a_w.w_symbol->s_name); - - case a_list: - post("a_list: not supported yet"); - break; - - case a_packet: - if ((argc != 2) - || argv[0].a_type != A_SYMBOL - || argv[1].a_type != A_FLOAT) post ("bad pdp msg"); - else{ - t_symbol *command = argv[0].a_w.w_symbol; - int packet = (int)argv[1].a_w.w_float; - - - /* PDP */ - /* register the pd packet readonly by default: stack owns a ro copy. - the forth words should convert a packet to rw if they need to - (we can't tell here) */ - if (command == S_REGISTER_RO){ - ta.w.w_packet = pdp_packet_copy_ro(packet); - } - - /* DPD: does not work when multiple context outlets are involved */ - - /* register readonly just like pdp packets. but for dpd context - processors it's understood that the packet can be modified. - and store the reference to pass it along, if it's an active dpd packet */ - else if (command == S_ACCUMULATE){ - - ta.w.w_packet = pdp_packet_copy_ro(packet); - - if (s == S_DPD){ // only store main (left) inlet's dpd messages - x->x_dpd_packet = ta.w.w_packet; - } - } - - else { - /* if it's not a register_ro (pdp) phase, or an accumulate (dpd) phase, - we're not going to do anything with the paket */ - ta.w.w_packet = -1; - } - - /* only the pdp process message or dpd accumulate message can be active */ - if ((command != S_PROCESS) - && (command != S_ACCUMULATE)) active = 0; - - } - break; - default: - post("unknown"); - return; - - } - - /* check if we need to store the atom into the processor stack - directly or should put it in the input event queue */ - - if (!x->x_thread){ - /* handle packets */ - if (ta.t == a_packet){ - - /* only copy if valid (if it was valid and it's a register_ro phase */ - if (ta.w.w_packet != -1){ - pdp_packet_mark_unused(stack_atom->w.w_packet); - stack_atom->w = ta.w; - } - } - /* handle other atoms: store directly */ - else{ - stack_atom->w = ta.w; - } - } - else { - - /* don't store invalid packets */ - if (!(ta.t == a_packet && ta.w.w_packet == -1)){ - - /* store atom + location in event list */ - t_pdp_list *ev = pdp_list_new(2); - pdp_list_set_0(ev, a_int, (t_pdp_word)index); // store atom location - pdp_list_set_1(ev, ta.t, ta.w); // store atom - pdp_list_add_back(x->x_input_events, a_list, - (t_pdp_word)ev); // store event in list - - } - } - - - /* run the processor if it was an active input */ - if (active) run(x); - - -} - - - -/* OTHER METHODS */ -/* these serve as a replacement for the pdp_base class - the most prominent messages are: - - debug - - chanmask - - thread on/off/default on a per object basis -*/ - - - -/* MEM & INIT */ - -static void forthproc_free(t_forthproc *x) -{ - /* wait for thread processing to finish */ - pdp_procqueue_flush(x->x_q); - - /* free state stack + template stack */ - pdp_tree_strip_packets(x->x_stack); - pdp_tree_free(x->x_stack); - pdp_tree_free(x->x_stack_template); - - - /* free input event list */ - pdp_tree_strip_packets(x->x_input_events); - pdp_tree_free(x->x_input_events); - - /* free input/output event queues */ - pdp_tree_strip_packets(x->x_queue_input); - pdp_tree_strip_packets(x->x_queue_output); - pdp_tree_free(x->x_queue_input); - pdp_tree_free(x->x_queue_output); - - /* delete outlet pointer array */ - if (x->x_outlet) pdp_dealloc(x->x_outlet); -} - -t_class *forthproc_class; - - - -static void *forthproc_new(t_symbol *protocol, int argc, t_atom *argv) -{ - t_forthproc *x; - t_pdp_atom *a; - t_symbol *procname; - int i; - - /* get processor name */ - if ((argc < 1) || (argv[0].a_type != A_SYMBOL)) return 0; - procname = argv[0].a_w.w_symbol; - argc--; - argv++; - - - /* allocate */ - x = (t_forthproc *)pd_new(forthproc_class); - - /* init */ - x->x_stack = 0; - x->x_stack_template = 0; - x->x_outlet = 0; - x->x_pdmap = 0; - x->x_processor = 0; - x->x_thread = 1; - x->x_program = 0; - x->x_chanmask = -1; - x->x_dpd_outlet = 0; - x->x_dpd_packet = -1; - - /* get the protocol */ - x->x_protocol = protocol; - //post("forthproc using protocol: %s", protocol->s_name); - - /* input event list */ - x->x_input_events = pdp_list_new(0); - - /* input/output event queues */ - x->x_queue_input = pdp_list_new(0); - x->x_queue_output = pdp_list_new(0); - - /* default queue is pdp queue */ - x->x_q = pdp_queue_get_queue(); - - - - /* get the pd mapper */ - x->x_pdmap = pdp_forth_pdmap_getbyname(pdp_gensym(procname->s_name)); - if (!x->x_pdmap) goto error; - - /* get the processor */ - x->x_processor = pdp_forth_pdmap_get_processor(x->x_pdmap); - if (!x->x_processor) goto error; - - /* get the program */ - x->x_program = x->x_processor->first->next->next->next->w.w_list; - - /* create state stack template and remove packets - so they don't consume resources */ - x->x_stack_template = pdp_forth_processor_setup_stack(x->x_processor); - pdp_tree_strip_packets(x->x_stack_template); - - /* create the state stack */ - x->x_stack = pdp_forth_processor_setup_stack(x->x_processor); - - - /* create additional inlets from description */ - for (a = pdp_forth_pdmap_inlist(x->x_pdmap)->first; a; a=a->next){ - t_pdp_symbol *message_id = a->w.w_symbol; - t_symbol *dsym = gensym(message_id->s_name); - t_symbol *ssym = 0; - - t_pdp_symbol *pname = pdp_forth_pdmap_get_pname(x->x_pdmap, message_id); - t_pdp_atom *sa = pdp_forth_processor_stackatom_from_inputname(x->x_processor, x->x_stack, pname); - if (sa) { - switch(sa->t){ - case a_float: - case a_int: - ssym = &s_float; break; - case a_packet: - ssym = S_PDP; break; - default: - post("unsupported type on stack"); break; - } - } - - /* add inlet */ - if (ssym){ - //post("adding %s inlet %s (forth processor param %s)", - // ssym->s_name, dsym->s_name, pname->s_name); - inlet_new(&x->x_obj, &x->x_obj.ob_pd, ssym, dsym); - } - else { - post("error adding inlet"); - } - } - - /* create outlets */ - if (x->x_protocol == S_DPD){ - x->x_dpd_outlet = outlet_new(&x->x_obj, &s_anything); - } - - x->x_nb_outlets = pdp_forth_pdmap_outlist(x->x_pdmap)->elements; - if (x->x_nb_outlets){ - x->x_outlet = pdp_alloc(x->x_nb_outlets * sizeof(*x->x_outlet)); - for (i=0; ix_nb_outlets; i++){ - x->x_outlet[i] = outlet_new(&x->x_obj, &s_anything); - } - } - - /* interpret arguments */ - //pdp_list_print(pdp_forth_pdmap_arglist(x->x_pdmap)); - for(a = pdp_forth_pdmap_arglist(x->x_pdmap)->first; - a && argc; - a=a->next, argv++, argc--){ - - t_pdp_atom *sa = pdp_forth_processor_stackatom_from_inputname - (x->x_processor, x->x_stack, a->w.w_symbol); - if (!sa) { - post("parameter %s not found", a->w.w_symbol->s_name); - continue; - } - //post("loading parameter %s", a->w.w_symbol->s_name); - /* handle symbols */ - if((sa->t == a_symbol) && (argv->a_type == A_SYMBOL)) - sa->w.w_symbol = pdp_gensym(argv->a_w.w_symbol->s_name); - /* handle floats */ - else if (argv->a_type == A_FLOAT){ - switch(sa->t){ - case a_float: sa->w.w_float = argv->a_w.w_float; break; - case a_int: sa->w.w_int = (int)argv->a_w.w_float; break; - default: break; - } - } - - } - - - /* finished */ - return (void *)x; - - error: - - post ("error creating forth processor %s", procname->s_name); - forthproc_free(x); - return 0; - -} - - -#ifdef __cplusplus -extern "C" -{ -#endif - - -void pdp_forthproc_setup(void) -{ - int i; - - /* create a standard pd class */ - forthproc_class = class_new(gensym("pdp"), (t_newmethod)forthproc_new, - (t_method)forthproc_free, sizeof(t_forthproc), 0, A_GIMME, A_NULL); - class_addcreator((t_newmethod)forthproc_new, gensym("dpd"), A_GIMME, A_NULL); - - /* add global message handler */ - class_addanything(forthproc_class, (t_method)handle_pd_message); - -} - -#ifdef __cplusplus -} -#endif diff --git a/puredata/pdp_imagebase.c b/puredata/pdp_imagebase.c deleted file mode 100644 index f9634e1..0000000 --- a/puredata/pdp_imagebase.c +++ /dev/null @@ -1,79 +0,0 @@ -/* - * Pure Data Packet image processor base class implementation. - * Copyright (c) by Tom Schouten - * - * This program is free software; you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation; either version 2 of the License, or - * (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program; if not, write to the Free Software - * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. - * - */ - - -/* - - This file contains the pdp image base class object. -*/ - -#include "pdp_imagebase.h" -#include - - -static void pdp_imagebase_chanmask(t_pdp_base *b, t_floatarg f) -{ - int i = (int)f; - if (i < 0) i = -1; - b->b_channel_mask = i; -} - -void pdp_imagebase_setup(t_class *c) -{ - /* parent class setup */ - pdp_base_setup(c); - - /* add pdp base class methods */ - class_addmethod(c, (t_method)pdp_imagebase_chanmask, gensym("chanmask"), A_FLOAT, A_NULL); - -} - -/* pdp base instance constructor */ -void pdp_imagebase_init(void *x) -{ - int i; - t_pdp_imagebase *b = (t_pdp_imagebase *)x; - - /* init super */ - pdp_base_init(x); - - /* convert all active incoming packet types to image */ - pdp_base_set_type_template(x, 0, pdp_gensym("image/*/*")); - - /* default chanmask == all */ - b->b_channel_mask = -1; - -} - -/* base instance destructor */ -void pdp_imagebase_free(void *x) -{ - /* free super */ - pdp_base_free(x); - -} - -/* chanmask getter */ -u32 pdp_imagebase_get_chanmask(void *x) -{ - t_pdp_base *b = (t_pdp_base *)x; - return b->b_channel_mask; -} - diff --git a/puredata/pdp_queue.c b/puredata/pdp_queue.c deleted file mode 100644 index b66289a..0000000 --- a/puredata/pdp_queue.c +++ /dev/null @@ -1,386 +0,0 @@ -/* - * Pure Data Packet - processor queue module. - * Copyright (c) by Tom Schouten - * - * This program is free software; you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation; either version 2 of the License, or - * (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program; if not, write to the Free Software - * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. - * - */ - - - -/* - this is a the processor queue pdp system module - it receives tasks from objects that are schedules to - be computed in another thread. the object is signalled back - when the task is completed, using a polling mechanism - based on a pd clock. - - the queue object can be reused. the pdp system however only - has one instance (one pdp queue. pdp remains a serial program, though - it can run in a separate thread) - - */ - - -#include - -#include "pdp_queue.h" -#include "pdp_mem.h" - - -#define D if (0) - -#ifdef __cplusplus -extern "C" -{ -#endif - -#define PDP_QUEUE_LOGSIZE 10 -#define PDP_QUEUE_DELTIME 10.0f - - -/* there are 3 synchro methods, which can be used i.e. to ensure - all processing is done before shared resources are freed. - - all 3 wait for the processing thread to finish, and - - _wait: leaves callback queue untouched - _finish: clears the queue_id item in the callback queue - _flush: waits for thread and calls callbacks - and loops until callback list is empty - -*/ - - - -/********************* general purpose pd process queue class *********************/ - -void pdp_procqueue_wait(t_pdp_procqueue *q) -{ - D post("pdp_procqueue_wait(%x): waiting for pdp_queue_thread to finish processing", q); - pthread_mutex_lock(&q->mut); - while(((q->curr - q->head) & q->mask) != 0){ - - pthread_cond_wait(&q->cond_processingdone, &q->mut); - } - pthread_mutex_unlock(&q->mut); - D post("pdp_procqueue_wait(%x): pdp_procqueue_thread has finished processing", q); - -} -void pdp_procqueue_finish(t_pdp_procqueue *q, int index) -{ - - if (-1 == index) { - //post("pdp_pq_remove: index == -1"); - return; - } - /* wait for processing thread to finish*/ - 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; - -} - -static void pdp_procqueue_callback (t_pdp_procqueue *q); - -void pdp_procqueue_flush(t_pdp_procqueue *q) -{ - /* wait once */ - pdp_procqueue_wait(q); - - do { - - /* process callbacks and wait again - in case the callbacks introduced new tasks */ - pdp_procqueue_callback(q); - pdp_procqueue_wait(q); - - } - /* repeat if callback list is not empty */ - while ((q->curr - q->head) & q->mask); - - D post("pdp_procqueue_flush: done"); -} - -static void pdp_procqueue_signal_processor(t_pdp_procqueue *q) -{ - - //NOTE: uncommenting these post statements causes a libc crash - //in mutex lock in putc - //D post("pdp_procqueue_signal_processor(%x): signalling process thread", q); - pthread_mutex_lock(&q->mut); - pthread_cond_signal(&q->cond_dataready); - pthread_mutex_unlock(&q->mut); - //D post("pdp_procqueue_signal_processor(%x): signalling done", q); - - -} - -static void pdp_procqueue_wait_for_feeder(t_pdp_procqueue *q) -{ - - - /* only use locking when there is no data */ - if(((q->curr - q->head) & q->mask) == 0){ - - /* signal processing done */ - D post("pdp_procqueue_wait_for_feeder(%x): signalling processing is done", q); - pthread_mutex_lock(&q->mut); - pthread_cond_signal(&q->cond_processingdone); - - /* wait until there is an item in the queue */ - while(((q->curr - q->head) & q->mask) == 0){ - pthread_cond_wait(&q->cond_dataready, &q->mut); - } - - pthread_mutex_unlock(&q->mut); - D post("pdp_procqueue_wait_for_feeder(%x): waiting done", q); - - } -} - - -int pdp_procqueue_full(t_pdp_procqueue *q) -{ - return (1 == ((q->tail - q->head) & q->mask)); -} - - -void pdp_procqueue_add(t_pdp_procqueue *q, void *owner, void *process, void *callback, int *queue_id) -{ - int i; - - /* if processing is in not in thread, just call the funcs */ - if (!q->use_thread){ - D post("pdp_procqueue_add(%q): calling processing routine directly", q); - if (queue_id) *queue_id = -1; - if (process) ((t_pdpmethod) process)(owner); - if (callback) ((t_pdpmethod) callback)(owner); - return; - } - - - /* if queue is full, print an error message and return */ - if (pdp_procqueue_full(q)) { - post("pdp_procqueue_add: WARNING: processing queue (%x) is full.\n", q); - post("pdp_procqueue_add: WARNING: tail %08x, head %08x (%08x), mask %08x.\n", q->tail, q->head, q->head & q->mask, q->mask); - post("pdp_procqueue_add: WARNING: skipping process method, calling callback directly.\n"); - if (queue_id) *queue_id = -1; - if (callback) ((t_pdpmethod) callback)(owner); - return; - //exit(1); - } - - /* schedule method in thread queue */ - i = q->head & q->mask; - q->q[i].x_owner = owner; - q->q[i].x_process = process; - q->q[i].x_callback = callback; - q->q[i].x_queue_id = queue_id; - if (queue_id) *queue_id = i; - //post("pdp_queue_add: added method to queue, index %d", i); - - - // increase the packet count - q->packets++; - - // move head forward - q->head++; - - pdp_procqueue_signal_processor(q); - -} - - -/* processing thread */ -static void *pdp_procqueue_thread(void *vq) -{ - t_pdp_procqueue *q = (t_pdp_procqueue *)vq; - - D post("pdp_procqueue_thread(%x): thread started", q); - - while(1){ - t_process_queue_item *p; - - - D post("pdp_procqueue_thread(%x): waiting for feeder", q); - - /* wait until there is data available */ - pdp_procqueue_wait_for_feeder(q); - - - D post("pdp_procqueue_thread(%x): processing %d", q, q->curr & q->mask); - - - /* call the process routine */ - p = &q->q[q->curr & q->mask]; - if (p->x_process) - (p->x_process)(p->x_owner); - - /* advance */ - q->curr++; - - - } - return 0; -} - - -/* call back all the callbacks */ -static void pdp_procqueue_callback (t_pdp_procqueue *q) -{ - - /* call callbacks for finished packets */ - while(0 != ((q->curr - q->tail) & q->mask)) - { - int i = q->tail & q->mask; - /* invalidate queue id */ - if(q->q[i].x_queue_id) *q->q[i].x_queue_id = -1; - /* call callback */ - if(q->q[i].x_callback) (q->q[i].x_callback)(q->q[i].x_owner); - //else post("pdp_pq_tick: callback %d is disabled",i ); - q->tail++; - } - -} - -/* the clock method */ -static void pdp_procqueue_tick (t_pdp_procqueue *q) -{ - /* do work */ - //if (!(ticks % 1000)) post("pdp tick %d", ticks); - - if (!q->use_thread) return; - - /* call callbacks */ - pdp_procqueue_callback(q); - - /* increase counter */ - q->ticks++; - - /* set clock for next update */ - clock_delay(q->pdp_clock, q->deltime); -} - - - -void pdp_procqueue_use_thread(t_pdp_procqueue* q, int t) -{ - /* if thread usage is being disabled, - wait for thread to finish processing first */ - if (t == 0) { - pdp_procqueue_wait(q); - q->use_thread = 0; - pdp_procqueue_callback(q); - clock_unset(q->pdp_clock); - } - else { - clock_unset(q->pdp_clock); - clock_delay(q->pdp_clock, q->deltime); - q->use_thread = 1; - } - -} - -void pdp_procqueue_init(t_pdp_procqueue *q, double milliseconds, int logsize) -{ - pthread_attr_t attr; - int size = 1 << logsize; - - /* setup pdp queue processor object */ - q->ticks = 0; - q->deltime = milliseconds; - - /* setup queue data */ - q->mask = size - 1; - q->head = 0; - q->tail = 0; - q->curr = 0; - q->q = pdp_alloc(size * sizeof(t_process_queue_item)); - memset(q->q, 0, size * sizeof(t_process_queue_item)); - - /* enable threads */ - q->use_thread = 1; - - /* setup synchro stuff */ - pthread_mutex_init(&q->mut, NULL); - pthread_cond_init(&q->cond_dataready, NULL); - pthread_cond_init(&q->cond_processingdone, NULL); - - - /* allocate the clock */ - q->pdp_clock = clock_new(q, (t_method)pdp_procqueue_tick); - - /* set the clock */ - clock_delay(q->pdp_clock, 0); - - /* start processing thread */ - - /* glibc doc says SCHED_OTHER is default, - but it seems not to be when initiated from a RT thread - so we explicitly set it here */ - pthread_attr_init (&attr); - //pthread_attr_setschedpolicy(&attr, SCHED_FIFO); - pthread_attr_setschedpolicy(&attr, SCHED_OTHER); - - D post("pdp_procqueue_init(%x): starting thread", q); - pthread_create(&q->thread_id, &attr, pdp_procqueue_thread, (void *)q); - D post("pdp_procqueue_init(%x): back in pd thread", q); - - /* wait for processing thread to finish */ - //pdp_procqueue_wait(q); - - /* set default disable/enable thread here */ - //post("pdp_queue: THREAD PROCESSING ON BY DEFAULT!!"); - pdp_procqueue_use_thread(q,0); - -} - - - - -/* the (static) pdp queue object */ -static t_pdp_procqueue pdp_queue; - - -/* get the default queue */ -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_add(void *owner, void *process, void *callback, int *queue_id) { - pdp_procqueue_add(&pdp_queue, owner, process, callback, queue_id); -} -void pdp_queue_use_thread(int t) {pdp_procqueue_use_thread(&pdp_queue, t);} -void pdp_queue_setup(void){ - pdp_procqueue_init(&pdp_queue, PDP_QUEUE_DELTIME, PDP_QUEUE_LOGSIZE); - pdp_procqueue_use_thread(&pdp_queue,0); -} -#endif - - - - - - - -#ifdef __cplusplus -} -#endif diff --git a/puredata/pdp_ut.c b/puredata/pdp_ut.c deleted file mode 100644 index a1369e3..0000000 --- a/puredata/pdp_ut.c +++ /dev/null @@ -1,262 +0,0 @@ -/* - * Pure Data Packet - Utility toolkit objects. - * Copyright (c) by Tom Schouten - * - * This program is free software; you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation; either version 2 of the License, or - * (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program; if not, write to the Free Software - * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. - * - */ - - -/* This file contains some small utility pd objects that make working with - pdp objects a lot easier. Mainly as glue to be used in the abstractions - in the distro. */ - - -#include "pdp_pd.h" -#include - -/* this object does an add, scale, clip operation */ - -t_class *pdp_ut_addscaleclip_class; - -typedef struct pdp_ut_addscaleclip_struct -{ - t_object x_obj; - t_outlet *x_outlet0; - t_float x_min; - t_float x_max; - t_float x_offset; - t_float x_scale; -} t_pdp_ut_addscaleclip; - - -static void pdp_ut_addscaleclip_float(t_pdp_ut_addscaleclip *x, t_floatarg f) -{ - f += x->x_offset; - f *= x->x_scale; - f = (f < x->x_min) ? x->x_min : f; - f = (f > x->x_max) ? x->x_max : f; - outlet_float(x->x_outlet0, f); -} - -static void pdp_ut_addscaleclip_free(t_pdp_ut_addscaleclip *x){} - -void *pdp_ut_addscaleclip_new(t_floatarg offset, t_floatarg scale, t_floatarg min, t_floatarg max) -{ - t_pdp_ut_addscaleclip *x = (t_pdp_ut_addscaleclip *)pd_new(pdp_ut_addscaleclip_class); - x->x_outlet0 = outlet_new(&x->x_obj, &s_float); - x->x_offset = offset; - x->x_scale = scale; - x->x_min = min; - x->x_max = max; - return (void *)x; -} - -void pdp_ut_addscaleclip_setup(void) -{ - pdp_ut_addscaleclip_class = class_new(gensym("pdp_ut_addscaleclip"), (t_newmethod)pdp_ut_addscaleclip_new, - (t_method)pdp_ut_addscaleclip_free, sizeof(t_pdp_ut_addscaleclip), 0, - A_FLOAT, A_FLOAT, A_FLOAT, A_FLOAT, A_NULL); - class_addfloat(pdp_ut_addscaleclip_class, pdp_ut_addscaleclip_float); -} - - -/* pdp_ut_logmap does a logarithmic parameter mapping [0->1] x -> min(max/min)^x max an add, scale, clip operation */ -/* pdp_ut_logmap_comp does x -> min(max/min)^(1-x) */ -/* pdp_ut_linmap dos x -> min + (max - min * x */ - -t_class *pdp_ut_linmap_class; -t_class *pdp_ut_logmap_class; -t_class *pdp_ut_logmap_comp_class; - -typedef struct pdp_ut_map_struct -{ - t_object x_obj; - t_outlet *x_outlet0; - t_float x_min; - t_float x_max; -} t_pdp_ut_map; - - -static void pdp_ut_logmap_float(t_pdp_ut_map *x, t_floatarg f) -{ - f = (f < 0.0f) ? 0.0f : f; - f = (f > 1.0f) ? 1.0f : f; - - f = x->x_min * pow((x->x_max / x->x_min), f); - - outlet_float(x->x_outlet0, f); -} - -static void pdp_ut_linmap_float(t_pdp_ut_map *x, t_floatarg f) -{ - f = (f < 0.0f) ? 0.0f : f; - f = (f > 1.0f) ? 1.0f : f; - - f = x->x_min + ((x->x_max - x->x_min) * f); - - outlet_float(x->x_outlet0, f); -} - -static void pdp_ut_logmap_comp_float(t_pdp_ut_map *x, t_floatarg f) -{ - f = (f < 0.0f) ? 0.0f : f; - f = (f > 1.0f) ? 1.0f : f; - - f = x->x_min * pow((x->x_max / x->x_min), (1.0f - f)); - - outlet_float(x->x_outlet0, f); -} - -static void pdp_ut_map_free(t_pdp_ut_map *x){} - - -void pdp_ut_map_init(t_pdp_ut_map *x, t_floatarg min, t_floatarg max) -{ - x->x_outlet0 = outlet_new(&x->x_obj, &s_float); - x->x_min = min; - x->x_max = max; -} - -void *pdp_ut_logmap_new(t_floatarg min, t_floatarg max) -{ - t_pdp_ut_map *x = (t_pdp_ut_map *)pd_new(pdp_ut_logmap_class); - pdp_ut_map_init(x, min, max); - return (void *)x; -} - -void *pdp_ut_linmap_new(t_floatarg min, t_floatarg max) -{ - t_pdp_ut_map *x = (t_pdp_ut_map *)pd_new(pdp_ut_linmap_class); - pdp_ut_map_init(x, min, max); - return (void *)x; -} - -void *pdp_ut_logmap_comp_new(t_floatarg min, t_floatarg max) -{ - t_pdp_ut_map *x = (t_pdp_ut_map *)pd_new(pdp_ut_logmap_comp_class); - pdp_ut_map_init(x, min, max); - return (void *)x; -} - -void pdp_ut_logmap_setup(void) -{ - pdp_ut_logmap_class = class_new(gensym("pdp_ut_logmap"), (t_newmethod)pdp_ut_logmap_new, - (t_method)pdp_ut_map_free, sizeof(t_pdp_ut_map), 0, - A_FLOAT, A_FLOAT, A_NULL); - class_addfloat(pdp_ut_logmap_class, pdp_ut_logmap_float); -} - -void pdp_ut_logmap_comp_setup(void) -{ - pdp_ut_logmap_comp_class = class_new(gensym("pdp_ut_logmap_comp"), (t_newmethod)pdp_ut_logmap_comp_new, - (t_method)pdp_ut_map_free, sizeof(t_pdp_ut_map), 0, - A_FLOAT, A_FLOAT, A_NULL); - class_addfloat(pdp_ut_logmap_comp_class, pdp_ut_logmap_comp_float); -} - -void pdp_ut_linmap_setup(void) -{ - pdp_ut_linmap_class = class_new(gensym("pdp_ut_linmap"), (t_newmethod)pdp_ut_linmap_new, - (t_method)pdp_ut_map_free, sizeof(t_pdp_ut_map), 0, - A_FLOAT, A_FLOAT, A_NULL); - class_addfloat(pdp_ut_linmap_class, pdp_ut_linmap_float); -} - - - -t_class *pdp_ut_rgb2ycrcb_class; - -typedef struct pdp_ut_rgb2ycrcb -{ - t_object x_obj; - t_outlet *x_outlet_luma; - t_outlet *x_outlet_chroma_red; - t_outlet *x_outlet_chroma_blue; - - t_float x_red, x_green, x_blue; - -} t_pdp_ut_rgb2ycrcb; - - -static void pdp_ut_rgb2ycrcb_bang (t_pdp_ut_rgb2ycrcb* x) -{ - - float luma = 0.299f * x->x_red + 0.587f * x->x_green + 0.114f * x->x_blue; - float chroma_red = (x->x_red - luma) * 0.713f; - float chroma_blue = (x->x_blue - luma) * 0.565f; - - outlet_float(x->x_outlet_chroma_blue, chroma_blue); - outlet_float(x->x_outlet_chroma_red, chroma_red); - outlet_float(x->x_outlet_luma, luma); - -} - - -static void pdp_ut_rgb2ycrcb_red (t_pdp_ut_rgb2ycrcb* x, t_floatarg f) {x->x_red = f; pdp_ut_rgb2ycrcb_bang(x);} -static void pdp_ut_rgb2ycrcb_green (t_pdp_ut_rgb2ycrcb* x, t_floatarg f) {x->x_green = f; pdp_ut_rgb2ycrcb_bang(x);} -static void pdp_ut_rgb2ycrcb_blue (t_pdp_ut_rgb2ycrcb* x, t_floatarg f) {x->x_blue = f; pdp_ut_rgb2ycrcb_bang(x);} - - - -static void pdp_ut_rgb2ycrcb_free (t_pdp_ut_rgb2ycrcb* x) {} -static void* pdp_ut_rgb2ycrcb_new(void) -{ - t_pdp_ut_rgb2ycrcb *x = (t_pdp_ut_rgb2ycrcb *)pd_new(pdp_ut_rgb2ycrcb_class); - - - inlet_new(&x->x_obj, &x->x_obj.ob_pd, gensym("float"), gensym("green")); - inlet_new(&x->x_obj, &x->x_obj.ob_pd, gensym("float"), gensym("blue")); - - x->x_outlet_luma = outlet_new(&x->x_obj, &s_float); - x->x_outlet_chroma_red = outlet_new(&x->x_obj, &s_float); - x->x_outlet_chroma_blue = outlet_new(&x->x_obj, &s_float); - - x->x_red = 0.0f; - x->x_green = 0.0f; - x->x_blue = 0.0f; - - - return (void *)x; -} - -void pdp_ut_rgb2ycrcb_setup(void) -{ - pdp_ut_rgb2ycrcb_class = class_new(gensym("pdp_ut_rgb2ycrcb"), (t_newmethod)pdp_ut_rgb2ycrcb_new, - (t_method)pdp_ut_rgb2ycrcb_free, sizeof(t_pdp_ut_rgb2ycrcb), 0, A_NULL); - class_addfloat(pdp_ut_rgb2ycrcb_class, pdp_ut_rgb2ycrcb_red); - class_addmethod(pdp_ut_rgb2ycrcb_class, (t_method)pdp_ut_rgb2ycrcb_green, gensym("green"), A_FLOAT, A_NULL); - class_addmethod(pdp_ut_rgb2ycrcb_class, (t_method)pdp_ut_rgb2ycrcb_blue, gensym("blue"), A_FLOAT, A_NULL); -} - - -#ifdef __cplusplus -extern "C" -{ -#endif - -void pdp_ut_setup(void) -{ - pdp_ut_addscaleclip_setup(); - pdp_ut_logmap_setup(); - pdp_ut_logmap_comp_setup(); - pdp_ut_linmap_setup(); - pdp_ut_rgb2ycrcb_setup(); -} - - -#ifdef __cplusplus -} -#endif diff --git a/system/net/Makefile b/system/net/Makefile deleted file mode 100644 index 53d1d61..0000000 --- a/system/net/Makefile +++ /dev/null @@ -1,11 +0,0 @@ - -OBJECTS = pdp_net.o - - -include ../../Makefile.config - -all: $(OBJECTS) - -clean: - rm -f *~ - rm -f *.o diff --git a/system/net/pdp_net.c b/system/net/pdp_net.c deleted file mode 100644 index 04c97d6..0000000 --- a/system/net/pdp_net.c +++ /dev/null @@ -1,685 +0,0 @@ - -#include "pdp_net.h" -#include "pdp_debug.h" -#include "pdp_post.h" -#include "pdp_mem.h" - -#define D if (0) // DEBUG MSG -#define DD if (0) // DROP DEBUG MSG - -/* shared internals */ - -static int _is_udp_header(t_pdp_udp_header *header, unsigned int size) -{ - if (size < sizeof(t_pdp_udp_header)) return 0; - if (strcmp(header->signature, "PDP")) return 0; - if (PDP_UDP_VERSION != header->version) return 0; - return 1; -} - -static void _make_udp_header(t_pdp_udp_header *header) -{ - strcpy(header->signature, "PDP"); - header->version = PDP_UDP_VERSION; -} - - - - -/* R E C E I V E R */ - - -/* INTERNALS */ - -static void _send_packet(t_pdp_udp_receiver *x) -{ - _make_udp_header(&x->x_resend_header); - PDP_ASSERT(x->x_resend_udp_packet_size <= sizeof(t_pdp_udp_header) + sizeof(x->x_resend_chunks)); - - /* send the packet */ - if (-1 == sendto (x->x_socket, &x->x_resend_header, x->x_resend_udp_packet_size, 0, - (struct sockaddr *)&x->x_source_socket, x->x_sslen)){ - pdp_post("pdp_netreceive: send failed"); - } -} - -static void _send_ack_new(t_pdp_udp_receiver *x) -{ - /* setup resend header */ - x->x_resend_header.connection_id = x->x_connection_id; - x->x_resend_header.sequence_number = PDP_UDP_ACKNEW; - x->x_resend_udp_packet_size = sizeof(t_pdp_udp_header); - - _send_packet(x); - -} - - -static int _handle_PDP_UDP_NEW(t_pdp_udp_receiver *x) -{ - /* we've got a PDP_UDP_NEW packet, so prepare to receive the data */ - t_pdp_udp_newpacket *np = (t_pdp_udp_newpacket *)x->x_buf; - - - //pdp_post("conn_id = %x", x->x_header.connection_id); - //pdp_post("size = %d", np->data_size); - //pdp_post("nb_chunks = %d", np->nb_chunks); - //pdp_post("chunk_size = %d", np->chunk_size); - //pdp_post("type = %s", np->type); - - /* check if it is a resend of the PDP_UDP_NEW packet (if NEW_ACK didn't get through) - if not, prepare for reception */ - - if (x->x_connection_id != x->x_header.connection_id){ - - - /* prepare for reception : TODO add some more checks here */ - - // setup type info - if (x->x_data_type) pdp_dealloc (x->x_data_type); - x->x_data_type = pdp_alloc(1 + strlen(np->type)); - strcpy(x->x_data_type, np->type); - - // setup data buffer - x->x_data_size = np->data_size; - if (x->x_data) pdp_dealloc (x->x_data); - x->x_data = pdp_alloc(x->x_data_size); - memset(x->x_data, 0, x->x_data_size); // clear for debug - - // setup connection info - x->x_connection_id = x->x_header.connection_id; - x->x_nb_chunks = np->nb_chunks; - x->x_chunk_size = np->chunk_size; - - /* setup chunk list */ - if (x->x_chunk_list) pdp_dealloc(x->x_chunk_list); - x->x_chunk_list = pdp_alloc(sizeof(unsigned int)*x->x_nb_chunks); - memset(x->x_chunk_list, 0, sizeof(unsigned int)*x->x_nb_chunks); - - x->x_receive_finished = 0; // we're in a receiving state - x->x_packet_transferred = 0; // we didn't pass the packet yet - } - - /* send ACK */ - _send_ack_new(x); - - - - return 1; -} - -static void _handle_PDP_UDP_DONE(t_pdp_udp_receiver *x) -{ - unsigned int chunk; - unsigned int missing; - unsigned int i; - unsigned int resend_packet_size; - - - /* check the connection id */ - if (x->x_connection_id != x->x_header.connection_id) return; - - /* determine how many packets are missing */ - missing = 0; - for (i=0; ix_nb_chunks; i++) - if (!x->x_chunk_list[i]) missing++; - - D pdp_post ("last packet %x had %d/%d dropped chunks", x->x_connection_id, missing, x->x_nb_chunks); - - - /* build the resend request (chunk list )*/ - if (missing > RESEND_MAX_CHUNKS) missing = RESEND_MAX_CHUNKS; - chunk = 0; - i = missing; - while(i--){ - while (x->x_chunk_list[chunk]) chunk++; // find next missing chunk - x->x_resend_chunks[i] = chunk++; // store it in list - } - - /* set the packet size to include the list */ - x->x_resend_udp_packet_size = sizeof(t_pdp_udp_header) - + missing * sizeof(unsigned int); - - /* setup resend header */ - strcpy((char *)&x->x_resend_header, "PDP"); - x->x_resend_header.version = PDP_UDP_VERSION; - x->x_resend_header.connection_id = x->x_connection_id; - x->x_resend_header.sequence_number = PDP_UDP_RESEND; - - D pdp_post("pdp_netreceive: sending RESEND response for %u chunks", missing); - - /* send out */ - _send_packet(x); - - /* indicate we're done if there's no chunks missing */ - if (!missing) x->x_receive_finished = 1; - -} - - -static int _handle_UDP_DATA(t_pdp_udp_receiver *x) -{ - unsigned int seq = x->x_header.sequence_number; - unsigned int offset = x->x_chunk_size * seq; - - /* ignore the packet if we're not expecting it */ - if ((!x->x_connection_id) || (x->x_connection_id != x->x_header.connection_id)){ - //pdp_post("pdp_netreceive: got invalid data packet: transmission id %x is not part of current transmisson %x", - // x->x_header.connection_id, x->x_connection_id); - return 0; - } - - /* check if it is valid */ - if (seq >= x->x_nb_chunks){ - pdp_post("pdp_netreceive: got invalid data packet: sequence number %u out of bound (nb_chunks=%u)", - seq, x->x_nb_chunks); - return 0; - } - - /* final check */ - PDP_ASSERT(offset + x->x_buf_size <= x->x_data_size); - - /* write & log it */ - memcpy(x->x_data + offset, x->x_buf, x->x_buf_size); - x->x_chunk_list[seq] = 1; - return 1; - -} - -/* INTERFACE */ - -/* setup */ -t_pdp_udp_receiver *pdp_udp_receiver_new(int port) -{ - t_pdp_udp_receiver *x = pdp_alloc(sizeof(*x)); - memset(x, 0, sizeof(*x)); - - /* init */ - x->x_data = 0; - x->x_data_type = 0; - x->x_data_size = 0; - x->x_chunk_list = 0; - x->x_receive_finished = 0; - x->x_packet_transferred = 0; - x->x_zero_terminator = 0; - - x->x_socket = socket(PF_INET, SOCK_DGRAM, 0); - x->x_connection_id = 0; /* zero for bootstrap (0 == an invalid id) */ - x->x_sslen = sizeof(struct sockaddr_in); - - /* bind socket */ - x->x_sa.sin_port = htons(port); - x->x_sa.sin_addr.s_addr = 0; - if (-1 != bind (x->x_socket, (struct sockaddr *)&x->x_sa, - sizeof(struct sockaddr_in))) return x; - - /* suicide if find failed */ - else { - pdp_dealloc(x); - return 0; - } -} -void pdp_udp_receiver_free(t_pdp_udp_receiver *x) -{ - if (!x) return; - if (x->x_socket != 1) close (x->x_socket); - if (x->x_data) pdp_dealloc(x->x_data); - if (x->x_data_type) pdp_dealloc (x->x_data_type); - if (x->x_chunk_list) pdp_dealloc (x->x_chunk_list); -} - -void pdp_udp_receiver_reset(t_pdp_udp_receiver *x) -{ - x->x_connection_id = 0; -} - - -/* receive loop, returns 1 on success, -1 on error, 0 on timeout */ -int pdp_udp_receiver_receive(t_pdp_udp_receiver *x, unsigned int timeout_ms) -{ - /* listen for packets */ - - unsigned int size; - struct timeval tv = {0,1000 * timeout_ms}; - fd_set inset; - FD_ZERO(&inset); - FD_SET(x->x_socket, &inset); - switch(select (x->x_socket+1, &inset, NULL, NULL, &tv)){ - case -1: - return -1; /* select error */ - case 0: - return 0; /* select time out */ - default: - break; /* data ready */ - } - - /* this won't block, since there's data available */ - if (-1 == (int)(size = recvfrom(x->x_socket, (void *)&x->x_header, - PDP_UDP_BUFSIZE+sizeof(x->x_header), 0, - (struct sockaddr *)&x->x_source_socket, &x->x_sslen))) return -1; - - /* store the data size of the packet */ - x->x_buf_size = size - sizeof(t_pdp_udp_header); - - /* parse the udp packet */ - if (_is_udp_header(&x->x_header, size)){ - - /* it is a control packet */ - if ((int)x->x_header.sequence_number < 0){ - - switch (x->x_header.sequence_number){ - case PDP_UDP_NEW: - _handle_PDP_UDP_NEW(x); - break; - - case PDP_UDP_DONE: - _handle_PDP_UDP_DONE(x); - - /* check if we got a complete packet - and signal arrival if we haven't done this already */ - if (x->x_receive_finished && !x->x_packet_transferred){ - x->x_packet_transferred = 1; - return 1; // data complete, please receive - } - break; - - default: - pdp_post("got unknown msg"); - break; - } - } - - /* it is a data packet */ - else { - _handle_UDP_DATA(x); - } - - - } - - else { - pdp_post("pdp_netreceive: got invalid UDP packet (size = %d)", size); - } - - return 0; //no major event, please poll again - -} - -/* get meta & data */ -char *pdp_udp_receiver_type(t_pdp_udp_receiver *x){return x->x_data_type;} -unsigned int pdp_udp_receiver_size(t_pdp_udp_receiver *x){return x->x_data_size;} -void *pdp_udp_receiver_data(t_pdp_udp_receiver *x){return x->x_data;} - - -/* S E N D E R */ - -/* INTERNALS */ - -static void _sleep(t_pdp_udp_sender *x) -{ - int sleep_period = x->x_sleep_period; - - if (sleep_period) { - if (!x->x_sleep_count++) usleep(x->x_sleepgrain_us); - x->x_sleep_count %= sleep_period; - } -} - -static void _send(t_pdp_udp_sender *x) -{ - //post("sending %u data bytes", x->x_buf_size); - - _make_udp_header(&x->x_header); - - PDP_ASSERT (x->x_buf_size <= PDP_UDP_BUFSIZE); - - if (-1 == sendto (x->x_socket, &x->x_header, x->x_buf_size + sizeof(t_pdp_udp_header), - 0, (struct sockaddr *)&x->x_sa, sizeof(struct sockaddr_in))) - pdp_post("pdp_netsend: send FAILED"); - - _sleep(x); - -} - - -static void _prepare_for_new_transmission(t_pdp_udp_sender *x, char *type, unsigned int size, void *data) -{ - unsigned int i; - - /* setup data for transmission */ - x->x_data_type = type; - x->x_data_size = size; - x->x_data = data; - x->x_chunk_size = x->x_udp_payload_size; - x->x_nb_chunks = (x->x_data_size - 1) / x->x_chunk_size + 1; - - /* generate a connection id (non-zero) */ - while (!(x->x_connection_id = rand())); - - /* setup chunk list to contain all chunks */ - if (x->x_chunk_list) free (x->x_chunk_list); - x->x_chunk_list_size = x->x_nb_chunks; - x->x_chunk_list = malloc(sizeof(unsigned int)*x->x_chunk_list_size); - for (i=0; ix_chunk_list_size; i++) x->x_chunk_list[i] = i; - -} - -static void _send_header_packet(t_pdp_udp_sender *x) -{ - t_pdp_udp_newpacket *np = (t_pdp_udp_newpacket *)x->x_buf; /* buf contains the PDP_UDP_NEW body */ - - /* init packet */ - x->x_header.sequence_number = PDP_UDP_NEW; - x->x_header.connection_id = x->x_connection_id; - np->data_size = x->x_data_size; - np->nb_chunks = x->x_nb_chunks; - np->chunk_size = x->x_chunk_size; - strcpy(np->type, x->x_data_type); - x->x_buf_size = sizeof(*np) + strlen(np->type) + 1; - PDP_ASSERT(x->x_buf_size <= PDP_UDP_BUFSIZE); - - /* send the packet */ - _send(x); -} - -/* saend the chunks in the chunk list */ -static void _send_chunks(t_pdp_udp_sender *x){ - unsigned int i; - unsigned int count = 0; - - /* send chunks: this requires header is setup ok (sig,ver,connid)*/ - for (i=0; ix_chunk_list_size; i++){ - unsigned int offset; - unsigned int current_chunk_size; - unsigned int seq = x->x_chunk_list[i]; - - PDP_ASSERT(seq < x->x_nb_chunks); - x->x_header.sequence_number = seq; // store chunk number - - /* get current chunk offset */ - offset = seq * x->x_chunk_size; - PDP_ASSERT(offset < x->x_data_size); - - - /* get current chunk size */ - current_chunk_size = (offset + x->x_chunk_size > x->x_data_size) ? - (x->x_data_size - offset) : x->x_chunk_size; - x->x_buf_size = current_chunk_size; - PDP_ASSERT(x->x_buf_size <= PDP_UDP_BUFSIZE); - - /* copy chunk to transmission buffer & send */ - PDP_ASSERT(offset + current_chunk_size <= x->x_data_size); - memcpy(x->x_buf, x->x_data + offset, current_chunk_size); - - - /* send the chunk */ - _send(x); - count++; - - } - D pdp_post("sent %d chunks, id=%x", count,x->x_connection_id); -} - -/* send a DONE packet */ -static void _send_done(t_pdp_udp_sender *x){ - x->x_header.sequence_number = PDP_UDP_DONE; - x->x_buf_size = 0; - _send(x); -} -static int _receive_packet(t_pdp_udp_sender *x, int desired_type) -/* 0 == timeout, -1 == error, 1 == got packet */ -{ - unsigned int size; - int type; - - struct timeval tv; - fd_set inset; - int sr; - - - while (1){ - int retval; - - /* wait for incoming */ - tv.tv_sec = 0; - tv.tv_usec = x->x_timeout_us; - FD_ZERO(&inset); - FD_SET(x->x_socket, &inset); - switch (select (x->x_socket+1, &inset, NULL, NULL, &tv)){ - case -1: - return -1; /* select error */ - case 0: - return 0; /* select time out */ - default: - break; /* data ready */ - } - - /* read packet */ - if (-1 == (int)(size = recv(x->x_socket, (void *)&x->x_resend_header, MAX_UDP_PACKET, 0))){ - pdp_post("pdp_netsend: error while reading from socket"); - return -1; - } - - /* check if it is a valid PDP_UDP packet */ - if (!_is_udp_header(&x->x_resend_header, size)){ - pdp_post("pdp_netsend: ignoring invalid UDP packet (size = %u)", size); - continue; - } - - - /* check connection id */ - if (x->x_connection_id != x->x_resend_header.connection_id){ - D pdp_post("pdp_netsend: ignoring ghost packet id=%x, current id=%x", - x->x_resend_header.connection_id, x->x_connection_id); - continue; - } - - /* check type */ - type = x->x_resend_header.sequence_number; - if (type != desired_type) continue; - - - /* setup data buffer for known packets */ - switch(type){ - case PDP_UDP_RESEND: - x->x_resend_items = (size - sizeof(t_pdp_udp_header)) / sizeof(unsigned int); - break; - default: - break; - } - - return 1; - } - -} - -/* get the resend list */ -static int _need_resend(t_pdp_udp_sender *x) { - - int retries = 3; - int retval; - while (retries--){ - - /* send a DONE msg */ - _send_done(x); - - /* wait for ACK */ - switch(_receive_packet(x, PDP_UDP_RESEND)){ - case 0: - /* timeout, retry */ - continue; - case -1: - /* error */ - goto move_on; - - default: - /* got PDP_UDP_RESEND packet: setup resend list */ - if (x->x_resend_items > x->x_nb_chunks){ - pdp_post("pdp_netsend: WARNING: chunk list size (%d) is too big, ignoring RESEND request", - x->x_resend_items); - x->x_resend_items = 0; - continue; - } - x->x_chunk_list_size = x->x_resend_items; - - memcpy(x->x_chunk_list, x->x_resend_chunks, sizeof(unsigned int) * x->x_resend_items); - D pdp_post("got RESEND request for %d chunks (id %x)", x->x_resend_items,x->x_connection_id); - - return x->x_chunk_list_size > 0; - } - - } - - /* timeout */ - move_on: - x->x_chunk_list_size = 0; - return 0; - - -} - - -/* INTERFACE */ - - -/* some flow control hacks */ - -void pdp_udp_sender_timeout_us(t_pdp_udp_sender *x, unsigned int timeout_us) -{ - x->x_timeout_us = timeout_us; -} - - -void pdp_udp_sender_sleepgrain_us(t_pdp_udp_sender *x, unsigned int sleepgrain_us) -{ - x->x_sleepgrain_us = sleepgrain_us; -} - -void pdp_udp_sender_sleepperiod(t_pdp_udp_sender *x, unsigned int sleepperiod) -{ - x->x_sleep_period = sleepperiod; -} - - -void pdp_udp_sender_udp_packet_size(t_pdp_udp_sender *x, unsigned int udp_packet_size) -{ - int i = (int)udp_packet_size - sizeof(t_pdp_udp_header); - if (i < 1024) i = 1024; - if (i > PDP_UDP_BUFSIZE) i = PDP_UDP_BUFSIZE; - x->x_udp_payload_size = i; -} - -void pdp_udp_sender_connect(t_pdp_udp_sender *x, char *host, unsigned int port) -{ - struct hostent *hp; - - hp = gethostbyname(host); - if (!hp){ - pdp_post("pdp_udp_sender: host %s not found", host); - } - else{ - /* host ok, setup address */ - x->x_sa.sin_family = AF_INET; - x->x_sa.sin_port = htons(port); - memcpy((char *)&x->x_sa.sin_addr, (char *)hp->h_addr, hp->h_length); - - /* create the a socket if necessary */ - if (x->x_socket == -1){ - if (-1 == (x->x_socket = socket(PF_INET, SOCK_DGRAM, 0))){ - pdp_post("pdp_udp_sender: can't create socket"); - } - if (1){ - int on = 1; - if (setsockopt(x->x_socket,SOL_SOCKET,SO_BROADCAST,(char *)&on,sizeof(on))<0) - pdp_post("pdp_udp_sender: can't set broadcast flag"); - } - } - } -} - -/* setup */ -t_pdp_udp_sender *pdp_udp_sender_new(void) -{ - t_pdp_udp_sender *x = pdp_alloc(sizeof(*x)); - memset(x,0,sizeof(*x)); - - x->x_chunk_list = 0; - - /* no connection */ - x->x_socket = -1; - - - /* set flow control */ - pdp_udp_sender_timeout_us(x, 50000); - x->x_sleep_count = 0; - pdp_udp_sender_sleepgrain_us(x, 0); - pdp_udp_sender_sleepperiod(x, 50); - pdp_udp_sender_udp_packet_size(x, 1472); //optimal udp packet size (ip: 1500 = 28 + 1472) - - - return x; -} - -void pdp_udp_sender_free(t_pdp_udp_sender *x) -{ - int i; - void* retval; - if (x->x_socket != -1) close(x->x_socket); - if (x->x_chunk_list) free (x->x_chunk_list); -} - -/* send, returns 1 on success, 0 on error */ -int pdp_udp_sender_send(t_pdp_udp_sender *x, char* type, unsigned int size, void *data) -{ - - /* SEND A PACKET */ - - /* get the type and data from caller */ - /* send header packet and make sure it has arrived */ - /* send a chunk burst */ - /* send done packet and get the resend list */ - /* repeat until send list is empty */ - - - int hs_retry = 5; // retry count for initial handshake - int rs_retry = 5; // retry count for resends - - /* check if we have a target */ - if (-1 == x->x_socket) goto transerror; - - /* setup internal state */ - _prepare_for_new_transmission(x,type,size,data); - - /* handshake a new transmission */ - do { - if (!(hs_retry--)) break; - // pdp_post("handshake retry %d for packet %x", hscount, x->x_connection_id); - _send_header_packet(x); - } while (!_receive_packet(x, PDP_UDP_ACKNEW)); - - - /* exit if no handshake was possible */ - if (hs_retry < 0){ - DD pdp_post("pdp_netsend: DROP: receiver does not accept new transmission"); - goto transerror; - } - - /* transmission loop */ - do { - if (!(rs_retry--)) break; - _send_chunks(x); - } while (_need_resend(x)); - - /* exit if transmission was not successful */ - if (rs_retry < 0){ - DD pdp_post("pdp_netsend: DROP: receiver did not confirm reception"); - goto transerror; - } - - /* send successful */ - return 1; - - transerror: - /* transmission error */ - return 0; -} -- cgit v1.2.1