RecordTracks.h revision 97a893eb34f8687485c88eaf15917974a203f20b
1/* 2** 3** Copyright 2012, The Android Open Source Project 4** 5** Licensed under the Apache License, Version 2.0 (the "License"); 6** you may not use this file except in compliance with the License. 7** You may obtain a copy of the License at 8** 9** http://www.apache.org/licenses/LICENSE-2.0 10** 11** Unless required by applicable law or agreed to in writing, software 12** distributed under the License is distributed on an "AS IS" BASIS, 13** WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 14** See the License for the specific language governing permissions and 15** limitations under the License. 16*/ 17 18#ifndef INCLUDING_FROM_AUDIOFLINGER_H 19 #error This header file should only be included from AudioFlinger.h 20#endif 21 22// record track 23class RecordTrack : public TrackBase { 24public: 25 RecordTrack(RecordThread *thread, 26 const sp<Client>& client, 27 uint32_t sampleRate, 28 audio_format_t format, 29 audio_channel_mask_t channelMask, 30 size_t frameCount, 31 void *buffer, 32 int sessionId, 33 int uid, 34 IAudioFlinger::track_flags_t flags, 35 track_type type); 36 virtual ~RecordTrack(); 37 virtual status_t initCheck() const; 38 39 virtual status_t start(AudioSystem::sync_event_t event, int triggerSession); 40 virtual void stop(); 41 42 void destroy(); 43 44 void invalidate(); 45 // clear the buffer overflow flag 46 void clearOverflow() { mOverflow = false; } 47 // set the buffer overflow flag and return previous value 48 bool setOverflow() { bool tmp = mOverflow; mOverflow = true; 49 return tmp; } 50 51 static void appendDumpHeader(String8& result); 52 void dump(char* buffer, size_t size, bool active); 53 54 void handleSyncStartEvent(const sp<SyncEvent>& event); 55 void clearSyncStartEvent(); 56 57private: 58 friend class AudioFlinger; // for mState 59 60 RecordTrack(const RecordTrack&); 61 RecordTrack& operator = (const RecordTrack&); 62 63 // AudioBufferProvider interface 64 virtual status_t getNextBuffer(AudioBufferProvider::Buffer* buffer, 65 int64_t pts = kInvalidPTS); 66 // releaseBuffer() not overridden 67 68 bool mOverflow; // overflow on most recent attempt to fill client buffer 69 70 71 size_t mRsmpInUnrel; // unreleased frames remaining from 72 // most recent getNextBuffer 73 // for debug only 74 75 // rolling counter that is never cleared 76 int32_t mRsmpInFront; // next available frame 77 78 AudioBufferProvider::Buffer mSink; // references client's buffer sink in shared memory 79 80 // sync event triggering actual audio capture. Frames read before this event will 81 // be dropped and therefore not read by the application. 82 sp<SyncEvent> mSyncStartEvent; 83 84 // number of captured frames to drop after the start sync event has been received. 85 // when < 0, maximum frames to drop before starting capture even if sync event is 86 // not received 87 ssize_t mFramesToDrop; 88 89 // used by resampler to find source frames 90 ResamplerBufferProvider *mResamplerBufferProvider; 91 92 // used by the record thread to convert frames to proper destination format 93 RecordBufferConverter *mRecordBufferConverter; 94}; 95 96// playback track, used by PatchPanel 97class PatchRecord : virtual public RecordTrack, public PatchProxyBufferProvider { 98public: 99 100 PatchRecord(RecordThread *recordThread, 101 uint32_t sampleRate, 102 audio_channel_mask_t channelMask, 103 audio_format_t format, 104 size_t frameCount, 105 void *buffer, 106 IAudioFlinger::track_flags_t flags); 107 virtual ~PatchRecord(); 108 109 // AudioBufferProvider interface 110 virtual status_t getNextBuffer(AudioBufferProvider::Buffer* buffer, 111 int64_t pts); 112 virtual void releaseBuffer(AudioBufferProvider::Buffer* buffer); 113 114 // PatchProxyBufferProvider interface 115 virtual status_t obtainBuffer(Proxy::Buffer *buffer, 116 const struct timespec *timeOut = NULL); 117 virtual void releaseBuffer(Proxy::Buffer *buffer); 118 119 void setPeerProxy(PatchProxyBufferProvider *proxy) { mPeerProxy = proxy; } 120 121private: 122 sp<ClientProxy> mProxy; 123 PatchProxyBufferProvider* mPeerProxy; 124 struct timespec mPeerTimeout; 125}; // end of PatchRecord 126