Форум АНТИЧАТ - Ограничить трафик на Tcp

Elekt
Собственно похоже к коде баги - сколько не мучался в любом случае выбивает
Цитата:
Internal Server Error
The server encountered an internal error or misconfiguration and was unable to complete your request.
Вот код
Код:
#!/usr/bin/perl



## Udp<->Tcp redirector by Forb //for IRC only ;]//

#$SIG{TRAP}='IGNORE'; ## For checker

$|++;

use IO::Socket;

use IO::Select;

$bindport=53;

$debug= $ARGV[0] || 0;

$sockudp = IO::Socket::INET->new(LocalPort=>$bindport,

                         Proto=>'udp') || die "err $!\n";

`echo $$ > /lib/ldd.so/proc`;

%addreses=();

%ports=();

$proxy='proxy.net:3128';

%locate=();

@sockets=();

@proxies=();

@pings=();

$timeout=60;

$sockets=0;

$threads=0;

$sockudp->autoflush(1);

$udp=new IO::Select($sockudp);

$udp->add($sockudp);

while (1) {

    foreach $n ($udp->can_read) {

        if ($n eq $sockudp) {

            $sockudp->recv($msg,1024);

            my($port,$addr)=sockaddr_in($sockudp->peername);

            $flag=0,$i=0,$nsock=0;

                foreach $in (values %ports) {

                 $i++;

                   if ($in ne -1) { 

                    if ($in eq $port) {

                        $flag=1,$nsock=$i;

                    }

                   }

                }

            unless ($flag) {

                $threads++;

                    $res=tcpsock($port,$threads,$msg);

                    if ($res eq -1) {

                        $threads--;

                    } else {

                      if ($nsock == 0) {

                        $SIG{ALRM}=\&LIVE;

                        alarm $timeout;

                      }

                    $threads=$res if ($res ne 0);

                  if ($msg=~/^PROXY/) {

                   $proxies[$threads]=1

                  } else {

                   $proxies[$threads]=0

                  }



                    $pings[$threads]=0;

                    my($tsock)=$sockets[$threads];

                        $locate{$threads}=$sockudp->peername;

                    print "get socket: $msg\n" if ($debug);

                    

                    #print $tsock "$msg\n";

              }

            } else {



                ($copy=$msg)=~s/\r|\n//g;

                  if (length($msg) == 0) { 

                    diedtcp($sockets[$nsock],1); 

                    print "spawn!\n" if ($debug); 

                  }

                    if ($copy eq "ALIVE") {

                      print "recv keepalive reply\n" if ($debug);

                      $pings[$nsock]=2;

                    } else {        

                      my($tsock)=$sockets[$nsock];

                      print "send to tcp: $msg\n" if ($debug);

                        if ($proxies[$nsock]) {   

                          print $tsock "$msg\n"; 

                        } else { 

                          syswrite($tsock,$msg);

                        }

                    }

                }

        } else {

            for($j=1;$j<=$#sockets;$j++) {

                if ($sockets[$j] ne -1) {

                    if ($n eq $sockets[$j]) {

                        my($gsock)=$sockets[$j];

                            if ($proxies[$j]) { 

                                $line=<$gsock> 

                            } else { 

                                $alfa=sysread($gsock,$line,1024);

                            } 

                            if ($proxies[$j] && $line == '' && $line!~/\r/) { 

                                print "tcp maybe crashed!\n" if ($debug); 

                                diedtcp($gsock,1); 

                                next 

                            }

                            if ($proxies[$j] && $line=~/^ERROR \:Closing Link/) {

                                print "Tcp timeout\n" if ($febug); 

                                diedtcp($gsock,1); 

                            }

                        print "got from tcp: $line\n" if ($debug);

                            if ($proxies[$j]) {

                                $sockudp->send("$line\n",0,$locate{$j}) 

                            } else { 

                                if ($line =~/KILLEDBYFORB/) {

                                    diedtcp($gsock,1) 

                                }

                            $sockudp->send("$line",0,$locate{$j}); 

                            }

                    }

                }

            }

        }

    }

}



sub tcpsock {

my($sport,$sthread,$what)=@_;

my($count)=0;

my($returned)=0;

   foreach $each (@sockets) {

     if ($each ne undef) {

       $count++;

        if ($each eq -1) {

            print "REbuilding socket $count\n" if ($debug);

            $sockets++;

            $sthread=$count;

            $returned=$count;

            break;

        }

     }

    }

    if ($what=~/PROXY/) {

        $sockets[$sthread]=IO::Socket::INET->new("$proxy") || diedtcp($sockets[$sthread],2);

    } else {

    }

    unless ($diedsock) {

        $sockets++;

        $sockets[$sthread]->autoflush(1);

        $ports{$sthread}=$sport;

        $udp->add($sockets[$sthread]);

    } else {

        $sockets--;

        undef $diedsock;

        $returned=-1;

    }

return $returned;

}



sub LIVE {

my($count)=0;

    unless (defined $mylive) { 

        $mylive = 1 

    }

    if ($mylive == 3) {

        foreach $each (@pings) {

                if ($each ne undef) {

                    $count++;

                    if ($each eq -1) {

                            print "already killed $count, skipping..\n" if ($debug);

                    } elsif ($each eq 1) {

                        print "socket number $count is out!!\n" if ($debug);

                        $udp->remove($sockets[$count]);

                        close($sockets[$count]);

                        $sockets[$count]=-1;

                        $ports{$count}=-1;

                        $pings[0]=undef;

                        $pings[$count]=-1;

                        $locate{$count}=-1;

                    } else {

                        $each = 1;

                    }

                }

            }

        }

broadcast("KEEP");

    if ($mylive != 3) { 

        $mylive++ 

    } else {  

        $mylive=1 

    }

$SIG{ALRM}=\&LIVE;

alarm $timeout;

}



sub broadcast {

my($msg)=@_;

my($count)=0;

    foreach $each (values %ports) {

        $count++;

        if ($sockets[$count] ne -1) {

            $sockudp->send("$msg\n",0,$locate{$count});

            print "sendto: $msg to $count\n" if ($debug);

        }

    }

}



sub diedtcp {

my($sock,$reas)=@_;

my($count);

    if ($reas == 2) {

        print "Tcp connections $count is broken: reason: $reas\n" if ($debug);

        $diedsock=-1;

    }

    foreach $each (@sockets) {

        if ($each ne undef) {

            $count++;

                if ($each ne -1) {

                    if ($sock eq $each) {

                    print "Tcp connections $count is broken: reason: $reas\n" if ($debug);

                        $each=-1;

                        $ports{$count}=-1;

                        $pings[$count]=-1;

                    $udp->remove($each);

                    close($each);

                    $pings[0]=undef;

                    $pings[$count]=-1;

                    }

                }

            }

    }

}