FastThread.cpp revision 05d19b08f3affa6fa8407e779f67e7ad1c1ca84f
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> 2505d19b08f3affa6fa8407e779f67e7ad1c1ca84fMathias Agopian#include <cutils/atomic.h> 262234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#include <utils/Log.h> 272234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#include <utils/Trace.h> 282234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#include "FastThread.h" 29045ee7ea3e42b8657869d81c917feed5fb0c2b4aGlenn Kasten#include "FastThreadDumpState.h" 302234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 312234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#define FAST_DEFAULT_NS 999999999L // ~1 sec: default time to sleep 322234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#define FAST_HOT_IDLE_NS 1000000L // 1 ms: time to sleep while hot idling 33d2123e631834a887c2d8600c3ac43dda02d47cb9Glenn Kasten#define MIN_WARMUP_CYCLES 2 // minimum number of consecutive in-range loop cycles 34d2123e631834a887c2d8600c3ac43dda02d47cb9Glenn Kasten // to wait for warmup 352234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#define MAX_WARMUP_CYCLES 10 // maximum number of loop cycles to wait for warmup 362234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 372234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kastennamespace android { 382234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 39f9715e43ea73361321663514c44129c939c5db2fGlenn KastenFastThread::FastThread(const char *cycleMs, const char *loadUs) : Thread(false /*canCallJava*/), 40e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten // re-initialized to &sInitial by subclass constructor 41e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mPrevious(NULL), mCurrent(NULL), 42e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten /* mOldTs({0, 0}), */ 43e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mOldTsValid(false), 44e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mSleepNs(-1), 45e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mPeriodNs(0), 46e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mUnderrunNs(0), 47e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mOverrunNs(0), 48e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mForceNs(0), 49e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mWarmupNsMin(0), 50e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mWarmupNsMax(LONG_MAX), 51e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten // re-initialized to &mDummySubclassDumpState by subclass constructor 522234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten mDummyDumpState(NULL), 53e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mDumpState(NULL), 54e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mIgnoreNextOverrun(true), 55214b406c813e5baca3e4b5cdc1d986de35f09bbbGlenn Kasten#ifdef FAST_THREAD_STATISTICS 56e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten // mOldLoad 57e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mOldLoadValid(false), 58e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mBounds(0), 59e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mFull(false), 60e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten // mTcu 612234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#endif 62e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mColdGen(0), 63e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mIsWarm(false), 64e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten /* mMeasuredWarmupTs({0, 0}), */ 65e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mWarmupCycles(0), 66e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mWarmupConsecutiveInRangeCycles(0), 67e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten // mDummyLogWriter 68e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mLogWriter(&mDummyLogWriter), 69e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mTimestampStatus(INVALID_OPERATION), 702234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 71e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mCommand(FastThreadState::INITIAL), 722234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#if 0 732234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten frameCount(0), 742234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#endif 75e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mAttemptedWrite(false) 76f9715e43ea73361321663514c44129c939c5db2fGlenn Kasten // mCycleMs(cycleMs) 77f9715e43ea73361321663514c44129c939c5db2fGlenn Kasten // mLoadUs(loadUs) 782234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten{ 79e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mOldTs.tv_sec = 0; 80e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mOldTs.tv_nsec = 0; 81e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMeasuredWarmupTs.tv_sec = 0; 82e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMeasuredWarmupTs.tv_nsec = 0; 83f9715e43ea73361321663514c44129c939c5db2fGlenn Kasten strlcpy(mCycleMs, cycleMs, sizeof(mCycleMs)); 84f9715e43ea73361321663514c44129c939c5db2fGlenn Kasten strlcpy(mLoadUs, loadUs, sizeof(mLoadUs)); 852234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten} 862234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 872234002b0710c8db73f82d397cb945cd541c6bbbGlenn KastenFastThread::~FastThread() 882234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten{ 892234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten} 902234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 912234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kastenbool FastThread::threadLoop() 922234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten{ 932234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten for (;;) { 942234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 952234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // either nanosleep, sched_yield, or busy wait 96e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if (mSleepNs >= 0) { 97e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if (mSleepNs > 0) { 98e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten ALOG_ASSERT(mSleepNs < 1000000000); 99e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten const struct timespec req = {0, mSleepNs}; 1002234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten nanosleep(&req, NULL); 1012234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } else { 1022234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten sched_yield(); 1032234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 1042234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 1052234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // default to long sleep for next cycle 106e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mSleepNs = FAST_DEFAULT_NS; 1072234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 1082234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // poll for state change 1092234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten const FastThreadState *next = poll(); 1102234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (next == NULL) { 1112234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // continue to use the default initial state until a real state is available 112e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten // FIXME &sInitial not available, should save address earlier 113e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten //ALOG_ASSERT(mCurrent == &sInitial && previous == &sInitial); 114e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten next = mCurrent; 1152234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 1162234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 117e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mCommand = next->mCommand; 118e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if (next != mCurrent) { 1192234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 1202234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // As soon as possible of learning of a new dump area, start using it 121e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mDumpState = next->mDumpState != NULL ? next->mDumpState : mDummyDumpState; 122e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mLogWriter = next->mNBLogWriter != NULL ? next->mNBLogWriter : &mDummyLogWriter; 123e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten setLog(mLogWriter); 1242234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 1252234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // We want to always have a valid reference to the previous (non-idle) state. 1262234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // However, the state queue only guarantees access to current and previous states. 1272234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // So when there is a transition from a non-idle state into an idle state, we make a 1282234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // copy of the last known non-idle state so it is still available on return from idle. 1292234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // The possible transitions are: 1302234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // non-idle -> non-idle update previous from current in-place 1312234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // non-idle -> idle update previous from copy of current 1322234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // idle -> idle don't update previous 1332234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // idle -> non-idle don't update previous 134e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if (!(mCurrent->mCommand & FastThreadState::IDLE)) { 135e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if (mCommand & FastThreadState::IDLE) { 1362234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten onIdle(); 137e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mOldTsValid = false; 138214b406c813e5baca3e4b5cdc1d986de35f09bbbGlenn Kasten#ifdef FAST_THREAD_STATISTICS 139e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mOldLoadValid = false; 1402234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#endif 141e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mIgnoreNextOverrun = true; 1422234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 143e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mPrevious = mCurrent; 1442234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 145e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mCurrent = next; 1462234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 1472234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#if !LOG_NDEBUG 1482234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten next = NULL; // not referenced again 1492234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#endif 1502234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 151e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mDumpState->mCommand = mCommand; 1522234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 153e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten // FIXME what does this comment mean? 1542234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // << current, previous, command, dumpState >> 1552234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 156e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten switch (mCommand) { 1572234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten case FastThreadState::INITIAL: 1582234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten case FastThreadState::HOT_IDLE: 159e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mSleepNs = FAST_HOT_IDLE_NS; 1602234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten continue; 1612234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten case FastThreadState::COLD_IDLE: 1622234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // only perform a cold idle command once 1632234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // FIXME consider checking previous state and only perform if previous != COLD_IDLE 164e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if (mCurrent->mColdGen != mColdGen) { 165e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten int32_t *coldFutexAddr = mCurrent->mColdFutexAddr; 1662234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ALOG_ASSERT(coldFutexAddr != NULL); 1672234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten int32_t old = android_atomic_dec(coldFutexAddr); 1682234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (old <= 0) { 169e348c5b72ad889389c7c1c900c121f0fbee221b5Elliott Hughes syscall(__NR_futex, coldFutexAddr, FUTEX_WAIT_PRIVATE, old - 1, NULL); 1702234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 1718255ba7b40774b2b8868482f1a302db3ae98e905Glenn Kasten int policy = sched_getscheduler(0) & ~SCHED_RESET_ON_FORK; 1722234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (!(policy == SCHED_FIFO || policy == SCHED_RR)) { 1732234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ALOGE("did not receive expected priority boost"); 1742234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 1752234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // This may be overly conservative; there could be times that the normal mixer 1762234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // requests such a brief cold idle that it doesn't require resetting this flag. 177e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mIsWarm = false; 178e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMeasuredWarmupTs.tv_sec = 0; 179e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMeasuredWarmupTs.tv_nsec = 0; 180e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mWarmupCycles = 0; 181e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mWarmupConsecutiveInRangeCycles = 0; 182e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mSleepNs = -1; 183e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mColdGen = mCurrent->mColdGen; 184214b406c813e5baca3e4b5cdc1d986de35f09bbbGlenn Kasten#ifdef FAST_THREAD_STATISTICS 185e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mBounds = 0; 186e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mFull = false; 1872234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#endif 188e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mOldTsValid = !clock_gettime(CLOCK_MONOTONIC, &mOldTs); 189e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mTimestampStatus = INVALID_OPERATION; 1902234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } else { 191e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mSleepNs = FAST_HOT_IDLE_NS; 1922234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 1932234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten continue; 1942234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten case FastThreadState::EXIT: 1952234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten onExit(); 1962234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten return false; 1972234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten default: 198e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten LOG_ALWAYS_FATAL_IF(!isSubClassCommand(mCommand)); 1992234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten break; 2002234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 2012234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 2022234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // there is a non-idle state available to us; did the state change? 203e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if (mCurrent != mPrevious) { 2042234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten onStateChange(); 2052234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#if 1 // FIXME shouldn't need this 2062234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // only process state change once 207e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mPrevious = mCurrent; 2082234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#endif 2092234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 2102234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 2112234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // do work using current state here 212e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mAttemptedWrite = false; 2132234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten onWork(); 2142234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 2152234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // To be exactly periodic, compute the next sleep time based on current time. 2162234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // This code doesn't have long-term stability when the sink is non-blocking. 2172234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // FIXME To avoid drift, use the local audio clock or watch the sink's fill status. 2182234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten struct timespec newTs; 2192234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten int rc = clock_gettime(CLOCK_MONOTONIC, &newTs); 2202234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (rc == 0) { 221e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten //mLogWriter->logTimestamp(newTs); 222e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if (mOldTsValid) { 223e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten time_t sec = newTs.tv_sec - mOldTs.tv_sec; 224e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten long nsec = newTs.tv_nsec - mOldTs.tv_nsec; 2252234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ALOGE_IF(sec < 0 || (sec == 0 && nsec < 0), 2262234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten "clock_gettime(CLOCK_MONOTONIC) failed: was %ld.%09ld but now %ld.%09ld", 227e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mOldTs.tv_sec, mOldTs.tv_nsec, newTs.tv_sec, newTs.tv_nsec); 2282234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (nsec < 0) { 2292234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten --sec; 2302234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten nsec += 1000000000; 2312234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 2322234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // To avoid an initial underrun on fast tracks after exiting standby, 2332234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // do not start pulling data from tracks and mixing until warmup is complete. 2342234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // Warmup is considered complete after the earlier of: 235d2123e631834a887c2d8600c3ac43dda02d47cb9Glenn Kasten // MIN_WARMUP_CYCLES consecutive in-range write() attempts, 236e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten // where "in-range" means mWarmupNsMin <= cycle time <= mWarmupNsMax 2372234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // MAX_WARMUP_CYCLES write() attempts. 2382234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // This is overly conservative, but to get better accuracy requires a new HAL API. 239e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if (!mIsWarm && mAttemptedWrite) { 240e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMeasuredWarmupTs.tv_sec += sec; 241e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMeasuredWarmupTs.tv_nsec += nsec; 242e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if (mMeasuredWarmupTs.tv_nsec >= 1000000000) { 243e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMeasuredWarmupTs.tv_sec++; 244e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMeasuredWarmupTs.tv_nsec -= 1000000000; 2452234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 246e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten ++mWarmupCycles; 247e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if (mWarmupNsMin <= nsec && nsec <= mWarmupNsMax) { 248e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten ALOGV("warmup cycle %d in range: %.03f ms", mWarmupCycles, nsec * 1e-9); 249e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten ++mWarmupConsecutiveInRangeCycles; 250d2123e631834a887c2d8600c3ac43dda02d47cb9Glenn Kasten } else { 251e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten ALOGV("warmup cycle %d out of range: %.03f ms", mWarmupCycles, nsec * 1e-9); 252e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mWarmupConsecutiveInRangeCycles = 0; 253d2123e631834a887c2d8600c3ac43dda02d47cb9Glenn Kasten } 254e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if ((mWarmupConsecutiveInRangeCycles >= MIN_WARMUP_CYCLES) || 255e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten (mWarmupCycles >= MAX_WARMUP_CYCLES)) { 256e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mIsWarm = true; 257e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mDumpState->mMeasuredWarmupTs = mMeasuredWarmupTs; 258e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mDumpState->mWarmupCycles = mWarmupCycles; 2592234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 2602234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 261e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mSleepNs = -1; 262e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if (mIsWarm) { 263e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if (sec > 0 || nsec > mUnderrunNs) { 2642234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ATRACE_NAME("underrun"); 2652234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // FIXME only log occasionally 2662234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ALOGV("underrun: time since last cycle %d.%03ld sec", 2672234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten (int) sec, nsec / 1000000L); 268e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mDumpState->mUnderruns++; 269e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mIgnoreNextOverrun = true; 270e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten } else if (nsec < mOverrunNs) { 271e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if (mIgnoreNextOverrun) { 272e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mIgnoreNextOverrun = false; 2732234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } else { 2742234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // FIXME only log occasionally 2752234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ALOGV("overrun: time since last cycle %d.%03ld sec", 2762234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten (int) sec, nsec / 1000000L); 277e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mDumpState->mOverruns++; 2782234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 2792234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // This forces a minimum cycle time. It: 2802234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // - compensates for an audio HAL with jitter due to sample rate conversion 2812234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // - works with a variable buffer depth audio HAL that never pulls at a 282e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten // rate < than mOverrunNs per buffer. 2832234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // - recovers from overrun immediately after underrun 2842234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // It doesn't work with a non-blocking audio HAL. 285e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mSleepNs = mForceNs - nsec; 2862234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } else { 287e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mIgnoreNextOverrun = false; 2882234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 2892234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 290214b406c813e5baca3e4b5cdc1d986de35f09bbbGlenn Kasten#ifdef FAST_THREAD_STATISTICS 291e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if (mIsWarm) { 2922234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // advance the FIFO queue bounds 293e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten size_t i = mBounds & (mDumpState->mSamplingN - 1); 294e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mBounds = (mBounds & 0xFFFF0000) | ((mBounds + 1) & 0xFFFF); 295e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if (mFull) { 296e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mBounds += 0x10000; 297e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten } else if (!(mBounds & (mDumpState->mSamplingN - 1))) { 298e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mFull = true; 2992234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 3002234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // compute the delta value of clock_gettime(CLOCK_MONOTONIC) 3012234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten uint32_t monotonicNs = nsec; 3022234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (sec > 0 && sec < 4) { 3032234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten monotonicNs += sec * 1000000000; 3042234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 3052234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // compute raw CPU load = delta value of clock_gettime(CLOCK_THREAD_CPUTIME_ID) 3062234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten uint32_t loadNs = 0; 3072234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten struct timespec newLoad; 3082234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten rc = clock_gettime(CLOCK_THREAD_CPUTIME_ID, &newLoad); 3092234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (rc == 0) { 310e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if (mOldLoadValid) { 311e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten sec = newLoad.tv_sec - mOldLoad.tv_sec; 312e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten nsec = newLoad.tv_nsec - mOldLoad.tv_nsec; 3132234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (nsec < 0) { 3142234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten --sec; 3152234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten nsec += 1000000000; 3162234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 3172234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten loadNs = nsec; 3182234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (sec > 0 && sec < 4) { 3192234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten loadNs += sec * 1000000000; 3202234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 3212234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } else { 3222234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // first time through the loop 323e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mOldLoadValid = true; 3242234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 325e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mOldLoad = newLoad; 3262234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 3272234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#ifdef CPU_FREQUENCY_STATISTICS 3282234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // get the absolute value of CPU clock frequency in kHz 3292234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten int cpuNum = sched_getcpu(); 330e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten uint32_t kHz = mTcu.getCpukHz(cpuNum); 3312234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten kHz = (kHz << 4) | (cpuNum & 0xF); 3322234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#endif 3332234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // save values in FIFO queues for dumpsys 3342234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // these stores #1, #2, #3 are not atomic with respect to each other, 3352234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // or with respect to store #4 below 336e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mDumpState->mMonotonicNs[i] = monotonicNs; 337e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mDumpState->mLoadNs[i] = loadNs; 3382234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#ifdef CPU_FREQUENCY_STATISTICS 339e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mDumpState->mCpukHz[i] = kHz; 3402234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#endif 3412234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // this store #4 is not atomic with respect to stores #1, #2, #3 above, but 3422234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // the newest open & oldest closed halves are atomic with respect to each other 343e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mDumpState->mBounds = mBounds; 344f9715e43ea73361321663514c44129c939c5db2fGlenn Kasten ATRACE_INT(mCycleMs, monotonicNs / 1000000); 345f9715e43ea73361321663514c44129c939c5db2fGlenn Kasten ATRACE_INT(mLoadUs, loadNs / 1000); 3462234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 3472234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten#endif 3482234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } else { 3492234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // first time through the loop 350e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mOldTsValid = true; 351e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mSleepNs = mPeriodNs; 352e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mIgnoreNextOverrun = true; 3532234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 354e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mOldTs = newTs; 3552234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } else { 3562234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // monotonic clock is broken 357e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mOldTsValid = false; 358e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mSleepNs = mPeriodNs; 3592234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 3602234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 3612234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } // for (;;) 3622234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 3632234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // never return 'true'; Thread::_threadLoop() locks mutex which can result in priority inversion 3642234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten} 3652234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 3662234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten} // namespace android 367