WifiDisplaySource.cpp revision 5131d127a042ee88f903370be88845dc8c9f8578
1d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber/* 2d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber * Copyright 2012, The Android Open Source Project 3d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber * 4d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber * Licensed under the Apache License, Version 2.0 (the "License"); 5d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber * you may not use this file except in compliance with the License. 6d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber * You may obtain a copy of the License at 7d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber * 8d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber * http://www.apache.org/licenses/LICENSE-2.0 9d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber * 10d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber * Unless required by applicable law or agreed to in writing, software 11d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber * distributed under the License is distributed on an "AS IS" BASIS, 12d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber * See the License for the specific language governing permissions and 14d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber * limitations under the License. 15d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber */ 16d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1772f6aea5afba3ff8ab7e8eab49552d65ee3bb97bAndreas Huber//#define LOG_NDEBUG 0 18d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#define LOG_TAG "WifiDisplaySource" 19d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#include <utils/Log.h> 20d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 21d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#include "WifiDisplaySource.h" 22d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#include "PlaybackSession.h" 23b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#include "Parameters.h" 24d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#include "ParsedMessage.h" 2590a92053219ae50ddf4bb54e3d54db2d309e2b8dAndreas Huber#include "Sender.h" 26d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 27b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#include <binder/IServiceManager.h> 280b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber#include <gui/ISurfaceTexture.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> 35d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#include <media/stagefright/MediaErrors.h> 36d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 37bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber#include <arpa/inet.h> 38bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber#include <cutils/properties.h> 39bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 40d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber#include <ctype.h> 41d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 42d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubernamespace android { 43d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 440b73d4730202fcad53aefc4314a06e7b95f442f0Andreas HuberWifiDisplaySource::WifiDisplaySource( 450b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber const sp<ANetworkSession> &netSession, 460b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber const sp<IRemoteDisplayClient> &client) 47ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber : mState(INITIALIZED), 48ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mNetSession(netSession), 490b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber mClient(client), 50d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mSessionID(0), 51ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber mStopReplyID(0), 52d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber mChosenRTPPort(-1), 53e7bd24af08ef0722fb124a550662bcec48c56f86Andreas Huber mUsingPCMAudio(false), 54c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientSessionID(0), 55d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mReaperPending(false), 560328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mNextCSeq(1), 570328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mUsingHDCP(false), 580328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mIsHDCP2_0(false), 590328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mHDCPPort(0), 600328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mHDCPInitializationComplete(false), 610328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mSetupTriggerDeferred(false) 62b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber{ 63d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 64d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 65d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas HuberWifiDisplaySource::~WifiDisplaySource() { 66d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 67d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 685131d127a042ee88f903370be88845dc8c9f8578Andreas Huberstatic status_t PostAndAwaitResponse( 695131d127a042ee88f903370be88845dc8c9f8578Andreas Huber const sp<AMessage> &msg, sp<AMessage> *response) { 705131d127a042ee88f903370be88845dc8c9f8578Andreas Huber status_t err = msg->postAndAwaitResponse(response); 71d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 72d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 73d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 74d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 75d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 765131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (response == NULL || !(*response)->findInt32("err", &err)) { 77d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber err = OK; 78d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 79d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 80d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 81d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 82d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 835131d127a042ee88f903370be88845dc8c9f8578Andreas Huberstatus_t WifiDisplaySource::start(const char *iface) { 845131d127a042ee88f903370be88845dc8c9f8578Andreas Huber CHECK_EQ(mState, INITIALIZED); 855131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 865131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> msg = new AMessage(kWhatStart, id()); 875131d127a042ee88f903370be88845dc8c9f8578Andreas Huber msg->setString("iface", iface); 885131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 895131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> response; 905131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return PostAndAwaitResponse(msg, &response); 915131d127a042ee88f903370be88845dc8c9f8578Andreas Huber} 925131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 93d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::stop() { 94d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<AMessage> msg = new AMessage(kWhatStop, id()); 95d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 96d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<AMessage> response; 975131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return PostAndAwaitResponse(msg, &response); 985131d127a042ee88f903370be88845dc8c9f8578Andreas Huber} 99d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1005131d127a042ee88f903370be88845dc8c9f8578Andreas Huberstatus_t WifiDisplaySource::pause() { 1015131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> msg = new AMessage(kWhatPause, id()); 102d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1035131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> response; 1045131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return PostAndAwaitResponse(msg, &response); 1055131d127a042ee88f903370be88845dc8c9f8578Andreas Huber} 106d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1075131d127a042ee88f903370be88845dc8c9f8578Andreas Huberstatus_t WifiDisplaySource::resume() { 1085131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> msg = new AMessage(kWhatResume, id()); 1095131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 1105131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> response; 1115131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return PostAndAwaitResponse(msg, &response); 112d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 113d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 114d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubervoid WifiDisplaySource::onMessageReceived(const sp<AMessage> &msg) { 115d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber switch (msg->what()) { 116d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case kWhatStart: 117d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 118d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber uint32_t replyID; 119d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->senderAwaitsResponse(&replyID)); 120d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 121bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber AString iface; 122bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber CHECK(msg->findString("iface", &iface)); 123bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 124bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber status_t err = OK; 125bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 126bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber ssize_t colonPos = iface.find(":"); 127bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 128bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber unsigned long port; 129bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 130bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber if (colonPos >= 0) { 131bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber const char *s = iface.c_str() + colonPos + 1; 132bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 133bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber char *end; 134bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber port = strtoul(s, &end, 10); 135bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 136bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber if (end == s || *end != '\0' || port > 65535) { 137bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber err = -EINVAL; 138bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } else { 139bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber iface.erase(colonPos, iface.size() - colonPos); 140bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } 141bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } else { 142bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber port = kWifiDisplayDefaultPort; 143bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } 144bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 145bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber if (err == OK) { 146bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber if (inet_aton(iface.c_str(), &mInterfaceAddr) != 0) { 147bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber sp<AMessage> notify = new AMessage(kWhatRTSPNotify, id()); 148d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 149bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber err = mNetSession->createRTSPServer( 150bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber mInterfaceAddr, port, notify, &mSessionID); 151bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } else { 152bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber err = -EINVAL; 153bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } 154bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } 155d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 156ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber if (err == OK) { 157ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = AWAITING_CLIENT_CONNECTION; 158ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber } 159ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 160d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<AMessage> response = new AMessage; 161d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->setInt32("err", err); 162d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->postReply(replyID); 163d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 164d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 165d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 166d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case kWhatRTSPNotify: 167d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 168d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t reason; 169d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("reason", &reason)); 170d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 171d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber switch (reason) { 172d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case ANetworkSession::kWhatError: 173d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 174d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID; 175d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("sessionID", &sessionID)); 176d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 177d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t err; 178d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("err", &err)); 179d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 180d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString detail; 181d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findString("detail", &detail)); 182d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 183d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ALOGE("An error occurred in session %d (%d, '%s/%s').", 184d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, 185d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber err, 186d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber detail.c_str(), 187d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber strerror(-err)); 188d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 189d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mNetSession->destroySession(sessionID); 190d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 191c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (sessionID == mClientSessionID) { 192ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClientSessionID = 0; 193c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 194ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError( 195ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber IRemoteDisplayClient::kDisplayErrorUnknown); 196c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } 197d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 198d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 199d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 200d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case ANetworkSession::kWhatClientConnected: 201d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 202d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID; 203d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("sessionID", &sessionID)); 204d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 205c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientSessionID > 0) { 206c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber ALOGW("A client tried to connect, but we already " 207c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber "have one."); 208d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 209c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mNetSession->destroySession(sessionID); 210c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber break; 211c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } 212c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 213ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber CHECK_EQ(mState, AWAITING_CLIENT_CONNECTION); 214ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 215c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findString("client-ip", &mClientInfo.mRemoteIP)); 216c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findString("server-ip", &mClientInfo.mLocalIP)); 217c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 218c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientInfo.mRemoteIP == mClientInfo.mLocalIP) { 219c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber // Disallow connections from the local interface 220c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber // for security reasons. 221c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mNetSession->destroySession(sessionID); 222c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber break; 223c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } 224d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 225c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findInt32( 226c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber "server-port", &mClientInfo.mLocalPort)); 227c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mPlaybackSessionID = -1; 228c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 229c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientSessionID = sessionID; 230c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 231c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber ALOGI("We now have a client (%d) connected.", sessionID); 232d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 233ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = AWAITING_CLIENT_SETUP; 234ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 235d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = sendM1(sessionID); 236d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK_EQ(err, (status_t)OK); 237d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 238d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 239d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 240d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case ANetworkSession::kWhatData: 241d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 242b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber status_t err = onReceiveClientData(msg); 243b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 244b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err != OK) { 245ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError( 246ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber IRemoteDisplayClient::kDisplayErrorUnknown); 247b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 2485131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 2495131d127a042ee88f903370be88845dc8c9f8578Andreas Huber#if 0 2505131d127a042ee88f903370be88845dc8c9f8578Andreas Huber // testing only. 2515131d127a042ee88f903370be88845dc8c9f8578Andreas Huber char val[PROPERTY_VALUE_MAX]; 2525131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (property_get("media.wfd.trigger", val, NULL)) { 2535131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (!strcasecmp(val, "pause") && mState == PLAYING) { 2545131d127a042ee88f903370be88845dc8c9f8578Andreas Huber mState = PLAYING_TO_PAUSED; 2555131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sendTrigger(mClientSessionID, TRIGGER_PAUSE); 2565131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } else if (!strcasecmp(val, "play") && mState == PAUSED) { 2575131d127a042ee88f903370be88845dc8c9f8578Andreas Huber mState = PAUSED_TO_PLAYING; 2585131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sendTrigger(mClientSessionID, TRIGGER_PLAY); 2595131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 2605131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 2615131d127a042ee88f903370be88845dc8c9f8578Andreas Huber#endif 262d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 263d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 264d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 265d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber default: 266d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber TRESPASS(); 267d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 268d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 269d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 270d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 271d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case kWhatStop: 272d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 273eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber CHECK(msg->senderAwaitsResponse(&mStopReplyID)); 274d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 275ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber CHECK_LT(mState, AWAITING_CLIENT_TEARDOWN); 276ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 277ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber if (mState >= AWAITING_CLIENT_PLAY) { 278ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber // We have a session, i.e. a previous SETUP succeeded. 279ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 2805131d127a042ee88f903370be88845dc8c9f8578Andreas Huber status_t err = sendTrigger( 2815131d127a042ee88f903370be88845dc8c9f8578Andreas Huber mClientSessionID, TRIGGER_TEARDOWN); 2820b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber 283ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber if (err == OK) { 284ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = AWAITING_CLIENT_TEARDOWN; 285ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 286ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber (new AMessage(kWhatTeardownTriggerTimedOut, id()))->post( 287ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber kTeardownTriggerTimeouSecs * 1000000ll); 288ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 289ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber break; 290ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber } 291ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 292ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber // fall through. 293b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 294d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 295eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber finishStop(); 296d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 297d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 298d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 2995131d127a042ee88f903370be88845dc8c9f8578Andreas Huber case kWhatPause: 3005131d127a042ee88f903370be88845dc8c9f8578Andreas Huber { 3015131d127a042ee88f903370be88845dc8c9f8578Andreas Huber uint32_t replyID; 3025131d127a042ee88f903370be88845dc8c9f8578Andreas Huber CHECK(msg->senderAwaitsResponse(&replyID)); 3035131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 3045131d127a042ee88f903370be88845dc8c9f8578Andreas Huber status_t err = OK; 3055131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 3065131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (mState != PLAYING) { 3075131d127a042ee88f903370be88845dc8c9f8578Andreas Huber err = INVALID_OPERATION; 3085131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } else { 3095131d127a042ee88f903370be88845dc8c9f8578Andreas Huber mState = PLAYING_TO_PAUSED; 3105131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sendTrigger(mClientSessionID, TRIGGER_PAUSE); 3115131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 3125131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 3135131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> response = new AMessage; 3145131d127a042ee88f903370be88845dc8c9f8578Andreas Huber response->setInt32("err", err); 3155131d127a042ee88f903370be88845dc8c9f8578Andreas Huber response->postReply(replyID); 3165131d127a042ee88f903370be88845dc8c9f8578Andreas Huber break; 3175131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 3185131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 3195131d127a042ee88f903370be88845dc8c9f8578Andreas Huber case kWhatResume: 3205131d127a042ee88f903370be88845dc8c9f8578Andreas Huber { 3215131d127a042ee88f903370be88845dc8c9f8578Andreas Huber uint32_t replyID; 3225131d127a042ee88f903370be88845dc8c9f8578Andreas Huber CHECK(msg->senderAwaitsResponse(&replyID)); 3235131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 3245131d127a042ee88f903370be88845dc8c9f8578Andreas Huber status_t err = OK; 3255131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 3265131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (mState != PAUSED) { 3275131d127a042ee88f903370be88845dc8c9f8578Andreas Huber err = INVALID_OPERATION; 3285131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } else { 3295131d127a042ee88f903370be88845dc8c9f8578Andreas Huber mState = PAUSED_TO_PLAYING; 3305131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sendTrigger(mClientSessionID, TRIGGER_PLAY); 3315131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 3325131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 3335131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> response = new AMessage; 3345131d127a042ee88f903370be88845dc8c9f8578Andreas Huber response->setInt32("err", err); 3355131d127a042ee88f903370be88845dc8c9f8578Andreas Huber response->postReply(replyID); 3365131d127a042ee88f903370be88845dc8c9f8578Andreas Huber break; 3375131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 3385131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 339d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case kWhatReapDeadClients: 340d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 341d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mReaperPending = false; 342d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 343c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientSessionID == 0 344c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber || mClientInfo.mPlaybackSession == NULL) { 345c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber break; 346d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 347d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 348c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientInfo.mPlaybackSession->getLastLifesignUs() 349c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber + kPlaybackSessionTimeoutUs < ALooper::GetNowUs()) { 350c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber ALOGI("playback session timed out, reaping."); 351c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 352ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mNetSession->destroySession(mClientSessionID); 353ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClientSessionID = 0; 354ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 355ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError( 356ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber IRemoteDisplayClient::kDisplayErrorUnknown); 357c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } else { 358d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber scheduleReaper(); 359d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 360d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 361d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 362d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 363d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case kWhatPlaybackSessionNotify: 364d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 365d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 366d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("playbackSessionID", &playbackSessionID)); 367d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 368d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t what; 369d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("what", &what)); 370d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 371c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (what == PlaybackSession::kWhatSessionDead) { 372c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber ALOGI("playback session wants to quit."); 373c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 374ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError( 375ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber IRemoteDisplayClient::kDisplayErrorUnknown); 376c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } else if (what == PlaybackSession::kWhatSessionEstablished) { 377c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClient != NULL) { 378c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClient->onDisplayConnected( 379c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mPlaybackSession->getSurfaceTexture(), 380c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mPlaybackSession->width(), 381c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mPlaybackSession->height(), 3820328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mUsingHDCP 3830328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber ? IRemoteDisplayClient::kDisplayFlagSecure 3840328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber : 0); 385c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } 386ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 387ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber if (mState == ABOUT_TO_PLAY) { 388ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = PLAYING; 389ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber } 39096fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber } else if (what == PlaybackSession::kWhatSessionDestroyed) { 39196fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber disconnectClient2(); 392c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } else { 393c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_EQ(what, PlaybackSession::kWhatBinaryData); 394d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 395c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber int32_t channel; 396c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findInt32("channel", &channel)); 397d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 398c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber sp<ABuffer> data; 399c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findBuffer("data", &data)); 400d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 401c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_LE(channel, 0xffu); 402c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_LE(data->size(), 0xffffu); 403d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 404c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber int32_t sessionID; 405c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findInt32("sessionID", &sessionID)); 406d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 407c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber char header[4]; 408c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber header[0] = '$'; 409c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber header[1] = channel; 410c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber header[2] = data->size() >> 8; 411c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber header[3] = data->size() & 0xff; 412d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 413c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mNetSession->sendRequest( 414c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber sessionID, header, sizeof(header)); 415d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 416c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mNetSession->sendRequest( 417c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber sessionID, data->data(), data->size()); 418d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 419d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 420d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 421d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 422b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber case kWhatKeepAlive: 423b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber { 424b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber int32_t sessionID; 425b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber CHECK(msg->findInt32("sessionID", &sessionID)); 426b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 427c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientSessionID != sessionID) { 428b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // Obsolete event, client is already gone. 429b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber break; 430b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber } 431b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 432b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber sendM16(sessionID); 433b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber break; 434b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber } 435b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 436ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber case kWhatTeardownTriggerTimedOut: 437ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber { 438ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber if (mState == AWAITING_CLIENT_TEARDOWN) { 439ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber ALOGI("TEARDOWN trigger timed out, forcing disconnection."); 440ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 441ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber CHECK_NE(mStopReplyID, 0); 442ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber finishStop(); 443ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber break; 444ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber } 445ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber break; 446ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber } 447ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 448b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber case kWhatHDCPNotify: 449b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber { 450b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber int32_t msgCode, ext1, ext2; 451b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber CHECK(msg->findInt32("msg", &msgCode)); 452b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber CHECK(msg->findInt32("ext1", &ext1)); 453b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber CHECK(msg->findInt32("ext2", &ext2)); 454b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 455eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber ALOGI("Saw HDCP notification code %d, ext1 %d, ext2 %d", 456b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber msgCode, ext1, ext2); 457b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 458b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber switch (msgCode) { 459b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber case HDCPModule::HDCP_INITIALIZATION_COMPLETE: 460b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber { 461b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mHDCPInitializationComplete = true; 462b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 463b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (mSetupTriggerDeferred) { 464b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mSetupTriggerDeferred = false; 465b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 4665131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sendTrigger(mClientSessionID, TRIGGER_SETUP); 467b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 468b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber break; 469b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 470b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 471eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber case HDCPModule::HDCP_SHUTDOWN_COMPLETE: 472ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber case HDCPModule::HDCP_SHUTDOWN_FAILED: 473eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber { 474ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber // Ugly hack to make sure that the call to 475ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber // HDCPObserver::notify is completely handled before 476ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber // we clear the HDCP instance and unload the shared 477ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber // library :( 478ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber (new AMessage(kWhatFinishStop2, id()))->post(300000ll); 479eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber break; 480eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber } 481eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber 482b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber default: 483b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber { 484ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber ALOGE("HDCP failure, shutting down."); 485ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 486ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError( 487ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber IRemoteDisplayClient::kDisplayErrorUnknown); 488b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber break; 489b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 490b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 491b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber break; 492b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 493ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 494ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber case kWhatFinishStop2: 495ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber { 496ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber finishStop2(); 497ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber break; 498ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber } 499b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 500d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber default: 501d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber TRESPASS(); 502d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 503d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 504d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 505d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubervoid WifiDisplaySource::registerResponseHandler( 506d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, int32_t cseq, HandleRTSPResponseFunc func) { 507d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ResponseID id; 508d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber id.mSessionID = sessionID; 509d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber id.mCSeq = cseq; 510d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mResponseHandlers.add(id, func); 511d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 512d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 513d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::sendM1(int32_t sessionID) { 514d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString request = "OPTIONS * RTSP/1.0\r\n"; 515d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&request, mNextCSeq); 516d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 517d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append( 518d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "Require: org.wfa.wfd1.0\r\n" 519d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "\r\n"); 520d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 521d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = 522d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mNetSession->sendRequest(sessionID, request.c_str(), request.size()); 523d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 524d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 525d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 526d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 527d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 528d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber registerResponseHandler( 529d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, mNextCSeq, &WifiDisplaySource::onReceiveM1Response); 530d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 531d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ++mNextCSeq; 532d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 533d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 534d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 535d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 536d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::sendM3(int32_t sessionID) { 537d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString body = 538b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber "wfd_content_protection\r\n" 539d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "wfd_video_formats\r\n" 540d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "wfd_audio_codecs\r\n" 541d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "wfd_client_rtp_ports\r\n"; 542d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 543d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString request = "GET_PARAMETER rtsp://localhost/wfd1.0 RTSP/1.0\r\n"; 544d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&request, mNextCSeq); 545d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 546d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("Content-Type: text/parameters\r\n"); 547d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(StringPrintf("Content-Length: %d\r\n", body.size())); 548d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("\r\n"); 549d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(body); 550d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 551d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = 552d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mNetSession->sendRequest(sessionID, request.c_str(), request.size()); 553d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 554d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 555d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 556d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 557d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 558d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber registerResponseHandler( 559d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, mNextCSeq, &WifiDisplaySource::onReceiveM3Response); 560d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 561d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ++mNextCSeq; 562d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 563d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 564d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 565d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 566d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::sendM4(int32_t sessionID) { 567d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // wfd_video_formats: 568d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // 1 byte "native" 569d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // 1 byte "preferred-display-mode-supported" 0 or 1 570d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // one or more avc codec structures 571d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // 1 byte profile 572d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // 1 byte level 573d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // 4 byte CEA mask 574d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // 4 byte VESA mask 575d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // 4 byte HH mask 576d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // 1 byte latency 577d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // 2 byte min-slice-slice 578d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // 2 byte slice-enc-params 579d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // 1 byte framerate-control-support 580d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // max-hres (none or 2 byte) 581d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // max-vres (none or 2 byte) 582d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 583c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_EQ(sessionID, mClientSessionID); 584d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 585bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber AString transportString = "UDP"; 586bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber 587bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber char val[PROPERTY_VALUE_MAX]; 588bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber if (property_get("media.wfd.enable-tcp", val, NULL) 589bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber && (!strcasecmp("true", val) || !strcmp("1", val))) { 590bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber ALOGI("Using TCP transport."); 591bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber transportString = "TCP"; 592bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } 593bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber 594b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber // For 720p60: 595b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber // use "30 00 02 02 00000040 00000000 00000000 00 0000 0000 00 none none\r\n" 596b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber // For 720p30: 597b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber // use "28 00 02 02 00000020 00000000 00000000 00 0000 0000 00 none none\r\n" 59872ff5903df5f409ea83f74c363a52f0745ced8b8Andreas Huber // For 720p24: 59972ff5903df5f409ea83f74c363a52f0745ced8b8Andreas Huber // use "78 00 02 02 00008000 00000000 00000000 00 0000 0000 00 none none\r\n" 6000224bf170a3904576bba81593eaab113c5d3a4e7Andreas Huber // For 1080p30: 6010224bf170a3904576bba81593eaab113c5d3a4e7Andreas Huber // use "38 00 02 02 00000080 00000000 00000000 00 0000 0000 00 none none\r\n" 602d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString body = StringPrintf( 603d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "wfd_video_formats: " 6040224bf170a3904576bba81593eaab113c5d3a4e7Andreas Huber#if USE_1080P 6050224bf170a3904576bba81593eaab113c5d3a4e7Andreas Huber "38 00 02 02 00000080 00000000 00000000 00 0000 0000 00 none none\r\n" 6060224bf170a3904576bba81593eaab113c5d3a4e7Andreas Huber#else 6074a8b9a2363b7b7b4f98022e6d9aae8b8aa8e35e5Andreas Huber "28 00 02 02 00000020 00000000 00000000 00 0000 0000 00 none none\r\n" 6080224bf170a3904576bba81593eaab113c5d3a4e7Andreas Huber#endif 609e7bd24af08ef0722fb124a550662bcec48c56f86Andreas Huber "wfd_audio_codecs: %s\r\n" 610de799a74064a363d26f4c1bbc5a59d1b7127f49fAndreas Huber "wfd_presentation_URL: rtsp://%s/wfd1.0/streamid=0 none\r\n" 611d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber "wfd_client_rtp_ports: RTP/AVP/%s;unicast %d 0 mode=play\r\n", 612e7bd24af08ef0722fb124a550662bcec48c56f86Andreas Huber (mUsingPCMAudio 613e7bd24af08ef0722fb124a550662bcec48c56f86Andreas Huber ? "LPCM 00000002 00" // 2 ch PCM 48kHz 614e7bd24af08ef0722fb124a550662bcec48c56f86Andreas Huber : "AAC 00000001 00"), // 2 ch AAC 48kHz 615d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber mClientInfo.mLocalIP.c_str(), transportString.c_str(), mChosenRTPPort); 616d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 617d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString request = "SET_PARAMETER rtsp://localhost/wfd1.0 RTSP/1.0\r\n"; 618d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&request, mNextCSeq); 619d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 620d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("Content-Type: text/parameters\r\n"); 621d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(StringPrintf("Content-Length: %d\r\n", body.size())); 622d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("\r\n"); 623d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(body); 624d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 625d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = 626d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mNetSession->sendRequest(sessionID, request.c_str(), request.size()); 627d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 628d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 629d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 630d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 631d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 632d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber registerResponseHandler( 633d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, mNextCSeq, &WifiDisplaySource::onReceiveM4Response); 634d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 635d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ++mNextCSeq; 636d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 637d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 638d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 639d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 6405131d127a042ee88f903370be88845dc8c9f8578Andreas Huberstatus_t WifiDisplaySource::sendTrigger( 6415131d127a042ee88f903370be88845dc8c9f8578Andreas Huber int32_t sessionID, TriggerType triggerType) { 642ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber AString body = "wfd_trigger_method: "; 6435131d127a042ee88f903370be88845dc8c9f8578Andreas Huber switch (triggerType) { 6445131d127a042ee88f903370be88845dc8c9f8578Andreas Huber case TRIGGER_SETUP: 6455131d127a042ee88f903370be88845dc8c9f8578Andreas Huber body.append("SETUP"); 6465131d127a042ee88f903370be88845dc8c9f8578Andreas Huber break; 6475131d127a042ee88f903370be88845dc8c9f8578Andreas Huber case TRIGGER_TEARDOWN: 6485131d127a042ee88f903370be88845dc8c9f8578Andreas Huber ALOGI("Sending TEARDOWN trigger."); 6495131d127a042ee88f903370be88845dc8c9f8578Andreas Huber body.append("TEARDOWN"); 6505131d127a042ee88f903370be88845dc8c9f8578Andreas Huber break; 6515131d127a042ee88f903370be88845dc8c9f8578Andreas Huber case TRIGGER_PAUSE: 6525131d127a042ee88f903370be88845dc8c9f8578Andreas Huber body.append("PAUSE"); 6535131d127a042ee88f903370be88845dc8c9f8578Andreas Huber break; 6545131d127a042ee88f903370be88845dc8c9f8578Andreas Huber case TRIGGER_PLAY: 6555131d127a042ee88f903370be88845dc8c9f8578Andreas Huber body.append("PLAY"); 6565131d127a042ee88f903370be88845dc8c9f8578Andreas Huber break; 6575131d127a042ee88f903370be88845dc8c9f8578Andreas Huber default: 6585131d127a042ee88f903370be88845dc8c9f8578Andreas Huber TRESPASS(); 659ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber } 660ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 661ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber body.append("\r\n"); 662d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 663d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString request = "SET_PARAMETER rtsp://localhost/wfd1.0 RTSP/1.0\r\n"; 664d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&request, mNextCSeq); 665d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 666d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("Content-Type: text/parameters\r\n"); 667d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(StringPrintf("Content-Length: %d\r\n", body.size())); 668d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("\r\n"); 669d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(body); 670d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 671d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = 672d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mNetSession->sendRequest(sessionID, request.c_str(), request.size()); 673d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 674d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 675d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 676d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 677d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 678d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber registerResponseHandler( 679d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, mNextCSeq, &WifiDisplaySource::onReceiveM5Response); 680d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 681d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ++mNextCSeq; 682d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 683d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 684d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 685d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 686b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huberstatus_t WifiDisplaySource::sendM16(int32_t sessionID) { 687b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber AString request = "GET_PARAMETER rtsp://localhost/wfd1.0 RTSP/1.0\r\n"; 688b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber AppendCommonResponse(&request, mNextCSeq); 689b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 690c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_EQ(sessionID, mClientSessionID); 691c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber request.append( 692c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber StringPrintf("Session: %d\r\n", mClientInfo.mPlaybackSessionID)); 693a438123bd96c7faf145683876702387efe5628d9Andreas Huber request.append("\r\n"); // Empty body 694b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 695b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber status_t err = 696b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber mNetSession->sendRequest(sessionID, request.c_str(), request.size()); 697b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 698b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber if (err != OK) { 699b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber return err; 700b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber } 701b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 702b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber registerResponseHandler( 703b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber sessionID, mNextCSeq, &WifiDisplaySource::onReceiveM16Response); 704b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 705b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber ++mNextCSeq; 706b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 707b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber return OK; 708b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber} 709b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 710d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::onReceiveM1Response( 711d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, const sp<ParsedMessage> &msg) { 712d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t statusCode; 713d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!msg->getStatusCode(&statusCode)) { 714d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_MALFORMED; 715d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 716d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 717d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (statusCode != 200) { 718d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_UNSUPPORTED; 719d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 720d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 721d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 722d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 723d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 724d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber// sink_audio_list := ("LPCM"|"AAC"|"AC3" HEXDIGIT*8 HEXDIGIT*2) 725d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber// (", " sink_audio_list)* 726d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huberstatic void GetAudioModes(const char *s, const char *prefix, uint32_t *modes) { 727d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber *modes = 0; 728d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 729d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber size_t prefixLen = strlen(prefix); 730d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 731d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber while (*s != '0') { 732d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber if (!strncmp(s, prefix, prefixLen) && s[prefixLen] == ' ') { 733d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber unsigned latency; 734d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber if (sscanf(&s[prefixLen + 1], "%08x %02x", modes, &latency) != 2) { 735d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber *modes = 0; 736d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 737d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 738d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber return; 739d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 740d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 741d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber char *commaPos = strchr(s, ','); 742d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber if (commaPos != NULL) { 743d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber s = commaPos + 1; 744d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 745d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber while (isspace(*s)) { 746d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber ++s; 747d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 748d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } else { 749d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber break; 750d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 751d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 752d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber} 753d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 754d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::onReceiveM3Response( 755d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, const sp<ParsedMessage> &msg) { 756d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t statusCode; 757d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!msg->getStatusCode(&statusCode)) { 758d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_MALFORMED; 759d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 760d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 761d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (statusCode != 200) { 762d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_UNSUPPORTED; 763d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 764d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 765b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<Parameters> params = 766b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber Parameters::Parse(msg->getContent(), strlen(msg->getContent())); 767b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 768b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (params == NULL) { 769b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 770b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 771b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 772b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber AString value; 773d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber if (!params->findParameter("wfd_client_rtp_ports", &value)) { 774d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber ALOGE("Sink doesn't report its choice of wfd_client_rtp_ports."); 775d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber return ERROR_MALFORMED; 776d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 777d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 778d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber unsigned port0, port1; 779d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber if (sscanf(value.c_str(), 780d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber "RTP/AVP/UDP;unicast %u %u mode=play", 781d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber &port0, 782d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber &port1) != 2 783d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber || port0 == 0 || port0 > 65535 || port1 != 0) { 784d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber ALOGE("Sink chose its wfd_client_rtp_ports poorly (%s)", 785d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber value.c_str()); 786d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 787d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber return ERROR_MALFORMED; 788d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 789d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 790d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber mChosenRTPPort = port0; 791d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 792d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber if (!params->findParameter("wfd_audio_codecs", &value)) { 793d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber ALOGE("Sink doesn't report its choice of wfd_audio_codecs."); 794d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber return ERROR_MALFORMED; 795d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 796d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 797d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber if (value == "none") { 798d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber ALOGE("Sink doesn't support audio at all."); 799d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber return ERROR_UNSUPPORTED; 800d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 801d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 802d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber uint32_t modes; 803d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber GetAudioModes(value.c_str(), "AAC", &modes); 804d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 805d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber bool supportsAAC = (modes & 1) != 0; // AAC 2ch 48kHz 806d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 807d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber GetAudioModes(value.c_str(), "LPCM", &modes); 808d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 809d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber bool supportsPCM = (modes & 2) != 0; // LPCM 2ch 48kHz 810d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 811d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber char val[PROPERTY_VALUE_MAX]; 812d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber if (supportsPCM 813d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber && property_get("media.wfd.use-pcm-audio", val, NULL) 814d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber && (!strcasecmp("true", val) || !strcmp("1", val))) { 815d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber ALOGI("Using PCM audio."); 816d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber mUsingPCMAudio = true; 817d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } else if (supportsAAC) { 818d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber ALOGI("Using AAC audio."); 819d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber mUsingPCMAudio = false; 820d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } else if (supportsPCM) { 821d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber ALOGI("Using PCM audio."); 822d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber mUsingPCMAudio = true; 823d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } else { 824d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber ALOGI("Sink doesn't support an audio format we do."); 825d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber return ERROR_UNSUPPORTED; 826d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 827d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 8280328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mUsingHDCP = false; 829b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (!params->findParameter("wfd_content_protection", &value)) { 8300328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber ALOGI("Sink doesn't appear to support content protection."); 8310328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber } else if (value == "none") { 8320328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber ALOGI("Sink does not support content protection."); 8330328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber } else { 8340328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mUsingHDCP = true; 835b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 8360328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber bool isHDCP2_0 = false; 8370328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber if (value.startsWith("HDCP2.0 ")) { 8380328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber isHDCP2_0 = true; 8390328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber } else if (!value.startsWith("HDCP2.1 ")) { 8400328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber ALOGE("malformed wfd_content_protection: '%s'", value.c_str()); 841b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 8420328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber return ERROR_MALFORMED; 8430328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber } 844b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 8450328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber int32_t hdcpPort; 8460328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber if (!ParsedMessage::GetInt32Attribute( 8470328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber value.c_str() + 8, "port", &hdcpPort) 8480328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber || hdcpPort < 1 || hdcpPort > 65535) { 8490328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber return ERROR_MALFORMED; 8500328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber } 851b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 8520328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mIsHDCP2_0 = isHDCP2_0; 8530328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mHDCPPort = hdcpPort; 854b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 8550328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber status_t err = makeHDCP(); 8560328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber if (err != OK) { 8570224bf170a3904576bba81593eaab113c5d3a4e7Andreas Huber ALOGE("Unable to instantiate HDCP component. " 8580224bf170a3904576bba81593eaab113c5d3a4e7Andreas Huber "Not using HDCP after all."); 8590224bf170a3904576bba81593eaab113c5d3a4e7Andreas Huber 8600224bf170a3904576bba81593eaab113c5d3a4e7Andreas Huber mUsingHDCP = false; 8610328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber } 862b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 863b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 864d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return sendM4(sessionID); 865d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 866d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 867d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::onReceiveM4Response( 868d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, const sp<ParsedMessage> &msg) { 869d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t statusCode; 870d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!msg->getStatusCode(&statusCode)) { 871d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_MALFORMED; 872d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 873d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 874d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (statusCode != 200) { 875d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_UNSUPPORTED; 876d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 877d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 8780328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber if (mUsingHDCP && !mHDCPInitializationComplete) { 879b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber ALOGI("Deferring SETUP trigger until HDCP initialization completes."); 880b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 881b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mSetupTriggerDeferred = true; 882b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 883b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 884b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 8855131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return sendTrigger(sessionID, TRIGGER_SETUP); 886d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 887d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 888d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::onReceiveM5Response( 889d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, const sp<ParsedMessage> &msg) { 890d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t statusCode; 891d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!msg->getStatusCode(&statusCode)) { 892d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_MALFORMED; 893d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 894d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 895d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (statusCode != 200) { 896d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_UNSUPPORTED; 897d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 898d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 899d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 900d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 901d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 902b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huberstatus_t WifiDisplaySource::onReceiveM16Response( 903b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber int32_t sessionID, const sp<ParsedMessage> &msg) { 904b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // If only the response was required to include a "Session:" header... 905b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 906c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_EQ(sessionID, mClientSessionID); 907b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 908c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientInfo.mPlaybackSession != NULL) { 909c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mPlaybackSession->updateLiveness(); 910b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 911b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber scheduleKeepAlive(sessionID); 912b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber } 913b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 914b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber return OK; 915b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber} 916b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 917d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubervoid WifiDisplaySource::scheduleReaper() { 918d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (mReaperPending) { 919d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return; 920d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 921d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 922d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mReaperPending = true; 923d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber (new AMessage(kWhatReapDeadClients, id()))->post(kReaperIntervalUs); 924d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 925d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 926b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Hubervoid WifiDisplaySource::scheduleKeepAlive(int32_t sessionID) { 927b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // We need to send updates at least 5 secs before the timeout is set to 928b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // expire, make sure the timeout is greater than 5 secs to begin with. 929b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber CHECK_GT(kPlaybackSessionTimeoutUs, 5000000ll); 930b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 931b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber sp<AMessage> msg = new AMessage(kWhatKeepAlive, id()); 932b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber msg->setInt32("sessionID", sessionID); 933b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber msg->post(kPlaybackSessionTimeoutUs - 5000000ll); 934b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber} 935b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 936b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onReceiveClientData(const sp<AMessage> &msg) { 937d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID; 938d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("sessionID", &sessionID)); 939d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 940d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<RefBase> obj; 941d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findObject("data", &obj)); 942d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 943d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<ParsedMessage> data = 944d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber static_cast<ParsedMessage *>(obj.get()); 945d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 946d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ALOGV("session %d received '%s'", 947d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, data->debugString().c_str()); 948d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 949d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString method; 950d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString uri; 951d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber data->getRequestField(0, &method); 952d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 953d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq; 954d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!data->findInt32("cseq", &cseq)) { 955d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "400 Bad Request", -1 /* cseq */); 956b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 957d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 958d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 959d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (method.startsWith("RTSP/")) { 960d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // This is a response. 961d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 962d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ResponseID id; 963d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber id.mSessionID = sessionID; 964d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber id.mCSeq = cseq; 965d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 966d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ssize_t index = mResponseHandlers.indexOfKey(id); 967d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 968d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (index < 0) { 969d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ALOGW("Received unsolicited server response, cseq %d", cseq); 970b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 971d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 972d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 973d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber HandleRTSPResponseFunc func = mResponseHandlers.valueAt(index); 974d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mResponseHandlers.removeItemsAt(index); 975d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 976d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = (this->*func)(sessionID, data); 977d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 978d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 979d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ALOGW("Response handler for session %d, cseq %d returned " 980d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "err %d (%s)", 981d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, cseq, err, strerror(-err)); 982d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 983b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 984d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 985d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 986b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 987b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 988d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 989b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber AString version; 990b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber data->getRequestField(2, &version); 991b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (!(version == AString("RTSP/1.0"))) { 992b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sendErrorResponse(sessionID, "505 RTSP Version not supported", cseq); 993b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_UNSUPPORTED; 994b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 995d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 996b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber status_t err; 997b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (method == "OPTIONS") { 998b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onOptionsRequest(sessionID, cseq, data); 999b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "SETUP") { 1000b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onSetupRequest(sessionID, cseq, data); 1001b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "PLAY") { 1002b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onPlayRequest(sessionID, cseq, data); 1003b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "PAUSE") { 1004b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onPauseRequest(sessionID, cseq, data); 1005b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "TEARDOWN") { 1006b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onTeardownRequest(sessionID, cseq, data); 1007b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "GET_PARAMETER") { 1008b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onGetParameterRequest(sessionID, cseq, data); 1009b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "SET_PARAMETER") { 1010b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onSetParameterRequest(sessionID, cseq, data); 1011b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else { 1012b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sendErrorResponse(sessionID, "405 Method Not Allowed", cseq); 1013d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1014b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = ERROR_UNSUPPORTED; 1015b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1016d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1017b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1018d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1019d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1020b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onOptionsRequest( 1021d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1022d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1023d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1024d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1025d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1026d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1027d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1028d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession != NULL) { 1029d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber playbackSession->updateLiveness(); 1030d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1031d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1032d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1033d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq); 1034d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1035d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append( 1036b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber "Public: org.wfa.wfd1.0, SETUP, TEARDOWN, PLAY, PAUSE, " 1037d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "GET_PARAMETER, SET_PARAMETER\r\n"); 1038d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1039d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1040d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1041d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = mNetSession->sendRequest(sessionID, response.c_str()); 1042d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1043b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err == OK) { 1044b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = sendM3(sessionID); 1045b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1046b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1047b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1048d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1049d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1050b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onSetupRequest( 1051d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1052d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1053d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1054c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_EQ(sessionID, mClientSessionID); 1055c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientInfo.mPlaybackSessionID != -1) { 1056b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // We only support a single playback session per client. 1057b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // This is due to the reversed keep-alive design in the wfd specs... 1058b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber sendErrorResponse(sessionID, "400 Bad Request", cseq); 1059b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1060b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber } 1061b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 1062d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString transport; 1063d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!data->findString("transport", &transport)) { 1064d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "400 Bad Request", cseq); 1065b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1066d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1067d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 106890a92053219ae50ddf4bb54e3d54db2d309e2b8dAndreas Huber Sender::TransportMode transportMode = Sender::TRANSPORT_UDP; 1069d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1070d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int clientRtp, clientRtcp; 1071d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (transport.startsWith("RTP/AVP/TCP;")) { 1072d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString interleaved; 1073bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber if (ParsedMessage::GetAttribute( 1074d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber transport.c_str(), "interleaved", &interleaved) 1075bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber && sscanf(interleaved.c_str(), "%d-%d", 1076bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber &clientRtp, &clientRtcp) == 2) { 107790a92053219ae50ddf4bb54e3d54db2d309e2b8dAndreas Huber transportMode = Sender::TRANSPORT_TCP_INTERLEAVED; 1078bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } else { 1079bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber bool badRequest = false; 1080bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber 1081bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber AString clientPort; 1082bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber if (!ParsedMessage::GetAttribute( 1083bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber transport.c_str(), "client_port", &clientPort)) { 1084bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber badRequest = true; 1085bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } else if (sscanf(clientPort.c_str(), "%d-%d", 1086bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber &clientRtp, &clientRtcp) == 2) { 1087bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } else if (sscanf(clientPort.c_str(), "%d", &clientRtp) == 1) { 1088bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber // No RTCP. 1089bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber clientRtcp = -1; 1090bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } else { 1091bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber badRequest = true; 1092bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } 1093bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber 1094bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber if (badRequest) { 1095bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber sendErrorResponse(sessionID, "400 Bad Request", cseq); 1096b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1097bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } 1098d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 109990a92053219ae50ddf4bb54e3d54db2d309e2b8dAndreas Huber transportMode = Sender::TRANSPORT_TCP; 1100bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } 1101d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else if (transport.startsWith("RTP/AVP;unicast;") 1102d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber || transport.startsWith("RTP/AVP/UDP;unicast;")) { 1103d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber bool badRequest = false; 1104d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1105d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString clientPort; 1106d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!ParsedMessage::GetAttribute( 1107d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber transport.c_str(), "client_port", &clientPort)) { 1108d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber badRequest = true; 1109d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else if (sscanf(clientPort.c_str(), "%d-%d", 1110d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber &clientRtp, &clientRtcp) == 2) { 1111d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else if (sscanf(clientPort.c_str(), "%d", &clientRtp) == 1) { 1112d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // No RTCP. 1113d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtcp = -1; 1114d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else { 1115d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber badRequest = true; 1116d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1117d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1118d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (badRequest) { 1119d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "400 Bad Request", cseq); 1120b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1121d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1122d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#if 1 1123a438123bd96c7faf145683876702387efe5628d9Andreas Huber // The older LG dongles doesn't specify client_port=xxx apparently. 1124d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else if (transport == "RTP/AVP/UDP;unicast") { 1125d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtp = 19000; 112628e17ed7e2fbb254fb99481b74db85e427c905eeAndreas Huber clientRtcp = -1; 1127d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#endif 1128d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else { 1129d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "461 Unsupported Transport", cseq); 1130b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_UNSUPPORTED; 1131d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1132d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1133d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID = makeUniquePlaybackSessionID(); 1134d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1135d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<AMessage> notify = new AMessage(kWhatPlaybackSessionNotify, id()); 1136d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber notify->setInt32("playbackSessionID", playbackSessionID); 1137d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber notify->setInt32("sessionID", sessionID); 1138d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1139d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 11400b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber new PlaybackSession( 11410328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mNetSession, notify, mInterfaceAddr, mHDCP); 1142d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1143d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber looper()->registerHandler(playbackSession); 1144d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1145d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString uri; 1146d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber data->getRequestField(1, &uri); 1147d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1148d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (strncasecmp("rtsp://", uri.c_str(), 7)) { 1149d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "400 Bad Request", cseq); 1150b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1151d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1152d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1153d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!(uri.startsWith("rtsp://") && uri.endsWith("/wfd1.0/streamid=0"))) { 1154d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "404 Not found", cseq); 1155b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1156d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1157d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1158d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = playbackSession->init( 1159c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mRemoteIP.c_str(), 1160d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtp, 1161d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtcp, 1162e7bd24af08ef0722fb124a550662bcec48c56f86Andreas Huber transportMode, 1163e7bd24af08ef0722fb124a550662bcec48c56f86Andreas Huber mUsingPCMAudio); 1164d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1165d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 1166d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber looper()->unregisterHandler(playbackSession->id()); 1167d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber playbackSession.clear(); 1168d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1169d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1170d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber switch (err) { 1171d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case OK: 1172d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 1173d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case -ENOENT: 1174d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "404 Not Found", cseq); 1175b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1176d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber default: 1177d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "403 Forbidden", cseq); 1178b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1179d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1180d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1181c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mPlaybackSessionID = playbackSessionID; 1182c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mPlaybackSession = playbackSession; 1183b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 1184d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1185d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1186d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 118790a92053219ae50ddf4bb54e3d54db2d309e2b8dAndreas Huber if (transportMode == Sender::TRANSPORT_TCP_INTERLEAVED) { 1188d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append( 1189d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber StringPrintf( 1190d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "Transport: RTP/AVP/TCP;interleaved=%d-%d;", 1191d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtp, clientRtcp)); 1192d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else { 1193d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t serverRtp = playbackSession->getRTPPort(); 1194d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1195bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber AString transportString = "UDP"; 119690a92053219ae50ddf4bb54e3d54db2d309e2b8dAndreas Huber if (transportMode == Sender::TRANSPORT_TCP) { 1197bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber transportString = "TCP"; 1198bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } 1199bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber 1200d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (clientRtcp >= 0) { 1201d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append( 1202d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber StringPrintf( 1203bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber "Transport: RTP/AVP/%s;unicast;client_port=%d-%d;" 1204d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "server_port=%d-%d\r\n", 1205bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber transportString.c_str(), 1206d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtp, clientRtcp, serverRtp, serverRtp + 1)); 1207d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else { 1208d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append( 1209d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber StringPrintf( 1210bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber "Transport: RTP/AVP/%s;unicast;client_port=%d;" 1211d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "server_port=%d\r\n", 1212bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber transportString.c_str(), 1213d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtp, serverRtp)); 1214d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1215d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1216d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1217d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1218d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1219d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber err = mNetSession->sendRequest(sessionID, response.c_str()); 1220b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1221b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err != OK) { 1222b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1223b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1224d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1225ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = AWAITING_CLIENT_PLAY; 1226ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 1227d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber scheduleReaper(); 1228b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber scheduleKeepAlive(sessionID); 1229b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1230b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 1231d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1232d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1233b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onPlayRequest( 1234d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1235d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1236d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1237d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1238d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1239d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1240d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1241d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession == NULL) { 1242d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "454 Session Not Found", cseq); 1243b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1244d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1245d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1246ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGI("Received PLAY request."); 1247ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 1248d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = playbackSession->play(); 1249d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK_EQ(err, (status_t)OK); 1250d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1251d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1252d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1253d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("Range: npt=now-\r\n"); 1254d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1255d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1256d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber err = mNetSession->sendRequest(sessionID, response.c_str()); 1257b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1258b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err != OK) { 1259b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1260b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 12610b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber 12625131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (mState == PAUSED_TO_PLAYING) { 12635131d127a042ee88f903370be88845dc8c9f8578Andreas Huber mState = PLAYING; 12645131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return OK; 12655131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 12665131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 1267bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber playbackSession->finishPlay(); 1268b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1269ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber CHECK_EQ(mState, AWAITING_CLIENT_PLAY); 1270ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = ABOUT_TO_PLAY; 1271ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 1272b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 1273d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1274d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1275b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onPauseRequest( 1276d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1277d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1278d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1279d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1280d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1281d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1282d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1283d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession == NULL) { 1284d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "454 Session Not Found", cseq); 1285b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1286d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1287d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 12885131d127a042ee88f903370be88845dc8c9f8578Andreas Huber ALOGI("Received PAUSE request."); 12895131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 12905131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (mState != PLAYING_TO_PAUSED) { 12915131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return INVALID_OPERATION; 12925131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 12935131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 1294d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = playbackSession->pause(); 1295d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK_EQ(err, (status_t)OK); 1296d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1297d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1298d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1299d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1300d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1301d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber err = mNetSession->sendRequest(sessionID, response.c_str()); 1302b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 13035131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (err != OK) { 13045131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return err; 13055131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 13065131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 13075131d127a042ee88f903370be88845dc8c9f8578Andreas Huber mState = PAUSED; 13085131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 1309b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1310d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1311d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1312b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onTeardownRequest( 1313d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1314d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1315d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1316ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGI("Received TEARDOWN request."); 1317ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 1318d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1319d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1320d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1321d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1322d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession == NULL) { 1323d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "454 Session Not Found", cseq); 1324b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1325d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1326d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1327d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1328d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1329c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber response.append("Connection: close\r\n"); 1330d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1331d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1332ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mNetSession->sendRequest(sessionID, response.c_str()); 1333c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 1334ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber if (mState == AWAITING_CLIENT_TEARDOWN) { 1335ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber CHECK_NE(mStopReplyID, 0); 1336eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber finishStop(); 1337ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber } else { 1338ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError(IRemoteDisplayClient::kDisplayErrorUnknown); 1339ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber } 1340b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1341b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 1342d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1343d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1344eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Hubervoid WifiDisplaySource::finishStop() { 1345ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGV("finishStop"); 1346ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 1347ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = STOPPING; 1348ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 134996fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber disconnectClientAsync(); 135096fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber} 135196fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber 135296fc6cc65ca93009a759a3a874b82a35771b9714Andreas Hubervoid WifiDisplaySource::finishStopAfterDisconnectingClient() { 135396fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber ALOGV("finishStopAfterDisconnectingClient"); 135496fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber 1355ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber if (mHDCP != NULL) { 1356ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGI("Initiating HDCP shutdown."); 1357ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber mHDCP->shutdownAsync(); 1358eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber return; 1359ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber } 1360ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 1361eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber finishStop2(); 1362eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber} 1363eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber 1364eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Hubervoid WifiDisplaySource::finishStop2() { 1365ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGV("finishStop2"); 1366ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 1367bbe96f0f05a1f1a1b3cfec0d124cb0d63c1ebf2aAndreas Huber if (mHDCP != NULL) { 1368bbe96f0f05a1f1a1b3cfec0d124cb0d63c1ebf2aAndreas Huber mHDCP->setObserver(NULL); 1369bbe96f0f05a1f1a1b3cfec0d124cb0d63c1ebf2aAndreas Huber mHDCPObserver.clear(); 1370bbe96f0f05a1f1a1b3cfec0d124cb0d63c1ebf2aAndreas Huber mHDCP.clear(); 1371bbe96f0f05a1f1a1b3cfec0d124cb0d63c1ebf2aAndreas Huber } 1372eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber 1373ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber if (mSessionID != 0) { 1374ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mNetSession->destroySession(mSessionID); 1375ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mSessionID = 0; 1376ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber } 1377ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 137896fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber ALOGI("We're stopped."); 1379ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = STOPPED; 1380ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 1381ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber status_t err = OK; 1382ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 1383ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber sp<AMessage> response = new AMessage; 1384ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber response->setInt32("err", err); 1385eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber response->postReply(mStopReplyID); 1386ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber} 1387ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 1388b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onGetParameterRequest( 1389d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1390d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1391d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1392d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1393d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1394d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1395d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1396d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession == NULL) { 1397d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "454 Session Not Found", cseq); 1398b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1399d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1400d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1401d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber playbackSession->updateLiveness(); 1402d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1403d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1404d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1405d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1406d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1407d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = mNetSession->sendRequest(sessionID, response.c_str()); 1408b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1409d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1410d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1411b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onSetParameterRequest( 1412d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1413d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1414d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1415d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1416d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1417d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1418d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1419d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession == NULL) { 1420d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "454 Session Not Found", cseq); 1421b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1422d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1423d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1424b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (strstr(data->getContent(), "wfd_idr_request\r\n")) { 1425b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber playbackSession->requestIDRFrame(); 1426b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1427496238cc7551d414067dcbbb4fe3bd801f205f95Andreas Huber 1428d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber playbackSession->updateLiveness(); 1429d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1430d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1431d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1432d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1433d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1434d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = mNetSession->sendRequest(sessionID, response.c_str()); 1435b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1436d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1437d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1438d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber// static 1439d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubervoid WifiDisplaySource::AppendCommonResponse( 1440d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString *response, int32_t cseq, int32_t playbackSessionID) { 1441d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber time_t now = time(NULL); 1442d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber struct tm *now2 = gmtime(&now); 1443d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber char buf[128]; 1444d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber strftime(buf, sizeof(buf), "%a, %d %b %Y %H:%M:%S %z", now2); 1445d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1446d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append("Date: "); 1447d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append(buf); 1448d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append("\r\n"); 1449d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1450d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append("Server: Mine/1.0\r\n"); 1451d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1452d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (cseq >= 0) { 1453d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append(StringPrintf("CSeq: %d\r\n", cseq)); 1454d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1455d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1456d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSessionID >= 0ll) { 1457d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append( 1458d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber StringPrintf( 1459d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "Session: %d;timeout=%lld\r\n", 1460d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber playbackSessionID, kPlaybackSessionTimeoutSecs)); 1461d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1462d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1463d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1464d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubervoid WifiDisplaySource::sendErrorResponse( 1465d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1466d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const char *errorDetail, 1467d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq) { 1468d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response; 1469d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("RTSP/1.0 "); 1470d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append(errorDetail); 1471d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1472d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1473d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq); 1474d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1475d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1476d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1477eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber mNetSession->sendRequest(sessionID, response.c_str()); 1478d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1479d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1480d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberint32_t WifiDisplaySource::makeUniquePlaybackSessionID() const { 1481c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber return rand(); 1482d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1483d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1484d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubersp<WifiDisplaySource::PlaybackSession> WifiDisplaySource::findPlaybackSession( 1485d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data, int32_t *playbackSessionID) const { 1486d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!data->findInt32("session", playbackSessionID)) { 1487c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber // XXX the older dongles do not always include a "Session:" header. 1488c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber *playbackSessionID = mClientInfo.mPlaybackSessionID; 1489c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber return mClientInfo.mPlaybackSession; 1490d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1491d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1492c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (*playbackSessionID != mClientInfo.mPlaybackSessionID) { 1493d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return NULL; 1494d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1495d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1496c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber return mClientInfo.mPlaybackSession; 1497c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber} 1498c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 149996fc6cc65ca93009a759a3a874b82a35771b9714Andreas Hubervoid WifiDisplaySource::disconnectClientAsync() { 150096fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber ALOGV("disconnectClient"); 150196fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber 150296fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber if (mClientInfo.mPlaybackSession == NULL) { 150396fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber disconnectClient2(); 150496fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber return; 150596fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber } 150696fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber 150796fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber if (mClientInfo.mPlaybackSession != NULL) { 150896fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber ALOGV("Destroying PlaybackSession"); 150996fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber mClientInfo.mPlaybackSession->destroyAsync(); 151096fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber } 151196fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber} 151296fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber 151396fc6cc65ca93009a759a3a874b82a35771b9714Andreas Hubervoid WifiDisplaySource::disconnectClient2() { 151496fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber ALOGV("disconnectClient2"); 151596fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber 1516ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber if (mClientInfo.mPlaybackSession != NULL) { 151796fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber looper()->unregisterHandler(mClientInfo.mPlaybackSession->id()); 1518ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClientInfo.mPlaybackSession.clear(); 1519ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber } 1520c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 1521ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber if (mClientSessionID != 0) { 1522c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mNetSession->destroySession(mClientSessionID); 1523c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientSessionID = 0; 1524c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } 1525c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 1526ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayDisconnected(); 152796fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber 152896fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber finishStopAfterDisconnectingClient(); 1529d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1530d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1531b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstruct WifiDisplaySource::HDCPObserver : public BnHDCPObserver { 1532b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber HDCPObserver(const sp<AMessage> ¬ify); 1533b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1534b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber virtual void notify( 1535b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber int msg, int ext1, int ext2, const Parcel *obj); 1536b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1537b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberprivate: 1538b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<AMessage> mNotify; 1539b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1540b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber DISALLOW_EVIL_CONSTRUCTORS(HDCPObserver); 1541b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber}; 1542b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1543b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas HuberWifiDisplaySource::HDCPObserver::HDCPObserver( 1544b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber const sp<AMessage> ¬ify) 1545b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber : mNotify(notify) { 1546b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber} 1547b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1548b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Hubervoid WifiDisplaySource::HDCPObserver::notify( 1549b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber int msg, int ext1, int ext2, const Parcel *obj) { 1550b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<AMessage> notify = mNotify->dup(); 1551b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber notify->setInt32("msg", msg); 1552b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber notify->setInt32("ext1", ext1); 1553b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber notify->setInt32("ext2", ext2); 1554b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber notify->post(); 1555b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber} 1556b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1557b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::makeHDCP() { 1558b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<IServiceManager> sm = defaultServiceManager(); 1559b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<IBinder> binder = sm->getService(String16("media.player")); 1560b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<IMediaPlayerService> service = interface_cast<IMediaPlayerService>(binder); 1561b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber CHECK(service != NULL); 1562b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1563b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mHDCP = service->makeHDCP(); 1564b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1565b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (mHDCP == NULL) { 1566b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_UNSUPPORTED; 1567b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1568b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1569b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<AMessage> notify = new AMessage(kWhatHDCPNotify, id()); 1570b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mHDCPObserver = new HDCPObserver(notify); 1571b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1572b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber status_t err = mHDCP->setObserver(mHDCPObserver); 1573b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1574b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err != OK) { 1575b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber ALOGE("Failed to set HDCP observer."); 1576b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1577b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mHDCPObserver.clear(); 1578b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mHDCP.clear(); 1579b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1580b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1581b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1582b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1583ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGI("Initiating HDCP negotiation w/ host %s:%d", 1584b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mClientInfo.mRemoteIP.c_str(), mHDCPPort); 1585b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1586b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = mHDCP->initAsync(mClientInfo.mRemoteIP.c_str(), mHDCPPort); 1587b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1588b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err != OK) { 1589b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1590b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1591b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1592b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 1593b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber} 1594b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1595d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} // namespace android 1596d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1597