implement link using proxy

9a19e55c · Roman Haefeli · b76d3296 · 9a19e55c
Commit 9a19e55c authored Jan 18, 2018 by Roman Haefeli
--- a/pd-tools/include/tpf-client-link.pd
+++ b/pd-tools/include/tpf-client-link.pd
@@ -53,10 +53,10 @@
 #X obj 21 262 s \$0.error;
 #X obj 54 131 text get \$1.clients;
 #X obj 54 151 unpack f s f s;
-#X obj 135 173 s \$0.peer.ip;
 #X obj 108 196 s \$0.peer.master;
 #X obj 81 217 s \$0.peer.name;
 #X obj 21 18 inlet;
+#X obj 135 173 s \$0.peer.ip;
 #X connect 0 0 1 0;
 #X connect 1 0 3 0;
 #X connect 2 0 1 1;
@@ -65,10 +65,10 @@
 #X connect 4 1 7 0;
 #X connect 5 0 6 0;
 #X connect 7 0 8 0;
-#X connect 8 1 11 0;
-#X connect 8 2 10 0;
-#X connect 8 3 9 0;
-#X connect 12 0 0 0;
+#X connect 8 1 10 0;
+#X connect 8 2 9 0;
+#X connect 8 3 12 0;
+#X connect 11 0 0 0;
 #X restore 16 104 pd get.peer.data;
 #N canvas 277 523 937 517 gui.code 0;
 #X obj 11 164 s \$0.client.label;
@@ -411,9 +411,8 @@
 #X obj 107 136 r \$0.peer.port;
 #X obj 25 157 pack f f;
 #X obj 107 157 r \$0.bind.port;
-#X obj 107 177 r \$0.peer.ip;
 #X obj 25 177 list prepend;
-#X obj 25 375 s \$0.to.jacktrip;
+#X obj 25 445 s \$0.to.jacktrip;
 #X obj 315 257 s \$0.to.jacktrip;
 #X obj 315 131 r \$0.link;
 #X obj 315 153 sel 0;
@@ -423,25 +422,21 @@
 #X obj 315 194 f;
 #X obj 25 136 f;
 #X obj 315 216 sel 1;
-#X obj 111 202 r \$0.linkID;
-#X obj 111 222 + 4464;
-#X obj 25 233 list append;
 #X obj 428 30 r \$1.queue;
 #X obj 324 33 r \$1.channels;
 #X obj 496 29 r \$1.blocksize;
 #X msg 324 53 outchannels \$1;
 #X msg 428 50 queue \$1;
 #X obj 324 83 s \$0.to.jacktrip;
-#X msg 25 324 start;
+#X msg 25 394 start;
 #X msg 496 49 blocksize \$1;
 #X obj 25 20 r \$0.udp.link.status;
-#X msg 72 325 server \$1 \, peerport \$2 \, bindport \$3;
+#X msg 72 395 server \$1 \, peerport \$2 \, bindport \$3;
 #X obj 533 268 s \$0.udp.link.status;
-#X obj 25 41 sel 3;
 #X obj 533 215 sel 0;
 #X msg 533 240 4;
-#X obj 25 283 t b a;
-#X text 67 283 peer ip \, peer port \, bind port \, server port;
+#X obj 25 353 t b a;
+#X text 67 353 peer ip \, peer port \, bind port \, server port;
 #X obj 352 301 r \$0.tx.switch.s;
 #X obj 380 324 r \$0.udp.link.status;
 #X obj 352 324 f;
@@ -450,81 +445,95 @@
 #X obj 549 608 s \$0.udp.link.status;
 #X msg 549 586 0;
 #X obj 549 500 t b b;
-#X obj 352 371 t b b;
+#X obj 352 381 t b b;
 #X obj 352 586 s \$1.send;
 #X obj 367 497 r \$0.peer;
 #X obj 352 519 f;
 #X obj 397 517 r \$0.linkID;
 #X obj 352 540 pack f f;
-#X obj 594 381 r \$0.linkID;
+#X obj 594 380 r \$0.linkID;
 #X msg 594 401 set /\$1;
 #X obj 575 315 r \$1.receive;
 #X obj 575 422 routeOSC /__;
 #X obj 575 339 routeOSC /*;
 #X msg 352 562 /\$1/tpf/requeststop/\$2;
 #X obj 575 359 routeOSC /tpf/requeststop;
-#X obj 352 347 sel 1 3 4;
 #X obj 552 189 tgl 20 0 empty empty empty 17 7 0 10 -204786 -1 -1 0
 1;
 #X obj 549 565 del 0;
 #X obj 533 169 route connected;
