首页
下载
文档
问答社区
视频
捐赠
源代码
AI 助理
赞助商
CRMEB
Apipost
腾讯云
微擎
禅道
51Talk
商业产品
Swoole AI 智能文档翻译器
Swoole-Compiler PHP 代码加密器
CRMEB 新零售社交电商系统
登录
注册
全部
提问
分享
讨论
建议
公告
开发框架
CodeGalaxy
发表新帖
阅读源码发现几个问题
请问下高手，其中发现一个问题是： if (SwooleTG.type == SW_THREAD_REACTOR) { return swReactorThread_send2worker((void *) &(task->data), send_len, target_worker_id); } else { return swServer_send2worker_blocking(serv, (void *) &(task->data), send_len, target_worker_id); } **swServer_send2worker_blocking**这个方法是阻塞发送，但是有个问题，看了他的实现，发现如果写入失败返回EAGAIN的话，只是等待，没有将这次的写入数据重发，这数据不是就丢掉了吗？ 第二个问题 代码里有一处直接 if (read(event->fd, &task, sizeof(task)) > 0) { /** * Big package */ ret = swWorker_excute(factory, &task); if (task.info.type == SW_EVENT_PACKAGE_START) { //no data if (ret < 0 && errno == EAGAIN) { return SW_OK; } else if (ret > 0) { goto read_from_pipe; } } return ret; } 不考虑read中发生EINTR以及EANGIN事件吗？无法保证一下子读出就是task结构吧 看了后苦恼好几天了，请版主帮忙解答，业务上想用，但是发现这几个问题，不太敢用啊，求解答
发布于8年前 · 0 次浏览 · 来自
提问
ζ
ζั͡ޓއއއ°辞久
请问下高手，其中发现一个问题是： if (SwooleTG.type == SW_THREAD_REACTOR) { return swReactorThread_send2worker((void *) &(task->data), send_len, target_worker_id); } else { return swServer_send2worker_blocking(serv, (void *) &(task->data), send_len, target_worker_id); } **swServer_send2worker_blocking**这个方法是阻塞发送，但是有个问题，看了他的实现，发现如果写入失败返回EAGAIN的话，只是等待，没有将这次的写入数据重发，这数据不是就丢掉了吗？ 第二个问题 代码里有一处直接 if (read(event->fd, &task, sizeof(task)) > 0) { /** * Big package */ ret = swWorker_excute(factory, &task); if (task.info.type == SW_EVENT_PACKAGE_START) { //no data if (ret < 0 && errno == EAGAIN) { return SW_OK; } else if (ret > 0) { goto read_from_pipe; } } return ret; } 不考虑read中发生EINTR以及EANGIN事件吗？无法保证一下子读出就是task结构吧 看了后苦恼好几天了，请版主帮忙解答，业务上想用，但是发现这几个问题，不太敢用啊，求解答
赞
0
分享
收藏
提问
分享
讨论
建议
公告
开发框架
CodeGalaxy
评论
2016-09-17
天
天君
1. 你用的swoole版本是比较老的代码，新代码中没有swServer_send2worker_blocking 2. swoole使用的unix socket dgram 每次读取的一定是一个完整的包。所以肯定是task结构
赞
0
回复
微信公众号
热门内容
作者其它话题
- swoole_http_server中的onFinish如何调用response对象？
暂无回复的问答
- CodeGalaxy K3s 轻量集群节点之间如何实现负载均衡
- 关于openssl CURL WARNING swSSL_connect: SSL_connect(fd=69) failed. Error: error:141A318A:SSL routines:tls_process_ske_dhe:dh key too small[1|394]
- 多个模型如何进行事务异常回退？
- websocket开启wss报错
- 协程tcp服务器如何使用多进程？recv()方法接收信息，打印出来的pid一直是同一个。没用使用到多进程啊。
