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 CPulseStreamSpec;
34 class CPulseAudioClient {
36 enum class EStreamDirection : unsigned int {
37 STREAM_DIRECTION_RECORD, /**< Record stream */
38 STREAM_DIRECTION_PLAYBACK /**< Playback stream */
42 static const char* CLIENT_NAME;
44 /* Constructor & Destructor */
45 CPulseAudioClient(EStreamDirection direction,
46 CPulseStreamSpec& spec,
47 IPulseStreamListener* listener);
50 /* Implemented Methods */
55 int read(void* buffer, size_t length);
56 int peek(const void** buffer, size_t* length);
58 int write(const void* buffer, size_t length);
66 void checkRunningState();
67 bool isInThread() noexcept;
69 size_t getWritableSize();
70 size_t getReadableSize();
72 size_t getBufferSize();
74 pa_usec_t getLatency();
75 pa_usec_t getFinalLatency();
79 EStreamDirection __mDirection;
80 CPulseStreamSpec __mSpec;
81 IPulseStreamListener* __mpListener;
83 pa_threaded_mainloop* __mpMainloop;
84 pa_context* __mpContext;
85 pa_stream* __mpStream;
86 pa_proplist* __mpPropList;
89 bool __mIsOperationSuccess;
91 const void* __mpSyncReadDataPtr;
92 size_t __mSyncReadIndex;
93 size_t __mSyncReadLength;
94 bool __mIsUsedSyncRead;
95 bool __mIsFirstStream;
103 /* Private Calblack Method */
104 static void __contextStateChangeCb(pa_context* c, void* user_data);
105 static void __streamStateChangeCb(pa_stream* s, void* user_data);
106 static void __streamCaptureCb(pa_stream* s, size_t length, void* user_data);
107 static void __streamPlaybackCb(pa_stream* s, size_t length, void* user_data);
108 static void __streamLatencyUpdateCb(pa_stream* s, void* user_data);
109 static void __streamStartedCb(pa_stream* s, void* user_data);
110 static void __streamUnderflowCb(pa_stream* s, void* user_data);
111 static void __streamEventCb(pa_stream* s, const char *name, pa_proplist *pl, void *user_data);
112 static void __successStreamCb(pa_stream* s, int success, void* user_data);
113 static void __successDrainCb(pa_stream* s, int success, void* user_data);
114 static void __successDrainCbInThread(pa_stream* s, int success, void* user_data);
118 } /* namespace tizen_media_audio */
121 #endif /* __TIZEN_MEDIA_AUDIO_IO_CPULSEAUDIO_CLIENT_H__ */