X-Git-Url: http://dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FDXMsg.pm;h=c87fd2e4ec5b316433e9749f28aa525a0098cb8d;hb=b91254375e95e7931312c4177ee390866f82c648;hp=f3c2172cfba7c45c70e7fa5d3c12353853dd2b92;hpb=2a43619b670b8f9249558f814b0183262c3ba4f6;p=spider.git diff --git a/perl/DXMsg.pm b/perl/DXMsg.pm index f3c2172c..c87fd2e4 100644 --- a/perl/DXMsg.pm +++ b/perl/DXMsg.pm @@ -686,7 +686,15 @@ sub start_msg $busy{$self->{tonode}} = $self; $work{$self->{tonode}} = $self; $self->{lastt} = $main::systime; - $dxchan->send(DXProt::pc28($self->{tonode}, $self->{fromnode}, $self->{to}, $self->{from}, $self->{t}, $self->{private}, $self->{subject}, $self->{origin}, $self->{rrreq})); + my ($fromnode, $origin); + if ($dxchan->is_arcluster) { + $fromnode = $self->{origin}; + $origin = $self->{fromnode}; + } else { + $fromnode = $self->{fromnode}; + $origin = $self->{origin}; + } + $dxchan->send(DXProt::pc28($self->{tonode}, $fromnode, $self->{to}, $self->{from}, $self->{t}, $self->{private}, $self->{subject}, $origin, $self->{rrreq})); } # get the ref of a busy node