X-Git-Url: http://gb7djk.dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FAsyncMsg.pm;h=cb1c2f2bdc64a228f6b5c76bd6d3fcc8c047b800;hb=a24cc09d8262093df92c767d3010c0a5fd6e42d7;hp=cb0878762f1ba7f3d60dd5c4b8cd43bf2366100d;hpb=4ae3641339d8511e0b458bc6eacd287339c70cb2;p=spider.git

diff --git a/perl/AsyncMsg.pm b/perl/AsyncMsg.pm
index cb087876..cb1c2f2b 100644
--- a/perl/AsyncMsg.pm
+++ b/perl/AsyncMsg.pm
@@ -118,6 +118,8 @@ sub _getpost
 	$conn->{_assort} = $sort;
 	$conn->{csort} = 'http';
 
+	my $data = delete $args{data};
+
 	my $ua =  Mojo::UserAgent->new;
 	my $s;
 	$s .= $host;
@@ -130,6 +132,19 @@ sub _getpost
 #	$tx->on(error => sub { $conn->_error(@_); });
 #	$tx->on(finish => sub { $conn->disconnect; });
 
+	$ua->on(start => sub {
+				my ($ua, $tx) = @_;
+				while (my ($k, $v) = each %args) {
+					dbg("AsyncMsg: attaching header $k: $v") if isdbg('async');
+					$tx->req->headers->header($k => $v);
+				}
+				if (defined $data) {
+					dbg("AsyncMsg: body ='$data'") if isdbg('async'); 
+					$tx->req->body($data);
+				}
+			});
+	
+
 	$ua->start($tx => sub { $conn->handle_getpost(@_) }); 
 
 	
@@ -188,9 +203,11 @@ sub raw
 	my %args = @_;
 
 	my $handler = delete $args{handler} || \&handle_raw;
+	
 	my $conn = $pkg->new($call, $handler);
 	$conn->{prefix} = delete $args{prefix} if exists $args{prefix};
 	$conn->{prefix} ||= '';
+	$conn->{on_disconnect} = delete $args{on_disc} || delete $args{on_disconnect};
 	$r = $conn->connect($host, $port, on_connect => &_on_raw_connect);
 	return $r ? $conn : undef;
 }
@@ -251,7 +268,8 @@ sub disconnect
 		my $dxchan = DXChannel::get($conn->{caller});
 		if ($dxchan) {
 			no strict 'refs';
-			$ondisc->($conn, $dxchan)
+			$ondisc->($conn, $dxchan);
+			delete $conn->{on_disconnect};
 		}
 	}
 	delete $conn->{mojo};