grahamc/hydra2 - Change 4ZCUCACYWDLCZUKIH2OLFC4NCPBE2YO7Y7AZ7WL3AESZQ3TSIYXQC

hydra-notify: Fix processing notifications

Created by Eelco Dolstra on August 12, 2019

4ZCUCACYWDLCZUKIH2OLFC4NCPBE2YO7Y7AZ7WL3AESZQ3TSIYXQC

Dependencies

In channels

main

Change contents

Deletion in src/script/hydra-notify at line 99 [4.2994]
B:BD[3.2725] → [3.2725:2791]
```
    my $notify = $dbh->func("pg_notifies");
    next if !$notify;
```

Replacement in src/script/hydra-notify at line 100 [4.2994]

B:BD[3.2792] → [3.2792:2904]

    my ($channelName, $pid, $payload) = @$notify;
    #print STDERR "got '$channelName' from $pid: $payload\n";

[3.2792]

[3.2904]

    while (my $notify = $dbh->func("pg_notifies")) {

Replacement in src/script/hydra-notify at line 102 [4.2994]

B:BD[3.2905] → [2.163:203]

    my @payload = split /\t/, $payload;

[3.2905]

[3.2944]

        my ($channelName, $pid, $payload) = @$notify;
        #print STDERR "got '$channelName' from $pid: $payload\n";
        my @payload = split /\t/, $payload;

Replacement in src/script/hydra-notify at line 107 [4.2994]

B:BD[3.2945] → [3.2945:3440]

    eval {
        if ($channelName eq "build_started") {
            buildStarted(int($payload[0]));
        } elsif ($channelName eq "build_finished") {
            my $buildId = int($payload[0]);
            my $build = $db->resultset('Builds')->find($buildId)
                or die "build $buildId does not exist\n";
            buildFinished($build, @payload[1..$#payload]);
        } elsif ($channelName eq "step_finished") {
            stepFinished(int($payload[0]), int($payload[1]));

[3.2945]

[3.3440]

        eval {
            if ($channelName eq "build_started") {
                buildStarted(int($payload[0]));
            } elsif ($channelName eq "build_finished") {
                my $buildId = int($payload[0]);
                my $build = $db->resultset('Builds')->find($buildId)
                    or die "build $buildId does not exist\n";
                buildFinished($build, @payload[1..$#payload]);
            } elsif ($channelName eq "step_finished") {
                stepFinished(int($payload[0]), int($payload[1]));
            }
        };
        if ($@) {
            print STDERR "error processing message '$payload' on channel '$channelName': $@\n";

Deletion in src/script/hydra-notify at line 122 [4.2994]

B:BD[3.3450] → [3.3450:3563]

    };
    if ($@) {
        print STDERR "error processing message '$payload' on channel '$channelName': $@\n";