10t.c
9.6 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
// #include <stdio.h>
// #include <pthread.h>
// #include <errno.h>
// #include <string.h>
// #include <stdlib.h>
// #include "JZsdkLib.h"
// #include "Megaphone_InputAndOutput.h"
// #include "../Megaphone_Music.h"
// static int ReadTimeMP2_StatusFlag = JZ_FLAGCODE_OFF;
// //解码播放部分
// static unsigned char Music_RealTimeMP2_PlayData_Loop[ (256 + 1) ][128];//解码缓存池
// static int Music_RealTimeMP2_PlayData_LoopHead = 0; //池数头
// static int Music_RealTimeMP2_PlayData_LoopEnd = 0; //池数尾
// static int Music_RealTimeMP2__PlayData_LoopReadFlag=0;//读取标志位0为停止，1为开始
// static int Music_RealTimeMP2_Play_init();
// static void *Music_RealTimeMP2_LoopPlay(void *arg);
// static int Music_RealTimeMP2_ClearLoop();
// static void Music_RealTimeMP2_PlayLoop_HeadReset();
// //写入数据部分
// static unsigned char Music_RealTimeMP2_WriteData_Loop[(255 + 1)][128]; //实时mp2缓冲输入池
// static int Music_RealTimeMP2_WriteData_LoopHead = 0; //池数头
// static int Music_RealTimeMP2_WriteData_LoopEnd = 0; //池数尾
// static int Music_RealTimeMP2_WriteData_ResidueLenth; // 写入缓存池池子残余物长度
// static int Music_RealTimeMP2_WriteFlag=0;//读取标志位0为停止，1为开始
// pthread_mutex_t RealTimeMP2_WriteDataLock = PTHREAD_MUTEX_INITIALIZER;
// pthread_cond_t RealTimeMP2_WriteCond = PTHREAD_COND_INITIALIZER;
// static void *Music_RealTimeMP2_WriteData_Task(void *arg);
// static int Music_RealTimeMP2_WriteDataClear();
// static int Music_RealTimeMP2_WriteDataToLoop(unsigned char *buf,int length);
// static void Music_RealTimeMP2_WriteDataHeadReset();
// static int Music_RealTimeMP2_WriteData_init();
// T_JZsdkReturnCode Music_RealTimeMP2_start()
// {
// //1、开启实时mp2模式
// ReadTimeMP2_StatusFlag = JZ_FLAGCODE_ON;
// //2、创建输入缓冲线程
// Music_RealTimeMP2_WriteData_init();
// //3、创建播放线程
// //Music_RealTimeMP2_Play_init();
// return JZ_ERROR_SYSTEM_MODULE_CODE_SUCCESS;
// }
// T_JZsdkReturnCode Music_RealTimeMP2_trans(unsigned char *getdata, int len)
// {
// Music_RealTimeMP2_WriteDataToLoop(getdata, len);
// return JZ_ERROR_SYSTEM_MODULE_CODE_SUCCESS;
// }
// T_JZsdkReturnCode Music_RealTimeMP2_stop()
// {
// ReadTimeMP2_StatusFlag = JZ_FLAGCODE_OFF;
// Music_RealTimeMP2__PlayData_LoopReadFlag = JZ_FLAGCODE_OFF;
// Music_RealTimeMP2_WriteFlag = JZ_FLAGCODE_OFF;
// return JZ_ERROR_SYSTEM_MODULE_CODE_SUCCESS;
// }
// /************************************************************************************************************************************************
// *
// * 解码播放部分
// *
// *
// *************************************************************************************************************************************************/
// //解码opus并播放
// static int Music_RealTimeMP2_PlayData(unsigned char *data,int len)
// {
// unsigned char playFile[len + 9 + 2];
// printf("播放开始\n");
// //清空
// memset(playFile, 0, (len + 9 + 2));
// //帧头
// playFile[0] = 0x5a;
// playFile[1] = 0x5a;
// playFile[2] = 0x77;
// playFile[7] = 0x51;
// playFile[8] = 0x04;
// //帧数据
// memcpy(&playFile[9],data,len);
// len = len + 9 + 2;
// //帧尾
// playFile[len - 1] = 0x00;
// playFile[len] = 0x00;
// Music_SendFrame_FramePlay(playFile,len);
// printf("播放结束\n");
// return 0;
// }
// /************************************************************************************************************************************************
// *
// * 写入缓冲池部分
// *
// *
// *************************************************************************************************************************************************/
// //写入数据部分初始化
// static int Music_RealTimeMP2_WriteData_init()
// {
// //清空写入数据池
// Music_RealTimeMP2_WriteDataClear();
// pthread_t WriteDataTask;
// pthread_attr_t task_attribute; //线程属性
// pthread_attr_init(&task_attribute); //初始化线程属性
// pthread_attr_setdetachstate(&task_attribute, PTHREAD_CREATE_DETACHED); //设置线程分离属性
// int opus_Protection = pthread_create(&WriteDataTask,&task_attribute,Music_RealTimeMP2_WriteData_Task,NULL); //线程
// if(opus_Protection != 0)
// {
// printf("创建输入缓冲池线程线程失败！\n");
// ReadTimeMP2_StatusFlag = JZ_FLAGCODE_OFF;
// return -2;
// }
// }
// //输入缓冲池任务
// static void *Music_RealTimeMP2_WriteData_Task(void *arg)
// {
// int ret;
// printf("MP2实施喊话,输入数据缓冲线程建立\n");
// Music_RealTimeMP2_WriteFlag = JZ_FLAGCODE_ON;
// while(Music_RealTimeMP2_WriteFlag == JZ_FLAGCODE_ON)
// {
// pthread_mutex_lock(&RealTimeMP2_WriteDataLock); // 获取互斥锁
// if(Music_RealTimeMP2_WriteData_LoopHead != Music_RealTimeMP2_WriteData_LoopEnd)
// {
// printf("缓冲线程写入中\n");
// //将输入缓冲池的数据放入播放缓冲池
// Music_RealTimeMP2_PlayData(Music_RealTimeMP2_WriteData_Loop[Music_RealTimeMP2_WriteData_LoopHead], 128);
// printf("Music_RealTimeMP2_WriteData_LoopHead:%d\n",Music_RealTimeMP2_WriteData_LoopHead);
// Music_RealTimeMP2_WriteData_LoopHead ++;
// Music_RealTimeMP2_WriteDataHeadReset();
// }
// pthread_cond_signal(&RealTimeMP2_WriteCond); // 发送信号通知播放线程可以开始播放
// pthread_mutex_unlock(&RealTimeMP2_WriteDataLock); // 释放互斥锁
// }
// }
// //写入数据缓存池重置
// static int Music_RealTimeMP2_WriteDataClear()
// {
// Music_RealTimeMP2_WriteData_LoopHead=0;
// Music_RealTimeMP2_WriteData_LoopEnd=0;
// Music_RealTimeMP2_WriteData_ResidueLenth = 0;
// }
// // 写入池子头部到底了，重置池头
// static void Music_RealTimeMP2_WriteDataHeadReset()
// {
// if (Music_RealTimeMP2_WriteData_LoopHead >= 255)
// {
// Music_RealTimeMP2_WriteData_LoopHead = 0;
// }
// }
// // 写入池子尾部到底了，重置池尾
// static void Music_RealTimeMP2_WriteDataEndReset()
// {
// if (Music_RealTimeMP2_WriteData_LoopEnd >= 255)
// {
// Music_RealTimeMP2_WriteData_LoopEnd = 0;
// }
// }
// //写入数据进缓存池,以用于后续播放
// static int Music_RealTimeMP2_WriteDataToLoop(unsigned char *buf,int length)
// {
// int temp_lenth = 0; //临时长度
// //判断输入的数据长度是否正常
// if (length <= 0)
// {
// printf("输入进缓冲池的数据长度有误:%d\n",length);
// return -1;
// }
// //写入处理
// //① 、检查池子当前组内有无剩余数据，如果池子当前组有剩 上次写入的语音数据， 接着往里面写入
// if (Music_RealTimeMP2_WriteData_ResidueLenth > 0) //如果残留物有长度
// {
// pthread_mutex_lock(&RealTimeMP2_WriteDataLock); // 获取互斥锁
// //数据进池，每组128数据
// for( ; Music_RealTimeMP2_WriteData_ResidueLenth < 128 ; Music_RealTimeMP2_WriteData_ResidueLenth ++)
// {
// Music_RealTimeMP2_WriteData_Loop[Music_RealTimeMP2_WriteData_LoopEnd] [Music_RealTimeMP2_WriteData_ResidueLenth] = buf [temp_lenth];
// temp_lenth ++;
// }
// Music_RealTimeMP2_WriteData_LoopEnd+=1; //池尾后移一组
// Music_RealTimeMP2_WriteData_ResidueLenth = 0; //残留物长度归0
// Music_RealTimeMP2_WriteDataEndReset(); //池满判断
// pthread_cond_wait(&RealTimeMP2_WriteCond, &RealTimeMP2_WriteDataLock);
// pthread_mutex_unlock(&RealTimeMP2_WriteDataLock); // 释放互斥锁
// }
// //②、从新的组处理数据
// //待处理数据超过128长度时
// while( (length - temp_lenth) >= 128)
// {
// //数据进池，每组128数据
// //printf("往池子里的第%d号里写入数据\n",Music_RealTimeMP2_WriteData_LoopEnd);
// pthread_mutex_lock(&RealTimeMP2_WriteDataLock); // 获取互斥锁
// for(int ucLen = 0 ; ucLen < 128 ; ucLen ++)
// {
// Music_RealTimeMP2_WriteData_Loop[Music_RealTimeMP2_WriteData_LoopEnd] [ucLen] = buf [temp_lenth];
// temp_lenth ++;
// }
// printf("携入loopend:%d\n",Music_RealTimeMP2_WriteData_LoopEnd);
// Music_RealTimeMP2_WriteData_LoopEnd+=1; //池尾后移一组
// Music_RealTimeMP2_WriteDataEndReset(); //池满判断
// pthread_cond_wait(&RealTimeMP2_WriteCond, &RealTimeMP2_WriteDataLock);
// pthread_mutex_unlock(&RealTimeMP2_WriteDataLock); // 释放互斥锁
// }
// //③、如果长度还有剩，把数据存到池子内的新组，并记录残留物长度
// if( (length - temp_lenth) > 0)
// {
// for ( ; temp_lenth < length ; Music_RealTimeMP2_WriteData_ResidueLenth++)
// {
// Music_RealTimeMP2_WriteData_Loop[Music_RealTimeMP2_WriteData_LoopEnd] [Music_RealTimeMP2_WriteData_ResidueLenth] = buf [temp_lenth];
// temp_lenth ++;
// }
// }
// return 0;
// }
// /************************************************************************************************************************************************
// *
// * 状态相关
// *
// *
// *************************************************************************************************************************************************/
// /********************
// *
// * 获取实时MP2模式
// *
// * **************/
// T_JZsdkReturnCode Music_RealTimeMP2_GetStatusFlag()
// {
// return ReadTimeMP2_StatusFlag;
// }