X-Git-Url: http://dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FAGWMsg.pm;h=41f23702abd7ab5b79ea6fcd1fa82012867c89ca;hb=59e9f019432790d60afcbc96e490375e6a544dbc;hp=7582e2c723be8d45e0e3b0f23293e3d6f72174a3;hpb=33f5a4eea5d24c44885ec0d2b937b0c6b40a331d;p=spider.git

diff --git a/perl/AGWMsg.pm b/perl/AGWMsg.pm
index 7582e2c7..41f23702 100644
--- a/perl/AGWMsg.pm
+++ b/perl/AGWMsg.pm
@@ -157,6 +157,9 @@ sub _send
                     return 0; # fail. Message remains in queue ..
                 }
             }
+			if (isdbg('raw')) {
+				dbgdump('raw', "send $bytes_written: ", $msg);
+			}
             $offset         += $bytes_written;
             $bytes_to_write -= $bytes_written;
         }
@@ -183,6 +186,9 @@ sub _rcv {                     # Complement to _send
 	if (defined ($bytes_read)) {
 		if ($bytes_read > 0) {
 			$inmsg .= $msg;
+			if (isdbg('raw')) {
+				dbgdump('raw', "read $bytes_read: ", $msg);
+			}
 		} 
 	} else {
 		if (Msg::_err_will_block($!)) {
@@ -196,7 +202,7 @@ FINISH:
     if (defined $bytes_read && $bytes_read == 0) {
 		finish();
     } else {
-		_decode() if length $inmsg > 36;
+		_decode() if length $inmsg >= 36;
 	}
 }
 
@@ -358,7 +364,8 @@ sub _decode
 			dbg('agw', "AGW Port: $_");
 		}
 		for (my $i = 0; $i < $noports; $i++) {
-			_sendf('y', undef, undef, $i );
+			_sendf('y', undef, undef, $i);
+			_sendf('g', undef, undef, $i);
 		}
 	} else {
 		my $d = unpack "Z*", $data;