--- loncom/LondConnection.pm 2003/06/13 02:56:45 1.6 +++ loncom/LondConnection.pm 2003/09/15 09:25:57 1.10 @@ -1,7 +1,7 @@ # This module defines and implements a class that represents # a connection to a lond daemon. # -# $Id: LondConnection.pm,v 1.6 2003/06/13 02:56:45 foxr Exp $ +# $Id: LondConnection.pm,v 1.10 2003/09/15 09:25:57 foxr Exp $ # # Copyright Michigan State University Board of Trustees # @@ -27,6 +27,7 @@ # package LondConnection; +use strict; use IO::Socket; use IO::Socket::INET; use IO::Handle; @@ -70,6 +71,8 @@ Dump the internal state of the object: F sub Dump { my $self = shift; + my $key; + my $value; print "Dumping LondConnectionObject:\n"; while(($key, $value) = each %$self) { print "$key -> $value\n"; @@ -145,15 +148,16 @@ sub new { TimeoutCallback => undef, TransitionCallback => undef, Timeoutable => 0, - TimeoutValue => 60, - TimeoutRemaining => 0, + TimeoutValue => 30, + TimeoutRemaining => 0, CipherKey => "", Cipher => undef}; bless($self, $class); unless ($self->{Socket} = IO::Socket::INET->new(PeerHost => $self->{Host}, PeerPort => $self->{Port}, Type => SOCK_STREAM, - Proto => "tcp")) { + Proto => "tcp", + Timeout => 5)) { return undef; # Inidicates the socket could not be made. } # @@ -161,13 +165,14 @@ sub new { # $self->Transition("Connected"); $self->{InformWritable} = 1; # When socket is writable we send init + $self->{Timeoutable} = 1; # Timeout allowed during startup negotiation. $self->{TransactionRequest} = "init\n"; # # Set socket to nonblocking I/O. # my $socket = $self->{Socket}; - $flags = fcntl($socket->fileno, F_GETFL,0); + my $flags = fcntl($socket->fileno, F_GETFL,0); if($flags == -1) { $socket->close; return undef; @@ -215,11 +220,10 @@ sub Readable { my $rv = $socket->recv($data, POSIX::BUFSIZ, 0); my $errno = $! + 0; # Force numeric context. - unless (defined($rv) && length($data)) { # Read failed, + unless (defined($rv) && length $data) {# Read failed, if(($errno == POSIX::EWOULDBLOCK) || ($errno == POSIX::EAGAIN) || - ($errno == POSIX::EINTR) || - ($errno == 0)) { + ($errno == POSIX::EINTR)) { return 0; } @@ -237,7 +241,7 @@ sub Readable { if($self->{TransactionReply} =~ /(.*\n)/) { &Debug(8,"Readable End of line detected"); if ($self->{State} eq "Initialized") { # We received the challenge: - if($self->{TransactionReply} eq "refused") { # Remote doesn't have + if($self->{TransactionReply} eq "refused\n") { # Remote doesn't have $self->Transition("Disconnected"); # in host tables. $socket->close(); @@ -337,7 +341,7 @@ sub Writable { } } - if (($rv >= 0) || + if (($nwritten >= 0) || ($errno == POSIX::EWOULDBLOCK) || ($errno == POSIX::EAGAIN) || ($errno == POSIX::EINTR) || @@ -654,7 +658,7 @@ sub Decrypt { # Decode the data in 8 byte blocks. The string is encoded # as hex digits so there are two characters per byte: - $decrpyted = ""; + my $decrypted = ""; for(my $index = 0; $index < length($EncryptedString); $index += 16) { $decrypted .= $self->{Cipher}->decrypt(