Open Source Projects Europe

    if (m_metadata.empty()) {

    if (m_metadata.empty()) {

        LOGERR("OHReceiver::play: no metadata" << endl);

        LOGERR("OHReceiver::play: no metadata" << endl);

        return false;

        return false;

    }

    }

    int id = -1;

    int id = -1;

    unordered_map<int, string> urlmap;

    unordered_map<int, string> urlmap;

    string line;

    string line;

    // We start the songcast command to receive the audio flux and either

    // We start the songcast command to receive the audio flux and either

    } else {

    } else {

        LOGDEB("OHReceiver::play: sc2mpd pid "<< m_cmd->getChildPid()<< endl);

        LOGDEB("OHReceiver::play: sc2mpd pid "<< m_cmd->getChildPid()<< endl);

    }

    }

    if (m_pm == OHReceiverParams::OHRP_MPD) {

    if (m_pm == OHReceiverParams::OHRP_MPD) {

        // Wait for sc2mpd to signal ready, then play.

        // Wait for sc2mpd to signal ready, then play.

        // sc2mpd writes a single line to stdout "CONNECTED" when

        // sc2mpd writes a single line to stdout "CONNECTED" when

        // it gets there, which should be more or less instantaneous

        // it gets there, which should be more or less instantaneous

        int timeo = 15;

        int timeo = 15;

        if (m_cmd->getline(line, timeo) < 0) {

        if (m_cmd->getline(line, timeo) < 0) {

out:

out:

    if (!ok) {

    if (!ok) {

        iStop();

        iStop();

    }

    }

    return ok;

    return ok;

}

}

int OHReceiver::play(const SoapIncoming& sc, SoapOutgoing& data)

int OHReceiver::play(const SoapIncoming& sc, SoapOutgoing& data)

{

{

    LOGDEB("OHReceiver::play" << endl);

    LOGDEB("OHReceiver::play" << endl);

    bool ok = iPlay();

    bool ok = iPlay();

    if (ok && m_dev->m_ohpr)

    if (ok && m_dev->m_ohpr)

        m_dev->m_ohpr->iSetSourceIndexByName("Receiver");

        m_dev->m_ohpr->iSetSourceIndexByName("Receiver");

    return ok ? UPNP_E_SUCCESS : UPNP_E_INTERNAL_ERROR;

    return ok ? UPNP_E_SUCCESS : UPNP_E_INTERNAL_ERROR;

}

}

bool OHReceiver::iStop()

bool OHReceiver::iStop()

{

{

    LOGDEB("OHReceiver::iStop()\n");

    LOGDEB("OHReceiver::iStop()\n");

    if (m_cmd) {

    if (m_cmd) {

        m_cmd->zapChild();

        m_cmd->zapChild();

        m_cmd = shared_ptr<ExecCmd>();

        m_cmd = shared_ptr<ExecCmd>();

    }

    }

    m_dev->m_mpdcli->stop();

    unordered_map<int, string> urlmap;

    // Remove our bogus URi from the playlist

    if (!m_dev->m_ohpl->urlMap(urlmap)) {

        LOGERR("OHReceiver::stop: urlMap() failed" <<endl);

    }

    for (auto it = urlmap.begin(); it != urlmap.end(); it++) {

        if (it->second == m_httpuri) {

            m_dev->m_mpdcli->deleteId(it->first);

        }

    // At least the songcast windows driver never resets the source

    // At least the songcast windows driver never resets the source

    // index (it does call stop when it deconnects).

    // index (it does call stop when it deconnects).

    // I guess that there is no reason to reset the source, and

    // I guess that there is no reason to reset the source, and

    // another CP could just set it to what it wants, but Bubble at

    // another CP could just set it to what it wants, but Bubble at

    // least won't do a thing with the renderer as long as the source

    // least won't do a thing with the renderer as long as the source

    // is set to receiver.

    // is set to receiver.

    if (m_dev->m_ohpr)

    if (m_dev->m_ohpr)

        m_dev->m_ohpr->iSetSourceIndexByName("Playlist");

        m_dev->m_ohpr->iSetSourceIndexByName("Playlist");

    maybeWakeUp(true);

    maybeWakeUp(true);

}

}

bool OHReceiver::iSetSender(const string& uri, const string& metadata)

bool OHReceiver::iSetSender(const string& uri, const string& metadata)

{

{

    // Only do something if data changes, and then first stop any

    // Only do something if data changes, and then first stop any