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