文档章节

Live555源代码解读(2)

Sean-x
 Sean-x
发布于 2016/02/24 21:09
字数 1012
阅读 56
收藏 0

三、消息循环

     看服端的主体:live555MediaServer.cpp中的main()函数,可见其创建一个RTSPServer类实例后,即进入一个函数env->taskScheduler().doEventLoop()中,看名字很明显是一个消息循坏,执行到里面后不停地转圈,生名不息,转圈不止。那么在这个人生的圈圈中如何实现RTSP服务和RTP传输呢?别想那么远了,还是先看这个圈圈中实现了什么功能吧。


[cpp]
 view plaincopy

  1. void BasicTaskScheduler0::doEventLoop(char* watchVariable) {  

  2.     // Repeatedly loop, handling readble sockets and timed events:  

  3.     while (1) {  

  4.         if (watchVariable != NULL && *watchVariable != 0)  

  5.             break;  

  6.         SingleStep();  

  7.     }  

  8. }  

BasicTaskScheduler0从TaskScheduler派生,所以还是一个任务调度对象,所以依然说明任务调度对象是整个程序的发动机。

循环中每次走一步:SingleStep()。这走一步中都做些什么呢?

总结为以下四步:

1为所有需要操作的socket执行select。

2找出第一个应执行的socket任务(handler)并执行之。

3找到第一个应响应的事件,并执行之。

4找到第一个应执行的延迟任务并执行之。

可见,每一步中只执行三个任务队列中的一项。下面详细分析函数SingleStep():


