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;