【转载请注明出处】:http://blog.csdn.net/longlong530
EventThread负责侦听Darwin系统的Socket事件,包括以下两类, 对于两类事件是分别如何处理的,我们从头开始分析。
a) 建立新的RTSP连接请求事件
b) 已有RTSP连接上的RTSP请求消息事件
一. EventThread 的创建
RunServer.cpp 中StartServer函数初始化调用了 Socket::Initialize(),在该函数内即创建了EventThread,但是这里仅为创建,并未启动,所以还没有进入到线程的Entry()函数
二. EventThread 的启动
RunServer.cpp 中StartServer函数初始化调用了Socket::StartThread(),启动了在上一步创建的sEventThread类所对应的线程。
三. EventThread 的运行
EventThread 线程启动后进入,EventThread::Entry()函数中开始调用select_waitevent函数监听所有的Socket端口,直到有事件发生为止
当有事件发生时:
//通过事件中的标识找到相应的对象参考指针 StrPtrLen idStr((char*)&theCurrentEvent.er_data, sizeof(theCurrentEvent.er_data)); //fRefTable中的对象参考指针RTSPListenerSocket OSRef* ref = fRefTable.Resolve(&idStr); if (ref != NULL) { //通过参考指针得到EventContext对象 EventContext* theContext = (EventContext*)ref->GetObject();
找到对应的对象后,开始调用其处理方法,这里要着重关注ProcessEvent()方法:
ProcessEvent作为虚函数有两个实现,在这里RTSP连接和RTSP连接内的消息请求会有不同的调用分支;
EventContext类中实现了ProcessEvent方法;
EventContext的派生类TCPListenerSocket中实现了ProcessEvent方法。
a). 建立新的RTSP连接请求事件
fRefTable表插入时间: QTSServer::StartTasks()中的 fListeners[x]->RequestEvent(EV_RE);,存入的对象为RTSPListenerSocket
调用方法: TCPListenerSocket::ProcessEvent
方法描述: 此方法调用RTSPListenerSocket的GetSessionTask方法建立一个RTSPSession,并把相应的套接口加入侦听队列,等待RTSP请求。
然后还需调用this->RequestEvent(EV_RE)把建立RTSP连接的请求加入到侦听队列。
b). 已有RTSP连接上的RTSP请求消息事件
fRefTable表插入时间: 上一步的this->RequestEvent(EV_RE)
调用方法: EventContext::ProcessEvent
方法描述: 通过Task的Signal把对应的RTSPSession类型的Task加入到TaskThread::fTaskQueue中等待TaskThread处理。
//处理RTSP连接请求或者RTSP连接上的消息请求事件 theContext->ProcessEvent(theCurrentEvent.er_eventbits); fRefTable.Release(ref);//减少引用计数
另外介绍下TCPListenerSocket::ProcessEvent方法,摘取片段进行备注说明
//获取RTSPSession的fSocket参数,然后将当前接收数据的socket赋值给该参数; theTask = this->GetSessionTask(&theSocket); if (theTask == NULL) { //this should be a disconnect. do an ioctl call? close(osSocket); if (theSocket) theSocket->fState &= ~kConnected; // turn off connected state } else//创建成功,接着创建Socket对象; { /*此处省略部分代码*/ //把刚刚建立好的RTSP连接加入到侦听队列,等待RTSP请求的到来; theSocket->Set(osSocket, &addr); theSocket->InitNonBlocking(osSocket);//初始化; //将新建的RTSPSession保存到EventContext对应的fTask属性,当该socket连接后面的消息事件到来时即将该RTSPSession任务加入到task线程中; theSocket->SetTask(theTask); theSocket->RequestEvent(EV_RE);//新对象监听读事件;(EventContext开始监听该socket连接之上发送的消息) //theTask就是新建的RTSPSession; theTask->SetThreadPicker(Task::GetBlockingTaskThreadPicker()); //The RTSP Task processing threads
【转载请注明出处】:http://blog.csdn.net/longlong530