WifiDisplaySource.cpp revision 87ecf19404586672008e98babc225e094292ceb5
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" 24a556c4822fc205db0d27834ba5b637c351d73ffaAndreas Huber#include "rtp/RTPSender.h" 25c86ef45279185b474bd6af0a7ae407f8ab577f13Andreas Huber#include "TimeSyncer.h" 26d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 27b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#include <binder/IServiceManager.h> 288ba01021b573889802e67e029225a96f0dfa471aAndy McFadden#include <gui/IGraphicBufferProducer.h> 29b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#include <media/IHDCP.h> 30b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#include <media/IMediaPlayerService.h> 310b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber#include <media/IRemoteDisplayClient.h> 32d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#include <media/stagefright/foundation/ABuffer.h> 33d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#include <media/stagefright/foundation/ADebug.h> 34d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#include <media/stagefright/foundation/AMessage.h> 358060060217ff16cd67c8f6a15c649f44c343acf0Andreas Huber#include <media/stagefright/foundation/ParsedMessage.h> 36d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#include <media/stagefright/MediaErrors.h> 37cd77d4a1d38b7609a03f6826a1ff5fa7c98aa34fAndreas Huber#include <media/stagefright/Utils.h> 38d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 39bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber#include <arpa/inet.h> 40bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber#include <cutils/properties.h> 41bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 42d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber#include <ctype.h> 43d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 44d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubernamespace android { 45d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 46cd77d4a1d38b7609a03f6826a1ff5fa7c98aa34fAndreas Huber// static 47cd77d4a1d38b7609a03f6826a1ff5fa7c98aa34fAndreas Huberconst AString WifiDisplaySource::sUserAgent = MakeUserAgent(); 48cd77d4a1d38b7609a03f6826a1ff5fa7c98aa34fAndreas Huber 490b73d4730202fcad53aefc4314a06e7b95f442f0Andreas HuberWifiDisplaySource::WifiDisplaySource( 500b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber const sp<ANetworkSession> &netSession, 510b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber const sp<IRemoteDisplayClient> &client, 520b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber const char *path) 53ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber : mState(INITIALIZED), 54ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mNetSession(netSession), 550b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber mClient(client), 56d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mSessionID(0), 57ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber mStopReplyID(0), 58d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber mChosenRTPPort(-1), 59e7bd24af08ef0722fb124a550662bcec48c56f86Andreas Huber mUsingPCMAudio(false), 60c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientSessionID(0), 61d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mReaperPending(false), 620328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mNextCSeq(1), 630328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mUsingHDCP(false), 640328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mIsHDCP2_0(false), 650328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mHDCPPort(0), 660328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mHDCPInitializationComplete(false), 670b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber mSetupTriggerDeferred(false), 680b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber mPlaybackSessionEstablished(false) { 690b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber if (path != NULL) { 700b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber mMediaPath.setTo(path); 710b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber } 720b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber 735abf87f9af48149972eeb851ecaea679911da040Andreas Huber mSupportedSourceVideoFormats.disableAll(); 7494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 7594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mSupportedSourceVideoFormats.setNativeResolution( 7694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber VideoFormats::RESOLUTION_CEA, 5); // 1280x720 p30 77308bcaa44e578279e61be32b572fdb0b11b1e4c7Chong Zhang 781ad3eb9441eb509c792c61aa0181b0e74dbe9984Chong Zhang // Enable all resolutions up to 1280x720p30 791ad3eb9441eb509c792c61aa0181b0e74dbe9984Chong Zhang mSupportedSourceVideoFormats.enableResolutionUpto( 80308bcaa44e578279e61be32b572fdb0b11b1e4c7Chong Zhang VideoFormats::RESOLUTION_CEA, 5, 81308bcaa44e578279e61be32b572fdb0b11b1e4c7Chong Zhang VideoFormats::PROFILE_CHP, // Constrained High Profile 82308bcaa44e578279e61be32b572fdb0b11b1e4c7Chong Zhang VideoFormats::LEVEL_32); // Level 3.2 83d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 84d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 85d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas HuberWifiDisplaySource::~WifiDisplaySource() { 86d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 87d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 885131d127a042ee88f903370be88845dc8c9f8578Andreas Huberstatic status_t PostAndAwaitResponse( 895131d127a042ee88f903370be88845dc8c9f8578Andreas Huber const sp<AMessage> &msg, sp<AMessage> *response) { 905131d127a042ee88f903370be88845dc8c9f8578Andreas Huber status_t err = msg->postAndAwaitResponse(response); 91d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 92d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 93d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 94d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 95d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 965131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (response == NULL || !(*response)->findInt32("err", &err)) { 97d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber err = OK; 98d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 99d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 100d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 101d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 102d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1035131d127a042ee88f903370be88845dc8c9f8578Andreas Huberstatus_t WifiDisplaySource::start(const char *iface) { 1045131d127a042ee88f903370be88845dc8c9f8578Andreas Huber CHECK_EQ(mState, INITIALIZED); 1055131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 1065131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> msg = new AMessage(kWhatStart, id()); 1075131d127a042ee88f903370be88845dc8c9f8578Andreas Huber msg->setString("iface", iface); 1085131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 1095131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> response; 1105131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return PostAndAwaitResponse(msg, &response); 1115131d127a042ee88f903370be88845dc8c9f8578Andreas Huber} 1125131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 113d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::stop() { 114d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<AMessage> msg = new AMessage(kWhatStop, id()); 115d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 116d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<AMessage> response; 1175131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return PostAndAwaitResponse(msg, &response); 1185131d127a042ee88f903370be88845dc8c9f8578Andreas Huber} 119d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1205131d127a042ee88f903370be88845dc8c9f8578Andreas Huberstatus_t WifiDisplaySource::pause() { 1215131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> msg = new AMessage(kWhatPause, id()); 122d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1235131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> response; 1245131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return PostAndAwaitResponse(msg, &response); 1255131d127a042ee88f903370be88845dc8c9f8578Andreas Huber} 126d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1275131d127a042ee88f903370be88845dc8c9f8578Andreas Huberstatus_t WifiDisplaySource::resume() { 1285131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> msg = new AMessage(kWhatResume, id()); 1295131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 1305131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> response; 1315131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return PostAndAwaitResponse(msg, &response); 132d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 133d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 134d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubervoid WifiDisplaySource::onMessageReceived(const sp<AMessage> &msg) { 135d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber switch (msg->what()) { 136d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case kWhatStart: 137d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 138d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber uint32_t replyID; 139d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->senderAwaitsResponse(&replyID)); 140d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 141bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber AString iface; 142bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber CHECK(msg->findString("iface", &iface)); 143bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 144bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber status_t err = OK; 145bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 146bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber ssize_t colonPos = iface.find(":"); 147bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 148bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber unsigned long port; 149bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 150bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber if (colonPos >= 0) { 151bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber const char *s = iface.c_str() + colonPos + 1; 152bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 153bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber char *end; 154bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber port = strtoul(s, &end, 10); 155bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 156bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber if (end == s || *end != '\0' || port > 65535) { 157bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber err = -EINVAL; 158bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } else { 159bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber iface.erase(colonPos, iface.size() - colonPos); 160bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } 161bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } else { 162bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber port = kWifiDisplayDefaultPort; 163bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } 164bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 165bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber if (err == OK) { 166bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber if (inet_aton(iface.c_str(), &mInterfaceAddr) != 0) { 167bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber sp<AMessage> notify = new AMessage(kWhatRTSPNotify, id()); 168d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 169bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber err = mNetSession->createRTSPServer( 170bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber mInterfaceAddr, port, notify, &mSessionID); 171bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } else { 172bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber err = -EINVAL; 173bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } 174c86ef45279185b474bd6af0a7ae407f8ab577f13Andreas Huber } 175c86ef45279185b474bd6af0a7ae407f8ab577f13Andreas Huber 176c86ef45279185b474bd6af0a7ae407f8ab577f13Andreas Huber if (err == OK) { 177c86ef45279185b474bd6af0a7ae407f8ab577f13Andreas Huber sp<AMessage> notify = new AMessage(kWhatTimeSyncerNotify, id()); 178c86ef45279185b474bd6af0a7ae407f8ab577f13Andreas Huber mTimeSyncer = new TimeSyncer(mNetSession, notify); 179c86ef45279185b474bd6af0a7ae407f8ab577f13Andreas Huber looper()->registerHandler(mTimeSyncer); 180c86ef45279185b474bd6af0a7ae407f8ab577f13Andreas Huber 181c86ef45279185b474bd6af0a7ae407f8ab577f13Andreas Huber mTimeSyncer->startServer(8123); 182d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber 183ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = AWAITING_CLIENT_CONNECTION; 184ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber } 185ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 186d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<AMessage> response = new AMessage; 187d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->setInt32("err", err); 188d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->postReply(replyID); 189d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 190d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 191d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 192d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case kWhatRTSPNotify: 193d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 194d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t reason; 195d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("reason", &reason)); 196d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 197d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber switch (reason) { 198d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case ANetworkSession::kWhatError: 199d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 200d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID; 201d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("sessionID", &sessionID)); 202d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 203d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t err; 204d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("err", &err)); 205d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 206d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString detail; 207d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findString("detail", &detail)); 208d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 209d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ALOGE("An error occurred in session %d (%d, '%s/%s').", 210d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, 211d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber err, 212d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber detail.c_str(), 213d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber strerror(-err)); 214d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 215d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mNetSession->destroySession(sessionID); 216d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 217c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (sessionID == mClientSessionID) { 218ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClientSessionID = 0; 219c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 220ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError( 221ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber IRemoteDisplayClient::kDisplayErrorUnknown); 222c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } 223d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 224d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 225d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 226d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case ANetworkSession::kWhatClientConnected: 227d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 228d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID; 229d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("sessionID", &sessionID)); 230d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 231c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientSessionID > 0) { 232c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber ALOGW("A client tried to connect, but we already " 233c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber "have one."); 234d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 235c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mNetSession->destroySession(sessionID); 236c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber break; 237c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } 238c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 239ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber CHECK_EQ(mState, AWAITING_CLIENT_CONNECTION); 240ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 241c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findString("client-ip", &mClientInfo.mRemoteIP)); 242c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findString("server-ip", &mClientInfo.mLocalIP)); 243c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 244c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientInfo.mRemoteIP == mClientInfo.mLocalIP) { 245c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber // Disallow connections from the local interface 246c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber // for security reasons. 247c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mNetSession->destroySession(sessionID); 248c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber break; 249c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } 250d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 251c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findInt32( 252c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber "server-port", &mClientInfo.mLocalPort)); 253c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mPlaybackSessionID = -1; 254c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 255c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientSessionID = sessionID; 256c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 257c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber ALOGI("We now have a client (%d) connected.", sessionID); 258d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 259ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = AWAITING_CLIENT_SETUP; 260ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 261d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = sendM1(sessionID); 262d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK_EQ(err, (status_t)OK); 263d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 264d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 265d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 266d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case ANetworkSession::kWhatData: 267d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 268b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber status_t err = onReceiveClientData(msg); 269b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 270b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err != OK) { 271ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError( 272ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber IRemoteDisplayClient::kDisplayErrorUnknown); 273b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 2745131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 2755131d127a042ee88f903370be88845dc8c9f8578Andreas Huber#if 0 2765131d127a042ee88f903370be88845dc8c9f8578Andreas Huber // testing only. 2775131d127a042ee88f903370be88845dc8c9f8578Andreas Huber char val[PROPERTY_VALUE_MAX]; 2785131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (property_get("media.wfd.trigger", val, NULL)) { 2795131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (!strcasecmp(val, "pause") && mState == PLAYING) { 2805131d127a042ee88f903370be88845dc8c9f8578Andreas Huber mState = PLAYING_TO_PAUSED; 2815131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sendTrigger(mClientSessionID, TRIGGER_PAUSE); 282ff9297ac908aa01e44fda4ab9ca7a4bb514c00fdAndreas Huber } else if (!strcasecmp(val, "play") 283ff9297ac908aa01e44fda4ab9ca7a4bb514c00fdAndreas Huber && mState == PAUSED) { 2845131d127a042ee88f903370be88845dc8c9f8578Andreas Huber mState = PAUSED_TO_PLAYING; 2855131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sendTrigger(mClientSessionID, TRIGGER_PLAY); 2865131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 2875131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 2885131d127a042ee88f903370be88845dc8c9f8578Andreas Huber#endif 289d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 290d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 291d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 292126568c7aeeb5570789e70a310477f44dbdbd885Andreas Huber case ANetworkSession::kWhatNetworkStall: 293126568c7aeeb5570789e70a310477f44dbdbd885Andreas Huber { 294126568c7aeeb5570789e70a310477f44dbdbd885Andreas Huber break; 295126568c7aeeb5570789e70a310477f44dbdbd885Andreas Huber } 296126568c7aeeb5570789e70a310477f44dbdbd885Andreas Huber 297d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber default: 298d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber TRESPASS(); 299d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 300d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 301d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 302d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 303d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case kWhatStop: 304d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 305eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber CHECK(msg->senderAwaitsResponse(&mStopReplyID)); 306d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 307ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber CHECK_LT(mState, AWAITING_CLIENT_TEARDOWN); 308ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 309ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber if (mState >= AWAITING_CLIENT_PLAY) { 310ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber // We have a session, i.e. a previous SETUP succeeded. 311ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 3125131d127a042ee88f903370be88845dc8c9f8578Andreas Huber status_t err = sendTrigger( 3135131d127a042ee88f903370be88845dc8c9f8578Andreas Huber mClientSessionID, TRIGGER_TEARDOWN); 3140b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber 315ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber if (err == OK) { 316ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = AWAITING_CLIENT_TEARDOWN; 317ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 318ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber (new AMessage(kWhatTeardownTriggerTimedOut, id()))->post( 319ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber kTeardownTriggerTimeouSecs * 1000000ll); 320ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 321ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber break; 322ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber } 323ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 324ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber // fall through. 325b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 326d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 327eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber finishStop(); 328d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 329d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 330d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 3315131d127a042ee88f903370be88845dc8c9f8578Andreas Huber case kWhatPause: 3325131d127a042ee88f903370be88845dc8c9f8578Andreas Huber { 3335131d127a042ee88f903370be88845dc8c9f8578Andreas Huber uint32_t replyID; 3345131d127a042ee88f903370be88845dc8c9f8578Andreas Huber CHECK(msg->senderAwaitsResponse(&replyID)); 3355131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 3365131d127a042ee88f903370be88845dc8c9f8578Andreas Huber status_t err = OK; 3375131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 3385131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (mState != PLAYING) { 3395131d127a042ee88f903370be88845dc8c9f8578Andreas Huber err = INVALID_OPERATION; 3405131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } else { 3415131d127a042ee88f903370be88845dc8c9f8578Andreas Huber mState = PLAYING_TO_PAUSED; 3425131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sendTrigger(mClientSessionID, TRIGGER_PAUSE); 3435131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 3445131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 3455131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> response = new AMessage; 3465131d127a042ee88f903370be88845dc8c9f8578Andreas Huber response->setInt32("err", err); 3475131d127a042ee88f903370be88845dc8c9f8578Andreas Huber response->postReply(replyID); 3485131d127a042ee88f903370be88845dc8c9f8578Andreas Huber break; 3495131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 3505131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 3515131d127a042ee88f903370be88845dc8c9f8578Andreas Huber case kWhatResume: 3525131d127a042ee88f903370be88845dc8c9f8578Andreas Huber { 3535131d127a042ee88f903370be88845dc8c9f8578Andreas Huber uint32_t replyID; 3545131d127a042ee88f903370be88845dc8c9f8578Andreas Huber CHECK(msg->senderAwaitsResponse(&replyID)); 3555131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 3565131d127a042ee88f903370be88845dc8c9f8578Andreas Huber status_t err = OK; 3575131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 3585131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (mState != PAUSED) { 3595131d127a042ee88f903370be88845dc8c9f8578Andreas Huber err = INVALID_OPERATION; 3605131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } else { 3615131d127a042ee88f903370be88845dc8c9f8578Andreas Huber mState = PAUSED_TO_PLAYING; 3625131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sendTrigger(mClientSessionID, TRIGGER_PLAY); 3635131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 3645131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 3655131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> response = new AMessage; 3665131d127a042ee88f903370be88845dc8c9f8578Andreas Huber response->setInt32("err", err); 3675131d127a042ee88f903370be88845dc8c9f8578Andreas Huber response->postReply(replyID); 3685131d127a042ee88f903370be88845dc8c9f8578Andreas Huber break; 3695131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 3705131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 371d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case kWhatReapDeadClients: 372d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 373d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mReaperPending = false; 374d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 375c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientSessionID == 0 376c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber || mClientInfo.mPlaybackSession == NULL) { 377c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber break; 378d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 379d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 380c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientInfo.mPlaybackSession->getLastLifesignUs() 381c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber + kPlaybackSessionTimeoutUs < ALooper::GetNowUs()) { 382c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber ALOGI("playback session timed out, reaping."); 383c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 384ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mNetSession->destroySession(mClientSessionID); 385ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClientSessionID = 0; 386ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 387ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError( 388ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber IRemoteDisplayClient::kDisplayErrorUnknown); 389c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } else { 390d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber scheduleReaper(); 391d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 392d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 393d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 394d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 395d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case kWhatPlaybackSessionNotify: 396d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 397d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 398d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("playbackSessionID", &playbackSessionID)); 399d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 400d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t what; 401d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("what", &what)); 402d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 403c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (what == PlaybackSession::kWhatSessionDead) { 404c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber ALOGI("playback session wants to quit."); 405c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 406ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError( 407ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber IRemoteDisplayClient::kDisplayErrorUnknown); 408c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } else if (what == PlaybackSession::kWhatSessionEstablished) { 4090b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber mPlaybackSessionEstablished = true; 4100b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber 411c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClient != NULL) { 41294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (!mSinkSupportsVideo) { 41394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mClient->onDisplayConnected( 41494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber NULL, // SurfaceTexture 41594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 0, // width, 41694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 0, // height, 41794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mUsingHDCP 41894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ? IRemoteDisplayClient::kDisplayFlagSecure 41987ecf19404586672008e98babc225e094292ceb5Chong Zhang : 0, 42087ecf19404586672008e98babc225e094292ceb5Chong Zhang 0); 42194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } else { 42294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber size_t width, height; 42394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 42494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber CHECK(VideoFormats::GetConfiguration( 42594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mChosenVideoResolutionType, 42694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mChosenVideoResolutionIndex, 42794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber &width, 42894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber &height, 42994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber NULL /* framesPerSecond */, 43094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber NULL /* interlaced */)); 43194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 43294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mClient->onDisplayConnected( 433ff9297ac908aa01e44fda4ab9ca7a4bb514c00fdAndreas Huber mClientInfo.mPlaybackSession 434ff9297ac908aa01e44fda4ab9ca7a4bb514c00fdAndreas Huber ->getSurfaceTexture(), 43594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber width, 43694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber height, 43794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mUsingHDCP 43894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ? IRemoteDisplayClient::kDisplayFlagSecure 43987ecf19404586672008e98babc225e094292ceb5Chong Zhang : 0, 44087ecf19404586672008e98babc225e094292ceb5Chong Zhang playbackSessionID); 44194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } 442c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } 443ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 4440b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber finishPlay(); 4450b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber 446ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber if (mState == ABOUT_TO_PLAY) { 447ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = PLAYING; 448ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber } 44996fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber } else if (what == PlaybackSession::kWhatSessionDestroyed) { 45096fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber disconnectClient2(); 451c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } else { 452c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_EQ(what, PlaybackSession::kWhatBinaryData); 453d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 454c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber int32_t channel; 455c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findInt32("channel", &channel)); 456d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 457c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber sp<ABuffer> data; 458c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findBuffer("data", &data)); 459d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 460c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_LE(channel, 0xffu); 461c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_LE(data->size(), 0xffffu); 462d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 463c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber int32_t sessionID; 464c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findInt32("sessionID", &sessionID)); 465d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 466c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber char header[4]; 467c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber header[0] = '$'; 468c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber header[1] = channel; 469c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber header[2] = data->size() >> 8; 470c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber header[3] = data->size() & 0xff; 471d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 472c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mNetSession->sendRequest( 473c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber sessionID, header, sizeof(header)); 474d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 475c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mNetSession->sendRequest( 476c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber sessionID, data->data(), data->size()); 477d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 478d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 479d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 480d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 481b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber case kWhatKeepAlive: 482b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber { 483b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber int32_t sessionID; 484b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber CHECK(msg->findInt32("sessionID", &sessionID)); 485b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 486c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientSessionID != sessionID) { 487b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // Obsolete event, client is already gone. 488b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber break; 489b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber } 490b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 491b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber sendM16(sessionID); 492b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber break; 493b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber } 494b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 495ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber case kWhatTeardownTriggerTimedOut: 496ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber { 497ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber if (mState == AWAITING_CLIENT_TEARDOWN) { 498ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber ALOGI("TEARDOWN trigger timed out, forcing disconnection."); 499ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 500ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber CHECK_NE(mStopReplyID, 0); 501ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber finishStop(); 502ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber break; 503ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber } 504ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber break; 505ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber } 506ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 507b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber case kWhatHDCPNotify: 508b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber { 509b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber int32_t msgCode, ext1, ext2; 510b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber CHECK(msg->findInt32("msg", &msgCode)); 511b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber CHECK(msg->findInt32("ext1", &ext1)); 512b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber CHECK(msg->findInt32("ext2", &ext2)); 513b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 514eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber ALOGI("Saw HDCP notification code %d, ext1 %d, ext2 %d", 515b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber msgCode, ext1, ext2); 516b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 517b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber switch (msgCode) { 518b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber case HDCPModule::HDCP_INITIALIZATION_COMPLETE: 519b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber { 520b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mHDCPInitializationComplete = true; 521b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 522b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (mSetupTriggerDeferred) { 523b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mSetupTriggerDeferred = false; 524b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 5255131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sendTrigger(mClientSessionID, TRIGGER_SETUP); 526b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 527b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber break; 528b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 529b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 530eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber case HDCPModule::HDCP_SHUTDOWN_COMPLETE: 531ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber case HDCPModule::HDCP_SHUTDOWN_FAILED: 532eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber { 533ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber // Ugly hack to make sure that the call to 534ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber // HDCPObserver::notify is completely handled before 535ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber // we clear the HDCP instance and unload the shared 536ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber // library :( 537ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber (new AMessage(kWhatFinishStop2, id()))->post(300000ll); 538eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber break; 539eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber } 540eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber 541b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber default: 542b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber { 543ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber ALOGE("HDCP failure, shutting down."); 544ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 545ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError( 546ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber IRemoteDisplayClient::kDisplayErrorUnknown); 547b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber break; 548b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 549b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 550b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber break; 551b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 552ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 553ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber case kWhatFinishStop2: 554ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber { 555ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber finishStop2(); 556ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber break; 557ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber } 558b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 559c86ef45279185b474bd6af0a7ae407f8ab577f13Andreas Huber case kWhatTimeSyncerNotify: 560c86ef45279185b474bd6af0a7ae407f8ab577f13Andreas Huber { 561c86ef45279185b474bd6af0a7ae407f8ab577f13Andreas Huber break; 562c86ef45279185b474bd6af0a7ae407f8ab577f13Andreas Huber } 563c86ef45279185b474bd6af0a7ae407f8ab577f13Andreas Huber 564d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber default: 565d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber TRESPASS(); 566d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 567d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 568d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 569d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubervoid WifiDisplaySource::registerResponseHandler( 570d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, int32_t cseq, HandleRTSPResponseFunc func) { 571d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ResponseID id; 572d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber id.mSessionID = sessionID; 573d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber id.mCSeq = cseq; 574d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mResponseHandlers.add(id, func); 575d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 576d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 577d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::sendM1(int32_t sessionID) { 578d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString request = "OPTIONS * RTSP/1.0\r\n"; 579d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&request, mNextCSeq); 580d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 581d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append( 582d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "Require: org.wfa.wfd1.0\r\n" 583d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "\r\n"); 584d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 585d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = 586d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mNetSession->sendRequest(sessionID, request.c_str(), request.size()); 587d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 588d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 589d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 590d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 591d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 592d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber registerResponseHandler( 593d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, mNextCSeq, &WifiDisplaySource::onReceiveM1Response); 594d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 595d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ++mNextCSeq; 596d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 597d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 598d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 599d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 600d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::sendM3(int32_t sessionID) { 601d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString body = 602b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber "wfd_content_protection\r\n" 603d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "wfd_video_formats\r\n" 604d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "wfd_audio_codecs\r\n" 605d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "wfd_client_rtp_ports\r\n"; 606d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 607d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString request = "GET_PARAMETER rtsp://localhost/wfd1.0 RTSP/1.0\r\n"; 608d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&request, mNextCSeq); 609d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 610d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("Content-Type: text/parameters\r\n"); 611d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(StringPrintf("Content-Length: %d\r\n", body.size())); 612d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("\r\n"); 613d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(body); 614d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 615d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = 616d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mNetSession->sendRequest(sessionID, request.c_str(), request.size()); 617d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 618d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 619d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 620d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 621d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 622d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber registerResponseHandler( 623d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, mNextCSeq, &WifiDisplaySource::onReceiveM3Response); 624d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 625d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ++mNextCSeq; 626d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 627d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 628d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 629d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 630d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::sendM4(int32_t sessionID) { 631c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_EQ(sessionID, mClientSessionID); 632d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 63394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber AString body; 63494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 63594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (mSinkSupportsVideo) { 63694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber body.append("wfd_video_formats: "); 63794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 63894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber VideoFormats chosenVideoFormat; 63994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber chosenVideoFormat.disableAll(); 64094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber chosenVideoFormat.setNativeResolution( 64194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mChosenVideoResolutionType, mChosenVideoResolutionIndex); 642308bcaa44e578279e61be32b572fdb0b11b1e4c7Chong Zhang chosenVideoFormat.setProfileLevel( 643308bcaa44e578279e61be32b572fdb0b11b1e4c7Chong Zhang mChosenVideoResolutionType, mChosenVideoResolutionIndex, 644308bcaa44e578279e61be32b572fdb0b11b1e4c7Chong Zhang mChosenVideoProfile, mChosenVideoLevel); 64594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 6465abf87f9af48149972eeb851ecaea679911da040Andreas Huber body.append(chosenVideoFormat.getFormatSpec(true /* forM4Message */)); 64794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber body.append("\r\n"); 64894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } 64994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 65094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (mSinkSupportsAudio) { 65194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber body.append( 65294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber StringPrintf("wfd_audio_codecs: %s\r\n", 65394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber (mUsingPCMAudio 65494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ? "LPCM 00000002 00" // 2 ch PCM 48kHz 65594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber : "AAC 00000001 00"))); // 2 ch AAC 48kHz 65694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } 65794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 65894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber body.append( 65994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber StringPrintf( 6607cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber "wfd_presentation_URL: rtsp://%s/wfd1.0/streamid=0 none\r\n", 6617cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber mClientInfo.mLocalIP.c_str())); 6627cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber 663aef5c98cd3f67e0209e1fa28489078e9f40d6f46Chong Zhang body.append( 664aef5c98cd3f67e0209e1fa28489078e9f40d6f46Chong Zhang StringPrintf( 665aef5c98cd3f67e0209e1fa28489078e9f40d6f46Chong Zhang "wfd_client_rtp_ports: %s\r\n", mWfdClientRtpPorts.c_str())); 666d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 667d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString request = "SET_PARAMETER rtsp://localhost/wfd1.0 RTSP/1.0\r\n"; 668d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&request, mNextCSeq); 669d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 670d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("Content-Type: text/parameters\r\n"); 671d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(StringPrintf("Content-Length: %d\r\n", body.size())); 672d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("\r\n"); 673d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(body); 674d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 675d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = 676d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mNetSession->sendRequest(sessionID, request.c_str(), request.size()); 677d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 678d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 679d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 680d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 681d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 682d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber registerResponseHandler( 683d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, mNextCSeq, &WifiDisplaySource::onReceiveM4Response); 684d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 685d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ++mNextCSeq; 686d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 687d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 688d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 689d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 6905131d127a042ee88f903370be88845dc8c9f8578Andreas Huberstatus_t WifiDisplaySource::sendTrigger( 6915131d127a042ee88f903370be88845dc8c9f8578Andreas Huber int32_t sessionID, TriggerType triggerType) { 692ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber AString body = "wfd_trigger_method: "; 6935131d127a042ee88f903370be88845dc8c9f8578Andreas Huber switch (triggerType) { 6945131d127a042ee88f903370be88845dc8c9f8578Andreas Huber case TRIGGER_SETUP: 6955131d127a042ee88f903370be88845dc8c9f8578Andreas Huber body.append("SETUP"); 6965131d127a042ee88f903370be88845dc8c9f8578Andreas Huber break; 6975131d127a042ee88f903370be88845dc8c9f8578Andreas Huber case TRIGGER_TEARDOWN: 6985131d127a042ee88f903370be88845dc8c9f8578Andreas Huber ALOGI("Sending TEARDOWN trigger."); 6995131d127a042ee88f903370be88845dc8c9f8578Andreas Huber body.append("TEARDOWN"); 7005131d127a042ee88f903370be88845dc8c9f8578Andreas Huber break; 7015131d127a042ee88f903370be88845dc8c9f8578Andreas Huber case TRIGGER_PAUSE: 7025131d127a042ee88f903370be88845dc8c9f8578Andreas Huber body.append("PAUSE"); 7035131d127a042ee88f903370be88845dc8c9f8578Andreas Huber break; 7045131d127a042ee88f903370be88845dc8c9f8578Andreas Huber case TRIGGER_PLAY: 7055131d127a042ee88f903370be88845dc8c9f8578Andreas Huber body.append("PLAY"); 7065131d127a042ee88f903370be88845dc8c9f8578Andreas Huber break; 7075131d127a042ee88f903370be88845dc8c9f8578Andreas Huber default: 7085131d127a042ee88f903370be88845dc8c9f8578Andreas Huber TRESPASS(); 709ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber } 710ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 711ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber body.append("\r\n"); 712d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 713d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString request = "SET_PARAMETER rtsp://localhost/wfd1.0 RTSP/1.0\r\n"; 714d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&request, mNextCSeq); 715d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 716d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("Content-Type: text/parameters\r\n"); 717d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(StringPrintf("Content-Length: %d\r\n", body.size())); 718d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("\r\n"); 719d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(body); 720d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 721d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = 722d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mNetSession->sendRequest(sessionID, request.c_str(), request.size()); 723d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 724d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 725d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 726d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 727d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 728d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber registerResponseHandler( 729d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, mNextCSeq, &WifiDisplaySource::onReceiveM5Response); 730d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 731d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ++mNextCSeq; 732d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 733d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 734d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 735d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 736b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huberstatus_t WifiDisplaySource::sendM16(int32_t sessionID) { 737b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber AString request = "GET_PARAMETER rtsp://localhost/wfd1.0 RTSP/1.0\r\n"; 738b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber AppendCommonResponse(&request, mNextCSeq); 739b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 740c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_EQ(sessionID, mClientSessionID); 741c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber request.append( 742c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber StringPrintf("Session: %d\r\n", mClientInfo.mPlaybackSessionID)); 743a438123bd96c7faf145683876702387efe5628d9Andreas Huber request.append("\r\n"); // Empty body 744b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 745b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber status_t err = 746b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber mNetSession->sendRequest(sessionID, request.c_str(), request.size()); 747b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 748b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber if (err != OK) { 749b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber return err; 750b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber } 751b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 752b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber registerResponseHandler( 753b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber sessionID, mNextCSeq, &WifiDisplaySource::onReceiveM16Response); 754b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 755b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber ++mNextCSeq; 756b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 7571ad3eb9441eb509c792c61aa0181b0e74dbe9984Chong Zhang scheduleKeepAlive(sessionID); 7581ad3eb9441eb509c792c61aa0181b0e74dbe9984Chong Zhang 759b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber return OK; 760b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber} 761b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 762d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::onReceiveM1Response( 763d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, const sp<ParsedMessage> &msg) { 764d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t statusCode; 765d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!msg->getStatusCode(&statusCode)) { 766d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_MALFORMED; 767d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 768d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 769d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (statusCode != 200) { 770d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_UNSUPPORTED; 771d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 772d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 773d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 774d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 775d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 776d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber// sink_audio_list := ("LPCM"|"AAC"|"AC3" HEXDIGIT*8 HEXDIGIT*2) 777d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber// (", " sink_audio_list)* 778d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huberstatic void GetAudioModes(const char *s, const char *prefix, uint32_t *modes) { 779d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber *modes = 0; 780d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 781d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber size_t prefixLen = strlen(prefix); 782d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 783d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber while (*s != '0') { 784d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber if (!strncmp(s, prefix, prefixLen) && s[prefixLen] == ' ') { 785d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber unsigned latency; 786d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber if (sscanf(&s[prefixLen + 1], "%08x %02x", modes, &latency) != 2) { 787d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber *modes = 0; 788d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 789d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 790d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber return; 791d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 792d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 793d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber char *commaPos = strchr(s, ','); 794d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber if (commaPos != NULL) { 795d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber s = commaPos + 1; 796d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 797d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber while (isspace(*s)) { 798d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber ++s; 799d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 800d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } else { 801d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber break; 802d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 803d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 804d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber} 805d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 806d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::onReceiveM3Response( 807d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, const sp<ParsedMessage> &msg) { 808d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t statusCode; 809d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!msg->getStatusCode(&statusCode)) { 810d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_MALFORMED; 811d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 812d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 813d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (statusCode != 200) { 814d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_UNSUPPORTED; 815d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 816d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 817b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<Parameters> params = 818b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber Parameters::Parse(msg->getContent(), strlen(msg->getContent())); 819b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 820b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (params == NULL) { 821b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 822b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 823b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 824b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber AString value; 825d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber if (!params->findParameter("wfd_client_rtp_ports", &value)) { 826d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber ALOGE("Sink doesn't report its choice of wfd_client_rtp_ports."); 827d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber return ERROR_MALFORMED; 828d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 829d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 8307cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber unsigned port0 = 0, port1 = 0; 831d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber if (sscanf(value.c_str(), 832d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber "RTP/AVP/UDP;unicast %u %u mode=play", 833d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber &port0, 8347cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber &port1) == 2 8357cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber || sscanf(value.c_str(), 8367cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber "RTP/AVP/TCP;unicast %u %u mode=play", 8377cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber &port0, 8387cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber &port1) == 2) { 8397cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber if (port0 == 0 || port0 > 65535 || port1 != 0) { 8407cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber ALOGE("Sink chose its wfd_client_rtp_ports poorly (%s)", 8417cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber value.c_str()); 8427cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber 8437cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber return ERROR_MALFORMED; 8447cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber } 8457cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber } else if (strcmp(value.c_str(), "RTP/AVP/TCP;interleaved mode=play")) { 8467cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber ALOGE("Unsupported value for wfd_client_rtp_ports (%s)", 847d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber value.c_str()); 848d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 8497cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber return ERROR_UNSUPPORTED; 850d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 851d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 8527cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber mWfdClientRtpPorts = value; 853d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber mChosenRTPPort = port0; 854d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 85594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (!params->findParameter("wfd_video_formats", &value)) { 85694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGE("Sink doesn't report its choice of wfd_video_formats."); 85794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber return ERROR_MALFORMED; 85894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } 85994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 86094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mSinkSupportsVideo = false; 86194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 86294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (!(value == "none")) { 86394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mSinkSupportsVideo = true; 86494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (!mSupportedSinkVideoFormats.parseFormatSpec(value.c_str())) { 86594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGE("Failed to parse sink provided wfd_video_formats (%s)", 86694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber value.c_str()); 86794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 86894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber return ERROR_MALFORMED; 86994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } 87094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 87194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (!VideoFormats::PickBestFormat( 87294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mSupportedSinkVideoFormats, 87394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mSupportedSourceVideoFormats, 87494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber &mChosenVideoResolutionType, 875308bcaa44e578279e61be32b572fdb0b11b1e4c7Chong Zhang &mChosenVideoResolutionIndex, 876308bcaa44e578279e61be32b572fdb0b11b1e4c7Chong Zhang &mChosenVideoProfile, 877308bcaa44e578279e61be32b572fdb0b11b1e4c7Chong Zhang &mChosenVideoLevel)) { 87894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGE("Sink and source share no commonly supported video " 87994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber "formats."); 88094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 88194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber return ERROR_UNSUPPORTED; 88294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } 88394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 88494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber size_t width, height, framesPerSecond; 88594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber bool interlaced; 88694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber CHECK(VideoFormats::GetConfiguration( 88794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mChosenVideoResolutionType, 88894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mChosenVideoResolutionIndex, 88994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber &width, 89094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber &height, 89194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber &framesPerSecond, 89294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber &interlaced)); 89394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 89494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGI("Picked video resolution %u x %u %c%u", 89594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber width, height, interlaced ? 'i' : 'p', framesPerSecond); 896308bcaa44e578279e61be32b572fdb0b11b1e4c7Chong Zhang 897308bcaa44e578279e61be32b572fdb0b11b1e4c7Chong Zhang ALOGI("Picked AVC profile %d, level %d", 898308bcaa44e578279e61be32b572fdb0b11b1e4c7Chong Zhang mChosenVideoProfile, mChosenVideoLevel); 89994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } else { 90094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGI("Sink doesn't support video at all."); 90194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } 90294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 903d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber if (!params->findParameter("wfd_audio_codecs", &value)) { 904d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber ALOGE("Sink doesn't report its choice of wfd_audio_codecs."); 905d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber return ERROR_MALFORMED; 906d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 907d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 90894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mSinkSupportsAudio = false; 909d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 91094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (!(value == "none")) { 91194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mSinkSupportsAudio = true; 912d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 91394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber uint32_t modes; 91494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber GetAudioModes(value.c_str(), "AAC", &modes); 915d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 91694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber bool supportsAAC = (modes & 1) != 0; // AAC 2ch 48kHz 917d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 91894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber GetAudioModes(value.c_str(), "LPCM", &modes); 919d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 92094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber bool supportsPCM = (modes & 2) != 0; // LPCM 2ch 48kHz 92194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 92294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber char val[PROPERTY_VALUE_MAX]; 92394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (supportsPCM 92494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber && property_get("media.wfd.use-pcm-audio", val, NULL) 92594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber && (!strcasecmp("true", val) || !strcmp("1", val))) { 92694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGI("Using PCM audio."); 92794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mUsingPCMAudio = true; 92894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } else if (supportsAAC) { 92994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGI("Using AAC audio."); 93094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mUsingPCMAudio = false; 93194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } else if (supportsPCM) { 93294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGI("Using PCM audio."); 93394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mUsingPCMAudio = true; 93494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } else { 93594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGI("Sink doesn't support an audio format we do."); 93694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber return ERROR_UNSUPPORTED; 93794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } 938d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } else { 93994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGI("Sink doesn't support audio at all."); 94094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } 94194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 94294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (!mSinkSupportsVideo && !mSinkSupportsAudio) { 94394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGE("Sink supports neither video nor audio..."); 944d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber return ERROR_UNSUPPORTED; 945d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 946d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 9470328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mUsingHDCP = false; 948b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (!params->findParameter("wfd_content_protection", &value)) { 9490328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber ALOGI("Sink doesn't appear to support content protection."); 9500328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber } else if (value == "none") { 9510328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber ALOGI("Sink does not support content protection."); 9520328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber } else { 9530328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mUsingHDCP = true; 954b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 9550328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber bool isHDCP2_0 = false; 9560328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber if (value.startsWith("HDCP2.0 ")) { 9570328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber isHDCP2_0 = true; 9580328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber } else if (!value.startsWith("HDCP2.1 ")) { 9590328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber ALOGE("malformed wfd_content_protection: '%s'", value.c_str()); 960b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 9610328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber return ERROR_MALFORMED; 9620328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber } 963b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 9640328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber int32_t hdcpPort; 9650328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber if (!ParsedMessage::GetInt32Attribute( 9660328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber value.c_str() + 8, "port", &hdcpPort) 9670328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber || hdcpPort < 1 || hdcpPort > 65535) { 9680328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber return ERROR_MALFORMED; 9690328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber } 970b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 9710328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mIsHDCP2_0 = isHDCP2_0; 9720328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mHDCPPort = hdcpPort; 973b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 9740328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber status_t err = makeHDCP(); 9750328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber if (err != OK) { 9760224bf170a3904576bba81593eaab113c5d3a4e7Andreas Huber ALOGE("Unable to instantiate HDCP component. " 9770224bf170a3904576bba81593eaab113c5d3a4e7Andreas Huber "Not using HDCP after all."); 9780224bf170a3904576bba81593eaab113c5d3a4e7Andreas Huber 9790224bf170a3904576bba81593eaab113c5d3a4e7Andreas Huber mUsingHDCP = false; 9800328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber } 981b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 982b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 983d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return sendM4(sessionID); 984d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 985d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 986d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::onReceiveM4Response( 987d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, const sp<ParsedMessage> &msg) { 988d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t statusCode; 989d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!msg->getStatusCode(&statusCode)) { 990d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_MALFORMED; 991d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 992d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 993d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (statusCode != 200) { 994d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_UNSUPPORTED; 995d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 996d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 9970328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber if (mUsingHDCP && !mHDCPInitializationComplete) { 998b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber ALOGI("Deferring SETUP trigger until HDCP initialization completes."); 999b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1000b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mSetupTriggerDeferred = true; 1001b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 1002b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1003b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 10045131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return sendTrigger(sessionID, TRIGGER_SETUP); 1005d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1006d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1007d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::onReceiveM5Response( 1008d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, const sp<ParsedMessage> &msg) { 1009d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t statusCode; 1010d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!msg->getStatusCode(&statusCode)) { 1011d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_MALFORMED; 1012d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1013d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1014d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (statusCode != 200) { 1015d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_UNSUPPORTED; 1016d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1017d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1018d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 1019d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1020d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1021b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huberstatus_t WifiDisplaySource::onReceiveM16Response( 1022b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber int32_t sessionID, const sp<ParsedMessage> &msg) { 1023b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // If only the response was required to include a "Session:" header... 1024b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 1025c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_EQ(sessionID, mClientSessionID); 1026b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 1027c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientInfo.mPlaybackSession != NULL) { 1028c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mPlaybackSession->updateLiveness(); 1029b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber } 1030b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 1031b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber return OK; 1032b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber} 1033b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 1034d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubervoid WifiDisplaySource::scheduleReaper() { 1035d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (mReaperPending) { 1036d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return; 1037d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1038d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1039d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mReaperPending = true; 1040d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber (new AMessage(kWhatReapDeadClients, id()))->post(kReaperIntervalUs); 1041d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1042d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1043b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Hubervoid WifiDisplaySource::scheduleKeepAlive(int32_t sessionID) { 1044b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // We need to send updates at least 5 secs before the timeout is set to 1045b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // expire, make sure the timeout is greater than 5 secs to begin with. 1046b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber CHECK_GT(kPlaybackSessionTimeoutUs, 5000000ll); 1047b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 1048b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber sp<AMessage> msg = new AMessage(kWhatKeepAlive, id()); 1049b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber msg->setInt32("sessionID", sessionID); 1050b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber msg->post(kPlaybackSessionTimeoutUs - 5000000ll); 1051b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber} 1052b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 1053b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onReceiveClientData(const sp<AMessage> &msg) { 1054d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID; 1055d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("sessionID", &sessionID)); 1056d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1057d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<RefBase> obj; 1058d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findObject("data", &obj)); 1059d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1060d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<ParsedMessage> data = 1061d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber static_cast<ParsedMessage *>(obj.get()); 1062d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1063d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ALOGV("session %d received '%s'", 1064d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, data->debugString().c_str()); 1065d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1066d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString method; 1067d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString uri; 1068d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber data->getRequestField(0, &method); 1069d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1070d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq; 1071d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!data->findInt32("cseq", &cseq)) { 1072d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "400 Bad Request", -1 /* cseq */); 1073b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1074d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1075d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1076d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (method.startsWith("RTSP/")) { 1077d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // This is a response. 1078d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1079d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ResponseID id; 1080d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber id.mSessionID = sessionID; 1081d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber id.mCSeq = cseq; 1082d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1083d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ssize_t index = mResponseHandlers.indexOfKey(id); 1084d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1085d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (index < 0) { 1086d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ALOGW("Received unsolicited server response, cseq %d", cseq); 1087b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1088d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1089d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1090d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber HandleRTSPResponseFunc func = mResponseHandlers.valueAt(index); 1091d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mResponseHandlers.removeItemsAt(index); 1092d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1093d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = (this->*func)(sessionID, data); 1094d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1095d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 1096d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ALOGW("Response handler for session %d, cseq %d returned " 1097d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "err %d (%s)", 1098d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, cseq, err, strerror(-err)); 1099d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1100b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1101d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1102d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1103b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 1104b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1105d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1106b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber AString version; 1107b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber data->getRequestField(2, &version); 1108b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (!(version == AString("RTSP/1.0"))) { 1109b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sendErrorResponse(sessionID, "505 RTSP Version not supported", cseq); 1110b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_UNSUPPORTED; 1111b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1112d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1113b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber status_t err; 1114b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (method == "OPTIONS") { 1115b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onOptionsRequest(sessionID, cseq, data); 1116b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "SETUP") { 1117b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onSetupRequest(sessionID, cseq, data); 1118b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "PLAY") { 1119b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onPlayRequest(sessionID, cseq, data); 1120b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "PAUSE") { 1121b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onPauseRequest(sessionID, cseq, data); 1122b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "TEARDOWN") { 1123b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onTeardownRequest(sessionID, cseq, data); 1124b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "GET_PARAMETER") { 1125b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onGetParameterRequest(sessionID, cseq, data); 1126b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "SET_PARAMETER") { 1127b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onSetParameterRequest(sessionID, cseq, data); 1128b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else { 1129b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sendErrorResponse(sessionID, "405 Method Not Allowed", cseq); 1130d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1131b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = ERROR_UNSUPPORTED; 1132b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1133d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1134b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1135d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1136d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1137b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onOptionsRequest( 1138d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1139d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1140d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1141d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1142d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1143d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1144d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1145d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession != NULL) { 1146d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber playbackSession->updateLiveness(); 1147d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1148d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1149d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1150d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq); 1151d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1152d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append( 1153b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber "Public: org.wfa.wfd1.0, SETUP, TEARDOWN, PLAY, PAUSE, " 1154d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "GET_PARAMETER, SET_PARAMETER\r\n"); 1155d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1156d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1157d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1158d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = mNetSession->sendRequest(sessionID, response.c_str()); 1159d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1160b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err == OK) { 1161b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = sendM3(sessionID); 1162b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1163b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1164b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1165d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1166d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1167b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onSetupRequest( 1168d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1169d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1170d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1171c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_EQ(sessionID, mClientSessionID); 1172c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientInfo.mPlaybackSessionID != -1) { 1173b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // We only support a single playback session per client. 1174b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // This is due to the reversed keep-alive design in the wfd specs... 1175b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber sendErrorResponse(sessionID, "400 Bad Request", cseq); 1176b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1177b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber } 1178b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 1179d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString transport; 1180d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!data->findString("transport", &transport)) { 1181d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "400 Bad Request", cseq); 1182b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1183d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1184d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 11852aea9552aeba92bbaf9e56c666049ea2d14057b5Andreas Huber RTPSender::TransportMode rtpMode = RTPSender::TRANSPORT_UDP; 1186d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1187d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int clientRtp, clientRtcp; 1188d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (transport.startsWith("RTP/AVP/TCP;")) { 1189d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString interleaved; 1190bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber if (ParsedMessage::GetAttribute( 1191d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber transport.c_str(), "interleaved", &interleaved) 1192bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber && sscanf(interleaved.c_str(), "%d-%d", 1193bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber &clientRtp, &clientRtcp) == 2) { 11942aea9552aeba92bbaf9e56c666049ea2d14057b5Andreas Huber rtpMode = RTPSender::TRANSPORT_TCP_INTERLEAVED; 1195bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } else { 1196bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber bool badRequest = false; 1197bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber 1198bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber AString clientPort; 1199bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber if (!ParsedMessage::GetAttribute( 1200bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber transport.c_str(), "client_port", &clientPort)) { 1201bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber badRequest = true; 1202bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } else if (sscanf(clientPort.c_str(), "%d-%d", 1203bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber &clientRtp, &clientRtcp) == 2) { 1204bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } else if (sscanf(clientPort.c_str(), "%d", &clientRtp) == 1) { 1205bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber // No RTCP. 1206bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber clientRtcp = -1; 1207bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } else { 1208bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber badRequest = true; 1209bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } 1210bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber 1211bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber if (badRequest) { 1212bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber sendErrorResponse(sessionID, "400 Bad Request", cseq); 1213b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1214bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } 1215d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 12162aea9552aeba92bbaf9e56c666049ea2d14057b5Andreas Huber rtpMode = RTPSender::TRANSPORT_TCP; 1217bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } 1218d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else if (transport.startsWith("RTP/AVP;unicast;") 1219d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber || transport.startsWith("RTP/AVP/UDP;unicast;")) { 1220d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber bool badRequest = false; 1221d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1222d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString clientPort; 1223d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!ParsedMessage::GetAttribute( 1224d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber transport.c_str(), "client_port", &clientPort)) { 1225d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber badRequest = true; 1226d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else if (sscanf(clientPort.c_str(), "%d-%d", 1227d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber &clientRtp, &clientRtcp) == 2) { 1228d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else if (sscanf(clientPort.c_str(), "%d", &clientRtp) == 1) { 1229d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // No RTCP. 1230d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtcp = -1; 1231d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else { 1232d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber badRequest = true; 1233d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1234d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1235d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (badRequest) { 1236d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "400 Bad Request", cseq); 1237b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1238d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1239d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#if 1 1240a438123bd96c7faf145683876702387efe5628d9Andreas Huber // The older LG dongles doesn't specify client_port=xxx apparently. 1241d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else if (transport == "RTP/AVP/UDP;unicast") { 1242d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtp = 19000; 124328e17ed7e2fbb254fb99481b74db85e427c905eeAndreas Huber clientRtcp = -1; 1244d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#endif 1245d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else { 1246d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "461 Unsupported Transport", cseq); 1247b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_UNSUPPORTED; 1248d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1249d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1250d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID = makeUniquePlaybackSessionID(); 1251d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1252d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<AMessage> notify = new AMessage(kWhatPlaybackSessionNotify, id()); 1253d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber notify->setInt32("playbackSessionID", playbackSessionID); 1254d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber notify->setInt32("sessionID", sessionID); 1255d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1256d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 12570b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber new PlaybackSession( 12580b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber mNetSession, notify, mInterfaceAddr, mHDCP, mMediaPath.c_str()); 1259d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1260d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber looper()->registerHandler(playbackSession); 1261d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1262d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString uri; 1263d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber data->getRequestField(1, &uri); 1264d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1265d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (strncasecmp("rtsp://", uri.c_str(), 7)) { 1266d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "400 Bad Request", cseq); 1267b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1268d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1269d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1270d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!(uri.startsWith("rtsp://") && uri.endsWith("/wfd1.0/streamid=0"))) { 1271d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "404 Not found", cseq); 1272b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1273d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1274d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 12752aea9552aeba92bbaf9e56c666049ea2d14057b5Andreas Huber RTPSender::TransportMode rtcpMode = RTPSender::TRANSPORT_UDP; 12762aea9552aeba92bbaf9e56c666049ea2d14057b5Andreas Huber if (clientRtcp < 0) { 12772aea9552aeba92bbaf9e56c666049ea2d14057b5Andreas Huber rtcpMode = RTPSender::TRANSPORT_NONE; 12782aea9552aeba92bbaf9e56c666049ea2d14057b5Andreas Huber } 12792aea9552aeba92bbaf9e56c666049ea2d14057b5Andreas Huber 1280d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = playbackSession->init( 1281c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mRemoteIP.c_str(), 1282d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtp, 12832aea9552aeba92bbaf9e56c666049ea2d14057b5Andreas Huber rtpMode, 1284d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtcp, 12852aea9552aeba92bbaf9e56c666049ea2d14057b5Andreas Huber rtcpMode, 128694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mSinkSupportsAudio, 128794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mUsingPCMAudio, 128894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mSinkSupportsVideo, 128994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mChosenVideoResolutionType, 1290308bcaa44e578279e61be32b572fdb0b11b1e4c7Chong Zhang mChosenVideoResolutionIndex, 1291308bcaa44e578279e61be32b572fdb0b11b1e4c7Chong Zhang mChosenVideoProfile, 1292308bcaa44e578279e61be32b572fdb0b11b1e4c7Chong Zhang mChosenVideoLevel); 1293d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1294d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 1295d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber looper()->unregisterHandler(playbackSession->id()); 1296d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber playbackSession.clear(); 1297d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1298d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1299d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber switch (err) { 1300d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case OK: 1301d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 1302d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case -ENOENT: 1303d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "404 Not Found", cseq); 1304b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1305d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber default: 1306d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "403 Forbidden", cseq); 1307b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1308d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1309d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1310c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mPlaybackSessionID = playbackSessionID; 1311c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mPlaybackSession = playbackSession; 1312b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 1313d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1314d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1315d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 13162aea9552aeba92bbaf9e56c666049ea2d14057b5Andreas Huber if (rtpMode == RTPSender::TRANSPORT_TCP_INTERLEAVED) { 1317d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append( 1318d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber StringPrintf( 1319d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "Transport: RTP/AVP/TCP;interleaved=%d-%d;", 1320d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtp, clientRtcp)); 1321d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else { 1322d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t serverRtp = playbackSession->getRTPPort(); 1323d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1324bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber AString transportString = "UDP"; 13252aea9552aeba92bbaf9e56c666049ea2d14057b5Andreas Huber if (rtpMode == RTPSender::TRANSPORT_TCP) { 1326bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber transportString = "TCP"; 1327bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } 1328bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber 1329d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (clientRtcp >= 0) { 1330d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append( 1331d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber StringPrintf( 1332bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber "Transport: RTP/AVP/%s;unicast;client_port=%d-%d;" 1333d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "server_port=%d-%d\r\n", 1334bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber transportString.c_str(), 1335d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtp, clientRtcp, serverRtp, serverRtp + 1)); 1336d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else { 1337d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append( 1338d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber StringPrintf( 1339bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber "Transport: RTP/AVP/%s;unicast;client_port=%d;" 1340d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "server_port=%d\r\n", 1341bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber transportString.c_str(), 1342d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtp, serverRtp)); 1343d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1344d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1345d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1346d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1347d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1348d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber err = mNetSession->sendRequest(sessionID, response.c_str()); 1349b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1350b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err != OK) { 1351b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1352b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1353d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1354ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = AWAITING_CLIENT_PLAY; 1355ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 1356d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber scheduleReaper(); 1357b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber scheduleKeepAlive(sessionID); 1358b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1359b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 1360d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1361d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1362b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onPlayRequest( 1363d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1364d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1365d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1366d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1367d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1368d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1369d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1370d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession == NULL) { 1371d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "454 Session Not Found", cseq); 1372b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1373d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1374d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1375bd25dacce1187c827dde3fb72036c044c8106719Chong Zhang if (mState != AWAITING_CLIENT_PLAY 1376bd25dacce1187c827dde3fb72036c044c8106719Chong Zhang && mState != PAUSED_TO_PLAYING 1377bd25dacce1187c827dde3fb72036c044c8106719Chong Zhang && mState != PAUSED) { 1378ff9297ac908aa01e44fda4ab9ca7a4bb514c00fdAndreas Huber ALOGW("Received PLAY request but we're in state %d", mState); 1379ff9297ac908aa01e44fda4ab9ca7a4bb514c00fdAndreas Huber 1380ff9297ac908aa01e44fda4ab9ca7a4bb514c00fdAndreas Huber sendErrorResponse( 1381ff9297ac908aa01e44fda4ab9ca7a4bb514c00fdAndreas Huber sessionID, "455 Method Not Valid in This State", cseq); 1382ff9297ac908aa01e44fda4ab9ca7a4bb514c00fdAndreas Huber 1383ff9297ac908aa01e44fda4ab9ca7a4bb514c00fdAndreas Huber return INVALID_OPERATION; 1384ff9297ac908aa01e44fda4ab9ca7a4bb514c00fdAndreas Huber } 1385ff9297ac908aa01e44fda4ab9ca7a4bb514c00fdAndreas Huber 1386ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGI("Received PLAY request."); 13870b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber if (mPlaybackSessionEstablished) { 13880b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber finishPlay(); 13890b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber } else { 13900b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber ALOGI("deferring PLAY request until session established."); 13910b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber } 1392d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1393d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1394d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1395d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("Range: npt=now-\r\n"); 1396d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1397d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 13980b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber status_t err = mNetSession->sendRequest(sessionID, response.c_str()); 1399b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1400b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err != OK) { 1401b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1402b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 14030b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber 1404bd25dacce1187c827dde3fb72036c044c8106719Chong Zhang if (mState == PAUSED_TO_PLAYING || mPlaybackSessionEstablished) { 14055131d127a042ee88f903370be88845dc8c9f8578Andreas Huber mState = PLAYING; 14065131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return OK; 14075131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 14085131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 1409ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber CHECK_EQ(mState, AWAITING_CLIENT_PLAY); 1410ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = ABOUT_TO_PLAY; 1411ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 1412b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 1413d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1414d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 14150b530f1050150bb751ae642d5a9dce34141d9475Andreas Hubervoid WifiDisplaySource::finishPlay() { 14160b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber const sp<PlaybackSession> &playbackSession = 14170b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber mClientInfo.mPlaybackSession; 14180b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber 14190b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber status_t err = playbackSession->play(); 14200b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber CHECK_EQ(err, (status_t)OK); 14210b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber} 14220b530f1050150bb751ae642d5a9dce34141d9475Andreas Huber 1423b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onPauseRequest( 1424d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1425d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1426d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1427d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1428d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1429d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1430d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1431d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession == NULL) { 1432d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "454 Session Not Found", cseq); 1433b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1434d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1435d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 14365131d127a042ee88f903370be88845dc8c9f8578Andreas Huber ALOGI("Received PAUSE request."); 14375131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 1438bd25dacce1187c827dde3fb72036c044c8106719Chong Zhang if (mState != PLAYING_TO_PAUSED && mState != PLAYING) { 14395131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return INVALID_OPERATION; 14405131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 14415131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 1442d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = playbackSession->pause(); 1443d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK_EQ(err, (status_t)OK); 1444d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1445d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1446d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1447d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1448d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1449d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber err = mNetSession->sendRequest(sessionID, response.c_str()); 1450b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 14515131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (err != OK) { 14525131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return err; 14535131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 14545131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 14555131d127a042ee88f903370be88845dc8c9f8578Andreas Huber mState = PAUSED; 14565131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 1457b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1458d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1459d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1460b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onTeardownRequest( 1461d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1462d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1463d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1464ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGI("Received TEARDOWN request."); 1465ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 1466d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1467d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1468d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1469d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1470d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession == NULL) { 1471d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "454 Session Not Found", cseq); 1472b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1473d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1474d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1475d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1476d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1477c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber response.append("Connection: close\r\n"); 1478d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1479d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1480ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mNetSession->sendRequest(sessionID, response.c_str()); 1481c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 1482ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber if (mState == AWAITING_CLIENT_TEARDOWN) { 1483ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber CHECK_NE(mStopReplyID, 0); 1484eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber finishStop(); 1485ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber } else { 1486ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError(IRemoteDisplayClient::kDisplayErrorUnknown); 1487ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber } 1488b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1489b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 1490d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1491d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1492eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Hubervoid WifiDisplaySource::finishStop() { 1493ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGV("finishStop"); 1494ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 1495ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = STOPPING; 1496ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 149796fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber disconnectClientAsync(); 149896fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber} 149996fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber 150096fc6cc65ca93009a759a3a874b82a35771b9714Andreas Hubervoid WifiDisplaySource::finishStopAfterDisconnectingClient() { 150196fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber ALOGV("finishStopAfterDisconnectingClient"); 150296fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber 1503ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber if (mHDCP != NULL) { 1504ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGI("Initiating HDCP shutdown."); 1505ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber mHDCP->shutdownAsync(); 1506eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber return; 1507ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber } 1508ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 1509eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber finishStop2(); 1510eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber} 1511eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber 1512eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Hubervoid WifiDisplaySource::finishStop2() { 1513ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGV("finishStop2"); 1514ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 1515bbe96f0f05a1f1a1b3cfec0d124cb0d63c1ebf2aAndreas Huber if (mHDCP != NULL) { 1516bbe96f0f05a1f1a1b3cfec0d124cb0d63c1ebf2aAndreas Huber mHDCP->setObserver(NULL); 1517bbe96f0f05a1f1a1b3cfec0d124cb0d63c1ebf2aAndreas Huber mHDCPObserver.clear(); 1518bbe96f0f05a1f1a1b3cfec0d124cb0d63c1ebf2aAndreas Huber mHDCP.clear(); 1519bbe96f0f05a1f1a1b3cfec0d124cb0d63c1ebf2aAndreas Huber } 1520eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber 1521ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber if (mSessionID != 0) { 1522ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mNetSession->destroySession(mSessionID); 1523ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mSessionID = 0; 1524ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber } 1525ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 152696fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber ALOGI("We're stopped."); 1527ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = STOPPED; 1528ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 1529ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber status_t err = OK; 1530ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 1531ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber sp<AMessage> response = new AMessage; 1532ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber response->setInt32("err", err); 1533eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber response->postReply(mStopReplyID); 1534ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber} 1535ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 1536b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onGetParameterRequest( 1537d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1538d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1539d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1540d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1541d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1542d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1543d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1544d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession == NULL) { 1545d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "454 Session Not Found", cseq); 1546b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1547d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1548d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1549d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber playbackSession->updateLiveness(); 1550d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1551d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1552d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1553d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1554d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1555d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = mNetSession->sendRequest(sessionID, response.c_str()); 1556b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1557d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1558d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1559b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onSetParameterRequest( 1560d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1561d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1562d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1563d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1564d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1565d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1566d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1567d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession == NULL) { 1568d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "454 Session Not Found", cseq); 1569b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1570d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1571d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1572b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (strstr(data->getContent(), "wfd_idr_request\r\n")) { 1573b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber playbackSession->requestIDRFrame(); 1574b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1575496238cc7551d414067dcbbb4fe3bd801f205f95Andreas Huber 1576d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber playbackSession->updateLiveness(); 1577d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1578d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1579d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1580d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1581d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1582d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = mNetSession->sendRequest(sessionID, response.c_str()); 1583b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1584d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1585d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1586d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber// static 1587d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubervoid WifiDisplaySource::AppendCommonResponse( 1588d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString *response, int32_t cseq, int32_t playbackSessionID) { 1589d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber time_t now = time(NULL); 1590d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber struct tm *now2 = gmtime(&now); 1591d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber char buf[128]; 1592d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber strftime(buf, sizeof(buf), "%a, %d %b %Y %H:%M:%S %z", now2); 1593d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1594d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append("Date: "); 1595d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append(buf); 1596d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append("\r\n"); 1597d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1598cd77d4a1d38b7609a03f6826a1ff5fa7c98aa34fAndreas Huber response->append(StringPrintf("Server: %s\r\n", sUserAgent.c_str())); 1599d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1600d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (cseq >= 0) { 1601d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append(StringPrintf("CSeq: %d\r\n", cseq)); 1602d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1603d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1604d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSessionID >= 0ll) { 1605d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append( 1606d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber StringPrintf( 1607d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "Session: %d;timeout=%lld\r\n", 1608d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber playbackSessionID, kPlaybackSessionTimeoutSecs)); 1609d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1610d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1611d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1612d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubervoid WifiDisplaySource::sendErrorResponse( 1613d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1614d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const char *errorDetail, 1615d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq) { 1616d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response; 1617d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("RTSP/1.0 "); 1618d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append(errorDetail); 1619d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1620d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1621d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq); 1622d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1623d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1624d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1625eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber mNetSession->sendRequest(sessionID, response.c_str()); 1626d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1627d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1628d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberint32_t WifiDisplaySource::makeUniquePlaybackSessionID() const { 1629c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber return rand(); 1630d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1631d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1632d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubersp<WifiDisplaySource::PlaybackSession> WifiDisplaySource::findPlaybackSession( 1633d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data, int32_t *playbackSessionID) const { 1634d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!data->findInt32("session", playbackSessionID)) { 1635c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber // XXX the older dongles do not always include a "Session:" header. 1636c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber *playbackSessionID = mClientInfo.mPlaybackSessionID; 1637c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber return mClientInfo.mPlaybackSession; 1638d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1639d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1640c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (*playbackSessionID != mClientInfo.mPlaybackSessionID) { 1641d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return NULL; 1642d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1643d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1644c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber return mClientInfo.mPlaybackSession; 1645c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber} 1646c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 164796fc6cc65ca93009a759a3a874b82a35771b9714Andreas Hubervoid WifiDisplaySource::disconnectClientAsync() { 164896fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber ALOGV("disconnectClient"); 164996fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber 165096fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber if (mClientInfo.mPlaybackSession == NULL) { 165196fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber disconnectClient2(); 165296fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber return; 165396fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber } 165496fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber 165596fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber if (mClientInfo.mPlaybackSession != NULL) { 165696fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber ALOGV("Destroying PlaybackSession"); 165796fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber mClientInfo.mPlaybackSession->destroyAsync(); 165896fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber } 165996fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber} 166096fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber 166196fc6cc65ca93009a759a3a874b82a35771b9714Andreas Hubervoid WifiDisplaySource::disconnectClient2() { 166296fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber ALOGV("disconnectClient2"); 166396fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber 1664ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber if (mClientInfo.mPlaybackSession != NULL) { 166596fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber looper()->unregisterHandler(mClientInfo.mPlaybackSession->id()); 1666ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClientInfo.mPlaybackSession.clear(); 1667ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber } 1668c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 1669ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber if (mClientSessionID != 0) { 1670c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mNetSession->destroySession(mClientSessionID); 1671c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientSessionID = 0; 1672c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } 1673c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 1674ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayDisconnected(); 167596fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber 167696fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber finishStopAfterDisconnectingClient(); 1677d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1678d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1679b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstruct WifiDisplaySource::HDCPObserver : public BnHDCPObserver { 1680b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber HDCPObserver(const sp<AMessage> ¬ify); 1681b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1682b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber virtual void notify( 1683b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber int msg, int ext1, int ext2, const Parcel *obj); 1684b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1685b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberprivate: 1686b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<AMessage> mNotify; 1687b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1688b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber DISALLOW_EVIL_CONSTRUCTORS(HDCPObserver); 1689b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber}; 1690b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1691b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas HuberWifiDisplaySource::HDCPObserver::HDCPObserver( 1692b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber const sp<AMessage> ¬ify) 1693b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber : mNotify(notify) { 1694b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber} 1695b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1696b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Hubervoid WifiDisplaySource::HDCPObserver::notify( 1697b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber int msg, int ext1, int ext2, const Parcel *obj) { 1698b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<AMessage> notify = mNotify->dup(); 1699b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber notify->setInt32("msg", msg); 1700b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber notify->setInt32("ext1", ext1); 1701b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber notify->setInt32("ext2", ext2); 1702b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber notify->post(); 1703b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber} 1704b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1705b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::makeHDCP() { 1706b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<IServiceManager> sm = defaultServiceManager(); 1707b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<IBinder> binder = sm->getService(String16("media.player")); 1708ff9297ac908aa01e44fda4ab9ca7a4bb514c00fdAndreas Huber 1709ff9297ac908aa01e44fda4ab9ca7a4bb514c00fdAndreas Huber sp<IMediaPlayerService> service = 1710ff9297ac908aa01e44fda4ab9ca7a4bb514c00fdAndreas Huber interface_cast<IMediaPlayerService>(binder); 1711ff9297ac908aa01e44fda4ab9ca7a4bb514c00fdAndreas Huber 1712b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber CHECK(service != NULL); 1713b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1714a6a88d9c445e261972c2433254e0a996336e78a4Andreas Huber mHDCP = service->makeHDCP(true /* createEncryptionModule */); 1715b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1716b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (mHDCP == NULL) { 1717b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_UNSUPPORTED; 1718b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1719b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1720b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<AMessage> notify = new AMessage(kWhatHDCPNotify, id()); 1721b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mHDCPObserver = new HDCPObserver(notify); 1722b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1723b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber status_t err = mHDCP->setObserver(mHDCPObserver); 1724b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1725b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err != OK) { 1726b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber ALOGE("Failed to set HDCP observer."); 1727b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1728b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mHDCPObserver.clear(); 1729b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mHDCP.clear(); 1730b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1731b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1732b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1733b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1734ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGI("Initiating HDCP negotiation w/ host %s:%d", 1735b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mClientInfo.mRemoteIP.c_str(), mHDCPPort); 1736b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1737b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = mHDCP->initAsync(mClientInfo.mRemoteIP.c_str(), mHDCPPort); 1738b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1739b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err != OK) { 1740b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1741b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1742b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1743b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 1744b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber} 1745b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1746d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} // namespace android 1747d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1748