你真的懂select Socket模型吗?
你看到的这个文章来自于http://www.cnblogs.com/ayanmw
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);}
转载请注明出处:http://www.cnblogs.com/ayanmw 我会很高兴的!
------------------------------------------------------------------------------------------------
一定要专业!本博客定位于 ,C语言,C++语言,Java语言,Android开发和少量的Web开发,之前是做Web开发的,其实就是ASP维护,发现EasyASP这个好框架,对前端后端数据库 都很感觉亲切啊。.linux,总之后台开发多一点。以后也愿意学习 cocos2d-x 游戏客户端的开发。
你真的懂select Socket模型吗?相关推荐
- 你真的懂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 四. 实现重叠模型的步骤 作了这么多的准备工作,费了这么多的笔墨,我们终 ...
最新文章
- SAP QM 执行事务代码QA11 报错- Selected set code does not exist, or data entered is incomplete-
- springMVC3学习(二)--ModelAndView对象
- 转译:Oracle 中 Object_iD 和 Data_Object_ID 的区别
- python多核运行程序怎么关闭_在多核上运行程序
- [译]第三章:什么是组织结构
- matlab用解析法求二自由度阻尼系统的自由振动(先求系统状态方程
- 学生开源项目_吸引学生加入您的开源项目的9种方法
- 为什么说苹果是唯一在乎你隐私的科技公司?
- 启动车子温车_什么是冷车启动
- win11语言输入没反应怎么办 windows11语音输入没反应的解决方法
- 服务器VM虚拟机更换序列号,修改vmware虚拟机硬盘序列号id 献给初学者:谈谈如何学习Linux操作系统(3)...
- 创建JSON集合使用JSONArray.fromObject 转化后得到的jsonArray集为空?
- 设计思维的定义与一些步骤
- 网络信息安全之零信任
- 什么是dataSource 对数据源的简单理解。
- 用纯Python就能写一个漂亮的网页
- 发字的楷书写法图片_优秀的楷体书写作品高清图片
- 用python监控A股股票波动并发送预警邮件_V3
- html合并单元格后有虚线,excle单元格中间出现虚线/Excel表格里出现虚线,是怎么回事?...
- 汽车常识全面介绍 - 引擎详论
热门文章
- 用python画漫画_Python——turtle绘制动漫形象(魔法少女小圆晓美焰,super beautiful)...
- python模型训练效果没有优化_LSTM模型训练效果好,但测试结果较差,不能看出拟合过度...
- 【深度学习】单位高斯化
- 彩色图像分割方法的汇总
- Android开发入门经典实例
- java 异常捕捉 ( try catch finally ) 你真的掌握了吗?
- Java并发编程(8):多线程环境中安全使用集合API(含代码)
- Java并发编程(7):使用synchronized获取互斥锁的几点说明
- PowerPoint出现“受保护的视图,Office已检测到该文件存在问题。编辑此文件可能会损坏您的计算机。”的提示
- Nginx模块开发入门