pdxx
/
libserverframe
mirror of https://github.com/happyfish100/libserverframe.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ioevent_init: set max entries for io_uring gracefully

use_iouring
YuQing 2025-10-12 10:24:35 +08:00
parent b688973cf9
commit 926cd40114
2 changed files with 30 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/sf_global.c
View File

@ -907,6 +907,7 @@ static const char *get_address_family_caption(
}
}
#if IOEVENT_USE_URING
static void get_io_uring_configs(const SFContext *sf_context,
bool *use_io_uring, bool *use_send_zc)
{
@ -929,6 +930,7 @@ static void get_io_uring_configs(const SFContext *sf_context,
}
}
}
#endif
void sf_context_config_to_string(const SFContext *sf_context,
char *output, const int size)

35
src/sf_service.c
View File

@ -108,6 +108,7 @@ int sf_service_init_ex2(SFContext *sf_context, const char *name,
int result;
int bytes;
int extra_events;
int max_entries;
int i;
struct worker_thread_context *thread_contexts;
struct worker_thread_context *thread_ctx;
@ -200,15 +201,35 @@ int sf_service_init_ex2(SFContext *sf_context, const char *name,
thread_data->arg = NULL;
}
if (ioevent_init(&thread_data->ev_puller, sf_context->name,
2 + sf_context->net_buffer_cfg.max_connections,
net_timeout_ms, extra_events) != 0)
#if IOEVENT_USE_URING
if (sf_context->net_buffer_cfg.max_connections < 16 * 1024) {
max_entries = 2 * sf_context->net_buffer_cfg.max_connections;
} else {
max_entries = sf_context->net_buffer_cfg.max_connections;
}
#else
max_entries = 2 + sf_context->net_buffer_cfg.max_connections;
#endif
if ((result=ioevent_init(&thread_data->ev_puller, sf_context->name,
max_entries, net_timeout_ms, extra_events)) != 0)
{
result = errno != 0 ? errno : ENOMEM;
char prompt[256];
#if IOEVENT_USE_URING
if (result == EPERM) {
strcpy(prompt, " make sure kernel.io_uring_disabled set to 0");
} else if (result == EINVAL) {
sprintf(prompt, " maybe max_connections: %d is too large",
sf_context->net_buffer_cfg.max_connections);
} else {
*prompt = '\0';
}
#else
*prompt = '\0';
#endif
logError("file: "__FILE__", line: %d, "
"ioevent_init fail, "
"errno: %d, error info: %s",
__LINE__, result, strerror(result));
"ioevent_init fail, errno: %d, error info: %s.%s"
, __LINE__, result, strerror(result), prompt);
return result;
}