]> dxcluster.org Git - spider.git/commitdiff
fix AsyncMsg.pm + clusteraddr issues
authorDirk Koopman <djk@tobit.co.uk>
Fri, 12 May 2017 19:04:50 +0000 (20:04 +0100)
committerDirk Koopman <djk@tobit.co.uk>
Fri, 12 May 2017 19:04:50 +0000 (20:04 +0100)
perl/AsyncMsg.pm
perl/cluster.pl
perl/console.pl

index c2eeaadcaf453c587da1278d9165b46542f7296f..e6ae80c696f39c21904cdbda2fda90a8d730edd4 100644 (file)
@@ -181,20 +181,20 @@ sub _getpost
        
        $r = $conn->connect($host, $port);
        if ($r) {
-               dbg("Sending '$sort $path HTTP/1.0'") if isdbg('async');
-               $conn->send_later("$sort $path HTTP/1.0\n");
+               dbg("Sending '$sort $path HTTP/1.1'") if isdbg('async');
+               $conn->send_later("$sort $path HTTP/1.1\r\n");
 
                my $h = delete $args{Host} || $host;
                my $u = delete $args{'User-Agent'} || "DxSpider;$main::version;$main::build;$^O;$main::mycall"; 
                my $d = delete $args{data};
                
-           $conn->send_later("Host: $h\n");
-               $conn->send_later("User-Agent: $u\n");
+           $conn->send_later("Host: $h\r\n");
+               $conn->send_later("User-Agent: $u\r\n");
                while (my ($k,$v) = each %args) {
-                       $conn->send_later("$k: $v\n");
+                       $conn->send_later("$k: $v\r\n");
                }
-               $conn->send_later("\n$d") if defined $d;
-               $conn->send_later("\n");
+               $conn->send_later("\r\n$d") if defined $d;
+               $conn->send_later("\r\n");
        }
        
        return $r ? $conn : undef;
index 0db8e0bcb2e0d59354f276a41a5c2a21c098e333..b9031719718fc291e1ef18343a65b4639af872a8 100755 (executable)
@@ -15,7 +15,15 @@ require 5.004;
 package main;
 
 # set default paths, these should be overwritten by DXVars.pm
-use vars qw($data $system $cmd $localcmd $userfn);
+use vars qw($data $system $cmd $localcmd $userfn $clusteraddr $clusterport $yes $no $user_interval $lang);
+
+$lang = 'en';                   # default language
+$clusteraddr = '127.0.0.1';     # cluster tcp host address - used for things like console.pl
+$clusterport = 27754;           # cluster tcp port
+$yes = 'Yes';                   # visual representation of yes
+$no = 'No';                     # ditto for no
+$user_interval = 11*60;         # the interval between unsolicited prompts if no traffic
+
 
 # make sure that modules are searched in the order local then perl
 BEGIN {
@@ -128,8 +136,8 @@ package main;
 
 use strict;
 use vars qw(@inqueue $systime $starttime $lockfn @outstanding_connects
-                       $zombies $root @listeners $lang $myalias @debug $userfn $clusteraddr
-                       $clusterport $mycall $decease $is_win $routeroot $me $reqreg $bumpexisting
+                       $zombies $root @listeners $lang $myalias @debug $userfn
+                       $mycall $decease $is_win $routeroot $me $reqreg $bumpexisting
                        $allowdxby $dbh $dsn $dbuser $dbpass $do_xml $systime_days $systime_daystart
                        $can_encode $maxconnect_user $maxconnect_node
                   );
index f85e235d7d726ece77cb50c36dbd98733549e48f..2c8c456bbfff35268d43fcb9e72d12b37f32132e 100755 (executable)
 require 5.004;
 package main;
 
-use vars qw($data);
+use vars qw($data $clusteraddr $clusterport);
+
+$clusteraddr = '127.0.0.1';     # cluster tcp host address - used for things like console.pl
+$clusterport = 27754;           # cluster tcp port
 
 # search local then perl directories
 BEGIN {