美文网首页
Live555 源代码分析(一)

Live555 源代码分析(一)

作者: RonZheng2010 | 来源:发表于2020-09-20 16:54 被阅读0次

版本说明

本文分析基于2019-12-30的版本。(Live555没有版本管理?)

1 Hash容器

1.1 HashTable

HashTable 定义了Hash表的接口。

  • 成员函数 Add()、Remove() 和 Lookup() 分别用于添加、删除和查找元素。

1.2 HashTable

BasicHashTable实现了HashTable接口。这是hash表的一个标准实现。

  • 成员fBuckets[]指向一个TableEntry*的数组。其中每个元素指向一个TableEntry链表。TableEntry包括一个(key,value)对。
  • 成员函数 hashIndexFromKey()计算key的HASH值。它将Key值进行若干变换,然后限缩在数组fBuckets的索引范围内。
  • 成员函数keyMatches()用于比较两个key值是否相同。
  • insertNewEntry()向Hash表添加新元素。
    • 它调用hashIndexFromKey()计算在数组fBucket中的索引,然后创建新的TableEntry实例,并挂接到该索引位置上的TableEntry链表。
  • TableEntry的key值一般有两种类型:string和unsigned。两种类型计算HASH值的方法不同。
  • 如果Hash表中的TableEntry实例数超过指定的阈值,则调用rebuild()重建Hash表,将成员fBuckets[]加长。这样做的目的是保证Hash表的效率。

2 任务调度

2.1 TaskScheduler

TaskScheduler定义任务调度器接口。

TaskScheduler接口涵盖三种任务:Socket监听、延时任务、和事件通知任务。后面依次说明这三种任务。

  • 成员函数setBackgroundHandling()创建Socket监听任务。
  • 成员函数createEventTrigger()创建事件通知任务,triggerEvent()触发任务。
  • 成员函数scheduleDelayedTask()创建延时任务。
  • 成员函数doEventLoop()处理任务。

2.2 HandlerDescritor、HandlerSet - Socket监听任务

HandlerDescriptor保存socket、以及与socket关联的处理函数。

  • 成员socketNum是socket的值
  • 成员conditionSet是fd_set值的组合
  • handlerProc是指定的处理函数,clientData是handlerProc的参数。

这些成员分别指定应该监控Socket上的什么事件(可读、可写、异常),事件发生时应该调用什么函数处理它。

HandlerSet是HandlerDescriptor的集合。

如下图,HandlerSet的成员fHandlers保存一个HandlerDescriptor双向列表。

对于HandlerDescriptor,

  • 成员fPrevHandler和fNextHandler用于链接双向链表。

对于HandlerSet,

  • 成员函数assignHandler()设置Socket的处理函数。创建新的HandlerDescriptor实例,或者更新已有的实例。创建HandlerDescriptor实例时,将它链接在双向链表的尾部。
  • 成员函数clearHandler()清除Socket的处理函数。在HandlerDescriptor的析构函数中,把它自身从双向链表中移除。
  • 成员函数lookupHandler()查找Socket的处理函数。

HanderIterator基于HandlerDescriptor双向链表。

  • 调用它的成员函数next(),可以遍历HandlerDescriptor链表。

2.3 AlarmHandler - 延时任务

DelayQueueEntry保存延时任务,而DelayQueue保存一个DelayQueueEntry双向链表。

对于DelayQueueEntry,

  • 成员fDeltaTimeRemaining保存延时的时长,这是一个相对值。
  • 成员fPrev和fNext 让DelayQueueEntry的多个实例能链成一个双向列表。
  • 虚拟成员函数handleTimeout()是延时到达时执行的函数。DelayQueueEntry的派生类可以定制自己的实现。

DelayQueue是一个DelayQueueEntry容器。

  • 它从DelayQueueEntry派生。这样的设计看起来只是为了不需要为起始节点加一个DelayQueryEntry成员。(让人迷惑的设计!)
  • 成员函数addEntry()、updateEntry()、和removeEntry()分别用于增加、更新和移除元素。

AlarmHandler是DelayQueueEntry的派生类,实现了虚拟成员函数handleTimeout()。

  • 成员fProc是处理函数,由handleTimeout()调用。成员fClientData是fProc的参数。两者在AlarmHandler的构造函数中作为参数指定。

