You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
300 lines
9.5 KiB
Plaintext
300 lines
9.5 KiB
Plaintext
#N canvas 361 252 878 523 10;
|
|
#X declare -stdpath extra/mrpeach;
|
|
#X declare -stdpath extra/mrpeach;
|
|
#X declare -lib moocow;
|
|
#X declare -stdpath extra/mrpeach;
|
|
#X declare -lib moocow;
|
|
#X msg 471 74 print;
|
|
#X text 521 75 list of connections;
|
|
#X text 627 103 send to all clients;
|
|
#X text 629 132 send to client 1;
|
|
#X text 615 155 send to client on socket 504;
|
|
#X text 613 28 'send' prefix is optional;
|
|
#X text 474 48 (the first number is socket number);
|
|
#X msg 556 257 disconnectsocket \$1;
|
|
#X msg 484 284 disconnectclient \$1;
|
|
#X floatatom 506 215 5 0 0 0 - - -;
|
|
#X obj 484 235 f;
|
|
#X obj 484 216 bng 15 250 50 0 empty empty empty 17 7 0 10 -258699
|
|
-241291 -1;
|
|
#X floatatom 578 216 5 0 0 0 - - -;
|
|
#X obj 556 235 f;
|
|
#X obj 556 216 bng 15 250 50 0 empty empty empty 17 7 0 10 -258699
|
|
-241291 -1;
|
|
#X text 483 197 disconnect by socket or client number;
|
|
#X obj 618 335 unpack 0 0 0 0;
|
|
#X floatatom 618 355 3 0 0 0 - - -;
|
|
#X floatatom 649 355 3 0 0 0 - - -;
|
|
#X floatatom 681 356 3 0 0 0 - - -;
|
|
#X floatatom 715 356 3 0 0 0 - - -;
|
|
#X text 616 372 IP;
|
|
#X floatatom 569 355 5 0 0 0 - - -;
|
|
#X text 566 371 socket;
|
|
#X floatatom 520 376 5 0 0 0 - - -;
|
|
#X text 520 391 number of connections;
|
|
#X obj 471 433 spigot;
|
|
#X obj 510 413 tgl 15 0 empty empty enable_print 17 7 0 10 -24198 -258699
|
|
-258699 0 1;
|
|
#X text 15 37 [tcpsocketserver <protocol> <port>];
|
|
#X obj 469 311 cnv 15 185 22 empty empty empty 20 12 0 14 -204786 -66577
|
|
0;
|
|
#X obj 471 314 tcpsocketserver FUDI 2468;
|
|
#X text 15 115 [tcpsocketserver] is able to handle multiple sockets
|
|
of a packet oriented protocol correctly \, unlike [tcpserver] \, which
|
|
might mix up packets from different sockets.;
|
|
#X text 24 308 - OSC;
|
|
#X text 16 245 each protocol requires its own specific socket handler
|
|
abstraction \, which should be named [tcpsocket.PROTOCOL]. currently
|
|
available are the protocols:;
|
|
#X text 23 293 - FUDI;
|
|
#N canvas 702 157 472 356 EXTENDABILITY 0;
|
|
#X text 3 39 Support for more protocols can easily be added. In order
|
|
to do so:;
|
|
#X text 5 10 EXTENDABILITY;
|
|
#X text 6 105 - open tcpsocket.NEWPROTOCOL.pd;
|
|
#X text 7 127 - edit the green-marked subpatch;
|
|
#X text 10 208 - save it;
|
|
#X text 12 227 - in order to use it \, instantiate:;
|
|
#X text 46 247 [tcpsocketserver NEWPROTOCOL <port>];
|
|
#X text 8 148 - replace code with code \, that creates proper packets
|
|
out of the incoming stream for the desired protocol. don't forget to
|
|
implement a reset mechanism \, in case a socket is closed in the middle
|
|
of packet transmission.;
|
|
#X text 5 83 - copy tcpsocket.FUDI.pd to tcpsocket.NEWPROTOCOL.pd;
|
|
#X restore 21 387 pd EXTENDABILITY;
|
|
#X text 17 453 Author: Roman Haefeli;
|
|
#X text 16 468 Version: 2009-01-11;
|
|
#X text 15 65 [tcpsocketserver] is meant to be a protocol-aware drop-in
|
|
replacement for [tcpserver]. it uses same the same inlet and outlet
|
|
configuration as [tcpserver].;
|
|
#X text 469 478 only well-formed FUDI messages are received here.;
|
|
#N canvas 463 454 147 274 EXAMPLES 0;
|
|
#N canvas 705 77 571 769 FUDI 0;
|
|
#X obj 8 52 cnv 15 550 240 empty empty client_1 20 12 0 14 -249661
|
|
-66577 0;
|
|
#X obj 24 206 tcpclient;
|
|
#X msg 368 107 connect localhost 11001;
|
|
#X msg 392 128 disconnect;
|
|
#X obj 368 85 sel 1 0;
|
|
#X obj 368 64 tgl 15 0 empty empty empty 17 7 0 10 -261234 -1 -1 0
|
|
1;
|
|
#X obj 24 272 print CLIENT_1;
|
|
#X msg 24 83 one two;
|
|
#X obj 24 104 any2string 0 -1;
|
|
#X msg 68 164 59 10;
|
|
#X msg 32 130 32 116 104 114 101 101 23;
|
|
#X obj 8 299 cnv 15 550 150 empty empty client_2 20 12 0 14 -249661
|
|
-66577 0;
|
|
#X msg 368 354 connect localhost 11001;
|
|
#X msg 392 375 disconnect;
|
|
#X obj 368 332 sel 1 0;
|
|
#X obj 368 311 tgl 15 0 empty empty empty 17 7 0 10 -261234 -1 -1 0
|
|
1;
|
|
#X obj 24 227 string2any 0 59;
|
|
#X obj 24 247 route bang;
|
|
#X obj 24 386 netclient;
|
|
#X obj 24 415 print CLIENT_2;
|
|
#X text 168 337 <- send FUDI message;
|
|
#X obj 9 457 cnv 15 550 300 empty empty FUDI_server 20 12 0 14 -241408
|
|
-66577 0;
|
|
#X obj 11 613 tcpsocketserver FUDI 11001;
|
|
#X obj 11 687 string2any 0 59;
|
|
#X obj 11 708 route bang;
|
|
#X obj 190 633 unpack 0 0 0 0;
|
|
#X floatatom 190 653 3 0 0 0 - - -;
|
|
#X floatatom 221 653 3 0 0 0 - - -;
|
|
#X floatatom 253 654 3 0 0 0 - - -;
|
|
#X floatatom 287 654 3 0 0 0 - - -;
|
|
#X text 188 670 IP;
|
|
#X floatatom 130 653 5 0 0 0 - - -;
|
|
#X floatatom 70 654 5 0 0 0 - - -;
|
|
#X text 59 669 clients;
|
|
#X text 126 669 socket;
|
|
#X text 131 688 <--;
|
|
#X text 164 688 [tcpsocketserver FUDI] does _not_ remove the trailing
|
|
' \; ';
|
|
#X text 164 83 1) start a FUDI message;
|
|
#X text 231 131 2) continue;
|
|
#X text 117 165 3) finish FUDI message (with semicolon - newline);
|
|
#X text 390 65 connect;
|
|
#X text 389 309 connect;
|
|
#X text 19 488 [tcpsocketserver FUDI] doesn't take care of building
|
|
FUDI-compliant messages. this should be done by the user.;
|
|
#X text 153 229 4) try sending a message from client_2 during composing
|
|
a message with client_1 and see \, how the server behaves.;
|
|
#X text 278 535 <- this doesn't work;
|
|
#X text 314 562 <- this should;
|
|
#X msg 24 336 send four five six;
|
|
#X msg 42 563 client 2 115 101 118 101 110 32 59 10;
|
|
#X msg 41 534 client 2 115 101 118 101 110 32;
|
|
#X obj 11 733 print SERVER;
|
|
#X obj 20 32 import moocow;
|
|
#X connect 1 0 16 0;
|
|
#X connect 2 0 1 0;
|
|
#X connect 3 0 1 0;
|
|
#X connect 4 0 2 0;
|
|
#X connect 4 1 3 0;
|
|
#X connect 5 0 4 0;
|
|
#X connect 7 0 8 0;
|
|
#X connect 8 0 1 0;
|
|
#X connect 9 0 1 0;
|
|
#X connect 10 0 1 0;
|
|
#X connect 12 0 18 0;
|
|
#X connect 13 0 18 0;
|
|
#X connect 14 0 12 0;
|
|
#X connect 14 1 13 0;
|
|
#X connect 15 0 14 0;
|
|
#X connect 16 0 17 0;
|
|
#X connect 17 1 6 0;
|
|
#X connect 18 0 19 0;
|
|
#X connect 22 0 23 0;
|
|
#X connect 22 1 32 0;
|
|
#X connect 22 2 31 0;
|
|
#X connect 22 3 25 0;
|
|
#X connect 23 0 24 0;
|
|
#X connect 24 1 49 0;
|
|
#X connect 25 0 26 0;
|
|
#X connect 25 1 27 0;
|
|
#X connect 25 2 28 0;
|
|
#X connect 25 3 29 0;
|
|
#X connect 46 0 18 0;
|
|
#X connect 47 0 22 0;
|
|
#X connect 48 0 22 0;
|
|
#X restore 23 25 pd FUDI;
|
|
#N canvas 697 77 579 756 OSC 0;
|
|
#X obj 9 39 cnv 15 550 240 empty empty client_1 20 12 0 14 -249661
|
|
-66577 0;
|
|
#X obj 25 211 tcpclient;
|
|
#X msg 357 229 disconnect;
|
|
#X obj 333 186 sel 1 0;
|
|
#X obj 333 165 tgl 15 0 empty empty empty 17 7 0 10 -261234 -1 -1 0
|
|
1;
|
|
#X obj 25 259 print CLIENT_1;
|
|
#X obj 9 286 cnv 15 550 150 empty empty client_2 20 12 0 14 -249661
|
|
-66577 0;
|
|
#X msg 393 362 disconnect;
|
|
#X obj 369 319 sel 1 0;
|
|
#X obj 369 298 tgl 15 0 empty empty empty 17 7 0 10 -261234 -1 -1 0
|
|
1;
|
|
#X obj 25 417 print CLIENT_2;
|
|
#X obj 10 444 cnv 15 550 300 empty empty OSC_server 20 12 0 14 -241408
|
|
-66577 0;
|
|
#X obj 188 636 unpack 0 0 0 0;
|
|
#X floatatom 188 656 3 0 0 0 - - -;
|
|
#X floatatom 219 656 3 0 0 0 - - -;
|
|
#X floatatom 251 657 3 0 0 0 - - -;
|
|
#X floatatom 285 657 3 0 0 0 - - -;
|
|
#X text 186 673 IP;
|
|
#X floatatom 130 656 5 0 0 0 - - -;
|
|
#X floatatom 73 657 5 0 0 0 - - -;
|
|
#X text 62 672 clients;
|
|
#X text 126 672 socket;
|
|
#X text 355 166 connect;
|
|
#X text 390 296 connect;
|
|
#X obj 16 616 tcpsocketserver OSC 11002;
|
|
#X obj 16 694 unpackOSC;
|
|
#X obj 16 720 print SERVER;
|
|
#X msg 333 208 connect localhost 11002;
|
|
#X msg 369 341 connect localhost 11002;
|
|
#X obj 25 234 unpackOSCstream;
|
|
#X obj 25 373 tcpclient;
|
|
#X obj 25 395 unpackOSCstream;
|
|
#X msg 49 498 /synth1/tone3/freq 440;
|
|
#X msg 25 79 0 0 0 16 47 102 114 101 113;
|
|
#X msg 41 104 0 0 0 44 105 0 0 0 0 1 184;
|
|
#X text 155 324 send OSC message;
|
|
#X msg 25 323 /amplitude 0.78;
|
|
#X obj 25 347 packOSCstream;
|
|
#X obj 16 522 packOSCstream;
|
|
#X obj 16 594 list trim;
|
|
#X msg 16 473 /synth3/tone4/amplitude 0.36;
|
|
#X obj 180 555 hradio 15 1 0 2 empty empty empty 0 -8 0 10 -4034 -1
|
|
-1 0;
|
|
#X obj 180 573 + 1;
|
|
#X text 221 555 client;
|
|
#X obj 16 551 list prepend 1;
|
|
#X obj 16 573 list prepend client;
|
|
#X text 236 80 1) start sending an OSC packet;
|
|
#X text 247 106 2) complete the OSC packet;
|
|
#X text 59 137 also try sending an OSC packet from client_2 between
|
|
1) and 2);
|
|
#X text 124 520 <- use [packOSCstream] in order to create OSC packets
|
|
suitable for tcp transport.;
|
|
#X text 238 486 send to clients;
|
|
#X text 93 695 <---;
|
|
#X text 139 694 CAUTION: not [unpackOSCstream] is used here \, since
|
|
[tcpsocket.OSC] already unwraps the OSC message;
|
|
#X obj 8 9 import moocow;
|
|
#X connect 1 0 29 0;
|
|
#X connect 2 0 1 0;
|
|
#X connect 3 0 27 0;
|
|
#X connect 3 1 2 0;
|
|
#X connect 4 0 3 0;
|
|
#X connect 7 0 30 0;
|
|
#X connect 8 0 28 0;
|
|
#X connect 8 1 7 0;
|
|
#X connect 9 0 8 0;
|
|
#X connect 12 0 13 0;
|
|
#X connect 12 1 14 0;
|
|
#X connect 12 2 15 0;
|
|
#X connect 12 3 16 0;
|
|
#X connect 24 0 25 0;
|
|
#X connect 24 1 19 0;
|
|
#X connect 24 2 18 0;
|
|
#X connect 24 3 12 0;
|
|
#X connect 25 0 26 0;
|
|
#X connect 27 0 1 0;
|
|
#X connect 28 0 30 0;
|
|
#X connect 29 0 5 0;
|
|
#X connect 30 0 31 0;
|
|
#X connect 31 0 10 0;
|
|
#X connect 32 0 38 0;
|
|
#X connect 33 0 1 0;
|
|
#X connect 34 0 1 0;
|
|
#X connect 36 0 37 0;
|
|
#X connect 37 0 30 0;
|
|
#X connect 38 0 44 0;
|
|
#X connect 39 0 24 0;
|
|
#X connect 40 0 38 0;
|
|
#X connect 41 0 42 0;
|
|
#X connect 42 0 44 1;
|
|
#X connect 44 0 45 0;
|
|
#X connect 45 0 39 0;
|
|
#X restore 23 49 pd OSC;
|
|
#X restore 21 365 pd EXAMPLES;
|
|
#X obj 471 455 print FUDI;
|
|
#X msg 471 101 broadcast 97 98 99 59 10;
|
|
#X msg 471 128 client 1 97 98 99 59 10;
|
|
#X msg 471 155 send 504 97 98 99 59 10;
|
|
#X msg 471 28 10 97 98 99 59 10;
|
|
#X text 17 8 TCPSOCKETSERVER - a protocol-aware wrapper aroun [tcpserver]
|
|
;
|
|
#X text 13 167 [tcpsocketserver] dynamically creates (internally) an
|
|
instance of a socket handler abstraction [tcpsocket.PROTOCOL] for each
|
|
opened socket. every socket handler creates proper packets from the
|
|
incoming stream and sends them to the left outlet of [tcpsocketserver].
|
|
;
|
|
#X connect 0 0 30 0;
|
|
#X connect 7 0 30 0;
|
|
#X connect 8 0 30 0;
|
|
#X connect 9 0 10 1;
|
|
#X connect 10 0 8 0;
|
|
#X connect 11 0 10 0;
|
|
#X connect 12 0 13 1;
|
|
#X connect 13 0 7 0;
|
|
#X connect 14 0 13 0;
|
|
#X connect 16 0 17 0;
|
|
#X connect 16 1 18 0;
|
|
#X connect 16 2 19 0;
|
|
#X connect 16 3 20 0;
|
|
#X connect 26 0 41 0;
|
|
#X connect 27 0 26 1;
|
|
#X connect 30 0 26 0;
|
|
#X connect 30 1 24 0;
|
|
#X connect 30 2 22 0;
|
|
#X connect 30 3 16 0;
|
|
#X connect 42 0 30 0;
|
|
#X connect 43 0 30 0;
|
|
#X connect 44 0 30 0;
|
|
#X connect 45 0 30 0;
|