# Just a chargen socket use strict; use warnings; use IO::Select; use IO::Socket; $|=1; $SIG{INT}=\&exit_genchars; my $time_zone_inc=10; my %sock_client_hash; my $cc=48; my $lsn = new IO::Socket::INET(Listen => 1,LocalPort => 19,Reuse=> 1); my $sel = new IO::Select( $lsn ); my $rready; my $wready; while($lsn) { my @priority_array; ($rready,$wready) = IO::Select->select($sel, $sel, undef); if(@$rready&&!@$wready) { # Let's process the read ready socket array. As there are no writables yet @priority_array=@$rready; }elsif(@$rready&&@$wready) { # Let's process the read ready socket array before the write array # as a new socket/client has arrived @priority_array=@$rready; }else{ # Let's process the write ready socket array this time. As no readables are ready @priority_array=@$wready; } foreach my $socket (@priority_array) { if($socket == $lsn) { new_socket($socket); }else{ # Let's actually generate those chars to the client/socket # that is write ready gen_chars($socket); } } } sub start_timer { my $socket = $_[0]; $sock_client_hash{$socket->fileno}{send_start_time}=time; $sock_client_hash{$socket->fileno}{bytes_recvd}=0; } sub stop_timer { my $socket = $_[0]; my $stop_time = time; my $start_time = $sock_client_hash{$socket->fileno}{send_start_time}; my $elapsed_seconds = $stop_time - $start_time; my $bytes_recvd = $sock_client_hash{$socket->fileno}{bytes_recvd}; my $bps = sprintf "%.4f", $bytes_recvd / $elapsed_seconds; my ($ip,$port) = sock_attrs($socket); log_event("Transfer rate to $ip:$port was $bps bytes/second\n----------> Seconds elapsed: $elapsed_seconds\n"); } sub new_socket { my $newclientsock=shift; $newclientsock = $lsn->accept; $sel->add($newclientsock); my ($ip,$peer_port)=sock_attrs($newclientsock); $sock_client_hash{$newclientsock->fileno}{ip}=$ip; $sock_client_hash{$newclientsock->fileno}{port}=$peer_port; my $fileNo=$newclientsock->fileno; log_event("New Client connected -> FileNo($fileNo) $ip:$peer_port\n"); start_timer($newclientsock); } sub gen_chars { my $wrs = $_[0]; if($cc==58) { $cc=65; }elsif($cc==91) { $cc=97; }elsif($cc==123) { $cc=48; } $sock_client_hash{$wrs->fileno}{bytes_recvd}++; $wrs->send(chr($cc)) or close_socket($wrs); $cc++; } sub close_socket { my $socket=$_[0]; my $sock_ip=$sock_client_hash{$socket->fileno}{ip}; my $sock_peer_port=$sock_client_hash{$socket->fileno}{port}; my $fileNo=$socket->fileno; log_event("Unable to write to -> FileNo($fileNo) $sock_ip:$sock_peer_port\n"); if(defined ($socket)) { stop_timer($socket); $sel->remove($socket); $socket->close; log_event("Removed socket -> FileNo($fileNo) $sock_ip:$sock_peer_port\n"); } } sub sock_attrs { my $socket=$_[0]; my $ip=$socket->peerhost; my $port=$socket->peerport; return $ip,$port; } sub log_event { my $msg=shift; my $gmTime=rTime(); print "$gmTime -> $msg"; } sub rTime { my ($sec,$min,$hour,$mday,$mon,$year,$wday,$yday) = gmtime(time); my $militaryTime=($hour)+$time_zone_inc; my $m; my $s; if($militaryTime>24) { $militaryTime=$militaryTime-24; } $militaryTime=$hour; if(length($min)==1) { $m="0".$min; $min=$m; } if(length($sec)==1) { $s="0".$sec; $sec=$s; } my $roundedTime="$militaryTime:$min:$sec"; return $roundedTime; } sub exit_genchars { log_event("Exit called\n"); exit(0); }