blob: c1c7dd8f58ee575cdfbba7e1548f7f2b3e5c9cc0 [file] [log] [blame]
Glenn Kasten97b5d0d2012-03-23 18:54:19 -07001/*
2 * Copyright (C) 2012 The Android Open Source Project
3 *
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
7 *
8 * http://www.apache.org/licenses/LICENSE-2.0
9 *
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 */
16
Glenn Kastena3d26282012-11-30 07:57:43 -080017// <IMPORTANT_WARNING>
18// Design rules for threadLoop() are given in the comments at section "Fast mixer thread" of
19// StateQueue.h. In particular, avoid library and system calls except at well-known points.
20// The design rules are only for threadLoop(), and don't apply to FastMixerDumpState methods.
21// </IMPORTANT_WARNING>
22
Glenn Kasten97b5d0d2012-03-23 18:54:19 -070023#define LOG_TAG "FastMixer"
Glenn Kasten7f5d3352013-02-15 23:55:04 +000024//#define LOG_NDEBUG 0
Glenn Kasten97b5d0d2012-03-23 18:54:19 -070025
Alex Rayb3a83642012-11-30 19:42:28 -080026#define ATRACE_TAG ATRACE_TAG_AUDIO
Alex Ray371eb972012-11-30 11:11:54 -080027
Glenn Kasten153b9fe2013-07-15 11:23:36 -070028#include "Configuration.h"
Glenn Kasten97b5d0d2012-03-23 18:54:19 -070029#include <sys/atomics.h>
30#include <time.h>
31#include <utils/Log.h>
Glenn Kastend8e6fd32012-05-07 11:07:57 -070032#include <utils/Trace.h>
Glenn Kasten97b5d0d2012-03-23 18:54:19 -070033#include <system/audio.h>
34#ifdef FAST_MIXER_STATISTICS
35#include <cpustats/CentralTendencyStatistics.h>
Glenn Kasten0a14c4c2012-06-13 14:58:49 -070036#ifdef CPU_FREQUENCY_STATISTICS
Glenn Kasten42d45cf2012-05-02 10:34:47 -070037#include <cpustats/ThreadCpuUsage.h>
Glenn Kasten97b5d0d2012-03-23 18:54:19 -070038#endif
Glenn Kasten0a14c4c2012-06-13 14:58:49 -070039#endif
Glenn Kasten97b5d0d2012-03-23 18:54:19 -070040#include "AudioMixer.h"
41#include "FastMixer.h"
42
Glenn Kasten7fc97ba2013-07-16 17:18:58 -070043#define FCC_2 2 // fixed channel count assumption
44
Glenn Kasten97b5d0d2012-03-23 18:54:19 -070045namespace android {
46
Glenn Kasten22340022014-04-07 12:04:41 -070047/*static*/ const FastMixerState FastMixer::initial;
48
49FastMixer::FastMixer() : FastThread(),
50 slopNs(0),
51 // fastTrackNames
52 // generations
53 outputSink(NULL),
54 outputSinkGen(0),
55 mixer(NULL),
Andy Hung45d68d32014-05-23 21:13:31 -070056 mMixerBuffer(NULL),
57 mMixerBufferState(UNDEFINED),
Glenn Kasten22340022014-04-07 12:04:41 -070058 format(Format_Invalid),
59 sampleRate(0),
60 fastTracksGen(0),
61 totalNativeFramesWritten(0),
62 // timestamp
63 nativeFramesWrittenButNotPresented(0) // the = 0 is to silence the compiler
Glenn Kasten97b5d0d2012-03-23 18:54:19 -070064{
Glenn Kasten22340022014-04-07 12:04:41 -070065 // FIXME pass initial as parameter to base class constructor, and make it static local
66 previous = &initial;
67 current = &initial;
68
69 mDummyDumpState = &dummyDumpState;
70
Glenn Kasten97b5d0d2012-03-23 18:54:19 -070071 unsigned i;
72 for (i = 0; i < FastMixerState::kMaxFastTracks; ++i) {
73 fastTrackNames[i] = -1;
74 generations[i] = 0;
75 }
Glenn Kasten97b5d0d2012-03-23 18:54:19 -070076#ifdef FAST_MIXER_STATISTICS
Glenn Kasten22340022014-04-07 12:04:41 -070077 oldLoad.tv_sec = 0;
78 oldLoad.tv_nsec = 0;
Glenn Kasten97b5d0d2012-03-23 18:54:19 -070079#endif
Glenn Kasten22340022014-04-07 12:04:41 -070080}
81
82FastMixer::~FastMixer()
83{
84}
85
86FastMixerStateQueue* FastMixer::sq()
87{
88 return &mSQ;
89}
90
91const FastThreadState *FastMixer::poll()
92{
93 return mSQ.poll();
94}
95
96void FastMixer::setLog(NBLog::Writer *logWriter)
97{
98 if (mixer != NULL) {
99 mixer->setLog(logWriter);
100 }
101}
102
103void FastMixer::onIdle()
104{
105 preIdle = *(const FastMixerState *)current;
106 current = &preIdle;
107}
108
109void FastMixer::onExit()
110{
111 delete mixer;
Andy Hung45d68d32014-05-23 21:13:31 -0700112 delete[] mMixerBuffer;
Glenn Kasten22340022014-04-07 12:04:41 -0700113}
114
115bool FastMixer::isSubClassCommand(FastThreadState::Command command)
116{
117 switch ((FastMixerState::Command) command) {
118 case FastMixerState::MIX:
119 case FastMixerState::WRITE:
120 case FastMixerState::MIX_WRITE:
121 return true;
122 default:
123 return false;
124 }
125}
126
127void FastMixer::onStateChange()
128{
129 const FastMixerState * const current = (const FastMixerState *) this->current;
130 const FastMixerState * const previous = (const FastMixerState *) this->previous;
131 FastMixerDumpState * const dumpState = (FastMixerDumpState *) this->dumpState;
132 const size_t frameCount = current->mFrameCount;
133
134 // handle state change here, but since we want to diff the state,
135 // we're prepared for previous == &initial the first time through
136 unsigned previousTrackMask;
137
138 // check for change in output HAL configuration
139 NBAIO_Format previousFormat = format;
140 if (current->mOutputSinkGen != outputSinkGen) {
141 outputSink = current->mOutputSink;
142 outputSinkGen = current->mOutputSinkGen;
143 if (outputSink == NULL) {
144 format = Format_Invalid;
145 sampleRate = 0;
146 } else {
147 format = outputSink->format();
148 sampleRate = Format_sampleRate(format);
149 ALOG_ASSERT(Format_channelCount(format) == FCC_2);
150 }
151 dumpState->mSampleRate = sampleRate;
152 }
153
154 if ((!Format_isEqual(format, previousFormat)) || (frameCount != previous->mFrameCount)) {
155 // FIXME to avoid priority inversion, don't delete here
156 delete mixer;
157 mixer = NULL;
Andy Hung45d68d32014-05-23 21:13:31 -0700158 delete[] mMixerBuffer;
159 mMixerBuffer = NULL;
Glenn Kasten22340022014-04-07 12:04:41 -0700160 if (frameCount > 0 && sampleRate > 0) {
161 // FIXME new may block for unbounded time at internal mutex of the heap
162 // implementation; it would be better to have normal mixer allocate for us
163 // to avoid blocking here and to prevent possible priority inversion
164 mixer = new AudioMixer(frameCount, sampleRate, FastMixerState::kMaxFastTracks);
Andy Hung45d68d32014-05-23 21:13:31 -0700165 mMixerBuffer = new short[frameCount * FCC_2];
Glenn Kasten22340022014-04-07 12:04:41 -0700166 periodNs = (frameCount * 1000000000LL) / sampleRate; // 1.00
167 underrunNs = (frameCount * 1750000000LL) / sampleRate; // 1.75
168 overrunNs = (frameCount * 500000000LL) / sampleRate; // 0.50
169 forceNs = (frameCount * 950000000LL) / sampleRate; // 0.95
170 warmupNs = (frameCount * 500000000LL) / sampleRate; // 0.50
171 } else {
172 periodNs = 0;
173 underrunNs = 0;
174 overrunNs = 0;
175 forceNs = 0;
176 warmupNs = 0;
177 }
Andy Hung45d68d32014-05-23 21:13:31 -0700178 mMixerBufferState = UNDEFINED;
Glenn Kasten22340022014-04-07 12:04:41 -0700179#if !LOG_NDEBUG
180 for (unsigned i = 0; i < FastMixerState::kMaxFastTracks; ++i) {
181 fastTrackNames[i] = -1;
182 }
Glenn Kasten0a14c4c2012-06-13 14:58:49 -0700183#endif
Glenn Kasten22340022014-04-07 12:04:41 -0700184 // we need to reconfigure all active tracks
185 previousTrackMask = 0;
186 fastTracksGen = current->mFastTracksGen - 1;
187 dumpState->mFrameCount = frameCount;
188 } else {
189 previousTrackMask = previous->mTrackMask;
190 }
Glenn Kasten732845c2013-08-23 09:26:31 -0700191
Glenn Kasten22340022014-04-07 12:04:41 -0700192 // check for change in active track set
193 const unsigned currentTrackMask = current->mTrackMask;
194 dumpState->mTrackMask = currentTrackMask;
195 if (current->mFastTracksGen != fastTracksGen) {
Andy Hung45d68d32014-05-23 21:13:31 -0700196 ALOG_ASSERT(mMixerBuffer != NULL);
Glenn Kasten22340022014-04-07 12:04:41 -0700197 int name;
Glenn Kasten97b5d0d2012-03-23 18:54:19 -0700198
Glenn Kasten22340022014-04-07 12:04:41 -0700199 // process removed tracks first to avoid running out of track names
200 unsigned removedTracks = previousTrackMask & ~currentTrackMask;
201 while (removedTracks != 0) {
202 int i = __builtin_ctz(removedTracks);
203 removedTracks &= ~(1 << i);
204 const FastTrack* fastTrack = &current->mFastTracks[i];
205 ALOG_ASSERT(fastTrack->mBufferProvider == NULL);
Glenn Kastenab7d72f2013-02-27 09:05:28 -0800206 if (mixer != NULL) {
Glenn Kasten22340022014-04-07 12:04:41 -0700207 name = fastTrackNames[i];
Glenn Kasten97b5d0d2012-03-23 18:54:19 -0700208 ALOG_ASSERT(name >= 0);
Glenn Kasten22340022014-04-07 12:04:41 -0700209 mixer->deleteTrackName(name);
210 }
211#if !LOG_NDEBUG
212 fastTrackNames[i] = -1;
213#endif
214 // don't reset track dump state, since other side is ignoring it
215 generations[i] = fastTrack->mGeneration;
216 }
217
218 // now process added tracks
219 unsigned addedTracks = currentTrackMask & ~previousTrackMask;
220 while (addedTracks != 0) {
221 int i = __builtin_ctz(addedTracks);
222 addedTracks &= ~(1 << i);
223 const FastTrack* fastTrack = &current->mFastTracks[i];
224 AudioBufferProvider *bufferProvider = fastTrack->mBufferProvider;
225 ALOG_ASSERT(bufferProvider != NULL && fastTrackNames[i] == -1);
226 if (mixer != NULL) {
Andy Hunge8a1ced2014-05-09 15:02:21 -0700227 name = mixer->getTrackName(fastTrack->mChannelMask,
228 fastTrack->mFormat, AUDIO_SESSION_OUTPUT_MIX);
Glenn Kasten22340022014-04-07 12:04:41 -0700229 ALOG_ASSERT(name >= 0);
230 fastTrackNames[i] = name;
231 mixer->setBufferProvider(name, bufferProvider);
232 mixer->setParameter(name, AudioMixer::TRACK, AudioMixer::MAIN_BUFFER,
Andy Hung45d68d32014-05-23 21:13:31 -0700233 (void *) mMixerBuffer);
Glenn Kasten22340022014-04-07 12:04:41 -0700234 // newly allocated track names default to full scale volume
Andy Hungef7c7fb2014-05-12 16:51:41 -0700235 mixer->setParameter(name, AudioMixer::TRACK, AudioMixer::FORMAT,
236 (void *)(uintptr_t)fastTrack->mFormat);
Glenn Kasten22340022014-04-07 12:04:41 -0700237 mixer->enable(name);
238 }
239 generations[i] = fastTrack->mGeneration;
240 }
241
242 // finally process (potentially) modified tracks; these use the same slot
243 // but may have a different buffer provider or volume provider
244 unsigned modifiedTracks = currentTrackMask & previousTrackMask;
245 while (modifiedTracks != 0) {
246 int i = __builtin_ctz(modifiedTracks);
247 modifiedTracks &= ~(1 << i);
248 const FastTrack* fastTrack = &current->mFastTracks[i];
249 if (fastTrack->mGeneration != generations[i]) {
250 // this track was actually modified
251 AudioBufferProvider *bufferProvider = fastTrack->mBufferProvider;
252 ALOG_ASSERT(bufferProvider != NULL);
253 if (mixer != NULL) {
254 name = fastTrackNames[i];
255 ALOG_ASSERT(name >= 0);
256 mixer->setBufferProvider(name, bufferProvider);
257 if (fastTrack->mVolumeProvider == NULL) {
258 mixer->setParameter(name, AudioMixer::VOLUME, AudioMixer::VOLUME0,
259 (void *)0x1000);
260 mixer->setParameter(name, AudioMixer::VOLUME, AudioMixer::VOLUME1,
261 (void *)0x1000);
Glenn Kasten288ed212012-04-25 17:52:27 -0700262 }
Glenn Kasten22340022014-04-07 12:04:41 -0700263 mixer->setParameter(name, AudioMixer::RESAMPLE,
264 AudioMixer::REMOVE, NULL);
Andy Hungef7c7fb2014-05-12 16:51:41 -0700265 mixer->setParameter(name, AudioMixer::TRACK, AudioMixer::FORMAT,
266 (void *)(uintptr_t)fastTrack->mFormat);
Glenn Kasten22340022014-04-07 12:04:41 -0700267 mixer->setParameter(name, AudioMixer::TRACK, AudioMixer::CHANNEL_MASK,
268 (void *)(uintptr_t) fastTrack->mChannelMask);
269 // already enabled
270 }
271 generations[i] = fastTrack->mGeneration;
272 }
273 }
274
275 fastTracksGen = current->mFastTracksGen;
276
277 dumpState->mNumTracks = popcount(currentTrackMask);
278 }
279}
280
281void FastMixer::onWork()
282{
283 const FastMixerState * const current = (const FastMixerState *) this->current;
284 FastMixerDumpState * const dumpState = (FastMixerDumpState *) this->dumpState;
285 const FastMixerState::Command command = this->command;
286 const size_t frameCount = current->mFrameCount;
287
288 if ((command & FastMixerState::MIX) && (mixer != NULL) && isWarm) {
Andy Hungef7c7fb2014-05-12 16:51:41 -0700289 ALOG_ASSERT(mMixerBuffer != NULL);
Glenn Kasten22340022014-04-07 12:04:41 -0700290 // for each track, update volume and check for underrun
291 unsigned currentTrackMask = current->mTrackMask;
292 while (currentTrackMask != 0) {
293 int i = __builtin_ctz(currentTrackMask);
294 currentTrackMask &= ~(1 << i);
295 const FastTrack* fastTrack = &current->mFastTracks[i];
296
297 // Refresh the per-track timestamp
298 if (timestampStatus == NO_ERROR) {
299 uint32_t trackFramesWrittenButNotPresented =
300 nativeFramesWrittenButNotPresented;
301 uint32_t trackFramesWritten = fastTrack->mBufferProvider->framesReleased();
302 // Can't provide an AudioTimestamp before first frame presented,
303 // or during the brief 32-bit wraparound window
304 if (trackFramesWritten >= trackFramesWrittenButNotPresented) {
305 AudioTimestamp perTrackTimestamp;
306 perTrackTimestamp.mPosition =
307 trackFramesWritten - trackFramesWrittenButNotPresented;
308 perTrackTimestamp.mTime = timestamp.mTime;
309 fastTrack->mBufferProvider->onTimestamp(perTrackTimestamp);
310 }
311 }
312
313 int name = fastTrackNames[i];
314 ALOG_ASSERT(name >= 0);
315 if (fastTrack->mVolumeProvider != NULL) {
316 uint32_t vlr = fastTrack->mVolumeProvider->getVolumeLR();
317 mixer->setParameter(name, AudioMixer::VOLUME, AudioMixer::VOLUME0,
318 (void *)(uintptr_t)(vlr & 0xFFFF));
319 mixer->setParameter(name, AudioMixer::VOLUME, AudioMixer::VOLUME1,
320 (void *)(uintptr_t)(vlr >> 16));
321 }
322 // FIXME The current implementation of framesReady() for fast tracks
323 // takes a tryLock, which can block
324 // up to 1 ms. If enough active tracks all blocked in sequence, this would result
325 // in the overall fast mix cycle being delayed. Should use a non-blocking FIFO.
326 size_t framesReady = fastTrack->mBufferProvider->framesReady();
327 if (ATRACE_ENABLED()) {
328 // I wish we had formatted trace names
329 char traceName[16];
330 strcpy(traceName, "fRdy");
331 traceName[4] = i + (i < 10 ? '0' : 'A' - 10);
332 traceName[5] = '\0';
333 ATRACE_INT(traceName, framesReady);
334 }
335 FastTrackDump *ftDump = &dumpState->mTracks[i];
336 FastTrackUnderruns underruns = ftDump->mUnderruns;
337 if (framesReady < frameCount) {
338 if (framesReady == 0) {
339 underruns.mBitFields.mEmpty++;
340 underruns.mBitFields.mMostRecent = UNDERRUN_EMPTY;
341 mixer->disable(name);
Glenn Kasten09474df2012-05-10 14:48:07 -0700342 } else {
Glenn Kasten22340022014-04-07 12:04:41 -0700343 // allow mixing partial buffer
344 underruns.mBitFields.mPartial++;
345 underruns.mBitFields.mMostRecent = UNDERRUN_PARTIAL;
Glenn Kasten288ed212012-04-25 17:52:27 -0700346 mixer->enable(name);
347 }
Glenn Kasten97b5d0d2012-03-23 18:54:19 -0700348 } else {
Glenn Kasten22340022014-04-07 12:04:41 -0700349 underruns.mBitFields.mFull++;
350 underruns.mBitFields.mMostRecent = UNDERRUN_FULL;
351 mixer->enable(name);
Glenn Kasten97b5d0d2012-03-23 18:54:19 -0700352 }
Glenn Kasten22340022014-04-07 12:04:41 -0700353 ftDump->mUnderruns = underruns;
354 ftDump->mFramesReady = framesReady;
Glenn Kasten97b5d0d2012-03-23 18:54:19 -0700355 }
356
Glenn Kasten22340022014-04-07 12:04:41 -0700357 int64_t pts;
358 if (outputSink == NULL || (OK != outputSink->getNextWriteTimestamp(&pts))) {
359 pts = AudioBufferProvider::kInvalidPTS;
360 }
361
362 // process() is CPU-bound
363 mixer->process(pts);
Andy Hung45d68d32014-05-23 21:13:31 -0700364 mMixerBufferState = MIXED;
365 } else if (mMixerBufferState == MIXED) {
366 mMixerBufferState = UNDEFINED;
Glenn Kasten22340022014-04-07 12:04:41 -0700367 }
368 //bool didFullWrite = false; // dumpsys could display a count of partial writes
Andy Hung45d68d32014-05-23 21:13:31 -0700369 if ((command & FastMixerState::WRITE) && (outputSink != NULL) && (mMixerBuffer != NULL)) {
370 if (mMixerBufferState == UNDEFINED) {
371 memset(mMixerBuffer, 0, frameCount * FCC_2 * sizeof(short));
372 mMixerBufferState = ZEROED;
Glenn Kasten22340022014-04-07 12:04:41 -0700373 }
374 // if non-NULL, then duplicate write() to this non-blocking sink
375 NBAIO_Sink* teeSink;
376 if ((teeSink = current->mTeeSink) != NULL) {
Andy Hung45d68d32014-05-23 21:13:31 -0700377 (void) teeSink->write(mMixerBuffer, frameCount);
Glenn Kasten22340022014-04-07 12:04:41 -0700378 }
379 // FIXME write() is non-blocking and lock-free for a properly implemented NBAIO sink,
380 // but this code should be modified to handle both non-blocking and blocking sinks
381 dumpState->mWriteSequence++;
382 ATRACE_BEGIN("write");
Andy Hung45d68d32014-05-23 21:13:31 -0700383 ssize_t framesWritten = outputSink->write(mMixerBuffer, frameCount);
Glenn Kasten22340022014-04-07 12:04:41 -0700384 ATRACE_END();
385 dumpState->mWriteSequence++;
386 if (framesWritten >= 0) {
387 ALOG_ASSERT((size_t) framesWritten <= frameCount);
388 totalNativeFramesWritten += framesWritten;
389 dumpState->mFramesWritten = totalNativeFramesWritten;
390 //if ((size_t) framesWritten == frameCount) {
391 // didFullWrite = true;
392 //}
Glenn Kasten97b5d0d2012-03-23 18:54:19 -0700393 } else {
Glenn Kasten22340022014-04-07 12:04:41 -0700394 dumpState->mWriteErrors++;
Glenn Kasten97b5d0d2012-03-23 18:54:19 -0700395 }
Glenn Kasten22340022014-04-07 12:04:41 -0700396 attemptedWrite = true;
397 // FIXME count # of writes blocked excessively, CPU usage, etc. for dump
Glenn Kasten97b5d0d2012-03-23 18:54:19 -0700398
Glenn Kasten22340022014-04-07 12:04:41 -0700399 timestampStatus = outputSink->getTimestamp(timestamp);
400 if (timestampStatus == NO_ERROR) {
401 uint32_t totalNativeFramesPresented = timestamp.mPosition;
402 if (totalNativeFramesPresented <= totalNativeFramesWritten) {
403 nativeFramesWrittenButNotPresented =
404 totalNativeFramesWritten - totalNativeFramesPresented;
405 } else {
406 // HAL reported that more frames were presented than were written
407 timestampStatus = INVALID_OPERATION;
408 }
409 }
410 }
Glenn Kasten97b5d0d2012-03-23 18:54:19 -0700411}
412
Glenn Kasten4182c4e2013-07-15 14:45:07 -0700413FastMixerDumpState::FastMixerDumpState(
414#ifdef FAST_MIXER_STATISTICS
415 uint32_t samplingN
416#endif
Glenn Kasten22340022014-04-07 12:04:41 -0700417 ) : FastThreadDumpState(),
418 mWriteSequence(0), mFramesWritten(0),
419 mNumTracks(0), mWriteErrors(0),
420 mSampleRate(0), mFrameCount(0),
Glenn Kasten1295bb4d2012-05-31 07:43:43 -0700421 mTrackMask(0)
Glenn Kasten97b5d0d2012-03-23 18:54:19 -0700422{
Glenn Kasten153b9fe2013-07-15 11:23:36 -0700423#ifdef FAST_MIXER_STATISTICS
Glenn Kasten4182c4e2013-07-15 14:45:07 -0700424 increaseSamplingN(samplingN);
Glenn Kasten153b9fe2013-07-15 11:23:36 -0700425#endif
Glenn Kasten97b5d0d2012-03-23 18:54:19 -0700426}
427
Glenn Kasten4182c4e2013-07-15 14:45:07 -0700428#ifdef FAST_MIXER_STATISTICS
429void FastMixerDumpState::increaseSamplingN(uint32_t samplingN)
430{
431 if (samplingN <= mSamplingN || samplingN > kSamplingN || roundup(samplingN) != samplingN) {
432 return;
433 }
434 uint32_t additional = samplingN - mSamplingN;
435 // sample arrays aren't accessed atomically with respect to the bounds,
436 // so clearing reduces chance for dumpsys to read random uninitialized samples
437 memset(&mMonotonicNs[mSamplingN], 0, sizeof(mMonotonicNs[0]) * additional);
438 memset(&mLoadNs[mSamplingN], 0, sizeof(mLoadNs[0]) * additional);
439#ifdef CPU_FREQUENCY_STATISTICS
440 memset(&mCpukHz[mSamplingN], 0, sizeof(mCpukHz[0]) * additional);
441#endif
442 mSamplingN = samplingN;
443}
444#endif
445
Glenn Kasten97b5d0d2012-03-23 18:54:19 -0700446FastMixerDumpState::~FastMixerDumpState()
447{
448}
449
Glenn Kasten1ab212cf2012-09-07 12:58:38 -0700450// helper function called by qsort()
451static int compare_uint32_t(const void *pa, const void *pb)
452{
453 uint32_t a = *(const uint32_t *)pa;
454 uint32_t b = *(const uint32_t *)pb;
455 if (a < b) {
456 return -1;
457 } else if (a > b) {
458 return 1;
459 } else {
460 return 0;
461 }
462}
463
Glenn Kasten4182c4e2013-07-15 14:45:07 -0700464void FastMixerDumpState::dump(int fd) const
Glenn Kasten97b5d0d2012-03-23 18:54:19 -0700465{
Glenn Kasten868c0ab2012-06-13 14:59:17 -0700466 if (mCommand == FastMixerState::INITIAL) {
Marco Nelissenb2208842014-02-07 14:00:50 -0800467 fdprintf(fd, " FastMixer not initialized\n");
Glenn Kasten868c0ab2012-06-13 14:59:17 -0700468 return;
469 }
Glenn Kasten97b5d0d2012-03-23 18:54:19 -0700470#define COMMAND_MAX 32
471 char string[COMMAND_MAX];
472 switch (mCommand) {
473 case FastMixerState::INITIAL:
474 strcpy(string, "INITIAL");
475 break;
476 case FastMixerState::HOT_IDLE:
477 strcpy(string, "HOT_IDLE");
478 break;
479 case FastMixerState::COLD_IDLE:
480 strcpy(string, "COLD_IDLE");
481 break;
482 case FastMixerState::EXIT:
483 strcpy(string, "EXIT");
484 break;
485 case FastMixerState::MIX:
486 strcpy(string, "MIX");
487 break;
488 case FastMixerState::WRITE:
489 strcpy(string, "WRITE");
490 break;
491 case FastMixerState::MIX_WRITE:
492 strcpy(string, "MIX_WRITE");
493 break;
494 default:
495 snprintf(string, COMMAND_MAX, "%d", mCommand);
496 break;
497 }
Glenn Kasten42d45cf2012-05-02 10:34:47 -0700498 double measuredWarmupMs = (mMeasuredWarmupTs.tv_sec * 1000.0) +
Glenn Kasten288ed212012-04-25 17:52:27 -0700499 (mMeasuredWarmupTs.tv_nsec / 1000000.0);
Glenn Kasten42d45cf2012-05-02 10:34:47 -0700500 double mixPeriodSec = (double) mFrameCount / (double) mSampleRate;
Marco Nelissenb2208842014-02-07 14:00:50 -0800501 fdprintf(fd, " FastMixer command=%s writeSequence=%u framesWritten=%u\n"
502 " numTracks=%u writeErrors=%u underruns=%u overruns=%u\n"
Narayan Kamath1d6fa7a2014-02-11 13:47:53 +0000503 " sampleRate=%u frameCount=%zu measuredWarmup=%.3g ms, warmupCycles=%u\n"
Marco Nelissenb2208842014-02-07 14:00:50 -0800504 " mixPeriod=%.2f ms\n",
Glenn Kasten97b5d0d2012-03-23 18:54:19 -0700505 string, mWriteSequence, mFramesWritten,
Glenn Kasten21e8c502012-04-12 09:39:42 -0700506 mNumTracks, mWriteErrors, mUnderruns, mOverruns,
Glenn Kasten42d45cf2012-05-02 10:34:47 -0700507 mSampleRate, mFrameCount, measuredWarmupMs, mWarmupCycles,
508 mixPeriodSec * 1e3);
Glenn Kasten97b5d0d2012-03-23 18:54:19 -0700509#ifdef FAST_MIXER_STATISTICS
Glenn Kasten42d45cf2012-05-02 10:34:47 -0700510 // find the interval of valid samples
511 uint32_t bounds = mBounds;
512 uint32_t newestOpen = bounds & 0xFFFF;
513 uint32_t oldestClosed = bounds >> 16;
514 uint32_t n = (newestOpen - oldestClosed) & 0xFFFF;
Glenn Kasten4182c4e2013-07-15 14:45:07 -0700515 if (n > mSamplingN) {
Glenn Kasten42d45cf2012-05-02 10:34:47 -0700516 ALOGE("too many samples %u", n);
Glenn Kasten4182c4e2013-07-15 14:45:07 -0700517 n = mSamplingN;
Glenn Kasten42d45cf2012-05-02 10:34:47 -0700518 }
519 // statistics for monotonic (wall clock) time, thread raw CPU load in time, CPU clock frequency,
520 // and adjusted CPU load in MHz normalized for CPU clock frequency
Glenn Kasten0a14c4c2012-06-13 14:58:49 -0700521 CentralTendencyStatistics wall, loadNs;
522#ifdef CPU_FREQUENCY_STATISTICS
523 CentralTendencyStatistics kHz, loadMHz;
Glenn Kasten42d45cf2012-05-02 10:34:47 -0700524 uint32_t previousCpukHz = 0;
Glenn Kasten0a14c4c2012-06-13 14:58:49 -0700525#endif
Glenn Kasten1ab212cf2012-09-07 12:58:38 -0700526 // Assuming a normal distribution for cycle times, three standard deviations on either side of
527 // the mean account for 99.73% of the population. So if we take each tail to be 1/1000 of the
528 // sample set, we get 99.8% combined, or close to three standard deviations.
529 static const uint32_t kTailDenominator = 1000;
530 uint32_t *tail = n >= kTailDenominator ? new uint32_t[n] : NULL;
Glenn Kasten42d45cf2012-05-02 10:34:47 -0700531 // loop over all the samples
Glenn Kasten1ab212cf2012-09-07 12:58:38 -0700532 for (uint32_t j = 0; j < n; ++j) {
Glenn Kasten4182c4e2013-07-15 14:45:07 -0700533 size_t i = oldestClosed++ & (mSamplingN - 1);
Glenn Kasten42d45cf2012-05-02 10:34:47 -0700534 uint32_t wallNs = mMonotonicNs[i];
Glenn Kasten1ab212cf2012-09-07 12:58:38 -0700535 if (tail != NULL) {
536 tail[j] = wallNs;
537 }
Glenn Kasten42d45cf2012-05-02 10:34:47 -0700538 wall.sample(wallNs);
539 uint32_t sampleLoadNs = mLoadNs[i];
Glenn Kasten42d45cf2012-05-02 10:34:47 -0700540 loadNs.sample(sampleLoadNs);
Glenn Kasten0a14c4c2012-06-13 14:58:49 -0700541#ifdef CPU_FREQUENCY_STATISTICS
542 uint32_t sampleCpukHz = mCpukHz[i];
Glenn Kastenc059bd42012-05-14 17:41:09 -0700543 // skip bad kHz samples
544 if ((sampleCpukHz & ~0xF) != 0) {
545 kHz.sample(sampleCpukHz >> 4);
546 if (sampleCpukHz == previousCpukHz) {
547 double megacycles = (double) sampleLoadNs * (double) (sampleCpukHz >> 4) * 1e-12;
548 double adjMHz = megacycles / mixPeriodSec; // _not_ wallNs * 1e9
549 loadMHz.sample(adjMHz);
550 }
Glenn Kasten42d45cf2012-05-02 10:34:47 -0700551 }
552 previousCpukHz = sampleCpukHz;
Glenn Kasten0a14c4c2012-06-13 14:58:49 -0700553#endif
Glenn Kasten42d45cf2012-05-02 10:34:47 -0700554 }
Marco Nelissenb2208842014-02-07 14:00:50 -0800555 if (n) {
556 fdprintf(fd, " Simple moving statistics over last %.1f seconds:\n",
557 wall.n() * mixPeriodSec);
558 fdprintf(fd, " wall clock time in ms per mix cycle:\n"
559 " mean=%.2f min=%.2f max=%.2f stddev=%.2f\n",
560 wall.mean()*1e-6, wall.minimum()*1e-6, wall.maximum()*1e-6,
561 wall.stddev()*1e-6);
562 fdprintf(fd, " raw CPU load in us per mix cycle:\n"
563 " mean=%.0f min=%.0f max=%.0f stddev=%.0f\n",
564 loadNs.mean()*1e-3, loadNs.minimum()*1e-3, loadNs.maximum()*1e-3,
565 loadNs.stddev()*1e-3);
566 } else {
567 fdprintf(fd, " No FastMixer statistics available currently\n");
568 }
Glenn Kasten0a14c4c2012-06-13 14:58:49 -0700569#ifdef CPU_FREQUENCY_STATISTICS
Glenn Kasten42d45cf2012-05-02 10:34:47 -0700570 fdprintf(fd, " CPU clock frequency in MHz:\n"
571 " mean=%.0f min=%.0f max=%.0f stddev=%.0f\n",
572 kHz.mean()*1e-3, kHz.minimum()*1e-3, kHz.maximum()*1e-3, kHz.stddev()*1e-3);
573 fdprintf(fd, " adjusted CPU load in MHz (i.e. normalized for CPU clock frequency):\n"
574 " mean=%.1f min=%.1f max=%.1f stddev=%.1f\n",
575 loadMHz.mean(), loadMHz.minimum(), loadMHz.maximum(), loadMHz.stddev());
Glenn Kasten97b5d0d2012-03-23 18:54:19 -0700576#endif
Glenn Kasten1ab212cf2012-09-07 12:58:38 -0700577 if (tail != NULL) {
578 qsort(tail, n, sizeof(uint32_t), compare_uint32_t);
579 // assume same number of tail samples on each side, left and right
580 uint32_t count = n / kTailDenominator;
581 CentralTendencyStatistics left, right;
582 for (uint32_t i = 0; i < count; ++i) {
583 left.sample(tail[i]);
584 right.sample(tail[n - (i + 1)]);
585 }
Marco Nelissenb2208842014-02-07 14:00:50 -0800586 fdprintf(fd, " Distribution of mix cycle times in ms for the tails (> ~3 stddev outliers):\n"
587 " left tail: mean=%.2f min=%.2f max=%.2f stddev=%.2f\n"
588 " right tail: mean=%.2f min=%.2f max=%.2f stddev=%.2f\n",
Glenn Kasten1ab212cf2012-09-07 12:58:38 -0700589 left.mean()*1e-6, left.minimum()*1e-6, left.maximum()*1e-6, left.stddev()*1e-6,
590 right.mean()*1e-6, right.minimum()*1e-6, right.maximum()*1e-6,
591 right.stddev()*1e-6);
592 delete[] tail;
593 }
Glenn Kasten0a14c4c2012-06-13 14:58:49 -0700594#endif
Glenn Kasten1295bb4d2012-05-31 07:43:43 -0700595 // The active track mask and track states are updated non-atomically.
596 // So if we relied on isActive to decide whether to display,
597 // then we might display an obsolete track or omit an active track.
598 // Instead we always display all tracks, with an indication
599 // of whether we think the track is active.
600 uint32_t trackMask = mTrackMask;
Marco Nelissenb2208842014-02-07 14:00:50 -0800601 fdprintf(fd, " Fast tracks: kMaxFastTracks=%u activeMask=%#x\n",
Glenn Kasten1295bb4d2012-05-31 07:43:43 -0700602 FastMixerState::kMaxFastTracks, trackMask);
Marco Nelissenb2208842014-02-07 14:00:50 -0800603 fdprintf(fd, " Index Active Full Partial Empty Recent Ready\n");
Glenn Kasten1295bb4d2012-05-31 07:43:43 -0700604 for (uint32_t i = 0; i < FastMixerState::kMaxFastTracks; ++i, trackMask >>= 1) {
605 bool isActive = trackMask & 1;
606 const FastTrackDump *ftDump = &mTracks[i];
607 const FastTrackUnderruns& underruns = ftDump->mUnderruns;
608 const char *mostRecent;
609 switch (underruns.mBitFields.mMostRecent) {
610 case UNDERRUN_FULL:
611 mostRecent = "full";
612 break;
613 case UNDERRUN_PARTIAL:
614 mostRecent = "partial";
615 break;
616 case UNDERRUN_EMPTY:
617 mostRecent = "empty";
618 break;
619 default:
620 mostRecent = "?";
621 break;
622 }
Narayan Kamath1d6fa7a2014-02-11 13:47:53 +0000623 fdprintf(fd, " %5u %6s %4u %7u %5u %7s %5zu\n", i, isActive ? "yes" : "no",
Glenn Kasten1295bb4d2012-05-31 07:43:43 -0700624 (underruns.mBitFields.mFull) & UNDERRUN_MASK,
625 (underruns.mBitFields.mPartial) & UNDERRUN_MASK,
626 (underruns.mBitFields.mEmpty) & UNDERRUN_MASK,
627 mostRecent, ftDump->mFramesReady);
628 }
Glenn Kasten97b5d0d2012-03-23 18:54:19 -0700629}
630
631} // namespace android