libevent源码学习6---链接监听器evconnlistener

libevent源码学习6—链接监听器evconnlistener

evconnlistener 机制提供了监听和接受 TCP 连接的方法。

struct evconnlistener {const struct evconnlistener_ops *ops;void *lock;evconnlistener_cb cb;evconnlistener_errorcb errorcb;void *user_data;unsigned flags;short refcnt;int accept4_flags;unsigned enabled : 1;
};

1. 创建和释放evconnlistener

/**Allocate a new evconnlistener object to listen for incoming TCP connectionson a given file descriptor.@param base The event base to associate the listener with.@param cb A callback to be invoked when a new connection arrives.  If thecallback is NULL, the listener will be treated as disabled until thecallback is set.@param ptr A user-supplied pointer to give to the callback.@param flags Any number of LEV_OPT_* flags@param backlog Passed to the listen() call to determine the length of theacceptable connection backlog.  Set to -1 for a reasonable default.Set to 0 if the socket is already listening.@param fd The file descriptor to listen on.  It must be a nonblockingfile descriptor, and it should already be bound to an appropriateport and address.
*/
struct evconnlistener *evconnlistener_new(struct event_base *base,evconnlistener_cb cb, void *ptr, unsigned flags, int backlog,evutil_socket_t fd);

/**Allocate a new evconnlistener object to listen for incoming TCP connectionson a given address.@param base The event base to associate the listener with.@param cb A callback to be invoked when a new connection arrives. If thecallback is NULL, the listener will be treated as disabled until thecallback is set.@param ptr A user-supplied pointer to give to the callback.@param flags Any number of LEV_OPT_* flags@param backlog Passed to the listen() call to determine the length of theacceptable connection backlog.  Set to -1 for a reasonable default.@param addr The address to listen for connections on.@param socklen The length of the address.*/
struct evconnlistener *evconnlistener_new_bind(struct event_base *base,evconnlistener_cb cb, void *ptr, unsigned flags, int backlog,const struct sockaddr *sa, int socklen);

两个函数都分配和返回一个新的链接监听器对象。差异在于后面的参数，前者是根据给定文件描述符，后者是根据给定的地址。

/**Disable and deallocate an evconnlistener.*/
void evconnlistener_free(struct evconnlistener *lev);

1.1 可识别的标志

可以给 evconnlistener_new() 函数的 flags 参数传入一些标志。可以用或 运算任意连接下述几个常用的标志:

  • LEV_OPT_LEAVE_SOCKETS_BLOCKING
    默认情况下，连接监听器接收新套接字后，会将其设置为非阻塞的，以便将其用于 libevent。如果不想要这种行为，可以设置这个标志。
  • LEV_OPT_CLOSE_ON_FREE
    如果设置了这个选项，释放连接监听器会关闭底层套接字。
  • LEV_OPT_CLOSE_ON_EXEC
    如果设置了这个选项，连接监听器会为底层套接字设置 close-on-exec 标志。更多信息请查看 fcntl 和 FD_CLOEXEC 的平台文档。
  • LEV_OPT_REUSEABLE
    某些平台在默认情况下，关闭某监听套接字后，要过一会儿其他套接字才可以绑定到同一个端口。设置这个标志会让 libevent 标记套接字是可重用的，这样一旦关闭，可以立即打开其他套接字，在相同端口进行监听。
  • LEV_OPT_THREADSAFE
    指示侦听器应被锁定，以便可以安全地同时从多个线程使用

文档全部标志，感兴趣可以看看

