#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 ]; #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 ]; #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;