Skip to content

Commit

Permalink
CR2
Browse files Browse the repository at this point in the history
  • Loading branch information
GehaFearless committed Sep 22, 2022
1 parent eba217c commit dea62cf
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 12 deletions.
20 changes: 10 additions & 10 deletions src/rdsn/src/runtime/nativerun.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -64,18 +64,18 @@ void nativerun::install(service_spec &spec)
}
if (FLAGS_enable_udp) {
{
network_client_config cs;
cs.factory_name = "dsn::tools::asio_udp_provider";
cs.message_buffer_block_size = 1024 * 64;
spec.network_default_client_cfs[RPC_CHANNEL_UDP] = cs;
network_client_config client_conf;
client_conf.factory_name = "dsn::tools::asio_udp_provider";
client_conf.message_buffer_block_size = 1024 * 64;
spec.network_default_client_cfs[RPC_CHANNEL_UDP] = client_conf;
}
{
network_server_config cs2;
cs2.port = 0;
cs2.channel = RPC_CHANNEL_UDP;
cs2.factory_name = "dsn::tools::asio_udp_provider";
cs2.message_buffer_block_size = 1024 * 64;
spec.network_default_server_cfs[cs2] = cs2;
network_server_config server_conf;
server_conf.port = 0;
server_conf.channel = RPC_CHANNEL_UDP;
server_conf.factory_name = "dsn::tools::asio_udp_provider";
server_conf.message_buffer_block_size = 1024 * 64;
spec.network_default_server_cfs[server_conf] = server_conf;
}
}

Expand Down
4 changes: 2 additions & 2 deletions src/rdsn/src/runtime/task/task_spec.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -238,8 +238,8 @@ bool task_spec::init()
}

if (spec->rpc_call_channel == RPC_CHANNEL_UDP && !dsn::tools::FLAGS_enable_udp) {
derror("task rpc_call_channel RPC_CHANNEL_UCP need udp service, set network "
"configuration enable_udp true");
derror("task rpc_call_channel RPC_CHANNEL_UCP need udp service, make sure "
"[network].enable_udp");
return false;
}
}
Expand Down

0 comments on commit dea62cf

Please sign in to comment.