/** Flag: Indicates that we should not make incoming sockets nonblocking* before passing them to the callback. */
#define LEV_OPT_LEAVE_SOCKETS_BLOCKING	(1u<<0)
/** Flag: Indicates that freeing the listener should close the underlying* socket. */
#define LEV_OPT_CLOSE_ON_FREE		(1u<<1)
/** Flag: Indicates that we should set the close-on-exec flag, if possible */
#define LEV_OPT_CLOSE_ON_EXEC		(1u<<2)
/** Flag: Indicates that we should disable the timeout (if any) between when* this socket is closed and when we can listen again on the same port. */
#define LEV_OPT_REUSEABLE		(1u<<3)
/** Flag: Indicates that the listener should be locked so it's safe to use* from multiple threadcs at once. */
#define LEV_OPT_THREADSAFE		(1u<<4)
/** Flag: Indicates that the listener should be created in disabled* state. Use evconnlistener_enable() to enable it later. */
#define LEV_OPT_DISABLED		(1u<<5)
/** Flag: Indicates that the listener should defer accept() until data is* available, if possible.  Ignored on platforms that do not support this.** This option can help performance for protocols where the client transmits* immediately after connecting.  Do not use this option if your protocol* _doesn't_ start out with the client transmitting data, since in that case* this option will sometimes cause the kernel to never tell you about the* connection.** This option is only supported by evconnlistener_new_bind(): it can't* work with evconnlistener_new_fd(), since the listener needs to be told* to use the option before it is actually bound.*/
#define LEV_OPT_DEFERRED_ACCEPT		(1u<<6)
/** Flag: Indicates that we ask to allow multiple servers (processes or* threads) to bind to the same port if they each set the option. * * SO_REUSEPORT is what most people would expect SO_REUSEADDR to be, however* SO_REUSEPORT does not imply SO_REUSEADDR.** This is only available on Linux and kernel 3.9+*/
#define LEV_OPT_REUSEABLE_PORT		(1u<<7)
/** Flag: Indicates that the listener wants to work only in IPv6 socket.** According to RFC3493 and most Linux distributions, default value is to* work in IPv4-mapped mode. If there is a requirement to bind same port* on same ip addresses but different handlers for both IPv4 and IPv6,* it is required to set IPV6_V6ONLY socket option to be sure that the* code works as expected without affected by bindv6only sysctl setting in* system.** This socket option also supported by Windows.*/
#define LEV_OPT_BIND_IPV6ONLY		(1u<<8)

1.2 链接监听器回调

/**A callback that we invoke when a listener has a new connection.@param listener The evconnlistener@param fd The new file descriptor@param addr The source address of the connection@param socklen The length of addr@param user_arg the pointer passed to evconnlistener_new()*/
typedef void (*evconnlistener_cb)(struct evconnlistener *, evutil_socket_t, struct sockaddr *, int socklen, void *);

2. 启用和禁用 evconnlistener

int evconnlistener_disable(struct evconnlistener *lev);
int evconnlistener_enable(struct evconnlistener *lev);

这两个函数暂时禁止或者重新允许监听新连接。

3. 调整 evconnlistener 的回调函数

/** Change the callback on the listener to cb and its user_data to arg.*/
void evconnlistener_set_cb(struct evconnlistener *lev,evconnlistener_cb cb, void *arg);

4. 检测 evconnlistener

/** Return the socket that an evconnlistner is listening on. */
evutil_socket_t evconnlistener_get_fd(struct evconnlistener *lev);

/** Return an evconnlistener's associated event_base. */
struct event_base *evconnlistener_get_base(struct evconnlistener *lev);

这两个函数分别返回监听器关联的套接字和 event_base。

5. 侦测错误

可以设置一个一旦监听器上的 accept()调用失败就被调用的错误回调函数。对于一个不解决就会锁定进程的错误条件，这很重要。

/**A callback that we invoke when a listener encounters a non-retriable error.@param listener The evconnlistener@param user_arg the pointer passed to evconnlistener_new()*/
typedef void (*evconnlistener_errorcb)(struct evconnlistener *, void *);/** Set an evconnlistener's error callback. */
void evconnlistener_set_error_cb(struct evconnlistener *lev,evconnlistener_errorcb errorcb);

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/52554.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

职业技术培训内容介绍

职业技术培训内容介绍

泰迪职业技术培训包括&#xff1a;Python技术应用、大数据技术应用、机器学习、大数据分析 、人工智能技术应用。 职业技术培训-Python技术应用 “Python技术应用工程师”职业技术认证是由工业和信息化部教育与考试中心推出一套专业化、科学化、系统化的人才考核标准&…
阅读更多...
行业追踪，2023-08-24

行业追踪，2023-08-24

自动复盘 2023-08-24 凡所有相&#xff0c;皆是虚妄。若见诸相非相&#xff0c;即见如来。 k 线图是最好的老师&#xff0c;每天持续发布板块的rps排名&#xff0c;追踪板块&#xff0c;板块来开仓&#xff0c;板块去清仓&#xff0c;丢弃自以为是的想法&#xff0c;板块去留让…
阅读更多...
Hadoop分布式计算与资源调度：打开专业江湖的魔幻之门

Hadoop分布式计算与资源调度：打开专业江湖的魔幻之门

