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

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

流媒体/Mpeg4/MP4

开发平台：

C/C++

proxy-2600：源码内容
  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/>.
  52. use Socket;
  53. require "getopts.pl";
  55. &Getopts("n:");
  57. $number = $opt_n;
  59. if($#ARGV < 1) {
  60. #  print "Usage:n";
  61. #  print "$0 a:b:c d:e:f gn";
  62. #  print "where,n";
  63. #  print "a = agent host e.g. 192.168.5.1n";
  64. #  print "b = gateway sends to this port e.g. 2427n";
  65. #  print "c = agent listens to this port e.g. 5010n";
  66. #  print "d = gateway host e.g. 192.168.5.171n";
  67. #  print "e = agent sends to this port e.g. 5050n";
  68. #  print "f = gateway listens to this port e.g. 2427n";
  69. #  print "g = filter filen";
  70. #  print "e.g.n$0 192.168.22.17:2427:5011 192.168.5.146:5051:2427n";
  71. #  exit(-1);
  72.   $ARGV[0] = "172.19.175.195:2427:5011";
  73.   $ARGV[1] = "172.19.175.222:5051:2427";
  74. }
  76. open(F, $ARGV[0]);
  77. while(<F>) {
  78.   chomp;
  79.   if(/^listener/) {
  80.     #listener  name        port     filter            default-sender
  81.     ($file, $in_name, $in_port, $in_filter_name, $in_default_sender) = split(/s+/);
  82.     &mksocket($in_port, "IN_$in_name");
  84.     $in_port{$in_name} = $in_port;
  85.     $in_filter{$in_name} = $in_filter_name;
  86.     $in_sender{$in_name} = $in_default_sender;
  88.     
  89.   } elsif(/^sender/) {
  90.     #sender   sender-name   destination-ip   destination-port   listener-name
  92.     ($file, $in_name, $in_port, $in_filter_name, $in_default_sender) = split(/s+/);
  93.   }
  95. }
  96. close(F);
  99. ($host1, $local_port1, $remote_port1) = split(/:/, $ARGV[0]);
  100. ($host2, $local_port2, $remote_port2) = split(/:/, $ARGV[1]);
  102. &mksocket($local_port1, S1);
  103. &mksocket($local_port2, S2);
  105. ($name,$aliases,$type,$len,$host1_addr) = gethostbyname($host1);
  106. ($name,$aliases,$type,$len,$host2_addr) = gethostbyname($host2);
  108. $them_S1 = pack($sockaddr,PF_INET, $remote_port1, $host1_addr);
  109. $them_S2 = pack($sockaddr,PF_INET, $remote_port2, $host2_addr);
  111. # ($name,$aliases,$type,$len,$host3_addr) = gethostbyname("192.168.5.1");
  112. # $them_agent1 = pack($sockaddr,PF_INET, "5012", $host3_addr);
  113. # $them_agent2= pack($sockaddr,PF_INET, "5011", $host3_addr);
  115. sub mksocket {
  116.   local($port, $socket) = @_;
  117.   
  118.   $sockaddr = "S n a4 x8";($name,$aliases,$proto) = getprotobyname('udp');
  119.   chomp($hostname  = `hostname`);
  120.   #$hostname  = "192.168.10.12";
  121.   
  122.   ($name,$aliases,$type,$len,$myaddr) = gethostbyname($hostname);
  123.   
  124.   $me   = pack($sockaddr,PF_INET, $port, $myaddr);
  125.   
  126.   print "myaddr: $myaddrn";
  127.   print "port: $portn";
  128.   
  129.   socket($socket, PF_INET, SOCK_DGRAM, $proto) || die $!;
  130.   bind($socket , $me) || die "died with port $port $!";
  131.   
  132. }
  135. while(1) {
  136.   $rin = '';
  137.   vec($rin, fileno(S1), 1) = 1;
  138.   vec($rin, fileno(S2), 1) = 1;
  139.   #        @bits = split(//, unpack("b*", $rin));
  140.   # if($bits[fileno(S)]) {
  141.   # print "got Sn";
  142.   # }
  143.   if(select($rin, undef, undef, undef)) {
  144.     @bits = split(//, unpack("b*", $rin));
  145.     undef($data);
  146.     undef($new_data);
  147.     if($bits[fileno(S1)]) {
  148.       print "got S1n";
  149.       $data = "";
  150.       $his_address = recv(S1, $data, 60000, 0);
  151.       if($data) {
  152. print "-----------------------------n";
  153. print "$data";
  154. print "-----------------------------n";
  155.         $new_data = &rewrite_S1($data);
  156.         if($new_data) {
  157.   print "$new_data";
  158.   print "-----------------------------n";
  159.   defined(send(S2,$new_data,0,$them_S1)) || die $!;
  160.         }
  161.       }
  162.     } elsif($bits[fileno(S2)]) {
  163.       print "got S2n";
  164.       $data = "";
  165.       $his_address = recv(S2, $data, 60000, 0);
  166.       if($data) {
  167. print "-----------------------------n";
  168. print "$data";
  169. print "-----------------------------n";
  170.         $new_data = &rewrite_S2($data);
  171.         if($new_data) {
  172.   print "$new_data";
  173.   print "-----------------------------n";
  174.   defined(send(S1,$new_data,0,$them_S2)) || die $!;
  175.         }
  176.       }
  177.     }
  178.   }
  179. }
  180. #$them = pack($sockaddr,PF_INET, $port, $myaddr);
  181. #send(S,$msg,0,$them) || die $!;
  184. sub renumber_S2 {
  185.   local($_) = $_[0];
  186.   
  187.   s/^([0-9]*)s([0-9]*)s/$1 $map{$2} /;
  188.   $map{$number} = $2;
  189.   
  190.   return $_;
  191. }
  194. sub renumber_S1 {
  195.   local($_) = $_[0];
  196.   if(s/^([a-zA-Z]*)s([0-9]*)s/$1 $number /) {
  197.     $map{$number} = $2;
  198.     $number++;
  199.   }
  200.   return $_;
  201. }
  204. # incoming messages to the call agent
  205. sub rewrite_S1
  206. {
  207.   local($_) = $_[0];
  208. #  if(y///d) {
  209. #    print "killed \0!n";
  210. #  }
  212.   # pretend a wild card is actually for the first endpoint
  213. #  s/*@ubr/aaln/0@ubr/;
  214.   # Use _ instead of / due to parsing problems (also change ubr924 to galileo)
  216.   # split up dialed digits
  217. #  s/O: D/9/o: d/5,d/0,d/0,d//;
  218. #  s/O: D/9([0-9])([0-9])([0-9])([0-9])([0-9])([0-9])([0-9])/o: d/9,d/1,d/2,d/3,d/4,d/5,d/6,d/7/;
  219. #  s/O: D/([0-9])([0-9])([0-9])([0-9])/o: d/1,d/2,d/3,d/4/;
  221. #  s/*@MGCP-2600.private.vovida.com/6243@192.168.22.17/g;
  222. #  s/*@MGCP-2600.private.vovida.com/aaln/S1/SU0/0@MGCP-2600.private.vovida.com/g;
  224. #  s/aaln/S1/SU0/0@MGCP-2600.private.vovida.com/6243@192.168.22.17/g;  
  225. #  s/aaln/S1/SU0/1@MGCP-2600.private.vovida.com/5501@192.168.22.17/g;
  226.    
  227.    return $_;
  228. }
  231. # outgoing messages to the MGCP gateways
  232. sub rewrite_S2 
  233. {
  234.   local($_) = $_[0];
  235.  if(y///d)
  236.   {
  237.     print "killed \0!n";
  238.   }
  241.   # Change _ back to /   (also change galileo back to ubr924)
  243.   # change the use of wildcard x to explicit [0-9#*T], but it T needed here?
  244.   s/d/x(d)/d/[0-9#*T](D)/;
  247. #  s/d/x(n)/d/[0-9#*](n)/; 
  248. #  if (/crcx/)
  249. #  {
  250. #      if (!/v=0/)
  251. #      {
  252. #          s/M: sendrecv/M: recvonly/;
  253. #      }
  254. #  }
  256. #  s/rnrn/rn/g;
  257. #
  258. #  if (/mdcx/)
  259. #  {
  260. #      s/v=0/rnv=0/;
  261. #  }
  262. #  if(/RQNT/)
  263. #  {
  264. #    s/S: l/dl/S: l/wt/g;
  265. #   }
  267. #
  268. #s/o=- 0 0 IN IP4 192.168.22.17rns=Vovida Gatewayrn//;
  270. #s/o=CiscoSystemsSIP-GW-UserAgent [0-9]+ [0-9]+ IN IP4 192.168.6.210rns=SIP Callrn//;
  272. #s/o=[^rn]*r?n[^rn]*r?n//g;
  273. #s/s=[^rn]*r?n//g;
  275.  #changes here 
  276. #  s/IN IP4 hera.private.vovida.com/IN IP4 192.168.22.17/g;
  277. #  s/2600@192.168.5.146/*@MGCP-2600.private.vovida.com/g;
  278. # s/6243@192.168.22.17/aaln/S1/SU0/0@MGCP-2600.private.vovida.com/g;
  279. #  s/5501@192.168.22.17/aaln/S1/SU0/1@MGCP-2600.private.vovida.com/g;
  280.    
  281.    s/a=fmtp*r?n[^rn]*r?n//g;
  282.    s/a=fmtp:101 0-11//g;
  283.    s/a=fmtp:100 0-11//g;
  285.   return $_;
  287. }