Projet

Général

Profil

Révision fa1298bf

IDfa1298bfdef42a32716c30e1713c9bc14d292832
Parent 80dcbf72
Enfant c6222819

Ajouté par XciD il y a presque 12 ans

Add IP/Port

Voir les différences:

plugins/rtorrent/rtom_allsessions_spdd
40 40 
#
41 41 
# Configuration example
42 42 
#
43 
#       [rtom_spdd]
43 
#       [rtom_allsessions_*]
44 44 
#       user username
45 45 
#       env.src socket
46 
#       env.socket /home/user/torrent/.socket/rpc.socket,/home/user2/torrent/.socket/rpc2.socket
47 
#       env.category Sometext
46 
#       env.socket /home/user/torrent/.socket/rpc.socket,/home/user/torrent/.socket/rpc.socket
47 
#       env.category Category
48 48 
#
49 
#       [rtom_allsessions_*]
50 
#       user username
51 
#       env.port 5000,5001,5002,5003
52 
#       env.category Category
49 53 
#
50 54 
#%# family=auto
51 55 

  		




  ......




  82
  86
  
    
}


  		




  83
  87
  
    

  		




  84
  88
  
    
use IO::Socket;


  		




  85
  
  
    
my @sockets = split /,/, $ENV{"socket"} || "";


  		




  86
  89
  
    
my $src         = $ENV{"src"} || "";


  		




  
  90
  
    
my @sockets     = split /,/, $ENV{"socket"} || "";


  		




  
  91
  
    
my $ip          = $ENV{"ip"} || "127.0.0.1";


  		




  
  92
  
    
my @ports       = split /,/, $ENV{"port"} || "";


  		




  
  93
  
    

  		




  
  94
  
    
my $pattern     = qr/<value><(int|i4|i8|ex\.i8)>([-]{0,1}\d+)<\/(int|i4|i8|ex\.i8)><\/value>/;


  		




  
  95
  
    
my $line        = "<?xml version=\"1.0\" encoding=\"utf-8\"?><methodCall><methodName>system.multicall</methodName><params><param><value><array><data><value><struct><member><name>methodName</name><value><string>get_up_total</string></value></member><member><name>params</name><value><array><data/></array></value></member></struct></value><value><struct><member><name>methodName</name><value><string>get_down_total</string></value></member><member><name>params</name><value><array><data/></array></value></member></struct></value><value><struct><member><name>methodName</name><value><string>get_upload_rate</string></value></member><member><name>params</name><value><array><data/></array></value></member></struct></value><value><struct><member><name>methodName</name><value><string>get_download_rate</string></value></member><member><name>params</name><value><array><data/></array></value></member></struct></value></data></array></value></param></params></methodCall>";


  		




  
  96
  
    
my $llen        = length $line;


  		




  
  97
  
    
my $header      = "CONTENT_LENGTH\000${llen}\000SCGI\001\000";


  		




  
  98
  
    
my $hlen        = length $header;


  		




  87
  99
  
    

  		




  88
  100
  
    
my $up = -1;


  		




  89
  101
  
    
my $down = -1;


  		




  90
  102
  
    

  		




  91
  
  
    
for $socket (@sockets)


  		




  92
  
  
    
