1 /* 2 * Copyright (C) 2010 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 /* interactive buffer queue test program */ 18 19 #ifdef ANDROID 20 #define USE_ANDROID_SIMPLE_BUFFER_QUEUE // change to #undef for compatibility testing 21 #endif 22 23 #include <assert.h> 24 #include <math.h> 25 #include <stdio.h> 26 #include <stdlib.h> 27 #include <unistd.h> 28 #include <SLES/OpenSLES.h> 29 #ifdef USE_ANDROID_SIMPLE_BUFFER_QUEUE 30 #include <SLES/OpenSLES_Android.h> 31 #endif 32 #include "getch.h" 33 34 #ifdef USE_ANDROID_SIMPLE_BUFFER_QUEUE 35 #define DATALOCATOR_BUFFERQUEUE SL_DATALOCATOR_ANDROIDSIMPLEBUFFERQUEUE 36 #define IID_BUFFERQUEUE SL_IID_ANDROIDSIMPLEBUFFERQUEUE 37 #define BufferQueueItf SLAndroidSimpleBufferQueueItf 38 #define BufferQueueState SLAndroidSimpleBufferQueueState 39 #define INDEX index 40 #else 41 #define DATALOCATOR_BUFFERQUEUE SL_DATALOCATOR_BUFFERQUEUE 42 #define IID_BUFFERQUEUE SL_IID_BUFFERQUEUE 43 #define BufferQueueItf SLBufferQueueItf 44 #define BufferQueueState SLBufferQueueState 45 #define INDEX playIndex 46 #endif 47 48 #define checkResult(r) do { if ((r) != SL_RESULT_SUCCESS) fprintf(stderr, "error %d at %s:%d\n", \ 49 (int) r, __FILE__, __LINE__); } while (0) 50 51 typedef struct { 52 short left; 53 short right; 54 } frame_t; 55 56 #define SINE_FRAMES (44100*5) 57 frame_t sine[SINE_FRAMES]; 58 59 #define SQUARE_FRAMES (44100*5) 60 frame_t square[SQUARE_FRAMES]; 61 62 #define SAWTOOTH_FRAMES (44100*5) 63 frame_t sawtooth[SAWTOOTH_FRAMES]; 64 65 #define HALF_FRAMES (44100*5) 66 frame_t half[HALF_FRAMES]; 67 68 BufferQueueItf expectedCaller = NULL; 69 void *expectedContext = NULL; 70 71 static void callback(BufferQueueItf caller, void *context) 72 { 73 putchar('.'); 74 if (caller != expectedCaller) 75 printf("caller %p expected %p\r\n", caller, expectedCaller); 76 if (context != expectedContext) 77 printf("context %p expected %p\r\n", context, expectedContext); 78 fflush(stdout); 79 } 80 81 int main(int argc, char **argv) 82 { 83 SLresult result; 84 85 // create engine 86 SLObjectItf engineObject; 87 result = slCreateEngine(&engineObject, 0, NULL, 0, NULL, NULL); 88 checkResult(result); 89 result = (*engineObject)->Realize(engineObject, SL_BOOLEAN_FALSE); 90 checkResult(result); 91 SLEngineItf engineEngine; 92 result = (*engineObject)->GetInterface(engineObject, SL_IID_ENGINE, &engineEngine); 93 checkResult(result); 94 95 // create output mix 96 SLObjectItf outputmixObject; 97 result = (*engineEngine)->CreateOutputMix(engineEngine, &outputmixObject, 0, NULL, NULL); 98 checkResult(result); 99 result = (*outputmixObject)->Realize(outputmixObject, SL_BOOLEAN_FALSE); 100 checkResult(result); 101 102 // create audio player 103 SLDataSource audiosrc; 104 SLDataSink audiosnk; 105 SLDataFormat_PCM pcm; 106 SLDataLocator_OutputMix locator_outputmix; 107 SLDataLocator_BufferQueue locator_bufferqueue; 108 locator_bufferqueue.locatorType = DATALOCATOR_BUFFERQUEUE; 109 locator_bufferqueue.numBuffers = 255; 110 locator_outputmix.locatorType = SL_DATALOCATOR_OUTPUTMIX; 111 locator_outputmix.outputMix = outputmixObject; 112 pcm.formatType = SL_DATAFORMAT_PCM; 113 pcm.numChannels = 2; 114 pcm.samplesPerSec = SL_SAMPLINGRATE_44_1; 115 pcm.bitsPerSample = SL_PCMSAMPLEFORMAT_FIXED_16; 116 pcm.containerSize = 16; 117 pcm.channelMask = SL_SPEAKER_FRONT_LEFT | SL_SPEAKER_FRONT_RIGHT; 118 pcm.endianness = SL_BYTEORDER_LITTLEENDIAN; 119 audiosrc.pLocator = &locator_bufferqueue; 120 audiosrc.pFormat = &pcm; 121 audiosnk.pLocator = &locator_outputmix; 122 audiosnk.pFormat = NULL; 123 SLObjectItf playerObject; 124 SLInterfaceID ids[2] = {IID_BUFFERQUEUE, SL_IID_MUTESOLO}; 125 SLboolean flags[2] = {SL_BOOLEAN_TRUE, SL_BOOLEAN_TRUE}; 126 result = (*engineEngine)->CreateAudioPlayer(engineEngine, &playerObject, &audiosrc, &audiosnk, 127 2, ids, flags); 128 checkResult(result); 129 result = (*playerObject)->Realize(playerObject, SL_BOOLEAN_FALSE); 130 checkResult(result); 131 SLPlayItf playerPlay; 132 result = (*playerObject)->GetInterface(playerObject, SL_IID_PLAY, &playerPlay); 133 checkResult(result); 134 BufferQueueItf playerBufferqueue; 135 result = (*playerObject)->GetInterface(playerObject, IID_BUFFERQUEUE, &playerBufferqueue); 136 checkResult(result); 137 SLMuteSoloItf playerMuteSolo; 138 result = (*playerObject)->GetInterface(playerObject, SL_IID_MUTESOLO, &playerMuteSolo); 139 checkResult(result); 140 SLuint8 numChannels = 123; 141 result = (*playerMuteSolo)->GetNumChannels(playerMuteSolo, &numChannels); 142 assert(2 == numChannels); 143 SLuint32 state; 144 state = SL_PLAYSTATE_PLAYING; 145 result = (*playerPlay)->SetPlayState(playerPlay, state); 146 checkResult(result); 147 148 unsigned i; 149 float pi2 = 3.14*2; 150 float hz = 441; 151 float sr = 44100; 152 for (i = 0; i < SINE_FRAMES; ++i) { 153 sine[i].left = sin((float) (i / (sr / hz)) * pi2 ) * 32000.0; 154 sine[i].right = sine[i].left; 155 } 156 for (i = 0; i < SQUARE_FRAMES; ++i) { 157 square[i].left = (i % (unsigned) (sr / hz)) < 50 ? 32767 : -32768; 158 square[i].right = square[i].left; 159 } 160 for (i = 0; i < SAWTOOTH_FRAMES; ++i) { 161 sawtooth[i].left = ((((int) (i % (unsigned) (sr / hz))) - 50) / 100.0) * 60000.0 - 30000.0; 162 sawtooth[i].right = sawtooth[i].left; 163 } 164 for (i = 0; i < HALF_FRAMES; ++i) { 165 half[i].left = sine[i].left; 166 half[i].right = sawtooth[i].right / 2; 167 } 168 169 set_conio_terminal_mode(); 170 int in_count = 0; 171 unsigned count = 0; 172 for (;;) { 173 usleep(10000); 174 if (kbhit()) { 175 frame_t *buffer; 176 unsigned size; 177 BufferQueueState bufqstate; 178 int ch = getch(); 179 switch (ch) { 180 case '0' ... '9': 181 if (in_count) { 182 count = count * 10 + (ch - '0'); 183 } else { 184 count = ch - '0'; 185 in_count = 1; 186 } 187 continue; 188 case 'i': 189 buffer = sine; 190 size = sizeof(sine); 191 goto enqueue; 192 case 'q': 193 buffer = square; 194 size = sizeof(square); 195 goto enqueue; 196 case 'h': 197 buffer = half; 198 size = sizeof(half); 199 goto enqueue; 200 case 'r': 201 if (in_count) { 202 expectedCaller = playerBufferqueue; 203 expectedContext = (void *) count; 204 } else { 205 expectedCaller = NULL; 206 expectedContext = (void *) NULL; 207 } 208 result = (*playerBufferqueue)->RegisterCallback(playerBufferqueue, in_count ? 209 callback : NULL, expectedContext); 210 checkResult(result); 211 break; 212 case 'a': 213 buffer = sawtooth; 214 size = sizeof(sawtooth); 215 enqueue: 216 for (i = 0; i < (in_count ? count : 1); ++i) { 217 result = (*playerBufferqueue)->Enqueue(playerBufferqueue, buffer, size); 218 checkResult(result); 219 } 220 break; 221 case 'c': 222 result = (*playerBufferqueue)->Clear(playerBufferqueue); 223 checkResult(result); 224 putchar('\r'); 225 result = (*playerBufferqueue)->GetState(playerBufferqueue, &bufqstate); 226 checkResult(result); 227 if (bufqstate.count != 0) 228 printf("\rcount=%u\r\n", (unsigned) bufqstate.count); 229 #if 0 230 putchar('\r'); 231 putchar('\n'); 232 #endif 233 fflush(stdout); 234 break; 235 case 'g': 236 result = (*playerBufferqueue)->GetState(playerBufferqueue, &bufqstate); 237 checkResult(result); 238 printf("\rplayIndex=%u\r\n", (unsigned) bufqstate.INDEX); 239 printf("count=%u\r\n", (unsigned) bufqstate.count); 240 break; 241 case 'p': 242 state = SL_PLAYSTATE_PAUSED; 243 goto setplaystate; 244 case 's': 245 state = SL_PLAYSTATE_STOPPED; 246 goto setplaystate; 247 case 'P': 248 state = SL_PLAYSTATE_PLAYING; 249 setplaystate: 250 result = (*playerPlay)->SetPlayState(playerPlay, state); 251 checkResult(result); 252 SLuint32 newstate; 253 result = (*playerPlay)->GetPlayState(playerPlay, &newstate); 254 checkResult(result); 255 if (newstate != state) 256 printf("\rSetPlayState(%u) -> GetPlayState(%u)\r\n", (unsigned) state, 257 (unsigned) newstate); 258 #if 0 259 putchar('\r'); 260 putchar('\n'); 261 fflush(stdout); 262 #endif 263 checkResult(result); 264 break; 265 case 'x': 266 goto out; 267 default: 268 putchar('?'); 269 fflush(stdout); 270 break; 271 } 272 in_count = 0; 273 } 274 } 275 276 out: 277 (*playerObject)->Destroy(playerObject); 278 (*outputmixObject)->Destroy(outputmixObject); 279 (*engineObject)->Destroy(engineObject); 280 return EXIT_SUCCESS; 281 } 282
