View | Details | Raw Unified | Return to bug 33898
Collapse All | Expand All

(-)a/misc/workers/es_indexer_daemon.pl (-3 / +4 lines)
Lines 69-74 my ( $help, $batch_size ); Link Here
69
69
70
my $not_found_retries = {};
70
my $not_found_retries = {};
71
my $max_retries = $ENV{MAX_RETRIES} || 10;
71
my $max_retries = $ENV{MAX_RETRIES} || 10;
72
my $mq_timeout = $ENV{MQ_TIMEOUT} // 10;
72
73
73
GetOptions(
74
GetOptions(
74
    'h|help' => \$help,
75
    'h|help' => \$help,
Lines 111-119 my @jobs = (); Link Here
111
while (1) {
112
while (1) {
112
113
113
    if ( $conn ) {
114
    if ( $conn ) {
114
        my $frame = $conn->receive_frame;
115
        my $frame = $conn->receive_frame( { timeout => $mq_timeout } );
115
        if ( !defined $frame ) {
116
        if ( !defined $frame ) {
116
            # maybe log connection problems
117
            # timeout or connection issue?
118
            $pm->reap_finished_children;
117
            next;    # will reconnect automatically
119
            next;    # will reconnect automatically
118
        }
120
        }
119
121
120
- 

Return to bug 33898