文章目录 版权声明一 分布式计算概述1.1 分布式计算1.2 分布式&#xff08;数据&#xff09;计算模式1.3 小结 二 MapReduce概述2.1 分布式计算框架 - MapReduce2.2 MapReduce执行原理2.3 小结 三 YARN概述3.1 YARN & MapReduce3.2 资源调度3.3 程序的资源调度3.4 YARN的资…
阅读更多...
进程同步

进程同步

目录 临界区&#xff08;Critical Section&#xff09;: 互斥量&#xff08;Mutex&#xff09;: 信号量&#xff08;Semaphore&#xff09;: 事件&#xff08;Event&#xff09;: 进程同步的四种方法 临界区&#xff08;Critical Section&#xff09;: 通过对多线程的串行…
阅读更多...
Apache Hudi初探(二)(与flink的结合)--flink写hudi的操作(JobManager端的提交操作)

Apache Hudi初探(二)(与flink的结合)--flink写hudi的操作(JobManager端的提交操作)

背景 在Apache Hudi初探(一)(与flink的结合)中&#xff0c;我们提到了Pipelines.hoodieStreamWrite 写hudi文件,这个操作真正写hudi是在Pipelines.hoodieStreamWrite方法下的transform(opName("stream_write", conf), TypeInformation.of(Object.class), operatorFa…
阅读更多...
AI加持，创意设计效率百倍提升，探秘背后的数字化魔法

AI加持，创意设计效率百倍提升，探秘背后的数字化魔法

在当今创新潮流不断涌现的时代&#xff0c;人工智能正以惊人的速度和深度赋能各行各业&#xff0c;食品包装设计界也已来到了一个“拼创意、拼二创和拼审美”的时代。有了AI的加入&#xff0c;设计界正迎来一股AI创意风暴&#xff0c;不仅颠覆了设计流程&#xff0c;更为食品包…
阅读更多...
go MongoDB

go MongoDB

