Open Source Projects Europe

// stuck forever.

// stuck forever.

static const int read_timeout(60);

static const int read_timeout(60);

class PlgWithSlave::Internal {

class PlgWithSlave::Internal {

public:

public:

    Internal(PlgWithSlave *_plg, const string& hst,

             int prt, const string& pp)

             int prt, const string& pp)

        : plg(_plg), cmd(read_timeout), upnphost(hst),

          upnpport(prt), pathprefix(pp), laststream(this) { }

          upnpport(prt), pathprefix(pp), laststream(this) { }

    bool maybeStartCmd();

    bool maybeStartCmd();

    PlgWithSlave *plg;

    PlgWithSlave *plg;

    CmdTalk cmd;

    CmdTalk cmd;

    // Upnp Host and port. This would only be used to generate URLs *if*

    // Upnp Host and port. This would only be used to generate URLs *if*

    // we were using the libupnp miniserver. We currently use

    // we were using the libupnp miniserver. We currently use

    // microhttp because it can do redirects

    // microhttp because it can do redirects

    string upnphost;

    string upnphost;

    int upnpport;

    int upnpport;

    StreamHandle laststream;

    StreamHandle laststream;

};

};

// microhttpd daemon handle. There is only one of these, and one port, we find

// microhttpd daemon handle. There is only one of these, and one port, we find

// the right plugin by looking at the url path.

// the right plugin by looking at the url path.

static struct MHD_Daemon *mhd;

// Microhttpd connection handler. We re-build the complete url + query

// Microhttpd connection handler. We re-build the complete url + query

// string (&trackid=value), use this to retrieve a service URL

// string (&trackid=value), use this to retrieve a service URL

// (tidal/qobuz...), and redirect to it (HTTP). A previous version

// (tidal/qobuz...), and redirect to it (HTTP). A previous version

// handled rtmp streams, and had to read them. Look up the history if

// handled rtmp streams, and had to read them. Look up the history if

           " version " << version << endl);

           " version " << version << endl);

    // The 'plgi' here is just whatever plugin started up the httpd task

    // The 'plgi' here is just whatever plugin started up the httpd task

    // We just use it to find the appropriate plugin for this path,

    // We just use it to find the appropriate plugin for this path,

    // and then dispatch the request.

    // and then dispatch the request.

    PlgWithSlave *realplg =

    PlgWithSlave *realplg =

    if (nullptr == realplg) {

    if (nullptr == realplg) {

        LOGERR("answer_to_connection: no plugin for path [" << url << endl);

        LOGERR("answer_to_connection: no plugin for path [" << url << endl);

        return MHD_NO;

        return MHD_NO;

    }

    }

static int accept_policy(void *, const struct sockaddr* sa, socklen_t addrlen)

static int accept_policy(void *, const struct sockaddr* sa, socklen_t addrlen)

{

{

    return MHD_YES;

    return MHD_YES;

}

}

{

{

    return true;

    if (nullptr == mhd) {

        // Start the microhttpd daemon. There can be only one, and it

        // Start the microhttpd daemon. There can be only one, and it

        // is started with a context handle which points to whatever

        // is started with a context handle which points to whatever

        // plugin got there first. The callback will only use the

        // plugin got there first. The callback will only use the

        // handle to get to the plugin services, and retrieve the

        // handle to get to the plugin services, and retrieve the

        // appropriate plugin based on the url path prefix.

        // appropriate plugin based on the url path prefix.

        LOGDEB("PlgWithSlave: starting httpd on port "<< port << endl);

        LOGDEB("PlgWithSlave: starting httpd on port "<< port << endl);

        mhd = MHD_start_daemon(

            MHD_USE_THREAD_PER_CONNECTION,

            MHD_USE_THREAD_PER_CONNECTION,

            //MHD_USE_SELECT_INTERNALLY, 

            //MHD_USE_SELECT_INTERNALLY, 

            port, 

            port, 

            /* Accept policy callback and arg */

            /* Accept policy callback and arg */

            accept_policy, NULL, 

            accept_policy, NULL, 

            /* handler and arg */

            /* handler and arg */

            MHD_OPTION_END);

            MHD_OPTION_END);

        if (nullptr == mhd) {

            LOGERR("PlgWithSlave: MHD_start_daemon failed\n");

            LOGERR("PlgWithSlave: MHD_start_daemon failed\n");

            return false;

            return false;

        }

        }

    }

    }

        return false;

        return false;

    }

    }

}

}

bool PlgWithSlave::startInit()

bool PlgWithSlave::startInit()

{

{

    return m && m->maybeStartCmd();

    return m && m->maybeStartCmd();

PlgWithSlave::PlgWithSlave(const string& name, CDPluginServices *services)

PlgWithSlave::PlgWithSlave(const string& name, CDPluginServices *services)

    : CDPlugin(name, services)

    : CDPlugin(name, services)

{

{

    m = new Internal(this,

                     services->getupnpaddr(this),

                     services->getupnpaddr(this),

                     services->getupnpport(this),

                     services->getupnpport(this),

                     services->getpathprefix(this));

                     services->getpathprefix(this));

}

}