Adding upstream version 0.1.10+dfsg.upstream/0.1.10+dfsgupstream

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

2 files changed, 227 insertions, 0 deletions

diff --git a/tools/all_bytes b/tools/all_bytes
new file mode 100644
index 0000000..c866266
--- /dev/null
+++ b/tools/all_bytes
diff --git a/tools/talk_to_sz.pl b/tools/talk_to_sz.pl
new file mode 100755
index 0000000..8357a01
--- /dev/null
+++ b/tools/talk_to_sz.pl
@@ -0,0 +1,227 @@
+#!/usr/bin/env perl
+
+use strict;
+use warnings;
+use autodie;
+
+use constant CANCEL_BYTES => (
+    ((24) x 5),
+    ((8) x 5),
+    #0,
+);
+
+use constant ZCAN_BYTES => (
+    42, 42, 24, 66, 49, 48, 48, 48, 48, 48, 48, 48, 48, 48, 48, 52, 53, 97, 13, 10, 17
+);
+
+use constant VERBOSE => '-vvvvvvvvvvvv';
+
+use feature 'say';
+
+use IO::Poll ();
+use File::Temp ();
+use File::Which ();
+use Text::Control ();
+
+my $COMMAND = 'sz';
+
+#my @verbose_flags = ( VERBOSE() );
+my @verbose_flags = ();
+
+my $size = 2**24;
+
+my $file_content = ('x' x $size) . '=THE END';
+
+my $cmd_path = File::Which::which($COMMAND) or die "Need “$COMMAND”!";
+
+#$cmd_path = '/Users/felipe/code/lrzsz/src/lsz';
+
+my ($tfh, $tpath) = File::Temp::tempfile( CLEANUP => 1 );
+print "temp file path: $tpath\n";
+syswrite $tfh, $file_content;
+close $tfh;
+
+pipe( my $pr, my $cw );
+pipe( my $cr, my $pw );
+my $pid = fork or do {
+    close $_ for ($pr, $pw);
+    open \*STDIN, '<&=', $cr;
+    open \*STDOUT, '>>&=', $cw;
+    exec $cmd_path, @verbose_flags, $tpath or die $!;
+};
+
+close $_ for ($cr, $cw);
+
+$pr->blocking(0);
+
+my $poll = IO::Poll->new();
+$poll->mask( $pr, IO::Poll::POLLIN() );
+
+sub _poll_in {
+    return $poll->poll(30) || die 'Timed out on read!';
+}
+
+sub _read {
+    _poll_in();
+
+    my $buf = q<>;
+    sysread( $pr, $buf, 4096, length $buf );   #it’ll never be that big
+    return $buf;
+}
+
+sub _read_and_report {
+    my $input = _read();
+    _report_from_child($input);
+}
+
+sub _report_from_child {
+    my $bytes = $_[0];
+
+    my $truncated_yn;
+    my $orig_len = length $bytes;
+
+    if ($orig_len > 70) {
+        substr($bytes, 25) = q<>;
+        $truncated_yn = 1;
+    }
+
+    $bytes = Text::Control::to_hex($bytes);
+    if ($truncated_yn) {
+        $bytes .= ' … ' . Text::Control::to_hex( substr($_[0], -45) );
+        $bytes .= " ($orig_len bytes)";
+    }
+
+    say "$COMMAND says: $bytes";
+}
+
+sub _write { syswrite $pw, $_[0]; }
+
+sub _write_octets {
+    my $bytes = join( q<>, map { chr } @_ );
+    _write( $bytes );
+    say "to $COMMAND: " . Text::Control::to_hex($bytes);
+}
+
+sub _write_and_wait_to_finish {
+    _write_octets(@_);
+
+    _wait_to_finish();
+}
+
+sub _wait_to_finish {
+    close $pw;
+
+    $pr->blocking(1);
+    my $buf = q<>;
+    while (my $read = sysread $pr, $buf, 65536) {
+        if ($buf =~ m<=THE END>) {
+            print STDERR "\x07XXXXX FAILED TO STOP THE ONSLAUGHT!!\n";
+            sleep 2;
+        }
+
+        print "=========== FINAL ($read) ===========\n";
+        _report_from_child($buf);
+    }
+
+    close $pr;
+
+    waitpid $pid, 0;
+    my $exit = $? >> 8;
+    print "$COMMAND exit: $exit\n";
+
+    exit;
+}
+
+sub _send_cancel {
+    print "======= SENDING CANCEL\n";
+    _write_and_wait_to_finish( CANCEL_BYTES() );
+}
+
+sub _read_until_packet_end {
+    my $buf = q<>;
+
+    my $next_header;
+
+    while (1) {
+        if ($buf =~ m<\x18h..(.*)>) {
+            $next_header = $1;
+            last;
+        }
+
+        _poll_in();
+        sysread $pr, $buf, 65536, length $buf;
+    }
+
+    print "\nEnd of packet\n";
+    _report_from_child($next_header) if length $next_header;
+    return;
+}
+
+sub _send_ZCAN {
+    print "======= SENDING ZCAN\n";
+    _write_and_wait_to_finish( ZCAN_BYTES() );
+}
+
+#----------------------------------------------------------------------
+
+#Shows ZRQINIT
+_read_and_report();
+
+#_send_cancel();    #works
+#_send_ZCAN();      #doesn’t work
+
+use constant ZRINIT_BYTES => (
+    #CANOVIO, CANFDX
+    #42, 42, 24, 66, 48, 49, 48, 48, 48, 48, 48, 48, 48, 48, 97, 97, 53, 49, 13, 10, 17,
+
+    #CANOVIO, CANFDX, CANFC32
+    qw( 42 42 24 66 48 49 48 48 48 48 48 48 50 51 98 101 53 48 13 10 17 ),
+);
+
+use constant ZSKIP_BYTES => (
+    42, 42, 24, 66, 48, 53, 48, 48, 48, 48, 48, 48, 48, 48, 50, 51, 53, 55, 13, 10, 17,
+);
+
+#ZRINIT
+_write_octets( ZRINIT_BYTES() );
+
+#Shows ZFILE and offer subpacket
+_read_and_report();
+
+#_send_cancel();    #works
+#_send_ZCAN();      #works
+
+#ZRPOS
+_write_octets(
+    42, 42, 24, 66, 48, 57, 48, 48, 48, 48, 48, 48, 48, 48, 97, 56, 55, 99, 13, 10, 17
+);
+
+#Shows initial batch of file data
+#_read_and_report();
+#
+#_send_ZCAN();      #works - BUFFER OVERFLOW
+_send_cancel();    #works - BUFFER OVERFLOW
+
+_read_and_report();
+
+#_write_octets( ZSKIP_BYTES() );
+
+#_read_until_packet_end();
+
+#_send_cancel();    #works
+
+#ZRINIT
+_write_octets( ZRINIT_BYTES() );
+
+#_send_cancel();    #works
+
+_read_and_report();
+
+_send_cancel();    #works - but by this point the transfer is done
+
+#ZFIN
+_write_octets(
+    42, 42, 24, 66, 48, 56, 48, 48, 48, 48, 48, 48, 48, 48, 48, 50, 50, 100, 13, 10
+);
+
+_wait_to_finish();