WifiDisplaySource.cpp revision ef7d3793fa9bbfb25253626ede9a020ee9280a17
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" 25d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 26b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#include <binder/IServiceManager.h> 270b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber#include <gui/ISurfaceTexture.h> 28b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#include <media/IHDCP.h> 29b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#include <media/IMediaPlayerService.h> 300b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber#include <media/IRemoteDisplayClient.h> 31d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#include <media/stagefright/foundation/ABuffer.h> 32d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#include <media/stagefright/foundation/ADebug.h> 33d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#include <media/stagefright/foundation/AMessage.h> 34d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#include <media/stagefright/MediaErrors.h> 35d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 36bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber#include <arpa/inet.h> 37bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber#include <cutils/properties.h> 38bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 39d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubernamespace android { 40d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 410b73d4730202fcad53aefc4314a06e7b95f442f0Andreas HuberWifiDisplaySource::WifiDisplaySource( 420b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber const sp<ANetworkSession> &netSession, 430b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber const sp<IRemoteDisplayClient> &client) 44d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber : mNetSession(netSession), 450b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber mClient(client), 46d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mSessionID(0), 47ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber mStopReplyID(0), 48c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientSessionID(0), 49d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mReaperPending(false), 50b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mNextCSeq(1) 51b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#if REQUIRE_HDCP 52b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber ,mIsHDCP2_0(false) 53b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber ,mHDCPPort(0) 54b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber ,mHDCPInitializationComplete(false) 55b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber ,mSetupTriggerDeferred(false) 56b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#endif 57b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber{ 58d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 59d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 60d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas HuberWifiDisplaySource::~WifiDisplaySource() { 61d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 62d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 63bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huberstatus_t WifiDisplaySource::start(const char *iface) { 64d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<AMessage> msg = new AMessage(kWhatStart, id()); 65bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber msg->setString("iface", iface); 66d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 67d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<AMessage> response; 68d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = msg->postAndAwaitResponse(&response); 69d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 70d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 71d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 72d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 73d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 74d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!response->findInt32("err", &err)) { 75d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber err = OK; 76d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 77d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 78d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 79d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 80d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 81d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::stop() { 82d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<AMessage> msg = new AMessage(kWhatStop, id()); 83d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 84d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<AMessage> response; 85d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = msg->postAndAwaitResponse(&response); 86d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 87d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 88d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 89d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 90d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 91d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!response->findInt32("err", &err)) { 92d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber err = OK; 93d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 94d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 95d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 96d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 97d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 98d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubervoid WifiDisplaySource::onMessageReceived(const sp<AMessage> &msg) { 99d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber switch (msg->what()) { 100d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case kWhatStart: 101d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 102d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber uint32_t replyID; 103d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->senderAwaitsResponse(&replyID)); 104d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 105bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber AString iface; 106bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber CHECK(msg->findString("iface", &iface)); 107bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 108bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber status_t err = OK; 109bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 110bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber ssize_t colonPos = iface.find(":"); 111bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 112bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber unsigned long port; 113bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 114bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber if (colonPos >= 0) { 115bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber const char *s = iface.c_str() + colonPos + 1; 116bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 117bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber char *end; 118bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber port = strtoul(s, &end, 10); 119bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 120bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber if (end == s || *end != '\0' || port > 65535) { 121bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber err = -EINVAL; 122bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } else { 123bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber iface.erase(colonPos, iface.size() - colonPos); 124bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } 125bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } else { 126bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber port = kWifiDisplayDefaultPort; 127bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } 128bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 129bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber if (err == OK) { 130bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber if (inet_aton(iface.c_str(), &mInterfaceAddr) != 0) { 131bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber sp<AMessage> notify = new AMessage(kWhatRTSPNotify, id()); 132d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 133bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber err = mNetSession->createRTSPServer( 134bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber mInterfaceAddr, port, notify, &mSessionID); 135bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } else { 136bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber err = -EINVAL; 137bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } 138bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } 139d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 140d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<AMessage> response = new AMessage; 141d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->setInt32("err", err); 142d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->postReply(replyID); 143d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 144d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 145d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 146d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case kWhatRTSPNotify: 147d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 148d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t reason; 149d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("reason", &reason)); 150d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 151d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber switch (reason) { 152d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case ANetworkSession::kWhatError: 153d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 154d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID; 155d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("sessionID", &sessionID)); 156d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 157d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t err; 158d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("err", &err)); 159d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 160d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString detail; 161d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findString("detail", &detail)); 162d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 163d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ALOGE("An error occurred in session %d (%d, '%s/%s').", 164d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, 165d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber err, 166d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber detail.c_str(), 167d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber strerror(-err)); 168d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 169d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mNetSession->destroySession(sessionID); 170d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 171c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (sessionID == mClientSessionID) { 172ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClientSessionID = 0; 173c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 174ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError( 175ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber IRemoteDisplayClient::kDisplayErrorUnknown); 176c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } 177d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 178d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 179d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 180d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case ANetworkSession::kWhatClientConnected: 181d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 182d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID; 183d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("sessionID", &sessionID)); 184d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 185c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientSessionID > 0) { 186c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber ALOGW("A client tried to connect, but we already " 187c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber "have one."); 188d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 189c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mNetSession->destroySession(sessionID); 190c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber break; 191c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } 192c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 193c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findString("client-ip", &mClientInfo.mRemoteIP)); 194c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findString("server-ip", &mClientInfo.mLocalIP)); 195c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 196c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientInfo.mRemoteIP == mClientInfo.mLocalIP) { 197c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber // Disallow connections from the local interface 198c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber // for security reasons. 199c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mNetSession->destroySession(sessionID); 200c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber break; 201c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } 202d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 203c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findInt32( 204c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber "server-port", &mClientInfo.mLocalPort)); 205c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mPlaybackSessionID = -1; 206c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 207c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientSessionID = sessionID; 208c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 209c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber ALOGI("We now have a client (%d) connected.", sessionID); 210d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 211d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = sendM1(sessionID); 212d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK_EQ(err, (status_t)OK); 213d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 214d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 215d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 216d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case ANetworkSession::kWhatData: 217d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 218b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber status_t err = onReceiveClientData(msg); 219b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 220b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err != OK) { 221ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError( 222ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber IRemoteDisplayClient::kDisplayErrorUnknown); 223b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 224d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 225d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 226d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 227d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber default: 228d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber TRESPASS(); 229d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 230d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 231d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 232d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 233d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case kWhatStop: 234d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 235eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber CHECK(msg->senderAwaitsResponse(&mStopReplyID)); 236d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 237ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber if (mClientSessionID != 0 238ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber && mClientInfo.mPlaybackSessionID != -1) { 239ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber status_t err = sendM5( 240ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber mClientSessionID, true /* requestShutdown */); 2410b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber 242ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber if (err == OK) { 243ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber break; 244ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber } 245b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 246d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 247eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber finishStop(); 248d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 249d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 250d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 251d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case kWhatReapDeadClients: 252d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 253d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mReaperPending = false; 254d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 255c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientSessionID == 0 256c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber || mClientInfo.mPlaybackSession == NULL) { 257c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber break; 258d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 259d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 260c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientInfo.mPlaybackSession->getLastLifesignUs() 261c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber + kPlaybackSessionTimeoutUs < ALooper::GetNowUs()) { 262c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber ALOGI("playback session timed out, reaping."); 263c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 264ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mNetSession->destroySession(mClientSessionID); 265ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClientSessionID = 0; 266ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 267ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError( 268ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber IRemoteDisplayClient::kDisplayErrorUnknown); 269c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } else { 270d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber scheduleReaper(); 271d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 272d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 273d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 274d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 275d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case kWhatPlaybackSessionNotify: 276d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 277d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 278d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("playbackSessionID", &playbackSessionID)); 279d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 280d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t what; 281d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("what", &what)); 282d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 283c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (what == PlaybackSession::kWhatSessionDead) { 284c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber ALOGI("playback session wants to quit."); 285c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 286ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError( 287ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber IRemoteDisplayClient::kDisplayErrorUnknown); 288c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } else if (what == PlaybackSession::kWhatSessionEstablished) { 289c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClient != NULL) { 290c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClient->onDisplayConnected( 291c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mPlaybackSession->getSurfaceTexture(), 292c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mPlaybackSession->width(), 293c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mPlaybackSession->height(), 294c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 0 /* flags */); 295c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } 296c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } else { 297c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_EQ(what, PlaybackSession::kWhatBinaryData); 298d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 299c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber int32_t channel; 300c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findInt32("channel", &channel)); 301d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 302c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber sp<ABuffer> data; 303c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findBuffer("data", &data)); 304d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 305c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_LE(channel, 0xffu); 306c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_LE(data->size(), 0xffffu); 307d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 308c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber int32_t sessionID; 309c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findInt32("sessionID", &sessionID)); 310d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 311c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber char header[4]; 312c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber header[0] = '$'; 313c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber header[1] = channel; 314c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber header[2] = data->size() >> 8; 315c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber header[3] = data->size() & 0xff; 316d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 317c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mNetSession->sendRequest( 318c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber sessionID, header, sizeof(header)); 319d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 320c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mNetSession->sendRequest( 321c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber sessionID, data->data(), data->size()); 322d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 323d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 324d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 325d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 326b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber case kWhatKeepAlive: 327b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber { 328b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber int32_t sessionID; 329b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber CHECK(msg->findInt32("sessionID", &sessionID)); 330b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 331c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientSessionID != sessionID) { 332b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // Obsolete event, client is already gone. 333b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber break; 334b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber } 335b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 336b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber sendM16(sessionID); 337b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber break; 338b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber } 339b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 340b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#if REQUIRE_HDCP 341b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber case kWhatHDCPNotify: 342b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber { 343b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber int32_t msgCode, ext1, ext2; 344b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber CHECK(msg->findInt32("msg", &msgCode)); 345b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber CHECK(msg->findInt32("ext1", &ext1)); 346b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber CHECK(msg->findInt32("ext2", &ext2)); 347b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 348eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber ALOGI("Saw HDCP notification code %d, ext1 %d, ext2 %d", 349b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber msgCode, ext1, ext2); 350b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 351b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber switch (msgCode) { 352b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber case HDCPModule::HDCP_INITIALIZATION_COMPLETE: 353b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber { 354b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mHDCPInitializationComplete = true; 355b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 356b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (mSetupTriggerDeferred) { 357b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mSetupTriggerDeferred = false; 358b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 359ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber sendM5(mClientSessionID, false /* requestShutdown */); 360b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 361b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber break; 362b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 363b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 364eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber case HDCPModule::HDCP_SHUTDOWN_COMPLETE: 365ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber case HDCPModule::HDCP_SHUTDOWN_FAILED: 366eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber { 367ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber // Ugly hack to make sure that the call to 368ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber // HDCPObserver::notify is completely handled before 369ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber // we clear the HDCP instance and unload the shared 370ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber // library :( 371ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber (new AMessage(kWhatFinishStop2, id()))->post(300000ll); 372eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber break; 373eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber } 374eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber 375b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber default: 376b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber { 377ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber ALOGE("HDCP failure, shutting down."); 378ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 379ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError( 380ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber IRemoteDisplayClient::kDisplayErrorUnknown); 381b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber break; 382b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 383b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 384b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber break; 385b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 386ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 387ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber case kWhatFinishStop2: 388ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber { 389ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber finishStop2(); 390ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber break; 391ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber } 392b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#endif 393b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 394d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber default: 395d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber TRESPASS(); 396d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 397d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 398d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 399d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubervoid WifiDisplaySource::registerResponseHandler( 400d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, int32_t cseq, HandleRTSPResponseFunc func) { 401d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ResponseID id; 402d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber id.mSessionID = sessionID; 403d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber id.mCSeq = cseq; 404d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mResponseHandlers.add(id, func); 405d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 406d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 407d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::sendM1(int32_t sessionID) { 408d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString request = "OPTIONS * RTSP/1.0\r\n"; 409d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&request, mNextCSeq); 410d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 411d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append( 412d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "Require: org.wfa.wfd1.0\r\n" 413d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "\r\n"); 414d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 415d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = 416d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mNetSession->sendRequest(sessionID, request.c_str(), request.size()); 417d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 418d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 419d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 420d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 421d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 422d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber registerResponseHandler( 423d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, mNextCSeq, &WifiDisplaySource::onReceiveM1Response); 424d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 425d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ++mNextCSeq; 426d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 427d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 428d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 429d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 430d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::sendM3(int32_t sessionID) { 431d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString body = 432b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#if REQUIRE_HDCP 433b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber "wfd_content_protection\r\n" 434b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#endif 435d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "wfd_video_formats\r\n" 436d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "wfd_audio_codecs\r\n" 437d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "wfd_client_rtp_ports\r\n"; 438d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 439d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString request = "GET_PARAMETER rtsp://localhost/wfd1.0 RTSP/1.0\r\n"; 440d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&request, mNextCSeq); 441d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 442d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("Content-Type: text/parameters\r\n"); 443d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(StringPrintf("Content-Length: %d\r\n", body.size())); 444d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("\r\n"); 445d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(body); 446d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 447d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = 448d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mNetSession->sendRequest(sessionID, request.c_str(), request.size()); 449d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 450d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 451d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 452d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 453d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 454d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber registerResponseHandler( 455d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, mNextCSeq, &WifiDisplaySource::onReceiveM3Response); 456d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 457d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ++mNextCSeq; 458d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 459d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 460d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 461d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 462d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::sendM4(int32_t sessionID) { 463d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // wfd_video_formats: 464d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // 1 byte "native" 465d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // 1 byte "preferred-display-mode-supported" 0 or 1 466d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // one or more avc codec structures 467d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // 1 byte profile 468d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // 1 byte level 469d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // 4 byte CEA mask 470d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // 4 byte VESA mask 471d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // 4 byte HH mask 472d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // 1 byte latency 473d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // 2 byte min-slice-slice 474d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // 2 byte slice-enc-params 475d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // 1 byte framerate-control-support 476d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // max-hres (none or 2 byte) 477d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // max-vres (none or 2 byte) 478d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 479c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_EQ(sessionID, mClientSessionID); 480d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 481bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber AString transportString = "UDP"; 482bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber 483bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber char val[PROPERTY_VALUE_MAX]; 484bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber if (property_get("media.wfd.enable-tcp", val, NULL) 485bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber && (!strcasecmp("true", val) || !strcmp("1", val))) { 486bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber ALOGI("Using TCP transport."); 487bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber transportString = "TCP"; 488bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } 489bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber 490b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber // For 720p60: 491b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber // use "30 00 02 02 00000040 00000000 00000000 00 0000 0000 00 none none\r\n" 492b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber // For 720p30: 493b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber // use "28 00 02 02 00000020 00000000 00000000 00 0000 0000 00 none none\r\n" 49472ff5903df5f409ea83f74c363a52f0745ced8b8Andreas Huber // For 720p24: 49572ff5903df5f409ea83f74c363a52f0745ced8b8Andreas Huber // use "78 00 02 02 00008000 00000000 00000000 00 0000 0000 00 none none\r\n" 496d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString body = StringPrintf( 497d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "wfd_video_formats: " 49872ff5903df5f409ea83f74c363a52f0745ced8b8Andreas Huber "78 00 02 02 00008000 00000000 00000000 00 0000 0000 00 none none\r\n" 499d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "wfd_audio_codecs: AAC 00000001 00\r\n" // 2 ch AAC 48kHz 500d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "wfd_presentation_URL: rtsp://%s:%d/wfd1.0/streamid=0 none\r\n" 501bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber "wfd_client_rtp_ports: RTP/AVP/%s;unicast 19000 0 mode=play\r\n", 502c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mLocalIP.c_str(), mClientInfo.mLocalPort, 503c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber transportString.c_str()); 504d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 505d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString request = "SET_PARAMETER rtsp://localhost/wfd1.0 RTSP/1.0\r\n"; 506d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&request, mNextCSeq); 507d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 508d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("Content-Type: text/parameters\r\n"); 509d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(StringPrintf("Content-Length: %d\r\n", body.size())); 510d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("\r\n"); 511d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(body); 512d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 513d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = 514d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mNetSession->sendRequest(sessionID, request.c_str(), request.size()); 515d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 516d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 517d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 518d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 519d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 520d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber registerResponseHandler( 521d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, mNextCSeq, &WifiDisplaySource::onReceiveM4Response); 522d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 523d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ++mNextCSeq; 524d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 525d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 526d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 527d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 528ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huberstatus_t WifiDisplaySource::sendM5(int32_t sessionID, bool requestShutdown) { 529ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber AString body = "wfd_trigger_method: "; 530ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber if (requestShutdown) { 531ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGI("Sending TEARDOWN trigger."); 532ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber body.append("TEARDOWN"); 533ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber } else { 534ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber body.append("SETUP"); 535ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber } 536ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 537ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber body.append("\r\n"); 538d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 539d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString request = "SET_PARAMETER rtsp://localhost/wfd1.0 RTSP/1.0\r\n"; 540d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&request, mNextCSeq); 541d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 542d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("Content-Type: text/parameters\r\n"); 543d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(StringPrintf("Content-Length: %d\r\n", body.size())); 544d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("\r\n"); 545d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(body); 546d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 547d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = 548d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mNetSession->sendRequest(sessionID, request.c_str(), request.size()); 549d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 550d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 551d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 552d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 553d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 554d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber registerResponseHandler( 555d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, mNextCSeq, &WifiDisplaySource::onReceiveM5Response); 556d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 557d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ++mNextCSeq; 558d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 559d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 560d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 561d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 562b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huberstatus_t WifiDisplaySource::sendM16(int32_t sessionID) { 563b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber AString request = "GET_PARAMETER rtsp://localhost/wfd1.0 RTSP/1.0\r\n"; 564b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber AppendCommonResponse(&request, mNextCSeq); 565b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 566c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_EQ(sessionID, mClientSessionID); 567c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber request.append( 568c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber StringPrintf("Session: %d\r\n", mClientInfo.mPlaybackSessionID)); 569a438123bd96c7faf145683876702387efe5628d9Andreas Huber request.append("\r\n"); // Empty body 570b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 571b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber status_t err = 572b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber mNetSession->sendRequest(sessionID, request.c_str(), request.size()); 573b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 574b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber if (err != OK) { 575b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber return err; 576b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber } 577b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 578b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber registerResponseHandler( 579b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber sessionID, mNextCSeq, &WifiDisplaySource::onReceiveM16Response); 580b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 581b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber ++mNextCSeq; 582b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 583b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber return OK; 584b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber} 585b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 586d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::onReceiveM1Response( 587d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, const sp<ParsedMessage> &msg) { 588d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t statusCode; 589d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!msg->getStatusCode(&statusCode)) { 590d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_MALFORMED; 591d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 592d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 593d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (statusCode != 200) { 594d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_UNSUPPORTED; 595d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 596d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 597d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 598d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 599d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 600d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::onReceiveM3Response( 601d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, const sp<ParsedMessage> &msg) { 602d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t statusCode; 603d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!msg->getStatusCode(&statusCode)) { 604d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_MALFORMED; 605d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 606d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 607d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (statusCode != 200) { 608d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_UNSUPPORTED; 609d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 610d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 611b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<Parameters> params = 612b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber Parameters::Parse(msg->getContent(), strlen(msg->getContent())); 613b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 614b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (params == NULL) { 615b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 616b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 617b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 618b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#if REQUIRE_HDCP 619b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber AString value; 620b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (!params->findParameter("wfd_content_protection", &value)) { 621b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber ALOGE("Sink doesn't appear to support content protection."); 622b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return -EACCES; 623b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 624b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 625b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (value == "none") { 626b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber ALOGE("Sink does not support content protection."); 627b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return -EACCES; 628b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 629b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 630b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber bool isHDCP2_0 = false; 631b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (value.startsWith("HDCP2.0 ")) { 632b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber isHDCP2_0 = true; 633b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (!value.startsWith("HDCP2.1 ")) { 634b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 635b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 636b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 637b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber int32_t hdcpPort; 638b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (!ParsedMessage::GetInt32Attribute(value.c_str() + 8, "port", &hdcpPort) 639b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber || hdcpPort < 1 || hdcpPort > 65535) { 640b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 641b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 642b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 643b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mIsHDCP2_0 = isHDCP2_0; 644b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mHDCPPort = hdcpPort; 645b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 646b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber status_t err = makeHDCP(); 647b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err != OK) { 648b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber ALOGE("Unable to instantiate HDCP component."); 649b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 650b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 651b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#endif 652b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 653d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return sendM4(sessionID); 654d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 655d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 656d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::onReceiveM4Response( 657d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, const sp<ParsedMessage> &msg) { 658d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t statusCode; 659d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!msg->getStatusCode(&statusCode)) { 660d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_MALFORMED; 661d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 662d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 663d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (statusCode != 200) { 664d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_UNSUPPORTED; 665d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 666d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 667b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#if REQUIRE_HDCP 668b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (!mHDCPInitializationComplete) { 669b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber ALOGI("Deferring SETUP trigger until HDCP initialization completes."); 670b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 671b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mSetupTriggerDeferred = true; 672b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 673b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 674b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#endif 675b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 676ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber return sendM5(sessionID, false /* requestShutdown */); 677d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 678d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 679d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::onReceiveM5Response( 680d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, const sp<ParsedMessage> &msg) { 681d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t statusCode; 682d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!msg->getStatusCode(&statusCode)) { 683d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_MALFORMED; 684d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 685d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 686d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (statusCode != 200) { 687d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_UNSUPPORTED; 688d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 689d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 690d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 691d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 692d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 693b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huberstatus_t WifiDisplaySource::onReceiveM16Response( 694b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber int32_t sessionID, const sp<ParsedMessage> &msg) { 695b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // If only the response was required to include a "Session:" header... 696b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 697c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_EQ(sessionID, mClientSessionID); 698b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 699c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientInfo.mPlaybackSession != NULL) { 700c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mPlaybackSession->updateLiveness(); 701b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 702b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber scheduleKeepAlive(sessionID); 703b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber } 704b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 705b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber return OK; 706b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber} 707b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 708d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubervoid WifiDisplaySource::scheduleReaper() { 709d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (mReaperPending) { 710d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return; 711d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 712d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 713d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mReaperPending = true; 714d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber (new AMessage(kWhatReapDeadClients, id()))->post(kReaperIntervalUs); 715d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 716d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 717b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Hubervoid WifiDisplaySource::scheduleKeepAlive(int32_t sessionID) { 718b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // We need to send updates at least 5 secs before the timeout is set to 719b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // expire, make sure the timeout is greater than 5 secs to begin with. 720b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber CHECK_GT(kPlaybackSessionTimeoutUs, 5000000ll); 721b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 722b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber sp<AMessage> msg = new AMessage(kWhatKeepAlive, id()); 723b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber msg->setInt32("sessionID", sessionID); 724b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber msg->post(kPlaybackSessionTimeoutUs - 5000000ll); 725b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber} 726b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 727b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onReceiveClientData(const sp<AMessage> &msg) { 728d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID; 729d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("sessionID", &sessionID)); 730d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 731d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<RefBase> obj; 732d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findObject("data", &obj)); 733d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 734d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<ParsedMessage> data = 735d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber static_cast<ParsedMessage *>(obj.get()); 736d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 737d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ALOGV("session %d received '%s'", 738d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, data->debugString().c_str()); 739d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 740d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString method; 741d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString uri; 742d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber data->getRequestField(0, &method); 743d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 744d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq; 745d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!data->findInt32("cseq", &cseq)) { 746d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "400 Bad Request", -1 /* cseq */); 747b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 748d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 749d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 750d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (method.startsWith("RTSP/")) { 751d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // This is a response. 752d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 753d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ResponseID id; 754d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber id.mSessionID = sessionID; 755d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber id.mCSeq = cseq; 756d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 757d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ssize_t index = mResponseHandlers.indexOfKey(id); 758d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 759d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (index < 0) { 760d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ALOGW("Received unsolicited server response, cseq %d", cseq); 761b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 762d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 763d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 764d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber HandleRTSPResponseFunc func = mResponseHandlers.valueAt(index); 765d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mResponseHandlers.removeItemsAt(index); 766d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 767d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = (this->*func)(sessionID, data); 768d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 769d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 770d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ALOGW("Response handler for session %d, cseq %d returned " 771d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "err %d (%s)", 772d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, cseq, err, strerror(-err)); 773d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 774b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 775d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 776d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 777b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 778b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 779d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 780b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber AString version; 781b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber data->getRequestField(2, &version); 782b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (!(version == AString("RTSP/1.0"))) { 783b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sendErrorResponse(sessionID, "505 RTSP Version not supported", cseq); 784b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_UNSUPPORTED; 785b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 786d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 787b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber status_t err; 788b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (method == "OPTIONS") { 789b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onOptionsRequest(sessionID, cseq, data); 790b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "SETUP") { 791b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onSetupRequest(sessionID, cseq, data); 792b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "PLAY") { 793b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onPlayRequest(sessionID, cseq, data); 794b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "PAUSE") { 795b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onPauseRequest(sessionID, cseq, data); 796b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "TEARDOWN") { 797b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onTeardownRequest(sessionID, cseq, data); 798b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "GET_PARAMETER") { 799b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onGetParameterRequest(sessionID, cseq, data); 800b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "SET_PARAMETER") { 801b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onSetParameterRequest(sessionID, cseq, data); 802b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else { 803b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sendErrorResponse(sessionID, "405 Method Not Allowed", cseq); 804d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 805b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = ERROR_UNSUPPORTED; 806b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 807d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 808b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 809d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 810d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 811b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onOptionsRequest( 812d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 813d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 814d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 815d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 816d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 817d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 818d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 819d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession != NULL) { 820d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber playbackSession->updateLiveness(); 821d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 822d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 823d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 824d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq); 825d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 826d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append( 827b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber "Public: org.wfa.wfd1.0, SETUP, TEARDOWN, PLAY, PAUSE, " 828d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "GET_PARAMETER, SET_PARAMETER\r\n"); 829d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 830d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 831d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 832d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = mNetSession->sendRequest(sessionID, response.c_str()); 833d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 834b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err == OK) { 835b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = sendM3(sessionID); 836b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 837b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 838b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 839d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 840d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 841b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onSetupRequest( 842d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 843d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 844d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 845c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_EQ(sessionID, mClientSessionID); 846c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientInfo.mPlaybackSessionID != -1) { 847b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // We only support a single playback session per client. 848b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // This is due to the reversed keep-alive design in the wfd specs... 849b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber sendErrorResponse(sessionID, "400 Bad Request", cseq); 850b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 851b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber } 852b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 853d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString transport; 854d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!data->findString("transport", &transport)) { 855d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "400 Bad Request", cseq); 856b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 857d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 858d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 859bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber PlaybackSession::TransportMode transportMode = 860bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber PlaybackSession::TRANSPORT_UDP; 861d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 862d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int clientRtp, clientRtcp; 863d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (transport.startsWith("RTP/AVP/TCP;")) { 864d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString interleaved; 865bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber if (ParsedMessage::GetAttribute( 866d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber transport.c_str(), "interleaved", &interleaved) 867bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber && sscanf(interleaved.c_str(), "%d-%d", 868bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber &clientRtp, &clientRtcp) == 2) { 869bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber transportMode = PlaybackSession::TRANSPORT_TCP_INTERLEAVED; 870bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } else { 871bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber bool badRequest = false; 872bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber 873bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber AString clientPort; 874bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber if (!ParsedMessage::GetAttribute( 875bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber transport.c_str(), "client_port", &clientPort)) { 876bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber badRequest = true; 877bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } else if (sscanf(clientPort.c_str(), "%d-%d", 878bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber &clientRtp, &clientRtcp) == 2) { 879bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } else if (sscanf(clientPort.c_str(), "%d", &clientRtp) == 1) { 880bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber // No RTCP. 881bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber clientRtcp = -1; 882bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } else { 883bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber badRequest = true; 884bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } 885bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber 886bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber if (badRequest) { 887bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber sendErrorResponse(sessionID, "400 Bad Request", cseq); 888b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 889bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } 890d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 891bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber transportMode = PlaybackSession::TRANSPORT_TCP; 892bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } 893d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else if (transport.startsWith("RTP/AVP;unicast;") 894d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber || transport.startsWith("RTP/AVP/UDP;unicast;")) { 895d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber bool badRequest = false; 896d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 897d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString clientPort; 898d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!ParsedMessage::GetAttribute( 899d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber transport.c_str(), "client_port", &clientPort)) { 900d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber badRequest = true; 901d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else if (sscanf(clientPort.c_str(), "%d-%d", 902d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber &clientRtp, &clientRtcp) == 2) { 903d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else if (sscanf(clientPort.c_str(), "%d", &clientRtp) == 1) { 904d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // No RTCP. 905d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtcp = -1; 906d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else { 907d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber badRequest = true; 908d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 909d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 910d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (badRequest) { 911d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "400 Bad Request", cseq); 912b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 913d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 914d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#if 1 915a438123bd96c7faf145683876702387efe5628d9Andreas Huber // The older LG dongles doesn't specify client_port=xxx apparently. 916d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else if (transport == "RTP/AVP/UDP;unicast") { 917d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtp = 19000; 91828e17ed7e2fbb254fb99481b74db85e427c905eeAndreas Huber clientRtcp = -1; 919d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#endif 920d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else { 921d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "461 Unsupported Transport", cseq); 922b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_UNSUPPORTED; 923d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 924d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 925d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID = makeUniquePlaybackSessionID(); 926d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 927d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<AMessage> notify = new AMessage(kWhatPlaybackSessionNotify, id()); 928d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber notify->setInt32("playbackSessionID", playbackSessionID); 929d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber notify->setInt32("sessionID", sessionID); 930d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 931d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 9320b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber new PlaybackSession( 933bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber mNetSession, notify, mInterfaceAddr, 934b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#if REQUIRE_HDCP 935b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mHDCP 936b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#else 937b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber NULL 938b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#endif 939b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber ); 940d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 941d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber looper()->registerHandler(playbackSession); 942d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 943d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString uri; 944d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber data->getRequestField(1, &uri); 945d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 946d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (strncasecmp("rtsp://", uri.c_str(), 7)) { 947d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "400 Bad Request", cseq); 948b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 949d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 950d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 951d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!(uri.startsWith("rtsp://") && uri.endsWith("/wfd1.0/streamid=0"))) { 952d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "404 Not found", cseq); 953b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 954d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 955d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 956d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = playbackSession->init( 957c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mRemoteIP.c_str(), 958d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtp, 959d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtcp, 960bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber transportMode); 961d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 962d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 963d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber looper()->unregisterHandler(playbackSession->id()); 964d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber playbackSession.clear(); 965d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 966d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 967d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber switch (err) { 968d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case OK: 969d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 970d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case -ENOENT: 971d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "404 Not Found", cseq); 972b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 973d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber default: 974d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "403 Forbidden", cseq); 975b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 976d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 977d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 978c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mPlaybackSessionID = playbackSessionID; 979c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mPlaybackSession = playbackSession; 980b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 981d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 982d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 983d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 984bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber if (transportMode == PlaybackSession::TRANSPORT_TCP_INTERLEAVED) { 985d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append( 986d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber StringPrintf( 987d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "Transport: RTP/AVP/TCP;interleaved=%d-%d;", 988d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtp, clientRtcp)); 989d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else { 990d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t serverRtp = playbackSession->getRTPPort(); 991d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 992bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber AString transportString = "UDP"; 993bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber if (transportMode == PlaybackSession::TRANSPORT_TCP) { 994bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber transportString = "TCP"; 995bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } 996bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber 997d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (clientRtcp >= 0) { 998d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append( 999d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber StringPrintf( 1000bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber "Transport: RTP/AVP/%s;unicast;client_port=%d-%d;" 1001d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "server_port=%d-%d\r\n", 1002bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber transportString.c_str(), 1003d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtp, clientRtcp, serverRtp, serverRtp + 1)); 1004d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else { 1005d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append( 1006d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber StringPrintf( 1007bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber "Transport: RTP/AVP/%s;unicast;client_port=%d;" 1008d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "server_port=%d\r\n", 1009bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber transportString.c_str(), 1010d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtp, serverRtp)); 1011d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1012d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1013d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1014d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1015d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1016d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber err = mNetSession->sendRequest(sessionID, response.c_str()); 1017b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1018b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err != OK) { 1019b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1020b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1021d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1022d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber scheduleReaper(); 1023b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber scheduleKeepAlive(sessionID); 1024b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1025b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 1026d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1027d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1028b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onPlayRequest( 1029d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1030d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1031d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1032d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1033d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1034d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1035d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1036d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession == NULL) { 1037d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "454 Session Not Found", cseq); 1038b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1039d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1040d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1041ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGI("Received PLAY request."); 1042ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 1043d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = playbackSession->play(); 1044d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK_EQ(err, (status_t)OK); 1045d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1046d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1047d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1048d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("Range: npt=now-\r\n"); 1049d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1050d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1051d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber err = mNetSession->sendRequest(sessionID, response.c_str()); 1052b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1053b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err != OK) { 1054b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1055b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 10560b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber 1057bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber playbackSession->finishPlay(); 1058b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1059b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 1060d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1061d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1062b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onPauseRequest( 1063d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1064d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1065d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1066d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1067d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1068d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1069d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1070d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession == NULL) { 1071d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "454 Session Not Found", cseq); 1072b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1073d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1074d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1075d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = playbackSession->pause(); 1076d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK_EQ(err, (status_t)OK); 1077d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1078d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1079d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1080d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1081d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1082d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber err = mNetSession->sendRequest(sessionID, response.c_str()); 1083b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1084b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1085d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1086d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1087b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onTeardownRequest( 1088d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1089d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1090d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1091ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGI("Received TEARDOWN request."); 1092ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 1093d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1094d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1095d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1096d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1097d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession == NULL) { 1098d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "454 Session Not Found", cseq); 1099b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1100d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1101d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1102d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1103d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1104c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber response.append("Connection: close\r\n"); 1105d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1106d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1107ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mNetSession->sendRequest(sessionID, response.c_str()); 1108c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 1109ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber if (mStopReplyID != 0) { 1110eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber finishStop(); 1111ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber } else { 1112ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError(IRemoteDisplayClient::kDisplayErrorUnknown); 1113ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber } 1114b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1115b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 1116d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1117d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1118eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Hubervoid WifiDisplaySource::finishStop() { 1119ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGV("finishStop"); 1120ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 1121ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber#if REQUIRE_HDCP 1122ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber if (mHDCP != NULL) { 1123ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGI("Initiating HDCP shutdown."); 1124ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber mHDCP->shutdownAsync(); 1125eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber return; 1126ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber } 1127ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber#endif 1128ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 1129eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber finishStop2(); 1130eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber} 1131eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber 1132eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Hubervoid WifiDisplaySource::finishStop2() { 1133ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGV("finishStop2"); 1134ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 1135eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber#if REQUIRE_HDCP 1136ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mHDCP->setObserver(NULL); 1137ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mHDCPObserver.clear(); 1138eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber mHDCP.clear(); 1139eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber#endif 1140eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber 1141ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber disconnectClient(); 1142ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 1143ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber if (mSessionID != 0) { 1144ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mNetSession->destroySession(mSessionID); 1145ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mSessionID = 0; 1146ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber } 1147ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 1148ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGV("finishStop2 completed."); 1149ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 1150ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber status_t err = OK; 1151ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 1152ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber sp<AMessage> response = new AMessage; 1153ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber response->setInt32("err", err); 1154eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber response->postReply(mStopReplyID); 1155ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber} 1156ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 1157b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onGetParameterRequest( 1158d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1159d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1160d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1161d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1162d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1163d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1164d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1165d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession == NULL) { 1166d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "454 Session Not Found", cseq); 1167b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1168d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1169d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1170d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber playbackSession->updateLiveness(); 1171d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1172d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1173d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1174d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1175d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1176d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = mNetSession->sendRequest(sessionID, response.c_str()); 1177b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1178d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1179d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1180b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onSetParameterRequest( 1181d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1182d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1183d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1184d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1185d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1186d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1187d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1188d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession == NULL) { 1189d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "454 Session Not Found", cseq); 1190b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1191d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1192d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1193b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (strstr(data->getContent(), "wfd_idr_request\r\n")) { 1194b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber playbackSession->requestIDRFrame(); 1195b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1196496238cc7551d414067dcbbb4fe3bd801f205f95Andreas Huber 1197d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber playbackSession->updateLiveness(); 1198d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1199d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1200d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1201d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1202d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1203d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = mNetSession->sendRequest(sessionID, response.c_str()); 1204b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1205d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1206d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1207d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber// static 1208d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubervoid WifiDisplaySource::AppendCommonResponse( 1209d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString *response, int32_t cseq, int32_t playbackSessionID) { 1210d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber time_t now = time(NULL); 1211d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber struct tm *now2 = gmtime(&now); 1212d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber char buf[128]; 1213d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber strftime(buf, sizeof(buf), "%a, %d %b %Y %H:%M:%S %z", now2); 1214d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1215d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append("Date: "); 1216d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append(buf); 1217d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append("\r\n"); 1218d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1219d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append("Server: Mine/1.0\r\n"); 1220d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1221d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (cseq >= 0) { 1222d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append(StringPrintf("CSeq: %d\r\n", cseq)); 1223d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1224d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1225d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSessionID >= 0ll) { 1226d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append( 1227d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber StringPrintf( 1228d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "Session: %d;timeout=%lld\r\n", 1229d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber playbackSessionID, kPlaybackSessionTimeoutSecs)); 1230d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1231d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1232d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1233d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubervoid WifiDisplaySource::sendErrorResponse( 1234d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1235d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const char *errorDetail, 1236d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq) { 1237d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response; 1238d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("RTSP/1.0 "); 1239d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append(errorDetail); 1240d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1241d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1242d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq); 1243d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1244d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1245d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1246eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber mNetSession->sendRequest(sessionID, response.c_str()); 1247d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1248d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1249d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberint32_t WifiDisplaySource::makeUniquePlaybackSessionID() const { 1250c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber return rand(); 1251d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1252d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1253d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubersp<WifiDisplaySource::PlaybackSession> WifiDisplaySource::findPlaybackSession( 1254d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data, int32_t *playbackSessionID) const { 1255d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!data->findInt32("session", playbackSessionID)) { 1256c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber // XXX the older dongles do not always include a "Session:" header. 1257c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber *playbackSessionID = mClientInfo.mPlaybackSessionID; 1258c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber return mClientInfo.mPlaybackSession; 1259d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1260d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1261c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (*playbackSessionID != mClientInfo.mPlaybackSessionID) { 1262d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return NULL; 1263d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1264d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1265c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber return mClientInfo.mPlaybackSession; 1266c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber} 1267c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 1268ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Hubervoid WifiDisplaySource::disconnectClient() { 1269ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber if (mClientInfo.mPlaybackSession != NULL) { 1270ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber sp<PlaybackSession> playbackSession = mClientInfo.mPlaybackSession; 1271ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClientInfo.mPlaybackSession.clear(); 1272df4ddebe61ac84c7773da1f774d13e4d4bbe9f72Andreas Huber 1273ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGI("Destroying PlaybackSession"); 1274ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber playbackSession->destroy(); 1275ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber looper()->unregisterHandler(playbackSession->id()); 1276ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber } 1277c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 1278ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber if (mClientSessionID != 0) { 1279c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mNetSession->destroySession(mClientSessionID); 1280c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientSessionID = 0; 1281c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } 1282c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 1283ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayDisconnected(); 1284d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1285d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1286b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#if REQUIRE_HDCP 1287b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstruct WifiDisplaySource::HDCPObserver : public BnHDCPObserver { 1288b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber HDCPObserver(const sp<AMessage> ¬ify); 1289b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1290b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber virtual void notify( 1291b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber int msg, int ext1, int ext2, const Parcel *obj); 1292b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1293b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberprivate: 1294b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<AMessage> mNotify; 1295b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1296b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber DISALLOW_EVIL_CONSTRUCTORS(HDCPObserver); 1297b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber}; 1298b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1299b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas HuberWifiDisplaySource::HDCPObserver::HDCPObserver( 1300b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber const sp<AMessage> ¬ify) 1301b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber : mNotify(notify) { 1302b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber} 1303b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1304b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Hubervoid WifiDisplaySource::HDCPObserver::notify( 1305b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber int msg, int ext1, int ext2, const Parcel *obj) { 1306b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<AMessage> notify = mNotify->dup(); 1307b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber notify->setInt32("msg", msg); 1308b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber notify->setInt32("ext1", ext1); 1309b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber notify->setInt32("ext2", ext2); 1310b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber notify->post(); 1311b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber} 1312b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1313b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::makeHDCP() { 1314b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<IServiceManager> sm = defaultServiceManager(); 1315b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<IBinder> binder = sm->getService(String16("media.player")); 1316b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<IMediaPlayerService> service = interface_cast<IMediaPlayerService>(binder); 1317b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber CHECK(service != NULL); 1318b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1319b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mHDCP = service->makeHDCP(); 1320b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1321b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (mHDCP == NULL) { 1322b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_UNSUPPORTED; 1323b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1324b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1325b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<AMessage> notify = new AMessage(kWhatHDCPNotify, id()); 1326b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mHDCPObserver = new HDCPObserver(notify); 1327b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1328b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber status_t err = mHDCP->setObserver(mHDCPObserver); 1329b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1330b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err != OK) { 1331b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber ALOGE("Failed to set HDCP observer."); 1332b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1333b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mHDCPObserver.clear(); 1334b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mHDCP.clear(); 1335b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1336b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1337b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1338b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1339ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGI("Initiating HDCP negotiation w/ host %s:%d", 1340b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mClientInfo.mRemoteIP.c_str(), mHDCPPort); 1341b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1342b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = mHDCP->initAsync(mClientInfo.mRemoteIP.c_str(), mHDCPPort); 1343b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1344b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err != OK) { 1345b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1346b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1347b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1348b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 1349b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber} 1350b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#endif 1351b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1352d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} // namespace android 1353d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1354