-#X connect 0 0 13 1;
-#X connect 1 0 4 0;
+#X obj 107 177 r \$0.peer.host;
+#X obj 25 41 sel 3 7;
+#X obj 25 72 b;
+#X obj 352 347 sel 1 3 4 5 7;
+#X obj 25 198 t a a;
+#X obj 52 277 print link;
+#X obj 95 216 r \$0.linkID;
+#X obj 52 236 list append;
+#X msg 52 256 ID=\$4 localhost:\$3 => \$1:\$2;
+#X connect 0 0 12 1;
+#X connect 1 0 3 0;
 #X connect 2 0 1 1;
-#X connect 3 0 4 1;
-#X connect 4 0 17 0;
-#X connect 7 0 8 0;
-#X connect 8 0 12 0;
-#X connect 9 0 6 0;
-#X connect 10 0 11 0;
-#X connect 11 0 58 0;
-#X connect 12 0 14 0;
-#X connect 13 0 1 0;
-#X connect 14 0 9 0;
-#X connect 15 0 16 0;
-#X connect 16 0 17 1;
-#X connect 17 0 32 0;
-#X connect 18 0 22 0;
-#X connect 19 0 21 0;
-#X connect 20 0 25 0;
-#X connect 21 0 23 0;
-#X connect 22 0 23 0;
-#X connect 24 0 5 0;
-#X connect 25 0 23 0;
-#X connect 26 0 29 0;
-#X connect 27 0 5 0;
-#X connect 29 0 13 0;
-#X connect 30 0 31 0;
-#X connect 31 0 28 0;
-#X connect 32 0 24 0;
-#X connect 32 1 27 0;
-#X connect 34 0 36 0;
-#X connect 35 0 36 1;
-#X connect 36 0 55 0;
-#X connect 38 0 37 0;
-#X connect 40 0 39 0;
-#X connect 41 0 57 0;
-#X connect 41 1 38 0;
-#X connect 42 0 45 0;
-#X connect 42 1 41 0;
-#X connect 44 0 45 1;
+#X connect 3 0 57 0;
+#X connect 6 0 7 0;
+#X connect 7 0 11 0;
+#X connect 8 0 5 0;
+#X connect 9 0 10 0;
+#X connect 10 0 52 0;
+#X connect 11 0 13 0;
+#X connect 12 0 1 0;
+#X connect 13 0 8 0;
+#X connect 14 0 18 0;
+#X connect 15 0 17 0;
+#X connect 16 0 21 0;
+#X connect 17 0 19 0;
+#X connect 18 0 19 0;
+#X connect 20 0 4 0;
+#X connect 21 0 19 0;
+#X connect 22 0 54 0;
+#X connect 23 0 4 0;
+#X connect 25 0 26 0;
+#X connect 26 0 24 0;
+#X connect 27 0 20 0;
+#X connect 27 1 23 0;
+#X connect 29 0 31 0;
+#X connect 30 0 31 1;
+#X connect 31 0 56 0;
+#X connect 33 0 32 0;
+#X connect 35 0 34 0;
+#X connect 36 0 51 0;
+#X connect 36 1 33 0;
+#X connect 37 0 40 0;
+#X connect 37 1 36 0;
+#X connect 39 0 40 1;
+#X connect 40 0 42 0;
+#X connect 41 0 42 1;
+#X connect 42 0 48 0;
+#X connect 43 0 44 0;
+#X connect 44 0 46 0;
 #X connect 45 0 47 0;
-#X connect 46 0 47 1;
-#X connect 47 0 53 0;
-#X connect 48 0 49 0;
-#X connect 49 0 51 0;
-#X connect 50 0 52 0;
-#X connect 51 0 41 0;
-#X connect 52 0 54 0;
-#X connect 53 0 43 0;
-#X connect 54 0 51 0;
-#X connect 55 0 42 0;
-#X connect 55 1 42 0;
-#X connect 55 2 42 0;
-#X connect 57 0 40 0;
-#X connect 58 0 12 1;
-#X connect 58 0 30 0;
-#X connect 58 0 56 0;
+#X connect 46 0 36 0;
+#X connect 47 0 49 0;
+#X connect 48 0 38 0;
+#X connect 49 0 46 0;
+#X connect 51 0 35 0;
+#X connect 52 0 11 1;
+#X connect 52 0 25 0;
+#X connect 52 0 50 0;
+#X connect 53 0 3 1;
+#X connect 54 0 55 0;
+#X connect 54 1 55 0;
+#X connect 55 0 12 0;
+#X connect 56 0 37 0;
+#X connect 56 1 37 0;
+#X connect 56 2 37 0;
+#X connect 56 3 37 0;
+#X connect 56 4 37 0;
+#X connect 57 0 27 0;
+#X connect 57 1 60 0;
+#X connect 59 0 60 1;
+#X connect 60 0 61 0;
+#X connect 61 0 58 0;
 #X restore 16 164 pd jacktrip.start.stop;
 #X obj 404 20 cnv 32 70 32 empty \$0.channels.label empty 8 16 0 20
 -1 -262144 0;
