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