]> Sergey Matveev's repositories - public-inbox.git/commitdiff
net_reader: load IO::Socket::Socks in all workers
authorEric Wong <e@80x24.org>
Thu, 16 Sep 2021 09:41:16 +0000 (09:41 +0000)
committerEric Wong <e@80x24.org>
Thu, 16 Sep 2021 20:09:40 +0000 (20:09 +0000)
This was previously undetected since SOCKS is mainly used for
read-only (single worker) tasks, and worker[0] always loaded
the module.  However, "lei refresh-mail-sync" can bounce reads
to any worker, so we need to ensure worker[1..Inf] load it, too.

lib/PublicInbox/NetReader.pm

index abcb5d2f0432e7867f995d7e974411af20eb8a0c..5725a1551a03ab501da1e7672e7cb2388b37342b 100644 (file)
@@ -35,6 +35,7 @@ sub socks_args ($) {
                eval { require IO::Socket::Socks } or die <<EOM;
 IO::Socket::Socks missing for socks5h://$h:$p
 EOM
+               # for Mail::IMAPClient
                return { ProxyAddr => $h, ProxyPort => $p };
        }
        die "$val not understood (only socks5h:// is supported)\n";
@@ -45,6 +46,10 @@ sub mic_new ($$$$) {
        my %mic_arg = %$mic_arg;
        my $sa = $self->{cfg_opt}->{$sec}->{-proxy_cfg} || $self->{-proxy_cli};
        if ($sa) {
+               # this `require' needed for worker[1..Inf], since socks_args
+               # only got called in worker[0]
+               require IO::Socket::Socks;
+
                my %opt = %$sa;
                $opt{ConnectAddr} = delete $mic_arg{Server};
                $opt{ConnectPort} = delete $mic_arg{Port};