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