X-Git-Url: http://mj.ucw.cz/gitweb/?a=blobdiff_plain;f=submit%2FMO%2FSubmit.pm;h=e571be3706ca8ee8f39c4faec7f25ae63bbbccc7;hb=babd817998d5e7026a3e392024779216ab59ca94;hp=f85852cfb008f3a2aeb4dd7eb4d4e6b7072efd50;hpb=91f44a34afc80be20a8f9de9b07e9b0099275fe8;p=moe.git

diff --git a/submit/MO/Submit.pm b/submit/MO/Submit.pm
index f85852c..e571be3 100644
--- a/submit/MO/Submit.pm
+++ b/submit/MO/Submit.pm
@@ -23,8 +23,10 @@ sub new($) {
 		"Cert" => "$mo/cert.pem",
 		"CACert" => "$mo/ca-cert.pem",
 		"Trace" => defined $ENV{"MO_SUBMIT_TRACE"},
-		"History" => "$home/.history",	# Keep submission history in this directory
-		"RefreshTimer" => 5000,		# How often GUI sends STATUS commands [ms]
+		"Checks" => 1,
+#		"History" => "$home/.history",	# Keep submission history in this directory
+		"RefreshTimer" => 60000,	# How often GUI sends STATUS commands [ms]
+		"root" => $root,
 		"user" => $user,
 		"sk" => undef,
 		"error" => undef,
@@ -66,6 +68,7 @@ sub disconnect($) {
 sub connect($) {
 	my $self = shift @_;
 	$self->disconnect;
+
 	$self->log("Connecting to submit server");
 	my $sk = new IO::Socket::INET(
 		PeerAddr => $self->{"Server"},
@@ -104,6 +107,7 @@ sub connect($) {
 		}
 	}
 	$self->{"sk"} = $sk;
+	$sk->autoflush(0);
 
 	$self->log("Logging in");
 	my $req = new Sherlock::Object("U" => $self->{"user"});
@@ -121,12 +125,14 @@ sub connect($) {
 sub request($$) {
 	my ($self, $obj) = @_;
 	my $sk = $self->{"sk"};
-	$obj->write($sk);	### FIXME: Flushing
+	## $SIG{'PIPE'} = 'ignore';
+	$obj->write($sk);
+	print $sk "\n";
+	$sk->flush();
 	if ($sk->error) {
 		$self->err("Connection broken");
 		return undef;
 	}
-	print $sk "\n";
 	return $self->reply;
 }