WifiDisplaySource.cpp revision 2aea9552aeba92bbaf9e56c666049ea2d14057b5
1d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber/* 2d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber * Copyright 2012, The Android Open Source Project 3d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber * 4d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber * Licensed under the Apache License, Version 2.0 (the "License"); 5d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber * you may not use this file except in compliance with the License. 6d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber * You may obtain a copy of the License at 7d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber * 8d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber * http://www.apache.org/licenses/LICENSE-2.0 9d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber * 10d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber * Unless required by applicable law or agreed to in writing, software 11d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber * distributed under the License is distributed on an "AS IS" BASIS, 12d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber * See the License for the specific language governing permissions and 14d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber * limitations under the License. 15d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber */ 16d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1772f6aea5afba3ff8ab7e8eab49552d65ee3bb97bAndreas Huber//#define LOG_NDEBUG 0 18d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#define LOG_TAG "WifiDisplaySource" 19d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#include <utils/Log.h> 20d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 21d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#include "WifiDisplaySource.h" 22d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#include "PlaybackSession.h" 23b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#include "Parameters.h" 24d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#include "ParsedMessage.h" 25a556c4822fc205db0d27834ba5b637c351d73ffaAndreas Huber#include "rtp/RTPSender.h" 26d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber#include "TimeSyncer.h" 27d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 28b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#include <binder/IServiceManager.h> 298ba01021b573889802e67e029225a96f0dfa471aAndy McFadden#include <gui/IGraphicBufferProducer.h> 30b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#include <media/IHDCP.h> 31b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#include <media/IMediaPlayerService.h> 320b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber#include <media/IRemoteDisplayClient.h> 33d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#include <media/stagefright/foundation/ABuffer.h> 34d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#include <media/stagefright/foundation/ADebug.h> 35d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#include <media/stagefright/foundation/AMessage.h> 36d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#include <media/stagefright/MediaErrors.h> 37d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 38bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber#include <arpa/inet.h> 39bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber#include <cutils/properties.h> 40bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 41d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber#include <ctype.h> 42d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 43d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubernamespace android { 44d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 450b73d4730202fcad53aefc4314a06e7b95f442f0Andreas HuberWifiDisplaySource::WifiDisplaySource( 460b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber const sp<ANetworkSession> &netSession, 470b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber const sp<IRemoteDisplayClient> &client, 480b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber const char *path) 49ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber : mState(INITIALIZED), 50ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mNetSession(netSession), 510b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber mClient(client), 52d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mSessionID(0), 53ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber mStopReplyID(0), 54d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber mChosenRTPPort(-1), 55e7bd24af08ef0722fb124a550662bcec48c56f86Andreas Huber mUsingPCMAudio(false), 56c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientSessionID(0), 57d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mReaperPending(false), 580328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mNextCSeq(1), 590328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mUsingHDCP(false), 600328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mIsHDCP2_0(false), 610328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mHDCPPort(0), 620328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mHDCPInitializationComplete(false), 630b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber mSetupTriggerDeferred(false), 640b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber mPlaybackSessionEstablished(false) { 650b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber if (path != NULL) { 660b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber mMediaPath.setTo(path); 670b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber } 680b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber 695abf87f9af48149972eeb851ecaea679911da040Andreas Huber mSupportedSourceVideoFormats.disableAll(); 7094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 7194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mSupportedSourceVideoFormats.setNativeResolution( 7294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber VideoFormats::RESOLUTION_CEA, 5); // 1280x720 p30 73d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 74d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 75d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas HuberWifiDisplaySource::~WifiDisplaySource() { 76d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 77d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 785131d127a042ee88f903370be88845dc8c9f8578Andreas Huberstatic status_t PostAndAwaitResponse( 795131d127a042ee88f903370be88845dc8c9f8578Andreas Huber const sp<AMessage> &msg, sp<AMessage> *response) { 805131d127a042ee88f903370be88845dc8c9f8578Andreas Huber status_t err = msg->postAndAwaitResponse(response); 81d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 82d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 83d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 84d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 85d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 865131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (response == NULL || !(*response)->findInt32("err", &err)) { 87d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber err = OK; 88d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 89d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 90d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 91d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 92d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 935131d127a042ee88f903370be88845dc8c9f8578Andreas Huberstatus_t WifiDisplaySource::start(const char *iface) { 945131d127a042ee88f903370be88845dc8c9f8578Andreas Huber CHECK_EQ(mState, INITIALIZED); 955131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 965131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> msg = new AMessage(kWhatStart, id()); 975131d127a042ee88f903370be88845dc8c9f8578Andreas Huber msg->setString("iface", iface); 985131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 995131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> response; 1005131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return PostAndAwaitResponse(msg, &response); 1015131d127a042ee88f903370be88845dc8c9f8578Andreas Huber} 1025131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 103d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::stop() { 104d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<AMessage> msg = new AMessage(kWhatStop, id()); 105d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 106d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<AMessage> response; 1075131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return PostAndAwaitResponse(msg, &response); 1085131d127a042ee88f903370be88845dc8c9f8578Andreas Huber} 109d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1105131d127a042ee88f903370be88845dc8c9f8578Andreas Huberstatus_t WifiDisplaySource::pause() { 1115131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> msg = new AMessage(kWhatPause, id()); 112d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1135131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> response; 1145131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return PostAndAwaitResponse(msg, &response); 1155131d127a042ee88f903370be88845dc8c9f8578Andreas Huber} 116d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1175131d127a042ee88f903370be88845dc8c9f8578Andreas Huberstatus_t WifiDisplaySource::resume() { 1185131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> msg = new AMessage(kWhatResume, id()); 1195131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 1205131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> response; 1215131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return PostAndAwaitResponse(msg, &response); 122d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 123d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 124d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubervoid WifiDisplaySource::onMessageReceived(const sp<AMessage> &msg) { 125d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber switch (msg->what()) { 126d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case kWhatStart: 127d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 128d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber uint32_t replyID; 129d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->senderAwaitsResponse(&replyID)); 130d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 131bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber AString iface; 132bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber CHECK(msg->findString("iface", &iface)); 133bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 134bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber status_t err = OK; 135bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 136bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber ssize_t colonPos = iface.find(":"); 137bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 138bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber unsigned long port; 139bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 140bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber if (colonPos >= 0) { 141bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber const char *s = iface.c_str() + colonPos + 1; 142bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 143bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber char *end; 144bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber port = strtoul(s, &end, 10); 145bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 146bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber if (end == s || *end != '\0' || port > 65535) { 147bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber err = -EINVAL; 148bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } else { 149bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber iface.erase(colonPos, iface.size() - colonPos); 150bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } 151bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } else { 152bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber port = kWifiDisplayDefaultPort; 153bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } 154bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 155bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber if (err == OK) { 156bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber if (inet_aton(iface.c_str(), &mInterfaceAddr) != 0) { 157bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber sp<AMessage> notify = new AMessage(kWhatRTSPNotify, id()); 158d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 159bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber err = mNetSession->createRTSPServer( 160bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber mInterfaceAddr, port, notify, &mSessionID); 161bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } else { 162bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber err = -EINVAL; 163bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } 164bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } 165d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 166ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber if (err == OK) { 167d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber sp<AMessage> notify = new AMessage(kWhatTimeSyncerNotify, id()); 168d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber mTimeSyncer = new TimeSyncer(mNetSession, notify); 169d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber looper()->registerHandler(mTimeSyncer); 170d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber 171d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber mTimeSyncer->startServer(8123); 172d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber 173ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = AWAITING_CLIENT_CONNECTION; 174ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber } 175ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 176d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<AMessage> response = new AMessage; 177d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->setInt32("err", err); 178d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->postReply(replyID); 179d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 180d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 181d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 182d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case kWhatRTSPNotify: 183d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 184d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t reason; 185d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("reason", &reason)); 186d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 187d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber switch (reason) { 188d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case ANetworkSession::kWhatError: 189d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 190d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID; 191d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("sessionID", &sessionID)); 192d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 193d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t err; 194d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("err", &err)); 195d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 196d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString detail; 197d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findString("detail", &detail)); 198d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 199d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ALOGE("An error occurred in session %d (%d, '%s/%s').", 200d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, 201d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber err, 202d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber detail.c_str(), 203d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber strerror(-err)); 204d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 205d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mNetSession->destroySession(sessionID); 206d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 207c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (sessionID == mClientSessionID) { 208ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClientSessionID = 0; 209c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 210ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError( 211ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber IRemoteDisplayClient::kDisplayErrorUnknown); 212c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } 213d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 214d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 215d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 216d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case ANetworkSession::kWhatClientConnected: 217d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 218d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID; 219d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("sessionID", &sessionID)); 220d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 221c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientSessionID > 0) { 222c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber ALOGW("A client tried to connect, but we already " 223c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber "have one."); 224d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 225c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mNetSession->destroySession(sessionID); 226c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber break; 227c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } 228c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 229ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber CHECK_EQ(mState, AWAITING_CLIENT_CONNECTION); 230ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 231c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findString("client-ip", &mClientInfo.mRemoteIP)); 232c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findString("server-ip", &mClientInfo.mLocalIP)); 233c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 234c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientInfo.mRemoteIP == mClientInfo.mLocalIP) { 235c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber // Disallow connections from the local interface 236c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber // for security reasons. 237c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mNetSession->destroySession(sessionID); 238c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber break; 239c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } 240d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 241c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findInt32( 242c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber "server-port", &mClientInfo.mLocalPort)); 243c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mPlaybackSessionID = -1; 244c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 245c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientSessionID = sessionID; 246c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 247c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber ALOGI("We now have a client (%d) connected.", sessionID); 248d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 249ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = AWAITING_CLIENT_SETUP; 250ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 251d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = sendM1(sessionID); 252d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK_EQ(err, (status_t)OK); 253d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 254d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 255d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 256d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case ANetworkSession::kWhatData: 257d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 258b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber status_t err = onReceiveClientData(msg); 259b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 260b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err != OK) { 261ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError( 262ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber IRemoteDisplayClient::kDisplayErrorUnknown); 263b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 2645131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 2655131d127a042ee88f903370be88845dc8c9f8578Andreas Huber#if 0 2665131d127a042ee88f903370be88845dc8c9f8578Andreas Huber // testing only. 2675131d127a042ee88f903370be88845dc8c9f8578Andreas Huber char val[PROPERTY_VALUE_MAX]; 2685131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (property_get("media.wfd.trigger", val, NULL)) { 2695131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (!strcasecmp(val, "pause") && mState == PLAYING) { 2705131d127a042ee88f903370be88845dc8c9f8578Andreas Huber mState = PLAYING_TO_PAUSED; 2715131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sendTrigger(mClientSessionID, TRIGGER_PAUSE); 2725131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } else if (!strcasecmp(val, "play") && mState == PAUSED) { 2735131d127a042ee88f903370be88845dc8c9f8578Andreas Huber mState = PAUSED_TO_PLAYING; 2745131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sendTrigger(mClientSessionID, TRIGGER_PLAY); 2755131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 2765131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 2775131d127a042ee88f903370be88845dc8c9f8578Andreas Huber#endif 278d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 279d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 280d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 281126568c7aeeb5570789e70a310477f44dbdbd885Andreas Huber case ANetworkSession::kWhatNetworkStall: 282126568c7aeeb5570789e70a310477f44dbdbd885Andreas Huber { 283126568c7aeeb5570789e70a310477f44dbdbd885Andreas Huber break; 284126568c7aeeb5570789e70a310477f44dbdbd885Andreas Huber } 285126568c7aeeb5570789e70a310477f44dbdbd885Andreas Huber 286d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber default: 287d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber TRESPASS(); 288d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 289d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 290d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 291d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 292d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case kWhatStop: 293d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 294eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber CHECK(msg->senderAwaitsResponse(&mStopReplyID)); 295d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 296ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber CHECK_LT(mState, AWAITING_CLIENT_TEARDOWN); 297ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 298ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber if (mState >= AWAITING_CLIENT_PLAY) { 299ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber // We have a session, i.e. a previous SETUP succeeded. 300ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 3015131d127a042ee88f903370be88845dc8c9f8578Andreas Huber status_t err = sendTrigger( 3025131d127a042ee88f903370be88845dc8c9f8578Andreas Huber mClientSessionID, TRIGGER_TEARDOWN); 3030b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber 304ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber if (err == OK) { 305ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = AWAITING_CLIENT_TEARDOWN; 306ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 307ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber (new AMessage(kWhatTeardownTriggerTimedOut, id()))->post( 308ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber kTeardownTriggerTimeouSecs * 1000000ll); 309ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 310ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber break; 311ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber } 312ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 313ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber // fall through. 314b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 315d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 316eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber finishStop(); 317d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 318d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 319d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 3205131d127a042ee88f903370be88845dc8c9f8578Andreas Huber case kWhatPause: 3215131d127a042ee88f903370be88845dc8c9f8578Andreas Huber { 3225131d127a042ee88f903370be88845dc8c9f8578Andreas Huber uint32_t replyID; 3235131d127a042ee88f903370be88845dc8c9f8578Andreas Huber CHECK(msg->senderAwaitsResponse(&replyID)); 3245131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 3255131d127a042ee88f903370be88845dc8c9f8578Andreas Huber status_t err = OK; 3265131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 3275131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (mState != PLAYING) { 3285131d127a042ee88f903370be88845dc8c9f8578Andreas Huber err = INVALID_OPERATION; 3295131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } else { 3305131d127a042ee88f903370be88845dc8c9f8578Andreas Huber mState = PLAYING_TO_PAUSED; 3315131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sendTrigger(mClientSessionID, TRIGGER_PAUSE); 3325131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 3335131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 3345131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> response = new AMessage; 3355131d127a042ee88f903370be88845dc8c9f8578Andreas Huber response->setInt32("err", err); 3365131d127a042ee88f903370be88845dc8c9f8578Andreas Huber response->postReply(replyID); 3375131d127a042ee88f903370be88845dc8c9f8578Andreas Huber break; 3385131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 3395131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 3405131d127a042ee88f903370be88845dc8c9f8578Andreas Huber case kWhatResume: 3415131d127a042ee88f903370be88845dc8c9f8578Andreas Huber { 3425131d127a042ee88f903370be88845dc8c9f8578Andreas Huber uint32_t replyID; 3435131d127a042ee88f903370be88845dc8c9f8578Andreas Huber CHECK(msg->senderAwaitsResponse(&replyID)); 3445131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 3455131d127a042ee88f903370be88845dc8c9f8578Andreas Huber status_t err = OK; 3465131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 3475131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (mState != PAUSED) { 3485131d127a042ee88f903370be88845dc8c9f8578Andreas Huber err = INVALID_OPERATION; 3495131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } else { 3505131d127a042ee88f903370be88845dc8c9f8578Andreas Huber mState = PAUSED_TO_PLAYING; 3515131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sendTrigger(mClientSessionID, TRIGGER_PLAY); 3525131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 3535131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 3545131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> response = new AMessage; 3555131d127a042ee88f903370be88845dc8c9f8578Andreas Huber response->setInt32("err", err); 3565131d127a042ee88f903370be88845dc8c9f8578Andreas Huber response->postReply(replyID); 3575131d127a042ee88f903370be88845dc8c9f8578Andreas Huber break; 3585131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 3595131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 360d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case kWhatReapDeadClients: 361d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 362d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mReaperPending = false; 363d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 364c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientSessionID == 0 365c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber || mClientInfo.mPlaybackSession == NULL) { 366c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber break; 367d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 368d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 369c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientInfo.mPlaybackSession->getLastLifesignUs() 370c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber + kPlaybackSessionTimeoutUs < ALooper::GetNowUs()) { 371c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber ALOGI("playback session timed out, reaping."); 372c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 373ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mNetSession->destroySession(mClientSessionID); 374ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClientSessionID = 0; 375ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 376ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError( 377ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber IRemoteDisplayClient::kDisplayErrorUnknown); 378c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } else { 379d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber scheduleReaper(); 380d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 381d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 382d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 383d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 384d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case kWhatPlaybackSessionNotify: 385d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 386d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 387d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("playbackSessionID", &playbackSessionID)); 388d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 389d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t what; 390d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("what", &what)); 391d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 392c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (what == PlaybackSession::kWhatSessionDead) { 393c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber ALOGI("playback session wants to quit."); 394c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 395ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError( 396ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber IRemoteDisplayClient::kDisplayErrorUnknown); 397c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } else if (what == PlaybackSession::kWhatSessionEstablished) { 3980b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber mPlaybackSessionEstablished = true; 3990b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber 400c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClient != NULL) { 40194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (!mSinkSupportsVideo) { 40294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mClient->onDisplayConnected( 40394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber NULL, // SurfaceTexture 40494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 0, // width, 40594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 0, // height, 40694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mUsingHDCP 40794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ? IRemoteDisplayClient::kDisplayFlagSecure 40894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber : 0); 40994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } else { 41094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber size_t width, height; 41194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 41294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber CHECK(VideoFormats::GetConfiguration( 41394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mChosenVideoResolutionType, 41494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mChosenVideoResolutionIndex, 41594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber &width, 41694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber &height, 41794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber NULL /* framesPerSecond */, 41894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber NULL /* interlaced */)); 41994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 42094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mClient->onDisplayConnected( 42194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mClientInfo.mPlaybackSession->getSurfaceTexture(), 42294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber width, 42394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber height, 42494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mUsingHDCP 42594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ? IRemoteDisplayClient::kDisplayFlagSecure 42694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber : 0); 42794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } 428c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } 429ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 4300b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber finishPlay(); 4310b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber 432ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber if (mState == ABOUT_TO_PLAY) { 433ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = PLAYING; 434ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber } 43596fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber } else if (what == PlaybackSession::kWhatSessionDestroyed) { 43696fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber disconnectClient2(); 437c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } else { 438c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_EQ(what, PlaybackSession::kWhatBinaryData); 439d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 440c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber int32_t channel; 441c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findInt32("channel", &channel)); 442d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 443c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber sp<ABuffer> data; 444c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findBuffer("data", &data)); 445d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 446c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_LE(channel, 0xffu); 447c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_LE(data->size(), 0xffffu); 448d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 449c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber int32_t sessionID; 450c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findInt32("sessionID", &sessionID)); 451d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 452c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber char header[4]; 453c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber header[0] = '$'; 454c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber header[1] = channel; 455c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber header[2] = data->size() >> 8; 456c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber header[3] = data->size() & 0xff; 457d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 458c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mNetSession->sendRequest( 459c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber sessionID, header, sizeof(header)); 460d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 461c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mNetSession->sendRequest( 462c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber sessionID, data->data(), data->size()); 463d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 464d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 465d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 466d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 467b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber case kWhatKeepAlive: 468b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber { 469b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber int32_t sessionID; 470b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber CHECK(msg->findInt32("sessionID", &sessionID)); 471b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 472c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientSessionID != sessionID) { 473b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // Obsolete event, client is already gone. 474b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber break; 475b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber } 476b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 477b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber sendM16(sessionID); 478b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber break; 479b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber } 480b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 481ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber case kWhatTeardownTriggerTimedOut: 482ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber { 483ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber if (mState == AWAITING_CLIENT_TEARDOWN) { 484ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber ALOGI("TEARDOWN trigger timed out, forcing disconnection."); 485ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 486ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber CHECK_NE(mStopReplyID, 0); 487ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber finishStop(); 488ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber break; 489ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber } 490ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber break; 491ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber } 492ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 493b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber case kWhatHDCPNotify: 494b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber { 495b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber int32_t msgCode, ext1, ext2; 496b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber CHECK(msg->findInt32("msg", &msgCode)); 497b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber CHECK(msg->findInt32("ext1", &ext1)); 498b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber CHECK(msg->findInt32("ext2", &ext2)); 499b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 500eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber ALOGI("Saw HDCP notification code %d, ext1 %d, ext2 %d", 501b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber msgCode, ext1, ext2); 502b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 503b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber switch (msgCode) { 504b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber case HDCPModule::HDCP_INITIALIZATION_COMPLETE: 505b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber { 506b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mHDCPInitializationComplete = true; 507b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 508b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (mSetupTriggerDeferred) { 509b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mSetupTriggerDeferred = false; 510b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 5115131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sendTrigger(mClientSessionID, TRIGGER_SETUP); 512b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 513b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber break; 514b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 515b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 516eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber case HDCPModule::HDCP_SHUTDOWN_COMPLETE: 517ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber case HDCPModule::HDCP_SHUTDOWN_FAILED: 518eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber { 519ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber // Ugly hack to make sure that the call to 520ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber // HDCPObserver::notify is completely handled before 521ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber // we clear the HDCP instance and unload the shared 522ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber // library :( 523ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber (new AMessage(kWhatFinishStop2, id()))->post(300000ll); 524eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber break; 525eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber } 526eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber 527b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber default: 528b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber { 529ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber ALOGE("HDCP failure, shutting down."); 530ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 531ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError( 532ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber IRemoteDisplayClient::kDisplayErrorUnknown); 533b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber break; 534b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 535b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 536b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber break; 537b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 538ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 539ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber case kWhatFinishStop2: 540ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber { 541ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber finishStop2(); 542ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber break; 543ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber } 544b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 545d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber case kWhatTimeSyncerNotify: 546d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber { 547d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber break; 548d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber } 549d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber 550d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber default: 551d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber TRESPASS(); 552d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 553d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 554d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 555d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubervoid WifiDisplaySource::registerResponseHandler( 556d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, int32_t cseq, HandleRTSPResponseFunc func) { 557d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ResponseID id; 558d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber id.mSessionID = sessionID; 559d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber id.mCSeq = cseq; 560d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mResponseHandlers.add(id, func); 561d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 562d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 563d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::sendM1(int32_t sessionID) { 564d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString request = "OPTIONS * RTSP/1.0\r\n"; 565d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&request, mNextCSeq); 566d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 567d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append( 568d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "Require: org.wfa.wfd1.0\r\n" 569d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "\r\n"); 570d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 571d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = 572d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mNetSession->sendRequest(sessionID, request.c_str(), request.size()); 573d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 574d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 575d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 576d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 577d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 578d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber registerResponseHandler( 579d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, mNextCSeq, &WifiDisplaySource::onReceiveM1Response); 580d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 581d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ++mNextCSeq; 582d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 583d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 584d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 585d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 586d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::sendM3(int32_t sessionID) { 587d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString body = 588b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber "wfd_content_protection\r\n" 589d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "wfd_video_formats\r\n" 590d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "wfd_audio_codecs\r\n" 591d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "wfd_client_rtp_ports\r\n"; 592d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 593d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString request = "GET_PARAMETER rtsp://localhost/wfd1.0 RTSP/1.0\r\n"; 594d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&request, mNextCSeq); 595d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 596d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("Content-Type: text/parameters\r\n"); 597d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(StringPrintf("Content-Length: %d\r\n", body.size())); 598d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("\r\n"); 599d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(body); 600d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 601d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = 602d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mNetSession->sendRequest(sessionID, request.c_str(), request.size()); 603d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 604d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 605d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 606d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 607d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 608d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber registerResponseHandler( 609d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, mNextCSeq, &WifiDisplaySource::onReceiveM3Response); 610d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 611d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ++mNextCSeq; 612d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 613d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 614d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 615d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 616d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::sendM4(int32_t sessionID) { 617c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_EQ(sessionID, mClientSessionID); 618d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 61994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber AString body; 62094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 62194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (mSinkSupportsVideo) { 62294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber body.append("wfd_video_formats: "); 62394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 62494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber VideoFormats chosenVideoFormat; 62594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber chosenVideoFormat.disableAll(); 62694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber chosenVideoFormat.setNativeResolution( 62794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mChosenVideoResolutionType, mChosenVideoResolutionIndex); 62894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 6295abf87f9af48149972eeb851ecaea679911da040Andreas Huber body.append(chosenVideoFormat.getFormatSpec(true /* forM4Message */)); 63094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber body.append("\r\n"); 63194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } 63294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 63394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (mSinkSupportsAudio) { 63494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber body.append( 63594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber StringPrintf("wfd_audio_codecs: %s\r\n", 63694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber (mUsingPCMAudio 63794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ? "LPCM 00000002 00" // 2 ch PCM 48kHz 63894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber : "AAC 00000001 00"))); // 2 ch AAC 48kHz 63994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } 64094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 64194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber body.append( 64294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber StringPrintf( 6437cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber "wfd_presentation_URL: rtsp://%s/wfd1.0/streamid=0 none\r\n", 6447cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber mClientInfo.mLocalIP.c_str())); 6457cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber 6467cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber body.append(mWfdClientRtpPorts); 6477cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber body.append("\r\n"); 648d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 649d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString request = "SET_PARAMETER rtsp://localhost/wfd1.0 RTSP/1.0\r\n"; 650d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&request, mNextCSeq); 651d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 652d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("Content-Type: text/parameters\r\n"); 653d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(StringPrintf("Content-Length: %d\r\n", body.size())); 654d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("\r\n"); 655d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(body); 656d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 657d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = 658d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mNetSession->sendRequest(sessionID, request.c_str(), request.size()); 659d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 660d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 661d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 662d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 663d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 664d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber registerResponseHandler( 665d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, mNextCSeq, &WifiDisplaySource::onReceiveM4Response); 666d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 667d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ++mNextCSeq; 668d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 669d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 670d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 671d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 6725131d127a042ee88f903370be88845dc8c9f8578Andreas Huberstatus_t WifiDisplaySource::sendTrigger( 6735131d127a042ee88f903370be88845dc8c9f8578Andreas Huber int32_t sessionID, TriggerType triggerType) { 674ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber AString body = "wfd_trigger_method: "; 6755131d127a042ee88f903370be88845dc8c9f8578Andreas Huber switch (triggerType) { 6765131d127a042ee88f903370be88845dc8c9f8578Andreas Huber case TRIGGER_SETUP: 6775131d127a042ee88f903370be88845dc8c9f8578Andreas Huber body.append("SETUP"); 6785131d127a042ee88f903370be88845dc8c9f8578Andreas Huber break; 6795131d127a042ee88f903370be88845dc8c9f8578Andreas Huber case TRIGGER_TEARDOWN: 6805131d127a042ee88f903370be88845dc8c9f8578Andreas Huber ALOGI("Sending TEARDOWN trigger."); 6815131d127a042ee88f903370be88845dc8c9f8578Andreas Huber body.append("TEARDOWN"); 6825131d127a042ee88f903370be88845dc8c9f8578Andreas Huber break; 6835131d127a042ee88f903370be88845dc8c9f8578Andreas Huber case TRIGGER_PAUSE: 6845131d127a042ee88f903370be88845dc8c9f8578Andreas Huber body.append("PAUSE"); 6855131d127a042ee88f903370be88845dc8c9f8578Andreas Huber break; 6865131d127a042ee88f903370be88845dc8c9f8578Andreas Huber case TRIGGER_PLAY: 6875131d127a042ee88f903370be88845dc8c9f8578Andreas Huber body.append("PLAY"); 6885131d127a042ee88f903370be88845dc8c9f8578Andreas Huber break; 6895131d127a042ee88f903370be88845dc8c9f8578Andreas Huber default: 6905131d127a042ee88f903370be88845dc8c9f8578Andreas Huber TRESPASS(); 691ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber } 692ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 693ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber body.append("\r\n"); 694d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 695d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString request = "SET_PARAMETER rtsp://localhost/wfd1.0 RTSP/1.0\r\n"; 696d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&request, mNextCSeq); 697d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 698d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("Content-Type: text/parameters\r\n"); 699d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(StringPrintf("Content-Length: %d\r\n", body.size())); 700d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("\r\n"); 701d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(body); 702d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 703d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = 704d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mNetSession->sendRequest(sessionID, request.c_str(), request.size()); 705d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 706d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 707d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 708d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 709d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 710d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber registerResponseHandler( 711d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, mNextCSeq, &WifiDisplaySource::onReceiveM5Response); 712d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 713d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ++mNextCSeq; 714d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 715d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 716d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 717d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 718b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huberstatus_t WifiDisplaySource::sendM16(int32_t sessionID) { 719b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber AString request = "GET_PARAMETER rtsp://localhost/wfd1.0 RTSP/1.0\r\n"; 720b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber AppendCommonResponse(&request, mNextCSeq); 721b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 722c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_EQ(sessionID, mClientSessionID); 723c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber request.append( 724c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber StringPrintf("Session: %d\r\n", mClientInfo.mPlaybackSessionID)); 725a438123bd96c7faf145683876702387efe5628d9Andreas Huber request.append("\r\n"); // Empty body 726b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 727b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber status_t err = 728b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber mNetSession->sendRequest(sessionID, request.c_str(), request.size()); 729b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 730b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber if (err != OK) { 731b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber return err; 732b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber } 733b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 734b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber registerResponseHandler( 735b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber sessionID, mNextCSeq, &WifiDisplaySource::onReceiveM16Response); 736b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 737b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber ++mNextCSeq; 738b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 739b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber return OK; 740b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber} 741b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 742d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::onReceiveM1Response( 743d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, const sp<ParsedMessage> &msg) { 744d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t statusCode; 745d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!msg->getStatusCode(&statusCode)) { 746d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_MALFORMED; 747d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 748d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 749d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (statusCode != 200) { 750d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_UNSUPPORTED; 751d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 752d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 753d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 754d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 755d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 756d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber// sink_audio_list := ("LPCM"|"AAC"|"AC3" HEXDIGIT*8 HEXDIGIT*2) 757d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber// (", " sink_audio_list)* 758d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huberstatic void GetAudioModes(const char *s, const char *prefix, uint32_t *modes) { 759d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber *modes = 0; 760d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 761d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber size_t prefixLen = strlen(prefix); 762d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 763d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber while (*s != '0') { 764d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber if (!strncmp(s, prefix, prefixLen) && s[prefixLen] == ' ') { 765d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber unsigned latency; 766d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber if (sscanf(&s[prefixLen + 1], "%08x %02x", modes, &latency) != 2) { 767d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber *modes = 0; 768d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 769d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 770d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber return; 771d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 772d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 773d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber char *commaPos = strchr(s, ','); 774d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber if (commaPos != NULL) { 775d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber s = commaPos + 1; 776d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 777d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber while (isspace(*s)) { 778d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber ++s; 779d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 780d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } else { 781d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber break; 782d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 783d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 784d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber} 785d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 786d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::onReceiveM3Response( 787d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, const sp<ParsedMessage> &msg) { 788d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t statusCode; 789d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!msg->getStatusCode(&statusCode)) { 790d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_MALFORMED; 791d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 792d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 793d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (statusCode != 200) { 794d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_UNSUPPORTED; 795d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 796d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 797b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<Parameters> params = 798b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber Parameters::Parse(msg->getContent(), strlen(msg->getContent())); 799b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 800b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (params == NULL) { 801b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 802b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 803b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 804b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber AString value; 805d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber if (!params->findParameter("wfd_client_rtp_ports", &value)) { 806d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber ALOGE("Sink doesn't report its choice of wfd_client_rtp_ports."); 807d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber return ERROR_MALFORMED; 808d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 809d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 8107cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber unsigned port0 = 0, port1 = 0; 811d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber if (sscanf(value.c_str(), 812d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber "RTP/AVP/UDP;unicast %u %u mode=play", 813d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber &port0, 8147cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber &port1) == 2 8157cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber || sscanf(value.c_str(), 8167cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber "RTP/AVP/TCP;unicast %u %u mode=play", 8177cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber &port0, 8187cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber &port1) == 2) { 8197cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber if (port0 == 0 || port0 > 65535 || port1 != 0) { 8207cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber ALOGE("Sink chose its wfd_client_rtp_ports poorly (%s)", 8217cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber value.c_str()); 8227cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber 8237cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber return ERROR_MALFORMED; 8247cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber } 8257cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber } else if (strcmp(value.c_str(), "RTP/AVP/TCP;interleaved mode=play")) { 8267cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber ALOGE("Unsupported value for wfd_client_rtp_ports (%s)", 827d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber value.c_str()); 828d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 8297cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber return ERROR_UNSUPPORTED; 830d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 831d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 8327cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber mWfdClientRtpPorts = value; 833d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber mChosenRTPPort = port0; 834d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 83594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (!params->findParameter("wfd_video_formats", &value)) { 83694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGE("Sink doesn't report its choice of wfd_video_formats."); 83794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber return ERROR_MALFORMED; 83894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } 83994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 84094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mSinkSupportsVideo = false; 84194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 84294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (!(value == "none")) { 84394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mSinkSupportsVideo = true; 84494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (!mSupportedSinkVideoFormats.parseFormatSpec(value.c_str())) { 84594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGE("Failed to parse sink provided wfd_video_formats (%s)", 84694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber value.c_str()); 84794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 84894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber return ERROR_MALFORMED; 84994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } 85094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 85194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (!VideoFormats::PickBestFormat( 85294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mSupportedSinkVideoFormats, 85394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mSupportedSourceVideoFormats, 85494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber &mChosenVideoResolutionType, 85594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber &mChosenVideoResolutionIndex)) { 85694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGE("Sink and source share no commonly supported video " 85794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber "formats."); 85894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 85994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber return ERROR_UNSUPPORTED; 86094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } 86194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 86294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber size_t width, height, framesPerSecond; 86394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber bool interlaced; 86494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber CHECK(VideoFormats::GetConfiguration( 86594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mChosenVideoResolutionType, 86694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mChosenVideoResolutionIndex, 86794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber &width, 86894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber &height, 86994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber &framesPerSecond, 87094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber &interlaced)); 87194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 87294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGI("Picked video resolution %u x %u %c%u", 87394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber width, height, interlaced ? 'i' : 'p', framesPerSecond); 87494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } else { 87594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGI("Sink doesn't support video at all."); 87694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } 87794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 878d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber if (!params->findParameter("wfd_audio_codecs", &value)) { 879d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber ALOGE("Sink doesn't report its choice of wfd_audio_codecs."); 880d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber return ERROR_MALFORMED; 881d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 882d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 88394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mSinkSupportsAudio = false; 884d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 88594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (!(value == "none")) { 88694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mSinkSupportsAudio = true; 887d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 88894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber uint32_t modes; 88994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber GetAudioModes(value.c_str(), "AAC", &modes); 890d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 89194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber bool supportsAAC = (modes & 1) != 0; // AAC 2ch 48kHz 892d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 89394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber GetAudioModes(value.c_str(), "LPCM", &modes); 894d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 89594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber bool supportsPCM = (modes & 2) != 0; // LPCM 2ch 48kHz 89694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 89794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber char val[PROPERTY_VALUE_MAX]; 89894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (supportsPCM 89994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber && property_get("media.wfd.use-pcm-audio", val, NULL) 90094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber && (!strcasecmp("true", val) || !strcmp("1", val))) { 90194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGI("Using PCM audio."); 90294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mUsingPCMAudio = true; 90394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } else if (supportsAAC) { 90494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGI("Using AAC audio."); 90594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mUsingPCMAudio = false; 90694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } else if (supportsPCM) { 90794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGI("Using PCM audio."); 90894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mUsingPCMAudio = true; 90994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } else { 91094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGI("Sink doesn't support an audio format we do."); 91194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber return ERROR_UNSUPPORTED; 91294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } 913d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } else { 91494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGI("Sink doesn't support audio at all."); 91594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } 91694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 91794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (!mSinkSupportsVideo && !mSinkSupportsAudio) { 91894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGE("Sink supports neither video nor audio..."); 919d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber return ERROR_UNSUPPORTED; 920d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 921d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 9220328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mUsingHDCP = false; 923b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (!params->findParameter("wfd_content_protection", &value)) { 9240328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber ALOGI("Sink doesn't appear to support content protection."); 9250328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber } else if (value == "none") { 9260328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber ALOGI("Sink does not support content protection."); 9270328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber } else { 9280328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mUsingHDCP = true; 929b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 9300328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber bool isHDCP2_0 = false; 9310328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber if (value.startsWith("HDCP2.0 ")) { 9320328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber isHDCP2_0 = true; 9330328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber } else if (!value.startsWith("HDCP2.1 ")) { 9340328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber ALOGE("malformed wfd_content_protection: '%s'", value.c_str()); 935b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 9360328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber return ERROR_MALFORMED; 9370328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber } 938b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 9390328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber int32_t hdcpPort; 9400328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber if (!ParsedMessage::GetInt32Attribute( 9410328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber value.c_str() + 8, "port", &hdcpPort) 9420328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber || hdcpPort < 1 || hdcpPort > 65535) { 9430328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber return ERROR_MALFORMED; 9440328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber } 945b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 9460328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mIsHDCP2_0 = isHDCP2_0; 9470328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mHDCPPort = hdcpPort; 948b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 9490328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber status_t err = makeHDCP(); 9500328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber if (err != OK) { 9510224bf170a3904576bba81593eaab113c5d3a4e7Andreas Huber ALOGE("Unable to instantiate HDCP component. " 9520224bf170a3904576bba81593eaab113c5d3a4e7Andreas Huber "Not using HDCP after all."); 9530224bf170a3904576bba81593eaab113c5d3a4e7Andreas Huber 9540224bf170a3904576bba81593eaab113c5d3a4e7Andreas Huber mUsingHDCP = false; 9550328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber } 956b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 957b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 958d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return sendM4(sessionID); 959d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 960d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 961d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::onReceiveM4Response( 962d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, const sp<ParsedMessage> &msg) { 963d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t statusCode; 964d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!msg->getStatusCode(&statusCode)) { 965d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_MALFORMED; 966d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 967d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 968d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (statusCode != 200) { 969d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_UNSUPPORTED; 970d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 971d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 9720328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber if (mUsingHDCP && !mHDCPInitializationComplete) { 973b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber ALOGI("Deferring SETUP trigger until HDCP initialization completes."); 974b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 975b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mSetupTriggerDeferred = true; 976b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 977b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 978b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 9795131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return sendTrigger(sessionID, TRIGGER_SETUP); 980d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 981d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 982d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::onReceiveM5Response( 983d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, const sp<ParsedMessage> &msg) { 984d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t statusCode; 985d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!msg->getStatusCode(&statusCode)) { 986d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_MALFORMED; 987d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 988d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 989d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (statusCode != 200) { 990d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_UNSUPPORTED; 991d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 992d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 993d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 994d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 995d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 996b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huberstatus_t WifiDisplaySource::onReceiveM16Response( 997b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber int32_t sessionID, const sp<ParsedMessage> &msg) { 998b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // If only the response was required to include a "Session:" header... 999b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 1000c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_EQ(sessionID, mClientSessionID); 1001b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 1002c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientInfo.mPlaybackSession != NULL) { 1003c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mPlaybackSession->updateLiveness(); 1004b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 1005b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber scheduleKeepAlive(sessionID); 1006b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber } 1007b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 1008b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber return OK; 1009b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber} 1010b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 1011d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubervoid WifiDisplaySource::scheduleReaper() { 1012d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (mReaperPending) { 1013d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return; 1014d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1015d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1016d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mReaperPending = true; 1017d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber (new AMessage(kWhatReapDeadClients, id()))->post(kReaperIntervalUs); 1018d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1019d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1020b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Hubervoid WifiDisplaySource::scheduleKeepAlive(int32_t sessionID) { 1021b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // We need to send updates at least 5 secs before the timeout is set to 1022b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // expire, make sure the timeout is greater than 5 secs to begin with. 1023b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber CHECK_GT(kPlaybackSessionTimeoutUs, 5000000ll); 1024b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 1025b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber sp<AMessage> msg = new AMessage(kWhatKeepAlive, id()); 1026b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber msg->setInt32("sessionID", sessionID); 1027b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber msg->post(kPlaybackSessionTimeoutUs - 5000000ll); 1028b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber} 1029b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 1030b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onReceiveClientData(const sp<AMessage> &msg) { 1031d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID; 1032d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("sessionID", &sessionID)); 1033d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1034d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<RefBase> obj; 1035d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findObject("data", &obj)); 1036d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1037d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<ParsedMessage> data = 1038d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber static_cast<ParsedMessage *>(obj.get()); 1039d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1040d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ALOGV("session %d received '%s'", 1041d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, data->debugString().c_str()); 1042d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1043d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString method; 1044d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString uri; 1045d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber data->getRequestField(0, &method); 1046d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1047d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq; 1048d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!data->findInt32("cseq", &cseq)) { 1049d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "400 Bad Request", -1 /* cseq */); 1050b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1051d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1052d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1053d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (method.startsWith("RTSP/")) { 1054d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // This is a response. 1055d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1056d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ResponseID id; 1057d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber id.mSessionID = sessionID; 1058d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber id.mCSeq = cseq; 1059d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1060d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ssize_t index = mResponseHandlers.indexOfKey(id); 1061d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1062d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (index < 0) { 1063d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ALOGW("Received unsolicited server response, cseq %d", cseq); 1064b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1065d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1066d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1067d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber HandleRTSPResponseFunc func = mResponseHandlers.valueAt(index); 1068d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mResponseHandlers.removeItemsAt(index); 1069d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1070d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = (this->*func)(sessionID, data); 1071d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1072d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 1073d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ALOGW("Response handler for session %d, cseq %d returned " 1074d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "err %d (%s)", 1075d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, cseq, err, strerror(-err)); 1076d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1077b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1078d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1079d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1080b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 1081b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1082d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1083b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber AString version; 1084b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber data->getRequestField(2, &version); 1085b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (!(version == AString("RTSP/1.0"))) { 1086b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sendErrorResponse(sessionID, "505 RTSP Version not supported", cseq); 1087b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_UNSUPPORTED; 1088b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1089d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1090b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber status_t err; 1091b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (method == "OPTIONS") { 1092b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onOptionsRequest(sessionID, cseq, data); 1093b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "SETUP") { 1094b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onSetupRequest(sessionID, cseq, data); 1095b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "PLAY") { 1096b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onPlayRequest(sessionID, cseq, data); 1097b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "PAUSE") { 1098b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onPauseRequest(sessionID, cseq, data); 1099b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "TEARDOWN") { 1100b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onTeardownRequest(sessionID, cseq, data); 1101b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "GET_PARAMETER") { 1102b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onGetParameterRequest(sessionID, cseq, data); 1103b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "SET_PARAMETER") { 1104b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onSetParameterRequest(sessionID, cseq, data); 1105b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else { 1106b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sendErrorResponse(sessionID, "405 Method Not Allowed", cseq); 1107d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1108b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = ERROR_UNSUPPORTED; 1109b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1110d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1111b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1112d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1113d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1114b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onOptionsRequest( 1115d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1116d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1117d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1118d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1119d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1120d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1121d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1122d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession != NULL) { 1123d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber playbackSession->updateLiveness(); 1124d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1125d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1126d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1127d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq); 1128d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1129d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append( 1130b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber "Public: org.wfa.wfd1.0, SETUP, TEARDOWN, PLAY, PAUSE, " 1131d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "GET_PARAMETER, SET_PARAMETER\r\n"); 1132d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1133d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1134d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1135d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = mNetSession->sendRequest(sessionID, response.c_str()); 1136d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1137b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err == OK) { 1138b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = sendM3(sessionID); 1139b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1140b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1141b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1142d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1143d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1144b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onSetupRequest( 1145d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1146d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1147d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1148c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_EQ(sessionID, mClientSessionID); 1149c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientInfo.mPlaybackSessionID != -1) { 1150b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // We only support a single playback session per client. 1151b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // This is due to the reversed keep-alive design in the wfd specs... 1152b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber sendErrorResponse(sessionID, "400 Bad Request", cseq); 1153b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1154b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber } 1155b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 1156d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString transport; 1157d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!data->findString("transport", &transport)) { 1158d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "400 Bad Request", cseq); 1159b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1160d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1161d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 11622aea9552aeba92bbaf9e56c666049ea2d14057b5Andreas Huber RTPSender::TransportMode rtpMode = RTPSender::TRANSPORT_UDP; 1163d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1164d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int clientRtp, clientRtcp; 1165d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (transport.startsWith("RTP/AVP/TCP;")) { 1166d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString interleaved; 1167bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber if (ParsedMessage::GetAttribute( 1168d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber transport.c_str(), "interleaved", &interleaved) 1169bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber && sscanf(interleaved.c_str(), "%d-%d", 1170bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber &clientRtp, &clientRtcp) == 2) { 11712aea9552aeba92bbaf9e56c666049ea2d14057b5Andreas Huber rtpMode = RTPSender::TRANSPORT_TCP_INTERLEAVED; 1172bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } else { 1173bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber bool badRequest = false; 1174bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber 1175bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber AString clientPort; 1176bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber if (!ParsedMessage::GetAttribute( 1177bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber transport.c_str(), "client_port", &clientPort)) { 1178bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber badRequest = true; 1179bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } else if (sscanf(clientPort.c_str(), "%d-%d", 1180bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber &clientRtp, &clientRtcp) == 2) { 1181bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } else if (sscanf(clientPort.c_str(), "%d", &clientRtp) == 1) { 1182bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber // No RTCP. 1183bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber clientRtcp = -1; 1184bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } else { 1185bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber badRequest = true; 1186bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } 1187bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber 1188bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber if (badRequest) { 1189bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber sendErrorResponse(sessionID, "400 Bad Request", cseq); 1190b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1191bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } 1192d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 11932aea9552aeba92bbaf9e56c666049ea2d14057b5Andreas Huber rtpMode = RTPSender::TRANSPORT_TCP; 1194bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } 1195d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else if (transport.startsWith("RTP/AVP;unicast;") 1196d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber || transport.startsWith("RTP/AVP/UDP;unicast;")) { 1197d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber bool badRequest = false; 1198d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1199d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString clientPort; 1200d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!ParsedMessage::GetAttribute( 1201d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber transport.c_str(), "client_port", &clientPort)) { 1202d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber badRequest = true; 1203d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else if (sscanf(clientPort.c_str(), "%d-%d", 1204d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber &clientRtp, &clientRtcp) == 2) { 1205d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else if (sscanf(clientPort.c_str(), "%d", &clientRtp) == 1) { 1206d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // No RTCP. 1207d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtcp = -1; 1208d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else { 1209d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber badRequest = true; 1210d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1211d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1212d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (badRequest) { 1213d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "400 Bad Request", cseq); 1214b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1215d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1216d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#if 1 1217a438123bd96c7faf145683876702387efe5628d9Andreas Huber // The older LG dongles doesn't specify client_port=xxx apparently. 1218d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else if (transport == "RTP/AVP/UDP;unicast") { 1219d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtp = 19000; 122028e17ed7e2fbb254fb99481b74db85e427c905eeAndreas Huber clientRtcp = -1; 1221d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#endif 1222d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else { 1223d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "461 Unsupported Transport", cseq); 1224b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_UNSUPPORTED; 1225d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1226d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1227d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID = makeUniquePlaybackSessionID(); 1228d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1229d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<AMessage> notify = new AMessage(kWhatPlaybackSessionNotify, id()); 1230d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber notify->setInt32("playbackSessionID", playbackSessionID); 1231d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber notify->setInt32("sessionID", sessionID); 1232d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1233d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 12340b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber new PlaybackSession( 12350b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber mNetSession, notify, mInterfaceAddr, mHDCP, mMediaPath.c_str()); 1236d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1237d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber looper()->registerHandler(playbackSession); 1238d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1239d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString uri; 1240d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber data->getRequestField(1, &uri); 1241d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1242d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (strncasecmp("rtsp://", uri.c_str(), 7)) { 1243d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "400 Bad Request", cseq); 1244b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1245d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1246d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1247d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!(uri.startsWith("rtsp://") && uri.endsWith("/wfd1.0/streamid=0"))) { 1248d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "404 Not found", cseq); 1249b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1250d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1251d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 12522aea9552aeba92bbaf9e56c666049ea2d14057b5Andreas Huber RTPSender::TransportMode rtcpMode = RTPSender::TRANSPORT_UDP; 12532aea9552aeba92bbaf9e56c666049ea2d14057b5Andreas Huber if (clientRtcp < 0) { 12542aea9552aeba92bbaf9e56c666049ea2d14057b5Andreas Huber rtcpMode = RTPSender::TRANSPORT_NONE; 12552aea9552aeba92bbaf9e56c666049ea2d14057b5Andreas Huber } 12562aea9552aeba92bbaf9e56c666049ea2d14057b5Andreas Huber 1257d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = playbackSession->init( 1258c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mRemoteIP.c_str(), 1259d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtp, 12602aea9552aeba92bbaf9e56c666049ea2d14057b5Andreas Huber rtpMode, 1261d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtcp, 12622aea9552aeba92bbaf9e56c666049ea2d14057b5Andreas Huber rtcpMode, 126394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mSinkSupportsAudio, 126494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mUsingPCMAudio, 126594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mSinkSupportsVideo, 126694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mChosenVideoResolutionType, 126794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mChosenVideoResolutionIndex); 1268d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1269d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 1270d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber looper()->unregisterHandler(playbackSession->id()); 1271d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber playbackSession.clear(); 1272d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1273d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1274d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber switch (err) { 1275d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case OK: 1276d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 1277d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case -ENOENT: 1278d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "404 Not Found", cseq); 1279b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1280d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber default: 1281d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "403 Forbidden", cseq); 1282b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1283d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1284d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1285c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mPlaybackSessionID = playbackSessionID; 1286c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mPlaybackSession = playbackSession; 1287b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 1288d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1289d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1290d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 12912aea9552aeba92bbaf9e56c666049ea2d14057b5Andreas Huber if (rtpMode == RTPSender::TRANSPORT_TCP_INTERLEAVED) { 1292d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append( 1293d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber StringPrintf( 1294d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "Transport: RTP/AVP/TCP;interleaved=%d-%d;", 1295d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtp, clientRtcp)); 1296d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else { 1297d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t serverRtp = playbackSession->getRTPPort(); 1298d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1299bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber AString transportString = "UDP"; 13002aea9552aeba92bbaf9e56c666049ea2d14057b5Andreas Huber if (rtpMode == RTPSender::TRANSPORT_TCP) { 1301bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber transportString = "TCP"; 1302bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } 1303bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber 1304d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (clientRtcp >= 0) { 1305d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append( 1306d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber StringPrintf( 1307bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber "Transport: RTP/AVP/%s;unicast;client_port=%d-%d;" 1308d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "server_port=%d-%d\r\n", 1309bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber transportString.c_str(), 1310d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtp, clientRtcp, serverRtp, serverRtp + 1)); 1311d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else { 1312d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append( 1313d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber StringPrintf( 1314bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber "Transport: RTP/AVP/%s;unicast;client_port=%d;" 1315d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "server_port=%d\r\n", 1316bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber transportString.c_str(), 1317d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtp, serverRtp)); 1318d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1319d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1320d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1321d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1322d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1323d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber err = mNetSession->sendRequest(sessionID, response.c_str()); 1324b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1325b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err != OK) { 1326b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1327b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1328d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1329ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = AWAITING_CLIENT_PLAY; 1330ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 1331d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber scheduleReaper(); 1332b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber scheduleKeepAlive(sessionID); 1333b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1334b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 1335d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1336d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1337b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onPlayRequest( 1338d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1339d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1340d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1341d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1342d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1343d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1344d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1345d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession == NULL) { 1346d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "454 Session Not Found", cseq); 1347b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1348d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1349d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1350ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGI("Received PLAY request."); 13510b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber if (mPlaybackSessionEstablished) { 13520b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber finishPlay(); 13530b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber } else { 13540b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber ALOGI("deferring PLAY request until session established."); 13550b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber } 1356d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1357d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1358d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1359d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("Range: npt=now-\r\n"); 1360d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1361d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 13620b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber status_t err = mNetSession->sendRequest(sessionID, response.c_str()); 1363b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1364b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err != OK) { 1365b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1366b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 13670b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber 13685131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (mState == PAUSED_TO_PLAYING) { 13695131d127a042ee88f903370be88845dc8c9f8578Andreas Huber mState = PLAYING; 13705131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return OK; 13715131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 13725131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 1373ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber CHECK_EQ(mState, AWAITING_CLIENT_PLAY); 1374ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = ABOUT_TO_PLAY; 1375ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 1376b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 1377d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1378d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 13790b530f1050150bb751ae642d5a9dce34141d9475Andreas Hubervoid WifiDisplaySource::finishPlay() { 13800b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber const sp<PlaybackSession> &playbackSession = 13810b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber mClientInfo.mPlaybackSession; 13820b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber 13830b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber status_t err = playbackSession->play(); 13840b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber CHECK_EQ(err, (status_t)OK); 13850b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber} 13860b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber 1387b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onPauseRequest( 1388d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1389d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1390d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1391d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1392d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1393d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1394d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1395d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession == NULL) { 1396d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "454 Session Not Found", cseq); 1397b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1398d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1399d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 14005131d127a042ee88f903370be88845dc8c9f8578Andreas Huber ALOGI("Received PAUSE request."); 14015131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 14025131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (mState != PLAYING_TO_PAUSED) { 14035131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return INVALID_OPERATION; 14045131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 14055131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 1406d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = playbackSession->pause(); 1407d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK_EQ(err, (status_t)OK); 1408d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1409d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1410d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1411d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1412d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1413d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber err = mNetSession->sendRequest(sessionID, response.c_str()); 1414b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 14155131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (err != OK) { 14165131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return err; 14175131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 14185131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 14195131d127a042ee88f903370be88845dc8c9f8578Andreas Huber mState = PAUSED; 14205131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 1421b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1422d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1423d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1424b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onTeardownRequest( 1425d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1426d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1427d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1428ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGI("Received TEARDOWN request."); 1429ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 1430d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1431d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1432d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1433d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1434d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession == NULL) { 1435d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "454 Session Not Found", cseq); 1436b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1437d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1438d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1439d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1440d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1441c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber response.append("Connection: close\r\n"); 1442d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1443d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1444ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mNetSession->sendRequest(sessionID, response.c_str()); 1445c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 1446ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber if (mState == AWAITING_CLIENT_TEARDOWN) { 1447ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber CHECK_NE(mStopReplyID, 0); 1448eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber finishStop(); 1449ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber } else { 1450ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError(IRemoteDisplayClient::kDisplayErrorUnknown); 1451ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber } 1452b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1453b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 1454d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1455d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1456eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Hubervoid WifiDisplaySource::finishStop() { 1457ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGV("finishStop"); 1458ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 1459ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = STOPPING; 1460ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 146196fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber disconnectClientAsync(); 146296fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber} 146396fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber 146496fc6cc65ca93009a759a3a874b82a35771b9714Andreas Hubervoid WifiDisplaySource::finishStopAfterDisconnectingClient() { 146596fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber ALOGV("finishStopAfterDisconnectingClient"); 146696fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber 1467ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber if (mHDCP != NULL) { 1468ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGI("Initiating HDCP shutdown."); 1469ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber mHDCP->shutdownAsync(); 1470eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber return; 1471ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber } 1472ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 1473eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber finishStop2(); 1474eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber} 1475eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber 1476eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Hubervoid WifiDisplaySource::finishStop2() { 1477ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGV("finishStop2"); 1478ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 1479bbe96f0f05a1f1a1b3cfec0d124cb0d63c1ebf2aAndreas Huber if (mHDCP != NULL) { 1480bbe96f0f05a1f1a1b3cfec0d124cb0d63c1ebf2aAndreas Huber mHDCP->setObserver(NULL); 1481bbe96f0f05a1f1a1b3cfec0d124cb0d63c1ebf2aAndreas Huber mHDCPObserver.clear(); 1482bbe96f0f05a1f1a1b3cfec0d124cb0d63c1ebf2aAndreas Huber mHDCP.clear(); 1483bbe96f0f05a1f1a1b3cfec0d124cb0d63c1ebf2aAndreas Huber } 1484eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber 1485ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber if (mSessionID != 0) { 1486ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mNetSession->destroySession(mSessionID); 1487ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mSessionID = 0; 1488ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber } 1489ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 149096fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber ALOGI("We're stopped."); 1491ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = STOPPED; 1492ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 1493ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber status_t err = OK; 1494ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 1495ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber sp<AMessage> response = new AMessage; 1496ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber response->setInt32("err", err); 1497eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber response->postReply(mStopReplyID); 1498ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber} 1499ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 1500b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onGetParameterRequest( 1501d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1502d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1503d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1504d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1505d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1506d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1507d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1508d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession == NULL) { 1509d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "454 Session Not Found", cseq); 1510b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1511d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1512d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1513d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber playbackSession->updateLiveness(); 1514d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1515d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1516d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1517d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1518d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1519d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = mNetSession->sendRequest(sessionID, response.c_str()); 1520b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1521d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1522d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1523b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onSetParameterRequest( 1524d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1525d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1526d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1527d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1528d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1529d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1530d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1531d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession == NULL) { 1532d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "454 Session Not Found", cseq); 1533b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1534d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1535d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1536b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (strstr(data->getContent(), "wfd_idr_request\r\n")) { 1537b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber playbackSession->requestIDRFrame(); 1538b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1539496238cc7551d414067dcbbb4fe3bd801f205f95Andreas Huber 1540d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber playbackSession->updateLiveness(); 1541d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1542d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1543d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1544d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1545d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1546d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = mNetSession->sendRequest(sessionID, response.c_str()); 1547b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1548d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1549d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1550d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber// static 1551d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubervoid WifiDisplaySource::AppendCommonResponse( 1552d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString *response, int32_t cseq, int32_t playbackSessionID) { 1553d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber time_t now = time(NULL); 1554d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber struct tm *now2 = gmtime(&now); 1555d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber char buf[128]; 1556d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber strftime(buf, sizeof(buf), "%a, %d %b %Y %H:%M:%S %z", now2); 1557d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1558d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append("Date: "); 1559d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append(buf); 1560d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append("\r\n"); 1561d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1562d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append("Server: Mine/1.0\r\n"); 1563d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1564d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (cseq >= 0) { 1565d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append(StringPrintf("CSeq: %d\r\n", cseq)); 1566d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1567d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1568d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSessionID >= 0ll) { 1569d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append( 1570d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber StringPrintf( 1571d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "Session: %d;timeout=%lld\r\n", 1572d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber playbackSessionID, kPlaybackSessionTimeoutSecs)); 1573d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1574d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1575d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1576d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubervoid WifiDisplaySource::sendErrorResponse( 1577d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1578d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const char *errorDetail, 1579d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq) { 1580d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response; 1581d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("RTSP/1.0 "); 1582d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append(errorDetail); 1583d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1584d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1585d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq); 1586d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1587d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1588d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1589eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber mNetSession->sendRequest(sessionID, response.c_str()); 1590d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1591d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1592d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberint32_t WifiDisplaySource::makeUniquePlaybackSessionID() const { 1593c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber return rand(); 1594d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1595d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1596d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubersp<WifiDisplaySource::PlaybackSession> WifiDisplaySource::findPlaybackSession( 1597d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data, int32_t *playbackSessionID) const { 1598d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!data->findInt32("session", playbackSessionID)) { 1599c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber // XXX the older dongles do not always include a "Session:" header. 1600c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber *playbackSessionID = mClientInfo.mPlaybackSessionID; 1601c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber return mClientInfo.mPlaybackSession; 1602d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1603d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1604c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (*playbackSessionID != mClientInfo.mPlaybackSessionID) { 1605d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return NULL; 1606d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1607d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1608c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber return mClientInfo.mPlaybackSession; 1609c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber} 1610c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 161196fc6cc65ca93009a759a3a874b82a35771b9714Andreas Hubervoid WifiDisplaySource::disconnectClientAsync() { 161296fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber ALOGV("disconnectClient"); 161396fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber 161496fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber if (mClientInfo.mPlaybackSession == NULL) { 161596fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber disconnectClient2(); 161696fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber return; 161796fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber } 161896fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber 161996fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber if (mClientInfo.mPlaybackSession != NULL) { 162096fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber ALOGV("Destroying PlaybackSession"); 162196fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber mClientInfo.mPlaybackSession->destroyAsync(); 162296fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber } 162396fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber} 162496fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber 162596fc6cc65ca93009a759a3a874b82a35771b9714Andreas Hubervoid WifiDisplaySource::disconnectClient2() { 162696fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber ALOGV("disconnectClient2"); 162796fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber 1628ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber if (mClientInfo.mPlaybackSession != NULL) { 162996fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber looper()->unregisterHandler(mClientInfo.mPlaybackSession->id()); 1630ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClientInfo.mPlaybackSession.clear(); 1631ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber } 1632c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 1633ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber if (mClientSessionID != 0) { 1634c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mNetSession->destroySession(mClientSessionID); 1635c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientSessionID = 0; 1636c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } 1637c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 1638ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayDisconnected(); 163996fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber 164096fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber finishStopAfterDisconnectingClient(); 1641d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1642d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1643b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstruct WifiDisplaySource::HDCPObserver : public BnHDCPObserver { 1644b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber HDCPObserver(const sp<AMessage> ¬ify); 1645b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1646b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber virtual void notify( 1647b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber int msg, int ext1, int ext2, const Parcel *obj); 1648b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1649b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberprivate: 1650b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<AMessage> mNotify; 1651b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1652b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber DISALLOW_EVIL_CONSTRUCTORS(HDCPObserver); 1653b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber}; 1654b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1655b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas HuberWifiDisplaySource::HDCPObserver::HDCPObserver( 1656b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber const sp<AMessage> ¬ify) 1657b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber : mNotify(notify) { 1658b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber} 1659b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1660b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Hubervoid WifiDisplaySource::HDCPObserver::notify( 1661b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber int msg, int ext1, int ext2, const Parcel *obj) { 1662b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<AMessage> notify = mNotify->dup(); 1663b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber notify->setInt32("msg", msg); 1664b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber notify->setInt32("ext1", ext1); 1665b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber notify->setInt32("ext2", ext2); 1666b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber notify->post(); 1667b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber} 1668b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1669b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::makeHDCP() { 1670b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<IServiceManager> sm = defaultServiceManager(); 1671b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<IBinder> binder = sm->getService(String16("media.player")); 1672b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<IMediaPlayerService> service = interface_cast<IMediaPlayerService>(binder); 1673b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber CHECK(service != NULL); 1674b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1675a6a88d9c445e261972c2433254e0a996336e78a4Andreas Huber mHDCP = service->makeHDCP(true /* createEncryptionModule */); 1676b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1677b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (mHDCP == NULL) { 1678b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_UNSUPPORTED; 1679b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1680b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1681b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<AMessage> notify = new AMessage(kWhatHDCPNotify, id()); 1682b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mHDCPObserver = new HDCPObserver(notify); 1683b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1684b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber status_t err = mHDCP->setObserver(mHDCPObserver); 1685b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1686b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err != OK) { 1687b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber ALOGE("Failed to set HDCP observer."); 1688b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1689b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mHDCPObserver.clear(); 1690b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mHDCP.clear(); 1691b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1692b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1693b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1694b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1695ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGI("Initiating HDCP negotiation w/ host %s:%d", 1696b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mClientInfo.mRemoteIP.c_str(), mHDCPPort); 1697b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1698b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = mHDCP->initAsync(mClientInfo.mRemoteIP.c_str(), mHDCPPort); 1699b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1700b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err != OK) { 1701b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1702b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1703b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1704b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 1705b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber} 1706b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1707d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} // namespace android 1708d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1709