开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 多媒体 > 流媒体/Mpeg4/MP4 > 查看源码
proxyudp-telogy-sdp
资源名称：rtsp-1.0.1.tar.gz　[点击查看]
上传用户：sy_wanhua
上传日期：2013-07-25
资源大小：3048k
文件大小：14k
源码类别：

流媒体/Mpeg4/MP4

开发平台：

C/C++

proxyudp-telogy-sdp：源码内容
  1. #!/usr/bin/perl
  3. # ====================================================================
  4. # The Vovida Software License, Version 1.0 
  5. # 
  6. # Copyright (c) 2000 Vovida Networks, Inc.  All rights reserved.
  7. # 
  8. # Redistribution and use in source and binary forms, with or without
  9. # modification, are permitted provided that the following conditions
  10. # are met:
  11. # 
  12. # 1. Redistributions of source code must retain the above copyright
  13. #    notice, this list of conditions and the following disclaimer.
  14. # 
  15. # 2. Redistributions in binary form must reproduce the above copyright
  16. #    notice, this list of conditions and the following disclaimer in
  17. #    the documentation and/or other materials provided with the
  18. #    distribution.
  19. # 
  20. # 3. The names "VOCAL", "Vovida Open Communication Application Library",
  21. #    and "Vovida Open Communication Application Library (VOCAL)" must
  22. #    not be used to endorse or promote products derived from this
  23. #    software without prior written permission. For written
  24. #    permission, please contact vocal@vovida.org.
  25. # 
  26. # 4. Products derived from this software may not be called "VOCAL", nor
  27. #    may "VOCAL" appear in their name, without prior written
  28. #    permission of Vovida Networks, Inc.
  29. # 
  30. # THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESSED OR IMPLIED
  31. # WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
  32. # OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE, TITLE AND
  33. # NON-INFRINGEMENT ARE DISCLAIMED.  IN NO EVENT SHALL VOVIDA
  34. # NETWORKS, INC. OR ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT DAMAGES
  35. # IN EXCESS OF $1,000, NOR FOR ANY INDIRECT, INCIDENTAL, SPECIAL,
  36. # EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
  37. # PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
  38. # PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY
  39. # OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  40. # (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE
  41. # USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH
  42. # DAMAGE.
  43. # 
  44. # ====================================================================
  45. # 
  46. # This software consists of voluntary contributions made by Vovida
  47. # Networks, Inc. and many individuals on behalf of Vovida Networks,
  48. # Inc.  For more information on Vovida Networks, Inc., please see
  49. # <http://www.vovida.org/>.
  51. # $Id: proxyudp-telogy-sdp,v 1.4 2000/08/12 01:25:04 bogawa Exp $
  53. # this version of proxyudp proxies correctly for telogy MGCP gateway v 6.1
  55. BEGIN {
  56. push(@INC, "../contrib/perl/Time-HiRes-01.20/blib/lib", "../contrib/perl/Time-HiRes-01.20/blib/arch/auto/Time/HiRes");
  57. }
  59. use Socket;
  60. require "getopts.pl";
  61. use Time::HiRes qw(gettimeofday tv_interval);
  63. &Getopts("n:d");
  65. if($opt_d) { 
  66.     $debug = 1;
  67. }
  68. $number = 1;
  69. if($opt_n) {
  70.     $number = $opt_n;
  71. }
  73. # if($#ARGV < 1) {
  74. #     print "Usage:n";
  75. #     print "$0 host1:<local_port1>:<remote_port1> host2:<local_port2>:<remote_port2> host3:<local_port3>:<remote_port3>n";
  76. #     exit(-1);
  77. # }
  79. if($ARGV[0]) {
  80.    $agent_host = $ARGV[0];
  81. } else {
  82.    chomp($agent_host = `hostname`);
  83. }
  84. $unique_internal = 0;
  86. $flash_time = .5;
  88. $proxy_ip = "192.168.5.3";
  90. print "Agent is at $agent_hostn";
  92. $dest{"o_agent1"} = "$agent_host:5011";
  93. $dest{"o_agent2"} = "$agent_host:5012";
  94. $dest{"o_agent3"} = "$agent_host:5013";
  95. $dest{"o_agent4"} = "$agent_host:5014";
  97. $dest{"o_gw1"} = "192.168.5.180:2427";
  98. $dest{"o_gw2"} = "192.168.5.182:2427";
  101. $src{"rtp1"} = "8000";
  102. $src{"rtp2"} = "8002";
  103. $src{"rtp3"} = "8004";
  104. $src{"rtp4"} = "8006";
  105. $src{"rtp5"} = "8008";
  107. $src{"i_agent1"} = "5051";
  108. $src{"i_agent2"} = "5052";
  109. $src{"i_agent3"} = "5053";
  110. $src{"i_agent4"} = "5054";
  112. $src{"i_gw"} = "2427";
  114. $map{"i_gw"} = "";
  115. $map{"i_agent1"} = "o_gw1";
  116. $map{"i_agent2"} = "o_gw1";
  117. $map{"i_agent3"} = "o_gw2";
  118. $map{"i_agent4"} = "o_gw2";
  120. $dest{"o_rtp3"} = "0.0.0.0:9";
  121. $dest{"o_rtp4"} = "0.0.0.0:9";
  123. $map{"rtp3"} = "o_rtp4";
  124. $map{"rtp4"} = "o_rtp3";
  126. $dont_print{"rtp3"} = 1;
  127. $dont_print{"rtp4"} = 1;
  129. $rewrite{"i_gw"} = &rewrite_S2;
  130. $rewrite{"i_agent1"} = &rewrite_S1;
  131. $rewrite{"i_agent2"} = &rewrite_S1;
  132. $rewrite{"i_agent3"} = &rewrite_S1;
  133. $rewrite{"i_agent4"} = &rewrite_S1;
  135. $rewrite{"rtp1"} = &rewrite_rtp;
  136. $rewrite{"rtp2"} = &rewrite_rtp;
  137. $rewrite{"rtp3"} = &rewrite_rtp;
  138. $rewrite{"rtp4"} = &rewrite_rtp;
  139. $rewrite{"rtp5"} = &rewrite_rtp;
  141. #$fake{"rtp3"} = "rtp3";
  142. #$fake{"rtp4"} = "rtp4";
  143. $fake{"rtp3"} = "rtp4";
  144. $fake{"rtp4"} = "rtp4";
  146. $fake{"i_agent1"} = "i_gw";
  147. $fake{"i_agent2"} = "i_gw";
  148. $fake{"i_agent3"} = "i_gw";
  149. $fake{"i_agent4"} = "i_gw";
  150. $fake{"i_gw"} = "i_agent1";
  152. $terminal_name[1] = 'aaln/1@gw1.vovida.com';
  153. $terminal_name[2] = 'aaln/2@gw1.vovida.com';
  154. $terminal_name[3] = 'aaln/1@gw2.vovida.com';
  155. $terminal_name[4] = 'aaln/2@gw2.vovida.com';
  158. foreach(sort keys %src) {
  159.     $FROM{$_} = $_;
  160.     &mksocket($src{$_}, $FROM{$_});
  161. }
  163. sub rewrite_rtp {
  164.     return $_[0];
  165. }
  167. foreach(sort keys %dest) {
  168.     &make_dest($_);
  169. }
  171. sub make_dest {
  172.     local($x) = $_[0];
  173.     local($host, $port, $name, $aliasese, $type, $len, $host_addr, $sockaddr);
  175.     ($host, $port) = split(/:/, $dest{$x});
  176.     ($name,$aliases,$type,$len,$host_addr) = gethostbyname($host);
  177.     $sockaddr = "S n a4 x8";
  178.     $TO{$x} = pack($sockaddr, PF_INET, $port, $host_addr);
  179.     print "TO: $x : $host : $port : $TO{$x} : n";
  180.     &debug( "TO: $x : $TO{$x}n");
  181. }
  184. sub mksocket {
  185.     local($port, $socket) = @_;
  186.     
  187.     $sockaddr = "S n a4 x8";
  188.     ($name,$aliases,$proto) = getprotobyname('udp');
  189.     chomp($hostname  = `hostname`);
  190.     ($name,$aliases,$type,$len,$myaddr) = gethostbyname($hostname);
  191.     $me = pack($sockaddr,PF_INET, $port, $myaddr);
  192.     
  193.     &debug( "myaddr: $hostnamen");
  194.     &debug( "port: $portn");
  195.     
  196.     socket($socket, PF_INET, SOCK_DGRAM, $proto) || die $!;
  197.     bind($socket , $me) || die "died with port $port $!";
  198.     
  199. }
  202. while(1) {
  203.     $rin = '';
  204.     foreach(sort keys %FROM) {
  205. vec($rin, fileno($FROM{$_}), 1) = 1;
  206.     }
  208.     if(select($rin, undef, undef, 0.25)) {
  209. @bits = split(//, unpack("b*", $rin));
  210. undef($data);
  211. undef($new_data);
  212. $flag = 0;
  213. foreach(sort keys %FROM) {
  214.     if($flag == 0 && $bits[fileno($FROM{$_})]) {
  215. &debug( "got $_, $FROM{$_}, target $targetn");
  216. $data = "";
  217. $his_address = recv($FROM{$_}, $data, 60000, 0);
  218. &send_msg($_, $data);
  219. &dequeue();
  220. $flag = 1;
  221.     }
  222. }
  223.     }
  224.     &handle_timeouts();
  225. }
  228. sub handle_timeouts {
  230.     for($i = 1; $i <= 4; $i++) {
  231. if($hookflash_timestamp[$i]) {
  232. #     print "a: $hookflash_timestamp[$i]n";
  233.     $b = gettimeofday;
  234. #     print "b: $bn";
  235.     $elapsed = $b - $hookflash_timestamp[$i];
  236.     print "e: $elapsedn";
  237.     if($elapsed > $flash_time) {
  238. # longer than a second
  239. &enqueue("i_gw", "fake $in_hookflash[$i]");
  240. $in_hookflash[$i]  = "";
  241. $hookflash_timestamp[$i] = "";
  242.     }
  243. }
  245.     }
  246.     &dequeue();
  247. }
  249. sub renumber_S2 {
  250.     local($_) = $_[0];
  251.     
  252.     s/^([0-9]*)s([0-9]*)s/$1 $map{$2} /;
  253.     $map{$number} = $2;
  254.     
  255.     
  256.     return $_;
  257. }
  259. sub renumber_S1 {
  260.     local($_) = $_[0];
  261.     if(s/^([a-zA-Z]*)s([0-9]*)s/$1 $number /) {
  262. $map{$number} = $2;
  263. $number++;
  264.     }
  265.     return $_;
  266. }
  268. sub send_msg {
  269.     local($_, $data) = @_;
  271.     local($target, $myfake, $new_data);
  273.     $target = $map{$FROM{$_}};
  274.     $myfake = $fake{$_};
  275.     if($data) {
  276.   if(!$dont_print{$_}) {
  277.     &debug( "-----------------------------n");
  278.     &debug( "$data");
  279.     &debug( "-----------------------------n");
  280. }
  281. $new_data = &{$rewrite{$_}}($data);
  282. if($new_data) {
  283.     if(!$dont_print{$_}) {
  284. &debug( "$new_data");
  285. &debug( "-----------------------------n");
  286.     }
  287.     &debug( "target $target fake $myfake eg: $FROM{$myfake} / $TO{$target} #n");
  288.     if($target) {
  289. $x = defined(send($FROM{$myfake},$new_data,0,$TO{$target}));
  290. #or die "errno= $? $!";
  291.     }
  292. }
  293.     }
  294. }
  296. sub enqueue {
  297.     local($_, $data) = @_;
  298.     &debug( "enqueuing $_n");
  299.     push(@my_target, $_);
  300.     push(@my_data, $data);
  301. };
  303. sub dequeue {
  304.     local($x, $y);
  305.     while($x = shift(@my_target)) {
  306. $y = shift(@my_data);
  307. &debug( "dequeuing $xn");
  309. &send_msg($x, $y);
  310.     }
  311. }
  313. sub mini_send {
  314.     local($new_data, $myfake, $target);
  315.     send($FROM{$myfake},$new_data,0,$TO{$target});
  316. }
  318. sub rewrite_S1 {
  319.     # convert from the agent to the gateway
  321.     local($_) = $_[0];
  323.     $is_fake = 0;
  325.     if(/^fake [a-zA-Z]+ ([0-9]+)/i) {
  326. $fake{$1} = 1;
  327. $is_fake = 1;
  328. s/^fake //;
  329.     }
  330.     
  331.     if(/^200 ([0-9]+)/i) {
  332. if($fake1{$1}) {
  333.     $fake1{$1} = 0;
  334.     $_ = "";
  335.     &debug( "deletian");
  336. }
  337.     }
  338.     
  340.     if(/^([a-z]{4,4})s+([0-9]+)/i) {
  341. $x = $2;
  342. &debug( "S1 sawn");
  343. if(/aaln/1@gw1.vovida.com/) {
  345.     $terminal = "1";
  346.     &debug( "got: $xn");
  347.     $host1{$x} = "o_agent1";
  348.     $target = "o_gw1";
  349. }
  350. if(/aaln/2@gw1.vovida.com/) {
  351.     &debug( "got: $xn");
  353.     $terminal = "2";
  355.     $host1{$x} = "o_agent2";
  356.     $target = "o_gw1";
  357. }
  358. if(/aaln/1@gw2.vovida.com/) {
  359.     &debug( "got: $xn");
  361.     $terminal = "3";
  363.     $host1{$x} = "o_agent3";
  364.     $target = "o_gw2";
  365. }
  366. if(/aaln/2@gw2.vovida.com/) {
  367.     &debug( "got: $xn");
  369.     $terminal = "4";
  371.     $host1{$x} = "o_agent4";
  372.     $target = "o_gw2";
  373. }
  374.     }
  375.     
  376.     s/auep/AUEP/;
  377.     s/rqnt/RQNT/;
  378.     s/crcx/CRCX/;
  379.     s/mdcx/MDCX/;
  380.     s/dlcx/DLCX/;
  381.     s/mgcp/MGCP/;
  383.     s/nr:/nR:/;
  384.     s/nx:/nX:/;
  385.     
  386.     s/MGCP 0.1/MGCP 0.1 NCS 1.0/;
  387.     
  388. #    s/testID/aaln/1@vovida.com/;
  389.     s/d/x(d)/[0-9*#T](D), T(N)/;
  390.     s/nd:.*/nD: (xxxx)/;
  391.     s/,/, /g;
  392. #    s/l/hf(n), //;
  393. #    s/l/hu(n), l/hf(n), /l/hf(n), [T](n), T(n), l/hu(n), /;
  394. #    s/l/hu(n), l/hf(n), /hf(n), /;
  396. #    s/l/hu(n), l/hf(n).*/l/hf(n)/;
  398.     #hookflash implementation
  400.     if(!$is_fake) {
  401. if(/l/hf(n)/) {
  402.     &debug("hookflash activen"); 
  403.     $hookflash[$terminal] = 1;
  404.     $in_hookflash[$terminal] = "";
  405.     $hookflash_timestamp[$terminal] = "";
  407. } elsif (/^rqnt/i) {
  408.     &debug("hookflash offn"); 
  409.     $hookflash[$terminal] = 0;
  410.     $in_hookflash[$terminal] = "";
  411.     $hookflash_timestamp[$terminal] = "";
  413. }
  414.     }
  416.     s/nl:.*/nL: p:20, a:G.711u, e:on, s:on/;
  418.     if(!/nv=0/) {
  419. s/nM: sendrecv/nM: recvonly/;
  420.     }
  422.     if(/nv=0/ && !/na=/ && !/^crcx/i && !/^mdcx/i) {
  423. s/nv=0/nnv=0/;
  424. s/=in ip4/=IN IP4/g;
  425. s/(nm=.*n)/$1a=ptime:20na=recvonlyn/;
  426.     } elsif(/nv=0/ && !/na=/ && /^crcx/i) {
  427. s/nv=0/nnv=0/;
  428.      s/(nm=.*n)/$1a=rtpmap:96 G.711un/;
  429. s/=in ip4/=IN IP4/g;
  430.     } elsif(/nv=0/ && !/na=/ && /^mdcx/i) {
  431. s/nv=0/nnv=0/;
  432.      s/(nm=.*n)/$1a=rtpmap:96 G.711un/;
  433. s/=in ip4/=IN IP4/g;
  434. s/ns=.*//;
  435. s/no=.*//;
  436.     }
  439.     if(/^([0-9]*) ([0-9]*)/) {
  440. if($fake{$2}) {
  441.     &debug( " xx faken");
  442.     $_ = "";
  443. }
  444. $target = $host{$2};
  445.     }
  447.     $_ = &renumber_S1($_);
  448.     return $_;
  449. }
  452. sub rewrite_S2 {
  453.     # convert from the gateway to the agent
  455.     local($_) = $_[0];
  456.     local($nosend) = 0;
  457.     
  458.     $_ = &renumber_S2($_);
  460.     $is_fake = 0;
  461.     
  462.     if(/^fake [a-zA-Z]+ ([0-9]+)/i) {
  463. $fake1{$1} = 1;
  464.   $is_fake = 1;
  465. s/^fake //;
  466.     }
  467.     
  468.     if(/^200 ([0-9]+)/i) {
  469. if($fake{$1}) {
  470.     $fake{$1} = 0;
  471.     $_ = "";
  472. }
  473.     }
  474.     
  475.     if(s/^nosend //) {
  476. $nosend = 1;
  477.     }
  478.     
  480.     if(s/aaln/*@gw1.vovida.com/aaln/1@gw1.vovida.com/i) {
  481. &debug( "matchedn");
  482.     }
  484.     if(s/aaln/*@gw2.vovida.com/aaln/1@gw2.vovida.com/i) {
  485. &debug( "matchedn");
  486.     }
  488.     if(/^([a-z]{4,4})s+([0-9]+)/i) {
  489. $x = $2;
  490. $transaction_id = $x;
  491. &debug( "S2 saw $xn");
  492. if(/aaln/1@gw1.vovida.com/) {
  493.     &debug( "1/1 got: $xn");
  494.     $terminal = 1;
  495.     $host{$x} = "o_gw1";
  496.     $target = "o_agent1";
  497. }
  498. if(/aaln/2@gw1.vovida.com/) {
  499.     &debug( "2/1 got: $xn");
  500.     $terminal = 2;
  501.     $host{$x} = "o_gw1";
  502.     $target = "o_agent2";
  503. }
  504. if(/aaln/1@gw2.vovida.com/) {
  505.     &debug( "1/2 got: $xn");
  506.     $terminal = 3;
  507.     $host{$x} = "o_gw2";
  508.     $target = "o_agent3";
  509. }
  510. if(/aaln/2@gw2.vovida.com/) {
  511.     &debug( "2/2 got: $xn");
  512.     $terminal = 4;
  513.     $host{$x} = "o_gw2";
  514.     $target = "o_agent4";
  515. }
  516.     }
  518.     s/ NCS 1.0//;
  519.     s/ni:(.*)/nI: $1/i;
  521.     if(/^([0-9]*) ([0-9]*)/) {
  522. if($fake{$2}) {
  523.     &debug( " xx faken");
  524.     $_ = "";
  525. }
  526. $target = $host1{$2};
  527.     }
  529.     # hookflash implementation
  531.     if(!$is_fake) {
  532. if(/^ntfy /i) {
  533.     if($in_hookflash[$terminal]) {
  534. &debug("in the middle of hookflashn");
  535. if(/no:.*hd/i) {
  536.     &debug("REPLACING hd with hfn");
  537.     # then this was a flash, so eat it
  538.     $in_hookflash[$terminal] =~ s/hu/l/hf/i;
  539.     $_ = $in_hookflash[$terminal];
  540.     $in_hookflash[$terminal] = "";
  541.     $hookflash_timestamp[$terminal] = "";
  542.     &enqueue("i_gw", $_);
  543.     &enqueue("i_agent1", &renumber_S1("200 $transaction_id okn"));
  544.     $_ = "";
  545.     $hookflash[$terminal] = 0;
  546. }
  547.     } elsif(/no:.*hu/i) {
  548. # start of hookflash
  549. &debug("starting hookflashn");
  550. if($hookflash[$terminal]) {
  551.     # send pseudo-message to gateway
  552.     &debug("got hookflash startn");
  553.     &enqueue("i_agent1", &renumber_S1("200 $transaction_id okn"));
  554.     $unique = &unique();
  555.     &enqueue("i_agent1", "fake rqnt 65000 $terminal_name[$terminal] mgcp 0.1nR: l/hd(n)nx: $uniquen");
  556.     $in_hookflash[$terminal] = $_;
  557.     $_ = "";
  558.     $hookflash_timestamp[$terminal] = gettimeofday();
  559. }
  560.     }
  561. }
  562.     }
  565.     if(s/(v=0[00-377]*)$//) {
  567. $sdp = $1;
  569. print "got sdp; killed sdpn";
  571. $ip_address = "0.0.0.0"; $ip_port = 9;
  573. if($sdp =~ /ip4 ([0-9.]+)n/i) {
  574.     $ip_address = $1;
  575. }
  577. if($sdp =~/nm=audio ([0-9]+) /) {
  578.     $ip_port = $1;
  579. }
  581. if($terminal == 3) {
  582.     $_ .= "v=0no=aaln/1 2 0 IN IP4 $proxy_ipns=phonecallnc=IN IP4 $proxy_ipnm=audio $src{rtp3} rtp/avp 0na=rtpmap:96 G.711un";
  583.     $dest{"o_rtp4"} = "$ip_address:$ip_port";
  584.     &make_dest("o_rtp4");
  586. } elsif ($terminal == 4) {
  587.     $_ .= "v=0no=aaln/2 2 0 IN IP4 $proxy_ipns=phonecallnc=IN IP4 $proxy_ipnm=audio $src{rtp4} rtp/avp 0na=rtpmap:96 G.711un";
  588.     $dest{"o_rtp3"} = "$ip_address:$ip_port";
  589.     &make_dest("o_rtp3");
  591. }
  592.     }
  594.     
  595.     s/auep/AUEP/;
  596.     s/rqnt/RQNT/;
  597.     s/crcx/CRCX/;
  598.     s/mdcx/MDCX/;
  599.     s/dlcx/DLCX/;
  600.     s/mgcp/MGCP/;
  601.     s/*/ep1/;
  602.     
  603.     s/nO:/nO: /i;
  604.     s/nX:/nX: /i;
  605.     
  606.     s/hd/l/hd/;
  607.     s/hu/l/hu/;
  608.     
  609. #    s/,l/hf(n)//ig;
  610.     if(y///d) {
  611. &debug( "killed \0!n");
  612.     }
  613.     
  614.     s/ns+n/nn/g;
  615.     y/r//d;
  616.     s/n+$/n/;
  617.     s/nn$/n/g;
  618.     #    s/n+/n/g; 
  619.     s/n/rn/g;
  620.     if(s/([^rn])(rn)+$/$1rn/g) {
  621. &debug( "2 ate \r\nn");
  622.     }
  623.     
  624.     if(/^rqnt/i) {
  625. s/,d/x(n)//i;
  626.     }
  627.     
  628.     
  629.     if(/^crcx/i) {
  630. if(!/v=0/i) {
  631.     s/sendrecv/recvonly/;
  632. }
  633.     }
  634.     
  635.     s/RM:restart//;
  636.     
  637.     if($nosend) {
  638. &debug( "nosend:n$_----------n");
  639. $_ = "";
  640.     }
  642.     return $_;
  643. }
  645. sub debug {
  646.     if($debug) {
  647. print @_;
  648.     }
  649. }
  651. sub unique {
  652.     $unique_internal++;
  653. }