From 121448e72d29963ec0964e67f09972edbbf26ac3 Mon Sep 17 00:00:00 2001 From: Sledge Sulaweyo Date: Tue, 10 Jul 2018 16:58:28 +0200 Subject: [PATCH] fix indentation, rename lagacy to pre09 --- plugins/rtorrent/rtom_allsessions_mem | 84 ++++++------ plugins/rtorrent/rtom_allsessions_peers | 164 ++++++++++++------------ plugins/rtorrent/rtom_allsessions_spdd | 150 +++++++++++----------- plugins/rtorrent/rtom_allsessions_vol | 140 ++++++++++---------- 4 files changed, 269 insertions(+), 269 deletions(-) diff --git a/plugins/rtorrent/rtom_allsessions_mem b/plugins/rtorrent/rtom_allsessions_mem index 1c83292b..9011b9d3 100755 --- a/plugins/rtorrent/rtom_allsessions_mem +++ b/plugins/rtorrent/rtom_allsessions_mem @@ -27,7 +27,7 @@ # ip rTorrent's ip address - using scgi_port - needed, when "src" is NOT set to "socket" # port rTorrent's scgi port (scgi_port) - using scgi_port - needed, when "src" is NOT set to "socket" # category Change graph category -# api use 'legacy' (pre 0.9.0) or current (0.9.0+) API calls +# api use 'pre09' (pre 0.9.0) or 'current' (0.9.0+) API calls # # Configuration example # @@ -47,20 +47,20 @@ if ( $ARGV[0] and $ARGV[0] eq "autoconf" ) { - exit 1; + exit 1; } if ( $ARGV[0] and $ARGV[0] eq "config" ) { - my $category = $ENV{"category"} || ""; - print "graph_title rTorrent memory usage\n"; - print "graph_args --base 1024 --lower-limit 0\n"; - print "graph_vlabel Bytes\n"; - print "graph_category filetransfer".${category}."\n"; - print "mem.label Memory usage\n"; - print "mem.info Memory usage of rTorrent\n"; - print "mem.type GAUGE\n"; - print "mem.draw LINE2\n"; - exit 0; + my $category = $ENV{"category"} || ""; + print "graph_title rTorrent memory usage\n"; + print "graph_args --base 1024 --lower-limit 0\n"; + print "graph_vlabel Bytes\n"; + print "graph_category filetransfer".${category}."\n"; + print "mem.label Memory usage\n"; + print "mem.info Memory usage of rTorrent\n"; + print "mem.type GAUGE\n"; + print "mem.draw LINE2\n"; + exit 0; } use IO::Socket; @@ -68,12 +68,12 @@ my $src = $ENV{"src"} || ""; my @sockets = split /,/, $ENV{"socket"} || ""; my $ip = $ENV{"ip"} || "127.0.0.1"; my @ports = split /,/, $ENV{"port"} || ""; -my $api = $ENV{"api"} || "legacy"; +my $api = $ENV{"api"} || "pre09"; my $mem = 0; my $pattern = qr/<(int|i4|i8|ex\.i8)>(\d+)<\/(int|i4|i8|ex\.i8)><\/value>/; my $line = ""; -if ($api =~ /legacy/) { +if ($api =~ /pre09/) { $line = "get_memory_usage"; } else { $line = "pieces.memory.current"; @@ -83,35 +83,35 @@ my $header = "CONTENT_LENGTH\000${llen}\000SCGI\001\000"; my $hlen = length $header; if ( ( defined $src ) && ( $src eq "socket" ) ) { - for $socket (@sockets) - { - socket( SOCK, PF_UNIX, SOCK_STREAM, 0 ) or die; - connect( SOCK, sockaddr_un( $socket ) ) or die $!; - my $line = "${hlen}:${header},${line}"; - print SOCK $line; - flush SOCK; - while ( $line = ) { - if ( $line =~ /$pattern/ ) { - $mem = $mem + $2; - } - } - close (SOCK); - } + for $socket (@sockets) + { + socket( SOCK, PF_UNIX, SOCK_STREAM, 0 ) or die; + connect( SOCK, sockaddr_un( $socket ) ) or die $!; + my $line = "${hlen}:${header},${line}"; + print SOCK $line; + flush SOCK; + while ( $line = ) { + if ( $line =~ /$pattern/ ) { + $mem = $mem + $2; + } + } + close (SOCK); + } } else { - for $port (@ports) - { - socket( SOCK, PF_INET, SOCK_STREAM, getprotobyname( "tcp" ) ); - connect( SOCK, sockaddr_in( $port, inet_aton( $ip ) ) ); - my $line = "${hlen}:${header},${line}"; - print SOCK $line; - flush SOCK; - while ( $line = ) { - if ( $line =~ /$pattern/ ) { - $mem = $mem + $2; - } - } - close (SOCK); - } + for $port (@ports) + { + socket( SOCK, PF_INET, SOCK_STREAM, getprotobyname( "tcp" ) ); + connect( SOCK, sockaddr_in( $port, inet_aton( $ip ) ) ); + my $line = "${hlen}:${header},${line}"; + print SOCK $line; + flush SOCK; + while ( $line = ) { + if ( $line =~ /$pattern/ ) { + $mem = $mem + $2; + } + } + close (SOCK); + } } print "mem.value ${mem}\n"; diff --git a/plugins/rtorrent/rtom_allsessions_peers b/plugins/rtorrent/rtom_allsessions_peers index e0ea4532..3e01b4a8 100755 --- a/plugins/rtorrent/rtom_allsessions_peers +++ b/plugins/rtorrent/rtom_allsessions_peers @@ -17,15 +17,15 @@ # # Parameters: # -# config required +# config required # # # Configurable variables # -# src "socket" when using scgi_socket, or anything else when using scgi_port -# socket rTorrent's rpc socket (scgi_local) - using scgi_local - needed, when "src" is set to "socket" -# category Change graph category -# api use 'legacy' (pre 0.9.0) or current (0.9.0+) API calls +# src "socket" when using scgi_socket, or anything else when using scgi_port +# socket rTorrent's rpc socket (scgi_local) - using scgi_local - needed, when "src" is set to "socket" +# category Change graph category +# api use 'pre09' (pre 0.9.0) or 'current' (0.9.0+) API calls # # Configuration example # @@ -45,31 +45,31 @@ if ( $ARGV[0] and $ARGV[0] eq "autoconf" ) { - exit 1; + exit 1; } if ( $ARGV[0] and $ARGV[0] eq "config" ) { - my $category = $ENV{"category"} || ""; - print "graph_title rTorrent peer statistics\n"; - print "graph_args --base 1000 --lower-limit 0\n"; - print "graph_vlabel peers\n"; - print "graph_category filetransfer".${category}."\n"; - print "outgoing.label outgoing\n"; - print "outgoing.draw AREA\n"; - print "outgoing.info number of outgoing connections\n"; - print "incoming.label incoming\n"; - print "incoming.draw STACK\n"; - print "incoming.info number of incoming connections\n"; - print "plain.label plain text\n"; - print "plain.draw LINE2\n"; - print "plain.info number of plain text connections\n"; - print "encrypted.label encrypted\n"; - print "encrypted.draw LINE2\n"; - print "encrypted.info number of encrypted connections\n"; - print "total.label total\n"; - print "total.draw LINE2\n"; - print "total.info total number of connections\n"; - exit 0; + my $category = $ENV{"category"} || ""; + print "graph_title rTorrent peer statistics\n"; + print "graph_args --base 1000 --lower-limit 0\n"; + print "graph_vlabel peers\n"; + print "graph_category filetransfer".${category}."\n"; + print "outgoing.label outgoing\n"; + print "outgoing.draw AREA\n"; + print "outgoing.info number of outgoing connections\n"; + print "incoming.label incoming\n"; + print "incoming.draw STACK\n"; + print "incoming.info number of incoming connections\n"; + print "plain.label plain text\n"; + print "plain.draw LINE2\n"; + print "plain.info number of plain text connections\n"; + print "encrypted.label encrypted\n"; + print "encrypted.draw LINE2\n"; + print "encrypted.info number of encrypted connections\n"; + print "total.label total\n"; + print "total.draw LINE2\n"; + print "total.info total number of connections\n"; + exit 0; } use IO::Socket; @@ -78,20 +78,20 @@ my $src = $ENV{"src"} || ""; my @sockets = split /,/, $ENV{"socket"} || ""; my $ip = $ENV{"ip"} || "127.0.0.1"; my @ports = split /,/, $ENV{"port"} || ""; -my $api = $ENV{"api"} || "legacy"; +my $api = $ENV{"api"} || "pre09"; -my $pattern = qr/<(int|i4|i8|ex\.i8)>(\d+)<\/(int|i4|i8|ex\.i8)><\/value>/; -my $tpattern = qr/[0-9A-F]{20}/; +my $pattern = qr/<(int|i4|i8|ex\.i8)>(\d+)<\/(int|i4|i8|ex\.i8)><\/value>/; +my $tpattern = qr/[0-9A-F]{20}/; my $line = ""; -if ($api =~ /legacy/) { +if ($api =~ /pre09/) { $line = "d.multicallmaind.get_hash=p.multicall=,p.is_encrypted=,p.is_incoming="; } else { $line = "d.multicall2maind.hash=p.multicall=,p.is_encrypted=,p.is_incoming="; } -my $llen = length $line; -my $header = "CONTENT_LENGTH\000${llen}\000SCGI\001\000"; -my $hlen = length $header; +my $llen = length $line; +my $header = "CONTENT_LENGTH\000${llen}\000SCGI\001\000"; +my $hlen = length $header; my $tor = 0; my $tot = 0; @@ -104,55 +104,55 @@ my $pla = 0; if ( ( defined $src ) && ( $src eq "socket" ) ) { - for $socket (@sockets) - { - socket( SOCK, PF_UNIX, SOCK_STREAM, 0 ) or die; - connect( SOCK, sockaddr_un( $socket ) ) or die $!; - my $line = "${hlen}:${header},${line}"; - print SOCK $line; - flush SOCK; - while ( $line = ) { - if ( $line =~ /$tpattern/ ) { - $tor += 1; - } elsif ( $line =~ /$pattern/ ) { - $tot += 1; - $enc += $2; - $line = ; - $line =~ /$pattern/; - $inc += $2; - } - $ppline = $pline; - $pline = $line; - } - close (SOCK); - $out = $out + $tot - $inc; - $pla = $pla + $tot - $enc; - } + for $socket (@sockets) + { + socket( SOCK, PF_UNIX, SOCK_STREAM, 0 ) or die; + connect( SOCK, sockaddr_un( $socket ) ) or die $!; + my $line = "${hlen}:${header},${line}"; + print SOCK $line; + flush SOCK; + while ( $line = ) { + if ( $line =~ /$tpattern/ ) { + $tor += 1; + } elsif ( $line =~ /$pattern/ ) { + $tot += 1; + $enc += $2; + $line = ; + $line =~ /$pattern/; + $inc += $2; + } + $ppline = $pline; + $pline = $line; + } + close (SOCK); + $out = $out + $tot - $inc; + $pla = $pla + $tot - $enc; + } } else { - for $port (@ports) - { - socket( SOCK, PF_INET, SOCK_STREAM, getprotobyname( "tcp" ) ); - connect( SOCK, sockaddr_in( $port, inet_aton( $ip ) ) ); - my $line = "${hlen}:${header},${line}"; - print SOCK $line; - flush SOCK; - while ( $line = ) { - if ( $line =~ /$tpattern/ ) { - $tor += 1; - } elsif ( $line =~ /$pattern/ ) { - $tot += 1; - $enc += $2; - $line = ; - $line =~ /$pattern/; - $inc += $2; - } - $ppline = $pline; - $pline = $line; - } - close (SOCK); - $out = $out + $tot - $inc; - $pla = $pla + $tot - $enc; - } + for $port (@ports) + { + socket( SOCK, PF_INET, SOCK_STREAM, getprotobyname( "tcp" ) ); + connect( SOCK, sockaddr_in( $port, inet_aton( $ip ) ) ); + my $line = "${hlen}:${header},${line}"; + print SOCK $line; + flush SOCK; + while ( $line = ) { + if ( $line =~ /$tpattern/ ) { + $tor += 1; + } elsif ( $line =~ /$pattern/ ) { + $tot += 1; + $enc += $2; + $line = ; + $line =~ /$pattern/; + $inc += $2; + } + $ppline = $pline; + $pline = $line; + } + close (SOCK); + $out = $out + $tot - $inc; + $pla = $pla + $tot - $enc; + } } diff --git a/plugins/rtorrent/rtom_allsessions_spdd b/plugins/rtorrent/rtom_allsessions_spdd index 26e51435..d608dd78 100755 --- a/plugins/rtorrent/rtom_allsessions_spdd +++ b/plugins/rtorrent/rtom_allsessions_spdd @@ -36,7 +36,7 @@ # src "socket" when using scgi_socket, or anything else when using scgi_port # socket rTorrent's rpc socket (scgi_local) - using scgi_local - needed, when "src" is set to "socket" # diff "yes" for using bps for upload and Bps for download, or anything else for using Bps for both -# api use 'legacy' (pre 0.9.0) or current (0.9.0+) API calls +# api use 'pre09' (pre 0.9.0) or 'current' (0.9.0+) API calls # # # Configuration example @@ -46,7 +46,7 @@ # env.src socket # env.socket /home/user/torrent/.socket/rpc.socket,/home/user/torrent/.socket/rpc.socket # env.category Category -# env.api current +# env.api pre09 # # [rtom_allsessions_*] # user username @@ -57,34 +57,34 @@ if ( $ARGV[0] and $ARGV[0] eq "autoconf" ) { - exit 1; + exit 1; } if ( $ARGV[0] and $ARGV[0] eq "config" ) { - my $diff = $ENV{"diff"} || ""; - my $category = $ENV{"category"} || ""; - print "graph_order down up\n"; - print "graph_title rTorrent speeds\n"; - print "graph_args --base 1024\n"; - print "graph_vlabel Bytes per \${graph_period}\n"; - print "graph_category filetransfer".${category}."\n"; - print "down.label Download B/s\n"; - print "down.info Download speed in Bytes per seconds\n"; - print "down.type DERIVE\n"; - print "down.min 0\n"; - print "down.draw AREA\n"; - if ( ( defined $diff ) && ( $diff eq "yes" ) ) { - print "up.label Upload b/s\n"; - print "up.info Upload speed in bits per seconds\n"; - print "up.cdef up,8,*\n"; - } else { - print "up.label Upload B/s\n"; - print "up.info Upload speed in Bytes per seconds\n"; - } - print "up.type DERIVE\n"; - print "up.min 0\n"; - print "up.draw LINE2\n"; - exit 0; + my $diff = $ENV{"diff"} || ""; + my $category = $ENV{"category"} || ""; + print "graph_order down up\n"; + print "graph_title rTorrent speeds\n"; + print "graph_args --base 1024\n"; + print "graph_vlabel Bytes per \${graph_period}\n"; + print "graph_category filetransfer".${category}."\n"; + print "down.label Download B/s\n"; + print "down.info Download speed in Bytes per seconds\n"; + print "down.type DERIVE\n"; + print "down.min 0\n"; + print "down.draw AREA\n"; + if ( ( defined $diff ) && ( $diff eq "yes" ) ) { + print "up.label Upload b/s\n"; + print "up.info Upload speed in bits per seconds\n"; + print "up.cdef up,8,*\n"; + } else { + print "up.label Upload B/s\n"; + print "up.info Upload speed in Bytes per seconds\n"; + } + print "up.type DERIVE\n"; + print "up.min 0\n"; + print "up.draw LINE2\n"; + exit 0; } use IO::Socket; @@ -92,11 +92,11 @@ my $src = $ENV{"src"} || ""; my @sockets = split /,/, $ENV{"socket"} || ""; my $ip = $ENV{"ip"} || "127.0.0.1"; my @ports = split /,/, $ENV{"port"} || ""; -my $api = $ENV{"api"} || "legacy"; +my $api = $ENV{"api"} || "pre09"; my $pattern = qr/<(int|i4|i8|ex\.i8)>([-]{0,1}\d+)<\/(int|i4|i8|ex\.i8)><\/value>/; my $line = ""; -if ($api =~ /legacy/) { +if ($api =~ /pre09/) { $line = "system.multicallmethodNameget_up_totalparamsmethodNameget_down_totalparamsmethodNameget_upload_rateparamsmethodNameget_download_rateparams"; } else { $line = "system.multicallmethodNamethrottle.global_up.totalparamsmethodNamethrottle.global_down.totalparamsmethodNamethrottle.global_up.max_rateparamsmethodNamethrottle.global_down.max_rateparams"; @@ -110,53 +110,53 @@ my $up = -1; my $down = -1; if ( ( defined $src ) && ( $src eq "socket" ) ) { - for $socket (@sockets) - { - socket( SOCK, PF_UNIX, SOCK_STREAM, 0 ) or die; - connect( SOCK, sockaddr_un( $socket ) ) or die $!; - my $line = "${hlen}:${header},${line}"; - print SOCK $line; - flush SOCK; - my $up_tmp = -1; - my $down_tmp = -1; - while (( $up_tmp == -1 ) && ( $line = ) ) { - if ( $line =~ /$pattern/ ) { - $up_tmp = $2; - } - } - while (( $down_tmp == -1 ) && ( $line = ) ) { - if ( $line =~ /$pattern/ ) { - $down_tmp = $2; - } - } - close (SOCK); - $up = $up + $up_tmp; - $down = $down + $down_tmp; - } + for $socket (@sockets) + { + socket( SOCK, PF_UNIX, SOCK_STREAM, 0 ) or die; + connect( SOCK, sockaddr_un( $socket ) ) or die $!; + my $line = "${hlen}:${header},${line}"; + print SOCK $line; + flush SOCK; + my $up_tmp = -1; + my $down_tmp = -1; + while (( $up_tmp == -1 ) && ( $line = ) ) { + if ( $line =~ /$pattern/ ) { + $up_tmp = $2; + } + } + while (( $down_tmp == -1 ) && ( $line = ) ) { + if ( $line =~ /$pattern/ ) { + $down_tmp = $2; + } + } + close (SOCK); + $up = $up + $up_tmp; + $down = $down + $down_tmp; + } } else { - for $port (@ports) - { - socket( SOCK, PF_INET, SOCK_STREAM, getprotobyname( "tcp" ) ); - connect( SOCK, sockaddr_in( $port, inet_aton( $ip ) ) ); - my $line = "${hlen}:${header},${line}"; - print SOCK $line; - flush SOCK; - my $up_tmp = -1; - my $down_tmp = -1; - while (( $up_tmp == -1 ) && ( $line = ) ) { - if ( $line =~ /$pattern/ ) { - $up_tmp = $2; - } - } - while (( $down_tmp == -1 ) && ( $line = ) ) { - if ( $line =~ /$pattern/ ) { - $down_tmp = $2; - } - } - close (SOCK); - $up = $up + $up_tmp; - $down = $down + $down_tmp; - } + for $port (@ports) + { + socket( SOCK, PF_INET, SOCK_STREAM, getprotobyname( "tcp" ) ); + connect( SOCK, sockaddr_in( $port, inet_aton( $ip ) ) ); + my $line = "${hlen}:${header},${line}"; + print SOCK $line; + flush SOCK; + my $up_tmp = -1; + my $down_tmp = -1; + while (( $up_tmp == -1 ) && ( $line = ) ) { + if ( $line =~ /$pattern/ ) { + $up_tmp = $2; + } + } + while (( $down_tmp == -1 ) && ( $line = ) ) { + if ( $line =~ /$pattern/ ) { + $down_tmp = $2; + } + } + close (SOCK); + $up = $up + $up_tmp; + $down = $down + $down_tmp; + } } diff --git a/plugins/rtorrent/rtom_allsessions_vol b/plugins/rtorrent/rtom_allsessions_vol index fe99af9b..3dac5aa8 100755 --- a/plugins/rtorrent/rtom_allsessions_vol +++ b/plugins/rtorrent/rtom_allsessions_vol @@ -3,7 +3,7 @@ # xmlrpc based munin plugin for monitoring rtorrent's torrent count # prerequisites: # - rtorrent 0.7.5 or newer compiled with --with-xmlrpc-c -# check http://libtorrent.rakshasa.no/wiki/RTorrentXMLRPCGuide for further informations +# check http://libtorrent.rakshasa.no/wiki/RTorrentXMLRPCGuide for further information # # written by Gabor Hudiczius # web: http://projects.cyla.homeip.net/rtwi/wiki/rTorrentOMeter @@ -25,7 +25,7 @@ # src "socket" when using scgi_socket, or anything else when using scgi_port # socket rTorrent's rpc socket (scgi_local) - using scgi_local - needed, when "src" is set to "socket" # category Change graph category -# api use 'legacy' (pre 0.9.0) or current (0.9.0+) API calls +# api use 'pre09' (pre 0.9.0) or 'current' (0.9.0+) API calls # # Configuration example # @@ -40,41 +40,41 @@ # user username # env.port 5000,5001,5002,5003 # env.category Category -# env.api legacy +# env.api pre09 # #%# family=auto my @views = ( "default", "started", "stopped", "complete", "incomplete" ); if ( $ARGV[0] and $ARGV[0] eq "autoconf" ) { - exit 1; + exit 1; } if ( $ARGV[0] and $ARGV[0] eq "config" ) { - my $category = $ENV{"category"} || ""; - print "graph_args --base 1000 -r --lower-limit 0\n"; - print "graph_title rTorrent volume\n"; - print "graph_vlabel active torrents\n"; - print "graph_category torrent ".${category}."\n"; - print "complete.label complete\n"; - print "complete.draw AREA\n"; - print "complete.info complete torrents\n"; - print "incomplete.label incomplete\n"; - print "incomplete.draw STACK\n"; - print "incomplete.info incomplete torrents\n"; - print "stopped.label stopped\n"; - print "stopped.draw LINE2\n"; - print "stopped.info stopped torrents\n"; - print "started.label started\n"; - print "started.draw LINE2\n"; - print "started.info started torrents\n"; - print "default.label total\n"; - print "default.draw LINE2\n"; - print "default.info all torrents\n"; - print "hashing.graph no\n"; - print "seeding.graph no\n"; - print "active.graph no\n"; - exit 0; + my $category = $ENV{"category"} || ""; + print "graph_args --base 1000 -r --lower-limit 0\n"; + print "graph_title rTorrent volume\n"; + print "graph_vlabel active torrents\n"; + print "graph_category torrent ".${category}."\n"; + print "complete.label complete\n"; + print "complete.draw AREA\n"; + print "complete.info complete torrents\n"; + print "incomplete.label incomplete\n"; + print "incomplete.draw STACK\n"; + print "incomplete.info incomplete torrents\n"; + print "stopped.label stopped\n"; + print "stopped.draw LINE2\n"; + print "stopped.info stopped torrents\n"; + print "started.label started\n"; + print "started.draw LINE2\n"; + print "started.info started torrents\n"; + print "default.label total\n"; + print "default.draw LINE2\n"; + print "default.info all torrents\n"; + print "hashing.graph no\n"; + print "seeding.graph no\n"; + print "active.graph no\n"; + exit 0; } use IO::Socket; @@ -83,54 +83,54 @@ my $src = $ENV{"src"} || ""; my @sockets = split /,/, $ENV{"socket"} || ""; my $ip = $ENV{"ip"} || "127.0.0.1"; my @ports = split /,/, $ENV{"port"} || ""; -my $api = $ENV{"api"} || "legacy"; +my $api = $ENV{"api"} || "pre09"; my $pattern = qr/([A-Z0-9]+)<\/string><\/value>/; foreach ( @views ) { - my $num = 0; - my $line = ""; - if ($api =~ /legacy/) { - $line = "d.multicall${_}d.get_hash="; - } else { - $line = "d.multicall2${_}d.hash="; - } - my $llen = length $line; - my $header = "CONTENT_LENGTH\000${llen}\000SCGI\001\000"; - my $hlen = length $header; + my $num = 0; + my $line = ""; + if ($api =~ /pre09/) { + $line = "d.multicall${_}d.get_hash="; + } else { + $line = "d.multicall2${_}d.hash="; + } + my $llen = length $line; + my $header = "CONTENT_LENGTH\000${llen}\000SCGI\001\000"; + my $hlen = length $header; - if ( ( defined $src ) && ( $src eq "socket" ) ) { - for $socket (@sockets) - { - socket( SOCK, PF_UNIX, SOCK_STREAM, 0 ) or die; - connect( SOCK, sockaddr_un( $socket ) ) or die $!; - my $line = "${hlen}:${header},${line}"; - print SOCK $line; - flush SOCK; - while ( $line = ) { - if ( $line =~ /$pattern/ ) { - $num++; - } - } - close (SOCK); - } - } else { - for $port (@ports) - { - socket( SOCK, PF_INET, SOCK_STREAM, getprotobyname( "tcp" ) ); - connect( SOCK, sockaddr_in( $port, inet_aton( $ip ) ) ); - my $line = "${hlen}:${header},${line}"; - print SOCK $line; - flush SOCK; - while ( $line = ) { - if ( $line =~ /$pattern/ ) { - $num++; - } - } - close (SOCK); - } + if ( ( defined $src ) && ( $src eq "socket" ) ) { + for $socket (@sockets) + { + socket( SOCK, PF_UNIX, SOCK_STREAM, 0 ) or die; + connect( SOCK, sockaddr_un( $socket ) ) or die $!; + my $line = "${hlen}:${header},${line}"; + print SOCK $line; + flush SOCK; + while ( $line = ) { + if ( $line =~ /$pattern/ ) { + $num++; } - print "${_}.value ${num}\n"; + } + close (SOCK); + } + } else { + for $port (@ports) + { + socket( SOCK, PF_INET, SOCK_STREAM, getprotobyname( "tcp" ) ); + connect( SOCK, sockaddr_in( $port, inet_aton( $ip ) ) ); + my $line = "${hlen}:${header},${line}"; + print SOCK $line; + flush SOCK; + while ( $line = ) { + if ( $line =~ /$pattern/ ) { + $num++; + } + } + close (SOCK); + } + } + print "${_}.value ${num}\n"; } exit;