1 /*
2  * Copyright (C) 2017 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 
17 #ifndef ANDROID_AAUDIO_AUDIO_STREAM_INTERNAL_PLAY_H
18 #define ANDROID_AAUDIO_AUDIO_STREAM_INTERNAL_PLAY_H
19 
20 #include <stdint.h>
21 #include <aaudio/AAudio.h>
22 
23 #include "binding/AAudioServiceInterface.h"
24 #include "client/AAudioFlowGraph.h"
25 #include "client/AudioStreamInternal.h"
26 
27 using android::sp;
28 using android::IAAudioService;
29 
30 namespace aaudio {
31 
32 class AudioStreamInternalPlay : public AudioStreamInternal {
33 public:
34     AudioStreamInternalPlay(AAudioServiceInterface  &serviceInterface, bool inService = false);
35     virtual ~AudioStreamInternalPlay();
36 
37     aaudio_result_t open(const AudioStreamBuilder &builder) override;
38 
39     aaudio_result_t requestPause() override;
40 
41     aaudio_result_t requestFlush() override;
42 
isFlushSupported()43     bool isFlushSupported() const override {
44         // Only implement FLUSH for OUTPUT streams.
45         return true;
46     }
47 
isPauseSupported()48     bool isPauseSupported() const override {
49         // Only implement PAUSE for OUTPUT streams.
50         return true;
51     }
52 
53     aaudio_result_t write(const void *buffer,
54                           int32_t numFrames,
55                           int64_t timeoutNanoseconds) override;
56 
57     int64_t getFramesRead() override;
58     int64_t getFramesWritten() override;
59 
60     void *callbackLoop() override;
61 
getDirection()62     aaudio_direction_t getDirection() const override {
63         return AAUDIO_DIRECTION_OUTPUT;
64     }
65 
66 protected:
67 
68     void advanceClientToMatchServerPosition() override;
69 
70     void onFlushFromServer() override;
71 
72     android::status_t doSetVolume() override;
73 
74 /**
75  * Low level write that will not block. It will just write as much as it can.
76  *
77  * It passed back a recommended time to wake up if wakeTimePtr is not NULL.
78  *
79  * @return the number of frames written or a negative error code.
80  */
81     aaudio_result_t processDataNow(void *buffer,
82                              int32_t numFrames,
83                              int64_t currentTimeNanos,
84                              int64_t *wakeTimePtr) override;
85 private:
86     /*
87      * Asynchronous write with data conversion.
88      * @param buffer
89      * @param numFrames
90      * @return fdrames written or negative error
91      */
92     aaudio_result_t writeNowWithConversion(const void *buffer,
93                                            int32_t numFrames);
94 
95     AAudioFlowGraph          mFlowGraph;
96 
97 };
98 
99 } /* namespace aaudio */
100 
101 #endif //ANDROID_AAUDIO_AUDIO_STREAM_INTERNAL_PLAY_H
102