[cpp]
 view plaincopy

  1. //循坏中主要执行的函数  

  2. void BasicTaskScheduler::SingleStep(unsigned maxDelayTime) {  

  3.     fd_set readSet = fReadSet; // make a copy for this select() call  

  4.     fd_set writeSet = fWriteSet; // ditto  

  5.     fd_set exceptionSet = fExceptionSet; // ditto  

  6.   

  7.     //计算select socket们时的超时时间。  

  8.     DelayInterval const& timeToDelay = fDelayQueue.timeToNextAlarm();  

  9.     struct timeval tv_timeToDelay;  

  10.     tv_timeToDelay.tv_sec = timeToDelay.seconds();  

  11.     tv_timeToDelay.tv_usec = timeToDelay.useconds();  

  12.     // Very large "tv_sec" values cause select() to fail.  

  13.     // Don't make it any larger than 1 million seconds (11.5 days)  

  14.     const long MAX_TV_SEC = MILLION;  

  15.     if (tv_timeToDelay.tv_sec > MAX_TV_SEC) {  

  16.         tv_timeToDelay.tv_sec = MAX_TV_SEC;  

  17.     }  

  18.     // Also check our "maxDelayTime" parameter (if it's > 0):  

  19.     if (maxDelayTime > 0  

  20.             && (tv_timeToDelay.tv_sec > (long) maxDelayTime / MILLION  

  21.                     || (tv_timeToDelay.tv_sec == (long) maxDelayTime / MILLION  

  22.                             && tv_timeToDelay.tv_usec  

  23.                                     > (long) maxDelayTime % MILLION))) {  

  24.         tv_timeToDelay.tv_sec = maxDelayTime / MILLION;  

  25.         tv_timeToDelay.tv_usec = maxDelayTime % MILLION;  

  26.     }  

  27.   

  28.     //先执行socket的select操作,以确定哪些socket任务(handler)需要执行。  

  29.     int selectResult = select(fMaxNumSockets,  

  30.             &readSet, &writeSet,&exceptionSet,  

  31.             &tv_timeToDelay);  

  32.   

  33.     if (selectResult < 0) {  

  34. //#if defined(__WIN32__) || defined(_WIN32)  

  35.         int err = WSAGetLastError();  

  36.         // For some unknown reason, select() in Windoze sometimes fails with WSAEINVAL if  

  37.         // it was called with no entries set in "readSet".  If this happens, ignore it:  

  38.         if (err == WSAEINVAL && readSet.fd_count == 0) {  

  39.             err = EINTR;  

  40.             // To stop this from happening again, create a dummy socket:  

  41.             int dummySocketNum = socket(AF_INET, SOCK_DGRAM, 0);  

  42.             FD_SET((unsigned) dummySocketNum, &fReadSet);  

  43.         }  

  44.         if (err != EINTR) {  

  45. //#else  

  46. //      if (errno != EINTR && errno != EAGAIN) {  

  47. //#endif  

  48.             // Unexpected error - treat this as fatal:  

  49. //#if !defined(_WIN32_WCE)  

  50. //          perror("BasicTaskScheduler::SingleStep(): select() fails");  

  51. //#endif  

  52.             internalError();  

  53.         }  

  54.     }  

  55.   

  56.     // Call the handler function for one readable socket:  

  57.     HandlerIterator iter(*fHandlers);  

  58.     HandlerDescriptor* handler;  

  59.     // To ensure forward progress through the handlers, begin past the last  

  60.     // socket number that we handled:  

  61.     if (fLastHandledSocketNum >= 0) {  

  62.         //找到上次执行的socket handler的下一个  

  63.         while ((handler = iter.next()) != NULL) {  

  64.             if (handler->socketNum == fLastHandledSocketNum)  

  65.                 break;  

  66.         }  

  67.         if (handler == NULL) {  

  68.             fLastHandledSocketNum = -1;  

  69.             iter.reset(); // start from the beginning instead  

  70.         }  

  71.     }  

  72.   

  73.     //从找到的handler开始,找一个可以执行的handler,不论其状态是可读,可写,还是出错,执行之。  

  74.     while ((handler = iter.next()) != NULL) {  

  75.         int sock = handler->socketNum; // alias  

  76.         int resultConditionSet = 0;  

  77.         if (FD_ISSET(sock, &readSet)  

  78.                 && FD_ISSET(sock, &fReadSet)/*sanity check*/)  

  79.             resultConditionSet |= SOCKET_READABLE;  

  80.         if (FD_ISSET(sock, &writeSet)  

  81.                 && FD_ISSET(sock, &fWriteSet)/*sanity check*/)  

  82.             resultConditionSet |= SOCKET_WRITABLE;  

  83.         if (FD_ISSET(sock, &exceptionSet)  

  84.                 && FD_ISSET(sock, &fExceptionSet)/*sanity check*/)  

  85.             resultConditionSet |= SOCKET_EXCEPTION;  

  86.         if ((resultConditionSet & handler->conditionSet)  

  87.                 != 0 && handler->handlerProc != NULL) {  

  88.             fLastHandledSocketNum = sock;  

  89.             // Note: we set "fLastHandledSocketNum" before calling the handler,  

  90.             // in case the handler calls "doEventLoop()" reentrantly.  

  91.             (*handler->handlerProc)(handler->clientData, resultConditionSet);  

  92.             break;  

  93.         }  

  94.     }  

  95.   

  96.     //如果寻找完了依然没有执行任何handle,则从头再找。  

  97.     if (handler == NULL && fLastHandledSocketNum >= 0) {  

  98.         // We didn't call a handler, but we didn't get to check all of them,  

  99.         // so try again from the beginning:  

  100.         iter.reset();  

  101.         while ((handler = iter.next()) != NULL) {  

  102.             int sock = handler->socketNum; // alias  

  103.             int resultConditionSet = 0;  

  104.             if (FD_ISSET(sock, &readSet)&& FD_ISSET(sock, &fReadSet)/*sanity check*/)  

  105.                 resultConditionSet |= SOCKET_READABLE;  

  106.             if (FD_ISSET(sock, &writeSet)&& FD_ISSET(sock, &fWriteSet)/*sanity check*/)  

  107.                 resultConditionSet |= SOCKET_WRITABLE;  

  108.             if (FD_ISSET(sock, &exceptionSet)   && FD_ISSET(sock, &fExceptionSet)/*sanity check*/)  

  109.                 resultConditionSet |= SOCKET_EXCEPTION;  

  110.             if ((resultConditionSet & handler->conditionSet)  

  111.                     != 0 && handler->handlerProc != NULL) {  

  112.                 fLastHandledSocketNum = sock;  

  113.                 // Note: we set "fLastHandledSocketNum" before calling the handler,  

  114.                 // in case the handler calls "doEventLoop()" reentrantly.  

  115.                 (*handler->handlerProc)(handler->clientData, resultConditionSet);  

  116.                 break;  

  117.             }  

  118.         }  

  119.   

  120.         //依然没有找到可执行的handler。  

  121.         if (handler == NULL)  

  122.             fLastHandledSocketNum = -1; //because we didn't call a handler  

  123.     }  

  124.   

  125.     //响应事件  

  126.     // Also handle any newly-triggered event  

  127.     // (Note that we do this *after* calling a socket handler,  

  128.     // in case the triggered event handler modifies The set of readable sockets.)  

  129.     if (fTriggersAwaitingHandling != 0) {  

  130.         if (fTriggersAwaitingHandling == fLastUsedTriggerMask) {  

  131.             // Common-case optimization for a single event trigger:  

  132.             fTriggersAwaitingHandling = 0;  

  133.             if (fTriggeredEventHandlers[fLastUsedTriggerNum] != NULL) {  

  134.                 //执行一个事件处理函数  

  135.                 (*fTriggeredEventHandlers[fLastUsedTriggerNum])(fTriggeredEventClientDatas[fLastUsedTriggerNum]);  

  136.             }  

  137.         } else {  

  138.             // Look for an event trigger that needs handling  

  139.             // (making sure that we make forward progress through all possible triggers):  

  140.             unsigned i = fLastUsedTriggerNum;  

  141.             EventTriggerId mask = fLastUsedTriggerMask;  

  142.   

  143.             do {  

  144.                 i = (i + 1) % MAX_NUM_EVENT_TRIGGERS;  

  145.                 mask >>= 1;  

  146.                 if (mask == 0)  

  147.                     mask = 0x80000000;  

  148.   

  149.                 if ((fTriggersAwaitingHandling & mask) != 0) {  

  150.                     //执行一个事件响应  

  151.                     fTriggersAwaitingHandling &= ~mask;  

  152.                     if (fTriggeredEventHandlers[i] != NULL) {  

  153.                         (*fTriggeredEventHandlers[i])(fTriggeredEventClientDatas[i]);  

  154.                     }  

  155.   

  156.                     fLastUsedTriggerMask = mask;  

  157.                     fLastUsedTriggerNum = i;  

  158.                     break;  

  159.                 }  

  160.             } while (i != fLastUsedTriggerNum);  

  161.         }  

  162.     }  

  163.   

  164.     //执行一个最迫切的延迟任务。  

  165.     // Also handle any delayed event that may have come due.  

  166.     fDelayQueue.handleAlarm();  

  167. }  


