MediaPlayerService.cpp revision 8e1b6cce24574b9ecd5b0300155776bd0b4ef756
18d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt/* 28d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt** 3c5ec7f57ead87efa365800228aa0b09a12d9e6c4Dmitry Shmidt** Copyright 2008, The Android Open Source Project 48d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt** 5c5ec7f57ead87efa365800228aa0b09a12d9e6c4Dmitry Shmidt** Licensed under the Apache License, Version 2.0 (the "License"); 6c5ec7f57ead87efa365800228aa0b09a12d9e6c4Dmitry Shmidt** you may not use this file except in compliance with the License. 78d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt** You may obtain a copy of the License at 88d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt** 98d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt** http://www.apache.org/licenses/LICENSE-2.0 108d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt** 118d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt** Unless required by applicable law or agreed to in writing, software 128d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt** distributed under the License is distributed on an "AS IS" BASIS, 138d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt** WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 148d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt** See the License for the specific language governing permissions and 158d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt** limitations under the License. 168d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt*/ 178d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 188d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// Proxy for media player implementations 198d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 208d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt//#define LOG_NDEBUG 0 218d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#define LOG_TAG "MediaPlayerService" 228d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#include <utils/Log.h> 238d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 248d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#include <sys/types.h> 258d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#include <sys/stat.h> 268d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#include <dirent.h> 278d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#include <unistd.h> 288d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 298d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#include <string.h> 308d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 318d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#include <cutils/atomic.h> 328d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#include <cutils/properties.h> 338d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 348d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#include <utils/misc.h> 358d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 368d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#include <android_runtime/ActivityManager.h> 378d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 388d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#include <binder/IPCThreadState.h> 398d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#include <binder/IServiceManager.h> 408d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#include <binder/MemoryHeapBase.h> 418d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#include <binder/MemoryBase.h> 428d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#include <utils/Errors.h> // for status_t 438d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#include <utils/String8.h> 448d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#include <utils/Vector.h> 458d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#include <cutils/properties.h> 468d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 478d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#include <media/MediaPlayerInterface.h> 488d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#include <media/mediarecorder.h> 498d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#include <media/MediaMetadataRetrieverInterface.h> 508d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#include <media/AudioTrack.h> 518d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 528d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#include "MediaRecorderClient.h" 538d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#include "MediaPlayerService.h" 548d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#include "MetadataRetrieverClient.h" 558d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 568d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#include "MidiFile.h" 578d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#include "VorbisPlayer.h" 588d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#include <media/PVPlayer.h> 598d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 608d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt/* desktop Linux needs a little help with gettid() */ 618d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#if defined(HAVE_GETTID) && !defined(HAVE_ANDROID_OS) 628d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#define __KERNEL__ 638d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt# include <linux/unistd.h> 648d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#ifdef _syscall0 658d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt_syscall0(pid_t,gettid) 668d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#else 678d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtpid_t gettid() { return syscall(__NR_gettid);} 688d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#endif 698d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#undef __KERNEL__ 708d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#endif 718d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 728d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtnamespace { 738d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtusing android::status_t; 748d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtusing android::OK; 758d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtusing android::BAD_VALUE; 768d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtusing android::NOT_ENOUGH_DATA; 778d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtusing android::Parcel; 788d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtusing android::Vector; 798d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 808d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// Max number of entries in the filter. 818d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtconst int kMaxFilterSize = 64; // I pulled that out of thin air. 828d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 838d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// Keep in sync with ANY in Metadata.java 848d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtconst int32_t kAny = 0; 858d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 868d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// To order the metadata types in the vector-filter. 878d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtint lessThan(const int32_t *lhs, const int32_t *rhs) 888d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt{ 898d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt return *lhs < *rhs ? 0 : 1; 908d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt} 918d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 928d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// Unmarshall a filter from a Parcel. 938d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// Filter format in a parcel: 948d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// 958d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 968d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ 978d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// | number of entries (n) | 988d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ 998d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// | metadata type 1 | 1008d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ 1018d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// | metadata type 2 | 1028d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ 1038d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// .... 1048d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ 1058d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// | metadata type n | 1068d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+ 1078d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// 1088d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// @param p Parcel that should start with a filter. 1098d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// @param[out] filter On exit contains the list of metadata type to be 1108d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// filtered. 1118d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// @param[out] status On exit contains the status code to be returned. 1128d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// @return true if the parcel starts with a valid filter. 1138d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtbool unmarshallFilter(const Parcel& p, 1148d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt Vector<int32_t> *filter, 1158d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt status_t *status) 1168d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt{ 1178d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt int32_t s; 1188d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt if (p.readInt32(&s) != OK) 1198d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt { 1208d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt LOGE("Failed to read filter's length"); 1218d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt *status = NOT_ENOUGH_DATA; 1228d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt return false; 1238d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 1248d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 1258d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt if( s > kMaxFilterSize || s < 0) 1268d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt { 1278d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt LOGE("Invalid filter len %d", s); 1288d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt *status = BAD_VALUE; 1298d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt return false; 1308d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 1318d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 1328d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt size_t size = s; 1338d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 1348d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt filter->clear(); 1358d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt filter->setCapacity(size); 1368d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 1378d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt s *= sizeof(int32_t); 1388d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 1398d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt if (p.dataAvail() < static_cast<size_t>(s)) 1408d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt { 1418d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt LOGE("Filter too short expected %d but got %d", s, p.dataAvail()); 1428d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt *status = NOT_ENOUGH_DATA; 1438d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt return false; 1448d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 1458d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 1468d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt const int32_t *data = static_cast<const int32_t*>(p.readInplace(s)); 1478d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 1488d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt if (NULL == data ) 1498d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt { 1508d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt LOGE("Filter had no data"); 1518d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt *status = BAD_VALUE; 1528d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt return false; 1538d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 1548d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 1558d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt // TODO: The stl impl of vector would be more efficient here 1568d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt // because it degenerates into a memcpy on pod types. Try to 1578d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt // replace later or use stl::set. 1588d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt for (size_t i = 0; i < size; ++i) 1598d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt { 1608d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt filter->push(*data); 1618d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt ++data; 1628d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 1638d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt *status = OK; 1648d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt return true; 1658d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt} 1668d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 1678d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtbool unmarshallBothFilters(const Parcel& p, 1688d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt Vector<int32_t> *allow, 1698d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt Vector<int32_t> *block, 1708d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt status_t *status) 1718d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt{ 1728d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt if (!(unmarshallFilter(p, allow, status) && unmarshallFilter(p, block, status))) 1738d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt { 1748d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt return false; 1758d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 1768d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt allow->sort(lessThan); 1778d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt block->sort(lessThan); 1788d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt return true; 1798d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt} 1808d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 1818d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// @param filter Should be sorted in ascending order. 1828d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// @param val To be searched. 1838d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// @return true if a match was found. 1848d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtbool findMetadata(const Vector<int32_t> filter, const int32_t val) 1858d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt{ 1868d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt // Deal with empty and ANY right away 1878d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt if (filter.isEmpty()) return false; 1888d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt if (filter[0] == kAny) return true; 1898d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 1908d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt ssize_t min = 0; 1918d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt ssize_t max = filter.size() - 1; 1928d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt ssize_t mid; 1938d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt do 1948d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt { 1958d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt mid = (min + max) / 2; 1968d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt if (val > filter[mid]) 1978d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt { 1988d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt min = mid + 1; 1998d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 2008d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt else 2018d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt { 2028d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt max = mid - 1; 2038d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 2048d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt if (filter[mid] == val) 2058d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt { 2068d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt return true; 2078d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 2088d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 2098d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt while(min <= max); 2108d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt return false; 2118d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt} 2128d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 2138d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt} // anonymous namespace 2148d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 2158d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 2168d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtnamespace android { 2178d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 2188d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// TODO: Temp hack until we can register players 2198d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidttypedef struct { 2208d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt const char *extension; 2218d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt const player_type playertype; 2228d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt} extmap; 2238d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtextmap FILE_EXTS [] = { 2248d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt {".mid", SONIVOX_PLAYER}, 2258d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt {".midi", SONIVOX_PLAYER}, 2268d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt {".smf", SONIVOX_PLAYER}, 2278d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt {".xmf", SONIVOX_PLAYER}, 2288d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt {".imy", SONIVOX_PLAYER}, 2298d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt {".rtttl", SONIVOX_PLAYER}, 2308d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt {".rtx", SONIVOX_PLAYER}, 2318d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt {".ota", SONIVOX_PLAYER}, 2328d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt {".ogg", VORBIS_PLAYER}, 2338d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt {".oga", VORBIS_PLAYER}, 2348d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt}; 2358d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 2368d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt// TODO: Find real cause of Audio/Video delay in PV framework and remove this workaround 2378d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt/* static */ const uint32_t MediaPlayerService::AudioOutput::kAudioVideoDelayMs = 96; 2388d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt/* static */ int MediaPlayerService::AudioOutput::mMinBufferCount = 4; 2398d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt/* static */ bool MediaPlayerService::AudioOutput::mIsOnEmulator = false; 2408d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 2418d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtvoid MediaPlayerService::instantiate() { 2428d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt defaultServiceManager()->addService( 2438d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt String16("media.player"), new MediaPlayerService()); 2448d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt} 2458d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 2468d520ff1dc2da35cdca849e982051b86468016d8Dmitry ShmidtMediaPlayerService::MediaPlayerService() 2478d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt{ 2488d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt LOGV("MediaPlayerService created"); 2498d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt mNextConnId = 1; 2508d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt} 2518d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 2528d520ff1dc2da35cdca849e982051b86468016d8Dmitry ShmidtMediaPlayerService::~MediaPlayerService() 2538d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt{ 2548d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt LOGV("MediaPlayerService destroyed"); 2558d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt} 2568d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 2578d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtsp<IMediaRecorder> MediaPlayerService::createMediaRecorder(pid_t pid) 2588d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt{ 2598d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#ifndef NO_OPENCORE 2608d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt sp<MediaRecorderClient> recorder = new MediaRecorderClient(pid); 2618d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#else 2628d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt sp<MediaRecorderClient> recorder = NULL; 2638d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#endif 2648d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt LOGV("Create new media recorder client from pid %d", pid); 2658d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt return recorder; 2668d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt} 2678d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 2688d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtsp<IMediaMetadataRetriever> MediaPlayerService::createMetadataRetriever(pid_t pid) 2698d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt{ 2708d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt sp<MetadataRetrieverClient> retriever = new MetadataRetrieverClient(pid); 2718d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt LOGV("Create new media retriever from pid %d", pid); 2728d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt return retriever; 2738d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt} 2748d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 2758d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtsp<IMediaPlayer> MediaPlayerService::create(pid_t pid, const sp<IMediaPlayerClient>& client, const char* url) 2768d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt{ 2778d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt int32_t connId = android_atomic_inc(&mNextConnId); 2788d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt sp<Client> c = new Client(this, pid, connId, client); 2798d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt LOGV("Create new client(%d) from pid %d, url=%s, connId=%d", connId, pid, url, connId); 2808d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt if (NO_ERROR != c->setDataSource(url)) 2818d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt { 2828d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt c.clear(); 2838d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt return c; 2848d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 2858d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt wp<Client> w = c; 2868d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt Mutex::Autolock lock(mLock); 2878d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt mClients.add(w); 2888d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt return c; 2898d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt} 2908d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 2918d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtsp<IMediaPlayer> MediaPlayerService::create(pid_t pid, const sp<IMediaPlayerClient>& client, 2928d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt int fd, int64_t offset, int64_t length) 2938d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt{ 2948d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt int32_t connId = android_atomic_inc(&mNextConnId); 2958d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt sp<Client> c = new Client(this, pid, connId, client); 2968d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt LOGV("Create new client(%d) from pid %d, fd=%d, offset=%lld, length=%lld", 2978d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt connId, pid, fd, offset, length); 2988d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt if (NO_ERROR != c->setDataSource(fd, offset, length)) { 2998d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt c.clear(); 3008d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } else { 3018d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt wp<Client> w = c; 3028d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt Mutex::Autolock lock(mLock); 3038d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt mClients.add(w); 3048d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 3058d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt ::close(fd); 3068d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt return c; 3078d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt} 308c5ec7f57ead87efa365800228aa0b09a12d9e6c4Dmitry Shmidt 3098d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtstatus_t MediaPlayerService::AudioCache::dump(int fd, const Vector<String16>& args) const 3108d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt{ 3118d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt const size_t SIZE = 256; 3128d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt char buffer[SIZE]; 3138d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt String8 result; 3148d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 3158d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt result.append(" AudioCache\n"); 3168d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt if (mHeap != 0) { 3178d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt snprintf(buffer, 255, " heap base(%p), size(%d), flags(%d), device(%s)\n", 3188d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt mHeap->getBase(), mHeap->getSize(), mHeap->getFlags(), mHeap->getDevice()); 3198d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt result.append(buffer); 3208d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 3218d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt snprintf(buffer, 255, " msec per frame(%f), channel count(%d), format(%d), frame count(%ld)\n", 3228d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt mMsecsPerFrame, mChannelCount, mFormat, mFrameCount); 3238d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt result.append(buffer); 3248d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt snprintf(buffer, 255, " sample rate(%d), size(%d), error(%d), command complete(%s)\n", 3258d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt mSampleRate, mSize, mError, mCommandComplete?"true":"false"); 3268d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt result.append(buffer); 3278d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt ::write(fd, result.string(), result.size()); 3288d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt return NO_ERROR; 3298d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt} 3308d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 3318d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtstatus_t MediaPlayerService::AudioOutput::dump(int fd, const Vector<String16>& args) const 3328d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt{ 3338d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt const size_t SIZE = 256; 3348d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt char buffer[SIZE]; 3358d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt String8 result; 3368d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 3378d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt result.append(" AudioOutput\n"); 3388d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt snprintf(buffer, 255, " stream type(%d), left - right volume(%f, %f)\n", 3398d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt mStreamType, mLeftVolume, mRightVolume); 3408d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt result.append(buffer); 3418d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt snprintf(buffer, 255, " msec per frame(%f), latency (%d)\n", 3428d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt mMsecsPerFrame, mLatency); 3438d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt result.append(buffer); 3448d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt ::write(fd, result.string(), result.size()); 3458d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt if (mTrack != 0) { 3468d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt mTrack->dump(fd, args); 3478d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 3488d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt return NO_ERROR; 3498d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt} 3508d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 3518d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtstatus_t MediaPlayerService::Client::dump(int fd, const Vector<String16>& args) const 3528d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt{ 3538d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt const size_t SIZE = 256; 3548d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt char buffer[SIZE]; 3558d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt String8 result; 3568d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt result.append(" Client\n"); 3578d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt snprintf(buffer, 255, " pid(%d), connId(%d), status(%d), looping(%s)\n", 3588d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt mPid, mConnId, mStatus, mLoop?"true": "false"); 3598d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt result.append(buffer); 3608d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt write(fd, result.string(), result.size()); 3618d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt if (mAudioOutput != 0) { 3628d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt mAudioOutput->dump(fd, args); 3638d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 3648d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt write(fd, "\n", 1); 3658d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt return NO_ERROR; 3668d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt} 3678d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 3688d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtstatic int myTid() { 3698d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#ifdef HAVE_GETTID 3708d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt return gettid(); 3718d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#else 3728d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt return getpid(); 3738d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#endif 3748d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt} 3758d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 3768d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#if defined(__arm__) 3778d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtextern "C" void get_malloc_leak_info(uint8_t** info, size_t* overallSize, 3788d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt size_t* infoSize, size_t* totalMemory, size_t* backtraceSize); 3798d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtextern "C" void free_malloc_leak_info(uint8_t* info); 3808d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 3818d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtvoid memStatus(int fd, const Vector<String16>& args) 3828d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt{ 3838d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt const size_t SIZE = 256; 3848d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt char buffer[SIZE]; 3858d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt String8 result; 3868d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 3878d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt typedef struct { 3888d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt size_t size; 3898d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt size_t dups; 3908d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt intptr_t * backtrace; 3918d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } AllocEntry; 3928d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 3938d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt uint8_t *info = NULL; 3948d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt size_t overallSize = 0; 3958d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt size_t infoSize = 0; 3968d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt size_t totalMemory = 0; 3978d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt size_t backtraceSize = 0; 3988d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 3998d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt get_malloc_leak_info(&info, &overallSize, &infoSize, &totalMemory, &backtraceSize); 4008d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt if (info) { 4018d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt uint8_t *ptr = info; 4028d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt size_t count = overallSize / infoSize; 4038d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 4048d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt snprintf(buffer, SIZE, " Allocation count %i\n", count); 4058d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt result.append(buffer); 4068d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 4078d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt AllocEntry * entries = new AllocEntry[count]; 4088d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 4098d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt for (size_t i = 0; i < count; i++) { 4108d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt // Each entry should be size_t, size_t, intptr_t[backtraceSize] 4118d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt AllocEntry *e = &entries[i]; 4128d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 4138d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt e->size = *reinterpret_cast<size_t *>(ptr); 4148d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt ptr += sizeof(size_t); 4158d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 4168d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt e->dups = *reinterpret_cast<size_t *>(ptr); 4178d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt ptr += sizeof(size_t); 4188d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 4198d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt e->backtrace = reinterpret_cast<intptr_t *>(ptr); 4208d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt ptr += sizeof(intptr_t) * backtraceSize; 4218d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 4228d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 4238d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt // Now we need to sort the entries. They come sorted by size but 4248d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt // not by stack trace which causes problems using diff. 4258d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt bool moved; 4268d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt do { 4278d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt moved = false; 4288d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt for (size_t i = 0; i < (count - 1); i++) { 4298d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt AllocEntry *e1 = &entries[i]; 4308d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt AllocEntry *e2 = &entries[i+1]; 4318d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 4328d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt bool swap = e1->size < e2->size; 4338d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt if (e1->size == e2->size) { 4348d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt for(size_t j = 0; j < backtraceSize; j++) { 4358d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt if (e1->backtrace[j] == e2->backtrace[j]) { 4368d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt continue; 4378d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 4388d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt swap = e1->backtrace[j] < e2->backtrace[j]; 4398d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt break; 4408d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 4418d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 4428d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt if (swap) { 4438d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt AllocEntry t = entries[i]; 4448d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt entries[i] = entries[i+1]; 4458d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt entries[i+1] = t; 4468d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt moved = true; 4478d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 4488d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 4498d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } while (moved); 4508d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 4518d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt for (size_t i = 0; i < count; i++) { 4528d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt AllocEntry *e = &entries[i]; 4538d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 4548d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt snprintf(buffer, SIZE, "size %8i, dup %4i", e->size, e->dups); 455c5ec7f57ead87efa365800228aa0b09a12d9e6c4Dmitry Shmidt result.append(buffer); 4568d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt for (size_t ct = 0; (ct < backtraceSize) && e->backtrace[ct]; ct++) { 4578d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt if (ct) { 4588d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt result.append(", "); 4598d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 4608d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt snprintf(buffer, SIZE, "0x%08x", e->backtrace[ct]); 4618d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt result.append(buffer); 4628d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 4638d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt result.append("\n"); 4648d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 4658d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 4668d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt delete[] entries; 4678d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt free_malloc_leak_info(info); 4688d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 4698d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 4708d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt write(fd, result.string(), result.size()); 4718d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt} 4728d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt#endif 4738d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 4748d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidtstatus_t MediaPlayerService::dump(int fd, const Vector<String16>& args) 4758d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt{ 4768d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt const size_t SIZE = 256; 4778d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt char buffer[SIZE]; 4788d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt String8 result; 4798d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt if (checkCallingPermission(String16("android.permission.DUMP")) == false) { 4808d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt snprintf(buffer, SIZE, "Permission Denial: " 4818d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt "can't dump MediaPlayerService from pid=%d, uid=%d\n", 4828d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt IPCThreadState::self()->getCallingPid(), 4838d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt IPCThreadState::self()->getCallingUid()); 4848d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt result.append(buffer); 4858d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } else { 4868d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt Mutex::Autolock lock(mLock); 4878d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt for (int i = 0, n = mClients.size(); i < n; ++i) { 4888d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt sp<Client> c = mClients[i].promote(); 4898d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt if (c != 0) c->dump(fd, args); 4908d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 4918d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt result.append(" Files opened and/or mapped:\n"); 4928d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt snprintf(buffer, SIZE, "/proc/%d/maps", myTid()); 4938d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt FILE *f = fopen(buffer, "r"); 4948d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt if (f) { 4958d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt while (!feof(f)) { 4968d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt fgets(buffer, SIZE, f); 4978d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt if (strstr(buffer, " /sdcard/") || 4988d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt strstr(buffer, " /system/sounds/") || 4998d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt strstr(buffer, " /system/media/")) { 5008d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt result.append(" "); 5018d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt result.append(buffer); 5028d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 5038d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 5048d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt fclose(f); 5058d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } else { 5068d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt result.append("couldn't open "); 5078d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt result.append(buffer); 5088d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt result.append("\n"); 5098d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt } 5108d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt 5118d520ff1dc2da35cdca849e982051b86468016d8Dmitry Shmidt snprintf(buffer, SIZE, "/proc/%d/fd", myTid()); 512 DIR *d = opendir(buffer); 513 if (d) { 514 struct dirent *ent; 515 while((ent = readdir(d)) != NULL) { 516 if (strcmp(ent->d_name,".") && strcmp(ent->d_name,"..")) { 517 snprintf(buffer, SIZE, "/proc/%d/fd/%s", myTid(), ent->d_name); 518 struct stat s; 519 if (lstat(buffer, &s) == 0) { 520 if ((s.st_mode & S_IFMT) == S_IFLNK) { 521 char linkto[256]; 522 int len = readlink(buffer, linkto, sizeof(linkto)); 523 if(len > 0) { 524 if(len > 255) { 525 linkto[252] = '.'; 526 linkto[253] = '.'; 527 linkto[254] = '.'; 528 linkto[255] = 0; 529 } else { 530 linkto[len] = 0; 531 } 532 if (strstr(linkto, "/sdcard/") == linkto || 533 strstr(linkto, "/system/sounds/") == linkto || 534 strstr(linkto, "/system/media/") == linkto) { 535 result.append(" "); 536 result.append(buffer); 537 result.append(" -> "); 538 result.append(linkto); 539 result.append("\n"); 540 } 541 } 542 } else { 543 result.append(" unexpected type for "); 544 result.append(buffer); 545 result.append("\n"); 546 } 547 } 548 } 549 } 550 closedir(d); 551 } else { 552 result.append("couldn't open "); 553 result.append(buffer); 554 result.append("\n"); 555 } 556 557#if defined(__arm__) 558 bool dumpMem = false; 559 for (size_t i = 0; i < args.size(); i++) { 560 if (args[i] == String16("-m")) { 561 dumpMem = true; 562 } 563 } 564 if (dumpMem) { 565 memStatus(fd, args); 566 } 567#endif 568 } 569 write(fd, result.string(), result.size()); 570 return NO_ERROR; 571} 572 573void MediaPlayerService::removeClient(wp<Client> client) 574{ 575 Mutex::Autolock lock(mLock); 576 mClients.remove(client); 577} 578 579MediaPlayerService::Client::Client(const sp<MediaPlayerService>& service, pid_t pid, 580 int32_t connId, const sp<IMediaPlayerClient>& client) 581{ 582 LOGV("Client(%d) constructor", connId); 583 mPid = pid; 584 mConnId = connId; 585 mService = service; 586 mClient = client; 587 mLoop = false; 588 mStatus = NO_INIT; 589#if CALLBACK_ANTAGONIZER 590 LOGD("create Antagonizer"); 591 mAntagonizer = new Antagonizer(notify, this); 592#endif 593} 594 595MediaPlayerService::Client::~Client() 596{ 597 LOGV("Client(%d) destructor pid = %d", mConnId, mPid); 598 mAudioOutput.clear(); 599 wp<Client> client(this); 600 disconnect(); 601 mService->removeClient(client); 602} 603 604void MediaPlayerService::Client::disconnect() 605{ 606 LOGV("disconnect(%d) from pid %d", mConnId, mPid); 607 // grab local reference and clear main reference to prevent future 608 // access to object 609 sp<MediaPlayerBase> p; 610 { 611 Mutex::Autolock l(mLock); 612 p = mPlayer; 613 } 614 mClient.clear(); 615 mPlayer.clear(); 616 617 // clear the notification to prevent callbacks to dead client 618 // and reset the player. We assume the player will serialize 619 // access to itself if necessary. 620 if (p != 0) { 621 p->setNotifyCallback(0, 0); 622#if CALLBACK_ANTAGONIZER 623 LOGD("kill Antagonizer"); 624 mAntagonizer->kill(); 625#endif 626 p->reset(); 627 } 628 629 IPCThreadState::self()->flushCommands(); 630} 631 632static player_type getPlayerType(int fd, int64_t offset, int64_t length) 633{ 634 char buf[20]; 635 lseek(fd, offset, SEEK_SET); 636 read(fd, buf, sizeof(buf)); 637 lseek(fd, offset, SEEK_SET); 638 639 long ident = *((long*)buf); 640 641 // Ogg vorbis? 642 if (ident == 0x5367674f) // 'OggS' 643 return VORBIS_PLAYER; 644 645 // Some kind of MIDI? 646 EAS_DATA_HANDLE easdata; 647 if (EAS_Init(&easdata) == EAS_SUCCESS) { 648 EAS_FILE locator; 649 locator.path = NULL; 650 locator.fd = fd; 651 locator.offset = offset; 652 locator.length = length; 653 EAS_HANDLE eashandle; 654 if (EAS_OpenFile(easdata, &locator, &eashandle) == EAS_SUCCESS) { 655 EAS_CloseFile(easdata, eashandle); 656 EAS_Shutdown(easdata); 657 return SONIVOX_PLAYER; 658 } 659 EAS_Shutdown(easdata); 660 } 661 662 // Fall through to PV 663 return PV_PLAYER; 664} 665 666static player_type getPlayerType(const char* url) 667{ 668 669 // use MidiFile for MIDI extensions 670 int lenURL = strlen(url); 671 for (int i = 0; i < NELEM(FILE_EXTS); ++i) { 672 int len = strlen(FILE_EXTS[i].extension); 673 int start = lenURL - len; 674 if (start > 0) { 675 if (!strncmp(url + start, FILE_EXTS[i].extension, len)) { 676 return FILE_EXTS[i].playertype; 677 } 678 } 679 } 680 681 // Fall through to PV 682 return PV_PLAYER; 683} 684 685static sp<MediaPlayerBase> createPlayer(player_type playerType, void* cookie, 686 notify_callback_f notifyFunc) 687{ 688 sp<MediaPlayerBase> p; 689 switch (playerType) { 690#ifndef NO_OPENCORE 691 case PV_PLAYER: 692 LOGV(" create PVPlayer"); 693 p = new PVPlayer(); 694 break; 695#endif 696 case SONIVOX_PLAYER: 697 LOGV(" create MidiFile"); 698 p = new MidiFile(); 699 break; 700 case VORBIS_PLAYER: 701 LOGV(" create VorbisPlayer"); 702 p = new VorbisPlayer(); 703 break; 704 } 705 if (p != NULL) { 706 if (p->initCheck() == NO_ERROR) { 707 p->setNotifyCallback(cookie, notifyFunc); 708 } else { 709 p.clear(); 710 } 711 } 712 if (p == NULL) { 713 LOGE("Failed to create player object"); 714 } 715 return p; 716} 717 718sp<MediaPlayerBase> MediaPlayerService::Client::createPlayer(player_type playerType) 719{ 720 // determine if we have the right player type 721 sp<MediaPlayerBase> p = mPlayer; 722 if ((p != NULL) && (p->playerType() != playerType)) { 723 LOGV("delete player"); 724 p.clear(); 725 } 726 if (p == NULL) { 727 p = android::createPlayer(playerType, this, notify); 728 } 729 return p; 730} 731 732status_t MediaPlayerService::Client::setDataSource(const char *url) 733{ 734 LOGV("setDataSource(%s)", url); 735 if (url == NULL) 736 return UNKNOWN_ERROR; 737 738 if (strncmp(url, "content://", 10) == 0) { 739 // get a filedescriptor for the content Uri and 740 // pass it to the setDataSource(fd) method 741 742 String16 url16(url); 743 int fd = android::openContentProviderFile(url16); 744 if (fd < 0) 745 { 746 LOGE("Couldn't open fd for %s", url); 747 return UNKNOWN_ERROR; 748 } 749 setDataSource(fd, 0, 0x7fffffffffLL); // this sets mStatus 750 close(fd); 751 return mStatus; 752 } else { 753 player_type playerType = getPlayerType(url); 754 LOGV("player type = %d", playerType); 755 756 // create the right type of player 757 sp<MediaPlayerBase> p = createPlayer(playerType); 758 if (p == NULL) return NO_INIT; 759 760 if (!p->hardwareOutput()) { 761 mAudioOutput = new AudioOutput(); 762 static_cast<MediaPlayerInterface*>(p.get())->setAudioSink(mAudioOutput); 763 } 764 765 // now set data source 766 LOGV(" setDataSource"); 767 mStatus = p->setDataSource(url); 768 if (mStatus == NO_ERROR) mPlayer = p; 769 return mStatus; 770 } 771} 772 773status_t MediaPlayerService::Client::setDataSource(int fd, int64_t offset, int64_t length) 774{ 775 LOGV("setDataSource fd=%d, offset=%lld, length=%lld", fd, offset, length); 776 struct stat sb; 777 int ret = fstat(fd, &sb); 778 if (ret != 0) { 779 LOGE("fstat(%d) failed: %d, %s", fd, ret, strerror(errno)); 780 return UNKNOWN_ERROR; 781 } 782 783 LOGV("st_dev = %llu", sb.st_dev); 784 LOGV("st_mode = %u", sb.st_mode); 785 LOGV("st_uid = %lu", sb.st_uid); 786 LOGV("st_gid = %lu", sb.st_gid); 787 LOGV("st_size = %llu", sb.st_size); 788 789 if (offset >= sb.st_size) { 790 LOGE("offset error"); 791 ::close(fd); 792 return UNKNOWN_ERROR; 793 } 794 if (offset + length > sb.st_size) { 795 length = sb.st_size - offset; 796 LOGV("calculated length = %lld", length); 797 } 798 799 player_type playerType = getPlayerType(fd, offset, length); 800 LOGV("player type = %d", playerType); 801 802 // create the right type of player 803 sp<MediaPlayerBase> p = createPlayer(playerType); 804 if (p == NULL) return NO_INIT; 805 806 if (!p->hardwareOutput()) { 807 mAudioOutput = new AudioOutput(); 808 static_cast<MediaPlayerInterface*>(p.get())->setAudioSink(mAudioOutput); 809 } 810 811 // now set data source 812 mStatus = p->setDataSource(fd, offset, length); 813 if (mStatus == NO_ERROR) mPlayer = p; 814 return mStatus; 815} 816 817status_t MediaPlayerService::Client::setVideoSurface(const sp<ISurface>& surface) 818{ 819 LOGV("[%d] setVideoSurface(%p)", mConnId, surface.get()); 820 sp<MediaPlayerBase> p = getPlayer(); 821 if (p == 0) return UNKNOWN_ERROR; 822 return p->setVideoSurface(surface); 823} 824 825status_t MediaPlayerService::Client::invoke(const Parcel& request, 826 Parcel *reply) 827{ 828 sp<MediaPlayerBase> p = getPlayer(); 829 if (p == NULL) return UNKNOWN_ERROR; 830 return p->invoke(request, reply); 831} 832 833// This call doesn't need to access the native player. 834status_t MediaPlayerService::Client::setMetadataFilter(const Parcel& filter) 835{ 836 status_t status; 837 Vector<int32_t> allow, drop; 838 839 if (unmarshallBothFilters(filter, &allow, &drop, &status)) 840 { 841 Mutex::Autolock l(mLock); 842 843 mMetadataAllow = allow; 844 mMetadataDrop = drop; 845 } 846 return status; 847} 848 849status_t MediaPlayerService::Client::getMetadata(bool update_only, bool apply_filter, Parcel *metadata) 850{ 851 status_t status; 852 metadata->writeInt32(-1); // Placeholder for the return code 853 854 // FIXME: Implement, query the native player and do the optional filtering, etc... 855 status = OK; 856 return status; 857} 858 859status_t MediaPlayerService::Client::prepareAsync() 860{ 861 LOGV("[%d] prepareAsync", mConnId); 862 sp<MediaPlayerBase> p = getPlayer(); 863 if (p == 0) return UNKNOWN_ERROR; 864 status_t ret = p->prepareAsync(); 865#if CALLBACK_ANTAGONIZER 866 LOGD("start Antagonizer"); 867 if (ret == NO_ERROR) mAntagonizer->start(); 868#endif 869 return ret; 870} 871 872status_t MediaPlayerService::Client::start() 873{ 874 LOGV("[%d] start", mConnId); 875 sp<MediaPlayerBase> p = getPlayer(); 876 if (p == 0) return UNKNOWN_ERROR; 877 p->setLooping(mLoop); 878 return p->start(); 879} 880 881status_t MediaPlayerService::Client::stop() 882{ 883 LOGV("[%d] stop", mConnId); 884 sp<MediaPlayerBase> p = getPlayer(); 885 if (p == 0) return UNKNOWN_ERROR; 886 return p->stop(); 887} 888 889status_t MediaPlayerService::Client::pause() 890{ 891 LOGV("[%d] pause", mConnId); 892 sp<MediaPlayerBase> p = getPlayer(); 893 if (p == 0) return UNKNOWN_ERROR; 894 return p->pause(); 895} 896 897status_t MediaPlayerService::Client::isPlaying(bool* state) 898{ 899 *state = false; 900 sp<MediaPlayerBase> p = getPlayer(); 901 if (p == 0) return UNKNOWN_ERROR; 902 *state = p->isPlaying(); 903 LOGV("[%d] isPlaying: %d", mConnId, *state); 904 return NO_ERROR; 905} 906 907status_t MediaPlayerService::Client::getCurrentPosition(int *msec) 908{ 909 LOGV("getCurrentPosition"); 910 sp<MediaPlayerBase> p = getPlayer(); 911 if (p == 0) return UNKNOWN_ERROR; 912 status_t ret = p->getCurrentPosition(msec); 913 if (ret == NO_ERROR) { 914 LOGV("[%d] getCurrentPosition = %d", mConnId, *msec); 915 } else { 916 LOGE("getCurrentPosition returned %d", ret); 917 } 918 return ret; 919} 920 921status_t MediaPlayerService::Client::getDuration(int *msec) 922{ 923 LOGV("getDuration"); 924 sp<MediaPlayerBase> p = getPlayer(); 925 if (p == 0) return UNKNOWN_ERROR; 926 status_t ret = p->getDuration(msec); 927 if (ret == NO_ERROR) { 928 LOGV("[%d] getDuration = %d", mConnId, *msec); 929 } else { 930 LOGE("getDuration returned %d", ret); 931 } 932 return ret; 933} 934 935status_t MediaPlayerService::Client::seekTo(int msec) 936{ 937 LOGV("[%d] seekTo(%d)", mConnId, msec); 938 sp<MediaPlayerBase> p = getPlayer(); 939 if (p == 0) return UNKNOWN_ERROR; 940 return p->seekTo(msec); 941} 942 943status_t MediaPlayerService::Client::reset() 944{ 945 LOGV("[%d] reset", mConnId); 946 sp<MediaPlayerBase> p = getPlayer(); 947 if (p == 0) return UNKNOWN_ERROR; 948 return p->reset(); 949} 950 951status_t MediaPlayerService::Client::setAudioStreamType(int type) 952{ 953 LOGV("[%d] setAudioStreamType(%d)", mConnId, type); 954 // TODO: for hardware output, call player instead 955 Mutex::Autolock l(mLock); 956 if (mAudioOutput != 0) mAudioOutput->setAudioStreamType(type); 957 return NO_ERROR; 958} 959 960status_t MediaPlayerService::Client::setLooping(int loop) 961{ 962 LOGV("[%d] setLooping(%d)", mConnId, loop); 963 mLoop = loop; 964 sp<MediaPlayerBase> p = getPlayer(); 965 if (p != 0) return p->setLooping(loop); 966 return NO_ERROR; 967} 968 969status_t MediaPlayerService::Client::setVolume(float leftVolume, float rightVolume) 970{ 971 LOGV("[%d] setVolume(%f, %f)", mConnId, leftVolume, rightVolume); 972 // TODO: for hardware output, call player instead 973 Mutex::Autolock l(mLock); 974 if (mAudioOutput != 0) mAudioOutput->setVolume(leftVolume, rightVolume); 975 return NO_ERROR; 976} 977 978void MediaPlayerService::Client::notify(void* cookie, int msg, int ext1, int ext2) 979{ 980 Client* client = static_cast<Client*>(cookie); 981 982 if (MEDIA_INFO == msg && 983 MEDIA_INFO_METADATA_UPDATE == ext1 && 984 client->shouldDropMetadata(ext2 /* metadata type */)) { 985 return; 986 } 987 LOGV("[%d] notify (%p, %d, %d, %d)", client->mConnId, cookie, msg, ext1, ext2); 988 client->mClient->notify(msg, ext1, ext2); 989} 990 991bool MediaPlayerService::Client::shouldDropMetadata(int code) const 992{ 993 Mutex::Autolock l(mLock); 994 995 if (findMetadata(mMetadataDrop, code)) 996 { 997 return true; 998 } 999 1000 if (mMetadataAllow.isEmpty() || findMetadata(mMetadataAllow, code)) 1001 { 1002 return false; 1003 } 1004 else 1005 { 1006 return true; 1007 } 1008} 1009 1010#if CALLBACK_ANTAGONIZER 1011const int Antagonizer::interval = 10000; // 10 msecs 1012 1013Antagonizer::Antagonizer(notify_callback_f cb, void* client) : 1014 mExit(false), mActive(false), mClient(client), mCb(cb) 1015{ 1016 createThread(callbackThread, this); 1017} 1018 1019void Antagonizer::kill() 1020{ 1021 Mutex::Autolock _l(mLock); 1022 mActive = false; 1023 mExit = true; 1024 mCondition.wait(mLock); 1025} 1026 1027int Antagonizer::callbackThread(void* user) 1028{ 1029 LOGD("Antagonizer started"); 1030 Antagonizer* p = reinterpret_cast<Antagonizer*>(user); 1031 while (!p->mExit) { 1032 if (p->mActive) { 1033 LOGV("send event"); 1034 p->mCb(p->mClient, 0, 0, 0); 1035 } 1036 usleep(interval); 1037 } 1038 Mutex::Autolock _l(p->mLock); 1039 p->mCondition.signal(); 1040 LOGD("Antagonizer stopped"); 1041 return 0; 1042} 1043#endif 1044 1045static size_t kDefaultHeapSize = 1024 * 1024; // 1MB 1046 1047sp<IMemory> MediaPlayerService::decode(const char* url, uint32_t *pSampleRate, int* pNumChannels, int* pFormat) 1048{ 1049 LOGV("decode(%s)", url); 1050 sp<MemoryBase> mem; 1051 sp<MediaPlayerBase> player; 1052 1053 // Protect our precious, precious DRMd ringtones by only allowing 1054 // decoding of http, but not filesystem paths or content Uris. 1055 // If the application wants to decode those, it should open a 1056 // filedescriptor for them and use that. 1057 if (url != NULL && strncmp(url, "http://", 7) != 0) { 1058 LOGD("Can't decode %s by path, use filedescriptor instead", url); 1059 return mem; 1060 } 1061 1062 player_type playerType = getPlayerType(url); 1063 LOGV("player type = %d", playerType); 1064 1065 // create the right type of player 1066 sp<AudioCache> cache = new AudioCache(url); 1067 player = android::createPlayer(playerType, cache.get(), cache->notify); 1068 if (player == NULL) goto Exit; 1069 if (player->hardwareOutput()) goto Exit; 1070 1071 static_cast<MediaPlayerInterface*>(player.get())->setAudioSink(cache); 1072 1073 // set data source 1074 if (player->setDataSource(url) != NO_ERROR) goto Exit; 1075 1076 LOGV("prepare"); 1077 player->prepareAsync(); 1078 1079 LOGV("wait for prepare"); 1080 if (cache->wait() != NO_ERROR) goto Exit; 1081 1082 LOGV("start"); 1083 player->start(); 1084 1085 LOGV("wait for playback complete"); 1086 if (cache->wait() != NO_ERROR) goto Exit; 1087 1088 mem = new MemoryBase(cache->getHeap(), 0, cache->size()); 1089 *pSampleRate = cache->sampleRate(); 1090 *pNumChannels = cache->channelCount(); 1091 *pFormat = cache->format(); 1092 LOGV("return memory @ %p, sampleRate=%u, channelCount = %d, format = %d", mem->pointer(), *pSampleRate, *pNumChannels, *pFormat); 1093 1094Exit: 1095 if (player != 0) player->reset(); 1096 return mem; 1097} 1098 1099sp<IMemory> MediaPlayerService::decode(int fd, int64_t offset, int64_t length, uint32_t *pSampleRate, int* pNumChannels, int* pFormat) 1100{ 1101 LOGV("decode(%d, %lld, %lld)", fd, offset, length); 1102 sp<MemoryBase> mem; 1103 sp<MediaPlayerBase> player; 1104 1105 player_type playerType = getPlayerType(fd, offset, length); 1106 LOGV("player type = %d", playerType); 1107 1108 // create the right type of player 1109 sp<AudioCache> cache = new AudioCache("decode_fd"); 1110 player = android::createPlayer(playerType, cache.get(), cache->notify); 1111 if (player == NULL) goto Exit; 1112 if (player->hardwareOutput()) goto Exit; 1113 1114 static_cast<MediaPlayerInterface*>(player.get())->setAudioSink(cache); 1115 1116 // set data source 1117 if (player->setDataSource(fd, offset, length) != NO_ERROR) goto Exit; 1118 1119 LOGV("prepare"); 1120 player->prepareAsync(); 1121 1122 LOGV("wait for prepare"); 1123 if (cache->wait() != NO_ERROR) goto Exit; 1124 1125 LOGV("start"); 1126 player->start(); 1127 1128 LOGV("wait for playback complete"); 1129 if (cache->wait() != NO_ERROR) goto Exit; 1130 1131 mem = new MemoryBase(cache->getHeap(), 0, cache->size()); 1132 *pSampleRate = cache->sampleRate(); 1133 *pNumChannels = cache->channelCount(); 1134 *pFormat = cache->format(); 1135 LOGV("return memory @ %p, sampleRate=%u, channelCount = %d, format = %d", mem->pointer(), *pSampleRate, *pNumChannels, *pFormat); 1136 1137Exit: 1138 if (player != 0) player->reset(); 1139 ::close(fd); 1140 return mem; 1141} 1142 1143#undef LOG_TAG 1144#define LOG_TAG "AudioSink" 1145MediaPlayerService::AudioOutput::AudioOutput() 1146{ 1147 mTrack = 0; 1148 mStreamType = AudioSystem::MUSIC; 1149 mLeftVolume = 1.0; 1150 mRightVolume = 1.0; 1151 mLatency = 0; 1152 mMsecsPerFrame = 0; 1153 setMinBufferCount(); 1154} 1155 1156MediaPlayerService::AudioOutput::~AudioOutput() 1157{ 1158 close(); 1159} 1160 1161void MediaPlayerService::AudioOutput::setMinBufferCount() 1162{ 1163 char value[PROPERTY_VALUE_MAX]; 1164 if (property_get("ro.kernel.qemu", value, 0)) { 1165 mIsOnEmulator = true; 1166 mMinBufferCount = 12; // to prevent systematic buffer underrun for emulator 1167 } 1168} 1169 1170bool MediaPlayerService::AudioOutput::isOnEmulator() 1171{ 1172 setMinBufferCount(); 1173 return mIsOnEmulator; 1174} 1175 1176int MediaPlayerService::AudioOutput::getMinBufferCount() 1177{ 1178 setMinBufferCount(); 1179 return mMinBufferCount; 1180} 1181 1182ssize_t MediaPlayerService::AudioOutput::bufferSize() const 1183{ 1184 if (mTrack == 0) return NO_INIT; 1185 return mTrack->frameCount() * frameSize(); 1186} 1187 1188ssize_t MediaPlayerService::AudioOutput::frameCount() const 1189{ 1190 if (mTrack == 0) return NO_INIT; 1191 return mTrack->frameCount(); 1192} 1193 1194ssize_t MediaPlayerService::AudioOutput::channelCount() const 1195{ 1196 if (mTrack == 0) return NO_INIT; 1197 return mTrack->channelCount(); 1198} 1199 1200ssize_t MediaPlayerService::AudioOutput::frameSize() const 1201{ 1202 if (mTrack == 0) return NO_INIT; 1203 return mTrack->frameSize(); 1204} 1205 1206uint32_t MediaPlayerService::AudioOutput::latency () const 1207{ 1208 return mLatency; 1209} 1210 1211float MediaPlayerService::AudioOutput::msecsPerFrame() const 1212{ 1213 return mMsecsPerFrame; 1214} 1215 1216status_t MediaPlayerService::AudioOutput::open(uint32_t sampleRate, int channelCount, int format, int bufferCount) 1217{ 1218 // Check argument "bufferCount" against the mininum buffer count 1219 if (bufferCount < mMinBufferCount) { 1220 LOGD("bufferCount (%d) is too small and increased to %d", bufferCount, mMinBufferCount); 1221 bufferCount = mMinBufferCount; 1222 1223 } 1224 LOGV("open(%u, %d, %d, %d)", sampleRate, channelCount, format, bufferCount); 1225 if (mTrack) close(); 1226 int afSampleRate; 1227 int afFrameCount; 1228 int frameCount; 1229 1230 if (AudioSystem::getOutputFrameCount(&afFrameCount, mStreamType) != NO_ERROR) { 1231 return NO_INIT; 1232 } 1233 if (AudioSystem::getOutputSamplingRate(&afSampleRate, mStreamType) != NO_ERROR) { 1234 return NO_INIT; 1235 } 1236 1237 frameCount = (sampleRate*afFrameCount*bufferCount)/afSampleRate; 1238 AudioTrack *t = new AudioTrack(mStreamType, sampleRate, format, channelCount, frameCount); 1239 if ((t == 0) || (t->initCheck() != NO_ERROR)) { 1240 LOGE("Unable to create audio track"); 1241 delete t; 1242 return NO_INIT; 1243 } 1244 1245 LOGV("setVolume"); 1246 t->setVolume(mLeftVolume, mRightVolume); 1247 mMsecsPerFrame = 1.e3 / (float) sampleRate; 1248 mLatency = t->latency() + kAudioVideoDelayMs; 1249 mTrack = t; 1250 return NO_ERROR; 1251} 1252 1253void MediaPlayerService::AudioOutput::start() 1254{ 1255 LOGV("start"); 1256 if (mTrack) { 1257 mTrack->setVolume(mLeftVolume, mRightVolume); 1258 mTrack->start(); 1259 } 1260} 1261 1262ssize_t MediaPlayerService::AudioOutput::write(const void* buffer, size_t size) 1263{ 1264 //LOGV("write(%p, %u)", buffer, size); 1265 if (mTrack) return mTrack->write(buffer, size); 1266 return NO_INIT; 1267} 1268 1269void MediaPlayerService::AudioOutput::stop() 1270{ 1271 LOGV("stop"); 1272 if (mTrack) mTrack->stop(); 1273} 1274 1275void MediaPlayerService::AudioOutput::flush() 1276{ 1277 LOGV("flush"); 1278 if (mTrack) mTrack->flush(); 1279} 1280 1281void MediaPlayerService::AudioOutput::pause() 1282{ 1283 LOGV("pause"); 1284 if (mTrack) mTrack->pause(); 1285} 1286 1287void MediaPlayerService::AudioOutput::close() 1288{ 1289 LOGV("close"); 1290 delete mTrack; 1291 mTrack = 0; 1292} 1293 1294void MediaPlayerService::AudioOutput::setVolume(float left, float right) 1295{ 1296 LOGV("setVolume(%f, %f)", left, right); 1297 mLeftVolume = left; 1298 mRightVolume = right; 1299 if (mTrack) { 1300 mTrack->setVolume(left, right); 1301 } 1302} 1303 1304#undef LOG_TAG 1305#define LOG_TAG "AudioCache" 1306MediaPlayerService::AudioCache::AudioCache(const char* name) : 1307 mChannelCount(0), mFrameCount(1024), mSampleRate(0), mSize(0), 1308 mError(NO_ERROR), mCommandComplete(false) 1309{ 1310 // create ashmem heap 1311 mHeap = new MemoryHeapBase(kDefaultHeapSize, 0, name); 1312} 1313 1314uint32_t MediaPlayerService::AudioCache::latency () const 1315{ 1316 return 0; 1317} 1318 1319float MediaPlayerService::AudioCache::msecsPerFrame() const 1320{ 1321 return mMsecsPerFrame; 1322} 1323 1324status_t MediaPlayerService::AudioCache::open(uint32_t sampleRate, int channelCount, int format, int bufferCount) 1325{ 1326 LOGV("open(%u, %d, %d, %d)", sampleRate, channelCount, format, bufferCount); 1327 if (mHeap->getHeapID() < 0) return NO_INIT; 1328 mSampleRate = sampleRate; 1329 mChannelCount = (uint16_t)channelCount; 1330 mFormat = (uint16_t)format; 1331 mMsecsPerFrame = 1.e3 / (float) sampleRate; 1332 return NO_ERROR; 1333} 1334 1335ssize_t MediaPlayerService::AudioCache::write(const void* buffer, size_t size) 1336{ 1337 LOGV("write(%p, %u)", buffer, size); 1338 if ((buffer == 0) || (size == 0)) return size; 1339 1340 uint8_t* p = static_cast<uint8_t*>(mHeap->getBase()); 1341 if (p == NULL) return NO_INIT; 1342 p += mSize; 1343 LOGV("memcpy(%p, %p, %u)", p, buffer, size); 1344 if (mSize + size > mHeap->getSize()) { 1345 LOGE("Heap size overflow! req size: %d, max size: %d", (mSize + size), mHeap->getSize()); 1346 size = mHeap->getSize() - mSize; 1347 } 1348 memcpy(p, buffer, size); 1349 mSize += size; 1350 return size; 1351} 1352 1353// call with lock held 1354status_t MediaPlayerService::AudioCache::wait() 1355{ 1356 Mutex::Autolock lock(mLock); 1357 if (!mCommandComplete) { 1358 mSignal.wait(mLock); 1359 } 1360 mCommandComplete = false; 1361 1362 if (mError == NO_ERROR) { 1363 LOGV("wait - success"); 1364 } else { 1365 LOGV("wait - error"); 1366 } 1367 return mError; 1368} 1369 1370void MediaPlayerService::AudioCache::notify(void* cookie, int msg, int ext1, int ext2) 1371{ 1372 LOGV("notify(%p, %d, %d, %d)", cookie, msg, ext1, ext2); 1373 AudioCache* p = static_cast<AudioCache*>(cookie); 1374 1375 // ignore buffering messages 1376 if (msg == MEDIA_BUFFERING_UPDATE) return; 1377 1378 // set error condition 1379 if (msg == MEDIA_ERROR) { 1380 LOGE("Error %d, %d occurred", ext1, ext2); 1381 p->mError = ext1; 1382 } 1383 1384 // wake up thread 1385 LOGV("wakeup thread"); 1386 p->mCommandComplete = true; 1387 p->mSignal.signal(); 1388} 1389 1390}; // namespace android 1391