12234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten/* 22234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten * Copyright (C) 2014 The Android Open Source Project 32234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten * 42234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten * Licensed under the Apache License, Version 2.0 (the "License"); 52234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten * you may not use this file except in compliance with the License. 62234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten * You may obtain a copy of the License at 72234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten * 82234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten * http://www.apache.org/licenses/LICENSE-2.0 92234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten * 102234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten * Unless required by applicable law or agreed to in writing, software 112234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten * distributed under the License is distributed on an "AS IS" BASIS, 122234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 132234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten * See the License for the specific language governing permissions and 142234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten * limitations under the License. 152234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten */ 162234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 172234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#define LOG_TAG "FastThread" 182234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten//#define LOG_NDEBUG 0 192234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 202234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#define ATRACE_TAG ATRACE_TAG_AUDIO 212234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 222234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#include "Configuration.h" 23e348c5b72ad889389c7c1c900c121f0fbee221b5Elliott Hughes#include <linux/futex.h> 24e348c5b72ad889389c7c1c900c121f0fbee221b5Elliott Hughes#include <sys/syscall.h> 252234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#include <utils/Log.h> 262234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#include <utils/Trace.h> 272234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#include "FastThread.h" 282234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 292234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#define FAST_DEFAULT_NS 999999999L // ~1 sec: default time to sleep 302234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#define FAST_HOT_IDLE_NS 1000000L // 1 ms: time to sleep while hot idling 312234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#define MIN_WARMUP_CYCLES 2 // minimum number of loop cycles to wait for warmup 322234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#define MAX_WARMUP_CYCLES 10 // maximum number of loop cycles to wait for warmup 332234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 342234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kastennamespace android { 352234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 362234002b0710c8db73f82d397cb945cd541c6bbbGlenn KastenFastThread::FastThread() : Thread(false /*canCallJava*/), 372234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // re-initialized to &initial by subclass constructor 382234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten previous(NULL), current(NULL), 392234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten /* oldTs({0, 0}), */ 402234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten oldTsValid(false), 412234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten sleepNs(-1), 422234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten periodNs(0), 432234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten underrunNs(0), 442234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten overrunNs(0), 452234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten forceNs(0), 462234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten warmupNs(0), 472234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // re-initialized to &dummyDumpState by subclass constructor 482234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten mDummyDumpState(NULL), 492234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten dumpState(NULL), 502234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ignoreNextOverrun(true), 512234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#ifdef FAST_MIXER_STATISTICS 522234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // oldLoad 532234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten oldLoadValid(false), 542234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten bounds(0), 552234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten full(false), 562234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // tcu 572234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#endif 582234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten coldGen(0), 592234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten isWarm(false), 602234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten /* measuredWarmupTs({0, 0}), */ 612234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten warmupCycles(0), 622234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // dummyLogWriter 632234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten logWriter(&dummyLogWriter), 642234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten timestampStatus(INVALID_OPERATION), 652234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 662234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten command(FastThreadState::INITIAL), 672234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#if 0 682234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten frameCount(0), 692234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#endif 702234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten attemptedWrite(false) 712234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten{ 722234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten oldTs.tv_sec = 0; 732234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten oldTs.tv_nsec = 0; 742234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten measuredWarmupTs.tv_sec = 0; 752234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten measuredWarmupTs.tv_nsec = 0; 762234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten} 772234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 782234002b0710c8db73f82d397cb945cd541c6bbbGlenn KastenFastThread::~FastThread() 792234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten{ 802234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten} 812234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 822234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kastenbool FastThread::threadLoop() 832234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten{ 842234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten for (;;) { 852234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 862234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // either nanosleep, sched_yield, or busy wait 872234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (sleepNs >= 0) { 882234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (sleepNs > 0) { 892234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ALOG_ASSERT(sleepNs < 1000000000); 902234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten const struct timespec req = {0, sleepNs}; 912234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten nanosleep(&req, NULL); 922234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } else { 932234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten sched_yield(); 942234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 952234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 962234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // default to long sleep for next cycle 972234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten sleepNs = FAST_DEFAULT_NS; 982234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 992234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // poll for state change 1002234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten const FastThreadState *next = poll(); 1012234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (next == NULL) { 1022234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // continue to use the default initial state until a real state is available 1032234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // FIXME &initial not available, should save address earlier 1042234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten //ALOG_ASSERT(current == &initial && previous == &initial); 1052234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten next = current; 1062234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 1072234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 1082234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten command = next->mCommand; 1092234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (next != current) { 1102234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 1112234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // As soon as possible of learning of a new dump area, start using it 1122234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten dumpState = next->mDumpState != NULL ? next->mDumpState : mDummyDumpState; 1132234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten logWriter = next->mNBLogWriter != NULL ? next->mNBLogWriter : &dummyLogWriter; 1142234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten setLog(logWriter); 1152234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 1162234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // We want to always have a valid reference to the previous (non-idle) state. 1172234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // However, the state queue only guarantees access to current and previous states. 1182234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // So when there is a transition from a non-idle state into an idle state, we make a 1192234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // copy of the last known non-idle state so it is still available on return from idle. 1202234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // The possible transitions are: 1212234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // non-idle -> non-idle update previous from current in-place 1222234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // non-idle -> idle update previous from copy of current 1232234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // idle -> idle don't update previous 1242234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // idle -> non-idle don't update previous 1252234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (!(current->mCommand & FastThreadState::IDLE)) { 1262234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (command & FastThreadState::IDLE) { 1272234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten onIdle(); 1282234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten oldTsValid = false; 1292234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#ifdef FAST_MIXER_STATISTICS 1302234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten oldLoadValid = false; 1312234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#endif 1322234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ignoreNextOverrun = true; 1332234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 1342234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten previous = current; 1352234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 1362234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten current = next; 1372234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 1382234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#if !LOG_NDEBUG 1392234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten next = NULL; // not referenced again 1402234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#endif 1412234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 1422234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten dumpState->mCommand = command; 1432234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 1442234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // << current, previous, command, dumpState >> 1452234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 1462234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten switch (command) { 1472234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten case FastThreadState::INITIAL: 1482234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten case FastThreadState::HOT_IDLE: 1492234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten sleepNs = FAST_HOT_IDLE_NS; 1502234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten continue; 1512234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten case FastThreadState::COLD_IDLE: 1522234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // only perform a cold idle command once 1532234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // FIXME consider checking previous state and only perform if previous != COLD_IDLE 1542234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (current->mColdGen != coldGen) { 1552234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten int32_t *coldFutexAddr = current->mColdFutexAddr; 1562234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ALOG_ASSERT(coldFutexAddr != NULL); 1572234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten int32_t old = android_atomic_dec(coldFutexAddr); 1582234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (old <= 0) { 159e348c5b72ad889389c7c1c900c121f0fbee221b5Elliott Hughes syscall(__NR_futex, coldFutexAddr, FUTEX_WAIT_PRIVATE, old - 1, NULL); 1602234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 1612234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten int policy = sched_getscheduler(0); 1622234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (!(policy == SCHED_FIFO || policy == SCHED_RR)) { 1632234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ALOGE("did not receive expected priority boost"); 1642234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 1652234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // This may be overly conservative; there could be times that the normal mixer 1662234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // requests such a brief cold idle that it doesn't require resetting this flag. 1672234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten isWarm = false; 1682234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten measuredWarmupTs.tv_sec = 0; 1692234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten measuredWarmupTs.tv_nsec = 0; 1702234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten warmupCycles = 0; 1712234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten sleepNs = -1; 1722234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten coldGen = current->mColdGen; 1732234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#ifdef FAST_MIXER_STATISTICS 1742234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten bounds = 0; 1752234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten full = false; 1762234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#endif 1772234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten oldTsValid = !clock_gettime(CLOCK_MONOTONIC, &oldTs); 1782234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten timestampStatus = INVALID_OPERATION; 1792234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } else { 1802234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten sleepNs = FAST_HOT_IDLE_NS; 1812234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 1822234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten continue; 1832234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten case FastThreadState::EXIT: 1842234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten onExit(); 1852234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten return false; 1862234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten default: 1872234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten LOG_ALWAYS_FATAL_IF(!isSubClassCommand(command)); 1882234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten break; 1892234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 1902234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 1912234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // there is a non-idle state available to us; did the state change? 1922234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (current != previous) { 1932234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten onStateChange(); 1942234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#if 1 // FIXME shouldn't need this 1952234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // only process state change once 1962234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten previous = current; 1972234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#endif 1982234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 1992234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 2002234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // do work using current state here 2012234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten attemptedWrite = false; 2022234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten onWork(); 2032234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 2042234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // To be exactly periodic, compute the next sleep time based on current time. 2052234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // This code doesn't have long-term stability when the sink is non-blocking. 2062234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // FIXME To avoid drift, use the local audio clock or watch the sink's fill status. 2072234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten struct timespec newTs; 2082234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten int rc = clock_gettime(CLOCK_MONOTONIC, &newTs); 2092234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (rc == 0) { 2102234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten //logWriter->logTimestamp(newTs); 2112234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (oldTsValid) { 2122234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten time_t sec = newTs.tv_sec - oldTs.tv_sec; 2132234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten long nsec = newTs.tv_nsec - oldTs.tv_nsec; 2142234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ALOGE_IF(sec < 0 || (sec == 0 && nsec < 0), 2152234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten "clock_gettime(CLOCK_MONOTONIC) failed: was %ld.%09ld but now %ld.%09ld", 2162234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten oldTs.tv_sec, oldTs.tv_nsec, newTs.tv_sec, newTs.tv_nsec); 2172234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (nsec < 0) { 2182234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten --sec; 2192234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten nsec += 1000000000; 2202234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 2212234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // To avoid an initial underrun on fast tracks after exiting standby, 2222234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // do not start pulling data from tracks and mixing until warmup is complete. 2232234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // Warmup is considered complete after the earlier of: 2242234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // MIN_WARMUP_CYCLES write() attempts and last one blocks for at least warmupNs 2252234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // MAX_WARMUP_CYCLES write() attempts. 2262234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // This is overly conservative, but to get better accuracy requires a new HAL API. 2272234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (!isWarm && attemptedWrite) { 2282234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten measuredWarmupTs.tv_sec += sec; 2292234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten measuredWarmupTs.tv_nsec += nsec; 2302234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (measuredWarmupTs.tv_nsec >= 1000000000) { 2312234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten measuredWarmupTs.tv_sec++; 2322234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten measuredWarmupTs.tv_nsec -= 1000000000; 2332234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 2342234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ++warmupCycles; 2352234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if ((nsec > warmupNs && warmupCycles >= MIN_WARMUP_CYCLES) || 2362234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten (warmupCycles >= MAX_WARMUP_CYCLES)) { 2372234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten isWarm = true; 2382234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten dumpState->mMeasuredWarmupTs = measuredWarmupTs; 2392234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten dumpState->mWarmupCycles = warmupCycles; 2402234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 2412234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 2422234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten sleepNs = -1; 2432234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (isWarm) { 2442234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (sec > 0 || nsec > underrunNs) { 2452234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ATRACE_NAME("underrun"); 2462234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // FIXME only log occasionally 2472234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ALOGV("underrun: time since last cycle %d.%03ld sec", 2482234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten (int) sec, nsec / 1000000L); 2492234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten dumpState->mUnderruns++; 2502234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ignoreNextOverrun = true; 2512234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } else if (nsec < overrunNs) { 2522234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (ignoreNextOverrun) { 2532234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ignoreNextOverrun = false; 2542234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } else { 2552234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // FIXME only log occasionally 2562234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ALOGV("overrun: time since last cycle %d.%03ld sec", 2572234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten (int) sec, nsec / 1000000L); 2582234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten dumpState->mOverruns++; 2592234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 2602234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // This forces a minimum cycle time. It: 2612234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // - compensates for an audio HAL with jitter due to sample rate conversion 2622234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // - works with a variable buffer depth audio HAL that never pulls at a 2632234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // rate < than overrunNs per buffer. 2642234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // - recovers from overrun immediately after underrun 2652234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // It doesn't work with a non-blocking audio HAL. 2662234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten sleepNs = forceNs - nsec; 2672234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } else { 2682234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ignoreNextOverrun = false; 2692234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 2702234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 2712234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#ifdef FAST_MIXER_STATISTICS 2722234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (isWarm) { 2732234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // advance the FIFO queue bounds 2742234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten size_t i = bounds & (dumpState->mSamplingN - 1); 2752234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten bounds = (bounds & 0xFFFF0000) | ((bounds + 1) & 0xFFFF); 2762234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (full) { 2772234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten bounds += 0x10000; 2782234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } else if (!(bounds & (dumpState->mSamplingN - 1))) { 2792234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten full = true; 2802234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 2812234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // compute the delta value of clock_gettime(CLOCK_MONOTONIC) 2822234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten uint32_t monotonicNs = nsec; 2832234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (sec > 0 && sec < 4) { 2842234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten monotonicNs += sec * 1000000000; 2852234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 2862234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // compute raw CPU load = delta value of clock_gettime(CLOCK_THREAD_CPUTIME_ID) 2872234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten uint32_t loadNs = 0; 2882234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten struct timespec newLoad; 2892234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten rc = clock_gettime(CLOCK_THREAD_CPUTIME_ID, &newLoad); 2902234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (rc == 0) { 2912234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (oldLoadValid) { 2922234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten sec = newLoad.tv_sec - oldLoad.tv_sec; 2932234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten nsec = newLoad.tv_nsec - oldLoad.tv_nsec; 2942234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (nsec < 0) { 2952234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten --sec; 2962234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten nsec += 1000000000; 2972234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 2982234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten loadNs = nsec; 2992234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (sec > 0 && sec < 4) { 3002234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten loadNs += sec * 1000000000; 3012234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 3022234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } else { 3032234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // first time through the loop 3042234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten oldLoadValid = true; 3052234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 3062234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten oldLoad = newLoad; 3072234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 3082234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#ifdef CPU_FREQUENCY_STATISTICS 3092234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // get the absolute value of CPU clock frequency in kHz 3102234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten int cpuNum = sched_getcpu(); 3112234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten uint32_t kHz = tcu.getCpukHz(cpuNum); 3122234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten kHz = (kHz << 4) | (cpuNum & 0xF); 3132234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#endif 3142234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // save values in FIFO queues for dumpsys 3152234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // these stores #1, #2, #3 are not atomic with respect to each other, 3162234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // or with respect to store #4 below 3172234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten dumpState->mMonotonicNs[i] = monotonicNs; 3182234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten dumpState->mLoadNs[i] = loadNs; 3192234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#ifdef CPU_FREQUENCY_STATISTICS 3202234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten dumpState->mCpukHz[i] = kHz; 3212234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#endif 3222234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // this store #4 is not atomic with respect to stores #1, #2, #3 above, but 3232234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // the newest open & oldest closed halves are atomic with respect to each other 3242234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten dumpState->mBounds = bounds; 3252234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ATRACE_INT("cycle_ms", monotonicNs / 1000000); 3262234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ATRACE_INT("load_us", loadNs / 1000); 3272234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 3282234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#endif 3292234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } else { 3302234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // first time through the loop 3312234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten oldTsValid = true; 3322234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten sleepNs = periodNs; 3332234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ignoreNextOverrun = true; 3342234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 3352234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten oldTs = newTs; 3362234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } else { 3372234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // monotonic clock is broken 3382234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten oldTsValid = false; 3392234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten sleepNs = periodNs; 3402234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 3412234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 3422234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } // for (;;) 3432234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 3442234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // never return 'true'; Thread::_threadLoop() locks mutex which can result in priority inversion 3452234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten} 3462234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 3472234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten} // namespace android 348