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