#    if( threads::list( threads::running ) >= 100 ) {
#        sendResponse("Session rejected. Too many sessions currently running.\n", 101, $client); #just decided 101 should be the retry return code, no reason really
#        # tprint( "Session request by " . $client->sockhost() . " rejected" ); #disabled because it was flodding the log
#        $client->shutdown(2);
#        $client->close;
#    }else

##</code><code>##

our $T //= 1000;
our $R //= 1000;

my @threads;
for my $t ( 0 .. $T ){
    push @threads, async {
        for my $r ( 1 .. $R ) {
            print "Client:$t sending command: $r\n";
            my $server;
            my $rc;
            my $response;


            while(1){
                $server = IO::Socket::INET->new(
                                    Proto    => "tcp",
                                    PeerAddr => $address,
                                    PeerPort => $port,
                                );
                unless (defined($server)){print "Unable to connect to RXD; [$! / $^E\n";}
                $server->autoflush(1);

                sendCommand( $server );
                ($response, $rc) = receiveResponse( $server );
                if($rc == 101){
                    shutdown($server, 2);
                    close $server;
                    my $random = 1 + rand(10);
#                    select(undef, undef, undef, $random);
                    next;
                }
                else{last;}
            }

            debug("Closing connection");
            shutdown($server, 2);
            close $server;
        };
    };
}

$_->join for @threads;