WifiDisplaySource.cpp revision d5e56231a598b180a1d898bb7dc61b75580e59a4
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" 25a556c4822fc205db0d27834ba5b637c351d73ffaAndreas Huber#include "rtp/RTPSender.h" 26d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber#include "TimeSyncer.h" 27d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 28b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#include <binder/IServiceManager.h> 298ba01021b573889802e67e029225a96f0dfa471aAndy McFadden#include <gui/IGraphicBufferProducer.h> 30b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#include <media/IHDCP.h> 31b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber#include <media/IMediaPlayerService.h> 320b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber#include <media/IRemoteDisplayClient.h> 33d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#include <media/stagefright/foundation/ABuffer.h> 34d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#include <media/stagefright/foundation/ADebug.h> 35d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#include <media/stagefright/foundation/AMessage.h> 36d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#include <media/stagefright/MediaErrors.h> 37d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 38bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber#include <arpa/inet.h> 39bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber#include <cutils/properties.h> 40bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 41d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber#include <ctype.h> 42d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 43d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubernamespace android { 44d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 450b73d4730202fcad53aefc4314a06e7b95f442f0Andreas HuberWifiDisplaySource::WifiDisplaySource( 460b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber const sp<ANetworkSession> &netSession, 470b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber const sp<IRemoteDisplayClient> &client) 48ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber : mState(INITIALIZED), 49ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mNetSession(netSession), 500b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber mClient(client), 51d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mSessionID(0), 52ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber mStopReplyID(0), 53d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber mChosenRTPPort(-1), 54e7bd24af08ef0722fb124a550662bcec48c56f86Andreas Huber mUsingPCMAudio(false), 55c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientSessionID(0), 56d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mReaperPending(false), 570328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mNextCSeq(1), 580328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mUsingHDCP(false), 590328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mIsHDCP2_0(false), 600328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mHDCPPort(0), 610328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mHDCPInitializationComplete(false), 6294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mSetupTriggerDeferred(false) { 635abf87f9af48149972eeb851ecaea679911da040Andreas Huber mSupportedSourceVideoFormats.disableAll(); 6494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 6594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mSupportedSourceVideoFormats.setNativeResolution( 6694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber VideoFormats::RESOLUTION_CEA, 5); // 1280x720 p30 67d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 68d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 69d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas HuberWifiDisplaySource::~WifiDisplaySource() { 70d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 71d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 725131d127a042ee88f903370be88845dc8c9f8578Andreas Huberstatic status_t PostAndAwaitResponse( 735131d127a042ee88f903370be88845dc8c9f8578Andreas Huber const sp<AMessage> &msg, sp<AMessage> *response) { 745131d127a042ee88f903370be88845dc8c9f8578Andreas Huber status_t err = msg->postAndAwaitResponse(response); 75d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 76d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 77d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 78d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 79d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 805131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (response == NULL || !(*response)->findInt32("err", &err)) { 81d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber err = OK; 82d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 83d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 84d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 85d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 86d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 875131d127a042ee88f903370be88845dc8c9f8578Andreas Huberstatus_t WifiDisplaySource::start(const char *iface) { 885131d127a042ee88f903370be88845dc8c9f8578Andreas Huber CHECK_EQ(mState, INITIALIZED); 895131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 905131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> msg = new AMessage(kWhatStart, id()); 915131d127a042ee88f903370be88845dc8c9f8578Andreas Huber msg->setString("iface", iface); 925131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 935131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> response; 945131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return PostAndAwaitResponse(msg, &response); 955131d127a042ee88f903370be88845dc8c9f8578Andreas Huber} 965131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 97d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::stop() { 98d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<AMessage> msg = new AMessage(kWhatStop, id()); 99d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 100d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<AMessage> response; 1015131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return PostAndAwaitResponse(msg, &response); 1025131d127a042ee88f903370be88845dc8c9f8578Andreas Huber} 103d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1045131d127a042ee88f903370be88845dc8c9f8578Andreas Huberstatus_t WifiDisplaySource::pause() { 1055131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> msg = new AMessage(kWhatPause, id()); 106d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1075131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> response; 1085131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return PostAndAwaitResponse(msg, &response); 1095131d127a042ee88f903370be88845dc8c9f8578Andreas Huber} 110d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1115131d127a042ee88f903370be88845dc8c9f8578Andreas Huberstatus_t WifiDisplaySource::resume() { 1125131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> msg = new AMessage(kWhatResume, id()); 1135131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 1145131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> response; 1155131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return PostAndAwaitResponse(msg, &response); 116d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 117d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 118d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubervoid WifiDisplaySource::onMessageReceived(const sp<AMessage> &msg) { 119d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber switch (msg->what()) { 120d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case kWhatStart: 121d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 122d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber uint32_t replyID; 123d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->senderAwaitsResponse(&replyID)); 124d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 125bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber AString iface; 126bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber CHECK(msg->findString("iface", &iface)); 127bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 128bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber status_t err = OK; 129bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 130bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber ssize_t colonPos = iface.find(":"); 131bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 132bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber unsigned long port; 133bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 134bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber if (colonPos >= 0) { 135bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber const char *s = iface.c_str() + colonPos + 1; 136bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 137bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber char *end; 138bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber port = strtoul(s, &end, 10); 139bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 140bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber if (end == s || *end != '\0' || port > 65535) { 141bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber err = -EINVAL; 142bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } else { 143bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber iface.erase(colonPos, iface.size() - colonPos); 144bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } 145bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } else { 146bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber port = kWifiDisplayDefaultPort; 147bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } 148bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber 149bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber if (err == OK) { 150bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber if (inet_aton(iface.c_str(), &mInterfaceAddr) != 0) { 151bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber sp<AMessage> notify = new AMessage(kWhatRTSPNotify, id()); 152d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 153bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber err = mNetSession->createRTSPServer( 154bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber mInterfaceAddr, port, notify, &mSessionID); 155bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } else { 156bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber err = -EINVAL; 157bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } 158bcf09f8c995221e75c7cd328f25c7cc6d2b5f7c9Andreas Huber } 159d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 160ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber if (err == OK) { 161d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber sp<AMessage> notify = new AMessage(kWhatTimeSyncerNotify, id()); 162d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber mTimeSyncer = new TimeSyncer(mNetSession, notify); 163d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber looper()->registerHandler(mTimeSyncer); 164d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber 165d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber mTimeSyncer->startServer(8123); 166d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber 167ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = AWAITING_CLIENT_CONNECTION; 168ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber } 169ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 170d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<AMessage> response = new AMessage; 171d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->setInt32("err", err); 172d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->postReply(replyID); 173d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 174d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 175d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 176d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case kWhatRTSPNotify: 177d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 178d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t reason; 179d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("reason", &reason)); 180d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 181d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber switch (reason) { 182d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case ANetworkSession::kWhatError: 183d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 184d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID; 185d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("sessionID", &sessionID)); 186d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 187d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t err; 188d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("err", &err)); 189d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 190d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString detail; 191d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findString("detail", &detail)); 192d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 193d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ALOGE("An error occurred in session %d (%d, '%s/%s').", 194d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, 195d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber err, 196d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber detail.c_str(), 197d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber strerror(-err)); 198d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 199d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mNetSession->destroySession(sessionID); 200d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 201c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (sessionID == mClientSessionID) { 202ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClientSessionID = 0; 203c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 204ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError( 205ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber IRemoteDisplayClient::kDisplayErrorUnknown); 206c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } 207d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 208d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 209d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 210d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case ANetworkSession::kWhatClientConnected: 211d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 212d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID; 213d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("sessionID", &sessionID)); 214d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 215c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientSessionID > 0) { 216c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber ALOGW("A client tried to connect, but we already " 217c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber "have one."); 218d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 219c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mNetSession->destroySession(sessionID); 220c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber break; 221c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } 222c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 223ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber CHECK_EQ(mState, AWAITING_CLIENT_CONNECTION); 224ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 225c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findString("client-ip", &mClientInfo.mRemoteIP)); 226c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findString("server-ip", &mClientInfo.mLocalIP)); 227c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 228c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientInfo.mRemoteIP == mClientInfo.mLocalIP) { 229c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber // Disallow connections from the local interface 230c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber // for security reasons. 231c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mNetSession->destroySession(sessionID); 232c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber break; 233c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } 234d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 235c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findInt32( 236c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber "server-port", &mClientInfo.mLocalPort)); 237c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mPlaybackSessionID = -1; 238c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 239c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientSessionID = sessionID; 240c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 241c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber ALOGI("We now have a client (%d) connected.", sessionID); 242d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 243ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = AWAITING_CLIENT_SETUP; 244ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 245d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = sendM1(sessionID); 246d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK_EQ(err, (status_t)OK); 247d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 248d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 249d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 250d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case ANetworkSession::kWhatData: 251d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 252b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber status_t err = onReceiveClientData(msg); 253b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 254b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err != OK) { 255ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError( 256ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber IRemoteDisplayClient::kDisplayErrorUnknown); 257b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 2585131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 2595131d127a042ee88f903370be88845dc8c9f8578Andreas Huber#if 0 2605131d127a042ee88f903370be88845dc8c9f8578Andreas Huber // testing only. 2615131d127a042ee88f903370be88845dc8c9f8578Andreas Huber char val[PROPERTY_VALUE_MAX]; 2625131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (property_get("media.wfd.trigger", val, NULL)) { 2635131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (!strcasecmp(val, "pause") && mState == PLAYING) { 2645131d127a042ee88f903370be88845dc8c9f8578Andreas Huber mState = PLAYING_TO_PAUSED; 2655131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sendTrigger(mClientSessionID, TRIGGER_PAUSE); 2665131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } else if (!strcasecmp(val, "play") && mState == PAUSED) { 2675131d127a042ee88f903370be88845dc8c9f8578Andreas Huber mState = PAUSED_TO_PLAYING; 2685131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sendTrigger(mClientSessionID, TRIGGER_PLAY); 2695131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 2705131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 2715131d127a042ee88f903370be88845dc8c9f8578Andreas Huber#endif 272d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 273d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 274d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 275d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber default: 276d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber TRESPASS(); 277d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 278d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 279d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 280d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 281d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case kWhatStop: 282d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 283eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber CHECK(msg->senderAwaitsResponse(&mStopReplyID)); 284d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 285ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber CHECK_LT(mState, AWAITING_CLIENT_TEARDOWN); 286ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 287ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber if (mState >= AWAITING_CLIENT_PLAY) { 288ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber // We have a session, i.e. a previous SETUP succeeded. 289ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 2905131d127a042ee88f903370be88845dc8c9f8578Andreas Huber status_t err = sendTrigger( 2915131d127a042ee88f903370be88845dc8c9f8578Andreas Huber mClientSessionID, TRIGGER_TEARDOWN); 2920b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber 293ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber if (err == OK) { 294ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = AWAITING_CLIENT_TEARDOWN; 295ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 296ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber (new AMessage(kWhatTeardownTriggerTimedOut, id()))->post( 297ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber kTeardownTriggerTimeouSecs * 1000000ll); 298ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 299ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber break; 300ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber } 301ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 302ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber // fall through. 303b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 304d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 305eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber finishStop(); 306d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 307d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 308d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 3095131d127a042ee88f903370be88845dc8c9f8578Andreas Huber case kWhatPause: 3105131d127a042ee88f903370be88845dc8c9f8578Andreas Huber { 3115131d127a042ee88f903370be88845dc8c9f8578Andreas Huber uint32_t replyID; 3125131d127a042ee88f903370be88845dc8c9f8578Andreas Huber CHECK(msg->senderAwaitsResponse(&replyID)); 3135131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 3145131d127a042ee88f903370be88845dc8c9f8578Andreas Huber status_t err = OK; 3155131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 3165131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (mState != PLAYING) { 3175131d127a042ee88f903370be88845dc8c9f8578Andreas Huber err = INVALID_OPERATION; 3185131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } else { 3195131d127a042ee88f903370be88845dc8c9f8578Andreas Huber mState = PLAYING_TO_PAUSED; 3205131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sendTrigger(mClientSessionID, TRIGGER_PAUSE); 3215131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 3225131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 3235131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> response = new AMessage; 3245131d127a042ee88f903370be88845dc8c9f8578Andreas Huber response->setInt32("err", err); 3255131d127a042ee88f903370be88845dc8c9f8578Andreas Huber response->postReply(replyID); 3265131d127a042ee88f903370be88845dc8c9f8578Andreas Huber break; 3275131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 3285131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 3295131d127a042ee88f903370be88845dc8c9f8578Andreas Huber case kWhatResume: 3305131d127a042ee88f903370be88845dc8c9f8578Andreas Huber { 3315131d127a042ee88f903370be88845dc8c9f8578Andreas Huber uint32_t replyID; 3325131d127a042ee88f903370be88845dc8c9f8578Andreas Huber CHECK(msg->senderAwaitsResponse(&replyID)); 3335131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 3345131d127a042ee88f903370be88845dc8c9f8578Andreas Huber status_t err = OK; 3355131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 3365131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (mState != PAUSED) { 3375131d127a042ee88f903370be88845dc8c9f8578Andreas Huber err = INVALID_OPERATION; 3385131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } else { 3395131d127a042ee88f903370be88845dc8c9f8578Andreas Huber mState = PAUSED_TO_PLAYING; 3405131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sendTrigger(mClientSessionID, TRIGGER_PLAY); 3415131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 3425131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 3435131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sp<AMessage> response = new AMessage; 3445131d127a042ee88f903370be88845dc8c9f8578Andreas Huber response->setInt32("err", err); 3455131d127a042ee88f903370be88845dc8c9f8578Andreas Huber response->postReply(replyID); 3465131d127a042ee88f903370be88845dc8c9f8578Andreas Huber break; 3475131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 3485131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 349d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case kWhatReapDeadClients: 350d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 351d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mReaperPending = false; 352d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 353c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientSessionID == 0 354c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber || mClientInfo.mPlaybackSession == NULL) { 355c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber break; 356d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 357d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 358c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientInfo.mPlaybackSession->getLastLifesignUs() 359c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber + kPlaybackSessionTimeoutUs < ALooper::GetNowUs()) { 360c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber ALOGI("playback session timed out, reaping."); 361c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 362ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mNetSession->destroySession(mClientSessionID); 363ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClientSessionID = 0; 364ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 365ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError( 366ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber IRemoteDisplayClient::kDisplayErrorUnknown); 367c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } else { 368d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber scheduleReaper(); 369d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 370d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 371d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 372d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 373d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case kWhatPlaybackSessionNotify: 374d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber { 375d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 376d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("playbackSessionID", &playbackSessionID)); 377d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 378d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t what; 379d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("what", &what)); 380d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 381c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (what == PlaybackSession::kWhatSessionDead) { 382c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber ALOGI("playback session wants to quit."); 383c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 384ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError( 385ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber IRemoteDisplayClient::kDisplayErrorUnknown); 386c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } else if (what == PlaybackSession::kWhatSessionEstablished) { 387c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClient != NULL) { 38894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (!mSinkSupportsVideo) { 38994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mClient->onDisplayConnected( 39094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber NULL, // SurfaceTexture 39194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 0, // width, 39294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 0, // height, 39394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mUsingHDCP 39494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ? IRemoteDisplayClient::kDisplayFlagSecure 39594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber : 0); 39694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } else { 39794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber size_t width, height; 39894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 39994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber CHECK(VideoFormats::GetConfiguration( 40094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mChosenVideoResolutionType, 40194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mChosenVideoResolutionIndex, 40294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber &width, 40394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber &height, 40494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber NULL /* framesPerSecond */, 40594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber NULL /* interlaced */)); 40694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 40794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mClient->onDisplayConnected( 40894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mClientInfo.mPlaybackSession->getSurfaceTexture(), 40994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber width, 41094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber height, 41194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mUsingHDCP 41294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ? IRemoteDisplayClient::kDisplayFlagSecure 41394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber : 0); 41494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } 415c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } 416ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 417ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber if (mState == ABOUT_TO_PLAY) { 418ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = PLAYING; 419ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber } 42096fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber } else if (what == PlaybackSession::kWhatSessionDestroyed) { 42196fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber disconnectClient2(); 422c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } else { 423c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_EQ(what, PlaybackSession::kWhatBinaryData); 424d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 425c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber int32_t channel; 426c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findInt32("channel", &channel)); 427d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 428c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber sp<ABuffer> data; 429c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findBuffer("data", &data)); 430d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 431c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_LE(channel, 0xffu); 432c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_LE(data->size(), 0xffffu); 433d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 434c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber int32_t sessionID; 435c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK(msg->findInt32("sessionID", &sessionID)); 436d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 437c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber char header[4]; 438c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber header[0] = '$'; 439c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber header[1] = channel; 440c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber header[2] = data->size() >> 8; 441c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber header[3] = data->size() & 0xff; 442d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 443c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mNetSession->sendRequest( 444c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber sessionID, header, sizeof(header)); 445d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 446c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mNetSession->sendRequest( 447c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber sessionID, data->data(), data->size()); 448d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 449d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 450d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 451d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 452b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber case kWhatKeepAlive: 453b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber { 454b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber int32_t sessionID; 455b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber CHECK(msg->findInt32("sessionID", &sessionID)); 456b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 457c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientSessionID != sessionID) { 458b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // Obsolete event, client is already gone. 459b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber break; 460b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber } 461b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 462b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber sendM16(sessionID); 463b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber break; 464b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber } 465b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 466ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber case kWhatTeardownTriggerTimedOut: 467ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber { 468ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber if (mState == AWAITING_CLIENT_TEARDOWN) { 469ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber ALOGI("TEARDOWN trigger timed out, forcing disconnection."); 470ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 471ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber CHECK_NE(mStopReplyID, 0); 472ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber finishStop(); 473ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber break; 474ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber } 475ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber break; 476ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber } 477ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 478b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber case kWhatHDCPNotify: 479b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber { 480b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber int32_t msgCode, ext1, ext2; 481b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber CHECK(msg->findInt32("msg", &msgCode)); 482b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber CHECK(msg->findInt32("ext1", &ext1)); 483b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber CHECK(msg->findInt32("ext2", &ext2)); 484b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 485eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber ALOGI("Saw HDCP notification code %d, ext1 %d, ext2 %d", 486b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber msgCode, ext1, ext2); 487b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 488b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber switch (msgCode) { 489b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber case HDCPModule::HDCP_INITIALIZATION_COMPLETE: 490b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber { 491b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mHDCPInitializationComplete = true; 492b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 493b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (mSetupTriggerDeferred) { 494b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mSetupTriggerDeferred = false; 495b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 4965131d127a042ee88f903370be88845dc8c9f8578Andreas Huber sendTrigger(mClientSessionID, TRIGGER_SETUP); 497b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 498b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber break; 499b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 500b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 501eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber case HDCPModule::HDCP_SHUTDOWN_COMPLETE: 502ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber case HDCPModule::HDCP_SHUTDOWN_FAILED: 503eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber { 504ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber // Ugly hack to make sure that the call to 505ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber // HDCPObserver::notify is completely handled before 506ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber // we clear the HDCP instance and unload the shared 507ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber // library :( 508ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber (new AMessage(kWhatFinishStop2, id()))->post(300000ll); 509eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber break; 510eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber } 511eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber 512b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber default: 513b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber { 514ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber ALOGE("HDCP failure, shutting down."); 515ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 516ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError( 517ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber IRemoteDisplayClient::kDisplayErrorUnknown); 518b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber break; 519b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 520b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 521b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber break; 522b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 523ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 524ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber case kWhatFinishStop2: 525ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber { 526ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber finishStop2(); 527ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber break; 528ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber } 529b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 530d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber case kWhatTimeSyncerNotify: 531d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber { 532d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber break; 533d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber } 534d5e56231a598b180a1d898bb7dc61b75580e59a4Andreas Huber 535d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber default: 536d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber TRESPASS(); 537d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 538d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 539d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 540d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubervoid WifiDisplaySource::registerResponseHandler( 541d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, int32_t cseq, HandleRTSPResponseFunc func) { 542d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ResponseID id; 543d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber id.mSessionID = sessionID; 544d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber id.mCSeq = cseq; 545d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mResponseHandlers.add(id, func); 546d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 547d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 548d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::sendM1(int32_t sessionID) { 549d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString request = "OPTIONS * RTSP/1.0\r\n"; 550d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&request, mNextCSeq); 551d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 552d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append( 553d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "Require: org.wfa.wfd1.0\r\n" 554d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "\r\n"); 555d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 556d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = 557d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mNetSession->sendRequest(sessionID, request.c_str(), request.size()); 558d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 559d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 560d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 561d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 562d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 563d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber registerResponseHandler( 564d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, mNextCSeq, &WifiDisplaySource::onReceiveM1Response); 565d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 566d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ++mNextCSeq; 567d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 568d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 569d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 570d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 571d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::sendM3(int32_t sessionID) { 572d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString body = 573b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber "wfd_content_protection\r\n" 574d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "wfd_video_formats\r\n" 575d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "wfd_audio_codecs\r\n" 576d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "wfd_client_rtp_ports\r\n"; 577d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 578d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString request = "GET_PARAMETER rtsp://localhost/wfd1.0 RTSP/1.0\r\n"; 579d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&request, mNextCSeq); 580d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 581d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("Content-Type: text/parameters\r\n"); 582d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(StringPrintf("Content-Length: %d\r\n", body.size())); 583d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("\r\n"); 584d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(body); 585d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 586d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = 587d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mNetSession->sendRequest(sessionID, request.c_str(), request.size()); 588d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 589d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 590d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 591d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 592d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 593d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber registerResponseHandler( 594d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, mNextCSeq, &WifiDisplaySource::onReceiveM3Response); 595d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 596d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ++mNextCSeq; 597d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 598d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 599d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 600d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 601d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::sendM4(int32_t sessionID) { 602c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_EQ(sessionID, mClientSessionID); 603d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 60494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber AString body; 60594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 60694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (mSinkSupportsVideo) { 60794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber body.append("wfd_video_formats: "); 60894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 60994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber VideoFormats chosenVideoFormat; 61094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber chosenVideoFormat.disableAll(); 61194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber chosenVideoFormat.setNativeResolution( 61294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mChosenVideoResolutionType, mChosenVideoResolutionIndex); 61394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 6145abf87f9af48149972eeb851ecaea679911da040Andreas Huber body.append(chosenVideoFormat.getFormatSpec(true /* forM4Message */)); 61594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber body.append("\r\n"); 61694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } 61794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 61894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (mSinkSupportsAudio) { 61994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber body.append( 62094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber StringPrintf("wfd_audio_codecs: %s\r\n", 62194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber (mUsingPCMAudio 62294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ? "LPCM 00000002 00" // 2 ch PCM 48kHz 62394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber : "AAC 00000001 00"))); // 2 ch AAC 48kHz 62494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } 62594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 62694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber body.append( 62794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber StringPrintf( 6287cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber "wfd_presentation_URL: rtsp://%s/wfd1.0/streamid=0 none\r\n", 6297cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber mClientInfo.mLocalIP.c_str())); 6307cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber 6317cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber body.append(mWfdClientRtpPorts); 6327cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber body.append("\r\n"); 633d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 634d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString request = "SET_PARAMETER rtsp://localhost/wfd1.0 RTSP/1.0\r\n"; 635d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&request, mNextCSeq); 636d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 637d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("Content-Type: text/parameters\r\n"); 638d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(StringPrintf("Content-Length: %d\r\n", body.size())); 639d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("\r\n"); 640d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(body); 641d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 642d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = 643d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mNetSession->sendRequest(sessionID, request.c_str(), request.size()); 644d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 645d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 646d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 647d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 648d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 649d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber registerResponseHandler( 650d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, mNextCSeq, &WifiDisplaySource::onReceiveM4Response); 651d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 652d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ++mNextCSeq; 653d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 654d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 655d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 656d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 6575131d127a042ee88f903370be88845dc8c9f8578Andreas Huberstatus_t WifiDisplaySource::sendTrigger( 6585131d127a042ee88f903370be88845dc8c9f8578Andreas Huber int32_t sessionID, TriggerType triggerType) { 659ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber AString body = "wfd_trigger_method: "; 6605131d127a042ee88f903370be88845dc8c9f8578Andreas Huber switch (triggerType) { 6615131d127a042ee88f903370be88845dc8c9f8578Andreas Huber case TRIGGER_SETUP: 6625131d127a042ee88f903370be88845dc8c9f8578Andreas Huber body.append("SETUP"); 6635131d127a042ee88f903370be88845dc8c9f8578Andreas Huber break; 6645131d127a042ee88f903370be88845dc8c9f8578Andreas Huber case TRIGGER_TEARDOWN: 6655131d127a042ee88f903370be88845dc8c9f8578Andreas Huber ALOGI("Sending TEARDOWN trigger."); 6665131d127a042ee88f903370be88845dc8c9f8578Andreas Huber body.append("TEARDOWN"); 6675131d127a042ee88f903370be88845dc8c9f8578Andreas Huber break; 6685131d127a042ee88f903370be88845dc8c9f8578Andreas Huber case TRIGGER_PAUSE: 6695131d127a042ee88f903370be88845dc8c9f8578Andreas Huber body.append("PAUSE"); 6705131d127a042ee88f903370be88845dc8c9f8578Andreas Huber break; 6715131d127a042ee88f903370be88845dc8c9f8578Andreas Huber case TRIGGER_PLAY: 6725131d127a042ee88f903370be88845dc8c9f8578Andreas Huber body.append("PLAY"); 6735131d127a042ee88f903370be88845dc8c9f8578Andreas Huber break; 6745131d127a042ee88f903370be88845dc8c9f8578Andreas Huber default: 6755131d127a042ee88f903370be88845dc8c9f8578Andreas Huber TRESPASS(); 676ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber } 677ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 678ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber body.append("\r\n"); 679d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 680d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString request = "SET_PARAMETER rtsp://localhost/wfd1.0 RTSP/1.0\r\n"; 681d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&request, mNextCSeq); 682d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 683d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("Content-Type: text/parameters\r\n"); 684d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(StringPrintf("Content-Length: %d\r\n", body.size())); 685d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append("\r\n"); 686d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber request.append(body); 687d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 688d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = 689d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mNetSession->sendRequest(sessionID, request.c_str(), request.size()); 690d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 691d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 692d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return err; 693d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 694d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 695d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber registerResponseHandler( 696d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, mNextCSeq, &WifiDisplaySource::onReceiveM5Response); 697d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 698d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ++mNextCSeq; 699d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 700d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 701d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 702d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 703b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huberstatus_t WifiDisplaySource::sendM16(int32_t sessionID) { 704b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber AString request = "GET_PARAMETER rtsp://localhost/wfd1.0 RTSP/1.0\r\n"; 705b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber AppendCommonResponse(&request, mNextCSeq); 706b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 707c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_EQ(sessionID, mClientSessionID); 708c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber request.append( 709c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber StringPrintf("Session: %d\r\n", mClientInfo.mPlaybackSessionID)); 710a438123bd96c7faf145683876702387efe5628d9Andreas Huber request.append("\r\n"); // Empty body 711b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 712b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber status_t err = 713b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber mNetSession->sendRequest(sessionID, request.c_str(), request.size()); 714b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 715b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber if (err != OK) { 716b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber return err; 717b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber } 718b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 719b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber registerResponseHandler( 720b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber sessionID, mNextCSeq, &WifiDisplaySource::onReceiveM16Response); 721b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 722b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber ++mNextCSeq; 723b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 724b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber return OK; 725b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber} 726b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 727d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::onReceiveM1Response( 728d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, const sp<ParsedMessage> &msg) { 729d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t statusCode; 730d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!msg->getStatusCode(&statusCode)) { 731d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_MALFORMED; 732d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 733d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 734d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (statusCode != 200) { 735d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_UNSUPPORTED; 736d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 737d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 738d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 739d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 740d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 741d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber// sink_audio_list := ("LPCM"|"AAC"|"AC3" HEXDIGIT*8 HEXDIGIT*2) 742d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber// (", " sink_audio_list)* 743d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huberstatic void GetAudioModes(const char *s, const char *prefix, uint32_t *modes) { 744d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber *modes = 0; 745d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 746d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber size_t prefixLen = strlen(prefix); 747d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 748d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber while (*s != '0') { 749d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber if (!strncmp(s, prefix, prefixLen) && s[prefixLen] == ' ') { 750d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber unsigned latency; 751d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber if (sscanf(&s[prefixLen + 1], "%08x %02x", modes, &latency) != 2) { 752d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber *modes = 0; 753d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 754d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 755d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber return; 756d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 757d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 758d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber char *commaPos = strchr(s, ','); 759d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber if (commaPos != NULL) { 760d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber s = commaPos + 1; 761d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 762d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber while (isspace(*s)) { 763d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber ++s; 764d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 765d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } else { 766d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber break; 767d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 768d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 769d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber} 770d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 771d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::onReceiveM3Response( 772d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, const sp<ParsedMessage> &msg) { 773d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t statusCode; 774d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!msg->getStatusCode(&statusCode)) { 775d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_MALFORMED; 776d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 777d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 778d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (statusCode != 200) { 779d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_UNSUPPORTED; 780d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 781d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 782b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<Parameters> params = 783b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber Parameters::Parse(msg->getContent(), strlen(msg->getContent())); 784b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 785b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (params == NULL) { 786b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 787b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 788b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 789b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber AString value; 790d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber if (!params->findParameter("wfd_client_rtp_ports", &value)) { 791d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber ALOGE("Sink doesn't report its choice of wfd_client_rtp_ports."); 792d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber return ERROR_MALFORMED; 793d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 794d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 7957cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber unsigned port0 = 0, port1 = 0; 796d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber if (sscanf(value.c_str(), 797d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber "RTP/AVP/UDP;unicast %u %u mode=play", 798d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber &port0, 7997cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber &port1) == 2 8007cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber || sscanf(value.c_str(), 8017cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber "RTP/AVP/TCP;unicast %u %u mode=play", 8027cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber &port0, 8037cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber &port1) == 2) { 8047cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber if (port0 == 0 || port0 > 65535 || port1 != 0) { 8057cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber ALOGE("Sink chose its wfd_client_rtp_ports poorly (%s)", 8067cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber value.c_str()); 8077cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber 8087cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber return ERROR_MALFORMED; 8097cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber } 8107cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber } else if (strcmp(value.c_str(), "RTP/AVP/TCP;interleaved mode=play")) { 8117cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber ALOGE("Unsupported value for wfd_client_rtp_ports (%s)", 812d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber value.c_str()); 813d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 8147cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber return ERROR_UNSUPPORTED; 815d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 816d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 8177cc0c29d6a7b76520ec588437ab51d5b8eac9ebcAndreas Huber mWfdClientRtpPorts = value; 818d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber mChosenRTPPort = port0; 819d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 82094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (!params->findParameter("wfd_video_formats", &value)) { 82194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGE("Sink doesn't report its choice of wfd_video_formats."); 82294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber return ERROR_MALFORMED; 82394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } 82494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 82594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mSinkSupportsVideo = false; 82694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 82794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (!(value == "none")) { 82894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mSinkSupportsVideo = true; 82994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (!mSupportedSinkVideoFormats.parseFormatSpec(value.c_str())) { 83094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGE("Failed to parse sink provided wfd_video_formats (%s)", 83194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber value.c_str()); 83294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 83394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber return ERROR_MALFORMED; 83494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } 83594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 83694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (!VideoFormats::PickBestFormat( 83794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mSupportedSinkVideoFormats, 83894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mSupportedSourceVideoFormats, 83994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber &mChosenVideoResolutionType, 84094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber &mChosenVideoResolutionIndex)) { 84194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGE("Sink and source share no commonly supported video " 84294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber "formats."); 84394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 84494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber return ERROR_UNSUPPORTED; 84594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } 84694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 84794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber size_t width, height, framesPerSecond; 84894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber bool interlaced; 84994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber CHECK(VideoFormats::GetConfiguration( 85094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mChosenVideoResolutionType, 85194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mChosenVideoResolutionIndex, 85294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber &width, 85394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber &height, 85494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber &framesPerSecond, 85594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber &interlaced)); 85694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 85794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGI("Picked video resolution %u x %u %c%u", 85894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber width, height, interlaced ? 'i' : 'p', framesPerSecond); 85994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } else { 86094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGI("Sink doesn't support video at all."); 86194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } 86294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 863d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber if (!params->findParameter("wfd_audio_codecs", &value)) { 864d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber ALOGE("Sink doesn't report its choice of wfd_audio_codecs."); 865d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber return ERROR_MALFORMED; 866d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 867d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 86894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mSinkSupportsAudio = false; 869d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 87094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (!(value == "none")) { 87194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mSinkSupportsAudio = true; 872d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 87394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber uint32_t modes; 87494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber GetAudioModes(value.c_str(), "AAC", &modes); 875d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 87694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber bool supportsAAC = (modes & 1) != 0; // AAC 2ch 48kHz 877d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 87894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber GetAudioModes(value.c_str(), "LPCM", &modes); 879d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 88094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber bool supportsPCM = (modes & 2) != 0; // LPCM 2ch 48kHz 88194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 88294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber char val[PROPERTY_VALUE_MAX]; 88394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (supportsPCM 88494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber && property_get("media.wfd.use-pcm-audio", val, NULL) 88594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber && (!strcasecmp("true", val) || !strcmp("1", val))) { 88694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGI("Using PCM audio."); 88794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mUsingPCMAudio = true; 88894a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } else if (supportsAAC) { 88994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGI("Using AAC audio."); 89094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mUsingPCMAudio = false; 89194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } else if (supportsPCM) { 89294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGI("Using PCM audio."); 89394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mUsingPCMAudio = true; 89494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } else { 89594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGI("Sink doesn't support an audio format we do."); 89694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber return ERROR_UNSUPPORTED; 89794a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } 898d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } else { 89994a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGI("Sink doesn't support audio at all."); 90094a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber } 90194a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber 90294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber if (!mSinkSupportsVideo && !mSinkSupportsAudio) { 90394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber ALOGE("Sink supports neither video nor audio..."); 904d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber return ERROR_UNSUPPORTED; 905d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber } 906d243c04534d1b74bd66625c5c96a9b918d8838bfAndreas Huber 9070328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mUsingHDCP = false; 908b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (!params->findParameter("wfd_content_protection", &value)) { 9090328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber ALOGI("Sink doesn't appear to support content protection."); 9100328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber } else if (value == "none") { 9110328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber ALOGI("Sink does not support content protection."); 9120328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber } else { 9130328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mUsingHDCP = true; 914b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 9150328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber bool isHDCP2_0 = false; 9160328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber if (value.startsWith("HDCP2.0 ")) { 9170328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber isHDCP2_0 = true; 9180328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber } else if (!value.startsWith("HDCP2.1 ")) { 9190328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber ALOGE("malformed wfd_content_protection: '%s'", value.c_str()); 920b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 9210328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber return ERROR_MALFORMED; 9220328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber } 923b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 9240328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber int32_t hdcpPort; 9250328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber if (!ParsedMessage::GetInt32Attribute( 9260328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber value.c_str() + 8, "port", &hdcpPort) 9270328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber || hdcpPort < 1 || hdcpPort > 65535) { 9280328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber return ERROR_MALFORMED; 9290328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber } 930b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 9310328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mIsHDCP2_0 = isHDCP2_0; 9320328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mHDCPPort = hdcpPort; 933b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 9340328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber status_t err = makeHDCP(); 9350328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber if (err != OK) { 9360224bf170a3904576bba81593eaab113c5d3a4e7Andreas Huber ALOGE("Unable to instantiate HDCP component. " 9370224bf170a3904576bba81593eaab113c5d3a4e7Andreas Huber "Not using HDCP after all."); 9380224bf170a3904576bba81593eaab113c5d3a4e7Andreas Huber 9390224bf170a3904576bba81593eaab113c5d3a4e7Andreas Huber mUsingHDCP = false; 9400328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber } 941b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 942b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 943d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return sendM4(sessionID); 944d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 945d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 946d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::onReceiveM4Response( 947d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, const sp<ParsedMessage> &msg) { 948d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t statusCode; 949d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!msg->getStatusCode(&statusCode)) { 950d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_MALFORMED; 951d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 952d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 953d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (statusCode != 200) { 954d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_UNSUPPORTED; 955d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 956d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 9570328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber if (mUsingHDCP && !mHDCPInitializationComplete) { 958b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber ALOGI("Deferring SETUP trigger until HDCP initialization completes."); 959b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 960b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mSetupTriggerDeferred = true; 961b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 962b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 963b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 9645131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return sendTrigger(sessionID, TRIGGER_SETUP); 965d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 966d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 967d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberstatus_t WifiDisplaySource::onReceiveM5Response( 968d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, const sp<ParsedMessage> &msg) { 969d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t statusCode; 970d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!msg->getStatusCode(&statusCode)) { 971d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_MALFORMED; 972d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 973d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 974d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (statusCode != 200) { 975d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return ERROR_UNSUPPORTED; 976d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 977d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 978d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return OK; 979d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 980d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 981b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huberstatus_t WifiDisplaySource::onReceiveM16Response( 982b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber int32_t sessionID, const sp<ParsedMessage> &msg) { 983b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // If only the response was required to include a "Session:" header... 984b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 985c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_EQ(sessionID, mClientSessionID); 986b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 987c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientInfo.mPlaybackSession != NULL) { 988c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mPlaybackSession->updateLiveness(); 989b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 990b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber scheduleKeepAlive(sessionID); 991b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber } 992b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 993b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber return OK; 994b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber} 995b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 996d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubervoid WifiDisplaySource::scheduleReaper() { 997d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (mReaperPending) { 998d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return; 999d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1000d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1001d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mReaperPending = true; 1002d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber (new AMessage(kWhatReapDeadClients, id()))->post(kReaperIntervalUs); 1003d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1004d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1005b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Hubervoid WifiDisplaySource::scheduleKeepAlive(int32_t sessionID) { 1006b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // We need to send updates at least 5 secs before the timeout is set to 1007b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // expire, make sure the timeout is greater than 5 secs to begin with. 1008b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber CHECK_GT(kPlaybackSessionTimeoutUs, 5000000ll); 1009b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 1010b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber sp<AMessage> msg = new AMessage(kWhatKeepAlive, id()); 1011b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber msg->setInt32("sessionID", sessionID); 1012b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber msg->post(kPlaybackSessionTimeoutUs - 5000000ll); 1013b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber} 1014b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 1015b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onReceiveClientData(const sp<AMessage> &msg) { 1016d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID; 1017d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findInt32("sessionID", &sessionID)); 1018d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1019d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<RefBase> obj; 1020d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK(msg->findObject("data", &obj)); 1021d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1022d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<ParsedMessage> data = 1023d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber static_cast<ParsedMessage *>(obj.get()); 1024d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1025d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ALOGV("session %d received '%s'", 1026d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, data->debugString().c_str()); 1027d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1028d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString method; 1029d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString uri; 1030d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber data->getRequestField(0, &method); 1031d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1032d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq; 1033d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!data->findInt32("cseq", &cseq)) { 1034d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "400 Bad Request", -1 /* cseq */); 1035b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1036d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1037d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1038d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (method.startsWith("RTSP/")) { 1039d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // This is a response. 1040d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1041d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ResponseID id; 1042d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber id.mSessionID = sessionID; 1043d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber id.mCSeq = cseq; 1044d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1045d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ssize_t index = mResponseHandlers.indexOfKey(id); 1046d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1047d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (index < 0) { 1048d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ALOGW("Received unsolicited server response, cseq %d", cseq); 1049b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1050d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1051d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1052d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber HandleRTSPResponseFunc func = mResponseHandlers.valueAt(index); 1053d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber mResponseHandlers.removeItemsAt(index); 1054d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1055d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = (this->*func)(sessionID, data); 1056d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1057d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 1058d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber ALOGW("Response handler for session %d, cseq %d returned " 1059d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "err %d (%s)", 1060d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sessionID, cseq, err, strerror(-err)); 1061d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1062b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1063d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1064d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1065b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 1066b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1067d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1068b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber AString version; 1069b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber data->getRequestField(2, &version); 1070b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (!(version == AString("RTSP/1.0"))) { 1071b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sendErrorResponse(sessionID, "505 RTSP Version not supported", cseq); 1072b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_UNSUPPORTED; 1073b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1074d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1075b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber status_t err; 1076b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (method == "OPTIONS") { 1077b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onOptionsRequest(sessionID, cseq, data); 1078b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "SETUP") { 1079b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onSetupRequest(sessionID, cseq, data); 1080b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "PLAY") { 1081b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onPlayRequest(sessionID, cseq, data); 1082b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "PAUSE") { 1083b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onPauseRequest(sessionID, cseq, data); 1084b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "TEARDOWN") { 1085b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onTeardownRequest(sessionID, cseq, data); 1086b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "GET_PARAMETER") { 1087b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onGetParameterRequest(sessionID, cseq, data); 1088b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else if (method == "SET_PARAMETER") { 1089b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = onSetParameterRequest(sessionID, cseq, data); 1090b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } else { 1091b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sendErrorResponse(sessionID, "405 Method Not Allowed", cseq); 1092d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1093b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = ERROR_UNSUPPORTED; 1094b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1095d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1096b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1097d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1098d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1099b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onOptionsRequest( 1100d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1101d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1102d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1103d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1104d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1105d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1106d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1107d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession != NULL) { 1108d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber playbackSession->updateLiveness(); 1109d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1110d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1111d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1112d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq); 1113d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1114d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append( 1115b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber "Public: org.wfa.wfd1.0, SETUP, TEARDOWN, PLAY, PAUSE, " 1116d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "GET_PARAMETER, SET_PARAMETER\r\n"); 1117d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1118d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1119d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1120d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = mNetSession->sendRequest(sessionID, response.c_str()); 1121d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1122b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err == OK) { 1123b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = sendM3(sessionID); 1124b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1125b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1126b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1127d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1128d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1129b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onSetupRequest( 1130d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1131d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1132d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1133c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber CHECK_EQ(sessionID, mClientSessionID); 1134c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (mClientInfo.mPlaybackSessionID != -1) { 1135b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // We only support a single playback session per client. 1136b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber // This is due to the reversed keep-alive design in the wfd specs... 1137b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber sendErrorResponse(sessionID, "400 Bad Request", cseq); 1138b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1139b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber } 1140b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 1141d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString transport; 1142d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!data->findString("transport", &transport)) { 1143d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "400 Bad Request", cseq); 1144b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1145d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1146d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1147a556c4822fc205db0d27834ba5b637c351d73ffaAndreas Huber RTPSender::TransportMode transportMode = RTPSender::TRANSPORT_UDP; 1148d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1149d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int clientRtp, clientRtcp; 1150d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (transport.startsWith("RTP/AVP/TCP;")) { 1151d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString interleaved; 1152bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber if (ParsedMessage::GetAttribute( 1153d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber transport.c_str(), "interleaved", &interleaved) 1154bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber && sscanf(interleaved.c_str(), "%d-%d", 1155bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber &clientRtp, &clientRtcp) == 2) { 1156a556c4822fc205db0d27834ba5b637c351d73ffaAndreas Huber transportMode = RTPSender::TRANSPORT_TCP_INTERLEAVED; 1157bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } else { 1158bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber bool badRequest = false; 1159bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber 1160bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber AString clientPort; 1161bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber if (!ParsedMessage::GetAttribute( 1162bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber transport.c_str(), "client_port", &clientPort)) { 1163bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber badRequest = true; 1164bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } else if (sscanf(clientPort.c_str(), "%d-%d", 1165bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber &clientRtp, &clientRtcp) == 2) { 1166bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } else if (sscanf(clientPort.c_str(), "%d", &clientRtp) == 1) { 1167bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber // No RTCP. 1168bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber clientRtcp = -1; 1169bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } else { 1170bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber badRequest = true; 1171bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } 1172bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber 1173bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber if (badRequest) { 1174bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber sendErrorResponse(sessionID, "400 Bad Request", cseq); 1175b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1176bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } 1177d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1178a556c4822fc205db0d27834ba5b637c351d73ffaAndreas Huber transportMode = RTPSender::TRANSPORT_TCP; 1179bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } 1180d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else if (transport.startsWith("RTP/AVP;unicast;") 1181d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber || transport.startsWith("RTP/AVP/UDP;unicast;")) { 1182d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber bool badRequest = false; 1183d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1184d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString clientPort; 1185d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!ParsedMessage::GetAttribute( 1186d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber transport.c_str(), "client_port", &clientPort)) { 1187d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber badRequest = true; 1188d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else if (sscanf(clientPort.c_str(), "%d-%d", 1189d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber &clientRtp, &clientRtcp) == 2) { 1190d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else if (sscanf(clientPort.c_str(), "%d", &clientRtp) == 1) { 1191d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber // No RTCP. 1192d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtcp = -1; 1193d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else { 1194d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber badRequest = true; 1195d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1196d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1197d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (badRequest) { 1198d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "400 Bad Request", cseq); 1199b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1200d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1201d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#if 1 1202a438123bd96c7faf145683876702387efe5628d9Andreas Huber // The older LG dongles doesn't specify client_port=xxx apparently. 1203d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else if (transport == "RTP/AVP/UDP;unicast") { 1204d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtp = 19000; 120528e17ed7e2fbb254fb99481b74db85e427c905eeAndreas Huber clientRtcp = -1; 1206d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber#endif 1207d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else { 1208d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "461 Unsupported Transport", cseq); 1209b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_UNSUPPORTED; 1210d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1211d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1212d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID = makeUniquePlaybackSessionID(); 1213d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1214d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<AMessage> notify = new AMessage(kWhatPlaybackSessionNotify, id()); 1215d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber notify->setInt32("playbackSessionID", playbackSessionID); 1216d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber notify->setInt32("sessionID", sessionID); 1217d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1218d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 12190b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber new PlaybackSession( 12200328ec08dc1e90caa2a9e0c4e107d8ddaa74af20Andreas Huber mNetSession, notify, mInterfaceAddr, mHDCP); 1221d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1222d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber looper()->registerHandler(playbackSession); 1223d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1224d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString uri; 1225d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber data->getRequestField(1, &uri); 1226d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1227d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (strncasecmp("rtsp://", uri.c_str(), 7)) { 1228d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "400 Bad Request", cseq); 1229b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1230d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1231d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1232d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!(uri.startsWith("rtsp://") && uri.endsWith("/wfd1.0/streamid=0"))) { 1233d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "404 Not found", cseq); 1234b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1235d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1236d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1237d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = playbackSession->init( 1238c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mRemoteIP.c_str(), 1239d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtp, 1240d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtcp, 1241e7bd24af08ef0722fb124a550662bcec48c56f86Andreas Huber transportMode, 124294a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mSinkSupportsAudio, 124394a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mUsingPCMAudio, 124494a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mSinkSupportsVideo, 124594a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mChosenVideoResolutionType, 124694a483bf2bd699275673d9cd57cb125d48572f30Andreas Huber mChosenVideoResolutionIndex); 1247d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1248d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (err != OK) { 1249d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber looper()->unregisterHandler(playbackSession->id()); 1250d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber playbackSession.clear(); 1251d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1252d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1253d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber switch (err) { 1254d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case OK: 1255d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber break; 1256d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber case -ENOENT: 1257d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "404 Not Found", cseq); 1258b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1259d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber default: 1260d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "403 Forbidden", cseq); 1261b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1262d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1263d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1264c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mPlaybackSessionID = playbackSessionID; 1265c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientInfo.mPlaybackSession = playbackSession; 1266b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber 1267d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1268d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1269d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1270a556c4822fc205db0d27834ba5b637c351d73ffaAndreas Huber if (transportMode == RTPSender::TRANSPORT_TCP_INTERLEAVED) { 1271d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append( 1272d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber StringPrintf( 1273d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "Transport: RTP/AVP/TCP;interleaved=%d-%d;", 1274d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtp, clientRtcp)); 1275d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else { 1276d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t serverRtp = playbackSession->getRTPPort(); 1277d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1278bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber AString transportString = "UDP"; 1279a556c4822fc205db0d27834ba5b637c351d73ffaAndreas Huber if (transportMode == RTPSender::TRANSPORT_TCP) { 1280bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber transportString = "TCP"; 1281bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber } 1282bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber 1283d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (clientRtcp >= 0) { 1284d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append( 1285d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber StringPrintf( 1286bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber "Transport: RTP/AVP/%s;unicast;client_port=%d-%d;" 1287d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "server_port=%d-%d\r\n", 1288bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber transportString.c_str(), 1289d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtp, clientRtcp, serverRtp, serverRtp + 1)); 1290d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } else { 1291d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append( 1292d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber StringPrintf( 1293bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber "Transport: RTP/AVP/%s;unicast;client_port=%d;" 1294d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "server_port=%d\r\n", 1295bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber transportString.c_str(), 1296d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber clientRtp, serverRtp)); 1297d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1298d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1299d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1300d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1301d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1302d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber err = mNetSession->sendRequest(sessionID, response.c_str()); 1303b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1304b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err != OK) { 1305b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1306b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1307d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1308ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = AWAITING_CLIENT_PLAY; 1309ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 1310d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber scheduleReaper(); 1311b6777017a68ed473d61cc9d6e77c34fd5cd301ccAndreas Huber scheduleKeepAlive(sessionID); 1312b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1313b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 1314d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1315d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1316b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onPlayRequest( 1317d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1318d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1319d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1320d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1321d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1322d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1323d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1324d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession == NULL) { 1325d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "454 Session Not Found", cseq); 1326b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1327d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1328d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1329ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGI("Received PLAY request."); 1330ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 1331d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = playbackSession->play(); 1332d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK_EQ(err, (status_t)OK); 1333d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1334d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1335d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1336d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("Range: npt=now-\r\n"); 1337d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1338d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1339d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber err = mNetSession->sendRequest(sessionID, response.c_str()); 1340b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1341b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err != OK) { 1342b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1343b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 13440b73d4730202fcad53aefc4314a06e7b95f442f0Andreas Huber 13455131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (mState == PAUSED_TO_PLAYING) { 13465131d127a042ee88f903370be88845dc8c9f8578Andreas Huber mState = PLAYING; 13475131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return OK; 13485131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 13495131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 1350bd08e2f93bafd02abf2c25d740e9fb8bce455a99Andreas Huber playbackSession->finishPlay(); 1351b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1352ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber CHECK_EQ(mState, AWAITING_CLIENT_PLAY); 1353ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = ABOUT_TO_PLAY; 1354ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 1355b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 1356d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1357d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1358b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onPauseRequest( 1359d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1360d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1361d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1362d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1363d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1364d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1365d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1366d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession == NULL) { 1367d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "454 Session Not Found", cseq); 1368b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1369d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1370d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 13715131d127a042ee88f903370be88845dc8c9f8578Andreas Huber ALOGI("Received PAUSE request."); 13725131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 13735131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (mState != PLAYING_TO_PAUSED) { 13745131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return INVALID_OPERATION; 13755131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 13765131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 1377d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = playbackSession->pause(); 1378d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber CHECK_EQ(err, (status_t)OK); 1379d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1380d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1381d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1382d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1383d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1384d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber err = mNetSession->sendRequest(sessionID, response.c_str()); 1385b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 13865131d127a042ee88f903370be88845dc8c9f8578Andreas Huber if (err != OK) { 13875131d127a042ee88f903370be88845dc8c9f8578Andreas Huber return err; 13885131d127a042ee88f903370be88845dc8c9f8578Andreas Huber } 13895131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 13905131d127a042ee88f903370be88845dc8c9f8578Andreas Huber mState = PAUSED; 13915131d127a042ee88f903370be88845dc8c9f8578Andreas Huber 1392b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1393d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1394d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1395b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onTeardownRequest( 1396d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1397d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1398d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1399ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGI("Received TEARDOWN request."); 1400ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 1401d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1402d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1403d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1404d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1405d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession == NULL) { 1406d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "454 Session Not Found", cseq); 1407b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1408d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1409d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1410d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1411d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1412c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber response.append("Connection: close\r\n"); 1413d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1414d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1415ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mNetSession->sendRequest(sessionID, response.c_str()); 1416c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 1417ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber if (mState == AWAITING_CLIENT_TEARDOWN) { 1418ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber CHECK_NE(mStopReplyID, 0); 1419eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber finishStop(); 1420ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber } else { 1421ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayError(IRemoteDisplayClient::kDisplayErrorUnknown); 1422ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber } 1423b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1424b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 1425d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1426d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1427eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Hubervoid WifiDisplaySource::finishStop() { 1428ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGV("finishStop"); 1429ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 1430ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = STOPPING; 1431ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber 143296fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber disconnectClientAsync(); 143396fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber} 143496fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber 143596fc6cc65ca93009a759a3a874b82a35771b9714Andreas Hubervoid WifiDisplaySource::finishStopAfterDisconnectingClient() { 143696fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber ALOGV("finishStopAfterDisconnectingClient"); 143796fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber 1438ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber if (mHDCP != NULL) { 1439ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGI("Initiating HDCP shutdown."); 1440ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber mHDCP->shutdownAsync(); 1441eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber return; 1442ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber } 1443ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 1444eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber finishStop2(); 1445eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber} 1446eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber 1447eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Hubervoid WifiDisplaySource::finishStop2() { 1448ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGV("finishStop2"); 1449ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 1450bbe96f0f05a1f1a1b3cfec0d124cb0d63c1ebf2aAndreas Huber if (mHDCP != NULL) { 1451bbe96f0f05a1f1a1b3cfec0d124cb0d63c1ebf2aAndreas Huber mHDCP->setObserver(NULL); 1452bbe96f0f05a1f1a1b3cfec0d124cb0d63c1ebf2aAndreas Huber mHDCPObserver.clear(); 1453bbe96f0f05a1f1a1b3cfec0d124cb0d63c1ebf2aAndreas Huber mHDCP.clear(); 1454bbe96f0f05a1f1a1b3cfec0d124cb0d63c1ebf2aAndreas Huber } 1455eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber 1456ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber if (mSessionID != 0) { 1457ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mNetSession->destroySession(mSessionID); 1458ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mSessionID = 0; 1459ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber } 1460ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 146196fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber ALOGI("We're stopped."); 1462ad0d97c7cf620e96a0b088dd9461645a3f8900b7Andreas Huber mState = STOPPED; 1463ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber 1464ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber status_t err = OK; 1465ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 1466ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber sp<AMessage> response = new AMessage; 1467ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber response->setInt32("err", err); 1468eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber response->postReply(mStopReplyID); 1469ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber} 1470ea4bbfdcad9478ea19257fb19a32de68a2dfd958Andreas Huber 1471b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onGetParameterRequest( 1472d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1473d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1474d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1475d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1476d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1477d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1478d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1479d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession == NULL) { 1480d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "454 Session Not Found", cseq); 1481b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1482d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1483d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1484d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber playbackSession->updateLiveness(); 1485d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1486d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1487d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1488d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1489d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1490d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = mNetSession->sendRequest(sessionID, response.c_str()); 1491b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1492d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1493d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1494b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::onSetParameterRequest( 1495d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1496d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq, 1497d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data) { 1498d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t playbackSessionID; 1499d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sp<PlaybackSession> playbackSession = 1500d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber findPlaybackSession(data, &playbackSessionID); 1501d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1502d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSession == NULL) { 1503d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber sendErrorResponse(sessionID, "454 Session Not Found", cseq); 1504b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_MALFORMED; 1505d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1506d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1507b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (strstr(data->getContent(), "wfd_idr_request\r\n")) { 1508b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber playbackSession->requestIDRFrame(); 1509b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1510496238cc7551d414067dcbbb4fe3bd801f205f95Andreas Huber 1511d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber playbackSession->updateLiveness(); 1512d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1513d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response = "RTSP/1.0 200 OK\r\n"; 1514d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq, playbackSessionID); 1515d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1516d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1517d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber status_t err = mNetSession->sendRequest(sessionID, response.c_str()); 1518b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1519d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1520d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1521d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber// static 1522d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubervoid WifiDisplaySource::AppendCommonResponse( 1523d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString *response, int32_t cseq, int32_t playbackSessionID) { 1524d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber time_t now = time(NULL); 1525d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber struct tm *now2 = gmtime(&now); 1526d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber char buf[128]; 1527d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber strftime(buf, sizeof(buf), "%a, %d %b %Y %H:%M:%S %z", now2); 1528d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1529d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append("Date: "); 1530d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append(buf); 1531d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append("\r\n"); 1532d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1533d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append("Server: Mine/1.0\r\n"); 1534d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1535d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (cseq >= 0) { 1536d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append(StringPrintf("CSeq: %d\r\n", cseq)); 1537d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1538d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1539d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (playbackSessionID >= 0ll) { 1540d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response->append( 1541d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber StringPrintf( 1542d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber "Session: %d;timeout=%lld\r\n", 1543d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber playbackSessionID, kPlaybackSessionTimeoutSecs)); 1544d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1545d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1546d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1547d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubervoid WifiDisplaySource::sendErrorResponse( 1548d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t sessionID, 1549d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const char *errorDetail, 1550d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber int32_t cseq) { 1551d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AString response; 1552d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("RTSP/1.0 "); 1553d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append(errorDetail); 1554d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1555d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1556d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber AppendCommonResponse(&response, cseq); 1557d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1558d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber response.append("\r\n"); 1559d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1560eb11600a248cfe5b95ddd3e5aaae02bd2ab65276Andreas Huber mNetSession->sendRequest(sessionID, response.c_str()); 1561d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1562d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1563d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huberint32_t WifiDisplaySource::makeUniquePlaybackSessionID() const { 1564c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber return rand(); 1565d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1566d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1567d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Hubersp<WifiDisplaySource::PlaybackSession> WifiDisplaySource::findPlaybackSession( 1568d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber const sp<ParsedMessage> &data, int32_t *playbackSessionID) const { 1569d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber if (!data->findInt32("session", playbackSessionID)) { 1570c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber // XXX the older dongles do not always include a "Session:" header. 1571c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber *playbackSessionID = mClientInfo.mPlaybackSessionID; 1572c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber return mClientInfo.mPlaybackSession; 1573d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1574d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1575c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber if (*playbackSessionID != mClientInfo.mPlaybackSessionID) { 1576d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber return NULL; 1577d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber } 1578d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1579c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber return mClientInfo.mPlaybackSession; 1580c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber} 1581c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 158296fc6cc65ca93009a759a3a874b82a35771b9714Andreas Hubervoid WifiDisplaySource::disconnectClientAsync() { 158396fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber ALOGV("disconnectClient"); 158496fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber 158596fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber if (mClientInfo.mPlaybackSession == NULL) { 158696fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber disconnectClient2(); 158796fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber return; 158896fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber } 158996fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber 159096fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber if (mClientInfo.mPlaybackSession != NULL) { 159196fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber ALOGV("Destroying PlaybackSession"); 159296fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber mClientInfo.mPlaybackSession->destroyAsync(); 159396fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber } 159496fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber} 159596fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber 159696fc6cc65ca93009a759a3a874b82a35771b9714Andreas Hubervoid WifiDisplaySource::disconnectClient2() { 159796fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber ALOGV("disconnectClient2"); 159896fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber 1599ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber if (mClientInfo.mPlaybackSession != NULL) { 160096fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber looper()->unregisterHandler(mClientInfo.mPlaybackSession->id()); 1601ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClientInfo.mPlaybackSession.clear(); 1602ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber } 1603c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 1604ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber if (mClientSessionID != 0) { 1605c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mNetSession->destroySession(mClientSessionID); 1606c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber mClientSessionID = 0; 1607c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber } 1608c92bed3a73c06e90217f8f199ca0b517aa7595d2Andreas Huber 1609ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber mClient->onDisplayDisconnected(); 161096fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber 161196fc6cc65ca93009a759a3a874b82a35771b9714Andreas Huber finishStopAfterDisconnectingClient(); 1612d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} 1613d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1614b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstruct WifiDisplaySource::HDCPObserver : public BnHDCPObserver { 1615b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber HDCPObserver(const sp<AMessage> ¬ify); 1616b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1617b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber virtual void notify( 1618b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber int msg, int ext1, int ext2, const Parcel *obj); 1619b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1620b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberprivate: 1621b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<AMessage> mNotify; 1622b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1623b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber DISALLOW_EVIL_CONSTRUCTORS(HDCPObserver); 1624b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber}; 1625b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1626b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas HuberWifiDisplaySource::HDCPObserver::HDCPObserver( 1627b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber const sp<AMessage> ¬ify) 1628b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber : mNotify(notify) { 1629b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber} 1630b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1631b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Hubervoid WifiDisplaySource::HDCPObserver::notify( 1632b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber int msg, int ext1, int ext2, const Parcel *obj) { 1633b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<AMessage> notify = mNotify->dup(); 1634b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber notify->setInt32("msg", msg); 1635b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber notify->setInt32("ext1", ext1); 1636b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber notify->setInt32("ext2", ext2); 1637b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber notify->post(); 1638b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber} 1639b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1640b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huberstatus_t WifiDisplaySource::makeHDCP() { 1641b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<IServiceManager> sm = defaultServiceManager(); 1642b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<IBinder> binder = sm->getService(String16("media.player")); 1643b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<IMediaPlayerService> service = interface_cast<IMediaPlayerService>(binder); 1644b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber CHECK(service != NULL); 1645b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1646a6a88d9c445e261972c2433254e0a996336e78a4Andreas Huber mHDCP = service->makeHDCP(true /* createEncryptionModule */); 1647b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1648b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (mHDCP == NULL) { 1649b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return ERROR_UNSUPPORTED; 1650b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1651b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1652b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber sp<AMessage> notify = new AMessage(kWhatHDCPNotify, id()); 1653b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mHDCPObserver = new HDCPObserver(notify); 1654b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1655b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber status_t err = mHDCP->setObserver(mHDCPObserver); 1656b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1657b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err != OK) { 1658b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber ALOGE("Failed to set HDCP observer."); 1659b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1660b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mHDCPObserver.clear(); 1661b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mHDCP.clear(); 1662b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1663b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1664b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1665b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1666ef7d3793fa9bbfb25253626ede9a020ee9280a17Andreas Huber ALOGI("Initiating HDCP negotiation w/ host %s:%d", 1667b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber mClientInfo.mRemoteIP.c_str(), mHDCPPort); 1668b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1669b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber err = mHDCP->initAsync(mClientInfo.mRemoteIP.c_str(), mHDCPPort); 1670b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1671b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber if (err != OK) { 1672b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return err; 1673b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber } 1674b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1675b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber return OK; 1676b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber} 1677b8c7bd418f0ee5b88923b0e0817e3a4acc53cf8dAndreas Huber 1678d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber} // namespace android 1679d7bee3a9d2ad76d073d91f0ee36d5ac5f9df480cAndreas Huber 1680