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