version 1.107, 2018/12/10 17:34:22
|
version 1.109, 2020/01/12 01:21:33
|
Line 97 my $executable = $0; # Get the full
|
Line 97 my $executable = $0; # Get the full
|
my $RemoteHost; # Hostname of host child is talking to. |
my $RemoteHost; # Hostname of host child is talking to. |
my $RemoteHostId; # lonid of host child is talking to. |
my $RemoteHostId; # lonid of host child is talking to. |
my $RemoteDefHostId; # default lonhostID of host child is talking to. |
my $RemoteDefHostId; # default lonhostID of host child is talking to. |
|
my $RemoteLoncapaRev; # LON-CAPA version of host child is talking to. |
my @all_host_ids; |
my @all_host_ids; |
my $UnixSocketDir= $perlvar{'lonSockDir'}; |
my $UnixSocketDir= $perlvar{'lonSockDir'}; |
my $IdleConnections = Stack->new(); # Set of idle connections |
my $IdleConnections = Stack->new(); # Set of idle connections |
Line 613 sub CompleteTransaction {
|
Line 614 sub CompleteTransaction {
|
StartClientReply($Transaction, $data); |
StartClientReply($Transaction, $data); |
} else { # Delete deferred transaction file. |
} else { # Delete deferred transaction file. |
Log("SUCCESS", "A delayed transaction was completed"); |
Log("SUCCESS", "A delayed transaction was completed"); |
LogPerm("S:".$Socket->PeerLoncapaHim().":".$Transaction->getRequest()); |
LogPerm("S:".$Transaction->getClient().":".$Transaction->getRequest()); |
unlink($Transaction->getFile()); |
unlink($Transaction->getFile()); |
} |
} |
} |
} |
Line 671 Parameters:
|
Line 672 Parameters:
|
=item client |
=item client |
|
|
The LondTransaction we are failing. |
The LondTransaction we are failing. |
|
|
|
|
=cut |
=cut |
|
|
Line 1250 sub MakeLondConnection {
|
Line 1250 sub MakeLondConnection {
|
my $Connection = LondConnection->new(&GetServerHost(), |
my $Connection = LondConnection->new(&GetServerHost(), |
&GetServerPort(), |
&GetServerPort(), |
&GetHostId(), |
&GetHostId(), |
&GetDefHostId()); |
&GetDefHostId(), |
|
&GetLoncapaRev()); |
|
|
if($Connection eq undef) { |
if($Connection eq undef) { |
Log("CRITICAL","Failed to make a connection with lond."); |
Log("CRITICAL","Failed to make a connection with lond."); |
Line 1575 sub GetDefHostId {
|
Line 1576 sub GetDefHostId {
|
|
|
=pod |
=pod |
|
|
|
=head2 GetLoncapaRev |
|
|
|
Returns the LON-CAPA version for the node whose lond we talk with. |
|
|
|
=cut |
|
|
|
sub GetLoncapaRev { |
|
return $RemoteLoncapaRev; # Setup by the fork. |
|
} |
|
|
|
=pod |
|
|
=head2 GetServerPort |
=head2 GetServerPort |
|
|
Returns the lond port number. |
Returns the lond port number. |
Line 1836 sub ChildProcess {
|
Line 1849 sub ChildProcess {
|
# Create a new child for host passed in: |
# Create a new child for host passed in: |
|
|
sub CreateChild { |
sub CreateChild { |
my ($host, $hostid, $defhostid) = @_; |
my ($host, $hostid, $defhostid, $loncaparev) = @_; |
|
|
my $sigset = POSIX::SigSet->new(SIGINT); |
my $sigset = POSIX::SigSet->new(SIGINT); |
sigprocmask(SIG_BLOCK, $sigset); |
sigprocmask(SIG_BLOCK, $sigset); |
Line 1852 sub CreateChild {
|
Line 1865 sub CreateChild {
|
} else { # child. |
} else { # child. |
$RemoteHostId = $hostid; |
$RemoteHostId = $hostid; |
$RemoteDefHostId = $defhostid; |
$RemoteDefHostId = $defhostid; |
|
$RemoteLoncapaRev = $loncaparev; |
ShowStatus("Connected to ".$RemoteHost); |
ShowStatus("Connected to ".$RemoteHost); |
$SIG{INT} = 'DEFAULT'; |
$SIG{INT} = 'DEFAULT'; |
sigprocmask(SIG_UNBLOCK, $sigset); |
sigprocmask(SIG_UNBLOCK, $sigset); |