【转】你真的懂select Socket模型吗?
volatile double SIGFPE_REQ = 0.0f;struct idx_info {int read_pos_plus1;int write_pos_plus1;};struct win32op {unsigned num_fds_in_fd_sets;int resize_out_sets;struct win_fd_set *readset_in;struct win_fd_set *writeset_in;struct win_fd_set *readset_out;struct win_fd_set *writeset_out;struct win_fd_set *exset_out;unsigned signals_are_broken : 1;};static void *win32_init(struct event_base *);static int win32_add(struct event_base *, evutil_socket_t, short old, short events, void *_idx);static int win32_del(struct event_base *, evutil_socket_t, short old, short events, void *_idx);static int win32_dispatch(struct event_base *base, struct timeval *);static void win32_dealloc(struct event_base *);struct eventop win32ops = {"win32",win32_init,win32_add,win32_del,win32_dispatch,win32_dealloc,0, /* doesn't need reinit */0, /* No features supported. */sizeof(struct idx_info),};#define FD_SET_ALLOC_SIZE(n) ((sizeof(struct win_fd_set) + ((n)-1)*sizeof(SOCKET)))static intgrow_fd_sets(struct win32op *op, unsigned new_num_fds){size_t size;EVUTIL_ASSERT(new_num_fds >= op->readset_in->fd_count &&new_num_fds >= op->writeset_in->fd_count);EVUTIL_ASSERT(new_num_fds >= 1);size = FD_SET_ALLOC_SIZE(new_num_fds);if (!(op->readset_in = mm_realloc(op->readset_in, size)))return (-1);if (!(op->writeset_in = mm_realloc(op->writeset_in, size)))return (-1);op->resize_out_sets = 1;op->num_fds_in_fd_sets = new_num_fds;return (0);}static intdo_fd_set(struct win32op *op, struct idx_info *ent, evutil_socket_t s, int read){struct win_fd_set *set = read ? op->readset_in : op->writeset_in;if (read) {if (ent->read_pos_plus1 > 0)return (0);} else {if (ent->write_pos_plus1 > 0)return (0);}if (set->fd_count == op->num_fds_in_fd_sets) {if (grow_fd_sets(op, op->num_fds_in_fd_sets*2))return (-1);/* set pointer will have changed and needs reiniting! */set = read ? op->readset_in : op->writeset_in;}set->fd_array[set->fd_count] = s;if (read)ent->read_pos_plus1 = set->fd_count+1;elseent->write_pos_plus1 = set->fd_count+1;return (set->fd_count++);}static intdo_fd_clear(struct event_base *base,struct win32op *op, struct idx_info *ent, int read){int i;struct win_fd_set *set = read ? op->readset_in : op->writeset_in;if (read) {i = ent->read_pos_plus1 - 1;ent->read_pos_plus1 = 0;} else {i = ent->write_pos_plus1 - 1;ent->write_pos_plus1 = 0;}if (i < 0)return (0);if (--set->fd_count != (unsigned)i) {struct idx_info *ent2;SOCKET s2;s2 = set->fd_array[i] = set->fd_array[set->fd_count];ent2 = evmap_io_get_fdinfo(&base->io, s2);if (!ent2) /* This indicates a bug. */return (0);if (read)ent2->read_pos_plus1 = i+1;elseent2->write_pos_plus1 = i+1;}return (0);}#define NEVENT 32void *win32_init(struct event_base *_base){struct win32op *winop;size_t size;if (!(winop = mm_calloc(1, sizeof(struct win32op))))return NULL;winop->num_fds_in_fd_sets = NEVENT;size = FD_SET_ALLOC_SIZE(NEVENT);if (!(winop->readset_in = mm_malloc(size)))goto err;if (!(winop->writeset_in = mm_malloc(size)))goto err;if (!(winop->readset_out = mm_malloc(size)))goto err;if (!(winop->writeset_out = mm_malloc(size)))goto err;if (!(winop->exset_out = mm_malloc(size)))goto err;winop->readset_in->fd_count = winop->writeset_in->fd_count = 0;winop->readset_out->fd_count = winop->writeset_out->fd_count= winop->exset_out->fd_count = 0;if (evsig_init(_base) < 0)winop->signals_are_broken = 1;return (winop);err:XFREE(winop->readset_in);XFREE(winop->writeset_in);XFREE(winop->readset_out);XFREE(winop->writeset_out);XFREE(winop->exset_out);XFREE(winop);return (NULL);}intwin32_add(struct event_base *base, evutil_socket_t fd,short old, short events, void *_idx){struct win32op *win32op = base->evbase;struct idx_info *idx = _idx;if ((events & EV_SIGNAL) && win32op->signals_are_broken)return (-1);if (!(events & (EV_READ|EV_WRITE)))return (0);event_debug(("%s: adding event for %d", __func__, (int)fd));if (events & EV_READ) {if (do_fd_set(win32op, idx, fd, 1)<0)return (-1);}if (events & EV_WRITE) {if (do_fd_set(win32op, idx, fd, 0)<0)return (-1);}return (0);}intwin32_del(struct event_base *base, evutil_socket_t fd, short old, short events,void *_idx){struct win32op *win32op = base->evbase;struct idx_info *idx = _idx;event_debug(("%s: Removing event for "EV_SOCK_FMT,__func__, EV_SOCK_ARG(fd)));if (events & EV_READ)do_fd_clear(base, win32op, idx, 1);if (events & EV_WRITE)do_fd_clear(base, win32op, idx, 0);return 0;}static voidfd_set_copy(struct win_fd_set *out, const struct win_fd_set *in){out->fd_count = in->fd_count;memcpy(out->fd_array, in->fd_array, in->fd_count * (sizeof(SOCKET)));}/*static void dump_fd_set(struct win_fd_set *s){unsigned int i;printf("[ ");for(i=0;i<s->fd_count;++i)printf("%d ",(int)s->fd_array[i]);printf("]\n");}*/intwin32_dispatch(struct event_base *base, struct timeval *tv){struct win32op *win32op = base->evbase;int res = 0;unsigned j, i;int fd_count;SOCKET s;if (win32op->resize_out_sets) {size_t size = FD_SET_ALLOC_SIZE(win32op->num_fds_in_fd_sets);if (!(win32op->readset_out = mm_realloc(win32op->readset_out, size)))return (-1);if (!(win32op->exset_out = mm_realloc(win32op->exset_out, size)))return (-1);if (!(win32op->writeset_out = mm_realloc(win32op->writeset_out, size)))return (-1);win32op->resize_out_sets = 0;}fd_set_copy(win32op->readset_out, win32op->readset_in);fd_set_copy(win32op->exset_out, win32op->writeset_in);fd_set_copy(win32op->writeset_out, win32op->writeset_in);fd_count =(win32op->readset_out->fd_count > win32op->writeset_out->fd_count) ?win32op->readset_out->fd_count : win32op->writeset_out->fd_count;if (!fd_count) {long msec = tv ? evutil_tv_to_msec(tv) : LONG_MAX;/* Sleep's DWORD argument is unsigned long */if (msec < 0)msec = LONG_MAX;/* Windows doesn't like you to call select() with no sockets */Sleep(msec);return (0);}EVBASE_RELEASE_LOCK(base, th_base_lock);res = select(fd_count,(struct fd_set*)win32op->readset_out,(struct fd_set*)win32op->writeset_out,(struct fd_set*)win32op->exset_out, tv);EVBASE_ACQUIRE_LOCK(base, th_base_lock);event_debug(("%s: select returned %d", __func__, res));if (res <= 0) {return res;}if (win32op->readset_out->fd_count) {i = rand() % win32op->readset_out->fd_count;for (j=0; j<win32op->readset_out->fd_count; ++j) {if (++i >= win32op->readset_out->fd_count)i = 0;s = win32op->readset_out->fd_array[i];evmap_io_active(base, s, EV_READ);}}if (win32op->exset_out->fd_count) {i = rand() % win32op->exset_out->fd_count;for (j=0; j<win32op->exset_out->fd_count; ++j) {if (++i >= win32op->exset_out->fd_count)i = 0;s = win32op->exset_out->fd_array[i];evmap_io_active(base, s, EV_WRITE);}}if (win32op->writeset_out->fd_count) {SOCKET s;i = rand() % win32op->writeset_out->fd_count;for (j=0; j<win32op->writeset_out->fd_count; ++j) {if (++i >= win32op->writeset_out->fd_count)i = 0;s = win32op->writeset_out->fd_array[i];evmap_io_active(base, s, EV_WRITE);}}return (0);}voidwin32_dealloc(struct event_base *_base){struct win32op *win32op = _base->evbase;evsig_dealloc(_base);if (win32op->readset_in)mm_free(win32op->readset_in);if (win32op->writeset_in)mm_free(win32op->writeset_in);if (win32op->readset_out)mm_free(win32op->readset_out);if (win32op->writeset_out)mm_free(win32op->writeset_out);if (win32op->exset_out)mm_free(win32op->exset_out);/* XXXXX free the tree. */memset(win32op, 0, sizeof(win32op));mm_free(win32op);}
转载于:https://www.cnblogs.com/ayanmw/p/3467373.html
【转】你真的懂select Socket模型吗?相关推荐
- 你真的懂select Socket模型吗?
你看到的这个文章来自于http://www.cnblogs.com/ayanmw 转自:http://www.cppblog.com/xvsdf100/archive/2013/12/10/20468 ...
- 你真的懂select吗??
只要接触过c/c++网路编程人都可能会知道select io 模式,网络书籍都说 fd_set {int num; SOCKET arr[64]} 有所限制,因为数组的长度只有64,那么超过64你就不 ...
- 你真的懂网络分层模型吗?
写在前边 整个暑假去面试,面试了很多家公司(无论是小厂还是大厂)问到的深度不同,网络原理是面试最容易问到的问题,虽然我们在项目中很少去实践它,但是了解其原理,会让我们背后网络通信是如果工作的,既能在面 ...
- 程序猿修仙之路--数据结构之你是否真的懂数组? c#socket TCP同步网络通信 用lambda表达式树替代反射 ASP.NET MVC如何做一个简单的非法登录拦截...
程序猿修仙之路--数据结构之你是否真的懂数组? 数据结构 但凡IT江湖侠士,算法与数据结构为必修之课.早有前辈已经明确指出:程序=算法+数据结构 .要想在之后的江湖历练中通关,数据结构必不可少.数据 ...
- 手把手教你玩转SOCKET模型:完成端口(Completion Port)详解
这篇文档我非常详细并且图文并茂的介绍了关于网络编程模型中完成端口的方方面面的信息,从API的用法到使用的步骤,从完成端口的实现机理到实际使用的注意事项,都有所涉及,并且为了让朋友们更直观的体会完成端口 ...
- Socket模型详解
Socket模型详解 两种I/O模式 一.选择模型 二.异步选择 三.事件选择 四.重叠I/O模型 五.完成端口模型 五种I/O模型的比较 两种I/O模式 1. 两种I/O模式 阻塞模式:执行I/O操 ...
- 读懂select函数
读懂select函数 1.定义: select函数属于IO多路转接模型中的监控函数,主要是监控描述符的读写和异常. 2.接口: void FD_ZERO(fd_set *set); 清空集合 fd_s ...
- 彻底搞懂 select/poll/epoll,就这篇了!
之前已经把网络 I/O 相关要点都盘了,还剩 select/poll/epoll 这几个区别没说,这篇就来搞搞它们,并且是从完全理解原理的角度来区分它们. 本来是要上源码的,但是感觉没啥必要,身为应用 ...
- 示波器_你真的懂示波器嘛?面试中会用到的示波器知识
示波器是电子工程师经常使用到的电子测量仪器,用途十分广泛,可将肉眼看不见的电信号变换成看得见的图像,便于人们研究各种电现象的变化过程.利用示波器能观察各种不同信号幅度随时间变化的波形曲线,还可以用它测 ...
- 手把手教你玩转SOCKET模型之重叠I/O篇(下)
http://blog.csdn.net/PiggyXP/archive/2004/09/23/114908.aspx 四. 实现重叠模型的步骤 作了这么多的准备工作,费了这么多的笔墨,我们终 ...
最新文章
- 破解无线路由免费上网
- C++包含头文件几种方式
- PAT-B 1015. 德才论(同PAT 1062. Talent and Virtue)
- Exchange Server 2003邮件服务器系统的基本部署思路
- java uuid静态方法_Java UUID compareTo()方法与示例
- Java笔记-当返回数据为Json时去除为null的字段
- Memcache安全性
- android学习笔记---34_Activity的启动模式
- ActionScript 与后台交互 RemoteObject
- hibernate关联映射
- 全网首发:解决JDK绘制位图字体的旋转位置错误
- 某超市销售数据的分析
- shell脚本学习指南-学习(1)
- 利用SPI编写类似sockscap的代理工具
- VMware安装win10:需win10虚拟机专用镜像,不是真机装系统的ISO镜像
- 欧几里得算法和扩展欧几里得算法
- plc原理及应用_【工控资料】西门子、三菱、欧姆龙PLC电气设计与编程自学宝典(双色版)...
- php 实现贪吃蛇游戏,php编写的贪吃蛇游戏
- js通过对象通过value找key
- 2022年值得购买的拍照手机推荐 这五款出片率极强
热门文章
- maven,eclipse--build时出现No compiler is provided in this environment
- 基于MicroPython:TPYBoard心率监测器
- SpringMVC之拦截器实现登录验证
- JavaScript基础笔记(十四)最佳实践
- 【转】某女生编的c语言程序
- [漏洞案例]thinkcmf 2.x从sql注入到getshell实战
- [leetcode] 65. 有效数字
- (二)cmockery中run_tests.c分析
- 动态规划解决分割问题
- 微信小程序组件slider