@@ -637,7 +646,7 @@
 #X obj 357 440 f;
 #X obj 357 462 sel 1;
 #X obj 357 483 t b b;
-#X obj 357 550 s \$0.udp.link.status;
+#X obj 357 570 s \$0.udp.link.status;
 #X obj 357 509 del 0;
 #X obj 456 521 s \$1.send;
 #X obj 471 433 r \$0.peer;
@@ -652,7 +661,7 @@
 #X obj 87 490 routeOSC /__;
 #X obj 87 447 routeOSC /*;
 #X obj 87 467 routeOSC /tpf/startproxyconnection;
-#X msg 357 530 7;
+#X msg 357 550 7;
 #X obj 87 511 b;
 #X obj 112 534 r \$0.udp.link.status;
 #X obj 87 534 f;
@@ -660,10 +669,24 @@
 #X obj 114 578 r \$0.link;
 #X obj 87 578 f;
 #X obj 87 601 sel 1;
-#X obj 75 729 s \$0.udp.link.status;
-#X msg 75 707 7;
-#X obj 87 626 t b b;
-#X obj 175 658 print WOULD_NOW_ESTABLISH_PROXY_CONNECTION;
+#X obj 87 775 s \$0.udp.link.status;
+#X msg 87 753 7;
+#X obj 596 676 r \$0.linkID;
+#X obj 581 697 f;
+#X msg 581 717 enabletoken tpf\$1;
+#X obj 581 740 s \$0.to.jacktrip;
+#X msg 475 696 4464;
+#X obj 475 717 +;
+#X obj 501 717 r \$0.linkID;
+#X obj 475 740 s \$0.bind.port;
+#X obj 371 743 s \$0.peer.port;
+#X msg 371 693 4460;
+#X obj 237 689 r \$1.host;
+#X obj 204 713 symbol;
+#X obj 204 739 s \$0.peer.host;
+#X obj 219 633 t b b b b;
+#X obj 87 622 t b b;
+#X obj 357 530 t b b;
 #X connect 0 0 1 0;
 #X connect 1 0 3 0;
 #X connect 2 0 4 0;
@@ -697,7 +720,7 @@
 #X connect 31 0 32 0;
 #X connect 32 0 34 0;
 #X connect 32 1 37 0;
-#X connect 34 0 48 0;
+#X connect 34 0 73 0;
 #X connect 36 0 37 1;
 #X connect 37 0 39 0;
 #X connect 38 0 39 1;
@@ -717,10 +740,25 @@
 #X connect 52 0 54 0;
 #X connect 53 0 54 1;
 #X connect 54 0 55 0;
-#X connect 55 0 58 0;
+#X connect 55 0 72 0;
 #X connect 57 0 56 0;
-#X connect 58 0 57 0;
-#X connect 58 1 59 0;
+#X connect 58 0 59 1;
+#X connect 59 0 60 0;
+#X connect 60 0 61 0;
+#X connect 62 0 63 0;
+#X connect 63 0 65 0;
+#X connect 64 0 63 1;
+#X connect 67 0 66 0;
+#X connect 68 0 69 1;
+#X connect 69 0 70 0;
+#X connect 71 0 69 0;
+#X connect 71 1 67 0;
+#X connect 71 2 62 0;
+#X connect 71 3 59 0;
+#X connect 72 0 57 0;
+#X connect 72 1 71 0;
+#X connect 73 0 48 0;
+#X connect 73 1 71 0;
 #X restore 16 144 pd negotiate.token;
 #N canvas 146 101 604 759 negotiate.port 0;
 #X obj 10 34 r \$1.receive;
@@ -729,9 +767,9 @@
 #X obj 147 21 r \$0.linkID;
 #X msg 147 41 set /\$1;
 #X obj 37 155 s \$0.peer.port;
-#X obj 264 17 r \$1.receive;
-#X obj 264 84 routeOSC /__;
-#X obj 264 61 routeOSC /tpf/requestpeerport;
+#X obj 371 24 r \$1.receive;
+#X obj 371 91 routeOSC /__;
+#X obj 371 68 routeOSC /tpf/requestpeerport;
 #X obj 9 690 s \$1.send;
 #X obj 64 509 r \$0.peer;
 #X obj 49 531 f;
@@ -742,12 +780,12 @@
 #X obj 238 608 s \$0.bind.port;
 #X obj 49 583 list append;
 #X obj 112 562 r \$0.bind.port;
-#X obj 264 108 b;
+#X obj 371 115 b;
 #X msg 49 653 /\$1/tpf/setpeerport/\$2 \$3;
 #X obj 9 608 list append;
 #X msg 9 630 /\$1/tpf/requestpeerport/\$2;
 #X obj 10 58 routeOSC /*;
