7.3.3 audio_track_cblk_t分析
前面讲解了AudioFlinger的工作方式,但AT和AF,以及那个神秘的CB对象的工作原理一直都还没能讲解。对于Audio系统来说,如果最终也解决不了这个,真会有当年岳飞在朱仙镇被十二道金牌召回时一样的悲愤心情。幸好我们没遇到秦桧,那就奋起直追,去解决这个CB对象吧。
解决问题要有好的对策。还是从AT和AF这两端关于CB对象的调用流程开始分析吧,这一招可是屡试不爽啊!
1.AT端的流程
AT端作为数据的生产者(可称它为写者),它在CB对象中用user表示。它的调用流程是:
调用framesAvailable,看看是否有空余的可写空间。
调用buffer,获得写空间起始地址。
调用stepUser,更新user的位置。
一起来分析一下,这几个函数都相当简单,力争一气呵成。
先调用framesAvailable,看看当前剩余多少可写空间。假设是第一次进来,读者还在那等待数据,这样就不用考虑竞争等问题了,代码如下所示:
[—>AudioTrack.cpp:audio_track_cblk_t的framesAvailable()及相关]
uint32_t audio_track_cblk_t:framesAvailable()
{
Mutex:Autolock_l(lock);
return framesAvailable_l();//调用framesAvailable_l。
}
int32_t audio_track_cblk_t:framesAvailable_l()
{
uint32_t u=this->user;//当前写者位置,此时为0。
uint32_t s=this->server;//当前读者位置,此时也为0。
if(out){//对于音频输出,out为1。
uint32_t limit=(s<loopStart)?s:loopStart;
//由于不设置播放端点,所以loopStart是初始值INT_MAX,limit=0。
return limit+frameCount-u;
//返回0+frameCount-0,也就是数据缓冲的全部大小。假设frameCount=1024帧。
}
}
然后,调用buffer获得起始位置,buffer返回一个地址,代码如下所示:
[—>AudioTrack.cpp]
void*audio_track_cblk_t:buffer(uint32_t offset)const
{
//buffers是数据缓冲的起始位置,offset是计算出来的基于userBase的偏移。
//通过这种方式巧妙地把数据缓冲当做环形缓冲来处理。
return(int8_t)this->buffers+(offset-userBase)this->frameSize;
}
当把数据写到缓冲后,调用stepUser,代码如下所示:
[—>AudioTrack.cpp]
uint32_t audio_track_cblk_t:stepUser(uint32_t frameCount)
{
/*
framecount表示写了多少帧,前面分配了1024帧,但写的数据可以比这个少。
假设这一次写了512帧。
*/
uint32_t u=this->user;//user位置还没更新,此时u=0;
u+=frameCount;//u更新了,u=512。
……
/*
userBase还是初始值0。可惜只写了1024的一半,所以userBase加不了。
但这句话很重要,还记得前面的buffer调用吗?取数据地址的时候用offset-userBase,一旦user位置到达缓冲的尾部,则userBase也会更新,这样offset-userBase的位置就会回到缓冲的头部,从头到尾这么反复循环,不就是一个环形缓冲了吗?非常巧妙!
*/
if(u>=userBase+this->frameCount){
userBase+=this->frameCount;
}
this->user=u;//哦,user位置也更新为512了,但是useBase还是0。
return u;
}
假设写者这时因某种原因停止了写数据,而读者却被唤醒。
2.AF端的流程
AF端作为数据的消费者,它在CB中的表示是server,可称它为读者。读者的使用流程是:
调用framesReady看是否有可读数据。
获得可读数据的起始位置,这个和上面的buffer调用基本一样,都是根据offset和serverBase来获得可读数据块的首地址的。
调用stepServer更新读位置。
现在来分析framesReady和stepServer这两个函数,framesReady的代码如下所示:
[—>AudioTrack.cpp]
uint32_t audio_track_cblk_t:framesReady()
{
uint32_t u=this->user;//u为512。
uint32_t s=this->server;//还没读呢,s为零。
if(out){
if(u<loopEnd){
return u-s;//loopEnd也是INT_MAX,所以这里返回512,表示有512帧可读了。
}else{
Mutex:Autolock_l(lock);
if(loopCount>=0){
return(loopEnd-loopStart)*loopCount+u-s;
}else{
return UINT_MAX;
}
}
}else{
return s-u;
}
}
可读数据地址的计算方法和前面的buffer调用一样,都是通过server和serverBase来计算的。接着看stepServer,代码如下所示:
[—>AudioTrack.cpp]
bool audio_track_cblk_t:stepServer(uint32_t frameCount)
{
status_t err;
err=lock.tryLock();
uint32_t s=this->server;
s+=frameCount;//读了512帧,所以s=512。
……
//没有设置循环播放,所以不走这个。
if(s>=loopEnd){
s=loopStart;
if(—loopCount==0){
loopEnd=UINT_MAX;
loopStart=UINT_MAX;
}
}
//和userBase一样的处理。
if(s>=serverBase+this->frameCount){
serverBase+=this->frameCount;
}
this->server=s;//server为512了。
cv.signal();//读者读完了,触发一个同步信号,因为读者可能在等待可写的数据缓冲。
lock.unlock();
return true;
}
3.真的是环形缓冲?
满足下面场景的缓冲可称为环形缓冲(假设数据缓冲最大为1024帧):
写者先写1024帧,此后便无剩余空间可写。
读者读了前面的512帧,那么这512帧的数据空间就空出来了。
所以,写者就可以重新利用这空余的512帧空间了。
关键是第三步,写者是否跟踪了读者的位置,并充分利用了读者已使用过的数据空间。所以得回头看看写者AT是否把这512帧利用了。
先看写者写完1024帧后的情况,stepUser中会有下面几句话:
if(u>=userBase+this->frameCount){
//u为1024,userBase为0,frameCount为1024。
userBase+=this->frameCount;//好,userBase也为1024了。
}
此时userBase更新为1024帧。再看写者获取可写空间的framesAvailable_l函数,按照以前的假设,应该返回512帧可写空间,代码如下所示:
[—>AudioTrack.cpp]
uint32_t audio_track_cblk_t:framesAvailable_l()
{
uint32_t u=this->user;//1024,写者上一次写完了整个1024帧空间。
uint32_t s=this->server;//512,读者当前读到的位置。
if(out){
uint32_t limit=(s<loopStart)?s:loopStart;
return limit+frameCount-u;//返回512。
}
}
framesAvailable返回了512帧,但可写空间的地址是否是从头开始的呢?要是从其他地方开始,情况就惨了。来看buffer中最后返回的可写空间地址:
return(int8_t)this->buffers+(offset-userBase)this->frameSize;
//offset是外界传入的基于userBase的一个偏移量,它的值是userBase+512,所以
//offset-userBase将得到从头开始的那段数据空间。真的是一个环形缓冲。
从上面的分析可看出,CB对象通过userBase和user等几个变量,将一段有限长度的线性缓冲变成了一段无限长的缓冲,这不正是环形缓冲的精髓吗!