{


  		




  93
  
  
    
        my $pattern     = qr/<value><(int|i4|i8|ex\.i8)>([-]{0,1}\d+)<\/(int|i4|i8|ex\.i8)><\/value>/;


  		




  94
  
  
    
        my $line        = "<?xml version=\"1.0\" encoding=\"utf-8\"?><methodCall><methodName>system.multicall</methodName><params><param><value><array><data><value><struct><member><name>methodName</name><value><string>get_up_total</string></value></member><member><name>params</name><value><array><data/></array></value></member></struct></value><value><struct><member><name>methodName</name><value><string>get_down_total</string></value></member><member><name>params</name><value><array><data/></array></value></member></struct></value><value><struct><member><name>methodName</name><value><string>get_upload_rate</string></value></member><member><name>params</name><value><array><data/></array></value></member></struct></value><value><struct><member><name>methodName</name><value><string>get_download_rate</string></value></member><member><name>params</name><value><array><data/></array></value></member></struct></value></data></array></value></param></params></methodCall>";


  		




  95
  
  
    
        my $llen        = length $line;


  		




  96
  
  
    
        my $header      = "CONTENT_LENGTH\000${llen}\000SCGI\001\000";


  		




  97
  
  
    
        my $hlen        = length $header;


  		




  98
  
  
    
        $line           = "${hlen}:${header},${line}";


  		




  99
  
  
    
        if ( ( defined $src ) && ( $src eq "socket" ) ) {


  		




  100
  
  
    
                socket( SOCK, PF_UNIX, SOCK_STREAM, 0 );


  		




  101
  
  
    
                connect( SOCK, sockaddr_un( $socket ) );


  		




  102
  
  
    
        }


  		




  103
  
  
    

  		




  104
  
  
    
        print SOCK $line;


  		




  105
  
  
    
        flush SOCK;


  		




  106
  
  
    
        my $up_tmp = -1;


  		




  107
  
  
    
        my $down_tmp = -1;


  		




  108
  
  
    
        while (( $up_tmp == -1 ) && ( $line = <SOCK> ) ) {


  		




  109
  
  
    
                if ( $line =~ /$pattern/ ) {


  		




  110
  
  
    
                        $up_tmp = $2;


  		




  
  103
  
    
if ( ( defined $src ) && ( $src eq "socket" ) ) {


  		




  
  104
  
    
        for $socket (@sockets)


  		




  
  105
  
    
        {


  		




  
  106
  
    
                socket( SOCK, PF_UNIX, SOCK_STREAM, 0 ) or die;


  		




  
  107
  
    
                connect( SOCK, sockaddr_un( $socket ) ) or die $!;


  		




  
  108
  
    
                my $line = "${hlen}:${header},${line}";


  		




  
  109
  
    
                print SOCK $line;


  		




  
  110
  
    
                flush SOCK;


  		




  
  111
  
    
                my $up_tmp = -1;


  		




  
  112
  
    
                my $down_tmp = -1;


  		




  
  113
  
    
                while (( $up_tmp == -1 ) && ( $line = <SOCK> ) ) {


  		




  
  114
  
    
                        if ( $line =~ /$pattern/ ) {


  		




  
  115
  
    
                                $up_tmp = $2;


  		




  
  116
  
    
                        }


  		




  111
  117
  
    
                }


  		




  112
  
  
    
        }


  		




  113
  
  
    
        while (( $down_tmp == -1 ) && ( $line = <SOCK> ) ) {


  		




  114
  
  
    
                if ( $line =~ /$pattern/ ) {


  		




  115
  
  
    
                        $down_tmp = $2;


  		




  
  118
  
    
                while (( $down_tmp == -1 ) && ( $line = <SOCK> ) ) {


  		




  
  119
  
    
                        if ( $line =~ /$pattern/ ) {


  		




  
  120
  
    
                                $down_tmp = $2;


  		




  
  121
  
    
                        }


  		




  116
  122
  
    
                }


  		




  
  123
  
    
                close (SOCK);


  		




  
  124
  
    
                $up = $up + $up_tmp;


  		




  
  125
  
    
                $down = $down + $down_tmp;


  		




  
  126
  
    
        }        


  		




  
  127
  
    
} else {


  		




  
  128
  
    
        for $port (@ports)


  		




  
  129
  
    
        { 


  		




  
  130
  
    
                socket( SOCK, PF_INET, SOCK_STREAM, getprotobyname( "tcp" ) );


  		




  
  131
  
    
                connect( SOCK, sockaddr_in( $port, inet_aton( $ip ) ) );


  		




  
  132
  
    
                my $line = "${hlen}:${header},${line}";


  		




  
  133
  
    
                print SOCK $line;


  		




  
  134
  
    
                flush SOCK;


  		




  
  135
  
    
                my $up_tmp = -1;


  		




  
  136
  
    
                my $down_tmp = -1;


  		




  
  137
  
    
                while (( $up_tmp == -1 ) && ( $line = <SOCK> ) ) {


  		




  
  138
  
    
                        if ( $line =~ /$pattern/ ) {


  		




  
  139
  
    
                                $up_tmp = $2;


  		




  
  140
  
    
                        }


  		




  
  141
  
    
                }


  		




  
  142
  
    
                while (( $down_tmp == -1 ) && ( $line = <SOCK> ) ) {


  		




  
  143
  
    
                        if ( $line =~ /$pattern/ ) {


  		




  
  144
  
    
                                $down_tmp = $2;


  		




  
  145
  
    
                        }


  		




  
  146
  
    
                }


  		




  
  147
  
    
                close (SOCK);


  		




  
  148
  
    
                $up = $up + $up_tmp;


  		




  
  149
  
    
                $down = $down + $down_tmp;


  		




  117
  150
  
    
        }


  		




  118
  
  
    
        close (SOCK);


  		




  119
  
  
    
        $up = $up + $up_tmp;


  		




  120
  
  
    
        $down = $down + $down_tmp;


  		




  121
  151
  
    
}


  		




  
  152
  
    

  		




  
  153
  
    

  		




  
  154
  
    

  		




  122
  155
  
    
print "up.value ${up}\ndown.value ${down}\n";


  		




  123
  156
  
    

  		




  124
  157
  
    
exit;


  		












Formats disponibles :  Unified diff