-#X obj 264 41 routeOSC /*;
+#X obj 371 48 routeOSC /*;
 #N canvas 750 196 301 279 random.seed 0;
 #X obj 35 24 loadbang;
 #X obj 34 96 realtime;
@@ -779,14 +817,14 @@
 #X obj 9 425 sel 1;
 #X msg 111 425 1;
 #X obj 111 444 s \$0.udp.link.status;
-#X obj 289 141 r \$0.udp.link.status;
-#X obj 291 189 r \$0.link;
-#X obj 264 141 f;
-#X obj 264 164 sel 0 4;
-#X obj 264 189 f;
-#X obj 264 211 sel 1;
-#X obj 264 254 s \$0.udp.link.status;
-#X msg 264 233 2;
+#X obj 396 148 r \$0.udp.link.status;
+#X obj 398 196 r \$0.link;
+#X obj 371 148 f;
+#X obj 371 171 sel 0 4;
+#X obj 371 196 f;
+#X obj 371 218 sel 1;
+#X obj 371 261 s \$0.udp.link.status;
+#X msg 371 240 2;
 #X obj 295 323 r \$0.tx.switch.s;
 #X obj 320 346 r \$0.udp.link.status;
 #X obj 322 394 r \$0.link;
@@ -801,9 +839,8 @@
 #X obj 10 231 f;
 #X obj 10 253 sel 1;
 #X obj 10 206 sel 1;
-#X obj 10 296 s \$0.udp.link.status;
-#X msg 10 274 3;
-#X obj 295 437 t b b;
+#X obj 10 317 s \$0.udp.link.status;
+#X msg 10 295 3;
 #X msg 295 484 3;
 #X obj 295 504 s \$0.udp.link.status;
 #X obj 295 463 del 0;
@@ -811,6 +848,14 @@
 #X obj 49 486 t b b;
 #X obj 111 403 del 0;
 #X obj 9 350 r \$0.initiate.stun;
+#X obj 10 274 t b b;
+#X obj 144 301 s \$0.to.jacktrip;
+#X obj 295 437 t b b b;
+#X msg 144 278 disabletoken;
+#X obj 204 208 r \$0.peer.ip;
+#X obj 144 214 t b b;
+#X obj 171 237 symbol;
+#X obj 171 258 s \$0.peer.host;
 #X connect 0 0 23 0;
 #X connect 1 0 2 0;
 #X connect 2 0 46 0;
@@ -838,7 +883,7 @@
 #X connect 25 0 14 0;
 #X connect 26 0 27 1;
 #X connect 27 0 28 0;
-#X connect 28 0 59 0;
+#X connect 28 0 58 0;
 #X connect 29 0 30 0;
 #X connect 31 0 33 1;
 #X connect 32 0 35 1;
@@ -853,7 +898,7 @@
 #X connect 41 0 43 1;
 #X connect 42 0 45 0;
 #X connect 43 0 44 0;
-#X connect 44 0 55 0;
+#X connect 44 0 64 0;
 #X connect 45 0 43 0;
 #X connect 46 0 49 0;
 #X connect 46 1 5 0;
@@ -861,20 +906,28 @@
 #X connect 48 0 50 1;
 #X connect 49 0 52 0;
 #X connect 50 0 51 0;
-#X connect 51 0 54 0;
+#X connect 51 0 62 0;
 #X connect 52 0 50 0;
 #X connect 54 0 53 0;
-#X connect 55 0 58 0;
-#X connect 55 1 60 0;
-#X connect 56 0 57 0;
-#X connect 58 0 56 0;
-#X connect 59 0 21 0;
-#X connect 59 1 60 0;
-#X connect 59 2 61 0;
-#X connect 60 0 11 0;
-#X connect 60 1 14 0;
-#X connect 61 0 29 0;
-#X connect 62 0 27 0;
+#X connect 55 0 56 0;
+#X connect 57 0 55 0;
+#X connect 58 0 21 0;
+#X connect 58 1 59 0;
+#X connect 58 2 60 0;
+#X connect 59 0 11 0;
+#X connect 59 1 14 0;
+#X connect 60 0 29 0;
+#X connect 61 0 27 0;
+#X connect 62 0 54 0;
+#X connect 62 1 67 0;
+#X connect 64 0 57 0;
+#X connect 64 1 59 0;
+#X connect 64 2 67 0;
+#X connect 65 0 63 0;
+#X connect 66 0 68 1;
+#X connect 67 0 65 0;
+#X connect 67 1 68 0;
+#X connect 68 0 69 0;
 #X restore 16 124 pd negotiate.port;
 #X connect 0 0 4 0;
 #X connect 1 0 2 0;