grahamc/hydra2 - Change 4HHHMXI6EMBSXWM2IGKRR4W5TWTZGWDJUAUGUSAB4UZPH7OBJYSAC

hydra-queue-runner: Handle exceptions in the dispatcher thread

E.g. "resource unavailable" when creating new threads.

Created by Eelco Dolstra on November 8, 2016

4HHHMXI6EMBSXWM2IGKRR4W5TWTZGWDJUAUGUSAB4UZPH7OBJYSAC

Dependencies

In channels

main

Change contents

Deletion in src/hydra-queue-runner/dispatcher.cc at line 35 [3.14628]
B:BD[3.15157] → [3.15157:15208]
B:BD[3.15208] → [2.24:55]
```
        printMsg(lvlDebug, "dispatcher woken up");
        nrDispatcherWakeups++;
```

Replacement in src/hydra-queue-runner/dispatcher.cc at line 36 [3.14628]

B:BD[2.56] → [2.56:110]

        auto now1 = std::chrono::steady_clock::now();

[2.56]

[3.15208]

        try {
            printMsg(lvlDebug, "dispatcher woken up");
            nrDispatcherWakeups++;

Replacement in src/hydra-queue-runner/dispatcher.cc at line 40 [3.14628]

B:BD[3.15209] → [4.0:40]

        auto sleepUntil = doDispatch();

[3.15209]

[2.111]

            auto now1 = std::chrono::steady_clock::now();

Replacement in src/hydra-queue-runner/dispatcher.cc at line 42 [3.14628]

B:BD[2.112] → [2.112:166]

        auto now2 = std::chrono::steady_clock::now();

[2.112]

[2.166]

            auto sleepUntil = doDispatch();

Replacement in src/hydra-queue-runner/dispatcher.cc at line 44 [3.14628]

B:BD[2.167] → [2.167:269]

        dispatchTimeMs += std::chrono::duration_cast<std::chrono::milliseconds>(now2 - now1).count();

[2.167]

[3.15255]

            auto now2 = std::chrono::steady_clock::now();

Replacement in src/hydra-queue-runner/dispatcher.cc at line 46 [3.14628]

B:BD[3.15256] → [4.41:176]

B:BD[4.176] → [5.0:380]

        /* Sleep until we're woken up (either because a runnable build
           is added, or because a build finishes). */
        {
            auto dispatcherWakeup_(dispatcherWakeup.lock());
            if (!*dispatcherWakeup_) {
                printMsg(lvlDebug, format("dispatcher sleeping for %1%s") %
                    std::chrono::duration_cast<std::chrono::seconds>(sleepUntil - std::chrono::system_clock::now()).count());
                dispatcherWakeup_.wait_until(dispatcherWakeupCV, sleepUntil);

[3.15256]

[5.380]

            dispatchTimeMs += std::chrono::duration_cast<std::chrono::milliseconds>(now2 - now1).count();
            /* Sleep until we're woken up (either because a runnable build
               is added, or because a build finishes). */
            {
                auto dispatcherWakeup_(dispatcherWakeup.lock());
                if (!*dispatcherWakeup_) {
                    printMsg(lvlDebug, format("dispatcher sleeping for %1%s") %
                        std::chrono::duration_cast<std::chrono::seconds>(sleepUntil - std::chrono::system_clock::now()).count());
                    dispatcherWakeup_.wait_until(dispatcherWakeupCV, sleepUntil);
                }
                *dispatcherWakeup_ = false;

Replacement in src/hydra-queue-runner/dispatcher.cc at line 59 [3.14628]

B:BD[4.528] → [5.395:435]

            *dispatcherWakeup_ = false;

[5.394]

[4.528]


        } catch (std::exception & e) {
            printMsg(lvlError, format("dispatcher: %1%") % e.what());
            sleep(1);

Insertion in src/hydra-queue-runner/dispatcher.cc at line 64 [3.14628]
[4.538]
[4.538]