© 著作权归作者所有

Sean-x
粉丝 4
博文 57
码字总数 83950
作品 0
武汉
程序员
私信 提问
VLC源码分析知识总结 (一)#和##的使用

关于#和## 1.1).在C语言的宏中,#的功能是将其后面的宏参数进行字符串化操作(Stringfication),简单说就是在对它所引用的宏变量通过替换后在其左右各加上一个双引号。 比如在早期的VLC版本...

地狱的烈火
2013/04/26
0
0
基于Hi3516A的H265 IPC LIVE555 开发基本原理

转载于http://m.blog.csdn.net/faihung/article/details/73008742,如有侵权,请告知删除。 1 系统工作原理 系统以Hi3516A开发平台(由高分辨率1080 p的AR0330摄像头模块和带千兆以太网功能的...

oqqHuTu12345678
2018/01/02
0
0
Live555源代码解读(10)

十一 、h264 RTP传输详解(3) 书接上回:H264FUAFragmenter又对数据做了什么呢? [cpp] view plaincopy void H264FUAFragmenter::doGetNextFrame() { if (fNumValidDataBytes == 1) { // We h......

Sean-x
2016/02/25
12
0
Live555源代码解读(4)下

[cpp] view plaincopy static ServerMediaSession* createNewSMS(UsageEnvironment& env,char const* fileName, FILE* /fid/) { // Use the file name extension to determine the type of "......

Sean-x
2016/02/24
19
0
Live555源代码解读(9)

十 、h264 RTP传输详解(2) 上一章并没有把打开文件分析文件的代码找到,因为发现它隐藏得比较深,而且H264的Source又有多个,形成了连环计。所以此章中就将文件处理与H264的Source们并在一起...

Sean-x
2016/02/25
13
0

没有更多内容

加载失败,请刷新页面

加载更多

jni接口NewStringUTF崩溃

转载 原文 https://blog.csdn.net/churuxu/article/details/49999575 ndk开发中,将c/c++的UTF8编码的字符串转换成java字符串,使用了NewStringUTF接口。 当字符串中包含emoji字符时,在有些...

shzwork
昨天
0
0
北斗三号IGSO-2卫星发射成功!

6月25日,中国航天科技集团官方公众号宣布,北斗三号IGSO-2卫星发射成功! 航天科技集团表示,6月25日2点09分,我国在西昌卫星发射中心用长征三号乙运载火箭成功将北斗三号第2颗倾斜地球同步...

linuxCool
昨天
3
0
阿里java开发规约的Idea插件安装(英文)

Idea Plugin Prepare Project JDK: 1.7+ Gradle: 3.0+(Require JDK1.8+ for gradle) Build cd p3c-ideagradle clean buildPlugin Run plugin cd p3c-ideagradle runIde# run speci......

Airship
昨天
1
0
很多人转行做程序员选择web前端学习,前端简单在哪里?

不管你是工人阶层还是服务行业,是否想过转行IT,转行IT后肯定会选择一门编程语言进行深入学习,很多转行的人基础都不是太好,不是科班出身,甚至有的是专科乃至中专,前端的HTML和CSS相对其...

智云编程
昨天
2
0
一文读懂内网、公网和NAT

我们做弱电监控系统的时候,都避免不了要跟IP地址打交道,比如摄像头、NVR、服务器等这些设备安装好之后,就需要给它们配上IP,那这个IP地址你了解嘛?今天我们就一起来聊聊什么是内网、公网和...

老孟的Linux私房菜
昨天
5
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部