Method scanNextPlugin

Server/Source/Server.cpp:692–810

}

void Server::scanNextPlugin(const String& id, const String& name, const String& fmt, int srvId,
                            std::function<void(const String&)> onShellPlugin, bool secondRun) {
    traceScope();
    String fileFmt = id;
    fileFmt << "|" << fmt;
    ChildProcess proc;
    StringArray args;
    args.add(File::getSpecialLocation(File::currentExecutableFile).getFullPathName());
    args.addArray({"-scan", fileFmt});
    args.addArray({"-id", String(srvId)});
    if (secondRun) {
        args.add("-secondrun");
    }
    String pipeName = "audiogridderscan." + String(srvId);
    NamedPipe pipe;
    if (!pipe.createNewPipe(pipeName)) {
        logln("warning: can't open pipe " << pipeName);
    }
    bool blacklist = false;
    if (proc.start(args)) {
        const int secondsPerPlugin = 30;
        std::atomic_int secondsLeft{secondsPerPlugin};

        FnThread outputReader(
            [this, &pipe, &proc, &secondsLeft, name, secs = secondsPerPlugin, onShellPlugin] {
                std::vector<char> buf(256);
                std::unique_ptr<TimeStatistic::Timeout> loadTimeout;
                String lastShellName;
                while (proc.isRunning() && !currentThreadShouldExit()) {
                    ScanPipeHdr hdr;
                    if (pipe.read(&hdr, sizeof(hdr), 100) == sizeof(hdr)) {
                        switch (hdr.type) {
                            case ScanPipeHdr::LOAD_START:
                                loadTimeout = std::make_unique<TimeStatistic::Timeout>(5000);
                                break;
                            case ScanPipeHdr::LOAD_FINISHED:
                                loadTimeout.reset();
                                break;
                            case ScanPipeHdr::SHELL:
                                if (pipe.read(buf.data(), hdr.len, 1000) == hdr.len) {
                                    buf[(size_t)hdr.len] = 0;
                                    lastShellName = buf.data();
                                    // let the scanner know, that the current plugin is a shell and has plugins inside
                                    onShellPlugin(lastShellName);
                                    // increase the timeout as there might be mutliple plugins per shell
                                    secondsLeft = secs;
                                    logln("    -> shell plugin: " << lastShellName);
                                }
                                break;
                        }
                    }
                    if (nullptr != loadTimeout && loadTimeout->getMillisecondsLeft() <= 0) {
                        logln("error: load timeout for '" << (lastShellName.isNotEmpty() ? lastShellName : name)
                                                          << "', killing process");
                        proc.kill();
                        loadTimeout.reset();
                    }
                }