2 * Copyright (c) 2015 Samsung Electronics Co., Ltd All Rights Reserved
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
8 * http://www.apache.org/licenses/LICENSE-2.0
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.
17 #ifndef __TIZEN_MEDIA_AUDIO_IO_CPULSEAUDIO_CLIENT_H__
18 #define __TIZEN_MEDIA_AUDIO_IO_CPULSEAUDIO_CLIENT_H__
24 #include <pulse/pulseaudio.h>
27 namespace tizen_media_audio {
33 class CPulseAudioVolume;
34 class CPulseAudioPolicy;
35 class CPulseStreamSpec;
36 class CPulseAudioClient {
38 enum class EStreamDirection : unsigned int {
39 STREAM_DIRECTION_RECORD, /**< Record stream */
40 STREAM_DIRECTION_PLAYBACK /**< Playback stream */
44 static const char* CLIENT_NAME;
46 /* Constructor & Destructor */
47 CPulseAudioClient(EStreamDirection direction,
48 CPulseStreamSpec& spec,
49 IPulseStreamListener* listener);
52 /* Implemented Methods */
53 void initialize() throw(CAudioError);
57 int read(void* buffer, size_t length) throw(CAudioError);
58 int peek(const void** buffer, size_t* length) throw(CAudioError);
59 int drop() throw(CAudioError);
60 int write(const void* buffer, size_t length) throw(CAudioError);
62 void cork(bool cork) throw(CAudioError);
63 bool isCorked() throw(CAudioError);
65 bool drain() throw(CAudioError);
66 bool flush() throw(CAudioError);
68 void checkRunningState() throw(CAudioError);
69 bool isInThread() throw(CAudioError);
71 size_t getWritableSize() throw(CAudioError);
72 size_t getReadableSize() throw(CAudioError);
74 size_t getBufferSize() throw(CAudioError);
76 pa_usec_t getLatency() throw(CAudioError);
77 pa_usec_t getFinalLatency() throw(CAudioError);
80 EStreamDirection getStreamDirection();
81 CPulseStreamSpec getStreamSpec();
85 EStreamDirection __mDirection;
86 CPulseStreamSpec __mSpec;
87 IPulseStreamListener* __mpListener;
89 pa_threaded_mainloop* __mpMainloop;
90 pa_context* __mpContext;
91 pa_stream* __mpStream;
92 pa_proplist* __mpPropList;
95 bool __mIsOperationSuccess;
97 const void* __mpSyncReadDataPtr;
98 size_t __mSyncReadIndex;
99 size_t __mSyncReadLength;
100 bool __mIsUsedSyncRead;
101 bool __mIsFirstStream;
108 /* Private Calblack Method */
109 static void __contextStateChangeCb(pa_context* c, void* user_data);
110 static void __successContextCb(pa_context* c, int success, void* user_data);
112 static void __streamStateChangeCb(pa_stream* s, void* user_data);
113 static void __streamCaptureCb(pa_stream* s, size_t length, void* user_data);
114 static void __streamPlaybackCb(pa_stream* s, size_t length, void* user_data);
115 static void __streamLatencyUpdateCb(pa_stream* s, void* user_data);
116 static void __streamEventCb(pa_stream* s, const char *name, pa_proplist *pl, void *user_data);
117 static void __successStreamCb(pa_stream* s, int success, void* user_data);
118 static void __successDrainCb(pa_stream* s, int success, void* user_data);
119 static void __successDrainCbInThread(pa_stream* s, int success, void* user_data);
123 } /* namespace tizen_media_audio */
126 #endif /* __TIZEN_MEDIA_AUDIO_IO_CPULSEAUDIO_CLIENT_H__ */