安装 go get go.mongodb.org/mongo-driver/mongo package mongodbexampleimport ("context""fmt""ginapi/structs""time""go.mongodb.org/mongo-driver/bson""go.mongodb.org/mongo-driver/bson/primitive""…
阅读更多...
全流程R语言Meta分析核心技术高阶应用

全流程R语言Meta分析核心技术高阶应用

查看原文>>>全流程R语言Meta分析核心技术高阶应用 目录 专题一、Meta分析的选题与检索 专题二、Meta分析与R语言数据清洗及统计方法 专题三、R语言Meta分析与作图 专题四、R语言Meta回归分析 专题五、R语言Meta诊断分析 专题六、R语言Meta分析的不确定性 专题…
阅读更多...
Linux centos7 bash编程小训练

Linux centos7 bash编程小训练

训练要求&#xff1a; 求比一个数小的最大回文数 知识点&#xff1a; 一个数字正读反读都一样&#xff0c;我们称为回文数&#xff0c;如5、11、55、121、222等。 我们训练用bash编写一个小程序&#xff0c;由我们标准输入一个整数&#xff0c;计算机将显示出一个比这个数小…
阅读更多...
最新ai系统ChatGPT程序源码+详细搭建教程+mj以图生图+Dall-E2绘画+支持GPT4+AI绘画+H5端+Prompt知识库

最新ai系统ChatGPT程序源码+详细搭建教程+mj以图生图+Dall-E2绘画+支持GPT4+AI绘画+H5端+Prompt知识库

目录 一、前言 二、系统演示 三、功能模块 3.1 GPT模型提问 3.2 应用工作台 3.3 Midjourney专业绘画 3.4 mind思维导图 四、源码系统 4.1 前台演示站点 4.2 SparkAi源码下载 4.3 SparkAi系统文档 五、详细搭建教程 5.1 基础env环境配置 5.2 env.env文件配置 六、环境…
阅读更多...
Java设计模式之建造者模式

Java设计模式之建造者模式

建造者模式&#xff0c;又称生成器模式&#xff1a;将一个复杂的构建与其表示相分离&#xff0c;使得同样的构建过程可以创建不同的表示。 三个角色&#xff1a;建造者、具体的建造者、监工、使用者 建造者角色&#xff1a;定义生成实例所需要的所有方法&#xff1b; 具体的建…
阅读更多...
力扣--数组类题目27. 移除元素

力扣--数组类题目27. 移除元素

给你一个数组 nums 和一个值 val&#xff0c;你需要 原地 移除所有数值等于 val 的元素&#xff0c;并返回移除后数组的新长度。 示例 1&#xff1a; 输入&#xff1a;nums [3,2,2,3], val 3 输出&#xff1a;2, nums [2,2] 解释&#xff1a;函数应该返回新的长度 2, 并且 n…
阅读更多...
曲面（弧面、柱面）展平（拉直）瓶子标签识别ocr

曲面（弧面、柱面）展平（拉直）瓶子标签识别ocr

瓶子或者柱面在做字符识别的时候由于变形&#xff0c;识别效果是很不好的 或者是检测瓶子表面缺陷的时候效果也没有展平的好 下面介绍两个项目&#xff0c;关于曲面&#xff08;弧面、柱面&#xff09;展平&#xff08;拉直&#xff09; 项目一&#xff1a;通过识别曲面的6个点…
阅读更多...
《Go 语言第一课》课程学习笔记（十）

《Go 语言第一课》课程学习笔记（十）

复合数据类型 同构复合类型&#xff1a;从定长数组到变长切片 由多个同构类型&#xff08;相同类型&#xff09;或异构类型&#xff08;不同类型&#xff09;的元素的值组合而成&#xff0c;这类数据类型在 Go 语言中被称为复合类型。 数组有哪些基本特性&#xff1f; Go 语…
阅读更多...
c语言 - inline关键字（内联函数）

c语言 - inline关键字（内联函数）

概念 在编程中&#xff0c;inline是一个关键字&#xff0c;用于修饰函数。inline函数是一种对编译器的提示&#xff0c;表示这个函数在编译时应该进行内联展开。 内联展开是指将函数的代码插入到调用该函数的地方&#xff0c;而不是通过函数调用的方式执行。这样可以减少函数调…
阅读更多...
用手势操控现实：OpenCV 音量控制与 AI 换脸技术解析

用手势操控现实：OpenCV 音量控制与 AI 换脸技术解析

基于opencv的手势控制音量和ai换脸 HandTrackingModule.py import cv2 import mediapipe as mp import timeclass handDetector():def __init__(self, mode False, maxHands 2, model_complexity 1, detectionCon 0.5, trackCon 0.5):self.mode modeself.maxHands max…
阅读更多...
MySQL三大日志(binlog、redo log和undo log)详解

MySQL三大日志(binlog、redo log和undo log)详解

1.redo log redo log是InnoDB存储引擎层的日志&#xff0c;又称重做日志文件。 用于记录事务操作的变化&#xff0c;记录的是数据修改之后的值&#xff0c;不管事务是否提交都会记录下来 redo log包括两部分&#xff1a;一个是内存中的日志缓冲(redo log buffer)&#xff0c;另…
阅读更多...
PythonJS逆向解密——实现翻译软件+语音播报

PythonJS逆向解密——实现翻译软件+语音播报

前言 嗨喽&#xff0c;大家好呀~这里是爱看美女的茜茜呐 环境使用: python 3.8 pycharm 模块使用: requests --> pip install requests execjs --> pip install PyExecJS ttkbootstrap --> pip install ttkbootstrap pyttsx3 --> pip install pyttsx3 第三…
阅读更多...
数据分享|R语言PCA主成分、lasso、岭回归降维分析近年来各国土地面积变化影响...

数据分享|R语言PCA主成分、lasso、岭回归降维分析近年来各国土地面积变化影响...

全文链接&#xff1a;http://tecdat.cn/?p31445 机器学习在环境监测领域的应用&#xff0c;着眼于探索全球范围内的环境演化规律&#xff0c;人类与自然生态之间的关系以及环境变化对人类生存的影响&#xff08;点击文末“阅读原文”获取完整代码数据&#xff09;。 课题着眼于…
阅读更多...
Yolov8小目标检测（10）：DCNv3可形变卷积助力涨点，COCO新纪录65.4mAP | CVPR2023 InternImage

Yolov8小目标检测（10）：DCNv3可形变卷积助力涨点，COCO新纪录65.4mAP | CVPR2023 InternImage

💡💡💡本文改进：DCNv3，基于DCNv2算子引入共享投射权重、多组机制和采样点调制 DCNv3 | 亲测在红外弱小目标检测涨点，map@0.5 从0.755提升至0.765 💡💡💡Yolo小目标检测，独家首发创新（原创），适用于Yolov5、Yolov7、Yolov8等各个Yolo系列，专栏文章提供每一…
阅读更多...
最新文章

Copyright @ 2022~2023