Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
youngwolf
ascs
提交
0a2561ef
A
ascs
项目概览
youngwolf
/
ascs
通知
5
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
A
ascs
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
前往新版Gitcode,体验更适合开发者的 AI 搜索 >>
提交
0a2561ef
编写于
9月 07, 2021
作者:
Y
youngwolf
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
Use unsigned instead of uint_fast64_t as the reference number of io_context.
上级
f41446ab
变更
3
隐藏空白更改
内联
并排
Showing
3 changed file
with
8 addition
and
5 deletion
+8
-5
examples/config.mk
examples/config.mk
+1
-1
include/ascs/service_pump.h
include/ascs/service_pump.h
+6
-3
include/ascs/udp/reliable_socket.h
include/ascs/udp/reliable_socket.h
+1
-1
未找到文件。
examples/config.mk
浏览文件 @
0a2561ef
...
...
@@ -3,7 +3,7 @@
asio_dir
=
-I
../../asio/asio/include/
# asio.hpp and asio directory should be available in this place.
# If possible,
-std=c++14 or -std=c++1y would be
better.
# If possible,
a higher edition of c++ would be always
better.
cflag
=
-Wall
-fexceptions
-std
=
c++11
ifeq
(${MAKECMDGOALS}, debug)
cflag
+=
-g
-DDEBUG
...
...
include/ascs/service_pump.h
浏览文件 @
0a2561ef
...
...
@@ -59,7 +59,7 @@ protected:
struct
context
{
asio
::
io_context
io_context
;
u
int_fast64_t
refs
;
u
nsigned
refs
;
#ifdef ASCS_AVOID_AUTO_STOP_SERVICE
#if ASIO_VERSION > 101100
asio
::
executor_work_guard
<
typename
asio
::
io_context
::
executor_type
>
work
;
...
...
@@ -124,9 +124,12 @@ public:
}
#endif
#endif
int
get_io_context_num
()
const
{
return
(
int
)
context_can
.
size
();}
virtual
~
service_pump
()
{
stop_service
();}
int
get_io_context_num
()
const
{
return
(
int
)
context_can
.
size
();}
void
get_io_context_refs
(
std
::
list
<
unsigned
>&
refs
)
{
if
(
!
single_io_context
)
ascs
::
do_something_to_all
(
context_can
,
context_can_mutex
,
[
&
](
context
&
item
)
{
refs
.
push_back
(
item
.
refs
);});}
operator
asio
::
io_context
&
()
{
return
assign_io_context
();}
#if ASIO_VERSION > 101100
asio
::
io_context
::
executor_type
get_executor
()
{
return
assign_io_context
().
get_executor
();}
...
...
@@ -137,7 +140,7 @@ public:
return
context_can
.
front
().
io_context
;
context
*
ctx
=
nullptr
;
u
int_fast64_t
refs
=
0
;
u
nsigned
refs
=
0
;
std
::
lock_guard
<
std
::
mutex
>
lock
(
context_can_mutex
);
ascs
::
do_something_to_one
(
context_can
,
[
&
](
context
&
item
)
{
...
...
include/ascs/udp/reliable_socket.h
浏览文件 @
0a2561ef
...
...
@@ -146,7 +146,7 @@ protected:
if
(
re
<
0
)
unified_out
::
error_out
(
"ikcp_input return error: %d"
,
re
);
else
this
->
need_kcp_check
=
true
;
need_kcp_check
=
true
;
});
msg_can
.
clear
();
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录