缩略版muduo网络库（2）：事件处理器 Chanel

文章目录

从TcpServer开始，找到了EventLoop，在EventLoop中又找到了两个重要组成部分，Chanel和Poller，那就自底向上。

#pragma once#include "nocopyable.hpp"
#include "timestamp.hpp"#include <functional>
#include <memory>   //智能指针需要class EventLoop;    //前置声明，避免过多的头文件包含class Channel:nocpoyable{public:using EventCallback = std::function<void()>;    //设置事件回调名称using ReadEventCallback = std::function<void(timestamp)>; Channel(EventLoop* loop,int fd);    //这里只需要个指针，前置声明无伤大雅~Channel();//fd得到poller事件通知后，处理事件void handleEvent(timestamp receiveTime);    //这里需要初始化了，不能仅仅前置声明，需要包头文件了//设置回调函数对象void setReadCallback(ReadEventCallback cb){ readCallback_ = std::move(cb); }void setWriteCallback(EventCallback cb){ writeCallback_ = std::move(cb); }void setCloseCallback(EventCallback cb){ closeCallback_ = std::move(cb); }void setErrorCallback(EventCallback cb){ errorCallback_ = std::move(cb); }//防止手动remove channel之后，channel还在执行回调操作  void tie(const std::shared_ptr<void>&);int fd() const { return fd_; }int events() const { return events_; }void set_revents(int revt) { revents_ = revt; }// int revents() const { return revents_; }bool isNoneEvent() const { return events_ == kNoneEvent; }void enableReading() { events_ |= kReadEvent; update(); }void disableReading() { events_ &= ~kReadEvent; update(); }void enableWriting() { events_ |= kWriteEvent; update(); }void disableWriting() { events_ &= ~kWriteEvent; update(); }void disableAll() { events_ = kNoneEvent; update(); }bool isWriting() const { return events_ & kWriteEvent; }bool isReading() const { return events_ & kReadEvent; }// for Pollerint index() { return index_; }void set_index(int idx) { index_ = idx; }//one loop per threadEventLoop* ownerLoop() { return loop_; }void remove();private:void update();void handleEventWithGuard(timestamp receiveTime);//事件状态标志static const int kNoneEvent;static const int kReadEvent;static const int kWriteEvent;EventLoop* loop_;   //  事件循环const int fd_;      //poller监听对象int events_;        //注册fd感兴趣的事件int revents_;       //poller返回的具体发生的事情int index_;bool       logHup_;std::weak_ptr<void> tie_;int tied_;bool eventHandling_;bool addedToLoop_;//channel通道可以获知fd最终发生的具体时间revents，所以它负责调用具体事件的回调操作ReadEventCallback readCallback_;EventCallback writeCallback_;EventCallback closeCallback_;EventCallback errorCallback_;};

#include"channel.hpp"
#include"eventloop.hpp"
#include"logger.hpp"#include<sys/epoll.h>//事件状态标志
const int kNoneEvent = 0;
const int kReadEvent = EPOLLIN | EPOLLPRI;
const int kWriteEvent = EPOLLOUT;Channel::Channel(EventLoop* loop,int fd): loop_(loop),fd_(fd),events_(0),revents_(0),index_(-1),logHup_(true),tied_(false),eventHandling_(false),addedToLoop_(false)
{}Channel::~Channel(){}void Channel::tie(const std::shared_ptr<void> &obj){tie_ = obj;tied_ = true;
}//当改变了channel所表示的fd的events事件后，update负责在poller中修改fd相应事件的epoll_ctl
void Channel::update(){/*当channel所属的EventLoop调用poller的相应方法，注册fd的events事件add code...*/
}//用完了把自己咔嚓了
void Channel::remove(){//add code...
}void Channel::handleEvent(timestamp receiveTime){if (tied_){     //对于tied_的在哪里被修改使用目前是个未知数std::shared_ptr<void> guard = tie_.lock();if (guard){handleEventWithGuard(receiveTime);}}else{handleEventWithGuard(receiveTime);}}//根据具体接收到的事件，执行相应的回调操作
void Channel::handleEventWithGuard(timestamp receiveTime){LOG_INFO("channel handleEvent revents:%d",revents_);if((revents_ & EPOLLHUP) && !(revents_ & EPOLLIN)){ //发生异常if(closeCallback_){closeCallback_();}}if(revents_ & EPOLLERR){    //发生错误if(errorCallback_){errorCallback_();}}//有可读事件if(revents_ & (EPOLLIN | EPOLLPRI)){if(readCallback_){readCallback_(receiveTime);}}//有可写事件if(revents_ & EPOLLOUT){if(writeCallback_){writeCallback_();}}
}

缩略版muduo网络库（2）：事件处理器 Chanel相关推荐

muduo网络库使用心得
上个月看了朋友推荐的mudo网络库,下完代码得知是国内同行的开源作品,甚是敬佩.下了mudo使用手冊和035版的代码看了下结构,感觉是一个比較成熟并且方便使用的网络库.本人手头也有自己的网络库,尽管不 ...
muduo网络库学习（八）事件驱动循环线程池EventLoopThreadPool
muduo是支持多线程的网络库,在muduo网络库学习(七)用于创建服务器的类TcpServer中也提及了TcpServer中有一个事件驱动循环线程池,线程池中存在大量线程,每个线程运行一个Event ...
muduo网络库学习（七）用于创建服务器的类TcpServer
目前为止,涉及到的绝大多数操作都没有提及线程,EventLoop,Poller,Channel,Acceptor,TcpConnection,这些对象的执行都是在单独线程完成,并没有设计多线程的创建销 ...
muduo网络库学习（四）事件驱动循环EventLoop
muduo的设计采用高并发服务器框架中的one loop per thread模式,即一个线程一个事件循环. 这里的loop,其实就是muduo中的EventLoop,所以到目前为止,不管是Polle ...
muduo网络库源码阅读Step by Step
Posted on: Nov 26 2015 Categories: muduo C++ Tags: muduo 一般写服务端程序都需要有一个称手的网络库来帮我们处理琐碎的网络通信细节,比如连接的建立 ...
基于C++11的muduo网络库
文章目录写在前面项目编译问题库安装的问题项目测试代码关于压力测试项目概述 muduo网络库的reactor模型 muduo的设计 muduo各个类辅助类 NonCopyable Time ...
muduo网络库源码复现笔记(十七):什么都不做的EventLoop
Muduo网络库简介 muduo 是一个基于 Reactor 模式的现代 C++ 网络库,作者陈硕.它采用非阻塞 IO 模型,基于事件驱动和回调,原生支持多核多线程,适合编写 Linux 服务端多线程 ...
muduo网络库的封装
一.基础socket编程网络编程的底层离不开socket,其处理流程表示如下: int sockfd = socket(AF_INET, SOCK_STREAM, 0);struct sockadd ...
muduo网络库浅谈（一）
muduo网络库浅谈(一) 序言第一章 muduo的关键结构 class EventLoop class Channel class Poller 番外定时任务 class Timestamp c ...

缩略版muduo网络库（2）：事件处理器 Chanel

文章目录

缩略版muduo网络库（2）：事件处理器 Chanel相关推荐

最新文章

热门文章