在DelayQueueEntry双向链表中,元素的延时fDeltaTimeRemaining是相对的,是前一个元素的相对值。

如下图中,有4个元素,它们的fDeltaTimeRemaining值分别是4、4、3和2,那么第一个元素的实际延时是最近的,是4,其他元素的实际延时依次累加,分别是8、11和13。

DelayQueueEntry和DelayQueue用Timeval度量时间。Timeval的派生类DelayInterval和_EventTime,是对Timeval的简单包装。

2.4 事件通知任务

没有定义专门的类处理事件通知任务。BasicTaskScheduler0类直接处理这类任务。

2.5 BasicTaskScheduler0、BasicTaskScheduler

BasicTaskSchduler0实现了TaskScheduler接口,实现延时任务和事件监听任务。

BasicTaskScheduler派生自BasicTaskScheduler0,进一步实现socket监听任务。

对于BasicTaskSchduler0,

  • 实现shceduleDelayedTask()创建延时任务。成员fDelayQueue保存一组延时任务。
  • 实现createEventTrigger()和triggerEvent(),创建、触发事件通知任务。成员fTriggerEventHandlers[]保存一组事件通知任务。
  • BasicTaskScheduler0定义了新接口,也就是新的虚拟函数SingleStep()。它实现了虚拟函数doEventLoop()。在里面,它在循环中调用singleStep()。

对于BasicTaskScheduler,

  • 实现setBackgroundHandling()创建Socket监听任务。BasicTaskScheduler0的成员fHandlers保存socket处理函数。(为什么不是BasicTaskSchduler的成员?)
  • 实现BasicTaskScheduler0定义的接口SingleStep()。

在BasicTaskScheduler::SingleStep()中,

  • 调用select(),监听HandlerSet中保存的socket的可读、可写和异常信号。如果有信号,则调用指定HandlerSet实例中指定的处理函数TaskScheduler::BackgroundHandleProc()处理。
  • 检查fTriggerEventHandlers[]中的任务是否为触发状态,如果是,则调用指定处理函数TaskFunc()进行处理。
  • 调用DelayQueue::handleAlarm(),检查成员fDelayQueue中延时任务是否到达,如果是,调用处理函数TaskFunc()进行处理。

3 程序上下文

3.1 UsageEnvironment

UsageEnvironment定义了一个输出打印消息的接口。

  • 成员函数setResultMsg()将打印消息保存起来,getResultMsg()获得保存的打印信息, reportBackgroundError()输出保存的打印信息。
  • operator <<() 一系列成员函数,输出指定格式的数据。

BasicUsageEnvironment0实现了这个接口的setResultMsg()、getResultMsg()和reportBackgroundError()。

  • 成员fResultMsgBuffer[]保存打印消息。
  • reportBackgroundError()向stderr输出打印消息。

BasicUsageEnvironment进一步实现了这个接口的operator<<()系列函数。

  • 这些函数向stderr输出打印消息。

UsageEnvironment还是整个程序运行的上下文。

  • 成员fScheduler引用全局唯一的TaskScheduler实例
  • 成员liveMediaPriv引用全局唯一的_Tables实例,保存了两个全局表。
  • 成员groupsockPriv实际上是_groupsockPriv实例,保存几个组播全局变量,其中reuseFlag是绑定Socket时是否重用地址。

应用程序只创建一个UsageEnvironment实例。

3.2 _Tables - 全局容器

_Tables保存几个hash表。

  • _Tables是singleton模式,调用getOurTables()可以得到唯一的实例。
  • 成员mediaTable是其中一个Hash表,它是MediumLookupTable的实例。

3.3 Medium、MediaLookupTable

Medium给它的派生类的实例保存一个名字。

  • 成员fMediumName[]保存这个名字。这个名字调用MediaLookupTable::generateNewName()得到。
  • Medium还引用唯一的UsageEnvironment实例。

MediumLookupTable保存一个Medium集合。这个集合保存在成员fTable中,这是一个HashTable实例。

  • addNew()、lookup()和remove()分别向hashtable加入、查找和删除Medium实例。

相关文章

网友评论

      本文标题:Live555 源代码分析(一)

      本文链接:https://www.haomeiwen.com/subject/sscpyktx.html