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